masquitos

Untitled

May 6th, 2020
889
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.   private sendData(data: any, event: SOCKET_EVENTS): Observable<any> {
  2.     if (!this.isConnected) {
  3.       console.error(ERROR_SOCKET_NOT_CONNECTED, event, data);
  4.       const myError: MyError = {
  5.         code: 1,
  6.         message: ERROR_SOCKET_NOT_CONNECTED,
  7.         name: ERROR_SOCKET_NOT_CONNECTED,
  8.         type: MyerrorTypes.NETWORK
  9.       };
  10.       return throwError(myError);
  11.     }
  12.  
  13.     return new Observable<any>(observer => {
  14.       this.socket
  15.         .emit(event, data, function(responseData: Result<any>) {
  16.           console.log("Data sended", responseData);
  17.           if (responseData.success === true) {
  18.             observer.next(responseData.data);
  19.             observer.complete();
  20.           } else {
  21.             console.error("Data not sended", responseData);
  22.             const myError: MyError = {
  23.               code: responseData.error.code,
  24.               message: responseData.error.text,
  25.               name: ERROR_SOCKET_NOT_CONNECTED,
  26.               type: MyerrorTypes.APPLICATION
  27.             };
  28.  
  29.             observer.error(myError);
  30.           }
  31.         })
  32.         .once("disconnect", err => {
  33.           console.error("Socket emit disconnect :", err);
  34.           const myError: MyError = {
  35.             code: 1,
  36.             message: ERROR_SOCKET_NOT_CONNECTED,
  37.             name: ERROR_SOCKET_NOT_CONNECTED,
  38.             type: MyerrorTypes.NETWORK
  39.           };
  40.           observer.error(myError);
  41.         });
  42.     }).pipe(takeUntil(this.actions$.pipe(ofType(LOG_OUT))));
  43.   }
Advertisement
Add Comment
Please, Sign In to add comment