Functions — github.com/Kevin7Qi/codex-collab

hub / github.com/Kevin7Qi/codex-collab / functions

Functions413 in github.com/Kevin7Qi/codex-collab

⨍ Functions 413◇ Types & classes 90

↓ 6 callersFunctionacquireSpawnLock

(stateDir: string)

src/broker.ts:209

↓ 6 callersFunctionbelongsToTurn

( params: { threadId: string; turnId: string }, expectedThreadId: string, expectedTurnId: string, )

src/turns.ts:30

↓ 6 callersFunctionbuildGuardianOverrideEvent

(record: GuardianDenialRecord)

src/guardian.ts:133

↓ 6 callersFunctionclip

Truncate to the terminal width, accounting for an already-styled prefix length.

src/render.ts:114

↓ 6 callersFunctionconnectDirect

(opts?: ConnectOptions)

src/client.ts:85

↓ 6 callersFunctionformatPeekJson

( thread: Thread, shortId: string | null, items: ThreadItem[], totalItems: number, truncated: boolea

src/commands/peek.ts:74

↓ 6 callersFunctionformatResponse

(id: RequestId, result: unknown)

src/rpc.ts:33

↓ 6 callersFunctiongenerateRunId

()

src/threads.ts:266

↓ 6 callersFunctiongenerateShortId

()

src/threads.ts:51

↓ 6 callersFunctiongetCurrentSessionId

(stateDir: string)

src/broker.ts:290

↓ 6 callersFunctionhasPendingApproval

(stateDir: string, runId: string)

src/commands/shared.ts:1171

↓ 6 callersFunctionhumanizeTurnError

(raw: string)

src/commands/shared.ts:1081

↓ 6 callersFunctionisBrokerAlive

(endpoint: string | null, timeoutMs = 150)

src/broker.ts:166

↓ 6 callersMethodonClose

Register a callback invoked on unexpected connection loss (fail()). * Not called after markClosed(). Returns an unsubscribe function.

src/rpc.ts:163

↓ 6 callersFunctionpickDefaultRun

(stateDir: string, pidsDir: string)

src/commands/follow.ts:110

↓ 6 callersFunctionrecordTerminalRunState

( ws: WorkspacePaths, threadId: string, runId: string, result: TurnResult, label: "Turn" | "Review",

src/commands/shared.ts:1126

↓ 6 callersFunctionremovePidFile

(pidsDir: string, shortId: string)

src/commands/shared.ts:1223

↓ 6 callersFunctionresolveModel

(model: string | undefined)

src/config.ts:186

↓ 6 callersFunctionresolveStateDir

(cwd: string)

src/config.ts:169

↓ 6 callersFunctionsaveBrokerState

(stateDir: string, state: BrokerState)

src/broker.ts:105

↓ 6 callersFunctionsaveSessionState

(stateDir: string, state: SessionState)

src/broker.ts:152

↓ 6 callersFunctionshutdown

(server: net.Server)

src/broker-server.ts:351

↓ 6 callersFunctionthreadsFilePath

(stateDir: string)

src/threads.ts:57

↓ 6 callersFunctionwithThreadLock

(filePath: string, fn: () => T)

src/threads.ts:40

↓ 6 callersFunctionwrite

(data: string)

src/rpc.ts:195

↓ 6 callersFunctionwriteMigrationMarker

* Atomically stamp the per-workspace migration marker. * * Caller MUST hold withThreadLock(markerPath, …). The entire * migrateGlobalState body run

src/threads.ts:668

↓ 5 callersFunctionapplyDiscoverLimit

(options: { discover: boolean; limit: number; explicit: Set<string>; })

src/commands/threads.ts:59

↓ 5 callersFunctionclearInferenceTimer

()

src/turns.ts:177

↓ 5 callersFunctioncollectThreadLogPaths

( stateDir: string, logsDir: string, shortId: string, globalLogsDir: string = config.logsDir, )

src/commands/threads.ts:247

↓ 5 callersFunctioncreateEndpoint

(stateDir: string, platform?: string)

src/broker.ts:46

↓ 5 callersFunctiondescribeGuardianAction

(record: GuardianDenialRecord)

src/guardian.ts:172

↓ 5 callersFunctiondieWithRunnerOutput

(reason)

src/commands/run.ts:123

↓ 5 callersFunctionformatNotification

(method: string, params?: unknown)

src/rpc.ts:26

↓ 5 callersFunctionformatPeekHuman

( thread: Thread, shortId: string | null, items: ThreadItem[], totalItems: number, truncated: boolea

src/commands/peek.ts:105

↓ 5 callersFunctionformatRequest

(method: string, params?: unknown)

src/client.test.ts:9

↓ 5 callersFunctioninterpolateTemplate

( template: string, vars: Record<string, string>, )

src/config.ts:329

↓ 5 callersFunctionisProcessAlive

(pid: number)

src/process.ts:12

↓ 5 callersFunctionlistGuardianDenials

(guardianDir: string)

src/guardian.ts:47

↓ 5 callersFunctionmutateThreadIndex

( stateDir: string, mutate: (index: ThreadIndex) => boolean | void, )

src/threads.ts:120

↓ 5 callersFunctionpickThreadRun

( stateDir: string, pidsDir: string, shortId: string, oldestLive = false, )

src/commands/follow.ts:141

↓ 5 callersFunctionrecord

(shortId: string, runId: string, logFile: string)

src/commands/threads.test.ts:46

↓ 5 callersFunctionrecord

(ws: WorkspacePaths, runId: string, pending: boolean)

src/commands/shared.test.ts:1864

↓ 5 callersFunctionrenderFinalStatus

( status: string, detail: { elapsed?: string | null; filesChanged?: number; error?: string | null }, col

src/render.ts:186

↓ 5 callersFunctionrunsDir

(stateDir: string)

src/threads.ts:258

↓ 5 callersFunctionstripDetachFlag

(args: string[])

src/commands/run.ts:61

↓ 5 callersFunctiontagExitCode

(e: unknown, code: number)

src/commands/shared.ts:185

↓ 5 callersFunctionvalidateEffort

(effort: string | undefined)

src/config.ts:195

↓ 5 callersFunctionvalidateIdOrDie

(id: string)

src/commands/shared.ts:209

↓ 4 callersFunctionbuildJsonRpcError

(code: number, message: string, data?: unknown)

src/broker-server.ts:73

↓ 4 callersFunctionclearBrokerArtifacts

(stateDir: string, state: BrokerState)

src/broker.ts:230

↓ 4 callersFunctiondeleteOldFiles

Delete files older than maxAgeMs in the given directory. With `recurse`, * descend one level into subdirectories (per-run log dirs under logs/) and

src/commands/threads.ts:513

↓ 4 callersMethoddrain

Flush an unterminated agent-output block (writer crashed mid-entry).

src/render.ts:67

↓ 4 callersMethodgetCommandsRun

()

src/events.ts:231

↓ 4 callersFunctiongetDefaultBranch

(cwd: string)

src/git.ts:12

↓ 4 callersMethodgetFilesChanged

()

src/events.ts:227

↓ 4 callersFunctionloadSessionState

(stateDir: string)

src/broker.ts:128

↓ 4 callersFunctionpickWatchStartRun

(stateDir: string, pidsDir: string)

src/commands/follow.ts:123

↓ 4 callersFunctionreadThreadLog

(stateDir: string, logsDir: string, shortId: string)

src/commands/threads.ts:274

↓ 4 callersFunctionrec

(over: Partial<RunRecord>)

src/commands/threads.test.ts:171

↓ 4 callersFunctionrunFilePath

(stateDir: string, runId: string)

src/threads.ts:262

↓ 4 callersFunctionsetActiveRunId

(id: string | undefined)

src/commands/shared.ts:616

↓ 4 callersFunctionsetActiveShortId

(id: string | undefined)

src/commands/shared.ts:613

↓ 4 callersFunctionsetActiveThreadId

(id: string | undefined)

src/commands/shared.ts:611

↓ 4 callersFunctionsetActiveTurnId

(id: string | undefined)

src/commands/shared.ts:614

↓ 4 callersFunctionsetActiveWsPaths

(ws: WorkspacePaths | undefined)

src/commands/shared.ts:615

↓ 4 callersFunctionshowHelp

()

src/cli.ts:93

↓ 4 callersFunctionteardownBroker

(stateDir: string, state: BrokerState)

src/broker.ts:269

↓ 4 callersFunctionterminateProcessTree

(pid: number)

src/process.ts:33

↓ 3 callersFunctionarmOrphanWatchdog

Arm the watchdog after a stream owner disconnects mid-turn. If * turn/completed doesn't arrive, force the orphaned turn to end so the * broker

src/broker-server.ts:175

↓ 3 callersFunctioncandidateRuns

* Candidate runs for bare-follow selection, newest first. Run records whose * thread is no longer in the index are excluded: `delete` now removes the

src/commands/follow.ts:98

↓ 3 callersFunctioncanonicalizePath

Canonicalize a path for workspace-scope comparisons. When the path does * not exist (deleted dirs, dangling entries), canonicalize the deepest * e

src/threads.ts:596

↓ 3 callersFunctioncaptureErrorMessage

(promise: Promise<unknown>)

src/client.test.ts:16

↓ 3 callersFunctionclientFor

(impl: () => Promise<unknown>)

src/commands/shared.test.ts:1777

↓ 3 callersFunctionclientThrowing

(err: Error)

src/commands/shared.test.ts:1811

↓ 3 callersFunctioncollectNotifications

Collect notifications from a client into an array. Returns the array ref.

src/broker-server.test.ts:426

↓ 3 callersFunctiondone

(value: boolean)

src/broker.ts:180

↓ 3 callersFunctionensureLedgerVersion

(stateDir: string)

src/threads.ts:302

↓ 3 callersMethodfail

Report an unexpected connection loss: reject pending requests with the * given reason and fire onClose handlers once. No-op after markClosed().

src/rpc.ts:169

↓ 3 callersFunctiongetLatestRun

(stateDir: string, shortId: string)

src/threads.ts:423

↓ 3 callersMethodgetTurnOutput

Output for `TurnResult.output`, with precedence: * 1. `reviewOutput` — set from an `exitedReviewMode` item; for review turns * this is the

src/events.ts:223

↓ 3 callersFunctiongit

Run a git command synchronously with a 5-second timeout.

src/git.ts:6

↓ 3 callersFunctiongroupAlive

()

src/client.ts:135

↓ 3 callersMethodhandleDelta

(method: string, params: DeltaParams)

src/events.ts:130

↓ 3 callersMethodhandleFileChangeApproval

(req: FileChangeApprovalRequest, signal?: AbortSignal)

src/approvals.ts:15

↓ 3 callersMethodhandleGuardianWarning

guardianWarning: a human-facing message about a Guardian decision. Fires * on denials AND on risky approvals ("Automatic approval review approved

src/events.ts:199

↓ 3 callersMethodhandleItemStarted

(params: ItemStartedParams)

src/events.ts:43

↓ 3 callersMethodisClosed

True after markClosed().

src/rpc.ts:174

↓ 3 callersFunctionisKnownItem

(item: ThreadItem)

src/types.ts:202

↓ 3 callersFunctionkillTree

Signal the app-server's process group (Unix, detached) with a fallback * to the direct child; plain child kill elsewhere.

src/client.ts:113

↓ 3 callersFunctionlockAgeMs

Age of the lock file in ms, or null if it cannot be statted.

src/lock.ts:55

↓ 3 callersMethodnotifyPending

(pending: PendingApproval | null)

src/approvals.ts:68

↓ 3 callersMethodon

src/client.ts:54

↓ 3 callersFunctionrecordRunFailure

( ws: WorkspacePaths, threadId: string, runId: string, error: unknown, )

src/commands/shared.ts:1184

↓ 3 callersFunctionrejectAllPending

(reason: string)

src/rpc.ts:208

↓ 3 callersFunctionremoveThread

(stateDir: string, shortId: string)

src/threads.ts:247

↓ 3 callersFunctionresolveRunLogPath

( stateDir: string, logsDir: string, run: RunRecord, globalLogsDir: string = config.logsDir, )

src/commands/threads.ts:223

↓ 3 callersFunctionresolveThreadIdAllowRaw

( stateDir: string, id: string, )

src/commands/shared.ts:236

↓ 3 callersFunctionrunLogRelPath

(shortId: string, runId: string)

src/threads.ts:274

↓ 3 callersFunctionsaveUserConfig

(cfg: UserConfig)

src/commands/shared.ts:533

↓ 3 callersFunctionsweepGroup

After the direct child is gone, its detached process group can still * hold descendants (the group id stays reserved while any member lives). *

src/client.ts:132

← previous next →101–200 of 413, ranked by callers