NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2025-07-14 09:51:24 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: Added websocket with lib socket.io

Browse Source
This commit is contained in:
Davidson Gomes 2023-08-02 13:21:15 -03:00
parent 79864e97d6
commit 341148612f
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/whatsapp/services/whatsapp.service.ts
View File

@ -417,11 +417,18 @@ export class WAStartupService {
const serverUrl = this.configService.get<HttpServer>('SERVER').URL; const serverUrl = this.configService.get<HttpServer>('SERVER').URL;
const we = event.replace(/[.-]/gm, '_').toUpperCase(); const we = event.replace(/[.-]/gm, '_').toUpperCase();
const transformedWe = we.replace(/_/gm, '-').toLowerCase(); const transformedWe = we.replace(/_/gm, '-').toLowerCase();
const io = getIO();
const expose = this.configService.get<Auth>('AUTHENTICATION').EXPOSE_IN_FETCH_INSTANCES; const expose = this.configService.get<Auth>('AUTHENTICATION').EXPOSE_IN_FETCH_INSTANCES;
const tokenStore = await this.repository.auth.find(this.instanceName); const tokenStore = await this.repository.auth.find(this.instanceName);
const instanceApikey = tokenStore?.apikey || 'Apikey not found'; const instanceApikey = tokenStore?.apikey || 'Apikey not found';
const io = getIO();
this.logger.verbose('Sending data to socket.io in channel: ' + this.instance.name);
io.of(`/${this.instance.name}`).emit(event, {
event,
instance: this.instance.name,
data,
});
const globalApiKey = this.configService.get<Auth>('AUTHENTICATION').API_KEY.KEY; const globalApiKey = this.configService.get<Auth>('AUTHENTICATION').API_KEY.KEY;
@ -555,12 +562,6 @@ export class WAStartupService {
} }
} }
} }
io.emit(event, {
event,
instance: this.instance.name,
data,
});
} }
private async connectionUpdate({ qr, connection, lastDisconnect }: Partial<ConnectionState>) { private async connectionUpdate({ qr, connection, lastDisconnect }: Partial<ConnectionState>) {