integration.stream.session_ended.v1
Constant
import { EVENT_NAMES } from "@platform/contracts";
EVENT_NAMES.INTEGRATION_STREAM_SESSION_ENDED_V1;Publishers
Subscribers
Payload schema
z.object({
provider: z.literal("stream"),
session_id: z.string(),
brand_id: z.string().nullable(),
stream_call_id: z.string().nullable(),
host_id: z.string().nullable(),
participant_ids: z.array(z.string()).default([]),
ended_at: z.string().datetime(),
payload: z.record(z.unknown()),
}Delivery semantics
- At-least-once delivery. Consumers must dedupe by event ID.
- Fanned out to both NATS (in-cluster) and EventBridge (durable). See Events concept.