daniel543x/artcraft
1
0 Fork 0
mirror of https://github.com/storytold/artcraft.git synced 2026-11-02 16:38:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix various stripe handler errors :(

Browse Source
This commit is contained in:
kasisnu committed 2023-11-10 15:05:02 +05:30
1 parent 797332b887
commit 2ebd6dc634
4 files changed
+45 -30
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

crates/service/plugins/billing/src/stripe/http_endpoints/webhook/webhook_event_handlers/customer_subscription/customer_subscription_created_handler.rs
+15 -10
View File
@@ -25,8 +25,9 @@ pub async fn customer_subscription_created_handler(
let summary = subscription_summary_extractor(subscription)
.map_err(|err| {
error!("Error extracting subscription from 'customer.subscription.created' payload: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error extracting subscription from 'customer.subscription.created' payload: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut result = StripeWebhookSummary {
@@ -42,8 +43,9 @@ pub async fn customer_subscription_created_handler(
let maybe_existing_subscription = get_user_subscription_by_stripe_subscription_id(&summary.stripe_subscription_id, &mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
if maybe_existing_subscription.is_some() {
@@ -54,8 +56,9 @@ pub async fn customer_subscription_created_handler(
let maybe_internal_subscription_product =
internal_subscription_product_lookup.lookup_internal_product_from_stripe_product_id(&summary.stripe_product_id)
.map_err(|err| {
error!("Error mapping to internal product: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error mapping to internal product: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut subscription_namespace = UNKNOWN_SUBSCRIPTION_NAMESPACE;
@@ -91,8 +94,9 @@ pub async fn customer_subscription_created_handler(
let _r = upsert.upsert(mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
@@ -104,8 +108,9 @@ pub async fn customer_subscription_created_handler(
Some(&summary.stripe_customer_id))
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
result.action_was_taken = true;
crates/service/plugins/billing/src/stripe/http_endpoints/webhook/webhook_event_handlers/customer_subscription/customer_subscription_deleted_handler.rs
+12 -8
View File
@@ -22,8 +22,9 @@ pub async fn customer_subscription_deleted_handler(
) -> Result<StripeWebhookSummary, StripeWebhookError> {
let summary = subscription_summary_extractor(subscription)
.map_err(|err| {
error!("Error extracting subscription from 'customer.subscription.deleted' payload: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error extracting subscription from 'customer.subscription.deleted' payload: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut should_process_update = true;
@@ -34,8 +35,9 @@ pub async fn customer_subscription_deleted_handler(
let maybe_internal_subscription_product =
internal_subscription_product_lookup.lookup_internal_product_from_stripe_product_id(&summary.stripe_product_id)
.map_err(|err| {
error!("Error mapping to internal product: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error mapping to internal product: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut subscription_namespace = UNKNOWN_SUBSCRIPTION_NAMESPACE;
@@ -50,8 +52,9 @@ pub async fn customer_subscription_deleted_handler(
let maybe_existing_subscription = get_user_subscription_by_stripe_subscription_id(&summary.stripe_subscription_id, &mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
if let Some(existing_subscription) = maybe_existing_subscription {
@@ -92,8 +95,9 @@ pub async fn customer_subscription_deleted_handler(
let _r = upsert.upsert(mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
action_was_taken = true;
crates/service/plugins/billing/src/stripe/http_endpoints/webhook/webhook_event_handlers/customer_subscription/customer_subscription_updated_handler.rs
+15 -10
View File
@@ -23,8 +23,9 @@ pub async fn customer_subscription_updated_handler(
let summary = subscription_summary_extractor(subscription)
.map_err(|err| {
error!("Error extracting subscription from 'customer.subscription.updated' payload: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error extracting subscription from 'customer.subscription.updated' payload: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut should_process_update = true;
@@ -35,8 +36,9 @@ pub async fn customer_subscription_updated_handler(
let maybe_internal_subscription_product =
internal_subscription_product_lookup.lookup_internal_product_from_stripe_product_id(&summary.stripe_product_id)
.map_err(|err| {
error!("Error mapping to internal product: {:?}", err);
StripeWebhookError::ServerError // NB: This was probably *our* fault.
let reason = format!("Error mapping to internal product: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason) // NB: This was probably *our* fault.
})?;
let mut subscription_namespace = UNKNOWN_SUBSCRIPTION_NAMESPACE;
@@ -51,8 +53,9 @@ pub async fn customer_subscription_updated_handler(
let maybe_existing_subscription = get_user_subscription_by_stripe_subscription_id(&summary.stripe_subscription_id, &mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
if let Some(existing_subscription) = maybe_existing_subscription {
@@ -92,8 +95,9 @@ pub async fn customer_subscription_updated_handler(
let _r = upsert.upsert(mysql_pool)
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
info!("Updating user record with stripe customer ID");
@@ -106,8 +110,9 @@ pub async fn customer_subscription_updated_handler(
Some(&summary.stripe_customer_id))
.await
.map_err(|err| {
error!("Mysql error: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Mysql error: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
action_was_taken = true;
crates/service/plugins/billing/src/stripe/http_endpoints/webhook/webhook_event_handlers/invoice/invoice_paid_handler.rs
+3 -2
View File
@@ -71,8 +71,9 @@ pub enum InvoicePaidDetails {
pub fn invoice_paid_handler(invoice: &Invoice) -> Result<StripeWebhookSummary, StripeWebhookError> {
let maybe_invoice_details = invoice_paid_extractor(invoice)
.map_err(|err| {
error!("Error processing invoice: {:?}", err);
StripeWebhookError::ServerError
let reason = format!("Error extracting invoice details from 'invoice.paid' payload: {:?}", err);
error!("{}", reason);
StripeWebhookError::ServerError(reason)
})?;
// TODO