Function uploadDirectArtifact

src/remote/upload-client.ts:264–291

(
  artifact: PreparedUploadArtifact,
  ticket: Extract<UploadPreflightResult, { kind: 'direct-upload' }>,
  onProgress: UploadProgressSink | undefined,
)

}

async function uploadDirectArtifact(
  artifact: PreparedUploadArtifact,
  ticket: Extract<UploadPreflightResult, { kind: 'direct-upload' }>,
  onProgress: UploadProgressSink | undefined,
): Promise<void> {
  const response = await streamFileToHttpRequest({
    url: new URL(ticket.url),
    method: 'PUT',
    headers: ticket.headers,
    payloadPath: artifact.payloadPath,
    timeoutMessage: 'Direct artifact upload timed out',
    timeoutHint: 'The direct upload ticket did not accept the artifact within the timeout.',
    errorMessage: 'Failed to upload artifact with direct upload ticket',
    retryable: true,
    progress: {
      stage: 'direct',
      fileName: artifact.fileName,
      onProgress,
    },
  });

  if (response.statusCode < 200 || response.statusCode >= 300) {
    throw new AppError('COMMAND_FAILED', 'Direct artifact upload failed', {
      statusCode: response.statusCode,
      statusMessage: response.statusMessage,
    });
  }
}

async function finalizeDirectUpload(options: {
  normalizedBase: string;