fix: 🐛 fix deadlock issues

lucca180 · Nov 17, 2024 · 7b87a00 · 7b87a00
1 parent ce2c162
commit 7b87a00
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 11 deletions.
diff --git a/pages/api/v1/items/[id_name]/index.ts b/pages/api/v1/items/[id_name]/index.ts
@@ -438,7 +438,9 @@ export const fetchOwlsData = async (
         },
       });
 
-      await prisma.$transaction([updateAll, createAll]);
+      await prisma.$transaction([updateAll, createAll], {
+        isolationLevel: Prisma.TransactionIsolationLevel.Serializable,
+      });
     } else if (lastOwls && isSameDay(lastOwls.pricedAt, lastUpdated)) {
       await prisma.owlsPrice.update({
         where: {

diff --git a/pages/api/v1/items/owls.ts b/pages/api/v1/items/owls.ts
@@ -3,6 +3,7 @@ import { isSameDay } from 'date-fns';
 import { NextApiRequest, NextApiResponse } from 'next';
 import prisma from '../../../../utils/prisma';
 import { getManyItems } from './many';
+import { Prisma } from '@prisma/client';
 
 type OwlsRes = {
   recent_updates: {
@@ -81,7 +82,9 @@ export const getLatestOwls = async (limit = 20) => {
         },
       });
 
-      await prisma.$transaction([updateAll, createAll]);
+      await prisma.$transaction([updateAll, createAll], {
+        isolationLevel: Prisma.TransactionIsolationLevel.Serializable,
+      });
 
       item.owls = {
         value: owlsItem.owls_value,

diff --git a/pages/api/v1/prices/process.ts b/pages/api/v1/prices/process.ts
@@ -244,15 +244,20 @@ const POST = async (req: NextApiRequest, res: NextApiResponse) => {
     },
   });
 
-  const result = await prisma.$transaction([
-    prisma.itemPrices.createMany({ data: priceAddList }),
-    prisma.priceProcess2.updateMany({
-      data: { processed: true },
-      where: {
-        internal_id: { in: processedIDs },
-      },
-    }),
-  ]);
+  const result = await prisma.$transaction(
+    [
+      prisma.itemPrices.createMany({ data: priceAddList, skipDuplicates: true }),
+      prisma.priceProcess2.updateMany({
+        data: { processed: true },
+        where: {
+          internal_id: { in: processedIDs },
+        },
+      }),
+    ],
+    {
+      isolationLevel: Prisma.TransactionIsolationLevel.ReadUncommitted,
+    }
+  );
 
   const manualCheckList = priceAddList.filter((x) => x.manual_check).map((x) => x.item_iid);