feat(overmind): make all operators an action

Author: christianalfoni

packages/node_modules/overmind/src/index.ts

@@ -559,7 +559,7 @@ function startDebugOperator(type, operationName, execution) {
 export function map<Input, Output>(
   operation: (input: Context<Input>) => Output
 ): Operator<Input, Output extends Promise<infer U> ? U : Output> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else {
       const stopDebugOperator = startDebugOperator(
@@ -572,12 +572,15 @@ export function map<Input, Output>(
       next(null, { ...context, value } as any)
     }
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function run<Input>(
   operation: (input: Context<Input>) => void
 ): Operator<Input, Input> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else {
       const stopDebugOperator = startDebugOperator(
@@ -590,12 +593,15 @@ export function run<Input>(
       next(null, context as any)
     }
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function forEach<Input extends any[]>(
   forEachItemOperator: Operator<Input[0], any>
 ): Operator<Input, Input> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else {
       const stopDebugOperator = startDebugOperator(
@@ -627,22 +633,28 @@ export function forEach<Input extends any[]>(
       )
     }
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function filter<Input>(
   operation: (input: Context<Input>) => boolean
 ): Operator<Input, Input> {
-  return (err, context, next, final) => {
+  const instance = (err, context, next, final) => {
     if (err) next(err)
     else if (operation(context)) next(null, context)
     else final(null, context)
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function mutate<Input>(
   operation: (input: Context<Input>) => void
 ): Operator<Input, Input> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else {
       const operatorId = context.execution.operatorId
@@ -663,6 +675,9 @@ export function mutate<Input>(
       next(null, context)
     }
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function fork<
@@ -672,13 +687,16 @@ export function fork<
   operation: (input: Context<Input>) => keyof Paths,
   paths: Paths
 ): Operator<Input, Input> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) return next(err)
     paths[operation(context)](null, context, (err) => {
       if (err) next(err)
       else next(null, context)
     })
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function when<Input, OutputA, OutputB>(
@@ -688,24 +706,30 @@ export function when<Input, OutputA, OutputB>(
     false: Operator<Input, OutputB>
   }
 ): Operator<Input, OutputA | OutputB> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else if (operation(context)) paths.true(null, context, next)
     else paths.false(null, context, next)
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function wait<Input>(ms: number): Operator<Input, Input> {
-  return (err, context, next) => {
+  const instance = (err, context, next) => {
     if (err) next(err)
     else setTimeout(() => next(null, context), ms)
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }
 
 export function debounce<Input>(ms: number): Operator<Input, Input> {
   let timeout
   let previousFinal
-  return (err, value, next, final) => {
+  const instance = (err, value, next, final) => {
     if (err) {
       return next(err)
     }
@@ -719,4 +743,7 @@ export function debounce<Input>(ms: number): Operator<Input, Input> {
       next(null, value)
     }, ms)
   }
+  instance[IS_PIPE] = true
+
+  return instance
 }