Bobby44-max/real-estate-workflows

Real Estate Workflows

Core Pipeline

URL → Video Workflow

[Listing URL Input]
       ↓
[Firecrawl Extraction]
       ↓
[Data Validation]
       ↓
[AI Script Generation]
       ↓
[TTS Voiceover (Optional)]
       ↓
[Remotion Render]
       ↓
[Upload to Storage]
       ↓
[Notify User]

Workflow API

Single Video Generation

POST /api/workflow/generate-video
{
  listingUrl: "https://zillow.com/...",
  videoType: "property-showcase",
  options: {
    voiceover: true,
    music: "upbeat",
    branding: {
      agentName: "Jane Smith",
      logoUrl: "https://..."
    }
  }
}

Batch Processing

POST /api/workflow/batch
{
  urls: ["url1", "url2", "url3"],
  videoType: "social-short",
  options: { ... }
}

Status Tracking

GET /api/workflow/status/:jobId

{
  jobId: "job_abc123",
  status: "rendering",
  progress: 65,
  steps: [
    { name: "scrape", status: "complete", duration: 2.3 },
    { name: "script", status: "complete", duration: 4.1 },
    { name: "voiceover", status: "complete", duration: 8.2 },
    { name: "render", status: "in_progress", progress: 45 }
  ],
  estimatedCompletion: "2024-01-15T10:30:00Z"
}

Detailed Rules

• URL to Video: See rules/url-to-video.md
• Batch Processing: See rules/batch-processing.md
• Social Distribution: See rules/social-distribution.md

Database Schema

Video Jobs (Convex)

defineTable({
  userId: v.string(),
  listingUrl: v.string(),
  videoType: v.string(),
  status: v.string(), // pending, scraping, generating, rendering, complete, failed
  progress: v.number(),
  propertyData: v.optional(v.any()),
  script: v.optional(v.string()),
  voiceoverUrl: v.optional(v.string()),
  videoUrl: v.optional(v.string()),
  thumbnailUrl: v.optional(v.string()),
  error: v.optional(v.string()),
  createdAt: v.number(),
  completedAt: v.optional(v.number()),
})

Error Handling

| Error | Recovery | |-------|----------| | Scrape failed | Retry with fallback parser | | AI timeout | Retry with shorter prompt | | Render OOM | Reduce resolution, retry | | Storage failed | Queue for later upload |

Webhook Notifications

// Configure in user settings
POST /webhooks/video-complete
{
  event: "video.complete",
  jobId: "job_abc123",
  videoUrl: "https://storage.../video.mp4",
  propertyAddress: "123 Main St",
  timestamp: "2024-01-15T10:30:00Z"
}

Integrations

• Firecrawl: Property data extraction
• Gemini AI: Script generation
• OpenAI TTS: Voiceover synthesis
• Remotion Lambda: Video rendering
• Supabase Storage: Asset hosting
• Convex: Real-time job tracking
• Clerk: User authentication
• Stripe: Usage billing