Mastodon/Sengi-Windows-MacOS-Linux
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

don't spam API in case of errors

Browse Source
This commit is contained in:
Nicolas Constant 2019-07-04 00:36:43 -04:00
parent 9e224efa88
commit b733631b28
No known key found for this signature in database
GPG Key ID: 1E9F677FB01A5688
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/app/services/streaming.service.ts
View File

@ -47,7 +47,7 @@ export class StreamingWrapper {
this.eventSource = new WebSocket(route); this.eventSource = new WebSocket(route);
this.eventSource.onmessage = x => this.statusParsing(<WebSocketEvent>JSON.parse(x.data)); this.eventSource.onmessage = x => this.statusParsing(<WebSocketEvent>JSON.parse(x.data));
this.eventSource.onerror = x => this.webSocketGotError(x); this.eventSource.onerror = x => this.webSocketGotError(x);
this.eventSource.onopen = x => {}; this.eventSource.onopen = x => { };
this.eventSource.onclose = x => this.webSocketClosed(route, x); this.eventSource.onclose = x => this.webSocketClosed(route, x);
} }
@ -57,10 +57,12 @@ export class StreamingWrapper {
private webSocketClosed(domain, x: Event) { private webSocketClosed(domain, x: Event) {
if (this.errorClosing) { if (this.errorClosing) {
this.pullNewStatuses(domain); setTimeout(() => {
this.errorClosing = false; this.pullNewStatuses(domain);
this.errorClosing = false;
}, 60 * 1000);
} else if (!this.disposed) { } else if (!this.disposed) {
setTimeout(() => { this.start(domain) }, 5000); setTimeout(() => { this.start(domain) }, 60 * 1000);
} }
} }
@ -83,7 +85,7 @@ export class StreamingWrapper {
.then(() => { .then(() => {
// setTimeout(() => { this.start(domain) }, 20 * 1000); // setTimeout(() => { this.start(domain) }, 20 * 1000);
if (!this.disposed) { if (!this.disposed) {
setTimeout(() => { this.pullNewStatuses(domain) }, 15 * 1000); setTimeout(() => { this.pullNewStatuses(domain) }, 60 * 1000);
} }
}); });
} }