formulaire.service.ts

import {map} from "rxjs/operators";
import { Injectable } from "@angular/core";
import { Response } from "@angular/http";
import { Observable as rxObservable } from "rxjs";
import "rxjs/add/operator/toPromise";
import { decode } from "he";
import { saveAs } from "file-saver";

import { CalculatorType, EnumEx, Observable, ParamDefinition, ParamValueMode } from "jalhyd";

import { ServiceFactory } from "../service-factory";
import { HttpService } from "../../services/http/http.service";
import { InternationalisationService } from "../../services/internationalisation/internationalisation.service";
import { FormulaireDefinition } from "../../formulaire/definition/form-definition";
import { FormulaireElement } from "../../formulaire/formulaire-element";
import { InputField } from "../../formulaire/input-field";
import { SelectField } from "../../formulaire/select-field";
import { CheckField } from "../../formulaire/check-field";
import { StringMap } from "../../stringmap";
import { FormulaireConduiteDistributrice } from "../../formulaire/definition/concrete/form-cond-distri";
import { FormulaireLechaptCalmon } from "../../formulaire/definition/concrete/form-lechapt-calmon";
import { FormulaireSectionParametree } from "../../formulaire/definition/concrete/form-section-parametree";
import { FormulaireCourbeRemous } from "../../formulaire/definition/concrete/form-courbe-remous";
import { FormulaireRegimeUniforme } from "../../formulaire/definition/concrete/form-regime-uniforme";
import { FormulairePasseBassinDimensions } from "../../formulaire/definition/concrete/form-passe-bassin-dim";
import { FormulairePasseBassinPuissance } from "../../formulaire/definition/concrete/form-passe-bassin-puissance";
import { FormulaireParallelStructure } from "../../formulaire/definition/concrete/form-parallel-structures";
import { NgParameter } from "../../formulaire/ngparam";

@Injectable()
export class FormulaireService extends Observable {
    private _formulaires: FormulaireDefinition[];

    private _currentFormId = -1;

    constructor() {
        super();
        this._formulaires = [];
    }

    private get _intlService(): InternationalisationService {
        return ServiceFactory.instance.internationalisationService;
    }

    private get _httpService(): HttpService {
        return ServiceFactory.instance.httpService;
    }

    public get formulaires(): FormulaireDefinition[] {
        return this._formulaires;
    }

    private loadLocalisation(calc: CalculatorType): Promise<any> {
        const f: string = this.getConfigPathPrefix(calc) + this._intlService.currentLanguage.tag + ".json";
        const prom = this._httpService.httpGetRequestPromise(undefined, undefined, undefined, f);

        return prom.then((j) => {
            return j as StringMap;
        });
    }

    /**
     * met à jour la langue du formulaire
     * @param formId id unique du formulaire
     * @param localisation ensemble id-message traduit
     */
    private updateFormulaireLocalisation(formId: number, localisation: StringMap) {
        for (const f of this._formulaires) {
            if (f.uid === formId) {
                f.updateLocalisation(localisation);
                break;
            }
        }
    }

    /**
     * charge la localisation et met à jour la langue du formulaire
     */
    private loadUpdateFormulaireLocalisation(f: FormulaireDefinition): Promise<FormulaireDefinition> {
        return this.loadLocalisation(f.calculatorType)
            .then(localisation => {
                this.updateFormulaireLocalisation(f.uid, localisation);
                return f;
            });
    }

    public updateLocalisation() {
        for (const c of EnumEx.getValues(CalculatorType)) {
            const prom: Promise<StringMap> = this.loadLocalisation(c);
            prom.then(loc => {
                for (const f of this._formulaires) {
                    if (f.calculatorType === c) {
                        this.updateFormulaireLocalisation(f.uid, loc);
                    }
                }
            }
            );
        }
    }

    public getLocalisedTitleFromCalculatorType(type: CalculatorType) {
        const sCalculator: string = CalculatorType[type].toUpperCase();
        return this._intlService.localizeText(`INFO_${sCalculator}_TITRE`);
    }

    public loadConfig(ct: CalculatorType): Promise<any> {
        const f: string = this.getConfigPathPrefix(ct) + "config.json";
        return this._httpService.httpGetRequestPromise(undefined, undefined, undefined, f);
    }

    private newFormulaire(ct: CalculatorType, jsonState?: {}): FormulaireDefinition {
        let f: FormulaireDefinition;
        switch (ct) {
            case CalculatorType.ConduiteDistributrice:
                f = new FormulaireConduiteDistributrice();
                break;

            case CalculatorType.LechaptCalmon:
                f = new FormulaireLechaptCalmon();
                break;

            case CalculatorType.SectionParametree:
                f = new FormulaireSectionParametree();
                break;

            case CalculatorType.RegimeUniforme:
                f = new FormulaireRegimeUniforme();
                break;

            case CalculatorType.CourbeRemous:
                f = new FormulaireCourbeRemous();
                break;

            case CalculatorType.PabDimensions:
                f = new FormulairePasseBassinDimensions();
                break;

            case CalculatorType.PabPuissance:
                f = new FormulairePasseBassinPuissance();
                break;

            case CalculatorType.ParallelStructure:
            case CalculatorType.Dever:
            case CalculatorType.Cloisons:
                f = new FormulaireParallelStructure();
                break;

            default:
                throw new Error(`FormulaireService.newFormulaire() : type de calculette ${CalculatorType[ct]} non pris en charge`);
        }

        f.defaultProperties["calcType"] = ct;

        return f;
    }

    /**
     * crée un formulaire d'un type donné
     * @param ct type de formulaire
     * @param jsonState
     */
    public createFormulaire(ct: CalculatorType, jsonState?: {}): Promise<FormulaireDefinition> {
        const f: FormulaireDefinition = this.newFormulaire(ct);
        this._formulaires.push(f);

        const prom: Promise<any> = this.loadConfig(ct);
        return prom.then(s => {
            f.preparseConfig(JSON.parse(s));
            return f;
        }).then(f => {
            if (jsonState === undefined) {
                f.calculatorName = decode(this.getLocalisedTitleFromCalculatorType(ct) + " (" + f.uid + ")");
            }
            f.initSessionNub();
            return f;
        }).then(f => {
            f.parseConfig(undefined);
            return f;
        }).then(f => {
            if (jsonState !== undefined) {
                f.deserialiseJSON(jsonState);
                const props = jsonState["props"];
            }
            return f;
        }).then(f => {
            // la méthode loadUpdateFormulaireLocalisation retourne une Promise; le fait de retourner une Promise dans un then
            // fait que le then suivant est exécuté juste après.
            return this.loadUpdateFormulaireLocalisation(f);
        }).then(f => {
            f.applyDependencies();
            return f;
        }).then(f => {
            this.notifyObservers(
                {
                    "action": "createForm",
                    "form": f
                });
            return f;
        });
    }

    public getFormulaireFromId(uid: number): FormulaireDefinition {
        for (const f of this._formulaires) {
            if (f.uid === uid) {
                return f;
            }
        }

        return undefined;
    }

    public getInputField(formId: number, elemId: string): InputField {
        const s = this.getFormulaireElementById(formId, elemId);
        if (!(s instanceof InputField)) {
            throw new Error("Form element with id '" + elemId + "' is not an input");
        }
        return <InputField>s;
    }

    public getCheckField(formId: number, elemId: string): CheckField {
        const s = this.getFormulaireElementById(formId, elemId);
        if (!(s instanceof CheckField)) {
            throw new Error("Form element with id '" + elemId + "' is not a checkbox");
        }
        return <CheckField>s;
    }

    public getSelectField(formId: number, elemId: string): SelectField {
        const s = this.getFormulaireElementById(formId, elemId);
        if (!(s instanceof SelectField)) {
            throw new Error("Form element with id '" + elemId + "' is not a select");
        }
        return <SelectField>s;
    }

    private getFormulaireElementById(formId: number, elemId: string): FormulaireElement {
        for (const f of this._formulaires) {
            if (f.uid === formId) {
                const s = f.getFormulaireNodeById(elemId);
                if (s !== undefined) {
                    return s as FormulaireElement;
                }
            }
        }
        return undefined;
    }

    public getParamdefParentForm(prm: ParamDefinition): FormulaireDefinition {
        for (const f of this._formulaires) {
            for (const p of f.allFormElements) {
                if (p instanceof NgParameter) {
                    if (p.paramDefinition.uid === prm.uid) {
                        return f;
                    }
                }
            }
        }
        return undefined;
    }

    public getConfigPathPrefix(ct: CalculatorType): string {
        if (ct === undefined) {
            throw new Error("FormulaireService.getConfigPathPrefix() : invalid undefined CalculatorType");
        }

        switch (ct) {
            case CalculatorType.ConduiteDistributrice:
                return "app/calculators/cond_distri/cond_distri.";

            case CalculatorType.LechaptCalmon:
                return "app/calculators/lechapt-calmon/lechapt-calmon.";

            case CalculatorType.SectionParametree:
                return "app/calculators/section-param/section-param.";

            case CalculatorType.RegimeUniforme:
                return "app/calculators/regime-uniforme/regime-uniforme.";

            case CalculatorType.CourbeRemous:
                return "app/calculators/remous/remous.";

            case CalculatorType.PabDimensions:
                return "app/calculators/pab-dimensions/pab-dimensions.";

            case CalculatorType.PabPuissance:
                return "app/calculators/pab-puissance/pab-puissance.";

            case CalculatorType.Structure:
                return "app/calculators/ouvrages/ouvrages.";

            case CalculatorType.ParallelStructure:
                return "app/calculators/parallel-structures/parallel-structures.";

            case CalculatorType.Dever:
                return "app/calculators/dever/dever.";

            case CalculatorType.Cloisons:
                return "app/calculators/cloisons/cloisons.";

            default:
                throw new Error("FormulaireService.getConfigPathPrefix() : valeur de CalculatorType " + ct + " non implémentée");
        }
    }

    public requestCloseForm(uid: number) {
        const form = this.getFormulaireFromId(uid);
        if (form !== undefined) {
            this._formulaires = this._formulaires.filter(f => f.uid !== uid);

            this.notifyObservers({
                "action": "closeForm",
                "form": form
            });
        }
    }

    public get currentFormId() {
        return this._currentFormId;
    }

    public setCurrentForm(formId: number) {
        const form = this.getFormulaireFromId(formId);
        if (form === undefined) {
            this._currentFormId = -1;
            this.notifyObservers({
                "action": "invalidFormId",
                "formId": formId
            });
        } else {
            this._currentFormId = formId;
            this.notifyObservers({
                "action": "currentFormChanged",
                "formId": formId
            });
        }
    }

    private get currentForm(): FormulaireDefinition {
        return this.getFormulaireFromId(this._currentFormId);
    }

    public get currentFormHasResults(): boolean {
        const form = this.currentForm;
        if (form !== undefined) {
            return form.hasResults;
        }

        return false;
    }

    private readSingleFile(file: File): Promise<any> {
        return new Promise<any>((resolve, reject) => {
            const fr = new FileReader();

            fr.onload = () => {
                resolve(fr.result);
            };

            fr.onerror = () => {
                fr.abort();
                reject(new Error(`Erreur de lecture du fichier ${file.name}`));
            };

            fr.readAsText(file);
        });
    }

    /**
     * charge une session en tenant compte des calculettes sélectionnées
     * @param f fichier session
     * @param formInfos infos sur les calculettes @see LoadCalculatorComponent._calculators
     */
    public loadSession(f: File, formInfos: any[]) {
        this.readSingleFile(f).then(s => {
            const session = JSON.parse(s);
            for (const k in session) {
                switch (k) {
                    case "session":
                        this.deserialiseSession(session[k], formInfos);
                        break;

                    default:
                        throw new Error(`session file : invalid key '${k}'`);
                }
            }
        }).catch(err => {
            throw err;
        });
    }

    public saveSession(session: {}, filename?: string) {
        const blob = new Blob([JSON.stringify(session)], { type: "text/plain;charset=utf-8" });
        saveAs(blob, filename);
    }

    /**
     * obtient des infos (nom, uid des calculettes) d'un fichier session
     * @param f fichier session
     */
    public calculatorInfosFromSessionFile(f: File): Promise<any[]> {
        return this.readSingleFile(f).then(s => {
            const res: any[] = [];
            const session = JSON.parse(s);

            // liste des noms de calculettes
            for (const k in session) {
                switch (k) {
                    case "session":
                        const sess = session[k];
                        const elems = sess["elements"];
                        for (const e of elems) {
                            for (const k in e) {
                                if (k === "form") {
                                    const form = e[k];
                                    res.push({ "uid": form["uid"], "title": form["id"] });
                                }
                            }
                        }
                        break;

                    default:
                        throw new Error(`session file : invalid key '${k}'`);
                }
            }
            return res;
        });
    }

    public saveForm(f: FormulaireDefinition) {
        this.notifyObservers({
            "action": "saveForm",
            "form": f
        });
    }

    private deserialiseForm(elements: {}) {
        const props = elements["props"];
        const ct: CalculatorType = props["calcType"];
        this.createFormulaire(ct, elements);
    }

    private deserialiseSessionElement(element: {}, formInfos: any[]) {
        const keys = Object.keys(element);
        if (keys.length !== 1) {
            throw new Error(`session file : invalid session object '${element}'`);
        }

        switch (keys[0]) {
            case "form":
                const form = element[keys[0]];

                for (const i of formInfos) {
                    if (i["uid"] === form["uid"] && i["selected"]) {
                        this.deserialiseForm(form);
                    }
                }
                break;

            default:
                throw new Error(`session file : invalid key '${keys[0]}' in session object`);
        }
    }

    private deserialiseSession(elements: {}, formInfos: any[]) {
        for (const ks in elements) {
            switch (ks) {
                case "elements":
                    for (const e of elements[ks]) {
                        this.deserialiseSessionElement(e, formInfos);
                    }
                    break;

                default:
                    throw new Error(`session file : invalid key '${ks}' in session object`);
            }
        }
    }

    /**
     * @returns liste des valeurs liables à un paramètre sous la forme d'un tableau d'objets
     * {"param":<paramètre lié>, "nub":<Nub d'origine du paramètre lié>, "formTitle":<nom de la calculette liée au nub>}
     * @param p paramètre qui sert de clé de recherche des paramètres liables
     */
    public getLinkableValues(p: NgParameter): any[] {
        const res: any[] = [];

        if (p !== undefined) {
            for (const f of this._formulaires) {
                // nub associé au formulaire
                const sn = f.currentSessionNub;

                try {
                    // on vérifie que le paramètre en entrée appartient au nub
                    const np = sn.nub.getParameter(p.symbol);

                    // si oui, on demande à exclure des valeurs retournées le résultat du même nom que le paramètre
                    const exclude = np !== undefined ? p.paramDefinition.uid === np.uid : false;

                    // valeurs liables
                    const ps = sn.getLinkableValues(p.paramDefinition, exclude);
                    for (const np of ps) {
                        np["formTitle"] = f.calculatorName;
                        res.push(np);
                    }
                } catch (e) {
                    //  p.symbol n'existe pas dans le nub testé
                }
            }
        }

        return res;
    }

    /**
     * filtre les valeurs liables à un paramètre :
     * - supprime les valeurs non affichées dans leur parent (ce n'est pas le cas par ex pour Q, Z1, Z2 dans les ouvrages enfants des ouvrages //)
     * @param values valeurs liables (modifié par la méthode)
     */
    public filterLinkableValues(values: any[]): any[] {
        // suppression des paramètres non affichés

        for (let i = values.length - 1; i >= 0; i--) {
            const v = values[i].value;
            if (v instanceof ParamDefinition) {
                // pour chaque paramètre...
                const prm: ParamDefinition = v;

                const parentForm: FormulaireDefinition = this.getParamdefParentForm(prm);

                // ... on cherche s'il est affiché dans son parent
                let found = false;
                if (parentForm !== undefined) {
                    for (const fe of parentForm.allFormElements) {
                        if (fe instanceof NgParameter) {
                            if (fe.paramDefinition.uid === prm.uid) {
                                found = true;
                                break;
                            }
                        }
                    }
                }

                if (!found) {
                    values.splice(i, 1);
                }
            }
        }

        return values;
    }
}