link-agent-to-meshcentral.js

Go to the documentation of this file.

#!/usr/bin/env node
 
/**
 * Link an agent to a MeshCentral device by updating meshcentral_nodeid
 * Usage: node link-agent-to-meshcentral.js <agent_uuid> <meshcentral_nodeid>
 */
 
const { Pool } = require('pg');
require('dotenv').config();
 
const pool = new Pool({
  host: process.env.POSTGRES_HOST,
  port: process.env.POSTGRES_PORT || 25060,
  database: process.env.POSTGRES_DATABASE || 'defaultdb',
  user: process.env.POSTGRES_USER,
  password: process.env.POSTGRES_PASSWORD,
  ssl: process.env.POSTGRES_SSL === 'true' ? { rejectUnauthorized: false } : false
});
 
/**
 *
 * @param agentUuid
 * @param meshcentralNodeId
 */
async function linkAgent(agentUuid, meshcentralNodeId) {
  try {
    // Check if agent exists
    const agentCheck = await pool.query(
      'SELECT agent_id, agent_uuid, hostname, meshcentral_nodeid FROM agents WHERE agent_uuid = $1',
      [agentUuid]
    );
 
    if (agentCheck.rows.length === 0) {
      console.error(`❌ Agent not found: ${agentUuid}`);
      process.exit(1);
    }
 
    const agent = agentCheck.rows[0];
    console.log(`\n📋 Current Agent State:`);
    console.log(`   Agent ID: ${agent.agent_id}`);
    console.log(`   UUID: ${agent.agent_uuid}`);
    console.log(`   Hostname: ${agent.hostname}`);
    console.log(`   Current Node ID: ${agent.meshcentral_nodeid || '(none)'}`);
 
    // Update the agent
    const result = await pool.query(
      `UPDATE agents 
       SET meshcentral_nodeid = $1,
           meshcentral_connected = true,
           meshcentral_last_seen = NOW()
       WHERE agent_uuid = $2
       RETURNING agent_id, hostname, meshcentral_nodeid`,
      [meshcentralNodeId, agentUuid]
    );
 
    console.log(`\n✅ Agent Updated:`);
    console.log(`   New Node ID: ${result.rows[0].meshcentral_nodeid}`);
    console.log(`\n🎉 Link successful! Agent ${agentUuid} is now connected to MeshCentral device.`);
    console.log(`\n📍 View agent at: https://everydaytech.au/agents/${agentUuid}`);
 
  } catch (error) {
    console.error('❌ Error linking agent:', error.message);
    console.error('Full error:', error);
    process.exit(1);
  } finally {
    await pool.end();
  }
}
 
// Parse command line arguments
const args = process.argv.slice(2);
 
if (args.length !== 2) {
  console.error('Usage: node link-agent-to-meshcentral.js <agent_uuid> <meshcentral_nodeid>');
  console.error('\nExample:');
  console.error('  node link-agent-to-meshcentral.js 2c3e2d7a-c521-4844-b44b-a30b4c2ec4d8 "yfNgVgiQyrbYaDLpK1El3YM81NyK3nwX9ggSYdjc1LdFPB9rL$zq2EYaAaOzi0xW"');
  process.exit(1);
}
 
const [agentUuid, meshcentralNodeId] = args;
 
linkAgent(agentUuid, meshcentralNodeId);