Creating Agents in Coreflux

DEFINE CONNECTOR SiteModel WITH TYPE LLM
    ADD LLM_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-6-luna"
        WITH API_KEY GET SECRET "OPENAI_API_KEY"
        WITH API_SURFACE "auto"

DEFINE AGENT OperationsReporter
    USES LLM CONNECTOR SiteModel
    WITH DESCRIPTION "Writes the hourly operations summary"
    WITH DEFAULT_USER "operator"
    WITH SYSTEM_PROMPT "You write operations reports from live MQTT. Use your tools on telemetry/ topics. Bullet points: current status, anomalies, items needing follow-up. Plain language for managers."
    WITH MEMORY "none"
    ADD TOOL "read_mqtt"
        WITH TOPICS "telemetry/#"

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.")
        RETURN AS {report}
    PUBLISH TOPIC "reports/operations/hourly" WITH {report}

DEFINE CONNECTOR SiteModel WITH TYPE LLM
    ADD LLM_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-6-luna"
        WITH API_KEY GET SECRET "OPENAI_API_KEY"
        WITH API_SURFACE "auto"

DEFINE AGENT AlertAnalyst
    USES LLM CONNECTOR SiteModel
    WITH DESCRIPTION "Explains one alert in three sentences"
    WITH DEFAULT_USER "operator"
    WITH SYSTEM_PROMPT "You triage operational alerts from MQTT. In 3 short sentences: what happened, likely cause, recommended first check. Be direct."
    WITH MEMORY "none"
    ADD TOOL "read_mqtt"
        WITH TOPICS "alerts/#"

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

DEFINE CONNECTOR SiteModel WITH TYPE LLM
    ADD LLM_CONFIG
        WITH PROVIDER "openai"
        WITH MODEL "gpt-6-luna"
        WITH API_KEY GET SECRET "OPENAI_API_KEY"
        WITH API_SURFACE "auto"

DEFINE AGENT HandoverBrief
    USES LLM CONNECTOR SiteModel
    WITH DESCRIPTION "Writes the shift handover"
    WITH DEFAULT_USER "operator"
    WITH SYSTEM_PROMPT "You write handover notes for operations teams. Bullet points: status, anomalies, open items. Max 8 bullets."
    WITH MEMORY "none"
    ADD TOOL "read_mqtt"
        WITH TOPICS "telemetry/#, alerts/#"

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.")
        RETURN AS {brief}
    PUBLISH TOPIC "agents/site/shift/handover" WITH {brief}