⚡ Replace updates with updateManys when possible

Easy performance win to avoid triggering SELECT query after an UPDATE

apps/builder/src/features/billing/api/getUsage.ts

@@ -36,11 +36,6 @@ export const getUsage = authenticatedProcedure
 
     const now = new Date()
     const firstDayOfMonth = new Date(now.getFullYear(), now.getMonth(), 1)
-    const firstDayOfNextMonth = new Date(
-      now.getFullYear(),
-      now.getMonth() + 1,
-      1
-    )
     const [
       totalChatsUsed,
       {
@@ -62,7 +57,6 @@ export const getUsage = authenticatedProcedure
             hasStarted: true,
             createdAt: {
               gte: firstDayOfMonth,
-              lt: firstDayOfNextMonth,
             },
           },
         }),

apps/builder/src/lib/googleSheets.ts

@@ -48,7 +48,7 @@ const updateTokens =
       access_token: credentials.access_token,
     }
     const { encryptedData, iv } = await encrypt(newCredentials)
-    await prisma.credentials.update({
+    await prisma.credentials.updateMany({
       where: { id: credentialsId },
       data: { data: encryptedData, iv },
     })

apps/builder/src/pages/api/auth/[...nextauth].ts

@@ -216,7 +216,7 @@ const updateLastActivityDate = async (user: User) => {
     first.getDate() === second.getDate()
 
   if (!datesAreOnSameDay(user.lastActivityAt, new Date()))
-    await prisma.user.update({
+    await prisma.user.updateMany({
       where: { id: user.id },
       data: { lastActivityAt: new Date() },
     })

apps/builder/src/pages/api/stripe/webhook.ts

@@ -104,7 +104,7 @@ const webhookHandler = async (req: NextApiRequest, res: NextApiResponse) => {
                 data: { claimedAt: new Date() },
               })
 
-            await prisma.workspace.update({
+            await prisma.workspace.updateMany({
               where: { id: workspaceId },
               data: {
                 plan: Plan.CUSTOM,

apps/viewer/src/features/chat/api/sendMessage.ts

@@ -95,13 +95,6 @@ export const sendMessage = publicProcedure
         const { messages, input, clientSideActions, newSessionState, logs } =
           await continueBotFlow(session.state)(message)
 
-        await prisma.chatSession.updateMany({
-          where: { id: session.id },
-          data: {
-            state: newSessionState,
-          },
-        })
-
         const containsSetVariableClientSideAction = clientSideActions?.some(
           (action) => 'setVariable' in action
         )
@@ -114,6 +107,13 @@ export const sendMessage = publicProcedure
         )
           await setResultAsCompleted(session.state.result.id)
 
+        await prisma.chatSession.updateMany({
+          where: { id: session.id },
+          data: {
+            state: newSessionState,
+          },
+        })
+
         return {
           messages,
           input,

apps/viewer/src/features/chat/helpers/continueBotFlow.ts

@@ -162,7 +162,7 @@ const saveVariableValueIfAny =
   }
 
 export const setResultAsCompleted = async (resultId: string) => {
-  await prisma.result.update({
+  await prisma.result.updateMany({
     where: { id: resultId },
     data: { isCompleted: true },
   })
@@ -235,7 +235,7 @@ const saveAnswer =
   }
 
 const setResultAsStarted = async (resultId: string) => {
-  await prisma.result.update({
+  await prisma.result.updateMany({
     where: { id: resultId },
     data: { hasStarted: true },
   })

apps/viewer/src/features/variables/updateVariables.ts

@@ -44,7 +44,7 @@ const updateResultVariables =
     ].filter((variable) => isDefined(variable.value)) as VariableWithValue[]
 
     if (result.id)
-      await prisma.result.update({
+      await prisma.result.updateMany({
         where: {
           id: result.id,
         },

apps/viewer/src/lib/google-sheets.ts

@@ -44,7 +44,7 @@ const updateTokens =
       access_token: credentials.access_token,
     }
     const { encryptedData, iv } = await encrypt(newCredentials)
-    await prisma.credentials.update({
+    await prisma.credentials.updateMany({
       where: { id: credentialsId },
       data: { data: encryptedData, iv },
     })

apps/viewer/src/pages/api/typebots/[typebotId]/blocks/[blockId]/steps/[stepId]/unsubscribeWebhook.ts

@@ -23,7 +23,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
       const { webhookId } = typebot.groups
         .find(byId(groupId))
         ?.blocks.find(byId(blockId)) as WebhookBlock
-      await prisma.webhook.update({
+      await prisma.webhook.updateMany({
         where: { id: webhookId },
         data: { url: null },
       })

apps/viewer/src/pages/api/typebots/[typebotId]/blocks/[blockId]/unsubscribeWebhook.ts

@@ -22,7 +22,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
       const { webhookId } = typebot.groups
         .flatMap((g) => g.blocks)
         .find(byId(blockId)) as WebhookBlock
-      await prisma.webhook.update({
+      await prisma.webhook.updateMany({
         where: { id: webhookId },
         data: { url: null },
       })

apps/viewer/src/pages/api/typebots/[typebotId]/results/[resultId].ts

@@ -9,7 +9,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
       typeof req.body === 'string' ? JSON.parse(req.body) : req.body
     ) as Result
     const resultId = req.query.resultId as string
-    const result = await prisma.result.update({
+    const result = await prisma.result.updateMany({
       where: { id: resultId },
       data,
     })

packages/prisma/mysql/schema.prisma

@@ -1,6 +1,5 @@
 generator client {
-  provider        = "prisma-client-js"
+  provider = "prisma-client-js"
-  previewFeatures = ["extendedWhereUnique"]
 }
 
 datasource db {

packages/scripts/sendAlertEmails.ts

@@ -144,7 +144,7 @@ const sendAlertIfLimitReached = async (
           chatsLimit,
           url: `https://app.typebot.io/typebots?workspaceId=${workspace.id}`,
         })
-        await prisma.workspace.update({
+        await prisma.workspace.updateMany({
           where: { id: workspace.id },
           data: { chatsLimitFirstEmailSentAt: new Date() },
         })
@@ -168,7 +168,7 @@ const sendAlertIfLimitReached = async (
           chatsLimit,
           url: `https://app.typebot.io/typebots?workspaceId=${workspace.id}`,
         })
-        await prisma.workspace.update({
+        await prisma.workspace.updateMany({
           where: { id: workspace.id },
           data: { chatsLimitSecondEmailSentAt: new Date() },
         })
@@ -179,7 +179,7 @@ const sendAlertIfLimitReached = async (
 
     if (totalChatsUsed > chatsLimit * 3 && workspace.plan === Plan.FREE) {
       console.log(`Automatically quarantine workspace ${workspace.id}...`)
-      await prisma.workspace.update({
+      await prisma.workspace.updateMany({
         where: { id: workspace.id },
         data: { isQuarantined: true },
       })