feat(payments): Update Cancel and Stay subscribed pages

Author: xlisachan

apps/payments/next/app/[locale]/subscriptions/[subscriptionId]/cancel/page.tsx

@@ -40,6 +40,16 @@ export default async function CancelSubscriptionPage({
     notFound();
   }
 
+  if (pageContent.isEligibleForChurnCancel === true) {
+    redirect(
+      `/${locale}/subscriptions/${subscriptionId}/loyalty-discount/cancel`
+    );
+  }
+
+  if (pageContent.isEligibleForCancelInterstitialOffer === true) {
+    redirect(`/${locale}/subscriptions/${subscriptionId}/offer`);
+  }
+
   return (
     <CancelSubscription
       userId={uid}

apps/payments/next/app/[locale]/subscriptions/[subscriptionId]/stay-subscribed/page.tsx

@@ -41,6 +41,12 @@ export default async function StaySubscribedPage({
     notFound();
   }
 
+  if (pageContent.isEligibleforChurnStaySubscribed === true) {
+    redirect(
+      `/${locale}/subscriptions/${subscriptionId}/loyalty-discount/stay-subscribed`
+    );
+  }
+
   return (
     <StaySubscribed
       userId={uid}

libs/payments/management/src/lib/churn-intervention.service.ts

@@ -327,9 +327,6 @@ export class ChurnInterventionService {
   async determineCancellationIntervention(args: {
     uid: string;
     subscriptionId: string;
-    offeringApiIdentifier: string;
-    currentInterval: SubplatInterval;
-    upgradeInterval: SubplatInterval;
     acceptLanguage?: string | null;
     selectedLanguage?: string;
   }) {
@@ -422,64 +419,105 @@ export class ChurnInterventionService {
   async determineCancelInterstitialOfferEligibility(args: {
     uid: string;
     subscriptionId: string;
-    offeringApiIdentifier: string;
-    currentInterval: SubplatInterval;
-    upgradeInterval: SubplatInterval;
     acceptLanguage?: string | null;
     selectedLanguage?: string;
   }) {
-    const cmsCancelInterstitialOffer =
-      await this.productConfigurationManager.getCancelInterstitialOffer(
-        args.offeringApiIdentifier,
-        args.currentInterval,
-        args.upgradeInterval,
-        args.acceptLanguage || undefined,
-        args.selectedLanguage
-      );
+    const upgradeInterval = SubplatInterval.Yearly;
+    const subscription = await this.subscriptionManager.retrieve(
+      args.subscriptionId
+    );
 
-    const cmsCancelInterstitialOfferResult =
-      cmsCancelInterstitialOffer.getTransformedResult();
-    if (!cmsCancelInterstitialOfferResult) {
+    if (!subscription) {
       this.statsd.increment('cancel_intervention_decision', {
         type: 'none',
-        reason: 'no_cancel_interstitial_offer_found',
+        reason: 'subscription_not_found',
       });
       return {
         isEligible: false,
-        reason: 'no_cancel_interstitial_offer_found',
+        reason: 'subscription_not_found',
         cmsCancelInterstitialOfferResult: null,
       };
     }
 
-    const currentStripeInterval =
+    const currentInterval =
       await this.productConfigurationManager.getSubplatIntervalBySubscription(
-        args.subscriptionId
+        subscription
       );
-    if (
-      !currentStripeInterval ||
-      currentStripeInterval !== args.currentInterval
-    ) {
+
+    if (!currentInterval) {
       this.statsd.increment('cancel_intervention_decision', {
         type: 'none',
-        reason: 'current_interval_mismatch',
+        reason: 'current_interval_not_found',
       });
       return {
         isEligible: false,
-        reason: 'current_interval_mismatch',
+        reason: 'current_interval_not_found',
         cmsCancelInterstitialOfferResult: null,
       };
     }
 
-    try {
-      await this.productConfigurationManager.retrieveStripePrice(
-        args.offeringApiIdentifier,
-        args.upgradeInterval
+    const stripePriceId = subscription.items.data.at(0)?.price.id;
+
+    if (!stripePriceId) {
+      this.statsd.increment('cancel_intervention_decision', {
+        type: 'none',
+        reason: 'stripe_price_id_not_found',
+      });
+      return {
+        isEligible: false,
+        reason: 'stripe_price_id_not_found',
+        cmsCancelInterstitialOfferResult: null,
+      };
+    }
+
+    const result =
+      await this.productConfigurationManager.getPageContentByPriceIds([
+        stripePriceId,
+      ]);
+    const offeringId =
+      result.purchaseForPriceId(stripePriceId).offering?.apiIdentifier;
+
+    if (!offeringId) {
+      this.statsd.increment('cancel_intervention_decision', {
+        type: 'none',
+        reason: 'offering_id_not_found',
+      });
+      return {
+        isEligible: false,
+        reason: 'offering_id_not_found',
+        cmsCancelInterstitialOfferResult: null,
+      };
+    }
+
+    const cmsCancelInterstitialOffer =
+      await this.productConfigurationManager.getCancelInterstitialOffer(
+        offeringId,
+        currentInterval,
+        upgradeInterval,
+        args.acceptLanguage || undefined,
+        args.selectedLanguage
       );
-    } catch {
+    const cmsCancelInterstitialOfferResult =
+      cmsCancelInterstitialOffer.getTransformedResult();
+
+    if (!cmsCancelInterstitialOfferResult) {
       this.statsd.increment('cancel_intervention_decision', {
         type: 'none',
-        reason: 'no_upgrade_plan_found',
+        reason: 'no_cancel_interstitial_offer_found',
       });
+      return {
+        isEligible: false,
+        reason: 'no_cancel_interstitial_offer_found',
+        cmsCancelInterstitialOfferResult: null,
+      };
+    }
+
+    try {
+      await this.productConfigurationManager.retrieveStripePrice(
+        offeringId,
+        upgradeInterval
+      );
+    } catch {
       return {
         isEligible: false,
         reason: 'no_upgrade_plan_found',
@@ -488,8 +526,8 @@ export class ChurnInterventionService {
     }
 
     const eligibility = await this.eligibilityService.checkEligibility(
-      args.upgradeInterval,
-      args.offeringApiIdentifier,
+      upgradeInterval,
+      offeringId,
       args.uid,
       args.subscriptionId
     );

libs/payments/ui/src/lib/actions/determineCancellationIntervention.ts

@@ -5,23 +5,16 @@
 'use server';
 
 import { getApp } from '../nestapp/app';
-import { SubplatInterval } from '@fxa/payments/customer';
 
 export const determineCancellationInterventionAction = async (args: {
   uid: string;
   subscriptionId: string;
-  offeringApiIdentifier: string;
-  currentInterval: SubplatInterval;
-  upgradeInterval: SubplatInterval;
   acceptLanguage?: string | null;
   selectedLanguage?: string;
 }) => {
   return await getApp().getActionsService().determineCancellationIntervention({
     uid: args.uid,
     subscriptionId: args.subscriptionId,
-    offeringApiIdentifier: args.offeringApiIdentifier,
-    currentInterval: args.currentInterval,
-    upgradeInterval: args.upgradeInterval,
     acceptLanguage: args.acceptLanguage,
     selectedLanguage: args.selectedLanguage,
   });

libs/payments/ui/src/lib/nestapp/nextjs-actions.service.ts

@@ -318,19 +318,13 @@ export class NextJSActionsService {
   async determineCancellationIntervention(args: {
     uid: string;
     subscriptionId: string;
-    offeringApiIdentifier: string;
-    currentInterval: SubplatInterval;
-    upgradeInterval: SubplatInterval;
     acceptLanguage?: string | null;
     selectedLanguage?: string;
   }) {
     return await this.churnInterventionService.determineCancellationIntervention(
       {
         uid: args.uid,
         subscriptionId: args.subscriptionId,
-        offeringApiIdentifier: args.offeringApiIdentifier,
-        currentInterval: args.currentInterval,
-        upgradeInterval: args.upgradeInterval,
         acceptLanguage: args.acceptLanguage,
         selectedLanguage: args.selectedLanguage,
       }
@@ -677,7 +671,25 @@ export class NextJSActionsService {
         args.selectedLanguage
       );
 
-    return result;
+    const churnCancelEligibility =
+      await this.churnInterventionService.determineCancellationIntervention({
+        uid: args.uid,
+        subscriptionId: args.subscriptionId,
+        acceptLanguage: args.acceptLanguage,
+        selectedLanguage: args.selectedLanguage,
+      });
+
+    return {
+      ...result,
+      isEligibleForChurnCancel:
+        churnCancelEligibility.reason === 'eligible' &&
+        churnCancelEligibility.cancelChurnInterventionType ===
+          'cancel_churn_intervention',
+      isEligibleForCancelInterstitialOffer:
+        churnCancelEligibility.reason === 'eligible' &&
+        churnCancelEligibility.cancelChurnInterventionType ===
+          'cancel_interstitial_offer',
+    };
   }
 
   @SanitizeExceptions()
@@ -701,7 +713,19 @@ export class NextJSActionsService {
         args.selectedLanguage
       );
 
-    return result;
+    const churnStaySubscribedEligibility =
+      await this.churnInterventionService.determineStaySubscribedEligibility(
+        args.uid,
+        args.subscriptionId,
+        args.acceptLanguage,
+        args.selectedLanguage
+      );
+
+    return {
+      ...result,
+      isEligibleforChurnStaySubscribed:
+        churnStaySubscribedEligibility.isEligible,
+    };
   }
 
   @SanitizeExceptions()