lib/lib-storage/example-code/upload-unknown-length-browser.ts

import { fromCognitoIdentityPool } from "@aws-sdk/credential-provider-cognito-identity";
import { CognitoIdentityClient } from "@aws-sdk/client-cognito-identity";

import { S3Client } from "@aws-sdk/client-s3";
import { Upload } from "@aws-sdk/lib-storage";

import { configuration } from "./config";

const idPool = "us-west-2:XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX";
const Bucket = configuration.Bucket;
const region = "us-west-2";

const sleep = async (seconds: number) => {
  return new Promise((resolve) => setTimeout(resolve, seconds * 1000));
};

const fakeStreamOfUnknownlength = new ReadableStream({
  start: async (controller) => {
    for (let index = 0; index < 8; index++) {
      const time = Math.random() * 5;
      await sleep(time);
      console.log(`Delaying part ${index} for ${time}`);
      controller.enqueue(`[part ${index}] with ${"#".repeat(2000000)}`);
    }
    controller.close();
  },
});

const uploadIndeterminateLengthStreamBrowser = async () => {
  const client = new S3Client({
    region,
    credentials: fromCognitoIdentityPool({
      client: new CognitoIdentityClient({ region }),
      identityPoolId: idPool,
    }),
  });

  const Key = configuration.Key;

  let upload = new Upload({
    client,
    params: {
      Key,
      Bucket,
      Body: fakeStreamOfUnknownlength,
    },
  });

  upload.on("httpUploadProgress", (progress: ProgressEvent) => {
    console.log(progress);
  });

  const uploadResult = await upload.done();
  console.log("done uploading", uploadResult);
};

uploadIndeterminateLengthStreamBrowser();