[server] Refactor StripeService.createCustomer to only use attributionIds

Author: jankeromnes

components/server/ee/src/user/stripe-service.ts

@@ -43,55 +43,32 @@ export class StripeService {
         return result.data[0]?.id;
     }
 
-    async createCustomerForUser(user: User): Promise<string> {
-        const attributionId = AttributionId.render({ kind: "user", userId: user.id });
+    async createCustomerForAttributionId(
+        attributionId: string,
+        preferredCurrency: string,
+        billingEmail?: string,
+        billingName?: string,
+    ): Promise<string> {
         if (await this.findCustomerByAttributionId(attributionId)) {
-            throw new Error(`A Stripe customer already exists for user '${user.id}'`);
+            throw new Error(`A Stripe customer already exists for '${attributionId}'`);
         }
         // Create the customer in Stripe
         const customer = await this.getStripe().customers.create({
-            email: User.getPrimaryEmail(user),
-            name: User.getName(user),
-            metadata: { attributionId },
+            email: billingEmail,
+            name: billingName,
+            metadata: { attributionId, preferredCurrency },
         });
         // Wait for the customer to show up in Stripe search results before proceeding
         let attempts = 0;
         while (!(await this.findCustomerByAttributionId(attributionId))) {
             await new Promise((resolve) => setTimeout(resolve, POLL_CREATED_CUSTOMER_INTERVAL_MS));
             if (++attempts > POLL_CREATED_CUSTOMER_MAX_ATTEMPTS) {
-                throw new Error(`Could not confirm Stripe customer creation for user '${user.id}'`);
+                throw new Error(`Could not confirm Stripe customer creation for '${attributionId}'`);
             }
         }
         return customer.id;
     }
 
-    async createCustomerForTeam(user: User, team: Team): Promise<string> {
-        const attributionId = AttributionId.render({ kind: "team", teamId: team.id });
-        if (await this.findCustomerByAttributionId(attributionId)) {
-            throw new Error(`A Stripe customer already exists for team '${team.id}'`);
-        }
-        // Create the customer in Stripe
-        const userName = User.getName(user);
-        const customer = await this.getStripe().customers.create({
-            email: User.getPrimaryEmail(user),
-            name: userName ? `${userName} (${team.name})` : team.name,
-            metadata: { attributionId },
-        });
-        // Wait for the customer to show up in Stripe search results before proceeding
-        let attempts = 0;
-        while (!(await this.findCustomerByAttributionId(attributionId))) {
-            await new Promise((resolve) => setTimeout(resolve, POLL_CREATED_CUSTOMER_INTERVAL_MS));
-            if (++attempts > POLL_CREATED_CUSTOMER_MAX_ATTEMPTS) {
-                throw new Error(`Could not confirm Stripe customer creation for team '${team.id}'`);
-            }
-        }
-        return customer.id;
-    }
-
-    async setPreferredCurrencyForCustomer(customerId: string, currency: string): Promise<void> {
-        await this.getStripe().customers.update(customerId, { metadata: { preferredCurrency: currency } });
-    }
-
     async setDefaultPaymentMethodForCustomer(customerId: string, setupIntentId: string): Promise<void> {
         const setupIntent = await this.getStripe().setupIntents.retrieve(setupIntentId);
         if (typeof setupIntent.payment_method !== "string") {

components/server/ee/src/workspace/gitpod-server-impl.ts

@@ -2099,14 +2099,12 @@ export class GitpodServerEEImpl extends GitpodServerImpl {
             if (await this.stripeService.findCustomerByAttributionId(attributionId)) {
                 throw new ResponseError(
                     ErrorCodes.BAD_REQUEST,
-                    "A Stripe customer profile already exists for this attributionId",
+                    `A Stripe customer profile already exists for '${attributionId}'`,
                 );
             }
-            const customerId =
-                attrId.kind === "team"
-                    ? await this.stripeService.createCustomerForTeam(user, team!)
-                    : await this.stripeService.createCustomerForUser(user);
-            await this.stripeService.setPreferredCurrencyForCustomer(customerId, currency);
+            const billingEmail = User.getPrimaryEmail(user);
+            const billingName = attrId.kind === "team" ? team!.name : User.getName(user);
+            await this.stripeService.createCustomerForAttributionId(attributionId, currency, billingEmail, billingName);
         } catch (error) {
             log.error(`Failed to create Stripe customer profile for '${attributionId}'`, error);
             throw new ResponseError(