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
|
var debug = require('debug')('webtorrent:server')
var http = require('http')
var mime = require('mime')
var pump = require('pump')
var rangeParser = require('range-parser')
var url = require('url')
module.exports = function Server (webtorrent, port) {
var server = http.createServer()
server.on('connection', function (socket) {
socket.setTimeout(36000000)
})
server.on('request', function (req, res) {
debug('onRequest')
var u = url.parse(req.url)
if (u.pathname === '/favicon.ico') return res.end()
if (u.pathname === '/') u.pathname = '/' + webtorrent.index
var i = Number(u.pathname.slice(1))
if (isNaN(i) || i >= webtorrent.torrent.files.length) {
res.statusCode = 404
return res.end()
}
if (webtorrent.torrent) onTorrent(webtorrent.torrent)
else webtorrent.once('torrent', onTorrent)
function onTorrent (torrent) {
var file = torrent.files[i]
res.setHeader('accept-ranges', 'bytes')
res.setHeader('content-type', mime.lookup(file.name))
res.statusCode = 206
var range
if (req.headers.range) {
// no support for multi-range reqs
range = rangeParser(file.length, req.headers.range)[0]
debug('range %s', JSON.stringify(range))
res.setHeader(
'Content-Range',
'bytes ' + range.start + '-' + range.end + '/' + file.length
)
res.setHeader('Content-Length', range.end - range.start + 1)
} else {
res.setHeader('Content-Length', file.length)
}
if (req.method === 'HEAD') res.end()
pump(file.createReadStream(range), res)
}
})
server.listen(port)
return server
}
|
