mirror of
https://github.com/melgarafael/DeskcommCRM.git
synced 2026-10-02 01:28:34 +08:00
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>
13 lines
350 B
TypeScript
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,
|
|
};
|