1 files changed, 210 insertions, 0 deletions
diff --git a/server/sonar-web/src/main/js/apps/background-tasks/store/actions.js b/server/sonar-web/src/main/js/apps/background-tasks/store/actions.js
new file mode 100644
index 00000000000..511af5cdb29
--- /dev/null
+++ b/server/sonar-web/src/main/js/apps/background-tasks/store/actions.js
@@ -0,0 +1,210 @@
+/*
+ * SonarQube
+ * Copyright (C) 2009-2016 SonarSource SA
+ * mailto:contact AT sonarsource DOT com
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+import _ from 'underscore';
+import { getTypes, getActivity, cancelAllTasks, cancelTask as cancelTaskAPI } from '../../../api/ce';
+
+import { STATUSES, ALL_TYPES, CURRENTS, DEBOUNCE_DELAY } from '../constants';
+
+const PAGE_SIZE = 1000;
+
+export const INIT = 'INIT';
+export const REQUEST_TASKS = 'REQUEST_TASKS';
+export const RECEIVE_TASKS = 'RECEIVE_TASKS';
+export const UPDATE_QUERY = 'UPDATE_QUERY';
+export const RECEIVE_STATS = 'RECEIVE_STATS';
+export const CANCEL_ALL_PENDING = 'CANCEL_ALL_PENDING';
+export const CANCEL_TASK = 'CANCEL_TASK';
+export const FINISH_CANCEL_TASK = 'FINISH_CANCEL_TASK';
+
+export function init (types) {
+  return {
+    type: INIT,
+    types
+  };
+}
+
+export function requestTasks (filters) {
+  return {
+    type: REQUEST_TASKS,
+    ...filters
+  };
+}
+
+export function receiveTasks (tasks, total) {
+  return {
+    type: RECEIVE_TASKS,
+    tasks,
+    total
+  };
+}
+
+export function updateQuery (query) {
+  return {
+    type: UPDATE_QUERY,
+    query
+  };
+}
+
+export function receiveStats ({ pendingCount, failingCount, inProgressDuration }) {
+  return {
+    type: RECEIVE_STATS,
+    pendingCount,
+    failingCount,
+    inProgressDuration
+  };
+}
+
+export function cancelAllPendingAction () {
+  return {
+    type: CANCEL_ALL_PENDING
+  };
+}
+
+export function cancelTaskAction (task) {
+  return {
+    type: CANCEL_TASK,
+    task
+  };
+}
+
+export function finishCancelTaskAction (task) {
+  return {
+    type: FINISH_CANCEL_TASK,
+    task
+  };
+}
+
+function mapFiltersToParameters (filters = {}) {
+  const parameters = {};
+
+  if (filters.status !== STATUSES.ALL) {
+    parameters.status = filters.status;
+  } else {
+    parameters.status = [
+      STATUSES.PENDING,
+      STATUSES.IN_PROGRESS,
+      STATUSES.SUCCESS,
+      STATUSES.FAILED,
+      STATUSES.CANCELED
+    ].join();
+  }
+
+  if (filters.taskType !== ALL_TYPES) {
+    parameters.type = filters.taskType;
+  }
+
+  if (filters.currents !== CURRENTS.ALL) {
+    parameters.onlyCurrents = true;
+  }
+
+  if (filters.date.minSubmittedAt) {
+    parameters.minSubmittedAt = filters.date.minSubmittedAt;
+  }
+
+  if (filters.date.maxExecutedAt) {
+    parameters.maxExecutedAt = filters.date.maxExecutedAt;
+  }
+
+  if (filters.query) {
+    parameters.componentQuery = filters.query;
+  }
+
+  if (filters.lastPage !== 1) {
+    parameters.p = filters.lastPage;
+  }
+
+  return parameters;
+}
+
+function getInProgressDuration (tasks) {
+  return tasks.length ? tasks[0].executionTimeMs : null;
+}
+
+function fetchTasks (filters) {
+  return dispatch => {
+    const parameters = mapFiltersToParameters(filters);
+    parameters.ps = PAGE_SIZE;
+
+    dispatch(requestTasks(filters));
+
+    return Promise.all([
+      getActivity(parameters),
+      getActivity({ ps: 1, onlyCurrents: true, status: STATUSES.FAILED }),
+      getActivity({ ps: 1, status: STATUSES.PENDING }),
+      getActivity({ ps: 1, status: STATUSES.IN_PROGRESS })
+    ]).then(responses => {
+      const [activity, failingActivity, pendingActivity, inProgressActivity] = responses;
+      const tasks = activity.tasks;
+      const total = activity.paging.total;
+
+      dispatch(receiveTasks(tasks, total));
+
+      const pendingCount = pendingActivity.paging.total;
+      const inProgressDuration = getInProgressDuration(inProgressActivity.tasks);
+      const failingCount = failingActivity.paging.total;
+
+      dispatch(receiveStats({ pendingCount, failingCount, inProgressDuration }));
+    });
+  };
+}
+
+export function filterTasks (overriddenFilters) {
+  return (dispatch, getState) => {
+    const { status, taskType, currents, date, query } = getState();
+    const filters = { status, taskType, currents, date, query };
+    const finalFilters = { ...filters, ...overriddenFilters };
+
+    dispatch(fetchTasks(finalFilters));
+  };
+}
+
+const debouncedFilter = _.debounce((dispatch, overriddenFilters) => {
+  dispatch(filterTasks(overriddenFilters));
+}, DEBOUNCE_DELAY);
+
+export function search (query) {
+  return dispatch => {
+    dispatch(updateQuery(query));
+    debouncedFilter(dispatch, { query });
+  };
+}
+
+export function cancelAllPending () {
+  return dispatch => {
+    dispatch(cancelAllPendingAction());
+    cancelAllTasks().then(() => dispatch(filterTasks()));
+  };
+}
+
+export function cancelTask (task) {
+  return dispatch => {
+    dispatch(cancelTaskAction(task));
+    cancelTaskAPI(task.id).then(nextTask => dispatch(finishCancelTaskAction(nextTask)));
+  };
+}
+
+export function initApp () {
+  return dispatch => {
+    getTypes().then(types => {
+      dispatch(init(types));
+      dispatch(filterTasks());
+    });
+  };
+}