add debug output for #278

pk910 · Aug 28, 2024 · f8e3784 · f8e3784
1 parent dd514e3
commit f8e3784
Showing 1 changed file with 48 additions and 2 deletions.
diff --git a/src/modules/ModuleManager.ts b/src/modules/ModuleManager.ts
@@ -1,6 +1,7 @@
 import { FaucetLogLevel, FaucetProcess } from "../common/FaucetProcess.js";
 import { ServiceManager } from "../common/ServiceManager.js";
 import { faucetConfig } from "../config/FaucetConfig.js";
+import { FaucetSession } from "../session/FaucetSession.js";
 import { BaseModule } from "./BaseModule.js";
 import { MODULE_CLASSES } from "./modules.js";
 
@@ -129,6 +130,7 @@ export class ModuleManager {
 
  public async processActionHooks(localfns: {prio: number, hook: Function}[], action: ModuleHookAction, args: any[]): Promise<void> {
  let hooks = this.getActionHooks(action);
+ let debugOutput = action == ModuleHookAction.SessionStart;
  let localIdx = 0;
  let hookIdx = 0;
  do {
@@ -142,11 +144,55 @@ export class ModuleManager {
 
  let promises: Promise<void>[] = [];
  while(localfns.length > localIdx && localfns[localIdx].prio == loopPrio) {
- promises.push(localfns[localIdx].hook.apply(this, args));
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " start: local " + localIdx);
+ }
+
+ let promise = localfns[localIdx].hook.apply(this, args);
+ if (promise instanceof Promise) {
+ ((hookIdx) => {
+ promise.then(() => {
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " end: local " + localIdx);
+ }
+ })
+ })(hookIdx);
+ } else {
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " nop: local " + localIdx);
+ }
+ }
+
+ promises.push(promise);
  localIdx++;
  }
  while(hooks.length > hookIdx && hooks[hookIdx].prio == loopPrio) {
- promises.push(hooks[hookIdx].hook.apply(this, args));
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " start: module " + hooks[hookIdx].module.getModuleName());
+ }
+
+ let promise = hooks[hookIdx].hook.apply(this, args);
+ if (promise instanceof Promise) {
+ ((hookIdx) => {
+ promise.then(() => {
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " end: module " + hooks[hookIdx].module.getModuleName());
+ }
+ })
+ })(hookIdx);
+ } else {
+ if(debugOutput) {
+ let session: FaucetSession = args[0];
+ ServiceManager.GetService(FaucetProcess).emitLog(FaucetLogLevel.INFO, "sessionStart " + session.getSessionId() + " nop: module " + hooks[hookIdx].module.getModuleName());
+ }
+ }
+
+ promises.push(promise);
  hookIdx++;
  }