OUT-2974: fetch item from QBO before creating and map if exists

src/app/api/quickbooks/product/product.service.ts

@@ -548,44 +548,54 @@ export class ProductService extends BaseService {
       )
       const productDescription = convert(copilotProduct.description)
 
-      const tokenService = new TokenService(this.user)
-      const incomeAccountRef = await tokenService.checkAndUpdateAccountStatus(
-        AccountTypeObj.Income,
-        qbTokenInfo.intuitRealmId,
-        intuitApi,
-        qbTokenInfo.incomeAccountRef,
-      )
-      // create item in QB
-      const item = await this.createItemInQB(
-        {
-          productName: z.string().parse(qbItemName),
-          unitPrice: priceResource.amount,
-          incomeAccRefVal: z.string().parse(incomeAccountRef),
-          productDescription,
-        },
-        intuitApi,
-      )
+      // check if item with name exists in QBO
+      let qbItem = await intuitApi.getAnItem(qbItemName, undefined, true)
+
+      if (!qbItem) {
+        const tokenService = new TokenService(this.user)
+        const incomeAccountRef = await tokenService.checkAndUpdateAccountStatus(
+          AccountTypeObj.Income,
+          qbTokenInfo.intuitRealmId,
+          intuitApi,
+          qbTokenInfo.incomeAccountRef,
+        )
+        // create item in QB
+        qbItem = await this.createItemInQB(
+          {
+            productName: z.string().parse(qbItemName),
+            unitPrice: priceResource.amount,
+            incomeAccRefVal: z.string().parse(incomeAccountRef),
+            productDescription,
+          },
+          intuitApi,
+        )
+      }
 
       // map product and price
       await this.createQBProduct({
         portalId: this.user.workspaceId,
         productId: priceResource.productId,
         priceId: priceResource.id,
         unitPrice: priceResource.amount.toFixed(2),
-        qbItemId: item.Id,
-        qbSyncToken: item.SyncToken,
+        qbItemId: qbItem.Id,
+        qbSyncToken: qbItem.SyncToken,
         name: qbItemName,
         copilotName: copilotProduct.name,
         description: productDescription,
       })
 
       console.info('WebhookService#webhookPriceCreated | Product created in QB')
-      await this.logSync(priceResource.productId, item.Id, EventType.CREATED, {
-        productName: copilotProduct.name,
-        productPrice: priceResource.amount.toFixed(2),
-        qbItemName: item.Name,
-        copilotPriceId: priceResource.id,
-      })
+      await this.logSync(
+        priceResource.productId,
+        qbItem.Id,
+        EventType.CREATED,
+        {
+          productName: copilotProduct.name,
+          productPrice: priceResource.amount.toFixed(2),
+          qbItemName: qbItem.Name,
+          copilotPriceId: priceResource.id,
+        },
+      )
 
       this.unsetTransaction()
     })

src/app/api/quickbooks/sync/sync.service.ts

@@ -17,7 +17,7 @@
 import CustomLogger from '@/utils/logger'
 import { QBSyncLog, QBSyncLogSelectSchemaType } from '@/db/schema/qbSyncLogs'
 import { z } from 'zod'
 import { and, eq, inArray, max } from 'drizzle-orm'
 import { WhereClause } from '@/type/common'
 import { TokenService } from '@/app/api/quickbooks/token/token.service'
 import { QBPortalConnection } from '@/db/schema/qbPortalConnections'
@@ -522,7 +522,7 @@
     // report to sentry if any records has exceeded max retry count
     if (attempt == MAX_ATTEMPTS) {
       captureMessage(
-        `SyncService#intiateSync | Records exceeded max retry count. Portal Id: ${this.user.workspaceId}.`,
+        `SyncService#checkAndUpdateAttempt | Records exceeded max retry count. Portal Id: ${this.user.workspaceId}.`,
         {
           tags: {
             key: 'exceedMaxAttempts', // can be used to search like "key:exceedMaxAttempts"