github/vimeo-private-downloader
1
0
Fork 0
mirror of https://github.com/Tusko/vimeo-private-downloader.git synced 2025-08-21 13:54:24 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

undo file identation changes

Browse source
This commit is contained in:
Felipe Andrada 2020-11-30 01:40:53 -03:00
commit 266a44bbd8
1 changed files with 47 additions and 47 deletions
Download patch file Download diff file Expand all files Collapse all files

50
vimeomaster.js
View file

@ -9,9 +9,9 @@ function loadVideo(num, cb) {
let masterUrl = list[num].url; let masterUrl = list[num].url;
if (!masterUrl.endsWith("?base64_init=1")) { if (!masterUrl.endsWith("?base64_init=1")) {
masterUrl += "?base64_init=1"; masterUrl += "?base64_init=1";
} }
getJson(masterUrl, (err, json) => { getJson(masterUrl, (err, json) => {
if (err) { if (err) {
return cb(err); return cb(err);
} }
@ -59,7 +59,7 @@ function loadVideo(num, cb) {
); );
} }
); );
}); });
} }
function processFile(type, baseUrl, initData, segments, filename, cb) { function processFile(type, baseUrl, initData, segments, filename, cb) {
@ -68,30 +68,30 @@ function processFile(type, baseUrl, initData, segments, filename, cb) {
if(fs.existsSync(downloadingFlag)) { if(fs.existsSync(downloadingFlag)) {
log("⚠️", ` ${filename} - ${type} is incomplete, restarting the download`); log("⚠️", ` ${filename} - ${type} is incomplete, restarting the download`);
} else if (fs.existsSync(filePath)) { } else if (fs.existsSync(filePath)) {
log("⚠️", ` ${filename} - ${type} already exists`); log("⚠️", ` ${filename} - ${type} already exists`);
return cb(); return cb();
} else { } else {
fs.writeFileSync(downloadingFlag, ''); fs.writeFileSync(downloadingFlag, '');
} }
const segmentsUrl = segments.map(seg => baseUrl + seg.url); const segmentsUrl = segments.map(seg => baseUrl + seg.url);
const initBuffer = Buffer.from(initData, "base64"); const initBuffer = Buffer.from(initData, "base64");
fs.writeFileSync(filePath, initBuffer); fs.writeFileSync(filePath, initBuffer);
const output = fs.createWriteStream(filePath, { const output = fs.createWriteStream(filePath, {
flags: "a" flags: "a"
}); });
combineSegments(type, 0, segmentsUrl, output, filePath, downloadingFlag, err => { combineSegments(type, 0, segmentsUrl, output, filePath, downloadingFlag, err => {
if (err) { if (err) {
log("⚠️", ` ${err}`); log("⚠️", ` ${err}`);
} }
output.end(); output.end();
cb(); cb();
}); });
} }
function combineSegments(type, i, segmentsUrl, output, filename, downloadingFlag, cb) { function combineSegments(type, i, segmentsUrl, output, filename, downloadingFlag, cb) {
@ -99,29 +99,29 @@ function combineSegments(type, i, segmentsUrl, output, filename, downloadingFlag
fs.unlinkSync(downloadingFlag); fs.unlinkSync(downloadingFlag);
log("🏁", ` ${filename} - ${type} done`); log("🏁", ` ${filename} - ${type} done`);
return cb(); return cb();
} }
log( log(
"📦", "📦",
type === "video" ? "📹" : "🎧", type === "video" ? "📹" : "🎧",
`Downloading ${type} segment ${i}/${segmentsUrl.length} of ${filename}` `Downloading ${type} segment ${i}/${segmentsUrl.length} of ${filename}`
); );
let req = https let req = https
.get(segmentsUrl[i], res => { .get(segmentsUrl[i], res => {
res.on("data", d => output.write(d)); res.on("data", d => output.write(d));
res.on("end", () => res.on("end", () =>
combineSegments(type, i + 1, segmentsUrl, output, filename, downloadingFlag, cb) combineSegments(type, i + 1, segmentsUrl, output, filename, downloadingFlag, cb)
); );
}) })
.on("error", e => { .on("error", e => {
cb(e); cb(e);
}); });
req.setTimeout(7000, function () { req.setTimeout(7000, function () {
console.log("Timeout. Retrying"); console.log("Timeout. Retrying");
combineSegments(type, i, segmentsUrl, output, filename, downloadingFlag, cb) combineSegments(type, i, segmentsUrl, output, filename, downloadingFlag, cb)
}) })
} }
function getJson(url, cb) { function getJson(url, cb) {
@ -132,10 +132,10 @@ function getJson(url, cb) {
res.on("data", d => (data += d)); res.on("data", d => (data += d));
res.on("end", () => cb(null, JSON.parse(data))); res.on("end", () => cb(null, JSON.parse(data)));
}) })
.on("error", e => { .on("error", e => {
cb(e); cb(e);
}); });
} }
function initJs(n = 0) { function initJs(n = 0) {
@ -150,7 +150,7 @@ function initJs(n = 0) {
if (list[num]) { if (list[num]) {
initJs(num); initJs(num);
} }
}); });
} }
initJs(); initJs();