forked from cloud-bulldozer/cpt-dashboard
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
This relies on the ilab API in cloud-bulldozer#123, which in turn builds on the crucible service in cloud-bulldozer#122.
- Loading branch information
Showing
25 changed files
with
794 additions
and
269 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,213 @@ | ||
| import * as API_ROUTES from "@/utils/apiConstants"; | ||
| import * as TYPES from "./types.js"; | ||
|
|
||
| import API from "@/utils/axiosInstance"; | ||
| import { appendQueryString } from "@/utils/helper"; | ||
| import { cloneDeep } from "lodash"; | ||
| import { showFailureToast } from "@/actions/toastActions"; | ||
|
|
||
| export const fetchILabJobs = | ||
| (shouldStartFresh = false) => | ||
| async (dispatch, getState) => { | ||
| try { | ||
| dispatch({ type: TYPES.LOADING }); | ||
| const { start_date, end_date, size, offset, results } = getState().ilab; | ||
| const response = await API.get(API_ROUTES.ILABS_JOBS_API_V1, { | ||
| params: { | ||
| ...(start_date && { start_date }), | ||
| ...(end_date && { end_date }), | ||
| ...(size && { size }), | ||
| ...(offset && { offset }), | ||
| }, | ||
| }); | ||
| if (response.status === 200 && response?.data?.results.length > 0) { | ||
| const startDate = response.data.startDate, | ||
| endDate = response.data.endDate; | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_JOBS_DATA, | ||
| payload: shouldStartFresh | ||
| ? response.data.results | ||
| : [...results, ...response.data.results], | ||
| }); | ||
|
|
||
| dispatch({ | ||
| type: TYPES.SET_ILAB_DATE_FILTER, | ||
| payload: { | ||
| start_date: startDate, | ||
| end_date: endDate, | ||
| }, | ||
| }); | ||
|
|
||
| dispatch({ | ||
| type: TYPES.SET_ILAB_TOTAL_ITEMS, | ||
| payload: response.data.total, | ||
| }); | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_OFFSET, | ||
| payload: response.data.next_offset, | ||
| }); | ||
|
|
||
| dispatch(tableReCalcValues()); | ||
| } | ||
| } catch (error) { | ||
| dispatch(showFailureToast()); | ||
| } | ||
| dispatch({ type: TYPES.COMPLETED }); | ||
| }; | ||
| export const sliceIlabTableRows = | ||
| (startIdx, endIdx) => (dispatch, getState) => { | ||
| const results = [...getState().ilab.results]; | ||
|
|
||
| dispatch({ | ||
| type: TYPES.SET_ILAB_INIT_JOBS, | ||
| payload: results.slice(startIdx, endIdx), | ||
| }); | ||
| }; | ||
| export const setIlabDateFilter = | ||
| (start_date, end_date, navigate) => (dispatch, getState) => { | ||
| const appliedFilters = getState().ilab.appliedFilters; | ||
|
|
||
| dispatch({ | ||
| type: TYPES.SET_ILAB_DATE_FILTER, | ||
| payload: { | ||
| start_date, | ||
| end_date, | ||
| }, | ||
| }); | ||
|
|
||
| appendQueryString({ ...appliedFilters, start_date, end_date }, navigate); | ||
| }; | ||
|
|
||
| export const fetchMetricsInfo = (uid) => async (dispatch) => { | ||
| try { | ||
| dispatch({ type: TYPES.LOADING }); | ||
| const response = await API.get(`/api/v1/ilab/runs/${uid}/metrics`); | ||
| if (response.status === 200) { | ||
| if ( | ||
| response.data.constructor === Object && | ||
| Object.keys(response.data).length > 0 | ||
| ) { | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_METRICS, | ||
| payload: { uid, metrics: Object.keys(response.data) }, | ||
| }); | ||
| } | ||
| } | ||
| } catch (error) { | ||
| console.error(error); | ||
| dispatch(showFailureToast()); | ||
| } | ||
| dispatch({ type: TYPES.COMPLETED }); | ||
| }; | ||
|
|
||
| export const fetchPeriods = (uid) => async (dispatch) => { | ||
| try { | ||
| dispatch({ type: TYPES.LOADING }); | ||
| const response = await API.get(`/api/v1/ilab/runs/${uid}/periods`); | ||
| if (response.status === 200) { | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_PERIODS, | ||
| payload: { uid, periods: response.data }, | ||
| }); | ||
| } | ||
| } catch (error) { | ||
| console.error( | ||
| `ERROR (${error?.response?.status}): ${JSON.stringify( | ||
| error?.response?.data | ||
| )}` | ||
| ); | ||
| dispatch(showFailureToast()); | ||
| } | ||
| dispatch({ type: TYPES.COMPLETED }); | ||
| }; | ||
|
|
||
| export const fetchGraphData = | ||
| (uid, metric, primary_metric) => async (dispatch, getState) => { | ||
| try { | ||
| const periods = getState().ilab.periods.find((i) => i.uid == uid); | ||
| const graphData = cloneDeep(getState().ilab.graphData); | ||
| const filterData = graphData.filter((i) => i.uid !== uid); | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_GRAPH_DATA, | ||
| payload: filterData, | ||
| }); | ||
| const copyData = cloneDeep(filterData); | ||
| dispatch({ type: TYPES.GRAPH_LOADING }); | ||
| let graphs = []; | ||
| periods?.periods?.forEach((p) => { | ||
| graphs.push({ metric: p.primary_metric, periods: [p.id] }); | ||
| graphs.push({ | ||
| metric, | ||
| aggregate: true, | ||
| periods: [p.id], | ||
| }); | ||
| }); | ||
| const response = await API.post(`/api/v1/ilab/runs/multigraph`, { | ||
| run: uid, | ||
| name: primary_metric, | ||
| graphs, | ||
| }); | ||
| if (response.status === 200) { | ||
| copyData.push({ | ||
| uid, | ||
| data: response.data.data, | ||
| layout: response.data.layout, | ||
| }); | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_GRAPH_DATA, | ||
| payload: copyData, | ||
| }); | ||
| } | ||
| } catch (error) { | ||
| console.error( | ||
| `ERROR (${error?.response?.status}): ${JSON.stringify( | ||
| error?.response?.data | ||
| )}` | ||
| ); | ||
| dispatch(showFailureToast()); | ||
| } | ||
| dispatch({ type: TYPES.GRAPH_COMPLETED }); | ||
| }; | ||
|
|
||
| export const setIlabPage = (pageNo) => ({ | ||
| type: TYPES.SET_ILAB_PAGE, | ||
| payload: pageNo, | ||
| }); | ||
|
|
||
| export const setIlabPageOptions = (page, perPage) => ({ | ||
| type: TYPES.SET_ILAB_PAGE_OPTIONS, | ||
| payload: { page, perPage }, | ||
| }); | ||
|
|
||
| export const checkIlabJobs = (newPage) => (dispatch, getState) => { | ||
| const results = cloneDeep(getState().ilab.results); | ||
| const { totalItems, perPage } = getState().ilab; | ||
|
|
||
| const startIdx = (newPage - 1) * perPage; | ||
| const endIdx = newPage * perPage; | ||
|
|
||
| if ( | ||
| (typeof results[startIdx] === "undefined" || | ||
| typeof results[endIdx] === "undefined") && | ||
| results.length < totalItems | ||
| ) { | ||
| dispatch(fetchILabJobs()); | ||
| } | ||
| }; | ||
|
|
||
| export const setSelectedMetrics = (id, metrics) => (dispatch, getState) => { | ||
| const metrics_selected = cloneDeep(getState().ilab.metrics_selected); | ||
| metrics_selected[id] = metrics; | ||
| dispatch({ | ||
| type: TYPES.SET_ILAB_SELECTED_METRICS, | ||
| payload: metrics_selected, | ||
| }); | ||
| }; | ||
|
|
||
| export const tableReCalcValues = () => (dispatch, getState) => { | ||
| const { page, perPage } = getState().ilab; | ||
|
|
||
| const startIdx = page !== 1 ? (page - 1) * perPage : 0; | ||
| const endIdx = page !== 1 ? page * perPage - 1 : perPage; | ||
| dispatch(sliceIlabTableRows(startIdx, endIdx)); | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.