fix: missing reupload product check on success

Author: desoindx

src/db/upload.ts

@@ -135,11 +135,17 @@ export const checkUploadsStatus = async (uploadsId: string[]) => {
 
   return Promise.all(
     uploads
-      .filter((upload) =>
-        upload.products.every((product) => product.status === Status.Done || product.status === Status.Error),
+      .filter(
+        (upload) =>
+          upload.products.every((product) => product.status === Status.Done || product.status === Status.Error) &&
+          upload.reUploadProducts.every(
+            (product) => product.product.status === Status.Done || product.product.status === Status.Error,
+          ),
       )
       .map(async (upload) => {
-        const allDone = upload.products.every((product) => product.status === Status.Done)
+        const allDone =
+          upload.products.every((product) => product.status === Status.Done) &&
+          upload.reUploadProducts.every((product) => product.product.status === Status.Done)
         if (allDone) {
           return completeUpload(upload)
         } else {

src/scripts/generateCSV.ts

@@ -44,7 +44,7 @@ const generate = (name: string, length?: string) => {
       countryMaking: faker.helpers.arrayElement(Object.keys(countries)),
       countrySpinning: faker.helpers.arrayElement(Object.keys(countries)),
       impressionMapping: faker.helpers.arrayElement(["", ...Object.keys(impressionMapping)]),
-      impressionPercentage: faker.number.float({ min: 0, max: 1 }),
+      impressionPercentage: faker.number.float({ min: 0, max: 0.8 }),
       mass: faker.number.float({ min: 0.01 }),
       price: faker.number.float({ min: 1, max: 1000 }),
       airTransportRatio: faker.number.float({ min: 0, max: 1 }),

src/utils/queue/uploads.ts

@@ -1,8 +1,8 @@
 import chardet from "chardet"
 import { parseCSV } from "../csv/parse"
 import { createProducts } from "../../db/product"
-import { completeUpload, failUpload } from "../../services/upload"
-import { getFirstFileUpload, updateUploadToPending } from "../../db/upload"
+import { failUpload } from "../../services/upload"
+import { checkUploadsStatus, getFirstFileUpload, updateUploadToPending } from "../../db/upload"
 import { downloadFileFromS3 } from "../s3/bucket"
 import { decryptAndDezipFile } from "../encryption/encryption"
 
@@ -39,7 +39,7 @@ export const processUploadsToQueue = async () => {
     const csvData = await parseCSV(buffer, encoding, upload)
     const numberOfCreatedProduct = await createProducts(csvData)
     if (numberOfCreatedProduct === 0) {
-      await completeUpload(upload)
+      await checkUploadsStatus([upload.id])
     }
     console.log(`Upload processed, ${csvData.products.length} products, ${numberOfCreatedProduct} created`)
   } catch (error) {