1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
import {call, put, select} from "redux-saga/effects";
import {addPropToStoreObject, addToStore} from "../actions/objects";
import {deleteExperiment, getExperiment} from "../api/routes/experiments";
import {addExperiment, getExperimentsOfSimulation} from "../api/routes/simulations";
import {fetchAndStoreAllSchedulers, fetchAndStoreAllTraces, fetchAndStorePathsOfSimulation} from "./objects";
import {fetchAllDatacentersOfExperiment} from "./topology";
export function* onOpenExperimentSucceeded(action) {
try {
const experiment = yield call(getExperiment, action.experimentId);
yield put(addToStore("experiment", experiment));
yield fetchAllDatacentersOfExperiment(experiment);
} catch (error) {
console.error(error);
}
}
export function* onFetchExperimentsOfSimulation() {
try {
const currentSimulationId = yield select(state => state.currentSimulationId);
yield fetchExperimentSpecifications();
const experiments = yield call(getExperimentsOfSimulation, currentSimulationId);
for (let i in experiments) {
yield put(addToStore("experiment", experiments[i]));
}
yield put(addPropToStoreObject("simulation", currentSimulationId,
{experimentIds: experiments.map(experiment => experiment.id)}));
} catch (error) {
console.error(error);
}
}
function* fetchExperimentSpecifications() {
try {
const currentSimulationId = yield select(state => state.currentSimulationId);
yield fetchAndStorePathsOfSimulation(currentSimulationId);
yield fetchAndStoreAllTraces();
yield fetchAndStoreAllSchedulers();
} catch (error) {
console.error(error);
}
}
export function* onAddExperiment(action) {
try {
const currentSimulationId = yield select(state => state.currentSimulationId);
const experiment = yield call(addExperiment,
currentSimulationId,
Object.assign({}, action.experiment, {
id: -1,
simulationId: currentSimulationId
})
);
yield put(addToStore("experiment", experiment));
const experimentIds = yield select(state => state.objects.simulation[currentSimulationId].experimentIds);
yield put(addPropToStoreObject("simulation", currentSimulationId,
{experimentIds: experimentIds.concat([experiment.id])}));
} catch (error) {
console.error(error);
}
}
export function* onDeleteExperiment(action) {
try {
yield call(deleteExperiment, action.id);
const currentSimulationId = yield select(state => state.currentSimulationId);
const experimentIds = yield select(state => state.objects.simulation[currentSimulationId].experimentIds);
yield put(addPropToStoreObject("simulation", currentSimulationId,
{experimentIds: experimentIds.filter(id => id !== action.id)}));
} catch (error) {
console.error(error);
}
}
|