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

feat: Edited event names for more conciseness, finished basic event emitters

Browse Source
This commit is contained in:
Jacob Nguyen
2022-05-19 22:52:23 -05:00
parent 115d1a49b5
commit 3f64a8aa0a
5 changed files with 31 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/handler/events/interactionCreate.ts
View File

@@ -131,16 +131,14 @@ export function onInteractionCreate (wrapper: Wrapper) {
ePlugArr.push(res as Awaited<Result<void, void>>);
}
if(ePlugArr.every(e => e.ok)) {
wrapper.sernEmitter?.emit('sern.command.success', [mod!]);
await execute();
wrapper.sernEmitter?.emit('module.activate', { success: true, module: mod! });
} else {
wrapper.sernEmitter?.emit('sern.command.fail', [mod!]);
console.log(ePlugArr);
console.log(mod, 'failed');
wrapper.sernEmitter?.emit('module.activate', { success: false, module: mod!, reason : SernError.PluginFailure });
}
},
error(err) {
wrapper.sernEmitter?.emit('sern.error', err);
wrapper.sernEmitter?.emit('error', err);
}
});
}

24
src/handler/events/messageEvent.ts
View File

@@ -9,6 +9,7 @@ import { fmt } from '../utilities/messageHelpers';
import * as Files from '../utilities/readFile';
import { filterCorrectModule, ignoreNonBot } from './observableHandling';
import { CommandType } from '../structures/enums';
import { SernError } from '../structures/errors';
export const onMessageCreate = (wrapper: Wrapper) => {
const { client, defaultPrefix } = wrapper;
@@ -50,11 +51,18 @@ export const onMessageCreate = (wrapper: Wrapper) => {
}),
);
processEventPlugins$.subscribe(({ mod, ctx, args, res }) => {
if (res.every(pl => pl.ok)) {
Promise.resolve(mod.execute(ctx, args)).then(() => console.log(mod));
} else {
console.log(mod, 'failed');
}
});
};
processEventPlugins$.subscribe({
next({ mod, ctx, args, res }) {
if (res.every(pl => pl.ok)) {
Promise.resolve(mod.execute(ctx, args)).then(() => {
wrapper.sernEmitter?.emit('module.activate', { success: true, module: mod! });
});
} else {
wrapper.sernEmitter?.emit('module.activate', { success: false, module: mod!, reason: SernError.PluginFailure });
}
},
error(e) {
wrapper.sernEmitter?.emit('error', e);
}
});
};

4
src/handler/events/readyEvent.ts
View File

@@ -63,9 +63,9 @@ export const onReady = (wrapper: Wrapper) => {
if(res.err) {
throw Error(SernError.NonValidModuleType);
}
wrapper.sernEmitter?.emit('module.register', { success : true, module : mod } );
} else {
console.log(`Failed to load command ${mod.name!}`);
console.log(mod);
wrapper.sernEmitter?.emit('module.register', { success : false, module : mod, reason : SernError.PluginFailure } );
}
});
};

15
src/handler/sernEmitter.ts
View File

@@ -1,12 +1,15 @@
import { EventEmitter } from 'events';
import type { Module } from './structures/module';
import type { Nullish } from '../types/handler';
import type { Err } from 'ts-results';
type Payload =
{ success : true, module : Module }
| { success : false, module: Module | undefined, reason : string | Error }
type SernEventsMapping = {
['sern.command.registered'] : [ Module ];
['sern.command.success'] : [ Module ];
['sern.command.fail'] : [ Nullish<Module> ];
['sern.error'] : [ Error ];
['module.register'] : [ Payload ];
['module.activate'] : [ Payload ];
['error'] : [ Error | string ];
}
export default class SernEmitter extends EventEmitter {
@@ -17,7 +20,7 @@ export default class SernEmitter extends EventEmitter {
public override once<T extends keyof SernEventsMapping>(eventName: T, listener: (...args: SernEventsMapping[T][]) => void): this {
return super.once(eventName,listener);
}
public override emit<T extends keyof SernEventsMapping>(eventName: T, args : SernEventsMapping[T]): boolean {
public override emit<T extends keyof SernEventsMapping>(eventName: T, ...args : SernEventsMapping[T]): boolean {
return super.emit(eventName, ...args);
}
}

1
src/handler/structures/errors.ts
View File

@@ -7,4 +7,5 @@ export enum SernError {
NotImplemented = 'This feature has not yet been implemented',
NotSupportedInteraction = `This interaction is not supported.`,
NotValidEventName = `Supplied a non valid event name`,
PluginFailure = `A plugin failed to call controller.next()`,
}