import * as io from 'socket.io-client';
import { Observable } from 'rxjs';

export class ChatService {
    private url = 'http://localhost';
    private socket;    

    constructor() {
        this.socket = io(this.url);
    }
    public sendMessage(message) {
        this.socket.emit('new-message', message);
    }
    public getMessages = () => {
        return Observable.create((observer) => {
            this.socket.on('new-message', (message) => {
                observer.next(message);
            });
            this.socket.on('PeerEntry', (message) => {
                observer.next(message);
            });
            this.socket.on('PeerStatus', (message) => {
                observer.next(message);
            });
            this.socket.on('DialBegin', (message) => {
                observer.next(message);
            });
            this.socket.on('disconnect', (message) => {
                // observer.next(message);
                console.log("Socket Disconnected");
            });
            this.socket.on('reconnecting', (attemptNumber) => {
                // ...
                console.log("Trying to reconnect ! "+attemptNumber+" times");
              });
        });
    }
}