startup-log.js

'use strict'

const os = require('os')
const { inspect } = require('util')
const tracerVersion = require('../../../package.json').version
const { getAgentUrl } = require('./agent/url')
const { warn } = require('./log/writer')

const errors = {}
let config
let pluginManager
/** @type {import('./sampling_rule')[]} */
let samplingRules = []
let startupLogRan = false
let agentErrorLogged = false

/**
 * Logs the tracer configuration on startup
 */
function startupLog () {
  if (startupLogRan || !config || !config.startupLogs || !pluginManager) {
    return
  }

  startupLogRan = true

  const out = tracerInfo()
  warn('DATADOG TRACER CONFIGURATION - ' + out)
}

/**
 * Logs a diagnostic error when the agent connection fails
 * @param {{ status: number, message: string }} agentError
 */
function logAgentError (agentError) {
  if (agentErrorLogged || !config || !config.startupLogs) {
    return
  }

  agentErrorLogged = true

  warn('DATADOG TRACER DIAGNOSTIC - Agent Error: ' + agentError.message)
  errors.agentError = {
    code: agentError.status,
    message: `Agent Error: ${agentError.message}`,
  }
}

/**
 * @returns {Record<string, unknown>}
 */
function tracerInfo () {
  const url = getAgentUrl(config)

  const out = {
    [inspect.custom] () {
      return String(this)
    },
    toString () {
      return JSON.stringify(this, (_key_, value) => {
        return typeof value === 'bigint' || typeof value === 'symbol' ? String(value) : value
      })
    },
    date: new Date().toISOString(),
    os_name: os.type(),
    os_version: os.release(),
    architecture: os.arch(),
    version: tracerVersion,
    lang: 'nodejs',
    lang_version: process.versions.node,
    env: config.env,
    enabled: config.enabled,
    service: config.service,
    agent_url: url,
    debug: !!config.debug,
    sample_rate: config.sampler.sampleRate,
    sampling_rules: samplingRules,
    tags: config.tags,
    ...(config.tags && config.tags.version && { dd_version: config.tags.version }),
    log_injection_enabled: !!config.logInjection,
    runtime_metrics_enabled: !!config.runtimeMetrics,
    profiling_enabled: config.profiling?.enabled === 'true' || config.profiling?.enabled === 'auto',
    integrations_loaded: Object.keys(pluginManager._pluginsByName),
    appsec_enabled: !!config.appsec.enabled,
    data_streams_enabled: !!config.dsmEnabled,
  }

  return out
}

/**
 * @param {import('./config')} aConfig
 */
function setStartupLogConfig (aConfig) {
  config = aConfig
}

/**
 * @param {import('./plugin_manager')} thePluginManager
 */
function setStartupLogPluginManager (thePluginManager) {
  pluginManager = thePluginManager
}

/**
 * @param {import('./sampling_rule')[]} theRules
 */
function setSamplingRules (theRules) {
  samplingRules = theRules
}

module.exports = {
  startupLog,
  logAgentError,
  setStartupLogConfig,
  setStartupLogPluginManager,
  setSamplingRules,
  tracerInfo,
  errors,
}