gownshirt.ipynb

{
 "cells": [
  {
   "cell_type": "markdown",
   "id": "88a915f1",
   "metadata": {},
   "source": [
    "This notebook implements a test flow described in the following [use case](https://github.com/interfacerproject/Interfacer-notebook/blob/main/gownshirt_flow.1.1.txt) ."
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "2899cdd5",
   "metadata": {},
   "outputs": [],
   "source": [
    "# The following should reload if_lib if we change it on disk\n",
    "%load_ext autoreload\n",
    "%aimport if_lib, if_utils, if_dpp, if_graphics, if_consts\n",
    "%autoreload 1\n",
    "import os\n",
    "import json\n",
    "import random\n",
    "\n",
    "from if_utils import get_filename, show_data, save_traces\n",
    "\n",
    "from if_lib import generate_random_challenge, read_HMAC, read_keypair, get_id_person, get_location_id, \\\n",
    "get_unit_id, get_resource_spec_id, get_resource, get_process, create_event, make_transfer, reduce_resource, set_user_location\n",
    "\n",
    "from if_dpp import trace_query, check_traces, er_before, get_dpp\n",
    "\n",
    "from if_graphics import vis_dpp, make_sankey, consol_trace"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "69530699",
   "metadata": {
    "tags": [
     "parameters"
    ]
   },
   "outputs": [],
   "source": [
    "# We define the constant for our case\n",
    "USE_CASE = 'gownshirt'\n",
    "\n",
    "# What endpoint are we talking to?\n",
    "# debug\n",
    "# ENDPOINT = 'http://65.109.11.42:10000/api'\n",
    "ENDPOINT = 'http://zenflows-debug.interfacer.dyne.org/api'\n",
    "# staging\n",
    "# ENDPOINT = 'http://65.109.11.42:8000/api'\n",
    "# ENDPOINT = 'https://zenflows-staging.interfacer.dyne.org/api'\n",
    "# testing\n",
    "# ENDPOINT = 'http://65.109.11.42:9000/api'\n",
    "# ENDPOINT = 'https://zenflows-test.interfacer.dyne.org/api'\n",
    "USERS = ['alice', 'carol', 'bob']"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "51191c99",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Calculate names of settings files\n",
    "USERS_FILE = get_filename('cred_users.json', ENDPOINT, USE_CASE)\n",
    "LOCS_FILE = get_filename('loc_users.json', ENDPOINT, USE_CASE)\n",
    "UNITS_FILE = get_filename('units_data.json', ENDPOINT, USE_CASE)\n",
    "SPECS_FILE = get_filename('res_spec_data.json', ENDPOINT, USE_CASE)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "b8bc7c31",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Read or define user data that is going to be used in the GraphQL calls\n",
    "\n",
    "# create data structure to hold processes\n",
    "process_data = {}\n",
    "\n",
    "# create data structures to hold resources and events (possibly to compare results from track and trace)\n",
    "res_data = {}\n",
    "event_seq = []\n",
    "\n",
    "if os.path.isfile(USERS_FILE):\n",
    "    with open(USERS_FILE,'r') as f:\n",
    "        users_data = json.loads(f.read())\n",
    "    print(\"Credentials file available for users\")\n",
    "else:\n",
    "    users_data = {}\n",
    "    users_data['alice'] = {\n",
    "      \"userChallenges\": {\n",
    "        \"whereParentsMet\": \"London\",\n",
    "        \"nameFirstPet\": \"Fuffy\",\n",
    "        \"nameFirstTeacher\": \"Jim\",\n",
    "        \"whereHomeTown\": \"Paris\",\n",
    "        \"nameMotherMaid\": \"Wright\"\n",
    "      },\n",
    "      \"name\": \"Alice\",\n",
    "      \"username\": \"alice_username\",\n",
    "      \"email\": \"alice@example.org\",\n",
    "      \"note\": \"me.alice.org\"\n",
    "    }\n",
    "    users_data['carol'] = {\n",
    "        \"userChallenges\": {\n",
    "            \"whereParentsMet\":\"Amsterdam\",\n",
    "            \"nameFirstPet\":\"Toby\",\n",
    "            \"nameFirstTeacher\":\"Juliet\",\n",
    "            \"whereHomeTown\":\"Rome\",\n",
    "            \"nameMotherMaid\":\"Banks\"\n",
    "        },\n",
    "        \"name\": \"Carol\",\n",
    "        \"username\": \"carol_username\",\n",
    "        \"email\": \"carol@example.org\",\n",
    "        \"note\" : \"me.carol.org\"\n",
    "    }\n",
    "\n",
    "    users_data['bob'] = {\n",
    "        \"userChallenges\": {\n",
    "            \"whereParentsMet\":\"Rome\",\n",
    "            \"nameFirstPet\":\"Ku\",\n",
    "            \"nameFirstTeacher\":\"George\",\n",
    "            \"whereHomeTown\":\"Florence\",\n",
    "            \"nameMotherMaid\":\"Canti\"\n",
    "        },\n",
    "        \"name\": \"Bob\",\n",
    "        \"username\": \"bob_username\",\n",
    "        \"email\": \"bob@example.org\",\n",
    "        \"note\" : \"me.bob.org\"\n",
    "    }\n",
    "\n",
    "    with open(USERS_FILE,'w') as f:\n",
    "        json.dump(users_data, f)\n",
    "\n",
    "if os.path.isfile(LOCS_FILE):\n",
    "    with open(LOCS_FILE,'r') as f:\n",
    "        locs_data = json.loads(f.read())\n",
    "    print(\"Location file available\")\n",
    "else:\n",
    "    locs_data = {}\n",
    "    locs_data['alice'] = {\n",
    "        \"name\": \"Dyne\",\n",
    "        \"lat\": 52.39679,\n",
    "        \"long\": 4.8781073,\n",
    "        \"addr\": \"Haparandadam 7, A1, 1013 AK Amsterdam\",\n",
    "        \"note\": \"location.alice.org\"\n",
    "    }\n",
    "    locs_data['carol'] = {\n",
    "        \"name\": \"CleanLease\",\n",
    "        \"lat\" : 51.47240440868687,\n",
    "        \"long\" : 5.412460440524406,\n",
    "        \"addr\" : \"De schakel 30, 5651 Eindhoven\",\n",
    "        \"note\": \"location.carol.org\"\n",
    "    }\n",
    "    locs_data['bob'] = {\n",
    "        \"name\": \"Fab Lab Hamburg\",\n",
    "        \"lat\" : 51.1531305,\n",
    "        \"long\" : 5.2685045,\n",
    "        \"addr\" : \"Stockmeyerstr. 43 Halle 4K Eingang von der Wasserseite, 20457 Hamburg, Germany\",\n",
    "        \"note\": \"location.bob.org\"\n",
    "    }\n",
    "\n",
    "    with open(LOCS_FILE,'w') as f:\n",
    "        json.dump(locs_data, f)\n",
    "\n",
    "if os.path.isfile(UNITS_FILE):\n",
    "    with open(UNITS_FILE,'r') as f:\n",
    "        units_data = json.loads(f.read())\n",
    "    print(f\"Unit file available\")\n",
    "else:\n",
    "    units_data = {}\n",
    "#     with open(file,'w') as f:\n",
    "#         json.dump(units_data, f)\n",
    "\n",
    "\n",
    "if os.path.isfile(SPECS_FILE):\n",
    "    with open(SPECS_FILE,'r') as f:\n",
    "        res_spec_data = json.loads(f.read())\n",
    "    print(f\"Resource Spec file available\")\n",
    "else:\n",
    "    res_spec_data = {}\n",
    "\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "5bf379da",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Read HMAC or get it from the server\n",
    "for user in USERS:\n",
    "    read_HMAC(USERS_FILE, users_data, user, endpoint=ENDPOINT)\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "968e547b",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Read the keypair\n",
    "for user in USERS:\n",
    "    read_keypair(USERS_FILE, users_data, user)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "5f04298a",
   "metadata": {},
   "outputs": [],
   "source": [
    "# read or get id of the person\n",
    "for user in USERS:\n",
    "    get_id_person(USERS_FILE, users_data, user, endpoint=ENDPOINT)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "b4898764",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Read of get the location id\n",
    "for user in USERS:\n",
    "    get_location_id(LOCS_FILE, users_data[user], locs_data, user, endpoint=ENDPOINT)\n",
    "    set_user_location(USERS_FILE, users_data, locs_data, user, endpoint=ENDPOINT)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "9df2fe4f",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Get the ids of all units\n",
    "get_unit_id(UNITS_FILE, users_data['alice'], units_data, 'piece', 'u_piece', 'om2:one', endpoint=ENDPOINT)\n",
    "get_unit_id(UNITS_FILE, users_data['alice'], units_data, 'mass', 'kg', 'om2:kilogram', endpoint=ENDPOINT)\n",
    "get_unit_id(UNITS_FILE, users_data['alice'], units_data, 'volume', 'lt', 'om2:litre', endpoint=ENDPOINT)\n",
    "get_unit_id(UNITS_FILE, users_data['alice'], units_data, 'time', 'h', 'om2:hour', endpoint=ENDPOINT)\n",
    "get_unit_id(UNITS_FILE, users_data['alice'], units_data, 'distance', 'km', 'om2:kilometer', endpoint=ENDPOINT)\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "ed2b15ba",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Create the processes\n",
    "\n",
    "# Create the process that wraps cleaning the gown\n",
    "process_name = 'Clean_gown_1'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Clean gown first time process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "process_name = 'Clean_gown_2'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Clean gown second time process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps cleaning the gown and shirt\n",
    "process_name = 'Clean_textile'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Clean gown and shirt process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps sewing of the gown (its creation)\n",
    "process_name = 'Create_gown'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Create gown process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps using the gown in the hospital and making it dirty\n",
    "process_name = 'Do_surgery'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Use gown in surgery process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps creating the shirt design\n",
    "process_name = 'Create_shirt_design'\n",
    "user_data = users_data['carol']\n",
    "note = f\"Create shirt design process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps creating the shirt design\n",
    "process_name = 'Create_shirt'\n",
    "user_data = users_data['carol']\n",
    "note = f\"Create shirt process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)\n",
    "\n",
    "# Create the process that wraps making the cotton insulation\n",
    "process_name = 'Make_cotton_insulation'\n",
    "user_data = users_data['alice']\n",
    "note = f\"Create make cotton insulation process performed by {user_data['name']}\"\n",
    "get_process(process_name, process_data, note, user_data, endpoint=ENDPOINT)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "cd1fd6e8",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Read all the resource specifications\n",
    "name = 'gown'\n",
    "note = 'Specification for gowns'\n",
    "classification = 'https://www.wikidata.org/wiki/Q89990310'\n",
    "default_unit_id = units_data['piece']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'soap'\n",
    "note = 'Specification for soap to be used to wash the gowns'\n",
    "classification = 'https://www.wikidata.org/wiki/Q34396'\n",
    "default_unit_id = units_data['mass']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'cotton'\n",
    "note = 'Specification for cotton'\n",
    "classification = 'https://www.wikidata.org/wiki/Q11457'\n",
    "default_unit_id = units_data['mass']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'water'\n",
    "note = 'Specification for water'\n",
    "classification = 'https://www.wikidata.org/wiki/Q283'\n",
    "default_unit_id = units_data['volume']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'surgery_work'\n",
    "note = 'Specification for surgical work'\n",
    "classification = 'https://www.wikidata.org/wiki/Q600236'\n",
    "default_unit_id = units_data['time']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'transport_service'\n",
    "note = 'Specification for transport service'\n",
    "classification = 'https://www.wikidata.org/wiki/Q600236'\n",
    "default_unit_id = units_data['distance']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'sewing_machine'\n",
    "note = 'Specification for sewing machine'\n",
    "classification = 'https://www.wikidata.org/wiki/Q106153893'\n",
    "default_unit_id = units_data['piece']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'sewing_machine_usage'\n",
    "note = 'Specification for sewing machine usage'\n",
    "classification = 'https://www.wikidata.org/wiki/Q106153893'\n",
    "default_unit_id = units_data['time']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'shirt'\n",
    "note = 'Specification for shirts'\n",
    "classification = 'https://www.wikidata.org/wiki/Q76768'\n",
    "default_unit_id = units_data['piece']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'shirt_design'\n",
    "note = 'Specification for shirt designs'\n",
    "classification = 'https://www.me.org/designs/shirt_12'\n",
    "default_unit_id = units_data['piece']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'cotton_scraps'\n",
    "note = 'Specification for cotton scraps'\n",
    "classification = 'https://www.wikidata.org/wiki/Q72134860'\n",
    "default_unit_id = units_data['mass']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'cotton_waste'\n",
    "note = 'Specification for cotton waste'\n",
    "classification = 'https://www.wikidata.org/wiki/Q39915841'\n",
    "default_unit_id = units_data['mass']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n",
    "\n",
    "name = 'cotton_insulation'\n",
    "note = 'Specification for cotton insulation'\n",
    "classification = 'https://www.wikidata.org/wiki/Q918306'\n",
    "default_unit_id = units_data['mass']['id']\n",
    "get_resource_spec_id(SPECS_FILE, users_data['alice'], res_spec_data, name, note, classification, default_unit_id, endpoint=ENDPOINT)\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "36377061",
   "metadata": {
    "scrolled": false
   },
   "outputs": [],
   "source": [
    "# We create the resources that will not be saved to file as it is assumed they are recreated at each run\n",
    "\n",
    "# gown will be produced\n",
    "\n",
    "res_name = 'cotton'\n",
    "amount = 100\n",
    "get_resource(res_data, res_spec_data, res_name, users_data['alice'], event_seq, amount, endpoint=ENDPOINT)\n",
    "\n",
    "res_name = 'water'\n",
    "amount = 60\n",
    "get_resource(res_data, res_spec_data, res_name, users_data['alice'], event_seq, amount, endpoint=ENDPOINT)\n",
    "\n",
    "res_name = 'soap'\n",
    "amount = 30\n",
    "get_resource(res_data, res_spec_data, res_name, users_data['alice'], event_seq, amount, endpoint=ENDPOINT)\n",
    "\n",
    "res_name = 'sewing_machine'\n",
    "amount = 1\n",
    "get_resource(res_data, res_spec_data, res_name, users_data['carol'], event_seq, amount, endpoint=ENDPOINT)\n",
    "\n",
    "# res_name = 'surgery_work'\n",
    "# amount = 100\n",
    "# get_resource(res_data, res_spec_data, res_name, users_data['alice'], event_seq, amount)\n",
    "\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "344627f2",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event consume for the gown creation\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume cotton for gown'\n",
    "amount = 25\n",
    "cur_pros = process_data['Create_gown']\n",
    "cur_res = res_data['cotton_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "468ba053",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Define event produce for the gown creation\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce gown'\n",
    "amount = 1\n",
    "cur_pros = process_data['Create_gown']\n",
    "\n",
    "res_data['gown_res'] = {\n",
    "    \"res_ref_id\": f'gown-{random.randint(0, 10000)}',\n",
    "    \"name\": 'gown',\n",
    "    \"spec_id\": res_spec_data['gown']['id']\n",
    "}\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "713c6903",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event produce for cotton scraps byproduct\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce cotton scraps'\n",
    "amount = 7\n",
    "cur_pros = process_data['Create_gown']\n",
    "\n",
    "res_data['cotton_scraps_res'] = {\n",
    "    \"res_ref_id\": f'cotton_scraps-{random.randint(0, 10000)}',\n",
    "    \"name\": 'cotton_scraps',\n",
    "    \"spec_id\": res_spec_data['cotton_scraps']['id']\n",
    "}\n",
    "cur_res = res_data['cotton_scraps_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "06ecd9bc",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# accept the gown for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'accept'\n",
    "event_note='accept gowns to be cleaned'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_gown_1']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "a78cea31",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume water for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume water for the washing'\n",
    "amount = 20\n",
    "cur_pros = process_data['Clean_gown_1']\n",
    "cur_res = res_data['water_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "72010b22",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume soap for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume soap for the washing'\n",
    "amount = 10\n",
    "cur_pros = process_data['Clean_gown_1']\n",
    "cur_res = res_data['soap_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "23f32f18",
   "metadata": {
    "scrolled": false
   },
   "outputs": [],
   "source": [
    "# modify the gown that is now clean\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'modify'\n",
    "event_note='modify clean after washing'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_gown_1']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "911631dd",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Transfer the gown from the owner/leaser to the hospital\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "note='Transfer gowns from Alice to Bob'\n",
    "action = 'transfer-custody'\n",
    "amount = 1\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "event_id, ts = make_transfer(users_data['alice'], action, note, users_data['bob'], amount, cur_res, locs_data, res_spec_data, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "0199a43b",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Use the gown to perform surgery and as a consequence make it dirty\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'accept'\n",
    "event_note='accept use for surgery'\n",
    "amount = 1\n",
    "cur_pros = process_data['Do_surgery']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "event_id, ts = create_event(users_data['bob'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "   \n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "8b2cc309",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Work with the gown to perform surgery\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'work'\n",
    "event_note='work perform surgery'\n",
    "\n",
    "cur_pros = process_data['Do_surgery']\n",
    "effort_spec = {}\n",
    "effort_spec['unit_id'] = res_spec_data['surgery_work']['defaultUnit']\n",
    "effort_spec['spec_id'] = res_spec_data['surgery_work']['id']\n",
    "effort_spec['amount'] = 5\n",
    "\n",
    "event_id, ts = create_event(users_data['bob'], action, event_note, amount=0, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, effort_spec=effort_spec, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'amount': effort_spec['amount']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "ca3471c3",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Modify the gown and make it dirty as a consequence of being used\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'modify'\n",
    "event_note='modify dirty after surgery'\n",
    "amount = 1\n",
    "cur_pros = process_data['Do_surgery']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['bob'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "02270f31",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Transfer the gown from Bob to Alice\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "note='Transfer gowns to Alice'\n",
    "action = 'transfer-custody'\n",
    "amount = 1\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "event_id, ts = make_transfer(users_data['bob'], action, note, users_data['alice'], amount, cur_res, locs_data, res_spec_data, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "9814e069",
   "metadata": {},
   "outputs": [],
   "source": [
    "# accept the gown for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'accept'\n",
    "event_note='accept gowns to be cleaned'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_gown_2']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "37fdc228",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume water for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume water for the washing'\n",
    "amount = 20\n",
    "cur_pros = process_data['Clean_gown_2']\n",
    "cur_res = res_data['water_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "171e0205",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume soap for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume soap for the washing'\n",
    "amount = 10\n",
    "cur_pros = process_data['Clean_gown_2']\n",
    "cur_res = res_data['soap_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "984545ee",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# modify the gown that is now clean\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'modify'\n",
    "event_note='modify clean after washing'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_gown_2']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "fd87e1f9",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Transfer 10 kg of cotton from from Alice to Carol\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "note='Transfer cotton to Carol'\n",
    "action = 'transfer'\n",
    "amount = 10\n",
    "cur_res = res_data['cotton_res']\n",
    "\n",
    "event_id, ts = make_transfer(users_data['alice'], action, note, users_data['carol'], amount, cur_res, locs_data, res_spec_data, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "9e7d293a",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Work with the gown to perform surgery\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'work'\n",
    "event_note='work at shirt design'\n",
    "\n",
    "cur_pros = process_data['Create_shirt_design']\n",
    "effort_spec = {}\n",
    "effort_spec['unit_id'] = res_spec_data['shirt_design']['defaultUnit']\n",
    "effort_spec['spec_id'] = res_spec_data['shirt_design']['id']\n",
    "effort_spec['amount'] = 5\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount=0, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, effort_spec=effort_spec, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'amount': effort_spec['amount']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "253d5ccc",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event produce for cotton scraps byproduct\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce shirt design'\n",
    "amount = 1\n",
    "cur_pros = process_data['Create_shirt_design']\n",
    "\n",
    "res_data['shirt_design_res'] = {\n",
    "    \"res_ref_id\": f'shirt_design-{random.randint(0, 10000)}',\n",
    "    \"name\": 'shirt_design',\n",
    "    \"spec_id\": res_spec_data['shirt_design']['id']\n",
    "}\n",
    "cur_res = res_data['shirt_design_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "03d4e271",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume cotton for shirt\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume cotton for shirt'\n",
    "amount = 5\n",
    "cur_pros = process_data['Create_shirt']\n",
    "cur_res = res_data['cotton_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "f1688e0a",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume cotton for shirt\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'cite'\n",
    "event_note='cite shirt design'\n",
    "amount = 1\n",
    "\n",
    "cur_pros = process_data['Create_shirt']\n",
    "cur_res = res_data['shirt_design_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "0269852f",
   "metadata": {
    "scrolled": true
   },
   "outputs": [],
   "source": [
    "# Use sewing machine for shirt\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'use'\n",
    "event_note='use sewing machine for shirt'\n",
    "\n",
    "cur_pros = process_data['Create_shirt']\n",
    "cur_res = res_data['sewing_machine_res']\n",
    "amount = 1\n",
    "\n",
    "effort_spec = {}\n",
    "effort_spec['unit_id'] = res_spec_data['sewing_machine_usage']['defaultUnit']\n",
    "# effort_spec['spec_id'] = res_spec_data['sewing_machine_usage']['id']\n",
    "effort_spec['amount'] = 3\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, effort_spec=effort_spec, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "a3f9c58b",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event produce for cotton scraps byproduct\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce shirts'\n",
    "amount = 2\n",
    "cur_pros = process_data['Create_shirt']\n",
    "\n",
    "res_data['shirt_res'] = {\n",
    "    \"res_ref_id\": f'shirt-{random.randint(0, 10000)}',\n",
    "    \"name\": 'shirt',\n",
    "    \"spec_id\": res_spec_data['shirt']['id']\n",
    "}\n",
    "cur_res = res_data['shirt_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['carol'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "da1eba0c",
   "metadata": {},
   "outputs": [],
   "source": [
    "# lower cotton (2 kg, Carol)\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "amount = 2\n",
    "cur_res = res_data['cotton_res']\n",
    "\n",
    "event_id, ts = reduce_resource(users_data['carol'], res_data=cur_res, res_spec_data=res_spec_data, amount=amount, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "7f59a544",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Transfer the shirt from Carol to Alice\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "note='Transfer shirt from Carol to Alice'\n",
    "action = 'transfer'\n",
    "amount = 1\n",
    "cur_res = res_data['shirt_res']\n",
    "\n",
    "event_id, ts = make_transfer(users_data['carol'], action, note, users_data['alice'], amount, cur_res, locs_data, res_spec_data, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "280814e9",
   "metadata": {},
   "outputs": [],
   "source": [
    "# accept the gown for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'accept'\n",
    "event_note='accept gown to be cleaned'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "75590b7a",
   "metadata": {
    "scrolled": false
   },
   "outputs": [],
   "source": [
    "# accept shirt for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'accept'\n",
    "event_note='accept shirt to be cleaned'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['shirt_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "978e0edc",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume water for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume water for the washing'\n",
    "amount = 20\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['water_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "a963663e",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume soap for washing\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume soap for the washing'\n",
    "amount = 10\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['soap_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n",
    "event_seq.append({'ts': ts, 'process_id':cur_pros['id'], 'name' : cur_pros['name']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "a6b1fe30",
   "metadata": {},
   "outputs": [],
   "source": [
    "# modify the gown that is now clean\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'modify'\n",
    "event_note='modify gown after washing'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['gown_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "d60e3f27",
   "metadata": {},
   "outputs": [],
   "source": [
    "# modify the gown that is now clean\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'modify'\n",
    "event_note='modify shirt after washing'\n",
    "amount = 1\n",
    "cur_pros = process_data['Clean_textile']\n",
    "cur_res = res_data['shirt_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "567ddf15",
   "metadata": {},
   "outputs": [],
   "source": [
    "# consume cotton scraps for insulation\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'consume'\n",
    "event_note='consume cotton scraps for insulation'\n",
    "amount = 7\n",
    "cur_pros = process_data['Make_cotton_insulation']\n",
    "cur_res = res_data['cotton_scraps_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, existing_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "8709b25c",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event produce for cotton insulation\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce cotton insulation'\n",
    "amount = 6\n",
    "cur_pros = process_data['Make_cotton_insulation']\n",
    "\n",
    "res_data['cotton_insulation_res'] = {\n",
    "    \"res_ref_id\": f'cotton_insulation-{random.randint(0, 10000)}',\n",
    "    \"name\": 'cotton_insulation',\n",
    "    \"spec_id\": res_spec_data['cotton_insulation']['id']\n",
    "}\n",
    "cur_res = res_data['cotton_insulation_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "83e703bf",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Define event produce for cotton waste\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "action = 'produce'\n",
    "event_note='produce cotton waste'\n",
    "amount = 1\n",
    "cur_pros = process_data['Make_cotton_insulation']\n",
    "\n",
    "res_data['cotton_waste_res'] = {\n",
    "    \"res_ref_id\": f'cotton_waste-{random.randint(0, 10000)}',\n",
    "    \"name\": 'cotton_waste',\n",
    "    \"spec_id\": res_spec_data['cotton_waste']['id']\n",
    "}\n",
    "cur_res = res_data['cotton_waste_res']\n",
    "\n",
    "\n",
    "event_id, ts = create_event(users_data['alice'], action, event_note, amount=amount, process=cur_pros, \\\n",
    "                 res_spec_data=res_spec_data, new_res=cur_res, endpoint=ENDPOINT)\n",
    "\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "f83069fa",
   "metadata": {},
   "outputs": [],
   "source": [
    "# Transfer the shirt from Carol to Alice\n",
    "cur_res = action = event_note = amount = cur_pros = None\n",
    "note='Transfer cotton waste from Alice to Bob'\n",
    "action = 'transfer'\n",
    "amount = 1\n",
    "cur_res = res_data['cotton_waste_res']\n",
    "\n",
    "event_id, ts = make_transfer(users_data['alice'], action, note, users_data['bob'], amount, cur_res, locs_data, res_spec_data, endpoint=ENDPOINT)\n",
    "event_seq.append({'ts': ts, 'event_id':event_id, 'action' : action, 'res_name': cur_res['name'], 'res': cur_res['id']})\n"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "4b8b4001",
   "metadata": {},
   "outputs": [],
   "source": [
    "show_data(users_data, locs_data, res_data, units_data, res_spec_data, process_data, event_seq)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "b98ddac7",
   "metadata": {},
   "outputs": [],
   "source": [
    "trace_me = res_data['gown_res']['id']\n",
    "print(f\"Resource to be traced: {trace_me}\")\n",
    "tot_dpp = []\n",
    "visited = set()\n",
    "er_before(trace_me, users_data['alice'], dpp_children=tot_dpp, depth=0, visited=visited, endpoint=ENDPOINT)\n",
    "\n",
    "# Serializing json\n",
    "json_object = json.dumps(tot_dpp, indent=2)\n",
    "\n",
    "print(json_object)\n",
    "print(visited)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "5df94926",
   "metadata": {},
   "outputs": [],
   "source": [
    "be_dpp = get_dpp(trace_me, users_data['alice'], endpoint=ENDPOINT)\n",
    "print(json.dumps(be_dpp, indent=2))"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "597c9173",
   "metadata": {},
   "outputs": [],
   "source": [
    "trace = trace_query(trace_me, users_data['alice'], endpoint=ENDPOINT)\n",
    "check_traces(trace, event_seq, tot_dpp, be_dpp)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "dfc531a7",
   "metadata": {},
   "outputs": [],
   "source": [
    "save_traces(USE_CASE, tot_dpp, trace, be_dpp, event_seq)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "85893af9",
   "metadata": {
    "scrolled": false
   },
   "outputs": [],
   "source": [
    "labels = []\n",
    "sources = []\n",
    "targets = []\n",
    "values = []\n",
    "color_nodes = []\n",
    "color_links = []\n",
    "assigned = {}\n",
    "vis_dpp(tot_dpp[0], count=0, assigned=assigned, labels=labels, targets=targets, sources=sources, values=values, color_nodes=color_nodes, color_links=color_links)\n",
    "sources, targets = consol_trace(assigned, sources, targets)\n",
    "make_sankey(sources, targets, labels, values, color_nodes, color_links)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "id": "5134d2bd",
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "celltoolbar": "Tags",
  "kernelspec": {
   "display_name": "Python 3 (ipykernel)",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.11.0"
  },
  "vscode": {
   "interpreter": {
    "hash": "aee8b7b246df8f9039afb4144a1f6fd8d2ca17a180786b69acc140d282b71a49"
   }
  }
 },
 "nbformat": 4,
 "nbformat_minor": 5
}