Function requireResumableUpload

src/daemon/resumable-upload.ts:199–211

(
  uploadId: string,
  tenantId: string | undefined,
)

}

function requireResumableUpload(
  uploadId: string,
  tenantId: string | undefined,
): ResumableUploadEntry {
  const entry = RESUMABLE_UPLOADS_BY_ID.get(uploadId);
  if (!entry) {
    throw new AppError('INVALID_ARGS', `Upload not found: ${uploadId}`);
  }
  if (entry.tenantId && entry.tenantId !== tenantId) {
    throw new AppError('UNAUTHORIZED', 'Upload belongs to a different tenant');
  }
  return entry;
}

function currentResumableUploadOffset(entry: ResumableUploadEntry): number {
  if (!fs.existsSync(entry.payloadPath)) return 0;