AI Routes

DEFINE ROUTE ProductionReporter WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-5.4-mini"
        WITH API_KEY GET SECRET "OPENAI_KEY"
        WITH BROKER_TOOLS "true"
        WITH INTERACTION_MODE "autonomous"
        WITH SYSTEM_PROMPT "You write production shift reports. Use broker tools on production-related topics. Bullet points: throughput, downtime signals, quality risks."

DEFINE ACTION HourlyProductionReport
ON EVERY 1 HOUR DO
    CALL AGENT "ProductionReporter.execute"
        WITH (task = "Hourly production report: summarise output and efficiency from production/ topics, flag lines or batches that look off-target, note anything that needs follow-up before the next shift.", use_history = "false")
        RETURN AS {report}

    PUBLISH TOPIC "reports/production/hourly" WITH {report}

DEFINE ROUTE Assistant WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-5.4-mini"
        WITH API_KEY GET SECRET "OPENAI_KEY"

DEFINE ROUTE Assistant WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "anthropic"
        WITH MODEL "claude-sonnet-4-6"
        WITH API_KEY GET SECRET "ANTHROPIC_KEY"

DEFINE ROUTE Assistant WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "mistral"
        WITH MODEL "mistral-large-latest"
        WITH API_KEY GET SECRET "MISTRAL_KEY"

DEFINE ROUTE Classifier WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "ollama"
        WITH MODEL "qwen3:8b"
        WITH INTERACTION_MODE "autonomous"
        WITH TEMPERATURE "0.0"
        WITH SYSTEM_PROMPT "Classify sensor readings as NORMAL, WARNING, or CRITICAL. Reply with only the label."

DEFINE ACTION ClassifySensor
ON TOPIC "sensors/+/reading" DO
    SET "device" WITH TOPIC POSITION 2
    SET "reading" WITH (PAYLOAD AS STRING)
    CALL AGENT "Classifier.execute"
        WITH (task = "Reading from " + {device} + ": " + {reading})
        RETURN AS {label}
    PUBLISH TOPIC "sensors/" + {device} + "/class" WITH {label}

DEFINE ROUTE Watchdog WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "ollama"
        WITH MODEL "qwen3:4b"
        WITH INTERACTION_MODE "autonomous"
        WITH BROKER_TOOLS "true"
        WITH SYSTEM_PROMPT "You are a health monitor. Check all routes for errors and publish a concise alert summary if any are unhealthy."

DEFINE ACTION HourlyHealthCheck
ON EVERY 1 HOUR DO
    CALL AGENT "Watchdog.execute"
        WITH (task = "Check all routes for errors and summarise the broker health.")
        RETURN AS {report}
    PUBLISH TOPIC "plant/health/hourly" WITH {report}

DEFINE ROUTE Reader WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-5.4-mini"
        WITH API_KEY GET SECRET "OPENAI_KEY"
        WITH BROKER_TOOLS "true"
        WITH AGENT_MODE "insight"
        WITH INTERACTION_MODE "interactive"
        WITH INTERACTION_TOPIC "plant/reader"
        WITH SYSTEM_PROMPT "You are a read-only plant observer. Answer questions about current state. You cannot change anything."