fix(overmind): fix async operator issue

Author: christianalfoni

packages/node_modules/overmind/src/operator.ts

@@ -37,10 +37,6 @@ export function stopDebugOperator(
   }
 
   if (value instanceof Promise) {
-    context.execution.emit(EventType.OPERATOR_ASYNC, {
-      ...context.execution,
-      isAsync: true,
-    })
     value
       .then((promiseValue) => {
         context.execution.emit(EventType.OPERATOR_END, {
@@ -127,6 +123,12 @@ export function createOperator<ThisConfig extends IConfiguration>(
   const operator = (err, context, next, final) => {
     startDebugOperator(type, name, context)
     try {
+      let asyncTimeout = setTimeout(() => {
+        context.execution.emit(EventType.OPERATOR_ASYNC, {
+          ...context.execution,
+          isAsync: true,
+        })
+      })
       cb(
         err,
         {
@@ -136,6 +138,7 @@ export function createOperator<ThisConfig extends IConfiguration>(
         },
         context.value,
         (err, value, options = {}) => {
+          clearTimeout(asyncTimeout)
           if (options.path) {
             const newContext = createContext(
               context,
@@ -156,6 +159,7 @@ export function createOperator<ThisConfig extends IConfiguration>(
           }
         },
         (err, value) => {
+          clearTimeout(asyncTimeout)
           stopDebugOperator(context, value, {
             isIntercepted: true,
           })
@@ -205,6 +209,12 @@ export function createMutationOperator<ThisConfig extends IConfiguration>(
       })
     }
     try {
+      let asyncTimeout = setTimeout(() => {
+        context.execution.emit(EventType.OPERATOR_ASYNC, {
+          ...context.execution,
+          isAsync: true,
+        })
+      })
       cb(
         err,
         {
@@ -216,12 +226,14 @@ export function createMutationOperator<ThisConfig extends IConfiguration>(
           ? context.value
           : context.execution.scopeValue(context.value, mutationTree),
         (err, value, options = {}) => {
+          clearTimeout(asyncTimeout)
           stopDebugOperator(context, value, {
             isSkipped: options.isSkipped,
           })
           next(err, createContext(context, value))
         },
         (err, value) => {
+          clearTimeout(asyncTimeout)
           stopDebugOperator(context, value, {
             isIntercepted: true,
           })