summaryrefslogtreecommitdiff
path: root/src/sagas/experiments.js
blob: cf92e97f9754c0ef8bf548316e7a15bc12ae543e (plain)
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);
    }
}