Null-DRM-Official/apps/agent

agent

Always-on credentials refresher, hosted by the single binary as drm agent.

apps/agent/
  agentcmd/        the command body, imported by apps/cli
  internal/        poller, durable queue, device pool, worker, ws client
  agent.yaml       config

What it does

1. Polls streamd (GET /api/streams)
2. When an enabled stream is down/errored or missing mpd/key, enqueues a job in a durable SQLite queue under data_dir
3. Claims a free ADB device that already has the app installed — it never installs
4. Runs a phone capture through the stream's app module
5. POST /api/streams/:id/credentials
6. Force-stops the app and clears the device proxy so the phone is free

It never runs a downloader. Claims are kept alive by a websocket heartbeat, so they expire by themselves if the agent dies.

Run

# terminal 1 — control plane
./bin/drm serve --bind 127.0.0.1:8083 --data .cache/streamd --token SECRET

# terminal 2 — agent
export STREAMD_TOKEN=SECRET
./bin/drm agent run --config apps/agent/agent.yaml

./bin/drm agent status
./bin/drm agent devices
./bin/drm agent enqueue --stream tg4-ioi --reason manual
./bin/drm agent cancel --job 3

App modules are compiled into the binary, so there is no modules_dir to set. The agent drives whichever module a stream names and contains no provider logic.

Config

agent.yaml — streamd_url, token (or STREAMD_TOKEN), poll_interval_sec, workers, max_attempts, capture_wait_sec, devices (empty = any authorised device), wvd, user_agent, agent_id, data_dir.

wvd must be set or key fetches fail.

Build

go -C apps/cli build -o ../../bin/drm .

# cross-compile
GOOS=darwin GOARCH=arm64 go -C apps/cli build -o ../../bin/drm .

Full guide: docs/streamd.md