[TM-1531] add job connection

src/admin/components/ResourceTabs/PolygonReviewTab/index.tsx

@@ -31,7 +31,6 @@ import { IconNames } from "@/components/extensive/Icon/Icon";
 import ModalAdd from "@/components/extensive/Modal/ModalAdd";
 import ModalConfirm from "@/components/extensive/Modal/ModalConfirm";
 import { ModalId } from "@/components/extensive/Modal/ModalConst";
-import { useLoading } from "@/context/loaderAdmin.provider";
 import { useMapAreaContext } from "@/context/mapArea.provider";
 import { useModalContext } from "@/context/modal.provider";
 import { useMonitoredDataContext } from "@/context/monitoredData.provider";
@@ -152,7 +151,6 @@ const PolygonReviewTab: FC<IProps> = props => {
   const [saveFlags, setSaveFlags] = useState<boolean>(false);
   const [polygonFromMap, setPolygonFromMap] = useState<IpolygonFromMap>({ isOpen: false, uuid: "" });
   const [errorMessage, setErrorMessage] = useState<string | null>(null);
-  const { showLoader, hideLoader } = useLoading();
   const {
     setSelectedPolygonsInCheckbox,
     setPolygonCriteriaMap,
@@ -314,8 +312,7 @@ const PolygonReviewTab: FC<IProps> = props => {
   }, [shouldRefetchValidation]);
   const uploadFiles = async () => {
     const uploadPromises = [];
-    showLoader();
-
+    closeModal(ModalId.ADD_POLYGON);
     for (const file of files) {
       const fileToUpload = file.rawFile as File;
       const site_uuid = record.uuid;
@@ -350,10 +347,8 @@ const PolygonReviewTab: FC<IProps> = props => {
       }
       refetch();
       refetchSiteBbox();
-      closeModal(ModalId.ADD_POLYGON);
       setPolygonLoaded(false);
       setSubmitPolygonLoaded(false);
-      hideLoader();
     } catch (error) {
       let errorMessage;
 
@@ -379,7 +374,6 @@ const PolygonReviewTab: FC<IProps> = props => {
         errorMessage = t("An unknown error occurred");
       }
       openNotification("error", t("Error uploading file"), errorMessage || t("An unknown error occurred"));
-      hideLoader();
     }
   };
 

src/admin/modules/sites/components/SiteShow.tsx

@@ -1,8 +1,7 @@
-import { FC, useState } from "react";
+import { FC } from "react";
 import { Show, TabbedShowLayout } from "react-admin";
 
 import ShowActions from "@/admin/components/Actions/ShowActions";
-import DelayedJobsProgressAlert from "@/admin/components/Alerts/DelayedJobsProgressAlert";
 import AuditLogTab from "@/admin/components/ResourceTabs/AuditLogTab/AuditLogTab";
 import { AuditLogButtonStates } from "@/admin/components/ResourceTabs/AuditLogTab/constants/enum";
 import ChangeRequestsTab from "@/admin/components/ResourceTabs/ChangeRequestsTab/ChangeRequestsTab";
@@ -16,9 +15,6 @@ import { RecordFrameworkProvider } from "@/context/framework.provider";
 import { MapAreaProvider } from "@/context/mapArea.provider";
 
 const SiteShow: FC = () => {
-  const [isLoadingDelayedJob, setIsLoadingDelayedJob] = useState(false);
-  const [alertTitle, setAlertTitle] = useState("");
-
   return (
     <Show
       title={<ShowTitle moduleName="Site" getTitle={record => record?.name} />}
@@ -30,13 +26,7 @@ const SiteShow: FC = () => {
           <InformationTab type="sites" />
           <TabbedShowLayout.Tab label="Polygon Review">
             <MapAreaProvider>
-              <PolygonReviewTab
-                label=""
-                type={"sites"}
-                setIsLoadingDelayedJob={setIsLoadingDelayedJob!}
-                isLoadingDelayedJob={isLoadingDelayedJob!}
-                setAlertTitle={setAlertTitle!}
-              />
+              <PolygonReviewTab label="" type={"sites"} />
             </MapAreaProvider>
           </TabbedShowLayout.Tab>
           <GalleryTab label="Site Gallery" entity="sites" />
@@ -46,11 +36,6 @@ const SiteShow: FC = () => {
           <AuditLogTab entity={AuditLogButtonStates.SITE} />
         </TabbedShowLayout>
       </RecordFrameworkProvider>
-      <DelayedJobsProgressAlert
-        show={isLoadingDelayedJob}
-        title={alertTitle}
-        setIsLoadingDelayedJob={setIsLoadingDelayedJob!}
-      />
     </Show>
   );
 };

src/components/elements/Map-mapbox/MapControls/CheckPolygonControl.tsx

@@ -200,6 +200,7 @@ const CheckPolygonControl = (props: CheckSitePolygonProps) => {
 
   const runFixPolygonOverlaps = () => {
     if (siteUuid) {
+      closeModal(ModalId.FIX_POLYGONS);
       setIsLoadingDelayedJob?.(true);
       setAlertTitle?.("Fix Polygons");
       clipPolygons({ pathParams: { uuid: siteUuid } });

src/components/elements/Map-mapbox/MapControls/ProcessBulkPolygonsControl.tsx

@@ -111,6 +111,7 @@ const ProcessBulkPolygonsControl = ({
           className: "px-8 py-3",
           variant: "primary",
           onClick: () => {
+            closeModal(ModalId.FIX_POLYGONS);
             setIsLoadingDelayedJob?.(true);
             setAlertTitle?.("Fix Polygons");
             fixPolygons(
@@ -124,7 +125,7 @@ const ProcessBulkPolygonsControl = ({
               {
                 onSuccess: response => {
                   const processedNames = response?.processed?.map(item => item.poly_name).join(", ");
-                  closeModal(ModalId.FIX_POLYGONS);
+
                   setIsLoadingDelayedJob?.(false);
                   ApiSlice.addTotalContent(0);
                   ApiSlice.addProgressContent(0);

src/components/elements/Notification/FloatNotification.tsx

@@ -1,8 +1,12 @@
+import { LinearProgress } from "@mui/material";
 import classNames from "classnames";
-import { useState } from "react";
+import { useEffect, useState } from "react";
 import { When } from "react-if";
 
 import Icon, { IconNames } from "@/components/extensive/Icon/Icon";
+import { triggerBulkUpdate, useDelayedJobs } from "@/connections/DelayedJob";
+import { DelayedJobData, DelayedJobDto } from "@/generated/v3/jobService/jobServiceSchemas";
+import { getErrorMessageFromPayload } from "@/utils/errors";
 
 import LinearProgressBar from "../ProgressBar/LinearProgressBar/LinearProgressBar";
 import Text from "../Text/Text";
@@ -17,8 +21,49 @@ export interface FloatNotificationProps {
   data: FloatNotificationDataProps[];
 }
 
-const FloatNotification = ({ data }: FloatNotificationProps) => {
+const FloatNotification = () => {
   const [openModalNotification, setOpenModalNotification] = useState(false);
+  const [isLoaded, { delayedJobs }] = useDelayedJobs();
+  const [notAcknowledgedJobs, setNotAcknowledgedJobs] = useState<DelayedJobDto[]>([]);
+  const clearJobs = () => {
+    if (delayedJobs === undefined) return;
+    const newJobsData: DelayedJobData[] = delayedJobs
+      .filter((job: DelayedJobDto) => job.status !== "pending")
+      .map((job: DelayedJobDto) => {
+        return {
+          uuid: job.uuid,
+          type: "delayedJobs",
+          attributes: {
+            isAcknowledged: true
+          }
+        };
+      });
+    triggerBulkUpdate(newJobsData);
+  };
+  useEffect(() => {
+    if (delayedJobs === undefined) return;
+    const notAcknowledgedJobs = delayedJobs.filter((job: DelayedJobDto) => !job.isAcknowledged);
+    setNotAcknowledgedJobs(notAcknowledgedJobs);
+  }, [delayedJobs]);
+  useEffect(() => {
+    if (!notAcknowledgedJobs.length) {
+      setOpenModalNotification(false);
+    }
+  }, [notAcknowledgedJobs]);
+  const listOfPolygonsFixed = (data: Record<string, any> | null) => {
+    if (data?.updated_polygons) {
+      const updatedPolygonNames = data.updated_polygons
+        ?.map((p: any) => p.poly_name)
+        .filter(Boolean)
+        .join(", ");
+      if (updatedPolygonNames) {
+        return "Success! The following polygons have been fixed: " + updatedPolygonNames;
+      } else {
+        return "No polygons were fixed";
+      }
+    }
+    return null;
+  };
 
   return (
     <div className="fixed bottom-10 right-10 z-50">
@@ -38,36 +83,81 @@ const FloatNotification = ({ data }: FloatNotificationProps) => {
               <Text variant="text-14-light" className="text-neutral-400">
                 Actions Taken
               </Text>
-              <Text variant="text-12-semibold" className="text-primary">
+              <Text variant="text-12-semibold" className="text-primary" onClick={clearJobs}>
                 Clear completed
               </Text>
             </div>
             <div className="-mr-2 flex flex-1 flex-col gap-3 overflow-auto pr-2">
-              {data.map((item, index) => (
-                <div key={index} className="rounded-lg border-2 border-grey-350 bg-white p-4 hover:border-primary">
-                  <div className="mb-2 flex items-center gap-1">
-                    <div className="h-2 w-2 rounded-full bg-primary" />
-                    <Text variant="text-14-light" className="leading-[normal] text-darkCustom " as={"span"}>
-                      {item.label}
-                    </Text>
-                  </div>
-                  <Text variant="text-14-light" className="text-darkCustom">
-                    Site: <b>{item.site}</b>
-                  </Text>
-                  <div className="mt-2 flex items-center gap-2">
-                    <LinearProgressBar value={parseInt(item.value)} className="h-2 bg-success-40" color="success-600" />
-                    <Text variant="text-12-semibold" className="text-black">
-                      {item.value}
+              {isLoaded &&
+                notAcknowledgedJobs &&
+                notAcknowledgedJobs.map((item, index) => (
+                  <div key={index} className="rounded-lg border-2 border-grey-350 bg-white p-4 hover:border-primary">
+                    <div className="mb-2 flex items-center gap-1">
+                      <div className="h-2 w-2 rounded-full bg-primary" />
+                      <Text variant="text-14-light" className="leading-[normal] text-darkCustom " as={"span"}>
+                        {item.name}
+                      </Text>
+                    </div>
+                    <Text variant="text-14-light" className="text-darkCustom">
+                      Site: <b>{item.entityName}</b>
                     </Text>
+                    <div className="mt-2">
+                      {item.status === "failed" ? (
+                        <Text variant="text-12-semibold" className="text-error-600">
+                          {item.payload ? getErrorMessageFromPayload(item.payload) : "Failed to complete"}
+                        </Text>
+                      ) : (
+                        <div className="flex items-center gap-2">
+                          {item.name === "Polygon Upload" &&
+                          (item.processedContent === null || item.totalContent === null) &&
+                          item.status === "pending" ? (
+                            <div style={{ width: "100%" }}>
+                              <LinearProgress
+                                sx={{
+                                  height: 9,
+                                  borderRadius: 99,
+                                  backgroundColor: "#a9e7d6",
+                                  "& .MuiLinearProgress-bar": { backgroundColor: "#29c499" }
+                                }}
+                              />
+                            </div>
+                          ) : (
+                            <LinearProgressBar
+                              value={
+                                item.status === "succeeded"
+                                  ? 100
+                                  : ((item.processedContent ?? 0) / (item.totalContent ?? 1)) * 100
+                              }
+                              className="h-2 bg-success-40"
+                              color="success-600"
+                            />
+                          )}
+                          <Text variant="text-12-semibold" className="text-black">
+                            {item.name === "Polygon Upload"
+                              ? item.status === "succeeded"
+                                ? "Done!"
+                                : ""
+                              : item.status === "succeeded"
+                              ? "Done!"
+                              : `${Math.round(((item.processedContent ?? 0) / (item.totalContent ?? 1)) * 100)}%`}
+                          </Text>
+                        </div>
+                      )}
+
+                      {item.status === "succeeded" && (
+                        <Text variant="text-12-light" className="mt-2 text-neutral-500">
+                          {listOfPolygonsFixed(item.payload)}
+                        </Text>
+                      )}
+                    </div>
                   </div>
-                </div>
-              ))}
+                ))}
             </div>
           </div>
         </div>
-        <When condition={data.length > 0}>
+        <When condition={isLoaded && (notAcknowledgedJobs ?? []).length > 0}>
           <div className="text-14-bold absolute right-[-5px] top-[-5px] z-20 flex min-h-[24px] min-w-[24px] items-center justify-center rounded-full bg-red-300 leading-[normal] text-white">
-            {data.length}
+            {notAcknowledgedJobs?.length}
           </div>
         </When>
         <button
@@ -77,8 +167,8 @@ const FloatNotification = ({ data }: FloatNotificationProps) => {
           className={classNames(
             "z-10 flex h-15 w-15 items-center justify-center rounded-full border border-grey-950 bg-primary duration-300  hover:scale-105",
             {
-              hidden: data.length < 1,
-              visible: data.length > 0
+              hidden: (notAcknowledgedJobs?.length ?? 0) === 0,
+              visible: (notAcknowledgedJobs?.length ?? 0) > 0
             }
           )}
         >

src/connections/DelayedJob.ts

@@ -0,0 +1,100 @@
+import { useEffect } from "react";
+import { createSelector } from "reselect";
+
+import { bulkUpdateJobs, listDelayedJobs } from "@/generated/v3/jobService/jobServiceComponents";
+import {
+  bulkUpdateJobsFetchFailed,
+  bulkUpdateJobsIsFetching,
+  listDelayedJobsFetchFailed
+} from "@/generated/v3/jobService/jobServicePredicates";
+import { DelayedJobData, DelayedJobDto } from "@/generated/v3/jobService/jobServiceSchemas";
+import { useConnection } from "@/hooks/useConnection";
+import { ApiDataStore } from "@/store/apiSlice";
+import { Connection } from "@/types/connection";
+import { connectionLoader } from "@/utils/connectionShortcuts";
+
+type DelayedJobsConnection = {
+  delayedJobs?: DelayedJobDto[];
+  delayedJobsIsLoading: boolean;
+  delayedJobsHasFailed: boolean;
+};
+
+const delayedJobsSelector = (store: ApiDataStore) =>
+  Object.values(store.delayedJobs ?? {}).map(resource => resource.attributes);
+
+const delayedJobsLoadFailedSelector = (store: ApiDataStore) => listDelayedJobsFetchFailed(store) != null;
+
+const delayedJobsIsLoaded = ({ delayedJobs, delayedJobsHasFailed, delayedJobsIsLoading }: DelayedJobsConnection) =>
+  delayedJobs != null || delayedJobsHasFailed;
+
+const delayedJobsConnection: Connection<DelayedJobsConnection> = {
+  load: connection => {
+    if (!delayedJobsIsLoaded(connection)) {
+      console.log("list call");
+      listDelayedJobs();
+    }
+  },
+  isLoaded: delayedJobsIsLoaded,
+  selector: createSelector(
+    [delayedJobsSelector, delayedJobsLoadFailedSelector],
+    (delayedJobs, delayedJobsHasFailed) => ({
+      delayedJobs,
+      delayedJobsIsLoading: delayedJobs == null && !delayedJobsHasFailed,
+      delayedJobsHasFailed
+    })
+  )
+};
+
+export const useDelayedJobs = () => {
+  const connection = useConnection(delayedJobsConnection);
+
+  useEffect(() => {
+    const intervalId = setInterval(() => {
+      console.log("This call");
+      listDelayedJobs();
+    }, 1500);
+
+    return () => {
+      clearInterval(intervalId);
+    };
+  }, []);
+
+  return connection;
+};
+
+type BulkUpdateJobsConnection = {
+  bulkUpdateJobsIsLoading: boolean;
+  bulkUpdateJobsHasFailed: boolean;
+  updatedJobsResponse?: DelayedJobDto[];
+};
+
+const bulkUpdateJobsSelector = (store: ApiDataStore) => ({
+  bulkUpdateJobsIsLoading: bulkUpdateJobsIsFetching(store),
+  bulkUpdateJobsHasFailed: bulkUpdateJobsFetchFailed(store) != null,
+  updatedJobsResponse: Object.values(store.delayedJobs ?? {}).map(resource => resource.attributes as DelayedJobDto)
+});
+
+const bulkUpdateJobsIsLoaded = ({ bulkUpdateJobsIsLoading, bulkUpdateJobsHasFailed }: BulkUpdateJobsConnection) =>
+  !bulkUpdateJobsIsLoading && !bulkUpdateJobsHasFailed;
+
+const bulkUpdateJobsConnection: Connection<BulkUpdateJobsConnection, { jobs: DelayedJobData[] }> = {
+  load: (connection, { jobs }) => {
+    if (!bulkUpdateJobsIsLoaded(connection)) {
+      bulkUpdateJobs({ body: { data: jobs } });
+    }
+  },
+  isLoaded: bulkUpdateJobsIsLoaded,
+  selector: createSelector(
+    bulkUpdateJobsSelector,
+    ({ bulkUpdateJobsIsLoading, bulkUpdateJobsHasFailed, updatedJobsResponse }) => ({
+      bulkUpdateJobsIsLoading,
+      bulkUpdateJobsHasFailed,
+      updatedJobsResponse
+    })
+  )
+};
+
+export const useBulkUpdateJobs = connectionLoader(bulkUpdateJobsConnection);
+
+// Function to trigger bulk update
+export const triggerBulkUpdate = (jobs: DelayedJobData[]) => bulkUpdateJobs({ body: { data: jobs } });