Director¶

Pipeline orchestration service that uses LangGraph to coordinate content creation with HITL approval gates and vector memory.

Endpoints¶

POST /api/v1/content/generate¶

Trigger content generation from a trend.

Request body:

{
  "trend_id": "550e8400-e29b-41d4-a716-446655440000",
  "trend_topic": "AI agents in production",
  "niche": "technology",
  "target_platform": "youtube_shorts",
  "tone": "informative and engaging",
  "visual_style": "cinematic"
}

Target platforms: youtube_shorts, tiktok, instagram_reels, youtube

curl -X POST http://localhost:8000/api/v1/director/api/v1/content/generate \
  -H "Authorization: Bearer $TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "trend_id": "550e8400-e29b-41d4-a716-446655440000",
    "trend_topic": "AI agents in production",
    "target_platform": "youtube_shorts"
  }'

resp = httpx.post(
    "http://localhost:8000/api/v1/director/api/v1/content/generate",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "trend_id": "550e8400-e29b-41d4-a716-446655440000",
        "trend_topic": "AI agents in production",
        "target_platform": "youtube_shorts",
    },
)
content = resp.json()

POST /api/v1/content/resume¶

Resume a paused HITL pipeline.

{
  "thread_id": "thread-uuid",
  "approved": true,
  "feedback": "Looks good, proceed with generation"
}

GET /api/v1/content¶

List content items with optional status filter.

GET /api/v1/content/{content_id}¶

Get full content details including script, visual prompts, and pipeline status.

GET /api/v1/content/{content_id}/visual-prompts¶

Get visual prompts generated for a content item.

LangGraph Pipeline¶

The Director builds a StateGraph with the following nodes:

graph LR
    START((Start)) --> S["Strategist\nScript + Critique"]
    S --> SR{"HITL Gate"}
    SR -->|approved| C["Creator\nVisual Prompts"]
    SR -->|rejected| END1((End))
    C --> CR{"HITL Gate"}
    CR -->|approved| A["Analyst\nPerformance"]
    CR -->|rejected| END2((End))
    A --> AR{"HITL Gate"}
    AR -->|approved + iterations left| S
    AR -->|rejected or max iterations| END3((End))

See LangGraph for detailed pipeline documentation.

Key Components¶

Events¶