feat: Add email template for failed team subscription payments

apps/web/app/api/cron/downgradeUsers/route.ts

@@ -33,6 +33,7 @@ async function postHandler(request: NextRequest) {
         metadata: true,
         isOrganization: true,
         parentId: true,
+        name: true,
       },
       skip: pageNumber * pageSize,
       take: pageSize,

apps/web/public/static/locales/en/common.json

@@ -115,8 +115,14 @@
   "refund_failed": "The refund for the event {{eventType}} with {{userName}} on {{date}} failed.",
   "check_with_provider_and_user": "Please check with your payment provider and {{user}} how to handle this.",
   "a_refund_failed": "A refund failed",
+  "subscription_payment_failed_subject": "Payment Failed: {{entityName}} Subscription",
+  "subscription_payment_failed_title": "Payment Failed for {{entityName}}: Please Update Your Details",
+  "subscription_payment_failed_description": "We were unable to process the payment for your {{entityName}} subscription.",
+  "subscription_payment_failed_next_steps": "Looks like your card didn't go through. Let's get this fixed so your bookings stay live. \n Click the button below to update your payment details. It only takes a moment.",
+  "subscription_payment_failed_contact_support": "If you need assistance, please contact our support team at support@cal.com.",
+  "update_payment_method": "Update Payment Method",
   "awaiting_payment_subject": "Awaiting payment: {{title}} on {{date}}",
-  "meeting_awaiting_payment": "Your meeting is awaiting payment",
+  "meeting_awaiting_payment":"Your meeting is awaiting payment",
   "dark_theme_contrast_error": "Dark theme color doesn't pass contrast check. We recommend you change this colour so your buttons will be more visible.",
   "light_theme_contrast_error": "Light theme color doesn't pass contrast check. We recommend you change this colour so your buttons will be more visible.",
   "event_type_color_light_theme_contrast_error": "Light theme color doesn't pass contrast check. We recommend you change this color so your event types color will be more visible.",

packages/app-store/stripepayment/lib/services/base/BillingPortalService.ts

@@ -120,4 +120,16 @@ export abstract class BillingPortalService {
     const billingPortalUrl = await this.createBillingPortalUrl(customerId, returnUrl);
     res.redirect(302, billingPortalUrl);
   }
+
+  /** Generates a team billing portal URL without permission checks */
+  async processBillingPortalWithoutPermissionChecks({ teamId }: { teamId: number }) {
+    const customerId = await this.getCustomerId(teamId);
+    if (!customerId) {
+      throw new Error(`Customer ID not found for team ${teamId}`);
+    }
+
+    const returnUrl = `${WEBAPP_URL}/settings/teams/${teamId}/billing`;
+    const billingPortalUrl = await this.createBillingPortalUrl(customerId, returnUrl);
+    return billingPortalUrl;
+  }
 }

packages/emails/email-manager.ts

@@ -45,6 +45,13 @@ import OrganizerRequestReminderEmail from "./templates/organizer-request-reminde
 import OrganizerRequestedToRescheduleEmail from "./templates/organizer-requested-to-reschedule-email";
 import OrganizerRescheduledEmail from "./templates/organizer-rescheduled-email";
 import OrganizerScheduledEmail from "./templates/organizer-scheduled-email";
+import SlugReplacementEmail from "./templates/slug-replacement-email";
+import type { SubscriptionPaymentFailedEmailData } from "./templates/subscription-payment-failed-email";
+import SubscriptionPaymentFailedEmail from "./templates/subscription-payment-failed-email";
+import type { TeamInvite } from "./templates/team-invite-email";
+import TeamInviteEmail from "./templates/team-invite-email";
+import type { WorkflowEmailData } from "./templates/workflow-email";
+import WorkflowEmail from "./templates/workflow-email";
 
 type EventTypeMetadata = z.infer<typeof EventTypeMetaDataSchema>;
 
@@ -770,3 +777,7 @@ export const sendAddGuestsEmailsAndSMS = async (args: {
 
   await Promise.all(emailsAndSMSToSend);
 };
+
+export const sendSubscriptionPaymentFailedEmail = async (emailData: SubscriptionPaymentFailedEmailData) => {
+  await sendEmail(() => new SubscriptionPaymentFailedEmail(emailData));
+};

packages/emails/src/templates/SubscriptionPaymentFailedEmail.tsx

@@ -0,0 +1,69 @@
+import { BaseEmailHtml, CallToAction } from "../components";
+
+type SubscriptionPaymentFailedEmailProps = {
+  entityName: string;
+  billingPortalUrl: string;
+  supportEmail: string;
+  language: {
+    translate: (key: string, variables?: Record<string, string | number>) => string;
+  };
+};
+
+export const SubscriptionPaymentFailedEmail = (props: SubscriptionPaymentFailedEmailProps) => {
+  const t = props.language.translate;
+
+  return (
+    <BaseEmailHtml
+      headerType="xCircle"
+      subject="subscription_payment_failed_subject"
+      title={t("subscription_payment_failed_title", { entityName: props.entityName })}
+      callToAction={
+        props.billingPortalUrl ? (
+          <CallToAction label={t("update_payment_method")} href={props.billingPortalUrl} />
+        ) : null
+      }>
+      <PaymentFailedInformation {...props} />
+    </BaseEmailHtml>
+  );
+};
+
+function PaymentFailedInformation(props: SubscriptionPaymentFailedEmailProps) {
+  const t = props.language.translate;
+
+  return (
+    <>
+      <tr>
+        <td align="center" style={{ fontSize: "0px", padding: "10px 25px", wordBreak: "break-word" }}>
+          <div
+            style={{
+              fontFamily: "Roboto, Helvetica, sans-serif",
+              fontSize: "16px",
+              fontWeight: 400,
+              lineHeight: "24px",
+              textAlign: "center",
+              color: "#494949",
+            }}>
+            {t("subscription_payment_failed_next_steps")}
+          </div>
+        </td>
+      </tr>
+      <tr>
+        <td align="center" style={{ fontSize: "0px", padding: "10px 25px", wordBreak: "break-word" }}>
+          <div
+            style={{
+              fontFamily: "Roboto, Helvetica, sans-serif",
+              fontSize: "14px",
+              fontWeight: 400,
+              lineHeight: "20px",
+              textAlign: "center",
+              color: "#666666",
+            }}>
+            {t("subscription_payment_failed_contact_support", {
+              supportEmail: props.supportEmail,
+            })}
+          </div>
+        </td>
+      </tr>
+    </>
+  );
+}

packages/emails/src/templates/index.ts

@@ -48,3 +48,4 @@ export { TeamInviteEmail } from "./TeamInviteEmail";
 export { VerifyAccountEmail } from "./VerifyAccountEmail";
 export { VerifyEmailByCode } from "./VerifyEmailByCode";
 export { VerifyEmailChangeEmail } from "./VerifyEmailChangeEmail";
+export { SubscriptionPaymentFailedEmail } from "./SubscriptionPaymentFailedEmail";

packages/emails/templates/subscription-payment-failed-email.ts

@@ -0,0 +1,67 @@
+import { EMAIL_FROM_NAME } from "@calcom/lib/constants";
+
+import renderEmail from "../src/renderEmail";
+import BaseEmail from "./_base-email";
+
+export interface SubscriptionPaymentFailedEmailData {
+  entityName: string;
+  billingPortalUrl: string;
+  to: string;
+  language: {
+    translate: (key: string, variables?: Record<string, string | number>) => string;
+  };
+}
+
+export default class SubscriptionPaymentFailedEmail extends BaseEmail {
+  emailData: SubscriptionPaymentFailedEmailData;
+
+  constructor(emailData: SubscriptionPaymentFailedEmailData) {
+    super();
+    this.name = "SEND_SUBSCRIPTION_PAYMENT_FAILED_EMAIL";
+    this.emailData = emailData;
+  }
+
+  protected override getLocale(): string {
+    return "";
+  }
+
+  protected async getNodeMailerPayload(): Promise<Record<string, unknown>> {
+    const t = this.emailData.language.translate;
+
+    return {
+      from: `${EMAIL_FROM_NAME} <${this.getMailerOptions().from}>`,
+      to: this.emailData.to,
+      subject: t("subscription_payment_failed_subject", {
+        entityName: this.emailData.entityName,
+      }),
+      html: await renderEmail("SubscriptionPaymentFailedEmail", {
+        entityName: this.emailData.entityName,
+        billingPortalUrl: this.emailData.billingPortalUrl,
+        supportEmail: process.env.NEXT_PUBLIC_SUPPORT_MAIL_ADDRESS || "support@cal.com",
+        language: this.emailData.language,
+      }),
+      text: this.getTextBody(),
+    };
+  }
+
+  protected getTextBody(): string {
+    const t = this.emailData.language.translate;
+    const supportEmail = process.env.NEXT_PUBLIC_SUPPORT_MAIL_ADDRESS || "support@cal.com";
+
+    return `
+${t("subscription_payment_failed_title")}
+
+${t("subscription_payment_failed_description", {
+  entityName: this.emailData.entityName,
+})}
+
+${t("subscription_payment_failed_next_steps")}
+
+${t("update_payment_method")}: ${this.emailData.billingPortalUrl}
+
+${t("subscription_payment_failed_contact_support", {
+  supportEmail,
+})}
+    `.trim();
+  }
+}

packages/features/ee/billing/service/teams/ITeamBillingService.ts

@@ -5,7 +5,7 @@ import {
   IBillingRepositoryCreateArgs,
 } from "../../repository/billing/IBillingRepository";
 
-export type TeamBillingInput = Pick<Team, "id" | "parentId" | "metadata" | "isOrganization">;
+export type TeamBillingInput = Pick<Team, "id" | "parentId" | "metadata" | "isOrganization" | "name">;
 export const TeamBillingPublishResponseStatus = {
   REQUIRES_PAYMENT: "REQUIRES_PAYMENT",
   REQUIRES_UPGRADE: "REQUIRES_UPGRADE",

packages/features/ee/billing/service/teams/TeamBillingService.ts

@@ -1,14 +1,20 @@
+import type { z } from "zod";
+
+import { BillingPortalServiceFactory } from "@calcom/app-store/stripepayment/lib/services/factory/BillingPortalServiceFactory";
 import { getRequestedSlugError } from "@calcom/app-store/stripepayment/lib/team-billing";
+import { sendSubscriptionPaymentFailedEmail } from "@calcom/emails/email-manager";
 import { purchaseTeamOrOrgSubscription } from "@calcom/features/ee/teams/lib/payments";
+import { PermissionCheckService } from "@calcom/features/pbac/services/permission-check.service";
 import { WEBAPP_URL } from "@calcom/lib/constants";
 import { getMetadataHelpers } from "@calcom/lib/getMetadataHelpers";
 import logger from "@calcom/lib/logger";
 import { Redirect } from "@calcom/lib/redirect";
 import { safeStringify } from "@calcom/lib/safeStringify";
+import { getTranslation } from "@calcom/lib/server/i18n";
 import { prisma } from "@calcom/prisma";
 import type { Prisma } from "@calcom/prisma/client";
+import { MembershipRole } from "@calcom/prisma/enums";
 import { teamMetadataStrictSchema } from "@calcom/prisma/zod-utils";
-import type { z } from "zod";
 import { updateSubscriptionQuantity } from "../../lib/subscription-updates";
 // import billing from "../..";
 import type {
@@ -232,4 +238,53 @@ export class TeamBillingService implements ITeamBillingService {
   async saveTeamBilling(args: IBillingRepositoryCreateArgs) {
     await this.billingRepository.create(args);
   }
+
+  /**
+   * Sends a payment failed email to team/organization admins with billing portal link
+   */
+  async sendPaymentFailedEmails(): Promise<void> {
+    try {
+      // Get members of the team that have access to billing
+      const billingPortalService = await BillingPortalServiceFactory.createService(this.team.id);
+      const billingPortalUrl = await billingPortalService.processBillingPortalWithoutPermissionChecks({
+        teamId: this.team.id,
+      });
+
+      const permissionService = new PermissionCheckService();
+      // Use the correct permission based on whether this is an organization or team
+      const billingPermission = this.team.isOrganization
+        ? "organization.manageBilling"
+        : "team.manageBilling";
+      const membersToSendBillingEmail = await permissionService.getUsersWithPermissionForTeam({
+        teamId: this.team.id,
+        permission: billingPermission,
+        fallbackRoles: [MembershipRole.ADMIN, MembershipRole.OWNER],
+      });
+
+      const emailsSent = await Promise.allSettled(
+        membersToSendBillingEmail.map(async (member) => {
+          const translate = await getTranslation(member.locale || "en", "common");
+
+          await sendSubscriptionPaymentFailedEmail({
+            entityName: `${this.team.name} ${this.team.isOrganization ? "organization" : "team"}`,
+            billingPortalUrl: billingPortalUrl,
+            to: member.email,
+            language: { translate },
+          });
+        })
+      );
+
+      const failedEmails = emailsSent.filter((result) => result.status === "rejected");
+      const failedEmailCount = failedEmails.length;
+
+      log.info(
+        `Sent payment failed email for team ${this.team.id} to ${
+          membersToSendBillingEmail.length - failedEmailCount
+        } members. Failed to send email to ${failedEmailCount} members.`
+      );
+    } catch (error) {
+      this.logErrorFromUnknown(error);
+      throw error;
+    }
+  }
 }

packages/features/ee/teams/repositories/TeamRepository.test.ts

@@ -172,6 +172,7 @@ describe("TeamRepository", () => {
           metadata: true,
           parentId: true,
           isOrganization: true,
+          name: true,
         },
       });
       expect(result).toEqual(mockTeam);

packages/features/ee/teams/repositories/TeamRepository.ts

@@ -287,6 +287,7 @@ export class TeamRepository {
         metadata: true,
         parentId: true,
         isOrganization: true,
+        name: true,
       },
     });
   }

packages/features/pbac/domain/repositories/IPermissionRepository.ts

@@ -82,4 +82,14 @@ export interface IPermissionRepository {
     fallbackRoles: MembershipRole[];
     orgId?: number;
   }): Promise<number[]>;
+
+  /**
+   * Gets all users in a team who have a specific permission
+   */
+  getUsersWithPermissionInTeam(params: {
+    teamId: number;
+    permission: PermissionString;
+    fallbackRoles: MembershipRole[];
+    take?: number;
+  }): Promise<{ id: number; name: string | null; email: string; locale: string | null }[]>;
 }