Fix for bug 23829

Author: NirajC-Microsoft

src/frontend/src/components/content/PlanPanelLeft.tsx

@@ -60,17 +60,29 @@ const PlanPanelLeft: React.FC<PlanPanelLefProps> = ({
       console.log("Loading plans, forceRefresh:", forceRefresh);
       setPlansLoading(true);
       setPlansError(null);
-      const plansData = await apiService.getPlans(undefined, forceRefresh);
+      const plansData = await apiService.getPlans(undefined, !forceRefresh); // Invert forceRefresh for useCache
       setPlans(plansData);
+      
+      // Reset the reload flag after successful load
+      if (forceRefresh && restReload) {
+        console.log("Plans loaded successfully, resetting reload flag");
+        restReload();
+      }
     } catch (error) {
       console.log("Failed to load plans:", error);
       setPlansError(
         error instanceof Error ? error : new Error("Failed to load plans")
       );
+      
+      // Reset the reload flag even on error to prevent infinite loops
+      if (forceRefresh && restReload) {
+        console.log("Plans load failed, resetting reload flag");
+        restReload();
+      }
     } finally {
       setPlansLoading(false);
     }
-  }, []);
+  }, [restReload]);
 
 
   // Fetch plans
@@ -85,7 +97,7 @@ const PlanPanelLeft: React.FC<PlanPanelLefProps> = ({
   useEffect(() => {
     console.log("Reload tasks changed:", reloadTasks);
     if (reloadTasks) {
-      loadPlansData();
+      loadPlansData(true); // Force refresh when reloadTasks is true
     }
   }, [loadPlansData, setUserInfo, reloadTasks]);
   useEffect(() => {

src/frontend/src/pages/PlanPage.tsx

@@ -132,19 +132,38 @@ const PlanPage: React.FC = () => {
         // Persist / forward to backend (fire-and-forget with logging)
         const agentMessageResponse = PlanDataService.createAgentMessageResponse(agentMessageData, planData, is_final, streaming_message);
         console.log('📤 Persisting agent message:', agentMessageResponse);
-        void apiService.sendAgentMessage(agentMessageResponse)
+        const sendPromise = apiService.sendAgentMessage(agentMessageResponse)
             .then(saved => {
                 console.log('[agent_message][persisted]', {
                     agent: agentMessageData.agent,
                     type: agentMessageData.agent_type,
                     ts: agentMessageData.timestamp
                 });
+                
+                // If this is a final message, refresh the task list after successful persistence
+                if (is_final) {
+                    // Single refresh with a delay to ensure backend processing is complete
+                    setTimeout(() => {
+                        console.log('✅ Final message persisted, forcing task list refresh');
+                        setReloadLeftList(true);
+                    }, 1000);
+                }
             })
             .catch(err => {
                 console.warn('[agent_message][persist-failed]', err);
+                // Even if persistence fails, still refresh the task list for final messages
+                // The local plan data has been updated, so the UI should reflect that
+                if (is_final) {
+                    setTimeout(() => {
+                        console.log('⚠️ Final message persistence failed, but still forcing task list refresh');
+                        setReloadLeftList(true);
+                    }, 1000);
+                }
             });
 
-    }, []);
+        return sendPromise;
+
+    }, [setReloadLeftList]);
 
     const resetPlanVariables = useCallback(() => {
         setInput("");
@@ -335,20 +354,17 @@ const PlanPage: React.FC = () => {
                     setPlanData({ ...planData });
                 }
 
+                // Wait for the agent message to be processed and persisted
+                // The processAgentMessage function will handle refreshing the task list
                 processAgentMessage(agentMessageData, planData, is_final, streamingMessageBuffer);
 
-                setTimeout(() => {
-                    console.log('✅ Plan completed, refreshing left list');
-                    setReloadLeftList(true);
-                }, 1000);
-
             }
 
 
         });
 
         return () => unsubscribe();
-    }, [scrollToBottom, planData, processAgentMessage, streamingMessageBuffer, setSelectedTeam, setReloadLeftList]);
+    }, [scrollToBottom, planData, processAgentMessage, streamingMessageBuffer, setSelectedTeam]);
 
     //WebsocketMessageType.AGENT_MESSAGE
     useEffect(() => {