mcp

type HandlerRegistrar interface {
	RegisterHandlers(mux *http.ServeMux)
}

type JWTValidator interface {
	ValidateAccessToken(tokenString string) bool
}

type Pipeline interface {
	// Write persists content through the WAL -> queue -> destination pipeline.
	// Returns a WriteResult containing the assigned payload_id on success.
	Write(ctx context.Context, params WriteParams) (WriteResult, error)

	// Search executes the 6-stage retrieval cascade and returns matching records.
	Search(ctx context.Context, params SearchParams) (SearchResult, error)

	// Status returns the current daemon health and queue state.
	Status(ctx context.Context) (StatusResult, error)
}

type SearchParams struct {
	// Source is the source name resolved from MCPConfig.SourceName.
	Source string

	// Q is a free-text content filter (optional).
	Q string

	// Destination is the target destination name (optional).
	Destination string

	// Subject is a subject filter (optional; empty means all subjects).
	Subject string

	// Limit is the maximum number of results to return (optional; 0 -> default 20).
	Limit int

	// Profile is the retrieval profile: "fast", "balanced", or "deep" (optional).
	Profile string
}

type SearchResult struct {
	Records             []destination.TranslatedPayload `json:"records"`
	HasMore             bool                            `json:"has_more"`
	NextCursor          string                          `json:"next_cursor,omitempty"`
	RetrievalStage      int                             `json:"retrieval_stage"`
	SemanticUnavailable bool                            `json:"semantic_unavailable,omitempty"`
}

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

type StatusResult struct {
	Status     string `json:"status"`
	Version    string `json:"version"`
	QueueDepth int    `json:"queue_depth"`
}

type TestPipeline struct{}

type WriteParams struct {
	// Source is the source name resolved from MCPConfig.SourceName. Set by the
	// server before calling pipeline.Write -- never supplied by the MCP client.
	Source string

	// Content is the memory text to persist (required).
	Content string

	// Subject is the subject namespace for the memory (optional).
	Subject string

	// Collection is the destination collection (optional).
	Collection string

	// Destination is the target destination name (optional; pipeline may use source default).
	Destination string

	// ActorType is "user", "agent", or "system" (optional).
	ActorType string

	// ActorID is the identity of the actor writing the memory (optional).
	ActorID string
}

type WriteResult struct {
	PayloadID string `json:"payload_id"`
	Status    string `json:"status"`
}