Start an execution and read its status as it advances

# Scenario 040: Start an execution and read its status as it advances
# Send the example ExecuteRequest to the reference hub with a person in the kitchen, then read the status a few seconds later and see the sequence number and the first step that needs a person.
# Run a hub first: python hub/cookwala_hub.py --recipes examples
import json, os
from cookwala.client import CookwalaClient, CookwalaProblem

def load(path):
    with open(path, encoding="utf-8") as f:
        return json.load(f)

def pick(obj, path):
    for part in path.replace("]", "").replace("[", ".").split("."):
        obj = obj[int(part)] if part.isdigit() else (len(obj) if part == "length" else obj.get(part))
    return obj

c = CookwalaClient(os.environ.get("COOKWALA_HUB", "http://localhost:7878"))


# Step 1: Read the capability document of the device behind the hub: one counter arm that cuts, cracks and transfers, with a vision sensor and no heat source.
hub = c.capabilities()
assert pick(hub, "actor.model") == "CounterArm 2", pick(hub, "actor.model")
print("ok", "actor.model", "=", "CounterArm 2")
assert pick(hub, "actor.kind") == "robot", pick(hub, "actor.kind")
print("ok", "actor.kind", "=", "robot")
assert pick(hub, "capabilities.ops.length") == 3, pick(hub, "capabilities.ops.length")
print("ok", "capabilities.ops.length", "=", 3)

# Step 2: Start the example request for shakshuka. The hub dry-runs the recipe first and answers with an ExecutionStatus at seq 0 that carries the plan.
try:
    started = c.start_execution(load("examples/core/execute-request.json"), "ex-2026-10-04-001-a", True)
except CookwalaProblem as p:
    started = p.body  # a refusal is a result, not a crash
    print("refused:", p.refusal)
assert pick(started, "state") == "accepted", pick(started, "state")
print("ok", "state", "=", "accepted")
assert pick(started, "seq") == 0, pick(started, "seq")
print("ok", "seq", "=", 0)
assert pick(started, "id") == "ex-2026-10-04-001", pick(started, "id")
print("ok", "id", "=", "ex-2026-10-04-001")
assert pick(started, "x-hub-plan.length") == 13, pick(started, "x-hub-plan.length")
print("ok", "x-hub-plan.length", "=", 13)

# Step 3: The hub used by the runner simulates time at 200x. The arm dices the onion, pepper and tomato, then reaches the first step a person must perform.
import time; time.sleep(4)

# Step 4: Read the status: seq has advanced (the ETag header carries the same number) and the device waits for a person to heat the pan.
status = c.get_execution("ex-2026-10-04-001")
assert pick(status, "state") == "needs_human", pick(status, "state")
print("ok", "state", "=", "needs_human")
assert pick(status, "seq") == 6, pick(status, "seq")
print("ok", "seq", "=", 6)
assert pick(status, "humanNeeded.why") == "a person performs cw.op.heat", pick(status, "humanNeeded.why")
print("ok", "humanNeeded.why", "=", "a person performs cw.op.heat")
assert pick(status, "step.progress") == 1.0, pick(status, "step.progress")
print("ok", "step.progress", "=", 1.0)

# Step 5: The status names the request it answers; the recipe reference and hash are in that request and in the execution log.
assert pick(status, "request") == "ex-2026-10-04-001", pick(status, "request")
print("ok", "request", "=", "ex-2026-10-04-001")
assert pick(status, "kind") == "ExecutionStatus", pick(status, "kind")
print("ok", "kind", "=", "ExecutionStatus")

print("scenario complete")