add pusher modules

Author: 125m125

package.json

@@ -4,7 +4,8 @@
   "description": "A Javascript API to access kadcontrade",
   "main": "target/ktapi-full.js",
   "scripts": {
-    "prepublish": "rollup -c"
+    "prepublish": "rollup -c && rollup --config rollup.config.noPusher.js",
+    "clean": "rm -r target/"
   },
   "repository": {
     "type": "git",
@@ -21,7 +22,8 @@
   "homepage": "https://github.com/125m125/ktapi-js#readme",
   "dependencies": {
     "d3-request": "^1.0.6",
-    "jssha": "^2.3.1"
+    "jssha": "^2.3.1",
+    "pusher": "^1.5.1"
   },
   "devDependencies": {
     "rollup": "^0.50.0"

rollup.config.js

@@ -1,13 +1,14 @@
 export default {
-    input: 'src/index.js',
+    input: 'src/full.js',
     name: 'Kt',
     output: {
         file: 'target/ktapi-full.js',
-        format: 'umd',
+        format: 'umd'
     },
-    external: ['jsSHA','d3-request'],
+    external: ['jsSHA','d3-request','pusher'],
     globals: {
         'jsSHA': 'jsSHA',
-        'd3-request': 'd3'
+        'd3-request': 'd3',
+        'pusher': 'Pusher'
     }
 }

rollup.config.noPusher.js

@@ -0,0 +1,14 @@
+export default {
+    input: 'src/noPusher.js',
+    name: 'Kt',
+    output: {
+        file: 'target/ktapi-noPusher.js',
+        format: 'umd',
+    },
+    external: ['jsSHA','d3-request','pusher'],
+    globals: {
+        'jsSHA': 'jsSHA',
+        'd3-request': 'd3',
+        'pusher': 'Pusher'
+    }
+}

src/full.js

@@ -0,0 +1,3 @@
+export {default as KtApi} from './ktapi/index.js'
+export * from './authenticators/authenticators.js'
+import './pusher/index.js'

src/ktapi/core.js

@@ -6,7 +6,9 @@ export default function (uid, tid, tkn, authenticator) {
         "tid": tid,
         "tkn": tkn
     };
-
+    this.getUserID = function () {
+        return user.uid;
+    }
     this.getRequest = function (method, type, suburl, params, headers, auth) {
         var requestAuthenticator;
         if (auth) {

src/ktapi/index.js

@@ -5,7 +5,6 @@ import './messages.js';
 import './orderbook.js';
 import './payouts.js';
 import './permissions.js';
-import './pusherAuth.js';
 import './trades.js';
 
 export default KtApi;

src/ktapi/pusherAuth.js

@@ -0,0 +1,3 @@
+import './pusherAuth.js';
+import './pusherCore.js';
+import './pusherSubscribtions.js';

src/index.js renamed to src/noPusher.js

@@ -0,0 +1,11 @@
+import { default as KtApi } from '../ktapi/core.js';
+
+KtApi.prototype.pusherAuthenticate = function (socket, channel, callback) {
+    var params;
+    params = {
+        "user": this.getUserID(), // FIXME 
+        "channel_name": channel,
+        "socketId": socket
+    };
+    this.performRequest("POST", "json", "pusher/authenticate?user={user}", params, null, true, callback);
+};

src/pusher/index.js

@@ -0,0 +1,30 @@
+import { default as KtApi } from '../ktapi/core.js';
+import Pusher from 'pusher';
+import './pusherAuth';
+
+KtApi.prototype.pusherSubscribe = function (channelname, callback) {
+    if (!this.pusher) {
+        var self = this;
+        var superCallback = callback;
+        this.pusher = new Pusher('25ba65999fadc5a6e290', {
+            cluster: 'eu',
+            encrypted: true,
+            authorizer: function (channel, options) {
+                return {
+                    authorize: function (socketId, callback) {
+                        self.pusherAuthenticate(socketId, channel.name, function (err, data) {
+                            if (err) {
+                                superCallback(err);
+                                return callback(err);
+                            }
+                            callback(false, JSON.parse(data.authdata));
+                        });
+                    }
+                };
+            }
+        });
+    }
+    this.pusher.subscribe(channelname).bind('update', function(data) {
+        callback(false, JSON.parse(data));
+    });
+}

src/pusher/pusherAuth.js

@@ -0,0 +1,25 @@
+import { default as KtApi } from '../ktapi/core.js';
+import './pusherCore';
+
+function subscribe(ktapi, name, selfCreated, callback) {
+    ktapi.pusherSubscribe('private-' + ktapi.getUserID() + '_r' + name + (selfCreated ? '.selfCreated' : ''), callback);
+}
+
+KtApi.prototype.subscribeItems = function (callback, selfCreated) {
+    subscribe(this, 'Items', selfCreated, callback);
+}
+KtApi.prototype.subscribeOrders = function (callback, selfCreated) {
+    subscribe(this, 'Orders', selfCreated, callback);
+}
+KtApi.prototype.subscribePayouts = function (callback, selfCreated) {
+    subscribe(this, 'Payouts', selfCreated, callback);
+}
+KtApi.prototype.subscribeMessages = function (callback, selfCreated) {
+    subscribe(this, 'Messages', selfCreated, callback);
+}
+KtApi.prototype.subscribeOrderbook = function (callback) {
+    this.pusherSubscribe('order', callback);
+}
+KtApi.prototype.subscribeHistory = function (callback) {
+    this.pusherSubscribe('history', callback);
+}