interaction

type Interaction struct {
	ID            string            `yaml:"id"`
	TaskID        string            `yaml:"task_id"`
	AgentID       string            `yaml:"agent_id"`
	Type          InteractionType   `yaml:"type"`
	Status        InteractionStatus `yaml:"status"`
	Title         string            `yaml:"title"`
	Description   string            `yaml:"description"`
	Options       []Option          `yaml:"options"`
	Response      string            `yaml:"response"`
	ResponseToken string            `yaml:"response_token,omitempty"`
	Metadata      string            `yaml:"metadata,omitempty"`
	CreatedAt     time.Time         `yaml:"created_at"`
	RespondedAt   *time.Time        `yaml:"responded_at"`
}

type InteractionStatus int32

type InteractionType int32

type Option struct {
	Label       string `yaml:"label"`
	Value       string `yaml:"value"`
	Description string `yaml:"description"`
}

type Repository interface {
	Create(ctx context.Context, i *Interaction) error
	Get(ctx context.Context, id string) (*Interaction, error)
	// GetByResponseToken finds a PENDING interaction by its single-use response token.
	// Returns nil and an error if no matching interaction is found.
	GetByResponseToken(ctx context.Context, token string) (*Interaction, error)
	List(ctx context.Context, taskID string, taskIDs []string, limit, offset int) ([]*Interaction, int, error)
	Update(ctx context.Context, i *Interaction) error
	// ExpirePendingByTask sets all PENDING interactions for the given task to EXPIRED.
	// Returns the number of interactions expired.
	ExpirePendingByTask(ctx context.Context, taskID string) (int, error)
	// DeleteByTaskID removes all interactions belonging to the given task.
	DeleteByTaskID(ctx context.Context, taskID string) (int, error)
}

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