1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
'use strict'
const fs = require('fs')
const fse = require('fs-extra')
const fetch = require('node-fetch')
const promisifyProcess = require('./promisify-process')
const tempy = require('tempy')
const path = require('path')
const sanitize = require('sanitize-filename')
const { spawn } = require('child_process')
const { promisify } = require('util')
const writeFile = promisify(fs.writeFile)
const copyFile = fse.copy
function makeHTTPDownloader() {
return function(arg) {
const dir = tempy.directory()
const out = dir + '/' + sanitize(decodeURIComponent(path.basename(arg)))
return fetch(arg)
.then(response => response.buffer())
.then(buffer => writeFile(out, buffer))
.then(() => out)
}
}
function makeYouTubeDownloader() {
return function(arg) {
const tempDir = tempy.directory()
const opts = [
'--quiet',
'--extract-audio',
'--audio-format', 'mp3',
'--output', tempDir + '/dl.%(ext)s',
arg
]
return promisifyProcess(spawn('youtube-dl', opts))
.then(() => tempDir + '/dl.mp3')
}
}
function makeLocalDownloader() {
// Usually we'd just return the given argument in a local
// downloader, which is efficient, since there's no need to
// copy a file from one place on the hard drive to another.
// But reading from a separate drive (e.g. a USB stick or a
// CD) can take a lot longer than reading directly from the
// computer's own drive, so this downloader copies the file
// to a temporary file on the computer's drive.
// Ideally, we'd be able to check whether a file is on the
// computer's main drive mount or not before going through
// the steps to copy, but I'm not sure if there's a way to
// do that (and it's even less likely there'd be a cross-
// platform way).
return function(arg) {
const dir = tempy.directory()
// TODO: Is it necessary to sanitize here?
// haha, the answer to "should I sanitize" is probably always
// YES..
const base = path.basename(arg, path.extname(arg))
const file = dir + '/' + sanitize(base) + '.mp3'
return copyFile(arg, file)
.then(() => file)
}
}
function makeLocalEchoDownloader() {
return function(arg) {
// Since we're grabbing the file from the local file system, there's no
// need to download or copy it!
return arg
}
}
function makePowerfulDownloader(downloader, maxAttempts = 5) {
// This should totally be named better..
return async function recursive(arg, attempts = 0) {
try {
return await downloader(arg)
} catch(err) {
if (attempts < maxAttempts) {
console.warn('Failed - attempting again:', arg)
return await recursive(arg, attempts + 1)
} else {
throw err
}
}
}
}
module.exports = {
makeHTTPDownloader,
makeYouTubeDownloader,
makeLocalDownloader,
makePowerfulDownloader,
getDownloaderFor: downloaderType => {
if (downloaderType === 'http') {
return makeHTTPDownloader()
} else if (downloaderType === 'youtube') {
return makeYouTubeDownloader()
} else if (downloaderType === 'local') {
return makeLocalDownloader()
} else {
return null
}
},
getDownloaderFor(arg) {
if (arg.startsWith('http://') || arg.startsWith('https://')) {
if (arg.includes('youtube.com')) {
return makeYouTubeDownloader()
} else {
return makeHTTPDownloader()
}
} else {
return makeLocalDownloader()
}
}
}
|
