Intelligence, indexing, and pattern services as first-class Omninode nodes
Project description
omniintelligence
Intelligence, pattern learning, code analysis, and evaluation as first-class ONEX (OmniNode eXecution) nodes.
What this repo is
OmniIntelligence is the intelligence platform for the ONEX ecosystem. It provides pattern learning, code quality analysis, evaluation, intent classification, document analysis, CI failure tracking, bloom evaluation, and Claude Code hook processing as 59 first-class ONEX nodes. All nodes follow the ONEX Four-Node Architecture (Effect / Compute / Reducer / Orchestrator) and delegate all business logic to handler modules.
Who uses it
- omniclaude — publishes Claude Code hook events consumed here; subscribes to intelligence events for hook routing
- omnimemory — consumes intent-classified and pattern events for graph and vector storage
- omnidash — projects quality-assessment, bloom-eval, routing-feedback, and pattern events into read-model dashboards
- omnimarket — portable workflow packages invoke intelligence nodes via the ONEX node entry-point registry
What this repo owns
- Pattern learning: extraction, ML learning pipeline, storage, promotion, demotion, lifecycle management
- Code quality scoring and ONEX compliance assessment
- Semantic analysis, AST extraction, and code entity bridging
- Intent classification from Claude Code hook events
- Intent drift detection, cost forecasting, and LLM routing decisions
- Document ingestion, parsing, retrieval, and staleness detection
- CI failure tracking, error classification, and fingerprinting
- Bloom evaluation orchestration and plan multi-model review
- Routing feedback processing and compliance evaluation
- Claude Code hook event processing (
UserPromptSubmit,Stop, and others) - REST API for pattern query by enforcement nodes (
GET /api/v1/patterns)
For the full node list see docs/reference/NODE_INVENTORY.md.
What this repo does not own
| Concern | Canonical owner |
|---|---|
| ONEX kernel, node execution, contracts, validation | omnibase_core |
| Kafka, PostgreSQL, runtime host, registration | omnibase_infra |
| Protocol interfaces | omnibase_spi |
| Portable workflow packages and automation logic | omnimarket |
| Vector and graph storage (Qdrant, Memgraph) | omnimemory |
| Dashboard UI and read-model projection surface | omnidash |
| Claude Code hooks, invocation UX, skills | omniclaude |
Install
uv add omninode-intelligence
Or install from source alongside sibling repos (editable):
uv sync --group all
Common workflows
# Full test suite (required before any PR)
uv run pytest tests/ -v
# Unit tests only (fast, no infrastructure)
uv run pytest tests/ -v -m unit
# Audit tests (AST purity enforcement)
uv run pytest tests/ -v -m audit
# Integration tests (requires Postgres + Kafka on .201)
uv run pytest tests/ -v -m integration
# Lint and format
uv run ruff format src/ tests/
uv run ruff check --fix src/ tests/
# Type check
uv run mypy src/
# Pre-commit (run before staging)
pre-commit run --all-files
# Review calibration CLI
uv run python -m omniintelligence.review_pairing \
--file plan.md --ground-truth codex --challenger deepseek-r1
Architecture summary
OmniIntelligence is built on the ONEX Four-Node Architecture. Nodes are thin shells that delegate all logic to handler modules. Contract YAML files declare event bus subscriptions, publish topics, handler routing, and dependencies — no hardcoded topic strings in Python.
Node types:
| Type | Example nodes | I/O |
|---|---|---|
| Compute (35+) | NodeQualityScoringCompute, NodeIntentClassifierCompute |
None — pure transforms |
| Effect (14+) | NodeClaudeHookEventEffect, NodePatternStorageEffect |
Kafka, PostgreSQL, external APIs |
| Reducer (2) | NodeDocPromotionReducer, NodePolicyStateReducer |
FSM state transitions |
| Orchestrator (2) | NodeBloomEvalOrchestrator, NodePatternAssemblerOrchestrator |
Workflow coordination |
Key pipelines:
- Claude Code Hook → intent classification → omnimemory graph
- Session end (Stop hook) → pattern learning → pattern storage → PostgreSQL
- Pattern promotion/demotion → lifecycle transition → audit trail
- Quality assessment command → scoring compute → quality-assessment-completed → omnidash
Dash integration boundary: omnidash never queries this repo's database directly. All data flows via Kafka topics projected into omnidash_analytics. See docs/reference/DASH_INTEGRATION_TRUTH_BOUNDARY.md for the live/dead/gap status of each topic.
For topology diagrams and full pipeline details see docs/architecture/ONEX_FOUR_NODE_ARCHITECTURE.md.
Documentation map
| Document | Purpose |
|---|---|
| docs/INDEX.md | Canonical docs entrypoint |
| docs/architecture/ONEX_FOUR_NODE_ARCHITECTURE.md | Node topology, data flow, pipeline diagrams |
| docs/reference/NODE_INVENTORY.md | Full node inventory sourced from pyproject.toml |
| docs/reference/EVENT_SURFACE.md | Produced, consumed, dashboard-visible, and deprecated topics |
| docs/reference/DASH_INTEGRATION_TRUTH_BOUNDARY.md | Omnidash integration truth boundary |
| CLAUDE.md | Developer context, invariants, quick reference |
| AGENT.md | LLM navigation guide |
Development and test commands
# Install (all groups including dev)
uv sync --group all
# Full test suite
uv run pytest tests/ -v
# Lint and format
uv run ruff format src/ tests/ && uv run ruff check --fix src/ tests/
# Type check
uv run mypy src/
# Pre-commit
pre-commit run --all-files
Security, contributing, and license
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file omninode_intelligence-0.24.0.tar.gz.
File metadata
- Download URL: omninode_intelligence-0.24.0.tar.gz
- Upload date:
- Size: 2.3 MB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.11.26 {"installer":{"name":"uv","version":"0.11.26","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
19872935e7dfef2a96bd0082c0e966b1ca147a7f3ceb9fa4030147bdb65cf4c6
|
|
| MD5 |
e05c0fbe9b63504475a2d97faab547ec
|
|
| BLAKE2b-256 |
858c138f5f16643416d65352e8bc8ec06d03d45d6f5339509b8b446b87a0e6ec
|
File details
Details for the file omninode_intelligence-0.24.0-py3-none-any.whl.
File metadata
- Download URL: omninode_intelligence-0.24.0-py3-none-any.whl
- Upload date:
- Size: 2.0 MB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: uv/0.11.26 {"installer":{"name":"uv","version":"0.11.26","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
ce21ca2831f493ae834d669f35c59daf2b89e41ebb24c5a44f90709c17d4038d
|
|
| MD5 |
fde502d463a805346d4979815926cea8
|
|
| BLAKE2b-256 |
7c455a54e6ce08b6baf8441b61c26c191bb16e578f84a15d3c1447d80aba637b
|