syrup-rail-postgres 0.5.0

Canonical provider-neutral PostgreSQL schema contract and SQLx orchestration for Syrup Rail
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175

//! PostgreSQL schema contract and transaction orchestration for Syrup Rail.
//!
//! Production service construction must not expose or invoke a migrator; host
//! applications materialize versioned install artifacts as immutable migrations.

#![doc = include_str!("../README.md")]
#![forbid(unsafe_code)]

mod attempts;
mod billing_portal;
mod cancellation;
mod deletion;
mod discounts;
mod enrollment_application;
mod entitlement;
mod gateway_accounts;
mod grants;
mod host_charge_application;
mod host_charge_reconciliation;
mod host_charges;
mod host_error;
mod lifecycle_quarantine;
mod lifecycle_reconciliation;
mod mode_verified_gateway;
mod operator_review;
#[cfg(test)]
mod paid_trial_dunning_tests;
mod processor_charge_persistence;
mod processor_charges;
mod reconciliation;
mod renewal;
mod renewal_failure;
// Production hosts receive only the runtime compatibility assertion. The
// feature-gated public module retains the checked-in install/upgrade artifacts
// for schema-contract fixtures and explicit test support without embedding a
// migrator in ordinary binaries.
#[cfg(any(test, feature = "schema-contract-test-support"))]
pub mod schema_contract;
#[cfg(not(any(test, feature = "schema-contract-test-support")))]
mod schema_contract;
mod subscription_billing_service;
mod subscription_persistence;
#[cfg(test)]
mod test_support;
mod transactions;

pub use attempts::{
    PaymentAttemptStoreError, admit_subscription_enrollment_submission_in_transaction,
    admit_subscription_payment_method_replacement_in_transaction,
    admit_subscription_recovery_submission_in_transaction,
    admit_subscription_renewal_submission_in_transaction,
    find_payment_attempt_by_id_in_transaction, lock_payment_attempt_by_idempotency_in_transaction,
    preflight_subscription_enrollment_in_transaction,
    preflight_subscription_payment_method_replacement_in_transaction,
    preflight_subscription_recovery_in_transaction, reserve_subscription_enrollment_in_transaction,
    reserve_subscription_payment_method_replacement_in_transaction,
    reserve_subscription_recovery_in_transaction, reserve_subscription_renewal_in_transaction,
};
pub use billing_portal::{
    SubscriptionBillingPortalQueryError, subscription_billing_portal,
    subscription_payment_history_page,
};
pub use cancellation::{SubscriptionCancellationError, cancel_subscription_in_transaction};
pub use deletion::{billing_deletion_blockers, scrub_subscriber_billing_data};
pub use discounts::{
    SubscriptionDiscountOperationError, SubscriptionEnrollmentOfferContext,
    SubscriptionEnrollmentOfferStage, SubscriptionOfferStore, claim_subscription_discount,
    claim_subscription_discount_in_transaction, clear_subscription_discount,
    clear_subscription_discount_in_transaction, create_subscription_discount_code,
    create_subscription_discount_code_in_transaction, disable_subscription_discount_code,
    disable_subscription_discount_code_in_transaction, list_subscription_discount_codes,
    list_subscription_discount_codes_in_transaction,
    mark_subscription_discount_claim_applied_in_transaction, saved_subscription_discount_claim,
    saved_subscription_discount_claim_in_transaction, update_subscription_discount_code,
    update_subscription_discount_code_in_transaction, validate_subscription_discount_code,
    validate_subscription_discount_code_in_transaction,
};
pub use enrollment_application::{
    AdmittedSubscriptionEnrollment, AdmittedSubscriptionPaymentMethodReplacement,
    AdmittedSubscriptionRecovery, AdmittedSubscriptionRenewal,
    SubscriptionEnrollmentAdmissionOutcome, SubscriptionEnrollmentApplicationError,
    SubscriptionEnrollmentProviderResult, SubscriptionPaymentMethodReplacementAdmissionOutcome,
    SubscriptionPaymentMethodReplacementProviderResult, SubscriptionRecoveryAdmissionOutcome,
    SubscriptionRecoveryProviderResult, SubscriptionRenewalAdmissionOutcome,
    SubscriptionRenewalProviderResult, admit_subscription_enrollment_submission,
    admit_subscription_payment_method_replacement, admit_subscription_recovery_submission,
    admit_subscription_renewal_submission,
    apply_reconciled_subscription_enrollment_gateway_outcome,
    apply_reconciled_subscription_payment_method_replacement_gateway_outcome,
    apply_reconciled_subscription_recovery_gateway_outcome,
    apply_reconciled_subscription_renewal_gateway_outcome,
    apply_subscription_enrollment_gateway_outcome,
    apply_subscription_payment_method_replacement_gateway_outcome,
    apply_subscription_recovery_gateway_outcome, apply_subscription_renewal_gateway_outcome,
    submit_admitted_subscription_enrollment,
    submit_admitted_subscription_payment_method_replacement, submit_admitted_subscription_recovery,
    submit_admitted_subscription_renewal,
};
pub use entitlement::{
    AdmittedEntitlementWriteTransaction, EntitlementGuardError, EntitlementQueryError,
    EntitlementWriteTransaction, entitlement, require_entitlement_for_update,
};
pub use gateway_accounts::{activate_gateway_configuration, register_gateway_account};
pub use grants::{
    SubscriptionGrantMutationError, create_subscription_grant, revoke_subscription_grant,
};
pub use host_charge_application::{
    AdmittedHostCharge, HostChargeAdmissionOutcome, HostChargeApplicationError,
    HostChargeProviderResult, admit_host_charge_submission, apply_host_charge_gateway_outcome,
    apply_reconciled_host_charge_gateway_outcome, submit_admitted_host_charge,
};
pub use host_charge_reconciliation::{
    StaleHostChargeCleanupSummary, fail_stale_unsubmitted_host_charges,
};
pub use host_charges::{
    HostChargeLedgerAdmission, HostChargeLedgerAdmissionError, HostChargeLedgerAdmissionMode,
    HostChargeLedgerAdmissionQuery, HostChargePreflightOutcome, HostChargeReservationDecision,
    HostChargeReservationOutcome, HostChargeStoreError, HostChargeSubmissionAdmission,
    HostChargeSubmissionDecision, HostChargeSubmissionOutcome, HostChargeTargetError,
    HostChargeTargetReservation, HostChargeTargetStore,
    admit_host_charge_submission_in_transaction, host_charge_ledger_admission,
    preflight_host_charge_in_transaction, reserve_host_charge_in_transaction,
};
pub use lifecycle_quarantine::{
    GatewayLifecycleQuarantineAlert, GatewayLifecycleQuarantineResolutionOutcome,
    GatewayLifecycleQuarantineResolutionRecord, GatewayLifecycleQuarantineReviewRecord,
    claim_gateway_lifecycle_quarantine_alert, gateway_lifecycle_quarantine_review_page,
    resolve_gateway_lifecycle_quarantine,
};
pub use lifecycle_reconciliation::{
    GatewayLifecycleApplyOutcome, GatewayLifecycleReconciliationError,
    GatewayLifecycleReconciliationSummary, apply_gateway_lifecycle_evidence,
    apply_staged_gateway_lifecycle_evidence, gateway_lifecycle_reconciliation_start,
    reconcile_gateway_transaction_reports, record_gateway_lifecycle_quarantines,
    save_gateway_lifecycle_reconciliation_cursor, stage_gateway_lifecycle_evidence,
};
pub use mode_verified_gateway::{
    GatewayAccountModeVerificationError, ModeVerifiedGateway, verify_gateway_account_mode,
};
pub use operator_review::{
    ExternalReversalAttestationOutcome, ExternalReversalHostStore, ExternalReversalHostStoreError,
    ExternalReversalHostTransitionOutcome, ManualAttemptFailureHostStore,
    ManualAttemptFailureHostStoreError, ManualAttemptFailureHostTransitionOutcome,
    OperatorReviewError, attempt_review_page, attest_external_reversal,
    fail_review_required_attempt, processor_charge_review_page,
};
pub use processor_charges::{
    CompensatingProcessorChargeOutcome, ProcessorChargeObservationOutcome,
    ProcessorChargeStoreError, observe_processor_charge_in_transaction,
    store_compensating_processor_charge, transition_processor_charge_in_transaction,
};
pub use reconciliation::{
    ExactQueryObservation, ProcessorChargeClassificationSummary, apply_exact_query_observation,
    claim_exact_reconciliation_attempts, classify_pending_processor_charges,
    fail_stale_unsubmitted_payment_method_replacements,
    fail_stale_unsubmitted_subscription_charges, fail_stale_unsubmitted_subscription_enrollments,
    reconciliation_gateway_accounts,
};
pub use renewal::{
    RenewalStoreError, due_renewals, due_renewals_for_mode, due_renewals_page,
    due_renewals_page_for_mode, renewal_attempt_state,
};
#[cfg(any(test, feature = "schema-contract-test-support"))]
pub use schema_contract::assert_runtime_schema_v3_compatible;
pub use schema_contract::{
    SUPPORTED_POSTGRES_MAJOR_VERSION, SchemaConformanceError, assert_runtime_schema_v4_compatible,
};
pub use subscription_billing_service::{
    GatewayMutationCooldownScope, SubscriptionBillingService, SubscriptionBillingServiceError,
    SubscriptionBillingServiceErrorDisposition,
};
pub use transactions::{
    BillingEventWriteError, BillingTransaction, BillingTransactionCoordinator,
    BillingTransactionError, BillingTransactionSubjectState,
};