Runnable/ponos

File rabbitmq.js has 496 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/* @flow */
/* global Bluebird$Promise RabbitMQChannel RabbitMQConfirmChannel RabbitMQConnection SubscribeObject RabbitMQOptions QueueObject */
'use strict'

const amqplib = require('amqplib')

RabbitMQ has 27 functions (exceeds 20 allowed). Consider refactoring.

Open

class RabbitMQ {
  static AMQPLIB_QUEUE_DEFAULTS: Object;
  static AMQPLIB_EXCHANGE_DEFAULTS: Object;

  channel: RabbitMQChannel;

Function connect has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  connect (): Bluebird$Promise<void> {
    if (this._isPartlyConnected() || this._isConnected()) {
      return Promise.reject(new Error('cannot call connect twice'))
    }
    let authString = ''

Function _subscribeToExchange has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  _subscribeToExchange (opts: SubscribeObject): Bluebird$Promise<void> {
    const log = this.log.child({
      method: '_subscribeToExchange',
      opts: opts
    })

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

Open

  consume (): Bluebird$Promise<void> {
    const log = this.log.child({ method: 'consume' })
    log.info('starting to consume')
    if (!this._isConnected()) {
      return Promise.reject(new Error('you must .connect() before consuming'))

XXX found

Open

      // XXX(bryan): is this valid? should I not be checking _this_.consuming?

• Exclude checks
  • Disable engine
  • Disable check

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

Open

  publishToExchange (
    exchange: string,
    routingKey: string,
    content: Object
  ): Bluebird$Promise<void> {

• Read up
  Read up

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

Open

  publishToQueue (queue: string, content: Object): Bluebird$Promise<void> {
    return Promise.try(() => {
      this.log.warn({
        method: 'publishToQueue',
        queue

• Read up
  Read up

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

Open

        return Promise.resolve(this.connection.createConfirmChannel())
          .catch((err) => {
            this.log.fatal({ err: err }, 'errored creating confirm channel')
            throw err
          })

• Read up
  Read up

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

Open

        return Promise.resolve(this.connection.createChannel())
          .catch((err) => {
            this.log.fatal({ err: err }, 'an error occured creating channel')
            throw err
          })

• Read up
  Read up

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

Open

    if (opts.type === 'topic' && opts.routingKey) {
      queueName = `${queueName}.${opts.routingKey}`
    }

• Read up
  Read up

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

Open

    if (opts.type === 'topic' && opts.routingKey) {
      subscribedKey = `${subscribedKey}:::${opts.routingKey}`
    }

• Read up
  Read up