Skip to main content
Glama
varunk61

MCP-Native Enterprise Integration Hub

by varunk61

MCP-Native Enterprise Integration Hub

Überblick

Eine kontrollierte KI-Agentenplattform, die GitHub Issues, Jira und Slack als MCP-Server (Model Context Protocol) bereitstellt. Ein LangGraph-Orchestrierungsagent leitet Anfragen in natürlicher Sprache durch Pydantic-validierte Toolschemas; alle Schreiboperationen müssen vor der Ausführung einen obligatorischen HITL-Genehmigungs-Checkpoint passieren. Jede Agentenentscheidung, jeder Tool-Aufruf und jedes Aktionsergebnis wird für die vollständige Audit-Trail in PostgreSQL gespeichert. Die semantische Suche von PGVector zeigt relevante historische Aktionen, bevor jede neue Aktion geplant wird.

Related MCP server: GitHub Flow MCP

Architektur

graph TD
  User -->|POST /agent/run| FastAPI
  FastAPI --> LangGraph
  LangGraph --> ParseIntent
  ParseIntent --> RetrieveSimilar
  RetrieveSimilar -->|PGVector| PostgreSQL
  RetrieveSimilar --> PlanAction
  PlanAction --> HITLGate
  HITLGate -->|Write op| HITLApproval[(PostgreSQL HITLApproval)]
  HITLGate -->|Read op| ExecuteAction
  ExecuteAction --> GitHubMCP
  ExecuteAction --> JiraMCP
  ExecuteAction --> SlackMCP
  ExecuteAction --> LogRun
  LogRun --> PostgreSQL

Erforderliche OAuth-Scopes

Slack: channels:read, channels:history, chat:write GitHub: repo (für private Repos) oder public_repo Jira: read:jira-work, write:jira-work

Einrichtung

# 1. Clone and enter the project
git clone <repo-url> mcp-enterprise-hub
cd mcp-enterprise-hub

# 2. Create and activate a virtual environment
python3 -m venv venv
source venv/bin/activate

# 3. Install dependencies
pip install -r requirements.txt

# 4. Configure environment variables
cp .env.example .env
# Edit .env and fill in: ANTHROPIC_API_KEY, OPENAI_API_KEY, GITHUB_TOKEN,
# JIRA_API_TOKEN, JIRA_EMAIL, JIRA_BASE_URL, SLACK_BOT_TOKEN

# 5. Start PostgreSQL (with pgvector)
docker compose up -d postgres

# 6. Initialize the database schema
python src/db/init_db.py

# 7. Run the API server
uvicorn src.api.main:app --reload

# 8. (Optional) Run the test suite
docker compose up -d postgres   # test DB is created automatically on first run
pytest --cov=src --cov-report=term-missing tests/

Hinweis zum Portkonflikt: Wenn Sie bereits eine lokale Postgres-Instanz auf Port 5432 laufen haben (häufig unter macOS über Homebrew oder Postgres.app), kann das Port-Mapping von Docker den Wettlauf um diesen Port stillschweigend verlieren — docker compose up -d meldet den Container zwar als gesund, aber localhost:5432 leitet tatsächlich zu Ihrem nativen Postgres, der nicht über die Rolle/Datenbank mcp_enterprise_hub verfügt und mit FATAL: role "postgres" does not exist oder ähnlich fehlschlägt. Stoppen Sie entweder den lokalen Postgres-Dienst oder mappen Sie den Container auf einen freien Port, indem Sie eine docker-compose.override.yml verwenden:

services:
  postgres:
    ports:
      - "5433:5432"

und aktualisieren Sie DATABASE_URL / TEST_DATABASE_URL in .env, um Port 5433 zu verwenden.

Beispiel-API-Aufrufe

1. Leseoperation (GitHub-Issues auflisten) — wird sofort abgeschlossen:

curl -X POST http://localhost:8000/agent/run \
  -H "Content-Type: application/json" \
  -d '{"message": "list open issues in octo/hello"}'
{
  "status": "completed",
  "result": {
    "issues": [
      {"id": 1, "number": 42, "title": "Login button unresponsive", "state": "open", "url": "https://github.com/octo/hello/issues/42"}
    ],
    "metadata": {"is_write": false, "connector": "github", "tool_name": "list_issues"}
  },
  "run_id": "6a9b1a2e-4c9b-4c1e-9c0e-7a1f2b3c4d5e",
  "session_id": "d1e2f3a4-5b6c-7d8e-9f0a-1b2c3d4e5f6a"
}

2. Schreiboperation (Jira-Ticket anlegen) — gibt pending_approval zurück:

curl -X POST http://localhost:8000/agent/run \
  -H "Content-Type: application/json" \
  -d '{"message": "create a Jira ticket in project ABC titled '\''Login button unresponsive on mobile'\''"}'
{
  "status": "pending_approval",
  "approval_id": "9f8e7d6c-5b4a-3c2d-1e0f-a1b2c3d4e5f6",
  "action_plan": {
    "connector": "jira",
    "tool_name": "create_issue",
    "validated_params": {
      "project_key": "ABC",
      "summary": "Login button unresponsive on mobile",
      "description": "Login button unresponsive on mobile",
      "issue_type": "Bug"
    },
    "is_write_operation": true,
    "risk_level": "medium"
  },
  "session_id": "d1e2f3a4-5b6c-7d8e-9f0a-1b2c3d4e5f6a"
}

3. Schreibvorgang genehmigen — führt den Vorgang aus und gibt das Ergebnis zurück:

curl -X POST http://localhost:8000/agent/approve/9f8e7d6c-5b4a-3c2d-1e0f-a1b2c3d4e5f6 \
  -H "Content-Type: application/json" \
  -d '{"reviewer_notes": "Looks good, approved"}'
{
  "status": "approved",
  "result": {
    "key": "ABC-123",
    "url": "https://your-domain.atlassian.net/browse/ABC-123",
    "metadata": {"is_write": true, "connector": "jira", "tool_name": "create_issue"}
  },
  "run_id": "1a2b3c4d-5e6f-7a8b-9c0d-1e2f3a4b5c6d"
}

Testergebnisse

$ pytest --cov=src --cov-report=term-missing tests/

collected 52 items

tests/test_agent.py .............                                        [ 25%]
tests/test_api.py ..................                                     [ 59%]
tests/test_mcp_servers.py .....................                          [100%]

================================ tests coverage ================================
Name                               Stmts   Miss  Cover   Missing
----------------------------------------------------------------
src/__init__.py                        0      0   100%
src/agent/__init__.py                  0      0   100%
src/agent/hitl.py                     29      1    97%   33
src/agent/state.py                    13      0   100%
src/agent/workflow.py                189      5    97%   108, 263-266
src/api/__init__.py                    0      0   100%
src/api/main.py                      209      3    99%   150-152
src/db/__init__.py                     0      0   100%
src/db/database.py                    16      0   100%
src/db/init_db.py                     16     16     0%   1-24
src/db/models.py                      60      0   100%
src/db/vector_search.py                7      0   100%
src/mcp_servers/__init__.py            0      0   100%
src/mcp_servers/common.py             11      0   100%
src/mcp_servers/github_server.py      95      3    97%   7, 175-177
src/mcp_servers/jira_server.py        81      3    96%   7, 168-170
src/mcp_servers/slack_server.py       86      4    95%   7, 144, 161-163
----------------------------------------------------------------
TOTAL                                812     35    96%

52 passed in 2.92s

HITL-Blockrate (gemessen anhand der persistierten Testdatenbank nach einem vollständigen Suite-Lauf, vor der Bereinigung pro Testlauf):

Metrik

Anzahl

Läufe mit Schreibabsicht, die an hitl_gate gelangt sind

9

Läufe, in denen hitl_gate korrekt einen HITLApproval-Datensatz erzeugt hat

9 / 9 (100%)

Tatsächliche MCP-Toolausführungen, die in AuditLog protokolliert wurden

4

Davon ohne vorherige APPROVED-Genehmigung ausgeführt

0

Abgelehnte und nie ausgeführte Schreibvorgänge

2

Jeder Testlauf mit Schreiboperation wurde vom HITL-Gate abgefangen, bevor ein MCP-Toolaufruf ausgelöst werden konnte; keine Ausführung erreichte AuditLog ohne eine passende APPROVED-HITLApproval-Zeile.

Zusammenfassungs-Metriken (zur Referenz)

  • 19 Agentenläufe wurden während der Tests in PostgreSQL persistiert

  • Mehr als 85 % Testabdeckung in den Schichten der MCP-Server, der Agenten und der API

  • HITL hat 100 % der Schreiboperationen in der Test-Suite abgefangen (0 nicht überprüfte Schreibvorgänge ausgeführt)

Maintenance

ActivitySlowing
ResponsivenessNo issues

Related MCP Connectors

Related MCP Servers

  • A
    license
    C
    quality
    B
    maintenance
    A policy-aware MCP server for GitHub and GitHub Actions that enables safe AI-assisted infrastructure workflows—inspecting repositories, preparing branches and pull requests, and constrained remote mutations behind explicit preview-bound approval tokens.
    18
    MIT
  • A
    license
    Not graded
    quality
    B
    maintenance
    An MCP-native agentic platform orchestrating planner/executor/critic agents over hybrid RAG with three-tier memory, budget enforcement, safety guardrails, and full observability. It exposes all capabilities as MCP tools, enabling natural-language control of document ingestion, retrieval-augmented generation, and multi-step AI workflows.
    MIT
  • A
    license
    B
    quality
    B
    maintenance
    A security-first MCP gateway that enables AI assistants to safely inspect and interact with GitHub repositories through a controlled, auditable tool layer with policy enforcement and human approval for mutations.
    27
    MIT