outreach-paced

outreach-paced

Why this exists

Cal.com is wired but has 0 inbound. Content-publish-daily builds audience slowly. Outreach drives qualified prospects directly to a 30-min audit booking THIS WEEK. This skill is the lead-acquisition surface.

Inputs

{
  "for_date": "2026-04-29",
  "surfaces": ["linkedin", "reddit", "email"],
  "dry_run": false
}

dry_run=true runs Steps 1-4 (drafts, anti-template, queue) but skips approval-gate creation and Telegram send.

Daily quotas (hard-capped)

Surface	Action	Max
linkedin	view-first DM	5
reddit	substantive comment	3
reddit	DM	1
email	personalized cold email	5
TOTAL		14

Procedure

Step 1 — Pull qualified prospects

import json, datetime, pathlib, hashlib
home = pathlib.Path.home() / "Dev/daily-ai-agent-os"
now = datetime.datetime.now(datetime.timezone.utc)
date_str = (now - datetime.timedelta(hours=5)).strftime("%Y-%m-%d")

# Reddit prospects from precise_leads.json (research agent populates)
reddit_leads_path = home / "data/leads/precise_leads.json"
reddit_leads = json.loads(reddit_leads_path.read_text()) if reddit_leads_path.exists() else []

# LinkedIn + email prospects from active.json (research agent populates this format)
active_path = home / "data/leads/active.json"
active = json.loads(active_path.read_text()) if active_path.exists() else []
linkedin_leads = [l for l in active if l.get("surface") == "linkedin"]
email_leads = [l for l in active if l.get("surface") == "email"]

# Idempotency: skip prospects already messaged in last 14 days
idx_path = home / "data/outreach/log/index.json"
recent = {}
if idx_path.exists():
    recent = json.loads(idx_path.read_text())
cutoff = (now - datetime.timedelta(days=14)).isoformat()
def already_messaged(prospect_id):
    return recent.get(prospect_id, "") > cutoff

reddit_leads = [l for l in reddit_leads if not already_messaged(l.get("permalink", ""))][:4]  # 3 comment + 1 DM
linkedin_leads = [l for l in linkedin_leads if not already_messaged(l.get("profile_url", ""))][:5]
email_leads = [l for l in email_leads if not already_messaged(l.get("email", ""))][:5]

print(f"[outreach-paced] candidates: linkedin={len(linkedin_leads)} reddit={len(reddit_leads)} email={len(email_leads)}")