graph

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

type CSRGraph struct {
	RowPtr  []int32   // Node adjacency list pointers
	ColIdx  []int32   // Edge destination IDs
	Weights []float32 // Edge weights
	// contains filtered or unexported fields
}

type Edge struct {
	FromID   int64
	ToID     int64
	Relation RelationType
	Weight   float32 // 0.0-1.0, higher = stronger relationship
}

type GraphStats struct {
	EdgeTypes    map[RelationType]int
	AvgDegree    float64
	MedianDegree float64
	NodeCount    int
	EdgeCount    int
	MaxDegree    int
	MinDegree    int
}

type GraphStore interface {
	// Ping checks connectivity to the graph backend.
	Ping(ctx context.Context) error

	// StoreEdge stores a single relation as a graph edge.
	StoreEdge(ctx context.Context, edge RelationEdge) error

	// StoreEdgesBatch stores multiple edges in a single operation.
	StoreEdgesBatch(ctx context.Context, edges []RelationEdge) error

	// GetNeighbors returns multi-hop neighbors of an observation.
	GetNeighbors(ctx context.Context, obsID int64, maxHops int, limit int) ([]Neighbor, error)

	// GetPath returns the shortest path between two observations as a list of IDs.
	GetPath(ctx context.Context, fromID, toID int64) ([]int64, error)

	// SyncFromRelations bulk-loads relations from PostgreSQL into the graph.
	SyncFromRelations(ctx context.Context, relations []*models.ObservationRelation) error

	// GetCluster returns observation IDs in the same cluster as the given node.
	// Uses BFS traversal up to maxNodes results.
	GetCluster(ctx context.Context, nodeID int64, maxNodes int) ([]int64, error)

	// Stats returns graph store statistics.
	Stats(ctx context.Context) (GraphStoreStats, error)

	// Close releases resources held by the graph store.
	Close() error
}

type GraphStoreStats struct {
	NodeCount int
	EdgeCount int
	Provider  string
	Connected bool
}

type Neighbor struct {
	ObsID        int64
	Hops         int
	RelationType models.RelationType
}

type Node struct {
	Metadata    NodeMetadata
	LastAccess  time.Time
	StoredEmb   []float32 // Nil if recomputed on-demand
	ID          int64
	Degree      int // Number of edges (hub detection)
	AccessCount int
}

type NodeMetadata struct {
	CreatedAt    time.Time
	Project      string
	Type         string
	Title        string
	IsSuperseded bool
}

type NoopGraphStore struct{}

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

type RelationEdge struct {
	SourceID     int64
	TargetID     int64
	RelationType models.RelationType // string: "causes", "fixes", etc.
	Confidence   float64
}

type RelationType int