Function useMasterMonitor

src/hooks/useMasterMonitor.ts:299–407

()

}

export function useMasterMonitor(): void {
  const role = useAppState(s => getPipeIpc(s).role)
  const setAppState = useSetAppState()
  const registryVersion = useSyncExternalStore(
    subscribeToSlaveClientRegistry,
    getSlaveClientRegistryVersion,
    getSlaveClientRegistryVersion,
  )

  useEffect(() => {
    if (role !== 'master' && _slaveClients.size === 0) return

    // Set up listeners for each connected slave client
    const cleanups: (() => void)[] = []

    for (const [slaveName, client] of _slaveClients.entries()) {
      const handler = (msg: PipeMessage) => {
        // Only record relevant message types
        if (!isMonitoredPipeEntryType(msg.type)) {
          return
        }

        // Mute gate (second gate, same helper as attachPipeEntryEmitter)
        if (shouldDropMutedMessage(slaveName, msg.type)) {
          return
        }

        // Clear /send override when slave turn completes
        if (
          (msg.type === 'done' || msg.type === 'error') &&
          hasSendOverride(slaveName)
        ) {
          removeSendOverride(slaveName)
        }

        const entry = pipeMessageToSessionEntry(slaveName, msg)

        setAppState(prev => {
          const slave = getPipeIpc(prev).slaves[slaveName]
          if (!slave) return prev

          const newStatus =
            msg.type === 'done' || msg.type === 'error'
              ? 'idle'
              : msg.type === 'prompt'
                ? 'busy'
                : slave.status

          return {
            ...prev,
            pipeIpc: {
              ...getPipeIpc(prev),
              slaves: {
                ...getPipeIpc(prev).slaves,
                [slaveName]: applyPipeEntryToSlaveState(
                  {
                    ...slave,
                    status: newStatus,