refactor: rewrite saga usecases with watchTransition

Author: edvincandon

usecases/sagas/saga.ts

@@ -1,8 +1,7 @@
 import { createAction } from '@reduxjs/toolkit';
-import { call, put, select, takeEvery, takeLeading } from 'redux-saga/effects';
+import { takeLeading } from 'redux-saga/effects';
 
-import type { StagedAction } from '~transitions';
-import { getTransitionMeta } from '~transitions';
+import { watchTransition, retryFailed } from '~saga/index';
 import { activitySelectors } from '~usecases/lib/store/activity/reducer';
 import { dismissActivity, editActivity, logActivity } from '~usecases/lib/store/activity/actions';
 import { createEpic, deleteEpic, editEpic } from '~usecases/lib/store/epics/actions';
@@ -16,126 +15,31 @@ import { generateId, simulateAPIRequest } from '~usecases/lib/utils/mock-api';
 
 export const retryAll = createAction('optimistron::retryAll');
 
-function* retryAllFailed() {
-    const epics: State['epics'] = yield select((s: State) => s.epics);
-    const profile: State['profile'] = yield select((s: State) => s.profile);
-    const projects: State['projects'] = yield select((s: State) => s.projects);
-    const activity: State['activity'] = yield select((s: State) => s.activity);
-
-    const failed: StagedAction[] = [
-        ...epicsSelectors.selectFailures(epics),
-        ...profileSelectors.selectFailures(profile),
-        ...projectsSelectors.selectFailures(projects),
-        ...activitySelectors.selectFailures(activity),
-    ];
-
-    for (const action of failed) {
-        yield put(action);
-    }
-}
+const retry = retryFailed(
+    (state: State) => [state.epics, state.profile, state.projects, state.activity],
+    [epicsSelectors, profileSelectors, projectsSelectors, activitySelectors],
+);
 
 export function* rootSaga() {
-    yield takeLeading(retryAll.match, retryAllFailed);
-    yield takeEvery(createEpic.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(createEpic.amend(transitionId, { ...action.payload, id: generateId() }));
-            yield put(createEpic.commit(transitionId));
-        } catch (error) {
-            yield put(createEpic.fail(transitionId, error));
-        }
-    });
-
-    yield takeEvery(editEpic.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(editEpic.commit(transitionId));
-        } catch (error) {
-            yield put(editEpic.fail(transitionId, error));
-        }
-    });
-
-    yield takeEvery(deleteEpic.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(deleteEpic.commit(transitionId));
-        } catch {
-            yield put(deleteEpic.stash(transitionId));
-        }
-    });
+    yield takeLeading(retryAll.match, retry);
 
-    yield takeEvery(updateProfile.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(updateProfile.commit(transitionId));
-        } catch (error) {
-            yield put(updateProfile.fail(transitionId, error));
-        }
+    yield* watchTransition(createEpic, simulateAPIRequest, {
+        amend: (payload) => ({ ...payload, id: generateId() }),
     });
+    yield* watchTransition(editEpic, simulateAPIRequest);
+    yield* watchTransition(deleteEpic, simulateAPIRequest);
 
-    yield takeEvery(createProjectTodo.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(createProjectTodo.amend(transitionId, { ...action.payload, id: generateId() }));
-            yield put(createProjectTodo.commit(transitionId));
-        } catch (error) {
-            yield put(createProjectTodo.fail(transitionId, error));
-        }
-    });
-
-    yield takeEvery(editProjectTodo.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(editProjectTodo.commit(transitionId));
-        } catch (error) {
-            yield put(editProjectTodo.fail(transitionId, error));
-        }
-    });
-
-    yield takeEvery(deleteProjectTodo.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(deleteProjectTodo.commit(transitionId));
-        } catch {
-            yield put(deleteProjectTodo.stash(transitionId));
-        }
-    });
-
-    yield takeEvery(logActivity.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(logActivity.amend(transitionId, { ...action.payload, id: generateId() }));
-            yield put(logActivity.commit(transitionId));
-        } catch (error) {
-            yield put(logActivity.fail(transitionId, error));
-        }
-    });
+    yield* watchTransition(updateProfile, simulateAPIRequest);
 
-    yield takeEvery(editActivity.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(editActivity.commit(transitionId));
-        } catch (error) {
-            yield put(editActivity.fail(transitionId, error));
-        }
+    yield* watchTransition(createProjectTodo, simulateAPIRequest, {
+        amend: (payload) => ({ ...payload, id: generateId() }),
     });
+    yield* watchTransition(editProjectTodo, simulateAPIRequest);
+    yield* watchTransition(deleteProjectTodo, simulateAPIRequest);
 
-    yield takeEvery(dismissActivity.stage.match, function* (action) {
-        const transitionId = getTransitionMeta(action).id;
-        try {
-            yield call(simulateAPIRequest);
-            yield put(dismissActivity.commit(transitionId));
-        } catch {
-            yield put(dismissActivity.stash(transitionId));
-        }
+    yield* watchTransition(logActivity, simulateAPIRequest, {
+        amend: (payload) => ({ ...payload, id: generateId() }),
     });
+    yield* watchTransition(editActivity, simulateAPIRequest);
+    yield* watchTransition(dismissActivity, simulateAPIRequest);
 }