Merge pull request #37 from medishen/dev/v2

refactor(events): Entering data for the publish method became optional.

packages/debug/index.ts

@@ -0,0 +1,3 @@
+export * from './services';
+export * from './types';
+export * from './interfaces';

packages/debug/interfaces/index.ts

@@ -0,0 +1 @@
+export * from './logger.interfaces';

packages/debug/interfaces/logger.interfaces.ts

@@ -0,0 +1,37 @@
+import { LogLevel } from '../types/logger.types';
+
+/**
+ * @public
+ */
+export interface LoggerService {
+  /**
+   * Write a 'log' level log.
+   */
+  log(message: any, ...optionalParams: any[]): any;
+
+  /**
+   * Write an 'error' level log.
+   */
+  error(message: any, ...optionalParams: any[]): any;
+
+  /**
+   * Write a 'warn' level log.
+   */
+  warn(message: any, ...optionalParams: any[]): any;
+
+  /**
+   * Write a 'debug' level log.
+   */
+  debug?(message: any, ...optionalParams: any[]): any;
+
+  /**
+   * Write a 'verbose' level log.
+   */
+  verbose?(message: any, ...optionalParams: any[]): any;
+
+  /**
+   * Set log levels.
+   * @param levels log levels
+   */
+  setLogLevels?(levels: LogLevel[]): any;
+}

packages/debug/package.json

@@ -0,0 +1,12 @@
+{
+  "name": "@gland/debug",
+  "version": "1.0.0",
+  "author": "Mahdi",
+  "license": "MIT",
+  "scripts": {
+    "build": "tsc"
+  },
+  "devDependencies": {
+    "typescript": "^5.5.4"
+  }
+}

packages/debug/services/index.ts

@@ -0,0 +1 @@
+export * from './logger.service';

packages/debug/services/logger.service.ts

@@ -0,0 +1,82 @@
+import { LoggerService } from '../interfaces/logger.interfaces';
+import { LogLevel } from '../types/logger.types';
+const DEFAULT_LOGGER = console;
+
+export class Logger implements LoggerService {
+  protected static logLevels: LogLevel[] = ['log', 'error', 'warn', 'debug', 'verbose'];
+  private static staticInstance: LoggerService = DEFAULT_LOGGER;
+  private static defaultContext = 'Application';
+
+  constructor(protected context?: string, protected options: { timestamp?: boolean } = {}) {}
+
+  /**
+   * Write an 'error' level log.
+   */
+  error(message: any, stack?: string, context?: string): void;
+  error(message: any, ...optionalParams: [...any, string?, string?]): void;
+  error(message: any, ...optionalParams: any[]) {
+    this.logWithLevel('error', message, optionalParams);
+  }
+
+  /**
+   * Write a 'log' level log.
+   */
+  log(message: any, context?: string): void;
+  log(message: any, ...optionalParams: [...any, string?]): void;
+  log(message: any, ...optionalParams: any[]) {
+    this.logWithLevel('log', message, optionalParams);
+  }
+
+  /**
+   * Write a 'warn' level log.
+   */
+  warn(message: any, context?: string): void;
+  warn(message: any, ...optionalParams: [...any, string?]): void;
+  warn(message: any, ...optionalParams: any[]) {
+    this.logWithLevel('warn', message, optionalParams);
+  }
+
+  /**
+   * Write a 'debug' level log.
+   */
+  debug(message: any, context?: string): void;
+  debug(message: any, ...optionalParams: [...any, string?]): void;
+  debug(message: any, ...optionalParams: any[]) {
+    this.logWithLevel('debug', message, optionalParams);
+  }
+
+  /**
+   * Write a 'verbose' level log.
+   */
+  verbose(message: any, context?: string): void;
+  verbose(message: any, ...optionalParams: [...any, string?]): void;
+  verbose(message: any, ...optionalParams: any[]) {
+    this.logWithLevel('verbose', message, optionalParams);
+  }
+  static setLogLevels(levels: LogLevel[]): void {
+    this.logLevels = levels;
+  }
+
+  static getTimestamp(): string {
+    return new Date().toISOString();
+  }
+
+  static isLevelEnabled(level: LogLevel): boolean {
+    return this.logLevels!.includes(level);
+  }
+
+  private logWithLevel(level: LogLevel, message: any, params: any[]): void {
+    if (!Logger.isLevelEnabled(level)) return;
+
+    const logger = Logger.staticInstance;
+    const context = this.context || Logger.defaultContext;
+    const timestamp = this.options.timestamp ? `[${Logger.getTimestamp()}] ` : '';
+
+    const formattedMessage = `${timestamp}[${context}] ${message}`;
+    if (typeof logger[level] === 'function') {
+      logger[level](formattedMessage, ...params);
+    } else {
+      logger.log(formattedMessage, ...params);
+    }
+  }
+}

packages/debug/tsconfig.json

@@ -0,0 +1,11 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "rootDir": ".",
+    "outDir": "."
+  },
+  "files": [],
+  "include": ["**/*.ts"],
+  "exclude": ["node_modules"],
+  "references": []
+}

packages/debug/types/index.ts

@@ -0,0 +1 @@
+export * from './logger.types';

packages/debug/types/logger.types.ts

@@ -0,0 +1,4 @@
+/**
+ * @public
+ */
+export type LogLevel = 'log' | 'error' | 'warn' | 'debug' | 'verbose';

packages/events/core/event-manager.ts

@@ -31,13 +31,13 @@ export class EventManager {
         return new ImmediateStrategy();
     }
   }
-  async publish<T extends string, D>(qualified: QualifiedEvent<T>, data: D): Promise<void> {
+  async publish<T extends string, D>(qualified: QualifiedEvent<T>, data?: D): Promise<void> {
     const { phase, type } = EventMapper.parseQualifiedType(qualified);
 
     const event: Event<typeof type, typeof phase, D> = {
       type,
       phase,
-      data,
+      data: data ?? ({} as D),
       lifecycle: {
         startedAt: new Date(),
       },