sern/handler
1
0
Fork 0
mirror of https://github.com/sern-handler/handler synced 2026-06-27 18:22:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

naive onError handling, not tested

Browse Source
This commit is contained in:
Jacob Nguyen
2023-10-04 00:38:18 -05:00
parent f2218d02d4
commit 56a74ab32a
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/handlers/event-utils.ts
View File

@@ -32,6 +32,7 @@ import type { AnyFunction, Awaitable } from '../types/utility';
import type { ControlPlugin } from '../types/core-plugin';
import type { AnyModule, CommandModule, Module, OnError, Processed } from '../types/core-modules';
import type { ImportPayload } from '../types/core';
import assert from 'node:assert';
function createGenericHandler<Source, Narrowed extends Source, Output>(
source: Observable<Source>,
@@ -167,17 +168,27 @@ export function executeModule(
return EMPTY;
}
if(onError) {
//Could be promise
const err = onError() as CommandError.Response
if(!err) {
return throwError(() =>
SernEmitter.failure(module, "Failed to handle onError: returned nothing"));
const failure = SernEmitter.failure(module, "Handling onError: returned undefined");
return throwError(() => failure);
}
if(err.log) {
const { type, message } = err.log;
logger?.[type]({ message });
};
return EMPTY
//args[0] will be Repliable ( has reply method ), unless it is autocomplete
const apiObject = args[0];
assert(apiObject && typeof apiObject === 'object', "Args[0] was falsy while trying to create onError");
assert(err.body, "Body of error response cannot be empty");
if('reply' in apiObject && typeof apiObject.reply === 'function') {
return from(apiObject.reply(err.body))
}
if('respond' in apiObject && typeof apiObject.respond === 'function') {
return from(apiObject.respond(err.body))
}
return EMPTY;
}
return throwError(() => SernEmitter.failure(module, result.error));