Social Bot Scheduler

📐 Arquitectura — Caso 05: 🎼 Laravel → 🌉 n8n → ⚛️ React#

Origen: Laravel Destino: React Persistencia: MongoDB Puente: n8n

Emisor de automatización en Laravel/Artisan (PHP Streams) que publica hacia un receptor fullstack React SPA + Node/Express, orquestado por n8n con guardrails de resiliencia (idempotencia, circuit breaker, DLQ) y persistencia documental en MongoDB.


🧭 Ficha técnica#

AtributoValor
ID05
OrigenLaravel 8.2 (PHP · Artisan) — origin/ArtisanPost.php
Puenten8n — case-05-laravel-to-react.json
DestinoReact SPA + Node/Express — dest/server.js
PersistenciaMongoDB 6.0
Puerto (dashboard)http://localhost:8085
Perfil Dockercase05
GuardrailsIdempotencia · Circuit Breaker · Dead Letter Queue

🗺️ Diagrama de arquitectura#

diagrama mermaid
%%{init: {'theme':'base','themeVariables':{'fontSize':'26px','fontFamily':'Segoe UI, Arial, sans-serif'},'flowchart':{'useMaxWidth':true,'htmlLabels':false,'nodeSpacing':55,'rankSpacing':70,'padding':16,'diagramPadding':16}}}%%
flowchart TB
    subgraph ORIGIN["ORIGEN - Laravel"]
        B["ArtisanPost.php"]
    end

    subgraph BRIDGE["PUENTE - n8n + Guardrails"]
        C(["Webhook"]) --> IDEM{"Idempotencia (fingerprint)"}
        IDEM -->|duplicado| DISCARD["200 OK - descarta"]
        IDEM -->|nuevo| CBK{"Circuit Breaker"}
        CBK -->|cerrado| FWD["HTTP forward"]
        CBK -->|abierto| DLQ["Dead Letter Queue"]
    end

    subgraph DEST["DESTINO - React / Node"]
        FWD --> H["server.js"]
        H --> DB[("MongoDB 6.0")]
        DB --> DASH["Dashboard :8085"]
    end

    B -->|POST JSON| C
    FWD -.->|error| DLQ

    classDef origin fill:#FF2D20,stroke:#333,color:#fff
    classDef bridge fill:#EA4B71,stroke:#333,color:#fff
    classDef dest fill:#61DAFB,stroke:#333,color:#fff
    classDef db fill:#47A248,stroke:#333,color:#fff
    class B origin
    class C,IDEM,CBK,FWD,DLQ,DISCARD bridge
    class H,DASH dest
    class DB db

🔁 Diagrama de secuencia (ciclo de una publicación)#

diagrama mermaid
%%{init: {'theme':'base','themeVariables':{'fontSize':'24px','fontFamily':'Segoe UI, Arial, sans-serif'},'sequence':{'useMaxWidth':true,'actorFontSize':22,'messageFontSize':20,'noteFontSize':18,'actorMargin':90,'boxMargin':16,'width':180}}}%%
sequenceDiagram
    autonumber
    participant Bot as ArtisanPost.php (Laravel)
    participant N8N as n8n
    participant Dest as server.js (React / Node)
    participant DB as MongoDB 6.0

    Bot->>Bot: Prepara y valida el payload
    Bot->>N8N: POST /webhook (JSON del post)
    N8N->>N8N: Idempotencia (fingerprint)
    alt Duplicado
        N8N-->>Bot: 200 OK (descartado)
    else Nuevo
        N8N->>N8N: Circuit Breaker (estado)
        alt Breaker cerrado
            N8N->>Dest: HTTP forward del payload
            Dest->>DB: INSERT post
            DB-->>Dest: OK
            Dest-->>N8N: 200 + registro
            N8N-->>Bot: 200 OK
        else Breaker abierto / error
            N8N->>N8N: Enruta a Dead Letter Queue
            N8N-->>Bot: 5xx (reintento posterior)
        end
    end

🧩 Componentes#

🎼 Origen — Laravel Artisan Simulator#

  • Clase que imita un Console Command de Artisan: extrae las publicaciones pendientes de posts.json y las despacha hacia el webhook de n8n.
  • Emplea PHP Streams para envíos HTTP eficientes y ligeros.

🌉 Puente — n8n#

  • Recibe el webhook, aplica idempotencia (descarta duplicados por fingerprint), pasa por el Circuit Breaker y reenvía al destino. Los fallos se enrutan a la Dead Letter Queue.

⚛️ Destino — React / Node Fullstack#

  • server.js (Node/Express) recibe el post, lo valida y lo persiste en MongoDB preservando su estructura documental. La Single Page Application de React (:8085) visualiza los posts con actualizaciones periódicas y una estética profesional.

▶️ Cómo levantarlo#

bash
docker-compose --profile case05 up -d       # levanta receptor React/Node + MongoDB + n8n
python hub.py ejecutar 05-laravel-to-react   # dispara el emisor Laravel

Dashboard: http://localhost:8085


🔗 Enlaces#


Diagramas en Mermaid — se renderizan nativamente en GitHub. Parte de Social Bot Scheduler.