import { Injectable } from '@angular/core';
import { BehaviorSubject, Observable } from 'rxjs';

import { GrowlMessage } from './growl-message';

@Injectable({
    providedIn: 'root'
})
export class GrowlBrokerService {
    private _messageAddedSubject: BehaviorSubject<GrowlMessage> =
        new BehaviorSubject<GrowlMessage>(null);

    get messageAddedSubject(): Observable<GrowlMessage> {
        return this._messageAddedSubject.asObservable();
    }

    addMessage(message: GrowlMessage): void {
        this._messageAddedSubject.next(message);
    }

    addWithType(type: string, content: string): void {
        const message = new GrowlMessage();
        message.type = type;
        message.content = content;
        this._messageAddedSubject.next(message);
    }

    addWithTypeAndTimeToDisplayInSeconds(
        type: string,
        content: string,
        timeToDisplayInSeconds: number
    ): void {
        const message = new GrowlMessage();
        message.type = type;
        message.content = content;
        message.timeToDisplayInSeconds = timeToDisplayInSeconds;
        this._messageAddedSubject.next(message);
    }
}