mirror of
https://github.com/czlonkowski/n8n-mcp.git
synced 2026-01-30 06:22:04 +00:00
289 lines
12 KiB
JavaScript
289 lines
12 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.TelemetryConfigManager = void 0;
|
|
const fs_1 = require("fs");
|
|
const path_1 = require("path");
|
|
const os_1 = require("os");
|
|
const crypto_1 = require("crypto");
|
|
const os_2 = require("os");
|
|
class TelemetryConfigManager {
|
|
constructor() {
|
|
this.config = null;
|
|
this.configDir = (0, path_1.join)((0, os_1.homedir)(), '.n8n-mcp');
|
|
this.configPath = (0, path_1.join)(this.configDir, 'telemetry.json');
|
|
}
|
|
static getInstance() {
|
|
if (!TelemetryConfigManager.instance) {
|
|
TelemetryConfigManager.instance = new TelemetryConfigManager();
|
|
}
|
|
return TelemetryConfigManager.instance;
|
|
}
|
|
generateUserId() {
|
|
if (process.env.IS_DOCKER === 'true' || this.isCloudEnvironment()) {
|
|
return this.generateDockerStableId();
|
|
}
|
|
const machineId = `${(0, os_2.hostname)()}-${(0, os_2.platform)()}-${(0, os_2.arch)()}-${(0, os_1.homedir)()}`;
|
|
return (0, crypto_1.createHash)('sha256').update(machineId).digest('hex').substring(0, 16);
|
|
}
|
|
generateDockerStableId() {
|
|
const bootId = this.readBootId();
|
|
if (bootId) {
|
|
const fingerprint = `${bootId}-${(0, os_2.platform)()}-${(0, os_2.arch)()}`;
|
|
return (0, crypto_1.createHash)('sha256').update(fingerprint).digest('hex').substring(0, 16);
|
|
}
|
|
const combinedFingerprint = this.generateCombinedFingerprint();
|
|
if (combinedFingerprint) {
|
|
return combinedFingerprint;
|
|
}
|
|
const genericId = `docker-${(0, os_2.platform)()}-${(0, os_2.arch)()}`;
|
|
return (0, crypto_1.createHash)('sha256').update(genericId).digest('hex').substring(0, 16);
|
|
}
|
|
readBootId() {
|
|
try {
|
|
const bootIdPath = '/proc/sys/kernel/random/boot_id';
|
|
if (!(0, fs_1.existsSync)(bootIdPath)) {
|
|
return null;
|
|
}
|
|
const bootId = (0, fs_1.readFileSync)(bootIdPath, 'utf-8').trim();
|
|
const uuidRegex = /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i;
|
|
if (!uuidRegex.test(bootId)) {
|
|
return null;
|
|
}
|
|
return bootId;
|
|
}
|
|
catch (error) {
|
|
return null;
|
|
}
|
|
}
|
|
generateCombinedFingerprint() {
|
|
try {
|
|
const signals = [];
|
|
if ((0, fs_1.existsSync)('/proc/cpuinfo')) {
|
|
const cpuinfo = (0, fs_1.readFileSync)('/proc/cpuinfo', 'utf-8');
|
|
const cores = (cpuinfo.match(/processor\s*:/g) || []).length;
|
|
if (cores > 0) {
|
|
signals.push(`cores:${cores}`);
|
|
}
|
|
}
|
|
if ((0, fs_1.existsSync)('/proc/meminfo')) {
|
|
const meminfo = (0, fs_1.readFileSync)('/proc/meminfo', 'utf-8');
|
|
const totalMatch = meminfo.match(/MemTotal:\s+(\d+)/);
|
|
if (totalMatch) {
|
|
signals.push(`mem:${totalMatch[1]}`);
|
|
}
|
|
}
|
|
if ((0, fs_1.existsSync)('/proc/version')) {
|
|
const version = (0, fs_1.readFileSync)('/proc/version', 'utf-8');
|
|
const kernelMatch = version.match(/Linux version ([\d.]+)/);
|
|
if (kernelMatch) {
|
|
signals.push(`kernel:${kernelMatch[1]}`);
|
|
}
|
|
}
|
|
signals.push((0, os_2.platform)(), (0, os_2.arch)());
|
|
if (signals.length < 3) {
|
|
return null;
|
|
}
|
|
const fingerprint = signals.join('-');
|
|
return (0, crypto_1.createHash)('sha256').update(fingerprint).digest('hex').substring(0, 16);
|
|
}
|
|
catch (error) {
|
|
return null;
|
|
}
|
|
}
|
|
isCloudEnvironment() {
|
|
return !!(process.env.RAILWAY_ENVIRONMENT ||
|
|
process.env.RENDER ||
|
|
process.env.FLY_APP_NAME ||
|
|
process.env.HEROKU_APP_NAME ||
|
|
process.env.AWS_EXECUTION_ENV ||
|
|
process.env.KUBERNETES_SERVICE_HOST ||
|
|
process.env.GOOGLE_CLOUD_PROJECT ||
|
|
process.env.AZURE_FUNCTIONS_ENVIRONMENT);
|
|
}
|
|
loadConfig() {
|
|
if (this.config) {
|
|
return this.config;
|
|
}
|
|
if (!(0, fs_1.existsSync)(this.configPath)) {
|
|
const version = this.getPackageVersion();
|
|
const envDisabled = this.isDisabledByEnvironment();
|
|
this.config = {
|
|
enabled: !envDisabled,
|
|
userId: this.generateUserId(),
|
|
firstRun: new Date().toISOString(),
|
|
version
|
|
};
|
|
this.saveConfig();
|
|
if (!envDisabled) {
|
|
this.showFirstRunNotice();
|
|
}
|
|
return this.config;
|
|
}
|
|
try {
|
|
const rawConfig = (0, fs_1.readFileSync)(this.configPath, 'utf-8');
|
|
this.config = JSON.parse(rawConfig);
|
|
if (!this.config.userId) {
|
|
this.config.userId = this.generateUserId();
|
|
this.saveConfig();
|
|
}
|
|
return this.config;
|
|
}
|
|
catch (error) {
|
|
console.error('Failed to load telemetry config, using defaults:', error);
|
|
this.config = {
|
|
enabled: false,
|
|
userId: this.generateUserId()
|
|
};
|
|
return this.config;
|
|
}
|
|
}
|
|
saveConfig() {
|
|
if (!this.config)
|
|
return;
|
|
try {
|
|
if (!(0, fs_1.existsSync)(this.configDir)) {
|
|
(0, fs_1.mkdirSync)(this.configDir, { recursive: true });
|
|
}
|
|
this.config.lastModified = new Date().toISOString();
|
|
(0, fs_1.writeFileSync)(this.configPath, JSON.stringify(this.config, null, 2));
|
|
}
|
|
catch (error) {
|
|
console.error('Failed to save telemetry config:', error);
|
|
}
|
|
}
|
|
isEnabled() {
|
|
if (this.isDisabledByEnvironment()) {
|
|
return false;
|
|
}
|
|
const config = this.loadConfig();
|
|
return config.enabled;
|
|
}
|
|
isDisabledByEnvironment() {
|
|
const envVars = [
|
|
'N8N_MCP_TELEMETRY_DISABLED',
|
|
'TELEMETRY_DISABLED',
|
|
'DISABLE_TELEMETRY'
|
|
];
|
|
for (const varName of envVars) {
|
|
const value = process.env[varName];
|
|
if (value !== undefined) {
|
|
const normalized = value.toLowerCase().trim();
|
|
if (!['true', 'false', '1', '0', ''].includes(normalized)) {
|
|
console.warn(`⚠️ Invalid telemetry environment variable value: ${varName}="${value}"\n` +
|
|
` Use "true" to disable or "false" to enable telemetry.`);
|
|
}
|
|
if (normalized === 'true' || normalized === '1') {
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
getUserId() {
|
|
const config = this.loadConfig();
|
|
return config.userId;
|
|
}
|
|
isFirstRun() {
|
|
return !(0, fs_1.existsSync)(this.configPath);
|
|
}
|
|
enable() {
|
|
const config = this.loadConfig();
|
|
config.enabled = true;
|
|
this.config = config;
|
|
this.saveConfig();
|
|
console.log('✓ Anonymous telemetry enabled');
|
|
}
|
|
disable() {
|
|
const config = this.loadConfig();
|
|
config.enabled = false;
|
|
this.config = config;
|
|
this.saveConfig();
|
|
console.log('✓ Anonymous telemetry disabled');
|
|
}
|
|
getStatus() {
|
|
const config = this.loadConfig();
|
|
const envDisabled = this.isDisabledByEnvironment();
|
|
let status = config.enabled ? 'ENABLED' : 'DISABLED';
|
|
if (envDisabled) {
|
|
status = 'DISABLED (via environment variable)';
|
|
}
|
|
return `
|
|
Telemetry Status: ${status}
|
|
Anonymous ID: ${config.userId}
|
|
First Run: ${config.firstRun || 'Unknown'}
|
|
Config Path: ${this.configPath}
|
|
|
|
To opt-out: npx n8n-mcp telemetry disable
|
|
To opt-in: npx n8n-mcp telemetry enable
|
|
|
|
For Docker: Set N8N_MCP_TELEMETRY_DISABLED=true
|
|
`;
|
|
}
|
|
showFirstRunNotice() {
|
|
console.log(`
|
|
╔════════════════════════════════════════════════════════════╗
|
|
║ Anonymous Usage Statistics ║
|
|
╠════════════════════════════════════════════════════════════╣
|
|
║ ║
|
|
║ n8n-mcp collects anonymous usage data to improve the ║
|
|
║ tool and understand how it's being used. ║
|
|
║ ║
|
|
║ We track: ║
|
|
║ • Which MCP tools are used (no parameters) ║
|
|
║ • Workflow structures (sanitized, no sensitive data) ║
|
|
║ • Error patterns (hashed, no details) ║
|
|
║ • Performance metrics (timing, success rates) ║
|
|
║ ║
|
|
║ We NEVER collect: ║
|
|
║ • URLs, API keys, or credentials ║
|
|
║ • Workflow content or actual data ║
|
|
║ • Personal or identifiable information ║
|
|
║ • n8n instance details or locations ║
|
|
║ ║
|
|
║ Your anonymous ID: ${this.config?.userId || 'generating...'} ║
|
|
║ ║
|
|
║ This helps me understand usage patterns and improve ║
|
|
║ n8n-mcp for everyone. Thank you for your support! ║
|
|
║ ║
|
|
║ To opt-out at any time: ║
|
|
║ npx n8n-mcp telemetry disable ║
|
|
║ ║
|
|
║ Data deletion requests: ║
|
|
║ Email romuald@n8n-mcp.com with your anonymous ID ║
|
|
║ ║
|
|
║ Learn more: ║
|
|
║ https://github.com/czlonkowski/n8n-mcp/blob/main/PRIVACY.md ║
|
|
║ ║
|
|
╚════════════════════════════════════════════════════════════╝
|
|
`);
|
|
}
|
|
getPackageVersion() {
|
|
try {
|
|
const possiblePaths = [
|
|
(0, path_1.resolve)(__dirname, '..', '..', 'package.json'),
|
|
(0, path_1.resolve)(process.cwd(), 'package.json'),
|
|
(0, path_1.resolve)(__dirname, '..', '..', '..', 'package.json')
|
|
];
|
|
for (const packagePath of possiblePaths) {
|
|
if ((0, fs_1.existsSync)(packagePath)) {
|
|
const packageJson = JSON.parse((0, fs_1.readFileSync)(packagePath, 'utf-8'));
|
|
if (packageJson.version) {
|
|
return packageJson.version;
|
|
}
|
|
}
|
|
}
|
|
try {
|
|
const packageJson = require('../../package.json');
|
|
return packageJson.version || 'unknown';
|
|
}
|
|
catch {
|
|
}
|
|
return 'unknown';
|
|
}
|
|
catch (error) {
|
|
return 'unknown';
|
|
}
|
|
}
|
|
}
|
|
exports.TelemetryConfigManager = TelemetryConfigManager;
|
|
//# sourceMappingURL=config-manager.js.map
|