node-postgres/lib/index.js

var EventEmitter = require('events').EventEmitter;
var sys = require('sys');
var net = require('net');
var NUL = '\0';

var chars = Buffer('RS','utf8');
var UTF8 = {
  R: chars[0],
  S: chars[1]
};


var Client = function(config) {
  EventEmitter.call(this);
  config = config || {};
  this.user = config.user;
  this.database = config.database;
  this.port = config.port || 5432;
};
sys.inherits(Client, EventEmitter);

Client.prototype.connect = function() {
  var con = net.createConnection(this.port);
  var self = this;
  con.on('connect', function() {

    var data = ['user',self.user,'database', self.database,NUL].join(NUL);
    var dataBuffer = Buffer(data);
    var fullBuffer = Buffer(8 + dataBuffer.length);
    fullBuffer[0] = fullBuffer.length >>> 24;
    fullBuffer[1] = fullBuffer.length >>> 16;
    fullBuffer[2] = fullBuffer.length >>> 8;
    fullBuffer[3] = fullBuffer.length >>> 0;
    fullBuffer[4] = 0;
    fullBuffer[5] = 3;
    fullBuffer[6] = 0;
    fullBuffer[7] = 0;
    fullBuffer.write(data,8);
    console.log(fullBuffer);
    con.write(fullBuffer);
  });
  con.on('data', function(data) {
    console.log('data!');
    console.log(data);
  });
};

var Parser = function(buffer) {
  this.offset = 0;
  this.buffer = buffer;
};

var p = Parser.prototype;

p.parse =  function(buffer) {
  switch(this.buffer[this.offset]) {
  case UTF8.R:
    return this.parseR();
  case UTF8.S:
    return this.parseS();
  default:
    throw new Error("Unsupported message ID");
  }
};

p.parseR = function() {
  var type = this.buffer[this.offset++];
  var length = this.parseLength();
  if(length == 8) {
    return {
      name: 'AuthenticationOk',
      id: 'R',
      length: length
    }
  }
  throw new Error("Unknown AuthenticatinOk message type");
};
p.parseS = function(buffer) {
  var type = this.buffer[this.offset++];
  var length = this.parseLength(this.buffer);
  var parameterName = this.parseCString();
  var parameterValue = this.parseCString();
  return {
    name: 'ParameterStatus',
    id: 'S',
    length: length,
    parameterName: parameterName,
    parameterValue: parameterValue
  }
};

p.parseLength =  function() {
  var buffer = this.buffer;
  return ((buffer[this.offset++] << 24) +
          (buffer[this.offset++] << 16) +
          (buffer[this.offset++] << 8) +
          buffer[this.offset++]);

};

p.parseCString = function(buffer) {
  var start = this.offset;
  while(this.buffer[this.offset++]) { };
  return this.buffer.toString('utf8',start, this.offset - 1);
};


module.exports = {
  Client: Client,
  Parser: Parser
};