pluginBuilder.js

Go to the documentation of this file.

const path = require('path');
const fs = require('fs');
const pool = require('./db');
const PLUGIN_SRC = path.resolve(__dirname, '../../agent/plugins');
const PLUGIN_DEST = path.resolve(__dirname, '../../agent/plugins');
// pluginBuilder.js - Redis worker for plugin build/check jobs
 
const { execSync } = require('child_process');
const Redis = require('ioredis');
const redisConfig = require('../config/redis');
const redis = new Redis(redisConfig);
 
 
const PLUGIN_HASHES_PATH = path.resolve(__dirname, 'pluginHashes.json');
/**
 *
 */
function getPluginHashes() {
  try {
    return JSON.parse(fs.readFileSync(PLUGIN_HASHES_PATH, 'utf8'));
  } catch {
    return {};
  }
}
/**
 *
 * @param hashes
 */
function savePluginHashes(hashes) {
  fs.writeFileSync(PLUGIN_HASHES_PATH, JSON.stringify(hashes, null, 2));
}
 
/**
 *
 * @param filePath
 */
function hashFile(filePath) {
  if (!fs.existsSync(filePath)) return null;
  const content = fs.readFileSync(filePath);
  return require('crypto').createHash('sha256').update(content).digest('hex');
}
 
/**
 *
 */
function buildAllWindowsPlugins() {
  }
  const hashes = getPluginHashes();
  const srcFiles = fs.readdirSync(PLUGIN_SRC).filter(f => f.endsWith('.js'));
  let changed = false;
  // Build plugins
  for (const file of srcFiles) {
    const pluginName = file.replace('.js', '');
    const srcPath = path.join(PLUGIN_SRC, file);
    const destPath = path.join(PLUGIN_DEST, 'windows', pluginName + '.exe');
    const newHash = hashFile(srcPath);
    if (hashes[file] !== newHash || !fs.existsSync(destPath)) {
      try {
        execSync(`npx pkg ${srcPath} --output ${destPath} --targets node18-win-x64`);
        console.log(`[PLUGIN BUILDER] Built ${pluginName}.exe for Windows.`);
        hashes[file] = newHash;
        changed = true;
      } catch (err) {
        console.error(`[PLUGIN BUILDER] Failed to build ${pluginName}.exe:`, err.message);
      }
    } else {
      console.log(`[PLUGIN BUILDER] No change for ${pluginName}.js, skipping build.`);
    }
    // Seed plugin info in database
    const version = '1.0.0';
    const description = `Auto-seeded plugin for ${pluginName}`;
    pool.query(
      `INSERT INTO plugins (name, description, version, type) VALUES ($1, $2, $3, $4)
       ON CONFLICT (name) DO UPDATE SET description = EXCLUDED.description, version = EXCLUDED.version, type = EXCLUDED.type`,
      [`${pluginName}.exe`, description, version, 'windows']
    ).then(() => {
      console.log(`[PLUGIN BUILDER] Seeded DB: ${pluginName}.exe`);
    }).catch((err) => {
      console.error(`[PLUGIN BUILDER] DB seed error for ${pluginName}.exe:`, err.message);
    });
  }
  // Build agent binary as plugin (use EverydayTechAgent-win-x64.exe)
  const agentSrc = path.resolve(__dirname, '../../agent/agent.js');
  const agentDest = path.resolve(__dirname, '../../agent/plugins/agent/EverydayTechAgent-win-x64.exe');
  const agentHash = hashFile(agentSrc);
  if (hashes['agent.js'] !== agentHash || !fs.existsSync(agentDest)) {
    try {
      execSync(`npx pkg ${agentSrc} --output ${agentDest} --targets node18-win-x64`);
      console.log(`[PLUGIN BUILDER] Built EverydayTechAgent-win-x64.exe for Windows.`);
      hashes['EverydayTechAgent-win-x64.exe'] = agentHash;
      changed = true;
    } catch (err) {
      console.error(`[PLUGIN BUILDER] Failed to build EverydayTechAgent-win-x64.exe:`, err.message);
    }
  } else {
    console.log(`[PLUGIN BUILDER] No change for agent.js, skipping agent build.`);
  }
  // Seed agent plugin info in database
  pool.query(
    `INSERT INTO plugins (name, description, version, type) VALUES ($1, $2, $3, $4)
     ON CONFLICT (name) DO UPDATE SET description = EXCLUDED.description, version = EXCLUDED.version, type = EXCLUDED.type`,
    ['EverydayTechAgent-win-x64.exe', 'Auto-seeded agent plugin', '1.0.0', 'agent']
  ).then(() => {
    console.log('[PLUGIN BUILDER] Seeded DB: EverydayTechAgent-win-x64.exe');
  }).catch((err) => {
    console.error('[PLUGIN BUILDER] DB seed error for EverydayTechAgent-win-x64.exe:', err.message);
  });
  if (changed) savePluginHashes(hashes);
 
 
redis.subscribe('plugin-build-jobs', (err, count) => {
  if (err) console.error('[PLUGIN BUILDER] Redis subscribe error:', err);
  else console.log(`[PLUGIN BUILDER] Subscribed to plugin-build-jobs (${count})`);
});
 
redis.on('message', (channel, message) => {
  if (channel !== 'plugin-build-jobs') return;
  try {
    const job = JSON.parse(message);
    const { os } = job;
    console.log(`[PLUGIN BUILDER] Received job for OS: ${os}`);
    if (os === 'windows') {
      buildAllWindowsPlugins();
    }
    // Add similar logic for other OS if needed
  } catch (err) {
    console.error('[PLUGIN BUILDER] Job error:', err.message);
  }
});
 
// To run: node backend/services/pluginBuilder.js