-
Notifications
You must be signed in to change notification settings - Fork 5
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: available sigver as command line tool
- Loading branch information
Showing
11 changed files
with
438 additions
and
326 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,172 @@ | ||
| (function (global, factory) { | ||
| typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports) : | ||
| typeof define === 'function' && define.amd ? define(['exports'], factory) : | ||
| (factory((global.sigver = global.sigver || {}))); | ||
| }(this, function (exports) { 'use strict'; | ||
|
|
||
| var WebSocketServer = require('ws').Server; | ||
| var WebSocket = require('ws'); | ||
|
|
||
| // CloseEvent codes | ||
| var DATA_SYNTAX_ERROR = 4000; | ||
| var DATA_UNKNOWN_ATTRIBUTE = 4001; | ||
| var KEY_ALREADY_EXISTS = 4002; | ||
| var KEY_UNKNOWN = 4003; | ||
| var KEY_NO_LONGER_AVAILABLE = 4004; | ||
|
|
||
| var settings = { | ||
| host: process.env.NODE_IP || 'localhost', | ||
| port: process.env.NODE_PORT || 8000, | ||
| onStart: function onStart() {} | ||
| }; | ||
| var server = void 0; | ||
|
|
||
| function error(socket, code, msg) { | ||
| console.log('Error ' + code + ': ' + msg); | ||
| socket.close(code, msg); | ||
| } | ||
|
|
||
| function start(options) { | ||
| Object.assign(settings, options); | ||
| server = new WebSocketServer(settings, function () { | ||
| console.log('Server runs on: ' + settings.host + ':' + settings.port); | ||
| settings.onStart(); | ||
| }); | ||
|
|
||
| server.on('connection', function (socket) { | ||
| socket.on('message', function (data) { | ||
| var msg = void 0; | ||
| try { | ||
| msg = JSON.parse(data); | ||
| } catch (event) { | ||
| error(socket, DATA_SYNTAX_ERROR, 'Server accepts only JSON'); | ||
| } | ||
| try { | ||
| if ('key' in msg) { | ||
| var _iteratorNormalCompletion = true; | ||
| var _didIteratorError = false; | ||
| var _iteratorError = undefined; | ||
|
|
||
| try { | ||
| for (var _iterator = server.clients[Symbol.iterator](), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) { | ||
| var master = _step.value; | ||
|
|
||
| if (master.key === msg.key) { | ||
| error(socket, KEY_ALREADY_EXISTS, 'The key already exists'); | ||
| return; | ||
| } | ||
| } | ||
| } catch (err) { | ||
| _didIteratorError = true; | ||
| _iteratorError = err; | ||
| } finally { | ||
| try { | ||
| if (!_iteratorNormalCompletion && _iterator.return) { | ||
| _iterator.return(); | ||
| } | ||
| } finally { | ||
| if (_didIteratorError) { | ||
| throw _iteratorError; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| socket.key = msg.key; | ||
| socket.joiningClients = []; | ||
| } else if ('id' in msg) { | ||
| for (var index in socket.joiningClients) { | ||
| if (index === msg.id.toString()) { | ||
| socket.joiningClients[index].send(JSON.stringify({ data: msg.data })); | ||
| return; | ||
| } | ||
| } | ||
| socket.send(JSON.stringify({ id: msg.id, unavailable: true })); | ||
| } else if ('join' in msg) { | ||
| var _iteratorNormalCompletion2 = true; | ||
| var _didIteratorError2 = false; | ||
| var _iteratorError2 = undefined; | ||
|
|
||
| try { | ||
| for (var _iterator2 = server.clients[Symbol.iterator](), _step2; !(_iteratorNormalCompletion2 = (_step2 = _iterator2.next()).done); _iteratorNormalCompletion2 = true) { | ||
| var _master = _step2.value; | ||
|
|
||
| if (_master.key === msg.join) { | ||
| socket.master = _master; | ||
| _master.joiningClients.push(socket); | ||
| var id = _master.joiningClients.length - 1; | ||
| _master.send(JSON.stringify({ id: id, data: msg.data })); | ||
| return; | ||
| } | ||
| } | ||
| } catch (err) { | ||
| _didIteratorError2 = true; | ||
| _iteratorError2 = err; | ||
| } finally { | ||
| try { | ||
| if (!_iteratorNormalCompletion2 && _iterator2.return) { | ||
| _iterator2.return(); | ||
| } | ||
| } finally { | ||
| if (_didIteratorError2) { | ||
| throw _iteratorError2; | ||
| } | ||
| } | ||
| } | ||
|
|
||
| error(socket, KEY_UNKNOWN, 'Unknown key'); | ||
| } else if ('data' in msg && 'master' in socket) { | ||
| var _id = socket.master.joiningClients.indexOf(socket); | ||
| if (socket.master.readyState === WebSocket.OPEN) { | ||
| socket.master.send(JSON.stringify({ id: _id, data: msg.data })); | ||
| } | ||
| } else { | ||
| console.log('data: ', msg); | ||
| error(socket, DATA_UNKNOWN_ATTRIBUTE, 'Unsupported message format'); | ||
| } | ||
| } catch (event) { | ||
| error(socket, DATA_SYNTAX_ERROR, 'server accepts only JSON'); | ||
| } | ||
| }); | ||
|
|
||
| socket.on('close', function (event) { | ||
| if ('joiningClients' in socket) { | ||
| var _iteratorNormalCompletion3 = true; | ||
| var _didIteratorError3 = false; | ||
| var _iteratorError3 = undefined; | ||
|
|
||
| try { | ||
| for (var _iterator3 = socket.joiningClients[Symbol.iterator](), _step3; !(_iteratorNormalCompletion3 = (_step3 = _iterator3.next()).done); _iteratorNormalCompletion3 = true) { | ||
| var client = _step3.value; | ||
|
|
||
| client.close(KEY_NO_LONGER_AVAILABLE, 'The peer is no longer available'); | ||
| } | ||
| } catch (err) { | ||
| _didIteratorError3 = true; | ||
| _iteratorError3 = err; | ||
| } finally { | ||
| try { | ||
| if (!_iteratorNormalCompletion3 && _iterator3.return) { | ||
| _iterator3.return(); | ||
| } | ||
| } finally { | ||
| if (_didIteratorError3) { | ||
| throw _iteratorError3; | ||
| } | ||
| } | ||
| } | ||
| } | ||
| }); | ||
| }); | ||
| } | ||
|
|
||
| function stop() { | ||
| console.log('Server has stopped successfully'); | ||
| server.close(); | ||
| } | ||
|
|
||
| exports.start = start; | ||
| exports.stop = stop; | ||
|
|
||
| Object.defineProperty(exports, '__esModule', { value: true }); | ||
|
|
||
| })); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,40 @@ | ||
| 'use strict' | ||
|
|
||
| let rollup = require('rollup') | ||
| let babel = require('rollup-plugin-babel') | ||
| let uglify = require('rollup-plugin-uglify') | ||
| let filesize = require('rollup-plugin-filesize') | ||
|
|
||
| rollup.rollup({ | ||
| entry: 'src/index.js', | ||
| banner: '#!/usr/bin/env node', | ||
| plugins: [ | ||
| babel({ | ||
| exclude: 'node_modules/**', | ||
| presets: ['es2015-rollup'] | ||
| }), | ||
| uglify(), | ||
| filesize() | ||
| ] | ||
| }).then((bundle) => { | ||
| console.log('index.es5.min.js: ') | ||
| bundle.write({dest: 'bin/index.es5.min.js'}) | ||
| }) | ||
|
|
||
| rollup.rollup({ | ||
| entry: 'src/sigver.js', | ||
| plugins: [ | ||
| babel({ | ||
| exclude: 'node_modules/**', | ||
| presets: ['es2015-rollup'] | ||
| }), | ||
| filesize() | ||
| ] | ||
| }).then((bundle) => { | ||
| console.log('sigver.es5.umd.js: ') | ||
| bundle.write({ | ||
| format: 'umd', | ||
| moduleName: 'sigver', | ||
| dest: 'dist/sigver.es5.umd.js' | ||
| }) | ||
| }) |
Oops, something went wrong.