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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
'use strict'
const fs = require('fs')
const fse = require('fs-extra')
const fetch = require('node-fetch')
const tempy = require('tempy')
const path = require('path')
const sanitize = require('sanitize-filename')
const promisifyProcess = require('./promisify-process')
const commandExists = require('./command-exists')
const { spawn } = require('child_process')
const { promisify } = require('util')
const writeFile = promisify(fs.writeFile)
const copyFile = fse.copy
// Pseudo-tempy!!
/*
const tempy = {
directory: () => './tempy-fake'
}
*/
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')
.catch(err => false)
}
}
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) {
// It's possible the downloader argument start with the "file://" protocol
// string; in that case we'll want to snip it off and URL-decode the
// string.
const fileProto = 'file://'
if (arg.startsWith(fileProto)) {
arg = decodeURIComponent(arg.slice(fileProto.length))
}
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
}
}
}
}
async function makeConverter(
converterCommand = null, exportExtension = 'wav',
converterOptions = ['-i', '$in', '$out']
) {
if (converterCommand === null) {
throw new Error(
'A converter is required! Try installing ffmpeg or avconv?'
)
}
return function(converterOptions = ['-i', '$in', '$out']) {
return async function(inFile) {
const base = path.basename(inFile, path.extname(inFile))
const tempDir = tempy.directory()
const outFile = `${tempDir}/${base}.${exportExtension}`
const processedOptions = converterOptions.slice(0)
// And some people say JavaScript isn't awesome!?
for (const [ i, item ] of processedOptions.entries()) {
if (item === '$in') {
processedOptions[i] = inFile
} else if (item === '$out') {
processedOptions[i] = outFile
}
}
await promisifyProcess(
spawn(converterCommand, processedOptions), false
)
return outFile
}
}
}
module.exports = {
makeHTTPDownloader,
makeYouTubeDownloader,
makeLocalDownloader,
makePowerfulDownloader,
makeConverter,
byName: {
'http': makeHTTPDownloader,
'local': makeLocalDownloader,
'file': makeLocalDownloader,
'youtube': makeYouTubeDownloader,
'youtube-dl': makeYouTubeDownloader
},
getDownloaderFor(arg) {
if (arg.startsWith('http://') || arg.startsWith('https://')) {
if (arg.includes('youtube.com')) {
return makeYouTubeDownloader()
} else {
return makeHTTPDownloader()
}
} else {
return makeLocalDownloader()
}
}
}
|
