Dist Connector Reddit

# apps/distribution/connectors/reddit.py
import httpx

REDDIT_API = "https://oauth.reddit.com"

def submit_post(*, job) -> dict:
    account = job.account
    payload = job.payload or {}
    subreddit = account.config.get("subreddit", "test")

    body = {
        "sr": subreddit,
        "title": payload.get("title", "")[:300],
        "kind": "link" if payload.get("link") else "self",
    }

    if payload.get("link"):
        body["url"] = payload["link"]
    else:
        body["text"] = payload.get("text", "")

    resp = httpx.post(
        f"{REDDIT_API}/api/submit",
        headers={
            "Authorization": f"Bearer {account.access_token}",
            "User-Agent": "GSMFWs:v1.0 (by /u/platform_bot)",
        },
        data=body,
        timeout=30,
    )
    resp.raise_for_status()
    result = resp.json()

    post_data = result.get("json", {}).get("data", {})
    job.external_post_id = post_data.get("id", "")
    job.status = "completed"
    job.save(update_fields=["external_post_id", "status"])
    return result

Anti-Patterns

• No User-Agent header — Reddit blocks requests silently
• Exceeding self-promotion ratio — account gets shadowbanned
• Posting same content to multiple subreddits simultaneously — spam
• Not handling 429 rate limit responses with backoff

Quality Gate

& .\.venv\Scripts\python.exe -m ruff check . --fix
& .\.venv\Scripts\python.exe -m ruff format .
& .\.venv\Scripts\python.exe manage.py check --settings=app.settings_dev