lsm/micromono

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

Open

exports.buildServiceFromAnnouncement = function(ann) {
  logger.info('Build remote service from announcement', {
    service: ann.name,
    version: ann.version
  }).trace(ann)

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

Open

exports.getAssetInfo = function(packagePath, packageJSON, serviceName) {
  serviceName = serviceName || ''

  var assetInfo
  var publicURL

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

Open

exports.listen = function(options, callback) {
  var port = options.MICROMONO_DISCOVERY_UDP_PORT || PORT
  var address = options.MICROMONO_DISCOVERY_UDP_ADDRESS || ADDRESS

  logger.info('Listening service annoucements using udp multicast', {

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

Open

  function checkAvailability() {
    var now = Date.now()
    remoteServices.forEach(function(service) {
      var scheduler = service.scheduler
      scheduler.each(function(ann) {

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

Open

  var chnAllowHook = Superpipe.pipeline()
    .pipe(prepareChnPipeline, 3, ['chn', 'meta', 'event', 'parentNext'])
    .pipe(channel.auth, ['meta', 'next'], ['session', 'ssn'])
    .pipe(requireSession, ['session', 'next'])
    .pipe(channel.allow, ['session', 'chn', 'event', 'next'])

• Read up
  Read up

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

Open

  var chnJoinHook = Superpipe.pipeline()
    .pipe(prepareChnPipeline, 3, ['chn', 'meta', 'event', 'parentNext'])
    .pipe(channel.auth, ['meta', 'next'], ['session', 'ssn'])
    .pipe(requireSession, ['session', 'next'])
    .pipe(channel.join, ['session', 'chn', 'next'], ['repEvents', 'subEvents'])

• Read up
  Read up

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

Open

  micromono
    .set(AssetPipe, '*^')
    .set(LocalPipe, '*^')
    .set(HealthPipe, '*^')
    .set(RemotePipe, '*^')

• Read up
  Read up

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

Open

  micromono
    .set(Router, '*^')
    .set(AssetPipe, '*^')
    .set(LocalPipe, '*^')
    .set(HealthPipe, '*^')

• Read up
  Read up

Function useMiddleware has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

ExpressAdapter.prototype.useMiddleware = function(url, middleware, routes, service) {
  if (!Array.isArray(url))
    url = [url]

  var app = this.app

Function mergeAssetDependencies has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.mergeAssetDependencies = function(dstAssetInfo, srcAssetInfo) {
  var assetDependenciesChanged = undefined

  if (srcAssetInfo.dependencies) {
    var srcDeps = srcAssetInfo.dependencies

Function createChannelAdapters has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.createChannelAdapters = function(channels, service) {
  logger.debug('createChannelAdapters', {
    service: service.name
  }).trace(channels)

Function announce has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.announce = function(data, options, interval) {
  options = assign({}, NATS_DEFAULT_OPTIONS, options)
  interval = interval || options.MICROMONO_DISCOVERY_ANNOUNCE_INTERVAL || 3000

  logger.info('Announcing service using nats pubsub', {

Function getJSPMConfig has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.getJSPMConfig = function(assetInfo, publicPath, next) {
  var configPath = path.join(publicPath, 'config.js')

  logger.debug('getJSPMConfig', {
    configPath: configPath

Function setDefaultChannelHandlers has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.setDefaultChannelHandlers = function(channel) {
  if (!channel.auth) {
    logger.warn('Please define `auth` property in channel to set your own auth handler function. All requests will be allowed by default.')
    channel.auth = function(session, next) {
      next()

Function localRequire has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.localRequire = function(serviceName, serviceDir, services) {
  var ServiceClass
  var servicePath = serviceName

  try {

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

Open

SocketMQAdapter.prototype.connect = function(provider) {
  var self = this
  var adapter = this.adapter
  var name = provider.name
  var endpoint = 'tcp://' + provider.host + ':' + provider.api.port

Function MicromonoRPC has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

var RPC = module.exports = function MicromonoRPC(options) {
  logger.info('Initialize MicromonoRPC', {
    type: options.type,
    isRemote: options.isRemote
  }).trace(options)

Function startChnBackendServer has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.startChnBackendServer = function(channels, chnBackend, chnEndpoint, next) {
  logger.debug('startChnBackendServer').trace({
    chnEndpoint: chnEndpoint,
    channels
  })

Function attachChannelHooks has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

exports.attachChannelHooks = function(chnAdapter, channel, chnJoinHook, chnAllowHook) {
  logger.debug('attachChannelHooks').trace(channel)

  var allowHook = function(pack, stream, dispatch) {
    if (REQ === pack.type) {

Function attachRoutes has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

ExpressAdapter.prototype.attachRoutes = function(routes, service) {
  var app = this.app

  Object.keys(routes).forEach(function(routeName) {
    var route = routes[routeName]