Documentation Index
Fetch the complete documentation index at: https://mintlify.com/QucoonAI/mcsp_docs/llms.txt
Use this file to discover all available pages before exploring further.
Topic Catalogue
All topics use JSON message payloads unless specified otherwise. All messages carry a minimum envelope of { "event_id": "<uuid>", "timestamp": "<iso8601>", "source_service": "<service>", "payload": { ... } }.
Topics prefixed internal. are consumed only within the same service and are not part of the inter-service contract.
| Property | Value |
|---|
| Producer | Upload Service |
| Consumers | Transcoding Worker |
| Partitions | 12 (keyed on upload_session_id) |
| Retention | 7 days |
| Trigger | Final segment of a multipart upload confirmed |
upload_session_id (string) — Unique upload session identifiercontent_id (string) — Pre-assigned content record IDcreator_id (string)s3_raw_key (string) — S3 key of the raw uploaded fileresidency (string) — GLOBAL or NGcontent_type (string) — VIDEO or AUDIO
| Property | Value |
|---|
| Producer | Transcoding Worker |
| Consumers | DRM Packaging Worker, Moderation Worker |
| Partitions | 24 (keyed on content_id) |
| Retention | 7 days |
| Trigger | All transcoding renditions completed successfully |
content_id (string)renditions (array) — List of { resolution, bitrate, s3_key } for each outputaudio_tracks (array) — List of { bitrate, lang, s3_key }duration_seconds (integer)
| Property | Value |
|---|
| Producer | DRM Packaging Worker |
| Consumers | Content Service |
| Partitions | 12 (keyed on content_id) |
| Retention | 7 days |
| Trigger | CMAF dual-encryption packaging complete and manifests written to S3 |
content_id (string)hls_manifest_url (string) — CDN-relative path to .m3u8dash_manifest_url (string) — CDN-relative path to .mpdcek_id (string) — Key store reference for the CEK
| Property | Value |
|---|
| Producer | Content Service |
| Consumers | Notification Service, ML Event Collector (for ANN index update), Creator Dashboard |
| Partitions | 12 (keyed on content_id) |
| Retention | 30 days |
| Trigger | Content record set to PUBLISHED visibility state |
content_id (string)creator_id (string)title (string)content_type (string)categories (array of strings)residency (string)
moderation.flagged
| Property | Value |
|---|
| Producer | Moderation Worker |
| Consumers | Content Service (hold publication), Admin Control Plane (queue review item) |
| Partitions | 6 (keyed on content_id) |
| Retention | 30 days |
| Trigger | Any automated AI moderation check returns a flag above threshold |
content_id (string)creator_id (string)flags (array) — List of { check_type, confidence_score, flagged_timestamp_start, flagged_timestamp_end }queue_priority (string) — STANDARD or ESCALATED
moderation.approved
| Property | Value |
|---|
| Producer | Admin Control Plane (on human reviewer approval) |
| Consumers | Content Service |
| Partitions | 6 (keyed on content_id) |
| Retention | 30 days |
| Trigger | Human reviewer approves a flagged content item |
content_id (string)reviewer_id (string)decision (string) — APPROVED, AGE_GATED, or EDIT_REQUESTED
user.engagement.events
| Property | Value |
|---|
| Producer | Engagement Service |
| Consumers | ML Event Collector (feature store), Creator Dashboard (analytics aggregation) |
| Partitions | 48 (keyed on user_id for ordering of per-user event stream) |
| Retention | 90 days |
| Trigger | Any trackable user action on content |
user_id (string)content_id (string)creator_id (string)event_type (string) — media_started, media_completed, media_liked, media_shared, media_disliked, media_skipped, media_replay, media_added_to_playlistwatch_duration_seconds (integer, nullable) — populated for play eventscontent_type (string) — VIDEO or AUDIOsession_id (string)
engagement.subscription.changed
| Property | Value |
|---|
| Producer | Engagement Service |
| Consumers | Notification Service, Creator Dashboard |
| Partitions | 12 (keyed on creator_id) |
| Retention | 30 days |
| Trigger | User subscribes to or unsubscribes from a creator channel |
user_id (string)creator_id (string)action (string) — SUBSCRIBED or UNSUBSCRIBED
payment.events
| Property | Value |
|---|
| Producer | Billing Service |
| Consumers | Subscription Service, Notification Service |
| Partitions | 12 (keyed on subscriber_id) |
| Retention | 365 days (regulatory) |
| Trigger | Any completed or failed payment attempt |
subscriber_id (string)subscription_id (string)event_type (string) — payment.processed or payment.failedamount (integer) — in lowest denomination (kobo for NGN, cents for USD)currency (string) — NGN or USDprocessor (string) — PAYSTACK or STRIPEprocessor_ref (string) — Provider’s transaction reference
notification.dispatch.requested
| Property | Value |
|---|
| Producer | Content Service, Subscription Service, Billing Service — all via Notification Service API (not directly) |
| Consumer | Notification Service channels (push, email, in-app workers) |
| Partitions | 12 (keyed on user_id) |
| Retention | 3 days |
| Trigger | Notification Service receives a dispatch request from any upstream service |
user_id (string)notification_type (string) — NEW_CONTENT, PAYMENT_FAILED, SUBSCRIPTION_EXPIRING, MODERATION_DECISION, CREATOR_MILESTONEchannels (array) — PUSH, EMAIL, IN_APPtemplate_id (string)template_vars (object)
