New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

beam-interactive-node

Package Overview
Dependencies
Maintainers
1
Versions
12
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

beam-interactive-node - npm Package Compare versions

Comparing version 0.2.2 to 0.2.3

coverage/coverage.json

49

dist/client.js
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol ? "symbol" : typeof obj; };
var _get = function get(_x, _x2, _x3) { var _again = true; _function: while (_again) { var object = _x, property = _x2, receiver = _x3; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x = parent; _x2 = property; _x3 = receiver; _again = true; desc = parent = undefined; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
function _inherits(subClass, superClass) { if (typeof superClass !== 'function' && superClass !== null) { throw new TypeError('Super expression must either be null or a function, not ' + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var _events = require('events');

@@ -19,20 +15,25 @@

var Client = (function (_EventEmitter) {
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var Client = function (_EventEmitter) {
_inherits(Client, _EventEmitter);
function Client(options) {
var _this = this;
_classCallCheck(this, Client);
_get(Object.getPrototypeOf(Client.prototype), 'constructor', this).call(this);
this.options = Object.assign({ debug: false }, options);
this.connect = this.newConnector();
var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(Client).call(this));
(0, _util.bubble)('error', this.connect, this);
_this.options = Object.assign({ debug: false }, options);
_this.connect = _this.newConnector();
(0, _util.bubble)('error', _this.connect, _this);
// By default Node throws when errors are emitted without a listener.
// But it's quite bad at printing out those errors. We'll watch
// and process for uncaught error events manually.
this.on('error', function (err) {
_this.on('error', function (err) {
if (_this.listeners('error').length > 1) {

@@ -47,4 +48,4 @@ return;

if (this.options.debug) {
this.connect.on('raw-message', function (data) {
if (_this.options.debug) {
_this.connect.on('raw-message', function (data) {
return _this.logEntry(data, true);

@@ -55,2 +56,3 @@ }).on('sending', function (data) {

}
return _this;
}

@@ -64,2 +66,3 @@

_createClass(Client, [{

@@ -86,2 +89,3 @@ key: 'logEntry',

*/
}, {

@@ -97,3 +101,3 @@ key: 'prettyError',

if (typeof err === 'object' && Object.keys(err).length > 0) {
if ((typeof err === 'undefined' ? 'undefined' : _typeof(err)) === 'object' && Object.keys(err).length > 0) {
output += 'Error: \n' + (0, _util.indent)(JSON.stringify(err, null, ' '), 1) + '\n\n';

@@ -112,2 +116,3 @@ }

*/
}, {

@@ -123,2 +128,3 @@ key: 'newConnector',

*/
}, {

@@ -136,2 +142,3 @@ key: 'send',

*/
}, {

@@ -146,2 +153,3 @@ key: 'call',

*/
}, {

@@ -155,5 +163,4 @@ key: 'close',

return Client;
})(_events.EventEmitter);
}(_events.EventEmitter);
exports['default'] = Client;
module.exports = exports['default'];
exports.default = Client;
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
var _get = function get(_x3, _x4, _x5) { var _again = true; _function: while (_again) { var object = _x3, property = _x4, receiver = _x5; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x3 = parent; _x4 = property; _x5 = receiver; _again = true; desc = parent = undefined; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
function _inherits(subClass, superClass) { if (typeof superClass !== 'function' && superClass !== null) { throw new TypeError('Super expression must either be null or a function, not ' + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var _errors = require('./errors');

@@ -27,2 +19,10 @@

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
/**

@@ -33,3 +33,3 @@ * The Connector provides a high-level interface, implemented to interact

var Connector = (function (_EventEmitter) {
var Connector = function (_EventEmitter) {
_inherits(Connector, _EventEmitter);

@@ -48,9 +48,11 @@

_get(Object.getPrototypeOf(Connector.prototype), 'constructor', this).call(this);
this.handlers = [];
this.remote = remote;
this.errorPacket = errorPacket;
this.encode = encode;
this.decode = decode;
this.open = true;
var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(Connector).call(this));
_this.handlers = [];
_this.remote = remote;
_this.errorPacket = errorPacket;
_this.encode = encode;
_this.decode = decode;
_this.open = true;
return _this;
}

@@ -64,9 +66,10 @@

_createClass(Connector, [{
key: 'connect',
value: function connect() {
var _this = this;
var _this2 = this;
var callback = arguments.length <= 0 || arguments[0] === undefined ? _util.noop : arguments[0];
var generator = arguments.length <= 1 || arguments[1] === undefined ? _socketMaker2['default'] : arguments[1];
var generator = arguments.length <= 1 || arguments[1] === undefined ? _socketMaker2.default : arguments[1];

@@ -78,3 +81,3 @@ var socket = this.socket = generator(this.remote);

socket.once('open', function () {
_this.emit('connect');
_this2.emit('connect');
callback();

@@ -88,3 +91,3 @@ });

socket.on('message', function (data) {
return _this.doDecode(data);
return _this2.doDecode(data);
});

@@ -97,2 +100,3 @@ }

*/
}, {

@@ -125,2 +129,3 @@ key: 'doDecode',

*/
}, {

@@ -136,2 +141,3 @@ key: 'setOpen',

*/
}, {

@@ -149,2 +155,3 @@ key: 'getOpen',

*/
}, {

@@ -172,2 +179,3 @@ key: 'bubbleOpen',

*/
}, {

@@ -193,6 +201,7 @@ key: 'handleIncoming',

*/
}, {
key: 'call',
value: function call(packet, Expected, callback) {
var _this2 = this;
var _this3 = this;

@@ -202,3 +211,3 @@ this.handlers.push(function (message) {

callback(undefined, message);
} else if (message instanceof _this2.errorPacket) {
} else if (message instanceof _this3.errorPacket) {
callback(message);

@@ -219,2 +228,3 @@ } else {

*/
}, {

@@ -237,2 +247,3 @@ key: 'send',

*/
}, {

@@ -249,5 +260,4 @@ key: 'close',

return Connector;
})(_events.EventEmitter);
}(_events.EventEmitter);
exports['default'] = Connector;
module.exports = exports['default'];
exports.default = Connector;
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.UnexpectedServerResponse = exports.AssertionError = exports.UnknownPacketError = exports.FatalCodingError = exports.CodingError = undefined;
var _lodash = require('lodash.assignin');
var _lodash2 = _interopRequireDefault(_lodash);
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function extendError(name, methods) {

@@ -12,3 +20,3 @@ /* eslint-disable no-new-func */

Err.prototype = Object.create(Error.prototype);
Object.assign(Err.prototype, methods);
(0, _lodash2.default)(Err.prototype, methods);

@@ -21,11 +29,9 @@ return Err;

*/
var CodingError = extendError('CodingError');
var CodingError = exports.CodingError = extendError('CodingError');
exports.CodingError = CodingError;
/**
* This error is thrown when there is a fatal error.
*/
var FatalCodingError = extendError('FatalCodingError');
var FatalCodingError = exports.FatalCodingError = extendError('FatalCodingError');
exports.FatalCodingError = FatalCodingError;
/**

@@ -35,3 +41,3 @@ * Thrown when we get an packet that we don't know about.

*/
var UnknownPacketError = extendError('UnknownPacketError', {
var UnknownPacketError = exports.UnknownPacketError = extendError('UnknownPacketError', {
constructor: function constructor(id, data) {

@@ -43,3 +49,2 @@ this.message = 'Unknown packet ID ' + id;

exports.UnknownPacketError = UnknownPacketError;
/**

@@ -49,5 +54,4 @@ * Error type thrown by util.assert. Fill since browsers don't have

*/
var AssertionError = extendError('AssertionError');
var AssertionError = exports.AssertionError = extendError('AssertionError');
exports.AssertionError = AssertionError;
/**

@@ -57,3 +61,2 @@ * Sent when we get a response that we didn't like when trying to

*/
var UnexpectedServerResponse = extendError('UnexpectedServerResponse');
exports.UnexpectedServerResponse = UnexpectedServerResponse;
var UnexpectedServerResponse = exports.UnexpectedServerResponse = extendError('UnexpectedServerResponse');
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
var _get = function get(_x2, _x3, _x4) { var _again = true; _function: while (_again) { var object = _x2, property = _x3, receiver = _x4; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x2 = parent; _x3 = property; _x4 = receiver; _again = true; desc = parent = undefined; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
function _inherits(subClass, superClass) { if (typeof superClass !== 'function' && superClass !== null) { throw new TypeError('Super expression must either be null or a function, not ' + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var _packets = require('./packets');

@@ -35,3 +27,11 @@

var Frontend = (function (_Client) {
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var Frontend = function (_Client) {
_inherits(Frontend, _Client);

@@ -57,5 +57,6 @@

_get(Object.getPrototypeOf(Frontend.prototype), 'constructor', this).call(this, options);
var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(Frontend).call(this, options));
this.reporter = new _reporter2['default'](this, this.options.reportInterval);
_this.reporter = new _reporter2.default(_this, _this.options.reportInterval);
return _this;
}

@@ -66,3 +67,3 @@

value: function newConnector() {
var _this = this;
var _this2 = this;

@@ -76,11 +77,11 @@ var endpoint = undefined;

var socket = new _connector2['default'](function (packet) {
var socket = new _connector2.default(function (packet) {
return packet.encode();
}, function (data) {
return _packets2['default'].decode(data);
}, _packets2['default'].Error, endpoint);
return _packets2.default.decode(data);
}, _packets2.default.Error, endpoint);
socket.on('message', function (packet) {
_this.emit('message', packet);
_this.emit(packet.id, packet.props);
_this2.emit('message', packet);
_this2.emit(packet.id, packet.props);
});

@@ -101,6 +102,7 @@

*/
}, {
key: 'handshake',
value: function handshake(callback) {
var _this2 = this;
var _this3 = this;

@@ -113,6 +115,6 @@ var connect = this.connect;

} else {
_this2.call(new _packets2['default'].Handshake({
id: _this2.options.user,
key: _this2.options.key
}), _packets2['default'].HandshakeACK, callback);
_this3.call(new _packets2.default.Handshake({
id: _this3.options.user,
key: _this3.options.key
}), _packets2.default.HandshakeACK, callback);
}

@@ -127,2 +129,3 @@ });

*/
}, {

@@ -143,6 +146,7 @@ key: 'report',

*/
}], [{
key: 'Packet',
value: function Packet(name, data) {
var Packet = _packets2['default'][name];
var Packet = _packets2.default[name];
if (Packet === undefined) {

@@ -157,5 +161,4 @@ throw new Error('Tried to instatiate unknown packet "' + name + '".');

return Frontend;
})(_client2['default']);
}(_client2.default);
exports['default'] = Frontend;
module.exports = exports['default'];
exports.default = Frontend;
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
var _errors = require('../errors');
var _lodashIsplainobject = require('lodash.isplainobject');
var _lodash = require('lodash.isplainobject');
var _lodashIsplainobject2 = _interopRequireDefault(_lodashIsplainobject);
var _lodash2 = _interopRequireDefault(_lodash);
var _util = require('../util');
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
var idLength = 4;
var BasicPacket = (function () {
var BasicPacket = function () {
function BasicPacket() {

@@ -31,2 +31,3 @@ _classCallCheck(this, BasicPacket);

/**

@@ -40,3 +41,3 @@ * Encodes the packet to a string to be sent over the websocket.

encoded = this.props.toJSON();
} else if ((0, _lodashIsplainobject2['default'])(this.props)) {
} else if ((0, _lodash2.default)(this.props)) {
encoded = JSON.stringify(this.props);

@@ -55,2 +56,3 @@ } else {

*/
}, {

@@ -73,2 +75,3 @@ key: 'get',

*/
}, {

@@ -85,2 +88,3 @@ key: 'toObject',

*/
}, {

@@ -94,3 +98,3 @@ key: 'toJSON',

return BasicPacket;
})();
}();

@@ -172,3 +176,2 @@ function packet(name, id) {

exports['default'] = Object.freeze(packets);
module.exports = exports['default'];
exports.default = Object.freeze(packets);
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
var _packets = require('./packets');

@@ -19,2 +15,6 @@

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
/**

@@ -25,3 +25,3 @@ * The reporter is responsible for building report data and

var Reporter = (function () {
var Reporter = function () {

@@ -48,2 +48,3 @@ /**

_createClass(Reporter, [{

@@ -74,2 +75,3 @@ key: 'add',

*/
}, {

@@ -80,3 +82,3 @@ key: 'mergeTactile',

var _loop = function (i) {
var _loop = function _loop(i) {
var right = data.tactile[i];

@@ -104,2 +106,3 @@ var left = (0, _util.find)(report.tactile, function (l) {

*/
}, {

@@ -110,3 +113,3 @@ key: 'mergeJoystick',

var _loop2 = function (i) {
var _loop2 = function _loop2(i) {
var right = data.joystick[i];

@@ -134,2 +137,3 @@ var left = (0, _util.find)(report.joystick, function (l) {

*/
}, {

@@ -148,2 +152,3 @@ key: 'resetQueued',

*/
}, {

@@ -153,3 +158,3 @@ key: 'runSend',

var q = this.queued;
this.client.send(new _packets2['default'].Report(q.report));
this.client.send(new _packets2.default.Report(q.report));

@@ -165,5 +170,4 @@ for (var i = 0; i < q.callbacks.length; i++) {

return Reporter;
})();
}();
exports['default'] = Reporter;
module.exports = exports['default'];
exports.default = Reporter;
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
var _createClass = function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; }();
var _get = function get(_x, _x2, _x3) { var _again = true; _function: while (_again) { var object = _x, property = _x2, receiver = _x3; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x = parent; _x2 = property; _x3 = receiver; _again = true; desc = parent = undefined; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
function _inherits(subClass, superClass) { if (typeof superClass !== 'function' && superClass !== null) { throw new TypeError('Super expression must either be null or a function, not ' + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
var _packets = require('./packets');

@@ -31,6 +23,14 @@

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; }
function _inherits(subClass, superClass) { if (typeof superClass !== "function" && superClass !== null) { throw new TypeError("Super expression must either be null or a function, not " + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
// Map of packet types to events that should be sent out on the robot.
var eventMap = [{ ev: 'report', obj: _packets2['default'].Report }, { ev: 'error', obj: _packets2['default'].Error }];
var eventMap = [{ ev: 'report', obj: _packets2.default.Report }, { ev: 'error', obj: _packets2.default.Error }];
var Robot = (function (_Client) {
var Robot = function (_Client) {
_inherits(Robot, _Client);

@@ -49,3 +49,3 @@

_get(Object.getPrototypeOf(Robot.prototype), 'constructor', this).call(this, options);
return _possibleConstructorReturn(this, Object.getPrototypeOf(Robot).call(this, options));
}

@@ -56,9 +56,9 @@

value: function newConnector() {
var _this = this;
var _this2 = this;
var socket = new _connector2['default'](function (packet) {
var socket = new _connector2.default(function (packet) {
return packet.encode();
}, function (data) {
return _packets2['default'].decode(data);
}, _packets2['default'].Error, this.options.remote + '/robot');
return _packets2.default.decode(data);
}, _packets2.default.Error, this.options.remote + '/robot');

@@ -70,3 +70,3 @@ socket.on('message', function (message) {

if (event) {
_this.emit(event.ev, message);
_this2.emit(event.ev, message);
}

@@ -88,6 +88,7 @@ });

*/
}, {
key: 'handshake',
value: function handshake(callback) {
var _this2 = this;
var _this3 = this;

@@ -97,6 +98,6 @@ var connect = this.connect;

connect.on('connect', function () {
_this2.call(new _packets2['default'].Handshake({
channel: _this2.options.channel,
streamKey: _this2.options.key
}), _packets2['default'].HandshakeACK, callback);
_this3.call(new _packets2.default.Handshake({
channel: _this3.options.channel,
streamKey: _this3.options.key
}), _packets2.default.HandshakeACK, callback);
});

@@ -109,5 +110,4 @@

return Robot;
})(_client2['default']);
}(_client2.default);
exports['default'] = Robot;
module.exports = exports['default'];
exports.default = Robot;
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
var _errors = require('../errors');

@@ -23,3 +21,5 @@

var builder = _protobufjs2['default'].loadProtoFile(_path2['default'].join(__dirname, 'tetris.proto'));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
var builder = _protobufjs2.default.loadProtoFile(_path2.default.join(__dirname, 'tetris.proto'));
var Packets = builder.build('tetris');

@@ -43,3 +43,3 @@

Packet.prototype.encode = function encode() {
return Buffer.concat([new Buffer(_varint2['default'].encode(id)), this.encodeOriginal().toBuffer()]);
return Buffer.concat([new Buffer(_varint2.default.encode(id)), this.encodeOriginal().toBuffer()]);
};

@@ -54,4 +54,4 @@

Packet.decode = function decode(buf) {
_varint2['default'].decode(buf, 0);
var offset = _varint2['default'].decode.bytes;
_varint2.default.decode(buf, 0);
var offset = _varint2.default.decode.bytes;

@@ -77,3 +77,3 @@ var decoded = undefined;

value: function decode(buf) {
var id = _varint2['default'].decode(buf);
var id = _varint2.default.decode(buf);
if (id === undefined) {

@@ -94,3 +94,2 @@ throw new _errors.FatalCodingError('Incomplete protobuf packet.');

exports['default'] = Packets;
module.exports = exports['default'];
exports.default = Packets;

@@ -0,5 +1,5 @@

'use strict';
// Importing this is DEPRECATED and will be removed in the future.
'use strict';
var packets = require('../packets');

@@ -6,0 +6,0 @@ Object.keys(packets).forEach(function (key) {

'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true
});
exports['default'] = makeSocket;
exports.default = makeSocket;
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
var _ws = require('ws');

@@ -14,2 +12,4 @@

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
// window will be undefined in node.js

@@ -69,5 +69,4 @@ var isNode = typeof window === 'undefined';

*/
function makeSocket(remote) {
var socket = new _ws2['default'](remote);
var socket = new _ws2.default(remote);

@@ -77,4 +76,2 @@ if (isNode) return wrapNode(socket);

return wrapDOM(socket);
}
module.exports = exports['default'];
}
'use strict';
Object.defineProperty(exports, '__esModule', {
Object.defineProperty(exports, "__esModule", {
value: true

@@ -26,3 +26,2 @@ });

*/
function bubble(event, child, parent) {

@@ -48,3 +47,2 @@ var emit = arguments.length <= 3 || arguments[3] === undefined ? 'emit' : arguments[3];

*/
function find(array, predicate) {

@@ -68,3 +66,2 @@ for (var i = 0; i < array.length; i++) {

*/
function findValue(obj, predicate) {

@@ -86,3 +83,2 @@ for (var key in obj) {

*/
function strRepeat(str, times) {

@@ -104,3 +100,2 @@ var output = '';

*/
function addIf(a, b) {

@@ -117,3 +112,2 @@ return (a || 0) + (b || 0);

*/
function indent(str, times) {

@@ -140,3 +134,2 @@ var indenter = arguments.length <= 2 || arguments[2] === undefined ? ' ' : arguments[2];

*/
function assert(condition) {

@@ -143,0 +136,0 @@ var error = arguments.length <= 1 || arguments[1] === undefined ? 'expected false to be true' : arguments[1];

exports.Robot = require('./dist/robot');
exports.Frontend = require('./dist/frontend');

@@ -0,0 +0,0 @@ import {EventEmitter} from 'events';

@@ -0,0 +0,0 @@ import {UnknownPacketError, UnexpectedServerResponse} from './errors';

@@ -0,1 +1,3 @@

import assignIn from 'lodash.assignin';
function extendError (name, methods) {

@@ -16,3 +18,3 @@ /* eslint-disable no-new-func */

Err.prototype = Object.create(Error.prototype);
Object.assign(Err.prototype, methods);
assignIn(Err.prototype, methods);

@@ -19,0 +21,0 @@ return Err;

@@ -0,0 +0,0 @@ import Packets from './packets';

@@ -0,0 +0,0 @@ import {FatalCodingError, UnknownPacketError} from '../errors';

@@ -0,0 +0,0 @@ import Packets from './packets';

@@ -0,0 +0,0 @@ import Packets from './packets';

@@ -0,0 +0,0 @@ import {FatalCodingError, UnknownPacketError} from '../errors';

@@ -0,0 +0,0 @@ // Importing this is DEPRECATED and will be removed in the future.

@@ -0,0 +0,0 @@ import WebSocket from 'ws';

@@ -0,0 +0,0 @@ import {AssertionError} from './errors';

{
"name": "beam-interactive-node",
"version": "0.2.2",
"version": "0.2.3",
"description": "This repository contains reference a implementation of a Beam Interactive robot.",

@@ -9,3 +9,3 @@ "main": "index.js",

"build": "rm -rf dist && babel lib --out-dir dist && cp lib/robot/tetris.proto dist/robot",
"test": "mocha test/unit --recursive --compilers js:babel/register && npm run lint",
"test": "mocha test/unit --recursive --compilers js:babel-register && npm run lint",
"testfe": "browserify -r ./dist/frontend:tetris > dist/bundle.js && http-server",

@@ -34,2 +34,3 @@ "integrate": "mocha test/integrate --recursive --compilers js:babel/register",

"dependencies": {
"lodash.assignin": "^4.0.2",
"lodash.isplainobject": "^4.0.1",

@@ -42,3 +43,5 @@ "protobufjs": "^4.0.0",

"async": "^1.4.2",
"babel": "^5.8.23",
"babel-cli": "^6.5.1",
"babel-preset-es2015": "^6.5.0",
"babel-register": "^6.5.2",
"browserify": "^11.2.0",

@@ -45,0 +48,0 @@ "chai": "^3.2.0",

@@ -0,0 +0,0 @@ # beam-interactive-node [![Build Status](https://travis-ci.org/WatchBeam/beam-interactive-node.svg)](https://travis-ci.org/WatchBeam/beam-interactive-node)

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc