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
|
const DHT = require('bittorrent-dht/server')
const fixtures = require('webtorrent-fixtures')
const fs = require('fs')
const MemoryChunkStore = require('memory-chunk-store')
const series = require('run-series')
const test = require('tape')
const WebTorrent = require('../../')
test('Seed and download a file at the same time', function (t) {
t.plan(14)
const dhtServer = new DHT({ bootstrap: false })
dhtServer.on('error', function (err) { t.fail(err) })
dhtServer.on('warning', function (err) { t.fail(err) })
let client1, client2
series([
function (cb) {
dhtServer.listen(cb)
},
function (cb) {
let announced = false
let loaded = false
client1 = new WebTorrent({
tracker: false,
lsd: 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) })
const 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()
})
function maybeDone () {
if (announced && loaded) cb(null)
}
},
function (cb) {
let announced = false
let loaded = false
client2 = new WebTorrent({
tracker: false,
lsd: 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) })
const 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()
})
function maybeDone () {
if (announced && loaded) cb(null)
}
},
function (cb) {
let gotBuffer1 = false
let gotBuffer2 = false
let gotDone1 = false
let gotDone2 = false
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()
})
})
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')
})
})
})
|
