summaryrefslogtreecommitdiff
path: root/frontend/src/sagas/errors.js
diff options
context:
space:
mode:
Diffstat (limited to 'frontend/src/sagas/errors.js')
-rw-r--r--frontend/src/sagas/errors.js38
1 files changed, 21 insertions, 17 deletions
diff --git a/frontend/src/sagas/errors.js b/frontend/src/sagas/errors.js
index ba1ae40d..42994610 100644
--- a/frontend/src/sagas/errors.js
+++ b/frontend/src/sagas/errors.js
@@ -1,36 +1,40 @@
-import { apply, call, cancelled, put, take } from 'redux-saga/effects'
+import { apply, call, cancelled, put, take } from "redux-saga/effects";
-import { createSubscriptionChannel } from '../utils/websocket'
-import { actions } from '../redux/errors'
+import { createSubscriptionChannel } from "../utils/websocket";
+import { actions } from "../redux/errors";
-import {toastr} from 'react-redux-toastr'
+import { toastr } from "react-redux-toastr";
-export default function *errorHandlingSaga({ socket }) {
- const errorChannel = yield call(createSubscriptionChannel, socket, '/user/queue/errors')
+export default function* errorHandlingSaga({ socket }) {
+ const errorChannel = yield call(
+ createSubscriptionChannel,
+ socket,
+ "/user/queue/errors"
+ );
try {
while (true) {
- const error = yield take(errorChannel)
- yield* handleOneError(error)
+ const error = yield take(errorChannel);
+ yield* handleOneError(error);
}
} finally {
if (yield cancelled()) {
- console.log('Error management saga cancelled')
- yield apply(errorChannel, errorChannel.close)
+ console.log("Error management saga cancelled");
+ yield apply(errorChannel, errorChannel.close);
}
}
}
-function *handleOneError(err) {
- console.error("Error received on web socket channel", err)
- const msg = buildMsg(err)
- yield apply(toastr, toastr.error, [msg, {icon: 'error'}])
- yield put(actions.errorReceived(err))
+function* handleOneError(err) {
+ console.error("Error received on web socket channel", err);
+ const msg = buildMsg(err);
+ yield apply(toastr, toastr.error, [msg, { icon: "error" }]);
+ yield put(actions.errorReceived(err));
}
function buildMsg(err) {
if (err.details.length > 0) {
- return err.details.map(d => d.message).join('\n')
+ return err.details.map(d => d.message).join("\n");
} else {
- return err.message
+ return err.message;
}
}
bgstack15