dan/node-x11
1
0
Fork 0
mirror of https://github.com/danbulant/node-x11 synced 2026-06-15 04:31:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

initial X bridge library code

Browse source
This commit is contained in:
Andrey Sidorov 2012-04-05 12:36:38 +10:00
parent 3cb9e2a85f
commit c26bc6b47d
1 changed files with 91 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

91
lib/x11/xserver.js Normal file
View file

@ -0,0 +1,91 @@
"use strict";
var util = require('util');
var net = require('net');
var PackStream = require('./unpackstream');
var EventEmitter = require('events').EventEmitter;
function XServer(servsock, params)
{
var server = this;
EventEmitter.call(this);
servsock.on('connection', function(stream) {
var cli = new XServerClientConnection(stream, params);
server.emit('connection', cli);
});
}
util.inherits(XServer, EventEmitter);
function XServerClientConnection(stream, params)
{
EventEmitter.call(this);
this.params = params;
var serv = this;
serv.stream = stream;
serv.pack_stream = new PackStream();
serv.pack_stream.on('data', function( data ) {
serv.stream.write(data);
});
stream.on('data', function( data ) {
serv.pack_stream.write(data);
});
serv.readClientHandshake();
}
util.inherits(XServerClientConnection, EventEmitter);
XServerClientConnection.prototype.readClientHandshake = function()
{
var serv = this;
var hello = {};
serv.pack_stream.unpackTo(hello,
[
'C byteOrder',
'x',
'S protocolMajor',
'S protocolMinor',
'S authTypeLength',
'S authDataLength',
],
function() {
console.log(hello);
serv.pack_stream.get(hello.authTypeLength, function(authType) {
serv.pack_stream.get(hello.authDataLength, function(authData) {
serv.byteOrder = hello.byteOrder;
serv.protocolMajor = hello.protocolMajor;
serv.protocolMinor = hello.protocolMinor;
serv.checkAuth(authType.toString('ascii'), authData);
});
});
}
);
}
XServerClientConnection.prototype.checkAuth = function(authType, authData)
{
var serv = this;
// ignore check for now;
// protocol page 140: add code for reject & ask additional info
console.log([authType, authData]);
console.log('Not YET');
//serv.pack_stream.unpack('C', function(isShared) {
// console.log([isShared]);
// serv.writeServerInit();
//});
}
XServerClientConnection.prototype.expectMessage = function()
{
var serv = this;
//serv.pack_stream.get(1, function(msgType) {
//});
}
module.exports.createServer = function(listenport, params) {
var s = net.createServer();
s.listen(listenport);
return new XServer(s, params);
}
module.exports.createServer(6001) ;
//function(client) {
//});