Creating Agents in Coreflux

DEFINE ROUTE OperationsReporter 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 operations reports from live MQTT. Use broker tools on telemetry/ and related topics. Bullet points: current status, anomalies, items needing follow-up. Plain language for managers. Adapt wording to what the data represents (production, energy, facilities, fleet, etc.)."

DEFINE ACTION HourlyOperationsReport
ON EVERY 1 HOUR DO
    CALL AGENT "OperationsReporter.execute"
        WITH (task = "Hourly operations report: summarise key signals from telemetry/ topics, flag anything off-norm or stale, note follow-ups before the next review period.", use_history = "false")
        RETURN AS {report}

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

DEFINE ROUTE AlertAnalyst 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 triage operational alerts from MQTT. In 3 short sentences: what happened, likely cause, recommended first check. Be direct."

DEFINE ACTION TriageAlert
ON TOPIC "alerts/#" DO
    CALL AGENT "AlertAnalyst.execute"
        WITH (task = "Alert on topic " + TOPIC + ": " + PAYLOAD, use_history = "false")
        RETURN AS {triage}
    PUBLISH TOPIC "agents/site/alerts/analysis" WITH {triage}

DEFINE ROUTE HandoverBrief WITH TYPE AGENT
    ADD AGENT_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-5.5"
        WITH API_KEY GET SECRET "OPENAI_KEY"
        WITH BROKER_TOOLS "true"
        WITH INTERACTION_MODE "autonomous"
        WITH SYSTEM_PROMPT "You write handover notes for operations teams. Use broker tools. Bullet points: status, anomalies, open items. Max 8 bullets."

DEFINE ACTION ShiftHandover
ON EVERY 8 HOURS DO
    CALL AGENT "HandoverBrief.execute"
        WITH (task = "Prepare handover for the next shift: current operational status, active alarms, and anything unusual in the last 8 hours.", use_history = "false")
        RETURN AS {brief}
    PUBLISH TOPIC "agents/site/shift/handover" WITH {brief}