const needle = require('needle');
const fs = require('fs');
const path = require('path');
const [, scriptName, filename, uploadURL] = process.argv;
if (!filename || !uploadURL) {
console.error(`Usage: node ${path.basename(scriptName)} filename upload_url`);
process.exit(-1);
}
async function uploadFile(file, url) {
// rangeEnd फ़ाइल में अंतिम बाइट का इंडेक्स है, यानी फ़ाइल में कुल बाइट्स की संख्या
const rangeEnd = (await fs.promises.stat(file)).size;
let options = {
headers: {
'Content-Range': `bytes */${rangeEnd}`,
},
};
const response = await needle('put', url, null, options);
switch (response.statusCode) {
case 200:
case 201:
console.log('अपलोड पूर्ण');
return;
case 308:
return resumeUpload(response, file, url);
default:
console.log('अप्रत्याशित रिस्पॉन्स कोड मिला: ', response.statusCode);
return;
}
}
async function resumeUpload(response, file, url) {
console.log('अपलोड पूरा नहीं हुआ, फिर से शुरू हो रहा है');
if (response.headers.range) {
let resumeOffset = Number(response.headers.range.split('-')[1]) + 1;
let options = {
headers: {
'Content-Range': `bytes ${resumeOffset}-${rangeEnd-1}/${rangeEnd}`,
'Content-Length': `${rangeEnd-resumeOffset}`,
},
};
let readStream = fs.createReadStream(file, {start: resumeOffset});
return needle('put', url, readStream, options);
} else {
console.log('अपलोड शुरू किया जा रहा है');
let options = {
headers: {
'Content-Type': 'text/plain'
}
};
let readStream = fs.createReadStream(file);
return needle('put', url, readStream, options);
}
}
// Resumable session URL का अनुरोध करें
async function requestResumableSession(url) {
const options = {
headers: {
'Content-Type': 'text/plain',
'Content-Length': '0',
'x-goog-resumable': 'start',
},
};
const res = await needle('post', url, null, options);
if (res.statusCode === 201) {
const resumableSessionURL = res.headers['location'];
console.log('यहाँ अपलोड शुरू हो रहा है: ', resumableSessionURL);
await uploadFile(filename, resumableSessionURL);
} else {
console.log('Resumable session URI बनाने में विफल');
}
}
requestResumableSession(uploadURL).then(result => console.log('अपलोड पूर्ण'));
