Struct SubscriptionBillingService 

pub struct SubscriptionBillingService { /* private fields */ }

Implementations

impl SubscriptionBillingService

pub fn new( pool: PgPool, offers: Arc<dyn SubscriptionOfferStore>, resolver: Arc<dyn GatewayResolver>, admission: Arc<dyn EndUserMutationAdmission>, coordinator: Arc<dyn BillingTransactionCoordinator>, ) -> Self

pub fn with_host_charge_targets( self, targets: Arc<dyn HostChargeTargetStore>, ) -> Self

pub async fn charge_host_target( &self, command: ChargeHostTarget, ) -> Result<HostChargePaymentResult, SubscriptionEnrollmentServiceError>

Charges one host-owned target through the canonical attempt ledger.

Target eligibility and economics are supplied by the configured host extension. No transaction or target lock spans gateway I/O.

pub async fn enroll( &self, command: EnrollSubscription, ) -> Result<SubscriptionEnrollmentPaymentResult, SubscriptionEnrollmentServiceError>

Runs one complete initial-subscription payment boundary.

Matching replay and conflict are resolved before host admission. No database transaction or lock is held across host admission, gateway resolution, readiness I/O, or the one provider mutation.

pub async fn renew( &self, command: ChargeRenewal, ) -> Result<SubscriptionRenewalOutcome, SubscriptionEnrollmentServiceError>

Runs one complete automatic recurring-renewal boundary.

Stale, future, canceled, paced, and contended work is a successful no-op. The operation never invokes end-user admission or the live offer store and never holds a database lock across provider I/O.

pub async fn recover( &self, command: RecoverSubscriptionPayment, ) -> Result<SubscriptionEnrollmentPaymentResult, SubscriptionEnrollmentServiceError>

Runs one complete subscriber-initiated recovery payment boundary.

The command carries only the owner, requested plan/configuration, and memory-only token/contact. Reservation derives the exact due period, amount, subscription, and payment-state snapshot under lock.

pub async fn replace_payment_method( &self, command: ReplaceSubscriptionPaymentMethod, ) -> Result<SubscriptionEnrollmentPaymentResult, SubscriptionEnrollmentServiceError>

Runs one complete stored payment-method replacement boundary.

pub async fn apply_reconciled_outcome( &self, billing_scope_id: BillingScopeId, attempt_id: PaymentAttemptId, outcome: &GatewayPaymentOutcome, ) -> Result<SubscriptionEnrollmentPaymentResult, SubscriptionEnrollmentServiceError>

Applies an already-observed provider outcome without another submission.

Reconciliation enters the same application authority as foreground enrollment but reconstructs its secret-free reservation from the exact durable attempt and canonical gateway account.

pub async fn apply_reconciled_host_charge_outcome( &self, billing_scope_id: BillingScopeId, attempt_id: PaymentAttemptId, outcome: &GatewayPaymentOutcome, ) -> Result<HostChargePaymentResult, SubscriptionEnrollmentServiceError>

Applies an exact-query outcome to one host charge without resubmission.

Trait Implementations

impl Clone for SubscriptionBillingService

fn clone(&self) -> SubscriptionBillingService

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.