[jonahgabriel]

Summary

Implements ONEX effect node that handles intent query requests via Kafka, enabling OmniDash to query intent data without direct database access.

• Add get_recent_intents() to AdapterIntentGraph for time-based queries across all sessions
• Add session_ref field to ModelIntentRecord for IntentRecordPayload mapping
• Create intent_query_effect node with contract.yaml, handler, registry
• Support 3 query types: distribution, session, recent
• Add integration and unit tests
• Update omnibase dependencies (core 0.9.4, spi 0.6.0, infra 0.2.3)

Architecture

OmniDash
    → Kafka: dev.omnimemory.intent.query.requested.v1
        → HandlerIntentQuery
            → AdapterIntentGraph (Memgraph)
    ← Kafka: dev.omnimemory.intent.query.response.v1

Files Changed

New Node (src/omnimemory/nodes/intent_query_effect/):

• contract.yaml - ONEX contract definition
• handlers/handler_intent_query.py - Main handler with query routing
• models/model_handler_intent_query_config.py - Configuration model
• utils/util_intent_mapping.py - ModelIntentRecord → IntentRecordPayload mapping
• registry/registry_intent_query_effect.py - DI registry

Modified:

• adapter_intent_graph.py - Added get_recent_intents() method
• model_intent_domain.py - Added session_ref field to ModelIntentRecord
• pyproject.toml - Updated omnibase dependencies

Test plan

• Unit tests pass (6 tests, no Memgraph required)
• Integration tests with Memgraph (requires running instance)
• Verify Kafka event flow end-to-end with OmniDash

Linear

Closes OMN-1504

[linear]

OMN-1504

[coderabbitai]

Warning

Rate limit exceeded

@jonahgabriel has exceeded the limit for the number of commits that can be reviewed per hour. Please wait 0 minutes and 23 seconds before requesting another review.

⌛ How to resolve this issue?

After the wait time has elapsed, a review can be triggered using the @coderabbitai review command as a PR comment. Alternatively, push new commits to this PR.

We recommend that you space out your commits to avoid hitting the rate limit.

🚦 How do rate limits work?

CodeRabbit enforces hourly rate limits for each developer per organization.

Our paid plans have higher rate limits than the trial, open-source and free plans. In all cases, we re-allow further reviews after a brief timeout.

Please see our FAQ for further information.

---

_{Comment @coderabbitai help to get the list of available commands and usage tips.}