Esquema de Eventos Tipados do Daemon v1

Visão geral

Cada frame SSE emitido pelo daemon em GET /session/:id/events tem a forma { id, v, type, data, originatorClientId?, _meta? }. v: 1 é o EVENT_SCHEMA_VERSION atual. type vem do conjunto fechado e fixado por versão DAEMON_KNOWN_EVENT_TYPE_VALUES em packages/sdk-typescript/src/daemon/events.ts. O campo _meta do envelope é carimbado no limite de escrita do SSE por formatSseFrame() em packages/cli/src/serve/routes/sse-events.ts; consulte Metadados no nível do envelope.

O SDK expõe asKnownDaemonEvent(evt). Ele retorna um KnownDaemonEvent discriminado para tipos de eventos conhecidos e undefined para outros tipos. Os consumidores do SDK podem, portanto, lidar com a compatibilidade futura sem exigir uma atualização sincronizada do SDK quando um daemon mais recente adiciona um novo tipo de evento; o reducer da sessão os registra como unrecognizedKnownEventCount.

O wire format está em ../qwen-serve-protocol.md. Esta página é o contrato de payload para cada evento.

Responsabilidades

• Fornecer a fonte única da verdade para o vocabulário de eventos (DAEMON_KNOWN_EVENT_TYPE_VALUES).
• Fornecer um envelope tipado para cada tipo de evento (DaemonEventEnvelope<TType, TData>).
• Fornecer reducers puros (reduceDaemonSessionEvent, reduceDaemonAuthEvent) que projetam um fluxo de eventos no estado de visualização do SDK.
• Transmitir a tag de capacidade typed_event_schema como um sinal informativo. Se a tag estiver ausente, asKnownDaemonEvent ainda faz fallback para unknown.

Vocabulário de eventos

Agrupados por domínio.

Sessão principal

Frames sintéticos no nível do assinante

fullTranscriptAvailable é uma flag booleana de capability, não um tipo literal true. Daemons atuais emitem true quando /session/:id/transcript pode ser usado para paginar a transcrição persistida; daemons mais antigos ou restritos podem emitir false, e clientes devem continuar renderizando o replay limitado normalmente.

Permissões (F3 + base)

Modelos

Guardrails do MCP (PR 14b + F2)

Controle de mutação (Wave 4 PR 16+17)

As APIs de Skill toggle anexam mutation: { id, kind: 'skill_toggle', skills: [{ name, enabled }], activation, sessionsRefreshed, sessionsFailed } opcional. Cada evento skills.disabled / skills.enabled da mesma requisição compartilha um mutation id. Outras gravações de configurações omitem mutation. Gravações do serviço de workspace incluem scope; alguns outros emissores (por exemplo, trocas de modelo da sessão) o omitem. O normalizador do SDK padroniza scope ausente para 'workspace'.

memory_changed também cobre tarefas de memória gerenciada sem sessão. Para esses payloads, scope é "managed", source é um de "workspace_memory_remember", "workspace_memory_forget" ou "workspace_memory_dream", taskId é o id da tarefa na fila e touchedScopes lista os escopos de memória gerenciada que foram alterados ("user" e/ou "project"). Nenhum evento é emitido quando uma tarefa remember/forget/dream é concluída sem alterar a memória gerenciada.

Fluxo de dispositivo de autenticação (PR 21)

Esses eventos têm o workspace como chave, não a sessão. O reducer da sessão os trata como no-ops; reduceDaemonAuthEvent os projeta no estado no nível do workspace.

Mutação em runtime do MCP

Ciclo de vida das extensões

Injeção de mensagem no meio do turno

Ciclo de vida do turno / pushes do assistente

Arquitetura

DaemonSessionViewState

reduceDaemonSessionEvent preenche este estado de visualização. O adaptador CLI TUI, DaemonChannelBridge e a IDE VS Code o consomem. Campos principais:

• alive: boolean - torna-se false após um frame terminal (session_died, session_closed, client_evicted, stream_error).
• currentModelId?: string - de model_switched.
• displayName?: string - de session_metadata_updated.
• recordingDegraded: boolean - estado aderente de gravação de sessão de session_recording_degraded; um valor explícito de session_snapshot.recordingDegraded é autoritativo.
• pendingPermissions: Record<string, DaemonPermissionRequestData> - solicitações abertas com chave requestId; limpo por permission_resolved / permission_already_resolved.
• lastSessionUpdate?: DaemonSessionUpdateData - session_update mais recente.
• lastModelSwitchFailure?: DaemonModelSwitchFailedData - de model_switch_failed.
• terminalEvent? - evento terminal bruto.
• streamError?: DaemonStreamErrorData - payload de stream_error mais recente.
• unrecognizedKnownEventCount, lastUnrecognizedKnownEvent? - o evento foi reconhecido por asKnownDaemonEvent, mas o reducer ainda não tem um estado dedicado para ele.
• droppedPermissionRequestCount, lastDroppedPermissionRequestId? - solicitação de permissão malformada não pôde entrar no mapa de pendentes.
• unmatchedPermissionResolutionCount, lastUnmatchedPermissionResolutionId? - a resolução de permissão não tinha nenhuma solicitação pendente correspondente.
• slowClientWarningCount, lastSlowClientWarning? - de slow_client_warning.
• mcpBudgetWarningCount, lastMcpBudgetWarning? - de mcp_budget_warning.
• mcpChildRefusedBatchCount, lastMcpChildRefusedBatch? - de mcp_child_refused_batch.
• lastWorkspaceMutation?, lastWorkspaceMutationType? - de memory_changed / agent_changed.
• approvalMode?, approvalModeChangedCount, lastApprovalModeChange? - de approval_mode_changed.
• toolToggleCount, lastToolToggle? - de tool_toggled.
• workspaceInitCount, lastWorkspaceInit? - de workspace_initialized.
• mcpRestartCount, lastMcpRestart? - de mcp_server_restarted.
• mcpRestartRefusedCount, lastMcpRestartRefused? - de mcp_server_restart_refused.
• settings_changed / settings_reloaded - reconhecido por asKnownDaemonEvent; o reducer da sessão não mantém campos de estado de visualização dedicados. Eventos settings_changed de Skill-toggle carregam metadados mutation opcionais para que hosts possam aplicar alterações apenas de Skill de forma incremental em vez de recarregar a tarefa. Outras UIs ainda podem tratar o evento como um sinal de atualização.
• permissionVoteProgress: Record<string, DaemonPermissionPartialVoteData> - progresso da votação de consenso.
• forbiddenVotes: DaemonPermissionForbiddenData[], forbiddenVoteCount - registros de votos rejeitados por política, limitados a 32.
• awaitingResync: boolean - definido por state_resync_required; limpo quando o consumidor redefine o estado de visualização.
• resyncRequiredCount, lastResyncRequired? - observabilidade de resync.
• lastFollowupSuggestion?: DaemonFollowupSuggestionData - sugestão de follow-up mais recente enviada pelo daemon.
• lastTurnComplete?: DaemonTurnCompleteData - conclusão de turno bem-sucedida mais recente.
• lastTurnError?: DaemonTurnErrorData - erro de turno mais recente.
• rewindCount, lastRewind?, lastBranch? - eventos de rewind / branch mais recentes.

DaemonAuthState

Uma entrada por providerId, acionada por auth_device_flow_*. Cada fluxo expõe { deviceFlowId, status, providerId, expiresAt?, lastThrottleIntervalMs?, lastError? }.

Fluxo

Lado do produtor

Lado do consumidor (SDK)

Metadados no nível do envelope

Além do payload data de cada evento, o daemon adiciona dois campos no nível do envelope.

_meta.serverTimestamp - relógio do daemon

O EventBus.publish() em packages/acp-bridge/src/eventBus.ts adiciona o _meta.serverTimestamp quando o evento entra no bus. O tipo BridgeEvent inclui _meta?: Record<string, unknown>, então os consumidores internos do daemon veem o _meta em cada evento publicado no bus. O formatSseFrame() em packages/cli/src/serve/routes/sse-events.ts fornece um timestamp de fallback apenas para frames sintéticos (ex.: stream_error) que ignoram o EventBus.publish.

{
  "id": 47,
  "v": 1,
  "type": "session_update",
  "data": { ... },
  "_meta": { "serverTimestamp": 1716287345123 }
}

O merge preserva quaisquer chaves _meta existentes do evento de entrada ({...input._meta, serverTimestamp: Date.now()}). Os produtores podem anexar chaves _meta adicionais no nível do envelope; o EventBus.publish faz o merge delas com o timestamp em vez de sobrescrevê-las.

Por que isso importa: UIs multi-cliente que renderizam tempo relativo ou ordenam blocos de transcrição devem usar o horário do servidor em vez do relógio local de cada navegador/aba/celular. O timestamp do servidor mantém a ordenação consistente entre os clientes.

Acesso pelo SDK: prefira event._meta?.serverTimestamp. Caminhos de compatibilidade também podem verificar event.serverTimestamp ou event.data._meta.serverTimestamp. Não misture o payload ACP data._meta com o envelope _meta do daemon.

originatorClientId

Eventos acionados por uma requisição que carregava um X-Qwen-Client-Id registrado podem adicionar este campo. Veja 08-session-lifecycle.md.

_meta de Tool-call (provenance / serverId)

Isso é separado do _meta do envelope: os payloads ACP session/update podem carregar seu próprio _meta em event.data._meta. O ToolCallEmitter (packages/cli/src/acp-integration/session/emitters/tool-call-emitter.ts) adiciona dois campos em emitStart, emitResult e emitError:

O nome de exibição _meta.toolName existente é preservado. A UI usa esses campos para renderizar badges de builtin / servidor MCP / subagent sem precisar analisar o nome da ferramenta novamente.

Comportamento do reducer do SDK

O reduceDaemonSessionEvent(state, evt) em packages/sdk-typescript/src/daemon/events.ts projeta o stream no DaemonSessionViewState. Os campos relacionados ao resync são:

• awaitingResync: boolean - definido por state_resync_required; o chamador o limpa, tipicamente após POST /session/:id/load redefinir o estado da view.
• resyncRequiredCount: number - contador de observabilidade.
• lastResyncRequired?: DaemonStateResyncRequiredData - payload mais recente.

Enquanto awaitingResync = true, o reducer ignora a aplicação de deltas e permite apenas o conjunto fechado RESYNC_PASSTHROUGH_TYPES:

O lastEventId ainda avança monotonicamente através de advanceLastEventId(base) durante o resync. Após o chamador redefinir e limpar o awaitingResync, os deltas subsequentes se alinham ao cursor correto.

O reduceDaemonAuthEvent projeta eventos de device-flow em entradas de estado de auth no nível do workspace, com a forma de {deviceFlowId, status, providerId, expiresAt?, lastThrottleIntervalMs?, lastError?} conceitualmente. No código, o reducer armazena status, errorKind, hint, intervalMs, lastSeenEventId, authorizedExpiresAt e accountAlias no DaemonDeviceFlowReducerState; os próprios payloads de evento do daemon mantêm as formas por evento listadas acima.

Estado e compatibilidade futura

• Adicione um tipo de evento conhecido anexando-o a DAEMON_KNOWN_EVENT_TYPE_VALUES. SDKs antigos retornam undefined para tipos de evento não reconhecidos através do caminho de fallback e incrementam unrecognizedKnownEventCount; novos SDKs dependem da união discriminada.
• Adicionar campos opcionais a um payload existente é seguro porque os payloads são abertos ({ [key: string]: unknown }).
• Alterar a forma de um payload existente é uma mudança quebrada (breaking change) e deve incrementar o EVENT_SCHEMA_VERSION, além de anunciar uma tag de capacidade compatível, como caps.features.typed_event_schema_v2.
• O id é monotônico por sessão. Frames sintéticos no nível do assinante (client_evicted, slow_client_warning, stream_error, state_resync_required, replay_complete, session_snapshot) intencionalmente não têm id para que outros assinantes não vejam lacunas.
• O originatorClientId fica no envelope em vez de data. Payloads de partial-vote / forbidden do F3 também fazem o merge dele em data através de mergeOriginator, para que os consumidores do estado da view não precisem reter o envelope.

Dependências

• 10-event-bus.md - canal de entrega.
• 11-capabilities-versioning.md - como os SDKs fazem preflight de typed_event_schema, mcp_guardrail_events e permission_mediation.
• 04-permission-mediation.md - como os eventos de permissão são produzidos.
• 13-sdk-daemon-client.md - asKnownDaemonEvent, reducers e forma do estado da view.

Configuração

• Sempre anunciadas: typed_event_schema, mcp_guardrail_events e permission_mediation (com modos de política suportados).
• Nenhuma variável de ambiente ou flag controla diretamente o schema em si. QWEN_SERVE_NO_MCP_POOL=1 altera o scope do evento MCP de 'workspace' para ausente ou 'session'.

Ressalvas e limites conhecidos

• Seis tipos de frame sintéticos intencionalmente não têm id; o código do SDK não deve assumir que todo evento tem um id.
• permission_partial_vote só aparece sob consensus. permission_forbidden aparece sob designated, consensus e local-only, mas não sob first-responder.
• mcp_child_refused_batch só aparece em mode: 'enforce'; o modo warn nunca recusa.
• Os eventos auth_device_flow_* não têm chave de sessão. Ao consumir através do DaemonSessionClient, use reduceDaemonAuthEvent para eles em vez do reducer de sessão.

Referências

• packages/sdk-typescript/src/daemon/events.ts
• packages/acp-bridge/src/eventBus.ts (EVENT_SCHEMA_VERSION)
• packages/cli/src/serve/capabilities.ts (typed_event_schema, mcp_guardrail_events, permission_mediation)
• Referência de wire: ../qwen-serve-protocol.md