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
|
var DHT = require('bittorrent-dht/server')
var fixtures = require('webtorrent-fixtures')
var fs = require('fs')
var MemoryChunkStore = require('memory-chunk-store')
var series = require('run-series')
var test = require('tape')
var WebTorrent = require('../../')
test('Seed and download a file at the same time', function (t) {
t.plan(14)
var dhtServer = new DHT({ bootstrap: false })
dhtServer.on('error', function (err) { t.fail(err) })
dhtServer.on('warning', function (err) { t.fail(err) })
var client1, client2
series([
function (cb) {
dhtServer.listen(cb)
},
function (cb) {
client1 = new WebTorrent({
tracker: false,
dht: { bootstrap: '127.0.0.1:' + dhtServer.address().port }
})
client1.on('error', function (err) { t.fail(err) })
client1.on('warning', function (err) { t.fail(err) })
var torrent = client1.add(fixtures.leaves.torrent, { store: MemoryChunkStore })
torrent.on('dhtAnnounce', function () {
t.pass('client1 finished dht announce')
announced = true
maybeDone()
})
torrent.load(fs.createReadStream(fixtures.leaves.contentPath), function (err) {
t.error(err, 'client1 started seeding')
loaded = true
maybeDone()
})
var announced = false
var loaded = false
function maybeDone () {
if (announced && loaded) cb(null)
}
},
function (cb) {
client2 = new WebTorrent({
tracker: false,
dht: { bootstrap: '127.0.0.1:' + dhtServer.address().port }
})
client2.on('error', function (err) { t.fail(err) })
client2.on('warning', function (err) { t.fail(err) })
var torrent = client2.add(fixtures.alice.torrent, { store: MemoryChunkStore })
torrent.on('dhtAnnounce', function () {
t.pass('client2 finished dht announce')
announced = true
maybeDone()
})
torrent.load(fs.createReadStream(fixtures.alice.contentPath), function (err) {
t.error(err, 'client2 started seeding')
loaded = true
maybeDone()
})
var announced = false
var loaded = false
function maybeDone () {
if (announced && loaded) cb(null)
}
},
function (cb) {
client1.add(fixtures.alice.magnetURI, { store: MemoryChunkStore })
client1.on('torrent', function (torrent) {
torrent.files[0].getBuffer(function (err, buf) {
t.error(err)
t.deepEqual(buf, fixtures.alice.content, 'client1 downloaded correct content')
gotBuffer1 = true
maybeDone()
})
torrent.once('done', function () {
t.pass('client1 downloaded torrent from client2')
gotDone1 = true
maybeDone()
})
})
client2.add(fixtures.leaves.magnetURI, { store: MemoryChunkStore })
client2.on('torrent', function (torrent) {
torrent.files[0].getBuffer(function (err, buf) {
t.error(err)
t.deepEqual(buf, fixtures.leaves.content, 'client2 downloaded correct content')
gotBuffer2 = true
maybeDone()
})
torrent.once('done', function () {
t.pass('client2 downloaded torrent from client1')
gotDone2 = true
maybeDone()
})
})
var gotBuffer1 = false
var gotBuffer2 = false
var gotDone1 = false
var gotDone2 = false
function maybeDone () {
if (gotBuffer1 && gotBuffer2 && gotDone1 && gotDone2) cb(null)
}
}
], function (err) {
t.error(err)
client1.destroy(function (err) {
t.error(err, 'client1 destroyed')
})
client2.destroy(function (err) {
t.error(err, 'client2 destroyed')
})
dhtServer.destroy(function (err) {
t.error(err, 'dht server destroyed')
})
})
})
|
