Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-31 04:23:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

working message offline

Browse Source
This commit is contained in:
Drew Ansbacher
2021-06-24 16:35:15 -06:00
committed by Aiden McClelland
parent fdbe00aef9
commit ce514646ff
2 changed files with 47 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
ui/src/app/services/connection.service.ts
View File

@@ -7,9 +7,9 @@ import { ApiService } from './api/api.service'
providedIn: 'root',
})
export class ConnectionService {
private offlineSubscription: Subscription
private onlineSubscription: Subscription
private httpSubscription: Subscription
private offlineSubscription$: Subscription
private onlineSubscription$: Subscription
private httpSubscription$: Subscription
private readonly currentState: ConnectionState = {
network: true,
internet: true,
@@ -25,9 +25,9 @@ export class ConnectionService {
ngOnDestroy (): void {
try {
this.offlineSubscription.unsubscribe()
this.onlineSubscription.unsubscribe()
this.httpSubscription.unsubscribe()
this.offlineSubscription$.unsubscribe()
this.onlineSubscription$.unsubscribe()
this.httpSubscription$.unsubscribe()
} catch (e) {
console.error(e.message)
}
@@ -44,34 +44,36 @@ export class ConnectionService {
}
private checkNetworkState (): void {
this.onlineSubscription = fromEvent(window, 'online').subscribe(() => {
this.onlineSubscription$ = fromEvent(window, 'online').subscribe(() => {
this.currentState.network = true
this.checkInternetState()
this.emitEvent()
})
this.offlineSubscription = fromEvent(window, 'offline').subscribe(() => {
this.currentState.network = true
this.checkInternetState()
this.offlineSubscription$ = fromEvent(window, 'offline').subscribe(() => {
this.currentState.network = false
if (this.httpSubscription$) {
this.httpSubscription$.unsubscribe()
}
this.emitEvent()
})
}
private checkInternetState (): void {
if (this.httpSubscription) {
this.httpSubscription.unsubscribe()
if (this.httpSubscription$) {
this.httpSubscription$.unsubscribe()
}
// ping server every 10 seconds
this.httpSubscription = timer(0, 10000)
this.httpSubscription$ = timer(0, 10000)
.pipe(
switchMap(() => this.apiService.echo()),
retryWhen(errors =>
errors.pipe(
tap(val => {
console.error('Echo error: ', val)
this.currentState.internet = true
this.currentState.internet = false
this.emitEvent()
}),
// restart after 2 seconds
@@ -86,7 +88,7 @@ export class ConnectionService {
}
private emitEvent (): void {
this.stateChangeEventEmitter.next(this.currentState)
this.stateChangeEventEmitter.next({ ...this.currentState })
}
}