Function startImageUpload

app/src/modules/image-upload.js:180–224

(image)

}

async function startImageUpload(image) {
  if (!image || !S.ws || S.ws.readyState !== WebSocket.OPEN) {
    throw new Error('Connection unavailable');
  }

  image.status = 'uploading';
  image.progress = 0;
  image.uploadedBytes = 0;
  updateImagePreviewUi();

  const totalChunks = Math.max(1, Math.ceil(image.file.size / IMAGE_CHUNK_BYTES));
  let waitForStatus = waitForUploadStatus(image.uploadId, ['ready_for_chunks']);
  S.ws.send(JSON.stringify({
    type: 'image_upload_init',
    uploadId: image.uploadId,
    totalBytes: image.file.size,
    totalChunks,
    mediaType: image.mediaType,
    name: image.name,
  }));
  await waitForStatus;

  for (let index = 0; index < totalChunks; index++) {
    const start = index * IMAGE_CHUNK_BYTES;
    const end = Math.min(image.file.size, start + IMAGE_CHUNK_BYTES);
    const base64 = await fileChunkToBase64(image.file.slice(start, end));
    waitForStatus = waitForUploadStatus(image.uploadId, ['uploading'], msg => msg.chunkIndex === index);
    S.ws.send(JSON.stringify({
      type: 'image_upload_chunk',
      uploadId: image.uploadId,
      index,
      base64,
    }));
    await waitForStatus;
  }

  waitForStatus = waitForUploadStatus(image.uploadId, ['uploaded']);
  S.ws.send(JSON.stringify({ type: 'image_upload_complete', uploadId: image.uploadId }));
  await waitForStatus;

  const currentImage = pendingImage;
  if (currentImage && currentImage.uploadId === image.uploadId && currentImage.submitQueued) {
    await submitPendingImageUpload();
  }
}

export function initImageUpload() {
  $('btn-image').addEventListener('click', () => {