feat(network): new network service that return the network status

packages/core/src/lib/network/index.ts

@@ -0,0 +1,2 @@
+export * from './network.service';
+export * from './network.module';

packages/core/src/lib/network/network.module.ts

@@ -0,0 +1,10 @@
+import { NgModule } from '@angular/core';
+import { CommonModule } from '@angular/common';
+import { NetworkService } from './network.service';
+
+@NgModule({
+  declarations: [],
+  imports: [CommonModule],
+  providers: [NetworkService]
+})
+export class NetworkModule { }

packages/core/src/lib/network/network.service.spec.ts

@@ -0,0 +1,12 @@
+import { TestBed } from '@angular/core/testing';
+
+import { NetworkService } from './network.service';
+
+describe('NetworkService', () => {
+  beforeEach(() => TestBed.configureTestingModule({}));
+
+  it('should be created', () => {
+    const service: NetworkService = TestBed.get(NetworkService);
+    expect(service).toBeTruthy();
+  });
+});

packages/core/src/lib/network/network.service.ts

@@ -0,0 +1,75 @@
+import { Injectable, EventEmitter, OnDestroy, AfterViewInit, OnInit, Injector } from '@angular/core';
+import { Observable, Subscription, fromEvent } from 'rxjs';
+import { debounceTime, startWith } from 'rxjs/operators';
+
+import { MessageService } from '../message';
+import { LanguageService } from '../language/shared/language.service';
+
+export interface ConnectionState {
+  connection: boolean;
+}
+
+@Injectable({
+  providedIn: 'root'
+})
+export class NetworkService implements OnDestroy {
+
+  private stateChangeEventEmitter = new EventEmitter<ConnectionState>();
+  private onlineSubscription: Subscription;
+  private offlineSubscription: Subscription;
+
+  private state: ConnectionState = {
+    connection: window.navigator.onLine
+  };
+
+  constructor(
+    private messageService: MessageService,
+    private injector: Injector
+    ) {
+    this.checkNetworkState();
+  }
+
+  private checkNetworkState() {
+    this.onlineSubscription = fromEvent(window, 'online').subscribe(() => {
+      const translate = this.injector.get(LanguageService).translate;
+      const message = translate.instant('igo.core.network.online.message');
+      const title = translate.instant('igo.core.network.online.title');
+      this.messageService.info(message, title);
+      this.state.connection = true;
+      this.emitEvent();
+    });
+
+    this.offlineSubscription = fromEvent(window, 'offline').subscribe(() => {
+      const translate = this.injector.get(LanguageService).translate;
+      const message = translate.instant('igo.core.network.offline.message');
+      const title = translate.instant('igo.core.network.offline.title');
+      this.messageService.info(message, title);
+      this.state.connection = false;
+      this.emitEvent();
+    });
+  }
+
+  private emitEvent() {
+    this.stateChangeEventEmitter.emit(this.state);
+  }
+
+  ngOnDestroy(): void {
+    try {
+      this.offlineSubscription.unsubscribe();
+      this.onlineSubscription.unsubscribe();
+    } catch (e) {
+    }
+  }
+
+  currentState(reportState = true): Observable<ConnectionState> {
+    return reportState ?
+    this.stateChangeEventEmitter.pipe(
+      debounceTime(300),
+      startWith(this.state),
+    )
+    :
+    this.stateChangeEventEmitter.pipe(
+      debounceTime(300)
+    );
+  }
+}

packages/core/src/locale/en.core.json

@@ -7,6 +7,16 @@
             "Sorry, service is currently not available. Please try again later",
           "title": "Error server"
         }
+      },
+      "network": {
+        "online": {
+          "message": "Online",
+          "title": "Status:"
+        },
+        "offline": {
+          "message": "Offline",
+          "title": "Status:"
+        }
       }
     }
   }

packages/core/src/locale/fr.core.json

@@ -7,6 +7,16 @@
             "Désolé! Le service que vous voulez utiliser n’est malheureusement pas disponible pour le moment. Essayez plus tard!",
           "title": "Erreur serveur"
         }
+      },
+      "network": {
+        "online": {
+          "message": "En ligne",
+          "title": "Statut:"
+        },
+        "offline": {
+          "message": "Hors-Ligne",
+          "title": "Statut:"
+        }
       }
     }
   }

packages/core/src/public_api.ts

@@ -22,3 +22,4 @@ export * from './lib/language';
 export * from './lib/media';
 export * from './lib/message';
 export * from './lib/request';
+export * from './lib/network';