Function finalizeResumableUpload

src/daemon/resumable-upload.ts:99–140

(
  uploadId: string,
  tenantId?: string,
)

}

export async function finalizeResumableUpload(
  uploadId: string,
  tenantId?: string,
): Promise<{ artifactPath: string; tempDir: string }> {
  const entry = requireResumableUpload(uploadId, tenantId);
  const offset = currentResumableUploadOffset(entry);
  if (offset !== entry.sizeBytes) {
    throw new AppError('INVALID_ARGS', 'Upload is incomplete', {
      uploadId,
      offset,
      sizeBytes: entry.sizeBytes,
    });
  }
  const actualHash = await computeFileHash(entry.payloadPath);
  if (actualHash !== entry.sha256) {
    cleanupResumableUpload(entry.id);
    throw new AppError('INVALID_ARGS', 'Upload hash mismatch', {
      uploadId,
      expectedSha256: entry.sha256,
      actualSha256: actualHash,
    });
  }

  RESUMABLE_UPLOADS_BY_ID.delete(entry.id);
  RESUMABLE_UPLOADS_BY_KEY.delete(entry.key);
  clearTimeout(entry.timer);

  if (entry.artifactType === 'file') {
    const artifactPath = path.join(entry.tempDir, entry.fileName);
    fs.renameSync(entry.payloadPath, artifactPath);
    return { artifactPath, tempDir: entry.tempDir };
  }

  const artifactPath = await extractTarInstallableArtifact({
    archivePath: entry.payloadPath,
    tempDir: entry.tempDir,
    platform: entry.platform === 'android' ? 'android' : 'ios',
    expectedRootName: entry.fileName,
  });
  fs.rmSync(entry.payloadPath, { force: true });
  return { artifactPath, tempDir: entry.tempDir };
}

function validateResumableUploadOptions(options: BeginResumableUploadOptions): void {
  if (!/^[a-f0-9]{64}$/i.test(options.sha256)) {