PromucFlow_constructor/app/client/src/sagas/WebsocketSagas/handleSocketEvent.ts

import { put } from "redux-saga/effects";
import { SOCKET_EVENTS } from "./constants";

import {
  newCommentEvent,
  newCommentThreadEvent,
  updateCommentThreadEvent,
  updateCommentEvent,
  fetchUnreadCommentThreadsCountRequest,
} 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]));
      yield put(fetchUnreadCommentThreadsCountRequest());
      return;
    }
    case SOCKET_EVENTS.INSERT_COMMENT: {
      yield put(newCommentEvent(event.payload[0]));
      yield put(fetchUnreadCommentThreadsCountRequest());
      return;
    }
    case SOCKET_EVENTS.UPDATE_COMMENT_THREAD: {
      yield put(updateCommentThreadEvent(event.payload[0].thread));
      yield put(fetchUnreadCommentThreadsCountRequest());
      return;
    }
    case SOCKET_EVENTS.UPDATE_COMMENT: {
      yield put(updateCommentEvent(event.payload[0].comment));
      yield put(fetchUnreadCommentThreadsCountRequest());
      return;
    }
    // notifications
    case SOCKET_EVENTS.INSERT_NOTIFICATION: {
      yield put(newNotificationEvent(event.payload[0].notification));
      return;
    }
  }
}