refactor(backend,taxonomy-editor-frontend): Handle background task on…

… frontend

backend/editor/api.py

@@ -120,6 +120,8 @@ class StatusFilter(str, Enum):
 
     OPEN = "OPEN"
     CLOSED = "CLOSED"
+    LOADING = "LOADING"
+    FAILED = "FAILED"
 
 
 @app.exception_handler(RequestValidationError)

backend/editor/entries.py

@@ -1,6 +1,7 @@
 """
 Database helper functions for API
 """
+import asyncio
 import re
 import shutil
 import tempfile
@@ -119,6 +120,10 @@ def parse_taxonomy(self, uploadfile=None):
                     except Exception as e:
                         raise TaxonomyParsingError() from e
         except Exception as e:
+            # async with TransactionCtx():
+            #     await self.set_project_status(status="FAILED")
+            # Call the asynchronous function to update status without awaiting it
+            asyncio.create_task(self.set_project_status_async(status="FAILED"))
             raise TaxonomyImportError() from e
 
     async def import_from_github(self, description, background_tasks: BackgroundTasks):
@@ -128,6 +133,9 @@ async def import_from_github(self, description, background_tasks: BackgroundTask
         # Close current transaction to use the session variable in parser
         await get_current_transaction().commit()
 
+        async with TransactionCtx():
+            await self.create_project(description)  # Creates a "project node" in neo4j
+
         # Add the task to background tasks
         background_tasks.add_task(self.parse_taxonomy)
         print("Background task added")
@@ -148,6 +156,9 @@ async def upload_taxonomy(
         # Close current transaction to use the session variable in parser
         await get_current_transaction().commit()
         try:
+            async with TransactionCtx():
+                await self.create_project(description)
+
             # Add the task to background tasks
             background_tasks.add_task(self.parse_taxonomy, uploadfile)
             print("Background task added")
@@ -263,10 +274,14 @@ async def create_project(self, description):
             "taxonomy_name": self.taxonomy_name,
             "branch_name": self.branch_name,
             "description": description,
-            "status": "OPEN",
+            "status": "LOADING",
         }
         await get_current_transaction().run(query, params)
 
+    async def set_project_status_async(self, status):
+        async with TransactionCtx():
+            await self.set_project_status(status=status)
+
     async def set_project_status(self, status):
         """
         Helper function to update a Taxonomy Editor project status

taxonomy-editor-frontend/src/pages/go-to-project/index.tsx

@@ -29,22 +29,30 @@ const GoToProject = ({ clearNavBarLinks }: Props) => {
   const navigate = useNavigate();
 
   const { data, isPending, isError } = useFetch<ProjectsAPIResponse>(
-    `${API_URL}projects?status=OPEN`
+    `${API_URL}projects`
   );
 
   useEffect(() => {
     let newProjects: ProjectType[] = [];
 
     if (data) {
       const backendProjects = data.map(
-        ({ id, branch_name, taxonomy_name, description, errors_count }) => {
+        ({
+          id,
+          branch_name,
+          taxonomy_name,
+          description,
+          errors_count,
+          status,
+        }) => {
           return {
             id, // needed by MaterialTable as key
             projectName: id,
             taxonomyName: toTitleCase(taxonomy_name),
             branchName: branch_name,
             description: description,
             errors_count: errors_count,
+            status: status,
           };
         }
       );
@@ -117,6 +125,7 @@ const GoToProject = ({ clearNavBarLinks }: Props) => {
                 }
               },
             },
+            { title: "Status", field: "status" },
           ]}
           options={{
             actionsColumnIndex: -1,

taxonomy-editor-frontend/src/pages/root-nodes/index.tsx

@@ -84,7 +84,7 @@ const RootNodes = ({
     );
   }
 
-  if (isPending || !nodes) {
+  if (isPending || !nodes || nodes.length === 0) {
     return (
       <Box
         sx={{
@@ -93,6 +93,12 @@ const RootNodes = ({
         }}
       >
         <CircularProgress />
+        <Typography sx={{ m: 5 }} variant="h6">
+          Taxonomy parsing may take several minutes, depending on the complexity
+          of the taxonomy being imported.
+          <br />
+          Kindly refresh the page to view the updated status of the project.
+        </Typography>
       </Box>
     );
   }

taxonomy-editor-frontend/src/pages/startproject/index.tsx

@@ -42,6 +42,7 @@ const StartProject = ({ clearNavBarLinks }) => {
     const baseUrl = createBaseURL(toSnakeCase(taxonomyName), branchName);
     setLoading(true);
     const dataToBeSent = { description: description };
+    let errorMessage: string = "Unable to import";
 
     fetch(`${baseUrl}import`, {
       method: "POST",
@@ -51,12 +52,13 @@ const StartProject = ({ clearNavBarLinks }) => {
       .then(async (response) => {
         const responseBody = await response.json();
         if (!response.ok) {
-          throw new Error(responseBody?.detail ?? "Unable to import");
+          errorMessage = responseBody?.detail ?? "Unable to import";
+          throw new Error(errorMessage);
         }
         navigate(`/${toSnakeCase(taxonomyName)}/${branchName}/entry`);
       })
       .catch(() => {
-        setErrorMessage("Unable to import");
+        setErrorMessage(errorMessage);
       })
       .finally(() => setLoading(false));
   };