feat: add socket launcher

.eslintrc.js

@@ -27,6 +27,7 @@ module.exports = {
     '@typescript-eslint/no-unsafe-return': 'off',
     '@typescript-eslint/consistent-type-imports': 'off',
     'no-await-in-loop': 'off',
+    'unicorn/no-nested-ternary': 'off',
     'prettier/prettier': [
       'error',
       {

__tests__/helpers/launchers-test.ts

@@ -1,4 +1,4 @@
-import { Gateway, Microservice } from '@lomray/microservice-nodejs-lib';
+import { Gateway, Microservice, Socket } from '@lomray/microservice-nodejs-lib';
 import type { IMiddlewareRepository } from '@lomray/microservice-remote-middleware';
 import {
   RemoteMiddlewareClient,
@@ -8,20 +8,15 @@ import { expect } from 'chai';
 import rewiremock from 'rewiremock';
 import sinon from 'sinon';
 import type { ConnectionOptions } from 'typeorm';
-import type {
-  start as OriginalStart,
-  startWithDb as OriginalStartWithDb,
-  run as OriginalRun,
-} from '@helpers/launchers';
+import type { start as OriginalStart, run as OriginalRun } from '@helpers/launchers';
 import { TypeormMock } from '@mocks/index';
 import Jobs from '@services/jobs';
 import Log from '@services/log';
 import RemoteConfig from '@services/remote-config';
 import waitResult from '@test-helpers/wait-result';
 
 const CreateDbConnection = sinon.stub().resolves();
-const { start, startWithDb, run } = rewiremock.proxy<{
-  startWithDb: typeof OriginalStartWithDb;
+const { start, run } = rewiremock.proxy<{
   start: typeof OriginalStart;
   run: typeof OriginalRun;
 }>(() => require('@helpers/launchers'), {
@@ -69,7 +64,7 @@ describe('helpers/launchers', () => {
         return rmMiddleware;
       });
 
-    await startWithDb({
+    await run({
       type: 'microservice',
       msOptions,
       msParams,
@@ -247,4 +242,28 @@ describe('helpers/launchers', () => {
 
     expect(CreateDbConnection).to.calledOnce;
   });
+
+  it('should correctly run microservice with socket', async () => {
+    const spyCreate = sandbox.spy(Socket, 'create');
+    const registerRoomsStub = sandbox.stub();
+    let stubbedStart;
+
+    await run({
+      type: 'socket',
+      msOptions,
+      msParams,
+      registerRooms: registerRoomsStub,
+      remoteMiddleware: { isEnable: false, type: 'client' },
+      remoteConfig: { isDisable: true },
+      hooks: {
+        afterCreateMicroservice: (microservice) => {
+          stubbedStart = sandbox.stub(microservice, 'start').resolves();
+        },
+      },
+    });
+
+    expect(stubbedStart).to.calledOnce;
+    expect(spyCreate).to.calledOnce;
+    expect(registerRoomsStub).to.calledOnceWith(Socket.getInstance());
+  });
 });