Eventos do Core e atualização da documentação OpenAPI¶
Separar a conclusão HTTP dos efeitos posteriores de publicação, exclusão e resolução de setups. O Core grava eventos no MongoDB; o transporte é responsabilidade do Outbox Dispatcher.
%%{init: {"theme":"base","themeVariables":{"fontFamily":"Arial, sans-serif","fontSize":"16px","lineColor":"#64748b","primaryTextColor":"#172b4d"},"flowchart":{"htmlLabels":true,"useMaxWidth":true,"nodeSpacing":28,"rankSpacing":38,"padding":14,"curve":"linear","subGraphTitleMargin":{"top":12,"bottom":16}},"sequence":{"useMaxWidth":true,"actorMargin":28,"width":145,"height":45,"diagramMarginX":32,"diagramMarginY":12,"messageMargin":24,"wrap":true,"mirrorActors":false},"themeCSS":".edgeLabel, .edgeLabel p {background-color:var(--diagram-surface)!important;color:var(--diagram-text)!important}\n.cluster rect {fill:var(--diagram-group)!important;stroke:var(--diagram-line)!important}\n.cluster-label span, .cluster-label text {color:var(--diagram-text)!important;fill:var(--diagram-text)!important}\n.flowchart-link, .actor-line {stroke:var(--diagram-line)!important}\nmarker path {fill:var(--diagram-line)!important;stroke:var(--diagram-line)!important}\n.actor {fill:var(--diagram-domain)!important;stroke:var(--diagram-domain-border)!important}\ntext.actor, .messageText, .loopText, .labelText {fill:var(--diagram-text)!important}\n.messageLine0, .messageLine1, .loopLine {stroke:var(--diagram-line)!important}\n.labelBox {fill:var(--diagram-surface)!important;stroke:var(--diagram-line)!important}\n.note {fill:var(--diagram-async)!important;stroke:var(--diagram-async-border)!important}\n.noteText {fill:var(--diagram-text)!important}\n.nodeLabel, .nodeLabel p, .nodeLabel span {color:var(--diagram-text)!important}\n.node .nodeLabel, .node .nodeLabel p {font-size:17px;font-weight:600;line-height:1.4;text-align:center}\n.nodeLabel small {display:inline-block;margin-top:4px;font-size:15px;font-weight:400;line-height:1.4;color:var(--diagram-description)!important}\ntext.actor, text.actor tspan {font-size:17px;font-weight:600}\n.node.entry rect, .node.entry polygon, .node.entry path, .node.entry circle {fill:var(--diagram-entry)!important;stroke:var(--diagram-entry-border)!important}\n.node.domain rect, .node.domain polygon, .node.domain path, .node.domain circle {fill:var(--diagram-domain)!important;stroke:var(--diagram-domain-border)!important}\n.node.security rect, .node.security polygon, .node.security path, .node.security circle {fill:var(--diagram-security)!important;stroke:var(--diagram-security-border)!important}\n.node.store rect, .node.store polygon, .node.store path, .node.store circle {fill:var(--diagram-store)!important;stroke:var(--diagram-store-border)!important}\n.node.async rect, .node.async polygon, .node.async path, .node.async circle {fill:var(--diagram-async)!important;stroke:var(--diagram-async-border)!important}\n.node.external rect, .node.external polygon, .node.external path, .node.external circle {fill:var(--diagram-external)!important;stroke:var(--diagram-external-border)!important}\n text.actor tspan, .loopText tspan, .labelText tspan, .messageText tspan, .noteText tspan {fill:var(--diagram-text)!important}\n\n"}}%%
%%{init: {"sequence":{"width":135,"actorMargin":24,"messageMargin":24,"wrap":true}}}%%
sequenceDiagram
participant C as Core
participant M as MongoDB
participant D as Outbox Dispatcher
participant Q as RabbitMQ
participant O as OpenAPI Doc
participant T as Template Service
C->>M: Gravar alteração e outbox_events
Note over C,M: Resposta HTTP não aguarda consumo
D->>M: Reivindicar evento pendente
D->>Q: Publicar payload
par Confirmação de transporte
Q-->>D: Confirmação de transporte
D->>M: Marcar SENT
and Consumo independente
alt gateway.published
Q--)O: Solicitar projeção
O->>C: GET gateways/id/openapi-model
C->>M: Agregar Gateway, categorias e rotas ACTIVE habilitadas
C-->>O: 200 — modelo de documentação
O->>M: Upsert gateway_openapi e registrar Inbox
else gateway.deleted
Q--)O: Remover projeção
O->>M: Excluir gateway_openapi e registrar Inbox
else gateway.setups_solved
Q--)T: Retomar operação da instância
Note over T,C: Configuração ou upgrade da instância
end
endResumo: O endpoint de exportação retorna o modelo, não o arquivo OpenAPI final. OpenAPI Doc converte e armazena a projeção. O Dispatcher aplica claim, lease e retry, com possibilidade de reentrega entre confirmação e marcação SENT. MongoDB representa os armazenamentos participantes, sem implicar uma transação única entre serviços.
Resultado: Eventos publicados e projeções/etapas atualizadas posteriormente. gateway.published também é produzido ao desabilitar ou excluir uma rota, para recompor a documentação.
Alternativas relevantes: A invalidação de cache por @ObjectEventListener é um mecanismo separado do Outbox: existem bindings em mutações de Gateway/rota e wizard. A ativação e a ordem do interceptor da biblioteca em relação ao commit não estão estabelecidas pelo fonte do Core; por isso não há uma chamada de invalidação com ordem presumida no diagrama.