Lars
ba17516814
All checks were successful
Deploy mindnet to llm-node / deploy (push) Successful in 3s
55 lines
1.8 KiB
Python
55 lines
1.8 KiB
Python
"""
|
||
app/routers/graph.py — Graph-Endpunkte (WP-04)
|
||
|
||
Zweck:
|
||
Liefert die Nachbarschaft einer Note/ID als JSON-Graph (Nodes/Edges/Stats).
|
||
Kompatibilität:
|
||
Python 3.12+, FastAPI 0.110+, qdrant-client 1.x
|
||
Version:
|
||
0.1.0 (Erstanlage)
|
||
Stand:
|
||
2025-10-07
|
||
Bezug:
|
||
- app/core/graph_adapter.py
|
||
- app/models/dto.py
|
||
Nutzung:
|
||
app.include_router(graph.router, prefix="/graph", tags=["graph"])
|
||
Änderungsverlauf:
|
||
0.1.0 (2025-10-07) – Erstanlage.
|
||
"""
|
||
|
||
from __future__ import annotations
|
||
from typing import List, Optional
|
||
from fastapi import APIRouter, Query
|
||
from qdrant_client import QdrantClient
|
||
from app.models.dto import GraphResponse, NodeDTO, EdgeDTO
|
||
from app.core.graph_adapter import expand
|
||
from app.config import get_settings
|
||
|
||
router = APIRouter()
|
||
|
||
@router.get("/{note_id}", response_model=GraphResponse)
|
||
def get_graph(note_id: str, depth: int = 1, edge_types: Optional[List[str]] = Query(None)) -> GraphResponse:
|
||
s = get_settings()
|
||
client = QdrantClient(url=s.QDRANT_URL, api_key=s.QDRANT_API_KEY)
|
||
|
||
sg = expand(client, s.COLLECTION_PREFIX, [note_id], depth=depth, edge_types=edge_types)
|
||
|
||
# Seed-Node (Payload optional später ergänzen über get_note_payload)
|
||
nodes = [NodeDTO(id=note_id, type="note",
|
||
title=None, tags=[],
|
||
in_degree=sg.in_degree.get(note_id, 0),
|
||
out_degree=sg.out_degree.get(note_id, 0))]
|
||
|
||
# direkte Out-Kanten des Seeds
|
||
edges = []
|
||
for e in sg.adj.get(note_id, []):
|
||
edges.append(EdgeDTO(
|
||
id=f"{note_id}->{e['target']}:{e['kind']}",
|
||
kind=e["kind"], source=note_id, target=e["target"],
|
||
weight=float(e["weight"]), direction="out"
|
||
))
|
||
|
||
return GraphResponse(center_note_id=note_id, nodes=nodes, edges=edges,
|
||
stats={"node_count": len(nodes), "edge_count": len(edges)})
|