feat(repeater): refrain from utilizing non standard ports

package.json

@@ -86,6 +86,8 @@
     "form-data": "^4.0.0",
     "reflect-metadata": "^0.1.13",
     "semver": "^7.5.2",
+    "socket.io-client": "^4.7.5",
+    "socket.io-msgpack-parser": "^3.0.2",
     "socks-proxy-agent": "^6.2.0-beta.0",
     "tslib": "~2.3.1",
     "tsyringe": "^4.6.0",
@@ -129,6 +131,7 @@
     "nx": "14.5.6",
     "prettier": "2.7.1",
     "semantic-release": "~19.0.3",
+    "socket.io": "^4.7.5",
     "ts-jest": "27.1.4",
     "ts-mockito": "^2.6.1",
     "typescript": "4.7.4"

packages/core/src/logger/Logger.ts

@@ -28,8 +28,12 @@ export class Logger {
     this._logLevel = logLevel;
   }
 
-  public error(message: string, ...args: any[]): void {
-    this.write(message, LogLevel.ERROR, ...args);
+  public error(errorOrMessage: string | Error, ...args: any[]): void {
+    if (typeof errorOrMessage === 'string') {
+      this.write(errorOrMessage, LogLevel.ERROR, ...args);
+    } else {
+      this.write(errorOrMessage.message, LogLevel.ERROR, ...args);
+    }
   }
 
   public warn(message: string, ...args: any[]): void {

packages/repeater/src/api/DefaultRepeatersManager.spec.ts

@@ -1,9 +1,5 @@
 import 'reflect-metadata';
-import {
-  CreateRepeaterRequest,
-  DeleteRepeaterRequest,
-  GetRepeaterRequest
-} from './commands';
+import { CreateRepeaterRequest, DeleteRepeaterRequest } from './commands';
 import { DefaultRepeatersManager } from './DefaultRepeatersManager';
 import { RepeatersManager } from './RepeatersManager';
 import { CommandDispatcher } from '@sectester/core';
@@ -67,32 +63,6 @@ describe('DefaultRepeatersManager', () => {
     });
   });
 
-  describe('getRepeater', () => {
-    it('should return repeater', async () => {
-      const repeaterId = '142';
-      when(
-        mockedCommandDispatcher.execute(anyOfClass(GetRepeaterRequest))
-      ).thenResolve({ id: repeaterId });
-
-      const result = await manager.getRepeater(repeaterId);
-
-      verify(
-        mockedCommandDispatcher.execute(anyOfClass(GetRepeaterRequest))
-      ).once();
-      expect(result).toMatchObject({ repeaterId });
-    });
-
-    it('should throw an error if cannot find repeater', async () => {
-      when(
-        mockedCommandDispatcher.execute(anyOfClass(GetRepeaterRequest))
-      ).thenResolve();
-
-      const act = manager.getRepeater('123');
-
-      await expect(act).rejects.toThrow('Cannot find repeater');
-    });
-  });
-
   describe('deleteRepeater', () => {
     it('should remove repeater', async () => {
       when(

packages/repeater/src/api/DefaultRepeatersManager.ts

@@ -1,9 +1,5 @@
 import { RepeatersManager } from './RepeatersManager';
-import {
-  CreateRepeaterRequest,
-  DeleteRepeaterRequest,
-  GetRepeaterRequest
-} from './commands';
+import { CreateRepeaterRequest, DeleteRepeaterRequest } from './commands';
 import { inject, injectable } from 'tsyringe';
 import { CommandDispatcher } from '@sectester/core';
 
@@ -14,20 +10,6 @@ export class DefaultRepeatersManager implements RepeatersManager {
     private readonly commandDispatcher: CommandDispatcher
   ) {}
 
-  public async getRepeater(
-    repeaterId: string
-  ): Promise<{ repeaterId: string }> {
-    const repeater = await this.commandDispatcher.execute(
-      new GetRepeaterRequest(repeaterId)
-    );
-
-    if (!repeater?.id) {
-      throw new Error('Cannot find repeater');
-    }
-
-    return { repeaterId: repeater.id };
-  }
-
   public async createRepeater({
     projectId,
     ...options

packages/repeater/src/api/ExecuteRequestEventHandler.spec.ts

@@ -1,8 +1,8 @@
 import 'reflect-metadata';
 import { ExecuteRequestEventHandler } from './ExecuteRequestEventHandler';
 import { Protocol } from '../models';
-import { Request, RequestRunner } from '../request-runner';
-import { anything, capture, instance, mock, reset, when } from 'ts-mockito';
+import { RequestRunner } from '../request-runner';
+import { anything, instance, mock, reset, when } from 'ts-mockito';
 
 describe('ExecuteRequestEventHandler', () => {
   const requestRunnerResponse = {
@@ -65,24 +65,5 @@ describe('ExecuteRequestEventHandler', () => {
 
       await expect(res).rejects.toThrow(`Unsupported protocol "http"`);
     });
-
-    it('`correlation_id_regex` should become `correlationIdRegex` in runner input', async () => {
-      const payload = {
-        protocol: Protocol.HTTP,
-        url: 'http://foo.bar/',
-        headers: {},
-        correlation_id_regex: 'baz'
-      };
-      const handler = new ExecuteRequestEventHandler([
-        instance(mockedRequestRunner)
-      ]);
-
-      await handler.handle(payload);
-
-      const [request]: [Request] = capture<Request>(
-        mockedRequestRunner.run
-      ).first();
-      expect(request.correlationIdRegex).toBeInstanceOf(RegExp);
-    });
   });
 });

packages/repeater/src/api/RepeatersManager.ts

@@ -1,6 +1,4 @@
 export interface RepeatersManager {
-  getRepeater(repeaterId: string): Promise<{ repeaterId: string }>;
-
   createRepeater(options: {
     name: string;
     projectId?: string;

packages/repeater/src/api/commands/index.ts

@@ -1,6 +1,5 @@
 export { CreateRepeaterRequest } from './CreateRepeaterRequest';
 export { DeleteRepeaterRequest } from './DeleteRepeaterRequest';
-export { GetRepeaterRequest } from './GetRepeaterRequest';
 export {
   RegisterRepeaterCommand,
   RegisterRepeaterCommandPayload,