models

type ClientOptions struct {
	// Address is the host:port of the Temporal server
	Address string
	// Namespace is the Temporal namespace to use
	Namespace string
	// APIKey is the authentication key for Temporal Cloud
	APIKey string
	// TLS enables TLS for the connection
	TLS bool
	// RetryPolicy defines the default retry policy for workflows
	RetryPolicy *common.RetryPolicy
	// DataConverter is an optional data converter for serialization
	DataConverter converter.DataConverter
}

type CreateScheduleOptions struct {
	ID     string
	Spec   client.ScheduleSpec
	Action *client.ScheduleWorkflowAction
	Paused bool
}

type PriceSyncWorkflowInput struct {
	PlanID        string `json:"plan_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
	UserID        string `json:"user_id"`
}

type ProcessFileChunkActivityInput struct {
	TaskID        string     `json:"task_id"`
	ChunkData     [][]string `json:"chunk_data"`
	ChunkIndex    int        `json:"chunk_index"`
	TotalChunks   int        `json:"total_chunks"`
	Headers       []string   `json:"headers"`
	EntityType    string     `json:"entity_type"`
	TenantID      string     `json:"tenant_id"`
	EnvironmentID string     `json:"environment_id"`
}

type ProcessFileChunkActivityResult struct {
	ChunkIndex        int     `json:"chunk_index"`
	ProcessedRecords  int     `json:"processed_records"`
	SuccessfulRecords int     `json:"successful_records"`
	FailedRecords     int     `json:"failed_records"`
	ErrorSummary      *string `json:"error_summary,omitempty"`
}

type ProcessTaskActivityInput struct {
	TaskID        string `json:"task_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
}

type ProcessTaskActivityResult struct {
	TaskID            string                 `json:"task_id"`
	ProcessedRecords  int                    `json:"processed_records"`
	SuccessfulRecords int                    `json:"successful_records"`
	FailedRecords     int                    `json:"failed_records"`
	ErrorSummary      *string                `json:"error_summary,omitempty"`
	Metadata          map[string]interface{} `json:"metadata,omitempty"`
}

type RetryPolicy struct {
	// InitialInterval is the initial interval between retries
	InitialInterval time.Duration
	// BackoffCoefficient is the coefficient to multiply the interval by for each retry
	BackoffCoefficient float64
	// MaximumInterval is the maximum interval between retries
	MaximumInterval time.Duration
	// MaximumAttempts is the maximum number of attempts
	MaximumAttempts int32
	// NonRetryableErrorTypes specifies error types that shouldn't be retried
	NonRetryableErrorTypes []string
}

type ScheduleHandle interface {
	// Pause pauses the schedule
	Pause(ctx context.Context, options client.SchedulePauseOptions) error
	// Unpause unpauses the schedule
	Unpause(ctx context.Context, options client.ScheduleUnpauseOptions) error
	// Delete deletes the schedule
	Delete(ctx context.Context) error
	// Describe gets schedule information
	Describe(ctx context.Context) (*client.ScheduleDescription, error)
	// Update updates the schedule
	Update(ctx context.Context, options client.ScheduleUpdateOptions) error
}

type StartWorkflowOptions struct {
	// ID is the business identifier of the workflow execution
	ID string
	// TaskQueue is the task queue name to use for workflow tasks
	TaskQueue string
	// WorkflowExecutionTimeout is the timeout for the entire workflow execution
	WorkflowExecutionTimeout time.Duration
	// WorkflowRunTimeout is the timeout for a single workflow run
	WorkflowRunTimeout time.Duration
	// WorkflowTaskTimeout is the timeout for processing workflow task from the time the worker
	// pulled this task
	WorkflowTaskTimeout time.Duration
	// RetryPolicy specifies how to retry workflow execution
	RetryPolicy *RetryPolicy
}

type TaskProcessingWorkflowInput struct {
	TaskID        string `json:"task_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
	UserID        string `json:"user_id"`
}

type TaskProcessingWorkflowResult struct {
	TaskID            string                 `json:"task_id"`
	Status            string                 `json:"status"`
	ProcessedRecords  int                    `json:"processed_records"`
	SuccessfulRecords int                    `json:"successful_records"`
	FailedRecords     int                    `json:"failed_records"`
	ErrorSummary      *string                `json:"error_summary,omitempty"`
	CompletedAt       time.Time              `json:"completed_at"`
	Metadata          map[string]interface{} `json:"metadata,omitempty"`
}

type TemporalWorkflowResult struct {
	Message    string `json:"message"`
	WorkflowID string `json:"workflow_id"`
	RunID      string `json:"run_id"`
}

type UpdateTaskProgressActivityInput struct {
	TaskID            string  `json:"task_id"`
	ProcessedRecords  int     `json:"processed_records"`
	SuccessfulRecords int     `json:"successful_records"`
	FailedRecords     int     `json:"failed_records"`
	ErrorSummary      *string `json:"error_summary,omitempty"`
}

type WorkerOptions struct {
	// TaskQueue is the name of the task queue to listen on
	TaskQueue string
	// MaxConcurrentActivityExecutionSize is the maximum number of activities that can be executed concurrently
	MaxConcurrentActivityExecutionSize int
	// MaxConcurrentWorkflowTaskExecutionSize is the maximum number of workflow tasks that can be executed concurrently
	MaxConcurrentWorkflowTaskExecutionSize int
	// WorkerStopTimeout is the time to wait for worker to stop gracefully
	WorkerStopTimeout time.Duration
	// EnableLoggingInReplay enables logging in replay mode
	EnableLoggingInReplay bool
}

type WorkflowRun interface {
	// GetID returns the workflow ID
	GetID() string
	// GetRunID returns the workflow run ID
	GetRunID() string
	// Get blocks until workflow completes and returns its result
	Get(ctx context.Context, valuePtr interface{}) error
}

type WorkflowTimeout struct {
	// ExecutionTimeout is the timeout for the entire workflow execution
	ExecutionTimeout time.Duration
	// RunTimeout is the timeout for a single workflow run
	RunTimeout time.Duration
	// TaskTimeout is the timeout for processing workflow task
	TaskTimeout time.Duration
}