yonote/yjs
19
0
Fork 0
Code Pull Requests 1 Releases Activity

Added Monaco editor example

Browse Source
This commit is contained in:
Kevin Jahns 2017-04-18 18:23:17 +02:00
parent e30e16c91b
commit 3eafd78710
9 changed files with 712 additions and 534 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -1 +1,2 @@
node_modules
bower_components bower_components

24
Examples/Monaco/index.html Normal file
View File

@ -0,0 +1,24 @@
<!DOCTYPE html>
<html>
<head>
</head>
<body>
<div id="monacoContainer"></div>
<style>
#monacoContainer {
position: fixed;
top: 0;
left: 0;
height: 100%;
width: 100%;
}
</style>
<script src="../bower_components/yjs/y.es6"></script>
<script src="../bower_components/y-array/y-array.es6"></script>
<script src="../bower_components/y-text/y-text.es6"></script>
<script src="../bower_components/y-websockets-client/y-websockets-client.es6"></script>
<script src="../bower_components/y-memory/y-memory.es6"></script>
<script src="../node_modules/monaco-editor/min/vs/loader.js"></script>
<script src="./index.js"></script>
</body>
</html>

31
Examples/Monaco/index.js Normal file
View File

@ -0,0 +1,31 @@
/* global Y */
require.config({ paths: { 'vs': '../node_modules/monaco-editor/min/vs' }})
require(['vs/editor/editor.main'], function() {
// Initialize a shared object. This function call returns a promise!
Y({
db: {
name: 'memory'
},
connector: {
name: 'websockets-client',
room: 'monaco-example'
},
sourceDir: '/bower_components',
share: {
monaco: 'Text' // y.share.monaco is of type Y.Text
}
}).then(function (y) {
window.yMonaco = y
// Create Monaco editor
var editor = monaco.editor.create(document.getElementById('monacoContainer'), {
language: 'javascript'
})
// Bind to y.share.monaco
y.share.monaco.bindMonaco(editor)
})
})

10
Examples/package.json Normal file
View File

@ -0,0 +1,10 @@
{
"name": "examples",
"version": "1.0.0",
"description": "",
"author": "Kevin Jahns",
"license": "MIT",
"dependencies": {
"monaco-editor": "^0.8.3"
}
}

2
README.md
View File

@ -40,7 +40,7 @@ is a list of the modules we know of:
|[map](https://github.com/y-js/y-map) | A shared Map implementation. Maps from text to any stringify-able object | |[map](https://github.com/y-js/y-map) | A shared Map implementation. Maps from text to any stringify-able object |
|[array](https://github.com/y-js/y-array) | A shared Array implementation | |[array](https://github.com/y-js/y-array) | A shared Array implementation |
|[xml](https://github.com/y-js/y-xml) | An implementation of the DOM. You can create a two way binding to Browser DOM objects | |[xml](https://github.com/y-js/y-xml) | An implementation of the DOM. You can create a two way binding to Browser DOM objects |
|[text](https://github.com/y-js/y-text) | Collaborate on text. Supports two way binding to the [Ace Editor](https://ace.c9.io), [CodeMirror](https://codemirror.net/), textareas, input elements, and HTML elements (e.g. <*h1*>, or <*p*>) | |[text](https://github.com/y-js/y-text) | Collaborate on text. Supports two way binding to the [Ace Editor](https://ace.c9.io), [CodeMirror](https://codemirror.net/), [Monaco](https://github.com/Microsoft/monaco-editor), textareas, input elements, and HTML elements (e.g. <*h1*>, or <*p*>) |
|[richtext](https://github.com/y-js/y-richtext) | Collaborate on rich text. Supports two way binding to the [Quill Rich Text Editor](http://quilljs.com/)| |[richtext](https://github.com/y-js/y-richtext) | Collaborate on rich text. Supports two way binding to the [Quill Rich Text Editor](http://quilljs.com/)|
##### Other ##### Other

378
y.es6
View File

@ -5,157 +5,6 @@
* @license MIT * @license MIT
*/ */
(function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.Y = f()}})(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){ (function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.Y = f()}})(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
/**
* Helpers.
*/
var s = 1000
var m = s * 60
var h = m * 60
var d = h * 24
var y = d * 365.25
/**
* Parse or format the given `val`.
*
* Options:
*
* - `long` verbose formatting [false]
*
* @param {String|Number} val
* @param {Object} options
* @throws {Error} throw an error if val is not a non-empty string or a number
* @return {String|Number}
* @api public
*/
module.exports = function (val, options) {
options = options || {}
var type = typeof val
if (type === 'string' && val.length > 0) {
return parse(val)
} else if (type === 'number' && isNaN(val) === false) {
return options.long ?
fmtLong(val) :
fmtShort(val)
}
throw new Error('val is not a non-empty string or a valid number. val=' + JSON.stringify(val))
}
/**
* Parse the given `str` and return milliseconds.
*
* @param {String} str
* @return {Number}
* @api private
*/
function parse(str) {
str = String(str)
if (str.length > 10000) {
return
}
var match = /^((?:\d+)?\.?\d+) *(milliseconds?|msecs?|ms|seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|years?|yrs?|y)?$/i.exec(str)
if (!match) {
return
}
var n = parseFloat(match[1])
var type = (match[2] || 'ms').toLowerCase()
switch (type) {
case 'years':
case 'year':
case 'yrs':
case 'yr':
case 'y':
return n * y
case 'days':
case 'day':
case 'd':
return n * d
case 'hours':
case 'hour':
case 'hrs':
case 'hr':
case 'h':
return n * h
case 'minutes':
case 'minute':
case 'mins':
case 'min':
case 'm':
return n * m
case 'seconds':
case 'second':
case 'secs':
case 'sec':
case 's':
return n * s
case 'milliseconds':
case 'millisecond':
case 'msecs':
case 'msec':
case 'ms':
return n
default:
return undefined
}
}
/**
* Short format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtShort(ms) {
if (ms >= d) {
return Math.round(ms / d) + 'd'
}
if (ms >= h) {
return Math.round(ms / h) + 'h'
}
if (ms >= m) {
return Math.round(ms / m) + 'm'
}
if (ms >= s) {
return Math.round(ms / s) + 's'
}
return ms + 'ms'
}
/**
* Long format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtLong(ms) {
return plural(ms, d, 'day') ||
plural(ms, h, 'hour') ||
plural(ms, m, 'minute') ||
plural(ms, s, 'second') ||
ms + ' ms'
}
/**
* Pluralization helper.
*/
function plural(ms, n, name) {
if (ms < n) {
return
}
if (ms < n * 1.5) {
return Math.floor(ms / n) + ' ' + name
}
return Math.ceil(ms / n) + ' ' + name + 's'
}
},{}],2:[function(require,module,exports){
(function (process){ (function (process){
/** /**
* This is the web browser implementation of `debug()`. * This is the web browser implementation of `debug()`.
@ -345,7 +194,7 @@ function localstorage() {
}).call(this,require('_process')) }).call(this,require('_process'))
},{"./debug":3,"_process":4}],3:[function(require,module,exports){ },{"./debug":2,"_process":4}],2:[function(require,module,exports){
/** /**
* This is the common logic for both the Node.js and web browser * This is the common logic for both the Node.js and web browser
@ -549,7 +398,158 @@ function coerce(val) {
return val; return val;
} }
},{"ms":1}],4:[function(require,module,exports){ },{"ms":3}],3:[function(require,module,exports){
/**
* Helpers.
*/
var s = 1000
var m = s * 60
var h = m * 60
var d = h * 24
var y = d * 365.25
/**
* Parse or format the given `val`.
*
* Options:
*
* - `long` verbose formatting [false]
*
* @param {String|Number} val
* @param {Object} options
* @throws {Error} throw an error if val is not a non-empty string or a number
* @return {String|Number}
* @api public
*/
module.exports = function (val, options) {
options = options || {}
var type = typeof val
if (type === 'string' && val.length > 0) {
return parse(val)
} else if (type === 'number' && isNaN(val) === false) {
return options.long ?
fmtLong(val) :
fmtShort(val)
}
throw new Error('val is not a non-empty string or a valid number. val=' + JSON.stringify(val))
}
/**
* Parse the given `str` and return milliseconds.
*
* @param {String} str
* @return {Number}
* @api private
*/
function parse(str) {
str = String(str)
if (str.length > 10000) {
return
}
var match = /^((?:\d+)?\.?\d+) *(milliseconds?|msecs?|ms|seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|years?|yrs?|y)?$/i.exec(str)
if (!match) {
return
}
var n = parseFloat(match[1])
var type = (match[2] || 'ms').toLowerCase()
switch (type) {
case 'years':
case 'year':
case 'yrs':
case 'yr':
case 'y':
return n * y
case 'days':
case 'day':
case 'd':
return n * d
case 'hours':
case 'hour':
case 'hrs':
case 'hr':
case 'h':
return n * h
case 'minutes':
case 'minute':
case 'mins':
case 'min':
case 'm':
return n * m
case 'seconds':
case 'second':
case 'secs':
case 'sec':
case 's':
return n * s
case 'milliseconds':
case 'millisecond':
case 'msecs':
case 'msec':
case 'ms':
return n
default:
return undefined
}
}
/**
* Short format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtShort(ms) {
if (ms >= d) {
return Math.round(ms / d) + 'd'
}
if (ms >= h) {
return Math.round(ms / h) + 'h'
}
if (ms >= m) {
return Math.round(ms / m) + 'm'
}
if (ms >= s) {
return Math.round(ms / s) + 's'
}
return ms + 'ms'
}
/**
* Long format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtLong(ms) {
return plural(ms, d, 'day') ||
plural(ms, h, 'hour') ||
plural(ms, m, 'minute') ||
plural(ms, s, 'second') ||
ms + ' ms'
}
/**
* Pluralization helper.
*/
function plural(ms, n, name) {
if (ms < n) {
return
}
if (ms < n * 1.5) {
return Math.floor(ms / n) + ' ' + name
}
return Math.ceil(ms / n) + ' ' + name + 's'
}
},{}],4:[function(require,module,exports){
// shim for using process in browser // shim for using process in browser
var process = module.exports = {}; var process = module.exports = {};
@ -561,35 +561,83 @@ var process = module.exports = {};
var cachedSetTimeout; var cachedSetTimeout;
var cachedClearTimeout; var cachedClearTimeout;
function defaultSetTimout() {
throw new Error('setTimeout has not been defined');
}
function defaultClearTimeout () {
throw new Error('clearTimeout has not been defined');
}
(function () { (function () {
try { try {
if (typeof setTimeout === 'function') {
cachedSetTimeout = setTimeout; cachedSetTimeout = setTimeout;
} catch (e) { } else {
cachedSetTimeout = function () { cachedSetTimeout = defaultSetTimout;
throw new Error('setTimeout is not defined');
} }
} catch (e) {
cachedSetTimeout = defaultSetTimout;
} }
try { try {
if (typeof clearTimeout === 'function') {
cachedClearTimeout = clearTimeout; cachedClearTimeout = clearTimeout;
} catch (e) { } else {
cachedClearTimeout = function () { cachedClearTimeout = defaultClearTimeout;
throw new Error('clearTimeout is not defined');
} }
} catch (e) {
cachedClearTimeout = defaultClearTimeout;
} }
} ()) } ())
function runTimeout(fun) { function runTimeout(fun) {
if (cachedSetTimeout === setTimeout) { if (cachedSetTimeout === setTimeout) {
//normal enviroments in sane situations
return setTimeout(fun, 0); return setTimeout(fun, 0);
} else {
return cachedSetTimeout.call(null, fun, 0);
} }
// if setTimeout wasn't available but was latter defined
if ((cachedSetTimeout === defaultSetTimout || !cachedSetTimeout) && setTimeout) {
cachedSetTimeout = setTimeout;
return setTimeout(fun, 0);
}
try {
// when when somebody has screwed with setTimeout but no I.E. maddness
return cachedSetTimeout(fun, 0);
} catch(e){
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normally
return cachedSetTimeout.call(null, fun, 0);
} catch(e){
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global error
return cachedSetTimeout.call(this, fun, 0);
}
}
} }
function runClearTimeout(marker) { function runClearTimeout(marker) {
if (cachedClearTimeout === clearTimeout) { if (cachedClearTimeout === clearTimeout) {
clearTimeout(marker); //normal enviroments in sane situations
} else { return clearTimeout(marker);
cachedClearTimeout.call(null, marker);
} }
// if clearTimeout wasn't available but was latter defined
if ((cachedClearTimeout === defaultClearTimeout || !cachedClearTimeout) && clearTimeout) {
cachedClearTimeout = clearTimeout;
return clearTimeout(marker);
}
try {
// when when somebody has screwed with setTimeout but no I.E. maddness
return cachedClearTimeout(marker);
} catch (e){
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normally
return cachedClearTimeout.call(null, marker);
} catch (e){
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global error.
// Some versions of I.E. have different rules for clearTimeout vs setTimeout
return cachedClearTimeout.call(this, marker);
}
}
} }
var queue = []; var queue = [];
var draining = false; var draining = false;
@ -4408,6 +4456,6 @@ class YConfig {
} }
} }
},{"./Connector.js":5,"./Connectors/Test.js":6,"./Database.js":7,"./Struct.js":8,"./Transaction.js":9,"./Utils.js":10,"debug":2}]},{},[11])(11) },{"./Connector.js":5,"./Connectors/Test.js":6,"./Database.js":7,"./Struct.js":8,"./Transaction.js":9,"./Utils.js":10,"debug":1}]},{},[11])(11)
}); });

2
y.es6.map
View File

File diff suppressed because one or more lines are too long

538
y.js
View File

@ -5,161 +5,10 @@
* @license MIT * @license MIT
*/ */
(function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.Y = f()}})(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){ (function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.Y = f()}})(function(){var define,module,exports;return (function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
/**
* Helpers.
*/
var s = 1000
var m = s * 60
var h = m * 60
var d = h * 24
var y = d * 365.25
/**
* Parse or format the given `val`.
*
* Options:
*
* - `long` verbose formatting [false]
*
* @param {String|Number} val
* @param {Object} options
* @throws {Error} throw an error if val is not a non-empty string or a number
* @return {String|Number}
* @api public
*/
module.exports = function (val, options) {
options = options || {}
var type = typeof val
if (type === 'string' && val.length > 0) {
return parse(val)
} else if (type === 'number' && isNaN(val) === false) {
return options.long ?
fmtLong(val) :
fmtShort(val)
}
throw new Error('val is not a non-empty string or a valid number. val=' + JSON.stringify(val))
}
/**
* Parse the given `str` and return milliseconds.
*
* @param {String} str
* @return {Number}
* @api private
*/
function parse(str) {
str = String(str)
if (str.length > 10000) {
return
}
var match = /^((?:\d+)?\.?\d+) *(milliseconds?|msecs?|ms|seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|years?|yrs?|y)?$/i.exec(str)
if (!match) {
return
}
var n = parseFloat(match[1])
var type = (match[2] || 'ms').toLowerCase()
switch (type) {
case 'years':
case 'year':
case 'yrs':
case 'yr':
case 'y':
return n * y
case 'days':
case 'day':
case 'd':
return n * d
case 'hours':
case 'hour':
case 'hrs':
case 'hr':
case 'h':
return n * h
case 'minutes':
case 'minute':
case 'mins':
case 'min':
case 'm':
return n * m
case 'seconds':
case 'second':
case 'secs':
case 'sec':
case 's':
return n * s
case 'milliseconds':
case 'millisecond':
case 'msecs':
case 'msec':
case 'ms':
return n
default:
return undefined
}
}
/**
* Short format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtShort(ms) {
if (ms >= d) {
return Math.round(ms / d) + 'd'
}
if (ms >= h) {
return Math.round(ms / h) + 'h'
}
if (ms >= m) {
return Math.round(ms / m) + 'm'
}
if (ms >= s) {
return Math.round(ms / s) + 's'
}
return ms + 'ms'
}
/**
* Long format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtLong(ms) {
return plural(ms, d, 'day') ||
plural(ms, h, 'hour') ||
plural(ms, m, 'minute') ||
plural(ms, s, 'second') ||
ms + ' ms'
}
/**
* Pluralization helper.
*/
function plural(ms, n, name) {
if (ms < n) {
return
}
if (ms < n * 1.5) {
return Math.floor(ms / n) + ' ' + name
}
return Math.ceil(ms / n) + ' ' + name + 's'
}
},{}],2:[function(require,module,exports){
(function (process){ (function (process){
'use strict'; 'use strict';
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 _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
/** /**
* This is the web browser implementation of `debug()`. * This is the web browser implementation of `debug()`.
@ -331,7 +180,7 @@ function localstorage() {
}).call(this,require('_process')) }).call(this,require('_process'))
},{"./debug":3,"_process":4}],3:[function(require,module,exports){ },{"./debug":2,"_process":4}],2:[function(require,module,exports){
'use strict'; 'use strict';
/** /**
@ -537,7 +386,156 @@ function coerce(val) {
return val; return val;
} }
},{"ms":1}],4:[function(require,module,exports){ },{"ms":3}],3:[function(require,module,exports){
'use strict';
var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
/**
* Helpers.
*/
var s = 1000;
var m = s * 60;
var h = m * 60;
var d = h * 24;
var y = d * 365.25;
/**
* Parse or format the given `val`.
*
* Options:
*
* - `long` verbose formatting [false]
*
* @param {String|Number} val
* @param {Object} options
* @throws {Error} throw an error if val is not a non-empty string or a number
* @return {String|Number}
* @api public
*/
module.exports = function (val, options) {
options = options || {};
var type = typeof val === 'undefined' ? 'undefined' : _typeof(val);
if (type === 'string' && val.length > 0) {
return parse(val);
} else if (type === 'number' && isNaN(val) === false) {
return options.long ? fmtLong(val) : fmtShort(val);
}
throw new Error('val is not a non-empty string or a valid number. val=' + JSON.stringify(val));
};
/**
* Parse the given `str` and return milliseconds.
*
* @param {String} str
* @return {Number}
* @api private
*/
function parse(str) {
str = String(str);
if (str.length > 10000) {
return;
}
var match = /^((?:\d+)?\.?\d+) *(milliseconds?|msecs?|ms|seconds?|secs?|s|minutes?|mins?|m|hours?|hrs?|h|days?|d|years?|yrs?|y)?$/i.exec(str);
if (!match) {
return;
}
var n = parseFloat(match[1]);
var type = (match[2] || 'ms').toLowerCase();
switch (type) {
case 'years':
case 'year':
case 'yrs':
case 'yr':
case 'y':
return n * y;
case 'days':
case 'day':
case 'd':
return n * d;
case 'hours':
case 'hour':
case 'hrs':
case 'hr':
case 'h':
return n * h;
case 'minutes':
case 'minute':
case 'mins':
case 'min':
case 'm':
return n * m;
case 'seconds':
case 'second':
case 'secs':
case 'sec':
case 's':
return n * s;
case 'milliseconds':
case 'millisecond':
case 'msecs':
case 'msec':
case 'ms':
return n;
default:
return undefined;
}
}
/**
* Short format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtShort(ms) {
if (ms >= d) {
return Math.round(ms / d) + 'd';
}
if (ms >= h) {
return Math.round(ms / h) + 'h';
}
if (ms >= m) {
return Math.round(ms / m) + 'm';
}
if (ms >= s) {
return Math.round(ms / s) + 's';
}
return ms + 'ms';
}
/**
* Long format for `ms`.
*
* @param {Number} ms
* @return {String}
* @api private
*/
function fmtLong(ms) {
return plural(ms, d, 'day') || plural(ms, h, 'hour') || plural(ms, m, 'minute') || plural(ms, s, 'second') || ms + ' ms';
}
/**
* Pluralization helper.
*/
function plural(ms, n, name) {
if (ms < n) {
return;
}
if (ms < n * 1.5) {
return Math.floor(ms / n) + ' ' + name;
}
return Math.ceil(ms / n) + ' ' + name + 's';
}
},{}],4:[function(require,module,exports){
// shim for using process in browser // shim for using process in browser
var process = module.exports = {}; var process = module.exports = {};
@ -549,35 +547,83 @@ var process = module.exports = {};
var cachedSetTimeout; var cachedSetTimeout;
var cachedClearTimeout; var cachedClearTimeout;
function defaultSetTimout() {
throw new Error('setTimeout has not been defined');
}
function defaultClearTimeout () {
throw new Error('clearTimeout has not been defined');
}
(function () { (function () {
try { try {
if (typeof setTimeout === 'function') {
cachedSetTimeout = setTimeout; cachedSetTimeout = setTimeout;
} catch (e) { } else {
cachedSetTimeout = function () { cachedSetTimeout = defaultSetTimout;
throw new Error('setTimeout is not defined');
} }
} catch (e) {
cachedSetTimeout = defaultSetTimout;
} }
try { try {
if (typeof clearTimeout === 'function') {
cachedClearTimeout = clearTimeout; cachedClearTimeout = clearTimeout;
} catch (e) { } else {
cachedClearTimeout = function () { cachedClearTimeout = defaultClearTimeout;
throw new Error('clearTimeout is not defined');
} }
} catch (e) {
cachedClearTimeout = defaultClearTimeout;
} }
} ()) } ())
function runTimeout(fun) { function runTimeout(fun) {
if (cachedSetTimeout === setTimeout) { if (cachedSetTimeout === setTimeout) {
//normal enviroments in sane situations
return setTimeout(fun, 0); return setTimeout(fun, 0);
} else {
return cachedSetTimeout.call(null, fun, 0);
} }
// if setTimeout wasn't available but was latter defined
if ((cachedSetTimeout === defaultSetTimout || !cachedSetTimeout) && setTimeout) {
cachedSetTimeout = setTimeout;
return setTimeout(fun, 0);
}
try {
// when when somebody has screwed with setTimeout but no I.E. maddness
return cachedSetTimeout(fun, 0);
} catch(e){
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normally
return cachedSetTimeout.call(null, fun, 0);
} catch(e){
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global error
return cachedSetTimeout.call(this, fun, 0);
}
}
} }
function runClearTimeout(marker) { function runClearTimeout(marker) {
if (cachedClearTimeout === clearTimeout) { if (cachedClearTimeout === clearTimeout) {
clearTimeout(marker); //normal enviroments in sane situations
} else { return clearTimeout(marker);
cachedClearTimeout.call(null, marker);
} }
// if clearTimeout wasn't available but was latter defined
if ((cachedClearTimeout === defaultClearTimeout || !cachedClearTimeout) && clearTimeout) {
cachedClearTimeout = clearTimeout;
return clearTimeout(marker);
}
try {
// when when somebody has screwed with setTimeout but no I.E. maddness
return cachedClearTimeout(marker);
} catch (e){
try {
// When we are in I.E. but the script has been evaled so I.E. doesn't trust the global object when called normally
return cachedClearTimeout.call(null, marker);
} catch (e){
// same as above but when it's a version of I.E. that must have the global object for 'this', hopfully our context correct otherwise it will throw a global error.
// Some versions of I.E. have different rules for clearTimeout vs setTimeout
return cachedClearTimeout.call(this, marker);
}
}
} }
var queue = []; var queue = [];
var draining = false; var draining = false;
@ -673,10 +719,6 @@ process.umask = function() { return 0; };
},{}],5:[function(require,module,exports){ },{}],5:[function(require,module,exports){
(function (process,global){ (function (process,global){
"use strict";
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; };
/** /**
* Copyright (c) 2014, Facebook, Inc. * Copyright (c) 2014, Facebook, Inc.
* All rights reserved. * All rights reserved.
@ -687,7 +729,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
* the same directory. * the same directory.
*/ */
!function (global) { !(function(global) {
"use strict"; "use strict";
var hasOwn = Object.prototype.hasOwnProperty; var hasOwn = Object.prototype.hasOwnProperty;
@ -696,7 +738,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
var iteratorSymbol = $Symbol.iterator || "@@iterator"; var iteratorSymbol = $Symbol.iterator || "@@iterator";
var toStringTagSymbol = $Symbol.toStringTag || "@@toStringTag"; var toStringTagSymbol = $Symbol.toStringTag || "@@toStringTag";
var inModule = (typeof module === "undefined" ? "undefined" : _typeof(module)) === "object"; var inModule = typeof module === "object";
var runtime = global.regeneratorRuntime; var runtime = global.regeneratorRuntime;
if (runtime) { if (runtime) {
if (inModule) { if (inModule) {
@ -714,8 +756,9 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
runtime = global.regeneratorRuntime = inModule ? module.exports : {}; runtime = global.regeneratorRuntime = inModule ? module.exports : {};
function wrap(innerFn, outerFn, self, tryLocsList) { function wrap(innerFn, outerFn, self, tryLocsList) {
// If outerFn provided, then outerFn.prototype instanceof Generator. // If outerFn provided and outerFn.prototype is a Generator, then outerFn.prototype instanceof Generator.
var generator = Object.create((outerFn || Generator).prototype); var protoGenerator = outerFn && outerFn.prototype instanceof Generator ? outerFn : Generator;
var generator = Object.create(protoGenerator.prototype);
var context = new Context(tryLocsList || []); var context = new Context(tryLocsList || []);
// The ._invoke method unifies the implementations of the .next, // The ._invoke method unifies the implementations of the .next,
@ -778,10 +821,12 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
runtime.isGeneratorFunction = function(genFun) { runtime.isGeneratorFunction = function(genFun) {
var ctor = typeof genFun === "function" && genFun.constructor; var ctor = typeof genFun === "function" && genFun.constructor;
return ctor ? ctor === GeneratorFunction || return ctor
? ctor === GeneratorFunction ||
// For the native GeneratorFunction constructor, the best we can // For the native GeneratorFunction constructor, the best we can
// do is to check its .name property. // do is to check its .name property.
(ctor.displayName || ctor.name) === "GeneratorFunction" : false; (ctor.displayName || ctor.name) === "GeneratorFunction"
: false;
}; };
runtime.mark = function(genFun) { runtime.mark = function(genFun) {
@ -848,7 +893,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
} }
if ((typeof process === "undefined" ? "undefined" : _typeof(process)) === "object" && process.domain) { if (typeof process === "object" && process.domain) {
invoke = process.domain.bind(invoke); invoke = process.domain.bind(invoke);
} }
@ -874,10 +919,12 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
// execute code before the first await. Since we implement simple // execute code before the first await. Since we implement simple
// async functions in terms of async generators, it is especially // async functions in terms of async generators, it is especially
// important to get this right, even though it requires care. // important to get this right, even though it requires care.
previousPromise ? previousPromise.then(callInvokeWithMethodAndArg, previousPromise ? previousPromise.then(
callInvokeWithMethodAndArg,
// Avoid propagating failures to Promises returned by later // Avoid propagating failures to Promises returned by later
// invocations of the iterator. // invocations of the iterator.
callInvokeWithMethodAndArg) : callInvokeWithMethodAndArg(); callInvokeWithMethodAndArg
) : callInvokeWithMethodAndArg();
} }
// Define the unified helper method that is used to implement .next, // Define the unified helper method that is used to implement .next,
@ -891,9 +938,12 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
// AsyncIterator objects; they just return a Promise for the value of // AsyncIterator objects; they just return a Promise for the value of
// the final result produced by the iterator. // the final result produced by the iterator.
runtime.async = function(innerFn, outerFn, self, tryLocsList) { runtime.async = function(innerFn, outerFn, self, tryLocsList) {
var iter = new AsyncIterator(wrap(innerFn, outerFn, self, tryLocsList)); var iter = new AsyncIterator(
wrap(innerFn, outerFn, self, tryLocsList)
);
return runtime.isGeneratorFunction(outerFn) ? iter // If outerFn is a generator, return the full iterator. return runtime.isGeneratorFunction(outerFn)
? iter // If outerFn is a generator, return the full iterator.
: iter.next().then(function(result) { : iter.next().then(function(result) {
return result.done ? result.value : iter.next(); return result.done ? result.value : iter.next();
}); });
@ -920,7 +970,8 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
while (true) { while (true) {
var delegate = context.delegate; var delegate = context.delegate;
if (delegate) { if (delegate) {
if (method === "return" || method === "throw" && delegate.iterator[method] === undefined) { if (method === "return" ||
(method === "throw" && delegate.iterator[method] === undefined)) {
// A return or throw (when the delegate iterator has no throw // A return or throw (when the delegate iterator has no throw
// method) always terminates the yield* loop. // method) always terminates the yield* loop.
context.delegate = null; context.delegate = null;
@ -946,7 +997,11 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
} }
var record = tryCatch(delegate.iterator[method], delegate.iterator, arg); var record = tryCatch(
delegate.iterator[method],
delegate.iterator,
arg
);
if (record.type === "throw") { if (record.type === "throw") {
context.delegate = null; context.delegate = null;
@ -980,6 +1035,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
// Setting context._sent for legacy support of Babel's // Setting context._sent for legacy support of Babel's
// function.sent implementation. // function.sent implementation.
context.sent = context._sent = arg; context.sent = context._sent = arg;
} else if (method === "throw") { } else if (method === "throw") {
if (state === GenStateSuspendedStart) { if (state === GenStateSuspendedStart) {
state = GenStateCompleted; state = GenStateCompleted;
@ -992,6 +1048,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
method = "next"; method = "next";
arg = undefined; arg = undefined;
} }
} else if (method === "return") { } else if (method === "return") {
context.abrupt("return", arg); context.abrupt("return", arg);
} }
@ -1002,7 +1059,9 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
if (record.type === "normal") { if (record.type === "normal") {
// If an exception is thrown from innerFn, we leave state === // If an exception is thrown from innerFn, we leave state ===
// GenStateExecuting and loop back for another invocation. // GenStateExecuting and loop back for another invocation.
state = context.done ? GenStateCompleted : GenStateSuspendedYield; state = context.done
? GenStateCompleted
: GenStateSuspendedYield;
var info = { var info = {
value: record.arg, value: record.arg,
@ -1018,6 +1077,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} else { } else {
return info; return info;
} }
} else if (record.type === "throw") { } else if (record.type === "throw") {
state = GenStateCompleted; state = GenStateCompleted;
// Dispatch the exception by looping back around to the // Dispatch the exception by looping back around to the
@ -1113,8 +1173,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
if (!isNaN(iterable.length)) { if (!isNaN(iterable.length)) {
var i = -1, var i = -1, next = function next() {
next = function next() {
while (++i < iterable.length) { while (++i < iterable.length) {
if (hasOwn.call(iterable, i)) { if (hasOwn.call(iterable, i)) {
next.value = iterable[i]; next.value = iterable[i];
@ -1145,7 +1204,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
Context.prototype = { Context.prototype = {
constructor: Context, constructor: Context,
reset: function reset(skipTempReset) { reset: function(skipTempReset) {
this.prev = 0; this.prev = 0;
this.next = 0; this.next = 0;
// Resetting context._sent for legacy support of Babel's // Resetting context._sent for legacy support of Babel's
@ -1159,14 +1218,16 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
if (!skipTempReset) { if (!skipTempReset) {
for (var name in this) { for (var name in this) {
// Not sure about the optimal order of these conditions: // Not sure about the optimal order of these conditions:
if (name.charAt(0) === "t" && hasOwn.call(this, name) && !isNaN(+name.slice(1))) { if (name.charAt(0) === "t" &&
hasOwn.call(this, name) &&
!isNaN(+name.slice(1))) {
this[name] = undefined; this[name] = undefined;
} }
} }
} }
}, },
stop: function stop() { stop: function() {
this.done = true; this.done = true;
var rootEntry = this.tryEntries[0]; var rootEntry = this.tryEntries[0];
@ -1178,7 +1239,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
return this.rval; return this.rval;
}, },
dispatchException: function dispatchException(exception) { dispatchException: function(exception) {
if (this.done) { if (this.done) {
throw exception; throw exception;
} }
@ -1212,14 +1273,17 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} else if (this.prev < entry.finallyLoc) { } else if (this.prev < entry.finallyLoc) {
return handle(entry.finallyLoc); return handle(entry.finallyLoc);
} }
} else if (hasCatch) { } else if (hasCatch) {
if (this.prev < entry.catchLoc) { if (this.prev < entry.catchLoc) {
return handle(entry.catchLoc, true); return handle(entry.catchLoc, true);
} }
} else if (hasFinally) { } else if (hasFinally) {
if (this.prev < entry.finallyLoc) { if (this.prev < entry.finallyLoc) {
return handle(entry.finallyLoc); return handle(entry.finallyLoc);
} }
} else { } else {
throw new Error("try statement without catch or finally"); throw new Error("try statement without catch or finally");
} }
@ -1227,16 +1291,22 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
}, },
abrupt: function abrupt(type, arg) { abrupt: function(type, arg) {
for (var i = this.tryEntries.length - 1; i >= 0; --i) { for (var i = this.tryEntries.length - 1; i >= 0; --i) {
var entry = this.tryEntries[i]; var entry = this.tryEntries[i];
if (entry.tryLoc <= this.prev && hasOwn.call(entry, "finallyLoc") && this.prev < entry.finallyLoc) { if (entry.tryLoc <= this.prev &&
hasOwn.call(entry, "finallyLoc") &&
this.prev < entry.finallyLoc) {
var finallyEntry = entry; var finallyEntry = entry;
break; break;
} }
} }
if (finallyEntry && (type === "break" || type === "continue") && finallyEntry.tryLoc <= arg && arg <= finallyEntry.finallyLoc) { if (finallyEntry &&
(type === "break" ||
type === "continue") &&
finallyEntry.tryLoc <= arg &&
arg <= finallyEntry.finallyLoc) {
// Ignore the finally entry if control is not jumping to a // Ignore the finally entry if control is not jumping to a
// location outside the try/catch block. // location outside the try/catch block.
finallyEntry = null; finallyEntry = null;
@ -1255,12 +1325,13 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
return ContinueSentinel; return ContinueSentinel;
}, },
complete: function complete(record, afterLoc) { complete: function(record, afterLoc) {
if (record.type === "throw") { if (record.type === "throw") {
throw record.arg; throw record.arg;
} }
if (record.type === "break" || record.type === "continue") { if (record.type === "break" ||
record.type === "continue") {
this.next = record.arg; this.next = record.arg;
} else if (record.type === "return") { } else if (record.type === "return") {
this.rval = record.arg; this.rval = record.arg;
@ -1270,7 +1341,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
}, },
finish: function finish(finallyLoc) { finish: function(finallyLoc) {
for (var i = this.tryEntries.length - 1; i >= 0; --i) { for (var i = this.tryEntries.length - 1; i >= 0; --i) {
var entry = this.tryEntries[i]; var entry = this.tryEntries[i];
if (entry.finallyLoc === finallyLoc) { if (entry.finallyLoc === finallyLoc) {
@ -1281,7 +1352,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
} }
}, },
"catch": function _catch(tryLoc) { "catch": function(tryLoc) {
for (var i = this.tryEntries.length - 1; i >= 0; --i) { for (var i = this.tryEntries.length - 1; i >= 0; --i) {
var entry = this.tryEntries[i]; var entry = this.tryEntries[i];
if (entry.tryLoc === tryLoc) { if (entry.tryLoc === tryLoc) {
@ -1299,7 +1370,7 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
throw new Error("illegal catch attempt"); throw new Error("illegal catch attempt");
}, },
delegateYield: function delegateYield(iterable, resultName, nextLoc) { delegateYield: function(iterable, resultName, nextLoc) {
this.delegate = { this.delegate = {
iterator: values(iterable), iterator: values(iterable),
resultName: resultName, resultName: resultName,
@ -1309,11 +1380,14 @@ var _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol
return ContinueSentinel; return ContinueSentinel;
} }
}; };
}( })(
// Among the various tricks for obtaining a reference to the global // Among the various tricks for obtaining a reference to the global
// object, this seems to be the most reliable technique that does not // object, this seems to be the most reliable technique that does not
// use indirect eval (which violates Content Security Policy). // use indirect eval (which violates Content Security Policy).
(typeof global === "undefined" ? "undefined" : _typeof(global)) === "object" ? global : (typeof window === "undefined" ? "undefined" : _typeof(window)) === "object" ? window : (typeof self === "undefined" ? "undefined" : _typeof(self)) === "object" ? self : undefined); typeof global === "object" ? global :
typeof window === "object" ? window :
typeof self === "object" ? self : this
);
}).call(this,require('_process'),typeof global !== "undefined" ? global : typeof self !== "undefined" ? self : typeof window !== "undefined" ? window : {}) }).call(this,require('_process'),typeof global !== "undefined" ? global : typeof self !== "undefined" ? self : typeof window !== "undefined" ? window : {})
@ -1797,7 +1871,6 @@ module.exports = function (Y /* :any */) {
if (this.connections[sender] != null && this.connections[sender].auth != null) { if (this.connections[sender] != null && this.connections[sender].auth != null) {
return this.connections[sender].auth.then(function (auth) { return this.connections[sender].auth.then(function (auth) {
if (message.type === 'sync step 1' && canRead(auth)) { if (message.type === 'sync step 1' && canRead(auth)) {
(function () {
var conn = _this; var conn = _this;
var m = message; var m = message;
@ -1860,41 +1933,33 @@ module.exports = function (Y /* :any */) {
} }
}, _callee3, this); }, _callee3, this);
})); }));
})();
} else if (message.type === 'sync step 2' && canWrite(auth)) { } else if (message.type === 'sync step 2' && canWrite(auth)) {
var broadcastHB; var _conn = _this;
var db; var broadcastHB = !_this.broadcastedHB;
var defer;
(function () {
var conn = _this;
broadcastHB = !_this.broadcastedHB;
_this.broadcastedHB = true; _this.broadcastedHB = true;
db = _this.y.db; var db = _this.y.db;
defer = {}; var defer = {};
defer.promise = new Promise(function (resolve) { defer.promise = new Promise(function (resolve) {
defer.resolve = resolve; defer.resolve = resolve;
}); });
_this.syncStep2 = defer.promise; _this.syncStep2 = defer.promise;
var m /* :MessageSyncStep2 */ = message; var _m /* :MessageSyncStep2 */ = message;
db.requestTransaction(regeneratorRuntime.mark(function _callee5() { db.requestTransaction(regeneratorRuntime.mark(function _callee5() {
return regeneratorRuntime.wrap(function _callee5$(_context5) { return regeneratorRuntime.wrap(function _callee5$(_context5) {
while (1) { while (1) {
switch (_context5.prev = _context5.next) { switch (_context5.prev = _context5.next) {
case 0: case 0:
return _context5.delegateYield(this.applyDeleteSet(m.deleteSet), 't0', 1); return _context5.delegateYield(this.applyDeleteSet(_m.deleteSet), 't0', 1);
case 1: case 1:
this.store.apply(m.os); this.store.apply(_m.os);
db.requestTransaction(regeneratorRuntime.mark(function _callee4() { db.requestTransaction(regeneratorRuntime.mark(function _callee4() {
var ops; var ops;
return regeneratorRuntime.wrap(function _callee4$(_context4) { return regeneratorRuntime.wrap(function _callee4$(_context4) {
while (1) { while (1) {
switch (_context4.prev = _context4.next) { switch (_context4.prev = _context4.next) {
case 0: case 0:
return _context4.delegateYield(this.getOperations(m.stateSet), 't0', 1); return _context4.delegateYield(this.getOperations(_m.stateSet), 't0', 1);
case 1: case 1:
ops = _context4.t0; ops = _context4.t0;
@ -1902,13 +1967,13 @@ module.exports = function (Y /* :any */) {
if (ops.length > 0) { if (ops.length > 0) {
if (!broadcastHB) { if (!broadcastHB) {
// TODO: consider to broadcast here.. // TODO: consider to broadcast here..
conn.send(sender, { _conn.send(sender, {
type: 'update', type: 'update',
ops: ops ops: ops
}); });
} else { } else {
// broadcast only once! // broadcast only once!
conn.broadcastOps(ops); _conn.broadcastOps(ops);
} }
} }
defer.resolve(); defer.resolve();
@ -1928,7 +1993,6 @@ module.exports = function (Y /* :any */) {
} }
}, _callee5, this); }, _callee5, this);
})); }));
})();
} else if (message.type === 'sync done') { } else if (message.type === 'sync done') {
var self = _this; var self = _this;
_this.syncStep2.then(function () { _this.syncStep2.then(function () {
@ -2257,7 +2321,7 @@ module.exports = function (Y) {
options.role = 'master'; options.role = 'master';
options.forwardToSyncingClients = false; options.forwardToSyncingClients = false;
var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(Test).call(this, y, options)); var _this = _possibleConstructorReturn(this, (Test.__proto__ || Object.getPrototypeOf(Test)).call(this, y, options));
_this.setUserId(userIdCounter++ + '').then(function () { _this.setUserId(userIdCounter++ + '').then(function () {
globalRoom.addUser(_this); globalRoom.addUser(_this);
@ -2270,7 +2334,7 @@ module.exports = function (Y) {
_createClass(Test, [{ _createClass(Test, [{
key: 'receiveMessage', key: 'receiveMessage',
value: function receiveMessage(sender, m) { value: function receiveMessage(sender, m) {
return _get(Object.getPrototypeOf(Test.prototype), 'receiveMessage', this).call(this, sender, JSON.parse(JSON.stringify(m))); return _get(Test.prototype.__proto__ || Object.getPrototypeOf(Test.prototype), 'receiveMessage', this).call(this, sender, JSON.parse(JSON.stringify(m)));
} }
}, { }, {
key: 'send', key: 'send',
@ -2304,7 +2368,7 @@ module.exports = function (Y) {
value: function reconnect() { value: function reconnect() {
if (this.isDisconnected()) { if (this.isDisconnected()) {
globalRoom.addUser(this); globalRoom.addUser(this);
_get(Object.getPrototypeOf(Test.prototype), 'reconnect', this).call(this); _get(Test.prototype.__proto__ || Object.getPrototypeOf(Test.prototype), 'reconnect', this).call(this);
} }
return Y.utils.globalRoom.flushAll(); return Y.utils.globalRoom.flushAll();
} }
@ -2313,7 +2377,7 @@ module.exports = function (Y) {
value: function disconnect() { value: function disconnect() {
if (!this.isDisconnected()) { if (!this.isDisconnected()) {
globalRoom.removeUser(this.userId); globalRoom.removeUser(this.userId);
_get(Object.getPrototypeOf(Test.prototype), 'disconnect', this).call(this); _get(Test.prototype.__proto__ || Object.getPrototypeOf(Test.prototype), 'disconnect', this).call(this);
} }
return this.y.db.whenTransactionsFinished(); return this.y.db.whenTransactionsFinished();
} }
@ -6473,7 +6537,7 @@ module.exports = function (Y /* :any */) {
synchronous. synchronous.
*/ */
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 _typeof = typeof Symbol === "function" && typeof Symbol.iterator === "symbol" ? function (obj) { return typeof obj; } : function (obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; };
var _get = function get(object, property, receiver) { 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 { return get(parent, property, receiver); } } else if ("value" in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } }; var _get = function get(object, property, receiver) { 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 { return get(parent, property, receiver); } } else if ("value" in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } };
@ -6557,7 +6621,7 @@ module.exports = function (Y /* : any*/) {
function EventHandler(onevent /* : Function */) { function EventHandler(onevent /* : Function */) {
_classCallCheck(this, EventHandler); _classCallCheck(this, EventHandler);
var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(EventHandler).call(this)); var _this = _possibleConstructorReturn(this, (EventHandler.__proto__ || Object.getPrototypeOf(EventHandler)).call(this));
_this.waiting = []; _this.waiting = [];
_this.awaiting = 0; _this.awaiting = 0;
@ -6568,7 +6632,7 @@ module.exports = function (Y /* : any*/) {
_createClass(EventHandler, [{ _createClass(EventHandler, [{
key: 'destroy', key: 'destroy',
value: function destroy() { value: function destroy() {
_get(Object.getPrototypeOf(EventHandler.prototype), 'destroy', this).call(this); _get(EventHandler.prototype.__proto__ || Object.getPrototypeOf(EventHandler.prototype), 'destroy', this).call(this);
this.waiting = null; this.waiting = null;
this.onevent = null; this.onevent = null;
} }
@ -7252,7 +7316,7 @@ module.exports = function (Y /* : any*/) {
function SmallLookupBuffer(arg1, arg2) { function SmallLookupBuffer(arg1, arg2) {
_classCallCheck(this, SmallLookupBuffer); _classCallCheck(this, SmallLookupBuffer);
var _this2 = _possibleConstructorReturn(this, Object.getPrototypeOf(SmallLookupBuffer).call(this, arg1, arg2)); var _this2 = _possibleConstructorReturn(this, (SmallLookupBuffer.__proto__ || Object.getPrototypeOf(SmallLookupBuffer)).call(this, arg1, arg2));
// super(...arguments) -- do this when this is supported by stable nodejs // super(...arguments) -- do this when this is supported by stable nodejs
@ -7328,7 +7392,7 @@ module.exports = function (Y /* : any*/) {
break; break;
} }
return _context2.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'find', this).call(this, id), 't0', 21); return _context2.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'find', this).call(this, id), 't0', 21);
case 21: case 21:
o = _context2.t0; o = _context2.t0;
@ -7401,7 +7465,7 @@ module.exports = function (Y /* : any*/) {
break; break;
} }
return _context3.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'put', this).call(this, write), 't0', 15); return _context3.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'put', this).call(this, write), 't0', 15);
case 15: case 15:
// put o to the end of writeBuffer // put o to the end of writeBuffer
@ -7449,7 +7513,7 @@ module.exports = function (Y /* : any*/) {
return _context4.delegateYield(this.flush(), 't0', 2); return _context4.delegateYield(this.flush(), 't0', 2);
case 2: case 2:
return _context4.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'delete', this).call(this, id), 't1', 3); return _context4.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'delete', this).call(this, id), 't1', 3);
case 3: case 3:
case 'end': case 'end':
@ -7483,7 +7547,7 @@ module.exports = function (Y /* : any*/) {
return _context5.delegateYield(this.flush(), 't1', 7); return _context5.delegateYield(this.flush(), 't1', 7);
case 7: case 7:
return _context5.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findWithLowerBound', this).apply(this, _args5), 't2', 8); return _context5.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findWithLowerBound', this).apply(this, _args5), 't2', 8);
case 8: case 8:
return _context5.abrupt('return', _context5.t2); return _context5.abrupt('return', _context5.t2);
@ -7520,7 +7584,7 @@ module.exports = function (Y /* : any*/) {
return _context6.delegateYield(this.flush(), 't1', 7); return _context6.delegateYield(this.flush(), 't1', 7);
case 7: case 7:
return _context6.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findWithUpperBound', this).apply(this, _args6), 't2', 8); return _context6.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findWithUpperBound', this).apply(this, _args6), 't2', 8);
case 8: case 8:
return _context6.abrupt('return', _context6.t2); return _context6.abrupt('return', _context6.t2);
@ -7543,7 +7607,7 @@ module.exports = function (Y /* : any*/) {
return _context7.delegateYield(this.flush(), 't0', 1); return _context7.delegateYield(this.flush(), 't0', 1);
case 1: case 1:
return _context7.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findNext', this).apply(this, _args7), 't1', 2); return _context7.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findNext', this).apply(this, _args7), 't1', 2);
case 2: case 2:
return _context7.abrupt('return', _context7.t1); return _context7.abrupt('return', _context7.t1);
@ -7566,7 +7630,7 @@ module.exports = function (Y /* : any*/) {
return _context8.delegateYield(this.flush(), 't0', 1); return _context8.delegateYield(this.flush(), 't0', 1);
case 1: case 1:
return _context8.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findPrev', this).apply(this, _args8), 't1', 2); return _context8.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'findPrev', this).apply(this, _args8), 't1', 2);
case 2: case 2:
return _context8.abrupt('return', _context8.t1); return _context8.abrupt('return', _context8.t1);
@ -7589,7 +7653,7 @@ module.exports = function (Y /* : any*/) {
return _context9.delegateYield(this.flush(), 't0', 1); return _context9.delegateYield(this.flush(), 't0', 1);
case 1: case 1:
return _context9.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'iterate', this).apply(this, _args9), 't1', 2); return _context9.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'iterate', this).apply(this, _args9), 't1', 2);
case 2: case 2:
case 'end': case 'end':
@ -7621,7 +7685,7 @@ module.exports = function (Y /* : any*/) {
break; break;
} }
return _context10.delegateYield(_get(Object.getPrototypeOf(SmallLookupBuffer.prototype), 'put', this).call(this, write), 't0', 5); return _context10.delegateYield(_get(SmallLookupBuffer.prototype.__proto__ || Object.getPrototypeOf(SmallLookupBuffer.prototype), 'put', this).call(this, write), 't0', 5);
case 5: case 5:
this.writeBuffer[i] = { this.writeBuffer[i] = {
@ -7970,7 +8034,7 @@ var YConfig = function () {
return YConfig; return YConfig;
}(); }();
},{"./Connector.js":7,"./Connectors/Test.js":8,"./Database.js":9,"./Struct.js":10,"./Transaction.js":11,"./Utils.js":12,"debug":2}]},{},[6,13])(13) },{"./Connector.js":7,"./Connectors/Test.js":8,"./Database.js":9,"./Struct.js":10,"./Transaction.js":11,"./Utils.js":12,"debug":1}]},{},[6,13])(13)
}); });

2
y.js.map
View File

File diff suppressed because one or more lines are too long