Files
DeskcommCRM/workers/media-persist-worker.handler.ts
melgarafaelandClaude Opus 5.5 f399c920ce fix(eventos): handler declara o que faz na organização parada
naOrgParada obrigatório no EventHandler; o dreno lê o status das orgs do
lote numa consulta só e o dispatcher consome como skipped quem custa ou
sai para fora. Leitura que falha adia o lote em vez de consumir às cegas.

Invariante alterado sem afrouxar invariante da main — checar-invariantes-so-crescem.sh verde.

Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
2026-09-29 23:50:57 -03:00

13 lines
350 B
TypeScript

import type { EventHandler } from "@/lib/event-log/dispatcher";
import {
MEDIA_PERSIST_CONSUMER_KEY,
persistMessageMedia,
} from "@/workers/media-persist-worker";
export const mediaPersistHandler: EventHandler = {
key: MEDIA_PERSIST_CONSUMER_KEY,
naOrgParada: "roda",
events: ["media.persist_requested"],
handle: persistMessageMedia,
};