📐 Arquitectura — Caso 07: 🦀 Rust → 🌉 n8n → 💎 Ruby#

Emisor asíncrono fuertemente tipado en Rust (cliente reqwest 0.12 + dotenvy) que publica hacia un receptor ágil en Ruby 3.2 / Sinatra, orquestado por n8n con guardrails de resiliencia (idempotencia, circuit breaker, DLQ) y persistencia distribuida en Cassandra.

🧭 Ficha técnica#

Atributo	Valor
ID	`07`
Origen	Rust 1.7x — cliente `reqwest` 0.12 + `dotenvy` — `origin/src/main.rs`
Puente	n8n — `case-07-rust-to-ruby.json`
Destino	Ruby 3.2 / Sinatra sobre Puma — `dest/app.rb`
Persistencia	Cassandra 4.1 (Columnar Distribuido)
Puerto (dashboard)	`http://localhost:8087`
Perfil Docker	`case07`
Guardrails	Idempotencia · 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 - Rust"]
        B["main.rs"]
    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 - Ruby / Sinatra"]
        FWD --> H["app.rb"]
        H --> DB[("Cassandra 4.1")]
        DB --> DASH["Dashboard :8087"]
    end

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

    classDef origin fill:#DEA584,stroke:#333,color:#fff
    classDef bridge fill:#EA4B71,stroke:#333,color:#fff
    classDef dest fill:#CC342D,stroke:#333,color:#fff
    classDef db fill:#1287B1,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 main.rs (Rust)
    participant N8N as n8n
    participant Dest as app.rb (Ruby / Sinatra)
    participant DB as Cassandra 4.1

    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 — Rust Safety Dispatcher#

Utiliza estructuras (structs) y Serde para una serialización ultra rápida de los posts, garantizando la integridad de los datos antes del envío mediante su sistema de tipos.
Cliente reqwest 0.12 asíncrono (con dotenvy para la configuración) para despachos masivos sin bloqueo hacia el webhook de n8n.

🌉 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 — Ruby / Sinatra#

app.rb (Sinatra DSL sobre el servidor Puma) gestiona los eventos entrantes, los persiste en Cassandra —ideal para flujos de alta escritura— y renderiza un dashboard dinámico con plantillas ERB (:8087).

▶️ Cómo levantarlo#

bash

docker-compose --profile case07 up -d      # levanta receptor Ruby + Cassandra + n8n
python hub.py ejecutar 07-rust-to-ruby      # dispara el emisor Rust

Dashboard: http://localhost:8087

🔗 Enlaces#

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

← Toda la documentación Portada Esta carpeta en GitHub