observability

type CartCheckoutEvent struct {
	Timestamp     time.Time
	CartID        string
	ItemCount     int
	TotalAmount   int64
	Token         string
	Status        string // "success", "failed", "pending"
	PaymentMethod string
	Wallet        string
	Metadata      map[string]string
}

type CartCreatedEvent struct {
	Timestamp   time.Time
	CartID      string
	ItemCount   int
	TotalAmount int64
	Token       string
	ExpiresAt   time.Time
	Metadata    map[string]string
}

type CartHook interface {
	Hook

	// OnCartCreated is called when a cart quote is created.
	OnCartCreated(ctx context.Context, event CartCreatedEvent)

	// OnCartCheckout is called when a cart checkout is attempted.
	OnCartCheckout(ctx context.Context, event CartCheckoutEvent)
}

type DatabaseHook interface {
	Hook

	// OnDatabaseQuery is called for database queries.
	OnDatabaseQuery(ctx context.Context, event DatabaseQueryEvent)
}

type DatabaseQueryEvent struct {
	Timestamp time.Time
	Operation string // "get", "list", "save", "delete", etc.
	Backend   string // "postgres", "mongodb", "file", "memory"
	Duration  time.Duration
	Success   bool
	Error     string
	Metadata  map[string]string
}

type Hook interface {
	// Name returns the hook's identifier for logging/debugging
	Name() string
}

type PaymentCompletedEvent struct {
	Timestamp     time.Time
	PaymentID     string
	Method        string
	ResourceID    string
	Success       bool
	ErrorReason   string // Set if Success=false
	Amount        int64
	Token         string
	Wallet        string
	Duration      time.Duration // Time from start to completion
	TransactionID string        // Blockchain tx signature or Stripe session ID
	Metadata      map[string]string
}

type PaymentHook interface {
	Hook

	// OnPaymentStarted is called when a payment request is received.
	OnPaymentStarted(ctx context.Context, event PaymentStartedEvent)

	// OnPaymentCompleted is called when a payment succeeds or fails.
	OnPaymentCompleted(ctx context.Context, event PaymentCompletedEvent)

	// OnPaymentSettled is called when payment is confirmed on-chain.
	OnPaymentSettled(ctx context.Context, event PaymentSettledEvent)
}

type PaymentSettledEvent struct {
	Timestamp          time.Time
	PaymentID          string
	Network            string // "solana-mainnet", "ethereum-mainnet", etc.
	TransactionID      string
	Confirmations      int
	SettlementDuration time.Duration // Time from payment to settlement
}

type PaymentStartedEvent struct {
	Timestamp  time.Time
	PaymentID  string
	Method     string // "stripe" or "x402"
	ResourceID string
	Amount     int64  // Amount in atomic units (e.g., cents, lamports)
	Token      string // Currency/token (e.g., "USD", "USDC")
	Wallet     string // Payer wallet address (for x402)
	Metadata   map[string]string
}

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

type RPCCallEvent struct {
	Timestamp time.Time
	Method    string // "getTransaction", "sendTransaction", etc.
	Network   string // "solana-mainnet", etc.
	Duration  time.Duration
	Success   bool
	ErrorType string // "timeout", "rate_limit", "connection", "not_found", "other"
	Metadata  map[string]string
}

type RPCHook interface {
	Hook

	// OnRPCCall is called before/after an RPC call.
	OnRPCCall(ctx context.Context, event RPCCallEvent)
}

type RefundHook interface {
	Hook

	// OnRefundRequested is called when a refund is requested.
	OnRefundRequested(ctx context.Context, event RefundRequestedEvent)

	// OnRefundProcessed is called when a refund is processed (success or failure).
	OnRefundProcessed(ctx context.Context, event RefundProcessedEvent)
}

type RefundProcessedEvent struct {
	Timestamp          time.Time
	RefundID           string
	OriginalPurchaseID string
	Success            bool
	ErrorReason        string
	Amount             int64
	Token              string
	TransactionID      string // On-chain transaction signature
	Duration           time.Duration
	Metadata           map[string]string
}

type RefundRequestedEvent struct {
	Timestamp          time.Time
	RefundID           string
	OriginalPurchaseID string
	RecipientWallet    string
	Amount             int64
	Token              string
	Reason             string
	Metadata           map[string]string
}

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

type WebhookDeliveredEvent struct {
	Timestamp  time.Time
	WebhookID  string
	EventType  string
	URL        string
	EventID    string
	Attempts   int
	Duration   time.Duration
	StatusCode int
}

type WebhookFailedEvent struct {
	Timestamp    time.Time
	WebhookID    string
	EventType    string
	URL          string
	EventID      string
	Attempts     int
	Error        string
	FinalFailure bool // true if all retries exhausted
}

type WebhookHook interface {
	Hook

	// OnWebhookQueued is called when a webhook is added to the delivery queue.
	OnWebhookQueued(ctx context.Context, event WebhookQueuedEvent)

	// OnWebhookDelivered is called when a webhook is successfully delivered.
	OnWebhookDelivered(ctx context.Context, event WebhookDeliveredEvent)

	// OnWebhookFailed is called when a webhook delivery fails.
	OnWebhookFailed(ctx context.Context, event WebhookFailedEvent)

	// OnWebhookRetried is called when a webhook is retried.
	OnWebhookRetried(ctx context.Context, event WebhookRetriedEvent)
}

type WebhookQueuedEvent struct {
	Timestamp time.Time
	WebhookID string
	EventType string // "payment" or "refund"
	URL       string
	EventID   string // Idempotency key for the webhook event
	Metadata  map[string]string
}

type WebhookRetriedEvent struct {
	Timestamp      time.Time
	WebhookID      string
	EventType      string
	URL            string
	EventID        string
	CurrentAttempt int
	MaxAttempts    int
	NextRetryAt    time.Time
	BackoffSeconds float64
}