Merge pull request #747 from AI4Bharat/revert-745-revert-735-autosave2

Revert "Revert "disable autosave when any other save call is in progress""

src/hooks/useAutoSave.js

@@ -1,4 +1,4 @@
-import { useEffect } from "react";
+import { useEffect, useState } from "react";
 import { useRef } from "react";
 import { useDispatch, useSelector } from "react-redux";
 import { useParams } from "react-router-dom";
@@ -13,6 +13,13 @@ export const useAutoSave = () => {
   const currentPage = useSelector((state) => state.commonReducer.currentPage);
   const subs = useSelector((state) => state.commonReducer.subtitles);
   const taskDetails = useSelector((state) => state.getTaskDetails.data);
+  const apiStatus = useSelector((state) => state.apiStatus);
+  const [apiInProgress, setApiInProgress] = useState(false);
+
+  useEffect(() => {
+    const { progress, success, data, apiType } = apiStatus;
+    setApiInProgress(progress);
+  }, [apiStatus]);
 
   useEffect(() => {
     const handleAutosave = () => {
@@ -38,8 +45,10 @@ export const useAutoSave = () => {
         },
       };
 
-      const obj = new SaveTranscriptAPI(reqBody, taskDetails?.task_type);
-      dispatch(APITransport(obj));
+      if(!apiInProgress){
+        const obj = new SaveTranscriptAPI(reqBody, taskDetails?.task_type);
+        dispatch(APITransport(obj));
+      }
     };
 
     saveIntervalRef.current = setInterval(handleAutosave, 60 * 1000);
@@ -61,5 +70,5 @@ export const useAutoSave = () => {
     };
 
     // eslint-disable-next-line
-  }, [subs]);
+  }, [subs, apiInProgress]);
 };

src/hooks/useUpdateTimeSpent.js

@@ -2,7 +2,7 @@ import { useEffect } from "react";
 import { useRef } from "react";
 import { useDispatch } from "react-redux";
 import { useParams } from "react-router-dom";
-import { APITransport, UpdateTimeSpentPerTask } from "redux/actions";
+import { APITransportUTS, UpdateTimeSpentPerTask } from "redux/actions";
 
 export const useUpdateTimeSpent = (ref) => {
   const { taskId } = useParams();
@@ -12,7 +12,7 @@ export const useUpdateTimeSpent = (ref) => {
   useEffect(() => {
     const handleUpdateTimeSpent = (time = 60) => {
       const apiObj = new UpdateTimeSpentPerTask(taskId, time);
-      dispatch(APITransport(apiObj));
+      dispatch(APITransportUTS(apiObj));
     };
 
     timeSpentIntervalRef.current = setInterval(

src/redux/actions/apitransport/apitransportUts.js

@@ -0,0 +1,120 @@
+import axios from "axios";
+import strings from "../../string";
+import { setSnackBar } from "../Common";
+
+const dispatchAPIAsync = (api) => {
+  return {
+    type: api.type,
+    endpoint: api.apiEndPoint(),
+    payload: api.getPayload(),
+  };
+};
+
+const success = (res, api, dispatch) => {
+  const { data, status } = res;
+
+  api.processResponse(data);
+
+  if (api.type) {
+    dispatch(dispatchAPIAsync(api));
+  }
+
+  if (data.message) {
+    dispatch(
+      setSnackBar({
+        open: true,
+        message: data.message,
+        variant: "success",
+      })
+    );
+  }
+
+  if (
+    typeof api.processNextSuccessStep === "function" &&
+    (status === 200 || status === 201)
+  ) {
+    api.processNextSuccessStep(data);
+  }
+};
+
+const error = (err, api, dispatch) => {
+  const {
+    response: {
+      data: { message },
+      status,
+    },
+  } = err;
+
+  const {
+    error: {
+      message: { http },
+    },
+  } = strings;
+
+  let errorMsg = message ?? http[status];
+
+  if (typeof api.processNextErrorStep === "function") {
+    api.processNextErrorStep();
+  }
+
+  dispatch(
+    setSnackBar({
+      open: true,
+      message: errorMsg,
+      variant: "error",
+    })
+  );
+
+  if (status === 401 && api.type !== "GET_USER_ACCESS_TOKEN") {
+    window.location.replace("/#/login");
+  }
+};
+
+export default function dispatchAPIUts(api) {
+  return (dispatch) => {
+    const { method } = api;
+
+    let request;
+    switch (method) {
+      case "MULTIPART":
+        request = axios.post(
+          api.apiEndPoint(),
+          api.getFormData(),
+          api.getHeaders()
+        );
+        break;
+
+      case "PATCH":
+        request = axios.patch(
+          api.apiEndPoint(),
+          api.getBody(),
+          api.getHeaders()
+        );
+        break;
+
+      case "POST":
+        request = axios.post(
+          api.apiEndPoint(),
+          api.getBody(),
+          api.getHeaders()
+        );
+        break;
+
+      case "PUT":
+        request = axios.put(api.apiEndPoint(), api.getBody(), api.getHeaders());
+        break;
+
+      case "DELETE":
+        request = axios.delete(api.apiEndPoint(), api.getHeaders());
+        break;
+
+      default:
+        request = axios.get(api.apiEndPoint(), api.getHeaders());
+        break;
+    }
+
+    request
+      .then((res) => success(res, api, dispatch))
+      .catch((err) => error(err, api, dispatch));
+  };
+}

src/redux/actions/index.js

@@ -155,6 +155,7 @@ import FetchVoiceoverChartAPI from "./api/Intro/FetchVoiceoverChart";
 import FetchTranslationChartAPI from "./api/Intro/FetchTranslationChart";
 
 import APITransport from "./apitransport/apitransport";
+import APITransportUTS from "./apitransport/apitransportUts";
 import UnSubscribeNewletterFromEmailAPI from "./api/User/UnSubscribeNewletterFromEmail";
 import RegenerateResponseAPI from "./api/Project/RegenerateResponse";
 import OnBoardingAPI from "./api/User/OnBoarding";
@@ -266,6 +267,7 @@ export {
   setRangeStart,
   setRangeEnd,
   APITransport,
+  APITransportUTS,
   FetchVoiceoverExportTypesAPI,
   FetchSupportedBulkTaskTypeAPI,
   setSnackBar,