n8n-mcp/dist/telemetry/telemetry-manager.js

"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
    if (k2 === undefined) k2 = k;
    var desc = Object.getOwnPropertyDescriptor(m, k);
    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
      desc = { enumerable: true, get: function() { return m[k]; } };
    }
    Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
    if (k2 === undefined) k2 = k;
    o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
    Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
    o["default"] = v;
});
var __importStar = (this && this.__importStar) || (function () {
    var ownKeys = function(o) {
        ownKeys = Object.getOwnPropertyNames || function (o) {
            var ar = [];
            for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
            return ar;
        };
        return ownKeys(o);
    };
    return function (mod) {
        if (mod && mod.__esModule) return mod;
        var result = {};
        if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
        __setModuleDefault(result, mod);
        return result;
    };
})();
Object.defineProperty(exports, "__esModule", { value: true });
exports.telemetry = exports.TelemetryManager = void 0;
const supabase_js_1 = require("@supabase/supabase-js");
const config_manager_1 = require("./config-manager");
const event_tracker_1 = require("./event-tracker");
const batch_processor_1 = require("./batch-processor");
const performance_monitor_1 = require("./performance-monitor");
const telemetry_types_1 = require("./telemetry-types");
const telemetry_error_1 = require("./telemetry-error");
const logger_1 = require("../utils/logger");
class TelemetryManager {
    constructor() {
        this.supabase = null;
        this.isInitialized = false;
        if (TelemetryManager.instance) {
            throw new Error('Use TelemetryManager.getInstance() instead of new TelemetryManager()');
        }
        this.configManager = config_manager_1.TelemetryConfigManager.getInstance();
        this.errorAggregator = new telemetry_error_1.TelemetryErrorAggregator();
        this.performanceMonitor = new performance_monitor_1.TelemetryPerformanceMonitor();
        this.eventTracker = new event_tracker_1.TelemetryEventTracker(() => this.configManager.getUserId(), () => this.isEnabled());
        this.batchProcessor = new batch_processor_1.TelemetryBatchProcessor(null, () => this.isEnabled());
    }
    static getInstance() {
        if (!TelemetryManager.instance) {
            TelemetryManager.instance = new TelemetryManager();
        }
        return TelemetryManager.instance;
    }
    ensureInitialized() {
        if (!this.isInitialized && this.configManager.isEnabled()) {
            this.initialize();
        }
    }
    initialize() {
        if (!this.configManager.isEnabled()) {
            logger_1.logger.debug('Telemetry disabled by user preference');
            return;
        }
        const supabaseUrl = process.env.SUPABASE_URL || telemetry_types_1.TELEMETRY_BACKEND.URL;
        const supabaseAnonKey = process.env.SUPABASE_ANON_KEY || telemetry_types_1.TELEMETRY_BACKEND.ANON_KEY;
        try {
            this.supabase = (0, supabase_js_1.createClient)(supabaseUrl, supabaseAnonKey, {
                auth: {
                    persistSession: false,
                    autoRefreshToken: false,
                },
                realtime: {
                    params: {
                        eventsPerSecond: 1,
                    },
                },
            });
            this.batchProcessor = new batch_processor_1.TelemetryBatchProcessor(this.supabase, () => this.isEnabled());
            this.batchProcessor.start();
            this.isInitialized = true;
            logger_1.logger.debug('Telemetry initialized successfully');
        }
        catch (error) {
            const telemetryError = new telemetry_error_1.TelemetryError(telemetry_error_1.TelemetryErrorType.INITIALIZATION_ERROR, 'Failed to initialize telemetry', { error: error instanceof Error ? error.message : String(error) });
            this.errorAggregator.record(telemetryError);
            telemetryError.log();
            this.isInitialized = false;
        }
    }
    trackToolUsage(toolName, success, duration) {
        this.ensureInitialized();
        this.performanceMonitor.startOperation('trackToolUsage');
        this.eventTracker.trackToolUsage(toolName, success, duration);
        this.eventTracker.updateToolSequence(toolName);
        this.performanceMonitor.endOperation('trackToolUsage');
    }
    async trackWorkflowCreation(workflow, validationPassed) {
        this.ensureInitialized();
        this.performanceMonitor.startOperation('trackWorkflowCreation');
        try {
            await this.eventTracker.trackWorkflowCreation(workflow, validationPassed);
            await this.flush();
        }
        catch (error) {
            const telemetryError = error instanceof telemetry_error_1.TelemetryError
                ? error
                : new telemetry_error_1.TelemetryError(telemetry_error_1.TelemetryErrorType.UNKNOWN_ERROR, 'Failed to track workflow', { error: String(error) });
            this.errorAggregator.record(telemetryError);
        }
        finally {
            this.performanceMonitor.endOperation('trackWorkflowCreation');
        }
    }
    async trackWorkflowMutation(data) {
        this.ensureInitialized();
        if (!this.isEnabled()) {
            logger_1.logger.debug('Telemetry disabled, skipping mutation tracking');
            return;
        }
        this.performanceMonitor.startOperation('trackWorkflowMutation');
        try {
            const { mutationTracker } = await Promise.resolve().then(() => __importStar(require('./mutation-tracker.js')));
            const userId = this.configManager.getUserId();
            const mutationRecord = await mutationTracker.processMutation(data, userId);
            if (mutationRecord) {
                this.eventTracker.enqueueMutation(mutationRecord);
                const queueSize = this.eventTracker.getMutationQueueSize();
                if (queueSize >= 2) {
                    await this.flushMutations();
                }
            }
        }
        catch (error) {
            const telemetryError = error instanceof telemetry_error_1.TelemetryError
                ? error
                : new telemetry_error_1.TelemetryError(telemetry_error_1.TelemetryErrorType.UNKNOWN_ERROR, 'Failed to track workflow mutation', { error: String(error) });
            this.errorAggregator.record(telemetryError);
            logger_1.logger.debug('Error tracking workflow mutation:', error);
        }
        finally {
            this.performanceMonitor.endOperation('trackWorkflowMutation');
        }
    }
    trackError(errorType, context, toolName, errorMessage) {
        this.ensureInitialized();
        this.eventTracker.trackError(errorType, context, toolName, errorMessage);
    }
    trackEvent(eventName, properties) {
        this.ensureInitialized();
        this.eventTracker.trackEvent(eventName, properties);
    }
    trackSessionStart() {
        this.ensureInitialized();
        this.eventTracker.trackSessionStart();
    }
    trackSearchQuery(query, resultsFound, searchType) {
        this.eventTracker.trackSearchQuery(query, resultsFound, searchType);
    }
    trackValidationDetails(nodeType, errorType, details) {
        this.eventTracker.trackValidationDetails(nodeType, errorType, details);
    }
    trackToolSequence(previousTool, currentTool, timeDelta) {
        this.eventTracker.trackToolSequence(previousTool, currentTool, timeDelta);
    }
    trackNodeConfiguration(nodeType, propertiesSet, usedDefaults) {
        this.eventTracker.trackNodeConfiguration(nodeType, propertiesSet, usedDefaults);
    }
    trackPerformanceMetric(operation, duration, metadata) {
        this.eventTracker.trackPerformanceMetric(operation, duration, metadata);
    }
    async flush() {
        this.ensureInitialized();
        if (!this.isEnabled() || !this.supabase)
            return;
        this.performanceMonitor.startOperation('flush');
        const events = this.eventTracker.getEventQueue();
        const workflows = this.eventTracker.getWorkflowQueue();
        const mutations = this.eventTracker.getMutationQueue();
        this.eventTracker.clearEventQueue();
        this.eventTracker.clearWorkflowQueue();
        this.eventTracker.clearMutationQueue();
        try {
            await this.batchProcessor.flush(events, workflows, mutations);
        }
        catch (error) {
            const telemetryError = error instanceof telemetry_error_1.TelemetryError
                ? error
                : new telemetry_error_1.TelemetryError(telemetry_error_1.TelemetryErrorType.NETWORK_ERROR, 'Failed to flush telemetry', { error: String(error) }, true);
            this.errorAggregator.record(telemetryError);
            telemetryError.log();
        }
        finally {
            const duration = this.performanceMonitor.endOperation('flush');
            if (duration > 100) {
                logger_1.logger.debug(`Telemetry flush took ${duration.toFixed(2)}ms`);
            }
        }
    }
    async flushMutations() {
        this.ensureInitialized();
        if (!this.isEnabled() || !this.supabase)
            return;
        const mutations = this.eventTracker.getMutationQueue();
        this.eventTracker.clearMutationQueue();
        if (mutations.length > 0) {
            await this.batchProcessor.flush([], [], mutations);
        }
    }
    isEnabled() {
        return this.isInitialized && this.configManager.isEnabled();
    }
    disable() {
        this.configManager.disable();
        this.batchProcessor.stop();
        this.isInitialized = false;
        this.supabase = null;
    }
    enable() {
        this.configManager.enable();
        this.initialize();
    }
    getStatus() {
        return this.configManager.getStatus();
    }
    getMetrics() {
        return {
            status: this.isEnabled() ? 'enabled' : 'disabled',
            initialized: this.isInitialized,
            tracking: this.eventTracker.getStats(),
            processing: this.batchProcessor.getMetrics(),
            errors: this.errorAggregator.getStats(),
            performance: this.performanceMonitor.getDetailedReport(),
            overhead: this.performanceMonitor.getTelemetryOverhead()
        };
    }
    static resetInstance() {
        TelemetryManager.instance = undefined;
        global.__telemetryManager = undefined;
    }
}
exports.TelemetryManager = TelemetryManager;
const globalAny = global;
if (!globalAny.__telemetryManager) {
    globalAny.__telemetryManager = TelemetryManager.getInstance();
}
exports.telemetry = globalAny.__telemetryManager;
//# sourceMappingURL=telemetry-manager.js.map