status-im/realm-js
2
0
Fork 0
mirror of https://github.com/status-im/realm-js.git synced 2025-02-04 10:43:29 +00:00
Code Issues Projects Releases Wiki Activity

Track Realms seen in the notifier by id rather than path

Browse Source 
If a Realm is deleted and then a new one is created at the same path it needs
to be treated as a new Realm.
This commit is contained in:
Thomas Goyne 2018-05-04 14:11:20 -07:00
parent c0c2606aa1
commit 29ad083f25
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/notifier.js
View File

@ -45,11 +45,11 @@ class FunctionListener {
return this.regexStr === regex && this.event === event && this.fn === fn; return this.regexStr === regex && this.event === event && this.fn === fn;
} }
onavailable(path) { onavailable(path, id) {
if (this.regex.test(path)) { if (this.regex.test(path)) {
if (this.event === 'available' && !this.seen[path]) { if (this.event === 'available' && !this.seen[id]) {
this.fn(path); this.fn(path);
this.seen[path] = true; this.seen[id] = true;
} }
return this.event === 'change'; return this.event === 'change';
} }
@ -103,11 +103,11 @@ class OutOfProcListener {
return this.regexStr === regex && this.worker === worker; return this.regexStr === regex && this.worker === worker;
} }
onavailable(path) { onavailable(path, id) {
if (this.regex.test(path)) { if (this.regex.test(path)) {
if (!this.seen[path]) { if (!this.seen[id]) {
this.worker.onavailable(path); this.worker.onavailable(path);
this.seen[path] = true; this.seen[id] = true;
} }
return true; return true;
} }
@ -161,10 +161,11 @@ class Listener {
changes.release(); changes.release();
} }
available(virtualPath) { available(virtualPath, id) {
let watch = false; let watch = false;
id = id || virtualPath;
for (const callback of this.callbacks) { for (const callback of this.callbacks) {
if (callback.onavailable(virtualPath)) { if (callback.onavailable(virtualPath, id)) {
watch = true; watch = true;
} }
} }