Compare commits
4 Commits
v13.0.0-9
...
v13.0.0-10
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a267affeda | ||
|
|
90b2a895b8 | ||
|
|
4f57c91b82 | ||
|
|
3e1d89253f |
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "yjs",
|
"name": "yjs",
|
||||||
"version": "13.0.0-9",
|
"version": "13.0.0-10",
|
||||||
"description": "A framework for real-time p2p shared editing on any data",
|
"description": "A framework for real-time p2p shared editing on any data",
|
||||||
"main": "./y.node.js",
|
"main": "./y.node.js",
|
||||||
"browser": "./y.js",
|
"browser": "./y.js",
|
||||||
|
|||||||
@@ -156,22 +156,24 @@ export default function extendConnector (Y/* :any */) {
|
|||||||
sendSyncStep1(this, syncUser)
|
sendSyncStep1(this, syncUser)
|
||||||
} else {
|
} else {
|
||||||
if (!conn.isSynced) {
|
if (!conn.isSynced) {
|
||||||
this.y.db.requestTransaction(function * () {
|
conn._fireIsSyncedListeners()
|
||||||
if (!conn.isSynced) {
|
|
||||||
// it is crucial that isSynced is set at the time garbageCollectAfterSync is called
|
|
||||||
conn.isSynced = true
|
|
||||||
// It is safer to remove this!
|
|
||||||
// TODO: remove: yield * this.garbageCollectAfterSync()
|
|
||||||
// call whensynced listeners
|
|
||||||
for (var f of conn.whenSyncedListeners) {
|
|
||||||
f()
|
|
||||||
}
|
|
||||||
conn.whenSyncedListeners = []
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
_fireIsSyncedListeners () {
|
||||||
|
this.y.db.whenTransactionsFinished().then(() => {
|
||||||
|
if (!this.isSynced) {
|
||||||
|
this.isSynced = true
|
||||||
|
// It is safer to remove this!
|
||||||
|
// TODO: remove: yield * this.garbageCollectAfterSync()
|
||||||
|
// call whensynced listeners
|
||||||
|
for (var f of this.whenSyncedListeners) {
|
||||||
|
f()
|
||||||
|
}
|
||||||
|
this.whenSyncedListeners = []
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
send (uid, buffer) {
|
send (uid, buffer) {
|
||||||
if (!(buffer instanceof ArrayBuffer || buffer instanceof Uint8Array)) {
|
if (!(buffer instanceof ArrayBuffer || buffer instanceof Uint8Array)) {
|
||||||
throw new Error('Expected Message to be an ArrayBuffer or Uint8Array - please don\'t use this method to send custom messages')
|
throw new Error('Expected Message to be an ArrayBuffer or Uint8Array - please don\'t use this method to send custom messages')
|
||||||
@@ -222,10 +224,10 @@ export default function extendConnector (Y/* :any */) {
|
|||||||
*/
|
*/
|
||||||
receiveMessage (sender, buffer) {
|
receiveMessage (sender, buffer) {
|
||||||
if (!(buffer instanceof ArrayBuffer || buffer instanceof Uint8Array)) {
|
if (!(buffer instanceof ArrayBuffer || buffer instanceof Uint8Array)) {
|
||||||
throw new Error('Expected Message to be an ArrayBuffer or Uint8Array!')
|
return Promise.reject(new Error('Expected Message to be an ArrayBuffer or Uint8Array!'))
|
||||||
}
|
}
|
||||||
if (sender === this.userId) {
|
if (sender === this.userId) {
|
||||||
return
|
return Promise.resolve()
|
||||||
}
|
}
|
||||||
let decoder = new BinaryDecoder(buffer)
|
let decoder = new BinaryDecoder(buffer)
|
||||||
let encoder = new BinaryEncoder()
|
let encoder = new BinaryEncoder()
|
||||||
@@ -244,29 +246,32 @@ export default function extendConnector (Y/* :any */) {
|
|||||||
if (messageType === 'sync step 1' || messageType === 'sync step 2') {
|
if (messageType === 'sync step 1' || messageType === 'sync step 2') {
|
||||||
let auth = decoder.readVarUint()
|
let auth = decoder.readVarUint()
|
||||||
if (senderConn.auth == null) {
|
if (senderConn.auth == null) {
|
||||||
senderConn.processAfterAuth.push([sender, buffer])
|
senderConn.processAfterAuth.push([messageType, senderConn, decoder, encoder, sender])
|
||||||
|
|
||||||
// check auth
|
// check auth
|
||||||
return this.checkAuth(auth, this.y, sender).then(authPermissions => {
|
return this.checkAuth(auth, this.y, sender).then(authPermissions => {
|
||||||
senderConn.auth = authPermissions
|
if (senderConn.auth == null) {
|
||||||
this.y.emit('userAuthenticated', {
|
senderConn.auth = authPermissions
|
||||||
user: senderConn.uid,
|
this.y.emit('userAuthenticated', {
|
||||||
auth: authPermissions
|
user: senderConn.uid,
|
||||||
})
|
auth: authPermissions
|
||||||
return senderConn.syncStep2.promise
|
})
|
||||||
}).then(() => {
|
|
||||||
if (senderConn.processAfterAuth == null) {
|
|
||||||
return Promise.resolve()
|
|
||||||
}
|
}
|
||||||
let messages = senderConn.processAfterAuth
|
let messages = senderConn.processAfterAuth
|
||||||
senderConn.processAfterAuth = null
|
senderConn.processAfterAuth = []
|
||||||
return Promise.all(messages.map(m =>
|
|
||||||
this.receiveMessage(m[0], m[1])
|
return messages.reduce((p, m) =>
|
||||||
))
|
p.then(() => this.computeMessage(m[0], m[1], m[2], m[3], m[4]))
|
||||||
|
, Promise.resolve())
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (senderConn.auth != null) {
|
||||||
|
return this.computeMessage(messageType, senderConn, decoder, encoder, sender)
|
||||||
|
} else {
|
||||||
|
senderConn.processAfterAuth.push([messageType, senderConn, decoder, encoder, sender])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
computeMessage (messageType, senderConn, decoder, encoder, sender) {
|
||||||
if (messageType === 'sync step 1' && (senderConn.auth === 'write' || senderConn.auth === 'read')) {
|
if (messageType === 'sync step 1' && (senderConn.auth === 'write' || senderConn.auth === 'read')) {
|
||||||
// cannot wait for sync step 1 to finish, because we may wait for sync step 2 in sync step 1 (->lock)
|
// cannot wait for sync step 1 to finish, because we may wait for sync step 2 in sync step 1 (->lock)
|
||||||
computeMessageSyncStep1(decoder, encoder, this, senderConn, sender)
|
computeMessageSyncStep1(decoder, encoder, this, senderConn, sender)
|
||||||
@@ -276,7 +281,7 @@ export default function extendConnector (Y/* :any */) {
|
|||||||
} else if (messageType === 'update' && senderConn.auth === 'write') {
|
} else if (messageType === 'update' && senderConn.auth === 'write') {
|
||||||
return computeMessageUpdate(decoder, encoder, this, senderConn, sender)
|
return computeMessageUpdate(decoder, encoder, this, senderConn, sender)
|
||||||
} else {
|
} else {
|
||||||
Promise.reject(new Error('Unable to receive message'))
|
return Promise.reject(new Error('Unable to receive message'))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
_setSyncedWith (user) {
|
_setSyncedWith (user) {
|
||||||
@@ -288,6 +293,9 @@ export default function extendConnector (Y/* :any */) {
|
|||||||
this.currentSyncTarget = null
|
this.currentSyncTarget = null
|
||||||
this.findNextSyncTarget()
|
this.findNextSyncTarget()
|
||||||
}
|
}
|
||||||
|
if (this.role === 'slave' && conn.role === 'master') {
|
||||||
|
this._fireIsSyncedListeners()
|
||||||
|
}
|
||||||
}
|
}
|
||||||
/*
|
/*
|
||||||
Currently, the HB encodes operations as JSON. For the moment I want to keep it
|
Currently, the HB encodes operations as JSON. For the moment I want to keep it
|
||||||
|
|||||||
1
y.node.js.map
Normal file
1
y.node.js.map
Normal file
File diff suppressed because one or more lines are too long
1
y.test.js.map
Normal file
1
y.test.js.map
Normal file
File diff suppressed because one or more lines are too long
Reference in New Issue
Block a user