d2542c9a62
Squash the current repository state back into one baseline commit while preserving the README reframing and repository contents. Constraint: User explicitly requested a single squashed commit with subject "asdf" Confidence: high Scope-risk: broad Reversibility: clean Directive: This commit intentionally rewrites published history; coordinate before future force-pushes Tested: git status clean; local history rewritten to one commit; force-pushed main to origin and instructkr Not-tested: Fresh clone verification after push
89 lines
2.1 KiB
TypeScript
89 lines
2.1 KiB
TypeScript
/* eslint-disable eslint-plugin-n/no-unsupported-features/node-builtins */
|
|
|
|
import { errorMessage } from '../utils/errors.js'
|
|
import { jsonStringify } from '../utils/slowOperations.js'
|
|
import type { DirectConnectConfig } from './directConnectManager.js'
|
|
import { connectResponseSchema } from './types.js'
|
|
|
|
/**
|
|
* Errors thrown by createDirectConnectSession when the connection fails.
|
|
*/
|
|
export class DirectConnectError extends Error {
|
|
constructor(message: string) {
|
|
super(message)
|
|
this.name = 'DirectConnectError'
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create a session on a direct-connect server.
|
|
*
|
|
* Posts to `${serverUrl}/sessions`, validates the response, and returns
|
|
* a DirectConnectConfig ready for use by the REPL or headless runner.
|
|
*
|
|
* Throws DirectConnectError on network, HTTP, or response-parsing failures.
|
|
*/
|
|
export async function createDirectConnectSession({
|
|
serverUrl,
|
|
authToken,
|
|
cwd,
|
|
dangerouslySkipPermissions,
|
|
}: {
|
|
serverUrl: string
|
|
authToken?: string
|
|
cwd: string
|
|
dangerouslySkipPermissions?: boolean
|
|
}): Promise<{
|
|
config: DirectConnectConfig
|
|
workDir?: string
|
|
}> {
|
|
const headers: Record<string, string> = {
|
|
'content-type': 'application/json',
|
|
}
|
|
if (authToken) {
|
|
headers['authorization'] = `Bearer ${authToken}`
|
|
}
|
|
|
|
let resp: Response
|
|
try {
|
|
resp = await fetch(`${serverUrl}/sessions`, {
|
|
method: 'POST',
|
|
headers,
|
|
body: jsonStringify({
|
|
cwd,
|
|
...(dangerouslySkipPermissions && {
|
|
dangerously_skip_permissions: true,
|
|
}),
|
|
}),
|
|
})
|
|
} catch (err) {
|
|
throw new DirectConnectError(
|
|
`Failed to connect to server at ${serverUrl}: ${errorMessage(err)}`,
|
|
)
|
|
}
|
|
|
|
if (!resp.ok) {
|
|
throw new DirectConnectError(
|
|
`Failed to create session: ${resp.status} ${resp.statusText}`,
|
|
)
|
|
}
|
|
|
|
const result = connectResponseSchema().safeParse(await resp.json())
|
|
if (!result.success) {
|
|
throw new DirectConnectError(
|
|
`Invalid session response: ${result.error.message}`,
|
|
)
|
|
}
|
|
|
|
const data = result.data
|
|
return {
|
|
config: {
|
|
serverUrl,
|
|
sessionId: data.session_id,
|
|
wsUrl: data.ws_url,
|
|
authToken,
|
|
},
|
|
workDir: data.work_dir,
|
|
}
|
|
}
|