import { IObservable, IDestroyable, ICancellation } from "../../interfaces";
import { TraceEvent, LogLevel, WarnLevel, DebugLevel } from "../TraceSource";
import { Cancellation } from "../../Cancellation";
import { destroy, argumentNotNull } from "../../safe";
import { ConsoleWriter } from "../ConsoleWriter";

export class ConsoleLogger implements IDestroyable {
    private readonly _subscriptions = new Array<IDestroyable>();
    private readonly _writer: ConsoleWriter;

    constructor(writer = ConsoleWriter.default) {
        argumentNotNull(writer, "writer");
        this._writer = writer;
    }

    writeEvents(source: IObservable<TraceEvent>, ct: ICancellation = Cancellation.none) {
        const subscription = source.on(this.writeEvent.bind(this));
        if (ct.isSupported()) {
            ct.register(subscription.destroy.bind(subscription));
        }
        this._subscriptions.push(subscription);
    }

    writeEvent(next: TraceEvent) {
        if (next.level >= DebugLevel) {
            this._writer.setLogLevel("debug");
        } else if (next.level >= LogLevel) {
            this._writer.setLogLevel("log");
        } else if (next.level >= WarnLevel) {
            this._writer.setLogLevel("warn");
        } else {
            this._writer.setLogLevel("error");
        }
        this._writer.write("{0}: ", next.source.id);

        if (next.args)
            this._writer.writeLine(next.message, ...next.args);
        else
        this._writer.writeLine(next.message);
    }

    destroy() {
        this._subscriptions.forEach(destroy);
    }
}