39 lines
1.0 KiB
TypeScript
39 lines
1.0 KiB
TypeScript
|
import { put } from "redux-saga/effects";
|
||
|
|
import { SOCKET_EVENTS } from "./constants";
|
||
|
|
|
||
|
|
import {
|
||
|
|
newCommentEvent,
|
||
|
|
newCommentThreadEvent,
|
||
|
|
updateCommentThreadEvent,
|
||
|
|
updateCommentEvent,
|
||
|
|
} from "actions/commentActions";
|
||
|
|
|
||
|
|
import { newNotificationEvent } from "actions/notificationActions";
|
||
|
|
|
||
|
|
export default function* handleSocketEvent(event: any) {
|
||
|
|
switch (event.type) {
|
||
|
|
// comments
|
||
|
|
case SOCKET_EVENTS.INSERT_COMMENT_THREAD: {
|
||
|
|
yield put(newCommentThreadEvent(event.payload[0]));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
case SOCKET_EVENTS.INSERT_COMMENT: {
|
||
|
|
yield put(newCommentEvent(event.payload[0]));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
case SOCKET_EVENTS.UPDATE_COMMENT_THREAD: {
|
||
|
|
yield put(updateCommentThreadEvent(event.payload[0].thread));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
case SOCKET_EVENTS.UPDATE_COMMENT: {
|
||
|
|
yield put(updateCommentEvent(event.payload[0].comment));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
// notifications
|
||
|
|
case SOCKET_EVENTS.INSERT_NOTIFICATION: {
|
||
|
|
yield put(newNotificationEvent(event.payload[0].notification));
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|