Compare commits

...

2 Commits

Author SHA1 Message Date
claude-code-best
7a0dd3057e chore: 1.9.3 2026-04-23 23:21:43 +08:00
claude-code-best
ca1c87f460 fix: 修复 usePipeIpc 中 require 返回 undefined 导致启动崩溃
将 lazy require() 调用全部替换为静态 import,解决构建产物中
模块加载时序问题导致的 'undefined is not an object' 错误。

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
2026-04-23 23:21:38 +08:00
2 changed files with 65 additions and 77 deletions

View File

@@ -1,6 +1,6 @@
{ {
"name": "claude-code-best", "name": "claude-code-best",
"version": "1.9.2", "version": "1.9.3",
"description": "Reverse-engineered Anthropic Claude Code CLI — interactive AI coding assistant in the terminal", "description": "Reverse-engineered Anthropic Claude Code CLI — interactive AI coding assistant in the terminal",
"type": "module", "type": "module",
"author": "claude-code-best <claude-code-best@proton.me>", "author": "claude-code-best <claude-code-best@proton.me>",

View File

@@ -12,29 +12,19 @@
*/ */
import { feature } from 'bun:bundle' import { feature } from 'bun:bundle'
import { useEffect } from 'react' import { useEffect } from 'react'
import * as pt from '../utils/pipeTransport.js'
import * as pr from '../utils/pipeRegistry.js'
import * as mm from './useMasterMonitor.js'
import { getSessionId as _getSessionId } from '../bootstrap/state.js'
import * as lb from '../utils/lanBeacon.js'
import * as pp from '../utils/pipePermissionRelay.js'
import * as osm from 'os'
import type { import type {
PipeMessage, PipeMessage,
PipeServer, PipeServer,
PipeIpcState, PipeIpcState,
} from '../utils/pipeTransport.js' } from '../utils/pipeTransport.js'
// Lazy-loaded module accessors (cached by Bun/Node require)
/* eslint-disable @typescript-eslint/no-require-imports */
const pt = () =>
require('../utils/pipeTransport.js') as typeof import('../utils/pipeTransport.js')
const pr = () =>
require('../utils/pipeRegistry.js') as typeof import('../utils/pipeRegistry.js')
const mm = () =>
require('./useMasterMonitor.js') as typeof import('./useMasterMonitor.js')
const bs = () =>
require('../bootstrap/state.js') as typeof import('../bootstrap/state.js')
const lb = () =>
require('../utils/lanBeacon.js') as typeof import('../utils/lanBeacon.js')
const pp = () =>
require('../utils/pipePermissionRelay.js') as typeof import('../utils/pipePermissionRelay.js')
const osm = () => require('os') as typeof import('os')
/* eslint-enable @typescript-eslint/no-require-imports */
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
// Types // Types
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
@@ -54,9 +44,9 @@ export type UsePipeIpcOptions = {
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
function removeDeadSlave(slaveName: string, store: StoreApi): void { function removeDeadSlave(slaveName: string, store: StoreApi): void {
mm().removeSlaveClient(slaveName) mm.removeSlaveClient(slaveName)
store.setState((prev: any) => { store.setState((prev: any) => {
const pipeIpc = pt().getPipeIpc(prev) const pipeIpc = pt.getPipeIpc(prev)
const { [slaveName]: _removed, ...remainingSlaves } = pipeIpc.slaves const { [slaveName]: _removed, ...remainingSlaves } = pipeIpc.slaves
return { return {
...prev, ...prev,
@@ -108,7 +98,7 @@ function refreshDiscoveredPipes(
// Include LAN beacon peers so they aren't wiped out by heartbeat // Include LAN beacon peers so they aren't wiped out by heartbeat
let lanDiscovered: typeof freshDiscovered = [] let lanDiscovered: typeof freshDiscovered = []
if (feature('LAN_PIPES')) { if (feature('LAN_PIPES')) {
const beacon = lb().getLanBeacon() const beacon = lb.getLanBeacon()
if (beacon) { if (beacon) {
const localNames = new Set(freshDiscovered.map(p => p.pipeName)) const localNames = new Set(freshDiscovered.map(p => p.pipeName))
localNames.add(pipeName) localNames.add(pipeName)
@@ -131,7 +121,7 @@ function refreshDiscoveredPipes(
const allDiscovered = [...freshDiscovered, ...lanDiscovered] const allDiscovered = [...freshDiscovered, ...lanDiscovered]
// Only update state if the list actually changed // Only update state if the list actually changed
const prev = pt().getPipeIpc(store.getState()) const prev = pt.getPipeIpc(store.getState())
const prevNames = (prev.discoveredPipes ?? []) const prevNames = (prev.discoveredPipes ?? [])
.map((p: any) => p.pipeName) .map((p: any) => p.pipeName)
.join(',') .join(',')
@@ -139,7 +129,7 @@ function refreshDiscoveredPipes(
if (prevNames === newNames) return if (prevNames === newNames) return
store.setState((prev: any) => { store.setState((prev: any) => {
const pipeIpc = pt().getPipeIpc(prev) const pipeIpc = pt.getPipeIpc(prev)
const aliveNames = new Set(allDiscovered.map(pipe => pipe.pipeName)) const aliveNames = new Set(allDiscovered.map(pipe => pipe.pipeName))
return { return {
...prev, ...prev,
@@ -174,8 +164,8 @@ function registerMessageHandlers(
server.onMessage((msg: PipeMessage, reply) => { server.onMessage((msg: PipeMessage, reply) => {
if (msg.type !== 'attach_request') return if (msg.type !== 'attach_request') return
const state = store.getState() const state = store.getState()
const currentPipeState = pt().getPipeIpc(state) const currentPipeState = pt.getPipeIpc(state)
if (pt().isPipeControlled(currentPipeState)) { if (pt.isPipeControlled(currentPipeState)) {
reply({ type: 'attach_reject', data: 'Already controlled' }) reply({ type: 'attach_reject', data: 'Already controlled' })
return return
} }
@@ -192,7 +182,7 @@ function registerMessageHandlers(
const clients = Array.from((server as any).clients as Set<any>) const clients = Array.from((server as any).clients as Set<any>)
const masterSocket = clients[clients.length - 1] const masterSocket = clients[clients.length - 1]
pp().setPipeRelay((relayMsg: any) => { pp.setPipeRelay((relayMsg: any) => {
if (masterSocket && !masterSocket.destroyed) { if (masterSocket && !masterSocket.destroyed) {
relayMsg.from = relayMsg.from ?? pipeName relayMsg.from = relayMsg.from ?? pipeName
relayMsg.ts = relayMsg.ts ?? new Date().toISOString() relayMsg.ts = relayMsg.ts ?? new Date().toISOString()
@@ -203,9 +193,9 @@ function registerMessageHandlers(
store.setState((prev: any) => ({ store.setState((prev: any) => ({
...prev, ...prev,
pipeIpc: { pipeIpc: {
...pt().getPipeIpc(prev), ...pt.getPipeIpc(prev),
role: 'sub', role: 'sub',
displayRole: pt().getPipeDisplayRole(pt().getPipeIpc(prev)), displayRole: pt.getPipeDisplayRole(pt.getPipeIpc(prev)),
attachedBy: msg.from ?? 'unknown', attachedBy: msg.from ?? 'unknown',
}, },
})) }))
@@ -230,8 +220,7 @@ function registerMessageHandlers(
server.onMessage((msg: PipeMessage, _reply) => { server.onMessage((msg: PipeMessage, _reply) => {
if (msg.type !== 'permission_response' && msg.type !== 'permission_cancel') if (msg.type !== 'permission_response' && msg.type !== 'permission_cancel')
return return
const { resolvePipePermissionResponse, cancelPipePermissionRequest } = const { resolvePipePermissionResponse, cancelPipePermissionRequest } = pp
require('../utils/pipePermissionRelay.js') as typeof import('../utils/pipePermissionRelay.js')
try { try {
const payload = msg.data ? JSON.parse(msg.data) : undefined const payload = msg.data ? JSON.parse(msg.data) : undefined
@@ -249,28 +238,27 @@ function registerMessageHandlers(
// Handle relay mute/unmute from master // Handle relay mute/unmute from master
server.onMessage((msg: PipeMessage, _reply) => { server.onMessage((msg: PipeMessage, _reply) => {
if (msg.type === 'relay_mute') { if (msg.type === 'relay_mute') {
pp().setRelayMuted(true) pp.setRelayMuted(true)
} else if (msg.type === 'relay_unmute') { } else if (msg.type === 'relay_unmute') {
pp().setRelayMuted(false) pp.setRelayMuted(false)
} }
}) })
// Handle detach // Handle detach
server.onMessage((msg: PipeMessage, _reply) => { server.onMessage((msg: PipeMessage, _reply) => {
if (msg.type !== 'detach') return if (msg.type !== 'detach') return
const { clearPendingPipePermissions } = const { clearPendingPipePermissions } = pp
require('../utils/pipePermissionRelay.js') as typeof import('../utils/pipePermissionRelay.js')
clearPendingPipePermissions('Pipe detached before permission was resolved.') clearPendingPipePermissions('Pipe detached before permission was resolved.')
pp().setPipeRelay(null) pp.setPipeRelay(null)
store.setState((prev: any) => ({ store.setState((prev: any) => ({
...prev, ...prev,
pipeIpc: (() => { pipeIpc: (() => {
const pipeIpc = pt().getPipeIpc(prev) const pipeIpc = pt.getPipeIpc(prev)
const nextRole = pipeIpc.subIndex != null ? 'sub' : 'main' const nextRole = pipeIpc.subIndex != null ? 'sub' : 'main'
const nextPipeState = { ...pipeIpc, role: nextRole, attachedBy: null } const nextPipeState = { ...pipeIpc, role: nextRole, attachedBy: null }
return { return {
...nextPipeState, ...nextPipeState,
displayRole: pt().getPipeDisplayRole(nextPipeState as PipeIpcState), displayRole: pt.getPipeDisplayRole(nextPipeState as PipeIpcState),
} }
})(), })(),
})) }))
@@ -289,11 +277,11 @@ function runMainHeartbeat(
): void { ): void {
void (async () => { void (async () => {
try { try {
await pr().cleanupStaleEntries() await pr.cleanupStaleEntries()
const aliveSubs = await pr().getAliveSubs() const aliveSubs = await pr.getAliveSubs()
refreshDiscoveredPipes(pipeName, aliveSubs, store) refreshDiscoveredPipes(pipeName, aliveSubs, store)
const connectedSlaves = mm().getAllSlaveClients() const connectedSlaves = mm.getAllSlaveClients()
const aliveSubNames = new Set(aliveSubs.map(sub => sub.pipeName)) const aliveSubNames = new Set(aliveSubs.map(sub => sub.pipeName))
// Build unified attach target list: local subs + LAN peers // Build unified attach target list: local subs + LAN peers
@@ -307,7 +295,7 @@ function runMainHeartbeat(
// Add LAN peers as attach targets // Add LAN peers as attach targets
if (feature('LAN_PIPES')) { if (feature('LAN_PIPES')) {
const beacon = lb().getLanBeacon() const beacon = lb.getLanBeacon()
if (beacon) { if (beacon) {
const localNames = new Set(attachTargets.map(t => t.pipeName)) const localNames = new Set(attachTargets.map(t => t.pipeName))
localNames.add(pipeName) localNames.add(pipeName)
@@ -323,7 +311,7 @@ function runMainHeartbeat(
} }
} }
const currentPipeState = pt().getPipeIpc(store.getState()) const currentPipeState = pt.getPipeIpc(store.getState())
for (const target of attachTargets) { for (const target of attachTargets) {
if (target.pipeName === pipeName) continue if (target.pipeName === pipeName) continue
@@ -331,7 +319,7 @@ function runMainHeartbeat(
try { try {
const myName = currentPipeState.serverName ?? pipeName const myName = currentPipeState.serverName ?? pipeName
const client = await pt().connectToPipe( const client = await pt.connectToPipe(
target.pipeName, target.pipeName,
myName, myName,
3000, 3000,
@@ -362,7 +350,7 @@ function runMainHeartbeat(
}) })
if (attached && !disposed.current) { if (attached && !disposed.current) {
mm().addSlaveClient(target.pipeName, client) mm.addSlaveClient(target.pipeName, client)
client.on('disconnect', () => { client.on('disconnect', () => {
removeDeadSlave(target.pipeName, store) removeDeadSlave(target.pipeName, store)
@@ -371,11 +359,11 @@ function runMainHeartbeat(
store.setState((prev: any) => ({ store.setState((prev: any) => ({
...prev, ...prev,
pipeIpc: { pipeIpc: {
...pt().getPipeIpc(prev), ...pt.getPipeIpc(prev),
role: 'master', role: 'master',
displayRole: 'master', displayRole: 'master',
slaves: { slaves: {
...pt().getPipeIpc(prev).slaves, ...pt.getPipeIpc(prev).slaves,
[target.pipeName]: { [target.pipeName]: {
name: target.pipeName, name: target.pipeName,
connectedAt: new Date().toISOString(), connectedAt: new Date().toISOString(),
@@ -395,7 +383,7 @@ function runMainHeartbeat(
// Clean up slaves that are no longer alive // Clean up slaves that are no longer alive
let lanPeerNames: Set<string> | null = null let lanPeerNames: Set<string> | null = null
if (feature('LAN_PIPES')) { if (feature('LAN_PIPES')) {
const beacon = lb().getLanBeacon() const beacon = lb.getLanBeacon()
if (beacon) { if (beacon) {
lanPeerNames = new Set(beacon.getPeers().keys()) lanPeerNames = new Set(beacon.getPeers().keys())
} }
@@ -422,28 +410,28 @@ function runSubHeartbeat(
): void { ): void {
void (async () => { void (async () => {
try { try {
const mainAlive = await pr().isMainAlive() const mainAlive = await pr.isMainAlive()
if (!mainAlive && !disposed.current) { if (!mainAlive && !disposed.current) {
const registry = await pr().readRegistry() const registry = await pr.readRegistry()
const isSameMachine = pr().isMainMachine(machineId, registry) const isSameMachine = pr.isMainMachine(machineId, registry)
if (isSameMachine) { if (isSameMachine) {
await pr().registerAsMain(entry) await pr.registerAsMain(entry)
} else { } else {
await pr().revertToIndependent(pipeName) await pr.revertToIndependent(pipeName)
} }
store.setState((prev: any) => ({ store.setState((prev: any) => ({
...prev, ...prev,
pipeIpc: { pipeIpc: {
...pt().getPipeIpc(prev), ...pt.getPipeIpc(prev),
role: 'main', role: 'main',
subIndex: null, subIndex: null,
displayRole: 'main', displayRole: 'main',
attachedBy: null, attachedBy: null,
}, },
})) }))
pp().setPipeRelay(null) pp.setPipeRelay(null)
} }
} catch { } catch {
// Heartbeat check error — non-fatal // Heartbeat check error — non-fatal
@@ -462,7 +450,9 @@ export function usePipeIpc({
if (!feature('UDS_INBOX')) return if (!feature('UDS_INBOX')) return
useEffect(() => { useEffect(() => {
const pipeName = `cli-${bs().getSessionId().slice(0, 8)}` const sessionId = _getSessionId()
if (!sessionId) return
const pipeName = `cli-${sessionId.slice(0, 8)}`
const disposed = { current: false } const disposed = { current: false }
let heartbeatTimer: ReturnType<typeof setInterval> | null = null let heartbeatTimer: ReturnType<typeof setInterval> | null = null
let heartbeatBusy = false let heartbeatBusy = false
@@ -471,11 +461,11 @@ export function usePipeIpc({
void (async () => { void (async () => {
try { try {
// --- Phase 1: Role determination --- // --- Phase 1: Role determination ---
const machId = await pr().getMachineId() const machId = await pr.getMachineId()
const mac = pr().getMacAddress() const mac = pr.getMacAddress()
const localIp = pt().getLocalIp() const localIp = pt.getLocalIp()
const host = osm().hostname() const host = osm.hostname()
const roleResult = await pr().determineRole(machId) const roleResult = await pr.determineRole(machId)
const entry = { const entry = {
id: pipeName, id: pipeName,
@@ -493,29 +483,29 @@ export function usePipeIpc({
let displayRole = 'main' let displayRole = 'main'
if (roleResult.role === 'main' || roleResult.role === 'main-recover') { if (roleResult.role === 'main' || roleResult.role === 'main-recover') {
await pr().registerAsMain(entry) await pr.registerAsMain(entry)
} else { } else {
subIndex = roleResult.subIndex subIndex = roleResult.subIndex
await pr().registerAsSub(entry, subIndex) await pr.registerAsSub(entry, subIndex)
initialRole = 'sub' initialRole = 'sub'
displayRole = `sub-${subIndex}` displayRole = `sub-${subIndex}`
} }
// --- Phase 2: Server creation --- // --- Phase 2: Server creation ---
const server = await pt().createPipeServer( const server = await pt.createPipeServer(
pipeName, pipeName,
feature('LAN_PIPES') ? { enableTcp: true, tcpPort: 0 } : undefined, feature('LAN_PIPES') ? { enableTcp: true, tcpPort: 0 } : undefined,
) )
pipeServer = server pipeServer = server
if (disposed.current) { if (disposed.current) {
await server.close() await server.close()
await pr().unregister(pipeName) await pr.unregister(pipeName)
return return
} }
// --- Phase 3: LAN beacon --- // --- Phase 3: LAN beacon ---
if (feature('LAN_PIPES') && server.tcpAddress) { if (feature('LAN_PIPES') && server.tcpAddress) {
const beacon = new (lb().LanBeacon)({ const beacon = new (lb.LanBeacon)({
pipeName, pipeName,
machineId: machId, machineId: machId,
hostname: host, hostname: host,
@@ -524,7 +514,7 @@ export function usePipeIpc({
role: initialRole, role: initialRole,
}) })
beacon.start() beacon.start()
lb().setLanBeacon(beacon) lb.setLanBeacon(beacon)
const entryWithTcp = { const entryWithTcp = {
...entry, ...entry,
@@ -532,9 +522,9 @@ export function usePipeIpc({
lanVisible: true, lanVisible: true,
} }
if (initialRole === 'main') { if (initialRole === 'main') {
await pr().registerAsMain(entryWithTcp) await pr.registerAsMain(entryWithTcp)
} else if (subIndex != null) { } else if (subIndex != null) {
await pr().registerAsSub(entryWithTcp, subIndex) await pr.registerAsSub(entryWithTcp, subIndex)
} }
} }
@@ -542,7 +532,7 @@ export function usePipeIpc({
store.setState((prev: any) => ({ store.setState((prev: any) => ({
...prev, ...prev,
pipeIpc: { pipeIpc: {
...pt().getPipeIpc(prev), ...pt.getPipeIpc(prev),
serverName: pipeName, serverName: pipeName,
role: initialRole, role: initialRole,
subIndex, subIndex,
@@ -570,7 +560,7 @@ export function usePipeIpc({
if (disposed.current || heartbeatBusy) return if (disposed.current || heartbeatBusy) return
heartbeatBusy = true heartbeatBusy = true
const currentPipeState = pt().getPipeIpc(store.getState()) const currentPipeState = pt.getPipeIpc(store.getState())
if ( if (
currentPipeState.role === 'main' || currentPipeState.role === 'main' ||
@@ -600,7 +590,7 @@ export function usePipeIpc({
} }
// Send detach to all slaves // Send detach to all slaves
const allClients = mm().getAllSlaveClients() const allClients = mm.getAllSlaveClients()
for (const [name, client] of allClients.entries()) { for (const [name, client] of allClients.entries()) {
try { try {
client.send({ type: 'detach' }) client.send({ type: 'detach' })
@@ -610,23 +600,21 @@ export function usePipeIpc({
} }
// Stop LAN beacon // Stop LAN beacon
const beacon = lb().getLanBeacon() const beacon = lb.getLanBeacon()
if (beacon) { if (beacon) {
try { try {
beacon.stop() beacon.stop()
} catch {} } catch {}
lb().setLanBeacon(null) lb.setLanBeacon(null)
} }
// Unregister + close server // Unregister + close server
void pr() pr.unregister(pipeName).catch(() => {})
.unregister(pipeName)
.catch(() => {})
if (pipeServer) { if (pipeServer) {
void pipeServer.close().catch(() => {}) void pipeServer.close().catch(() => {})
pipeServer = null pipeServer = null
} }
pp().setPipeRelay(null) pp.setPipeRelay(null)
} }
}, []) // eslint-disable-line react-hooks/exhaustive-deps }, []) // eslint-disable-line react-hooks/exhaustive-deps
} }