#!/usr/bin/env python3

"""

darwin-emit  - POST a contract-§1 event to the Darwin Deck event bus.

The forward hook for true `agents-of-agents` nesting: any process (a spawner,

a scheduler, a remote agent, a shell hook) can self-report into the live tree.

A spawner emits a `child_spawned` carrying its own --parent-id so the child

nests under it to any depth.

Deck endpoint (default): http://REDACTED-IP:9893/event

Contract: /shared/projects/darwin/deck/CONTRACTS.md §1

USAGE

  darwin-emit --agent-id ID [options]

  darwin-emit -a ID -t child_spawned -p PARENT_ID -l "Build gateway" -m glm --host ct247

OPTIONS  (env var fallback in parens; CLI wins)

  -a, --agent-id   ID    stable id for this agent run        (DARWIN_AGENT_ID)   [required]

  -p, --parent-id  ID    spawner id -> builds the tree edge  (DARWIN_PARENT_ID)

  -t, --type       T     spawned|tool_call|child_spawned|returned|error|token_tick

                                                             (DARWIN_TYPE, default: spawned)

  -l, --label      S     human label                         (DARWIN_LABEL)

  -m, --model      S     sonnet|opus|glm-5.2|codex|gpt-5.5|… (DARWIN_MODEL, default: sonnet)

  -s, --status     S     running|done|error|paused           (DARWIN_STATUS, default: running)

      --host       S     ct215|ct241|ct247|…                 (DARWIN_HOST, default: ct215)

      --tokens     N     cumulative token count               (DARWIN_TOKENS, default: 0)

      --tool       S     tool name (for tool_call)            (DARWIN_TOOL)

      --session    S     session id                           (DARWIN_SESSION)

      --deck-url   URL   override Deck base url                (DARWIN_DECK_URL)

  -q, --quiet            no stdout on success

EXAMPLES

  # a spawner registers a freshly-spawned child under itself

  darwin-emit -a child_abc -p $MY_AGENT_ID -t child_spawned -l "scan repo" -m glm --host ct247

  # heartbeat / token tick

  darwin-emit -a child_abc -t token_tick --tokens 53542

  # mark done

  darwin-emit -a child_abc -t returned -s done

EXIT  0 ok · 2 bad args · 3 POST failed

"""

import argparse

import json

import os

import sys

import urllib.request

from datetime import datetime, timezone

def main() -> int:

    p = argparse.ArgumentParser(add_help=True, description="Emit a Darwin Deck event.")

    p.add_argument("-a", "--agent-id", default=os.environ.get("DARWIN_AGENT_ID"))

    p.add_argument("-p", "--parent-id", default=os.environ.get("DARWIN_PARENT_ID"))

    p.add_argument("-t", "--type", default=os.environ.get("DARWIN_TYPE", "spawned"))

    p.add_argument("-l", "--label", default=os.environ.get("DARWIN_LABEL", ""))

    p.add_argument("-m", "--model", default=os.environ.get("DARWIN_MODEL", "sonnet"))

    p.add_argument("-s", "--status", default=os.environ.get("DARWIN_STATUS", "running"))

    p.add_argument("--host", default=os.environ.get("DARWIN_HOST", "ct215"))

    p.add_argument("--tokens", type=int, default=int(os.environ.get("DARWIN_TOKENS", "0")))

    p.add_argument("--tool", default=os.environ.get("DARWIN_TOOL"))

    p.add_argument("--session", default=os.environ.get("DARWIN_SESSION", ""))

    p.add_argument("--deck-url", default=os.environ.get("DARWIN_DECK_URL", "http://REDACTED-IP:9893"))

    p.add_argument("-q", "--quiet", action="store_true")

    args = p.parse_args()

    if not args.agent_id:

        sys.stderr.write("darwin-emit: --agent-id (or DARWIN_AGENT_ID) is required\n")

        return 2

    event = {

        "ts": datetime.now(timezone.utc).isoformat(),

        "agent_id": args.agent_id,

        "parent_id": args.parent_id,

        "type": args.type,

        "label": args.label,

        "model": args.model,

        "status": args.status,

        "tokens": args.tokens,

        "host": args.host,

        "session": args.session,

    }

    if args.tool:

        event["tool"] = args.tool

    url = args.deck_url.rstrip("/") + "/event"

    data = json.dumps(event).encode()

    req = urllib.request.Request(url, data=data, headers={"Content-Type": "application/json"}, method="POST")

    try:

        with urllib.request.urlopen(req, timeout=5) as resp:

            body = resp.read().decode()

    except Exception as e:  # noqa: BLE001 - deck down must never break a spawner

        sys.stderr.write(f"darwin-emit: POST failed: {e}\n")

        return 3

    if not args.quiet:

        print(body)

    return 0

if __name__ == "__main__":

    sys.exit(main())