stable

Author: deadBranch

.gitignore

@@ -0,0 +1,2 @@
+.idea/
+node_modules/

index.js

@@ -1,50 +1,27 @@
-var twc = require('./twc.js');
+var twc = require('./tokenwizard.js');
 
 twc.init(32);
 twc.connect();
-//twc.get_token("222sfsfsfsadfsfsfsdfpoiwerpowe222", function (err, data) {
-//    if(!err)
-//        console.log(data);
-//});
+twc.invalidate("xya0baHvB2Nwx44xSWrkWtmyompvGGnlgY4Ken", function (err) {
+
+});
+twc.get_token("xya0baHvB2Nwx44xSWrkWtmyompvGGnlgY4Ken", function (err, data) {
+    if(!err)
+       console.log(data.toString('ascii'));
+});
 
 var i = 1;
 var foo;
 
-
-foo = function() {
-    twc.gen_token(Buffer.from("lalka", 'ascii'), 10, function (err, data) {
-        if(!err)
-        {
-            //console.log(data.toString('ascii'));
-            ++i;
-
-        }
-        else
-            console.log("Threre is no token!");
-    });
-   /* twc.get_token("VrB4dacv8L239RPEOsRsgHh1WGcCKHw0jiPhTv", function (err, data) {
-        if(!err)
-        {
-            ++i;
-            console.log(data.toString('ascii'));
-            console.log(data.length);
-        }
-        else
-        {
-            ++i;
-            console.log("Threre is no token!");
-        }
-    });
-    /**/
-
-    setImmediate(function () {
-        foo();
-    });
-};
-foo();
-
-
-
+twc.gen_token(Buffer.from("12345", 'ascii'), 1000, function (err, data) {
+    if(!err)
+    {
+        console.log(data.toString('ascii'));
+        ++i;
+    }
+    else
+        console.log("Threre is no token!");
+});
 
 /*
 */
@@ -54,7 +31,7 @@ benchmark = function() {
     i = 0;
     setTimeout(benchmark, 1000);
 };
-benchmark();
+//benchmark();
 
 function randomInt (low, high) {
     return Math.floor(Math.random() * (high - low) + low);

twc.js renamed to tokenwizard.js

@@ -1,16 +1,19 @@
 var net = require('net');
-var LinkedList = require('./LinkedList').LinkedList
+var LinkedList = require('./LinkedList').LinkedList;
 var Buffer = require('buffer').Buffer;
+var fs = require('fs');
+
+console.log(a);
 
 var ClientCommands = {
     genToken : 0x0,
     invalidateToken : 0x1,
     getToken : 0x2
 };
 
-var ServerResponse = {
+var ServerResponses = {
     tokenCreated : 0x0,
-    tokenDestroyed : 0x1,
+    tokenInvalidated : 0x1,
     tokenDoesNotExist : 0x2,
     tokenExists : 0x3
 };
@@ -19,17 +22,12 @@ var client = new net.Socket();
 exports.client = client;
 var tokenLength;
 
-function int32ToBytes(num) {
-    arr = new ArrayBuffer(4); // an Int32 takes 4 bytes
-    view = new DataView(arr);
-    view.setUint32(0, num, false); // byteOffset = 0; litteEndian = false
-    return arr;
-}
+var sendBuff = new Buffer(65536);
+var sendBuffWritePos = 0;
+var isSendTaskStarted = false;
 
-console.log("lalka");
-var requestQueue = new LinkedList();
-var inputData;
 
+var requestQueue = new LinkedList();
 
 exports.init = function (_tokenLength) {
     tokenLength = _tokenLength;
@@ -80,7 +78,8 @@ exports.gen_token = function(dataBuf, lifeTime, handler) {
     requestQueue.push(handler);
 };
 
-exports.connect = function () {
+exports.connect = function (ip, port) {
+
     client.connect(10200, '127.0.0.1', function() {
         console.log('Connected');
         //client.write('Hello, server! Love, Client.');
@@ -96,7 +95,7 @@ var inputLength = 0;
 function handlePacket(packet) {
     var token = packet.readUInt8(0);
     switch(token) {
-        case ServerResponse.tokenExists:
+        case ServerResponses.tokenExists:
         {
             var retBuff = Buffer.allocUnsafe(packet.length-1);
             packet.copy(retBuff, 0, 1, packet.length);
@@ -108,7 +107,7 @@ function handlePacket(packet) {
             }, 0);
             break;
         }
-        case ServerResponse.tokenCreated:
+        case ServerResponses.tokenCreated:
         {
             var retBuff = Buffer.allocUnsafe(packet.length-1);
             packet.copy(retBuff, 0, 1, packet.length);
@@ -118,16 +117,24 @@ function handlePacket(packet) {
             }, 0);
             break;
         }
-        case ServerResponse.tokenDoesNotExist:
+        case ServerResponses.tokenDoesNotExist:
         {
             var handler = requestQueue.pop().value;
             setTimeout(function() {
                 handler(true);
             }, 0);
             break;
         }
+        case ServerResponses.tokenInvalidated:
+        {
+            var handler = requestQueue.pop().value;
+            setTimeout(function() {
+                handler(false);
+            }, 0);
+            break;
+        }
         default: {
-            console.log("THERE IS NO HANDLER");
+            console.error("THERE IS NO HANDLER");
         }
     }
 }
@@ -166,5 +173,4 @@ client.on('data', function(data) {
 
 client.on('close', function() {
     console.log('Connection closed');
-});
-
+});