@@ -368,11 +368,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
368368 eventHandlers . current . workflowReverted ?.( data )
369369 } )
370370
371- const rehydrateWorkflowStores = async (
372- workflowId : string ,
373- workflowState : any ,
374- source : 'copilot' | 'workflow-state'
375- ) => {
371+ const rehydrateWorkflowStores = async ( workflowId : string , workflowState : any ) => {
376372 const [
377373 { useOperationQueueStore } ,
378374 { useWorkflowRegistry } ,
@@ -397,7 +393,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
397393 . getState ( )
398394 . operations . some ( ( op : any ) => op . workflowId === workflowId && op . status !== 'confirmed' )
399395 if ( hasPending ) {
400- logger . info ( ` Skipping ${ source } rehydration due to pending operations in queue` )
396+ logger . info ( ' Skipping rehydration due to pending operations in queue' )
401397 return false
402398 }
403399
@@ -426,32 +422,10 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
426422 } ,
427423 } ) )
428424
429- logger . info ( ` Successfully rehydrated stores from ${ source } ` )
425+ logger . info ( ' Successfully rehydrated workflow stores' )
430426 return true
431427 }
432428
433- socketInstance . on ( 'copilot-workflow-edit' , async ( data ) => {
434- logger . info (
435- `Copilot edited workflow ${ data . workflowId } - rehydrating stores from database`
436- )
437-
438- try {
439- const response = await fetch ( `/api/workflows/${ data . workflowId } ` )
440- if ( response . ok ) {
441- const responseData = await response . json ( )
442- const workflowData = responseData . data
443-
444- if ( workflowData ?. state ) {
445- await rehydrateWorkflowStores ( data . workflowId , workflowData . state , 'copilot' )
446- }
447- } else {
448- logger . error ( 'Failed to fetch fresh workflow state:' , response . statusText )
449- }
450- } catch ( error ) {
451- logger . error ( 'Failed to rehydrate stores after copilot edit:' , error )
452- }
453- } )
454-
455429 socketInstance . on ( 'operation-confirmed' , ( data ) => {
456430 logger . debug ( 'Operation confirmed' , { operationId : data . operationId } )
457431 eventHandlers . current . operationConfirmed ?.( data )
@@ -522,7 +496,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
522496
523497 if ( workflowData ?. state ) {
524498 try {
525- await rehydrateWorkflowStores ( workflowData . id , workflowData . state , 'workflow-state' )
499+ await rehydrateWorkflowStores ( workflowData . id , workflowData . state )
526500 } catch ( error ) {
527501 logger . error ( 'Error rehydrating workflow state:' , error )
528502 }
0 commit comments