archived-handler/src/handler/events/readyEvent.ts

import { concatMap, first, from, fromEvent, pipe, tap } from 'rxjs';
import { basename } from 'path';
import * as Files from '../utilities/readFile';
import type Wrapper from '../structures/wrapper';
import type { Module } from '../structures/structxports';
import type { HandlerCallback, ModuleHandlers, ModuleStates, ModuleType } from '../structures/commands/moduleHandler';
import { CommandType } from '../sern';

export const onReady = ( wrapper : Wrapper ) => {
    const { client, init, commands, } = wrapper;
    fromEvent(client, 'ready')
       .pipe(
           first(),
           tap(() => init?.( wrapper ) ),
           concatMap( 
                pipe( 
                  () => Files.buildData(commands),
                  ( createCommandCache )
                )
            ),  
        )
       .subscribe({
            complete() {
                // on ready event, complete!
                // log stuff?
            }
       });
};

const handler = ( name : string ) =>
    ({
        [CommandType.TEXT] : mod => {
            mod.alias.forEach ( a => Files.Alias.set(a,mod));
            Files.Commands.set( name,  mod  );
        },
        [CommandType.SLASH]: mod => {
            Files.Commands.set( name,  mod);
        },
        [CommandType.BOTH] : mod => {
            Files.Commands.set ( name, mod); 
            mod.alias.forEach (a => Files.Alias.set(a, mod));
        },
        [CommandType.MENU_USER] : mod => {
            Files.Commands.set ( name, mod );
        },
        [CommandType.MENU_MSG] : mod =>  { 

            Files.Commands.set (name, mod );
        }
    } as ModuleHandlers);

const registerModules = <T extends ModuleType >(name : string, mod : ModuleStates[T]) =>
    (handler(name)[mod.type] as HandlerCallback<T>)(mod);

function setCommands ( { mod, absPath } : { mod : Module, absPath : string } ) {
   const name = mod.name ?? Files.fmtFileName(basename(absPath));
   registerModules(name, mod); 
}

async function createCommandCache( 
    arr: Promise<{mod: Module, absPath: string}[]> 
  ) {
    from(await arr).subscribe ( setCommands );
}