refactor: rm redudant fns and formatting

sern-handler · Nov 4, 2023 · 132b625 · 132b625
1 parent 03439fe
commit 132b625
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 38 deletions.
diff --git a/src/handlers/dispatchers.ts b/src/handlers/dispatchers.ts
@@ -14,23 +14,6 @@ import { CommandType, Context } from '../core';
 import type { Args } from '../types/utility';
 import type { BothCommand, CommandModule, Module, Processed } from '../types/core-modules';
 
-function dispatchInteraction<T extends CommandModule, V extends BaseInteraction | Message>(
-    payload: { module: Processed<T>; event: V },
-    createArgs: (m: typeof payload.event) => unknown[],
-) {
-    return {
-        module: payload.module,
-        args: createArgs(payload.event),
-    };
-}
-//TODO: refactor dispatchers so that it implements a strategy for each different type of payload?
-export function dispatchMessage(module: Processed<CommandModule>, args: [Context, Args]) {
-    return {
-        module,
-        args,
-    };
-}
-
 function dispatchAutocomplete(payload: {
     module: Processed<BothCommand>;
     event: AutocompleteInteraction;
@@ -52,9 +35,6 @@ export function contextArgs(wrappable: Message | BaseInteraction, messageArgs?:
     return [ctx, args] as [Context, Args];
 }
 
-function interactionArg<T extends BaseInteraction>(interaction: T) {
-    return [interaction] as [T];
-}
 
 function intoPayload(module: Processed<Module>) {
     return pipe(
@@ -109,9 +89,14 @@ export function createDispatcher(payload: {
                  */
                 return dispatchAutocomplete(payload as never);
             }
-            return dispatchInteraction(payload, contextArgs);
+            return {
+                module: payload.module,
+                args: contextArgs(payload.event),
+            };
         }
-        default:
-            return dispatchInteraction(payload, interactionArg);
+        default: return { 
+            module: payload.module,
+            args: [payload.event],
+        };
     }
 }
diff --git a/src/handlers/event-utils.ts b/src/handlers/event-utils.ts
@@ -24,7 +24,7 @@ import {
     useContainerRaw,
 } from '../core/_internal';
 import { Emitter, ErrorHandling, Logging, ModuleManager } from '../core';
-import { contextArgs, createDispatcher, dispatchMessage } from './dispatchers';
+import { contextArgs, createDispatcher } from './dispatchers';
 import { ObservableInput, pipe } from 'rxjs';
 import { SernEmitter } from '../core';
 import { Err, Ok, Result } from 'ts-results-es';
@@ -78,8 +78,7 @@ export function createInteractionHandler<T extends Interaction>(
             return Files
                 .defaultModuleLoader<Processed<CommandModule>>(fullPath)
                 .then(payload =>
-                   Ok(createDispatcher({ module: payload.module, event }))
-                );
+                   Ok(createDispatcher({ module: payload.module, event })));
         },
     );
 }
@@ -98,9 +97,9 @@ export function createMessageHandler(
         }
         return Files
             .defaultModuleLoader<Processed<CommandModule>>(fullPath)
-            .then(payload => {
+            .then(({ module })=> {
                 const args = contextArgs(event, rest);
-                return Ok(dispatchMessage(payload.module, args));
+                return Ok({ module, args });
             });
     });
 }
@@ -126,7 +125,9 @@ export function buildModules<T extends AnyModule>(
     input: ObservableInput<string>,
     moduleManager: ModuleManager,
 ) {
-    return Files.buildModuleStream<Processed<T>>(input).pipe(assignDefaults(moduleManager));
+    return Files
+        .buildModuleStream<Processed<T>>(input)
+        .pipe(assignDefaults(moduleManager));
 }
 
 /**

diff --git a/src/handlers/user-defined-events.ts b/src/handlers/user-defined-events.ts
@@ -24,14 +24,12 @@ export function eventsHandler(
         }
     };
     buildModules<EventModule>(allPaths, moduleManager)
-        .pipe(
-            callInitPlugins(emitter),
-            map(intoDispatcher),
-            /**
-             * Where all events are turned on
-             */
-            mergeAll(),
-            handleCrash(err, log),
-        )
+        .pipe(callInitPlugins(emitter),
+              map(intoDispatcher),
+              /**
+                * Where all events are turned on
+               */
+              mergeAll(),
+              handleCrash(err, log))
         .subscribe();
 }