元数据图谱服务

src/
├── graph/
│   ├── client.py        # FalkorDB connection singleton
│   ├── ontology.py      # MetaType CRUD + health-score management
│   ├── nodes.py         # ObjectNode CRUD + bulk ingest
│   ├── edges.py         # StigmergicEdge CRUD, reinforce, decay, cascading wither
│   ├── decay.py         # Decay runner (single edge + full-graph sweep)
│   ├── query.py         # Bounded traversal (1-2 hops) + flat scan + pagination
│   └── schema.py        # Graph schema helpers
├── dashboard/           # Visual web dashboard API (FastAPI, port 8080)
│   ├── api.py           # App factory; mounts static files; /health + /api/graph + /api/health
│   ├── auth.py          # JWT Bearer decode; DashboardUser dependency; 401/403
│   ├── router.py        # GET /api/graph route (scoped, read-only)
│   ├── health_router.py # GET /api/health/meta-types — USL enforced at constructor level
│   ├── health_service.py# HealthService: colour-band computation, DASHBOARD_NODE_LIMIT cap
│   ├── security.py      # Unified Security Layer: derive_session_id, AuditService, unified_security
│   ├── graph_service.py # DashboardGraphService — wraps query.py; 500-node cap
│   ├── models.py        # Pydantic response models (GraphNodeResponse, HealthPayloadResponse, ...)
│   ├── config.py        # Env-var loading (DASHBOARD_JWT_SECRET, DASHBOARD_PORT, ...)
│   └── server.py        # uvicorn entrypoint (port 8080)
├── models/
│   ├── base.py          # Pydantic models for all graph entities
│   ├── dynamic.py       # Runtime model factory (pydantic.create_model)
│   └── serialization.py # TOON compact serialiser / paginator
├── mcp_server/
│   ├── app.py           # FastMCP singleton
│   ├── server.py        # Entry point — registers all tools, calls mcp.run()
│   ├── formatters/
│   │   └── toon.py      # TOON compact format helpers
│   └── tools/
│       ├── ingestion.py # insert_node, bulk_ingest_seed (circuit breaker)
│       ├── ontology.py  # register_meta_type, list_meta_types_tool
│       ├── stigmergy.py # create_stigmergic_edge, reinforce_stigmergic_edge
│       ├── query.py     # query_graph
│       ├── lifecycle.py # deprecate_node, branch_node_for_domain, request/confirm deletion
│       ├── healing.py   # suggest_schema_heals, confirm_schema_heal
│       └── functions.py # create_function, query_functions, attach_function_to_nodes
└── utils/
    ├── logging.py       # Logger + error class hierarchy
    └── context.py       # RequestContext (profile, domain, prompt hash, session)

dashboard/               # Frontend static assets (served by the dashboard API)
├── index.html           # Single-page app shell; loads Cytoscape.js 3.x from CDN
├── app.js               # Canvas render, node click/dim, filter panel, search, edge tooltips,
│                        #   schema health panel (colour-band indicators, refresh, degraded state)
└── style.css            # Full-height dark-theme layout; confidence_score edge encoding;
                         #   health indicator colour classes (.health-green/amber/red)

scripts/
└── bootstrap_indices.py # Create FalkorDB indices on HumanAuditLog (profile_id, timestamp)

tests/
├── conftest.py
├── unit/
│   ├── dashboard/
│   │   ├── test_auth.py              # JWT auth (401/403, expired, missing claims)
│   │   ├── test_graph_service.py     # Scope enforcement, 500-node cap, confidence clamp
│   │   ├── test_health_service.py    # Health band boundaries, truncation, error handling
│   │   ├── test_unified_security.py  # USL: derive_session_id, audit write, 401/403/503
│   │   └── test_performance.py       # SC-002 serialisation <=1.5s, SC-005 filter <=50ms
│   ├── test_ontology.py
│   ├── test_ingestion.py
│   ├── test_stigmergy.py
│   ├── test_decay.py
│   ├── test_domain_scoping.py
│   ├── test_function_object_model.py
│   ├── test_remaining_rules.py
│   └── test_serialization.py
├── integration/
│   ├── test_dashboard_api.py         # Scope isolation, health endpoint, audit, degraded state
│   └── test_function_objects_e2e.py
└── contract/
    ├── test_dashboard_mutations.py   # Assert zero WRITE Cypher ops from any dashboard route
    └── test_health_mutations.py      # Static-analysis contract: no mutation Cypher in health code

python -m src.mcp_server.server

INFO: src.graph.client: Connecting to FalkorDBLite at localhost:6379
INFO: src.mcp_server.server: [FastMCP] MCP tools registered: 17
INFO: uvicorn.server: Uvicorn running on http://127.0.0.1:8000

export DASHBOARD_JWT_SECRET="your-secret-here"
python -m src.dashboard.server

# Terminal 1: start FalkorDBLite
docker run -p 6379:6379 -it --rm falkordb/falkordb

# Terminal 2: start the MCP server (port 8000)
python -m src.mcp_server.server

# Terminal 3: start the visual dashboard (port 8080)
export DASHBOARD_JWT_SECRET="my-super-secret"
python -m src.dashboard.server

import jwt, datetime

token = jwt.encode(
    {
        "profile_id": "user_alice",
        "domain_scope": "Finance",
        "exp": datetime.datetime.utcnow() + datetime.timedelta(hours=8),
    },
    "my-super-secret",
    algorithm="HS256",
)
print(token)

{
  "mcpServers": {
    "glossary-weaver": {
      "url": "http://127.0.0.1:8000/sse"
    }
  }
}

{
  "mcpServers": {
    "glossary-weaver": {
      "command": "python",
      "args": ["-m", "src.mcp_server.server"],
      "cwd": "/absolute/path/to/generic_database_metadata_mcp",
      "env": {
        "FALKORDB_HOST": "localhost",
        "FALKORDB_PORT": "6379"
      }
    }
  }
}

{
  "servers": {
    "glossary-weaver": {
      "type": "sse",
      "url": "http://127.0.0.1:8000/sse"
    }
  }
}

{
  "github.copilot.chat.mcp.servers": {
    "glossary-weaver": {
      "type": "sse",
      "url": "http://127.0.0.1:8000/sse"
    }
  }
}

{
  "mcpServers": {
    "glossary-weaver": {
      "httpUrl": "http://127.0.0.1:8000/sse",
      "timeout": 30000
    }
  }
}

gemini

/tools

npx @modelcontextprotocol/inspector

{
  "tool": "register_meta_type",
  "arguments": {
    "name": "Dashboard",
    "type_category": "NODE",
    "schema_definition": {
      "url": {"type": "string", "required": true},
      "owner": {"type": "string"}
    }
  }
}

{
  "tool": "query_graph",
  "arguments": {
    "meta_type_name": "Dashboard",
    "domain_scope": "Finance",
    "page": 0,
    "page_size": 5
  }
}

{
  "tool": "deprecate_node",
  "arguments": {
    "node_id": "node_uuid",
    "profile_id": "user_alice",
    "reason": "Node is no longer used in this domain"
  }
}

{
  "tool": "branch_node_for_domain",
  "arguments": {
    "source_node_id": "node_uuid",
    "target_domain_scope": "Finance",
    "profile_id": "user_alice",
    "domain_scope": "Global"
  }
}

from src.graph.decay import run_all_decay
result = run_all_decay()
# {"processed": 42, "pruned": 3}

# All tests (requires FalkorDB running)
pytest tests/ -v

# Dashboard tests only (no live FalkorDB needed)
pytest tests/unit/dashboard/ tests/contract/ tests/integration/test_dashboard_api.py -v

ruff check src/ tests/
mypy src/