# akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform architecture

> Architecture diagram of the GitHub repository akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform, generated by GitDiagram from its file tree, README and a sample of source files (last updated 2026-09-25). It is an AI-made overview: check details against the source.

- Interactive diagram: https://gitdiagram.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform
- Repository: https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform

## Overview

NexusAgent accepts enterprise questions through a web workbench or API, manages session context and security, routes work to knowledge, data, or joint-risk skills, and reviews evidence before returning a grounded answer or clarification. Its knowledge branch combines clause-aware retrieval with citations; its data branch plans and guards read-only SQL over an enterprise database. The graph follows README-documented orchestration and capabilities, supplemented by sampled API, retrieval, planning, context, and query-service code; unsampled subsystem wiring is shown only where documented.

Main entry points: [`src/decision_agent/application/executor.py`](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/application/executor.py) (Request Executor), [`src/decision_agent/retrieval/pipeline.py`](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/pipeline.py) (Hybrid Retrieval), [`src/decision_agent/coordination/coordinator.py`](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/coordination/coordinator.py) (Skill Coordinator), [`src/decision_agent/routing/request_router.py`](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/routing/request_router.py) (Request Router)

## Diagram (Mermaid)

```mermaid
flowchart TD

subgraph group_serving["Serving and Runtime"]
  node_workbench["Web Workbench<br/>[app.js]"]
  node_api["FastAPI Gateway<br/>[app.py]"]
  node_routes["Agent API Route<br/>[routes.py]"]
  node_executor["Request Executor<br/>[executor.py]"]
end

subgraph group_orchestration["Context and Orchestration"]
  node_context["Context Manager<br/>[manager.py]"]
  node_session[("Session Store<br/>[store.py]")]
  node_security["Security Policies<br/>[policy.py]"]
  node_router["Request Router<br/>[request_router.py]"]
  node_coordinator["Skill Coordinator<br/>[coordinator.py]"]
end

subgraph group_knowledge["Knowledge Retrieval"]
  node_knowledge_skill["Knowledge QA Skill"]
  node_retrieval["Hybrid Retrieval<br/>[pipeline.py]"]
  node_milvus[("Milvus Vector Store<br/>[milvus_store.py]")]
  node_bm25["BM25 Search<br/>[bm25.py]"]
  node_fusion["Rank Fusion<br/>[fusion.py]"]
  node_reranking["Cross-Encoder Reranker<br/>[reranking.py]"]
  node_expansion["Parent Expansion"]
  node_ingestion["Clause-Aware Ingestion"]
end

subgraph group_data["Guarded Data Access"]
  node_data_skill["Data Analysis Skill"]
  node_planner["Data Query Planner"]
  node_mcp_client["MCP Data Client"]
  node_mcp_server["MCP Data Server"]
  node_safe_query["Safe Query Service"]
  node_sql_guard["SQL AST Guard<br/>[sql_guard.py]"]
  node_database[("Enterprise SQL Database")]
end

subgraph group_review["Evidence and Decisions"]
  node_joint_skill["Inventory Risk Diagnosis"]
  node_synthesizer["Risk Policy Synthesizer"]
  node_reviewer["Answerability Reviewer"]
  node_answer["Grounded Answer<br/>[grounded_answer.py]"]
end

node_user(("Enterprise User"))
node_provider{{"LLM Provider"}}
node_result["Verified Result or Clarification"]

node_user -->|"submits question"| node_workbench
node_workbench -->|"sends request"| node_api
node_user -->|"calls API"| node_api
node_api -->|"dispatches request"| node_routes
node_routes -->|"executes request"| node_executor
node_executor -->|"selects context"| node_context
node_context -->|"loads and saves"| node_session
node_executor -->|"checks scope"| node_security
node_executor -->|"routes question"| node_router
node_router -.->|"requests route"| node_provider
node_router -->|"returns route"| node_coordinator
node_coordinator -->|"dispatches knowledge"| node_knowledge_skill
node_coordinator -->|"dispatches data"| node_data_skill
node_coordinator -->|"dispatches mixed work"| node_joint_skill
node_knowledge_skill -->|"retrieves evidence"| node_retrieval
node_retrieval -->|"dense search"| node_milvus
node_retrieval -->|"lexical search"| node_bm25
node_retrieval -->|"fuses rankings"| node_fusion
node_retrieval -->|"reranks candidates"| node_reranking
node_retrieval -->|"expands context"| node_expansion
node_ingestion -->|"indexes chunks"| node_milvus
node_data_skill -->|"plans query"| node_planner
node_planner -.->|"requests plan"| node_provider
node_data_skill -->|"requests data"| node_mcp_client
node_mcp_client -->|"calls MCP tools"| node_mcp_server
node_mcp_server -->|"executes query"| node_safe_query
node_safe_query -->|"authorizes SQL"| node_sql_guard
node_safe_query -->|"runs read-only SQL"| node_database
node_joint_skill -->|"synthesizes risks"| node_synthesizer
node_executor -->|"reviews evidence"| node_reviewer
node_reviewer -->|"grounds response"| node_answer
node_executor -->|"returns outcome"| node_result

click node_workbench "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/web/app.js"
click node_api "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/api/app.py"
click node_routes "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/api/routes.py"
click node_executor "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/application/executor.py"
click node_context "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/context/manager.py"
click node_session "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/memory/store.py"
click node_security "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/security/policy.py"
click node_router "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/routing/request_router.py"
click node_coordinator "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/coordination/coordinator.py"
click node_knowledge_skill "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/enterprise_knowledge_qa.py"
click node_retrieval "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/pipeline.py"
click node_milvus "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/milvus_store.py"
click node_bm25 "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/bm25.py"
click node_fusion "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/fusion.py"
click node_reranking "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/reranking.py"
click node_expansion "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/parent_expansion.py"
click node_ingestion "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/ingestion/clause_aware_chunking.py"
click node_data_skill "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/enterprise_data_analysis.py"
click node_planner "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/data_query_planner.py"
click node_mcp_client "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/mcp_client/enterprise_data_client.py"
click node_mcp_server "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/mcp_server/enterprise_data_server.py"
click node_safe_query "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/data/safe_query_service.py"
click node_sql_guard "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/data/sql_guard.py"
click node_joint_skill "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/inventory_risk_diagnosis.py"
click node_synthesizer "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/inventory_risk_synthesizer.py"
click node_reviewer "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/answerability_reviewer.py"
click node_answer "https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/grounded_answer.py"

classDef toneNeutral fill:#f8fafc,stroke:#334155,stroke-width:1.5px,color:#0f172a
classDef toneBlue fill:#dbeafe,stroke:#2563eb,stroke-width:1.5px,color:#172554
classDef toneAmber fill:#fef3c7,stroke:#d97706,stroke-width:1.5px,color:#78350f
classDef toneMint fill:#dcfce7,stroke:#16a34a,stroke-width:1.5px,color:#14532d
classDef toneRose fill:#ffe4e6,stroke:#e11d48,stroke-width:1.5px,color:#881337
classDef toneIndigo fill:#e0e7ff,stroke:#4f46e5,stroke-width:1.5px,color:#312e81
classDef toneTeal fill:#ccfbf1,stroke:#0f766e,stroke-width:1.5px,color:#134e4a
class node_workbench,node_api,node_routes,node_executor,node_user toneBlue
class node_context,node_session,node_security,node_router,node_coordinator toneAmber
class node_knowledge_skill,node_retrieval,node_milvus,node_bm25,node_fusion,node_reranking,node_expansion,node_ingestion toneMint
class node_data_skill,node_planner,node_mcp_client,node_mcp_server,node_safe_query,node_sql_guard,node_database toneRose
class node_joint_skill,node_synthesizer,node_reviewer,node_answer,node_provider,node_result toneIndigo
```

## Components

### Serving and Runtime

- [Web Workbench](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/web/app.js): `src/decision_agent/web/app.js`
- [FastAPI Gateway](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/api/app.py): `src/decision_agent/api/app.py`
- [Agent API Route](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/api/routes.py): `src/decision_agent/api/routes.py`
- [Request Executor](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/application/executor.py): `src/decision_agent/application/executor.py`

### Context and Orchestration

- [Context Manager](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/context/manager.py): `src/decision_agent/context/manager.py`
- [Session Store](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/memory/store.py): `src/decision_agent/memory/store.py`
- [Security Policies](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/security/policy.py): `src/decision_agent/security/policy.py`
- [Request Router](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/routing/request_router.py): `src/decision_agent/routing/request_router.py`
- [Skill Coordinator](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/coordination/coordinator.py): `src/decision_agent/coordination/coordinator.py`

### Knowledge Retrieval

- [Knowledge QA Skill](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/enterprise_knowledge_qa.py): `src/decision_agent/skills/enterprise_knowledge_qa.py`
- [Hybrid Retrieval](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/pipeline.py): `src/decision_agent/retrieval/pipeline.py`
- [Milvus Vector Store](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/milvus_store.py): `src/decision_agent/retrieval/milvus_store.py`
- [BM25 Search](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/bm25.py): `src/decision_agent/retrieval/bm25.py`
- [Rank Fusion](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/fusion.py): `src/decision_agent/retrieval/fusion.py`
- [Cross-Encoder Reranker](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/reranking.py): `src/decision_agent/retrieval/reranking.py`
- [Parent Expansion](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/retrieval/parent_expansion.py): `src/decision_agent/retrieval/parent_expansion.py`
- [Clause-Aware Ingestion](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/ingestion/clause_aware_chunking.py): `src/decision_agent/ingestion/clause_aware_chunking.py`

### Guarded Data Access

- [Data Analysis Skill](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/enterprise_data_analysis.py): `src/decision_agent/skills/enterprise_data_analysis.py`
- [Data Query Planner](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/data_query_planner.py): `src/decision_agent/agents/data_query_planner.py`
- [MCP Data Client](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/mcp_client/enterprise_data_client.py): `src/decision_agent/mcp_client/enterprise_data_client.py`
- [MCP Data Server](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/mcp_server/enterprise_data_server.py): `src/decision_agent/mcp_server/enterprise_data_server.py`
- [Safe Query Service](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/data/safe_query_service.py): `src/decision_agent/data/safe_query_service.py`
- [SQL AST Guard](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/data/sql_guard.py): `src/decision_agent/data/sql_guard.py`
- **Enterprise SQL Database**

### Evidence and Decisions

- [Inventory Risk Diagnosis](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/inventory_risk_diagnosis.py): `src/decision_agent/skills/inventory_risk_diagnosis.py`
- [Risk Policy Synthesizer](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/skills/inventory_risk_synthesizer.py): `src/decision_agent/skills/inventory_risk_synthesizer.py`
- [Answerability Reviewer](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/answerability_reviewer.py): `src/decision_agent/agents/answerability_reviewer.py`
- [Grounded Answer](https://github.com/akgithub2028/nexusagent-enterprise-autonomous-multi-agent-decision-intelligence-platform/blob/main/src/decision_agent/agents/grounded_answer.py): `src/decision_agent/agents/grounded_answer.py`

### Other components

- **Enterprise User**
- **LLM Provider**
- **Verified Result or Clarification**

## Connections

- Enterprise User → Web Workbench: submits question
- Web Workbench → FastAPI Gateway: sends request
- Enterprise User → FastAPI Gateway: calls API
- FastAPI Gateway → Agent API Route: dispatches request
- Agent API Route → Request Executor: executes request
- Request Executor → Context Manager: selects context
- Context Manager → Session Store: loads and saves
- Request Executor → Security Policies: checks scope
- Request Executor → Request Router: routes question
- Request Router → LLM Provider: requests route
- Request Router → Skill Coordinator: returns route
- Skill Coordinator → Knowledge QA Skill: dispatches knowledge
- Skill Coordinator → Data Analysis Skill: dispatches data
- Skill Coordinator → Inventory Risk Diagnosis: dispatches mixed work
- Knowledge QA Skill → Hybrid Retrieval: retrieves evidence
- Hybrid Retrieval → Milvus Vector Store: dense search
- Hybrid Retrieval → BM25 Search: lexical search
- Hybrid Retrieval → Rank Fusion: fuses rankings
- Hybrid Retrieval → Cross-Encoder Reranker: reranks candidates
- Hybrid Retrieval → Parent Expansion: expands context
- Clause-Aware Ingestion → Milvus Vector Store: indexes chunks
- Data Analysis Skill → Data Query Planner: plans query
- Data Query Planner → LLM Provider: requests plan
- Data Analysis Skill → MCP Data Client: requests data
- MCP Data Client → MCP Data Server: calls MCP tools
- MCP Data Server → Safe Query Service: executes query
- Safe Query Service → SQL AST Guard: authorizes SQL
- Safe Query Service → Enterprise SQL Database: runs read-only SQL
- Inventory Risk Diagnosis → Risk Policy Synthesizer: synthesizes risks
- Request Executor → Answerability Reviewer: reviews evidence
- Answerability Reviewer → Grounded Answer: grounds response
- Request Executor → Verified Result or Clarification: returns outcome