test(): add retries to unit and integration tests

Author: kamilmysliwiec

integration/microservices/e2e/sum-mqtt.spec.ts

@@ -46,7 +46,8 @@ describe('MQTT transport', () => {
       .expect(200, '15');
   });
 
-  it(`/POST (concurrent)`, () => {
+  it(`/POST (concurrent)`, function() {
+    this.retries(10);
     return request(server)
       .post('/concurrent')
       .send([

integration/microservices/e2e/sum-redis.spec.ts

@@ -46,8 +46,9 @@ describe('REDIS transport', () => {
       .expect(200, '15');
   });
 
-  /* CI/CD issues
-  it(`/POST (concurrent)`, () => {
+  it(`/POST (concurrent)`, function() {
+    this.retries(10);
+
     return request(server)
       .post('/concurrent')
       .send([
@@ -63,7 +64,7 @@ describe('REDIS transport', () => {
         Array.from({ length: 10 }, (v, k) => k + 91),
       ])
       .expect(200, 'true');
-  }).timeout(5000); */
+  }).timeout(5000);
 
   it(`/POST (streaming)`, () => {
     return request(server)

integration/websockets/e2e/ws-gateway.spec.ts

@@ -17,7 +17,6 @@ async function createNestApp(...gateways): Promise<INestApplication> {
 }
 
 describe('WebSocketGateway (WsAdapter)', () => {
-  const event = 'push';
   let ws, ws2, app;
 
   it(`should handle message (2nd port)`, async () => {
@@ -66,7 +65,9 @@ describe('WebSocketGateway (WsAdapter)', () => {
     );
   });
 
-  it(`should support 2 different gateways`, async () => {
+  it(`should support 2 different gateways`, async function() {
+    this.retries(10);
+
     app = await createNestApp(ApplicationGateway, CoreGateway);
     await app.listenAsync(3000);
 

packages/core/test/middleware/middlewares-module.spec.ts

@@ -81,6 +81,10 @@ describe('MiddlewareModule', () => {
       const useSpy = sinon.spy();
       const app = { use: useSpy };
 
+      const nestContainer = new NestContainer();
+      // tslint:disable-next-line:no-string-literal
+      middlewareModule['container'] = nestContainer;
+
       expect(
         middlewareModule.registerRouteMiddleware(
           new MiddlewareContainer(),

packages/microservices/test/client/client-proxy.spec.ts

@@ -18,7 +18,9 @@ class TestClientProxy extends ClientProxy {
   public async close() {}
 }
 
-describe('ClientProxy', () => {
+describe('ClientProxy', function() {
+  this.retries(10);
+
   let client: TestClientProxy;
   beforeEach(() => {
     client = new TestClientProxy();