n8n/packages/cli/src/ErrorReporting.ts

import * as Sentry from '@sentry/node';
import { RewriteFrames } from '@sentry/integrations';
import type { Application } from 'express';
import config from '../config';
import { ErrorReporterProxy } from 'n8n-workflow';

let initialized = false;

export const initErrorHandling = (app?: Application) => {
	if (initialized) return;

	if (!config.getEnv('diagnostics.enabled')) {
		initialized = true;
		return;
	}

	const dsn = config.getEnv('diagnostics.config.sentry.dsn');
	const { N8N_VERSION: release, ENVIRONMENT: environment } = process.env;

	Sentry.init({
		dsn,
		release,
		environment,
		integrations: (integrations) => {
			integrations.push(new RewriteFrames({ root: process.cwd() }));
			return integrations;
		},
	});

	if (app) {
		const { requestHandler, errorHandler } = Sentry.Handlers;
		app.use(requestHandler());
		app.use(errorHandler());
	}

	ErrorReporterProxy.init({
		report: (error, options) => Sentry.captureException(error, options),
	});

	initialized = true;
};