Merge pull request #922 from refly-ai/fix/local-storage-quota

fix: local storage quota exceeded errors

Author: mrcfps

packages/ai-workspace-common/src/components/canvas/launchpad/config-manager/index.tsx

@@ -323,17 +323,13 @@ export const ConfigManager = React.memo(
       return formErrors?.[field];
     };
 
-    console.log('tplConfig', tplConfig);
-
     // Handle initial setup - only run on mount and when tplConfig changes significantly
     useEffect(() => {
       // Skip if already initialized with this config
       if (initializedRef.current) {
         return;
       }
 
-      console.log('Initializing ConfigManager with tplConfig:', tplConfig);
-
       // Track this initialization
       initializedRef.current = true;
       prevTplConfigRef.current = tplConfig ? { ...tplConfig } : undefined;

packages/ai-workspace-common/src/components/canvas/node-chat-panel/index.tsx

@@ -264,7 +264,6 @@ export const ChatPanel = memo(
     const handleTplConfigChange = useCallback(
       (config: SkillTemplateConfig) => {
         if (setTplConfig && JSON.stringify(config) !== JSON.stringify(initialTplConfig)) {
-          console.log('Config changed:', { old: initialTplConfig, new: config });
           setTplConfig(config);
         }
       },

packages/ai-workspace-common/src/hooks/canvas/use-action-polling.ts

@@ -24,7 +24,6 @@ export const useActionPolling = () => {
     startTimeout,
     updateLastEventTime,
     clearTimeout: clearTimeoutState,
-    trackResultUsage,
   } = useActionResultStoreShallow((state) => ({
     startPolling: state.startPolling,
     stopPolling: state.stopPolling,
@@ -34,7 +33,6 @@ export const useActionPolling = () => {
     startTimeout: state.startTimeout,
     updateLastEventTime: state.updateLastEventTime,
     clearTimeout: state.clearTimeout,
-    trackResultUsage: state.trackResultUsage,
   }));
 
   const onUpdateResult = useUpdateActionResult();
@@ -61,9 +59,6 @@ export const useActionPolling = () => {
       }
 
       try {
-        // Track result usage when polling to keep it in the recent list
-        trackResultUsage(resultId);
-
         const { data: result } = await getClient().getActionResult({
           query: { resultId, version },
         });
@@ -120,14 +115,7 @@ export const useActionPolling = () => {
         }, POLLING_INTERVAL);
       }
     },
-    [
-      incrementErrorCount,
-      resetErrorCount,
-      stopPolling,
-      onUpdateResult,
-      updateLastPollTime,
-      trackResultUsage,
-    ],
+    [incrementErrorCount, resetErrorCount, stopPolling, onUpdateResult, updateLastPollTime],
   );
 
   const startPolling = useCallback(
@@ -136,9 +124,6 @@ export const useActionPolling = () => {
       const pollingState = pollingStateMap[resultId];
       const currentResult = resultMap[resultId];
 
-      // Track result usage when starting polling to ensure it's kept in storage
-      trackResultUsage(resultId);
-
       // Don't restart polling for results that are already marked as failed
       if (failedResultIds.has(resultId) || currentResult?.status === 'failed') {
         return;
@@ -154,17 +139,12 @@ export const useActionPolling = () => {
       // Start the polling cycle
       await pollActionResult(resultId, version);
     },
-    [clearTimeoutState, startPollingState, pollActionResult, trackResultUsage],
+    [clearTimeoutState, startPollingState, pollActionResult],
   );
 
-  const resetFailedState = useCallback(
-    (resultId: string) => {
-      failedResultIds.delete(resultId);
-      // Track usage when resetting failed state
-      trackResultUsage(resultId);
-    },
-    [trackResultUsage],
-  );
+  const resetFailedState = useCallback((resultId: string) => {
+    failedResultIds.delete(resultId);
+  }, []);
 
   // Cleanup all polling on unmount
   useEffect(() => {
@@ -177,19 +157,13 @@ export const useActionPolling = () => {
     (resultId: string, version: number) => {
       let timeoutId: NodeJS.Timeout;
 
-      // Track result usage to ensure it's kept in storage
-      trackResultUsage(resultId);
-
       const resetTimeout = () => {
         if (timeoutId) {
           clearTimeout(timeoutId);
         }
 
         updateLastEventTime(resultId);
 
-        // Track usage when timeout is reset
-        trackResultUsage(resultId);
-
         timeoutId = setTimeout(() => {
           const result = useActionResultStore.getState().resultMap[resultId];
 
@@ -220,14 +194,7 @@ export const useActionPolling = () => {
         },
       };
     },
-    [
-      startTimeout,
-      updateLastEventTime,
-      startPolling,
-      clearTimeoutState,
-      stopPolling,
-      trackResultUsage,
-    ],
+    [startTimeout, updateLastEventTime, startPolling, clearTimeoutState, stopPolling],
   );
 
   return {

packages/ai-workspace-common/src/hooks/canvas/use-debounced-context-update.ts

@@ -95,8 +95,6 @@ export const useContextUpdateByResultId = ({
   const updateContextItemsFromResultId = useCallback(() => {
     if (!resultId) return;
 
-    console.log('updateContextItemsFromResultId', resultId);
-
     // Find the node associated with this resultId
     const nodes = getNodes();
     const currentNode = nodes.find(

packages/ai-workspace-common/src/hooks/canvas/use-find-thread-history.ts

@@ -23,18 +23,6 @@ export const useFindThreadHistory = () => {
 
       const edges = getEdges();
 
-      console.log('startNode', startNode);
-
-      // Create a more detailed mapping for debugging
-      const allConnections = edges.map((edge) => ({
-        source: edge.source,
-        target: edge.target,
-        sourceNode: getNode(edge.source),
-        targetNode: getNode(edge.target),
-      }));
-
-      console.log('All connections:', allConnections);
-
       // Create two maps to handle bidirectional traversal if needed
       const targetToSourceMap = new Map();
       const sourceToTargetsMap = new Map();
@@ -53,9 +41,6 @@ export const useFindThreadHistory = () => {
         sourceToTargetsMap.get(edge.source).push(edge.target);
       }
 
-      // For debugging
-      console.log('Target to Source Map:', [...targetToSourceMap.entries()]);
-
       const history = [startNode];
       const visited = new Set<string>();
 
@@ -68,7 +53,6 @@ export const useFindThreadHistory = () => {
         const sourceIds = targetToSourceMap.get(nodeId) || [];
         for (const sourceId of sourceIds) {
           const sourceNode = getNode(sourceId);
-          console.log('Exploring source node:', sourceId, sourceNode?.type);
 
           if (sourceNode?.type === 'skillResponse') {
             // Only add if not already in history
@@ -84,15 +68,6 @@ export const useFindThreadHistory = () => {
       // Start the recursive search from the start node
       findSourceNodes(startNode.id);
 
-      console.log(
-        'Found history nodes:',
-        history.map((node) => ({
-          id: node.id,
-          type: node.type,
-          entityId: node.data?.entityId,
-        })),
-      );
-
       // Return nodes in reverse order (oldest to newest)
       return history.reverse();
     },