refactor(ipc): import worktree, watcher and runtime-environment helpers from their owning modules

src/main/agent-hooks/first-work-branch-rename-wsl-move.test.ts

@@ -26,7 +26,7 @@ vi.mock('../text-generation/commit-message-text-generation', () => ({
 vi.mock('../text-generation/commit-message-agent-environment', () => ({
   prepareLocalCommitMessageAgentEnv: vi.fn(async () => ({ ok: true }))
 }))
-vi.mock('../ipc/worktree-logic', () => ({
+vi.mock('../ipc/worktree-branch-name', () => ({
   computeBranchName: vi.fn((leaf: string) => `you/${leaf}`),
   getConfiguredBranchPrefix: vi.fn(() => 'you')
 }))

src/main/agent-hooks/first-work-branch-rename.test.ts

@@ -35,7 +35,7 @@ vi.mock('../text-generation/commit-message-text-generation', () => ({
 vi.mock('../text-generation/commit-message-agent-environment', () => ({
   prepareLocalCommitMessageAgentEnv: prepareLocalEnvMock
 }))
-vi.mock('../ipc/worktree-logic', () => ({
+vi.mock('../ipc/worktree-branch-name', () => ({
   computeBranchName: computeBranchNameMock,
   getConfiguredBranchPrefix: getConfiguredBranchPrefixMock
 }))

src/main/agent-hooks/first-work-branch-rename.ts

@@ -11,7 +11,7 @@ import {
   stripConfiguredBranchPrefix
 } from '../../shared/branch-name-from-work'
 import { getCommitMessageModelDiscoveryHostKey } from '../../shared/commit-message-host-key'
-import { computeBranchName, getConfiguredBranchPrefix } from '../ipc/worktree-logic'
+import { computeBranchName, getConfiguredBranchPrefix } from '../ipc/worktree-branch-name'
 import { gitExecFileAsync } from '../git/runner'
 import { resolveLocalGitUsername } from '../git/git-username'
 import { resolveGitRouteForHost } from '../providers/execution-host-provider-dispatch'

src/main/ipc/filesystem-watcher-document-lifetime.test.ts

@@ -34,14 +34,16 @@ import {
 import { getLocalWatcherRoot, getRemoteWatcherKey } from './filesystem-watcher-paths'
 import { reinstallRemoteWatchersForConnection } from './filesystem-watcher-remote-controller'
 import { reinstallRemoteWatchersForConnectionCore } from './filesystem-watcher-remote-provider-rearm'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
 import {
-  registerFilesystemWatcherHandlers,
-  closeAllWatchers,
   closeLocalWatcherForWorktreePath,
+  restoreLocalWatcherAfterFailedRemoval
+} from './filesystem-watcher-local-removal'
+import {
   closeRemoteWatcherForWorktreePath,
-  restoreLocalWatcherAfterFailedRemoval,
   restoreRemoteWatcherAfterFailedRemoval
-} from './filesystem-watcher'
+} from './filesystem-watcher-remote-removal'
 
 const handlers = new Map<string, (event: { sender: Sender }, args: WatchArgs) => Promise<void>>()
 function invoke(channel: string, sender: Sender, args: WatchArgs): Promise<void> {

src/main/ipc/filesystem-watcher-dormant-rearm.test.ts

@@ -21,7 +21,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   }
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 
 type HandlerMap = Record<string, (_event: unknown, args: unknown) => unknown>
 

src/main/ipc/filesystem-watcher-large-batch.test.ts

@@ -29,7 +29,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import { stat } from 'node:fs/promises'
 import { subscribe as subscribeParcelWatcher } from '@parcel/watcher'
 import type { Event as WatcherEvent } from '@parcel/watcher'

src/main/ipc/filesystem-watcher-local-unsubscribe.test.ts

@@ -37,12 +37,12 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
 import {
-  closeAllWatchers,
   closeLocalWatcherForWorktreePath,
-  registerFilesystemWatcherHandlers,
   restoreLocalWatcherAfterFailedRemoval
-} from './filesystem-watcher'
+} from './filesystem-watcher-local-removal'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import { stat } from 'node:fs/promises'
 import { subscribe as subscribeParcelWatcher } from '@parcel/watcher'
 import { subscribeViaWatcherProcess } from './parcel-watcher-process'

src/main/ipc/filesystem-watcher-native-capacity.test.ts

@@ -21,7 +21,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import {
   MAX_PHYSICAL_WATCHER_CHILDREN,
   reserveWatcherChild,

src/main/ipc/filesystem-watcher-real.test.ts

@@ -25,7 +25,8 @@ vi.mock('electron', () => ({
   ipcMain: { handle: handleMock }
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import {
   createAliasedWatcherRoot,
   removeAliasedWatcherRoot,

src/main/ipc/filesystem-watcher-remote-batch.test.ts

@@ -22,7 +22,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   }
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 
 type HandlerMap = Record<string, (_event: unknown, args: unknown) => unknown>
 type WatchCallback = (events: FsChangeEvent[]) => void

src/main/ipc/filesystem-watcher-remote-cancellation.test.ts

@@ -18,7 +18,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 
 type HandlerMap = Record<string, (_event: unknown, args: unknown) => unknown>
 

src/main/ipc/filesystem-watcher-remote-capacity.test.ts

@@ -19,7 +19,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
 }))
 
 import { WATCH_ROOT_CAPACITY_REFUSAL_MESSAGE } from '../../shared/watch-root-capacity-refusal'
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import { watcherLifecycleState } from './filesystem-watcher-lifecycle-state'
 import { getRemoteWatcherKey } from './filesystem-watcher-paths'
 

src/main/ipc/filesystem-watcher-remote-rearm.test.ts

@@ -28,7 +28,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   }
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 
 type HandlerMap = Record<string, (_event: unknown, args: unknown) => unknown>
 

src/main/ipc/filesystem-watcher-removal-deadline.test.ts

@@ -37,11 +37,9 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
-import {
-  closeAllWatchers,
-  closeLocalWatcherForWorktreePath,
-  registerFilesystemWatcherHandlers
-} from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { closeLocalWatcherForWorktreePath } from './filesystem-watcher-local-removal'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import {
   createWatcherRemovalDeadline,
   drainBeforeWatcherRemoval,

src/main/ipc/filesystem-watcher-terminal-resync.test.ts

@@ -20,13 +20,13 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   }
 }))
 
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
 import {
-  closeAllWatchers,
   closeRemoteWatcherForWorktreePath,
   forgetRemoteWatcherRemovalSnapshot,
-  registerFilesystemWatcherHandlers,
   restoreRemoteWatcherAfterFailedRemoval
-} from './filesystem-watcher'
+} from './filesystem-watcher-remote-removal'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 
 type HandlerMap = Record<string, (_event: unknown, args: unknown) => unknown>
 type TerminalErrorHandler = (error: Error) => void

src/main/ipc/filesystem-watcher-unwatchable-roots.test.ts

@@ -29,7 +29,8 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   onSshFilesystemProviderRegistered: () => () => {}
 }))
 
-import { closeAllWatchers, registerFilesystemWatcherHandlers } from './filesystem-watcher'
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import { stat } from 'node:fs/promises'
 import { watcherLifecycleState } from './filesystem-watcher-lifecycle-state'
 

src/main/ipc/filesystem-watcher.test.ts

@@ -42,13 +42,13 @@ vi.mock('../providers/ssh-filesystem-dispatch', () => ({
   }
 }))
 
+import { closeAllWatchers } from './filesystem-watcher-shutdown'
 import {
-  closeAllWatchers,
   closeRemoteWatcherForWorktreePath,
   forgetRemoteWatcherRemovalSnapshot,
-  registerFilesystemWatcherHandlers,
   restoreRemoteWatcherAfterFailedRemoval
-} from './filesystem-watcher'
+} from './filesystem-watcher-remote-removal'
+import { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
 import { stat } from 'node:fs/promises'
 import { subscribe as subscribeParcelWatcher } from '@parcel/watcher'
 import { createWslWatcher } from './filesystem-watcher-wsl'

src/main/ipc/filesystem-watcher.ts

@@ -10,15 +10,6 @@ import {
   restoreRemoteWatcherAfterFailedRemoval
 } from './filesystem-watcher-remote-removal'
 
-export { closeLocalWatcherForWorktreePath } from './filesystem-watcher-local-removal'
-export { restoreLocalWatcherAfterFailedRemoval } from './filesystem-watcher-local-removal'
-export { forgetLocalWatcherRemovalSnapshot } from './filesystem-watcher-local-removal'
-export { closeRemoteWatcherForWorktreePath } from './filesystem-watcher-remote-removal'
-export { restoreRemoteWatcherAfterFailedRemoval } from './filesystem-watcher-remote-removal'
-export { forgetRemoteWatcherRemovalSnapshot } from './filesystem-watcher-remote-removal'
-export { registerFilesystemWatcherHandlers } from './filesystem-watcher-handlers'
-export { closeAllWatchers } from './filesystem-watcher-shutdown'
-
 // ── Public API ───────────────────────────────────────────────────────
 
 /** The desktop binding for {@link WorktreeWatcherRemoval}. Installed during startup. */

src/main/ipc/folder-repo-git-upgrade-lifetime.test.ts

@@ -23,8 +23,11 @@ vi.mock('./registered-worktree-roots-cache', () => ({
 }))
 vi.mock('./repos/repos-changed-notification', () => ({ notifyReposChanged: fake.reposChanged }))
 vi.mock('./worktree-remote', () => ({ notifyWorktreesChanged: fake.worktreesChanged }))
+vi.mock('./worktree-base-directory-marker-poller', async (importOriginal) => ({
+  ...(await importOriginal<Record<string, unknown>>()),
+  WORKTREE_BASE_BACKSTOP_TICKS: 15
+}))
 vi.mock('./worktree-base-directory-poller', () => ({
-  WORKTREE_BASE_BACKSTOP_TICKS: 15,
   WORKTREE_BASE_POLL_INTERVAL_MS: 2000,
   createWorktreePollerWindowVisibility: () => ({
     isWindowVisible: () => true,

src/main/ipc/folder-repo-git-upgrade.ts

@@ -16,10 +16,10 @@ import { notifyWorktreesChanged } from './worktree-remote'
 import { setFolderRepoGitUpgradeWakeListener } from './folder-repo-git-upgrade-wake'
 import {
   createWorktreePollerWindowVisibility,
-  WORKTREE_BASE_BACKSTOP_TICKS,
   WORKTREE_BASE_POLL_INTERVAL_MS,
   type WorktreePollerWindowVisibility
 } from './worktree-base-directory-poller'
+import { WORKTREE_BASE_BACKSTOP_TICKS } from './worktree-base-directory-marker-poller'
 
 // Why: with no folder project registered there is nothing to stat, so back off until
 // the next catalog mutation wakes the fast cadence.

src/main/ipc/register-core-handlers/register-core-handlers.test.ts

@@ -300,7 +300,7 @@ vi.mock('../filesystem', () => ({
   registerFilesystemHandlers: registerFilesystemHandlersMock
 }))
 
-vi.mock('../filesystem-watcher', () => ({
+vi.mock('../filesystem-watcher-handlers', () => ({
   registerFilesystemWatcherHandlers: registerFilesystemWatcherHandlersMock
 }))
 

src/main/ipc/register-core-handlers/register-core-handlers.ts

@@ -7,7 +7,7 @@ import type { OrcaRuntimeService } from '../../runtime/orca-runtime'
 import type { StatsCollector } from '../../stats/collector'
 import { registerFilesystemHandlers } from '../filesystem'
 import type { CommitMessageAgentEnvironmentResolvers } from '../../text-generation/commit-message-agent-environment'
-import { registerFilesystemWatcherHandlers } from '../filesystem-watcher'
+import { registerFilesystemWatcherHandlers } from '../filesystem-watcher-handlers'
 import { registerUsageProviderHandlers } from '../usage-provider-handlers'
 import { registerGitHubHandlers } from '../github'
 import { registerGitLabHandlers } from '../gitlab'

src/main/ipc/runtime-environments/runtime-environment-browser-client-host-handler.test.ts

@@ -28,7 +28,7 @@ vi.mock('electron', () => ({ ipcMain: { handle: handleMock } }))
 vi.mock('../../../shared/runtime-environment-store', () => ({
   resolveEnvironment: resolveEnvironmentMock
 }))
-vi.mock('./runtime-environment-transport-routing', () => ({
+vi.mock('./runtime-environment-status-probe', () => ({
   getRuntimeEnvironmentStatus: getRuntimeEnvironmentStatusMock
 }))
 vi.mock('../../browser/paired-runtime-browser-client-host-runtime', () => ({

src/main/ipc/runtime-environments/runtime-environment-browser-client-host-handler.ts

@@ -11,7 +11,7 @@ import {
 } from '../../browser/paired-runtime-browser-client-host-runtime'
 import { prepareBrowserClientHostPlacement } from '../../browser/browser-client-host-placement-preparation'
 import { isRuntimeEnvironmentManuallyDisconnected } from './runtime-environment-connectivity-handlers'
-import { getRuntimeEnvironmentStatus } from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
 
 export function registerRuntimeEnvironmentBrowserClientHostHandler(options: {
   getUserDataPath: () => string

src/main/ipc/runtime-environments/runtime-environment-connectivity-handlers.ts

@@ -32,10 +32,8 @@ import {
   isRuntimeEnvironmentManuallyDisconnected,
   RUNTIME_MANUALLY_DISCONNECTED_MESSAGE
 } from './runtime-environment-manual-disconnect'
-import {
-  callRuntimeEnvironment,
-  getRuntimeEnvironmentStatus
-} from './runtime-environment-transport-routing'
+import { callRuntimeEnvironment } from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
 import { publicRuntimeEnvironmentWithHostKey } from './runtime-environment-host-key'
 import { withWslOrcadAccountEnv } from '../../wsl/wsl-orcad-account-env'
 import { clearSshCredentialDeclinedForEnvironment } from '../../ssh/ssh-credential-decline'

src/main/ipc/runtime-environments/runtime-environment-federated-read-routing.test.ts

@@ -32,10 +32,8 @@ vi.mock('./runtime-environment-request-connections', async () => {
   })
 })
 
-import {
-  callRuntimeEnvironment,
-  resetSharedControlSupport
-} from './runtime-environment-transport-routing'
+import { callRuntimeEnvironment } from './runtime-environment-transport-routing'
+import { resetSharedControlSupport } from './runtime-environment-shared-control-support'
 
 describe('federated read RPC transport routing', () => {
   let userDataPath: string

src/main/ipc/runtime-environments/runtime-environment-host-dispatch.test.ts

@@ -33,8 +33,8 @@ vi.mock('./runtime-environment-request-connections', async (importOriginal) => (
   ...(await importOriginal<Record<string, unknown>>()),
   closeRemoteRuntimeRequestConnection: mocks.closeRequest
 }))
-vi.mock('./runtime-environment-transport-routing', () => ({
-  callRuntimeEnvironment: vi.fn(),
+vi.mock('./runtime-environment-transport-routing', () => ({ callRuntimeEnvironment: vi.fn() }))
+vi.mock('./runtime-environment-status-probe', () => ({
   getRuntimeEnvironmentStatus: mocks.getStatus
 }))
 vi.mock('../../ssh/ssh-credential-decline', () => ({

src/main/ipc/runtime-environments/runtime-environment-managed-host-disconnect.test.ts

@@ -31,8 +31,8 @@ vi.mock('./runtime-environment-host-service-ops', () => ({
   connectThroughOwningService: vi.fn(async () => {}),
   removeThroughOwningService: vi.fn()
 }))
-vi.mock('./runtime-environment-transport-routing', () => ({
-  callRuntimeEnvironment: vi.fn(),
+vi.mock('./runtime-environment-transport-routing', () => ({ callRuntimeEnvironment: vi.fn() }))
+vi.mock('./runtime-environment-status-probe', () => ({
   getRuntimeEnvironmentStatus: vi.fn(async () => ({ ok: true }))
 }))
 vi.mock('../ssh/ssh-session-teardown', () => ({ disconnectRegisteredSshTarget: hoisted.teardown }))

src/main/ipc/runtime-environments/runtime-environment-session-tabs-delta.integration.test.ts

@@ -14,10 +14,8 @@ import { getPreferredPairedRuntimeConnection } from '../../../shared/runtime-env
 import { OrcaRuntimeService } from '../../runtime/orca-runtime'
 import { OrcaRuntimeRpcServer } from '../../runtime/runtime-rpc'
 import { makeStore, SESSION_WORKTREE_ID } from '../../runtime/paired-client-navigation-test-harness'
-import {
-  resetSharedControlSupport,
-  subscribeRuntimeEnvironment
-} from './runtime-environment-transport-routing'
+import { resetSharedControlSupport } from './runtime-environment-shared-control-support'
+import { subscribeRuntimeEnvironment } from './runtime-environment-transport-routing'
 
 vi.mock('electron', () => ({ BrowserWindow: { getAllWindows: () => [] } }))
 

src/main/ipc/runtime-environments/runtime-environment-status-connection.test.ts

@@ -9,7 +9,7 @@ import {
   createSharedControlTestServer,
   closeSharedControlTestServers
 } from '../../../shared/remote-runtime-shared-control-test-server'
-import { getRuntimeEnvironmentStatus } from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
 import {
   getRuntimeEnvironmentStatusOwner,
   resetRuntimeEnvironmentStatusOwners

src/main/ipc/runtime-environments/runtime-environment-status-recovery.test.ts

@@ -5,10 +5,8 @@ import { join } from 'node:path'
 import { afterEach, beforeEach, expect, it, vi } from 'vitest'
 import { addEnvironmentFromPairingCode } from '../../../shared/runtime-environment-store'
 import { pairingCode } from './runtime-environments-ipc-test-harness'
-import {
-  getRuntimeEnvironmentStatus,
-  resetSharedControlSupport
-} from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
+import { resetSharedControlSupport } from './runtime-environment-shared-control-support'
 
 const { request, publish } = vi.hoisted(() => ({ request: vi.fn(), publish: vi.fn() }))
 vi.mock('../../../shared/remote-runtime-client', () => ({

src/main/ipc/runtime-environments/runtime-environment-status-retirement.test.ts

@@ -34,7 +34,7 @@ vi.mock('./runtime-environment-request-connections', async () => {
 })
 vi.mock('electron', () => ({ BrowserWindow: { getAllWindows: () => [] } }))
 
-import { getRuntimeEnvironmentStatus } from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
 import { resetRuntimeEnvironmentStatusOwners } from './runtime-environment-request-connections'
 
 let directory: string

src/main/ipc/runtime-environments/runtime-environment-transport-routing-tailscale-hint.test.ts

@@ -7,10 +7,10 @@ import { encodePairingOffer, type PairingOffer } from '../../../shared/pairing'
 import { addEnvironmentFromPairingCode } from '../../../shared/runtime-environment-store'
 import {
   callRuntimeEnvironment,
-  getRuntimeEnvironmentStatus,
-  subscribeRuntimeEnvironment,
-  resetSharedControlSupport
+  subscribeRuntimeEnvironment
 } from './runtime-environment-transport-routing'
+import { getRuntimeEnvironmentStatus } from './runtime-environment-status-probe'
+import { resetSharedControlSupport } from './runtime-environment-shared-control-support'
 
 // Why: prove the wiring, not just the helper — an unreachable endpoint exercises
 // the real WebSocket failure → reject → Tailscale-hint join points the settings