test-phase2-detailed.js

Go to the documentation of this file.

#!/usr/bin/env node
/**
 * Detailed Phase 2 Test - Canvas Desktop Endpoint
 * Tests screen streaming integration with desktop multiplexor
 */
 
const WebSocket = require('ws');
 
const [,, token, nodeId] = process.argv;
 
if (!token || !nodeId) {
    console.error('Usage: node test-phase2-detailed.js <token> <nodeId>');
    process.exit(1);
}
 
// URL encode the nodeId to handle slashes
const encodedNodeId = encodeURIComponent(nodeId);
const url = `wss://rmm-psa-meshcentral-aq48h.ondigitalocean.app/api/canvas-desktop/${encodedNodeId}?token=${token}`;
 
console.log('========================================');
console.log('Phase 2 Canvas Desktop Endpoint Test');
console.log('========================================');
console.log('Configuration:');
console.log(`  Node ID: ${nodeId}`);
console.log(`  Token: ${token.substring(0, 20)}...`);
console.log(`  URL: ${url.replace(/\?token=.*/, '?token=***')}`);
console.log('Connecting...');
console.log('Test running... (press Ctrl+C to stop)');
console.log('');
 
let messageCount = 0;
let connectedPhase = null;
let capabilities = [];
 
const ws = new WebSocket(url, {
    rejectUnauthorized: false
});
 
ws.on('open', () => {
    console.log('✅ WebSocket connection OPENED');
    console.log('');
    
    // Send a ping to test Phase 1 functionality
    console.log('📤 Sending ping...');
    ws.send(JSON.stringify({ type: 'ping' }));
});
 
ws.on('message', (data) => {
    messageCount++;
    
    try {
        // Try to parse as JSON first (control messages)
        const msg = JSON.parse(data.toString());
        console.log(`📨 Message ${messageCount} received (JSON):`);
        console.log(JSON.stringify(msg, null, 2));
        console.log('');
        
        // Extract key info from connected message
        if (msg.type === 'connected') {
            connectedPhase = msg.phase;
            capabilities = msg.capabilities || [];
            console.log(`🎯 Phase ${connectedPhase} detected`);
            console.log(`🔧 Capabilities: ${capabilities.join(', ')}`);
            console.log('');
        }
        
        if (msg.type === 'pong') {
            console.log('🏓 Pong received - connection is alive');
            console.log('');
        }
        
    } catch (e) {
        // Binary data (screen frames from Phase 2)
        if (Buffer.isBuffer(data)) {
            console.log(`📺 Binary frame received: ${data.length} bytes`);
            console.log(`   First 20 bytes: ${data.slice(0, 20).toString('hex')}`);
            console.log('   ⚡ This is screen data from the agent!');
            console.log('');
        } else {
            console.log(`📨 Message ${messageCount} received:`, data.toString().substring(0, 100));
            console.log('');
        }
    }
});
 
ws.on('close', (code, reason) => {
    console.log('🔌 WebSocket CLOSED');
    console.log(`   Code: ${code}`);
    console.log(`   Reason: ${reason || '(none)'}`);
    console.log('');
    console.log(`Total messages received: ${messageCount}`);
    console.log('');
    
    if (messageCount === 0) {
        console.log('❌ No messages received - connection may have failed');
    } else if (connectedPhase === 2 && capabilities.includes('screen')) {
        console.log('✅ Phase 2 screen streaming ready!');
        if (messageCount === 2) {
            console.log('ℹ️  No screen frames received (agent not connected or no display)');
        } else if (messageCount > 2) {
            console.log(`✅ Received ${messageCount - 2} screen frames from agent!`);
        }
    } else if (connectedPhase === 1) {
        console.log('⚠️  Phase 1 only - screen streaming not yet active');
    } else {
        console.log('✅ Normal closure (successful test)');
    }
    
    process.exit(code === 1000 ? 0 : 1);
});
 
ws.on('error', (err) => {
    console.error('❌ WebSocket ERROR:', err.message);
    process.exit(1);
});
 
// Handle Ctrl+C gracefully
process.on('SIGINT', () => {
    console.log('\n⚠️  Interrupted by user');
    console.log('Closing connection...');
    ws.close();
});
 
// Auto-close after 10 seconds
setTimeout(() => {
    console.log('⏰ Test timeout reached (10 seconds)');
    console.log('Closing connection...');
    ws.close();
}, 10000);