server

type ACPAuthMethod struct {
	ID          string
	Name        string
	Description string
	Scheme      string
}

type ClientBridge struct {

	// Caps is protected by mu; use GetCaps/SetCaps from concurrent handlers.
	Caps ClientCapabilities
	// contains filtered or unexported fields
}

type ClientCapabilities struct {
	ElicitationForm bool
	ElicitationURL  bool
	VFSTokenRefresh bool
}

type ConfigOption struct {
	ID           string              `json:"id"`
	Name         string              `json:"name"`
	Description  string              `json:"description,omitempty"`
	Category     string              `json:"category"`
	Type         string              `json:"type"`
	CurrentValue string              `json:"currentValue"`
	Options      []ConfigOptionValue `json:"options"`
}

type ConfigOptionValue struct {
	Value       string `json:"value"`
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
}

type Conn struct {
	Writer   MessageWriter
	RPC      *ClientBridge
	Security *tacklrsecurity.Context
	// contains filtered or unexported fields
}

type Connection struct {
	ID     string
	Bridge *ClientBridge
	Writer MessageWriter
	// contains filtered or unexported fields
}

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

type ElicitationResult struct {
	Action  string         `json:"action"`
	Content map[string]any `json:"content"`
}

type HTTPAttemptExtractor func(*http.Request) (tacklrsecurity.Attempt, bool)

type HTTPRoute struct {
	Method               string // e.g. "POST"
	Pattern              string // e.g. "/acp"
	AllowUnauthenticated bool
	Handler              func(env ProtocolEnv, w http.ResponseWriter, r *http.Request)
}

type InterruptEventEnvelope struct {
	InterruptId string          `json:"interruptId"`
	Type        string          `json:"type"`
	Data        json.RawMessage `json:"data"`
}

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

type MessageWriter interface {
	WriteResult(id json.RawMessage, result any) error
	// WriteError writes a failure. Implementations should use PublicError /
	// JSONRPCErrorCode so internal details are not leaked on the wire.
	WriteError(id json.RawMessage, err error) error
	WriteFrame(data []byte) error
}

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

type PromptOrResume struct {
	Prompt durable.Prompt
	Resume *durable.Resume
	After  durable.Seq
}

type Protocol interface {
	// HandleInbound decodes one connection-oriented body (WebSocket or unary HTTP).
	// HTTP-route-only protocols may return nil.
	HandleInbound(ctx context.Context, env ProtocolEnv, body []byte) error
	HTTPRoutes() []HTTPRoute

	OnStreamEvent(ctx context.Context, env ProtocolEnv, threadID string, ev tacklr.StreamEvent, reqID json.RawMessage) StreamControl
	OnStreamClosed(ctx context.Context, env ProtocolEnv, threadID string, reqID json.RawMessage, cancelled bool) error
}

type ProtocolEnv struct {
	Runtime durable.Runtime
	Catalog durable.Catalog
	Conn    *Conn
	// Security is protocol-neutral. Implementations map wire credentials into
	// this service and store the resulting Context on Conn.
	Security *tacklrsecurity.Service
	// Connections is optional connection tracking (ACP Streamable HTTP uses it).
	// Custom protocols may leave it unused.
	Connections *ConnectionRegistry
}

type ProtocolWireStore interface {
	Put(ctx context.Context, sessionID string, payload []byte) error
	Get(ctx context.Context, sessionID string) ([]byte, error)
	Delete(ctx context.Context, sessionID string) error
}

type RequestPermissionResult struct {
	Outcome struct {
		Outcome  string `json:"outcome"`
		OptionID string `json:"optionId,omitempty"`
	} `json:"outcome"`
}

type Server struct {
	Runtime   durable.Runtime
	Catalog   durable.Catalog
	Protocols []Protocol
	// Connections tracks ACP Streamable HTTP / WebSocket connections.
	// Custom protocols may ignore it.
	Connections *ConnectionRegistry
	// Security is protocol-neutral authentication and authorization supplied by the host.
	Security *tacklrsecurity.Service
	// HTTPAttempt translates request credentials at the HTTP transport edge.
	HTTPAttempt HTTPAttemptExtractor
	// contains filtered or unexported fields
}

type StreamControl struct {
	Frames   [][]byte
	Resume   map[string][]byte
	Finished bool
	Err      error
}