import axios from '@/axios-client.js'; import router from '../../router'; import { objIsEmpty, findXformValue, activateFieldsNforceValues } from'@/utils'; const feature = { namespaced: true, state: { attachmentFormset: [], attachmentsToDelete: [], checkedFeatures: [], clickedFeatures: [], extra_forms: [], features: [], features_count: 0, currentFeature: null, form: null, linkedFormset: [], //* used to edit in feature_edit linked_features: [], //* used to display in feature_detail massMode: 'edit-status', }, mutations: { SET_FEATURES(state, features) { state.features = features.sort((a, b) => { return new Date(b.created_on) - new Date(a.created_on); // sort features chronologically }); }, SET_FEATURES_COUNT(state, features_count) { state.features_count = features_count; }, SET_CURRENT_FEATURE(state, feature) { state.currentFeature = feature; }, UPDATE_FORM(state, payload) { state.form = payload; }, INIT_FORM(state) { state.form = { title: state.currentFeature.properties.title, description: { value: state.currentFeature.properties.description }, status: { value: state.currentFeature.properties.status }, }; }, UPDATE_FORM_FIELD(state, field) { if (state.form[field.name].value !== undefined) { state.form[field.name].value = field.value; } else { state.form[field.name] = field.value; } }, UPDATE_EXTRA_FORM(state, extra_form) { const updatedExtraForms = state.extra_forms.map((field) => field.name === extra_form.name ? extra_form : field); state.extra_forms = activateFieldsNforceValues(updatedExtraForms); }, SET_EXTRA_FORMS(state, extra_forms) { state.extra_forms = extra_forms; }, CLEAR_EXTRA_FORM(state) { state.extra_forms = []; }, ADD_ATTACHMENT_FORM(state, attachmentFormset) { state.attachmentFormset = [...state.attachmentFormset, attachmentFormset]; }, UPDATE_ATTACHMENT_FORM(state, payload) { const index = state.attachmentFormset.findIndex((el) => el.dataKey === payload.dataKey); if (index !== -1) { state.attachmentFormset[index] = payload; } }, REMOVE_ATTACHMENT_FORM(state, payload) { state.attachmentFormset = state.attachmentFormset.filter(form => form.dataKey !== payload); }, CLEAR_ATTACHMENT_FORM(state) { state.attachmentFormset = []; }, ADD_LINKED_FORM(state, linkedFormset) { state.linkedFormset = [...state.linkedFormset, linkedFormset]; }, UPDATE_LINKED_FORM(state, payload) { const index = state.linkedFormset.findIndex((el) => el.dataKey === payload.dataKey); if (index !== -1) { state.linkedFormset[index] = payload; } }, REMOVE_LINKED_FORM(state, payload) { state.linkedFormset = state.linkedFormset.filter(form => form.dataKey !== payload); }, SET_LINKED_FEATURES(state, payload) { state.linked_features = payload; }, CLEAR_LINKED_FORM(state) { state.linkedFormset = []; }, ADD_ATTACHMENT_TO_DELETE(state, attachementId) { state.attachmentsToDelete.push(attachementId); }, REMOVE_ATTACHMENTS_ID_TO_DELETE(state, attachementId) { state.attachmentsToDelete = state.attachmentsToDelete.filter(el => el !== attachementId); }, UPDATE_CHECKED_FEATURES(state, checkedFeatures) { state.checkedFeatures = checkedFeatures; }, UPDATE_CLICKED_FEATURES(state, clickedFeatures) { state.clickedFeatures = clickedFeatures; }, TOGGLE_MASS_MODE(state, payload) { state.massMode = payload; }, }, actions: { async GET_PROJECT_FEATURES({ commit, dispatch, rootState }, { project_slug, feature_type__slug, ordering, search, limit, geojson = false }) { dispatch('CANCEL_CURRENT_SEARCH_REQUEST', null, { root: true }); const cancelToken = axios.CancelToken.source(); commit('SET_CANCELLABLE_SEARCH_REQUEST', cancelToken, { root: true }); commit('SET_FEATURES', []); commit('SET_FEATURES_COUNT', 0); let url = `${rootState.configuration.VUE_APP_DJANGO_API_BASE}v2/features/?project__slug=${project_slug}`; if (feature_type__slug) { url = url.concat('', `${url.includes('?') ? '&' : '?'}feature_type__slug=${feature_type__slug}`); } if (ordering) { url = url.concat('', `${url.includes('?') ? '&' : '?'}ordering=${ordering}`); } if (search) { url = url.concat('', `${url.includes('?') ? '&' : '?'}title__icontains=${search}`); } if (limit) { url = url.concat('', `${url.includes('?') ? '&' : '?'}limit=${limit}`); } if (geojson) { url = url.concat('', '&output=geojson'); } try { const response = await axios.get(url, { cancelToken: cancelToken.token }); if (response.status === 200 && response.data) { const features = response.data.features; commit('SET_FEATURES', features); const features_count = response.data.count; commit('SET_FEATURES_COUNT', features_count); } return response; } catch (error) { if (error.message) { console.error(error); } throw error; // 'throw' instead of 'return', in order to pass inside the 'catch' error instead of 'then', to avoid initiating map in another component after navigation } }, GET_PROJECT_FEATURE({ commit, dispatch, rootState }, { project_slug, feature_id }) { dispatch('CANCEL_CURRENT_SEARCH_REQUEST', null, { root: true }); const cancelToken = axios.CancelToken.source(); commit('SET_CANCELLABLE_SEARCH_REQUEST', cancelToken, { root: true }); const url = `${rootState.configuration.VUE_APP_DJANGO_API_BASE}v2/features/${feature_id}/?project__slug=${project_slug}`; return axios .get(url, { cancelToken: cancelToken.token }) .then((response) => { if (response.status === 200 && response.data) { commit('SET_CURRENT_FEATURE', response.data); } return response; }) .catch((error) => { console.error('Error while getting feature for id = ', feature_id, error); throw error; }); }, SEND_FEATURE({ state, rootState, commit, dispatch }, { routeName, query, extraForms }) { function redirect(featureName, response) { // when modifying more than 2 features, exit this function (to avoid conflict with next feature call to GET_PROJECT_FEATURE) if (routeName === 'editer-attribut-signalement') return response; let newQuery = { ...query }; // create a copy of query from the route to avoid redundant navigation error since the router object would be modified commit( 'DISPLAY_MESSAGE', { comment: routeName === 'ajouter-signalement' ? 'Le signalement a été crée' : `Le signalement ${featureName} a été mis à jour`, level: 'positive' }, { root: true }, ); const slug_type_signal = rootState['feature-type'].current_feature_type_slug; const project = rootState.projects.project; if (routeName === 'ajouter-signalement' && !query.ordering) { newQuery = { ordering: project.feature_browsing_default_sort, offset: 0,// if feature was just created, in both ordering it would be the first in project features list }; if (project.feature_browsing_default_filter === 'feature_type_slug') { newQuery['feature_type_slug'] = slug_type_signal; } } if (query && query.ordering === '-updated_on') { // if the list is ordered by update time newQuery.offset = 0;// it would be in first position (else, if ordered by creation, the position won't change anyway) } // in fast edition avoid redundant navigation if query didn't change if (routeName === 'details-signalement-filtre' && parseInt(query.offset) === parseInt(newQuery.offset)) { return 'reloadPage'; } if (!objIsEmpty(newQuery)) { router.push({ name: 'details-signalement-filtre', params: { slug_type_signal }, query: newQuery, }); } else { router.push({ name: 'details-signalement', params: { slug_type_signal }, }); } return response; } async function handleOtherForms(featureId, featureName, response) { await dispatch('SEND_ATTACHMENTS', featureId); await dispatch('PUT_LINKED_FEATURES', featureId); return redirect(featureName, response); } function createGeojson() { //* prepare feature data to send const extraFormObject = {}; //* prepare an object to be flatten in properties of geojson // use extraForms from argument if defined, overiding data from the store, in order to not use mutation (in case of multiple features) for (const field of extraForms || state.extra_forms) { // send extra form only if there is a value defined or if no value, if there was a value before, in order to avoid sending empty value when user didn't touch the extraform if (field.value !== null || (state.currentFeature.properties && state.currentFeature.properties[field.name])) { extraFormObject[field.name] = field.value; } } return { id: state.form.feature_id || state.currentFeature.id, type: 'Feature', geometry: state.form.geometry || state.form.geom || state.currentFeature.geometry || state.currentFeature.properties.geom, properties: { title: state.form.title, description: state.form.description.value, status: state.form.status.value.value || state.form.status.value, project: rootState.projects.project.slug, feature_type: rootState['feature-type'].current_feature_type_slug, ...extraFormObject } }; } const geojson = createGeojson(); let url = `${rootState.configuration.VUE_APP_DJANGO_API_BASE}v2/features/`; if (routeName !== 'ajouter-signalement') { url += `${geojson.id}/? feature_type__slug=${rootState['feature-type'].current_feature_type_slug} &project__slug=${rootState.projects.project.slug}`; } //* postOrPutFeature function from service featureAPI could be used here, but because configuration is in store, //* projectBase would need to be sent with each function which imply to modify all function from this service, //* which could create regression return axios({ url, method: routeName === 'ajouter-signalement' ? 'POST' : 'PUT', data: geojson }).then((response) => { if ((response.status === 200 || response.status === 201) && response.data) { const featureId = response.data.id; const featureName = response.data.properties.title; if (state.attachmentFormset.length > 0 || state.linkedFormset.length > 0 || state.attachmentsToDelete.length > 0) { return handleOtherForms(featureId, featureName, response); } else { return redirect(featureName, response); } } }) .catch((error) => { if (error.message === 'Network Error' || !rootState.isOnline) { let arraysOffline = []; const localStorageArray = localStorage.getItem('geocontrib_offline'); if (localStorageArray) { arraysOffline = JSON.parse(localStorageArray); } const updateMsg = { project: rootState.projects.project.slug, type: routeName === 'ajouter-signalement' ? 'post' : 'put', featureId: geojson.id, geojson: geojson }; arraysOffline.push(updateMsg); localStorage.setItem('geocontrib_offline', JSON.stringify(arraysOffline)); router.push({ name: 'offline-signalement', params: { slug_type_signal: rootState['feature-type'].current_feature_type_slug }, }); } else { console.error('Error while sending feature', error); throw error; } throw error; }); }, async SEND_ATTACHMENTS({ state, rootState, dispatch }, featureId) { const DJANGO_API_BASE = rootState.configuration.VUE_APP_DJANGO_API_BASE; function addFile(attachment, attchmtId) { const formdata = new FormData(); formdata.append('file', attachment.fileToImport, attachment.fileToImport.name); return axios .put(`${DJANGO_API_BASE}features/${featureId}/attachments/${attchmtId}/upload-file/`, formdata) .then((response) => { return response; }) .catch((error) => { console.error(error); return error; }); } function putOrPostAttachement(attachment) { const formdata = new FormData(); formdata.append('title', attachment.title); formdata.append('info', attachment.info); let url = `${DJANGO_API_BASE}features/${featureId}/attachments/`; if (attachment.id) { url += `${attachment.id}/`; } return axios({ url, method: attachment.id ? 'PUT' : 'POST', data: formdata }).then((response) => { if (response && (response.status === 200 || response.status === 201) && attachment.fileToImport) { return addFile(attachment, response.data.id); } return response; }) .catch((error) => { console.error(error); return error; }); } function deleteAttachement(attachmentsId, featureId) { const payload = { attachmentsId: attachmentsId, featureId: featureId }; return dispatch('DELETE_ATTACHMENTS', payload) .then((response) => response); } const promisesResult = await Promise.all([ ...state.attachmentFormset.map((attachment) => putOrPostAttachement(attachment)), ...state.attachmentsToDelete.map((attachmentsId) => deleteAttachement(attachmentsId, featureId)) ] ); state.attachmentsToDelete = []; return promisesResult; }, DELETE_ATTACHMENTS({ commit }, payload) { const url = `${this.state.configuration.VUE_APP_DJANGO_API_BASE}features/${payload.featureId}/attachments/${payload.attachmentsId}/`; return axios .delete(url) .then((response) => { if (response && response.status === 204) { commit('REMOVE_ATTACHMENTS_ID_TO_DELETE', payload.attachmentsId); return response; } }) .catch((error) => { console.error(error); return error; }); }, PUT_LINKED_FEATURES({ state, rootState }, featureId) { return axios .put(`${rootState.configuration.VUE_APP_DJANGO_API_BASE}features/${featureId}/feature-links/`, state.linkedFormset) .then((response) => { if (response.status === 200 && response.data) { return 'La relation a bien été ajouté'; } }) .catch((error) => { throw error; }); }, DELETE_FEATURE({ rootState }, payload) { const { feature_id, noFeatureType } = payload; let url = `${rootState.configuration.VUE_APP_DJANGO_API_BASE}v2/features/${feature_id}/?` + `project__slug=${rootState.projects.project.slug}`; if (!noFeatureType) { url +=`&feature_type__slug=${rootState['feature-type'].current_feature_type_slug}`; } return axios .delete(url) .then((response) => response) .catch(() => { return false; }); }, INIT_EXTRA_FORMS({ state, rootGetters, commit }) { const feature = state.currentFeature; const featureType = rootGetters['feature-type/feature_type']; const customFields = featureType.customfield_set; if (customFields) { //* retrieve 'name', 'options', 'position' from current feature_type data to display in the form commit('SET_EXTRA_FORMS', activateFieldsNforceValues( customFields.map((field) => { //* add value field to extra forms from feature_type and existing values if feature is defined field.value = feature.properties ? feature.properties[field.name] : findXformValue(feature, field); //* if a boolean has a null value, set it to false to allow comparison with false later on (for instance with forced value) if (field.field_type === 'boolean' && field.value === null) field.value = false; return field; }) ).sort((a, b) => a.position - b.position) //* order according to user defined position ); } }, }, }; export default feature;