src/app/services/websockets/websocket.global.ts

/// <reference path="../../../../typings/index.d.ts"/>

import {Injectable} from '@angular/core';
import {BehaviorSubject} from 'rxjs/Rx';
import * as io from 'socket.io-client';
import {AppConfig} from '../../config/app.config';
import {IWSEvent} from '../../interfaces/ws.interface';

@Injectable()
export class GlobalEvent {
  private _events: BehaviorSubject<IWSEvent> = new BehaviorSubject<IWSEvent>({
    model: 'XOS',
    msg: {
      changed_fields: []
    }
  });
  private socket;
  constructor() {
    this.socket = io(AppConfig.websocketClient);
    this.socket.on('event', (data: IWSEvent) => {
      this._events.next(data);
    });
  }

  list() {
    return this._events.asObservable();
  }

}