The smart oven and its core probe: the kofta recipe, the ladder, the limit

# Scenario 032: The smart oven and its core probe: the kofta recipe, the ladder, the limit
# The kofta recipe ends its bake when the core probe reads 71 degC. The oven preset has an oven thermometer and a core probe. See which rung the dry run records, what a probe alone would verify, and the limit the number comes from.
# 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: The bake step's end condition is the core probe at 71 degC or more, marked as a critical control point.
kofta = c.get_recipe("kofta-oven")
assert pick(kofta, "process.nodes[7].until.all[0].sensor") == "cw.sense.core_temp", pick(kofta, "process.nodes[7].until.all[0].sensor")
print("ok", "process.nodes[7].until.all[0].sensor", "=", "cw.sense.core_temp")
assert pick(kofta, "process.nodes[7].until.all[0].gte") == 71, pick(kofta, "process.nodes[7].until.all[0].gte")
print("ok", "process.nodes[7].until.all[0].gte", "=", 71)
assert pick(kofta, "process.nodes[7].ccp") == "ccp_ground_meat", pick(kofta, "process.nodes[7].ccp")
print("ok", "process.nodes[7].ccp", "=", "ccp_ground_meat")

# Step 2: The oven preset lists both sensors.
devices = c.get_devices()
assert pick(devices, "devices.demo-oven.capabilities.sensors[0].sensor") == "cw.sense.oven_temp", pick(devices, "devices.demo-oven.capabilities.sensors[0].sensor")
print("ok", "devices.demo-oven.capabilities.sensors[0].sensor", "=", "cw.sense.oven_temp")
assert pick(devices, "devices.demo-oven.capabilities.sensors[1].sensor") == "cw.sense.core_temp", pick(devices, "devices.demo-oven.capabilities.sensors[1].sensor")
print("ok", "devices.demo-oven.capabilities.sensors[1].sensor", "=", "cw.sense.core_temp")

# Step 3: The dry run records the first rung of the bake ladder, the oven thermometer; the end condition and the limit are the probe's job during the run. The preheat is a logged estimate because cw.op.heat's ladder names a pan thermometer, not an oven one.
plan = c.dry_run(recipe_id="kofta-oven", device_id="demo-oven", human_present=True)
assert pick(plan, "state") == "accepted", pick(plan, "state")
print("ok", "state", "=", "accepted")
assert pick(plan, "plan[7].op") == "cw.op.bake", pick(plan, "plan[7].op")
print("ok", "plan[7].op", "=", "cw.op.bake")
assert pick(plan, "plan[7].rung") == "cw.sense.oven_temp", pick(plan, "plan[7].rung")
print("ok", "plan[7].rung", "=", "cw.sense.oven_temp")
assert pick(plan, "plan[6].op") == "cw.op.heat", pick(plan, "plan[6].op")
print("ok", "plan[6].op", "=", "cw.op.heat")
assert pick(plan, "plan[6].rung") == "model", pick(plan, "plan[6].rung")
print("ok", "plan[6].rung", "=", "model")

# Step 4: An oven with only a core probe would still verify baking: the probe is the second rung.
probeOnly = c.ladder("cw.op.bake", ["cw.sense.core_temp"], True, False)

# Step 5: The 71 degC in the recipe is the default limit for ground meat; the device asks a person when it is not reached.
limits = c.safety_limits()
assert pick(limits, "limits[4].id") == "core.ground_meat", pick(limits, "limits[4].id")
print("ok", "limits[4].id", "=", "core.ground_meat")
assert pick(limits, "limits[4].min") == 71, pick(limits, "limits[4].min")
print("ok", "limits[4].min", "=", 71)
assert pick(limits, "limits[4].action") == "ask_human", pick(limits, "limits[4].action")
print("ok", "limits[4].action", "=", "ask_human")

# Step 6: The probe-only rung.
assert probeOnly == "cw.sense.core_temp", probeOnly
print("ok", "probeOnly", "=", "cw.sense.core_temp")

print("scenario complete")