peepshow/ sinks/ pipedream

Reel #60 Low-code workflow

peepshow sink / pipedream

PipedreamPOST runs to a Pipedream workflow with HMAC signing + retries.

Drop-in low-code automation: fire a Pipedream workflow on every extracted video, with signed requests and automatic retry on 429/5xx.

drop · process · pipedream

What it does

POST the full peepshow JSON payload to a Pipedream source URL (`https://<id>.m.pipedream.net`). Adds an HMAC-SHA256 `X-Pipedream-Signature` header when a signing secret is configured, plus run-metadata headers (`X-Peepshow-Run-Id`, `X-Peepshow-Duration-Seconds`) so workflow steps can branch without parsing the body. Retries on 429 and 5xx with exponential backoff up to 3 times.

When to reach for it

  • Wire every peepshow run into a Pipedream workflow that fans out to Slack + Linear + S3
  • Kick off downstream automation — scene-by-scene transcript processing, summarisation, notification fan-out
  • Prototype glue pipelines before baking them into a dedicated sink

Install

npm i -g peepshow

Use it

export PIPEDREAM_URL="https://eoabcdef.m.pipedream.net"
peepshow sinks add pipedream
peepshow ./video.mp4

Make it automatic

Register the sink once — every run fires it afterward. Scope by --when so it only runs for matching videos.

peepshow sinks add pipedream
peepshow sinks add pipedream --when extension=mp4,mov
peepshow sinks add pipedream --when path=/Volumes/Work/

Configuration

  • PIPEDREAM_URL Workflow source URL, e.g. `https://eo<id>.m.pipedream.net`. required
  • PIPEDREAM_SIGNING_SECRET Optional HMAC-SHA256 signing key. When set, each POST includes an `X-Pipedream-Signature` header.
  • PIPEDREAM_RETRY_MAX Max retries on 429/5xx. Default `3`.
  • PIPEDREAM_TIMEOUT_MS Per-request timeout in milliseconds. Default `15000`.

Use with an LLM agent

Every peepshow sink reads its config from env vars and receives a single JSON payload on stdin. An LLM agent (Claude Code, Cursor, Windsurf, Gemini, Codex) can drive the Pipedream sink automatically when three things are true:

  • the env vars below are exported in the agent's shell (or a project .env it can load),
  • the peepshow CLI is on PATH — install with npm i -g peepshow,
  • a peepshow auto-sink is registered for the run (optional but recommended — makes invocation zero-argument).

1. Set the environment

# Add to ~/.zshrc, ~/.bashrc, or a project .env the agent can load
export PIPEDREAM_URL="..."

2. Register as an auto-sink

peepshow sinks add pipedream
peepshow sinks add pipedream --when extension=mp4,mov

3. Example LLM session

You → drop a .mov into Claude Code.

Claude → auto-invokes /peepshow:slides ./clip.mov. peepshow extracts frames + audio, the Pipedream sink forwards the run to the configured Pipedream target. Claude replies with a summary and a link to the created record.

The transcript rides along in the payload whenever the audio pass transcribes successfully.

Write your own

A sink is any executable that reads the --emit json payload on stdin. Shell, Node, Python, Go — the spec's in docs/PLUGINS.md. Register persistent ones with peepshow sinks add-cmd 'your-command'.