aim-core-domain

What problem does it solve?

This skill centralizes the core domain logic required to route and deliver chat messages to the correct gateway nodes, including presence/typing/read-receipt propagation and system updates.

Core Features & Use Cases

• Transfer hot path: validate inputs, enforce idempotency, check message permissions via logic RPC, generate message_id, and publish ordered Kafka events per conversation_id.
• Delivery consumer fan-out: consume Kafka delivery events, resolve target gateway nodes, and push messages to all relevant online members to avoid missing recipients.
• Presence, typing, and read receipts: consume respective Kafka topics and push state updates to the correct target users by routing with node_id and target_user_id semantics.
• Conversation and attachment system events: consume conversation/group event streams and attachment-parsed events, then push system messages to all session members with is_system=true.

Quick Start

Use the aim-core-domain skill to design and verify the end-to-end message transfer and delivery pipeline for a core service that consumes Kafka topics and pushes real-time updates to gateways.