test-canvas-endpoint.js

Go to the documentation of this file.

#!/usr/bin/env node
/**
 * Test script for custom canvas desktop endpoint
 * Tests WebSocket connection and JWT authentication
 * 
 * Usage:
 *   node test-canvas-endpoint.js <jwt_token> <node_id> [meshcentral_url]
 * 
 * Example:
 *   node test-canvas-endpoint.js "eyJhbGc..." "node123" "wss://meshcentral.domain.com"
 */
 
const WebSocket = require('ws');
 
// Parse command line arguments
const args = process.argv.slice(2);
if (args.length < 2) {
    console.log('Usage: node test-canvas-endpoint.js <jwt_token> <node_id> [meshcentral_url]');
    console.log('');
    console.log('Arguments:');
    console.log('  jwt_token         - JWT token from dashboard login');
    console.log('  node_id           - MeshCentral node ID (agent identifier)');
    console.log('  meshcentral_url   - Optional: MeshCentral WebSocket URL');
    console.log('                      Default: wss://rmm-psa-meshcentral-aq48h.ondigitalocean.app');
    console.log('');
    console.log('Example:');
    console.log('  node test-canvas-endpoint.js "eyJhbGc..." "node//abc123..."');
    process.exit(1);
}
 
const token = args[0];
const nodeId = args[1];
const baseUrl = args[2] || 'wss://rmm-psa-meshcentral-aq48h.ondigitalocean.app';
 
// Construct URL
const wsUrl = `${baseUrl}/api/canvas-desktop/${encodeURIComponent(nodeId)}?token=${encodeURIComponent(token)}`;
 
console.log('========================================');
console.log('Canvas Desktop Endpoint Test');
console.log('========================================');
console.log('');
console.log('Configuration:');
console.log(`  Node ID: ${nodeId}`);
console.log(`  Token: ${token.substring(0, 30)}...`);
console.log(`  URL: ${baseUrl}`);
console.log('');
console.log('Connecting...');
console.log('');
 
// Create WebSocket connection
const ws = new WebSocket(wsUrl, {
    rejectUnauthorized: false // Accept self-signed certificates (dev/staging only)
});
 
let pingInterval;
let messageCount = 0;
 
ws.on('open', () => {
    console.log('✅ WebSocket connection OPENED');
    console.log('');
    
    // Send initial ping
    console.log('📤 Sending ping...');
    ws.send(JSON.stringify({ type: 'ping', timestamp: Date.now() }));
    
    // Setup ping interval to keep connection alive
    pingInterval = setInterval(() => {
        if (ws.readyState === WebSocket.OPEN) {
            console.log('📤 Sending periodic ping...');
            ws.send(JSON.stringify({ type: 'ping', timestamp: Date.now() }));
        }
    }, 10000); // Ping every 10 seconds
});
 
ws.on('message', (data) => {
    messageCount++;
    try {
        const msg = JSON.parse(data.toString());
        console.log(`📨 Message ${messageCount} received:`, JSON.stringify(msg, null, 2));
        console.log('');
        
        // If this is a pong response, calculate latency
        if (msg.type === 'pong' && msg.timestamp) {
            const latency = Date.now() - msg.timestamp;
            console.log(`⚡ Latency: ${latency}ms`);
            console.log('');
        }
        
        // If connected successfully, show capabilities
        if (msg.type === 'connected') {
            console.log('🎉 Connection Successful!');
            console.log('');
            console.log('Connection Details:');
            console.log(`  Node ID: ${msg.nodeId}`);
            console.log(`  User ID: ${msg.userId}`);
            console.log(`  Tenant ID: ${msg.tenantId}`);
            console.log(`  Phase: ${msg.phase}`);
            console.log(`  Capabilities: ${msg.capabilities?.join(', ')}`);
            console.log(`  Message: ${msg.message}`);
            console.log('');
        }
        
    } catch (err) {
        console.error('❌ Error parsing message:', err.message);
        console.error('   Raw data:', data.toString());
        console.log('');
    }
});
 
ws.on('error', (err) => {
    console.error('❌ WebSocket ERROR:', err.message);
    console.log('');
    
    // Common errors and solutions
    if (err.message.includes('ENOTFOUND')) {
        console.log('💡 Troubleshooting: Cannot resolve hostname');
        console.log('   - Check if MeshCentral URL is correct');
        console.log('   - Verify DNS resolution');
    } else if (err.message.includes('ECONNREFUSED')) {
        console.log('💡 Troubleshooting: Connection refused');
        console.log('   - Check if MeshCentral is running');
        console.log('   - Verify the port is correct');
    } else if (err.message.includes('401') || err.message.includes('403')) {
        console.log('💡 Troubleshooting: Authentication failed');
        console.log('   - Check if JWT token is valid');
        console.log('   - Verify token has not expired');
        console.log('   - Ensure JWT_SECRET matches between backend and MeshCentral');
    }
    console.log('');
});
 
ws.on('close', (code, reason) => {
    clearInterval(pingInterval);
    console.log(`🔌 WebSocket CLOSED`);
    console.log(`   Code: ${code}`);
    console.log(`   Reason: ${reason || 'No reason provided'}`);
    console.log('');
    console.log(`Total messages received: ${messageCount}`);
    console.log('');
    
    // Explain close codes
    if (code === 1000) {
        console.log('✅ Normal closure (successful test)');
    } else if (code === 1006) {
        console.log('⚠️  Abnormal closure (connection lost without close frame)');
    } else if (code === 1008) {
        console.log('❌ Policy violation (likely authentication failed)');
    } else if (code === 1011) {
        console.log('❌ Server error');
    }
    
    process.exit(code === 1000 ? 0 : 1);
});
 
// Handle Ctrl+C gracefully
process.on('SIGINT', () => {
    console.log('');
    console.log('⚠️  Interrupted by user');
    console.log('Closing connection...');
    ws.close(1000, 'User interrupted');
});
 
// Timeout after 30 seconds
setTimeout(() => {
    if (ws.readyState === WebSocket.OPEN) {
        console.log('⏱️  Test timeout (30 seconds) - closing connection');
        ws.close(1000, 'Test completed');
    }
}, 30000);
 
console.log('Test running... (press Ctrl+C to stop)');
console.log('');