socket.io, nestjs soap
This commit is contained in:
@@ -0,0 +1,18 @@
|
||||
import { Test, TestingModule } from '@nestjs/testing';
|
||||
import { AppGateway } from './app.gateway';
|
||||
|
||||
describe('AppGateway', () => {
|
||||
let gateway: AppGateway;
|
||||
|
||||
beforeEach(async () => {
|
||||
const module: TestingModule = await Test.createTestingModule({
|
||||
providers: [AppGateway],
|
||||
}).compile();
|
||||
|
||||
gateway = module.get<AppGateway>(AppGateway);
|
||||
});
|
||||
|
||||
it('should be defined', () => {
|
||||
expect(gateway).toBeDefined();
|
||||
});
|
||||
});
|
||||
@@ -0,0 +1,39 @@
|
||||
import {
|
||||
SubscribeMessage,
|
||||
WebSocketGateway,
|
||||
OnGatewayInit,
|
||||
WebSocketServer,
|
||||
OnGatewayConnection,
|
||||
OnGatewayDisconnect,
|
||||
} from '@nestjs/websockets';
|
||||
import { Logger } from '@nestjs/common';
|
||||
import { Socket, Server } from 'socket.io';
|
||||
|
||||
@WebSocketGateway({
|
||||
cors: {
|
||||
origin: '*',
|
||||
},
|
||||
})
|
||||
export class AppGateway
|
||||
implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect
|
||||
{
|
||||
@WebSocketServer() server: Server;
|
||||
private logger: Logger = new Logger('AppGateway');
|
||||
|
||||
// @SubscribeMessage('msgToServer')
|
||||
// handleMessage(client: Socket, payload: string): void {
|
||||
// this.server.emit('msgToClient', payload);
|
||||
// }
|
||||
|
||||
afterInit(server: Server) {
|
||||
this.logger.log('Init');
|
||||
}
|
||||
|
||||
handleDisconnect(client: Socket) {
|
||||
this.logger.log(`Client disconnected: ${client.id}`);
|
||||
}
|
||||
|
||||
handleConnection(client: Socket, ...args: any[]) {
|
||||
this.logger.log(`Client connected: ${client.id}`);
|
||||
}
|
||||
}
|
||||
@@ -1,6 +1,7 @@
|
||||
import { Module } from '@nestjs/common';
|
||||
import { ConfigModule, ConfigService } from '@nestjs/config';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { AppGateway } from './app.gateway';
|
||||
|
||||
import { AuthModule } from './auth/auth.module';
|
||||
import { BcryptModule } from './bcrypt/bcrypt.module';
|
||||
@@ -124,5 +125,6 @@ import { Usuario } from './usuario/entity/usuario.entity';
|
||||
UploadFileModule,
|
||||
UsuarioModule,
|
||||
],
|
||||
providers: [AppGateway],
|
||||
})
|
||||
export class AppModule {}
|
||||
|
||||
Reference in New Issue
Block a user