Function usePipeIpc

src/hooks/usePipeIpc.ts:446–620

({
  store,
  handleIncomingPrompt,
}: UsePipeIpcOptions)

// ---------------------------------------------------------------------------

export function usePipeIpc({
  store,
  handleIncomingPrompt,
}: UsePipeIpcOptions): void {
  if (!feature('UDS_INBOX')) return

  useEffect(() => {
    const sessionId = _getSessionId()
    if (!sessionId) return
    const pipeName = `cli-${sessionId.slice(0, 8)}`
    const disposed = { current: false }
    let heartbeatTimer: ReturnType<typeof setInterval> | null = null
    let heartbeatBusy = false
    let pipeServer: PipeServer | null = null

    void (async () => {
      try {
        // --- Phase 1: Role determination ---
        const machId = await pr.getMachineId()
        const mac = pr.getMacAddress()
        const localIp = pt.getLocalIp()
        const host = osm.hostname()
        const roleResult = await pr.determineRole(machId)

        const entry = {
          id: pipeName,
          pid: process.pid,
          machineId: machId,
          startedAt: Date.now(),
          ip: localIp,
          mac,
          hostname: host,
          pipeName,
        }

        let initialRole: 'main' | 'sub' = 'main'
        let subIndex: number | null = null
        let displayRole = 'main'

        if (roleResult.role === 'main' || roleResult.role === 'main-recover') {
          await pr.registerAsMain(entry)
        } else {
          subIndex = roleResult.subIndex
          await pr.registerAsSub(entry, subIndex)
          initialRole = 'sub'
          displayRole = `sub-${subIndex}`
        }

        // --- Phase 2: Server creation ---
        const server = await pt.createPipeServer(
          pipeName,
          feature('LAN_PIPES') ? { enableTcp: true, tcpPort: 0 } : undefined,
        )
        pipeServer = server
        if (disposed.current) {
          await server.close()
          await pr.unregister(pipeName)
          return