subscriptions

type BillingPeriod string

type ChangeSubscriptionRequest struct {
	SubscriptionID     string            // ID of existing subscription
	NewProductID       string            // New product/plan to switch to
	NewPriceID         string            // New Stripe price ID (for Stripe subscriptions)
	NewBillingPeriod   BillingPeriod     // New billing period
	NewBillingInterval int               // New billing interval
	ProrationBehavior  string            // "create_prorations", "none", "always_invoice"
	Metadata           map[string]string // Updated metadata
}

type ChangeSubscriptionResult struct {
	Subscription    Subscription
	PreviousProduct string
	NewProduct      string
	ProrationAmount int64 // Amount in cents (positive = charge, negative = credit)
	EffectiveDate   time.Time
}

type CreateStripeSubscriptionRequest struct {
	ProductID            string
	StripeCustomerID     string
	StripeSubscriptionID string
	BillingPeriod        BillingPeriod
	BillingInterval      int
	CurrentPeriodEnd     time.Time
	TrialEnd             *time.Time
	Metadata             map[string]string
}

type CreateX402SubscriptionRequest struct {
	ProductID       string
	Wallet          string
	BillingPeriod   BillingPeriod
	BillingInterval int
	Metadata        map[string]string
}

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

type PaymentMethod string

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

type ProductConfig struct {
	BillingPeriod    BillingPeriod `json:"billingPeriod" yaml:"billing_period"`
	BillingInterval  int           `json:"billingInterval" yaml:"billing_interval"`
	TrialDays        int           `json:"trialDays,omitempty" yaml:"trial_days"`
	StripePriceID    string        `json:"stripePriceId,omitempty" yaml:"stripe_price_id"`
	AllowX402        bool          `json:"allowX402" yaml:"allow_x402"`                // Allow x402 payment for this subscription
	GracePeriodHours int           `json:"gracePeriodHours" yaml:"grace_period_hours"` // Hours after expiry before blocking
}

type Repository interface {
	// Create stores a new subscription.
	Create(ctx context.Context, sub Subscription) error

	// Get retrieves a subscription by ID.
	Get(ctx context.Context, id string) (Subscription, error)

	// Update modifies an existing subscription.
	Update(ctx context.Context, sub Subscription) error

	// Delete removes a subscription (soft delete by setting status to cancelled).
	Delete(ctx context.Context, id string) error

	// GetByWallet finds an active subscription for a wallet and product.
	GetByWallet(ctx context.Context, wallet, productID string) (Subscription, error)

	// GetByStripeSubscriptionID finds a subscription by Stripe subscription ID.
	GetByStripeSubscriptionID(ctx context.Context, stripeSubID string) (Subscription, error)

	// GetByStripeCustomerID finds all subscriptions for a Stripe customer.
	GetByStripeCustomerID(ctx context.Context, customerID string) ([]Subscription, error)

	// ListByProduct returns all subscriptions for a product.
	ListByProduct(ctx context.Context, productID string) ([]Subscription, error)

	// ListActive returns all active subscriptions, optionally filtered by product.
	ListActive(ctx context.Context, productID string) ([]Subscription, error)

	// ListExpiring returns subscriptions expiring before the given time.
	ListExpiring(ctx context.Context, before time.Time) ([]Subscription, error)

	// UpdateStatus changes a subscription's status.
	UpdateStatus(ctx context.Context, id string, status Status) error

	// ExtendPeriod updates the current period end time (for renewals).
	ExtendPeriod(ctx context.Context, id string, newStart, newEnd time.Time) error

	// Close releases any resources held by the repository.
	Close() error
}

type RepositoryConfig struct {
	Backend          string  // "memory" or "postgres"
	PostgresURL      string  // Connection string for postgres
	PostgresDB       *sql.DB // Optional shared database connection
	TableName        string  // Custom table name (default: "subscriptions")
	GracePeriodHours int     // Hours after expiry before blocking access
}

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

type Status string

type StripeSubscriptionUpdate struct {
	Status             Status
	CurrentPeriodStart time.Time
	CurrentPeriodEnd   time.Time
	CancelAtPeriodEnd  bool
	CancelledAt        *time.Time
	NewProductID       string        // Set if plan changed
	BillingPeriod      BillingPeriod // Set if billing interval changed
	BillingInterval    int
}

type Subscription struct {
	ID        string `json:"id"`
	ProductID string `json:"productId"`

	// Subscriber identity (exactly one of these is set)
	Wallet               string `json:"wallet,omitempty"`               // x402: wallet address
	StripeCustomerID     string `json:"stripeCustomerId,omitempty"`     // Stripe: customer ID
	StripeSubscriptionID string `json:"stripeSubscriptionId,omitempty"` // Stripe: subscription ID

	// Billing configuration
	PaymentMethod   PaymentMethod `json:"paymentMethod"`
	BillingPeriod   BillingPeriod `json:"billingPeriod"`
	BillingInterval int           `json:"billingInterval"` // e.g., 1 month, 3 months

	// Status and dates
	Status             Status     `json:"status"`
	CurrentPeriodStart time.Time  `json:"currentPeriodStart"`
	CurrentPeriodEnd   time.Time  `json:"currentPeriodEnd"`
	TrialEnd           *time.Time `json:"trialEnd,omitempty"`
	CancelledAt        *time.Time `json:"cancelledAt,omitempty"`
	CancelAtPeriodEnd  bool       `json:"cancelAtPeriodEnd"` // Cancel at end of current period

	// Metadata
	Metadata  map[string]string `json:"metadata,omitempty"`
	CreatedAt time.Time         `json:"createdAt"`
	UpdatedAt time.Time         `json:"updatedAt"`
}