File consumer-stream.ts has 379 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import { Readable } from 'stream'
import { strict as assert } from 'assert'
import { once } from 'events'
import { uniqWith, isEqual } from 'lodash'
import { promisify, delay } from 'bluebird'

Function addRoute has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

  public addRoute(route: string, handler: ServiceAction): void {
    const { routes, config } = this
    let name: string = route

    if (config !== undefined) {

• Read up
  Read up

Function attachConsulPlugin has 94 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export const attach = async function attachConsulPlugin(
  this: Microfleet,
  opts: Partial<ConsulConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('logger'), new NotFoundError('log module must be included'))

Function auditLogFactory has a Cognitive Complexity of 21 (exceeds 5 allowed). Consider refactoring.

Open

export default function auditLogFactory(params: AuditLogExtensionParams = {}): LifecycleExtensions {
  const { getErrorLevel } = params
  const disableLogErrorsForNames: string[] = params.disableLogErrorsForNames || []

  return [

• Read up
  Read up

File index.ts has 285 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import type * as ns from '@microfleet/core-types'
import type { PartialDeep } from 'type-fest'

/**
 * Microservice Abstract Class

Function performMigration has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

export async function performMigration(redis: Redis.Redis | Redis.Cluster, service: Microfleet, scripts: unknown): Promise<boolean> {
  let files: Migration[]
  if (typeof scripts === 'string') {
    debug('looking for files in %s', scripts)
    files = await glob('*{.js,/}', { cwd: scripts, withFileTypes: true })

• Read up
  Read up

Function attach has 67 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  options: Partial<HapiPluginConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('validator'), 'validator plugin must be included')

Function attach has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

export async function attach(this: Microfleet, opts: Partial<LoggerConfig> = {}): Promise<PluginInterface> {
  const { version, config: { name: applicationName } } = this

  assert(this.hasPlugin('validator'), new NotFoundError('validator module must be included'))
  await this.validator.addLocation(resolve(__dirname, '../schemas'))

• Read up
  Read up

KafkaConsumerStream has 23 functions (exceeds 20 allowed). Consider refactoring.

Open

export class KafkaConsumerStream extends Readable {
  private static trackingKey(topicPart: Assignment): string {
    return `${topicPart.topic}_${topicPart.partition}`
  }

Function attach has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function attach(this: Microfleet, opts: Partial<LoggerConfig> = {}): Promise<PluginInterface> {
  const { version, config: { name: applicationName } } = this

  assert(this.hasPlugin('validator'), new NotFoundError('validator module must be included'))
  await this.validator.addLocation(resolve(__dirname, '../schemas'))

Function attach has 59 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  options: Partial<RouterAMQPPluginConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('logger'), new NotFoundError('log module must be included'))

Microfleet has 22 functions (exceeds 20 allowed). Consider refactoring.

Open

export class Microfleet extends EventEmitter {
  public static readonly version: string = getVersion()

  public config: ns.CoreOptions
  public readonly version: string

Function onCompleteRetry has 58 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  return async function onCompleteRetry(
    this: Microfleet, err: any, data: any, actionName: string, message: Message
  ): Promise<any> {
    const { properties } = message
    const { headers = Object.create(null) } = properties

Function attach has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  options: Partial<RouterAMQPPluginConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('logger'), new NotFoundError('log module must be included'))

• Read up
  Read up

Function attach has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  opts: ValidatorConfig,
  parentFile: string
): Promise<void> {

• Read up
  Read up

Function attach has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  options: Partial<HapiPluginConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('validator'), 'validator plugin must be included')

• Read up
  Read up

Function performMigration has 51 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function performMigration(redis: Redis.Redis | Redis.Cluster, service: Microfleet, scripts: unknown): Promise<boolean> {
  let files: Migration[]
  if (typeof scripts === 'string') {
    debug('looking for files in %s', scripts)
    files = await glob('*{.js,/}', { cwd: scripts, withFileTypes: true })

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

Open

function getAMQPRouterAdapter(
  service: Microfleet,
  config: RouterAMQPPluginConfig,
  onComplete?: (this: Microfleet, err: Error | null | undefined, data: any, actionName: string, raw: Message) => Promise<any>
): MessageConsumer {

Function attach has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function attach(
  this: Microfleet,
  opts: Partial<Config> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('logger'), new NotFoundError('logger module must be included'))

Function attachConsulPlugin has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

export const attach = async function attachConsulPlugin(
  this: Microfleet,
  opts: Partial<ConsulConfig> = {}
): Promise<PluginInterface> {
  assert(this.hasPlugin('logger'), new NotFoundError('log module must be included'))

• Read up
  Read up