callbacks

type DLQStore interface {
	SaveFailedWebhook(ctx context.Context, webhook FailedWebhook) error
	ListFailedWebhooks(ctx context.Context, limit int) ([]FailedWebhook, error)
	DeleteFailedWebhook(ctx context.Context, id string) error
}

type FailedWebhook struct {
	ID          string            `json:"id"`
	URL         string            `json:"url"`
	Payload     json.RawMessage   `json:"payload"`
	Headers     map[string]string `json:"headers"`
	EventType   string            `json:"eventType"` // "payment" or "refund"
	Attempts    int               `json:"attempts"`
	LastError   string            `json:"lastError"`
	LastAttempt time.Time         `json:"lastAttempt"`
	CreatedAt   time.Time         `json:"createdAt"`
}

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

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

type NoopDLQStore struct{}

type NoopNotifier struct{}

type Notifier interface {
	PaymentSucceeded(ctx context.Context, event PaymentEvent)
	RefundSucceeded(ctx context.Context, event RefundEvent)
}

type PaymentEvent struct {
	// Idempotency and event metadata (ALWAYS present)
	EventID        string    `json:"eventId"`        // Unique event identifier for idempotency (e.g., "evt_abc123")
	EventType      string    `json:"eventType"`      // Always "payment.succeeded" for this event
	EventTimestamp time.Time `json:"eventTimestamp"` // ISO8601 timestamp when event was created (UTC)

	// Payment details
	ResourceID         string            `json:"resource"`
	Method             string            `json:"method"` // "stripe" or "x402"
	StripeSessionID    string            `json:"stripeSessionId,omitempty"`
	StripeCustomer     string            `json:"stripeCustomer,omitempty"`
	FiatAmountCents    int64             `json:"fiatAmountCents,omitempty"`
	FiatCurrency       string            `json:"fiatCurrency,omitempty"`
	CryptoAtomicAmount int64             `json:"cryptoAtomicAmount,omitempty"`
	CryptoToken        string            `json:"cryptoToken,omitempty"`
	Wallet             string            `json:"wallet,omitempty"`
	ProofSignature     string            `json:"proofSignature,omitempty"`
	Metadata           map[string]string `json:"metadata,omitempty"`
	PaidAt             time.Time         `json:"paidAt"`
}

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

type PersistentCallbackOptions struct {
	Store       storage.Store
	Config      config.CallbacksConfig
	RetryConfig RetryConfig
	Logger      zerolog.Logger
	Metrics     *metrics.Metrics
}

type RefundEvent struct {
	// Idempotency and event metadata (ALWAYS present)
	EventID        string    `json:"eventId"`        // Unique event identifier for idempotency (e.g., "evt_refund_xyz")
	EventType      string    `json:"eventType"`      // Always "refund.succeeded" for this event
	EventTimestamp time.Time `json:"eventTimestamp"` // ISO8601 timestamp when event was created (UTC)

	// Refund details
	RefundID           string            `json:"refundId"`
	OriginalPurchaseID string            `json:"originalPurchaseId"`
	RecipientWallet    string            `json:"recipientWallet"`
	AtomicAmount       int64             `json:"atomicAmount"` // Amount in atomic units (e.g., 10500000 for 10.5 USDC with 6 decimals)
	Token              string            `json:"token"`
	ProcessedBy        string            `json:"processedBy"` // Server wallet that executed refund
	Signature          string            `json:"signature"`
	Reason             string            `json:"reason,omitempty"`
	Metadata           map[string]string `json:"metadata,omitempty"`
	RefundedAt         time.Time         `json:"refundedAt"`
}

type RetryConfig struct {
	MaxAttempts     int           // Maximum retry attempts (default: 5)
	InitialInterval time.Duration // Initial backoff interval (default: 1s)
	MaxInterval     time.Duration // Maximum backoff interval (default: 5m)
	Multiplier      float64       // Backoff multiplier (default: 2.0)
	Timeout         time.Duration // Per-attempt timeout (default: 10s)
}

type RetryOption func(*RetryableClient)

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

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

type WebhookQueueWorkerOptions struct {
	Store        storage.Store
	Config       config.CallbacksConfig
	RetryConfig  RetryConfig
	Logger       zerolog.Logger
	Metrics      *metrics.Metrics
	PollInterval time.Duration // How often to poll for pending webhooks (default: 5s)
}