const LEVELS = {
  NOTHING: 0,
  ERROR: 1,
  WARN: 2,
  INFO: 4,
  DEBUG: 5,
}

const createLevel = (label, level, currentLevel, namespace, loggerFunction) => (
  message,
  extra = {}
) => {
  if (level > currentLevel) return
  loggerFunction(
    namespace,
    Object.assign(
      {
        level: label,
        timestamp: new Date().toISOString(),
        message,
      },
      extra
    )
  )
}

const createLogger = ({ level = LEVELS.INFO, logFunction = null } = {}) => {
  const logLevel = parseInt(process.env.LOG_LEVEL, 10) || level
  const createLogFunctions = namespace => ({
    info: createLevel('INFO', LEVELS.INFO, logLevel, namespace, logFunction),
    error: createLevel('ERROR', LEVELS.ERROR, logLevel, namespace, logFunction),
    warn: createLevel('WARN', LEVELS.WARN, logLevel, namespace, logFunction),
    debug: createLevel('DEBUG', LEVELS.DEBUG, logLevel, namespace, logFunction),
  })

  return Object.assign(createLogFunctions(), {
    namespace: namespace => createLogFunctions(namespace),
  })
}

module.exports = {
  LEVELS,
  createLogger,
}

const LEVELS = {
  NOTHING: 0,
  ERROR: 1,
  WARN: 2,
  INFO: 4,
  DEBUG: 5,
}

const createLevel = (label, level, currentLevel, namespace, loggerFunction) => (
  message,
  extra = {}
) => {
  if (level > currentLevel) return
  loggerFunction(
    namespace,
    Object.assign(
      {
        level: label,
        timestamp: new Date().toISOString(),
        logger: 'kafkajs',
        message,
      },
      extra
    )
  )
}

const createLogger = ({ level = LEVELS.INFO, logFunction = null } = {}) => {
  const logLevel = parseInt(process.env.LOG_LEVEL, 10) || level
  const createLogFunctions = namespace => ({
    info: createLevel('INFO', LEVELS.INFO, logLevel, namespace, logFunction),
    error: createLevel('ERROR', LEVELS.ERROR, logLevel, namespace, logFunction),
    warn: createLevel('WARN', LEVELS.WARN, logLevel, namespace, logFunction),
    debug: createLevel('DEBUG', LEVELS.DEBUG, logLevel, namespace, logFunction),
  })

  return Object.assign(createLogFunctions(), {
    namespace: namespace => createLogFunctions(namespace),
  })
}

module.exports = {
  LEVELS,
  createLogger,
}

Add logger kafkajs to log lines
Add logger kafkajs to log lines
