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
|
// TODO: move vlc/airplay/etc. functionality from cmd.js to the module
module.exports = WebTorrent
var Client = require('bittorrent-client')
var debug = require('debug')('webtorrent')
var extend = require('extend.js')
var FSStorage = require('./lib/fs-storage')
var inherits = require('inherits')
var parallel = require('run-parallel')
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
debug('add %s', torrentId)
if (typeof opts === 'function') {
ontorrent = opts
opts = {}
}
opts = extend({
storage: typeof FSStorage === 'function' && FSStorage
}, opts)
// TODO: fix this to work with multiple torrents
self.index = opts.index
var torrent = Client.prototype.add.call(self, torrentId, opts, ontorrent)
process.nextTick(function () {
self.emit('add', 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
}
|
