core

type Agent struct {
	AgentID            string
	AgentMeta          *op.AgentMeta
	AvailableSkills    []op.OpNode
	AvailableSubagents []op.OpNode
	Conn               *Connection
	ToolSpecs          map[string]*op.ToolSpec
	Meta               op.Meta
	Sysprompt          string
	PromptIsFinal      bool
}

type AgentLoop struct {
	Ctx                  context.Context    `json:"-"`
	Cancel               context.CancelFunc `json:"-"`
	Agent                *Agent
	Meta                 op.Meta
	ThreadID             string
	TurnID               string
	ChatPath             string
	Workdir              string
	ThinkingLevel        string
	ContextWindow        int64
	PlanTurn             bool
	SelectedSkillIDs     []string
	SelectedSkillContext op.Meta
	Model                *ModelClient
	// contains filtered or unexported fields
}

type Connection struct {
	NodeID string `json:"nodeID"`
	Name   string `json:"name"`
	// ConnType    ConnType           `json:"connType"`
	Meta        op.Meta            `json:"meta"`
	TransType   op.TransportType   `json:"type"`
	Command     []string           `json:"command"`
	OpCodes     []op.OpCode        `json:"opcodes"`
	URL         string             `json:"url"`
	Description string             `json:"description"`
	Daemon      bool               `json:"daemon"`
	Session     *op.ClientSession  `json:"-"`
	Ctx         context.Context    `json:"-"`
	Cancel      context.CancelFunc `json:"-"`
	// contains filtered or unexported fields
}

type ConnectionRuntimeSnapshot struct {
	NodeID       string           `json:"nodeID"`
	Name         string           `json:"name,omitempty"`
	Transport    op.TransportType `json:"transport,omitempty"`
	Daemon       bool             `json:"daemon,omitempty"`
	ConnectedAt  *time.Time       `json:"connectedAt,omitempty"`
	PID          int              `json:"pid,omitempty"`
	StartedAt    *time.Time       `json:"startedAt,omitempty"`
	UptimeSec    int64            `json:"uptimeSec,omitempty"`
	LastActiveAt *time.Time       `json:"lastActiveAt,omitempty"`
	URL          string           `json:"url,omitempty"`
}

type ContinueLoopConfig struct {
	PendingMessages         []op.Message
	SkipInitialSteeringPoll bool
}

type CronTask struct {
	ID          string           `json:"id"`
	Name        string           `json:"name"`
	Description string           `json:"description,omitempty"`
	Enabled     bool             `json:"enabled"`
	Schedule    CronTaskSchedule `json:"schedule"`
	Target      CronTaskTarget   `json:"target"`
	Payload     CronTaskPayload  `json:"payload"`
	CreatedAtMs int64            `json:"createdAtMs,omitempty"`
	UpdatedAtMs int64            `json:"updatedAtMs,omitempty"`
}

type CronTaskHistoryResult struct {
	TaskID string                    `json:"taskID"`
	Limit  int                       `json:"limit"`
	Runs   []CronTaskRunHistoryEntry `json:"runs"`
}

type CronTaskListResult struct {
	Version int              `json:"version"`
	Tasks   []CronTaskRecord `json:"tasks"`
}

type CronTaskPayload struct {
	Kind string         `json:"kind"`
	Text string         `json:"text,omitempty"`
	Data map[string]any `json:"data,omitempty"`
}

type CronTaskRecord struct {
	Task  CronTask       `json:"task"`
	State *CronTaskState `json:"state,omitempty"`
}

type CronTaskRunHistoryEntry struct {
	RunID         string `json:"runID"`
	TaskID        string `json:"taskID"`
	Trigger       string `json:"trigger"`
	ScheduledAtMs int64  `json:"scheduledAtMs,omitempty"`
	StartedAtMs   int64  `json:"startedAtMs"`
	FinishedAtMs  int64  `json:"finishedAtMs,omitempty"`
	DurationMs    int64  `json:"durationMs,omitempty"`
	Status        string `json:"status"`
	Error         string `json:"error,omitempty"`
	ThreadID      string `json:"threadID,omitempty"`
	ChatPath      string `json:"chatPath,omitempty"`
	AgentID       string `json:"agentID,omitempty"`
}

type CronTaskRunResult struct {
	Queued bool           `json:"queued"`
	Task   CronTaskRecord `json:"task"`
}

type CronTaskSchedule struct {
	Cron  string `json:"cron,omitempty"`
	Every string `json:"every,omitempty"`
	Time  string `json:"time,omitempty"`
}

type CronTaskState struct {
	TaskID            string           `json:"taskID"`
	SpecHash          string           `json:"specHash,omitempty"`
	NextRunAtMs       int64            `json:"nextRunAtMs,omitempty"`
	RunNowAtMs        int64            `json:"runNowAtMs,omitempty"`
	RunNowPayload     *CronTaskPayload `json:"runNowPayload,omitempty"`
	LastRunAtMs       int64            `json:"lastRunAtMs,omitempty"`
	RunningAtMs       int64            `json:"runningAtMs,omitempty"`
	LastError         string           `json:"lastError,omitempty"`
	ConsecutiveErrors int              `json:"consecutiveErrors,omitempty"`
}

type CronTaskStoreFile struct {
	Version int        `json:"version"`
	Tasks   []CronTask `json:"tasks"`
}

type CronTaskTarget struct {
	Kind    string `json:"kind"`
	AgentID string `json:"agentID"`
	CWD     string `json:"cwd"`
}

type Loop struct {
	Ctx      context.Context
	Meta     op.Meta
	ThreadID string
	TurnID   string
	Workdir  string
}

type ModelClient struct {
	Canonical ai.CanonicalProvider
	Responses ai.ResponsesProvider
	Ctx       context.Context
	// contains filtered or unexported fields
}

type PendingLoopMessage struct {
	Message              op.Message
	QueueKind            op.ThreadQueueKind
	QueueItemID          string
	SelectedSkillIDs     []string
	SelectedSkillContext op.Meta
	PlanTurn             bool
}

type RunLoopConfig struct {
	GetSteeringMessages     func(context.Context) ([]PendingLoopMessage, error)
	GetFollowUpMessages     func(context.Context) ([]PendingLoopMessage, error)
	InitialPendingMessages  []PendingLoopMessage
	SkipInitialSteeringPoll bool
}

type Storage interface {

	// user task
	GetUserTask(ctx context.Context, taskID string) (*op.UserTask, error)
	ListUserTasks(ctx context.Context, uid string) ([]*op.UserTask, error)
	UpsertUserTask(ctx context.Context, task *op.UserTask) error
	BindThreadIDToUserTaskID(ctx context.Context, taskID, threadID string) error
	DeleteThreadIDFromUserTask(ctx context.Context, taskID, threadID string) error
	DeleteUserTask(ctx context.Context, taskID string) error

	// user settings
	UpsertUserSettings(ctx context.Context, settings *op.UserSettings) error
	GetUserSettings(ctx context.Context, uid string) (*op.UserSettings, error)

	// ListUIDs returns distinct UIDs that exist in storage.
	ListUIDs(ctx context.Context) ([]string, error)
}

type ToolCall struct {
	Type string   `json:"type"`
	ID   string   `json:"id"`
	Info toolInfo `json:"info"`
}

type ToolCallDelta struct {
	Index       int
	ID          string
	Type        string
	Name        string
	Description string
	Arguments   string
}

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