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
|
// TODO: move vlc/airplay/etc. functionality from cmd.js to the module
module.exports = WebTorrent
var Client = require('bittorrent-client')
var concat = require('concat-stream')
var debug = require('debug')('webtorrent')
var extend = require('extend.js')
var fs = require('fs')
var FSStorage = require('./lib/fs-storage')
var hh = require('http-https')
var inherits = require('inherits')
var parallel = require('run-parallel')
var parseTorrent = require('parse-torrent')
var Server = require('./lib/server')
inherits(WebTorrent, Client)
function WebTorrent (opts) {
var self = this
if (!opts) opts = {}
debug('new webtorrent')
Client.call(self, opts)
self.listening = false
if (opts.list) return
if (opts.port !== false && typeof Server === 'function') {
self.server = new Server(self, opts.port)
self.server.on('listening', function () {
self.listening = true
self.emit('listening')
})
}
self.on('torrent', self._onTorrent.bind(self))
}
/**
* Add a new torrent to the client. `torrentId` can be one of:
*
* - magnet uri (utf8 string)
* - torrent file (buffer)
* - info hash (hex string or buffer)
* - parsed torrent (from parse-torrent module)
* - http/https url to a .torrent file (string)
* - filesystem path to a .torrent file (string)
*
* @override
* @param {string|Buffer|Object} torrentId torrent (choose from above list)
* @param {Object} opts optional torrent-specific options
* @param {function=} ontorrent called when the torrent is ready (has metadata)
*/
WebTorrent.prototype.add =
WebTorrent.prototype.download = function (torrentId, opts, ontorrent) {
var self = this
if (typeof opts === 'function') {
ontorrent = opts
opts = {}
}
debug('add %s', torrentId)
opts = extend({
storage: typeof FSStorage === 'function' && FSStorage
}, opts)
// TODO: fix this to work with multiple torrents
self.index = opts.index
// Called once we have a torrentId that bittorrent-client can handle
function onTorrentId (torrentId) {
var torrent = Client.prototype.add.call(self, torrentId, opts, ontorrent)
process.nextTick(function () {
self.emit('add', torrent)
})
}
var parsed = parseTorrent(torrentId)
if (parsed && parsed.infoHash) {
// magnet uri, info hash, torrent file, or parsed torrent can be handled by bittorrent-client
process.nextTick(function () {
onTorrentId(parsed)
})
} else if (/^https?:/.test(torrentId)) {
// http or https url to torrent file
hh.get(torrentId, function (res) {
res.pipe(concat(function (torrent) {
onTorrentId(torrent)
}))
}).on('error', function (err) {
self.emit('error', new Error('Error downloading torrent. ' + err.message))
})
} else {
// assume it's a filesystem path
fs.readFile(torrentId, function (err, torrent) {
if (err) {
self.emit('error', new Error('Invalid torrent. Need magnet uri, info hash, ' +
'torrent file, http url, or filesystem path.'))
} else {
onTorrentId(torrent)
}
})
}
return self
}
/**
* Destroy the client, including all torrents and connections to peers.
*
* @override
* @param {function} cb
*/
WebTorrent.prototype.destroy = function (cb) {
var self = this
debug('destroy')
var tasks = [
Client.prototype.destroy.bind(self)
]
if (self.server) {
tasks.push(function (cb) {
try {
self.server.close(cb)
} catch (err) {
// ignore error, server was already closed or not listening
cb(null)
}
})
}
parallel(tasks, cb)
return self
}
WebTorrent.prototype._onTorrent = function (torrent) {
var self = this
debug('on torrent')
// if no index specified, use largest file
if (typeof torrent.index !== 'number') {
var largestFile = torrent.files.reduce(function (a, b) {
return a.length > b.length ? a : b
})
torrent.index = torrent.files.indexOf(largestFile)
}
torrent.files[torrent.index].select()
// TODO: this won't work with multiple torrents
self.index = torrent.index
self.torrent = torrent
}
|
