feat: erpnext sync

Author: akshayitzme

fyo/model/doc.ts

@@ -44,6 +44,8 @@ import {
   ValidationMap,
 } from './types';
 import { validateOptions, validateRequired } from './validationFunction';
+import { getShouldDocSyncToERPNext } from 'src/utils/erpnextSync';
+import { ModelNameEnum } from 'models/types';
 
 export class Doc extends Observable<DocValue | Doc[]> {
   /* eslint-disable @typescript-eslint/no-floating-promises */
@@ -247,6 +249,22 @@ export class Doc extends Observable<DocValue | Doc[]> {
     return true;
   }
 
+  get shouldDocSyncToERPNext() {
+    const syncEnabled = !!this.fyo.singles.ERPNextSyncSettings?.isEnabled;
+    if (!syncEnabled) {
+      return false;
+    }
+
+    if (!this.schemaName || !this.fyo.singles.ERPNextSyncSettings) {
+      return false;
+    }
+
+    return getShouldDocSyncToERPNext(
+      this.fyo.singles.ERPNextSyncSettings,
+      this
+    );
+  }
+
   _setValuesWithoutChecks(data: DocValueMap, convertToDocValue: boolean) {
     for (const field of this.schema.fields) {
       const { fieldname, fieldtype } = field;
@@ -912,6 +930,28 @@ export class Doc extends Observable<DocValue | Doc[]> {
     this._notInserted = false;
     await this.trigger('afterSync');
     this.fyo.doc.observer.trigger(`sync:${this.schemaName}`, this.name);
+
+    if (this._addDocToSyncQueue && !!this.shouldDocSyncToERPNext) {
+      const isDocExistsInQueue = await this.fyo.db.getAll(
+        ModelNameEnum.ERPNextSyncQueue,
+        {
+          filters: {
+            referenceType: this.schemaName,
+            documentName: this.name as string,
+          },
+        }
+      );
+
+      if (!isDocExistsInQueue.length) {
+        this.fyo.doc
+          .getNewDoc(ModelNameEnum.ERPNextSyncQueue, {
+            referenceType: this.schemaName,
+            documentName: this.name,
+          })
+          .sync();
+      }
+    }
+
     this._syncing = false;
     return doc;
   }

main/api.ts

@@ -0,0 +1,10 @@
+import fetch, { RequestInit } from 'node-fetch';
+
+export async function sendAPIRequest(
+  endpoint: string,
+  options: RequestInit | undefined
+) {
+  return (await fetch(endpoint, options)).json() as unknown as {
+    [key: string]: string | number | boolean;
+  }[];
+}

main/preload.ts

@@ -180,6 +180,18 @@ const ipc = {
     await ipcRenderer.invoke(IPC_ACTIONS.SEND_ERROR, body);
   },
 
+  async sendAPIRequest(endpoint: string, options: RequestInit | undefined) {
+    return (await ipcRenderer.invoke(
+      IPC_ACTIONS.SEND_API_REQUEST,
+      endpoint,
+      options
+    )) as Promise<
+      {
+        [key: string]: string | number | boolean | Date | object | object[];
+      }[]
+    >;
+  },
+
   registerMainProcessErrorListener(listener: IPCRendererListener) {
     ipcRenderer.on(IPC_CHANNELS.LOG_MAIN_PROCESS_ERROR, listener);
   },

main/registerIpcMainActionListeners.ts

@@ -26,6 +26,7 @@ import {
   setAndGetCleanedConfigFiles,
 } from './helpers';
 import { saveHtmlAsPdf } from './saveHtmlAsPdf';
+import { sendAPIRequest } from './api';
 
 export default function registerIpcMainActionListeners(main: Main) {
   ipcMain.handle(IPC_ACTIONS.CHECK_DB_ACCESS, async (_, filePath: string) => {
@@ -209,6 +210,13 @@ export default function registerIpcMainActionListeners(main: Main) {
     return getTemplates();
   });
 
+  ipcMain.handle(
+    IPC_ACTIONS.SEND_API_REQUEST,
+    async (e, endpoint: string, options: RequestInit | undefined) => {
+      return sendAPIRequest(endpoint, options);
+    }
+  );
+
   /**
    * Database Related Actions
    */

models/helpers.ts

@@ -818,8 +818,6 @@ export async function getPricingRulesOfCoupons(
     })) as CouponCode[];
   }
 
-  console.log('pricingRuleDocNames', pricingRuleDocNames);
-
   const filteredPricingRuleNames = appliedCoupons.filter(
     (val) => val.pricingRule === pricingRuleDocNames![0]
   );
@@ -842,7 +840,6 @@ export async function getPricingRulesOfCoupons(
     }
   )) as PricingRule[];
 
-  console.log('pricingRuleDocsForItem', pricingRuleDocsForItem);
   return pricingRuleDocsForItem;
 }
 
@@ -1204,7 +1201,7 @@ export async function updatePricingRule(sinvDoc: SalesInvoice) {
   ).length;
 
   setTimeout(() => {
-    (async () => {
+    void (async () => {
       if (appliedPricingRuleCount !== applicablePricingRuleNames?.length) {
         await sinvDoc.appendPricingRuleDetail(applicablePricingRuleNames);
         await sinvDoc.applyProductDiscount();

models/types.ts

@@ -61,7 +61,9 @@ export enum ModelNameEnum {
   POSSettings = 'POSSettings',
   POSShift = 'POSShift',
 
-  ERPNextSyncSettings= 'ERPNextSyncSettings'
+  ERPNextSyncSettings= 'ERPNextSyncSettings',
+  ERPNextSyncQueue = 'ERPNextSyncQueue',
+  FetchFromERPNextQueue = 'FetchFromERPNextQueue',
 }
 
 export type ModelName = keyof typeof ModelNameEnum;

src/App.vue

@@ -70,6 +70,7 @@ import { Shortcuts } from './utils/shortcuts';
 import { routeTo } from './utils/ui';
 import { useKeys } from './utils/vueUtils';
 import { setDarkMode } from 'src/utils/theme';
+import { initERPNSync, updateERPNSyncSettings } from './utils/erpnextSync';
 
 enum Screen {
   Desk = 'Desk',
@@ -224,6 +225,8 @@ export default defineComponent({
 
       await initializeInstance(filePath, false, countryCode, fyo);
       await updatePrintTemplates(fyo);
+      await updateERPNSyncSettings(fyo);
+      initERPNSync(fyo);
       await this.setDesk(filePath);
     },
     async handleConnectionFailed(error: Error, actionSymbol: symbol) {

src/utils/api.ts

@@ -0,0 +1,6 @@
+export async function sendAPIRequest(
+  endpoint: string,
+  options: RequestInit | undefined
+) {
+  return await ipc.sendAPIRequest(endpoint, options);
+}