Subir objeto

// crear un stream de lectura para subir el objeto
const file = fs.createReadStream("file_path");
// llamar al método de subida
const res = await bucket.putObject("sam/out/sample.txt", file);
console.log(res);

//Subir el objeto como cadena de texto
const res = await bucket.putObject("sam/out/sample.txt", "Content of the file");
console.log(res);

const options = {
'overwrite': true, //Esto sobrescribirá tu objeto existente
'ttl': '300', //tiempo de vida en segundos
'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', //tiempo de vida en segundos
'metaData': {
'author': 'John'
},
// Extraer el contenido del archivo ZIP dado y subir cada archivo como un objeto separado al 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();
// crear una instancia del bucket
const bucket = stratus.bucket("bucket_name");
// Subida multipart
const key = 'sample.mp4';
// iniciar subida multiparte
const initRes = await bucket.initiateMultipartUpload(key);
// obtener el Id de subida de la respuesta de inicio de subida.
const uploadId = initRes['upload_id'];
const filePath = '/Users/Aliza//sam.mp4';
const partSize = 50 * 1024 * 1024; // en MB
const fileStream = fs.createReadStream(
filePath,
{ highWaterMark: partSize }
);
let partNumber = 1;
const uploadPromises = [];
fileStream.on('data', async (partData) => {
// Agregar cada subida de parte al arreglo de promesas para subida en paralelo
const partUploadPromise = bucket.uploadPart(
key,
uploadId,
partData,
partNumber
);
uploadPromises.push(partUploadPromise);
console.log('Part Number: ', partNumber);
partNumber++;
});
// Esperar a que todas las partes se suban en paralelo
fileStream.on('end', async () => {			
await Promise.all(uploadPromises);
// Completar la subida multipart
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); // crear instancia de transfer manager

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

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 // en 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, // tiempo de expiración en segundos
'activeFrom':'12334454327', // activar la URL en la fecha dada
});
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');
// Reemplazar esto con la URL pre-firmada real generada para tu subida.
const url = 'https://sadi-development.zohostratus.com/_signed/text.txt?organizationId=96862383&stsCredential=96858154-96862383&stsDate=1747911331272&stsExpiresAfter=300&stsSignedHeaders=host&stsSignature=K9vuqC7JaATLeM3TX4xXWx0OHcSflbYQ2jCrbKSAAIE';
// Reemplazar 'file_path' con la ruta real de tu archivo
const data = fs.createReadStream('/Users/ranjitha-18338/Documents/NODE-SDK/Stratus/sam.py');
// Encabezados opcionales; el tipo de contenido puede variar según el tipo de archivo
const headers = {
// 'Content-Type': 'application/json', 
// ajustar si se suben archivos no JSON (ej., 'text/plain' o 'application/octet-stream')
// 'overwrite': 'true', // encabezado opcional
};
(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);
}
})();