OpenServer/SecureNotes
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Making periodic Synchronisation

Browse Source
This commit is contained in:
Fabian 2019-05-31 22:16:16 +02:00
parent c3c36504ab
commit e5b0c96434
2 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
public/serviceworker.js
View File

@ -48,19 +48,12 @@ var Types;
Types[Types["REFRESH"] = 2] = "REFRESH"; Types[Types["REFRESH"] = 2] = "REFRESH";
})(Types || (Types = {})); })(Types || (Types = {}));
let rules = [ let rules = [{
{
match: (url) => { match: (url) => {
return url.indexOf("/api/") >= 0; return url.indexOf("/api/") >= 0;
}, },
type: Types.NOCACHE type: Types.NOCACHE
}, },
{
match: (url) => {
return url.indexOf("/version_hash") >= 0;
},
type: Types.NOCACHE
},
{ {
match: () => { match: () => {
return true; return true;
@ -79,7 +72,7 @@ self.addEventListener('fetch', (evt) => {
return fromCache(evt.request); return fromCache(evt.request);
case Types.REFRESH: case Types.REFRESH:
return refresh(evt.request).then(r => { return refresh(evt.request).then(r => {
evt.waitUntil(r.refresh.catch(_ => { })); evt.waitUntil(r.refresh.catch(_ => {}));
return r.result; return r.result;
}); });
case Types.NOCACHE: case Types.NOCACHE:
@ -95,7 +88,12 @@ async function fromCache(request) {
return matching return matching
let res = await fetch(request.clone()); let res = await fetch(request.clone());
await cache.put(request, res); await cache.put(request, {
match: (url) => {
return url.indexOf("/version_hash") >= 0;
},
type: Types.NOCACHE
}, res);
return await cache.match(request); return await cache.match(request);
} }

2
src/notes.ts
View File

@ -167,7 +167,7 @@ class NotesProvider {
public async start() { public async start() {
const next = () => { const next = () => {
setTimeout(() => { setTimeout(() => {
this.sync().then(() => next); this.sync().then(next);
}, 30000) }, 30000)
} }
this.syncedObservableServer.send((await this.oplogDB.getAll()).length <= 0); this.syncedObservableServer.send((await this.oplogDB.getAll()).length <= 0);