Upload Object

// create a read stream for upload the object
const file = fs.createReadStream("file_path");
// call the upload method
await bucket.putObject("sam/out/sample.txt", file);

// Upload object as a string
await bucket.putObject("sam/out/sample.txt", "Content of the file");

const options = {
    'overwrite': true, //This will overwrite your existing object
    'ttl': '300', //time to live in seconds
    'metaData': {
        'author': 'John'
    }
};
const file = fs.createReadStream("filePath");
await bucket.putObject("sam/out/sample.txt", file, options);

const options = {
    'ttl': '300', //time to live in seconds
    'metaData': {
        'author': 'John'
    },
    // Extract the contents of the given ZIP file and upload each file as a separate object to the bucket
    'extractUpload': true
};
const file = fs.createReadStream("filePath");
await bucket.putObject("sam/out/sample.zip", file, options);

const initRes = await bucket.initiateMultipartUpload("sam/out/sample.txt");
console.log(initRes);

{
  "bucket": "zcstratus123-development",
  "key": "sam/out/sample.txt",
  "upload_id": "01j7xbm4vm5750zbedxqgc4q6m",
  "status": "PENDING"
}

const partNumber = 1;
const file = fs.createReadStream("filePath");
await bucket.uploadPart("sam/out/sample.txt", "uploadId", file, partNumber);

const uploadSummaryRes = await bucket.getMultipartUploadSummary("sam/out/sample.txt", "upload_id");
console.log(uploadSummaryRes);

{
    "bucket": "zcstratus12345-development",
    "key": "sam/out/sample.txt",
    "upload_id": "01hyfyeazrrstmt7k5fa7ej726",
    "status": "PENDING",
    "parts": [
        {
            "part_number": 1,
            "size": 0,
            "uploaded_at": 1716374678999
        },
        {
            "part_number": 2,
            "size": 2797094,
            "uploaded_at": 1716374678576
        },
        {
            "part_number": 4,
            "size": 0,
            "uploaded_at": 1716374679136
        }
    ]
}

const fs = require('fs');
module.exports = async (req, res) => {
	url = req.url;
	switch (url) {
 	case '/':
  	const auth = new ZCAuth();
    const authInit = await auth.init(req);
 		const stratus = new Stratus();
	/** create a bucket instance  */
	const bucket = stratus.bucket("bucket_name");
	/** multipart upload */
	const key = 'sample.mp4';
		// initiate multipart upload
	const initRes = await bucket.initiateMultipartUpload(key);		
		// get upload Id from initiate upload response.
	const uploadId = initRes['upload_id'];
	const filePath = '/Users/Aliza//sam.mp4';
	const partSize = 50 * 1024 * 1024; // in Mb
	const fileStream = fs.createReadStream(
				filePath,
				{ highWaterMark: partSize }
		);
	let partNumber = 1;
	const uploadPromises = [];
	fileStream.on('data', async (partData) => {
		// Push each part upload to the promises array for parallel upload
		const partUploadPromise = bucket.uploadPart(
						key,
						uploadId,
						partData,
						partNumber
			);
		uploadPromises.push(partUploadPromise);
		console.log('Part Number: ', partNumber);
		partNumber++;
	});
	// Wait for all parts to be uploaded in parallel
fileStream.on('end', async () => { 		
	await Promise.all(uploadPromises);
	// Complete the multipart upload
	await bucket.completeMultipartUpload(key, uploadId);
		console.log('Successfully Uploaded');
});
	res.end();
	break;
default:
	res.writeHead(404);
	res.write('You might find the page you are looking for at "/" path');
	break;
}
}

const transferManager = new TransferManager(bucket); // create transfer manager instance

const multipart = await transferManager.createMultipartInstance("sam/out/sample.txt"); // create multipart instance

const multipart = await transferManager.createMultipartInstance("sam/out/sample.txt", "uploadId");

await multipart.uploadPart(fs.createReadStream("filePath"), partNumber);

const summaryRes = await multipart.getUploadSummary();
console.log(summaryRes);

await multipart.completeUpload();

const file = fs.createReadStream("filePath");
const partSize = 50 // in MB
const objectPartUploadRes = await transferManager.putObjectAsParts("sam/out/sample.txt",file, partSize);
console.log(objectPartUploadRes);

const signedURLRes = await bucket.generatePreSignedUrl("sam/out/sample.txt", 'PUT', {
    'expiryIn': 100, // expiry time in seconds
    'activeFrom':'12334454327', // activate the url in the given date
});
console.log(signedURLRes);

{
  signature: "https://sadi-development.zohostratus.com/_signed/text.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747896279887&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=3YBUX1HFSxNQzQJjFrln82AyJsEEuC5T9dsZwWxGyEE"
}

const axios = require('axios');
const fs = require('fs');
// Replace this with the actual pre-signed URL generated for your upload.
const url = ‘https: //sadi-development.zohostratus.com/_signed/text.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747911331272&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=K9vuqC7JaATLeM3TX4xXWx0OHcSflbYQ2jCrbKSAAIE';
    // Replace ‘file_path’ with your actual file path
    const data = fs.createReadStream(’/Users/amelia - 426 / Documents / JavaScript - SDK / Stratus / sam.py’);
// Optional headers; content type may vary depending on the file type
const headers = {
    // ‘Content-Type’: ‘application/json’, // adjust if uploading non-JSON files (e.g., ’text/plain’ or ‘application/octet-stream’)
    // ‘overwrite’: ’true’, // optional header
};
(async () => {
    try {
        const response = await axios.put(url, data, {
            headers
        });
        if (response.status === 200) {
            console.log('Object uploaded successfully');
        } else {
            console.log('⚠️ Error uploading object:', response.data);
        }
    } catch (error) {
        console.error('Upload failed:', error.response?.data || error.message);
    }
})();