Login Repsonse

sidneyfilho · sidneyfilho · commit 0070c25656d0 · 2011-09-02T18:30:59.000-03:00
diff --git a/example.js b/example.js
@@ -1,7 +1,7 @@
 var mssql = require('./lib/mssql');
 
 //try a connection
-var connectionString = { Server: "127.0.0.1", Port: 1433, Database: "master", Login: "sa", Password: "yyy", Timeout: 15000 };
+var connectionString = { Server: "127.0.0.1", Port: 1433, Database: "master", Login: "sa", Password: "", Timeout: 15000 };
 var conn = new mssql.SqlConnection(connectionString, function() {
     //this.Open(function() { console.log(this.Version); this.Close(); });
 });
diff --git a/lib/mssql.js b/lib/mssql.js
@@ -6,8 +6,16 @@ var util = require('util');
 var assert = require('assert');
 var TdsBuilder = require('../lib/tds.js').TdsBuilder
 
+
+/*
+** Default Connection String
+*/
 var connectionStringDefault = { Server: '127.0.0.1', Port: '1433', Database: 'master', Login: 'sa', Password: '', Timeout: 10000 };
 
+
+/*
+** SqlConnection
+*/
 var SqlConnection = function(connString, callback) {
     assert.ok(arguments.length !== 0, "Connection String is missing!");
 
@@ -25,30 +33,33 @@ var SqlConnection = function(connString, callback) {
     for (var key in connectionStringDefault)
         it.ConnectionString[key] = it.ConnectionString[key] || connectionStringDefault[key];
 
-
     //
     // Create a Connection to get MS SQL Version
-    //
-
-    net.createConnection(it.ConnectionString.Port, it.ConnectionString.Server, function() {
-        var buffer = TdsBuilder.HandshakeRequest();
-        var res = it.socket.end(buffer);
-    }).on("data", function(data) {
-        it.Version = TdsBuilder.HandshakeResponse(data).Version;
-        console.log("My Version is " + util.inspect(it.Version));
-    });
+    //    
+    it.socket = new net.Socket({ allowHalfOpen: true }).on("connect", function() {
 
-    //
-    // Create other Connection
-    //
-    it.socket = net.createConnection(it.ConnectionString.Port, it.ConnectionString.Server, function() {
+        //var buffer = TdsBuilder.HandshakeRequest();
         var buffer = TdsBuilder.LoginRequest(it.ConnectionString.Login, it.ConnectionString.Password, it.ConnectionString.Database);
-        var res = it.socket.write(buffer);
-    }).on("data", function(data) {
-        console.log("Open(callback) End " + data.length);
-        callback && callback.call(it);
+        var res = this.write(buffer);
+        console.log("CLIENT sent LOGIN7 ");
+
+    }).once("data", function(data) {
+        var response = TdsBuilder.LoginResponse(data);
+        //it.Version = response.Version;
+        //console.log("CLIENT received PRELOGIN: " + util.inspect(response) + data.length);
+
+        //var buffer = TdsBuilder.LoginRequest(it.ConnectionString.Login, it.ConnectionString.Password, it.ConnectionString.Database);
+        //var res = it.socket.write(buffer);
+        //console.log("CLIENT sent LOGIN7 ");
+
+        //it.socket.on("data", function(data) {
+        //    console.log("CLIENT received LOGIN7  " + data.length);
+        //    callback && callback.call(it);
+        //});
+
     });
 
+
     // TIMEOUT
     it.socket.setTimeout(it.ConnectionString.Timeout);
     it.socket.on("timeout", function() { console.log("timeout"); it.Close(); });
@@ -61,13 +72,15 @@ var SqlConnection = function(connString, callback) {
     //this.socket.on("close", function(data) { console.log("close"); });    
     //this.socket.on("end", function(data) { console.log("end"); });
     //this.socket.on("connect", function(data) { console.log("connect"); });
-    //this.socket.connect(this.ConnectionString.Port, this.ConnectionString.Server);
+    this.socket.connect(this.ConnectionString.Port, this.ConnectionString.Server);
 
 
 
     return it;
 }
 
+
+
 SqlConnection.prototype.Close = function() {
     console.log("Close()");
     this.socket.end();
diff --git a/lib/tds.js b/lib/tds.js
@@ -164,7 +164,8 @@ TdsBuilder.HandshakeRequest = function(useMars) {
     msg.addData([0xFF]); // Terminator
 
     var buf = msg.toBuffer();
-    buf[3] = buf.length;
+
+    buf.writeUInt8(buf.length, 3, true);
 
     //return new Buffer([0x12, 0x01, 0x00, 0x2F, 0x00, 0x00, 0x01, 0x00, 0x00, 0x00, 0x1A, 0x00, 0x06, 0x01, 0x00, 0x20,0x00, 0x01, 0x02, 0x00, 0x21, 0x00, 0x01, 0x03, 0x00, 0x22, 0x00, 0x04, 0x04, 0x00, 0x26, 0x00,0x01, 0xFF, 0x09, 0x00, 0x00, 0x00, 0x00, 0x00, 0x01, 0x00, 0xB8, 0x0D, 0x00, 0x00, 0x01]);
 
@@ -198,7 +199,8 @@ TdsBuilder.HandshakeResponse = function(buffer) {
             Major: tmp.readUInt8(0, true),
             Minor: tmp.readUInt8(1, true),
             Revision: tmp.readUInt16(2, true) // 6->0x6, 64->0x40 = 0x640 = 1600
-        }
+        },
+        UseEncrypt: tmp.readUInt16(4, true)
     };
 }
 
@@ -225,10 +227,10 @@ TdsBuilder.LoginRequest = function(username, password, database/* , hostname, ap
     // 2008 -> 0x03000A73
     // 2008 -> 0x03000B73
     // SQL Server Denali -> 0x04000074
-    msg.addData([0x02, 0, 0x09, 0x72]); // 2005 TDS version
+    msg.addData([0x03, 0, 0x0A, 0x73]); // 2008 TDS version
 
     msg.addData([0, 0x10, 0, 0]); // PacketSize
-    msg.addData([0, 0, 0, 0x1]); // Client Prog ver
+    msg.addData([0, 0, 0, 0x7]); // Client Prog ver
     msg.addData([0, 0x1, 0, 0]); // Client Process ID
     msg.addData([0, 0, 0, 0]); // Connection ID
 
@@ -288,18 +290,70 @@ TdsBuilder.LoginRequest = function(username, password, database/* , hostname, ap
     msg.addData([0x00, 0x00, 0x00, 0x00]);
 
     var buf = msg.toBuffer();
-    buf[3] = buf.length;
-    buf[8] = buf[3] - 8;
+
+    buf.writeUInt8(buf.length, 3, false);
+    buf.writeUInt32(buf.length - 8, 8, false);
+
 
     //return new Buffer([0x10, 0x01, 0x00, 0x90, 0x00, 0x00, 0x01, 0x00, 0x88, 0x00, 0x00, 0x00, 0x02, 0x00, 0x09, 0x72, 0x00, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07, 0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xE0, 0x03, 0x00, 0x00, 0xE0, 0x01, 0x00, 0x00, 0x09, 0x04, 0x00, 0x00, 0x5E, 0x00, 0x08, 0x00, 0x6E, 0x00, 0x02, 0x00, 0x72, 0x00, 0x00, 0x00, 0x72, 0x00, 0x07, 0x00, 0x80, 0x00, 0x00, 0x00, 0x80, 0x00, 0x00, 0x00, 0x80, 0x00, 0x04, 0x00, 0x88, 0x00, 0x00, 0x00, 0x88, 0x00, 0x00, 0x00, 0x00, 0x50, 0x8B, 0xE2, 0xB7, 0x8F, 0x88, 0x00, 0x00, 0x00, 0x88, 0x00, 0x00, 0x00, 0x88, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x73, 0x00, 0x6B, 0x00, 0x6F, 0x00, 0x73, 0x00, 0x74, 0x00, 0x6F, 0x00, 0x76, 0x00, 0x31, 0x00, 0x73, 0x00, 0x61, 0x00, 0x4F, 0x00, 0x53, 0x00, 0x51, 0x00, 0x4C, 0x00, 0x2D, 0x00, 0x33, 0x00, 0x32, 0x00, 0x4F, 0x00, 0x44, 0x00, 0x42, 0x00, 0x43, 0x00]);
 
     return buf;
 }
 
 
+/*
+** Login Response is a token stream, then needs read the token and read your content, read next token and so on
+*/
 TdsBuilder.LoginResponse = function(buffer) {
     assert.ok(arguments.length === 1, "The argument 'buffer' is missing!");
     assert.ok(buffer[0] === 0x04, "This buffer is not Server Response or type bit not is 0x04!");
+
+    var offset = 8; /* header length*/
+    var response = {
+        envchange: [],
+        info: []
+    };
+
+    while (offset < buffer.length) {
+
+        var token = buffer.readUInt8(offset, false); offset += 1;
+
+        //
+        // ENVCHANGE
+        //
+        if (token === 0xE3) {
+            var length = buffer.readUInt16(offset, false); offset += 2;
+            var type = buffer.readUInt8(offset, false); //offset += 1;
+
+            var data = buffer.slice(offset, offset + length); offset += length;
+
+            response.envchange.push({ type: type, offset: offset, length: length, data: data });
+        }
+
+
+
+        //
+        // INFO
+        //
+        if (token === 0xAB) {
+            var info = {};
+            info.length = buffer.readUInt16(offset, false); offset += 2;
+            info.number = buffer.readUInt32(offset, false); //offset += 4;
+            info.state = buffer.readUInt8(offset, false); //offset += 1;
+            info.classType = buffer.readUInt8(offset, false); //offset += 1;
+            info.msgLength = buffer.readUInt16(offset, false); //offset += 2;
+            info.msg = buffer.toString('utf8', offset + 4 + 1 + 1 + 2, offset + 4 + 1 + 1 + 2 + info.length).replace(/\u0000/g,''); offset += info.length;
+
+            response.info.push(info);
+        }
+
+
+        //return response;
+    }
+
+
+    console.log(response);
+    return response;
 }
 
 exports.ExecuteQuery = function ExecuteQuery(query) {
diff --git a/tests/test-tds.js b/tests/test-tds.js
@@ -78,7 +78,7 @@ assert.equal(builder.toBuffer().length, 8 /*header */
 builder = new TdsBuilder();
 builder.addPacketData([1, 2, 3, 4, 5, 6]);
 assert.equal(builder.toBuffer().length, 8 /*header */
-                                      + 2 /*offset byte*/ + 2 /*length byte*/                                    
+                                      + 2 /*offset byte*/ + 2 /*length byte*/
                                       + 6 /*token data*/);
 builder = new TdsBuilder();
 builder.addHeaderPacket(0x12);
@@ -87,7 +87,7 @@ builder.addPacketData([9, 9]);
 assert.equal(builder.toBuffer().length, 8 /*header */
                                       + 4 /*token 1*/
                                       + 4 /*token 2*/
-                                      
+
                                       + 6 /*token 1 data*/
                                       + 2 /*token 2 data*/);
 
@@ -145,27 +145,28 @@ http://msdn.microsoft.com/en-us/library/dd358344(v=PROT.13).aspx
 */
 var expected = new Buffer([
     0x10, 0x01, 0x00, 0x90, 0x00, 0x00, 0x01, 0x00,
-    0x88, 0x00, 0x00, 0x00, 0x02, 0x00, 0x09, 0x72,
-    0x00, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07, 
+    0x88, 0x00, 0x00, 0x00, 0x03, 0x00, 0x0A, 0x73,
+    0x00, 0x10, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07,
     0x00, 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
-    0xE0, 0x03, 0x00, 0x00, 0xE0, 0x01, 0x00, 0x00, 
+    0xE0, 0x03, 0x00, 0x00, 0xE0, 0x01, 0x00, 0x00,
     0x09, 0x04, 0x00, 0x00, 0x5E, 0x00, 0x08, 0x00,
-    0x6E, 0x00, 0x02, 0x00, 0x72, 0x00, 0x00, 0x00, 
+    0x6E, 0x00, 0x02, 0x00, 0x72, 0x00, 0x00, 0x00,
     0x72, 0x00, 0x07, 0x00, 0x80, 0x00, 0x00, 0x00,
-    0x80, 0x00, 0x00, 0x00, 0x80, 0x00, 0x04, 0x00, 
+    0x80, 0x00, 0x00, 0x00, 0x80, 0x00, 0x04, 0x00,
     0x88, 0x00, 0x00, 0x00, 0x88, 0x00, 0x00, 0x00,
-    0x00, 0x50, 0x8B, 0xE2, 0xB7, 0x8F, 0x88, 0x00, 
+    0x00, 0x50, 0x8B, 0xE2, 0xB7, 0x8F, 0x88, 0x00,
     0x00, 0x00, 0x88, 0x00, 0x00, 0x00, 0x88, 0x00,
-    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x73, 0x00, 
+    0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x73, 0x00,
     0x6B, 0x00, 0x6F, 0x00, 0x73, 0x00, 0x74, 0x00,
-    0x6F, 0x00, 0x76, 0x00, 0x31, 0x00, 0x73, 0x00, 
+    0x6F, 0x00, 0x76, 0x00, 0x31, 0x00, 0x73, 0x00,
     0x61, 0x00, 0x4F, 0x00, 0x53, 0x00, 0x51, 0x00,
-    0x4C, 0x00, 0x2D, 0x00, 0x33, 0x00, 0x32, 0x00, 
+    0x4C, 0x00, 0x2D, 0x00, 0x33, 0x00, 0x32, 0x00,
     0x4F, 0x00, 0x44, 0x00, 0x42, 0x00, 0x43, 0x00
 ]);
 var atual = TdsBuilder.LoginRequest("sa", "", "", "skostov1", "OSQL-32");
 
 assert.equal(atual.length, expected.length);
+for (var i = 0; i < expected.length; i++) if (expected[i] !== atual[i]) assert.fail(atual[i], expected[i], "i = " + i);
 assert.equal(atual.inspect(), expected.inspect());
 
 
@@ -177,29 +178,30 @@ http://msdn.microsoft.com/en-us/library/dd303700(v=PROT.13).aspx
 
 */
 
-var expected = new Buffer([
-    0x04, 0x01, 0x01, 0x61, 0x00, 0x00, 0x01, 0x00, 0xE3, 0x1B, 0x00, 0x01, 0x06, 0x6D, 0x00, 0x61, 
-    0x00, 0x73, 0x00, 0x74, 0x00, 0x65, 0x00, 0x72, 0x00, 0x06, 0x6D, 0x00, 0x61, 0x00, 0x73, 0x00, 
-    0x74, 0x00, 0x65, 0x00, 0x72, 0x00, 0xAB, 0x58, 0x00, 0x45, 0x16, 0x00, 0x00, 0x02, 0x00, 0x25, 
-    0x00, 0x43, 0x00, 0x68, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x65, 0x00, 0x64, 0x00, 0x20, 
-    0x00, 0x64, 0x00, 0x61, 0x00, 0x74, 0x00, 0x61, 0x00, 0x62, 0x00, 0x61, 0x00, 0x73, 0x00, 0x65, 
-    0x00, 0x20, 0x00, 0x63, 0x00, 0x6F, 0x00, 0x6E, 0x00, 0x74, 0x00, 0x65, 0x00, 0x78, 0x00, 0x74, 
-    0x00, 0x20, 0x00, 0x74, 0x00, 0x6F, 0x00, 0x20, 0x00, 0x27, 0x00, 0x6D, 0x00, 0x61, 0x00, 0x73, 
+var buffer = new Buffer([
+    0x04, 0x01, 0x01, 0x61, 0x00, 0x00, 0x01, 0x00, 0xE3, 0x1B, 0x00, 0x01, 0x06, 0x6D, 0x00, 0x61,
+    0x00, 0x73, 0x00, 0x74, 0x00, 0x65, 0x00, 0x72, 0x00, 0x06, 0x6D, 0x00, 0x61, 0x00, 0x73, 0x00,
+    0x74, 0x00, 0x65, 0x00, 0x72, 0x00, 0xAB, 0x58, 0x00, 0x45, 0x16, 0x00, 0x00, 0x02, 0x00, 0x25,
+    0x00, 0x43, 0x00, 0x68, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x65, 0x00, 0x64, 0x00, 0x20,
+    0x00, 0x64, 0x00, 0x61, 0x00, 0x74, 0x00, 0x61, 0x00, 0x62, 0x00, 0x61, 0x00, 0x73, 0x00, 0x65,
+    0x00, 0x20, 0x00, 0x63, 0x00, 0x6F, 0x00, 0x6E, 0x00, 0x74, 0x00, 0x65, 0x00, 0x78, 0x00, 0x74,
+    0x00, 0x20, 0x00, 0x74, 0x00, 0x6F, 0x00, 0x20, 0x00, 0x27, 0x00, 0x6D, 0x00, 0x61, 0x00, 0x73,
     0x00, 0x74, 0x00, 0x65, 0x00, 0x72, 0x00, 0x27, 0x00, 0x2E, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
-    0x00, 0xE3, 0x08, 0x00, 0x07, 0x05, 0x09, 0x04, 0xD0, 0x00, 0x34, 0x00, 0xE3, 0x17, 0x00, 0x02, 
-    0x0A, 0x75, 0x00, 0x73, 0x00, 0x5F, 0x00, 0x65, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x6C, 0x00, 0x69, 
-    0x00, 0x73, 0x00, 0x68, 0x00, 0x00, 0xE3, 0x13, 0x00, 0x04, 0x04, 0x34, 0x00, 0x30, 0x00, 0x39, 
-    0x00, 0x36, 0x00, 0x04, 0x34, 0x00, 0x30, 0x00, 0x39, 0x00, 0x36, 0x00, 0xAB, 0x5C, 0x00, 0x47, 
-    0x16, 0x00, 0x00, 0x01, 0x00, 0x27, 0x00, 0x43, 0x00, 0x68, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67, 
-    0x00, 0x65, 0x00, 0x64, 0x00, 0x20, 0x00, 0x6C, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x75, 
-    0x00, 0x61, 0x00, 0x67, 0x00, 0x65, 0x00, 0x20, 0x00, 0x73, 0x00, 0x65, 0x00, 0x74, 0x00, 0x74, 
-    0x00, 0x69, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x20, 0x00, 0x74, 0x00, 0x6F, 0x00, 0x20, 0x00, 0x75, 
-    0x00, 0x73, 0x00, 0x5F, 0x00, 0x65, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x6C, 0x00, 0x69, 0x00, 0x73, 
+    0x00, 0xE3, 0x08, 0x00, 0x07, 0x05, 0x09, 0x04, 0xD0, 0x00, 0x34, 0x00, 0xE3, 0x17, 0x00, 0x02,
+    0x0A, 0x75, 0x00, 0x73, 0x00, 0x5F, 0x00, 0x65, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x6C, 0x00, 0x69,
+    0x00, 0x73, 0x00, 0x68, 0x00, 0x00, 0xE3, 0x13, 0x00, 0x04, 0x04, 0x34, 0x00, 0x30, 0x00, 0x39,
+    0x00, 0x36, 0x00, 0x04, 0x34, 0x00, 0x30, 0x00, 0x39, 0x00, 0x36, 0x00, 0xAB, 0x5C, 0x00, 0x47,
+    0x16, 0x00, 0x00, 0x01, 0x00, 0x27, 0x00, 0x43, 0x00, 0x68, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67,
+    0x00, 0x65, 0x00, 0x64, 0x00, 0x20, 0x00, 0x6C, 0x00, 0x61, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x75,
+    0x00, 0x61, 0x00, 0x67, 0x00, 0x65, 0x00, 0x20, 0x00, 0x73, 0x00, 0x65, 0x00, 0x74, 0x00, 0x74,
+    0x00, 0x69, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x20, 0x00, 0x74, 0x00, 0x6F, 0x00, 0x20, 0x00, 0x75,
+    0x00, 0x73, 0x00, 0x5F, 0x00, 0x65, 0x00, 0x6E, 0x00, 0x67, 0x00, 0x6C, 0x00, 0x69, 0x00, 0x73,
     0x00, 0x68, 0x00, 0x2E, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xAD, 0x36, 0x00, 0x01, 0x72,
-    0x09, 0x00, 0x02, 0x16, 0x4D, 0x00, 0x69, 0x00, 0x63, 0x00, 0x72, 0x00, 0x6F, 0x00, 0x73, 0x00, 
-    0x6F, 0x00, 0x66, 0x00, 0x74, 0x00, 0x20, 0x00, 0x53, 0x00, 0x51, 0x00, 0x4C, 0x00, 0x20, 0x00, 
+    0x09, 0x00, 0x02, 0x16, 0x4D, 0x00, 0x69, 0x00, 0x63, 0x00, 0x72, 0x00, 0x6F, 0x00, 0x73, 0x00,
+    0x6F, 0x00, 0x66, 0x00, 0x74, 0x00, 0x20, 0x00, 0x53, 0x00, 0x51, 0x00, 0x4C, 0x00, 0x20, 0x00,
     0x53, 0x00, 0x65, 0x00, 0x72, 0x00, 0x76, 0x00, 0x65, 0x00, 0x72, 0x00, 0x00, 0x00, 0x00, 0x00,
-    0x00, 0x00, 0x00, 0x00, 0xFD, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 
+    0x00, 0x00, 0x00, 0x00, 0xFD, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
     0x00
 ]);
-var atual = TdsBuilder.LoginRequest("sa", "", "");
+
+assert.equal(TdsBuilder.LoginResponse(buffer).envchange, "");
diff --git a/tests/test.js b/tests/test.js
@@ -1 +1,2 @@
-require("./test-tds");
+require("./test-tds");
+require("./test-mssql");

Original file line number	Diff line number	Diff line change
`@@ -1 +1,2 @@`
`1`		`-require("./test-tds");`
	`1`	`+require("./test-tds");`
	`2`	`+require("./test-mssql");`