// @flow

import {
  FAILURE_SUFFIX,
  PENDING_SUFFIX,
  SUCCESS_SUFFIX
} from "../../modules/types";
import { apiClient } from "@scm-manager/ui-components";
import { isPending } from "../../modules/pending";
import { getFailure } from "../../modules/failure";
import { combineReducers } from "redux";
import type { Action, PagedCollection } from "@scm-manager/ui-types";
import * as types from "../../modules/types";
import { CREATE_USER_RESET } from "../../users/modules/users";

export const FETCH_CHANGESETS = "scm/repos/FETCH_CHANGESETS";
export const FETCH_CHANGESETS_PENDING = `${FETCH_CHANGESETS}_${PENDING_SUFFIX}`;
export const FETCH_CHANGESETS_SUCCESS = `${FETCH_CHANGESETS}_${SUCCESS_SUFFIX}`;
export const FETCH_CHANGESETS_FAILURE = `${FETCH_CHANGESETS}_${FAILURE_SUFFIX}`;

//********added for detailed view of changesets

export const FETCH_CHANGESET = "scm/repos/FETCH_CHANGESET";
export const FETCH_CHANGESET_PENDING = `${FETCH_CHANGESET}_${PENDING_SUFFIX}`;
export const FETCH_CHANGESET_SUCCESS = `${FETCH_CHANGESET}_${SUCCESS_SUFFIX}`;
export const FETCH_CHANGESET_FAILURE = `${FETCH_CHANGESET}_${FAILURE_SUFFIX}`;
export const FETCH_CHANGESET_RESET = `${FETCH_CHANGESET}_${types.RESET_SUFFIX}`;

//********end of detailed view add

// actions
const REPO_URL = "repositories";
//TODO: Content type

//********added for detailed view of changesets

export function fetchChangesetIfNeeded(
  namespace: string,
  repoName: string,
  id: string
) {
  return (dispatch: any, getState: any) => {
    if (shouldFetchChangeset(getState(), namespace, repoName, id)) {
      return dispatch(fetchChangeset(namespace, repoName, id));
    }
  };
}

export function fetchChangeset(
  namespace: string,
  repoName: string,
  id: string
) {
  return function(dispatch: any) {
    dispatch(fetchChangesetPending(namespace, repoName, id));
    return apiClient
      .get(REPO_URL + `/${namespace}/${repoName}/changesets/${id}`)
      .then(response => response.json())
      .then(data =>
        dispatch(fetchChangesetSuccess(data, namespace, repoName, id))
      )
      .catch(err => {
        dispatch(fetchChangesetFailure(namespace, repoName, id, err));
      });
  };
}

export function fetchChangesetPending(
  namespace: string,
  repoName: string,
  id: string
): Action {
  return {
    type: FETCH_CHANGESET_PENDING,
    payload: {
      namespace,
      repoName,
      id
    },
    itemId: createItemId(namespace, repoName, id)
  };
}

export function fetchChangesetSuccess(
  changeset: any,
  namespace: string,
  repoName: string,
  id: string
): Action {
  return {
    type: FETCH_CHANGESET_SUCCESS,
    payload: { changeset, namespace, repoName, id },
    itemId: createItemId(namespace, repoName, id)
  };
}

function fetchChangesetFailure(
  namespace: string,
  repoName: string,
  id: string,
  error: Error
): Action {
  return {
    type: FETCH_CHANGESET_FAILURE,
    payload: {
      namespace,
      repoName,
      id,
      error
    },
    itemId: createItemId(namespace, repoName, id)
  };
}

export function fetchChangesetReset(
  namespace: string,
  repoName: string,
  id: string
) {
  return {
    type: FETCH_CHANGESET_RESET,
    itemId: createItemId(namespace, repoName, id)
  };
}
//********end of detailed view add

export function fetchChangesetsWithOptions(
  namespace: string,
  name: string,
  branch?: string,
  suffix?: string
) {
  let link = REPO_URL + `/${namespace}/${name}`;
  if (branch && branch !== "") {
    link = link + `/branches/${branch}`;
  }
  link = link + "/changesets";
  if (suffix) {
    link = link + `${suffix}`;
  }
  return function(dispatch: any) {
    dispatch(fetchChangesetsPending(namespace, name, branch));
    return apiClient
      .get(link)
      .then(response => response.json())
      .then(data => {
        dispatch(fetchChangesetsSuccess(data, namespace, name, branch));
      })
      .catch(cause => {
        dispatch(fetchChangesetsFailure(namespace, name, cause, branch));
      });
  };
}

export function fetchChangesets(namespace: string, name: string) {
  return fetchChangesetsWithOptions(namespace, name);
}

export function fetchChangesetsByPage(
  namespace: string,
  name: string,
  page: number
) {
  return fetchChangesetsWithOptions(namespace, name, "", `?page=${page}`);
}

export function fetchChangesetsByBranchAndPage(
  namespace: string,
  name: string,
  branch: string,
  page: number
) {
  return fetchChangesetsWithOptions(namespace, name, branch, `?page=${page}`);
}

export function fetchChangesetsByNamespaceNameAndBranch(
  namespace: string,
  name: string,
  branch: string
) {
  return fetchChangesetsWithOptions(namespace, name, branch);
}

export function fetchChangesetsPending(
  namespace: string,
  name: string,
  branch?: string
): Action {
  const itemId = createItemId(namespace, name, branch);
  return {
    type: FETCH_CHANGESETS_PENDING,
    payload: itemId,
    itemId
  };
}

export function fetchChangesetsSuccess(
  changesets: any,
  namespace: string,
  name: string,
  branch?: string
): Action {
  return {
    type: FETCH_CHANGESETS_SUCCESS,
    payload: changesets,
    itemId: createItemId(namespace, name, branch)
  };
}

function fetchChangesetsFailure(
  namespace: string,
  name: string,
  error: Error,
  branch?: string
): Action {
  return {
    type: FETCH_CHANGESETS_FAILURE,
    payload: {
      namespace,
      name,
      branch,
      error
    },
    itemId: createItemId(namespace, name, branch)
  };
}

function createItemId(
  namespace: string,
  name: string,
  branch?: string
): string {
  let itemId = namespace + "/" + name;
  if (branch && branch !== "") {
    itemId = itemId + "/" + branch;
  }
  return itemId;
}

// reducer
function byKeyReducer(
  state: any = {},
  action: Action = { type: "UNKNOWN" }
): Object {
  switch (action.type) {
    //********added for detailed view of changesets
    case FETCH_CHANGESET_SUCCESS:
      const _key = createItemId(
        action.payload.namespace,
        action.payload.repoName
      );
      let _oldChangesets = { [_key]: {} };
      if (state[_key] !== undefined) {
        _oldChangesets[_key] = state[_key];
      }
      return {
        ...state,
        [_key]: {
          byId: addChangesetToChangesets(
            action.payload.changeset,
            _oldChangesets[_key].byId
          )
        }
      };
    //********end of added for detailed view of changesets
    case FETCH_CHANGESETS_SUCCESS:
      const key = action.itemId;
      let oldChangesets = { [key]: {} };
      if (state[key] !== undefined) {
        oldChangesets[key] = state[key];
      }
      return {
        ...state,
        [key]: {
          byId: extractChangesetsByIds(action.payload, oldChangesets[key].byId)
        }
      };
    default:
      return state;
  }
}

function listReducer(
  state: any = {},
  action: Action = { type: "UNKNOWN" }
): Object {
  switch (action.type) {
    //********added for detailed view of changesets
    case FETCH_CHANGESET_SUCCESS:
      const changesetId = action.payload.changeset.id;
      const stateEntries = state.entries ? state.entries : [];
      stateEntries.push(changesetId);
      return {
        entries: stateEntries,
        entry: {
          ...state.entry
        }
      };
    //********end of added for detailed view of changesets
    case FETCH_CHANGESETS_SUCCESS:
      const changesets = action.payload._embedded.changesets;
      const changesetIds = changesets.map(c => c.id);
      return {
        entries: changesetIds,
        entry: {
          page: action.payload.page,
          pageTotal: action.payload.pageTotal,
          _links: action.payload._links
        }
      };
    default:
      return state;
  }
}

export default combineReducers({
  list: listReducer,
  byKey: byKeyReducer
});

function extractChangesetsByIds(data: any, oldChangesetsByIds: any) {
  const changesets = data._embedded.changesets;
  const changesetsByIds = {};

  for (let changeset of changesets) {
    changesetsByIds[changeset.id] = changeset;
  }

  for (let id in oldChangesetsByIds) {
    changesetsByIds[id] = oldChangesetsByIds[id];
  }

  return changesetsByIds;
}
//********added for detailed view of changesets

function addChangesetToChangesets(data: any, oldChangesetsByIds: any) {
  const changeset = data;
  const changesetsByIds = {};

  changesetsByIds[changeset.id] = changeset;

  for (let id in oldChangesetsByIds) {
    changesetsByIds[id] = oldChangesetsByIds[id];
  }

  return changesetsByIds;
}
//********end of added for detailed view of changesets

//selectors
export function getChangesets(
  state: Object,
  namespace: string,
  name: string,
  branch?: string
) {
  const key = createItemId(namespace, name, branch);
  if (!state.changesets.byKey[key]) {
    return null;
  }
  return Object.values(state.changesets.byKey[key].byId);
}

//********added for detailed view of changesets
export function getChangeset(
  state: Object,
  namespace: string,
  name: string,
  id: string,
  branch?: string
) {
  const key = createItemId(namespace, name, branch);
  const changesets =
    state.changesets && state.changesets.byKey && state.changesets.byKey[key]
      ? state.changesets.byKey[key].byId
      : null;
  if (changesets != null && changesets[id]) {
    return changesets[id];
  }
  return null;
}

export function shouldFetchChangeset(
  state: Object,
  namespace: string,
  repoName: string,
  id: string
) {
  if (getChangeset(state, namespace, repoName, id)) {
    return false;
  }
  return true;
}

export function isFetchChangesetPending(
  state: Object,
  namespace: string,
  name: string,
  id: string
) {
  return isPending(state, FETCH_CHANGESET, createItemId(namespace, name, id));
}

export function getFetchChangesetFailure(
  state: Object,
  namespace: string,
  name: string,
  id: string
) {
  return getFailure(state, FETCH_CHANGESET, createItemId(namespace, name, id));
}
//********end of added for detailed view of changesets

export function isFetchChangesetsPending(
  state: Object,
  namespace: string,
  name: string,
  branch?: string
) {
  return isPending(
    state,
    FETCH_CHANGESETS,
    createItemId(namespace, name, branch)
  );
}

export function getFetchChangesetsFailure(
  state: Object,
  namespace: string,
  name: string,
  branch?: string
) {
  return getFailure(
    state,
    FETCH_CHANGESETS,
    createItemId(namespace, name, branch)
  );
}

const selectList = (state: Object) => {
  if (state.changesets && state.changesets.list) {
    return state.changesets.list;
  }
  return {};
};

const selectListEntry = (state: Object): Object => {
  const list = selectList(state);
  if (list.entry) {
    return list.entry;
  }
  return {};
};

export const selectListAsCollection = (state: Object): PagedCollection => {
  return selectListEntry(state);
};