feat(api): add get user subscription services' (#358)

apps/api/prisma/migrations/20240921234642_add_user_entitlement/migration.sql

@@ -0,0 +1,4 @@
+-- AlterTable
+ALTER TABLE "User" ADD COLUMN     "entitlement" TEXT,
+ADD COLUMN     "entitlementExpiresAt" TIMESTAMP(3),
+ADD COLUMN     "entitlementProductIdentifier" TEXT;

apps/api/prisma/schema.prisma

@@ -23,8 +23,13 @@ model User {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  email                        String                        @unique
-  name                         String?
+  email String  @unique
+  name  String?
+
+  entitlement                  String?
+  entitlementExpiresAt         DateTime?
+  entitlementProductIdentifier String?
+
   walletAccounts               UserWalletAccount[]
   budgetUsers                  BudgetUser[]
   transactions                 Transaction[]

apps/api/v1/services/user.service.ts

@@ -1,5 +1,11 @@
 import type { CreateUser } from '@6pm/validation'
+import type { User } from '@prisma/client'
+import { getLogger } from '../../lib/log'
 import prisma from '../../lib/prisma'
+import {
+  getCustomerActiveSubscription,
+  getOrCreateCustomer,
+} from './revenue-cat.service'
 
 export async function findUserById(id: string) {
   return await prisma.user.findUnique({
@@ -37,3 +43,59 @@ export async function deleteUser(userId: string) {
     },
   })
 }
+
+export async function syncUserSubscription(user: User) {
+  const logger = getLogger(`${syncAllUsersSubscription.name}:${user.id}`)
+
+  logger.info('Current user %o', user)
+
+  const customer = await getOrCreateCustomer({
+    userId: user.id,
+  })
+
+  const activeSubscription = getCustomerActiveSubscription(customer)
+
+  const updatedUser = await prisma.user.update({
+    where: { id: user.id },
+    data: {
+      entitlement: activeSubscription?.entitlement ?? null,
+      entitlementExpiresAt: activeSubscription?.subscription.expires_date
+        ? new Date(activeSubscription.subscription.expires_date)
+        : null,
+      entitlementProductIdentifier:
+        activeSubscription?.subscription.product_identifier ?? null,
+    },
+  })
+
+  logger.info('Updated user %o', updatedUser)
+
+  return updatedUser
+}
+
+export async function syncAllUsersSubscription() {
+  const logger = getLogger(syncAllUsersSubscription.name)
+  const users = await prisma.user.findMany()
+  const failed = []
+
+  logger.info('Syncing %d users', users.length)
+
+  for (const user of users) {
+    try {
+      await syncUserSubscription(user)
+      logger.info('Synced user %s', user.email)
+    } catch (error) {
+      failed.push(user.email)
+
+      logger.warn('Failed to sync user %s', user.email)
+      logger.error(error)
+    }
+  }
+
+  logger.info('Synced %d users. Failed %d', users.length, failed.length)
+
+  return {
+    total: users.length,
+    success: users.length - failed.length,
+    failed,
+  }
+}