/**
 * Copyright 2016-2018 Ahoo Studio.co.th.
 * Maintained by nattapon.r@live.com
 */

import { StalkJS, ServerImp, ServerParam, IDictionary, IPomelo, IServer } from "../stalkjs";
import { DataListener } from "./DataListener";
import { PushDataListener } from "./PushDataListener";
import { ServerEventListener } from "./ServerEventListener";

export interface IStalkConfig {
    apiKey: string;
    apiVersion: string;
    appId: string;
    chat: string;
    port: number;
}

export interface IApiConfig {
    apiKey: string;
    host: string;
    api: string;
    auth: string;
    user: string;
    team: string;
    group: string;
    orgChart: string;
    chatroom: string;
    message: string;
    fileUpload: string;
}

export class BackendFactory {
    private static instance: BackendFactory;
    public static getInstance(): BackendFactory {
        return BackendFactory.instance;
    }
    public static createInstance(stalkConfig: IStalkConfig, apiConfig: IApiConfig): BackendFactory {
        if (!BackendFactory.instance) {
            BackendFactory.instance = new BackendFactory(stalkConfig, apiConfig);
        }

        return BackendFactory.instance;
    }

    config: IStalkConfig;
    private apiConfig: IApiConfig;
    public getApiConfig() {
        return this.apiConfig;
    }

    stalk: ServerImp;
    serverEventsListener: ServerEventListener;
    pushDataListener: PushDataListener;
    dataListener: DataListener;

    constructor(config: IStalkConfig, apiConfig: IApiConfig) {
        this.config = config;
        this.apiConfig = apiConfig;

        this.stalk = undefined as any;
        this.serverEventsListener = undefined as any;
        this.pushDataListener = new PushDataListener();
        this.dataListener = new DataListener();
    }

    getServer() {
        if (this.stalk._isConnected) {
            return this.stalk;
        }
        else {
            console.log("Stalk connection not yet ready.");
            return null;
        }
    }

    async stalkInit() {
        this.stalk = StalkJS.create(this.config.chat, this.config.port);
        let socket = await StalkJS.init(this.stalk);
        return socket;
    }

    async handshake(uid: string) {
        try {
            // @ get connector server.
            let msg = {} as IDictionary;
            msg["uid"] = uid;
            msg["x-api-key"] = this.config.apiKey;
            msg["x-api-version"] = this.config.apiVersion;
            msg["x-app-id"] = this.config.appId;
            let connector = await StalkJS.geteEnter(this.stalk, msg);

            let params = { host: connector.host, port: connector.port, reconnect: false } as ServerParam;
            await StalkJS.handshake(this.stalk, params);

            return await connector;
        } catch (ex) {
            throw new Error("handshake fail: " + ex.message);
        }
    }

    async checkIn(user: any) {
        let msg = {} as IDictionary;
        msg["user"] = user;
        msg["x-api-key"] = this.config.apiKey;
        msg["x-api-version"] = this.config.apiVersion;
        msg["x-app-id"] = this.config.appId;
        let result = await StalkJS.checkIn(this.stalk, msg);
        return result;
    }

    private async checkOut() {
        await StalkJS.checkOut(this.stalk);
    }

    /**
     * @returns
     *
     * @memberof BackendFactory
     */
    logout() {
        let self = this;
        self.checkOut();
        if (!!self.pushDataListener) { delete self.pushDataListener; }
        if (!!self.dataListener) { delete self.dataListener; }

        delete BackendFactory.instance;

        return Promise.resolve();
    }

    getServerListener() {
        if (!this.serverEventsListener) {
            this.serverEventsListener = new ServerEventListener(this.stalk.getSocket());
        }

        return this.serverEventsListener;
    }

    subscriptions() {
        this.serverEventsListener.addServerListener(this.dataListener);
        this.serverEventsListener.addChatListener(this.dataListener);
        this.serverEventsListener.addPushListener(this.pushDataListener);
    }
}