graph

type GraphHandler ¶

type GraphHandler struct {
	handler.Base
	// contains filtered or unexported fields
}

GraphHandler serves GET /api/v1/graph.

Query params (the frozen v1 contract the browser Graph Explorer already speaks):

• (none) -> the whole knowledge graph
• ?level=projects -> skeleton: project nodes + project->project edges only
• ?select=<terms> -> scoped neighborhood (graph export --select semantics)
• ?flavor=targets -> the describe/target graph (types.TargetGraphOutput)

At most one of flavor/level/select may be set; combinations are rejected. Knowledge-graph flavors are written as magus.graph.v1alpha1 protojson (snake_case, wire-compatible). The targets flavor has no proto twin and is written as its domain JSON. ETag is sha256 of the body; If-None-Match yields a 304. Gzip is applied by the NewGraphHandler wrapper.

func NewGraphHandler(src graphSource, log *slog.Logger) *GraphHandler

type Service ¶ added in v0.4.0

type Service struct {
	// contains filtered or unexported fields
}

Service implements graphv1alpha1connect.GraphServiceHandler over the workspace knowledge graph. Every RPC is read-only; the daemon mounts it behind the console read bearer.

func NewService(ws resolver) *Service

func (s *Service) ExplainNode(
	ctx context.Context, req *connect.Request[graphv1.ExplainNodeRequest],
) (*connect.Response[graphv1.NodeContext], error)

func (s *Service) FindAffected(
	ctx context.Context, req *connect.Request[graphv1.FindAffectedRequest],
) (*connect.Response[graphv1.Affected], error)

func (s *Service) FindDependents(
	ctx context.Context, req *connect.Request[graphv1.FindDependentsRequest],
) (*connect.Response[graphv1.Dependents], error)

func (s *Service) FindPath(
	ctx context.Context, req *connect.Request[graphv1.FindPathRequest],
) (*connect.Response[graphv1.Path], error)

func (s *Service) GetGraphStats(
	ctx context.Context, req *connect.Request[graphv1.GetGraphStatsRequest],
) (*connect.Response[graphv1.GraphStats], error)

func (s *Service) QueryNodes(
	ctx context.Context, req *connect.Request[graphv1.QueryNodesRequest],
) (*connect.Response[graphv1.QueryNodesResponse], error)

func (s *Service) ResolveNodes(
	ctx context.Context, req *connect.Request[graphv1.ResolveNodesRequest],
) (*connect.Response[graphv1.ResolveNodesResponse], error)