CodeCow/sharedrop
1
0
Fork 0
mirror of https://github.com/szimek/sharedrop.git synced 2026-06-05 21:02:47 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Make sure to remove received messages after reconnecting to Firebase

Browse Source
This commit is contained in:
Szymon Nowak 2019-01-18 17:04:47 +01:00
parent 13237935a2
commit 50decebed3
No known key found for this signature in database
GPG Key ID: 5C924145BFDDAFFF
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
vendor/peer.js vendored
View File

@ -453,21 +453,27 @@ util.inherits(Peer, EventEmitter);
/** Initialize a connection with the server. */
Peer.prototype._initialize = function (id) {
var self = this;
this.id = id;
// Firebase
this._ref = this.options.firebaseRef;
this._connectionRef = this._ref.child('.info/connected');
this._messagesRef = this._ref.child('rooms/' + this.options.room + '/messages');
this._yourMessagesRef = this._messagesRef.child(id);
this._receivedMessagesRef = this._messagesRef.child(id);
// Remove received messages on disconnect
this._yourMessagesRef.onDisconnect().remove();
this._connectionRef.on('value', (connectionSnapshot) => {
if (connectionSnapshot.val() === true) {
// Remove received messages on disconnect
this._receivedMessagesRef.onDisconnect().remove();
// Listen to incoming messages
this._yourMessagesRef.on('child_added', function (snapshot) {
var message = snapshot.val();
self._handleMessage(message);
// Listen to incoming messages
this._receivedMessagesRef.on('child_added', (snapshot) => {
const message = snapshot.val();
this._handleMessage(message);
});
} else {
this._receivedMessagesRef.off();
}
});
// The connection to the server is open