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

export const putObject = async (uploadFilePath, fileStream) => {
    const upload = new Upload({
        params: {
            Bucket: process.env.AWS_BUCKET,
            Key: uploadFilePath,
            Body: fileStream,
        },
        client: new S3Client({
            region: process.env.AWS_REGION,
            credentials: {
                accessKeyId: process.env.AWS_ACCESS_KEY,
                secretAccessKey: process.env.AWS_SECRET_KEY,
            },
        }),
        queueSize: 3,
    });

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

    await upload.done();
};