Compare commits
No commits in common. "master" and "v3.0.6" have entirely different histories.
@ -1,2 +0,0 @@
|
||||
.travis.yml
|
||||
test/
|
||||
@ -1,3 +1,7 @@
|
||||
language: node_js
|
||||
node_js:
|
||||
- lts/*
|
||||
- node
|
||||
env:
|
||||
global:
|
||||
- secure: Htsm8eeR11ph6lbAOLPbFfJGou8eDPQMfLXUBx6c9+QgrbBKHM1RKscJNvSi1AM1rOOKSk1pCZwqVR2n+9kQs30MxZppyIngiy5Jcz7/b5FDvnm/JkNzq+7sEeGZzRK11XmFkWuYRK9TvUaDuuo/NOc1NJc0ics/gzrjNLcT1tw=
|
||||
- secure: FufpUBE/caYoQ5MfsIWFYVM0C4gj+4OSaqu6W8exucFDB68zTmO0te11tOwg98PhFnSaDbJ7h3gWXYGTpbFUErkeMBRMTsNjYYoQhcWWjzD4yo5iIfh215TJ5vhE4sIeCCi0TxHgbJkF3KthsUyaOdy/Q3sFISZ/VQSPFBDdmbU=
|
||||
|
||||
16
.zuul.yml
Normal file
16
.zuul.yml
Normal file
@ -0,0 +1,16 @@
|
||||
ui: tape
|
||||
browsers:
|
||||
- name: chrome
|
||||
version: latest
|
||||
- name: firefox
|
||||
version: latest
|
||||
- name: safari
|
||||
version: latest
|
||||
- name: ie
|
||||
version: latest
|
||||
- name: microsoftedge
|
||||
version: latest
|
||||
- name: android
|
||||
version: latest
|
||||
- name: iphone
|
||||
version: latest
|
||||
2
LICENSE
2
LICENSE
@ -1,6 +1,6 @@
|
||||
The MIT License (MIT)
|
||||
|
||||
Copyright (c) Feross Aboukhadijeh and WebTorrent, LLC
|
||||
Copyright (c) Feross Aboukhadijeh
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy of
|
||||
this software and associated documentation files (the "Software"), to deal in
|
||||
|
||||
46
README.md
46
README.md
@ -1,17 +1,17 @@
|
||||
# ut_metadata [![travis][travis-image]][travis-url] [![npm][npm-image]][npm-url] [![downloads][downloads-image]][downloads-url] [![javascript style guide][standard-image]][standard-url]
|
||||
# ut_metadata [![travis][travis-image]][travis-url] [![npm][npm-image]][npm-url] [![downloads][downloads-image]][downloads-url]
|
||||
|
||||
[travis-image]: https://img.shields.io/travis/webtorrent/ut_metadata/master.svg
|
||||
[travis-url]: https://travis-ci.org/webtorrent/ut_metadata
|
||||
[travis-image]: https://img.shields.io/travis/feross/ut_metadata/master.svg
|
||||
[travis-url]: https://travis-ci.org/feross/ut_metadata
|
||||
[npm-image]: https://img.shields.io/npm/v/ut_metadata.svg
|
||||
[npm-url]: https://npmjs.org/package/ut_metadata
|
||||
[downloads-image]: https://img.shields.io/npm/dm/ut_metadata.svg
|
||||
[downloads-url]: https://npmjs.org/package/ut_metadata
|
||||
[standard-image]: https://img.shields.io/badge/code_style-standard-brightgreen.svg
|
||||
[standard-url]: https://standardjs.com
|
||||
|
||||
### BitTorrent Extension for Peers to Send Metadata Files (BEP 9)
|
||||
|
||||
JavaScript implementation of the [Extension for Peers to Send Metadata Files (BEP 9)](http://www.bittorrent.org/beps/bep_0009.html). Use with [bittorrent-protocol](https://www.npmjs.com/package/bittorrent-protocol).
|
||||
[](https://saucelabs.com/u/ut_metadata)
|
||||
|
||||
Node.js implementation of the [Extension for Peers to Send Metadata Files (BEP 9)](http://www.bittorrent.org/beps/bep_0009.html). Use with [bittorrent-protocol](https://github.com/feross/bittorrent-protocol).
|
||||
|
||||
The purpose of this extension is to allow clients to join a swarm and complete a download without the need of downloading a .torrent file first. This extension instead allows clients to download the metadata from peers. It makes it possible to support magnet links, a link on a web page only containing enough information to join the swarm (the info hash).
|
||||
|
||||
@ -25,20 +25,20 @@ npm install ut_metadata
|
||||
|
||||
### usage
|
||||
|
||||
This package should be used with [bittorrent-protocol](https://www.npmjs.com/package/bittorrent-protocol), which supports a plugin-like system for extending the protocol with additional functionality.
|
||||
This package should be used with [bittorrent-protocol](https://github.com/feross/bittorrent-protocol), which supports a plugin-like system for extending the protocol with additional functionality.
|
||||
|
||||
Say you're already using `bittorrent-protocol`. Your code might look something like this:
|
||||
|
||||
```js
|
||||
const Protocol = require('bittorrent-protocol')
|
||||
const net = require('net')
|
||||
var Protocol = require('bittorrent-protocol')
|
||||
var net = require('net')
|
||||
|
||||
net.createServer(socket => {
|
||||
net.createServer(function (socket) {
|
||||
var wire = new Protocol()
|
||||
socket.pipe(wire).pipe(socket)
|
||||
|
||||
// handle handshake
|
||||
wire.on('handshake', (infoHash, peerId) => {
|
||||
wire.on('handshake', function (infoHash, peerId) {
|
||||
wire.handshake(new Buffer('my info hash'), new Buffer('my peer id'))
|
||||
})
|
||||
|
||||
@ -48,12 +48,12 @@ net.createServer(socket => {
|
||||
To add support for BEP 9, simply modify your code like this:
|
||||
|
||||
```js
|
||||
const Protocol = require('bittorrent-protocol')
|
||||
const net = require('net')
|
||||
const ut_metadata = require('ut_metadata')
|
||||
var Protocol = require('bittorrent-protocol')
|
||||
var net = require('net')
|
||||
var ut_metadata = require('ut_metadata')
|
||||
|
||||
net.createServer(socket => {
|
||||
const wire = new Protocol()
|
||||
net.createServer(function (socket) {
|
||||
var wire = new Protocol()
|
||||
socket.pipe(wire).pipe(socket)
|
||||
|
||||
// initialize the extension
|
||||
@ -65,7 +65,7 @@ net.createServer(socket => {
|
||||
wire.ut_metadata.fetch()
|
||||
|
||||
// 'metadata' event will fire when the metadata arrives and is verified to be correct!
|
||||
wire.ut_metadata.on('metadata', metadata => {
|
||||
wire.ut_metadata.on('metadata', function (metadata) {
|
||||
// got metadata!
|
||||
|
||||
// Note: the event will not fire if the peer does not support ut_metadata, if they
|
||||
@ -75,12 +75,12 @@ net.createServer(socket => {
|
||||
|
||||
// optionally, listen to the 'warning' event if you want to know that metadata is
|
||||
// probably not going to arrive for one of the above reasons.
|
||||
wire.ut_metadata.on('warning', err => {
|
||||
wire.ut_metadata.on('warning', function (err) {
|
||||
console.log(err.message)
|
||||
})
|
||||
|
||||
// handle handshake
|
||||
wire.on('handshake', (infoHash, peerId) => {
|
||||
wire.on('handshake', function (infoHash, peerId) {
|
||||
wire.handshake(new Buffer('my info hash'), new Buffer('my peer id'))
|
||||
})
|
||||
|
||||
@ -95,7 +95,7 @@ Initialize the extension. If you have the torrent metadata (Buffer), pass it int
|
||||
`ut_metadata` constructor so it's made available to the peer.
|
||||
|
||||
```js
|
||||
const metadata = fs.readFileSync(__dirname + '/file.torrent')
|
||||
var metadata = fs.readFileSync(__dirname + '/file.torrent')
|
||||
wire.use(ut_metadata(metadata))
|
||||
```
|
||||
|
||||
@ -119,7 +119,7 @@ Fired when metadata is available and verified to be correct. Called with a singl
|
||||
parameter of type Buffer.
|
||||
|
||||
```js
|
||||
wire.ut_metadata.on('metadata', metadata => {
|
||||
wire.ut_metadata.on('metadata', function (metadata) {
|
||||
console.log(Buffer.isBuffer(metadata)) // true
|
||||
})
|
||||
```
|
||||
@ -136,11 +136,11 @@ Fired if:
|
||||
- the peer repeatedly sent invalid data
|
||||
|
||||
```js
|
||||
wire.ut_metadata.on('warning', err => {
|
||||
wire.ut_metadata.on('warning', function (err) {
|
||||
console.log(err.message)
|
||||
})
|
||||
```
|
||||
|
||||
### license
|
||||
|
||||
MIT. Copyright (c) [Feross Aboukhadijeh](https://feross.org) and [WebTorrent, LLC](https://webtorrent.io).
|
||||
MIT. Copyright (c) [Feross Aboukhadijeh](http://feross.org).
|
||||
|
||||
458
index.js
458
index.js
@ -1,244 +1,240 @@
|
||||
/*! ut_metadata. MIT License. WebTorrent LLC <https://webtorrent.io/opensource> */
|
||||
const { EventEmitter } = require('events')
|
||||
const bencode = require('bencode')
|
||||
const BitField = require('bitfield').default
|
||||
const debug = require('debug')('ut_metadata')
|
||||
const sha1 = require('simple-sha1')
|
||||
var bencode = require('bencode')
|
||||
var BitField = require('bitfield')
|
||||
var debug = require('debug')('ut_metadata')
|
||||
var EventEmitter = require('events').EventEmitter
|
||||
var inherits = require('inherits')
|
||||
var sha1 = require('simple-sha1')
|
||||
|
||||
const MAX_METADATA_SIZE = 1E7 // 10 MB
|
||||
const BITFIELD_GROW = 1E3
|
||||
const PIECE_LENGTH = 1 << 14 // 16 KiB
|
||||
var MAX_METADATA_SIZE = 10000000 // 10MB
|
||||
var BITFIELD_GROW = 1000
|
||||
var PIECE_LENGTH = 16 * 1024
|
||||
|
||||
module.exports = metadata => {
|
||||
class utMetadata extends EventEmitter {
|
||||
constructor (wire) {
|
||||
super()
|
||||
module.exports = function (metadata) {
|
||||
inherits(ut_metadata, EventEmitter)
|
||||
|
||||
this._wire = wire
|
||||
function ut_metadata (wire) {
|
||||
EventEmitter.call(this)
|
||||
|
||||
this._fetching = false
|
||||
this._metadataComplete = false
|
||||
this._metadataSize = null
|
||||
// how many reject messages to tolerate before quitting
|
||||
this._remainingRejects = null
|
||||
this._wire = wire
|
||||
|
||||
// The largest torrent file that I know of is ~1-2MB, which is ~100
|
||||
// pieces. Therefore, cap the bitfield to 10x that (1000 pieces) so a
|
||||
// malicious peer can't make it grow to fill all memory.
|
||||
this._bitfield = new BitField(0, { grow: BITFIELD_GROW })
|
||||
this._metadataComplete = false
|
||||
this._metadataSize = null
|
||||
this._remainingRejects = null // how many reject messages to tolerate before quitting
|
||||
this._fetching = false
|
||||
|
||||
if (Buffer.isBuffer(metadata)) {
|
||||
this.setMetadata(metadata)
|
||||
}
|
||||
}
|
||||
// The largest .torrent file that I know of is ~1-2MB, which is ~100 pieces.
|
||||
// Therefore, cap the bitfield to 10x that (1000 pieces) so a malicious peer can't
|
||||
// make it grow to fill all memory.
|
||||
this._bitfield = new BitField(0, { grow: BITFIELD_GROW })
|
||||
|
||||
onHandshake (infoHash, peerId, extensions) {
|
||||
this._infoHash = infoHash
|
||||
}
|
||||
|
||||
onExtendedHandshake (handshake) {
|
||||
if (!handshake.m || !handshake.m.ut_metadata) {
|
||||
return this.emit('warning', new Error('Peer does not support ut_metadata'))
|
||||
}
|
||||
if (!handshake.metadata_size) {
|
||||
return this.emit('warning', new Error('Peer does not have metadata'))
|
||||
}
|
||||
if (typeof handshake.metadata_size !== 'number' ||
|
||||
MAX_METADATA_SIZE < handshake.metadata_size ||
|
||||
handshake.metadata_size <= 0) {
|
||||
return this.emit('warning', new Error('Peer gave invalid metadata size'))
|
||||
}
|
||||
|
||||
this._metadataSize = handshake.metadata_size
|
||||
this._numPieces = Math.ceil(this._metadataSize / PIECE_LENGTH)
|
||||
this._remainingRejects = this._numPieces * 2
|
||||
|
||||
this._requestPieces()
|
||||
}
|
||||
|
||||
onMessage (buf) {
|
||||
let dict
|
||||
let trailer
|
||||
try {
|
||||
const str = buf.toString()
|
||||
const trailerIndex = str.indexOf('ee') + 2
|
||||
dict = bencode.decode(str.substring(0, trailerIndex))
|
||||
trailer = buf.slice(trailerIndex)
|
||||
} catch (err) {
|
||||
// drop invalid messages
|
||||
return
|
||||
}
|
||||
|
||||
switch (dict.msg_type) {
|
||||
case 0:
|
||||
// ut_metadata request (from peer)
|
||||
// example: { 'msg_type': 0, 'piece': 0 }
|
||||
this._onRequest(dict.piece)
|
||||
break
|
||||
case 1:
|
||||
// ut_metadata data (in response to our request)
|
||||
// example: { 'msg_type': 1, 'piece': 0, 'total_size': 3425 }
|
||||
this._onData(dict.piece, trailer, dict.total_size)
|
||||
break
|
||||
case 2:
|
||||
// ut_metadata reject (peer doesn't have piece we requested)
|
||||
// { 'msg_type': 2, 'piece': 0 }
|
||||
this._onReject(dict.piece)
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Ask the peer to send metadata.
|
||||
* @public
|
||||
*/
|
||||
fetch () {
|
||||
if (this._metadataComplete) {
|
||||
return
|
||||
}
|
||||
this._fetching = true
|
||||
if (this._metadataSize) {
|
||||
this._requestPieces()
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Stop asking the peer to send metadata.
|
||||
* @public
|
||||
*/
|
||||
cancel () {
|
||||
this._fetching = false
|
||||
}
|
||||
|
||||
setMetadata (metadata) {
|
||||
if (this._metadataComplete) return true
|
||||
debug('set metadata')
|
||||
|
||||
// if full torrent dictionary was passed in, pull out just `info` key
|
||||
try {
|
||||
const info = bencode.decode(metadata).info
|
||||
if (info) {
|
||||
metadata = bencode.encode(info)
|
||||
}
|
||||
} catch (err) {}
|
||||
|
||||
// check hash
|
||||
if (this._infoHash && this._infoHash !== sha1.sync(metadata)) {
|
||||
return false
|
||||
}
|
||||
|
||||
this.cancel()
|
||||
|
||||
this.metadata = metadata
|
||||
this._metadataComplete = true
|
||||
this._metadataSize = this.metadata.length
|
||||
this._wire.extendedHandshake.metadata_size = this._metadataSize
|
||||
|
||||
this.emit('metadata', bencode.encode({
|
||||
info: bencode.decode(this.metadata)
|
||||
}))
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
_send (dict, trailer) {
|
||||
let buf = bencode.encode(dict)
|
||||
if (Buffer.isBuffer(trailer)) {
|
||||
buf = Buffer.concat([buf, trailer])
|
||||
}
|
||||
this._wire.extended('ut_metadata', buf)
|
||||
}
|
||||
|
||||
_request (piece) {
|
||||
this._send({ msg_type: 0, piece })
|
||||
}
|
||||
|
||||
_data (piece, buf, totalSize) {
|
||||
const msg = { msg_type: 1, piece }
|
||||
if (typeof totalSize === 'number') {
|
||||
msg.total_size = totalSize
|
||||
}
|
||||
this._send(msg, buf)
|
||||
}
|
||||
|
||||
_reject (piece) {
|
||||
this._send({ msg_type: 2, piece })
|
||||
}
|
||||
|
||||
_onRequest (piece) {
|
||||
if (!this._metadataComplete) {
|
||||
this._reject(piece)
|
||||
return
|
||||
}
|
||||
const start = piece * PIECE_LENGTH
|
||||
let end = start + PIECE_LENGTH
|
||||
if (end > this._metadataSize) {
|
||||
end = this._metadataSize
|
||||
}
|
||||
const buf = this.metadata.slice(start, end)
|
||||
this._data(piece, buf, this._metadataSize)
|
||||
}
|
||||
|
||||
_onData (piece, buf, totalSize) {
|
||||
if (buf.length > PIECE_LENGTH || !this._fetching) {
|
||||
return
|
||||
}
|
||||
buf.copy(this.metadata, piece * PIECE_LENGTH)
|
||||
this._bitfield.set(piece)
|
||||
this._checkDone()
|
||||
}
|
||||
|
||||
_onReject (piece) {
|
||||
if (this._remainingRejects > 0 && this._fetching) {
|
||||
// If we haven't been rejected too much,
|
||||
// then try to request the piece again
|
||||
this._request(piece)
|
||||
this._remainingRejects -= 1
|
||||
} else {
|
||||
this.emit('warning', new Error('Peer sent "reject" too much'))
|
||||
}
|
||||
}
|
||||
|
||||
_requestPieces () {
|
||||
if (!this._fetching) return
|
||||
this.metadata = Buffer.alloc(this._metadataSize)
|
||||
for (let piece = 0; piece < this._numPieces; piece++) {
|
||||
this._request(piece)
|
||||
}
|
||||
}
|
||||
|
||||
_checkDone () {
|
||||
let done = true
|
||||
for (let piece = 0; piece < this._numPieces; piece++) {
|
||||
if (!this._bitfield.get(piece)) {
|
||||
done = false
|
||||
break
|
||||
}
|
||||
}
|
||||
if (!done) return
|
||||
|
||||
// attempt to set metadata -- may fail sha1 check
|
||||
const success = this.setMetadata(this.metadata)
|
||||
|
||||
if (!success) {
|
||||
this._failedMetadata()
|
||||
}
|
||||
}
|
||||
|
||||
_failedMetadata () {
|
||||
// reset bitfield & try again
|
||||
this._bitfield = new BitField(0, { grow: BITFIELD_GROW })
|
||||
this._remainingRejects -= this._numPieces
|
||||
if (this._remainingRejects > 0) {
|
||||
this._requestPieces()
|
||||
} else {
|
||||
this.emit('warning', new Error('Peer sent invalid metadata'))
|
||||
}
|
||||
if (Buffer.isBuffer(metadata)) {
|
||||
this.setMetadata(metadata)
|
||||
}
|
||||
}
|
||||
|
||||
// Name of the bittorrent-protocol extension
|
||||
utMetadata.prototype.name = 'ut_metadata'
|
||||
ut_metadata.prototype.name = 'ut_metadata'
|
||||
|
||||
return utMetadata
|
||||
ut_metadata.prototype.onHandshake = function (infoHash, peerId, extensions) {
|
||||
this._infoHash = infoHash
|
||||
}
|
||||
|
||||
ut_metadata.prototype.onExtendedHandshake = function (handshake) {
|
||||
if (!handshake.m || !handshake.m.ut_metadata) {
|
||||
return this.emit('warning', new Error('Peer does not support ut_metadata'))
|
||||
}
|
||||
if (!handshake.metadata_size) {
|
||||
return this.emit('warning', new Error('Peer does not have metadata'))
|
||||
}
|
||||
|
||||
if (handshake.metadata_size > MAX_METADATA_SIZE) {
|
||||
return this.emit('warning', new Error('Peer gave maliciously large metadata size'))
|
||||
}
|
||||
|
||||
this._metadataSize = handshake.metadata_size
|
||||
this._numPieces = Math.ceil(this._metadataSize / PIECE_LENGTH)
|
||||
this._remainingRejects = this._numPieces * 2
|
||||
|
||||
if (this._fetching) {
|
||||
this._requestPieces()
|
||||
}
|
||||
}
|
||||
|
||||
ut_metadata.prototype.onMessage = function (buf) {
|
||||
var dict, trailer
|
||||
try {
|
||||
var str = buf.toString()
|
||||
var trailerIndex = str.indexOf('ee') + 2
|
||||
dict = bencode.decode(str.substring(0, trailerIndex))
|
||||
trailer = buf.slice(trailerIndex)
|
||||
} catch (err) {
|
||||
// drop invalid messages
|
||||
return
|
||||
}
|
||||
|
||||
switch (dict.msg_type) {
|
||||
case 0:
|
||||
// ut_metadata request (from peer)
|
||||
// example: { 'msg_type': 0, 'piece': 0 }
|
||||
this._onRequest(dict.piece)
|
||||
break
|
||||
case 1:
|
||||
// ut_metadata data (in response to our request)
|
||||
// example: { 'msg_type': 1, 'piece': 0, 'total_size': 3425 }
|
||||
this._onData(dict.piece, trailer, dict.total_size)
|
||||
break
|
||||
case 2:
|
||||
// ut_metadata reject (peer doesn't have piece we requested)
|
||||
// { 'msg_type': 2, 'piece': 0 }
|
||||
this._onReject(dict.piece)
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Ask the peer to send metadata.
|
||||
* @public
|
||||
*/
|
||||
ut_metadata.prototype.fetch = function () {
|
||||
if (this._metadataComplete) {
|
||||
return
|
||||
}
|
||||
this._fetching = true
|
||||
if (this._metadataSize) {
|
||||
this._requestPieces()
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Stop asking the peer to send metadata.
|
||||
* @public
|
||||
*/
|
||||
ut_metadata.prototype.cancel = function () {
|
||||
this._fetching = false
|
||||
}
|
||||
|
||||
ut_metadata.prototype.setMetadata = function (metadata) {
|
||||
if (this._metadataComplete) return true
|
||||
debug('set metadata')
|
||||
|
||||
// if full torrent dictionary was passed in, pull out just `info` key
|
||||
try {
|
||||
var info = bencode.decode(metadata).info
|
||||
if (info) {
|
||||
metadata = bencode.encode(info)
|
||||
}
|
||||
} catch (err) {}
|
||||
|
||||
// check hash
|
||||
if (this._infoHash && this._infoHash !== sha1.sync(metadata)) {
|
||||
return false
|
||||
}
|
||||
|
||||
this.cancel()
|
||||
|
||||
this.metadata = metadata
|
||||
this._metadataComplete = true
|
||||
this._metadataSize = this.metadata.length
|
||||
this._wire.extendedHandshake.metadata_size = this._metadataSize
|
||||
|
||||
this.emit('metadata', bencode.encode({ info: bencode.decode(this.metadata) }))
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
ut_metadata.prototype._send = function (dict, trailer) {
|
||||
var buf = bencode.encode(dict)
|
||||
if (Buffer.isBuffer(trailer)) {
|
||||
buf = Buffer.concat([buf, trailer])
|
||||
}
|
||||
this._wire.extended('ut_metadata', buf)
|
||||
}
|
||||
|
||||
ut_metadata.prototype._request = function (piece) {
|
||||
this._send({ msg_type: 0, piece: piece })
|
||||
}
|
||||
|
||||
ut_metadata.prototype._data = function (piece, buf, totalSize) {
|
||||
var msg = { msg_type: 1, piece: piece }
|
||||
if (typeof totalSize === 'number') {
|
||||
msg.total_size = totalSize
|
||||
}
|
||||
this._send(msg, buf)
|
||||
}
|
||||
|
||||
ut_metadata.prototype._reject = function (piece) {
|
||||
this._send({ msg_type: 2, piece: piece })
|
||||
}
|
||||
|
||||
ut_metadata.prototype._onRequest = function (piece) {
|
||||
if (!this._metadataComplete) {
|
||||
this._reject(piece)
|
||||
return
|
||||
}
|
||||
var start = piece * PIECE_LENGTH
|
||||
var end = start + PIECE_LENGTH
|
||||
if (end > this._metadataSize) {
|
||||
end = this._metadataSize
|
||||
}
|
||||
var buf = this.metadata.slice(start, end)
|
||||
this._data(piece, buf, this._metadataSize)
|
||||
}
|
||||
|
||||
ut_metadata.prototype._onData = function (piece, buf, totalSize) {
|
||||
if (buf.length > PIECE_LENGTH) {
|
||||
return
|
||||
}
|
||||
buf.copy(this.metadata, piece * PIECE_LENGTH)
|
||||
this._bitfield.set(piece)
|
||||
this._checkDone()
|
||||
}
|
||||
|
||||
ut_metadata.prototype._onReject = function (piece) {
|
||||
if (this._remainingRejects > 0 && this._fetching) {
|
||||
// If we haven't been rejected too much, then try to request the piece again
|
||||
this._request(piece)
|
||||
this._remainingRejects -= 1
|
||||
} else {
|
||||
this.emit('warning', new Error('Peer sent "reject" too much'))
|
||||
}
|
||||
}
|
||||
|
||||
ut_metadata.prototype._requestPieces = function () {
|
||||
this.metadata = new Buffer(this._metadataSize)
|
||||
|
||||
for (var piece = 0; piece < this._numPieces; piece++) {
|
||||
this._request(piece)
|
||||
}
|
||||
}
|
||||
|
||||
ut_metadata.prototype._checkDone = function () {
|
||||
var done = true
|
||||
for (var piece = 0; piece < this._numPieces; piece++) {
|
||||
if (!this._bitfield.get(piece)) {
|
||||
done = false
|
||||
break
|
||||
}
|
||||
}
|
||||
if (!done) return
|
||||
|
||||
// attempt to set metadata -- may fail sha1 check
|
||||
var success = this.setMetadata(this.metadata)
|
||||
|
||||
if (!success) {
|
||||
this._failedMetadata()
|
||||
}
|
||||
}
|
||||
|
||||
ut_metadata.prototype._failedMetadata = function () {
|
||||
// reset bitfield & try again
|
||||
this._bitfield = new BitField(0, { grow: BITFIELD_GROW })
|
||||
this._remainingRejects -= this._numPieces
|
||||
if (this._remainingRejects > 0) {
|
||||
this._requestPieces()
|
||||
} else {
|
||||
this.emit('warning', new Error('Peer sent invalid metadata'))
|
||||
}
|
||||
}
|
||||
|
||||
return ut_metadata
|
||||
}
|
||||
|
||||
54
package.json
54
package.json
@ -1,29 +1,32 @@
|
||||
{
|
||||
"name": "ut_metadata",
|
||||
"description": "Extension for Peers to Send Metadata Files (BEP 9)",
|
||||
"version": "3.5.2",
|
||||
"version": "3.0.6",
|
||||
"author": {
|
||||
"name": "WebTorrent LLC",
|
||||
"email": "feross@webtorrent.io",
|
||||
"url": "https://webtorrent.io"
|
||||
"name": "Feross Aboukhadijeh",
|
||||
"email": "feross@feross.org",
|
||||
"url": "http://feross.org/"
|
||||
},
|
||||
"bugs": {
|
||||
"url": "https://github.com/webtorrent/ut_metadata/issues"
|
||||
"url": "https://github.com/feross/ut_metadata/issues"
|
||||
},
|
||||
"dependencies": {
|
||||
"bencode": "^2.0.1",
|
||||
"bitfield": "^4.0.0",
|
||||
"debug": "^4.2.0",
|
||||
"simple-sha1": "^3.0.1"
|
||||
"bencode": "^0.9.0",
|
||||
"bitfield": "^1.0.1",
|
||||
"debug": "^2.2.0",
|
||||
"inherits": "^2.0.1",
|
||||
"simple-sha1": "^2.0.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"bittorrent-protocol": "^3.1.2",
|
||||
"brfs": "^2.0.2",
|
||||
"standard": "*",
|
||||
"tape": "^5.0.1",
|
||||
"webtorrent-fixtures": "^1.7.3"
|
||||
"bittorrent-protocol": "^2.0.0",
|
||||
"brfs": "^1.2.0",
|
||||
"standard": "^6.0.4",
|
||||
"tape": "^4.0.0",
|
||||
"webtorrent-fixtures": "^1.3.0",
|
||||
"zuul": "^3.8.0"
|
||||
},
|
||||
"keywords": [
|
||||
"9",
|
||||
"Extension for Peers to Send Metadata Files",
|
||||
"bep",
|
||||
"bep 9",
|
||||
@ -38,23 +41,12 @@
|
||||
"main": "index.js",
|
||||
"repository": {
|
||||
"type": "git",
|
||||
"url": "git://github.com/webtorrent/ut_metadata.git"
|
||||
"url": "git://github.com/feross/ut_metadata.git"
|
||||
},
|
||||
"scripts": {
|
||||
"test": "standard && tape test/*.js"
|
||||
},
|
||||
"funding": [
|
||||
{
|
||||
"type": "github",
|
||||
"url": "https://github.com/sponsors/feross"
|
||||
},
|
||||
{
|
||||
"type": "patreon",
|
||||
"url": "https://www.patreon.com/feross"
|
||||
},
|
||||
{
|
||||
"type": "consulting",
|
||||
"url": "https://feross.org/support"
|
||||
}
|
||||
]
|
||||
"test": "standard && npm run test-node && npm run test-browser",
|
||||
"test-browser": "zuul -- test/*.js",
|
||||
"test-browser-local": "zuul --local -- test/*.js",
|
||||
"test-node": "tape test/*.js"
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,14 +1,14 @@
|
||||
const { leavesMetadata } = require('webtorrent-fixtures')
|
||||
const bencode = require('bencode')
|
||||
const Protocol = require('bittorrent-protocol')
|
||||
const test = require('tape')
|
||||
const utMetadata = require('../')
|
||||
var bencode = require('bencode')
|
||||
var fixtures = require('webtorrent-fixtures')
|
||||
var Protocol = require('bittorrent-protocol')
|
||||
var test = require('tape')
|
||||
var ut_metadata = require('../')
|
||||
|
||||
test('wire.use(utMetadata())', t => {
|
||||
const wire = new Protocol()
|
||||
test('wire.use(ut_metadata())', function (t) {
|
||||
var wire = new Protocol()
|
||||
wire.pipe(wire)
|
||||
|
||||
wire.use(utMetadata())
|
||||
wire.use(ut_metadata())
|
||||
|
||||
t.ok(wire.ut_metadata)
|
||||
t.ok(wire.ut_metadata.fetch)
|
||||
@ -17,18 +17,15 @@ test('wire.use(utMetadata())', t => {
|
||||
t.end()
|
||||
})
|
||||
|
||||
test('wire.use(utMetadata(metadata))', t => {
|
||||
const wire = new Protocol()
|
||||
test('wire.use(ut_metadata(metadata))', function (t) {
|
||||
var wire = new Protocol()
|
||||
wire.pipe(wire)
|
||||
|
||||
wire.use(utMetadata(leavesMetadata.torrent))
|
||||
wire.use(ut_metadata(fixtures.leavesMetadata.torrent))
|
||||
|
||||
t.ok(wire.ut_metadata)
|
||||
t.ok(wire.ut_metadata.fetch)
|
||||
t.ok(wire.ut_metadata.cancel)
|
||||
t.equal(
|
||||
wire.ut_metadata.metadata.toString('hex'),
|
||||
bencode.encode(bencode.decode(leavesMetadata.torrent).info).toString('hex')
|
||||
)
|
||||
t.equal(wire.ut_metadata.metadata.toString('hex'), bencode.encode(bencode.decode(fixtures.leavesMetadata.torrent).info).toString('hex'))
|
||||
t.end()
|
||||
})
|
||||
|
||||
190
test/fetch.js
190
test/fetch.js
@ -1,39 +1,34 @@
|
||||
const { leavesMetadata, sintel } = require('webtorrent-fixtures')
|
||||
const bencode = require('bencode')
|
||||
const Protocol = require('bittorrent-protocol')
|
||||
const test = require('tape')
|
||||
const utMetadata = require('../')
|
||||
var bencode = require('bencode')
|
||||
var fixtures = require('webtorrent-fixtures')
|
||||
var Protocol = require('bittorrent-protocol')
|
||||
var test = require('tape')
|
||||
var ut_metadata = require('../')
|
||||
|
||||
const id1 = Buffer.from('01234567890123456789')
|
||||
const id2 = Buffer.from('12345678901234567890')
|
||||
var id1 = new Buffer('01234567890123456789')
|
||||
var id2 = new Buffer('12345678901234567890')
|
||||
|
||||
test('fetch()', t => {
|
||||
test('fetch()', function (t) {
|
||||
t.plan(3)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
var wire1 = new Protocol()
|
||||
var wire2 = new Protocol()
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
wire1.use(utMetadata(leavesMetadata.torrent)) // wire1 already has metadata
|
||||
wire2.use(utMetadata()) // wire2 does not
|
||||
wire1.use(ut_metadata(fixtures.leavesMetadata.torrent)) // wire1 already has metadata
|
||||
wire2.use(ut_metadata()) // wire2 does not
|
||||
|
||||
wire2.ut_metadata.fetch()
|
||||
|
||||
wire2.ut_metadata.on('metadata', _metadata => {
|
||||
wire2.ut_metadata.on('metadata', function (_metadata) {
|
||||
// got metadata!
|
||||
t.equal(
|
||||
_metadata.toString('hex'),
|
||||
bencode.encode({
|
||||
info: bencode.decode(leavesMetadata.torrent).info
|
||||
}).toString('hex')
|
||||
)
|
||||
t.equal(_metadata.toString('hex'), bencode.encode({ info: bencode.decode(fixtures.leavesMetadata.torrent).info }).toString('hex'))
|
||||
})
|
||||
|
||||
wire2.on('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
wire2.on('handshake', function (infoHash, peerId, extensions) {
|
||||
wire2.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
})
|
||||
|
||||
wire2.on('extended', ext => {
|
||||
wire2.on('extended', function (ext) {
|
||||
if (ext === 'handshake') {
|
||||
t.pass('got extended handshake')
|
||||
} else if (ext === 'ut_metadata') {
|
||||
@ -46,40 +41,40 @@ test('fetch()', t => {
|
||||
}
|
||||
})
|
||||
|
||||
wire1.handshake(leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
wire1.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
|
||||
test('fetch() from peer without metadata', t => {
|
||||
test('fetch() from peer without metadata', function (t) {
|
||||
t.plan(2)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
var wire1 = new Protocol()
|
||||
var wire2 = new Protocol()
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
wire1.use(utMetadata()) // neither wire has metadata
|
||||
wire2.use(utMetadata())
|
||||
wire1.use(ut_metadata()) // neither wire has metadata
|
||||
wire2.use(ut_metadata())
|
||||
|
||||
wire2.ut_metadata.fetch()
|
||||
|
||||
wire2.ut_metadata.on('metadata', () => {
|
||||
wire2.ut_metadata.on('metadata', function () {
|
||||
t.fail('No "metadata" event should fire')
|
||||
})
|
||||
|
||||
wire1.ut_metadata.onMessage = () => {
|
||||
wire1.ut_metadata.onMessage = function () {
|
||||
t.fail('No messages should be sent to wire1')
|
||||
// No messages should be sent because wire1 never sent metadata_size
|
||||
// in the extended handshake, so he doesn't have metadata
|
||||
// No messages should be sent because wire1 never sent metadata_size in the
|
||||
// extended handshake, so he doesn't have metadata
|
||||
}
|
||||
|
||||
wire2.ut_metadata.on('warning', () => {
|
||||
wire2.ut_metadata.on('warning', function () {
|
||||
t.pass('got warning about peer missing metadata')
|
||||
})
|
||||
|
||||
wire2.on('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
wire2.on('handshake', function (infoHash, peerId, extensions) {
|
||||
wire2.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
})
|
||||
|
||||
wire2.on('extended', ext => {
|
||||
wire2.on('extended', function (ext) {
|
||||
if (ext === 'handshake') {
|
||||
t.pass('got extended handshake')
|
||||
} else if (ext === 'ut_metadata') {
|
||||
@ -89,44 +84,36 @@ test('fetch() from peer without metadata', t => {
|
||||
}
|
||||
})
|
||||
|
||||
wire1.handshake(leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
wire1.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
|
||||
test('fetch when peer gets metadata later (setMetadata)', t => {
|
||||
test('fetch when peer gets metadata later (setMetadata)', function (t) {
|
||||
t.plan(3)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
|
||||
var wire1 = new Protocol()
|
||||
var wire2 = new Protocol()
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
wire1.use(utMetadata()) // wire1 starts without metadata
|
||||
wire1.use(ut_metadata()) // wire1 starts without metadata
|
||||
|
||||
process.nextTick(() => {
|
||||
// wire1 gets metadata later
|
||||
wire1.ut_metadata.setMetadata(leavesMetadata.torrent)
|
||||
process.nextTick(function () {
|
||||
wire1.ut_metadata.setMetadata(fixtures.leavesMetadata.torrent) // wire1 gets metadata later
|
||||
|
||||
process.nextTick(() => {
|
||||
// wire2 does not start with metadata,
|
||||
// but connects to wire1 after it gets metadata
|
||||
wire2.use(utMetadata())
|
||||
process.nextTick(function () {
|
||||
// wire2 does not start with metadata, but connects to wire1 after it gets metadata
|
||||
wire2.use(ut_metadata())
|
||||
wire2.ut_metadata.fetch()
|
||||
|
||||
wire2.ut_metadata.on('metadata', _metadata => {
|
||||
wire2.ut_metadata.on('metadata', function (_metadata) {
|
||||
// got metadata!
|
||||
t.equal(
|
||||
_metadata.toString('hex'),
|
||||
bencode.encode({
|
||||
info: bencode.decode(leavesMetadata.torrent).info
|
||||
}).toString('hex')
|
||||
)
|
||||
t.equal(_metadata.toString('hex'), bencode.encode({ info: bencode.decode(fixtures.leavesMetadata.torrent).info }).toString('hex'))
|
||||
})
|
||||
|
||||
wire2.on('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
wire2.on('handshake', function (infoHash, peerId, extensions) {
|
||||
wire2.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
})
|
||||
|
||||
wire2.on('extended', ext => {
|
||||
wire2.on('extended', function (ext) {
|
||||
if (ext === 'handshake') {
|
||||
t.pass('got extended handshake')
|
||||
} else if (ext === 'ut_metadata') {
|
||||
@ -139,43 +126,37 @@ test('fetch when peer gets metadata later (setMetadata)', t => {
|
||||
}
|
||||
})
|
||||
|
||||
wire1.handshake(leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
wire1.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
})
|
||||
})
|
||||
|
||||
test('fetch() large torrent', t => {
|
||||
test('fetch() large torrent', function (t) {
|
||||
t.plan(4)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
var wire1 = new Protocol()
|
||||
var wire2 = new Protocol()
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
wire1.use(utMetadata(sintel.torrent)) // wire1 already has metadata
|
||||
wire2.use(utMetadata()) // wire2 does not
|
||||
wire1.use(ut_metadata(fixtures.sintel.torrent)) // wire1 already has metadata
|
||||
wire2.use(ut_metadata()) // wire2 does not
|
||||
|
||||
wire2.ut_metadata.fetch()
|
||||
|
||||
wire2.ut_metadata.on('metadata', _metadata => {
|
||||
wire2.ut_metadata.on('metadata', function (_metadata) {
|
||||
// got metadata!
|
||||
t.equal(
|
||||
_metadata.toString('hex'),
|
||||
bencode.encode({
|
||||
info: bencode.decode(sintel.torrent).info
|
||||
}).toString('hex')
|
||||
)
|
||||
t.equal(_metadata.toString('hex'), bencode.encode({ info: bencode.decode(fixtures.sintel.torrent).info }).toString('hex'))
|
||||
})
|
||||
|
||||
wire2.on('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(sintel.parsedTorrent.infoHash, id2)
|
||||
wire2.on('handshake', function (infoHash, peerId, extensions) {
|
||||
wire2.handshake(fixtures.sintel.parsedTorrent.infoHash, id2)
|
||||
})
|
||||
|
||||
wire2.on('extended', ext => {
|
||||
wire2.on('extended', function (ext) {
|
||||
if (ext === 'handshake') {
|
||||
t.pass('got extended handshake')
|
||||
} else if (ext === 'ut_metadata') {
|
||||
// note: this should get called twice,
|
||||
// once for each block of the sintel metadata
|
||||
// note: this should get called twice, once for each block of the sintel metadata
|
||||
t.pass('got extended ut_metadata message')
|
||||
|
||||
// this is emitted for consistency's sake, but it's ignored
|
||||
@ -186,66 +167,35 @@ test('fetch() large torrent', t => {
|
||||
}
|
||||
})
|
||||
|
||||
wire1.handshake(sintel.parsedTorrent.infoHash, id1)
|
||||
wire1.handshake(fixtures.sintel.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
|
||||
test('discard invalid metadata', t => {
|
||||
test('discard invalid metadata', function (t) {
|
||||
t.plan(1)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
var wire1 = new Protocol()
|
||||
var wire2 = new Protocol()
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
const invalidMetadata = leavesMetadata.torrent.slice(0)
|
||||
var invalidMetadata = fixtures.leavesMetadata.torrent.slice(0)
|
||||
invalidMetadata[55] = 65 // mess up a byte in the info block
|
||||
|
||||
wire1.use(utMetadata(invalidMetadata))
|
||||
wire2.use(utMetadata())
|
||||
wire1.use(ut_metadata(invalidMetadata))
|
||||
wire2.use(ut_metadata())
|
||||
|
||||
wire2.ut_metadata.fetch()
|
||||
|
||||
wire2.ut_metadata.on('metadata', () => {
|
||||
wire2.ut_metadata.on('metadata', function () {
|
||||
t.fail('No "metadata" event should fire')
|
||||
})
|
||||
|
||||
wire2.ut_metadata.on('warning', () => {
|
||||
wire2.ut_metadata.on('warning', function () {
|
||||
t.pass('got warning because peer sent reject too much')
|
||||
})
|
||||
|
||||
wire2.on('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
wire2.on('handshake', function (infoHash, peerId, extensions) {
|
||||
wire2.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id2)
|
||||
})
|
||||
|
||||
wire1.handshake(leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
|
||||
test('stop receiving data after cancel', t => {
|
||||
t.plan(1)
|
||||
|
||||
const wire1 = new Protocol()
|
||||
const wire2 = new Protocol()
|
||||
|
||||
wire1.pipe(wire2).pipe(wire1)
|
||||
|
||||
wire1.use(utMetadata(sintel.torrent))
|
||||
wire2.use(utMetadata())
|
||||
|
||||
wire2.ut_metadata.once('metadata', () => {
|
||||
t.fail('No "metadata" event should fire')
|
||||
})
|
||||
|
||||
wire2.once('handshake', (infoHash, peerId, extensions) => {
|
||||
wire2.handshake(sintel.parsedTorrent.infoHash, id2)
|
||||
wire2.ut_metadata.fetch()
|
||||
})
|
||||
|
||||
wire2.on('extended', ext => {
|
||||
if (ext === 'ut_metadata') {
|
||||
wire2.ut_metadata.cancel()
|
||||
}
|
||||
})
|
||||
|
||||
wire1.handshake(sintel.parsedTorrent.infoHash, id1)
|
||||
|
||||
process.nextTick(() => t.pass('no metadata received'))
|
||||
wire1.handshake(fixtures.leavesMetadata.parsedTorrent.infoHash, id1)
|
||||
})
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user