async createSandbox( params: WithPrivate<{ name?: string; ports?: number[]; projectId: string; source?: | { type: "git"; url: string; depth?: number; revision?: string; username?: string; password?: string; } | { type: "tarball"; url: string } | { type: "snapshot"; snapshotId: string }; timeout?: number; resources?: { vcpus: number }; persistent?: boolean; runtime?: RUNTIMES | (string & {}); networkPolicy?: NetworkPolicy; env?: Record; tags?: Record; snapshotExpiration?: number; signal?: AbortSignal; }>, ) { const privateParams = getPrivateParams(params); return parseOrThrow( SandboxAndSessionResponse, await this.request("/v2/sandboxes", { method: "POST", body: JSON.stringify({ projectId: params.projectId, ports: params.ports, source: params.source, timeout: params.timeout, resources: params.resources, runtime: params.runtime, name: params.name, persistent: params.persistent, networkPolicy: params.networkPolicy ? toAPINetworkPolicy(params.networkPolicy) : undefined, env: params.env, tags: params.tags, snapshotExpiration: params.snapshotExpiration, ...privateParams, }), signal: params.signal, }), ); } async runCommand(params: { sessionId: string; cwd?: string; command: string; args: string[]; env: Record; sudo: boolean; wait: true; signal?: AbortSignal; }): Promise<{ command: CommandData; finished: Promise }>; async runCommand(params: { sessionId: string; cwd?: string; command: string; args: string[]; env: Record; sudo: boolean; wait?: false; signal?: AbortSignal; }): Promise>>; async runCommand(params: { sessionId: string; cwd?: string; command: string; args: string[]; env: Record; sudo: boolean; wait?: boolean; signal?: AbortSignal; }) { if (params.wait) { const response = await this.request( `/v2/sandboxes/sessions/${params.sessionId}/cmd`, { method: "POST", body: JSON.stringify({ command: params.command, args: params.args, cwd: params.cwd, env: params.env, sudo: params.sudo, wait: true, }), signal: params.signal, }, ); if (!response.ok) { await parseOrThrow(z.any(), response); } if (response.headers.get("content-type") !== "application/x-ndjson") { throw new APIError(response, { message: "Expected a stream of command data", sessionId: params.sessionId, }); } if (response.body === null) { throw new APIError(response, { message: "No response body", sessionId: params.sessionId, }); } const jsonlinesStream = jsonlines.parse(); pipe(response.body, jsonlinesStream, { signal: params.signal }).catch( (err) => { console.error("Error piping command stream:", err); }, ); const iterator = jsonlinesStream[Symbol.asyncIterator](); const commandChunk = await iterator.next(); if (commandChunk.done) { throw new StreamError( "stream_ended_early", "Stream ended before command data was received", params.sessionId, ); } const { command } = CommandResponse.parse(commandChunk.value); const finished = (async () => { const finishedChunk = await iterator.next(); if (finishedChunk.done) { throw new StreamError( "stream_ended_early", "Stream ended before command finished", params.sessionId, ); } const { command } = CommandFinishedResponse.parse(finishedChunk.value); return command; })(); return { command, finished }; } return parseOrThrow( CommandResponse, await this.request(`/v2/sandboxes/sessions/${params.sessionId}/cmd`, {