doneit-web/src/app/services/socket/synchro.service.ts

import { Injectable } from '@angular/core';
import { SessionStore } from 'src/app/store/session.service';
import { v4 as uuidv4 } from 'uuid'
import { BackgroundService } from '../background.service';
import { environment } from 'src/environments/environment';

export interface wss{

  url: string,
  type: 'reflect' | 'emit'
  header: {
    id: string
    bluePrint: string,
    jwt: string
  }

}

@Injectable({
  providedIn: 'root'
})
class SynchroService {
	[x: string]: any;

	private connection!: WebSocket;
  private id: string = uuidv4();
  public conected = false
  private url: string = ''
  callback = function(){}
  private _connected = false;
  private BackgroundService = new BackgroundService()
  callBacks: {
    type: 'Offline' | 'Online' | 'Onmessage' | 'Chat' | 'Notification'  | 'Notifications' | '',
    object?: string
    funx: Function
  }[] = []
  private msgQueue = []

	constructor(){}

  get connected() {
    return this._connected
  }

  setUrl() {

    let header ={
      id:'1234',
      bluePrint: '12312123',
      jwt: uuidv4()
    }
    
    let wss: wss ={
      header,
      url: 'wss://synchro-server.herokuapp.com/ws/some_url/',
      type: 'reflect'
    }

    this.url = `${wss.url}${wss.header.id}/${wss.header.jwt}/${wss.header.bluePrint}/${this.id}/`
  }

  registerCallback(type: 'Offline' | 'Online' | 'Onmessage' | 'Chat' | 'Notifications' | 'Notification', funx: Function, object='') {
    this.callBacks.push({
      type,
      funx,
      object
    })
  }

	connect() {

		this.connection  = new WebSocket(this.url);
		// bind function
		this.connection.onopen = this.onopen;
		this.connection.onmessage = this.onmessage;
		this.connection.onclose = this.onclose;
		this.connection.onerror = this.onerror;
	}

	private onopen = () =>{
    
    
    
    if(!this.conected) {
      
      this.BackgroundService.online()
      this.callBacks.forEach((e)=>{
        if(e.type == 'Online') {
          e.funx()
        }
      })
  
    }

    console.log('open ======================= welcome to socket server')
    this._connected = true

    // send all saved data due to internet connection
    this.msgQueue.forEach((item, index, object) => {
      this.$send(item);
      object.splice(index, 1);
    })

	}

  public $send(object: any) {

    if(!this._connected) { // save data to send when back online
      this.msgQueue.push(object)
    }

    let payload =  {
      message: JSON.stringify(object) || '{"person.adress.country":"1Angola"}',
      username: SessionStore.user.FullName,
      idConnection: this.id
    }
    

    let sendData = JSON.stringify(payload);
    console.log(sendData)

    this.connection.send(sendData);
  }

	private onmessage = async (event: any)=> {


    let data = JSON.parse(event.data)
    let payload = JSON.parse(data.message)
    payload.message = JSON.parse(payload.message)
    const idConnection = payload.idConnection
    const username = payload.username

    if(idConnection != this.id ) {
      
      if(window['platform'].is('desktop') || this.platform.is('mobileweb')) {}
      else return false

      // if(environment.production) return false

      this.callBacks.forEach((e)=> {

        if(payload.message[0]) {
          if(payload.message[0].Service && payload.message[0].Object && payload.message[0].IdObject) {
            if(e.type == '' && !e.object) {
              if(username == SessionStore.user.FullName) {
                e.funx(payload.message, data)
              }
            }
            
            if(e.type == 'Notifications' ) {
              e.funx(payload.message, data)
            }
           
          }
        }  else if(payload.message.Service && payload.message.Object && payload.message.IdObject) {
          if(e.type == 'Notification' && e.object == payload.message.Object || e.type == 'Notification' &&  e.object == 'any' ) {
            e.funx(payload.message, data)
          }
        }

      })

    }
    this.callback()
	}

	private onclose=(event:any)=> {
		setTimeout(() => {
			if (event.wasClean) {
				console.log(`[close] Connection closed cleanly, code=${event.code} reason=${event.reason}`);
			} else {
				// e.g. server process killed or network down
				// event.code is usually 1006 in this case
				console.log('[close] Connection died');
        console.log('Reconnect')

        

        if(this._connected) {
          this.BackgroundService.offline();
          this.callBacks.forEach((e)=>{
            if(e.type == 'Offline') {
              e.funx()
            }
          })
        }

        // status
        this._connected = false
        // reconnect
        this.connect()
        
			}
		}, 100);
	}

  private onerror=(event: any)=>{
		console.log(`[error] ${event.message}`);
	}
}


export const synchro = new SynchroService()
synchro.setUrl()
synchro.connect()

window['synchro'] = synchro