fix+regres+errorhandling

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

.github/workflows/continuous-integration.yml

@@ -1,50 +0,0 @@
-name: Continuous Integration
-
-on:
-  # Trigger the workflow on push or pull request or custom
-  push:
-    branches: [main]
-    paths:
-      - '*.ts'
-  pull_request_target:
-    branches:
-      main
-    paths:
-      - '*ts'
-  workflow_dispatch:
-
-jobs:
-  Prettier:
-    name: Run Prettier
-    runs-on: ubuntu-latest
-
-    steps:
-      - name: Check out Git repository
-        uses: actions/checkout@f43a0e5ff2bd294095638e18286ca9a3d1956744 # v3
-
-      - name: Set up Node.js
-        uses: actions/setup-node@64ed1c7eab4cce3362f8c340dee64e5eaeef8f7c # v3
-        with:
-          node-version: 17
-
-      - name: Install pnpm
-        run: npm i -g yarn
-
-      # Prettier must be in `package.json`
-      - name: Install Node.js dependencies
-        run:  yarn --immutable
-
-      - name: Run Prettier
-        run: yarn pretty
-
-      - name: Create Pull Request
-        id: cpr
-        uses: peter-evans/create-pull-request@38e0b6e68b4c852a5500a94740f0e535e0d7ba54 # v4
-        with:
-          commit-message: "style: pretty please"
-          branch: prettier
-          delete-branch: true
-          branch-suffix: short-commit-hash
-          title: "style: pretty please"
-          body: "pretty pretty prettier"
-          reviewers: EvolutionX-10

.github/workflows/npm-publish-dev.yml

@@ -0,0 +1,34 @@
+name: Continuous Delivery
+
+on:
+  push:
+    branches:
+      - main
+    paths:
+      - 'src/**'
+      - 'package.json'
+
+jobs:
+  Publish:
+    name: Publishing Dev
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Check out Git repository
+        uses: actions/checkout@f43a0e5ff2bd294095638e18286ca9a3d1956744 # v3
+
+      - name: Set up Node.js
+        uses: actions/setup-node@1a4442cacd436585916779262731d5b162bc6ec7 # v3
+        with:
+          node-version: 18
+          registry-url: 'https://registry.npmjs.org'
+
+      - name: Install Node.js dependencies
+        run: npm i && npm run build:dev
+
+      - name: Publish to npm
+        run: |
+          npm version premajor --preid "dev.$(git rev-parse --verify --short HEAD)" --git-tag-version=false
+          npm publish --tag dev
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

.github/workflows/npm-publish.yml

@@ -11,7 +11,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@f43a0e5ff2bd294095638e18286ca9a3d1956744 # v3
-      - uses: actions/setup-node@5e21ff4d9bc1a8cf6de233a3057d20ec6b3fb69d # v3
+      - uses: actions/setup-node@1a4442cacd436585916779262731d5b162bc6ec7 # v3
         with:
           node-version: 17
       - run: yarn --immutable

.github/workflows/release-please.yml

@@ -6,7 +6,7 @@ jobs:
     release-please:
       runs-on: ubuntu-latest
       steps:
-        - uses: google-github-actions/release-please-action@ca6063f4ed81b55db15b8c42d1b6f7925866342d # v3
+        - uses: google-github-actions/release-please-action@db8f2c60ee802b3748b512940dde88eabd7b7e01 # v3
           with:
             release-type: node
             package-name: release-please-action

.github/workflows/test.yml

@@ -20,7 +20,7 @@ jobs:
     steps:
     - uses: actions/checkout@f43a0e5ff2bd294095638e18286ca9a3d1956744 # v3
     - name: Use Node.js ${{ matrix.node-version }}
-      uses: actions/setup-node@5e21ff4d9bc1a8cf6de233a3057d20ec6b3fb69d # v3
+      uses: actions/setup-node@1a4442cacd436585916779262731d5b162bc6ec7 # v3
       with:
         node-version: ${{ matrix.node-version }}
         cache: 'npm'

.npmignore

@@ -113,3 +113,4 @@ tsconfig-cjs.json
 tsconfig-esm.json
 
 renovate.json
+fortnite

CHANGELOG.md

@@ -1,5 +1,115 @@
 # Changelog
 
+## [4.1.0](https://github.com/sern-handler/handler/compare/v4.0.3...v4.1.0) (2025-01-06)
+
+
+### Features
+
+* moduleinfo-in-eventplugins ([#373](https://github.com/sern-handler/handler/issues/373)) ([220a60e](https://github.com/sern-handler/handler/commit/220a60ecf853df8d288de2533c669562a430c3f9))
+
+
+### Bug Fixes
+
+* update github username ([#371](https://github.com/sern-handler/handler/issues/371)) ([55715d5](https://github.com/sern-handler/handler/commit/55715d565990fe686159f3c1eda3754d1262c72c))
+
+## [4.0.3](https://github.com/sern-handler/handler/compare/v4.0.2...v4.0.3) (2024-10-06)
+
+
+### Bug Fixes
+
+* async presence ([#369](https://github.com/sern-handler/handler/issues/369)) ([eabfb81](https://github.com/sern-handler/handler/commit/eabfb81819b53a4656d8eac6e21cfb488b724a42))
+* fix eventModule typing for Discord events ([#368](https://github.com/sern-handler/handler/issues/368)) ([1789ccb](https://github.com/sern-handler/handler/commit/1789ccb2f22f502f87538fecdb07106ff7110434))
+
+## [4.0.2](https://github.com/sern-handler/handler/compare/v4.0.1...v4.0.2) (2024-08-13)
+
+
+### Bug Fixes
+
+* type issue ([2106cdc](https://github.com/sern-handler/handler/commit/2106cdc1d033f88b6ee4ccca6754fe7a595a9328))
+
+## [4.0.1](https://github.com/sern-handler/handler/compare/v4.0.0...v4.0.1) (2024-07-19)
+
+
+### Bug Fixes
+
+* add SDT typings to autocomplete commands ([#363](https://github.com/sern-handler/handler/issues/363)) ([92623d2](https://github.com/sern-handler/handler/commit/92623d2914fb80e31365f06cf896bb37f36fc814))
+
+## [4.0.0](https://github.com/sern-handler/handler/compare/v3.3.4...v4.0.0) (2024-07-18)
+
+
+### Features
+
+* v4 ([#361](https://github.com/sern-handler/handler/issues/361)) ([9a8904f](https://github.com/sern-handler/handler/commit/9a8904f5aed4fa36b018ad73bbe58049bae33274))
+
+
+### Miscellaneous Chores
+
+* release 4.0.0 ([dda0e33](https://github.com/sern-handler/handler/commit/dda0e3395b6704862bfd3fda2a201e2cb9b45d2f))
+
+## [3.3.4](https://github.com/sern-handler/handler/compare/v3.3.3...v3.3.4) (2024-03-18)
+
+
+### Bug Fixes
+
+* sern emitter err ([#358](https://github.com/sern-handler/handler/issues/358)) ([90e55df](https://github.com/sern-handler/handler/commit/90e55dfa1466c91e5da48922251309331921b1ef))
+
+## [3.3.3](https://github.com/sern-handler/handler/compare/v3.3.2...v3.3.3) (2024-02-25)
+
+
+### Bug Fixes
+
+* rm deprecated class modules, clean up, rm indirection ([#355](https://github.com/sern-handler/handler/issues/355)) ([48f9f6e](https://github.com/sern-handler/handler/commit/48f9f6ec16e650d574bd24dcbb0ed176933bfe17))
+* singleton init not being fired when inserting function ([07b11b3](https://github.com/sern-handler/handler/commit/07b11b357baac0c3c7055c022bc353995c80f766))
+* typings and cleanup ([#356](https://github.com/sern-handler/handler/issues/356)) ([ce8c4bf](https://github.com/sern-handler/handler/commit/ce8c4bf6492b9680fb1c1a530d3e0028f214ad2f))
+
+## [3.3.2](https://github.com/sern-handler/handler/compare/v3.3.1...v3.3.2) (2024-01-08)
+
+
+### Bug Fixes
+
+* presence feature not working on cjs applications ([#351](https://github.com/sern-handler/handler/issues/351)) ([4f23871](https://github.com/sern-handler/handler/commit/4f2387119acfde036d0d1626553e9050f55627d1))
+
+## [3.3.1](https://github.com/sern-handler/handler/compare/v3.3.0...v3.3.1) (2024-01-07)
+
+
+### Bug Fixes
+
+* crashing when slash command is used as text command ([#349](https://github.com/sern-handler/handler/issues/349)) ([a359f73](https://github.com/sern-handler/handler/commit/a359f73fa24127a4964d411c8c1c0dfea5edc0f1))
+
+
+### Reverts
+
+* the last commit ([655bb8d](https://github.com/sern-handler/handler/commit/655bb8d35815fe0ce9797d8b169310a07b284ae0))
+
+## [3.3.0](https://github.com/sern-handler/handler/compare/v3.2.1...v3.3.0) (2023-12-27)
+
+
+### Features
+
+* presence ([#345](https://github.com/sern-handler/handler/issues/345)) ([7458bef](https://github.com/sern-handler/handler/commit/7458befe8a5900480cd71900df02a8364837dc00))
+
+## [3.2.1](https://github.com/sern-handler/handler/compare/v3.2.0...v3.2.1) (2023-12-21)
+
+
+### Bug Fixes
+
+* logger swap failing ([daac37c](https://github.com/sern-handler/handler/commit/daac37c28858c42b21042bdcb8141239db634e7d))
+
+## [3.2.0](https://github.com/sern-handler/handler/compare/v3.1.1...v3.2.0) (2023-12-15)
+
+
+### Miscellaneous Chores
+
+* release 3.2.0 ([237c853](https://github.com/sern-handler/handler/commit/237c8537c66052309d7e13a7e6e0a4f7995c2558))
+
+## [3.1.1](https://github.com/sern-handler/handler/compare/v3.1.0...v3.1.1) (2023-11-06)
+
+
+### Bug Fixes
+
+* queuing events ([fd39858](https://github.com/sern-handler/handler/commit/fd39858636d3038abb6d91021b65c99c488a3d6e))
+* queuing events ([#332](https://github.com/sern-handler/handler/issues/332)) @Benzo-Fury ([#333](https://github.com/sern-handler/handler/issues/333)) ([fd39858](https://github.com/sern-handler/handler/commit/fd39858636d3038abb6d91021b65c99c488a3d6e))
+
 ## [3.1.0](https://github.com/sern-handler/handler/compare/v3.0.2...v3.1.0) (2023-09-04)
 
 

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2023 sern
+Copyright (c) 2025 sern
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -19,28 +19,16 @@
 - Lightweight. Does a lot while being small.
 - Latest features. Support for discord.js v14 and all of its interactions.
 - Start quickly. Plug and play or customize to your liking.
-- Switch and customize how errors are handled, logging, and more.
 - works with [bun](https://bun.sh/) and [node](https://nodejs.org/en) out the box!
 - Use it with TypeScript or JavaScript. CommonJS and ESM supported.
 - Active and growing community, always here to help. [Join us](https://sern.dev/discord)
 - Unleash its full potential with a powerful CLI and awesome plugins.
 
 ## 📜 Installation
-
-```sh
-npm install @sern/handler
-```
-
-```sh
-yarn add @sern/handler
-```
-
-```sh
-pnpm add @sern/handler
-```
+[Start here!!](https://sern.dev/v4/reference/getting-started)
 
 ## 👶 Basic Usage
-<details open><summary>ping.ts</summary>
+<details><summary>ping.ts</summary>
 
 ```ts
 export default commandModule({
@@ -54,60 +42,17 @@ export default commandModule({
 });
 ```
 </details>
-<details open><summary>modal.ts</summary>
 
-```ts
-export default commandModule({
-    type: CommandType.Modal,
-    //Installed a plugin to make sure modal fields pass a validation.
-    plugins : [
-        assertFields({
-            fields: { 
-                name: /^([^0-9]*)$/ 
-            },
-            failure: (errors, modal) => modal.reply('your submission did not pass the validations')
-        })
-    ],
-    execute : (modal) => {
-        modal.reply('thanks for the submission!');
-    }
-})
-```
-</details>
-<details open><summary>index.ts</summary>
-
-	
-```ts 
-import { Client, GatewayIntentBits } from 'discord.js';
-import { Sern, single } from '@sern/handler';
-
-//client has been declared previously
-//Version 3
-await makeDependencies({
-    build: root => root
-        .add({ '@sern/client': single(() => client)  })
-});
-
-//View docs for all options
-Sern.init({
-	defaultPrefix: '!', // removing defaultPrefix will shut down text commands
-	commands: 'src/commands',
-	// events: 'src/events' (optional),
-});
-
-client.login("YOUR_BOT_TOKEN_HERE");
-```
-</details>
 
 ## 🤖 Bots Using sern 
 - [Community Bot](https://github.com/sern-handler/sern-community), the community bot for our [discord server](https://sern.dev/discord).
 - [Vinci](https://github.com/SrIzan10/vinci), the bot for Mara Turing.
 - [Bask](https://github.com/baskbotml/bask), Listen your favorite artists on Discord.
-- [ava](https://github.com/SrIzan10/ava), A discord bot that plays KNGI and Gensokyo Radio.
 - [Murayama](https://github.com/murayamabot/murayama), :pepega:
-- [Protector (WIP)](https://github.com/needhamgary/Protector), Just a simple bot to help enhance a private minecraft server.
+- [Protector](https://github.com/GlitchApotamus/Protector), Just a simple bot to help enhance a private minecraft server.
 - [SmokinWeed 💨](https://github.com/Peter-MJ-Parker/sern-bud), A fun bot for a small - but growing - server.
-
+- [Man Nomic](https://github.com/jacoobes/man-nomic), A simple information bot to provide information to the nomic-ai discord community.
+- [Linear-Discord](https://github.com/sern-handler/linear-discord) Display and manage a linear dashboard.
 ## 💻 CLI
 
 It is **highly encouraged** to use the [command line interface](https://github.com/sern-handler/cli) for your project. Don't forget to view it.

fortnite

@@ -0,0 +1 @@
+

package.json

@@ -1,26 +1,23 @@
 {
     "name": "@sern/handler",
     "packageManager": "yarn@3.5.0",
-    "version": "3.1.0",
+    "version": "4.1.0",
     "description": "A complete, customizable, typesafe, & reactive framework for discord bots.",
     "main": "./dist/index.js",
-    "module": "./dist/index.mjs",
-    "types": "./dist/index.d.ts",
+    "module": "./dist/index.js",
     "exports": {
         ".": {
-            "import": "./dist/index.mjs",
-            "require": "./dist/index.js",
-            "types": "./dist/index.d.ts"
+            "import": "./dist/index.js",
+            "require": "./dist/index.js"
         }
     },
     "scripts": {
-        "watch": "tsup --watch",
-        "clean-modules": "rimraf node_modules/ && npm install",
+        "watch": "tsc --watch",
         "lint": "eslint src/**/*.ts",
         "format": "eslint src/**/*.ts --fix",
-        "build:dev": "tsup --metafile",
-        "build:prod": "tsup ",
-        "prepare": "npm run build:prod",
+        "build:dev": "tsc",
+        "build:prod": "tsc",
+        "prepare": "tsc",
         "pretty": "prettier --write .",
         "tdd": "vitest",
         "test": "vitest --run",
@@ -38,30 +35,21 @@
     "author": "SernDevs",
     "license": "MIT",
     "dependencies": {
-        "iti": "^0.6.0",
-        "rxjs": "^7.8.0",
-        "ts-results-es": "^4.0.0"
+        "@sern/ioc": "^1.1.0",
+        "callsites": "^3.1.0",
+        "cron": "^3.1.7",
+        "deepmerge": "^4.3.1"
     },
     "devDependencies": {
         "@faker-js/faker": "^8.0.1",
-        "@types/node": "^18.15.11",
+        "@types/node": "^20.0.0",
+        "@types/node-cron": "^3.0.11",
         "@typescript-eslint/eslint-plugin": "5.58.0",
         "@typescript-eslint/parser": "5.59.1",
-        "discord.js": "14.11.0",
-        "esbuild": "^0.17.0",
+        "discord.js": "^14.15.3",
         "eslint": "8.39.0",
-        "prettier": "2.8.8",
-        "tsup": "^6.7.0",
         "typescript": "5.0.2",
-        "vitest": "latest"
-    },
-    "prettier": {
-        "semi": true,
-        "trailingComma": "all",
-        "singleQuote": true,
-        "printWidth": 100,
-        "tabWidth": 4,
-        "arrowParens": "avoid"
+        "vitest": "^1.6.0"
     },
     "eslintConfig": {
         "parser": "@typescript-eslint/parser",
@@ -95,5 +83,14 @@
         "type": "git",
         "url": "git+https://github.com/sern-handler/handler.git"
     },
-    "homepage": "https://sern.dev"
+    "engines": {
+        "node": ">= 20.0.x"
+    },
+    "homepage": "https://sern.dev",
+    "overrides": {
+        "ws": "8.17.1"
+    },
+    "resolutions": {
+        "ws": "8.17.1"
+    }
 }

src/core/_internal.ts

@@ -1,10 +0,0 @@
-export * as Id from './id';
-export * from './operators';
-export * from './predicates';
-export * as Files from './module-loading';
-export * from './functions';
-export type { VoidResult } from '../types/core-plugin';
-export { SernError } from './structures/enums';
-export { ModuleStore } from './structures/module-store';
-export * as DefaultServices from './structures/services';
-export { useContainerRaw } from './ioc/base'

src/core/contracts/disposable.ts

@@ -1,9 +0,0 @@
-import type { Awaitable } from '../../types/utility';
-
-/**
- * Represents a Disposable contract.
- * Let dependencies implement this to dispose and cleanup.
- */
-export interface Disposable {
-    dispose(): Awaitable<unknown>;
-}

src/core/contracts/emitter.ts

@@ -1,7 +0,0 @@
-import type { AnyFunction } from '../../types/utility';
-
-export interface Emitter {
-    addListener(eventName: string | symbol, listener: AnyFunction): this;
-    removeListener(eventName: string | symbol, listener: AnyFunction): this;
-    emit(eventName: string | symbol, ...payload: any[]): boolean;
-}

src/core/contracts/error-handling.ts

@@ -1,26 +0,0 @@
-import type { CommandModule,Processed, EventModule } from "../../types/core-modules";
-
-/**
- * @since 2.0.0
- */
-export interface ErrorHandling {
-    /**
-     * @deprecated
-     * Version 4 will remove this method
-     */
-    crash(err: Error): never;
-    /**
-     * A function that is called on every throw,
-     * If and only if the command is not handled properly
-     * @param error
-     */
-    updateAlive(error: Error): void;
-
-    /**
-     * This callback is called if a module  
-     * handles onError with type 'fail'
-     *
-     */
-    handleError(error: Error): void;
-
-}

src/core/contracts/index.ts

@@ -1,7 +0,0 @@
-export * from './error-handling';
-export * from './logging';
-export * from './module-manager';
-export * from './module-store';
-export * from './init';
-export * from './emitter';
-export * from './disposable'

src/core/contracts/init.ts

@@ -1,9 +0,0 @@
-import type { Awaitable } from '../../types/utility';
-
-/**
- * Represents an initialization contract.
- * Let dependencies implement this to initiate some logic.
- */
-export interface Init {
-    init(): Awaitable<unknown>;
-}

src/core/contracts/logging.ts

@@ -1,11 +0,0 @@
-/**
- * @since 2.0.0
- */
-export interface Logging<T = unknown> {
-    error(payload: LogPayload<T>): void;
-    warning(payload: LogPayload<T>): void;
-    info(payload: LogPayload<T>): void;
-    debug(payload: LogPayload<T>): void;
-}
-
-export type LogPayload<T = unknown> = { message: T };

src/core/contracts/module-manager.ts

@@ -1,32 +0,0 @@
-import type {
-    CommandMeta,
-    CommandModule,
-    CommandModuleDefs,
-    Module,
-    OnError,
-} from '../../types/core-modules';
-import { CommandType } from '../structures';
-
-interface MetadataAccess {
-    getMetadata(m: Module): CommandMeta | undefined;
-    setMetadata(m: Module, c: CommandMeta): void;
-}
-
-interface OnErrorAccess {
-    getErrorCallback(m: Module): OnError;
-    setErrorCallback(m: Module, c: NonNullable<OnError>): void;
-}
-/**
- * @since 2.0.0
- * @internal - direct access to the module manager will be removed in version 4
- */
-export interface ModuleManager extends MetadataAccess, OnErrorAccess {
-    get(id: string): string | undefined;
-
-    set(id: string, path: string): void;
-    getPublishableCommands(): Promise<CommandModule[]>;
-    getByNameCommandType<T extends CommandType>(
-        name: string,
-        commandType: T,
-    ): Promise<CommandModuleDefs[T]> | undefined;
-}

src/core/contracts/module-store.ts

@@ -1,10 +0,0 @@
-import type { CommandMeta, Module, OnError } from '../../types/core-modules';
-
-/**
- * Represents a core module store that stores IDs mapped to file paths.
- */
-export interface CoreModuleStore {
-    commands: Map<string, string>;
-    metadata: WeakMap<Module, CommandMeta>;
-    onError: WeakMap<Module, NonNullable<OnError>>;
-}

src/core/create-plugins.ts

@@ -1,62 +0,0 @@
-import { CommandType, EventType, PluginType } from './structures';
-import type { Plugin, PluginResult, EventArgs, CommandArgs } from '../types/core-plugin';
-import type { ClientEvents } from 'discord.js';
-
-export function makePlugin<V extends unknown[]>(
-    type: PluginType,
-    execute: (...args: any[]) => any,
-): Plugin<V> {
-    return {
-        type,
-        execute,
-    } as Plugin<V>;
-}
-/**
- * @since 2.5.0
- * @__PURE__
- */
-export function EventInitPlugin<I extends EventType>(
-    execute: (...args: EventArgs<I, PluginType.Init>) => PluginResult,
-) {
-    return makePlugin(PluginType.Init, execute);
-}
-/**
- * @since 2.5.0
- * @__PURE__
- */
-export function CommandInitPlugin<I extends CommandType>(
-    execute: (...args: CommandArgs<I, PluginType.Init>) => PluginResult,
-) {
-    return makePlugin(PluginType.Init, execute);
-}
-/**
- * @since 2.5.0
- * @__PURE__
- */
-export function CommandControlPlugin<I extends CommandType>(
-    execute: (...args: CommandArgs<I, PluginType.Control>) => PluginResult,
-) {
-    return makePlugin(PluginType.Control, execute);
-}
-/**
- * @since 2.5.0
- * @__PURE__
- */
-export function EventControlPlugin<I extends EventType>(
-    execute: (...args: EventArgs<I, PluginType.Control>) => PluginResult,
-) {
-    return makePlugin(PluginType.Control, execute);
-}
-
-/**
- * @since 2.5.0
- * @Experimental
- * A specialized function for creating control plugins with discord.js ClientEvents.
- * Will probably be moved one day!
- */
-export function DiscordEventControlPlugin<T extends keyof ClientEvents>(
-    name: T,
-    execute: (...args: ClientEvents[T]) => PluginResult,
-) {
-    return makePlugin(PluginType.Control, execute);
-}

src/core/functions.ts

@@ -1,31 +1,60 @@
-import { Err, Ok } from 'ts-results-es';
-import { ApplicationCommandOptionType, AutocompleteInteraction } from 'discord.js';
-import type { SernAutocompleteData, SernOptionsData } from '../types/core-modules';
-import type { AnyCommandPlugin, AnyEventPlugin, Plugin } from '../types/core-plugin';
-import { PluginType } from './structures';
+import type { Module, SernAutocompleteData, SernOptionsData } from '../types/core-modules';
+import type {
+    AnySelectMenuInteraction,
+    ButtonInteraction,
+    ChatInputCommandInteraction,
+    MessageContextMenuCommandInteraction,
+    ModalSubmitInteraction,
+    UserContextMenuCommandInteraction,
+    AutocompleteInteraction
+} from 'discord.js';
+import { ApplicationCommandOptionType, InteractionType } from 'discord.js';
+import { PluginType } from './structures/enums';
 import assert from 'assert';
+import type { Payload, UnpackedDependencies } from '../types/utility';
 
-//function wrappers for empty ok / err
-export const ok = /* @__PURE__*/ () => Ok.EMPTY;
-export const err = /* @__PURE__*/ () => Err.EMPTY;
-
-export function partitionPlugins(
-    arr: (AnyEventPlugin | AnyCommandPlugin)[] = [],
-): [Plugin[], Plugin[]] {
-    const controlPlugins = [];
-    const initPlugins = [];
-
-    for (const el of arr) {
-        switch (el.type) {
-            case PluginType.Control:
-                controlPlugins.push(el);
-                break;
-            case PluginType.Init:
-                initPlugins.push(el);
-                break;
+export const createSDT = (module: Module, deps: UnpackedDependencies, params: string|undefined) => {
+    return {
+        state: {},
+        deps,
+        params, 
+        type: module.type,
+        module: {
+            name: module.name,
+            description: module.description,
+            locals: module.locals,
+            meta: module.meta
         }
     }
-    return [controlPlugins, initPlugins];
+}
+
+/**
+ * Removes the first character(s) _[depending on prefix length]_ of the message
+ * @param msg
+ * @param prefix The prefix to remove
+ * @returns The message without the prefix
+ * @example
+ * message.content = '!ping';
+ * console.log(fmt(message.content, '!'));
+ * // [ 'ping' ]
+ */
+export function fmt(msg: string, prefix?: string): string[] {
+    if(!prefix) throw Error("Unable to parse message without prefix");
+    return msg.slice(prefix.length).trim().split(/\s+/g);
+}
+
+
+export function partitionPlugins<T,V>
+(arr: Array<{ type: PluginType }> = []): [T[], V[]] {
+    const controlPlugins = [];
+    const initPlugins = [];
+    for (const el of arr) {
+        switch (el.type) {
+            case PluginType.Control: controlPlugins.push(el); break;
+            case PluginType.Init: initPlugins.push(el); break;
+        }
+    }
+    return [controlPlugins, initPlugins] as [T[], V[]];
 }
 
 /**
@@ -40,44 +69,73 @@ export function treeSearch(
     if (options === undefined) return undefined;
     //clone to prevent mutation of original command module
     const _options = options.map(a => ({ ...a }));
-    let subcommands = new Set();
+    const subcommands = new Set();
     while (_options.length > 0) {
         const cur = _options.pop()!;
         switch (cur.type) {
-            case ApplicationCommandOptionType.Subcommand:
-                {
+            case ApplicationCommandOptionType.Subcommand: {
                     subcommands.add(cur.name);
                     for (const option of cur.options ?? []) _options.push(option);
-                }
-                break;
-            case ApplicationCommandOptionType.SubcommandGroup:
-                {
+                } break;
+            case ApplicationCommandOptionType.SubcommandGroup: {
                     for (const command of cur.options ?? []) _options.push(command);
-                }
-                break;
-            default:
-                {
-                    if ('autocomplete' in cur && cur.autocomplete) {
-                        const choice = iAutocomplete.options.getFocused(true);
-                        assert(
-                            'command' in cur,
-                            'No command property found for autocomplete option',
-                        );
-                        if (subcommands.size > 0) {
-                            const parent = iAutocomplete.options.getSubcommand();
-                            const parentAndOptionMatches =
-                                subcommands.has(parent) && cur.name === choice.name;
-                            if (parentAndOptionMatches) {
-                                return { ...cur, parent };
-                            }
-                        } else {
-                            if (cur.name === choice.name) {
-                                return { ...cur, parent: undefined };
-                            }
+                } break;
+            default: {
+                if ('autocomplete' in cur && cur.autocomplete) {
+                    const choice = iAutocomplete.options.getFocused(true);
+                    assert( 'command' in cur, 'No `command` property found for option ' + cur.name);
+                    if (subcommands.size > 0) {
+                        const parent = iAutocomplete.options.getSubcommand();
+                        const parentAndOptionMatches =
+                            subcommands.has(parent) && cur.name === choice.name;
+                        if (parentAndOptionMatches) {
+                            return { ...cur, parent };
+                        }
+                    } else {
+                        if (cur.name === choice.name) {
+                            return { ...cur, parent: undefined };
                         }
                     }
                 }
-                break;
+            } break;
         }
     }
 }
+
+
+interface InteractionTypable {
+    type: InteractionType;
+}
+//discord.js pls fix ur typings or i will >:(
+type AnyMessageComponentInteraction = AnySelectMenuInteraction | ButtonInteraction;
+type AnyCommandInteraction =
+    | ChatInputCommandInteraction
+    | MessageContextMenuCommandInteraction
+    | UserContextMenuCommandInteraction;
+
+export function isMessageComponent(i: InteractionTypable): i is AnyMessageComponentInteraction {
+    return i.type === InteractionType.MessageComponent;
+}
+export function isCommand(i: InteractionTypable): i is AnyCommandInteraction {
+    return i.type === InteractionType.ApplicationCommand;
+}
+export function isAutocomplete(i: InteractionTypable): i is AutocompleteInteraction {
+    return i.type === InteractionType.ApplicationCommandAutocomplete;
+}
+
+export function isModal(i: InteractionTypable): i is ModalSubmitInteraction {
+    return i.type === InteractionType.ModalSubmit;
+}
+
+export function resultPayload<T extends 'success'|'warning'|'failure'>
+(type: T, module?: Module, reason?: unknown) {
+    return { type, module, reason } as Payload & { type : T };
+}
+
+export function pipe<T>(arg: unknown, firstFn: Function, ...fns: Function[]): T {
+  let result = firstFn(arg);
+  for (let fn of fns) {
+    result = fn(result);
+  }
+  return result;
+}

src/core/id.ts

@@ -1,23 +1,33 @@
-import { ApplicationCommandType, ComponentType, Interaction, InteractionType } from 'discord.js';
-import { CommandType, EventType } from './structures';
+import { ApplicationCommandType, ComponentType, type Interaction, InteractionType } from 'discord.js';
+import { CommandType, EventType } from './structures/enums';
 
+const parseParams = (event: { customId: string }, append: string) => {
+    const hasSlash = event.customId.indexOf('/')
+    if(hasSlash === -1) {
+        return { id:event.customId+append };
+    }
+    const baseid = event.customId.substring(0, hasSlash);
+    const params = event.customId.substring(hasSlash+1);
+    return { id: baseid+append, params }
+}
 /**
  * Construct unique ID for a given interaction object.
  * @param event The interaction object for which to create an ID.
- * @returns A unique string ID based on the type and properties of the interaction object.
+ * @returns An array of unique string IDs based on the type and properties of the interaction object.
  */
 export function reconstruct<T extends Interaction>(event: T) {
     switch (event.type) {
         case InteractionType.MessageComponent: {
-            return `${event.customId}_C${event.componentType}`;
+            const data = parseParams(event, `_C${event.componentType}`)
+            return [data];
         }
         case InteractionType.ApplicationCommand:
-        case InteractionType.ApplicationCommandAutocomplete: {
-            return `${event.commandName}_A${event.commandType}`;
-        }
+        case InteractionType.ApplicationCommandAutocomplete: 
+            return [{ id: `${event.commandName}_A${event.commandType}` }, { id: `${event.commandName}_B` }];
         //Modal interactions are classified as components for sern
         case InteractionType.ModalSubmit: {
-            return `${event.customId}_C1`;
+            const data = parseParams(event, '_M');
+            return [data];
         }
     }
 }
@@ -25,39 +35,40 @@ export function reconstruct<T extends Interaction>(event: T) {
  *
  * A magic number to represent any commandtype that is an ApplicationCommand.
  */
-const appBitField = 0b000000001111;
+const PUBLISHABLE = 0b000000001111;
 
-// Each index represents the exponent of a CommandType.
-// Every CommandType is a power of two.
-export const CommandTypeDiscordApi = [
-    1, // CommandType.Text
-    ApplicationCommandType.ChatInput,
-    ApplicationCommandType.User,
-    ApplicationCommandType.Message,
-    ComponentType.Button,
-    ComponentType.StringSelect,
-    1, //  CommandType.Modal
-    ComponentType.UserSelect,
-    ComponentType.RoleSelect,
-    ComponentType.MentionableSelect,
-    ComponentType.ChannelSelect,
-];
-/*
- * Generates a number based on CommandType.
- * This corresponds to an ApplicationCommandType or ComponentType
- * TextCommands are 0 as they aren't either or.
- */
-function apiType(t: CommandType | EventType) {
-    if (t === CommandType.Both || t === CommandType.Modal) return 1;
-    return CommandTypeDiscordApi[Math.log2(t)];
-}
+
+const TypeMap = new Map<number, number>([[CommandType.Text, 0],
+                                        [CommandType.Both, 0],
+                                        [CommandType.Slash, ApplicationCommandType.ChatInput],
+                                        [CommandType.CtxUser, ApplicationCommandType.User],
+                                        [CommandType.CtxMsg, ApplicationCommandType.Message],
+                                        [CommandType.Button, ComponentType.Button],
+                                        [CommandType.StringSelect, ComponentType.StringSelect],
+                                        [CommandType.Modal, InteractionType.ModalSubmit],
+                                        [CommandType.UserSelect, ComponentType.UserSelect],
+                                        [CommandType.MentionableSelect, ComponentType.MentionableSelect],
+                                        [CommandType.RoleSelect, ComponentType.RoleSelect],
+                                        [CommandType.ChannelSelect, ComponentType.ChannelSelect]]);
 
 /*
  * Generates an id based on name and CommandType.
  * A is for any ApplicationCommand. C is for any ComponentCommand
- * Then, another number generated by apiType function is appended
+ * Then, another number fetched from TypeMap
  */
 export function create(name: string, type: CommandType | EventType) {
-    const am = (appBitField & type) !== 0 ? 'A' : 'C';
-    return name + '_' + am + apiType(type);
+    if(type == CommandType.Text) {
+        return `${name}_T`;
+    }
+    if(type == CommandType.Both) {
+        return `${name}_B`;
+    }
+    if(type == CommandType.Modal) {
+        return `${name}_M`;
+    }
+    const am = (PUBLISHABLE & type) !== 0 ? 'A' : 'C';
+    return `${name}_${am}${TypeMap.get(type)!}`
 }
+
+
+

src/core/index.ts

@@ -1,4 +0,0 @@
-export * from './contracts';
-export * from './create-plugins';
-export * from './structures';
-export * from './ioc';

src/core/interfaces.ts

@@ -0,0 +1,55 @@
+import type { AnyFunction } from '../types/utility';
+
+
+/**
+ * Represents an initialization contract.
+ * Let dependencies implement this to initiate some logic.
+ */
+export interface Init {
+    init(): unknown;
+}
+
+/**
+ * Represents a Disposable contract.
+ * Let dependencies implement this to dispose and cleanup.
+ */
+export interface Disposable {
+    dispose(): unknown;
+}
+
+
+export interface Emitter {
+    addListener(eventName: string | symbol, listener: AnyFunction): this;
+    removeListener(eventName: string | symbol, listener: AnyFunction): this;
+    emit(eventName: string | symbol, ...payload: any[]): boolean;
+}
+
+
+/**
+ * @since 2.0.0
+ */
+export interface ErrorHandling {
+    /**
+     * @deprecated
+     * Version 4 will remove this method
+     */
+    crash(err: Error): never;
+    /**
+     * A function that is called on every throw.
+     * @param error
+     */
+    updateAlive(error: Error): void;
+
+}
+
+/**
+ * @since 2.0.0
+ */
+export interface Logging<T = unknown> {
+    error(payload: LogPayload<T>): void;
+    warning(payload: LogPayload<T>): void;
+    info(payload: LogPayload<T>): void;
+    debug(payload: LogPayload<T>): void;
+}
+
+export type LogPayload<T = unknown> = { message: T };

src/core/ioc.ts

@@ -0,0 +1,163 @@
+import { Service as $Service, Services as $Services } from '@sern/ioc/global'
+import { Container } from '@sern/ioc';
+import * as Contracts from './interfaces';
+import * as  __Services from './structures/default-services';
+import type { Logging } from './interfaces';
+import { __init_container, useContainerRaw } from '@sern/ioc/global';
+import { EventEmitter } from 'node:events';
+import { Client } from 'discord.js';
+import { Module } from '../types/core-modules';
+import { UnpackFunction } from '../types/utility';
+
+export function disposeAll(logger: Logging|undefined) {
+   useContainerRaw() 
+        ?.disposeAll()
+        .then(() => logger?.info({ message: 'Cleaning container and crashing' }));
+}
+
+type Insertable = | ((container: Dependencies) => object)
+                  | object
+
+const dependencyBuilder = (container: Container) => {
+    return {
+        /**
+          * Insert a dependency into your container.
+          * Supply the correct key and dependency
+          */
+        add(key: keyof Dependencies, v: Insertable) {
+            if(typeof v !== 'function') {
+                container.addSingleton(key, v)
+            } else {
+                //@ts-ignore
+                container.addWiredSingleton(key, (cntr) => v(cntr))
+            }
+        },
+        /**
+          * @param key the key of the dependency
+          * @param v The dependency to swap out.
+          * Swap out a preexisting dependency.
+          */
+        swap(key: keyof Dependencies, v: Insertable) {
+            if(typeof v !== 'function') {
+                container.swap(key, v);
+            } else {
+                container.swap(key, v(container.deps()));
+            }
+        },
+   };
+};
+
+type ValidDependencyConfig =
+    (c: ReturnType<typeof dependencyBuilder>) => any
+
+/**
+  * makeDependencies constructs a dependency injection container for sern handler to use.
+  * This is required to start the handler, and is to be called before Sern.init.
+  * @example
+  * ```ts
+  * await makeDependencies(({ add }) => {
+  *     add('@sern/client', new Client({ intents, partials }) 
+  * })
+  * ```
+  */
+export async function makeDependencies (conf: ValidDependencyConfig) {
+    const container = await __init_container({ autowire: false });
+    //We only include logger if it does not exist 
+    const includeLogger = !container.hasKey('@sern/logger');
+
+    if(includeLogger) {
+        container.addSingleton('@sern/logger', new __Services.DefaultLogging);
+    }
+    container.addSingleton('@sern/errors', new __Services.DefaultErrorHandling);
+    container.addSingleton('@sern/modules', new Map);
+    container.addSingleton('@sern/emitter', new EventEmitter({ captureRejections: true }))
+    container.addSingleton('@sern/scheduler', new __Services.TaskScheduler)
+    conf(dependencyBuilder(container));
+    await container.ready();
+}
+
+
+/**
+ * The Service api, which allows users to access dependencies in places IOC cannot reach. 
+ * To obtain intellisense, ensure a .d.ts file exists in the root of compilation.
+ * Our scaffolding tool takes care of this.
+ * Note: this method only works AFTER your container has been initiated
+ * @since 3.0.0
+ * @example
+ * ```ts
+ * const client = Service('@sern/client');
+ * ```
+ * @param key a key that corresponds to a dependency registered.
+ * @throws if container is absent or not present
+ */
+export function Service<const T extends keyof Dependencies>(key: T) {
+    return $Service(key) as Dependencies[T]
+}
+/**
+ * @since 3.0.0
+ * The plural version of {@link Service}
+ * @throws if container is absent or not present
+ * @returns array of dependencies, in the same order of keys provided
+ *
+ */
+export function Services<const T extends (keyof Dependencies)[]>(...keys: [...T]) {
+    return $Services<T, IntoDependencies<T>>(...keys)
+}
+
+/**
+ * @deprecated
+ * Creates a singleton object.
+ * @param cb
+ */
+export function single<T>(cb: () => T) { 
+    console.log('The `single` function is deprecated and has no effect')
+    return cb(); 
+}
+
+/**
+ * @deprecated
+ * @since 2.0.0
+ * Creates a transient object
+ * @param cb
+ */
+export function transient<T>(cb: () => () => T) { 
+    console.log('The `transient` function is deprecated and has no effect')
+    return cb()(); 
+}
+
+export type DependencyFromKey<T extends keyof Dependencies> = Dependencies[T];
+
+
+
+export type IntoDependencies<Tuple extends [...any[]]> = {
+    [Index in keyof Tuple]: UnpackFunction<NonNullable<DependencyFromKey<Tuple[Index]>>>; //Unpack and make NonNullable
+} & { length: Tuple['length'] };
+
+export interface CoreDependencies {
+    /**
+      * discord.js client.
+      */
+    '@sern/client':  Client;
+    /**
+      * sern emitter listens to events that happen throughout
+      * the handler. some include module.register, module.activate.
+      */
+    '@sern/emitter': Contracts.Emitter;
+    /**
+      * An error handler which is the final step before 
+      * the sern process actually crashes.
+      */
+    '@sern/errors':  Contracts.ErrorHandling;
+    /**
+      * Optional logger. Performs ... logging
+      */
+    '@sern/logger'?: Contracts.Logging;
+    /**
+      * Readonly module store. sern stores these 
+      * by module.meta.id -> Module
+      */
+    '@sern/modules': Map<string, Module>;
+
+    '@sern/scheduler': __Services.TaskScheduler
+}
+

src/core/ioc/base.ts

@@ -1,36 +0,0 @@
-import * as assert from 'assert';
-import { composeRoot, useContainer } from './dependency-injection';
-import type { DependencyConfiguration } from '../../types/ioc';
-import { CoreContainer } from './container';
-
-//SIDE EFFECT: GLOBAL DI
-let containerSubject: CoreContainer<Partial<Dependencies>>;
-
-/**
- * @deprecated
- * Returns the underlying data structure holding all dependencies.
- * Exposes methods from iti
- * Use the Service API. The container should be readonly
- */
-export function useContainerRaw() {
-    assert.ok(
-        containerSubject && containerSubject.isReady(),
-        "Could not find container or container wasn't ready. Did you call makeDependencies?",
-    );
-    return containerSubject;
-}
-
-/**
- * @since 2.0.0
- * @param conf a configuration for creating your project dependencies
- */
-export async function makeDependencies<const T extends Dependencies>(
-    conf: DependencyConfiguration,
-) {
-    //Until there are more optional dependencies, just check if the logger exists
-    //SIDE EFFECT
-    containerSubject = new CoreContainer();
-    await composeRoot(containerSubject, conf);
-
-    return useContainer<T>();
-}

src/core/ioc/container.ts

@@ -1,60 +0,0 @@
-import { Container } from 'iti';
-import { Disposable, SernEmitter } from '../';
-import * as assert from 'node:assert';
-import { Subject } from 'rxjs';
-import { DefaultServices, ModuleStore } from '../_internal';
-import * as Hooks from './hooks'
-
-
-/**
- * A semi-generic container that provides error handling, emitter, and module store. 
- * For the handler to operate correctly, The only user provided dependency needs to be @sern/client
- */
-export class CoreContainer<T extends Partial<Dependencies>> extends Container<T, {}> {
-    private ready$ = new Subject<void>();
-    constructor() {
-        super();
-        assert.ok(!this.isReady(), 'Listening for dispose & init should occur prior to sern being ready.');
-
-        const { unsubscribe } = Hooks.createInitListener(this);
-        this.ready$
-            .subscribe({ complete: unsubscribe });
-
-        (this as Container<{}, {}>)
-            .add({
-                '@sern/errors': () => new DefaultServices.DefaultErrorHandling(),
-                '@sern/emitter': () => new SernEmitter(),
-                '@sern/store': () => new ModuleStore(),
-            })
-            .add(ctx => {
-                return {
-                    '@sern/modules': () =>
-                        new DefaultServices.DefaultModuleManager(ctx['@sern/store']),
-                };
-            });
-    }
-
-
-    isReady() {
-
-        return this.ready$.closed;
-    }
-    override async disposeAll() {
-        
-        const otherDisposables = Object
-            .entries(this._context)
-            .flatMap(([key, value]) => 
-                'dispose' in value
-                    ? [key]
-                    : []);
-
-        for(const key of otherDisposables) {
-            this.addDisposer({ [key]: (dep: Disposable) => dep.dispose() } as never);
-        }
-        await super.disposeAll() 
-    }
-    ready() {
-        this.ready$.complete();
-        this.ready$.unsubscribe();
-    }
-}

src/core/ioc/dependency-injection.ts

@@ -1,80 +0,0 @@
-import type { CoreDependencies, DependencyConfiguration, IntoDependencies } from '../../types/ioc';
-import { DefaultServices } from '../_internal';
-import { useContainerRaw } from './base';
-import { CoreContainer } from './container';
-
-/**
- * @__PURE__
- * @since 2.0.0.
- * Creates a singleton object.
- * @param cb
- */
-export function single<T>(cb: () => T) {
-    return cb;
-}
-
-/**
- * @__PURE__
- * @since 2.0.0
- * Creates a transient object
- * @param cb
- */
-export function transient<T>(cb: () => () => T) {
-    return cb;
-}
-/**
- * The new Service api, a cleaner alternative to useContainer
- * To obtain intellisense, ensure a .d.ts file exists in the root of compilation.
- * Usually our scaffolding tool takes care of this.
- * @since 3.0.0
- * @example
- * ```ts
- * const client = Service('@sern/client');
- * ```
- * @param key a key that corresponds to a dependency registered.
- *
- */
-export function Service<const T extends keyof Dependencies>(key: T) {
-    return useContainerRaw().get(key)!;
-}
-/**
- * @since 3.0.0
- * The plural version of {@link Service}
- * @returns array of dependencies, in the same order of keys provided
- */
-export function Services<const T extends (keyof Dependencies)[]>(...keys: [...T]) {
-    const container = useContainerRaw();
-    return keys.map(k => container.get(k)!) as IntoDependencies<T>;
-}
-
-/**
- * Given the user's conf, check for any excluded dependency keys.
- * Then, call conf.build to get the rest of the users' dependencies.
- * Finally, update the containerSubject with the new container state
- * @param conf
- */
-export async function composeRoot(
-    container: CoreContainer<Partial<Dependencies>>,
-    conf: DependencyConfiguration,
-) {
-    //container should have no client or logger yet.
-    const hasLogger = conf.exclude?.has('@sern/logger');
-    if (!hasLogger) {
-        container.upsert({
-            '@sern/logger': () => new DefaultServices.DefaultLogging(),
-        });
-    }
-    //Build the container based on the callback provided by the user
-    conf.build(container as CoreContainer<Omit<CoreDependencies, '@sern/client'>>);
-    
-    if (!hasLogger) {
-        container.get('@sern/logger')?.info({ message: 'All dependencies loaded successfully.' });
-    }
-
-    container.ready();
-}
-
-export function useContainer<const T extends Dependencies>() {
-    return <V extends (keyof T)[]>(...keys: [...V]) =>
-        keys.map(key => useContainerRaw().get(key as keyof Dependencies)) as IntoDependencies<V>;
-}

src/core/ioc/hooks.ts

@@ -1,40 +0,0 @@
-import type { CoreContainer } from "./container"
-
-interface HookEvent { 
-    key : PropertyKey
-    newContainer: any
-}
-type HookName = 'init';
-
-export const createInitListener = (coreContainer : CoreContainer<any>) => {
-    const initCalled = new Set<PropertyKey>();
-    const hasCallableMethod = createPredicate(initCalled);
-    const unsubscribe = coreContainer.on('containerUpserted', async (event) => {
-       
-        if(isNotHookable(event)) {
-            return;
-        }
-
-        if(hasCallableMethod('init', event)) {
-            await event.newContainer?.init();
-            initCalled.add(event.key);
-        }
-
-    });
-    return { unsubscribe };
-}
-
-const isNotHookable = (hk: HookEvent) => {
-    return typeof hk.newContainer !== 'object' 
-        || Array.isArray(hk.newContainer) 
-        || hk.newContainer === null;
-}
-
-const createPredicate = <T extends HookEvent>(called: Set<PropertyKey>) => {
-    return (hookName: HookName, event: T) => {
-        const hasMethod = Reflect.has(event.newContainer!, hookName);
-        const beenCalledOnce = !called.has(event.key)
-
-        return hasMethod && beenCalledOnce
-    }
-}

src/core/ioc/index.ts

@@ -1,2 +0,0 @@
-export { makeDependencies } from './base';
-export { Service, Services, single, transient } from './dependency-injection';

src/core/module-loading.ts

@@ -1,13 +1,26 @@
-import { Result } from 'ts-results-es';
-import { type Observable, from, mergeMap, ObservableInput } from 'rxjs';
-import { readdir, stat } from 'fs/promises';
-import { basename, extname, join, resolve, parse } from 'path';
-import assert from 'assert';
-import { createRequire } from 'node:module';
-import type { ImportPayload, Wrapper } from '../types/core';
-import type { Module, OnError } from '../types/core-modules';
+import path from 'node:path';
+import { existsSync } from 'node:fs';
+import { readdir } from 'fs/promises';
+import assert from 'node:assert';
+import * as Id from './id'
+import { Module } from '../types/core-modules';
+
+export const parseCallsite = (site: string) => {
+    const pathobj = path.posix.parse(site.replace(/file:\\?/, "")
+                                   .split(path.sep)
+                                   .join(path.posix.sep))
+    return { name: pathobj.name,
+             absPath : path.posix.format(pathobj) }
+}
+
+export const shouldHandle = (pth: string, filenam: string) => {
+    const file_name = filenam+path.extname(pth);
+    let newPath = path.join(path.dirname(pth), file_name)
+                      .replace(/file:\\?/, "");
+    return { exists: existsSync(newPath),
+             path: 'file://'+newPath };
+}
 
-export type ModuleResult<T> = Promise<ImportPayload<T>>;
 
 /**
  * Import any module based on the absolute path.
@@ -15,7 +28,6 @@ export type ModuleResult<T> = Promise<ImportPayload<T>>;
  * commonjs, javascript :
  * ```js
  * exports = commandModule({ })
- *
  * //or
  * exports.default = commandModule({ })
  * ```
@@ -25,107 +37,34 @@ export type ModuleResult<T> = Promise<ImportPayload<T>>;
 export async function importModule<T>(absPath: string) {
     let fileModule = await import(absPath);
 
-    let commandModule = fileModule.default, 
-        onError = fileModule.onError;
+    let commandModule: Module = fileModule.default;
 
-    assert(commandModule , `Found no export @ ${absPath}. Forgot to ignore with "!"? (!${basename(absPath)})?`);
-    if ('default' in commandModule ) {
-        commandModule = commandModule.default;
+    assert(commandModule , `No default export @ ${absPath}`);
+    if ('default' in commandModule) {
+        commandModule = commandModule.default as Module;
     }
-    return Result
-        .wrap(() => ({ module: commandModule.getInstance(), onError }))
-        .unwrapOr({ module: commandModule, onError }) as T;
-}
-interface FileExtras { 
-    onError : OnError
-}
-
-export async function defaultModuleLoader<T extends Module>(absPath: string): ModuleResult<T> {
-    let { onError, module } = await importModule<{ module: T } & FileExtras>(absPath);
-    assert(module, `Found an undefined module: ${absPath}`);
-    return { module, absPath, onError };
-}
-
-export const fmtFileName = (fileName: string) => parse(fileName).name;
-
-/**
- * a directory string is converted into a stream of modules.
- * starts the stream of modules that sern needs to process on init
- * @returns {Observable<{ mod: Module; absPath: string; }[]>} data from command files
- * @param commandDir
- */
-export function buildModuleStream<T extends Module>(
-    input: ObservableInput<string>,
-): Observable<ImportPayload<T>> {
-    return from(input)
-        .pipe(mergeMap(defaultModuleLoader<T>));
-}
-
-export const getFullPathTree = (dir: string) => readPaths(resolve(dir));
-
-export const filename = (path: string) => fmtFileName(basename(path));
-
-const isSkippable = (filename: string) => {
-    //empty string is for non extension files (directories)
-    const validExtensions = ['.js', '.cjs', '.mts', '.mjs', '.cts', '.ts', ''];
-    return filename[0] === '!' || !validExtensions.includes(extname(filename));
-};
-async function deriveFileInfo(dir: string, file: string) {
-    const fullPath = join(dir, file);
-    return {
-        fullPath,
-        fileStats: await stat(fullPath),
-        base: basename(file),
+    const p = path.parse(absPath)
+    commandModule.name ??= p.name; commandModule.description ??= "...";
+    commandModule.meta = {
+        id: Id.create(commandModule.name, commandModule.type),
+        absPath,
     };
+    return { module: commandModule as T };
 }
-async function* readPaths(dir: string): AsyncGenerator<string> {
-    try {
-        const files = await readdir(dir);
-        for (const file of files) {
-            const { fullPath, fileStats, base } = await deriveFileInfo(dir, file);
-            if (fileStats.isDirectory()) {
-                //Todo: refactor so that i dont repeat myself for files (line 71)
-                if (!isSkippable(base)) {
-                    yield* readPaths(fullPath);
-                }
-            } else {
-                if (!isSkippable(base)) {
-                    yield 'file:///' + fullPath;
-                }
+
+
+export async function* readRecursive(dir: string): AsyncGenerator<string> {
+    const files = await readdir(dir, { withFileTypes: true });
+    for (const file of files) {
+        const fullPath = path.posix.join(dir, file.name);
+        if (file.isDirectory()) {
+            if (!file.name.startsWith('!')) {
+                yield* readRecursive(fullPath);
             }
+        } else if (!file.name.startsWith('!')) {
+            yield "file:///"+path.resolve(fullPath);
         }
-    } catch (err) {
-        throw err;
     }
 }
 
-const requir = createRequire(import.meta.url);
 
-export function loadConfig(wrapper: Wrapper | 'file'): Wrapper {
-    if (wrapper !== 'file') {
-        return wrapper;
-    }
-    console.log('Experimental loading of sern.config.json');
-    const config = requir(resolve('sern.config.json')); 
-
-    const makePath = (dir: PropertyKey) =>
-        config.language === 'typescript'
-            ? join('dist', config.paths[dir]!)
-            : join(config.paths[dir]!);
- 
-    console.log('Loading config: ', config);
-    const commandsPath = makePath('commands');
- 
-    console.log('Commands path is set to', commandsPath);
-    let eventsPath: string | undefined;
-    if (config.paths.events) {
-        eventsPath = makePath('events');
-        console.log('Events path is set to', eventsPath);
-    }
-    return {
-        defaultPrefix: config.defaultPrefix,
-        commands: commandsPath,
-        events: eventsPath,
-    };
-    
-}

src/core/modules.ts

@@ -1,112 +1,135 @@
-import { ClientEvents } from 'discord.js';
-import { CommandType, EventType, PluginType } from '../core/structures';
+import type { ClientEvents } from 'discord.js';
+import { EventType } from '../core/structures/enums';
 import type {
-    AnyCommandPlugin,
-    AnyEventPlugin,
-    CommandArgs,
-    ControlPlugin,
-    EventArgs,
-    InitPlugin,
-} from '../types/core-plugin';
-import type {
-    CommandModule,
-    EventModule,
     InputCommand,
     InputEvent,
     Module,
+    ScheduledTask,
 } from '../types/core-modules';
-import { partitionPlugins } from './_internal';
+import { partitionPlugins } from './functions'
 import type { Awaitable } from '../types/utility';
 
 /**
- * @since 1.0.0 The wrapper function to define command modules for sern
- * @param mod
- */
-export function commandModule(mod: InputCommand): CommandModule {
-    const [onEvent, plugins] = partitionPlugins(mod.plugins);
-    return {
-        ...mod,
-        onEvent,
-        plugins,
-    } as CommandModule;
-}
-/**
+ * Creates a command module with standardized structure and plugin support.
+ * 
  * @since 1.0.0
- * The wrapper function to define event modules for sern
- * @param mod
+ * @param {InputCommand} mod - Command module configuration
+ * @returns {Module} Processed command module ready for registration
+ * 
+ * @example
+ * // Basic slash command
+ * export default commandModule({
+ *   type: CommandType.Slash,
+ *   description: "Ping command",
+ *   execute: async (ctx) => {
+ *     await ctx.reply("Pong! 🏓");
+ *   }
+ * });
+ * 
+ * @example
+ * // Command with component interaction
+ * export default commandModule({
+ *   type: CommandType.Slash,
+ *   description: "Interactive command",
+ *   execute: async (ctx) => {
+ *     const button = new ButtonBuilder({
+ *       customId: "btn/someData",
+ *       label: "Click me",
+ *       style: ButtonStyle.Primary
+ *     });
+ *     await ctx.reply({
+ *       content: "Interactive message",
+ *       components: [new ActionRowBuilder().addComponents(button)]
+ *     });
+ *   }
+ * });
  */
-export function eventModule(mod: InputEvent): EventModule {
+export function commandModule(mod: InputCommand): Module {
     const [onEvent, plugins] = partitionPlugins(mod.plugins);
-    return {
-        ...mod,
-        plugins,
-        onEvent,
-    } as EventModule;
+    return { ...mod,
+             onEvent,
+             plugins,
+             locals: {} } as Module;
+}
+
+
+/**
+ * Creates an event module for handling Discord.js or custom events.
+ * 
+ * @since 1.0.0
+ * @template T - Event name from ClientEvents
+ * @param {InputEvent<T>} mod - Event module configuration
+ * @returns {Module} Processed event module ready for registration
+ * @throws {Error} If ControlPlugins are used in event modules
+ * 
+ * @example
+ * // Discord event listener
+ * export default eventModule({
+ *   type: EventType.Discord,
+ *   execute: async (message) => {
+ *     console.log(`${message.author.tag}: ${message.content}`);
+ *   }
+ * });
+ * 
+ * @example
+ * // Custom sern event
+ * export default eventModule({
+ *   type: EventType.Sern,
+ *   execute: async (eventData) => {
+ *     // Handle sern-specific event
+ *   }
+ * });
+ */
+export function eventModule<T extends keyof ClientEvents = keyof ClientEvents>(mod: InputEvent<T>): Module {
+    const [onEvent, plugins] = partitionPlugins(mod.plugins);
+    if(onEvent.length !== 0) throw Error("Event modules cannot have ControlPlugins");
+    return { ...mod,
+             plugins,
+             locals: {} } as Module;
 }
 
 /** Create event modules from discord.js client events,
- * This is an {@link eventModule} for discord events,
- * where typings can be very bad.
- * @Experimental
+ * This was an {@link eventModule} for discord events,
+ * where typings were bad.
+ * @deprecated Use {@link eventModule} instead
  * @param mod
  */
 export function discordEvent<T extends keyof ClientEvents>(mod: {
     name: T;
-    plugins?: AnyEventPlugin[];
+    once?: boolean;
     execute: (...args: ClientEvents[T]) => Awaitable<unknown>;
 }) {
-    return eventModule({
-        type: EventType.Discord,
-        ...mod,
-    });
-}
-
-function prepareClassPlugins(c: Module) {
-    const [onEvent, initPlugins] = partitionPlugins(c.plugins);
-    c.plugins = initPlugins as InitPlugin[];
-    c.onEvent = onEvent as ControlPlugin[];
-}
-//
-// Class modules:
-// Can be refactored.
-// Both implement singleton, could I make them inherit a singleton parent class?
-/**
- * @Experimental
- * Will be refactored / changed in future
- */
-export abstract class CommandExecutable<const Type extends CommandType = CommandType> {
-    abstract type: Type;
-    plugins: AnyCommandPlugin[] = [];
-    private static _instance: CommandModule;
-
-    static getInstance() {
-        if (!CommandExecutable._instance) {
-            //@ts-ignore
-            CommandExecutable._instance = new this();
-            prepareClassPlugins(CommandExecutable._instance);
-        }
-        return CommandExecutable._instance;
-    }
-
-    abstract execute(...args: CommandArgs<Type, PluginType.Control>): Awaitable<unknown>;
+    return eventModule({ type: EventType.Discord, ...mod, });
 }
 
 /**
- * @Experimental
- * Will be refactored in future
+ * Creates a scheduled task that can be executed at specified intervals using cron patterns
+ * 
+ * @param {ScheduledTask} ism - The scheduled task configuration object
+ * @param {string} ism.trigger - A cron pattern that determines when the task should execute
+ *                              Format: "* * * * *" (minute hour day month day-of-week)
+ * @param {Function} ism.execute - The function to execute when the task is triggered
+ * @param {Object} ism.execute.context - The execution context passed to the task
+ * 
+ * @returns {ScheduledTask} The configured scheduled task
+ * 
+ * @example
+ * // Create a task that runs every minute
+ * export default scheduledTask({
+ *   trigger: "* * * * *",
+ *   execute: (context) => {
+ *     console.log("Task executed!");
+ *   }
+ * });
+ * 
+ * @remarks
+ * - Tasks must be placed in the 'tasks' directory specified in your config
+ * - The file name serves as a unique identifier for the task
+ * - Tasks can be cancelled using deps['@sern/scheduler'].kill(uuid)
+ * 
+ * @see {@link https://crontab.guru/} for testing and creating cron patterns
  */
-export abstract class EventExecutable<Type extends EventType> {
-    abstract type: Type;
-    plugins: AnyEventPlugin[] = [];
-
-    private static _instance: EventModule;
-    static getInstance() {
-        if (!EventExecutable._instance) {
-            //@ts-ignore
-            EventExecutable._instance = new this();
-            prepareClassPlugins(EventExecutable._instance);
-        }
-        return EventExecutable._instance;
-    }
-    abstract execute(...args: EventArgs<Type, PluginType.Control>): Awaitable<unknown>;
+export function scheduledTask(ism: ScheduledTask): ScheduledTask { 
+    return ism 
 }
+

src/core/operators.ts

@@ -1,86 +0,0 @@
-/**
- * This file holds sern's rxjs operators used for processing data.
- * Each function should be modular and testable, not bound to discord / sern
- * and independent of each other.
- */
-import {
-    concatMap,
-    defaultIfEmpty,
-    EMPTY,
-    every,
-    fromEvent,
-    map,
-    Observable,
-    of,
-    OperatorFunction,
-    pipe,
-    share,
-} from 'rxjs';
-import { Emitter, ErrorHandling, Logging } from './contracts';
-import util from 'node:util';
-import type { PluginResult, VoidResult } from '../types/core-plugin';
-import type { Result } from 'ts-results-es'
-/**
- * if {src} is true, mapTo V, else ignore
- * @param item
- */
-export function filterMapTo<V>(item: () => V): OperatorFunction<boolean, V> {
-    return concatMap(shouldKeep => (shouldKeep ? of(item()) : EMPTY));
-}
-
-/**
- * Calls any plugin with {args}.
- * @param args if an array, its spread and plugin called.
- */
-export function callPlugin(args: unknown): OperatorFunction<
-    {
-        execute: (...args: unknown[]) => PluginResult;
-    },
-    VoidResult
-> {
-    return concatMap(async plugin => {
-        if (Array.isArray(args)) {
-            return plugin.execute(...args);
-        }
-        return plugin.execute(args);
-    });
-}
-
-export const arrayifySource = map(src => (Array.isArray(src) ? (src as unknown[]) : [src]));
-
-/**
- * Checks if the stream of results is all ok.
- */
-export const everyPluginOk: OperatorFunction<VoidResult, boolean> = pipe(
-    every(result => result.isOk()),
-    defaultIfEmpty(true),
-);
-
-export const sharedEventStream = <T>(e: Emitter, eventName: string) => {
-    return (fromEvent(e, eventName) as Observable<T>).pipe(share());
-};
-
-export function handleError<C>(crashHandler: ErrorHandling, logging?: Logging) {
-    return (pload: unknown, caught: Observable<C>) => {
-        // This is done to fit the ErrorHandling contract
-        const err = pload instanceof Error ? pload : Error(util.inspect(pload, { colors: true }));
-        //formatted payload
-        logging?.error({ message: util.inspect(pload) });
-        crashHandler.updateAlive(err);
-        return caught;
-    };
-}
-// Temporary until i get rxjs operators working on ts-results-es
-export const filterTap = <K, R>(onErr: (e: R) => void): OperatorFunction<Result<K, R>, K> => 
-    pipe(
-        concatMap(result => {
-            if(result.isOk()) {
-                return of(result.value)
-            }
-            onErr(result.error);
-            return EMPTY
-
-        })
-    )
-
-

src/core/plugin.ts

@@ -0,0 +1,137 @@
+import { CommandType, PluginType } from './structures/enums';
+import type { Plugin, PluginResult, CommandArgs, InitArgs } from '../types/core-plugin';
+import { Err, Ok } from './structures/result';
+import type { Dictionary } from '../types/utility';
+
+export function makePlugin<V extends unknown[]>(
+    type: PluginType,
+    execute: (...args: any[]) => any,
+): Plugin<V> {
+    return { type, execute } as Plugin<V>;
+}
+/**
+ * @since 2.5.0
+ */
+export function EventInitPlugin(execute: (args: InitArgs) => PluginResult) {
+    return makePlugin(PluginType.Init, execute);
+}
+
+/**
+ * Creates an initialization plugin for command preprocessing and modification
+ * 
+ * @since 2.5.0
+ * @template I - Extends CommandType to enforce type safety for command modules
+ * 
+ * @param {function} execute - Function to execute during command initialization
+ * @param {InitArgs<T>} execute.args - The initialization arguments
+ * @param {T} execute.args.module - The command module being initialized
+ * @param {string} execute.args.absPath - The absolute path to the module file
+ * @param {Dependencies} execute.args.deps - Dependency injection container
+ * 
+ * @returns {Plugin} A plugin that runs during command initialization
+ * 
+ * @example
+ * // Plugin to update command description
+ * export const updateDescription = (description: string) => {
+ *   return CommandInitPlugin(({ deps }) => {
+ *     if(description.length > 100) {
+ *       deps.logger?.info({ message: "Invalid description" })
+ *       return controller.stop("From updateDescription: description is invalid");
+ *     }
+ *     module.description = description;
+ *     return controller.next();
+ *   });
+ * };
+ * 
+ * @example
+ * // Plugin to store registration date in module locals
+ * export const dateRegistered = () => {
+ *   return CommandInitPlugin(({ module }) => {
+ *     module.locals.registered = Date.now()
+ *     return controller.next();
+ *   });
+ * };
+ * 
+ * @remarks
+ * - Init plugins can modify how commands are loaded and perform preprocessing
+ * - The module.locals object can be used to store custom plugin-specific data
+ * - Be careful when modifying module fields as multiple plugins may interact with them
+ * - Use controller.next() to continue to the next plugin
+ * - Use controller.stop(reason) to halt plugin execution
+ */
+export function CommandInitPlugin<I extends CommandType>(
+    execute: (args: InitArgs) => PluginResult
+): Plugin {
+    return makePlugin(PluginType.Init, execute);
+}
+
+/**
+ * Creates a control plugin for command preprocessing, filtering, and state management
+ * 
+ * @since 2.5.0
+ * @template I - Extends CommandType to enforce type safety for command modules
+ * 
+ * @param {function} execute - Function to execute during command control flow
+ * @param {CommandArgs<I>} execute.args - The command arguments array
+ * @param {Context} execute.args[0] - The discord context (e.g., guild, channel, user info, interaction)
+ * @param {SDT} execute.args[1] - The State, Dependencies, Params, Module, and Type object
+ * 
+ * @returns {Plugin} A plugin that runs during command execution flow
+ * 
+ * @example
+ * // Plugin to restrict command to specific guild
+ * export const inGuild = (guildId: string) => {
+ *   return CommandControlPlugin((ctx, sdt) => {
+ *     if(ctx.guild.id !== guildId) {
+ *       return controller.stop();
+ *     }
+ *     return controller.next();
+ *   });
+ * };
+ * 
+ * @example
+ * // Plugins passing state through the chain
+ * const plugin1 = CommandControlPlugin((ctx, sdt) => {
+ *   return controller.next({ 'plugin1/data': 'from plugin1' });
+ * });
+ * 
+ * const plugin2 = CommandControlPlugin((ctx, sdt) => {
+ *   return controller.next({ 'plugin2/data': ctx.user.id });
+ * });
+ * 
+ * export default commandModule({
+ *   type: CommandType.Slash,
+ *   plugins: [plugin1, plugin2],
+ *   execute: (ctx, sdt) => {
+ *     console.log(sdt.state); // Access accumulated state
+ *   }
+ * });
+ * 
+ * @remarks
+ * - Control plugins are executed in order when a discord.js event is emitted
+ * - Use controller.next() to continue to next plugin or controller.stop() to halt execution
+ * - State can be passed between plugins using controller.next({ key: value })
+ * - State keys should be namespaced to avoid collisions (e.g., 'plugin-name/key')
+ * - Final accumulated state is passed to the command's execute function
+ * - All plugins must succeed for the command to execute
+ * - Plugins have access to dependencies through the sdt.deps object
+ * - Useful for implementing preconditions, filters, and command preprocessing
+ */
+export function CommandControlPlugin<I extends CommandType>(
+    execute: (...args: CommandArgs<I>) => PluginResult,
+) {
+    return makePlugin(PluginType.Control, execute);
+}
+
+
+/**
+ * @since 1.0.0
+ * The object passed into every plugin to control a command's behavior
+ */
+export const controller = {
+    next: (val?: Dictionary) => Ok(val),
+    stop: (val?: string) => Err(val),
+};
+
+
+export type Controller = typeof controller;

src/core/predicates.ts

@@ -1,34 +0,0 @@
-import type {
-    AnySelectMenuInteraction,
-    AutocompleteInteraction,
-    ButtonInteraction,
-    ChatInputCommandInteraction,
-    MessageContextMenuCommandInteraction,
-    ModalSubmitInteraction,
-    UserContextMenuCommandInteraction,
-} from 'discord.js';
-import { InteractionType } from 'discord.js';
-
-interface InteractionTypable {
-    type: InteractionType;
-}
-//discord.js pls fix ur typings or i will >:(
-type AnyMessageComponentInteraction = AnySelectMenuInteraction | ButtonInteraction;
-type AnyCommandInteraction =
-    | ChatInputCommandInteraction
-    | MessageContextMenuCommandInteraction
-    | UserContextMenuCommandInteraction;
-
-export function isMessageComponent(i: InteractionTypable): i is AnyMessageComponentInteraction {
-    return i.type === InteractionType.MessageComponent;
-}
-export function isCommand(i: InteractionTypable): i is AnyCommandInteraction {
-    return i.type === InteractionType.ApplicationCommand;
-}
-export function isAutocomplete(i: InteractionTypable): i is AutocompleteInteraction {
-    return i.type === InteractionType.ApplicationCommandAutocomplete;
-}
-
-export function isModal(i: InteractionTypable): i is ModalSubmitInteraction {
-    return i.type === InteractionType.ModalSubmit;
-}

src/core/presences.ts

@@ -0,0 +1,65 @@
+import type { ActivitiesOptions } from "discord.js";
+import type { IntoDependencies } from "./ioc";
+import type { Emitter } from "./interfaces";
+import { Awaitable } from "../types/utility";
+
+type Status = 'online' | 'idle' | 'invisible' | 'dnd'
+type PresenceReduce = (previous: Presence.Result) => Awaitable<Presence.Result>;
+
+export const Presence = {
+    /**
+     * A small wrapper to provide type inference.
+     * Create a Presence module which **MUST** be put in a file called presence.(language-extension)
+     * adjacent to the file where **Sern.init** is CALLED.
+     */
+    module : <T extends (keyof Dependencies)[]>(conf: Presence.Config<T>) => conf,
+    /**
+     * Create a Presence body which can be either: 
+     * - once, the presence is activated only once.
+     * - repeated, per cycle or event, the presence can be changed.
+     */
+    of : (root: Omit<Presence.Result, 'repeat' | 'onRepeat'>) => {
+        return { 
+            /**
+             * @example
+             * Presence
+             *     .of({ activities: [{ name: "deez nuts" }] }) //starts presence with "deez nuts".
+             *     .repeated(prev => { 
+             *         return {
+             *             afk: true,
+             *             activities: prev.activities?.map(s => ({ ...s, name: s.name+"s" }))
+             *         };
+             *     }, 10000)) //every 10 s, the callback sets the presence to the value returned.
+             */
+            repeated: (onRepeat: PresenceReduce, repeat: number | [Emitter, string]) => {
+                return { repeat, onRepeat, ...root }
+            },
+            /**
+             * @example
+             * ```ts
+             * Presence.of({
+             *    activities: [{ name: "Chilling out" }]
+             * }).once() // Sets the presence once, with what's provided in '.of()'
+             *  ```
+             */
+            once: () => root
+        };
+    }
+}
+export declare namespace Presence {
+    export type Config<T extends (keyof Dependencies)[]> = {
+        inject?: [...T]
+        execute: (...v: IntoDependencies<T>) => Awaitable<Presence.Result>;
+
+    }
+
+    export interface Result { 
+        status?: Status;
+        afk?: boolean;
+        activities?: ActivitiesOptions[];
+        shardId?: number[];
+        repeat?: number | [Emitter, string];
+        onRepeat?: PresenceReduce 
+    }
+}
+

src/core/structures/command-error.ts

@@ -1,6 +0,0 @@
-import type { Logging } from "../contracts";
-
-export interface Response { 
-    type: 'fail' | 'handled';
-    log?: { type: keyof Logging; message: unknown }
-}

src/core/structures/context.ts

@@ -1,4 +1,4 @@
-import {
+import type {
     BaseInteraction,
     ChatInputCommandInteraction,
     Client,
@@ -8,10 +8,11 @@ import {
     Snowflake,
     User,
 } from 'discord.js';
-import { CoreContext } from '../structures/core-context';
-import { Result, Ok, Err } from 'ts-results-es';
+import { Result, Ok, Err, val } from './result';
 import * as assert from 'assert';
-import { ReplyOptions } from '../../types/utility';
+import type { ReplyOptions } from '../../types/utility';
+import { fmt } from '../functions'
+import { SernError } from './enums';
 
 
 /**
@@ -19,33 +20,32 @@ import { ReplyOptions } from '../../types/utility';
  * Provides values shared between
  * Message and ChatInputCommandInteraction
  */
-export class Context extends CoreContext<Message, ChatInputCommandInteraction> {
-    /*
-     * @Experimental
-     */
+export class Context {
+    
     get options() {
+        if(this.isMessage()) {
+            const [, ...rest] = fmt(this.message.content, this.prefix);
+            return rest;
+        } 
         return this.interaction.options;
     }
-    protected constructor(protected ctx: Result<Message, ChatInputCommandInteraction>) {
-        super(ctx);
-    }
+    
 
+    protected constructor(protected ctx: Result<Message, ChatInputCommandInteraction>,
+                          private __prefix?: string) { }
+    public get prefix() {
+        return this.__prefix;
+    }
     public get id(): Snowflake {
-        return safeUnwrap(this.ctx
-                            .map(m => m.id)
-                            .mapErr(i => i.id));
+        return val(this.ctx).id
     }
 
     public get channel() {
-        return safeUnwrap(this.ctx
-                            .map(m => m.channel)
-                            .mapErr(i => i.channel));
+        return val(this.ctx).channel;
     }
 
     public get channelId(): Snowflake {
-        return safeUnwrap(this.ctx
-                            .map(m => m.channelId)
-                            .mapErr(i => i.channelId));
+        return val(this.ctx).channelId;
     }
     
     /**
@@ -53,9 +53,11 @@ export class Context extends CoreContext<Message, ChatInputCommandInteraction> {
      * else, interaction.user
      */
     public get user(): User {
-        return safeUnwrap(this.ctx
-                            .map(m => m.author)
-                            .mapErr(i => i.user));
+        if(this.ctx.ok) {
+            return this.ctx.value.author;
+        } 
+        return this.ctx.error.user;
+        
     }
 
     public get userId(): Snowflake {
@@ -63,65 +65,67 @@ export class Context extends CoreContext<Message, ChatInputCommandInteraction> {
     }
 
     public get createdTimestamp(): number {
-        return safeUnwrap(this.ctx 
-                            .map(m => m.createdTimestamp)
-                            .mapErr(i => i.createdTimestamp));
+        return val(this.ctx).createdTimestamp;
     }
 
     public get guild() {
-        return safeUnwrap(this.ctx
-                            .map(m => m.guild)
-                            .mapErr(i => i.guild));
+        return val(this.ctx).guild;
     }
 
     public get guildId() {
-        return safeUnwrap(this.ctx
-                            .map(m => m.guildId)
-                            .mapErr(i => i.guildId));
+        return val(this.ctx).guildId;
     }
     /*
      * interactions can return APIGuildMember if the guild it is emitted from is not cached
      */
     public get member() {
-        return safeUnwrap(this.ctx
-                            .map(m => m.member)
-                            .mapErr(i => i.member));
+        return val(this.ctx).member;
     }
 
+    get message(): Message {
+        if(this.ctx.ok) {
+            return this.ctx.value;
+        }
+        throw Error(SernError.MismatchEvent);
+    }
+    public isMessage(): this is Context & { ctx: Result<Message, never> } {
+        return this.ctx.ok;
+    }
+
+    public isSlash(): this is Context & { ctx: Result<never, ChatInputCommandInteraction> } {
+        return !this.isMessage();
+    }
+
+    get interaction(): ChatInputCommandInteraction {
+        if(!this.ctx.ok) {
+            return this.ctx.error;
+        }
+        throw Error(SernError.MismatchEvent);
+    }
+
+
     public get client(): Client {
-        return safeUnwrap(this.ctx
-                            .map(m => m.client)
-                            .mapErr(i => i.client));
+        return val(this.ctx).client;
     }
 
     public get inGuild(): boolean {
-        return safeUnwrap(this.ctx
-                            .map(m => m.inGuild())
-                            .mapErr(i => i.inGuild()));
+        return val(this.ctx).inGuild()
     }
 
     public async reply(content: ReplyOptions) {
-        return safeUnwrap(
-            this.ctx
-                .map(m => m.reply(content as MessageReplyOptions))
-                .mapErr(i =>
-                    i.reply(content as InteractionReplyOptions).then(() => i.fetchReply()),
-                ),
-        );
+        if(this.ctx.ok) {
+            return this.ctx.value.reply(content as MessageReplyOptions)
+        } 
+        interface FetchReply { fetchReply: true };
+        return this.ctx.error.reply(content as InteractionReplyOptions & FetchReply)
+       
     }
 
-    static override wrap(wrappable: BaseInteraction | Message): Context {
+    static wrap(wrappable: BaseInteraction | Message, prefix?: string): Context {
         if ('interaction' in wrappable) {
-            return new Context(Ok(wrappable));
+            return new Context(Ok(wrappable), prefix);
         }
-        assert.ok(wrappable.isChatInputCommand());
-        return new Context(Err(wrappable));
+        assert.ok(wrappable.isChatInputCommand(), "Context created with bad interaction.");
+        return new Context(Err(wrappable), prefix);
     }
 }
-
-function safeUnwrap<T>(res: Result<T, T>) {
-    if(res.isOk()) {
-        return res.expect("Tried unwrapping message field: " + res)
-    } 
-    return res.expectErr("Tried unwrapping interaction field" + res)
-}

src/core/structures/core-context.ts

@@ -1,32 +0,0 @@
-import { Result as Either } from 'ts-results-es';
-import { SernError } from '../_internal';
-import * as assert from 'node:assert';
-
-/**
- * @since 3.0.0
- */
-export abstract class CoreContext<M, I> {
-    protected constructor(protected ctx: Either<M, I>) {
-        assert.ok(typeof ctx === 'object' && ctx != null);
-    }
-    get message(): M {
-        return this.ctx.expect(SernError.MismatchEvent);
-    }
-    get interaction(): I {
-        return this.ctx.expectErr(SernError.MismatchEvent);
-    }
-
-    public isMessage(): this is CoreContext<M, never> {
-        return this.ctx.isOk();
-    }
-
-    public isSlash(): this is CoreContext<never, I> {
-        return !this.isMessage();
-    }
-    //todo: add agnostic options resolver for Context
-    abstract get options(): unknown;
-
-    static wrap(_: unknown): unknown {
-        throw Error('You need to override this method; cannot wrap an abstract class');
-    }
-}

src/core/structures/default-services.ts

@@ -0,0 +1,89 @@
+import { ScheduledTask } from '../../types/core-modules';
+import type { LogPayload, Logging, ErrorHandling, Disposable } from '../interfaces';
+import { CronJob } from 'cron';
+
+/**
+ * @internal
+ * @since 2.0.0
+ * Version 4.0.0 will internalize this api. Please refrain from using the defaults!
+ */
+export class DefaultErrorHandling implements ErrorHandling {
+    crash(err: Error): never {
+        throw err;
+    }
+    updateAlive(err: Error) {
+        throw err;
+    }
+}
+
+
+/**
+ * @internal
+ * @since 2.0.0
+ * Version 4.0.0 will internalize this api. Please refrain from using ModuleStore!
+ */
+export class DefaultLogging implements Logging {
+    private date() { return new Date() } 
+    debug(payload: LogPayload): void {
+        console.debug(`DEBUG: ${this.date().toISOString()} -> ${payload.message}`);
+    }
+
+    error(payload: LogPayload): void {
+        console.error(`ERROR: ${this.date().toISOString()} -> ${payload.message}`);
+    }
+
+    info(payload: LogPayload): void {
+        console.info(`INFO: ${this.date().toISOString()} -> ${payload.message}`);
+    }
+
+    warning(payload: LogPayload): void {
+        console.warn(`WARN: ${this.date().toISOString()} -> ${payload.message}`);
+    }
+}
+
+
+export class TaskScheduler implements Disposable {
+    private __tasks: Map<string, CronJob<any, any>> = new Map();
+
+    schedule(uuid: string, task: ScheduledTask, deps: Dependencies) {
+        if (this.__tasks.has(uuid)) {
+            throw Error("while scheduling a task \
+                         found another task of same name. Not scheduling " +
+                         uuid + "again."  );
+        }
+        try {
+            const onTick = async function(this: CronJob) {
+                task.execute({ id: uuid,
+                               lastTimeExecution: this.lastExecution,
+                               nextTimeExecution: this.nextDate().toJSDate() }, { deps })
+           }
+           const job = CronJob.from({ cronTime: task.trigger, onTick, timeZone: task.timezone });
+           job.start();
+           this.__tasks.set(uuid, job);
+        } catch (error) {
+           throw Error(`while scheduling a task ${uuid} ` +  error);
+        }
+    }
+  
+    kill(taskName: string): boolean {
+        const job = this.__tasks.get(taskName);
+        if (job) {
+            job.stop();
+            this.__tasks.delete(taskName);
+            return true;
+        }
+        return false;
+    }
+  
+    get tasks(): string[] {
+        return Array.from(this.__tasks.keys());
+    }
+
+    dispose() {
+        this.__tasks.forEach((_, id) => {
+            this.kill(id);
+            this.__tasks.delete(id);
+        })
+    }
+    
+}

src/core/structures/enums.ts

@@ -48,16 +48,16 @@ export enum EventType {
     /**
      * The EventType for handling discord events
      */
-    Discord = 1,
+    Discord,
     /**
      * The EventType for handling sern events
      */
-    Sern = 2,
+    Sern,
     /**
      * The EventType for handling external events.
      * Could be for example, `process` events, database events
      */
-    External = 3,
+    External,
 }
 
 /**
@@ -85,20 +85,12 @@ export enum PluginType {
     Control = 2,
 }
 /**
+ * @deprecated - Use strings 'success' | 'failure' | 'warning'
  * @enum { string }
  */
 export enum PayloadType {
-    /**
-     * The PayloadType for a SernEmitter success event
-     */
     Success = 'success',
-    /**
-     * The PayloadType for a SernEmitter failure event
-     */
     Failure = 'failure',
-    /**
-     * The PayloadType for a SernEmitter warning event
-     */
     Warning = 'warning',
 }
 

src/core/structures/index.ts

@@ -1,6 +0,0 @@
-export { CommandType, PluginType, PayloadType, EventType } from './enums';
-export * from './context';
-export * from './sern-emitter';
-export * from './services';
-export * from './module-store';
-export * as CommandError from './command-error';

src/core/structures/module-store.ts

@@ -1,13 +0,0 @@
-import { CommandMeta, Module, OnError } from '../../types/core-modules';
-import { CoreModuleStore } from '../contracts';
-
-/*
- * @internal
- * Version 4.0.0 will internalize this api. Please refrain from using ModuleStore!
- * For interacting with modules, use the ModuleManager instead.
- */
-export class ModuleStore implements CoreModuleStore {
-    onError = new WeakMap<Module, NonNullable<OnError>>();
-    metadata = new WeakMap<Module, CommandMeta>();
-    commands = new Map<string, string>();
-}

src/core/structures/result.ts

@@ -0,0 +1,20 @@
+export type Result<Ok, Err> =
+  | { ok: true; value: Ok }
+  | { ok: false; error: Err };
+
+export const Ok = <Ok>(value: Ok) => ({ ok: true, value } as const);
+export const Err = <Err>(error: Err) => ({ ok: false, error } as const);
+
+export const val = <O, E>(r: Result<O, E>) => r.ok ? r.value : r.error;
+export const EMPTY_ERR = Err(undefined);
+
+/**
+ * Wrap an async operation that may throw an Error (`try-catch` style) into checked exception style
+ * @param op The operation function
+ */
+export async function wrapAsync<T, E = unknown>(op: () => Promise<T>): Promise<Result<T, E>> {
+    try { return op()
+            .then(Ok)
+            .catch(Err); } 
+    catch (e) { return Promise.resolve(Err(e as E)); }
+}

src/core/structures/sern-emitter.ts

@@ -1,89 +0,0 @@
-import { EventEmitter } from 'node:events';
-import { PayloadType } from '../../core/structures';
-import { Module } from '../../types/core-modules';
-import { SernEventsMapping, Payload } from '../../types/utility';
-
-/**
- * @since 1.0.0
- */
-export class SernEmitter extends EventEmitter {
-    constructor() {
-        super({ captureRejections: true });
-    }
-    /**
-     * Listening to sern events with on. This event stays on until a crash or a normal exit
-     * @param eventName
-     * @param listener what to do with the data
-     */
-    public override on<T extends keyof SernEventsMapping>(
-        eventName: T,
-        listener: (...args: SernEventsMapping[T][]) => void,
-    ): this {
-        return super.on(eventName, listener);
-    }
-    /**
-     * Listening to sern events with on. This event stays on until a crash or a normal exit
-     * @param eventName
-     * @param listener what to do with the data
-     */
-    public override once<T extends keyof SernEventsMapping>(
-        eventName: T,
-        listener: (...args: SernEventsMapping[T][]) => void,
-    ): this {
-        return super.once(eventName, listener);
-    }
-    /**
-     * Listening to sern events with on. This event stays on until a crash or a normal exit
-     * @param eventName
-     * @param args the arguments for emitting the eventName
-     */
-    public override emit<T extends keyof SernEventsMapping>(
-        eventName: T,
-        ...args: SernEventsMapping[T]
-    ): boolean {
-        return super.emit(eventName, ...args);
-    }
-    private static payload<T extends Payload>(
-        type: PayloadType,
-        module?: Module,
-        reason?: unknown,
-    ) {
-        return { type, module, reason } as T;
-    }
-
-    /**
-     * Creates a compliant SernEmitter failure payload
-     * @param module
-     * @param reason
-     */
-    static failure(module?: Module, reason?: unknown) {
-        //The generic cast Payload & { type : PayloadType.* } coerces the type to be a failure payload
-        // same goes to the other methods below
-        return SernEmitter.payload<Payload & { type: PayloadType.Failure }>(
-            PayloadType.Failure,
-            module,
-            reason,
-        );
-    }
-    /**
-     * Creates a compliant SernEmitter module success payload
-     * @param module
-     */
-    static success(module: Module) {
-        return SernEmitter.payload<Payload & { type: PayloadType.Success }>(
-            PayloadType.Success,
-            module,
-        );
-    }
-    /**
-     * Creates a compliant SernEmitter module warning payload
-     * @param reason
-     */
-    static warning(reason: unknown) {
-        return SernEmitter.payload<Payload & { type: PayloadType.Warning }>(
-            PayloadType.Warning,
-            undefined,
-            reason,
-        );
-    }
-}

src/core/structures/services/error-handling.ts

@@ -1,21 +0,0 @@
-import { ErrorHandling } from '../../contracts';
-
-/**
- * @internal
- * @since 2.0.0
- * Version 4.0.0 will internalize this api. Please refrain from using the defaults!
- */
-export class DefaultErrorHandling implements ErrorHandling {
-    crash(err: Error): never {
-        throw err;
-    }
-
-    #keepAlive = 5;
-
-    updateAlive(err: Error) {
-        this.#keepAlive--;
-        if (this.#keepAlive === 0) {
-            throw err;
-        }
-    }
-}

src/core/structures/services/index.ts

@@ -1,3 +0,0 @@
-export * from './error-handling';
-export * from './logger';
-export * from './module-manager';

src/core/structures/services/logger.ts

@@ -1,25 +0,0 @@
-import { LogPayload, Logging } from '../../contracts';
-
-/**
- * @internal
- * @since 2.0.0
- * Version 4.0.0 will internalize this api. Please refrain from using ModuleStore!
- */
-export class DefaultLogging implements Logging {
-    private date = () => new Date();
-    debug(payload: LogPayload): void {
-        console.debug(`DEBUG: ${this.date().toISOString()} -> ${payload.message}`);
-    }
-
-    error(payload: LogPayload): void {
-        console.error(`ERROR: ${this.date().toISOString()} -> ${payload.message}`);
-    }
-
-    info(payload: LogPayload): void {
-        console.info(`INFO: ${this.date().toISOString()} -> ${payload.message}`);
-    }
-
-    warning(payload: LogPayload): void {
-        console.warn(`WARN: ${this.date().toISOString()} -> ${payload.message}`);
-    }
-}

src/core/structures/services/module-manager.ts

@@ -1,58 +0,0 @@
-import * as Id from '../../../core/id';
-import { CoreModuleStore, ModuleManager } from '../../contracts';
-import { Files } from '../../_internal';
-import { CommandMeta, CommandModule, CommandModuleDefs, Module, OnError } from '../../../types/core-modules';
-import { CommandType } from '../enums';
-/**
- * @internal
- * @since 2.0.0
- * Version 4.0.0 will internalize this api. Please refrain from using DefaultModuleManager!
- */
-export class DefaultModuleManager implements ModuleManager {
-    constructor(private moduleStore: CoreModuleStore) {}
-
-
-    getErrorCallback(m: Module): OnError {
-        return this.moduleStore.onError.get(m);
-    }
-    setErrorCallback(m: Module, c: NonNullable<OnError>): void {
-        this.moduleStore.onError.set(m, c);
-    }
-
-    getByNameCommandType<T extends CommandType>(name: string, commandType: T) {
-        const id = this.get(Id.create(name, commandType));
-        if (!id) {
-            return undefined;
-        }
-        return Files.importModule<CommandModuleDefs[T]>(id);
-    }
-
-    setMetadata(m: Module, c: CommandMeta): void {
-        this.moduleStore.metadata.set(m, c);
-    }
-
-    getMetadata(m: Module): CommandMeta {
-        const maybeModule = this.moduleStore.metadata.get(m);
-        if (!maybeModule) {
-            throw Error('Could not find metadata in store for ' + m);
-        }
-        return maybeModule;
-    }
-
-    get(id: string) {
-        return this.moduleStore.commands.get(id);
-    }
-    set(id: string, path: string): void {
-        this.moduleStore.commands.set(id, path);
-    }
-    //not tested
-    getPublishableCommands(): Promise<CommandModule[]> {
-        const entries = this.moduleStore.commands.entries();
-        const publishable = 0b000000110;
-        return Promise.all(
-            Array.from(entries)
-                .filter(([id]) => !(Number.parseInt(id.at(-1)!) & publishable))
-                .map(([, path]) => Files.importModule<CommandModule>(path)),
-        );
-    }
-}

src/handlers/_internal.ts

@@ -1,2 +0,0 @@
-export * from './dispatchers';
-export * from './event-utils';

src/handlers/dispatchers.ts

@@ -1,107 +0,0 @@
-import { EventEmitter } from 'node:events';
-import * as assert from 'node:assert';
-import { concatMap, from, fromEvent, map, OperatorFunction, pipe } from 'rxjs';
-import {
-    arrayifySource,
-    callPlugin,
-    isAutocomplete,
-    treeSearch,
-    SernError,
-} from '../core/_internal';
-import { createResultResolver } from './event-utils';
-import { BaseInteraction, Message } from 'discord.js';
-import { CommandType, Context } from '../core';
-import type { AnyFunction, Args } from '../types/utility';
-import type { CommandModule, Module, OnError, Processed } from '../types/core-modules';
-
-//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,
-    };
-}
-
-export function contextArgs(wrappable: Message | BaseInteraction, messageArgs?: string[]) {
-    const ctx = Context.wrap(wrappable);
-    const args = ctx.isMessage() ? ['text', messageArgs!] : ['slash', ctx.options];
-    return [ctx, args] as [Context, Args];
-}
-
-function interactionArg<T extends BaseInteraction>(interaction: T) {
-    return [interaction] as [T];
-}
-
-function intoPayload(module: Processed<Module>, onError: AnyFunction|undefined) {
-    return pipe(
-        arrayifySource,
-        map(args => ({ module, args, onError })),
-    );
-}
-
-const createResult = createResultResolver<
-    Processed<Module>,
-    { module: Processed<Module>; args: unknown[], onError: AnyFunction|undefined },
-    unknown[]
->({
-    createStream: ({ module, args }) => from(module.onEvent).pipe(callPlugin(args)),
-    onNext: ({ args }) => args,
-});
-/**
- * Creates an observable from { source }
- * @param module
- * @param source
- */
-export function eventDispatcher(module: Processed<Module>, onError: OnError, source: unknown) {
-    assert.ok(source instanceof EventEmitter, `${source} is not an EventEmitter`);
-
-    const execute: OperatorFunction<unknown[], unknown> = concatMap(async args =>
-        module.execute(...args),
-    );
-    return fromEvent(source, module.name).pipe(
-        intoPayload(module, onError),
-        concatMap(createResult),
-        execute,
-    );
-}
-
-export function createDispatcher(payload: {
-    module: Processed<CommandModule>;
-    event: BaseInteraction;
-    onError:  OnError
-}) {
-    assert.ok(
-        CommandType.Text !== payload.module.type,
-        SernError.MismatchEvent + 'Found text command in interaction stream',
-    );
-    switch (payload.module.type) {
-        case CommandType.Slash:
-        case CommandType.Both: {
-            if (isAutocomplete(payload.event)) {
-                const option = treeSearch(payload.event, payload.module.options);
-                assert.ok(
-                    option,
-                    Error(SernError.NotSupportedInteraction + ` There is no autocomplete tag for this option`),
-                );
-                const { command } = option;
-             	return {
-                    ...payload,
-             	    module: command as Processed<Module>, //autocomplete is not a true "module" warning cast!
-             	    args: [payload.event],
-                    onError: undefined
-             	};
-            }
-            return { 
-                args: contextArgs(payload.event),
-                ...payload,
-                onError: payload.onError
-            }; 
-        }
-        default:
-            return {
-                args: interactionArg(payload.event),
-                ...payload,
-                onError: payload.onError
-            }
-    }
-}

src/handlers/event-utils.ts

@@ -1,288 +1,74 @@
-import { Interaction, Message } from 'discord.js';
-import {
-    EMPTY,
-    Observable,
-    concatMap,
-    filter,
-    from,
-    of,
-    throwError,
-    tap,
-    MonoTypeOperatorFunction,
-    catchError,
-    finalize,
-} from 'rxjs';
-import {
-    Files,
-    Id,
-    callPlugin,
-    everyPluginOk,
-    filterMapTo,
-    handleError,
-    SernError,
-    VoidResult,
-    useContainerRaw,
-} from '../core/_internal';
-import { CommandError, Emitter, ErrorHandling, Logging, ModuleManager } from '../core';
-import { contextArgs, createDispatcher } from './dispatchers';
-import { ObservableInput, pipe } from 'rxjs';
-import { SernEmitter } from '../core';
-import { Err, Ok, Result } from 'ts-results-es';
-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>,
-    makeModule: (event: Narrowed) => Promise<Output>,
-) {
-    return (pred: (i: Source) => i is Narrowed) => 
-        source.pipe(
-            filter(pred),
-            concatMap(makeModule));
-}
-
-/**
- * Removes the first character(s) _[depending on prefix length]_ of the message
- * @param msg
- * @param prefix The prefix to remove
- * @returns The message without the prefix
- * @example
- * message.content = '!ping';
- * console.log(fmt(message, '!'));
- * // [ 'ping' ]
- */
-export function fmt(msg: string, prefix: string): string[] {
-    return msg.slice(prefix.length).trim().split(/\s+/g);
-}
-
-/**
- *
- * Creates an RxJS observable that filters and maps incoming interactions to their respective modules.
- * @param i An RxJS observable of interactions.
- * @param mg The module manager instance used to retrieve the module path for each interaction.
- * @returns A handler to create a RxJS observable of dispatchers that take incoming interactions and execute their corresponding modules.
- */
-export function createInteractionHandler<T extends Interaction>(
-    source: Observable<Interaction>,
-    mg: ModuleManager,
-) {
-    return createGenericHandler<Interaction, T, Result<ReturnType<typeof createDispatcher>, void>>(
-        source,
-        async event => {
-            const fullPath = mg.get(Id.reconstruct(event));
-            if(!fullPath) {
-                return Err.EMPTY
-            }
-            return Files
-                .defaultModuleLoader<Processed<CommandModule>>(fullPath)
-                .then(payload =>
-                   Ok(createDispatcher({ 
-                       module: payload.module,
-                       onError: payload.onError,
-                       event,
-                      })));
-        },
-    );
-}
-
-export function createMessageHandler(
-    source: Observable<Message>,
-    defaultPrefix: string,
-    mg: ModuleManager,
-) {
-    return createGenericHandler(source, async event => {
-        const [prefix, ...rest] = fmt(event.content, defaultPrefix);
-        const fullPath = mg.get(`${prefix}_A1`);
-
-        if(!fullPath) {
-            return Err('Possibly undefined behavior: could not find a static id to resolve')
-        }
-        return Files
-            .defaultModuleLoader<Processed<CommandModule>>(fullPath)
-            .then(payload => {
-                const args = contextArgs(event, rest);
-                return Ok({ args, ...payload });
-            });
-    });
-}
-/**
- * IMPURE SIDE EFFECT
- * This function assigns remaining, incomplete data to each imported module.
- */
-function assignDefaults<T extends Module>(
-    moduleManager: ModuleManager,
-): MonoTypeOperatorFunction<ImportPayload<T>> {
-    return tap(({ module, absPath }) => {
-        module.name ??= Files.filename(absPath);
-        module.description ??= '...';
-        moduleManager.setMetadata(module, {
-            isClass: module.constructor.name === 'Function',
-            fullPath: absPath,
-            id: Id.create(module.name, module.type),
-        });
-    });
-}
-
-export function buildModules<T extends AnyModule>(
-    input: ObservableInput<string>,
-    moduleManager: ModuleManager,
-) {
-    return Files.buildModuleStream<Processed<T>>(input).pipe(assignDefaults(moduleManager));
-}
+import type { Emitter, Logging } from '../core/interfaces';
+import { SernError } from '../core/structures/enums'
+import { Ok, wrapAsync} from '../core/structures/result';
+import type {  Module } from '../types/core-modules';
+import { inspect } from 'node:util'
+import { resultPayload } from '../core/functions'
+import merge from 'deepmerge'
 
 
 interface ExecutePayload {
-    module: Processed<Module>;
-    task: () => Awaitable<unknown>;
-    onError: AnyFunction|undefined 
-    args: unknown[]
+    module: Module;
+    args: unknown[];
+    [key: string]: unknown
 }
-/**
- * Wraps the task in a Result as a try / catch.
- * if the task is ok, an event is emitted and the stream becomes empty
- * if the task is an error, throw an error down the stream which will be handled by catchError
- * @param emitter reference to SernEmitter that will emit a successful execution of module
- * @param module the module that will be executed with task
- * @param task the deferred execution which will be called
- */
-export function executeModule(
-    emitter: Emitter,
-    logger: Logging|undefined,
-    errHandler: ErrorHandling,
-    {
-        module,
-        task,
-        onError,
-        args
-    }: ExecutePayload,
-) {
-    const onError$ = (err_msg: unknown) => {
-        if(!onError) {
-            return throwError(() => SernEmitter.failure(module, err));
-        }
-        //Could be promise
-        const err = onError(err_msg) as CommandError.Response
-        if(!err) {
-            const failure = SernEmitter.failure(module, "onError: returned undefined/null");
-            return throwError(() => failure);
-        }
-        if(err.log) {
-           const { type, message } = err.log;
-           logger?.[type]({ message });
-        };
-        if(err.type === 'fail') {
 
-        } else {
-            
+
+function isObject(item: unknown) {
+    return (item && typeof item === 'object' && !Array.isArray(item));
+}
+
+//_module is frozen, preventing from mutations
+export async function callInitPlugins(_module: Module, deps: Dependencies, emit?: boolean) {
+    let module = _module;
+    const emitter = deps['@sern/emitter'];
+    for(const plugin of module.plugins ?? []) {
+        const result = await plugin.execute({ module, absPath: module.meta.absPath, deps });
+        if (!result) throw Error("Plugin did not return anything. " + inspect(plugin, false, Infinity, true));
+        if(!result.ok) {
+            if(emit) {
+                emitter?.emit('module.register',
+                              resultPayload('failure', module, result.error ?? SernError.PluginFailure));
+            }
+            throw Error((result.error ?? SernError.PluginFailure) +
+                        'on module ' + module.name + " " + module.meta.absPath);
         }
-        return EMPTY;
     }
-    return of(module).pipe(
-        //converting the task into a promise so rxjs can resolve the Awaitable properly
-        concatMap(() => Result.wrapAsync(async () => task())),
-        concatMap(result => {
-            if (result.isOk()) {
-                emitter.emit('module.activate', SernEmitter.success(module));
-                return EMPTY;
-            } 
-            return onError$(result.error);
-        }),
-    );
+    return module
 }
 
-/**
- * A higher order function that
- * - creates a stream of {@link VoidResult} { config.createStream }
- * - any failures results to { config.onFailure } being called
- * - if all results are ok, the stream is converted to { config.onNext }
- * emit config.onSuccess Observable
- * @param config
- * @returns receiver function for flattening a stream of data
- */
-export function createResultResolver<
-    T extends { execute: (...args: any[]) => any; onEvent: ControlPlugin[] },
-    Args extends { module: T; onError: unknown, [key: string]: unknown },
-    Output,
->(config: {
-    onStop?: (module: T) => unknown;
-    onNext: (args: Args) => Output;
-    createStream: (args: Args) => Observable<VoidResult>;
-}) {
-    return (args: Args) => {
-        const task$ = config.createStream(args);
-        return task$.pipe(
-            tap(result => {
-                result.isErr() && config.onStop?.(args.module);
-            }),
-            everyPluginOk,
-            filterMapTo(() => config.onNext(args)),
-        );
-    };
-}
+export function executeModule(emitter: Emitter, logger: Logging|undefined, { module, args } : ExecutePayload) {
+    
+    const moduleCalled = wrapAsync(async () => {
+        return module.execute(...args);
+    })
+    moduleCalled 
+        .then((res) => {
+            if(res.ok) {
+                emitter.emit('module.activate', resultPayload('success', module))    
+            } else {
+                if(!emitter.emit('error', resultPayload('failure', module, res.error))) {
+                    // node crashes here.
+                    logger?.error({ 'message': res.error })
+                }
+            }
+        })
+        .catch(err => { 
+            throw err 
+        })
+};
 
-/**
- * Calls a module's init plugins and checks for Err. If so, call { onStop } and
- * ignore the module
- */
-export function callInitPlugins<T extends Processed<AnyModule>>(sernEmitter: Emitter) {
-    return concatMap(
-        createResultResolver({
-            createStream: args => from(args.module.plugins).pipe(callPlugin(args)),
-            onStop: (module: T) => {
-                sernEmitter.emit(
-                    'module.register',
-                    SernEmitter.failure(module, SernError.PluginFailure),
-                );
-            },
-            onNext: ({ module, onError }) => {
-                sernEmitter.emit('module.register', SernEmitter.success(module));
-                return { module, onError: onError as OnError };
-            },
-        }),
-    );
-}
 
-/**
- * Creates an executable task ( execute the command ) if  all control plugins are successful
- * @param onStop emits a failure response to the SernEmitter
- */
-export function makeModuleExecutor<
-    M extends Processed<Module>,
-    Args extends { 
-        module: M;
-        args: unknown[];
-        onError: AnyFunction|undefined 
-    },
->(onStop: (m: M) => unknown) {
-    const onNext = ({ args, module, onError }: Args) => ({
-        task: () => module.execute(...args),
-        module,
-        onError,
-        args
-    });
-    return concatMap(
-        createResultResolver({
-            onStop,
-            createStream: ({ args, module }) => 
-                from(module.onEvent)
-                    .pipe(callPlugin(args)),
-            onNext,
-        }),
-    );
+export async function callPlugins({ args, module }: ExecutePayload) {
+    let state = {};
+    for(const plugin of module.onEvent??[]) {
+        const result = await plugin.execute(...args);
+        if(!result.ok) {
+            return result;
+        }
+        if(isObject(result.value)) {
+            state = merge(state, result.value!);
+        }
+    }
+    return Ok(state);
 }
-
-export const handleCrash = (err: ErrorHandling, log?: Logging) =>
-    pipe(
-        catchError(handleError(err, log)),
-        finalize(() => {
-            log?.info({
-                message: 'A stream closed or reached end of lifetime',
-            });
-            useContainerRaw()
-                ?.disposeAll()
-                .then(() => log?.info({ message: 'Cleaning container and crashing' }));
-        }),
-    );

src/handlers/interaction-event.ts

@@ -1,33 +0,0 @@
-import { Interaction } from 'discord.js';
-import { concatMap, merge } from 'rxjs';
-import { SernEmitter } from '../core';
-import {
-    isAutocomplete,
-    isCommand,
-    isMessageComponent,
-    isModal,
-    sharedEventStream,
-    SernError,
-    filterTap,
-} from '../core/_internal';
-import { createInteractionHandler, executeModule, makeModuleExecutor } from './_internal';
-import type { DependencyList } from '../types/ioc';
-
-export function interactionHandler([emitter, err, log, modules, client]: DependencyList) {
-    const interactionStream$ = sharedEventStream<Interaction>(client, 'interactionCreate');
-    const handle = createInteractionHandler(interactionStream$, modules);
-
-    const interactionHandler$ = merge(
-        handle(isMessageComponent),
-        handle(isAutocomplete),
-        handle(isCommand),
-        handle(isModal),
-    );
-    return interactionHandler$
-        .pipe(
-            filterTap(e => emitter.emit('warning', SernEmitter.warning(e))),
-            makeModuleExecutor(module => 
-                emitter.emit('module.activate', SernEmitter.failure(module, SernError.PluginFailure))),
-            concatMap(payload => executeModule(emitter, log, err, payload)),
-    );
-}

src/handlers/interaction.ts

@@ -0,0 +1,58 @@
+import type { Module } from '../types/core-modules'
+import {  callPlugins, executeModule } from './event-utils';
+import { SernError } from '../core/structures/enums'
+import { createSDT, isAutocomplete, isCommand, isMessageComponent, isModal, resultPayload, treeSearch } from '../core/functions'
+import type { UnpackedDependencies } from '../types/utility';
+import * as Id from '../core/id'
+import { Context } from '../core/structures/context';
+
+
+
+export function interactionHandler(deps: UnpackedDependencies, defaultPrefix?: string) {
+    //i wish javascript had clojure destructuring 
+    const { '@sern/client': client,
+            '@sern/modules': moduleManager,
+            '@sern/logger': log,
+            '@sern/emitter': reporter } = deps
+
+    client.on('interactionCreate', async (event) => {
+
+        //returns array of possible ids
+        const possibleIds = Id.reconstruct(event);
+
+        let modules = possibleIds
+            .map(({ id, params }) => ({ module: moduleManager.get(id)!, params }))
+            .filter(({ module }) => module !== undefined);
+
+        if(modules.length == 0) {
+            return;
+        }
+        const { module, params } = modules.at(0)!;
+        let payload;
+        if(isAutocomplete(event)) {
+            //@ts-ignore stfu
+            const { command } = treeSearch(event, module.options);
+            payload= { module: command as Module, //autocomplete is not a true "module" warning cast!
+                       args: [event, createSDT(command, deps, params)] };
+        } else if(isCommand(event)) {
+            payload= { module, args: [Context.wrap(event, defaultPrefix), createSDT(module, deps, params)] };
+        } else if (isModal(event) || isMessageComponent(event)) {
+            payload= { module, args: [event, createSDT(module, deps, params)] }
+        } else {
+            throw Error("Unknown interaction while handling in interactionCreate event " + event)
+        }
+        const result = await callPlugins(payload)
+        if(!result.ok) {
+            reporter.emit('module.activate', resultPayload('failure', module, result.error ?? SernError.PluginFailure))
+            return
+        }
+        if(payload.args.length !== 2) {
+            throw Error ('Invalid payload')
+        }
+        //@ts-ignore assigning final state from plugin
+        payload.args[1].state = result.value
+
+        // note: do not await this. will be blocking if long task (ie waiting for modal input)
+        executeModule(reporter, log, payload);
+    });
+}

src/handlers/message-event.ts

@@ -1,47 +0,0 @@
-import { concatMap, EMPTY } from 'rxjs';
-import type { Message } from 'discord.js';
-import { SernEmitter } from '../core';
-import { sharedEventStream, SernError, filterTap } from '../core/_internal';
-import { createMessageHandler, executeModule, makeModuleExecutor } from './_internal';
-import type { DependencyList } from '../types/ioc';
-
-/**
- * Ignores messages from any person / bot except itself
- * @param prefix
- */
-function isNonBot(prefix: string) {
-    return (msg: Message): msg is Message => !msg.author.bot && hasPrefix(prefix, msg.content);
-}
-
-function hasPrefix(prefix: string, content: string) {
-    const prefixInContent = content.slice(0, prefix.length);
-    return (
-        prefixInContent.localeCompare(prefix, undefined, {
-            sensitivity: 'accent',
-        }) === 0
-    );
-}
-
-export function messageHandler(
-    [emitter, err, log, modules, client]: DependencyList,
-    defaultPrefix: string | undefined,
-) {
-    if (!defaultPrefix) {
-        log?.debug({
-            message: 'No prefix found. message handler shutting down',
-        });
-        return EMPTY;
-    }
-    const messageStream$ = sharedEventStream<Message>(client, 'messageCreate');
-    const handle = createMessageHandler(messageStream$, defaultPrefix, modules);
-
-    const msgCommands$ = handle(isNonBot(defaultPrefix));
-
-    return msgCommands$.pipe(
-        filterTap((e) => emitter.emit('warning', SernEmitter.warning(e))),
-        makeModuleExecutor(module => {
-            emitter.emit('module.activate', SernEmitter.failure(module, SernError.PluginFailure));
-        }),
-        concatMap(payload => executeModule(emitter, log, err, payload)),
-    );
-}

src/handlers/message.ts

@@ -0,0 +1,54 @@
+import type { Message } from 'discord.js';
+import { callPlugins, executeModule } from './event-utils';
+import { SernError } from '../core/structures/enums'
+import { createSDT, fmt, resultPayload } from '../core/functions'
+import type { UnpackedDependencies } from '../types/utility';
+import type { Module } from '../types/core-modules';
+import { Context } from '../core/structures/context';
+
+/**
+ * Ignores messages from any person / bot except itself
+ * @param prefix
+ */
+function isBotOrNoPrefix(msg: Message, prefix: string) {
+    return msg.author.bot || !hasPrefix(prefix, msg.content);
+}
+
+function hasPrefix(prefix: string, content: string) {
+    const prefixInContent = content.slice(0, prefix.length);
+    return prefixInContent.localeCompare(prefix, undefined, { sensitivity: 'accent' }) === 0;
+}
+
+export function messageHandler (deps: UnpackedDependencies, defaultPrefix?: string) {
+    const {"@sern/emitter": emitter,  
+           '@sern/logger': log, 
+           '@sern/modules': mg,
+           '@sern/client': client} = deps
+
+    if (!defaultPrefix) {
+        log?.debug({ message: 'No prefix found. message handler shutting down' });
+        return;
+    }
+    client.on('messageCreate', async message => {
+        if(isBotOrNoPrefix(message, defaultPrefix)) {
+           return 
+        }
+        const [prefix] = fmt(message.content, defaultPrefix);
+        let module = mg.get(`${prefix}_T`) ?? mg.get(`${prefix}_B`) as Module;
+        if(!module) {
+            throw Error('Possibly undefined behavior: could not find a static id to resolve')
+        }
+        const payload = { module, args: [Context.wrap(message, defaultPrefix), createSDT(module, deps, undefined)] }
+        const result = await callPlugins(payload)
+        if (!result.ok) {
+            emitter.emit('module.activate', resultPayload('failure', module, result.error ?? SernError.PluginFailure))
+            return
+        }
+
+        //@ts-ignore
+        payload.args[1].state = result.value
+
+        executeModule(emitter, log, payload)
+    })
+    
+}

src/handlers/presence.ts

@@ -0,0 +1,99 @@
+import { Presence  } from "../core/presences";
+import { Services } from "../core/ioc";
+import * as Files from "../core/module-loading";
+type SetPresence = (conf: Presence.Result) => Promise<unknown>
+
+const parseConfig = async (conf: Promise<Presence.Result>, setPresence: SetPresence) => {
+    const result = await conf;
+    
+    if ('repeat' in result) {
+        const { onRepeat, repeat } = result;
+        // Validate configuration
+        if (repeat === undefined) {
+            throw new Error("repeat option is undefined");
+        }
+        if (onRepeat === undefined) {
+            throw new Error("onRepeat callback is undefined, but repeat exists");
+        }
+        // Initial state
+        let currentState = result;
+        const processState = async (state: typeof currentState) => {
+            try {
+                const result = onRepeat(state);
+                // If it's a promise, await it, otherwise use the value directly
+                return result instanceof Promise ? await result : result;
+            } catch (error) {
+                // TODO process error
+                //console.error(error);
+                return state; // Return previous state on error
+            }
+        };
+        // Handle numeric interval
+        if (typeof repeat === 'number') {
+            // Return a promise that never resolves (or resolves on cleanup)
+            return new Promise((resolve) => {
+                // Immediately return initial state
+                processState(currentState);
+                
+                // Set up interval
+                let isProcessing = false;
+                const intervalId = setInterval(() => {
+                    // Skip if previous operation is still running
+                    if (isProcessing) return;
+                    isProcessing = true;
+
+                    processState(currentState)
+                        .then(newState => { 
+                            currentState = newState; 
+                            return setPresence(currentState)
+                        })
+                        .catch(console.error)
+                        .finally(() => {
+                            isProcessing = false;
+                        });
+                }, repeat);
+
+                // Optional: Return cleanup function
+                return () => clearInterval(intervalId);
+            });
+        }
+        // Handle event-based repeat
+        else {
+            const handler = async () => {
+                currentState = await onRepeat(currentState);
+                await setPresence(currentState);
+            }; 
+            let has_registered = false;
+            return new Promise((resolve) => {
+                const [target, eventName] = repeat;
+                
+                // Immediately return initial state
+                processState(currentState);
+
+                // Set up event listener
+                if(!has_registered) {
+                    target.addListener(eventName, handler);
+                    has_registered=true;
+                }
+                // Optional: Return cleanup function
+                return () => target.removeListener(eventName, handler);
+            });
+        }
+    }
+    
+    // No repeat configuration, just return the result
+    return setPresence(result);
+};
+
+export const presenceHandler = async (path: string, setPresence: SetPresence) => {
+    const presence = await 
+        Files.importModule<Presence.Config<(keyof Dependencies)[]>>(path)
+             .then(({ module }) => {
+                //fetch services with the order preserved, passing it to the execute fn 
+                const fetchedServices = Services(...module.inject ?? []);
+                return async () => module.execute(...fetchedServices);
+             })
+     
+    return parseConfig(presence(), setPresence);
+       
+}

src/handlers/ready-event.ts

@@ -1,47 +0,0 @@
-import { ObservableInput, concat, first, fromEvent, ignoreElements, pipe } from 'rxjs';
-import { CommandType } from '../core/structures';
-import { SernError } from '../core/_internal';
-import { Result } from 'ts-results-es';
-import { ModuleManager } from '../core/contracts';
-import { buildModules, callInitPlugins } from './_internal';
-import * as assert from 'node:assert';
-import * as util from 'node:util';
-import type { DependencyList } from '../types/ioc';
-import type { AnyModule, Processed } from '../types/core-modules';
-
-export function startReadyEvent(
-    [sEmitter, , , moduleManager, client]: DependencyList,
-    allPaths: ObservableInput<string>,
-) {
-    const ready$ = fromEvent(client!, 'ready').pipe(once());
-
-    return concat(ready$, buildModules<AnyModule>(allPaths, moduleManager))
-        .pipe(callInitPlugins(sEmitter))
-        .subscribe(({ module }) => {
-            register(moduleManager, module)
-                .expect(SernError.InvalidModuleType + ' ' + util.inspect(module));
-        });
-}
-
-const once = () => pipe(
-    first(),
-    ignoreElements()
-)
-
-
-function register<T extends Processed<AnyModule>>(
-    manager: ModuleManager,
-    module: T,
-): Result<void, void> {
-    const { id, fullPath } = manager.getMetadata(module)!;
-
-    const validModuleType = module.type >= 0 && module.type <= 1 << 10;
-    assert.ok(
-        validModuleType,
-        `Found ${module.name} at ${fullPath}, which does not have a valid type`,
-    );
-    if (module.type === CommandType.Both || module.type === CommandType.Text) {
-        module.alias?.forEach(a => manager.set(`${a}_A1`, fullPath));
-    }
-    return Result.wrap(() => manager.set(id, fullPath));
-}

src/handlers/ready.ts

@@ -0,0 +1,32 @@
+import * as Files from '../core/module-loading'
+import { once } from 'node:events';
+import { resultPayload } from '../core/functions';
+import { CommandType } from '../core/structures/enums';
+import { Module } from '../types/core-modules';
+import type { UnpackedDependencies } from '../types/utility';
+import { callInitPlugins } from './event-utils';
+
+export default async function(dir: string, deps : UnpackedDependencies) {
+    const { '@sern/client': client,
+            '@sern/logger': log,
+            '@sern/emitter': sEmitter,
+            '@sern/modules': commands } = deps;
+    log?.info({ message: "Waiting on discord client to be ready..." })
+    await once(client, "ready");
+    log?.info({ message: "Client signaled ready, registering modules" });
+
+    // https://observablehq.com/@ehouais/multiple-promises-as-an-async-generator
+    // possibly optimize to concurrently import modules
+    for await (const path of Files.readRecursive(dir)) {
+        let { module } = await Files.importModule<Module>(path);
+        const validType = module.type >= CommandType.Text && module.type <= CommandType.ChannelSelect;
+        if(!validType) {
+            throw Error(`Found ${module.name} at ${module.meta.absPath}, which has incorrect \`type\``);
+        }
+        const resultModule = await callInitPlugins(module, deps, true);
+        // FREEZE! no more writing!!
+        commands.set(resultModule.meta.id, Object.freeze(resultModule));
+        sEmitter.emit('module.register', resultPayload('success', resultModule));
+    }
+    sEmitter.emit('modulesLoaded');
+}

src/handlers/tasks.ts

@@ -0,0 +1,16 @@
+import * as Files from '../core/module-loading'
+import { UnpackedDependencies } from "../types/utility";
+import type { ScheduledTask } from "../types/core-modules";
+import { relative } from "path";
+import { fileURLToPath } from "url";
+
+export const registerTasks = async (tasksPath: string, deps: UnpackedDependencies) => {
+    const taskManager = deps['@sern/scheduler']
+    for await (const f of Files.readRecursive(tasksPath)) {
+        let { module } = await Files.importModule<ScheduledTask>(f);
+        //module.name is assigned by Files.importModule<>
+        // the id created for the task is unique
+        const uuid = module.name+"/"+relative(tasksPath,fileURLToPath(f))
+        taskManager.schedule(uuid, module, deps)
+    }
+}

src/handlers/user-defined-events.ts

@@ -1,36 +1,57 @@
-import { ObservableInput, map, mergeAll } from 'rxjs';
-import { EventType } from '../core/structures';
-import { SernError } from '../core/_internal';
-import { buildModules, callInitPlugins, handleCrash, eventDispatcher } from './_internal';
-import { Service } from '../core/ioc';
-import type { DependencyList } from '../types/ioc';
-import type { EventModule, OnError, Processed } from '../types/core-modules';
+import { EventType,  SernError } from '../core/structures/enums';
+import { callInitPlugins } from './event-utils'
+import { EventModule,  Module  } from '../types/core-modules';
+import * as Files from '../core/module-loading'
+import type { UnpackedDependencies } from '../types/utility';
+import type { Emitter } from '../core/interfaces';
+import { inspect } from 'util'
+import { resultPayload } from '../core/functions';
+import type { Wrapper } from '../'
 
-export function eventsHandler(
-    [emitter, err, log, moduleManager, client]: DependencyList,
-    allPaths: ObservableInput<string>,
-) {
-    //code smell
-    const intoDispatcher = (e: { module: Processed<EventModule>, onError: OnError }) => {
-        switch (e.module.type) {
+export default async function(deps: UnpackedDependencies, wrapper: Wrapper) {
+    const eventModules: EventModule[] = [];
+    for await (const path of Files.readRecursive(wrapper.events!)) {
+        let { module } = await Files.importModule<Module>(path);
+        await callInitPlugins(module, deps)
+        eventModules.push(module as EventModule);
+    }
+    const logger = deps['@sern/logger'], report = deps['@sern/emitter'];
+    for (const module of eventModules) {
+        let source: Emitter;
+
+        switch (module.type) {
             case EventType.Sern:
-                return eventDispatcher(e.module, e.onError, emitter);
+                source=deps['@sern/emitter'];
+                break
             case EventType.Discord:
-                return eventDispatcher(e.module, e.onError, client);
+                source=deps['@sern/client'];
+                break
             case EventType.External:
-                return eventDispatcher(e.module, e.onError, Service(e.module.emitter));
-            default:
-                throw Error(SernError.InvalidModuleType + ' while creating event handler');
+                source=deps[module.emitter] as Emitter;
+                break   
+            default: throw Error(SernError.InvalidModuleType + ' while creating event handler');
         }
-    };
-    buildModules<EventModule>(allPaths, moduleManager)
-        .pipe(
-            callInitPlugins(emitter),
-            map(intoDispatcher),
-            /**
-             * Where all events are turned on
-             */
-            mergeAll(),
-            handleCrash(err, log))
-        .subscribe();
+        if(!source && typeof source !== 'object') {
+            throw Error(`${source} cannot be constructed into an event listener`)
+        }
+        
+        if(!('addListener' in source && 'removeListener' in source)) {
+            throw Error('source must implement Emitter')
+        }
+        const execute = async (...args: any[]) => {
+            try {
+                if(args) {
+                    if('once' in module) { source.removeListener(String(module.name!), execute); }
+                    await Reflect.apply(module.execute, null, args);
+                }
+            } catch(e) {
+                const err = e instanceof Error ? e : Error(inspect(e, { colors: true }));
+                if(!report.emit('error', resultPayload('failure', module, err))) {
+                    logger?.error({ message: inspect(err) });
+                }
+            }
+       }
+       source.addListener(String(module.name!), execute)
+    }
 }
+

src/index.ts

@@ -1,6 +1,7 @@
 export * as Sern from './sern';
-export * from './core';
+
 export type {
+    Module,
     CommandModule,
     EventModule,
     BothCommand,
@@ -24,33 +25,48 @@ export type {
     SernOptionsData,
     SernSubCommandData,
     SernSubCommandGroupData,
+    SDT,
+    ScheduledTask
 } from './types/core-modules';
 
 export type {
-    Controller,
     PluginResult,
     InitPlugin,
     ControlPlugin,
     Plugin,
-    AnyEventPlugin,
-    AnyCommandPlugin,
+    AnyPlugin,
 } from './types/core-plugin';
 
-export type { Wrapper } from './types/core';
 
-export type { Args, SlashOptions, Payload, SernEventsMapping } from './types/utility';
-
-export type { Singleton, Transient, CoreDependencies, Initializable } from './types/ioc';
+export type { Payload, SernEventsMapping, Wrapper } from './types/utility';
 
 export {
     commandModule,
     eventModule,
     discordEvent,
-    EventExecutable,
-    CommandExecutable,
+    scheduledTask
 } from './core/modules';
 
-export {
-    useContainerRaw
-} from './core/_internal'
-export { controller } from './sern';
+export * from './core/presences'
+export * from './core/interfaces'
+export * from './core/plugin';
+export { CommandType, PluginType, PayloadType, EventType } from './core/structures/enums';
+export { Context } from './core/structures/context';
+export { type CoreDependencies, makeDependencies, single, transient, Service, Services } from './core/ioc';
+
+
+import type { Container } from '@sern/ioc';
+
+/**
+  * @deprecated This old signature will be incompatible with future versions of sern >= 4.0.0. See {@link makeDependencies}
+  * @example
+  * ```ts
+  *  To switch your old code:
+     await makeDependencies(({ add }) => { 
+            add('@sern/client', new Client())
+     })
+  *  ```
+  */
+export interface DependencyConfiguration {
+    build: (root: Container) => Container;
+}

src/sern.ts

@@ -1,16 +1,24 @@
-import { handleCrash } from './handlers/_internal';
-import { err, ok, Files } from './core/_internal';
-import { merge } from 'rxjs';
-import { Services } from './core/ioc';
-import { Wrapper } from './types/core';
-import { eventsHandler } from './handlers/user-defined-events';
-import { startReadyEvent } from './handlers/ready-event';
-import { messageHandler } from './handlers/message-event';
-import { interactionHandler } from './handlers/interaction-event';
+//side effect: global container
+import { useContainerRaw } from '@sern/ioc/global';
+// set asynchronous capturing of errors
+import events from 'node:events'
+events.captureRejections = true;
+
+import callsites from 'callsites';
+import * as  Files from './core/module-loading';
+import eventsHandler from './handlers/user-defined-events';
+import ready  from './handlers/ready';
+import { interactionHandler } from './handlers/interaction';
+import { messageHandler } from './handlers/message'
+import { presenceHandler } from './handlers/presence';
+import { UnpackedDependencies, Wrapper } from './types/utility';
+import type { Presence} from './core/presences';
+import { registerTasks } from './handlers/tasks';
+
 
 /**
  * @since 1.0.0
- * @param wrapper Options to pass into sern.
+ * @param maybeWrapper Options to pass into sern.
  * Function to start the handler up
  * @example
  * ```ts title="src/index.ts"
@@ -21,46 +29,41 @@ import { interactionHandler } from './handlers/interaction-event';
  * ```
  */
 
-export function init(maybeWrapper: Wrapper | 'file') {
+export function init(maybeWrapper: Wrapper = { commands: "./dist/commands" }) {
     const startTime = performance.now();
-    const wrapper = Files.loadConfig(maybeWrapper);
-    const dependencies = useDependencies();
-    const logger = dependencies[2],
-        errorHandler = dependencies[1];
-
-    if (wrapper.events !== undefined) {
-        eventsHandler(dependencies, Files.getFullPathTree(wrapper.events));
+    const deps = useContainerRaw().deps<UnpackedDependencies>();
+    
+    if (maybeWrapper.events !== undefined) {
+        eventsHandler(deps, maybeWrapper)
+            .then(() => {
+                deps['@sern/logger']?.info({ message: "Events registered" });
+            });
+    } else {
+        deps['@sern/logger']?.info({ message: "No events registered" });
     }
+
+    const initCallsite = callsites()[1].getFileName();
+    const presencePath = Files.shouldHandle(initCallsite!, "presence");
     //Ready event: load all modules and when finished, time should be taken and logged
-    startReadyEvent(dependencies, Files.getFullPathTree(wrapper.commands)).add(() => {
-        const time = ((performance.now() - startTime) / 1000).toFixed(2);
-        dependencies[0].emit('modulesLoaded');
-        logger?.info({
-            message: `sern: registered all modules in ${time} s`,
-        });
-    });
+    ready(maybeWrapper.commands, deps)
+        .then(() => {
+            const time = ((performance.now() - startTime) / 1000).toFixed(2);
+            deps['@sern/logger']?.info({ message: `sern: registered in ${time} s` });
+            if(presencePath.exists) {
+                const setPresence = async (p: Presence.Result) => {
+                    return deps['@sern/client'].user?.setPresence(p);
+                }
+                presenceHandler(presencePath.path, setPresence);
+            }
+            if(maybeWrapper.tasks) {
+                registerTasks(maybeWrapper.tasks, deps);
+            }
+        })
+        .catch(err => { throw err });
 
-    const messages$ = messageHandler(dependencies, wrapper.defaultPrefix);
-    const interactions$ = interactionHandler(dependencies);
+    //const messages$ = messageHandler(deps, maybeWrapper.defaultPrefix);
+    interactionHandler(deps, maybeWrapper.defaultPrefix);
+    messageHandler(deps, maybeWrapper.defaultPrefix)
     // listening to the message stream and interaction stream
-    merge(messages$, interactions$).pipe(handleCrash(errorHandler, logger)).subscribe();
+    //merge(messages$, interactions$).subscribe();
 }
-
-function useDependencies() {
-    return Services(
-        '@sern/emitter',
-        '@sern/errors',
-        '@sern/logger',
-        '@sern/modules',
-        '@sern/client',
-    );
-}
-
-/**
- * @since 1.0.0
- * The object passed into every plugin to control a command's behavior
- */
-export const controller = {
-    next: ok,
-    stop: err,
-};

src/types/core-modules.ts

@@ -14,19 +14,103 @@ import type {
     StringSelectMenuInteraction,
     UserContextMenuCommandInteraction,
     UserSelectMenuInteraction,
+    ChatInputCommandInteraction,
 } from 'discord.js';
-import { CommandType, Context, EventType } from '../../src/core';
-import { AnyCommandPlugin, AnyEventPlugin, ControlPlugin, InitPlugin } from './core-plugin';
-import { Awaitable, Args, SlashOptions, SernEventsMapping, AnyFunction } from './utility';
+import type { CommandType, EventType } from '../core/structures/enums';
+import { Context } from '../core/structures/context'
+import { ControlPlugin, InitPlugin, Plugin } from './core-plugin';
+import { Awaitable, SernEventsMapping, UnpackedDependencies, Dictionary } from './utility';
 
-export type OnError = AnyFunction|undefined
+/**
+ * SDT (State, Dependencies, Type) interface represents the core data structure
+ * passed through the plugin pipeline to command modules.
+ * 
+ * @interface SDT
+ * @template TState - Type parameter for the state object's structure
+ * @template TDeps - Type parameter for dependencies interface
+ * 
+ * @property {Record<string, unknown>} state - Accumulated state data passed between plugins
+ * @property {TDeps} deps - Instance of application dependencies
+ * @property {CommandType} type - Command type identifier
+ * @property {string} [params] - Optional parameters passed to the command
+ * 
+ * @example
+ * // Example of a plugin using SDT
+ * const loggingPlugin = CommandControlPlugin((ctx, sdt: SDT) => {
+ *     console.log(`User ${ctx.user.id} executed command`);
+ *     return controller.next({ 'logging/timestamp': Date.now() });
+ * });
+ * 
+ * @example
+ * // Example of state accumulation through multiple plugins
+ * const plugin1 = CommandControlPlugin((ctx, sdt: SDT) => {
+ *     return controller.next({ 'plugin1/data': 'value1' });
+ * });
+ * 
+ * const plugin2 = CommandControlPlugin((ctx, sdt: SDT) => {
+ *     // Access previous state
+ *     const prevData = sdt.state['plugin1/data'];
+ *     return controller.next({ 'plugin2/data': 'value2' });
+ * });
+ * 
+ * @remarks
+ * - State is immutable and accumulated through the plugin chain
+ * - Keys in state should be namespaced to avoid collisions
+ * - Dependencies are injected and available throughout the pipeline
+ * - Type information helps plugins make type-safe decisions
+ * 
+ * @see {@link CommandControlPlugin} for plugin implementation
+ * @see {@link CommandType} for available command types
+ * @see {@link Dependencies} for dependency injection interface
+ */
+export type SDT = {
+    /**
+     * Accumulated state passed between plugins in the pipeline.
+     * Each plugin can add to or modify this state using controller.next().
+     * 
+     * @type {Record<string, unknown>}
+     * @example
+     * // Good: Namespaced state key
+     * { 'myPlugin/userData': { id: '123', name: 'User' } }
+     * 
+     * // Avoid: Non-namespaced keys that might collide
+     * { userData: { id: '123' } }
+     */
+    state: Record<string, unknown>;
 
+    /**
+     * Application dependencies available to plugins and command modules.
+     * Typically includes services, configurations, and utilities.
+     * 
+     * @type {Dependencies}
+     */
+    deps: Dependencies;
 
-export interface CommandMeta {
-    fullPath: string;
-    id: string;
-    isClass: boolean;
-}
+    /**
+     * Identifies the type of command being processed.
+     * Used by plugins to apply type-specific logic.
+     * 
+     * @type {CommandType}
+     */
+    type: CommandType;
+
+    /**
+     * Optional parameters passed to the command.
+     * May contain additional configuration or runtime data.
+     * 
+     * @type {string}
+     * @optional
+     */
+    params?: string;
+
+    /**
+     * A copy of the current module that the plugin is running in.
+     */
+    module: { name: string; 
+                  description: string;
+                  meta: Dictionary; 
+                  locals: Dictionary; }
+};
 
 export type Processed<T> = T & { name: string; description: string };
 
@@ -36,6 +120,79 @@ export interface Module {
     onEvent: ControlPlugin[];
     plugins: InitPlugin[];
     description?: string;
+    meta: {
+        id: string;
+        absPath: string;
+    }
+
+    /**
+     * Custom data storage object for module-specific information.
+     * Plugins and module code can use this to store and retrieve metadata,
+     * configuration, or any other module-specific information.
+     * 
+     * @type {Dictionary}
+     * @description A key-value store that allows plugins and module code to persist
+     * data at the module level. This is especially useful for InitPlugins that need
+     * to attach metadata or configuration to modules.
+     * 
+     * @example
+     * // In a plugin
+     * module.locals.registrationDate = Date.now();
+     * module.locals.version = "1.0.0";
+     * module.locals.permissions = ["ADMIN", "MODERATE"];
+     * 
+     * @example
+     * // In module execution
+     * console.log(`Command registered on: ${new Date(module.locals.registrationDate)}`);
+     * 
+     * @example
+     * // Storing localization data
+     * module.locals.translations = {
+     *   en: "Hello",
+     *   es: "Hola",
+     *   fr: "Bonjour"
+     * };
+     * 
+     * @example
+     * // Storing command metadata
+     * module.locals.metadata = {
+     *   category: "admin",
+     *   cooldown: 5000,
+     *   requiresPermissions: true
+     * };
+     * 
+     * @remarks
+     * - The locals object is initialized as an empty object ({}) by default
+     * - Keys should be namespaced to avoid collisions between plugins
+     * - Values can be of any type
+     * - Data persists for the lifetime of the module
+     * - Commonly used by InitPlugins during module initialization
+     * 
+     * @best-practices
+     * 1. Namespace your keys to avoid conflicts:
+     *    ```typescript
+     *    module.locals['myPlugin:data'] = value;
+     *    ```
+     * 
+     * 2. Document the data structure you're storing:
+     *    ```typescript
+     *    interface MyPluginData {
+     *      version: string;
+     *      timestamp: number;
+     *    }
+     *    module.locals['myPlugin:data'] = {
+     *      version: '1.0.0',
+     *      timestamp: Date.now()
+     *    } as MyPluginData;
+     *    ```
+     * 
+     * 3. Use type-safe accessors when possible:
+     *    ```typescript
+     *    const getPluginData = (module: Module): MyPluginData => 
+     *      module.locals['myPlugin:data'];
+     *    ```
+     */
+    locals: Dictionary;
     execute(...args: any[]): Awaitable<any>;
 }
 
@@ -45,6 +202,7 @@ export interface SernEventCommand<T extends keyof SernEventsMapping = keyof Sern
     type: EventType.Sern;
     execute(...args: SernEventsMapping[T]): Awaitable<unknown>;
 }
+
 export interface ExternalEventCommand extends Module {
     name?: string;
     emitter: keyof Dependencies;
@@ -52,55 +210,55 @@ export interface ExternalEventCommand extends Module {
     execute(...args: unknown[]): Awaitable<unknown>;
 }
 
+
 export interface ContextMenuUser extends Module {
     type: CommandType.CtxUser;
-    execute: (ctx: UserContextMenuCommandInteraction) => Awaitable<unknown>;
+    execute: (ctx: UserContextMenuCommandInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface ContextMenuMsg extends Module {
     type: CommandType.CtxMsg;
-    execute: (ctx: MessageContextMenuCommandInteraction) => Awaitable<unknown>;
+    execute: (ctx: MessageContextMenuCommandInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface ButtonCommand extends Module {
     type: CommandType.Button;
-    execute: (ctx: ButtonInteraction) => Awaitable<unknown>;
+    execute: (ctx: ButtonInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface StringSelectCommand extends Module {
     type: CommandType.StringSelect;
-    execute: (ctx: StringSelectMenuInteraction) => Awaitable<unknown>;
+    execute: (ctx: StringSelectMenuInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface ChannelSelectCommand extends Module {
     type: CommandType.ChannelSelect;
-    execute: (ctx: ChannelSelectMenuInteraction) => Awaitable<unknown>;
+    execute: (ctx: ChannelSelectMenuInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface RoleSelectCommand extends Module {
     type: CommandType.RoleSelect;
-    execute: (ctx: RoleSelectMenuInteraction) => Awaitable<unknown>;
+    execute: (ctx: RoleSelectMenuInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface MentionableSelectCommand extends Module {
     type: CommandType.MentionableSelect;
-    execute: (ctx: MentionableSelectMenuInteraction) => Awaitable<unknown>;
+    execute: (ctx: MentionableSelectMenuInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface UserSelectCommand extends Module {
     type: CommandType.UserSelect;
-    execute: (ctx: UserSelectMenuInteraction) => Awaitable<unknown>;
+    execute: (ctx: UserSelectMenuInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface ModalSubmitCommand extends Module {
     type: CommandType.Modal;
-    execute: (ctx: ModalSubmitInteraction) => Awaitable<unknown>;
+    execute: (ctx: ModalSubmitInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
-export interface AutocompleteCommand
-    extends Omit<Module, 'name' | 'type' | 'plugins' | 'description'> {
-    onEvent: ControlPlugin[];
-    execute: (ctx: AutocompleteInteraction) => Awaitable<unknown>;
+export interface AutocompleteCommand {
+    onEvent?: ControlPlugin[];
+    execute: (ctx: AutocompleteInteraction, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface DiscordEventCommand<T extends keyof ClientEvents = keyof ClientEvents>
@@ -111,26 +269,24 @@ export interface DiscordEventCommand<T extends keyof ClientEvents = keyof Client
 }
 export interface TextCommand extends Module {
     type: CommandType.Text;
-    alias?: string[];
-    execute: (ctx: Context, args: ['text', string[]]) => Awaitable<unknown>;
+    execute: (ctx: Context & { get options(): string[] }, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface SlashCommand extends Module {
     type: CommandType.Slash;
     description: string;
     options?: SernOptionsData[];
-    execute: (ctx: Context, args: ['slash', SlashOptions]) => Awaitable<unknown>;
+    execute: (ctx: Context  & { get options(): ChatInputCommandInteraction['options']}, tbd: SDT) => Awaitable<unknown>;
 }
 
 export interface BothCommand extends Module {
     type: CommandType.Both;
-    alias?: string[];
     description: string;
     options?: SernOptionsData[];
-    execute: (ctx: Context, args: Args) => Awaitable<unknown>;
+    execute: (ctx: Context, tbd: SDT) => Awaitable<unknown>;
 }
 
-export type EventModule = DiscordEventCommand | SernEventCommand | ExternalEventCommand;
+export type EventModule = DiscordEventCommand | SernEventCommand | ExternalEventCommand;  
 export type CommandModule =
     | TextCommand
     | SlashCommand
@@ -145,7 +301,6 @@ export type CommandModule =
     | RoleSelectCommand
     | ModalSubmitCommand;
 
-export type AnyModule = CommandModule | EventModule;
 //https://stackoverflow.com/questions/64092736/alternative-to-switch-statement-for-typescript-discriminated-union
 // Explicit Module Definitions for mapping
 export interface CommandModuleDefs {
@@ -163,9 +318,9 @@ export interface CommandModuleDefs {
     [CommandType.Modal]: ModalSubmitCommand;
 }
 
-export interface EventModuleDefs {
+export interface EventModuleDefs<T extends keyof ClientEvents = keyof ClientEvents> {
     [EventType.Sern]: SernEventCommand;
-    [EventType.Discord]: DiscordEventCommand;
+    [EventType.Discord]: DiscordEventCommand<T>;
     [EventType.External]: ExternalEventCommand;
 }
 
@@ -180,19 +335,22 @@ export interface SernAutocompleteData
 }
 
 type CommandModuleNoPlugins = {
-    [T in CommandType]: Omit<CommandModuleDefs[T], 'plugins' | 'onEvent'>;
+    [T in CommandType]: Omit<CommandModuleDefs[T], 'plugins' | 'onEvent' | 'meta' | 'locals'>;
 };
-type EventModulesNoPlugins = {
-    [T in EventType]: Omit<EventModuleDefs[T], 'plugins' | 'onEvent'>;
+type EventModulesNoPlugins<K extends keyof ClientEvents = keyof ClientEvents> = {
+    [T in EventType]: Omit<EventModuleDefs<K>[T], 'plugins' | 'onEvent' | 'meta' | 'locals'> ;
 };
 
-export type InputEvent = {
-    [T in EventType]: EventModulesNoPlugins[T] & { plugins?: AnyEventPlugin[] };
+export type InputEvent<K extends keyof ClientEvents = keyof ClientEvents> = {
+    [T in EventType]: EventModulesNoPlugins<K>[T] & {
+        once?: boolean;
+        plugins?: InitPlugin[] 
+    };
 }[EventType];
 
 export type InputCommand = {
     [T in CommandType]: CommandModuleNoPlugins[T] & {
-        plugins?: AnyCommandPlugin[];
+        plugins?: Plugin[];
     };
 }[CommandType];
 
@@ -215,3 +373,37 @@ export interface SernSubCommandGroupData extends BaseApplicationCommandOptionsDa
     type: ApplicationCommandOptionType.SubcommandGroup;
     options?: SernSubCommandData[];
 }
+
+
+export interface ScheduledTaskContext {
+     
+    /**
+     * the uuid of the current task being run
+     */
+    id: string;
+    /**
+     * the last time this task was executed. If this is the first time, it is null.
+     */
+    lastTimeExecution: Date | null;
+    /**
+      * The next time this task will be executed.
+      */
+    nextTimeExecution: Date | null;
+}
+
+//name subject to change
+interface TaskAttrs {
+    /**
+     * An object of dependencies configured in `makeDependencies`
+     */
+    deps: UnpackedDependencies
+}
+
+export interface ScheduledTask {
+    name?: string;
+    trigger: string | Date;
+    timezone?: string;
+    execute(tasks: ScheduledTaskContext, sdt: TaskAttrs): Awaitable<void>
+}
+
+

src/types/core-plugin.ts

@@ -11,34 +11,18 @@
  * Plugins are reminiscent of middleware in express.
  */
 
-import type { Err, Ok, Result } from 'ts-results-es';
 import type {
-    BothCommand,
-    ButtonCommand,
-    ChannelSelectCommand,
-    CommandModule,
-    ContextMenuMsg,
-    ContextMenuUser,
-    DiscordEventCommand,
-    EventModule,
-    ExternalEventCommand,
-    MentionableSelectCommand,
-    ModalSubmitCommand,
     Module,
     Processed,
-    RoleSelectCommand,
-    SernEventCommand,
-    SlashCommand,
-    StringSelectCommand,
-    TextCommand,
-    UserSelectCommand,
+    SDT,
 } from './core-modules';
-import { Args, Awaitable, Payload, SlashOptions } from './utility';
-import { CommandType, Context, EventType, PluginType } from '../core';
-import {
+import type { Awaitable } from './utility';
+import type { CommandType, PluginType } from '../core/structures/enums'
+import type { Context } from '../core/structures/context'
+import type {
     ButtonInteraction,
     ChannelSelectMenuInteraction,
-    ClientEvents,
+    ChatInputCommandInteraction,
     MentionableSelectMenuInteraction,
     MessageContextMenuCommandInteraction,
     ModalSubmitInteraction,
@@ -47,107 +31,42 @@ import {
     UserContextMenuCommandInteraction,
     UserSelectMenuInteraction,
 } from 'discord.js';
+import { Result } from '../core/structures/result';
 
-export type PluginResult = Awaitable<VoidResult>;
-export type VoidResult = Result<void, void>;
-
-export interface InitArgs<T extends Processed<Module>> {
+export type PluginResult = Awaitable<Result<Record<string,unknown>|undefined, string|undefined>>;
+export interface InitArgs<T extends Processed<Module> = Processed<Module>> {
     module: T;
     absPath: string;
-}
-export interface Controller {
-    next: () => Ok<void>;
-    stop: () => Err<void>;
+    deps: Dependencies
 }
 export interface Plugin<Args extends any[] = any[]> {
     type: PluginType;
     execute: (...args: Args) => PluginResult;
 }
 
-export interface InitPlugin<Args extends any[] = any[]> {
+export interface InitPlugin<Args extends any[] = any[]> extends Plugin<Args> {
     type: PluginType.Init;
     execute: (...args: Args) => PluginResult;
 }
-export interface ControlPlugin<Args extends any[] = any[]> {
+export interface ControlPlugin<Args extends any[] = any[]> extends Plugin<Args> {
     type: PluginType.Control;
-    execute: (...args: Args) => PluginResult;
 }
 
-export type AnyCommandPlugin = ControlPlugin | InitPlugin<[InitArgs<Processed<CommandModule>>]>;
-export type AnyEventPlugin = ControlPlugin | InitPlugin<[InitArgs<Processed<EventModule>>]>;
+export type AnyPlugin = ControlPlugin | InitPlugin<[InitArgs<Processed<Module>>]>;
 
-export type CommandArgs<
-    I extends CommandType = CommandType,
-    J extends PluginType = PluginType,
-> = CommandArgsMatrix[I][J];
-
-export type EventArgs<
-    I extends EventType = EventType,
-    J extends PluginType = PluginType,
-> = EventArgsMatrix[I][J];
+export type CommandArgs<I extends CommandType = CommandType> = CommandArgsMatrix[I]
 
 interface CommandArgsMatrix {
-    [CommandType.Text]: {
-        [PluginType.Control]: [Context, ['text', string[]]];
-        [PluginType.Init]: [InitArgs<Processed<TextCommand>>];
-    };
-    [CommandType.Slash]: {
-        [PluginType.Control]: [Context, ['slash', /* library coupled */ SlashOptions]];
-        [PluginType.Init]: [InitArgs<Processed<SlashCommand>>];
-    };
-    [CommandType.Both]: {
-        [PluginType.Control]: [Context, Args];
-        [PluginType.Init]: [InitArgs<Processed<BothCommand>>];
-    };
-    [CommandType.CtxMsg]: {
-        [PluginType.Control]: [/* library coupled */ MessageContextMenuCommandInteraction];
-        [PluginType.Init]: [InitArgs<Processed<ContextMenuMsg>>];
-    };
-    [CommandType.CtxUser]: {
-        [PluginType.Control]: [/* library coupled */ UserContextMenuCommandInteraction];
-        [PluginType.Init]: [InitArgs<Processed<ContextMenuUser>>];
-    };
-    [CommandType.Button]: {
-        [PluginType.Control]: [/* library coupled */ ButtonInteraction];
-        [PluginType.Init]: [InitArgs<Processed<ButtonCommand>>];
-    };
-    [CommandType.StringSelect]: {
-        [PluginType.Control]: [/* library coupled */ StringSelectMenuInteraction];
-        [PluginType.Init]: [InitArgs<Processed<StringSelectCommand>>];
-    };
-    [CommandType.RoleSelect]: {
-        [PluginType.Control]: [/* library coupled */ RoleSelectMenuInteraction];
-        [PluginType.Init]: [InitArgs<Processed<RoleSelectCommand>>];
-    };
-    [CommandType.ChannelSelect]: {
-        [PluginType.Control]: [/* library coupled */ ChannelSelectMenuInteraction];
-        [PluginType.Init]: [InitArgs<Processed<ChannelSelectCommand>>];
-    };
-    [CommandType.MentionableSelect]: {
-        [PluginType.Control]: [/* library coupled */ MentionableSelectMenuInteraction];
-        [PluginType.Init]: [InitArgs<Processed<MentionableSelectCommand>>];
-    };
-    [CommandType.UserSelect]: {
-        [PluginType.Control]: [/* library coupled */ UserSelectMenuInteraction];
-        [PluginType.Init]: [InitArgs<Processed<UserSelectCommand>>];
-    };
-    [CommandType.Modal]: {
-        [PluginType.Control]: [/* library coupled */ ModalSubmitInteraction];
-        [PluginType.Init]: [InitArgs<Processed<ModalSubmitCommand>>];
-    };
-}
-
-interface EventArgsMatrix {
-    [EventType.Discord]: {
-        [PluginType.Control]: /* library coupled */ ClientEvents[keyof ClientEvents];
-        [PluginType.Init]: [InitArgs<Processed<DiscordEventCommand>>];
-    };
-    [EventType.Sern]: {
-        [PluginType.Control]: [Payload];
-        [PluginType.Init]: [InitArgs<Processed<SernEventCommand>>];
-    };
-    [EventType.External]: {
-        [PluginType.Control]: unknown[];
-        [PluginType.Init]: [InitArgs<Processed<ExternalEventCommand>>];
-    };
+    [CommandType.Text]: [Context & { get options(): string[]}, SDT];
+    [CommandType.Slash]: [Context  & { get options(): ChatInputCommandInteraction['options']}, SDT];
+    [CommandType.Both]: [Context, SDT];
+    [CommandType.CtxMsg]: [MessageContextMenuCommandInteraction, SDT];
+    [CommandType.CtxUser]: [UserContextMenuCommandInteraction, SDT];
+    [CommandType.Button]: [ButtonInteraction, SDT];
+    [CommandType.StringSelect]: [StringSelectMenuInteraction, SDT];
+    [CommandType.RoleSelect]: [RoleSelectMenuInteraction, SDT];
+    [CommandType.ChannelSelect]: [ChannelSelectMenuInteraction, SDT];
+    [CommandType.MentionableSelect]: [MentionableSelectMenuInteraction, SDT];
+    [CommandType.UserSelect]: [UserSelectMenuInteraction, SDT];
+    [CommandType.Modal]: [ModalSubmitInteraction, SDT];
 }

src/types/core.ts

@@ -1,25 +0,0 @@
-import { OnError } from "./core-modules";
-
-export interface ImportPayload<T> {
-    module: T;
-    absPath: string;
-    onError:  OnError
-    [key: string]: unknown;
-}
-
-export interface Wrapper {
-    commands: string;
-    defaultPrefix?: string;
-    events?: string;
-    /**
-     * Overload to enable mode in case developer does not use a .env file.
-     * @deprecated - https://github.com/sern-handler/handler/pull/325
-     */
-    mode?: string
-    /*
-     * @deprecated
-     */
-    containerConfig?: {
-        get: (...keys: (keyof Dependencies)[]) => unknown[];
-    };
-}

src/types/dependencies.d.ts

@@ -4,9 +4,24 @@
 
 /* eslint-disable @typescript-eslint/consistent-type-imports */
 
-import { CoreDependencies } from './ioc';
+import { CoreDependencies } from '../core/ioc';
 
 declare global {
+   /**
+      * discord.js client. 
+      *   '@sern/client':  Client
+      * sern emitter listens to events that happen throughout
+      * the handler. some include module.register, module.activate.
+      *   '@sern/emitter': Contracts.Emitter;
+      * An error handler which is the final step before 
+      * the sern process actually crashes.
+         '@sern/errors':  Contracts.ErrorHandling;
+      * Optional logger. Performs ... logging
+      *  '@sern/logger'?: Contracts.Logging;
+      * Readonly module store. sern stores these 
+      * by module.meta.id -> Module
+      *  '@sern/modules': Map<string, Module>;
+      */
     interface Dependencies extends CoreDependencies {}
-
 }
+

src/types/ioc.ts

@@ -1,48 +0,0 @@
-import { Container, UnpackFunction } from 'iti';
-import * as Contracts from '../core/contracts';
-/**
-  * Type to annotate that something is a singleton. 
-  * T is created once and lazily.
-  */
-export type Singleton<T> = () => T;
-/**
-  * Type to annotate that something is transient. 
-  * Every time this is called, a new object is created
-  */
-export type Transient<T> = () => () => T;
-/**
-  * Type to annotate that something is initializable. 
-  * If T has an init method, this will be called.
-  */
-export type Initializable<T extends Contracts.Init> = T
-
-export type DependencyList = [
-    Contracts.Emitter,
-    Contracts.ErrorHandling,
-    Contracts.Logging | undefined,
-    Contracts.ModuleManager,
-    Contracts.Emitter,
-];
-
-export interface CoreDependencies {
-    '@sern/client': () => Contracts.Emitter;
-    '@sern/logger'?: () => Contracts.Logging;
-    '@sern/emitter': () => Contracts.Emitter;
-    '@sern/store': () => Contracts.CoreModuleStore;
-    '@sern/modules': () => Contracts.ModuleManager;
-    '@sern/errors': () => Contracts.ErrorHandling;
-}
-
-export type DependencyFromKey<T extends keyof Dependencies> = Dependencies[T];
-
-export type IntoDependencies<Tuple extends [...any[]]> = {
-    [Index in keyof Tuple]: UnpackFunction<NonNullable<DependencyFromKey<Tuple[Index]>>>; //Unpack and make NonNullable
-} & { length: Tuple['length'] };
-
-export interface DependencyConfiguration {
-    //@deprecated. Loggers will always be included in the future
-    exclude?: Set<'@sern/logger'>;
-    build: (
-        root: Container<Omit<CoreDependencies, '@sern/client'>, {}>,
-    ) => Container<Dependencies, {}>;
-}

src/types/utility.ts

@@ -1,33 +1,34 @@
-import type { CommandInteractionOptionResolver, InteractionReplyOptions, MessageReplyOptions } from 'discord.js';
-import type { PayloadType } from '../core';
-import type { AnyModule } from './core-modules';
+import type { InteractionReplyOptions, MessageReplyOptions } from 'discord.js';
+import type { Module } from './core-modules';
 
 export type Awaitable<T> = PromiseLike<T> | T;
+export type Dictionary = Record<string, unknown>
 
-export type AnyFunction = (...args: unknown[]) => unknown;
-
-// Thanks to @kelsny
-type ParseType<T> = {
-    [K in keyof T]: T[K] extends unknown ? [k: K, args: T[K]] : never;
-}[keyof T];
-
-export type SlashOptions = Omit<CommandInteractionOptionResolver, 'getMessage' | 'getFocused'>;
-
-export type Args = ParseType<{ text: string[]; slash: SlashOptions }>;
+export type AnyFunction = (...args: any[]) => unknown;
 
 export interface SernEventsMapping {
     'module.register': [Payload];
     'module.activate': [Payload];
-    error: [Payload];
+    error: [{ type: 'failure'; module?: Module; reason: string | Error }];
     warning: [Payload];
     modulesLoaded: [never?];
 }
 
 export type Payload =
-    | { type: PayloadType.Success; module: AnyModule }
-    | { type: PayloadType.Failure; module?: AnyModule; reason: string | Error }
-    | { type: PayloadType.Warning; reason: string };
-
-
+    | { type: 'success'; module: Module }
+    | { type: 'failure'; module?: Module; reason: string | Error }
+    | { type: 'warning'; module: undefined; reason: string };
 
+export type UnpackFunction<T> = T extends (...args: any) => infer U ? U : T
+export type UnpackedDependencies = {
+    [K in keyof Dependencies]: UnpackFunction<Dependencies[K]>
+}
 export type ReplyOptions = string | Omit<InteractionReplyOptions, 'fetchReply'> | MessageReplyOptions;
+
+
+export interface Wrapper {
+    commands: string;
+    defaultPrefix?: string;
+    events?: string;
+    tasks?: string;
+}

test/core/contracts.test.ts

@@ -1,16 +1,11 @@
 import { assertType, describe, it } from 'vitest';
 
-import { ModuleStore } from '../../src';
-import * as DefaultContracts from '../../src/core/structures/services';
-import * as Contracts from '../../src/core/contracts/index.js';
+import * as  __Services  from '../../src/core/structures/default-services';
+import * as Contracts from '../../src/core/interfaces';
 
 describe('default contracts', () => {
     it('should satisfy contracts', () => {
-        assertType<Contracts.Logging>(new DefaultContracts.DefaultLogging());
-        assertType<Contracts.ErrorHandling>(new DefaultContracts.DefaultErrorHandling());
-        assertType<Contracts.ModuleManager>(
-            new DefaultContracts.DefaultModuleManager(new ModuleStore()),
-        );
-        assertType<Contracts.CoreModuleStore>(new ModuleStore());
+        assertType<Contracts.Logging>(new __Services.DefaultLogging());
+        assertType<Contracts.ErrorHandling>(new __Services.DefaultErrorHandling());
     });
 });

test/core/create-plugin.test.ts

@@ -2,17 +2,12 @@ import { describe, it, expect } from 'vitest';
 import {
     CommandControlPlugin,
     CommandInitPlugin,
-    EventControlPlugin,
     EventInitPlugin,
-} from '../../src/core/create-plugins';
+} from '../../src';
 import { PluginType, controller } from '../../src';
 
 describe('create-plugins', () => {
     it('should make proper control plugins', () => {
-        const pl = EventControlPlugin(() => controller.next());
-        expect(pl).to.have.all.keys(['type', 'execute']);
-        expect(pl.type).toBe(PluginType.Control);
-        expect(pl.execute).an('function');
         const pl2 = CommandControlPlugin(() => controller.next());
         expect(pl2).to.have.all.keys(['type', 'execute']);
         expect(pl2.type).toBe(PluginType.Control);

test/core/functions.test.ts

@@ -1,76 +1,11 @@
+//@ts-nocheck
+
 import { afterEach, describe, expect, it, vi } from 'vitest';
 import { PluginType, SernOptionsData, controller } from '../../src/index';
 import { partitionPlugins, treeSearch } from '../../src/core/functions';
 import { faker } from '@faker-js/faker';
 import { ApplicationCommandOptionType, AutocompleteInteraction } from 'discord.js';
 
-vi.mock('discord.js', () => {
-    const Collection = Map;
-    const ModalSubmitInteraction = class {
-        customId;
-        type = 5;
-        isModalSubmit = vi.fn();
-        constructor(customId) {
-            this.customId = customId;
-        }
-    };
-    const ButtonInteraction = class {
-        customId;
-        type = 3;
-        componentType = 2;
-        isButton = vi.fn();
-        constructor(customId) {
-            this.customId = customId;
-        }
-    };
-    const AutocompleteInteraction = class {
-        type = 4;
-        option: string;
-        constructor(s: string) {
-            this.option = s;
-        }
-        options = {
-            getFocused: vi.fn(),
-            getSubcommand: vi.fn(),
-        };
-    };
-
-    return {
-        Collection,
-        ComponentType: {
-            Button: 2,
-        },
-        InteractionType: {
-            Ping: 1,
-            ApplicationCommand: 2,
-            MessageComponent: 3,
-            ApplicationCommandAutocomplete: 4,
-            ModalSubmit: 5,
-        },
-        ApplicationCommandOptionType: {
-            Subcommand: 1,
-            SubcommandGroup: 2,
-            String: 3,
-            Integer: 4,
-            Boolean: 5,
-            User: 6,
-            Channel: 7,
-            Role: 8,
-            Mentionable: 9,
-            Number: 10,
-            Attachment: 11,
-        },
-        ApplicationCommandType: {
-            ChatInput: 1,
-            User: 2,
-            Message: 3,
-        },
-        ModalSubmitInteraction,
-        ButtonInteraction,
-        AutocompleteInteraction,
-    };
-});
-
 describe('functions', () => {
     afterEach(() => {
         vi.clearAllMocks();

test/core/id.test.ts

@@ -0,0 +1,94 @@
+//@ts-nocheck
+import { expect, test, vi } from 'vitest'
+import { CommandType } from '../../src/core/structures/enums';
+
+import * as Id from '../../src/core/id'
+import { ButtonInteraction, ModalSubmitInteraction } from 'discord.js';
+
+test('id -> Text', () => {
+    expect(Id.create("ping", CommandType.Text)).toBe("ping_T")
+})
+
+test('id -> Both', () => {
+    expect(Id.create("ping", CommandType.Both)).toBe("ping_B")
+})
+
+test('id -> CtxMsg', () => {
+    expect(Id.create("ping", CommandType.CtxMsg)).toBe("ping_A3")
+})
+test('id -> CtxUsr', () => {
+    expect(Id.create("ping", CommandType.CtxUser)).toBe("ping_A2")
+})
+test('id -> Modal', () => {
+    expect(Id.create("my-modal", CommandType.Modal)).toBe("my-modal_M");
+})
+
+test('id -> Button', () => {
+    expect(Id.create("my-button", CommandType.Button)).toBe("my-button_C2");
+})
+
+test('id -> Slash', () => {
+    expect(Id.create("myslash", CommandType.Slash)).toBe("myslash_A1");
+})
+
+test('id -> StringSelect', () => {
+    expect(Id.create("mystringselect", CommandType.StringSelect)).toBe("mystringselect_C3");
+})
+
+test('id -> UserSelect', () => {
+    expect(Id.create("myuserselect", CommandType.UserSelect)).toBe("myuserselect_C5");
+})
+
+test('id -> RoleSelect', () => {
+    expect(Id.create("myroleselect", CommandType.RoleSelect)).toBe("myroleselect_C6");
+})
+
+test('id -> MentionSelect', () => {
+    expect(Id.create("mymentionselect", CommandType.MentionableSelect)).toBe("mymentionselect_C7");
+})
+
+test('id -> ChannelSelect', () => {
+    const modal = Id.create("mychannelselect", CommandType.ChannelSelect)
+    expect(modal).toBe("mychannelselect_C8");
+})
+
+test('id reconstruct button', () => {
+    const idload = Id.reconstruct(new ButtonInteraction("btn"))
+    expect(idload[0].id).toBe("btn_C2")
+})
+
+test('id reconstruct button with params', () => {
+    const idload = Id.reconstruct(new ButtonInteraction("btn/asdf"))
+    expect(idload[0].id).toBe("btn_C2")
+    expect(idload[0].params).toBe("asdf")
+})
+test('id reconstruct modal with params', () => {
+    const idload = Id.reconstruct(new ModalSubmitInteraction("btn/asdf"))
+    expect(idload[0].id).toBe("btn_M")
+    expect(idload[0].params).toBe("asdf")
+})
+test('id reconstruct modal', () => {
+    const idload = Id.reconstruct(new ModalSubmitInteraction("btn"))
+    expect(idload[0].id).toBe("btn_M")
+    expect(idload[0].params).toBe(undefined)
+})
+test('id reconstruct button with empty params', () => {
+    const idload = Id.reconstruct(new ButtonInteraction("btn/"))
+    expect(idload[0].id).toBe("btn_C2")
+    expect(idload[0].params).toBe("")
+})
+test('id reconstruct with multiple slashes', () => {
+    const idload = Id.reconstruct(new ButtonInteraction("btn//"))
+    expect(idload[0].id).toBe("btn_C2")
+    expect(idload[0].params).toBe("/")
+})
+
+
+test('id reconstruct button', () => {
+    const idload = Id.reconstruct(new ButtonInteraction("btn"))
+    expect(idload[0].id).toBe("btn_C2")
+    expect(idload[0].params).toBe(undefined)
+})
+
+
+

test/core/ioc.test.ts

@@ -1,86 +0,0 @@
-import { beforeEach, describe, expect, it, vi } from 'vitest';
-import { CoreContainer } from '../../src/core/ioc/container';
-import { EventEmitter } from 'events';
-import { DefaultLogging, Disposable, Init, Logging } from '../../src/core';
-import { CoreDependencies } from '../../src/types/ioc';
-
-describe('ioc container', () => {
-    let container: CoreContainer<{}> = new CoreContainer();
-    let dependency: Logging & Init & Disposable;
-    beforeEach(() => {
-        dependency = {
-            init: vi.fn(),
-            error(): void {},
-            warning(): void {},
-            info(): void {},
-            debug(): void {},
-            dispose: vi.fn()
-        };
-        container = new CoreContainer();
-    });
-    const wait = (seconds: number) =>  new Promise((resolve) => setTimeout(resolve, seconds));
-    class DB implements Init, Disposable {
-      public connected = false
-      constructor() {}
-      async init() {
-        this.connected = true
-        await wait(10)
-      }
-      async dispose() {
-        await wait(20)
-        this.connected = false
-      }
-    }
-    it('should be ready after calling container.ready()', () => {
-        container.ready();
-        expect(container.isReady()).toBe(true);
-    });
-    it('should container all core dependencies', async () => {
-        const keys = [
-            '@sern/modules',
-            '@sern/emitter',
-            '@sern/logger',
-            '@sern/errors',
-        ] satisfies (keyof CoreDependencies)[];
-        container.add({
-            '@sern/logger': () => new DefaultLogging(),
-            '@sern/client': () => new EventEmitter(),
-        });
-        for (const k of keys) {
-            //@ts-expect-error typings for iti are strict
-            expect(() => container.get(k)).not.toThrow();
-        }
-    });
-    it('should init modules', () => {
-        container.upsert({ '@sern/logger': dependency });
-        container.ready();
-        expect(dependency.init).to.toHaveBeenCalledOnce();
-    });
-    it('should dispose modules', async () => {
-        
-        container.upsert({ '@sern/logger': dependency })
-
-        container.ready();
-        // We need to access the dependency at least once to be able to dispose of it.
-        container.get('@sern/logger' as never);
-        await container.disposeAll();
-        expect(dependency.dispose).toHaveBeenCalledOnce();
-    });
-
-    it('should init and dispose', async () => {
-        container.add({ db: new DB() })
-        container.ready()
-        const db = container.get('db' as never) as DB
-        expect(db.connected).toBeTruthy()
-
-        await container.disposeAll();
-
-        expect(db.connected).toBeFalsy()
-    })
-
-    it('should not lazy module', () => {
-        container.upsert({ '@sern/logger': () => dependency });
-        container.ready();
-        expect(dependency.init).toHaveBeenCalledTimes(0);
-    });
-});

test/core/module-loading.test.ts

@@ -1,22 +1,64 @@
 import { describe, it, expect } from 'vitest'
-import { faker } from '@faker-js/faker'
+import path from 'node:path'
 import * as Files from '../../src/core/module-loading'
+import { Module } from '../../src/types/core-modules'
+import { AssertionError } from 'node:assert'
+//TODO: mock fs?
 describe('module-loading', () => {
-    it('should properly extract filename from file, nested once', () => {
-        const extension = faker.system.fileExt()
-        const name = faker.system.fileName({ extensionCount: 0 })
-        const filename = Files.fmtFileName(name+'.'+extension);
-        expect(filename).toBe(name)
+    it('should get the filename of the commandmodule (linux, esm)', () => {
+        const fname = "///home/pooba/Projects/sern/halibu/dist/commands/ping.js"
+        const callsiteinfo = Files.parseCallsite(fname)
+        expect(callsiteinfo.name).toBe("ping")
     })
-    
-//    todo: handle commands with multiple extensions
-//    it('should properly extract filename from file, nested multiple', () => {
-//        const extension = faker.system.fileExt()
-//        const extension2 = faker.system.fileExt()
-//        const name = faker.system.fileName({ extensionCount: 0 })
-//        const filename = Files.fmtFileName(name+'.'+extension+'.'+extension2);
-//        console.log(filename, name)
-//        expect(filename).toBe(name)
-//
-//    })
+    it('should get filename of commandmodule (linux, cjs)', () => {
+        const fname = "file:///home/pooba/Projects/sern/halibu/dist/commands/ping.js"
+        const callsiteinfo = Files.parseCallsite(fname)
+        expect(callsiteinfo.name).toBe("ping")
+
+    })
+    it('should get the filename of the commandmodule (windows, cjs)', () => {
+        //this test case is impossible on linux.
+        if(process.platform == 'win32') {
+            const fname = "C:\\pooba\\Projects\\sern\\halibu\\dist\\commands\\ping.js"
+            const callsiteinfo = Files.parseCallsite(fname)
+            expect(callsiteinfo.name).toEqual("ping");
+        }
+    })
+    it('should get filename of commandmodule (windows, esm)', () => {
+        //this test case is impossible on linux.
+        if(process.platform == 'win32') {
+            const fname = "file:///C:\\pooba\\Projects\\sern\\halibu\\dist\\commands\\ping.js"
+            const callsiteinfo = Files.parseCallsite(fname)
+            expect(callsiteinfo.name).toEqual("ping");
+        }
+        
+    })
+
+    it('should import a commandModule properly', async () => {
+        const { module } = await Files.importModule<Module>(path.resolve("test", 'mockules', "module.ts"));
+        expect(module.name).toBe('module')
+    })
+    it('should throw when failed commandModule import', async () => {
+        try {
+            await Files.importModule(path.resolve('test', 'mockules', 'failed.ts'))
+        } catch(e) {
+            expect(e instanceof AssertionError)
+        }
+    })
+    it('should throw when failed commandModule import', async () => {
+        try {
+            await Files.importModule(path.resolve('test', 'mockules', 'failed.ts'))
+        } catch(e) {
+            expect(e instanceof AssertionError)
+        }
+    })
+
+    it('reads all modules in mockules', async () => {
+        const ps = [] as string[]
+        for await (const fpath of Files.readRecursive(path.resolve('test', 'mockules'))) {
+            ps.push(fpath)
+        }
+        expect(ps.length === 4)
+    })
+
 }) 

test/core/presence.test.ts

@@ -0,0 +1,92 @@
+import { beforeEach, describe, expect, it, vi } from 'vitest';
+import { Presence } from '../../src';
+import * as Files from '../../src/core/module-loading'
+import { presenceHandler } from '../../src/handlers/presence'
+
+// Example test suite for the module function
+describe('module function', () => {
+  it('should return a valid configuration', () => {
+    const config = Presence.module({
+      inject: ['dependency1', 'dependency2'],
+      execute: vi.fn(),
+    });
+
+    expect(config).toBeDefined();
+    expect(config.inject).toEqual(['dependency1', 'dependency2']);
+    expect(typeof config.execute).toBe('function');
+  });
+});
+
+
+describe('of function', () => {
+  it('should return a valid presence configuration without repeat and onRepeat', () => {
+    const presenceConfig = Presence.of({
+      status: 'online',
+      afk: false,
+      activities: [{ name: 'Test Activity' }],
+      shardId: [1, 2, 3],
+    }).once();
+
+    expect(presenceConfig).toBeDefined();
+    //@ts-ignore Maybe fix?
+    expect(presenceConfig.repeat).toBeUndefined();
+    //@ts-ignore Maybe fix?
+    expect(presenceConfig.onRepeat).toBeUndefined();
+    expect(presenceConfig).toMatchObject({
+      status: 'online',
+      afk: false,
+      activities: [{ name: 'Test Activity' }],
+      shardId: [1, 2, 3],
+    });
+  });
+
+  it('should return a valid presence configuration with repeat and onRepeat', () => {
+    const onRepeatCallback = vi.fn();
+    const presenceConfig = Presence.of({
+      status: 'idle',
+      activities: [{ name: 'Another Test Activity' }],
+    }).repeated(onRepeatCallback, 5000);
+
+    expect(presenceConfig).toBeDefined();
+    expect(presenceConfig.repeat).toBe(5000);
+    expect(presenceConfig.onRepeat).toBe(onRepeatCallback);
+    expect(presenceConfig).toMatchObject({
+      status: 'idle',
+      activities: [{ name: 'Another Test Activity' }],
+    });
+  });
+
+
+})
+
+
+describe('Presence module execution', () => {
+    const mockExecuteResult = Presence.of({
+        status: 'online',
+    }).once();
+  
+    const mockModule = Presence.module({ 
+        inject: [ '@sern/client'],
+        execute: vi.fn().mockReturnValue(mockExecuteResult)
+    })
+    beforeEach(() => {
+        vi.clearAllMocks();
+        // Mock Files.importModule
+        vi.spyOn(Files, 'importModule').mockResolvedValue({
+          module: mockModule
+        });
+
+
+        
+    }); 
+    it('should set presence once.', async () => {
+        const setPresenceMock = vi.fn();
+        const mockPath = '/path/to/presence/config';
+    
+        await presenceHandler(mockPath, setPresenceMock);
+
+        expect(Files.importModule).toHaveBeenCalledWith(mockPath);
+        expect(setPresenceMock).toHaveBeenCalledOnce();
+    })
+
+})

test/core/services.test.ts

@@ -1,77 +0,0 @@
-import { SpyInstance, afterAll, beforeEach, describe, expect, it, vi } from 'vitest';
-import { CoreContainer } from '../../src/core/ioc/container';
-import { DefaultLogging } from '../../src/core';
-import { faker } from '@faker-js/faker';
-import { commandModule } from '../../src';
-import * as Id from '../../src/core/id';
-import { CommandMeta } from '../../src/types/core-modules';
-
-describe('services', () => {
-    //@ts-ignore
-    let container: CoreContainer<Dependencies>;
-    let consoleMock: SpyInstance;
-    beforeEach(() => {
-        container = new CoreContainer();
-        container.add({ '@sern/logger': () => new DefaultLogging() });
-        container.ready();
-        consoleMock = vi.spyOn(container.get('@sern/logger'), 'error').mockImplementation(() => {});
-    });
-
-    afterAll(() => {
-        consoleMock.mockReset();
-    });
-    it('module-store.ts', async () => {
-        function createRandomCommandModules() {
-            return commandModule({
-                type: faker.number.int({ min: 1 << 0, max: 1 << 10 }),
-                description: faker.string.alpha(),
-                name: faker.string.alpha(),
-                execute: () => {},
-            });
-        }
-
-        const modules = faker.helpers.multiple(createRandomCommandModules, {
-            count: 40,
-        });
-
-        const paths = faker.helpers
-            .multiple(faker.system.directoryPath, { count: 40 })
-            .map((path, i) => `${path}/${modules[i]}.js`);
-
-        const metadata: CommandMeta[] = modules.map((cm, i) => ({
-            id: Id.create(cm.name!, cm.type),
-            isClass: false,
-            fullPath: `${paths[i]}/${cm.name}.js`,
-        }));
-        const moduleManager = container.get('@sern/modules');
-        let i = 0;
-        for (const m of modules) {
-            moduleManager.set(Id.create(m.name!, m.type), paths[i]);
-            moduleManager.setMetadata(m, metadata[i]);
-            i++;
-        }
-        for (const m of modules) {
-            expect(moduleManager.getMetadata(m), 'module references do not exist').toBeDefined();
-        }
-    });
-
-    //todo add more
-    it('error-handling', () => {
-        const errorHandler = container.get('@sern/errors');
-        const lifetime = errorHandler.keepAlive;
-        for (let i = 0; i < lifetime; i++) {
-            if (i == lifetime - 1) {
-                expect(() => errorHandler.updateAlive(new Error('poo'))).toThrowError();
-            } else {
-                expect(() => errorHandler.updateAlive(new Error('poo'))).not.toThrowError();
-            }
-        }
-    });
-    //todo add more, spy on every instance?
-    it('logger', () => {
-        container.get('@sern/logger').error({ message: 'error' });
-
-        expect(consoleMock).toHaveBeenCalledOnce();
-        expect(consoleMock).toHaveBeenLastCalledWith({ message: 'error' });
-    });
-});

test/handlers.test.ts

@@ -0,0 +1,65 @@
+//@ts-nocheck
+import { beforeEach, describe, expect, it, test } from 'vitest';
+import { callInitPlugins } from '../src/handlers/event-utils';
+
+import { Client } from 'discord.js'
+import { faker } from '@faker-js/faker';
+import { EventEmitter } from 'events';
+import { CommandControlPlugin, CommandType, controller } from '../src';
+import { createRandomModule, createRandomInitPlugin } from './setup/util';
+
+
+
+function mockDeps() {
+   return {
+        '@sern/client': new Client(),
+        '@sern/emitter': new EventEmitter()
+   }
+}
+ 
+describe('calling init plugins', async () => {
+   let deps;
+   beforeEach(() => {
+       deps = mockDeps()
+   });
+
+   test ('call init plugins', async () => {
+       const plugins = createRandomInitPlugin('go', { name: "abc" })
+       const mod = createRandomModule([plugins])
+       const s = await callInitPlugins(mod, deps, false)
+       expect("abc").equal(s.name)
+   })
+   test('init plugins replace array', async () => {
+       const plugins = createRandomInitPlugin('go', { opts: [] })
+       const plugins2 = createRandomInitPlugin('go', { opts: ['a'] })
+       const mod = createRandomModule([plugins, plugins2])
+       const s = await callInitPlugins(mod, deps, false)
+       expect(['a']).deep.equal(s.opts)
+   })
+
+})
+
+
+
+
+test('form sdt', async () => {
+
+    const expectedObject = { 
+        "plugin/abc": faker.person.jobArea(),
+        "plugin2/abc": faker.git.branch(),
+        "plugin3/cheese": faker.person.jobArea()
+    }
+    
+    const plugin = CommandControlPlugin<CommandType.Slash>((ctx,sdt) => {
+        return controller.next({ "plugin/abc": expectedObject['plugin/abc'] });
+    });
+    const plugin2 = CommandControlPlugin<CommandType.Slash>((ctx,sdt) => {
+        return controller.next({ "plugin2/abc": expectedObject['plugin2/abc'] });
+    });
+    const plugin3 = CommandControlPlugin<CommandType.Slash>((ctx,sdt) => {
+        return controller.next({ "plugin3/cheese": expectedObject['plugin3/cheese'] });
+    });
+    
+})
+
+

test/handlers/dispatchers.test.ts

@@ -1,45 +0,0 @@
-import { beforeEach, describe, expect, vi, it } from 'vitest';
-import { createResultResolver, eventDispatcher } from '../../src/handlers/_internal';
-import { faker } from '@faker-js/faker';
-import { Module } from '../../src/core/types/modules';
-import { Processed } from '../../src/handlers/types';
-import { CommandType } from '../../src/core';
-import { EventEmitter } from 'events';
-
-function createRandomModule(): Processed<Module> {
-    return {
-        type: faker.number.int({
-            min: CommandType.Text,
-            max: CommandType.ChannelSelect,
-        }),
-        description: faker.string.alpha(),
-        name: faker.string.alpha(),
-        onEvent: [],
-        plugins: [],
-        execute: vi.fn(),
-    };
-}
-
-describe('eventDispatcher standard', () => {
-    let m: Processed<Module>;
-    let ee: EventEmitter;
-    beforeEach(() => {
-        ee = new EventEmitter();
-        m = createRandomModule();
-    });
-
-    it('should throw', () => {
-        expect(() => eventDispatcher(m, 'not event emitter')).toThrowError();
-    });
-    it("Shouldn't throw", () => {
-        expect(() => eventDispatcher(m, ee)).not.toThrowError();
-    });
-
-    it('Should be called once', () => {
-        const s = eventDispatcher(m, ee);
-        s.subscribe();
-        ee.emit(m.name, faker.string.alpha());
-
-        expect(m.execute).toHaveBeenCalledOnce();
-    });
-});

test/handlers/id.test.ts

@@ -1,72 +0,0 @@
-import { describe, expect, it, vi } from 'vitest';
-import * as Id from '../../src/core/id';
-import { faker } from '@faker-js/faker';
-import { CommandModule, CommandType, commandModule } from '../../src';
-import { CommandTypeDiscordApi } from '../../src/core/id';
-
-function createRandomCommandModules() {
-    const randomCommandType = [
-        CommandType.Text,
-        CommandType.Both,
-        CommandType.CtxMsg,
-        CommandType.CtxUser,
-        CommandType.Modal,
-        CommandType.ChannelSelect,
-        CommandType.RoleSelect,
-        CommandType.UserSelect,
-        CommandType.StringSelect,
-        CommandType.Button,
-    ];
-    return commandModule({
-        type: faker.helpers.uniqueArray(randomCommandType, 1)[0],
-        description: faker.string.alpha(),
-        name: faker.string.alpha(),
-        execute: () => {},
-    });
-}
-function createMetadata(c: CommandModule) {
-    return {
-        fullPath: faker.system.filePath(),
-        id: Id.create(c.name, c.type),
-        isClass: Boolean(Math.floor(Math.random())),
-    };
-}
-const appBitField = 0b000000001111;
-
-describe('id resolution', () => {
-    it('should resolve application commands correctly', () => {
-        const modules = faker.helpers.multiple(createRandomCommandModules, {
-            count: 20,
-        });
-        const metadata = modules.map(createMetadata);
-        metadata.forEach((meta, idx) => {
-            const associatedModule = modules[idx];
-            const am = (appBitField & associatedModule.type) !== 0 ? 'A' : 'C';
-            let uid = 0;
-            if (
-                associatedModule.type === CommandType.Both ||
-                associatedModule.type === CommandType.Modal
-            ) {
-                uid = 1;
-            } else {
-                uid = CommandTypeDiscordApi[Math.log2(associatedModule.type)];
-            }
-            expect(meta.id).toBe(associatedModule.name + '_' + am + uid);
-        });
-    });
-
-    it('maps commands type to discord components or application commands', () => {
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.Text)]).toBe(1);
-
-        expect(CommandTypeDiscordApi[1]).toBe(1);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.CtxUser)]).toBe(2);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.CtxMsg)]).toBe(3);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.Button)]).toBe(2);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.StringSelect)]).toBe(3);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.UserSelect)]).toBe(5);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.RoleSelect)]).toBe(6);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.MentionableSelect)]).toBe(7);
-        expect(CommandTypeDiscordApi[Math.log2(CommandType.ChannelSelect)]).toBe(8);
-        expect(CommandTypeDiscordApi[6]).toBe(1);
-    });
-});

test/mockules/module.ts

@@ -0,0 +1,6 @@
+import { CommandType, commandModule } from '../../src/'
+export default commandModule({ 
+    type: CommandType.Both,
+    description: "",
+    execute: (Ctx, args) => {}
+})

test/mockules/ug/pass.ts

@@ -0,0 +1,6 @@
+import { CommandType, commandModule } from '../../../src/'
+export default commandModule({ 
+    type: CommandType.Both,
+    description: "",
+    execute: (Ctx, args) => {}
+})

test/setup/setup-tests.ts

@@ -0,0 +1,54 @@
+import { vi } from 'vitest'
+import { makeDependencies } from '../../src';
+import { Client } from 'discord.js';
+
+vi.mock('discord.js', async (importOriginal) => {
+    const mod = await importOriginal()
+    const ModalSubmitInteraction = class {
+        customId;
+        type = 5;
+        isModalSubmit = vi.fn();
+        constructor(customId) {
+            this.customId = customId;
+        }
+    };
+    const ButtonInteraction = class {
+        customId;
+        type = 3;
+        componentType = 2;
+        isButton = vi.fn();
+        constructor(customId) {
+            this.customId = customId;
+        }
+    };
+    const AutocompleteInteraction = class {
+        type = 4;
+        option: string;
+        constructor(s: string) {
+            this.option = s;
+        }
+        options = {
+            getFocused: vi.fn(),
+            getSubcommand: vi.fn(),
+        };
+    };
+
+    return {
+        Client : vi.fn(),
+        Collection: mod.Collection,
+        ComponentType: mod.ComponentType,
+        InteractionType: mod.InteractionType,
+        ApplicationCommandOptionType: mod.ApplicationCommandOptionType,
+        ApplicationCommandType: mod.ApplicationCommandType, 
+        ModalSubmitInteraction,
+        ButtonInteraction,
+        AutocompleteInteraction,
+        ChatInputCommandInteraction: vi.fn()
+    };
+});
+
+await makeDependencies(({ add }) => {
+    add('@sern/client', {  })
+})
+
+

test/setup/util.ts

@@ -0,0 +1,30 @@
+import { faker } from "@faker-js/faker"
+import { CommandInitPlugin, CommandType, Module, controller } from "../../src"
+import { Processed } from "../../src/types/core-modules"
+import { vi } from 'vitest'
+
+export function createRandomInitPlugin (s: 'go', mut?: Partial<Module>) {
+    return CommandInitPlugin(({ module }) => {
+        if(mut) {
+            Object.entries(mut).forEach(([k, v]) => {
+                module[k] = v
+            })
+        }
+        return  s == 'go'
+            ? controller.next()
+            : controller.stop()
+    })
+}
+
+export function createRandomModule(plugins: any[]): Processed<Module> {
+    return {
+        type: CommandType.Both,
+        meta: { id:"", absPath: "" },
+        description: faker.string.alpha(),
+        plugins, 
+        name: "cheese",
+        onEvent: [],
+        locals: {},
+        execute: vi.fn(),
+    };
+}

tsconfig.json

@@ -4,15 +4,17 @@
         "strict": true,
         "esModuleInterop": true,
         "strictNullChecks": true,
-        "moduleResolution": "node",
+        "moduleResolution": "node16",
         "skipLibCheck": true,
         "declaration": true,
         "preserveSymlinks": true,
         "allowSyntheticDefaultImports": true,
         "forceConsistentCasingInFileNames": true,
         "isolatedModules": true,
-        "module": "esnext",
-        "target": "esnext"
+        "outDir": "dist",
+        "module": "node16",
+        "target": "esnext",
+        "sourceMap": true
     },
     "exclude": ["node_modules", "dist"],
     "include": ["./src", "./src/**/*.d.ts"]

tsup.config.js

@@ -1,24 +0,0 @@
-import { defineConfig } from 'tsup';
-const shared = {
-    entry: ['src/index.ts'],
-    external: ['discord.js', 'iti'],
-    platform: 'node',
-    clean: true,
-    sourcemap: true,
-    treeshake: {
-        moduleSideEffects: false,
-        correctVarValueBeforeDeclaration: true, //need this to treeshake esm discord.js empty import
-        annotations: true,
-    },
-};
-export default defineConfig([
-    {
-        format: ['esm', 'cjs'],
-        target: 'node18',
-        tsconfig: './tsconfig.json',
-        outDir: './dist',
-        minify: false,
-        dts: true,
-        ...shared,
-    },
- ]);

vitest.config.ts

@@ -0,0 +1,8 @@
+// vitest.config.ts or vitest.config.js
+import { defineConfig } from 'vitest/config'
+
+export default defineConfig({
+  test: {
+    setupFiles: ['./test/setup/setup-tests.ts'],
+  },
+})