ok now i can ping fff

Author: DevilstarII

lib/connection.js

@@ -5,7 +5,7 @@ var _ = require('underscore');
 var EventEmitter = require('events');
 var msgpack = require('msgpack');
 
-const states = {
+var states = {
     CONNECTING: 0,
     CONNECTED: 1,
     AWAITING: 2,
@@ -16,7 +16,7 @@ const states = {
     PREHELLO: 7
 };
 
-const commandType = {
+var commandType = {
     CONNECT: 0,
     REQUEST: 1
 };
@@ -58,7 +58,7 @@ TarantoolConnection.prototype.onData = function(data){
     console.log(data.length, data.toString());
     switch(this.state){
         case states.PREHELLO:
-            for (let i = 0; i<this.commandsQueue.length; i++)
+            for (var i = 0; i<this.commandsQueue.length; i++)
             {
                 if (this.commandsQueue[i][0] == commandType.CONNECT)
                 {
@@ -69,6 +69,9 @@ TarantoolConnection.prototype.onData = function(data){
             }
             this.state = states.CONNECTED;
             break;
+        case states.CONNECTED:
+            new TarantoolResponse(data);
+            break;
     }
 };
 
@@ -77,7 +80,7 @@ TarantoolConnection.prototype.onConnect = function(){
 };
 
 TarantoolConnection.prototype.onError = function(error){
-    for (let i=0; i<this.commandsQueue.length; i++)
+    for (var i=0; i<this.commandsQueue.length; i++)
         this.commandsQueue[i][2](error);
     this.commandsQueue = [];
 };
@@ -92,13 +95,39 @@ TarantoolConnection.prototype.connect = function(){
 };
 
 TarantoolConnection.prototype.ping = function(){
+    console.log('start ping');
+    var header = this._header(tarantoolConstants.RequestCode.rqPing);
+    console.log('header', header);
+    var body = new Buffer(0);
+    this._request(header, body);
+};
 
+
+TarantoolConnection.prototype._header = function(command){
+    try {
+        var header = new Buffer([0x82, tarantoolConstants.KeysCode.code, command,
+            tarantoolConstants.KeysCode.sync, 0xce, 0, 0, 0, 0]);
+        header.writeUIntBE(requestId.getId(), 5, 4);
+        return header;
+    } catch(e){
+        console.log(e, e.stack);
+    }
 };
 
 TarantoolConnection.prototype._request = function(header, body){
+    console.log('start request');
     var sumL = header.length + body.length;
     var prefixSizeBuffer = new Buffer(5);
-    socket.write()
+    prefixSizeBuffer[0] = 0xCE;
+    prefixSizeBuffer.writeUIntBE(sumL, 1, 4);
+    try {
+        var buffer = Buffer.concat([prefixSizeBuffer, header, body]);
+        console.log(buffer);
+        this.socket.write(buffer);
+    } catch (e){
+        console.log(e, e.stack);
+    }
+
 };
 
 TarantoolConnection.prototype.destroy = function(interupt){
@@ -112,4 +141,35 @@ TarantoolConnection.prototype.destroy = function(interupt){
     }
 };
 
+//@InputType(Buffer)
+function TarantoolResponse(buffer){
+    this.ended = false;
+    var length = buffer.readUIntBE(1, 4);
+    console.log('len', length);
+    this.buffer = buffer;
+    if (this.buffer.length - 5 == length)
+    {
+        this.ended = true;
+        this.processing();
+    }
+}
+
+TarantoolResponse.prototype.processing = function(){
+    try{
+        this.success = this.buffer[6] == 0x00;
+        console.log(this.buffer);
+        if (this.success){
+            var dataBuffer = this.buffer.slice(13);
+            console.log(dataBuffer);
+            var obj = msgpack.unpack(dataBuffer);
+            console.log(obj);
+        }
+        else{
+            console.log('its error');
+        }
+    } catch(e){
+        console.log(e, e.stack);
+    }
+};
+
 module.exports = TarantoolConnection;

test/app.js

@@ -7,6 +7,7 @@ var conn = new TarantoolConnection({port: 33013, host: '95.85.55.64'});
 conn.connect()
     .then(function(){
         console.log('resolve');
+        conn.ping();
     }, function(e){
         console.log('reject');
     })