import { Register } from '@steedos/metadata-registrar';

import _ = require('lodash')

export class LookupActionHandler {
    broker: any = null;
    constructor(broker) {
        this.broker = broker;
    }

    async add(objectConfig) {
        try {
            await this.addObjectLookups(objectConfig);
            return true
        } catch (error) {
            this.broker.logger.error(error);
        }
        return false
    }

    async deleteAll(objectConfig){
        try {
            if (!objectConfig) {
                return;
            }
            await this.deleteAllLookups(objectConfig);
            return true
        } catch (error) {
            this.broker.logger.error(error);
        }
        return false
    }

    async deleteAllLookups(objectConfig){
        const { name: objectApiName } = objectConfig;
        for await (const fieldName of _.keys(objectConfig.fields)) {
            const field = objectConfig.fields[fieldName];
            field.name = fieldName;
            if (field.type === "lookup") {
                try {
                    if (field.reference_to && _.isString(field.reference_to)) {
                        await this.removeDetail(field.reference_to, objectApiName, field);
                    }
                }
                catch (ex) {
                    console.error(ex);
                }
            }
        }
    }

    async addObjectLookups(objectConfig) {
        const { name: objectApiName } = objectConfig;
        // await this.deleteObjectLookups(objectApiName);
        for await (const fieldName of _.keys(objectConfig.fields)) {
            const field = objectConfig.fields[fieldName];
            field.name = fieldName;
            if (field.type === "lookup") {
                try {
                    if (field.reference_to && _.isString(field.reference_to)) {
                        await this.addDetail(field.reference_to, objectApiName, field);
                    }
                }
                catch (ex) {
                    console.error(ex);
                }
            }
        }
    }

    getDetailKey(objectApiName, detailApiName) {
        return `$steedos.$lookup.#${objectApiName}.$detail.${detailApiName}`
    }

    async getDetails(objectApiName: string) {
        let detailName = [];
        const detailsInfo = await this.getDetailsInfo(objectApiName);
        _.each(detailsInfo, function(item){
            if(item && _.isString(item)){
                const foo = item.split('.');
                if(foo.length > 0){
                    detailName.push(foo[0]);
                }
            }
        })
        return _.uniq(detailName);
    }

    getDetailsInfoKey(objectApiName: string) {
        return this.getDetailKey(objectApiName, "*");
    }


    async getDetailsInfo(objectApiName: string){
        const detailsInfo = [];
        // let records = (await this.broker.call('metadata.filter', { key: this.getDetailKey(objectApiName, "*") }, { meta: {} })) || {};
        let records: any = (await Register.filter(this.broker, this.getDetailKey(objectApiName, "*"))) || {};
        for await (const item of records) {
            const metadata = item?.metadata;
            if(metadata){
                detailsInfo.push(metadata.key);
            }
        }
        return detailsInfo;
    }

    async removeDetail(objectApiName: any, detailObjectApiName: string, detailField: any) {
        const detailFullName = `${detailObjectApiName}.${detailField.name}`
        // await this.broker.call('metadata.delete', { key: this.getDetailKey(objectApiName, detailFullName) }, { meta: {} });
        await Register.delete(this.broker, this.getDetailKey(objectApiName, detailFullName));
        return true;
    }

    async addDetail(objectApiName: any, detailObjectApiName: string, detailField: any) {
        const detailFullName = `${detailObjectApiName}.${detailField.name}`
        // await this.broker.call('metadata.add', { key: this.getDetailKey(objectApiName, detailFullName), data: {type: 'detail', objectName: objectApiName, key: detailFullName} }, { meta: {} })
        await Register.add(this.broker, { key: this.getDetailKey(objectApiName, detailFullName), data: {type: 'detail', objectName: objectApiName, key: detailFullName} }, {});
        this.broker.broadcast(`@${objectApiName}.detailsChanged`, { objectApiName, detailObjectApiName, detailFieldName: detailField.name, detailFieldReferenceToFieldName: detailField.reference_to_field });
        return true;
    }

    // async removeDetail(objectApiName: any, detailObjectApiName: string) {
    //     let detail = await this.getDetails(objectApiName);
    //     let index = detail.indexOf(detailObjectApiName);
    //     if (index >= 0) {
    //         detail.splice(index, 1);
    //     }
    //     await this.broker.call('metadata.add', { key: this.getDetailKey(objectApiName), data: detail }, { meta: {} })
    // }

    async deleteObjectLookups(objectApiName: string) {
        await Register.fuzzyDelete(this.broker, this.getDetailKey(objectApiName, '*'));
        // await this.broker.call('metadata.fuzzyDelete', { key: this.getDetailKey(objectApiName, '*') }, { meta: {} });
        return true;
    }
}