models

type AttemptPaymentActivityInput struct {
	InvoiceID      string `json:"invoice_id"`
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type BillingPeriod struct {
	SubscriptionID string          `json:"subscription_id"`
	StartDate      time.Time       `json:"start_date"`
	EndDate        time.Time       `json:"end_date"`
	Amount         decimal.Decimal `json:"amount"`
}

type CalculateBillingPeriodsActivityInput struct {
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type CalculateBillingPeriodsActivityOutput struct {
	BillingPeriods []BillingPeriod `json:"billing_periods"`
}

type CheckPauseActivityInput struct {
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type CheckPauseActivityOutput struct {
	IsPaused bool `json:"is_paused"`
}

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 CreateCustomerActionConfig struct {
	Action        WorkflowAction `json:"action"`                    // Type discriminator - automatically set to "create_customer"
	DefaultUserID *string        `json:"default_user_id,omitempty"` // Optional user_id to use for created_by/updated_by (defaults to NULL if not provided)

}

type CreateCustomerActivityInput struct {
	ExternalID    string `json:"external_id" validate:"required"`
	Name          string `json:"name" validate:"required"`
	Email         string `json:"email,omitempty"`
	TenantID      string `json:"tenant_id" validate:"required"`
	EnvironmentID string `json:"environment_id" validate:"required"`
	UserID        string `json:"user_id,omitempty"`
}

type CreateCustomerActivityResult struct {
	CustomerID string `json:"customer_id"`
	ExternalID string `json:"external_id"`
	Name       string `json:"name"`
	Email      string `json:"email,omitempty"`
}

type CreateInvoiceActivityInput struct {
	SubscriptionID string        `json:"subscription_id"`
	TenantID       string        `json:"tenant_id"`
	EnvironmentID  string        `json:"environment_id"`
	Period         BillingPeriod `json:"period"`
}

type CreateInvoiceActivityOutput struct {
	InvoiceID string `json:"invoice_id"`
}

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

type CreateSubscriptionActionConfig struct {
	Action       WorkflowAction `json:"action"`
	PlanID       string         `json:"plan_id,omitempty"`
	BillingCycle string         `json:"billing_cycle,omitempty"`
	StartDate    *time.Time     `json:"start_date,omitempty"` // Optional start_date, if provided takes highest priority
}

type CreateSubscriptionActivityInput struct {
	CustomerID         string                          `json:"customer_id" validate:"required"`
	EventTimestamp     *time.Time                      `json:"event_timestamp,omitempty"` // Optional - timestamp of the triggering event
	TenantID           string                          `json:"tenant_id" validate:"required"`
	EnvironmentID      string                          `json:"environment_id" validate:"required"`
	UserID             string                          `json:"user_id,omitempty"`
	SubscriptionConfig *CreateSubscriptionActionConfig `json:"subscription_config" validate:"required"`
}

type CreateSubscriptionActivityResult struct {
	SubscriptionID string                   `json:"subscription_id"`
	CustomerID     string                   `json:"customer_id"`
	PlanID         string                   `json:"plan_id"`
	Currency       string                   `json:"currency"`
	Status         types.SubscriptionStatus `json:"status"`
	BillingCycle   types.BillingCycle       `json:"billing_cycle"`
	StartDate      *time.Time               `json:"start_date"`
}

type CreateWalletActionConfig struct {
	Action         WorkflowAction  `json:"action"` // Type discriminator - automatically set to "create_wallet"
	Currency       string          `json:"currency" binding:"required"`
	ConversionRate decimal.Decimal `json:"conversion_rate" default:"1"`
}

type CreateWalletActivityInput struct {
	CustomerID    string                    `json:"customer_id" validate:"required"`
	TenantID      string                    `json:"tenant_id" validate:"required"`
	EnvironmentID string                    `json:"environment_id" validate:"required"`
	UserID        string                    `json:"user_id,omitempty"`
	WalletConfig  *CreateWalletActionConfig `json:"wallet_config" validate:"required"`
}

type CreateWalletActivityResult struct {
	WalletID       string             `json:"wallet_id"`
	CustomerID     string             `json:"customer_id"`
	Currency       string             `json:"currency"`
	ConversionRate string             `json:"conversion_rate"`
	WalletType     types.WalletType   `json:"wallet_type"`
	Status         types.WalletStatus `json:"status"`
}

type CustomerOnboardingActionResult struct {
	ActionType   WorkflowAction       `json:"action_type"`
	ActionIndex  int                  `json:"action_index"`
	Status       WorkflowStatus       `json:"status"`
	ResourceID   string               `json:"resource_id,omitempty"`
	ResourceType WorkflowResourceType `json:"resource_type,omitempty"`
	Error        *string              `json:"error,omitempty"`
}

type CustomerOnboardingWorkflowInput struct {
	CustomerID         string         `json:"customer_id,omitempty"`          // Optional - provided when customer exists
	ExternalCustomerID string         `json:"external_customer_id,omitempty"` // Optional - used for auto-creation
	EventTimestamp     *time.Time     `json:"event_timestamp,omitempty"`      // Optional - timestamp of the triggering event
	TenantID           string         `json:"tenant_id" validate:"required"`
	EnvironmentID      string         `json:"environment_id" validate:"required"`
	UserID             string         `json:"user_id,omitempty"`
	WorkflowConfig     WorkflowConfig `json:"workflow_config" validate:"required"`
}

type CustomerOnboardingWorkflowResult struct {
	CustomerID      string                           `json:"customer_id"`
	Status          WorkflowStatus                   `json:"status"`
	CompletedAt     time.Time                        `json:"completed_at"`
	ActionsExecuted int                              `json:"actions_executed"`
	Results         []CustomerOnboardingActionResult `json:"results"`
	ErrorSummary    *string                          `json:"error_summary,omitempty"`
}

type EnqueueSubscriptionWorkflowsInput struct {
	SubscriptionIDs []string `json:"subscription_ids"`
	TenantID        string   `json:"tenant_id"`
	EnvironmentID   string   `json:"environment_id"`
}

type FetchSubscriptionBatchInput struct {
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
	BatchSize     int    `json:"batch_size"`
	Offset        int    `json:"offset"`
}

type FetchSubscriptionBatchOutput struct {
	SubscriptionIDs []string `json:"subscription_ids"`
}

type HubSpotDealSyncWorkflowInput struct {
	SubscriptionID string `json:"subscription_id"`
	CustomerID     string `json:"customer_id"`
	DealID         string `json:"deal_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type HubSpotInvoiceSyncWorkflowInput struct {
	InvoiceID     string `json:"invoice_id"`
	CustomerID    string `json:"customer_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
}

type HubSpotQuoteSyncWorkflowInput struct {
	SubscriptionID string `json:"subscription_id"`
	CustomerID     string `json:"customer_id"`
	DealID         string `json:"deal_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type NomodInvoiceSyncWorkflowInput struct {
	InvoiceID     string `json:"invoice_id"`
	CustomerID    string `json:"customer_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
}

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 ProcessSingleSubscriptionWorkflowInput struct {
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

type ProcessSingleSubscriptionWorkflowResult struct {
	SubscriptionID          string    `json:"subscription_id"`
	Status                  string    `json:"status"`
	BillingPeriodsProcessed int       `json:"billing_periods_processed"`
	InvoicesCreated         []string  `json:"invoices_created"`
	ErrorSummary            *string   `json:"error_summary,omitempty"`
	CompletedAt             time.Time `json:"completed_at"`
}

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 QuickBooksPriceSyncWorkflowInput struct {
	PriceID       string `json:"price_id"`
	PlanID        string `json:"plan_id"`
	TenantID      string `json:"tenant_id"`
	EnvironmentID string `json:"environment_id"`
	UserID        string `json:"user_id"`
}

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 workflow ID
	ID string
	// TaskQueue is the task queue name
	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 workflow task processing
	WorkflowTaskTimeout time.Duration
}

type SubscriptionSchedulerWorkflowInput struct {
	BatchSize int `json:"batch_size"`
}

type SyncToExternalVendorActivityInput struct {
	InvoiceID      string `json:"invoice_id"`
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_id"`
}

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 UpdateSubscriptionPeriodActivityInput struct {
	SubscriptionID string `json:"subscription_id"`
	TenantID       string `json:"tenant_id"`
	EnvironmentID  string `json:"environment_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
	// Interceptors is a list of interceptors to apply to the worker
	Interceptors []interceptor.WorkerInterceptor
}

type WorkflowAction string

type WorkflowActionConfig interface {
	Validate() error
	GetAction() WorkflowAction
	// Convert to DTO using flexible parameters - implementations can type assert what they need
	ToDTO(params interface{}) (interface{}, error)
}

type WorkflowActionParams struct {
	CustomerID     string
	Currency       string
	EventTimestamp *time.Time // Optional - timestamp of the triggering event for subscription start date
	DefaultUserID  *string    // Optional - user_id from config for created_by/updated_by fields

}

type WorkflowConfig struct {
	WorkflowType WorkflowType           `json:"workflow_type" binding:"required"`
	Actions      []WorkflowActionConfig `json:"actions" binding:"required"`
}

type WorkflowResourceType string

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

type WorkflowStatus string

type WorkflowType string