amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(e2e): fix e2e tests

Browse Source
This commit is contained in:
Kamil Myśliwiec
2020-12-08 17:21:13 +01:00
parent 9c8cf3978a
commit a0ded7ad68
6 changed files with 14 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
integration/hooks/src/enable-shutdown-hooks-main.ts
View File

@@ -26,7 +26,7 @@ class TestInjectable
class AppModule {}
async function bootstrap() {
const app = await NestFactory.create(AppModule, { logger: true });
const app = await NestFactory.create(AppModule, { logger: false });
if (SIGNAL_TO_LISTEN && SIGNAL_TO_LISTEN !== 'NONE') {
app.enableShutdownHooks([SIGNAL_TO_LISTEN]);

7
integration/microservices/e2e/concurrent-kafka.spec.ts
View File

@@ -6,7 +6,6 @@ import * as request from 'supertest';
import * as util from 'util';
import { KafkaConcurrentController } from '../src/kafka-concurrent/kafka-concurrent.controller';
import { KafkaConcurrentMessagesController } from '../src/kafka-concurrent/kafka-concurrent.messages.controller';
import { Test } from '@nestjs/testing';
describe('Kafka concurrent', function () {
const numbersOfServers = 3;
@@ -154,7 +153,7 @@ describe('Kafka concurrent', function () {
// return startServer();
// wait in intervals so the consumers start in order
return new Promise(resolve => {
return new Promise<void>(resolve => {
setTimeout(async () => {
await startServer();
@@ -200,7 +199,7 @@ describe('Kafka concurrent', function () {
servers.map(async (server, index) => {
// shut off and delete the leader
if (index === 0) {
return new Promise(resolve => {
return new Promise<void>(resolve => {
// wait a second before closing so the producers can send the message to the server consumers
setTimeout(async () => {
// get the controller
@@ -243,7 +242,7 @@ describe('Kafka concurrent', function () {
servers.map(async (server, index) => {
// shut off and delete the leader
if (index === 0) {
return new Promise(resolve => {
return new Promise<void>(resolve => {
// wait a second before closing so the producers can send the message to the server consumers
setTimeout(async () => {
// get the controller

2
integration/websockets/e2e/error-gateway.spec.ts
View File

@@ -20,7 +20,7 @@ describe('ErrorGateway', () => {
ws.emit('push', {
test: 'test',
});
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('exception', data => {
expect(data).to.be.eql({
status: 'error',

4
integration/websockets/e2e/gateway-ack.spec.ts
View File

@@ -20,7 +20,7 @@ describe('WebSocketGateway (ack)', () => {
await app.listenAsync(3000);
ws = io.connect('http://localhost:8080');
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.emit('push', { test: 'test' }, data => {
expect(data).to.be.eql('pong');
resolve();
@@ -33,7 +33,7 @@ describe('WebSocketGateway (ack)', () => {
await app.listenAsync(3000);
ws = io.connect('http://localhost:8080');
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.emit('push', data => {
expect(data).to.be.eql('pong');
resolve();

6
integration/websockets/e2e/gateway.spec.ts
View File

@@ -25,7 +25,7 @@ describe('WebSocketGateway', () => {
ws.emit('push', {
test: 'test',
});
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('pop', data => {
expect(data.test).to.be.eql('test');
resolve();
@@ -41,7 +41,7 @@ describe('WebSocketGateway', () => {
ws.emit('push', {
test: 'test',
});
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('pop', data => {
expect(data.test).to.be.eql('test');
resolve();
@@ -58,7 +58,7 @@ describe('WebSocketGateway', () => {
ws.emit('push', {
test: 'test',
});
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('pop', data => {
expect(data.test).to.be.eql('test');
resolve();

8
integration/websockets/e2e/ws-gateway.spec.ts
View File

@@ -34,7 +34,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
},
}),
);
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('message', data => {
expect(JSON.parse(data).data.test).to.be.eql('test');
resolve();
@@ -57,7 +57,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
},
}),
);
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('message', data => {
expect(JSON.parse(data).data.test).to.be.eql('test');
resolve();
@@ -77,7 +77,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
ws = new WebSocket('ws://localhost:8080');
ws2 = new WebSocket('ws://localhost:8090');
await new Promise(resolve =>
await new Promise<void>(resolve =>
ws.on('open', () => {
ws.on('message', data => {
expect(JSON.parse(data).data.test).to.be.eql('test');
@@ -94,7 +94,7 @@ describe('WebSocketGateway (WsAdapter)', () => {
}),
);
await new Promise(resolve => {
await new Promise<void>(resolve => {
ws2.on('message', data => {
expect(JSON.parse(data).data.test).to.be.eql('test');
resolve();