iamolegga/nest-nsq-transport

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    return new Promise<void>((resolve, reject) => {
      this.writer
        .on('closed', () => {
          this.logger.debug('NSQ client closed');
          resolve();

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    this.connected = new Promise<void>((resolve, reject) => {
      this.writer
        .on('ready', () => {
          this.logger.debug('NSQ client connected');
          resolve();

• Read up
  Read up

Function handleMessage has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private handleMessage(pattern: NSQPattern) {
    return async (message: Message) => {
      this.handlingMessagesWG.add(1);

      const handler = this.getHandlerByPattern(pattern.toString());

Function metadata has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  get metadata(): ModuleMetadata {
    const wg = this.wg;
    const token = this.clientToken;
    const data = Math.random().toString();

Function metadata has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  get metadata(): ModuleMetadata {
    const wg = this.wg;
    const token = this.clientToken;
    const data = Math.random().toString();

Function metadata has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  get metadata(): ModuleMetadata {
    const wg = this.wg;
    const token = this.clientToken;
    const data = Math.random().toString();

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'should send and receive same data in two channels'() {
    await this.app.get(this.ctrl).emit();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'message goes to same handler when no discard handler'() {
    await this.app.get(this.ctrl).emit2();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'message goes to discard handler'() {
    await this.app.get(this.ctrl).emit1();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'options should be used'() {
    await this.app.get(this.ctrl).emit();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'should send and receive same data'() {
    await this.app.get(this.ctrl).emit();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'context shoud have original message and pattern'() {
    await this.app.get(this.ctrl).emit();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 7 locations. Consider refactoring.

Open

  @test
  async 'should send and receive same data'() {
    await this.app.get(this.ctrl).emit();
    await this.wg.wait();
  }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  @test
  async 'send should throw'() {
    await expect(this.app.get(this.ctrl).emit()).rejects.toBeTruthy();
  }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  @test
  async 'pattern should be only string'() {
    await expect(this.app.get(this.ctrl).emit()).rejects.toBeTruthy();
  }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    reader.on('nsqd_connected', (host, port) =>
      this.logger.log(`${logPrefix} not connected to nsqd ${host}:${port}`),
    );

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

      @EventPattern('topic-mono/channel-mono')
      handle(event: unknown) {
        expect(event).toBe(data);
        wg.done();
      }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    reader.on('nsqd_closed', (host, port) =>
      this.logger.log(`${logPrefix} nsqd closed ${host}:${port}`),
    );

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

      @EventPattern('topic-discard-1/channel-discard-1/discard')
      handleDiscarded1(event: unknown) {
        expect(event).toBe(data);
        wg.done();
      }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

      @EventPattern('topic-multi/channel-multi-1')
      handle1(event: unknown) {
        expect(event).toBe(data);
        wg.done();
      }

• Read up
  Read up