🚀 queue2runtime

Polyglot Queue — O Tradutor de Filas (Queue Translator) universal e nativo construído para curar o caos do ecossistema de mensageria, agnóstico de infraestrutura e altamente performático sob Bun.

🔗 Veja o nosso CHANGELOG.md para acompanhar as atualizações mais recentes.

🚀 Como Funciona

Imagine poder rotear mensagens do NATS para o Kafka, do Redis Streams para o RabbitMQ (e vice-versa), sem o custo de levantar containers ou sidecars super-robustos. O queue2runtime realiza esse mapeamento e proxy-streaming dinâmico atuando como uma via unificadora universal para protocolos de event-streaming.

import { QueueTranslator } from './packages/core';
import { NatsAdapter } from './packages/nats-native';
import { KafkaAdapter } from './packages/kafka-native';

const translator = new QueueTranslator();

// Registra os brokers no mesmo fluxo poliglota
await translator.register(new NatsAdapter({ url: 'nats://localhost:4222' }));
await translator.register(new KafkaAdapter({ brokers: ['localhost:9092'] }));

// Adiciona uma rota automática interceptadora: NATS -> Kafka
await translator.addRoute('nats', 'order.created', 'kafka', 'processing.orders');

🛠️ Como foi feito

O projeto foi codificado respeitando a fundação central do framework: ser à prova de falhas com Evidence-first.

Ele unifica drivers baseados nativamente em pacotes de sistema usando interfaces genéricas Type-safe — ou seja, criamos Adapters nominais (como TCP Nativo, RESP, Kafka Wire protocol) para encapsular as complexidades dentro de polimorfismo limpo.

O mecanismo central (QueueTranslator) adereção Object Calisthenics não conhecendo individualmente qual broker está rodando. As proteções do sistema garantem entrega com ACKs e NACKs sem ferir as responsabilidades ou dependências.

🧪 Como testar

Utilizamos o padrão TDD base do vibe2founder. Para testes diretos sem side-effects no sistema real:

1. Clone a base via bun install sempre no ambiente wsl.
2. É preferido o uso do módulo interno queue2tests, mas testes unitários locais rodam isoladamente simulando fluxos em memória (in-memory adapters de fallback) do QueueTranslator.
3. Use o comando de bun test e verifique todo o roteamento lógico da camada de transporte sem atrasos de container.