check-meshcentral-devices.js

Go to the documentation of this file.

const WebSocket = require('ws');
const https = require('https');
const { URL } = require('url');
 
// Load environment variables
require('dotenv').config();
 
const MESHCENTRAL_URL = process.env.MESHCENTRAL_URL;
const USERNAME = process.env.MESHCENTRAL_USERNAME;
const PASSWORD = process.env.MESHCENTRAL_PASSWORD;
 
/**
 *
 */
async function login() {
  const loginUrl = new URL('/login', MESHCENTRAL_URL);
  
  const postData = `action=login&username=${encodeURIComponent(USERNAME)}&password=${encodeURIComponent(PASSWORD)}&token=`;
  
  const options = {
    method: 'POST',
    headers: {
      'Content-Type': 'application/x-www-form-urlencoded',
      'Content-Length': Buffer.byteLength(postData)
    }
  };
  
  return new Promise((resolve, reject) => {
    const req = https.request(loginUrl, options, (res) => {
      let cookie = null;
      
      if (res.headers['set-cookie']) {
        const cookies = res.headers['set-cookie'];
        for (const c of cookies) {
          if (c.startsWith('xid=')) {
            cookie = c.split(';')[0].replace('xid=', '');
            break;
          }
        }
      }
      
      let data = '';
      res.on('data', chunk => data += chunk);
      res.on('end', () => resolve(cookie));
    });
    
    req.on('error', reject);
    req.write(postData);
    req.end();
  });
}
 
/**
 *
 * @param cookie
 */
async function connectWebSocket(cookie) {
  const wsUrl = MESHCENTRAL_URL.replace('https://', 'wss://') + '/control.ashx';
  
  console.log('🔌 Connecting to WebSocket:', wsUrl);
  console.log('🔑 Using cookie:', cookie ? 'present' : 'missing');
  
  const ws = new WebSocket(wsUrl, {
    headers: {
      'Cookie': `xid=${cookie}`
    }
  });
  
  return new Promise((resolve, reject) => {
    const timeout = setTimeout(() => {
      ws.close();
      reject(new Error('WebSocket connection timeout'));
    }, 10000);
    
    ws.on('open', () => {
      console.log('✅ WebSocket connected');
      clearTimeout(timeout);
      
      // Send authentication
      ws.send(JSON.stringify({
        action: 'authcookie',
        cookie: cookie
      }));
      
      // Request nodes
      setTimeout(() => {
        console.log('📡 Requesting nodes...');
        ws.send(JSON.stringify({
          action: 'nodes'
        }));
      }, 1000);
      
      resolve(ws);
    });
    
    ws.on('message', (data) => {
      try {
        const msg = JSON.parse(data.toString());
        console.log('📩 Received:', JSON.stringify(msg, null, 2));
        
        if (msg.action === 'nodes' || msg.nodes) {
          console.log('\n✅ Found devices:', Object.keys(msg.nodes || {}).length);
          Object.entries(msg.nodes || {}).forEach(([id, node]) => {
            console.log(`  - ${node.name || id}: ${node.ip || 'no IP'} (${node.state || 'unknown state'})`);
          });
          ws.close();
        }
      } catch (err) {
        console.log('📩 Raw message:', data.toString());
      }
    });
    
    ws.on('error', (err) => {
      console.error('❌ WebSocket error:', err.message);
      clearTimeout(timeout);
      reject(err);
    });
    
    ws.on('close', () => {
      console.log('🔌 WebSocket closed');
      clearTimeout(timeout);
    });
  });
}
 
/**
 *
 */
async function main() {
  try {
    console.log('🔧 Checking MeshCentral devices...\n');
    
    const cookie = await login();
    if (!cookie) {
      throw new Error('Login failed - no cookie received');
    }
    
    console.log('✅ Login successful\n');
    
    await connectWebSocket(cookie);
    
    setTimeout(() => {
      console.log('\n⏱️  Timeout - no response from server');
      process.exit(0);
    }, 15000);
    
  } catch (error) {
    console.error('❌ Error:', error.message);
    process.exit(1);
  }
}
 
main();