wikistore

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

type Store interface {
	// UpsertNode inserts or updates a single node by id (idempotent on conflict).
	UpsertNode(ctx context.Context, node migrate.NodeSpec) (migrate.NodeSpec, error)
	// GetNode returns one node by id, or ErrNodeNotFound.
	GetNode(ctx context.Context, botID, nodeID string) (migrate.NodeSpec, error)
	// ListNodes returns every node for a bot in captured_at ascending order.
	ListNodes(ctx context.Context, botID string) ([]migrate.NodeSpec, error)
	// ListNodesByLayer returns nodes for a bot filtered by layer.
	ListNodesByLayer(ctx context.Context, botID string, layer migrate.MemoryLayer) ([]migrate.NodeSpec, error)
	// DeleteNode removes a node (and its incident edges via ON DELETE CASCADE
	// at the SQL level for bot-scoped rows, plus explicit edge cleanup here).
	DeleteNode(ctx context.Context, botID, nodeID string) error
	// DeleteAllNodes removes every node for a bot (edges removed by the caller
	// or DB cascade).
	DeleteAllNodes(ctx context.Context, botID string) error
	// CountNodes returns the node count for a bot.
	CountNodes(ctx context.Context, botID string) (int, error)

	// UpsertEdges inserts or updates (on conflict) a batch of edges.
	UpsertEdges(ctx context.Context, edges []migrate.EdgeSpec) error
	// ListEdges returns every edge for a bot.
	ListEdges(ctx context.Context, botID string) ([]migrate.EdgeSpec, error)
	// DeleteEdgesForNode removes all edges incident to a node (src or dst).
	DeleteEdgesForNode(ctx context.Context, botID, nodeID string) error
	// DeleteAllEdges removes every edge for a bot.
	DeleteAllEdges(ctx context.Context, botID string) error
	// CountEdges returns the edge count for a bot.
	CountEdges(ctx context.Context, botID string) (int, error)

	// RebuildDerivedEdges recomputes same_profile / same_topic / same_day / refs
	// edges for a bot from its current nodes, replacing any prior derived edges.
	// Returns the number of edges written.
	RebuildDerivedEdges(ctx context.Context, botID string) (int, error)
}