79 lines
2.4 KiB
JavaScript
79 lines
2.4 KiB
JavaScript
import * as Sentry from '~/sentry/wrapper';
|
|
import Poll from '~/lib/utils/poll';
|
|
import axios from '~/lib/utils/axios_utils';
|
|
import { deprecatedCreateFlash as flash } from '~/flash';
|
|
import { __ } from '~/locale';
|
|
import { MAX_REQUESTS } from '../constants';
|
|
import { parseIntPagination, normalizeHeaders } from '~/lib/utils/common_utils';
|
|
import * as types from './mutation_types';
|
|
|
|
const allNodesPresent = (clusters, retryCount) => {
|
|
/*
|
|
Nodes are coming from external Kubernetes clusters.
|
|
They may fail for reasons GitLab cannot control.
|
|
MAX_REQUESTS will ensure this poll stops at some point.
|
|
*/
|
|
return retryCount > MAX_REQUESTS || clusters.every(cluster => cluster.nodes != null);
|
|
};
|
|
|
|
export const reportSentryError = (_store, { error, tag }) => {
|
|
Sentry.withScope(scope => {
|
|
scope.setTag('javascript_clusters_list', tag);
|
|
Sentry.captureException(error);
|
|
});
|
|
};
|
|
|
|
export const fetchClusters = ({ state, commit, dispatch }) => {
|
|
let retryCount = 0;
|
|
|
|
commit(types.SET_LOADING_NODES, true);
|
|
|
|
const poll = new Poll({
|
|
resource: {
|
|
fetchClusters: paginatedEndPoint => axios.get(paginatedEndPoint),
|
|
},
|
|
data: `${state.endpoint}?page=${state.page}`,
|
|
method: 'fetchClusters',
|
|
successCallback: ({ data, headers }) => {
|
|
retryCount += 1;
|
|
|
|
try {
|
|
if (data.clusters) {
|
|
const normalizedHeaders = normalizeHeaders(headers);
|
|
const paginationInformation = parseIntPagination(normalizedHeaders);
|
|
|
|
commit(types.SET_CLUSTERS_DATA, { data, paginationInformation });
|
|
commit(types.SET_LOADING_CLUSTERS, false);
|
|
|
|
if (allNodesPresent(data.clusters, retryCount)) {
|
|
poll.stop();
|
|
commit(types.SET_LOADING_NODES, false);
|
|
}
|
|
}
|
|
} catch (error) {
|
|
poll.stop();
|
|
|
|
commit(types.SET_LOADING_CLUSTERS, false);
|
|
commit(types.SET_LOADING_NODES, false);
|
|
|
|
dispatch('reportSentryError', { error, tag: 'fetchClustersSuccessCallback' });
|
|
}
|
|
},
|
|
errorCallback: response => {
|
|
poll.stop();
|
|
|
|
commit(types.SET_LOADING_CLUSTERS, false);
|
|
commit(types.SET_LOADING_NODES, false);
|
|
flash(__('Clusters|An error occurred while loading clusters'));
|
|
|
|
dispatch('reportSentryError', { error: response, tag: 'fetchClustersErrorCallback' });
|
|
},
|
|
});
|
|
|
|
poll.makeRequest();
|
|
};
|
|
|
|
export const setPage = ({ commit }, page) => {
|
|
commit(types.SET_PAGE, page);
|
|
};
|