From bc10c88f0817fbc29fec6623f4fc38152f7fbb89 Mon Sep 17 00:00:00 2001
From: akshayitzme <akshayitzme.official@gmail.com>
Date: Thu, 5 Dec 2024 17:16:49 +0530
Subject: [PATCH] feat: sync stockMovement

---
 src/utils/erpnextSync.ts | 35 +++++++++++++++++++++++++++++++----
 1 file changed, 31 insertions(+), 4 deletions(-)

diff --git a/src/utils/erpnextSync.ts b/src/utils/erpnextSync.ts
index baf13c6a..af021dd1 100644
--- a/src/utils/erpnextSync.ts
+++ b/src/utils/erpnextSync.ts
@@ -6,6 +6,7 @@ import { DocValueMap } from 'fyo/core/types';
 import { Doc } from 'fyo/model/doc';
 import { ERPNextSyncQueue } from 'models/baseModels/ERPNextSyncQueue/ERPNextSyncQueue';
 import { SalesInvoice } from 'models/baseModels/SalesInvoice/SalesInvoice';
+import { StockMovementItem } from 'models/inventory/StockMovementItem';
 
 export async function updateERPNSyncSettings(fyo: Fyo) {
   const syncSettingsDoc = (await fyo.doc.getDoc(
@@ -193,16 +194,17 @@ async function performPreSync(fyo: Fyo, doc: DocValueMap) {
       }
       return;
 
-    case ModelNameEnum.Party:
+    case 'Customer':
+    case 'Supplier':
       const isAddressExists = await fyo.db.exists(
         ModelNameEnum.Address,
-        doc.addressName as string
+        doc.address as string
       );
 
       if (!isAddressExists) {
         await addToFetchFromERPNextQueue(fyo, {
           referenceType: ModelNameEnum.Address,
-          documentName: doc.addressName,
+          documentName: doc.address,
         });
       }
 
@@ -210,6 +212,23 @@ async function performPreSync(fyo: Fyo, doc: DocValueMap) {
 
     case ModelNameEnum.SalesInvoice:
       return await preSyncSalesInvoice(fyo, doc as SalesInvoice);
+
+    case ModelNameEnum.StockMovement:
+      if (!doc || !doc.items) {
+        return;
+      }
+
+      for (const item of doc.items as StockMovementItem[]) {
+        const isItemExists = await fyo.db.exists(ModelNameEnum.Item, item.item);
+
+        if (!isItemExists) {
+          await addToFetchFromERPNextQueue(fyo, {
+            referenceType: ModelNameEnum.Item,
+            documentName: item.item,
+          });
+        }
+      }
+      return;
     default:
       return;
   }
@@ -364,7 +383,9 @@ export async function syncDocumentsToERPNext(fyo: Fyo) {
         await logDoc.delete();
       }
     }
-  } catch (error) {}
+  } catch (error) {
+    return error;
+  }
 }
 
 async function syncFetchFromERPNextQueue(fyo: Fyo) {
@@ -551,6 +572,12 @@ export interface ERPNSyncDocsResponse {
     failed_log?: DocValueMap[];
   };
 }
+export interface FetchFromBooksResponse {
+  message: {
+    success: boolean;
+    data?: DocValueMap[];
+  };
+}
 
 export interface ERPNextSyncSettingsAPIResponse {
   message: {