1 files changed, 48 insertions, 0 deletions
diff --git a/opendc-web/opendc-web-ui/src/redux/sagas/projects.js b/opendc-web/opendc-web-ui/src/redux/sagas/projects.js
new file mode 100644
index 00000000..ecd9a7c9
--- /dev/null
+++ b/opendc-web/opendc-web-ui/src/redux/sagas/projects.js
@@ -0,0 +1,48 @@
+import { call, put } from 'redux-saga/effects'
+import { addToStore } from '../actions/objects'
+import { addProjectSucceeded, deleteProjectSucceeded } from '../actions/projects'
+import { addProject, deleteProject, getProject } from '../../api/projects'
+import { fetchAndStoreAllTopologiesOfProject } from './topology'
+import { fetchAndStoreAllSchedulers, fetchAndStoreAllTraces } from './objects'
+import { fetchPortfoliosOfProject } from './portfolios'
+
+export function* onOpenProjectSucceeded(action) {
+    try {
+        const project = yield call(getProject, action.id)
+        yield put(addToStore('project', project))
+
+        yield fetchAndStoreAllTopologiesOfProject(action.id, true)
+        yield fetchPortfoliosOfProject()
+        yield fetchAndStoreAllSchedulers()
+        yield fetchAndStoreAllTraces()
+    } catch (error) {
+        console.error(error)
+    }
+}
+
+export function* onProjectAdd(action) {
+    try {
+        const project = yield call(addProject, { name: action.name })
+        yield put(addToStore('project', project))
+
+        const authorization = {
+            projectId: project._id,
+            userId: action.userId,
+            authorizationLevel: 'OWN',
+            project,
+        }
+        yield put(addToStore('authorization', authorization))
+        yield put(addProjectSucceeded([authorization.userId, authorization.projectId]))
+    } catch (error) {
+        console.error(error)
+    }
+}
+
+export function* onProjectDelete(action) {
+    try {
+        yield call(deleteProject, action.id)
+        yield put(deleteProjectSucceeded(action.id))
+    } catch (error) {
+        console.error(error)
+    }
+}