export class TwitchClientManager {

private clients = new Map<string, ChatClient>();

private messageHandlers = new Map<string, (message: TwitchChatMessage) => void>();

private messageHandlerTokens = new Map<string, symbol>();

constructor(private logger: ChannelLogSink) {}

handler: (message: TwitchChatMessage) => void,

): () => void {

const key = this.getAccountKey(account);

const token = Symbol(key);

this.messageHandlers.set(key, handler);

this.messageHandlerTokens.set(key, token);

return () => {

this.messageHandlers.delete(key);

// Only remove the exact registration this cleanup closure owns. A later

// onMessage() may reuse the same callback function for the same account.

if (this.messageHandlerTokens.get(key) === token) {

this.messageHandlers.delete(key);

this.messageHandlerTokens.delete(key);

}

};

}

client.quit();

this.clients.delete(key);

this.messageHandlers.delete(key);

this.messageHandlerTokens.delete(key);

this.logger.info(`Disconnected ${key}`);

}

}

this.clients.forEach((client) => client.quit());

this.clients.clear();

this.messageHandlers.clear();

this.messageHandlerTokens.clear();

this.logger.info(" Disconnected all clients");

}