// Deliver real-time websocket updates for intent, quote, negotiation, order, and payment events. Use when implementing push channels, subscription authorization, and connection/session lifecycle for market clients.
Writers Room Story Engine mega-skill. Creates, structures, drafts, and revises compelling standalone stories from zero using premise generation, audience engagement, thematic design, character arcs, Story Spine structure, causal beats, worldbuilding in service of story, scene construction, and revision diagnostics. Use when developing short stories, standalone fiction, scripts, or narrative concepts from scratch or when improving weak drafts.
Adaptive RAG 引擎 — 从线性检索到自主认知循环。集成胶囊预筛选、智能路由、CRAG纠错、L3校验。当需要搜索记忆/检索信息/回答复杂问题时触发。关键词：RAG、检索、记忆搜索、向量检索、Agentic RAG、CRAG。
Adopt a virtual Drift AI-native pet at animalhouse.ai. Wanders between states. Location is never the same twice. Feeding every 6 hours. Common tier creature.
Complete methodology for building production-grade React applications with architecture decisions, component design, state management, performance optimization, testing, and deployment.
Control Android over LAN without USB, ADB, or root.
Proactive agile metrics and team health analysis for Trello and Jira boards. Computes cycle time, throughput, WIP, sprint burndown, aging work items, and blocker detection. Use when: analyzing sprint/board health, generating agile reports, checking team flow metrics, identifying bottlenecks, computing cycle time or throughput, reviewing WIP limits, detecting stale or blocked items, or creating sprint health summaries. Triggers on: how is the sprint going, board health, cycle time, throughput, burndown, agile metrics, team flow, WIP, blocked items, sprint report, agile health check.
| name | a2a-market-websocket-realtime |
| description | Deliver real-time websocket updates for intent, quote, negotiation, order, and payment events. Use when implementing push channels, subscription authorization, and connection/session lifecycle for market clients. |
Set up realtime delivery skeleton for buyer and operator clients.
Current status: publishable framework with stable event contracts, not full scale tuning.
app/interfaces/ws/socket_gateway.pyapp/application/services/realtime_service.pyapp/infrastructure/ws/connection_registry.pyapp/infrastructure/cache/replay_cursor_store.pysubscribe(channel, cursor) validates permission and registers stream.publish_event(channel, event) fans out to online subscribers.resume(channel, cursor) replays missed events within retention window.heartbeat(connection_id) updates liveness and cleanup scheduling.INTENT_CREATEDQUOTE_RECEIVEDNEGOTIATION_STARTEDORDER_CREATEDPAYMENT_SUCCEEDEDruntime/src/interfaces/ws/event-bus.jsruntime/tests and npm test in runtime/.