direct pushes

Author: alexanderkirtzel

packages/sources/node/src/lib/handle.ts

@@ -53,7 +53,3 @@ export const handleCommand: SourceNode.HandleCommand = async (
 
   return createPushResult(result);
 };
-
-export const handleEvent: SourceNode.HandleEvent = async (instance, event) => {
-  return await pushToDestinations(instance, event);
-};

packages/sources/node/src/lib/push.ts

@@ -1,7 +1,13 @@
 import type { WalkerOS } from '@elbwalker/types';
 import type { SourceNode, Elb } from '../types';
-import { assign, isCommand, isSameType, tryCatchAsync } from '@elbwalker/utils';
-import { handleCommand, handleEvent } from './handle';
+import {
+  assign,
+  isCommand,
+  isSameType,
+  pushToDestinations,
+  tryCatchAsync,
+} from '@elbwalker/utils';
+import { handleCommand } from './handle';
 
 export function createPush(instance: SourceNode.Instance): Elb.Fn {
   const push = async (
@@ -39,7 +45,7 @@ export function createPush(instance: SourceNode.Instance): Elb.Fn {
           result = assign(result, commandResult);
         } else if (event) {
           // Regular event
-          const eventResult = await handleEvent(instance, event);
+          const eventResult = await pushToDestinations(instance, event);
           result = assign(result, eventResult);
           result.event = event;
         }

packages/sources/node/src/types/source.ts

@@ -38,11 +38,6 @@ export type HandleCommand = (
   options?: PushOptions,
 ) => Promise<Elb.PushResult>;
 
-export type HandleEvent = (
-  instance: Instance,
-  event: WalkerOS.Event,
-) => Promise<Elb.PushResult>;
-
 export interface Command {
   name: string;
   data: unknown;

packages/sources/walkerjs/src/lib/handle.ts

@@ -83,10 +83,3 @@ export async function handleCommand(
 
   return createPushResult(result);
 }
-
-export async function handleEvent(
-  instance: SourceWalkerjs.Instance,
-  event: WalkerOS.Event,
-): Promise<Elb.PushResult> {
-  return await pushToDestinations(instance, event);
-}

packages/sources/walkerjs/src/lib/push.ts

@@ -1,6 +1,6 @@
 import type { WalkerOS } from '@elbwalker/types';
 import type { Elb, SourceWalkerjs } from '../types';
-import { handleCommand, handleEvent } from './handle';
+import { handleCommand } from './handle';
 import {
   Const,
   assign,
@@ -11,6 +11,7 @@ import {
   isObject,
   isSameType,
   isString,
+  pushToDestinations,
   tryCatchAsync,
   useHooks,
 } from '@elbwalker/utils';
@@ -56,7 +57,7 @@ export function createPush(instance: SourceWalkerjs.Instance): Elb.Fn {
           await handleCommand(instance, command, pushData, options);
         } else if (event) {
           // Regular event
-          await handleEvent(instance, event);
+          await pushToDestinations(instance, event);
         }
 
         return assign({ status: { ok: true } }, result);