Functions — github.com/Kevin7Qi/codex-collab

CodeHub MCPcopy Create free account

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

Functions413 in github.com/Kevin7Qi/codex-collab

⨍ Functions 413◇ Types & classes 90

↓ 96 callersMethodclose

Close the connection and terminate the server process. * On Unix: close stdin -> wait 5s -> SIGTERM -> wait 3s -> SIGKILL, * signalling the ap

src/client.ts:73

↓ 84 callersMethodrequest

Send a request and wait for a response. Rejects on timeout, error, or connection loss.

↓ 68 callersFunctioncreateRun

(stateDir: string, record: RunRecord)

src/threads.ts:278

↓ 68 callersMethodlog

(entry: string)

src/events.ts:267

↓ 59 callersFunctionparseOptions

(args: string[])

src/commands/shared.ts:296

↓ 58 callersFunctionemit

(method: string, params: unknown)

src/turns.test.ts:59

↓ 49 callersMethodconnectAndInit

Connect and perform the initialize handshake.

src/broker-server.test.ts:338

↓ 47 callersFunctionrecord

(runId: string, shortId: string, status: RunStatus, startedAt: string)

src/commands/follow.test.ts:28

↓ 44 callersMethodon

Register a handler for server-sent notifications. Returns an unsubscribe function.

↓ 40 callersFunctioncreateMockCodex

* Create a mock codex CLI script that speaks JSON-RPC when invoked as * `codex app-server`. The mock handles initialize, thread/start, turn/start, *

src/broker-server.test.ts:47

↓ 40 callersFunctionspawnBroker

Spawn broker-server as a subprocess with the mock codex on PATH.

src/broker-server.test.ts:233

↓ 40 callersFunctionwaitForSocket

Wait for the broker socket to become connectable.

src/broker-server.test.ts:267

↓ 38 callersFunctiondie

src/commands/shared.ts:152

↓ 37 callersFunctionbuildMockClient

* Build a mock AppServerClient with an exposed emit() for firing notifications * and a custom request handler. All boilerplate (on, onRequest, notify

src/turns.test.ts:52

↓ 36 callersFunctionmakeRun

(overrides: Partial<RunRecord> = {})

src/threads.test.ts:253

↓ 34 callersFunctionloadThreadIndex

(stateDir: string)

src/threads.ts:61

↓ 33 callersFunctionrunTurn

( client: AppServerClient, threadId: string, input: UserInput[], opts: TurnOptions, )

src/turns.ts:96

↓ 31 callersFunctioninProgressTurn

Standard in-progress turn response.

src/turns.test.ts:113

↓ 27 callersFunctioncompletedTurn

Standard turn/completed notification payload.

src/turns.test.ts:105

↓ 24 callersFunctionmigrateGlobalState

(cwd: string, globalDataDir?: string)

src/threads.ts:693

↓ 22 callersFunctionfreshDirs

src/commands/follow.test.ts:12

↓ 22 callersFunctionrun

(...args: string[])

src/cli.test.ts:23

↓ 21 callersFunctionprogress

src/commands/shared.ts:249

↓ 21 callersFunctionsaveThreadIndex

(stateDir: string, index: ThreadIndex)

src/threads.ts:112

↓ 20 callersFunctioncreateIndexedRun

createRun + a matching thread-index entry — the bare-follow pickers skip * runs whose thread is missing from the index (orphan protection).

src/commands/follow.test.ts:21

↓ 20 callersFunctiondefaultOptions

src/commands/shared.ts:253

↓ 19 callersFunctionconnectToBroker

(opts: BrokerClientOptions)

src/broker-client.ts:29

↓ 19 callersFunctionlistRuns

(stateDir: string, opts?: { sessionId?: string })

src/threads.ts:400

↓ 18 callersFunctioncomputeWsStateDir

* Helper: compute the workspace state dir that migrateGlobalState will use. * Mirrors workspaceDirName logic in threads.ts.

src/threads.test.ts:659

↓ 17 callersFunctionstyle

(text: string, codes: string[], color: boolean)

src/render.ts:108

↓ 17 callersFunctionturn

(items: ThreadItem[], status: Turn["status"] = "completed")

src/commands/peek.test.ts:21

↓ 17 callersFunctionuserItem

(text: string, id: string = "u1")

src/commands/peek.test.ts:5

↓ 16 callersFunctioncheckSocketSupport

src/broker.test.ts:380

↓ 16 callersFunctionrenderEntry

(entry: LogEntry, opts: RenderOptions)

src/render.ts:128

↓ 15 callersFunctionfreshWorkspace

src/commands/shared.test.ts:38

↓ 15 callersFunctionrunCli

(args: string[], env?: Record<string, string>)

src/integration.test.ts:27

↓ 15 callersFunctionwriteGlobalThreads

(globalDataDir: string, mapping: ThreadIndex)

src/threads.test.ts:682

↓ 14 callersFunctionentry

(body: string, extra: string[] = [])

src/render.test.ts:52

↓ 14 callersMethodhandleCommandApproval

(req: CommandApprovalRequest, signal?: AbortSignal)

src/approvals.ts:14

↓ 14 callersFunctionparseMessage

↓ 14 callersFunctionreplayBound

(stateDir: string, run: RunRecord)

src/commands/follow.ts:172

↓ 13 callersFunctionagentItem

(text: string, id: string = "a1")

src/commands/peek.test.ts:13

↓ 12 callersFunctiongetWorkspacePaths

src/commands/shared.ts:70

↓ 12 callersMethodhandleAutoApprovalReview

Surface Guardian (auto_review) approval reviews in the progress stream * so autonomous permit/reject decisions stay auditable. Observed 0.142 *

src/events.ts:146

↓ 12 callersFunctionhasFlagValue

True iff argv[i+1] exists and is usable as the value of the flag at * argv[i]. A next token that looks like another flag is rejected — silently *

src/commands/shared.ts:290

↓ 12 callersFunctionm

(id: string, opts: { upgrade?: string; isDefault?: boolean } = {})

src/commands/shared.test.ts:748

↓ 12 callersFunctionpruneRuns

(stateDir: string, maxRuns?: number)

src/threads.ts:452

↓ 12 callersFunctionselectPeekItems

( turns: Turn[], limit: number, full: boolean, )

src/commands/peek.ts:33

↓ 12 callersFunctionturnOverrides

(opts: Options)

src/commands/shared.ts:1038

↓ 11 callersMethodconnect

(sockPath: string)

src/broker-server.test.ts:323

↓ 11 callersFunctioncreateMockBroker

( sockPath: string, onConnection?: ConnectionHandler, )

src/broker.test.ts:557

↓ 11 callersFunctionformatDuration

src/commands/shared.ts:1057

↓ 11 callersFunctionfreshTmpDir

src/commands/shared.test.ts:32

↓ 11 callersFunctionisBrokerBusyError

src/broker.ts:22

↓ 11 callersFunctionloadRun

(stateDir: string, runId: string)

src/threads.ts:337

↓ 11 callersFunctionrunApplyConfig

( configJson: string, explicitFlags: string[] = [], checkExpression: string, )

src/commands/shared.test.ts:980

↓ 11 callersFunctionstartOrResumeThread

( client: AppServerClient, opts: Options, ws: WorkspacePaths, extraStartParams?: Record<string, unknow

src/commands/shared.ts:822

↓ 10 callersFunctiondeniedNotification

(overrides: Partial<AutoApprovalReviewParams> = {})

src/guardian.test.ts:26

↓ 10 callersMethodfeed

Feed raw incoming bytes; complete lines are parsed and dispatched.

↓ 10 callersMethodhandleItemCompleted

(params: ItemCompletedParams)

src/events.ts:57

↓ 10 callersMethodprogress

src/events.ts:261

↓ 10 callersFunctionsaveGuardianDenial

( guardianDir: string, params: AutoApprovalReviewParams, )

src/guardian.ts:26

↓ 10 callersFunctionsend

(socket: net.Socket, message: Record<string, unknown>)

src/broker-server.ts:77

↓ 9 callersFunctionfindShortId

(stateDir: string, threadId: string)

src/threads.ts:194

↓ 9 callersFunctionloadBrokerState

(stateDir: string)

src/broker.ts:78

↓ 9 callersFunctionmakeThread

(overrides: Partial<Thread> = {})

src/commands/peek.test.ts:126

↓ 9 callersFunctionnextUnseenRun

( stateDir: string, seen: ReadonlySet<string>, scopedShortId: string | null, )

src/commands/follow.ts:201

↓ 9 callersFunctionparseEndpoint

(endpoint: string)

src/broker.ts:59

↓ 9 callersFunctionparseTemplateFrontmatter

src/config.ts:217

↓ 9 callersFunctionresolveThreadId

( stateDir: string, id: string, )

src/threads.ts:164

↓ 9 callersMethodsend

(msg: Record<string, unknown>)

src/broker-server.test.ts:378

↓ 9 callersFunctionthreadStartResponse

(threadId: string, cwd: string)

src/commands/shared.test.ts:55

↓ 9 callersFunctionvalidateGitRef

(value: string, label: string)

src/commands/shared.ts:201

↓ 9 callersFunctionwaitFor

Wait for a condition to become true within a timeout.

src/broker-server.test.ts:435

↓ 9 callersFunctionwithClient

(fn: (client: AppServerClient) => Promise<T>, cwd?: string, streaming = false)

src/commands/shared.ts:665

↓ 8 callersFunctionisPathInside

(candidate: string, root: string)

src/config.ts:41

↓ 8 callersFunctionisThreadProcessAlive

(pidsDir: string, shortId: string)

src/commands/shared.ts:1263

↓ 8 callersFunctionlistRunsForThread

(stateDir: string, shortId: string)

src/threads.ts:419

↓ 8 callersFunctionloadTemplate

(name: string, promptsDir?: string)

src/config.ts:253

↓ 8 callersMethodonRequest

Register a handler for server-sent requests. One handler per method; * new registrations replace previous ones (with a warning).

↓ 8 callersFunctionpickBestModel

(models: Model[])

src/commands/shared.ts:727

↓ 8 callersFunctionrecord

(overrides: Partial<AutoApprovalReviewParams> = {})

src/guardian.test.ts:41

↓ 8 callersFunctionrecordingClient

Mock client that records calls and answers from a method→response map. * Unlisted methods resolve to {} so incidental RPCs (thread/name/set) *

src/commands/shared.test.ts:1313

↓ 8 callersFunctionresolveWorkspaceDir

src/config.ts:137

↓ 8 callersFunctionrunIsLive

(run: RunRecord, pidsDir: string)

src/commands/follow.ts:79

↓ 8 callersFunctionupdateThreadStatus

( stateDir: string, threadId: string, status: NonNullable<ThreadIndexEntry["lastStatus"]>, )

src/threads.ts:229

↓ 8 callersFunctionvalidateId

src/config.ts:119

↓ 7 callersFunctionexitCodeForError

src/commands/shared.ts:193

↓ 7 callersFunctionextractAgentOutputBlocks

(content: string)

src/commands/threads.ts:299

↓ 7 callersMethodflush

src/events.ts:250

↓ 7 callersFunctionhoursAgo

src/threads.test.ts:439

↓ 7 callersFunctionmapGuardianAction

(action: Record<string, unknown>)

src/guardian.ts:120

↓ 7 callersFunctionpickLastOutput

(rec: RunRecord | null, logContent: string)

src/commands/threads.ts:331

↓ 7 callersFunctionregisterThread

( stateDir: string, threadId: string, meta?: Partial<Pick<ThreadIndexEntry, "model" | "cwd" | "preview"

src/threads.ts:130

↓ 7 callersFunctionresetIdleTimer

src/broker-server.ts:160

↓ 7 callersFunctionresolveApproval

(mode: ApprovalMode)

src/commands/shared.ts:1020

↓ 7 callersFunctionresolveGuardianDenial

( guardianDir: string, idOrPrefix: string, )

src/guardian.ts:67

↓ 7 callersFunctionrunReview

( client: AppServerClient, threadId: string, target: ReviewTarget, opts: ReviewOptions, )

src/turns.ts:120

↓ 7 callersFunctiontryServerDelete

(client: AppServerClient, threadId: string)

src/commands/shared.ts:1300

↓ 7 callersFunctionupdateRun

(stateDir: string, runId: string, patch: RunPatch)

src/threads.ts:379

next →1–100 of 413, ranked by callers