API ReferenceEvent Referenceintegration.stream.session_ended.v1

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.