update port

This commit is contained in:
Kevin Jahns 2015-12-02 20:04:11 +01:00
parent 5da36f07ce
commit 08f0702fcd
8 changed files with 43 additions and 49 deletions

View File

@ -17,7 +17,7 @@
</g> </g>
</svg> </svg>
<script src="../bower_components/yjs/y.es6"></script> <script src="../bower_components/yjs/y.js"></script>
<script src="../bower_components/d3/d3.js"></script> <script src="../bower_components/d3/d3.js"></script>
<script src="./index.js"></script> <script src="./index.js"></script>
</body> </body>

View File

@ -7,9 +7,9 @@ Y({
name: 'memory' name: 'memory'
}, },
connector: { connector: {
url: 'http://127.0.0.1:1234',
name: 'websockets-client', name: 'websockets-client',
room: 'Puzzle-example2', room: 'Puzzle-example2',
url: 'http://127.0.0.1:2345',
debug: true debug: true
}, },
sourceDir: '/bower_components', sourceDir: '/bower_components',

View File

@ -3,7 +3,7 @@
<body> <body>
<textarea style="width:80%;" rows=40 id="textfield"></textarea> <textarea style="width:80%;" rows=40 id="textfield"></textarea>
<script src="../bower_components/yjs/y.es6"></script> <script src="../bower_components/yjs/y.js"></script>
<script src="./index.js"></script> <script src="./index.js"></script>
</body> </body>
</html> </html>

View File

@ -7,7 +7,9 @@ Y({
}, },
connector: { connector: {
name: 'websockets-client', name: 'websockets-client',
room: 'Textarea-example' room: 'Textarea-example',
url: 'http://127.0.0.1:2345',
debug: true
}, },
sourceDir: '/bower_components', sourceDir: '/bower_components',
share: { share: {

34
y.es6
View File

@ -1814,7 +1814,7 @@ module.exports = function (Y/* :any */) {
} }
* addOperation (op) { * addOperation (op) {
yield* this.os.put(op) yield* this.os.put(op)
if (!this.store.y.connector.isDisconnected() && this.store.forwardAppliedOperations) { if (!this.store.y.connector.isDisconnected() && this.store.forwardAppliedOperations && op.id[0] !== '_') {
// is connected, and this is not going to be send in addOperation // is connected, and this is not going to be send in addOperation
this.store.y.connector.broadcast({ this.store.y.connector.broadcast({
type: 'update', type: 'update',
@ -2223,30 +2223,26 @@ function requestModules (modules) {
// determine if this module was compiled for es5 or es6 (y.js vs. y.es6) // determine if this module was compiled for es5 or es6 (y.js vs. y.es6)
// if Insert.execute is a Function, then it isnt a generator.. // if Insert.execute is a Function, then it isnt a generator..
// then load the es5(.js) files.. // then load the es5(.js) files..
var extention = Y.Struct.Insert.execute.constructor === Function ? '.js' : '.es6' var extention = typeof regeneratorRuntime !== 'undefined' ? '.js' : '.es6'
var promises = [] var promises = []
for (var i = 0; i < modules.length; i++) { for (var i = 0; i < modules.length; i++) {
var modulename = 'y-' + modules[i].toLowerCase() var modulename = 'y-' + modules[i].toLowerCase()
if (Y[modules[i]] == null) { if (Y[modules[i]] == null) {
if (requiringModules[modules[i]] == null) { if (requiringModules[modules[i]] == null) {
try { // module does not exist
require(modulename)(Y) if (typeof window !== 'undefined' && window.Y !== 'undefined') {
} catch (e) { var imported = document.createElement('script')
// module does not exist imported.src = Y.sourceDir + '/' + modulename + '/' + modulename + extention
if (typeof window !== 'undefined') { document.head.appendChild(imported)
var imported = document.createElement('script')
imported.src = Y.sourceDir + '/' + modulename + '/' + modulename + extention
document.head.appendChild(imported)
let requireModule = {} let requireModule = {}
requiringModules[modules[i]] = requireModule requiringModules[modules[i]] = requireModule
requireModule.promise = new Promise(function (resolve) { requireModule.promise = new Promise(function (resolve) {
requireModule.resolve = resolve requireModule.resolve = resolve
}) })
promises.push(requireModule.promise) promises.push(requireModule.promise)
} else { } else {
throw e require(modulename)(Y)
}
} }
} else { } else {
promises.push(requiringModules[modules[i]].promise) promises.push(requiringModules[modules[i]].promise)

File diff suppressed because one or more lines are too long

44
y.js
View File

@ -4044,7 +4044,7 @@ module.exports = function (Y /* :any */) {
return _context18.delegateYield(this.os.put(op), 't0', 1); return _context18.delegateYield(this.os.put(op), 't0', 1);
case 1: case 1:
if (!this.store.y.connector.isDisconnected() && this.store.forwardAppliedOperations) { if (!this.store.y.connector.isDisconnected() && this.store.forwardAppliedOperations && op.id[0] !== '_') {
// is connected, and this is not going to be send in addOperation // is connected, and this is not going to be send in addOperation
this.store.y.connector.broadcast({ this.store.y.connector.broadcast({
type: 'update', type: 'update',
@ -4801,35 +4801,31 @@ function requestModules(modules) {
// determine if this module was compiled for es5 or es6 (y.js vs. y.es6) // determine if this module was compiled for es5 or es6 (y.js vs. y.es6)
// if Insert.execute is a Function, then it isnt a generator.. // if Insert.execute is a Function, then it isnt a generator..
// then load the es5(.js) files.. // then load the es5(.js) files..
var extention = Y.Struct.Insert.execute.constructor === Function ? '.js' : '.es6'; var extention = typeof regeneratorRuntime !== 'undefined' ? '.js' : '.es6';
var promises = []; var promises = [];
for (var i = 0; i < modules.length; i++) { for (var i = 0; i < modules.length; i++) {
var modulename = 'y-' + modules[i].toLowerCase(); var modulename = 'y-' + modules[i].toLowerCase();
if (Y[modules[i]] == null) { if (Y[modules[i]] == null) {
if (requiringModules[modules[i]] == null) { if (requiringModules[modules[i]] == null) {
try { // module does not exist
if (typeof window !== 'undefined' && window.Y !== 'undefined') {
var imported;
(function () {
imported = document.createElement('script');
imported.src = Y.sourceDir + '/' + modulename + '/' + modulename + extention;
document.head.appendChild(imported);
var requireModule = {};
requiringModules[modules[i]] = requireModule;
requireModule.promise = new Promise(function (resolve) {
requireModule.resolve = resolve;
});
promises.push(requireModule.promise);
})();
} else {
require(modulename)(Y); require(modulename)(Y);
} catch (e) {
// module does not exist
if (typeof window !== 'undefined') {
var imported;
(function () {
imported = document.createElement('script');
imported.src = Y.sourceDir + '/' + modulename + '/' + modulename + extention;
document.head.appendChild(imported);
var requireModule = {};
requiringModules[modules[i]] = requireModule;
requireModule.promise = new Promise(function (resolve) {
requireModule.resolve = resolve;
});
promises.push(requireModule.promise);
})();
} else {
throw e;
}
} }
} else { } else {
promises.push(requiringModules[modules[i]].promise); promises.push(requiringModules[modules[i]].promise);

File diff suppressed because one or more lines are too long