2fa8f2435f
Capture, decrypt, and restream toolkit with compiled-in app modules (RTE, TG4, BBC), on-device MITM proxy, streamd control plane, and www. BBC module.yaml is published (clear streams); other module values stay local.
1.8 KiB
1.8 KiB
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
- Polls streamd (
GET /api/streams) - When an enabled stream is down/errored or missing
mpd/key, enqueues a job in a durable SQLite queue underdata_dir - Claims a free ADB device that already has the app installed — it never installs
- Runs a phone capture through the stream's app module
POST /api/streams/:id/credentials- 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