acp

type AgentEvent struct {
	Type     AgentEventType
	Content  string
	ToolName string
	ToolArgs string
	Error    error
}

type AgentEventType int

type Client struct {
	BaseURL string
	Token   string
	HTTP    *http.Client
}

type Config struct {
	Coordination   *coordination.Store
	Tasks          *TaskStore
	Addr           string
	Token          string
	AllowedOrigins []string
	Agent          Sender
	// ResolveSender selects the actual executing session. It may create a new
	// persisted session when the ID is empty; its returned identity is checked.
	ResolveSender func(context.Context, string) (Sender, error)
	Store         session.Store
	Name          string
	Version       string
	// JobStore and JobWorker are optional. When both are non-nil the server
	// registers the /v1/jobs endpoints and wires job submission through the worker.
	JobStore  *daemon.JobStore
	JobWorker *daemon.Worker
}

type CoordinationRequest struct {
	Execution        *coordination.TransportExecution `json:"execution,omitempty"`
	Send             *coordination.SendInput          `json:"send,omitempty"`
	MessageID        string                           `json:"message_id,omitempty"`
	Payload          json.RawMessage                  `json:"payload,omitempty"`
	IdempotencyKey   string                           `json:"idempotency_key,omitempty"`
	ExpectedRevision int64                            `json:"expected_revision,omitempty"`
	Event            string                           `json:"event,omitempty"`
	AfterRevision    int64                            `json:"after_revision,omitempty"`
	Limit            int                              `json:"limit,omitempty"`
	WaitMilliseconds int                              `json:"wait_milliseconds,omitempty"`
}

type CoordinationResponse struct {
	NextRevision int64                  `json:"next_revision,omitempty"`
	HasMore      bool                   `json:"has_more,omitempty"`
	Self         *coordination.Peer     `json:"self,omitempty"`
	Message      *coordination.Message  `json:"message,omitempty"`
	Messages     []coordination.Message `json:"messages,omitempty"`
	Peers        []coordination.Peer    `json:"peers,omitempty"`
	Events       []coordination.Event   `json:"events,omitempty"`
	TimedOut     bool                   `json:"timed_out,omitempty"`
}

type Event struct {
	Type      string         `json:"type"` // text_delta | tool_call | done | error
	Content   string         `json:"content,omitempty"`
	ToolName  string         `json:"tool_name,omitempty"`
	ToolArgs  string         `json:"tool_args,omitempty"`
	Error     string         `json:"error,omitempty"`
	Timestamp time.Time      `json:"timestamp"`
	Extra     map[string]any `json:"extra,omitempty"`
}

type InboundLog struct {
	From      string    `json:"from"`
	MessageID string    `json:"messageID"`
	Snippet   string    `json:"snippet"`
	At        time.Time `json:"at"`
}

type Info struct {
	Name         string   `json:"name"`
	Version      string   `json:"version"`
	Model        string   `json:"model"`
	Capabilities []string `json:"capabilities"`
}

type RoutePattern struct {
	Path    string   // e.g. "/v1/info", "/v1/messages/{id}/events"
	Methods []string // expected methods; empty = test all standard methods
}

type SendRequest struct {
	From      string         `json:"from"`
	Content   string         `json:"content"`
	SessionID string         `json:"sessionID,omitempty"`
	Options   map[string]any `json:"options,omitempty"`
}

type SendResponse struct {
	MessageID string `json:"messageID"`
	SessionID string `json:"sessionID"`
}

type Sender interface {
	StreamACP(ctx context.Context, userInput string) (<-chan AgentEvent, error)
	Model() string
	SessionID() string
}

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

type Task struct {
	WorkerError string    `json:"workerError,omitempty"`
	TaskID      string    `json:"taskID"`
	MessageID   string    `json:"messageID"`
	SessionID   string    `json:"sessionID"`
	Status      string    `json:"status"`
	Reply       string    `json:"reply,omitempty"`
	Error       string    `json:"error,omitempty"`
	Progress    string    `json:"progress,omitempty"`
	CreatedAt   time.Time `json:"createdAt"`
	UpdatedAt   time.Time `json:"updatedAt"`
}

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

type TaskSubmitRequest struct {
	From           string `json:"from,omitempty"`
	Content        string `json:"content"`
	SessionID      string `json:"sessionID"`
	IdempotencyKey string `json:"idempotencyKey"`
}