/* eslint-disable func-names */
import fetch from 'isomorphic-fetch';
import _ from 'lodash';

import { getTerms, getTermId } from './utils';


export const REQUEST_ANNOTATIONS = 'REQUEST_ANNOTATIONS';
export function requestAnnotations(url) {
  return {
    type: REQUEST_ANNOTATIONS,
    url,
  };
}

export const RECEIVE_ANNOTATIONS = 'RECEIVE_ANNOTATIONS';
export function receiveAnnotations(url, annotations, terms) {
  return {
    type: RECEIVE_ANNOTATIONS,
    url,
    annotations,
    terms,
    receivedAt: Date.now(),
  };
}

export const RECEIVE_MESSAGES_COUNT = 'RECEIVE_MESSAGES_COUNT';
export function receiveMessagesCount(url, terms, terms64, messagesCount) {
  return {
    type: RECEIVE_MESSAGES_COUNT,
    terms,
    terms64,
    messagesCount,
  };
}

export const REQUEST_MESSAGES_COUNT = 'REQUEST_MESSAGES_COUNT';
export function requestMessagesCount(url, terms, terms64) {
  return {
    type: REQUEST_MESSAGES_COUNT,
    url,
    terms,
    terms64,
  };
}

export const FETCH_MESSAGES_COUNT = 'FETCH_MESSAGES_COUNT';
export function fetchMessagesCount(terms, discussionUrl, dashboardId) {
  const url = `${discussionUrl}count`;
  const terms64 = _.map(terms, term => getTermId(term, dashboardId));

  return function (dispatch) {
    dispatch(requestMessagesCount(url, terms, terms64));

    if (!discussionUrl) {
      return dispatch(receiveMessagesCount(url, terms, terms64, {}));
    }

    return fetch(url, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      body: JSON.stringify(terms64),
    })
      .then(
        response => response.json(),
        error => console.log('An error occured.', error), // eslint-disable-line no-console
      )
      .then(
        json => dispatch(receiveMessagesCount(url, terms, terms64, json)),
      );
  };
}

export const FETCH_ANNOTATIONS = 'FETCH_ANNOTATIONS';
export function fetchAnnotations(url, discussionUrl, dashboardId) {
  return function (dispatch) {
    dispatch(requestAnnotations(url));

    return fetch(url)
      .then(
        response => response.json(),
        error => console.log('An error occured.', error), // eslint-disable-line no-console
      )
      .then((json) => {
        const annotations = json.rows;
        const terms = getTerms(annotations);

        dispatch(fetchMessagesCount(Object.keys(terms), discussionUrl, dashboardId));
        dispatch(receiveAnnotations(url, annotations, terms));
      });
  };
}