import { ILogItem } from './log-item';
import { AppState } from '../..';
import { LogDataSource } from './log-datasource';
import { Topics, MessageBusHandle } from '@csnext/cs-core';

export class LogManager {
    public items: ILogItem[] = [];
    public source: LogDataSource | undefined;

    private logHandle?: MessageBusHandle;

    public init(sourceId: string, state: AppState): Promise<ILogItem[]> {
        return new Promise((resolve, reject) => {
            state.loadDatasource<LogDataSource>(sourceId)
                .then(r => {
                    this.source = r;
                    this.items = this.items.concat(r.items);
                    this.logHandle = r.bus.subscribe(Topics.LOG_TOPIC, (a: string, logItem: ILogItem) => {
                        if (a === Topics.LOG_ITEM_ADDED) {
                            this.items.push(logItem);
                        }
                    });
                    resolve(this.items);
                })
                .catch(e => {
                    reject();                   
                });
        });
    }
}