background sync toast msg update #92 (#529)

background sync toast msg update #92 (#529)

Author: ann-aot

forms-flow-rsbcservice/src/helpers/helperDbServices.ts

@@ -146,7 +146,8 @@ class DBServiceHelper {
   public static constructApplicationData(
     formId: string,
     submissionId: string,
-    formData: any
+    formData: any,
+    submission: any
   ): Application {
     const userDetails = this.getUserDetails();
     const randomId = this.generateRandomNumber();
@@ -172,6 +173,7 @@ class DBServiceHelper {
       processName: null,
       processTenant: null,
       submissionId,
+      dashboardColumns: submission?.data?.dashboardColumns,
     };
   }
 

forms-flow-rsbcservice/src/services/offlineSubmissions.ts

@@ -26,44 +26,29 @@ class OfflineSubmissions {
    * It returns the count of drafts and submissions processed.
    */
   public static async processOfflineSubmissions(): Promise<void> {
-    let draftsProcessed = 0;
-    let submissionsProcessed = 0;
-    let totalSubmission = 0;
-
     try {
       await this.retryToken();
 
       const submissions =
         await OfflineFetchService.fetchAllNonActiveOfflineSubmissions();
-      totalSubmission = submissions.length ?? 0;
-      console.log(submissions);
       const processPromises = [
-        this.processDrafts(submissions, (count) => (draftsProcessed += count)),
-        this.processSubmission(
-          submissions,
-          (count) => (submissionsProcessed += count)
-        ),
+        this.processDrafts(submissions),
+        this.processSubmission(submissions),
         this.processDraftDelete()
       ];
 
       // Wait for all processes to finish
       await Promise.all(processPromises);
       PubSub.publish("DRAFT_ENABLED_SYNC_COMPLETED", {
-        status: "completed",
-        totalSubmission: totalSubmission,
-        draftsProcessed: draftsProcessed ?? 0,
-        submissionsProcessed: submissionsProcessed ?? 0
+        status: "completed"
       });
     } catch (error) {
       // Log error and track failed drafts/submissions
       console.error("Error processing drafts or submissions:", error);
 
       // Publish the failure status with counts
       PubSub.publish("DRAFT_ENABLED_SYNC_COMPLETED", {
-        status: "incompleted",
-        totalSubmission: totalSubmission,
-        draftsProcessed: draftsProcessed ?? 0,
-        submissionsProcessed: submissionsProcessed ?? 0
+        status: "incompleted"
       });
     }
   }
@@ -120,11 +105,9 @@ class OfflineSubmissions {
    * - If the draft exists and has both a server draft ID and application ID, it will be updated.
    * - If the draft is new (no server IDs), it will be created.
    * @param submissions List of offline submissions to process.
-   * @param countCallback Callback to update the draft count.
    */
   private static async processDrafts(
-    submissions: OfflineSubmission[],
-    countCallback: (count: number) => void
+    submissions: OfflineSubmission[]
   ): Promise<void> {
     const draftSubmissions = submissions.filter(
       (submission) => submission.type === "draft"
@@ -134,7 +117,6 @@ class OfflineSubmissions {
     await Promise.all(
       draftSubmissions.map(async (draft) => {
         await this.handleDraftSubmission(draft);
-        countCallback(1); // Increment count for each processed draft
       })
     );
   }
@@ -206,11 +188,9 @@ class OfflineSubmissions {
    * - If the application exists and has both server draft ID and application ID, it will be updated.
    * - If the application is new (no server IDs), it will be created.
    * @param submissions List of offline submissions to process.
-   * @param countCallback Callback to update the submission count.
    */
   private static async processSubmission(
-    submissions: OfflineSubmission[],
-    countCallback: (count: number) => void
+    submissions: OfflineSubmission[]
   ): Promise<void> {
     const submittedData = submissions.filter(
       (submission) => submission.type === "application"
@@ -220,8 +200,6 @@ class OfflineSubmissions {
     await Promise.all(
       submittedData.map(async (data) => {
         await this.handleSubmission(data);
-        // Increment count for each processed submission
-        countCallback(1);
       })
     );
   }

forms-flow-rsbcservice/src/storage/dbInsertServices.ts

@@ -436,7 +436,8 @@ class OfflineSaveService {
       const applicationData = DBServiceHelper.constructApplicationData(
         formId,
         draft.localSubmissionId,
-        formData
+        formData,
+        data
       );
       await this.saveFFDataToIndexedDB("offlineSubmission", draft);
       await this.saveFFDataToIndexedDB("applications", applicationData);

forms-flow-rsbcservice/src/storage/dbUpdateServices.ts

@@ -81,7 +81,8 @@ class OfflineEditService {
       const applicationData = DBServiceHelper.constructApplicationData(
         formId,
         draft.localSubmissionId,
-        formData
+        formData,
+        newSubmissionData
       );
       await OfflineSaveService.saveFFDataToIndexedDB(
         "applications",

forms-flow-rsbcservice/src/storage/ffDb.ts

@@ -59,6 +59,7 @@ export interface Application {
   processName: string;
   processTenant: string;
   submissionId: string;
+  dashboardColumns: Record<string, any>[];
 }
 
 export interface Draft {
@@ -178,7 +179,7 @@ class FormsFlowDB extends Dexie {
         "_id, title, description, name, path, type, created, modified, machineName, parentFormId",
       activeForm: "localDraftId, serverDraftId",
       formProcesses: "formId, formName",
-      deletedDrafts: "serverDraftId"
+      deletedDrafts: "serverDraftId",
     });
   }
 }