fix(server): subscription delete race condition (#11729)

packages/backend/server/src/plugins/payment/manager/user.ts

@@ -256,17 +256,19 @@ export class UserSubscriptionManager extends SubscriptionManager {
     stripeSubscription,
   }: KnownStripeSubscription) {
     this.assertUserIdExists(userId);
-    this.event.emit('user.subscription.canceled', {
+    const result = await this.db.subscription.deleteMany({
-      userId,
-      plan: lookupKey.plan,
-      recurring: lookupKey.recurring,
-    });
-
-    await this.db.subscription.deleteMany({
       where: {
         stripeSubscriptionId: stripeSubscription.id,
       },
     });
+
+    if (result.count > 0) {
+      this.event.emit('user.subscription.canceled', {
+        userId,
+        plan: lookupKey.plan,
+        recurring: lookupKey.recurring,
+      });
+    }
   }
 
   async cancelSubscription(subscription: Subscription) {

packages/backend/server/src/plugins/payment/manager/workspace.ts

@@ -187,15 +187,17 @@ export class WorkspaceSubscriptionManager extends SubscriptionManager {
       );
     }
 
-    this.event.emit('workspace.subscription.canceled', {
+    const result = await this.db.subscription.deleteMany({
-      workspaceId,
-      plan: lookupKey.plan,
-      recurring: lookupKey.recurring,
-    });
-
-    await this.db.subscription.deleteMany({
       where: { stripeSubscriptionId: stripeSubscription.id },
     });
+
+    if (result.count > 0) {
+      this.event.emit('workspace.subscription.canceled', {
+        workspaceId,
+        plan: lookupKey.plan,
+        recurring: lookupKey.recurring,
+      });
+    }
   }
 
   getSubscription(identity: z.infer<typeof WorkspaceSubscriptionIdentity>) {