Remove SSE for now

app.py

@@ -92,18 +92,8 @@ def index_tdocs_wg_progress(req: IndexTDoc):
     folder = meetings_mapping[category][wg_number]
     url = f"https://www.3gpp.org/ftp/{meetings_mapping[category][0]}"
 
-    def generate_events():
-        tdoc_indexer.processed_count = 0   # Reset progress
-        tdoc_indexer.total_count = 0
-        tdoc_indexer.process_workgroup(folder, url)
-        
-        while tdoc_indexer.processed_count < tdoc_indexer.total_count:
-            yield f"data: {tdoc_indexer.processed_count}/{tdoc_indexer.total_count}"
-            import time; time.sleep(0.2)
-        # Pour afficher la fin de l’indexation
-        yield f"data: {tdoc_indexer.total_count}/{tdoc_indexer.total_count}"
-
-    return StreamingResponse(generate_events(), media_type="text/event-stream")
+    tdoc_indexer.process_workgroup(folder, url)
+    return {"status": "OK"}
 
 @app.post("/index_tdocs/meeting")
 def index_tdocs_meeting_progress(req: IndexTDoc):
@@ -115,67 +105,28 @@ def index_tdocs_meeting_progress(req: IndexTDoc):
     category, wg_number = get_folder_name(req.wg)
     folder = meetings_mapping[category][wg_number]
     url = f"https://www.3gpp.org/ftp/{meetings_mapping[category][0]}/{folder}"
-    
-    def generate_events():
-        tdoc_indexer.processed_count = 0
-        tdoc_indexer.total_count = len(req.meetings)
-        for i, meet in enumerate(req.meetings):
-            tdoc_indexer.process_meeting(meet, url)
-            yield f"data: {i+1}/{tdoc_indexer.total_count}"
-        tdoc_indexer.save_indexer()
-    return StreamingResponse(generate_events(), media_type="text/event-stream")
+    for i, meet in enumerate(req.meetings):
+        tdoc_indexer.process_meeting(meet, url)
+    tdoc_indexer.save_indexer()
+    return {"status": "OK"}
 
 
 @app.post("/index_tdocs/all")
 def index_all_tdocs_progress():
-    def generate_events():
-        tdoc_indexer.processed_count = 0
-        tdoc_indexer.total_count = 0
-        # On lance l’indexation (la méthode met à jour les compteurs)
-        tdoc_indexer.index_all_tdocs()
-        while tdoc_indexer.processed_count < tdoc_indexer.total_count:
-            yield f"data: {tdoc_indexer.processed_count}/{tdoc_indexer.total_count}"
-            import time; time.sleep(0.2)
-        yield f"data: {tdoc_indexer.total_count}/{tdoc_indexer.total_count}"
-    return StreamingResponse(generate_events(), media_type="text/event-stream")
+    tdoc_indexer.index_all_tdocs()
+    return {"status": "OK"}
 
 
 @app.post("/index_specs/3gpp")
 def index_3gpp_specs_progress():
-    def generate_events():
-        spec_3gpp_indexer.processed_count = 0
-        spec_3gpp_indexer.total_count = 0
-        import threading
-
-        def worker():
-            spec_3gpp_indexer.run()
-            spec_3gpp_indexer.save()
-            spec_3gpp_indexer.create_bm25_index()
-
-        t = threading.Thread(target=worker)
-        t.start()
-        while t.is_alive() or spec_3gpp_indexer.processed_count < spec_3gpp_indexer.total_count:
-            yield f"data: {spec_3gpp_indexer.processed_count}/{spec_3gpp_indexer.total_count}"
-            import time; time.sleep(0.5)
-        yield f"data: {spec_3gpp_indexer.total_count}/{spec_3gpp_indexer.total_count}"
-    return StreamingResponse(generate_events(), media_type="text/event-stream")
+    spec_3gpp_indexer.run()
+    spec_3gpp_indexer.save()
+    spec_3gpp_indexer.create_bm25_index()
+    return {"status": "OK"}
 
 @app.post("/index_specs/etsi")
 def index_etsi_specs_progress():
-    def generate_events():
-        spec_etsi_indexer.processed_count = 0
-        spec_etsi_indexer.total_count = 0
-        import threading
-
-        def worker():
-            spec_etsi_indexer.run()
-            spec_etsi_indexer.save()
-            spec_etsi_indexer.create_bm25_index()
-
-        t = threading.Thread(target=worker)
-        t.start()
-        while t.is_alive() or spec_etsi_indexer.processed_count < spec_etsi_indexer.total_count:
-            yield f"data: {spec_etsi_indexer.processed_count}/{spec_etsi_indexer.total_count}"
-            import time; time.sleep(0.5)
-        yield f"data: {spec_etsi_indexer.total_count}/{spec_etsi_indexer.total_count}"
-    return StreamingResponse(generate_events(), media_type="text/event-stream")
+    spec_etsi_indexer.run()
+    spec_etsi_indexer.save()
+    spec_etsi_indexer.create_bm25_index()
+    return {"status": "OK"}

index.html

@@ -319,14 +319,14 @@ function updateDropbtnLabel() {
         fetch("/index_tdocs/meeting", {method: "POST", headers: {"Content-Type": "application/json"}, body: JSON.stringify({wg: document.getElementById("tdocs-wg-option").value, meetings: selectedMeetings})})
         .then(resp => resp.text())
         .then(data => {
-          logMessage(`${data}`)
+          logMessage("Index successful")
           enableButtons()
         })
       } else {
         fetch("/index_tdocs/working_group", {method: "POST", headers: {"Content-Type": "application/json"}, body: JSON.stringify({wg: document.getElementById("tdocs-wg-option").value})})
         .then(resp => resp.text())
         .then(data => {
-          logMessage(`${data}`)
+          logMessage("Index successful")
           enableButtons()
         })
       }
@@ -334,7 +334,7 @@ function updateDropbtnLabel() {
       fetch("/index_tdocs/all", {method: "POST", headers: {"Content-Type": "application/json"}})
         .then(resp => resp.text())
         .then(data => {
-          logMessage(`${data}`)
+          logMessage("Index successful")
           enableButtons()
         })
     }
@@ -346,7 +346,7 @@ function updateDropbtnLabel() {
     fetch("/index_specs/3gpp", {method: "POST", headers: {"Content-Type": "application/json"}})
       .then(resp => resp.text())
       .then(data => {
-        logMessage(`${data}`)
+        logMessage("Index successful")
         enableButtons()
       })
   });
@@ -357,7 +357,7 @@ function updateDropbtnLabel() {
     fetch("/index_specs/etsi", {method: "POST", headers: {"Content-Type": "application/json"}})
       .then(resp => resp.text())
       .then(data => {
-        logMessage(`${data}`)
+        logMessage("Index successful")
         enableButtons()
       })
   });