The same execution id with a new Idempotency-Key is a 409 conflict

# Scenario 050: The same execution id with a new Idempotency-Key is a 409 conflict
# The Idempotency-Key makes a retry safe; the execution id makes the run unique. Reusing the id with a different key is a conflict, while the original key still returns the original run.
# 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: Start a run with key ex-050-dup-k1.
try:
    first = c.start_execution({"core": "0.2.0", "kind": "ExecuteRequest", "id": "ex-050-dup", "recipe": "cw:cookwala.ai:example-shakshuka", "recipeHash": "sha256:2ea6fab93cc673fc6784f9bc9fe401d2387bb7779dc537df97286b73807c8841", "servings": 4, "requestedBy": "agent:planner-1", "idempotencyKey": "ex-050-dup-a"}, "ex-050-dup-k1", True)
except CookwalaProblem as p:
    first = p.body  # a refusal is a result, not a crash
    print("refused:", p.refusal)
assert pick(first, "state") == "accepted", pick(first, "state")
print("ok", "state", "=", "accepted")
assert pick(first, "id") == "ex-050-dup", pick(first, "id")
print("ok", "id", "=", "ex-050-dup")

# Step 2: Send the same request with a different key. The id already exists, so the answer is a Problem with title conflict.
try:
    conflict = c.start_execution({"core": "0.2.0", "kind": "ExecuteRequest", "id": "ex-050-dup", "recipe": "cw:cookwala.ai:example-shakshuka", "recipeHash": "sha256:2ea6fab93cc673fc6784f9bc9fe401d2387bb7779dc537df97286b73807c8841", "servings": 4, "requestedBy": "agent:planner-1", "idempotencyKey": "ex-050-dup-a"}, "ex-050-dup-k2", True)
except CookwalaProblem as p:
    conflict = p.body  # a refusal is a result, not a crash
    print("refused:", p.refusal)
assert pick(conflict, "title") == "conflict", pick(conflict, "title")
print("ok", "title", "=", "conflict")
assert pick(conflict, "detail") == "execution id already exists", pick(conflict, "detail")
print("ok", "detail", "=", "execution id already exists")

# Step 3: The first run advances to the step that needs a person.
import time; time.sleep(4)

# Step 4: Send it again with the original key: the hub returns the first run, at its current state.
try:
    retry = c.start_execution({"core": "0.2.0", "kind": "ExecuteRequest", "id": "ex-050-dup", "recipe": "cw:cookwala.ai:example-shakshuka", "recipeHash": "sha256:2ea6fab93cc673fc6784f9bc9fe401d2387bb7779dc537df97286b73807c8841", "servings": 4, "requestedBy": "agent:planner-1", "idempotencyKey": "ex-050-dup-a"}, "ex-050-dup-k1", True)
except CookwalaProblem as p:
    retry = p.body  # a refusal is a result, not a crash
    print("refused:", p.refusal)
assert pick(retry, "id") == "ex-050-dup", pick(retry, "id")
print("ok", "id", "=", "ex-050-dup")
assert pick(retry, "state") == "needs_human", pick(retry, "state")
print("ok", "state", "=", "needs_human")
assert pick(retry, "seq") == 6, pick(retry, "seq")
print("ok", "seq", "=", 6)

print("scenario complete")