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

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

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");
const uploadRes = await bucket.putObject("sam/out/sample.txt", file, options);
console.log(uploadRes);

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");
const uploadRes = await bucket.putObject("sam/out/sample.zip", file, options);
console.log(uploadRes);

{ 'task_id': '1234263749' }

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"
}

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

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 completeUploadRes = await bucket.completeMultipartUpload("sam/out/sample.txt", "uploadId");
console.log(completeUploadRes);

const catalyst = require('zcatalyst-sdk-node');
const fs = require('fs');
module.exports = async (req, res) => {
	url = req.url;
	switch (url) {
 	case '/':
  	const app = catalyst.initialize(req);
 		const stratus = app.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 } = require('zcatalyst-sdk-node/lib/stratus');

 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");

const uploadRes = await multipart.uploadPart(fs.createReadStream("filePath"), partNumber);
console.log(uploadRes);

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

const completeRes = await multipart.completeUpload();
console.log(completeRes);

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/ranjitha-18338/Documents/NODE-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);
}

})();