Performance Profiler

// performance-profiler/node-profiler.js
const fs = require('fs');
const path = require('path');
const { performance, PerformanceObserver } = require('perf_hooks');
const v8Profiler = require('v8-profiler-next');
const memwatch = require('@airbnb/node-memwatch');

class NodePerformanceProfiler {
  constructor(options = {}) {
    this.options = {
      cpuSamplingInterval: 1000,
      memoryThreshold: 50 * 1024 * 1024, // 50MB
      reportDirectory: './performance-reports',
      ...options
    };
    
    this.metrics = {
      memoryUsage: [],
      cpuUsage: [],
      eventLoopDelay: [],
      httpRequests: []
    };
    
    this.setupPerformanceObservers();
    this.setupMemoryMonitoring();
  }

  setupPerformanceObservers() {
    // HTTP request performance
    const httpObserver = new PerformanceObserver((list) => {
      list.getEntries().forEach((entry) => {
        if (entry.entryType === 'measure') {
          this.metrics.httpRequests.push({
            name: entry.name,
            duration: entry.duration,
            startTime: entry.startTime,
            timestamp: new Date().toISOString()
          });
        }
      });
    });
    httpObserver.observe({ entryTypes: ['measure'] });

    // Function performance
    const functionObserver = new PerformanceObserver((list) => {
      list.getEntries().forEach((entry) => {
        if (entry.duration > 100) { // Log slow functions (>100ms)
          console.warn(`Slow function detected: ${entry.name} took ${entry.duration.toFixed(2)}ms`);
        }
      });
    });
    functionObserver.observe({ entryTypes: ['function'] });
  }

  setupMemoryMonitoring() {
    // Memory leak detection
    memwatch.on('leak', (info) => {
      console.error('Memory leak detected:', info);
      this.generateMemorySnapshot();
    });

    // Garbage collection monitoring
    memwatch.on('stats', (stats) => {
      this.metrics.memoryUsage.push({
        ...stats,
        timestamp: new Date().toISOString(),
        heapUsed: process.memoryUsage().heapUsed,
        heapTotal: process.memoryUsage().heapTotal,
        external: process.memoryUsage().external
      });
    });
  }

  startCPUProfiling(duration = 30000) {
    console.log('Starting CPU profiling...');
    v8Profiler.startProfiling('CPU_PROFILE', true);
    
    setTimeout(() => {
      const profile = v8Profiler.stopProfiling('CPU_PROFILE');
      const reportPath = path.join(this.options.reportDirectory, `cpu-profile-${Date.now()}.cpuprofile`);
      
      profile.export((error, result) => {
        if (error) {
          console.error('CPU profile export error:', error);
          return;
        }
        
        fs.writeFileSync(reportPath, result);
        console.log(`CPU profile saved to: ${reportPath}`);
        
        // Analyze profile
        this.analyzeCPUProfile(JSON.parse(result));
      });
    }, duration);
  }

  analyzeCPUProfile(profile) {
    const hotFunctions = [];
    
    function traverseNodes(node, depth = 0) {
      if (node.hitCount > 0) {
        hotFunctions.push({
          functionName: node.callFrame.functionName || 'anonymous',
          url: node.callFrame.url,
          lineNumber: node.callFrame.lineNumber,
          hitCount: node.hitCount,
          selfTime: node.selfTime || 0
        });
      }
      
      if (node.children) {
        node.children.forEach(child => traverseNodes(child, depth + 1));
      }
    }
    
    traverseNodes(profile.head);
    
    // Sort by hit count and self time
    hotFunctions.sort((a, b) => (b.hitCount * b.selfTime) - (a.hitCount * a.selfTime));
    
    console.log('\nTop CPU consuming functions:');
    hotFunctions.slice(0, 10).forEach((func, index) => {
      console.log(`${index + 1}. ${func.functionName} (${func.hitCount} hits, ${func.selfTime}ms)`);
    });
    
    return hotFunctions;
  }

  measureEventLoopDelay() {
    const { monitorEventLoopDelay } = require('perf_hooks');
    const histogram = monitorEventLoopDelay({ resolution: 20 });
    
    histogram.enable();
    
    setInterval(() => {
      const delay = {
        min: histogram.min,
        max: histogram.max,
        mean: histogram.mean,
        stddev: histogram.stddev,
        percentile99: histogram.percentile(99),
        timestamp: new Date().toISOString()
      };
      
      this.metrics.eventLoopDelay.push(delay);
      
      if (delay.mean > 10) { // Alert if event loop delay > 10ms
        console.warn(`High event loop delay: ${delay.mean.toFixed(2)}ms`);
      }
      
      histogram.reset();
    }, 5000);
  }

  generateMemorySnapshot() {
    const snapshot = v8Profiler.takeSnapshot();
    const reportPath = path.join(this.options.reportDirectory, `memory-snapshot-${Date.now()}.heapsnapshot`);
    
    snapshot.export((error, result) => {
      if (error) {
        console.error('Memory snapshot export error:', error);
        return;
      }
      
      fs.writeFileSync(reportPath, result);
      console.log(`Memory snapshot saved to: ${reportPath}`);
    });
  }

  instrumentFunction(fn, name) {
    return function(...args) {
      const startMark = `${name}-start`;
      const endMark = `${name}-end`;
      const measureName = `${name}-duration`;
      
      performance.mark(startMark);
      const result = fn.apply(this, args);
      
      if (result instanceof Promise) {
        return result.finally(() => {
          performance.mark(endMark);
          performance.measure(measureName, startMark, endMark);
        });
      } else {
        performance.mark(endMark);
        performance.measure(measureName, startMark, endMark);
        return result;
      }
    };
  }

  generatePerformanceReport() {
    const report = {
      timestamp: new Date().toISOString(),
      summary: {
        totalMemoryMeasurements: this.metrics.memoryUsage.length,
        averageMemoryUsage: this.calculateAverageMemory(),
        totalHttpRequests: this.metrics.httpRequests.length,
        averageResponseTime: this.calculateAverageResponseTime(),
        slowestRequests: this.getSlowRequests(),
        memoryTrends: this.analyzeMemoryTrends()
      },
      recommendations: this.generateRecommendations()
    };
    
    const reportPath = path.join(this.options.reportDirectory, `performance-report-${Date.now()}.json`);
    fs.writeFileSync(reportPath, JSON.stringify(report, null, 2));
    
    console.log('\nPerformance Report Generated:');
    console.log(`- Report saved to: ${reportPath}`);
    console.log(`- Average memory usage: ${(report.summary.averageMemoryUsage / 1024 / 1024).toFixed(2)} MB`);
    console.log(`- Average response time: ${report.summary.averageResponseTime.toFixed(2)} ms`);
    
    return report;
  }

  calculateAverageMemory() {
    if (this.metrics.memoryUsage.length === 0) return 0;
    const sum = this.metrics.memoryUsage.reduce((acc, usage) => acc + usage.heapUsed, 0);
    return sum / this.metrics.memoryUsage.length;
  }

  calculateAverageResponseTime() {
    if (this.metrics.httpRequests.length === 0) return 0;
    const sum = this.metrics.httpRequests.reduce((acc, req) => acc + req.duration, 0);
    return sum / this.metrics.httpRequests.length;
  }

  getSlowRequests(threshold = 1000) {
    return this.metrics.httpRequests
      .filter(req => req.duration > threshold)
      .sort((a, b) => b.duration - a.duration)
      .slice(0, 10);
  }

  analyzeMemoryTrends() {
    if (this.metrics.memoryUsage.length < 2) return null;
    
    const first = this.metrics.memoryUsage[0].heapUsed;
    const last = this.metrics.memoryUsage[this.metrics.memoryUsage.length - 1].heapUsed;
    const trend = ((last - first) / first) * 100;
    
    return {
      trend: trend > 0 ? 'increasing' : 'decreasing',
      percentage: Math.abs(trend).toFixed(2),
      concerning: Math.abs(trend) > 20
    };
  }

  generateRecommendations() {
    const recommendations = [];
    
    // Memory recommendations
    const avgMemory = this.calculateAverageMemory();
    if (avgMemory > this.options.memoryThreshold) {
      recommendations.push({
        category: 'memory',
        severity: 'high',
        issue: 'High memory usage detected',
        recommendation: 'Consider implementing memory pooling or reducing object creation'
      });
    }
    
    // Response time recommendations
    const avgResponseTime = this.calculateAverageResponseTime();
    if (avgResponseTime > 500) {
      recommendations.push({
        category: 'performance',
        severity: 'medium',
        issue: 'Slow average response time',
        recommendation: 'Optimize database queries and add caching layers'
      });
    }
    
    // Event loop recommendations
    const recentDelays = this.metrics.eventLoopDelay.slice(-10);
    const highDelays = recentDelays.filter(delay => delay.mean > 10);
    if (highDelays.length > 5) {
      recommendations.push({
        category: 'concurrency',
        severity: 'high',
        issue: 'Frequent event loop delays',
        recommendation: 'Review blocking operations and consider worker threads'
      });
    }
    
    return recommendations;
  }
}

// Usage example
const profiler = new NodePerformanceProfiler({
  reportDirectory: './performance-reports'
});

// Start comprehensive monitoring
profiler.measureEventLoopDelay();
profiler.startCPUProfiling(60000); // 60 second CPU profile

// Instrument critical functions
const originalFunction = require('./your-module').criticalFunction;
const instrumentedFunction = profiler.instrumentFunction(originalFunction, 'criticalFunction');

module.exports = { NodePerformanceProfiler };

// performance-profiler/frontend-profiler.js
class FrontendPerformanceProfiler {
  constructor() {
    this.metrics = {
      coreWebVitals: {},
      resourceTimings: [],
      userTimings: [],
      navigationTiming: null
    };
    
    this.initialize();
  }

  initialize() {
    if (typeof window === 'undefined') return;
    
    this.measureCoreWebVitals();
    this.observeResourceTimings();
    this.observeUserTimings();
    this.measureNavigationTiming();
  }

  measureCoreWebVitals() {
    // Largest Contentful Paint (LCP)
    new PerformanceObserver((list) => {
      const entries = list.getEntries();
      const lastEntry = entries[entries.length - 1];
      this.metrics.coreWebVitals.lcp = {
        value: lastEntry.startTime,
        element: lastEntry.element,
        timestamp: new Date().toISOString()
      };
    }).observe({ entryTypes: ['largest-contentful-paint'] });

    // First Input Delay (FID)
    new PerformanceObserver((list) => {
      const firstInput = list.getEntries()[0];
      this.metrics.coreWebVitals.fid = {
        value: firstInput.processingStart - firstInput.startTime,
        timestamp: new Date().toISOString()
      };
    }).observe({ entryTypes: ['first-input'] });

    // Cumulative Layout Shift (CLS)
    let clsValue = 0;
    new PerformanceObserver((list) => {
      for (const entry of list.getEntries()) {
        if (!entry.hadRecentInput) {
          clsValue += entry.value;
        }
      }
      this.metrics.coreWebVitals.cls = {
        value: clsValue,
        timestamp: new Date().toISOString()
      };
    }).observe({ entryTypes: ['layout-shift'] });

    // First Contentful Paint (FCP)
    new PerformanceObserver((list) => {
      const entries = list.getEntries();
      const fcp = entries.find(entry => entry.name === 'first-contentful-paint');
      if (fcp) {
        this.metrics.coreWebVitals.fcp = {
          value: fcp.startTime,
          timestamp: new Date().toISOString()
        };
      }
    }).observe({ entryTypes: ['paint'] });
  }

  observeResourceTimings() {
    new PerformanceObserver((list) => {
      list.getEntries().forEach(entry => {
        this.metrics.resourceTimings.push({
          name: entry.name,
          type: entry.initiatorType,
          size: entry.transferSize,
          duration: entry.duration,
          startTime: entry.startTime,
          domainLookupTime: entry.domainLookupEnd - entry.domainLookupStart,
          connectTime: entry.connectEnd - entry.connectStart,
          requestTime: entry.responseStart - entry.requestStart,
          responseTime: entry.responseEnd - entry.responseStart,
          timestamp: new Date().toISOString()
        });
      });
    }).observe({ entryTypes: ['resource'] });
  }

  observeUserTimings() {
    new PerformanceObserver((list) => {
      list.getEntries().forEach(entry => {
        this.metrics.userTimings.push({
          name: entry.name,
          entryType: entry.entryType,
          startTime: entry.startTime,
          duration: entry.duration,
          timestamp: new Date().toISOString()
        });
      });
    }).observe({ entryTypes: ['mark', 'measure'] });
  }

  measureNavigationTiming() {
    if (window.performance && window.performance.timing) {
      const timing = window.performance.timing;
      this.metrics.navigationTiming = {
        pageLoadTime: timing.loadEventEnd - timing.navigationStart,
        domContentLoadedTime: timing.domContentLoadedEventEnd - timing.navigationStart,
        domInteractiveTime: timing.domInteractive - timing.navigationStart,
        dnsLookupTime: timing.domainLookupEnd - timing.domainLookupStart,
        tcpConnectionTime: timing.connectEnd - timing.connectStart,
        serverResponseTime: timing.responseEnd - timing.requestStart,
        domProcessingTime: timing.domComplete - timing.domLoading,
        timestamp: new Date().toISOString()
      };
    }
  }

  measureRuntimePerformance() {
    // Memory usage (if available)
    if (window.performance && window.performance.memory) {
      return {
        usedJSHeapSize: window.performance.memory.usedJSHeapSize,
        totalJSHeapSize: window.performance.memory.totalJSHeapSize,
        jsHeapSizeLimit: window.performance.memory.jsHeapSizeLimit,
        timestamp: new Date().toISOString()
      };
    }
    return null;
  }

  analyzeBundleSize() {
    const scripts = Array.from(document.querySelectorAll('script[src]'));
    const stylesheets = Array.from(document.querySelectorAll('link[rel="stylesheet"]'));
    
    const analysis = {
      scripts: scripts.map(script => ({
        src: script.src,
        async: script.async,
        defer: script.defer
      })),
      stylesheets: stylesheets.map(link => ({
        href: link.href,
        media: link.media
      })),
      recommendations: []
    };

    // Generate recommendations
    if (scripts.length > 10) {
      analysis.recommendations.push({
        type: 'bundle-optimization',
        message: 'Consider bundling and minifying JavaScript files'
      });
    }

    scripts.forEach(script => {
      if (!script.async && !script.defer) {
        analysis.recommendations.push({
          type: 'script-loading',
          message: `Consider adding async/defer to: ${script.src}`
        });
      }
    });

    return analysis;
  }

  generatePerformanceReport() {
    const report = {
      timestamp: new Date().toISOString(),
      coreWebVitals: this.metrics.coreWebVitals,
      performance: {
        navigation: this.metrics.navigationTiming,
        runtime: this.measureRuntimePerformance(),
        bundle: this.analyzeBundleSize()
      },
      resources: {
        count: this.metrics.resourceTimings.length,
        totalSize: this.metrics.resourceTimings.reduce((sum, resource) => sum + (resource.size || 0), 0),
        slowResources: this.metrics.resourceTimings
          .filter(resource => resource.duration > 1000)
          .sort((a, b) => b.duration - a.duration)
      },
      recommendations: this.generateOptimizationRecommendations()
    };

    console.log('Frontend Performance Report:', report);
    return report;
  }

  generateOptimizationRecommendations() {
    const recommendations = [];
    const vitals = this.metrics.coreWebVitals;

    // LCP recommendations
    if (vitals.lcp && vitals.lcp.value > 2500) {
      recommendations.push({
        metric: 'LCP',
        issue: 'Slow Largest Contentful Paint',
        recommendations: [
          'Optimize server response times',
          'Remove render-blocking resources',
          'Optimize images and use modern formats',
          'Consider lazy loading for below-fold content'
        ]
      });
    }

    // FID recommendations
    if (vitals.fid && vitals.fid.value > 100) {
      recommendations.push({
        metric: 'FID',
        issue: 'High First Input Delay',
        recommendations: [
          'Reduce JavaScript execution time',
          'Break up long tasks',
          'Use web workers for heavy computations',
          'Remove unused JavaScript'
        ]
      });
    }

    // CLS recommendations
    if (vitals.cls && vitals.cls.value > 0.1) {
      recommendations.push({
        metric: 'CLS',
        issue: 'High Cumulative Layout Shift',
        recommendations: [
          'Include size attributes on images and videos',
          'Reserve space for ad slots',
          'Avoid inserting content above existing content',
          'Use CSS transform animations instead of layout changes'
        ]
      });
    }

    return recommendations;
  }
}

// Usage
const frontendProfiler = new FrontendPerformanceProfiler();

// Generate report after page load
window.addEventListener('load', () => {
  setTimeout(() => {
    frontendProfiler.generatePerformanceReport();
  }, 2000);
});

export { FrontendPerformanceProfiler };

-- performance-profiler/database-analysis.sql

-- PostgreSQL Performance Analysis Queries

-- 1. Slow Query Analysis
SELECT 
    query,
    calls,
    total_time,
    mean_time,
    max_time,
    stddev_time,
    rows,
    100.0 * shared_blks_hit / nullif(shared_blks_hit + shared_blks_read, 0) AS hit_percent
FROM pg_stat_statements 
WHERE mean_time > 100  -- Queries averaging > 100ms
ORDER BY total_time DESC 
LIMIT 20;

-- 2. Index Usage Analysis
SELECT 
    schemaname,
    tablename,
    indexname,
    idx_tup_read,
    idx_tup_fetch,
    idx_scan,
    CASE 
        WHEN idx_scan = 0 THEN 'Never Used'
        WHEN idx_scan < 50 THEN 'Rarely Used'
        WHEN idx_scan < 1000 THEN 'Moderately Used'
        ELSE 'Frequently Used'
    END as usage_level,
    pg_size_pretty(pg_relation_size(indexrelid)) as index_size
FROM pg_stat_user_indexes
ORDER BY idx_scan ASC;

-- 3. Table Statistics and Performance
SELECT 
    schemaname,
    tablename,
    seq_scan,
    seq_tup_read,
    idx_scan,
    idx_tup_fetch,
    n_tup_ins,
    n_tup_upd,
    n_tup_del,
    n_tup_hot_upd,
    n_live_tup,
    n_dead_tup,
    CASE 
        WHEN n_live_tup > 0 
        THEN round((n_dead_tup::float / n_live_tup::float) * 100, 2)
        ELSE 0 
    END as dead_tuple_percent,
    last_vacuum,
    last_autovacuum,
    last_analyze,
    last_autoanalyze,
    pg_size_pretty(pg_total_relation_size(relid)) as total_size
FROM pg_stat_user_tables
ORDER BY seq_scan DESC;

-- 4. Lock Analysis
SELECT 
    pg_class.relname,
    pg_locks.mode,
    pg_locks.granted,
    COUNT(*) as lock_count,
    pg_locks.pid
FROM pg_locks
JOIN pg_class ON pg_locks.relation = pg_class.oid
WHERE pg_locks.mode IS NOT NULL
GROUP BY pg_class.relname, pg_locks.mode, pg_locks.granted, pg_locks.pid
ORDER BY lock_count DESC;

-- 5. Connection and Activity Analysis
SELECT 
    state,
    COUNT(*) as connection_count,
    AVG(EXTRACT(epoch FROM (now() - state_change))) as avg_duration_seconds
FROM pg_stat_activity 
WHERE state IS NOT NULL
GROUP BY state;

-- 6. Buffer Cache Analysis
SELECT 
    name,
    setting,
    unit,
    category,
    short_desc
FROM pg_settings 
WHERE name IN (
    'shared_buffers',
    'effective_cache_size',
    'work_mem',
    'maintenance_work_mem',
    'checkpoint_segments',
    'wal_buffers'
);

-- 7. Query Plan Analysis Function
CREATE OR REPLACE FUNCTION analyze_slow_queries(
    min_mean_time_ms FLOAT DEFAULT 100.0,
    limit_count INTEGER DEFAULT 10
)
RETURNS TABLE(
    query_text TEXT,
    calls BIGINT,
    total_time_ms FLOAT,
    mean_time_ms FLOAT,
    hit_percent FLOAT,
    analysis TEXT
) AS $$
BEGIN
    RETURN QUERY
    SELECT 
        pss.query::TEXT,
        pss.calls,
        pss.total_time,
        pss.mean_time,
        100.0 * pss.shared_blks_hit / NULLIF(pss.shared_blks_hit + pss.shared_blks_read, 0),
        CASE 
            WHEN pss.mean_time > 1000 THEN 'CRITICAL: Very slow query'
            WHEN pss.mean_time > 500 THEN 'WARNING: Slow query'
            WHEN 100.0 * pss.shared_blks_hit / NULLIF(pss.shared_blks_hit + pss.shared_blks_read, 0) < 90 
                THEN 'LOW_CACHE_HIT: Poor buffer cache utilization'
            ELSE 'REVIEW: Monitor for optimization'
        END
    FROM pg_stat_statements pss
    WHERE pss.mean_time >= min_mean_time_ms
    ORDER BY pss.total_time DESC
    LIMIT limit_count;
END;
$$ LANGUAGE plpgsql;

-- Usage: SELECT * FROM analyze_slow_queries(50.0, 20);

// Memory optimization patterns
class MemoryOptimizer {
  static createObjectPool(createFn, resetFn, initialSize = 10) {
    const pool = [];
    for (let i = 0; i < initialSize; i++) {
      pool.push(createFn());
    }
    
    return {
      acquire() {
        return pool.length > 0 ? pool.pop() : createFn();
      },
      
      release(obj) {
        resetFn(obj);
        pool.push(obj);
      },
      
      size() {
        return pool.length;
      }
    };
  }
  
  static debounce(func, wait) {
    let timeout;
    return function executedFunction(...args) {
      const later = () => {
        clearTimeout(timeout);
        func(...args);
      };
      clearTimeout(timeout);
      timeout = setTimeout(later, wait);
    };
  }
  
  static throttle(func, limit) {
    let inThrottle;
    return function() {
      const args = arguments;
      const context = this;
      if (!inThrottle) {
        func.apply(context, args);
        inThrottle = true;
        setTimeout(() => inThrottle = false, limit);
      }
    };
  }
}