adapter

type AdapterOption func(*AdapterOptions)

type AdapterOptions struct {
	// Additional options can be added here as needed
	IncludeMetadata bool
	DefaultUserID   string
}

type AdapterService[AgentTask any, AgentCreateRequest any, AgentApprovalRequest any, AgentTaskUpdate any] struct {
	// contains filtered or unexported fields
}

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

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

type DefaultApproveRequest struct {
	Approved bool   `json:"approved"`
	Feedback string `json:"feedback,omitempty"`
}

type DefaultCreateRequest struct {
	Description string `json:"description"`
	UserID      string `json:"user_id"`
	Title       string `json:"title,omitempty"`
	TaskKind    string `json:"task_kind,omitempty"`
}

type DefaultStep struct {
	ID          string     `json:"id"`
	Description string     `json:"description"`
	Status      string     `json:"status"`
	StartTime   *time.Time `json:"start_time,omitempty"`
	EndTime     *time.Time `json:"end_time,omitempty"`
	Error       string     `json:"error,omitempty"`
	Output      string     `json:"output,omitempty"`
}

type DefaultTask struct {
	ID             string                 `json:"id"`
	Description    string                 `json:"description"`
	Status         string                 `json:"status"`
	Title          string                 `json:"title,omitempty"`
	TaskKind       string                 `json:"task_kind,omitempty"`
	ConversationID string                 `json:"conversation_id,omitempty"`
	CreatedAt      time.Time              `json:"created_at"`
	UpdatedAt      time.Time              `json:"updated_at"`
	StartedAt      *time.Time             `json:"started_at,omitempty"`
	CompletedAt    *time.Time             `json:"completed_at,omitempty"`
	UserID         string                 `json:"user_id"`
	Steps          []DefaultStep          `json:"steps,omitempty"`
	Requirements   interface{}            `json:"requirements,omitempty"`
	Feedback       string                 `json:"feedback,omitempty"`
	Metadata       map[string]interface{} `json:"metadata,omitempty"`
}

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

type DefaultTaskUpdate struct {
	Type        string `json:"type"`
	StepID      string `json:"step_id,omitempty"`
	Description string `json:"description,omitempty"`
	Status      string `json:"status,omitempty"`
}

type Service interface {
	// CreateTask creates a new task
	CreateTask(ctx context.Context, req task.CreateTaskRequest) (*task.Task, error)
	// GetTask gets a task by ID
	GetTask(ctx context.Context, taskID string) (*task.Task, error)
	// ListTasks returns tasks filtered by the provided criteria
	ListTasks(ctx context.Context, filter task.TaskFilter) ([]*task.Task, error)
	// ApproveTaskPlan approves or rejects a task plan
	ApproveTaskPlan(ctx context.Context, taskID string, req task.ApproveTaskPlanRequest) (*task.Task, error)
	// UpdateTask updates an existing task with new steps or modifications
	UpdateTask(ctx context.Context, taskID string, updates []task.TaskUpdate) (*task.Task, error)
	// AddTaskLog adds a log entry to a task
	AddTaskLog(ctx context.Context, taskID string, message string, level string) error
}

type TaskAdapter[AgentTask any, AgentCreateRequest any, AgentApprovalRequest any, AgentTaskUpdate any] interface {

	// ConvertCreateRequest converts an agent-specific create request to an SDK create request
	ConvertCreateRequest(req AgentCreateRequest) task.CreateTaskRequest

	// ConvertApproveRequest converts an agent-specific approve request to an SDK approve request
	ConvertApproveRequest(req AgentApprovalRequest) task.ApproveTaskPlanRequest

	// ConvertTaskUpdates converts agent-specific task updates to SDK task updates
	ConvertTaskUpdates(updates []AgentTaskUpdate) []task.TaskUpdate

	// ConvertTask converts an SDK task to an agent-specific task
	ConvertTask(sdkTask *task.Task) AgentTask

	// ConvertTasks converts a slice of SDK tasks to a slice of agent-specific tasks
	ConvertTasks(sdkTasks []*task.Task) []AgentTask
}