Catalyst V2 — AI-Native Multi-Tenant CRM Platform

flowchart TB
    subgraph ClientLayer ["Client Layer (Next.js 16 + React 19)"]
        UI["Widescreen Responsive Dashboard"]
        Auth["Login & Registration with RBAC"]
        Studio["AI Campaign Studio & Live Console"]
        Cust360["Customer 360 & Digital Twin Panel"]
        AnalyticsUI["Attribution & Deliverability Telemetry"]
    end

    subgraph APILayer ["API & Middleware Layer (FastAPI)"]
        TenantMid["Tenant Isolation Middleware\n(In-Memory Session Cache: 60s TTL)"]
        AuthRouter["/api/auth (JWT, Silent Refresh, RBAC)"]
        CRMRouters["/api/customers, /api/campaigns, /api/segments"]
        StudioRouter["/api/chat_studio (Streaming SSE)"]
        TelemetryRouter["/api/analytics, /api/agents"]
    end

    subgraph AgentSwarm ["10-Agent LangGraph Orchestration Swarm"]
        Supervisor["1. Supervisor / Router Agent"]
        CustIntel["2. Customer Intelligence"]
        Segmenter["3. Segmentation & Cohort"]
        Copywriter["4. Content Personalization"]
        ChannelSel["5. Channel Selection"]
        Simulator["6. Monte Carlo Simulator"]
        Dispatcher["7. Idempotent Dispatcher"]
        CallbackProc["8. Callback Processor"]
        Explainability["9. Analytics & Explainability"]
        FallbackAgent["10. Self-Healing Fallback"]
    end

    subgraph StorageLayer ["Database & Infrastructure Layer"]
        Supabase["Supabase PostgreSQL 17\n(ThreadedConnectionPool: 2-15 conn)"]
        PGVector["pgvector Embedding Storage"]
        RLS["Row-Level Security (company_id isolated)"]
        Resend["Resend / SMTP Email Providers"]
        LangSmith["LangSmith Observability & Tracing"]
    end

    UI --> TenantMid
    TenantMid --> AuthRouter
    TenantMid --> CRMRouters
    TenantMid --> StudioRouter
    TenantMid --> TelemetryRouter

    StudioRouter --> AgentSwarm
    Supervisor <--> CustIntel
    Supervisor <--> Segmenter
    Supervisor <--> Copywriter
    Supervisor <--> ChannelSel
    Supervisor <--> Simulator
    Supervisor <--> Dispatcher
    Supervisor <--> CallbackProc
    Supervisor <--> Explainability
    Supervisor <--> FallbackAgent

    AgentSwarm --> Supabase
    AgentSwarm --> PGVector
    AgentSwarm --> Resend
    AgentSwarm --> LangSmith
    Supabase --> RLS

sequenceDiagram
    autonumber
    actor Marketer as Marketer / User
    participant Sup as 1. Supervisor Agent
    participant Intel as 2. Customer Intelligence
    participant Seg as 3. Segmentation Agent
    participant Cont as 4. Content Personalization
    participant Chan as 5. Channel Selection
    participant Sim as 6. Simulation Agent
    participant Exec as 7. Dispatcher Agent
    participant Callb as 8. Callback Processor
    participant Analy as 9. Analytics Agent
    participant Fall as 10. Fallback Agent

    Marketer->>Sup: Input Marketing Goal (e.g., "Navratri Festive Pre-Season")
    Sup->>Intel: Ingest Customer Behavior & RFM Scores
    Intel-->>Sup: Digital Twins & Churn Vulnerability Signals
    Sup->>Seg: Generate Rule-based & Vector Cohort
    Seg-->>Sup: Audience Isolated (1,000 Contacts)
    Sup->>Cont: Generate Dynamic Copy Variants
    Cont-->>Sup: Personalized Subject & Body Drafts
    Sup->>Chan: Determine Optimal Delivery Route
    Chan-->>Sup: Recommended Channel: Email (98% Deliverability)
    Sup->>Sim: Run Monte Carlo Pre-Flight Prediction
    Sim-->>Sup: Forecast: 45% Open, 15% Click, 5% Conv, $96K Rev
    Sup-->>Marketer: Awaiting Approval (Campaign Blueprint & Simulation)

    alt Marketer Approves Campaign
        Marketer->>Sup: "Yes, launch campaign"
        Sup->>Exec: Dispatch Batch with Idempotency Key
        Exec->>Callb: Provider Dispatched (Resend/SMTP)
        Callb->>Analy: Delivery Webhook Telemetry (Opened, Clicked)
        Analy-->>Sup: Campaign Performance & Attributed Revenue
    else Error / Rate Limit Occurs
        Exec-->>Fall: Provider Error / Rate Limit Triggered
        Fall-->>Sup: Circuit Broken -> Alternate SMTP Fallback Activated
    end