admin.ts

import * as _ from 'lodash';

// constants
import {
  ADMIN_APPEND_MATERIAL_REQUESTS,
  ADMIN_RECEIVE_MATERIAL_REQUEST,
  ADMIN_RECEIVE_MATERIAL_REQUEST_ACCESSIONS,
  ADMIN_RECEIVE_MATERIAL_REQUESTS,
} from 'requests/constants';

// actions
import navigateTo from 'actions/navigation';

// services
import RequestService from 'service/genesys/RequestService';
import AccessionService from 'service/genesys/AccessionService';

// models
import MaterialRequest from 'model/request/MaterialRequest';
import FilteredPage, { IPageRequest } from 'model/FilteredPage';
import Page from 'model/Page';
import MaterialRequestFilter from 'model/request/MaterialRequestFilter';
import Accession from 'model/accession/Accession';


const receiveRequests = (paged: FilteredPage<MaterialRequest>, error = null) => ({
  type: ADMIN_RECEIVE_MATERIAL_REQUESTS,
  payload: { paged, error },
});

const appendRequests = (paged: FilteredPage<MaterialRequest>, error = null) => ({
  type: ADMIN_APPEND_MATERIAL_REQUESTS,
  payload: { paged, error },
});

const receiveRequest = (request: MaterialRequest, error = null) => ({
  type: ADMIN_RECEIVE_MATERIAL_REQUEST,
  payload: { request, error },
});

const receiveRequestAccessions = (accessions: Accession[]) => ({
  type: ADMIN_RECEIVE_MATERIAL_REQUEST_ACCESSIONS,
  payload: {accessions},
});


const refreshRequestPID = (request: MaterialRequest) => (dispatch, getState) => {
  const page = getState().requests.admin.paged;
  if (page) {
    const toUpdateIndex = _.findIndex(page.content, (contentItem) => contentItem.uuid === request.uuid);

    if (toUpdateIndex !== -1) {
      page.content[toUpdateIndex].body.pid = request.body.pid;
    }

    return dispatch(receiveRequests(page));
  }
};

export const loadMoreRequests = (paged?: FilteredPage<MaterialRequest>) => (dispatch) => {
  return RequestService.list(paged && paged.filterCode, Page.nextPage(paged))
    .then((page) => {
      if (page.number === 0) {
        dispatch(receiveRequests(page));
      } else {
        dispatch(appendRequests(page));
      }
      dispatch(updateRoute(paged));
    })
    .catch((error) => {
      dispatch(receiveRequests(null, error));
    });
};

export const loadMaterialRequest = (uuid: string) => (dispatch) => {
  return RequestService.getRequest(uuid)
    .then((request) => {
      dispatch(loadRequestAccessions(request));
      dispatch(receiveRequest(request));
    })
    .catch((error) => {
      dispatch(receiveRequest(null, error));
    });
};

export const recheckPidAction = (uuid: string) => (dispatch) => {
  return RequestService.recheckPid(uuid)
    .then((request) => {
      dispatch(loadRequestAccessions(request));
      dispatch(receiveRequest(request));
      dispatch(refreshRequestPID(request));
    })
    .catch((error) => {
      dispatch(receiveRequest(null, error));
    });
};


export const validateRequestAction = (uuid: string) => (dispatch) => {
  return RequestService.validateRequest(uuid)
    .then((request) => {
      dispatch(loadRequestAccessions(request));
      dispatch(receiveRequest(request));
    })
    .catch((error) => {
      dispatch(receiveRequest(null, error));
    });
};

export const sendValidationEmailAction = (uuid: string) => (dispatch) => {
  return RequestService.sendValidationEmail(uuid)
    .then((request) => {
      dispatch(loadRequestAccessions(request));
      dispatch(receiveRequest(request));
    })
    .catch((error) => {
      dispatch(receiveRequest(null, error));
    });
};

const loadRequestAccessions = (request: MaterialRequest) => (dispatch) => {
  return AccessionService.uuidFromIds(request.body.accessionIds)
    .then((uuids) => AccessionService.listAllByUuid(uuids)
      .then((accessions) => dispatch(receiveRequestAccessions(accessions))));
};

export const applyFilters = (filters: string | MaterialRequestFilter, page: IPageRequest = { page: 0 }) => (dispatch) => {
  return RequestService.list(filters, page)
    .then((paged) => {
      if (paged.number === 0) {
        dispatch(receiveRequests(paged));
      } else {
        dispatch(appendRequests(paged));
      }
      dispatch(updateRoute(paged));
    }).catch((error) => {
      console.log(`API error`, error);
      dispatch(receiveRequests(null, error));
    });
};

export const updateRoute = (paged: FilteredPage<MaterialRequest>) => (dispatch) => {
  const qs = {
    s: paged.sort[0].property === MaterialRequest.DEFAULT_SORT.property ? undefined : paged.sort[0].property,
    d: paged.sort[0].direction === MaterialRequest.DEFAULT_SORT.direction ? undefined : paged.sort[0].direction,
  };
  dispatch(navigateTo(paged.filterCode ? `/admin/requests/${paged.filterCode}` : '/admin/requests', qs));
};