Function attachPipeEntryEmitter

src/hooks/useMasterMonitor.ts:181–223

(name: string, client: PipeClient)

}

function attachPipeEntryEmitter(name: string, client: PipeClient): void {
  detachPipeEntryEmitter(name, _slaveClients.get(name))
  if (typeof client.on !== 'function') return
  const handler = (msg: PipeMessage) => {
    if (!isMonitoredPipeEntryType(msg.type)) return

    // Mute gate: drop business messages from muted slaves
    if (shouldDropMutedMessage(name, msg.type)) {
      // Auto-deny permission_request to prevent slave deadlock
      if (msg.type === 'permission_request') {
        try {
          const payload = JSON.parse(msg.data ?? '{}')
          if (payload.requestId) {
            client.send({
              type: 'permission_response',
              data: JSON.stringify({
                requestId: payload.requestId,
                behavior: 'deny',
                feedback:
                  'Permission auto-denied: pipe is logically disconnected.',
              }),
            })
          }
        } catch {
          // Malformed payload — safe to ignore
        }
      }
      return
    }

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

    emitPipeEntry(name, pipeMessageToSessionEntry(name, msg))
  }
  _pipeEntryHandlers.set(name, handler)
  client.on('message', handler)
}

function emitSlaveClientRegistryChanged(): void {
  _slaveClientRegistryVersion += 1