test_ping.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const ws_1 = __importDefault(require("ws"));
const protocol_1 = require("./src/protocol");
const ws = new ws_1.default('ws://localhost:8080');
let pingCount = 0;
ws.on('open', () => {
    console.log('Connected to server');
    // Send initial handshake if needed, or just wait for ping
    // Protocol says connectionId is needed in header? Connection class handles null.
});
ws.on('message', (data) => {
    const msg = JSON.parse(data.toString());
    if (msg.header.type === protocol_1.MessageType.PING) {
        console.log('Received PING');
        pingCount++;
        if (pingCount <= 1) {
            console.log('Sending PONG...');
            ws.send(JSON.stringify({
                header: {
                    streamId: '',
                    connectionId: 'test-client',
                    type: protocol_1.MessageType.PONG,
                    timestamp: Date.now()
                },
                payload: null
            }));
        }
        else {
            console.log('Ignoring PING to trigger timeout...');
        }
    }
});
ws.on('close', () => {
    console.log('Disconnected');
    process.exit(0);
});
ws.on('error', (err) => {
    console.error('Error:', err);
});