fix: LSDV-4864: LEAP-148: Magic Wand doesn't work with MIG

src/sdk/dm-sdk.js

@@ -441,7 +441,7 @@ export class DataManager {
       const annotationID = annotation?.id ?? task.lastAnnotation?.id;
 
       // this.lsf.loadTask(task.id, annotationID);
-      this.lsf.selectTask(task, annotationID);
+      await this.lsf.selectTask(task, annotationID);
     }
   }
 

src/sdk/lsf-sdk.js

@@ -238,7 +238,7 @@ export class LSFWrapper {
       // for preload it's good to always load the first one
       const annotation = task.annotations[0];
 
-      this.selectTask(task, annotation?.id, true);
+      await this.selectTask(task, annotation?.id, true);
     }
 
     return false;
@@ -274,7 +274,7 @@ export class LSFWrapper {
       });
 
       // Add new data from received task
-      if (newTask) this.selectTask(newTask, annotationID, fromHistory);
+      if (newTask) await this.selectTask(newTask, annotationID, fromHistory);
     };
 
     if (isFF(FF_DEV_2887) && this.lsf?.commentStore?.hasUnsaved) {
@@ -292,14 +292,14 @@ export class LSFWrapper {
     await nextAction();
   }
 
-  selectTask(task, annotationID, fromHistory = false) {
+  async selectTask(task, annotationID, fromHistory = false) {
     const needsAnnotationsMerge = task && this.task?.id === task.id;
     const annotations = needsAnnotationsMerge ? [...this.annotations] : [];
 
     this.task = task;
 
     if (needsAnnotationsMerge) {
-      this.task.mergeAnnotations(annotations);
+      await this.task.mergeAnnotations(annotations);
     }
 
     this.loadUserLabels();
@@ -546,7 +546,7 @@ export class LSFWrapper {
   /** @private */
   onUpdateAnnotation = async (ls, annotation, extraData) => {
     const { task } = this;
-    const serializedAnnotation = this.prepareData(annotation);
+    const serializedAnnotation = await this.prepareData(annotation);
 
     Object.assign(serializedAnnotation, extraData);
 
@@ -621,7 +621,9 @@ export class LSFWrapper {
 
   onSubmitDraft = async (studio, annotation, params = {}) => {
     const annotationDoesntExist = !annotation.pk;
-    const data = { body: this.prepareData(annotation, { draft: true }) }; // serializedAnnotation
+    const data = {
+      body: await this.prepareData(annotation, { draft: true }),
+    }; // serializedAnnotation
 
     Object.assign(data.body, params);
 
@@ -692,7 +694,9 @@ export class LSFWrapper {
             body: { annotation: null },
           });
         } else {
-          const annotationData = { body: this.prepareData(currentAnnotation) };
+          const annotationData = {
+            body: await this.prepareData(currentAnnotation),
+          };
 
           await this.datamanager.apiCall("createDraftForTask", {
             taskID: this.task.id,
@@ -743,7 +747,7 @@ export class LSFWrapper {
   async submitCurrentAnnotation(eventName, submit, includeId = false, loadNext = true) {
     const { taskID, currentAnnotation } = this;
     const unique_id = this.task.unique_lock_id;
-    const serializedAnnotation = this.prepareData(currentAnnotation, { includeId });
+    const serializedAnnotation = await this.prepareData(currentAnnotation, { includeId });
 
     if (unique_id) {
       serializedAnnotation.unique_id = unique_id;
@@ -786,15 +790,15 @@ export class LSFWrapper {
   }
 
   /** @private */
-  prepareData(annotation, { includeId, draft } = {}) {
+  async prepareData(annotation, { includeId, draft } = {}) {
     const userGenerate =
       !annotation.userGenerate || annotation.sentUserGenerate;
 
     const result = {
       // task execution time, always summed up with previous values
       lead_time: (new Date() - annotation.loadedDate) / 1000 + Number(annotation.leadTime ?? 0),
       // don't serialize annotations twice for drafts
-      result: (draft ? annotation.versions.draft : annotation.serializeAnnotation()) ?? [],
+      result: (draft ? annotation.versions.draft : await annotation.serializeAnnotation()) ?? [],
       draft_id: annotation.draftId,
       parent_prediction: annotation.parent_prediction,
       parent_annotation: annotation.parent_annotation,

src/sdk/lsf-utils.ts

@@ -63,10 +63,10 @@ export const annotationToServer = (annotation: LSFAnnotation): APIAnnotation =>
   };
 };
 
-export const getAnnotationSnapshot = (c: LSFAnnotation) => ({
+export const getAnnotationSnapshot = async (c: LSFAnnotation) => ({
   id: c.id,
   pk: c.pk,
-  result: c.serializeAnnotation(),
+  result: await c.serializeAnnotation(),
   leadTime: c.leadTime,
   userGenerate: !!c.userGenerate,
   sentUserGenerate: !!c.sentUserGenerate,

src/stores/DataStores/tasks.js

@@ -41,9 +41,8 @@ export const create = (columns) => {
       },
     }))
     .actions((self) => ({
-      mergeAnnotations(annotations) {
-        // skip drafts, they'll be added later
-        self.annotations = annotations.filter(a => a.pk).map((c) => {
+      mergeAnnotations: flow(function *(annotations) {
+        const merged = annotations.filter(a => a.pk).map(async (c) => {
           const existingAnnotation = self.annotations.find(
             (ec) => ec.id === Number(c.pk),
           );
@@ -55,26 +54,31 @@ export const create = (columns) => {
               id: c.id,
               pk: c.pk,
               draftId: c.draftId,
-              result: c.serializeAnnotation(),
+              result: await c.serializeAnnotation(),
               leadTime: c.leadTime,
               userGenerate: !!c.userGenerate,
               sentUserGenerate: !!c.sentUserGenerate,
             };
           }
         });
-      },
 
-      updateAnnotation(annotation) {
+        // skip drafts, they'll be added later
+        self.annotations = yield Promise.all(merged);
+      }),
+
+      updateAnnotation: flow(function *(annotation) {
         const existingAnnotation = self.annotations.find((c) => {
           return c.id === Number(annotation.pk) || c.pk === annotation.pk;
         });
 
+        const snapshot = yield getAnnotationSnapshot(annotation);
+
         if (existingAnnotation) {
-          Object.assign(existingAnnotation, getAnnotationSnapshot(annotation));
+          Object.assign(existingAnnotation, snapshot);
         } else {
-          self.annotations.push(getAnnotationSnapshot(annotation));
+          self.annotations.push(snapshot);
         }
-      },
+      }),
 
       deleteAnnotation(annotation) {
         const index = self.annotations.findIndex((c) => {

src/types/Task.ts

@@ -97,5 +97,5 @@ export interface LSFAnnotation extends LSFAnnotationData {
 
   // editable: boolean;
 
-  serializeAnnotation(): APIResult[];
+  serializeAnnotation(): Promise<APIResult[]>;
 }