django: add rpc.js

Signed-off-by: Florian Scherf <f.scherf@pengutronix.de>

Author: fscherf

MANIFEST.in

@@ -0,0 +1 @@
+recursive-include aiohttp_json_rpc/django/static *

aiohttp_json_rpc/django/static/rpc.js

@@ -0,0 +1,149 @@
+function RPC(host) {
+    this._host = host;
+    this._message_id = 1;
+    this._pending = {};
+    this._topic_handler = {};
+    this._onopen_handler = [];
+    this._onclose_handler = [];
+    this.methods = {};
+    this.DEBUG = false;
+
+    this._handle_request = function(data) {
+        if(data.method in this.methods) {
+            var result = this.methods[data.method](data.params);
+
+            var response = {
+                jsonrpc: '2.0',
+                id: data.id,
+                result: result,
+            }
+
+            this._ws.send(JSON.stringify(response));
+        }
+    }
+
+    this.connect = function() {
+        this._ws = new WebSocket(this._host);
+        this._ws._rpc = this;
+
+        // onopen
+        this._ws.onopen = function(event) {
+            for(i in this._rpc._onopen_handler) {
+                this._rpc._onopen_handler[i](this._rpc);
+            }
+        };
+
+        // onclose
+        this._ws.onclose = function(event) {
+            for(i in this._rpc._onclose_handler) {
+                this._rpc._onclose_handler[i](this._rpc);
+            }
+        };
+
+        // onmessage
+        this._ws.onmessage = function(event) {
+            data = JSON.parse(event.data);
+
+            if (this._rpc.DEBUG) {
+                console.log('RPC <<', data);
+            }
+
+            if('method' in data) {
+                if('id' in data && data.id != null) {  // request
+                    this._rpc._handle_request(data);
+
+                } else {  // notification
+                    if(data.method in this._rpc._topic_handler) {
+                        this._rpc._topic_handler[data.method](data.params);
+                    }
+                }
+
+            } else {
+                if('id' in data && data.id in this._rpc._pending) {
+                    if('error' in data) {  // error
+                        this._rpc._pending[data.id].error_handler(
+                            data.error, this._rpc);
+
+                    } else if('result' in data) {  // result
+                            this._rpc._pending[data.id].success_handler(
+                                data.result, this._rpc);
+                    }
+
+                    delete this._rpc._pending[data.id];
+                }
+            }
+        };
+    };
+
+    this.disconnect = function(event) {
+        this._ws.close();
+    };
+
+    this.on = function(event_name, handler) {
+        switch(event_name) {
+            case 'open':
+                this._onopen_handler.push(handler);
+                break;
+
+            case 'close':
+                this._onclose_handler.push(handler);
+                break;
+
+            default:
+                throw "RPC.on: unknown event'" + event_name + "'";
+        }
+    };
+
+    this.call = function(method, params, success_handler, error_handler) {
+        var id = this._message_id;
+        this._message_id += 1;
+
+        var request = {
+            jsonrpc: '2.0',
+            id: id,
+            method: method,
+            params: params
+        };
+
+        // default handler
+        if(this.DEBUG) {
+            this._pending[id] = {
+                success_handler: function(data) {
+                    console.log('RPC success:', data)
+                },
+                error_handler: function(data) {
+                    console.log('RPC error:', data)
+                },
+            }
+        } else {
+            this._pending[id] = {
+                success_handler: function(data) {},
+                error_handler: function(data) {},
+            }
+        }
+
+        // custom handler
+        if(success_handler)
+            this._pending[id].success_handler = success_handler;
+
+        if(error_handler)
+            this._pending[id].error_handler = error_handler;
+
+        var request_data = JSON.stringify(request);
+        this._ws.send(request_data);
+
+        if(this.DEBUG) {
+            console.log('RPC >>', request);
+        }
+    };
+
+    this.subscribe = function(topic, handler) {
+        this.call('subscribe', topic, function(data) {
+            if(data.indexOf(topic) > -1 && handler) {
+                rpc._topic_handler[topic] = handler;
+            } else {
+                throw "RPC.subscribe: unknown topic '" + topic + "'";
+            }
+        });
+    };
+}