fix tests

Author: Artem

redisinsight/api/test/api/pub-sub/POST-instance-id-pub-sub-messages.test.ts

@@ -9,8 +9,7 @@ import {
   validateInvalidDataTestCase,
   validateApiCall
 } from '../deps';
-import { Socket } from 'socket.io-client';
-const { server, request, constants, rte, getSocket } = deps;
+const { server, request, constants, rte } = deps;
 
 // endpoint to test
 const endpoint = (instanceId = constants.TEST_INSTANCE_ID) =>
@@ -51,19 +50,6 @@ const mainCheckFn = async (testCase) => {
   });
 };
 
-const getClient = async (instanceId): Promise<Socket> => {
-  return getSocket('pub-sub', {
-    query: { instanceId },
-  });
-};
-
-const pSubscription = {
-  channel: '*',
-  type: 'p',
-};
-
-let client;
-
 describe('POST /instance/:instanceId/pub-sub/messages', () => {
   describe('Validation', () => {
     generateInvalidDataTestCases(dataSchema, validInputData).map(
@@ -72,17 +58,6 @@ describe('POST /instance/:instanceId/pub-sub/messages', () => {
   });
 
   describe('Common', () => {
-    beforeEach(async () => {
-      client = await getClient(constants.TEST_INSTANCE_ID);
-      await new Promise((res) => {
-        client.emit('subscribe', { subscriptions: [pSubscription] }, res);
-      });
-    });
-
-    afterEach(async () => {
-      client.close();
-    });
-
     [
       {
         name: 'Should send message',
@@ -91,9 +66,6 @@ describe('POST /instance/:instanceId/pub-sub/messages', () => {
         },
         responseSchema,
         statusCode: 201,
-        responseBody: {
-          affected: 1,
-        },
       },
       {
         name: 'Should return NotFound error if instance id does not exists',

redisinsight/api/test/api/ws/pub-sub/pub-sub.test.ts

@@ -100,6 +100,7 @@ describe('pub-sub', function () {
           expect(ack).to.eql({ status: 'ok' });
 
           client.on('s:channel-a', (data) => {
+            console.log('___data', data);
             expect(data.count).to.be.eql(1);
             expect(data.messages.length).to.be.eql(1);
             const [message] = data.messages;
@@ -113,8 +114,8 @@ describe('pub-sub', function () {
             reject(new Error('Should not receive message-a in this listener-b'))
           });
 
-          await rte.data.executeCommand('publish', 'channel-c', 'message-c');
-          await rte.data.executeCommand('publish', 'channel-a', 'message-a');
+          await rte.data.sendCommand('publish', ['channel-c', 'message-c']);
+          await rte.data.sendCommand('publish', ['channel-a', 'message-a']);
         })
       });
     });