billing

type BillingProvider interface {
	// CreateCustomer registers a new billing customer for the given tenant.
	CreateCustomer(ctx context.Context, tenantID, email string) (customerID string, err error)
	// CreateSubscription starts a subscription for the customer on the given plan.
	CreateSubscription(ctx context.Context, customerID, planID string) (subscriptionID string, err error)
	// CancelSubscription cancels an active subscription.
	CancelSubscription(ctx context.Context, subscriptionID string) error
	// ReportUsage reports metered usage for a subscription.
	ReportUsage(ctx context.Context, subscriptionID string, quantity int64) error
	// HandleWebhook processes an incoming webhook payload from the payment provider.
	HandleWebhook(ctx context.Context, payload []byte, signature string) error
}

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

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

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

type MockBillingProvider struct {

	// Customers maps tenantID -> customerID.
	Customers map[string]string
	// Subscriptions maps subscriptionID -> planID.
	Subscriptions map[string]string
	// UsageReports collects (subscriptionID, quantity) pairs.
	UsageReports []UsageEntry
	// WebhookPayloads collects raw webhook bodies.
	WebhookPayloads [][]byte

	// Error fields allow tests to inject failures.
	CreateCustomerErr     error
	CreateSubscriptionErr error
	CancelSubscriptionErr error
	ReportUsageErr        error
	HandleWebhookErr      error
	// contains filtered or unexported fields
}

type Plan struct {
	ID                  string   `json:"id"`
	Name                string   `json:"name"`
	PriceMonthly        int      `json:"price_monthly"`          // cents
	ExecutionsPerMonth  int64    `json:"executions_per_month"`   // 0 = unlimited
	MaxPipelines        int      `json:"max_pipelines"`          // 0 = unlimited
	MaxStepsPerPipeline int      `json:"max_steps_per_pipeline"` // 0 = unlimited
	RetentionDays       int      `json:"retention_days"`
	MaxWorkers          int      `json:"max_workers"`
	Features            []string `json:"features,omitempty"`
}

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

type StripePlanIDs map[string]string

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

type Subscription struct {
	ID                   string    `json:"id"`
	CustomerID           string    `json:"customer_id"`
	PlanID               string    `json:"plan_id"`
	Status               string    `json:"status"` // active, past_due, canceled, trialing
	CurrentPeriodEnd     time.Time `json:"current_period_end"`
	StripeSubscriptionID string    `json:"stripe_subscription_id,omitempty"`
}

type TenantIDFunc func(r *http.Request) string

type UsageEntry struct {
	SubscriptionID string
	Quantity       int64
}

type UsageMeter interface {
	// RecordExecution records a single pipeline execution for the tenant.
	RecordExecution(ctx context.Context, tenantID, pipelineName string) error
	// GetUsage returns the usage report for the given billing period.
	GetUsage(ctx context.Context, tenantID string, period time.Time) (*UsageReport, error)
	// CheckLimit checks whether the tenant is allowed to run another execution
	// and returns the remaining executions in the current period.
	CheckLimit(ctx context.Context, tenantID string) (allowed bool, remaining int64, err error)
}

type UsageReport struct {
	TenantID       string    `json:"tenant_id"`
	Period         time.Time `json:"period"` // first day of billing period
	ExecutionCount int64     `json:"execution_count"`
	PipelineCount  int       `json:"pipeline_count"`
	StepCount      int       `json:"step_count"`
	WorkerPeak     int       `json:"worker_peak"`
}