import { toExactArrayBuffer } from "./bytes.js";import {	type LiveMountDescriptor,	type LivePackageDescriptor,	type LiveProjectedModuleDescriptor,	type LiveSidecarPlacement,	type LiveSoftwareDescriptor,	toGeneratedMountDescriptor,	toGeneratedPackageDescriptor,	toGeneratedProjectedModuleDescriptor,	toGeneratedSidecarPlacement,	toGeneratedSoftwareDescriptor,} from "./descriptors.js";import { type LiveExtEnvelope, toGeneratedExtEnvelope } from "./ext.js";import {	type LiveRootFilesystemEntry,	type LiveRootFilesystemEntryEncoding,	toGeneratedRootFilesystemEntry,} from "./filesystem.js";import type { CreateVmConfig } from "./generated/CreateVmConfig.js";import type * as protocol from "./generated-protocol.js";import { stringifyJsonUtf8 } from "./json.js";import {	type LivePermissionsPolicy,	toGeneratedPermissionsPolicy,} from "./permissions.js";import {	type LiveDisposeReason,	type LiveFilesystemOperation,	type LiveGuestFilesystemOperation,	type LiveGuestRuntimeKind,	type LiveRootFilesystemMode,	type LiveWasmPermissionTier,	toGeneratedDisposeReason,	toGeneratedFilesystemOperation,	toGeneratedGuestFilesystemOperation,	toGeneratedGuestRuntimeKind,	toGeneratedRootFilesystemEntryEncoding,	toGeneratedRootFilesystemMode,	toGeneratedWasmPermissionTier,} from "./protocol-maps.js"; export interface LiveRegisteredHostCallbackExample {	description: string;	input: unknown;} export interface LiveRegisteredHostCallbackDefinition {	description: string;	input_schema: unknown;	timeout_ms?: number;	examples?: LiveRegisteredHostCallbackExample[];} export type LiveRequestPayload =	| {			type: "authenticate";			client_name: string;			auth_token: string;			protocol_version: number;			bridge_version: number;	  }	| {			type: "open_session";			placement: LiveSidecarPlacement;			metadata: Record<string, string>;	  }	| {			type: "create_vm";			runtime: LiveGuestRuntimeKind;			config: CreateVmConfig;	  }	| {			type: "configure_vm";			mounts: LiveMountDescriptor[];			software: LiveSoftwareDescriptor[];			permissions?: LivePermissionsPolicy;			module_access_cwd?: string;			instructions: string[];			projected_modules: LiveProjectedModuleDescriptor[];			command_permissions: Record<string, LiveWasmPermissionTier>;			loopback_exempt_ports?: number[];			packages?: LivePackageDescriptor[];			packages_mount_at?: string;			bootstrap_commands?: string[];			binding_shim_commands?: string[];	  }	| {			type: "link_package";			package: LivePackageDescriptor;	  }	| {			type: "provided_commands";	  }	| {			type: "register_host_callbacks";			name: string;			description: string;			command_aliases?: string[];			registry_command_aliases?: string[];			callbacks: Record<string, LiveRegisteredHostCallbackDefinition>;	  }	| {			type: "dispose_vm";			reason: LiveDisposeReason;	  }	| {			type: "bootstrap_root_filesystem";			entries: LiveRootFilesystemEntry[];	  }	| {			type: "create_layer";	  }	| {			type: "seal_layer";			layer_id: string;	  }	| {			type: "import_snapshot";			entries: LiveRootFilesystemEntry[];	  }	| {			type: "export_snapshot";			layer_id: string;	  }	| {			type: "create_overlay";			mode?: LiveRootFilesystemMode;			upper_layer_id?: string;			lower_layer_ids: string[];	  }	| {			type: "snapshot_root_filesystem";			max_bytes: number;	  }	| {			type: "list_mounts";	  }	| {			type: "guest_kernel_call";			execution_id: string;			operation: string;			payload: ArrayBuffer;	  }	| {			type: "guest_filesystem_call";			operation: LiveGuestFilesystemOperation;			path: string;			destination_path?: string;			target?: string;			content?: string;			encoding?: LiveRootFilesystemEntryEncoding;			recursive?: boolean;			max_depth?: number;			mode?: number;			uid?: number;			gid?: number;			atime_ms?: number;			mtime_ms?: number;			len?: number;			offset?: number;	  }	| {			type: "execute";			process_id: string;			command?: string;			runtime?: LiveGuestRuntimeKind;			entrypoint?: string;			args: string[];			env?: Record<string, string>;			cwd?: string;			wasm_permission_tier?: LiveWasmPermissionTier;	  }	| {			type: "write_stdin";			process_id: string;			chunk: Uint8Array;	  }	| {			type: "resize_pty";			process_id: string;			cols: number;			rows: number;	  }	| {			type: "close_stdin";			process_id: string;	  }	| {			type: "kill_process";			process_id: string;			signal: string;	  }	| {			type: "get_process_snapshot";	  }	| {			type: "get_resource_snapshot";	  }	| {			type: "find_listener";			host?: string;			port?: number;			path?: string;	  }	| {			type: "find_bound_udp";			host?: string;			port?: number;	  }	| {			type: "vm_fetch";			port: number;			method: string;			path: string;			headers_json: string;			body?: string;	  }	| {			type: "get_signal_state";			process_id: string;	  }	| {			type: "get_zombie_timer_count";	  }	| {			type: "host_filesystem_call";			operation: LiveFilesystemOperation;			path: string;			payload_size_bytes: number;	  }	| {			type: "persistence_load";			key: string;	  }	| {			type: "persistence_flush";			key: string;			payload_size_bytes: number;	  }	| {			type: "ext";			envelope: LiveExtEnvelope;	  }; export function toGeneratedRequestPayload(	payload: LiveRequestPayload,): protocol.RequestPayload {	switch (payload.type) {		case "authenticate":			return {				tag: "AuthenticateRequest",				val: {					clientName: payload.client_name,					authToken: payload.auth_token,					protocolVersion: payload.protocol_version,					bridgeVersion: payload.bridge_version,				},			};		case "open_session":			return {				tag: "OpenSessionRequest",				val: {					placement: toGeneratedSidecarPlacement(payload.placement),					metadata: new Map(Object.entries(payload.metadata ?? {})),				},			};		case "create_vm":			return {				tag: "CreateVmRequest",				val: {					runtime: toGeneratedGuestRuntimeKind(payload.runtime),					config: stringifyJsonUtf8(payload.config, "create VM config"),				},			};		case "dispose_vm":			return {				tag: "DisposeVmRequest",				val: { reason: toGeneratedDisposeReason(payload.reason) },			};		case "bootstrap_root_filesystem":			return {				tag: "BootstrapRootFilesystemRequest",				val: { entries: payload.entries.map(toGeneratedRootFilesystemEntry) },			};		case "configure_vm":			return {				tag: "ConfigureVmRequest",				val: {					mounts: (payload.mounts ?? []).map(toGeneratedMountDescriptor),					software: (payload.software ?? []).map(toGeneratedSoftwareDescriptor),					permissions: toGeneratedPermissionsPolicy(payload.permissions),					moduleAccessCwd: payload.module_access_cwd ?? null,					instructions: payload.instructions ?? [],					projectedModules: (payload.projected_modules ?? []).map(						toGeneratedProjectedModuleDescriptor,					),					commandPermissions: new Map(						Object.entries(payload.command_permissions ?? {}).map(							([name, tier]) => [name, toGeneratedWasmPermissionTier(tier)],						),					),					loopbackExemptPorts: new Uint16Array(						payload.loopback_exempt_ports ?? [],					),					packages: (payload.packages ?? []).map(toGeneratedPackageDescriptor),					packagesMountAt: payload.packages_mount_at ?? "",					bootstrapCommands: payload.bootstrap_commands ?? [],					bindingShimCommands: payload.binding_shim_commands ?? [],				},			};		case "link_package":			return {				tag: "LinkPackageRequest",				val: {					package: toGeneratedPackageDescriptor(payload.package),				},			};		case "provided_commands":			return {				tag: "ProvidedCommandsRequest",				val: null,			};		case "register_host_callbacks":			return {				tag: "RegisterHostCallbacksRequest",				val: {					name: payload.name,					description: payload.description,					commandAliases: payload.command_aliases ?? [],					registryCommandAliases: payload.registry_command_aliases ?? [],					callbacks: new Map(						Object.entries(payload.callbacks).map(([name, callback]) => [							name,							{								description: callback.description,								inputSchema: stringifyJsonUtf8(									callback.input_schema,									"register_host_callbacks.callback.input_schema",								),								timeoutMs:									callback.timeout_ms === undefined										? null										: BigInt(callback.timeout_ms),								examples: (callback.examples ?? []).map((example) => ({									description: example.description,									input: stringifyJsonUtf8(										example.input,										"register_host_callbacks.callback.example.input",									),								})),							},						]),					),				},			};		case "create_layer":			return { tag: "CreateLayerRequest", val: null };		case "seal_layer":			return { tag: "SealLayerRequest", val: { layerId: payload.layer_id } };		case "import_snapshot":			return {				tag: "ImportSnapshotRequest",				val: { entries: payload.entries.map(toGeneratedRootFilesystemEntry) },			};		case "export_snapshot":			return {				tag: "ExportSnapshotRequest",				val: { layerId: payload.layer_id },			};		case "create_overlay":			return {				tag: "CreateOverlayRequest",				val: {					mode: toGeneratedRootFilesystemMode(payload.mode ?? "ephemeral"),					upperLayerId: payload.upper_layer_id ?? null,					lowerLayerIds: payload.lower_layer_ids ?? [],				},			};		case "guest_filesystem_call":			return {				tag: "GuestFilesystemCallRequest",				val: {					operation: toGeneratedGuestFilesystemOperation(payload.operation),					path: payload.path,					destinationPath: payload.destination_path ?? null,					target: payload.target ?? null,					content: payload.content ?? null,					encoding:						payload.encoding === undefined							? null							: toGeneratedRootFilesystemEntryEncoding(payload.encoding),					recursive: payload.recursive ?? false,					maxDepth: payload.max_depth ?? null,					mode: payload.mode ?? null,					uid: payload.uid ?? null,					gid: payload.gid ?? null,					atimeMs: toGeneratedOptionalU64(payload.atime_ms),					mtimeMs: toGeneratedOptionalU64(payload.mtime_ms),					len: toGeneratedOptionalU64(payload.len),					offset: toGeneratedOptionalU64(payload.offset),				},			};		case "guest_kernel_call":			return {				tag: "GuestKernelCallRequest",				val: {					executionId: payload.execution_id,					operation: payload.operation,					payload: payload.payload,				},			};		case "snapshot_root_filesystem":			return {				tag: "SnapshotRootFilesystemRequest",				val: { maxBytes: BigInt(payload.max_bytes) },			};		case "list_mounts":			return { tag: "ListMountsRequest", val: null };		case "execute":			return {				tag: "ExecuteRequest",				val: {					processId: payload.process_id,					command: payload.command ?? null,					runtime:						payload.runtime === undefined							? null							: toGeneratedGuestRuntimeKind(payload.runtime),					entrypoint: payload.entrypoint ?? null,					args: payload.args ?? [],					env: new Map(Object.entries(payload.env ?? {})),					cwd: payload.cwd ?? null,					wasmPermissionTier:						payload.wasm_permission_tier === undefined							? null							: toGeneratedWasmPermissionTier(payload.wasm_permission_tier),				},			};		case "write_stdin":			return {				tag: "WriteStdinRequest",				val: {					processId: payload.process_id,					chunk: toExactArrayBuffer(payload.chunk),				},			};		case "resize_pty":			return {				tag: "ResizePtyRequest",				val: {					processId: payload.process_id,					cols: payload.cols,					rows: payload.rows,				},			};		case "close_stdin":			return {				tag: "CloseStdinRequest",				val: { processId: payload.process_id },			};		case "kill_process":			return {				tag: "KillProcessRequest",				val: { processId: payload.process_id, signal: payload.signal },			};		case "get_process_snapshot":			return { tag: "GetProcessSnapshotRequest", val: null };		case "get_resource_snapshot":			return { tag: "GetResourceSnapshotRequest", val: null };		case "find_listener":			return {				tag: "FindListenerRequest",				val: {					host: payload.host ?? null,					port: payload.port ?? null,					path: payload.path ?? null,				},			};		case "find_bound_udp":			return {				tag: "FindBoundUdpRequest",				val: { host: payload.host ?? null, port: payload.port ?? null },			};		case "vm_fetch":			return {				tag: "VmFetchRequest",				val: {					port: payload.port,					method: payload.method,					path: payload.path,					headersJson: payload.headers_json,					body: payload.body ?? null,				},			};		case "get_signal_state":			return {				tag: "GetSignalStateRequest",				val: { processId: payload.process_id },			};

Lines 1–500 of 535. Load more