Nemcio/meanTorrent
1
0
Fork 0
mirror of https://github.com/taobataoma/meanTorrent.git synced 2026-05-06 14:56:51 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): remove not used files.

Browse Source
This commit is contained in:
OldHawk
2017-08-14 16:08:31 +08:00
parent 4f64c41bf7
commit ddb0448bd7
3 changed files with 0 additions and 318 deletions
Download Patch File Download Diff File Expand all files Collapse all files

73
modules/announce/server/controllers/common/common-node.js
View File

@@ -1,73 +0,0 @@
'use strict';
/**
* Functions/constants needed by both the client and server (but only in node).
* These are separate from common.js so they can be skipped when bundling for the browser.
*/
var Buffer = require('safe-buffer').Buffer;
var querystring = require('querystring');
exports.IPV4_RE = /^[\d.]+$/;
exports.IPV6_RE = /^[\da-fA-F:]+$/;
exports.REMOVE_IPV4_MAPPED_IPV6_RE = /^::ffff:/;
exports.CONNECTION_ID = Buffer.concat([toUInt32(0x417), toUInt32(0x27101980)]);
exports.ACTIONS = {CONNECT: 0, ANNOUNCE: 1, SCRAPE: 2, ERROR: 3};
exports.EVENTS = {update: 0, completed: 1, started: 2, stopped: 3};
exports.EVENT_IDS = {
0: 'update',
1: 'completed',
2: 'started',
3: 'stopped'
};
exports.EVENT_NAMES = {
update: 'update',
completed: 'complete',
started: 'start',
stopped: 'stop'
};
/**
* Client request timeout. How long to wait before considering a request to a
* tracker server to have timed out.
*/
exports.REQUEST_TIMEOUT = 15000;
/**
* Client destroy timeout. How long to wait before forcibly cleaning up all
* pending requests, open sockets, etc.
*/
exports.DESTROY_TIMEOUT = 1000;
function toUInt32(n) {
var buf = Buffer.allocUnsafe(4);
buf.writeUInt32BE(n, 0);
return buf;
}
exports.toUInt32 = toUInt32;
/**
* `querystring.parse` using `unescape` instead of decodeURIComponent, since bittorrent
* clients send non-UTF8 querystrings
* @param {string} q
* @return {Object}
*/
exports.querystringParse = function (q) {
return querystring.parse(q, null, null, {decodeURIComponent: unescape});
};
/**
* `querystring.stringify` using `escape` instead of encodeURIComponent, since bittorrent
* clients send non-UTF8 querystrings
* @param {Object} obj
* @return {string}
*/
exports.querystringStringify = function (obj) {
var ret = querystring.stringify(obj, null, null, {encodeURIComponent: escape});
ret = ret.replace(/[@*/+]/g, function (char) {
// `escape` doesn't encode the characters @*/+ so we do it manually
return '%' + char.charCodeAt(0).toString(16).toUpperCase();
});
return ret;
};

31
modules/announce/server/controllers/common/common.js
View File

@@ -1,31 +0,0 @@
'use strict';
/**
* Created by wei on 2017/3/23.
*/
/**
* Functions/constants needed by both the client and server.
*/
var Buffer = require('safe-buffer').Buffer;
var extend = require('xtend/mutable');
exports.DEFAULT_ANNOUNCE_PEERS = 50;
exports.MAX_ANNOUNCE_PEERS = 82;
exports.binaryToHex = function (str) {
if (typeof str !== 'string') {
str = String(str);
}
return Buffer.from(str, 'binary').toString('hex');
};
exports.hexToBinary = function (str) {
if (typeof str !== 'string') {
str = String(str);
}
return Buffer.from(str, 'hex').toString('binary');
};
var config = require('./common-node');
extend(exports, config);

214
modules/announce/server/controllers/common/tracker.js
View File

@@ -1,214 +0,0 @@
'use strict';
function now() {
return Math.floor(new Date().getTime() / 1000);
}
const EVENT_NONE = 0;
const EVENT_COMPLETED = 1;
const EVENT_STARTED = 2;
const EVENT_STOPPED = 3;
function event(e) {
switch (e) {
case 'completed':
return EVENT_COMPLETED;
case 'started':
return EVENT_STARTED;
case 'stopped':
return EVENT_STOPPED;
}
return EVENT_NONE;
}
const PEERSTATE_SEEDER = 0;
const PEERSTATE_LEECHER = 1;
const PEER_COMPACT_SIZE = 6;
const ANNOUNCE_INTERVAL = 60;
function Peer(ip, port, left) {
if (!(this instanceof Peer))
return new Peer(ip, port, left);
this.compact = this._compact(ip, port);
this.state = (left > 0) ? PEERSTATE_LEECHER : PEERSTATE_SEEDER;
this.touch();
}
Peer.prototype = {
touch: function () {
this.lastAction = now();
},
timedOut: function (n) {
return n - this.lastAction > ANNOUNCE_INTERVAL * 2;
},
_compact: function (ip, port) {
var b = new Buffer(PEER_COMPACT_SIZE);
var parts = ip.split('.');
if (parts.length !== 4)
throw new Error('ip length error');
for (var i = 0; i < 4; i++)
b[i] = parseInt(parts[i], 10);
b[4] = (port >> 8) & 0xff;
b[5] = port & 0xff;
return b;
}
};
function File() {
if (!(this instanceof File))
return new File();
this.peerList = [];
this.peerDict = {};
this.downloads = 0;
this.seeders = 0;
this.leechers = 0;
this.lastCompact = now();
}
File.prototype = {
addPeer: function (peerId, peer, event) {
// Check if it is time to compact the peer list
var n = now();
if (this.seeders + this.leechers < this.peerList.length / 2 && this.peerList.length > 10 || (n - this.lastCompact) > ANNOUNCE_INTERVAL * 2) {
var newPeerList = [];
var i = 0;
for (var p in this.peerDict) {
if (!this.peerDict.hasOwnProperty(p))
continue;
var tmpPeer = this.peerList[this.peerDict[p]];
// Check if the peer is still alive
if (tmpPeer.timedOut(n)) {
if (tmpPeer.state === PEERSTATE_LEECHER)
this.leechers--;
else
this.seeders--;
delete this.peerDict[p];
continue;
}
newPeerList.push(tmpPeer);
this.peerDict[p] = i++;
}
this.peerList = newPeerList;
this.lastCompact = n;
}
if (event === EVENT_COMPLETED && peer.state === PEERSTATE_SEEDER)
this.downloads++;
// Check if the peer already exists
if (this.peerDict.hasOwnProperty(peerId)) {
var index = this.peerDict[peerId];
var oldPeer = this.peerList[index];
if (event === EVENT_STOPPED) {
if (oldPeer.state === PEERSTATE_LEECHER)
this.leechers--;
else
this.seeders--;
delete this.peerList[index];
delete this.peerDict[peerId];
} else {
// TODO: Should probably update compact in the old peer. So we
// handle the case if the user switched IP or Port. But we
// probably only want to do it if they differ
// oldPeer.compact = peer.compact;
if (oldPeer.state !== peer.state) {
if (peer.state === PEERSTATE_LEECHER) {
this.leechers++;
this.seeders--;
} else {
this.leechers--;
this.seeders++;
}
oldPeer.state = peer.state;
}
}
peer = oldPeer;
peer.touch();
} else if (event !== EVENT_STOPPED) {
this.peerDict[peerId] = this.peerList.length;
this.peerList.push(peer);
if (peer.state === PEERSTATE_LEECHER)
this.leechers++;
else
this.seeders++;
}
return peer;
},
writePeers: function (b, count, selfPeer) {
var c = 0;
var i = 0;
var p;
if (count > this.seeders + this.leechers) {
for (i = this.peerList.length - 1; i >= 0; i--) {
p = this.peerList[i];
if (p !== undefined && p !== selfPeer)
p.compact.copy(b, c++ * PEER_COMPACT_SIZE);
}
} else {
var m = Math.min(this.peerList.length, count);
for (i = 0; i < m; i++) {
var index = Math.floor(Math.random() * this.peerList.length);
p = this.peerList[index];
if (p !== undefined && p !== selfPeer)
p.compact.copy(b, c++ * PEER_COMPACT_SIZE);
}
}
return c * PEER_COMPACT_SIZE;
}
};
function Tracker() {
if (!(this instanceof Tracker))
return new Tracker();
this.files = {};
}
Tracker.prototype = {
getFile: function (infoHash) {
if (this.files.hasOwnProperty(infoHash))
return this.files[infoHash];
return this.addFile(infoHash);
},
addFile: function (infoHash) {
return (this.files[infoHash] = new File());
}
};
exports.PEER_COMPACT_SIZE = PEER_COMPACT_SIZE;
exports.ANNOUNCE_INTERVAL = ANNOUNCE_INTERVAL;
exports.event = event;
exports.Peer = Peer;
exports.Tracker = Tracker;