Merge pull request #42 from AsenaJs/release-v0.6.0

Release v0.6.0

Author: LibirSoft

CHANGELOG.md

@@ -1,5 +1,86 @@
 # @asenajs/asena
 
+## 0.6.0
+
+### Minor Changes
+
+- d1fd783: ## Event System
+
+  Added Spring-like event-driven architecture.
+
+  ```typescript
+  @EventService({ prefix: 'user' })
+  export class UserEventService {
+    @On('created')
+    handleUserCreated(eventName: string, data: any) {
+      console.log('User created:', data);
+    }
+
+    @On('*.error') // Wildcard support
+    handleErrors(eventName: string, data: any) {
+      console.error('Error:', eventName);
+    }
+  }
+  ```
+
+  **Features:**
+  - `@EventService` and `@On` decorators
+  - Wildcard pattern support (`user.*`, `*.error`)
+  - Fire-and-forget pattern
+  - Async/sync handler support
+  - Error isolation
+  - Event chaining
+
+  **Exports:**
+
+  ```typescript
+  import { EventService, On } from '@asenajs/asena/decorators';
+  import { EventEmitter } from '@asenajs/asena/event';
+  ```
+
+  ## Breaking Changes (Adapter Developers Only)
+
+  **WebSocket Refactoring - Circular Dependency Removal**
+
+  `AsenaSocket` no longer holds a reference to `AsenaWebSocketService`.
+
+  **Changes:**
+  - `AsenaSocket` constructor: removed `websocketService` parameter, added `namespace: string`
+  - Removed `cleanup()` method
+  - Removed manual `rooms` management (using Bun native pub/sub)
+  - Removed `getSocketsByRoom()` method from `AsenaWebSocketService`
+
+  **Impact:**
+  - ⚠️ HTTP/WebSocket adapter developers must update their code
+  - ✅ End users are not affected
+
+  **For adapter developers:**
+
+  ```typescript
+  // Before
+  new AsenaSocket(ws, websocketService);
+
+  // After
+  new AsenaSocket(ws, namespace);
+  ```
+
+### Patch Changes
+
+- ## Windows Path Compatibility Fix
+
+  Fixed route path joining issue on Windows by normalizing backslashes to forward slashes.
+
+  **Issue:** `path.join()` was using Windows backslashes (`\`) for route paths, causing adapter registration failures on Windows.
+
+  **Solution:** Route paths are now normalized using `.replace(/\\/g, '/')` to ensure cross-platform compatibility.
+
+  **Impact:**
+  - ✅ Routes now work correctly on Windows
+  - ✅ No breaking changes for users or adapter developers
+  - ✅ Test coverage added for path normalization
+
+  **Related:** Fixes #41
+
 ## 0.5.0
 
 ### Minor Changes

bun.lock

@@ -4,6 +4,10 @@ coverage = true
 
 coverageSkipTestFiles = true
 
+coveragePathIgnorePatterns = [
+    "test/utils/*.ts",
+]
+
 
 
 [test.reporter]

bunfig.toml

@@ -1,2 +1 @@
 export { AsenaServerFactory, AsenaServer } from './lib/server';
-export { ICoreServiceNames, ComponentConstants } from './lib/ioc';

index.ts

@@ -8,7 +8,10 @@ import { PrepareConfigService } from '../server/src/services/PrepareConfigServic
 import { PrepareWebsocketService } from '../server/src/services/PrepareWebsocketService';
 import { PrepareValidatorService } from '../server/src/services/PrepareValidatorService';
 import { PrepareStaticServeConfigService } from '../server/src/services/PrepareStaticServeConfigService';
+import { PrepareEventService } from '../server/src/services/PrepareEventService';
 import { Ulak } from '../server/messaging/Ulak';
+import { EventDispatchService } from '../server/event/EventDispatchService';
+import { EventEmitter } from '../server/event/EventEmitter';
 
 /**
  * @description CoreContainer manages framework-level services
@@ -123,12 +126,17 @@ export class CoreContainer {
       // Internal messaging system (must be registered before prepare services)
       { name: ICoreServiceNames.__ULAK__, Class: Ulak },
 
+      // Event system (must be registered before PrepareEventService)
+      { name: ICoreServiceNames.EVENT_DISPATCH_SERVICE, Class: EventDispatchService },
+      { name: ICoreServiceNames.EVENT_EMITTER, Class: EventEmitter },
+
       // Prepare services
       { name: ICoreServiceNames.PREPARE_MIDDLEWARE_SERVICE, Class: PrepareMiddlewareService },
       { name: ICoreServiceNames.PREPARE_CONFIG_SERVICE, Class: PrepareConfigService },
       { name: ICoreServiceNames.PREPARE_WEBSOCKET_SERVICE, Class: PrepareWebsocketService },
       { name: ICoreServiceNames.PREPARE_VALIDATOR_SERVICE, Class: PrepareValidatorService },
       { name: ICoreServiceNames.PREPARE_STATIC_SERVE_CONFIG_SERVICE, Class: PrepareStaticServeConfigService },
+      { name: ICoreServiceNames.PREPARE_EVENT_SERVICE, Class: PrepareEventService },
     ];
 
     for (const service of services) {

lib/ioc/CoreContainer.ts

@@ -56,4 +56,9 @@ export class ComponentConstants {
 
   // Static Serve specific
   public static readonly StaticServeRootKey = Symbol('staticServe:root');
+
+  // Event specific
+  public static readonly EventHandlersKey = Symbol('event:handlers');
+
+  public static readonly EventPrefixKey = Symbol('event:prefix');
 }

lib/ioc/constants/ComponentConstants.ts

@@ -13,12 +13,17 @@ export enum ICoreServiceNames {
   // Internal Messaging Services (Phase 5)
   __ULAK__ = '__Ulak__',
 
+  // Event Services (Phase 5)
+  EVENT_EMITTER = 'EventEmitter',
+  EVENT_DISPATCH_SERVICE = 'EventDispatchService',
+
   // Prepare Services (Phase 5)
   PREPARE_MIDDLEWARE_SERVICE = 'PrepareMiddlewareService',
   PREPARE_CONFIG_SERVICE = 'PrepareConfigService',
   PREPARE_WEBSOCKET_SERVICE = 'PrepareWebsocketService',
   PREPARE_VALIDATOR_SERVICE = 'PrepareValidatorService',
   PREPARE_STATIC_SERVE_CONFIG_SERVICE = 'PrepareStaticServeConfigService',
+  PREPARE_EVENT_SERVICE = 'PrepareEventService',
 
   // Factory Services (Phase 6+)
   CORE_CONTAINER = 'CoreContainer',

lib/ioc/types/ICoreServiceNamesType.ts

@@ -6,4 +6,5 @@ export enum ComponentType {
   MIDDLEWARE = 'MIDDLEWARE',
   WEBSOCKET = 'WEBSOCKET',
   CONFIG = 'CONFIG',
+  EVENT = 'EVENT',
 }

lib/ioc/types/decorators/ComponentType.ts

@@ -29,6 +29,7 @@ import type { PrepareValidatorService } from './src/services/PrepareValidatorSer
 import type { PrepareStaticServeConfigService } from './src/services/PrepareStaticServeConfigService';
 import { Inject, PostConstruct } from '../ioc/component';
 import type { GlobalMiddlewareConfig, GlobalMiddlewareEntry } from './config/AsenaConfig';
+import type { PrepareEventService } from './src/services/PrepareEventService';
 
 /**
  * @description AsenaServer - Main server class for Asena framework
@@ -62,6 +63,9 @@ export class AsenaServer<A extends AsenaAdapter<any, any>> implements ICoreServi
   @Inject(ICoreServiceNames.PREPARE_STATIC_SERVE_CONFIG_SERVICE)
   private prepareStaticServeConfigService!: PrepareStaticServeConfigService;
 
+  @Inject(ICoreServiceNames.PREPARE_EVENT_SERVICE)
+  private prepareEventService: PrepareEventService;
+
   // Instance state
   private _port!: number;
 
@@ -91,6 +95,7 @@ export class AsenaServer<A extends AsenaAdapter<any, any>> implements ICoreServi
     // Phase 7: Application setup
     this._coreContainer.setPhase(CoreBootstrapPhase.APPLICATION_SETUP);
     await this.prepareConfigs();
+    await this.prepareEventService.prepare();
     await this.initializeControllers();
     await this.prepareWebSocket();
 
@@ -138,7 +143,7 @@ export class AsenaServer<A extends AsenaAdapter<any, any>> implements ICoreServi
       await this.prepareTopMiddlewares({ controller, routePath });
 
       for (const [name, params] of Object.entries(routes)) {
-        const lastPath = path.join(`${routePath}/`, params.path);
+        const lastPath = path.join(`${routePath}/`, params.path).replace(/\\/g, '/');
 
         const middlewares = await this.prepareRouteMiddleware(params);
         const validatorInstance = await this.prepareValidator(params.validator);

lib/server/AsenaServer.ts

@@ -0,0 +1,50 @@
+import { ComponentConstants, ComponentType } from '../../../ioc';
+import { defineComponent } from '../../../ioc/component';
+import { defineTypedMetadata } from '../../../utils';
+import type { EventServiceParams } from '../../event';
+
+/**
+ * @description EventService decorator - Marks a class as an event service
+ *
+ * Event services contain @On decorated methods that handle events.
+ *
+ * @param params - Optional configuration or prefix string
+ *
+ * @example
+ * // With prefix
+ * @EventService({ prefix: 'user' })
+ * export class UserEventService {
+ *   @On('created')  // Handles 'user.created' event
+ *   handleUserCreated(eventName: string, data: any) {
+ *     console.log('User created:', data);
+ *   }
+ * }
+ *
+ * @example
+ * // Without prefix
+ * @EventService()
+ * export class GlobalEventService {
+ *   @On('app.started')
+ *   handleAppStarted() {
+ *     console.log('App started');
+ *   }
+ * }
+ *
+ * @example
+ * // Shorthand with prefix string
+ * @EventService('download')
+ * export class DownloadEventService {
+ *   @On('complete')  // Handles 'download.complete'
+ *   handleComplete(eventName: string, data: any) { }
+ * }
+ */
+export const EventService = (params?: EventServiceParams | string): ClassDecorator => {
+  // Normalize params - support both object and string
+  const _params =
+    typeof params === 'string' ? { prefix: params, name: undefined } : params || { prefix: undefined, name: undefined };
+
+  return defineComponent(ComponentType.EVENT, _params, (target) => {
+    // Store prefix metadata for PrepareEventService
+    defineTypedMetadata<string>(ComponentConstants.EventPrefixKey, _params.prefix || '', target);
+  });
+};