fix(sidebar): cover v1 workflow import fan-out and scope folder invalidation per review

Author: waleedlatif1

apps/sim/app/api/v1/workflows/import/route.test.ts

@@ -24,6 +24,7 @@ const {
   mockDbDelete,
   mockDbUpdate,
   mockWorkspaceRows,
+  mockNotifyWorkspaceWorkflowsChanged,
 } = vi.hoisted(() => ({
   mockCheckRateLimit: vi.fn(),
   mockValidateWorkspaceAccess: vi.fn(),
@@ -37,6 +38,7 @@ const {
   mockDbDelete: vi.fn(),
   mockDbUpdate: vi.fn(),
   mockWorkspaceRows: { value: [{ id: 'ws-1' }] as Array<{ id: string }> },
+  mockNotifyWorkspaceWorkflowsChanged: vi.fn(),
 }))
 
 vi.mock('@/app/api/v1/middleware', () => ({
@@ -53,6 +55,10 @@ vi.mock('@/lib/workflows/orchestration', () => ({
   performCreateWorkflow: mockPerformCreateWorkflow,
 }))
 
+vi.mock('@/lib/realtime/notify', () => ({
+  notifyWorkspaceWorkflowsChanged: mockNotifyWorkspaceWorkflowsChanged,
+}))
+
 vi.mock('@/lib/workflows/persistence/utils', () => ({
   saveWorkflowToNormalizedTables: mockSaveWorkflowToNormalizedTables,
 }))
@@ -270,6 +276,7 @@ describe('POST /api/v1/workflows/import', () => {
       expect.anything(),
       expect.anything()
     )
+    expect(mockNotifyWorkspaceWorkflowsChanged).toHaveBeenCalledWith(WORKSPACE_ID)
   })
 
   it('derives the name from the export envelope and deduplicates it', async () => {

apps/sim/app/api/v1/workflows/import/route.ts

@@ -8,6 +8,7 @@ import {
 } from '@/lib/api/contracts/v1/workflows'
 import { parseRequest } from '@/lib/api/server'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
+import { notifyWorkspaceWorkflowsChanged } from '@/lib/realtime/notify'
 import {
   importWorkflowIntoWorkspace,
   MAX_IMPORT_BODY_BYTES,
@@ -82,6 +83,8 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
       )
     }
 
+    await notifyWorkspaceWorkflowsChanged(result.workflow.workspaceId)
+
     const data: V1ImportWorkflowData = {
       id: result.workflow.id,
       name: result.workflow.name,

apps/sim/app/workspace/[workspaceId]/w/components/sidebar/hooks/use-workspace-workflows-room.ts

@@ -13,14 +13,17 @@ import { invalidateWorkflowLists } from '@/hooks/queries/utils/invalidate-workfl
  * workflow lists AND the workflow folders so every viewer refetches without waiting for staleness.
  * A created/renamed/moved/deleted/duplicated/imported/restored/reordered workflow changes the list
  * result; a folder create/rename/delete/restore changes the folder tree — the sidebar renders both,
- * so both are invalidated. Lists go through {@link invalidateWorkflowLists} (both scopes, plus the
- * workflow selectors) so a remote change refreshes exactly what a local mutation would. Thin
- * binding over {@link useWorkspaceInvalidationRoom}, mirroring `useWorkspaceTablesRoom`.
+ * so both are invalidated — each scoped to this workspace, in both scopes, so one workspace's
+ * broadcast never touches another workspace's cache. Lists go through
+ * {@link invalidateWorkflowLists} (which also covers the workflow selectors) so a remote change
+ * refreshes exactly what a local mutation would. Thin binding over
+ * {@link useWorkspaceInvalidationRoom}, mirroring `useWorkspaceTablesRoom`.
  */
 export function useWorkspaceWorkflowsRoom(workspaceId: string): void {
   const queryClient = useQueryClient()
   useWorkspaceInvalidationRoom(workspaceId, ROOM_TYPES.WORKSPACE_WORKFLOWS, () => {
     invalidateWorkflowLists(queryClient, workspaceId, ['active', 'archived'])
-    queryClient.invalidateQueries({ queryKey: folderKeys.resource('workflow') })
+    queryClient.invalidateQueries({ queryKey: folderKeys.list(workspaceId, 'active') })
+    queryClient.invalidateQueries({ queryKey: folderKeys.list(workspaceId, 'archived') })
   })
 }

apps/sim/lib/workflows/application/import-export.test.ts

@@ -158,6 +158,7 @@ describe('workflow import and export application operations', () => {
         }),
       })
     )
+    expect(mocks.notifyWorkspace).toHaveBeenCalledWith('ws-1')
   })
 
   it('preserves classified import details and does not audit a failure', async () => {

apps/sim/lib/workflows/application/restore-workflow.test.ts

@@ -91,6 +91,8 @@ describe('restoreWorkflow', () => {
       })
     )
     expect(mocks.recordAudit).toHaveBeenCalledBefore(mocks.notify)
+    expect(mocks.notify).toHaveBeenCalledWith('workflow-1')
+    expect(mocks.notifyWorkspace).toHaveBeenCalledWith('workspace-1')
   })
 
   it('refuses a workflow that is not archived as a conflict', async () => {