diff --git a/src/@types/adapters.ts b/src/@types/adapters.ts index ebddfe7..d570b52 100644 --- a/src/@types/adapters.ts +++ b/src/@types/adapters.ts @@ -13,6 +13,7 @@ export interface IWebServerAdapter extends EventEmitter { export type IWebSocketAdapter = EventEmitter & { getClientId(): string + getClientAddress(): string getSubscriptions(): Map } diff --git a/src/adapters/web-socket-adapter.ts b/src/adapters/web-socket-adapter.ts index 16ce8d9..db02c24 100644 --- a/src/adapters/web-socket-adapter.ts +++ b/src/adapters/web-socket-adapter.ts @@ -72,6 +72,10 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter return this.clientId } + public getClientAddress(): string { + return this.clientAddress + } + public onUnsubscribed(subscriptionId: string): void { debug('client %s unsubscribed %s', this.clientId, subscriptionId) this.subscriptions.delete(subscriptionId)