weseek__growi/apps/app/src/features/opentelemetry/server/node-sdk-configuration.ts

import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';
import { OTLPMetricExporter } from '@opentelemetry/exporter-metrics-otlp-grpc';
import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-grpc';
import type { Resource } from '@opentelemetry/resources';
import { resourceFromAttributes } from '@opentelemetry/resources';
import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics';
import type { NodeSDKConfiguration } from '@opentelemetry/sdk-node';
import {
  ATTR_SERVICE_NAME,
  ATTR_SERVICE_VERSION,
} from '@opentelemetry/semantic-conventions';

import { configManager } from '~/server/service/config-manager';
import { getGrowiVersion } from '~/utils/growi-version';

import { httpInstrumentationConfig as httpInstrumentationConfigForAnonymize } from './anonymization';
import { ATTR_SERVICE_INSTANCE_ID } from './semconv';

type Option = {
  enableAnonymization?: boolean;
};

type Configuration = Partial<NodeSDKConfiguration> & {
  resource: Resource;
};

let resource: Resource;
let configuration: Configuration;

export const generateNodeSDKConfiguration = (opts?: Option): Configuration => {
  if (configuration == null) {
    const version = getGrowiVersion();

    resource = resourceFromAttributes({
      [ATTR_SERVICE_NAME]: 'growi',
      [ATTR_SERVICE_VERSION]: version,
    });

    // Data anonymization configuration
    const httpInstrumentationConfig = opts?.enableAnonymization
      ? httpInstrumentationConfigForAnonymize
      : {};

    configuration = {
      resource,
      traceExporter: new OTLPTraceExporter(),
      metricReader: new PeriodicExportingMetricReader({
        exporter: new OTLPMetricExporter(),
        exportIntervalMillis: 300000, // 5 minute
      }),
      instrumentations: [
        getNodeAutoInstrumentations({
          '@opentelemetry/instrumentation-bunyan': {
            enabled: false,
          },
          // disable fs instrumentation since this generates very large amount of traces
          // see: https://opentelemetry.io/docs/languages/js/libraries/#registration
          '@opentelemetry/instrumentation-fs': {
            enabled: false,
          },
          // HTTP instrumentation with anonymization
          '@opentelemetry/instrumentation-http': {
            enabled: true,
            ...httpInstrumentationConfig,
          },
        }),
      ],
    };
  }

  return configuration;
};

/**
 * Generate additional attributes after database initialization
 * This function should be called after database is available
 */
export const generateAdditionalResourceAttributes = async (
  _opts?: Option,
): Promise<Resource> => {
  if (resource == null) {
    throw new Error(
      'Resource is not initialized. Call generateNodeSDKConfiguration first.',
    );
  }

  const serviceInstanceId =
    configManager.getConfig('otel:serviceInstanceId') ??
    configManager.getConfig('app:serviceInstanceId');

  const { getApplicationResourceAttributes, getOsResourceAttributes } =
    await import('./custom-resource-attributes');

  return resource.merge(
    resourceFromAttributes({
      [ATTR_SERVICE_INSTANCE_ID]: serviceInstanceId,
      ...(await getApplicationResourceAttributes()),
      ...(await getOsResourceAttributes()),
    }),
  );
};