/* This is Free Software under GNU Affero General Public License v >= 3.0
 * without warranty, see README.md and license for details.
 *
 * SPDX-License-Identifier: AGPL-3.0-or-later
 * License-Filename: LICENSES/AGPL-3.0.txt
 *
 * Copyright (C) 2018 by via donau
 *   – Österreichische Wasserstraßen-Gesellschaft mbH
 * Software engineering by Intevation GmbH
 *
 * Author(s):
 * Markus Kottländer <markuks.kottlaender@intevation.de>
 * Thomas Junk <thomas.junk@intevation.de>
 */
import { HTTP } from "@/lib/http";
import { WFS } from "ol/format";
import { displayError } from "@/lib/errors";

// initial state
const init = () => {
  return {
    bottlenecks: [],
    bottlenecksList: [],
    selectedBottleneck: null,
    surveys: [],
    selectedSurvey: null,
    surveysLoading: false
  };
};

export default {
  init,
  namespaced: true,
  state: init(),
  getters: {
    limitingFactorsPerBottleneck: state => {
      if (state.bottlenecks.length === 0) return {};
      return state.bottlenecks.reduce((o, n) => {
        o[n.properties.objnam] = n.properties.limiting;
        return o;
      }, {});
    },
    orderedBottlenecks: state => {
      let groupedBottlenecks = {},
        orderedGroups = {};

      // group bottlenecks by cc
      state.bottlenecksList.forEach(bn => {
        let cc = bn.properties.responsible_country;
        if (groupedBottlenecks.hasOwnProperty(cc)) {
          groupedBottlenecks[cc].push(bn);
        } else {
          groupedBottlenecks[cc] = [bn];
        }
      });

      // order groups by cc
      Object.keys(groupedBottlenecks)
        .sort()
        .forEach(cc => (orderedGroups[cc] = groupedBottlenecks[cc]));

      return orderedGroups;
    }
  },
  mutations: {
    setBottlenecks: (state, bottlenecks) => {
      state.bottlenecks = bottlenecks;
    },
    setBottlenecksList: (state, bottlenecksList) => {
      state.bottlenecksList = bottlenecksList;
    },
    setSelectedBottleneck: (state, name) => {
      state.selectedBottleneck = name;
    },
    setSurveys(state, surveys) {
      state.surveys = surveys;
    },
    setSelectedSurveyByDate(state, date) {
      const survey = state.surveys.filter(x => x.date_info === date)[0];
      state.selectedSurvey = survey;
    },
    setFirstSurveySelected(state) {
      state.selectedSurvey = state.surveys[0];
    },
    selectedSurvey(state, survey) {
      state.selectedSurvey = survey;
    },
    surveysLoading: (state, loading) => {
      state.surveysLoading = loading;
    }
  },
  actions: {
    setSelectedBottleneck({ state, commit, rootState }, name) {
      return new Promise((resolve, reject) => {
        if (name !== state.selectedBottleneck) {
          commit("selectedSurvey", null);
          commit("fairwayprofile/additionalSurvey", null, { root: true });
          commit("fairwayprofile/clearCurrentProfile", null, { root: true });
          commit("map/cutToolEnabled", false, { root: true });
          rootState.map.openLayersMaps.forEach(m => {
            m.getLayer("CUTTOOL")
              .getSource()
              .clear();
          });
        }
        commit("setSelectedBottleneck", name);
        if (name) {
          commit("surveysLoading", true);
          HTTP.get("/surveys/" + name, {
            headers: {
              "X-Gemma-Auth": localStorage.getItem("token"),
              "Content-type": "text/xml; charset=UTF-8"
            }
          })
            .then(response => {
              const surveys = response.data.surveys.sort((a, b) =>
                a.date_info < b.date_info ? 1 : -1
              );
              commit("setSurveys", surveys);
              commit("setFirstSurveySelected");
              resolve(response);
            })
            .catch(error => {
              commit("setSurveys", []);
              commit("selectedSurvey", null);
              const { status, data } = error.response;
              displayError({
                title: "Backend Error",
                message: `${status}: ${data.message || data}`
              });
              reject(error);
            })
            .finally(() => commit("surveysLoading", false));
        } else {
          commit("setSurveys", []);
          resolve();
        }
      });
    },
    loadBottlenecksList({ commit }) {
      return new Promise((resolve, reject) => {
        var bottleneckFeatureCollectionRequest = new WFS().writeGetFeature({
          srsName: "EPSG:4326",
          featureNS: "gemma",
          featurePrefix: "gemma",
          featureTypes: ["bottleneck_overview"],
          outputFormat: "application/json"
        });
        HTTP.post(
          "/internal/wfs",
          new XMLSerializer().serializeToString(
            bottleneckFeatureCollectionRequest
          ),
          {
            headers: {
              "X-Gemma-Auth": localStorage.getItem("token"),
              "Content-type": "text/xml; charset=UTF-8"
            }
          }
        )
          .then(response => {
            commit("setBottlenecksList", response.data.features);
            resolve(response);
          })
          .catch(error => {
            reject(error);
          });
      });
    },
    loadBottlenecks({ commit }) {
      return new Promise((resolve, reject) => {
        var bottleneckFeatureCollectionRequest = new WFS().writeGetFeature({
          srsName: "EPSG:4326",
          featureNS: "gemma",
          featurePrefix: "gemma",
          featureTypes: ["bottlenecks_geoserver"],
          outputFormat: "application/json",
          propertyNames: ["objnam", "limiting", "reference_water_levels"]
        });
        HTTP.post(
          "/internal/wfs",
          new XMLSerializer().serializeToString(
            bottleneckFeatureCollectionRequest
          ),
          {
            headers: {
              "X-Gemma-Auth": localStorage.getItem("token"),
              "Content-type": "text/xml; charset=UTF-8"
            }
          }
        )
          .then(response => {
            commit("setBottlenecks", response.data.features);
            resolve(response);
          })
          .catch(error => {
            reject(error);
          });
      });
    }
  }
};