Project

General

Profile

htsp.js, help a poor coder ;(

Added by daniel magnusson almost 13 years ago

Tried to convert the htsp hello method from johns android project to javascript. Did not go to well, anyone see what went wrong?
Goal is to get a "Welcomed client software: org.me.tvhguide" on the tvheadend server..

I get;
[INFO]:htsp: Got connection from 192.168.1.101
[INFO]:htsp: 192.168.1.101: Disconnected

I want;
[INFO]:htsp: 192.168.1.101: Welcomed client software: org.me.tvhguide

(Can i enable more logs?)

code;

var net = require('net');

var HOST = '192.168.1.102';
var PORT = 9982;

function serializeBinary(key, value) {
    var type = 2;
    if (typeof value == "number") {
        type = 2;
    } else if (typeof value == "string") {
        type = 3;
    }
    var bName = new Buffer(key);
    var bData = new Buffer(value);
    var buf = new Array(6)

    buf[0] = type;
    buf[1] = (bName.length & 0xFF);
    buf[2] = ((bData.length >> 24) & 0xFF);
    buf[3] = ((bData.length >> 16) & 0xFF);
    buf[4] = ((bData.length >> 8) & 0xFF);
    buf[5] = ((bData.length) & 0xFF);

    var ch, st = [];
    for (var i = 0; i < key.length; i++) {
        ch = key.charCodeAt(i);
        st = []; // set up "stack" 
        do {
            st.push(ch & 0xFF); // push byte to stack
            ch = ch >> 8; // shift value down by 1 byte
        }
        while (ch);
        // add stack contents to result
        // done because chars have "wrong" endianness
        buf = buf.concat(st.reverse());
    }

    if (typeof value == "string") {
        var ch, st = [];
        for (var i = 0; i < value.length; i++) {
            ch = value.charCodeAt(i); // get char 
            st = []; // set up "stack" 
            do {
                st.push(ch & 0xFF); // push byte to stack
                ch = ch >> 8; // shift value down by 1 byte
            }
            while (ch);
            // add stack contents to result
            // done because chars have "wrong" endianness
            buf = buf.concat(st.reverse());
        }
    }
    if (typeof value == "number") {
        buf = buf.concat(value);
    }
    return buf;
}

var client = new net.Socket();
client.setTimeout(5000);
client.setNoDelay(noDelay=true);
client.setKeepAlive(enable=true);

client.connect(PORT, HOST, function() {

    console.log('CONNECTED TO: ' + HOST + ':' + PORT);

    var buffer = new Array()
    var sub = serializeBinary('seq', 1);
    console.log('\nseq:1');
    console.log('expect: 2,3,0,0,0,1,115,101,113,1');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('buffer: ' + buffer);

    var sub = serializeBinary('clientversion', '1.0');
    console.log('\nclientversion:1.0');
    console.log('expect: 3,13,0,0,0,3,99,108,105,101,110,116,118,101,114,115,105,111,110,49,46,48');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('buffer: ' + buffer);

    var sub = serializeBinary('username', '');
    console.log('\nusername:');
    console.log('expect: 3,8,0,0,0,0,117,115,101,114,110,97,109,101');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('buffer: ' + buffer);

    var sub = serializeBinary('htspversion', 4);
    console.log('\nhtspversion:4');
    console.log('expect: 2,11,0,0,0,1,104,116,115,112,118,101,114,115,105,111,110,4');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('buffer: ' + buffer);

    var sub = serializeBinary('method', 'hello');
    console.log('\nmethod:hello');
    console.log('expect: 3,6,0,0,0,5,109,101,116,104,111,100,104,101,108,108,111');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('buffer: ' + buffer);

    var sub = serializeBinary('clientname', 'org.me.tvhguide');
    console.log('\nclientname:org.me.tvhguide');
    console.log('expect: 3,10,0,0,0,15,99,108,105,101,110,116,110,97,109,101,111,114,103,46,109,101,46,116,118,104,103,117,105,100,101');
    console.log('sub:    ' + sub);
    buffer = buffer.concat(sub);
    console.log('\nbuffer1: ' + buffer);

    //flip
    buffer.reverse().join("");
    console.log('\nbuffer2: ' + buffer);

    var dataBuffer = new Array(4)
    dataBuffer[0] = ((buffer.length >> 24) & 0xFF);
    dataBuffer[1] = ((buffer.length >> 16) & 0xFF);
    dataBuffer[2] = ((buffer.length >> 8) & 0xFF);
    dataBuffer[3] = ((buffer.length) & 0xFF);
    dataBuffer = dataBuffer.concat(buffer);
    console.log('\ndataBuffer1: ' + dataBuffer);

    //flip
    dataBuffer.reverse().join("");

    console.log('\ndataBuffer2: ' + dataBuffer);
    console.log('\ndataBuffer.length: ' + dataBuffer.length);
    var msg = new Buffer(dataBuffer);
    client.write(msg);
    client.pause();
});

client.on('connect', function(exception) {
    console.log('after connect');
});

client.on('data', function(data) {
    console.log('DATA: ' + data);
});

client.on('error', function(exception) {
    console.log('Connection exception');
});

client.on('timeout', function() {
    console.log('Connection timeout');
});

client.on('drain', function() {
    console.log('Connection drain');
});

client.on('end', function() {
    console.log('Connection end');
});

client.on('close', function(had_error) {
    console.log('Connection closed, had_error:' + had_error);
});