logos-storage/bittorrent-tracker
1
0
Fork 0
mirror of https://github.com/logos-storage/bittorrent-tracker.git synced 2026-01-07 15:33:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: add debug logs

Browse Source
This commit is contained in:
Feross Aboukhadijeh 2014-07-20 03:33:33 -07:00
parent d1ac7d930e
commit 8a6744f276
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server.js
View File

@ -3,6 +3,7 @@ module.exports = Server
var bencode = require('bencode') var bencode = require('bencode')
var bufferEqual = require('buffer-equal') var bufferEqual = require('buffer-equal')
var common = require('./lib/common') var common = require('./lib/common')
var debug = require('debug')('bittorrent-tracker:server')
var dgram = require('dgram') var dgram = require('dgram')
var EventEmitter = require('events').EventEmitter var EventEmitter = require('events').EventEmitter
var http = require('http') var http = require('http')
@ -234,6 +235,7 @@ Server.prototype._onHttpRequest = function (req, res) {
response['warning message'] = warning response['warning message'] = warning
} }
res.end(bencode.encode(response)) res.end(bencode.encode(response))
debug('sent response ' + response)
} else if (s[0] === '/scrape') { // unofficial scrape message } else if (s[0] === '/scrape') { // unofficial scrape message
if (typeof params.info_hash === 'string') { if (typeof params.info_hash === 'string') {
@ -268,12 +270,14 @@ Server.prototype._onHttpRequest = function (req, res) {
}) })
res.end(bencode.encode(response)) res.end(bencode.encode(response))
debug('sent response ' + response)
} else { } else {
error('only /announce and /scrape are valid endpoints') error('only /announce and /scrape are valid endpoints')
} }
function error (message) { function error (message) {
debug('sent error ' + message)
res.end(bencode.encode({ res.end(bencode.encode({
'failure reason': message 'failure reason': message
})) }))
@ -441,6 +445,7 @@ Server.prototype._onUdpRequest = function (msg, rinfo) {
} }
function send (buf) { function send (buf) {
debug('sent response ' + buf)
socket.send(buf, 0, buf.length, rinfo.port, rinfo.address, function () { socket.send(buf, 0, buf.length, rinfo.port, rinfo.address, function () {
try { try {
socket.close() socket.close()
@ -449,6 +454,7 @@ Server.prototype._onUdpRequest = function (msg, rinfo) {
} }
function error (message) { function error (message) {
debug('sent error ' + message)
send(Buffer.concat([ send(Buffer.concat([
common.toUInt32(common.ACTIONS.ERROR), common.toUInt32(common.ACTIONS.ERROR),
common.toUInt32(transactionId || 0), common.toUInt32(transactionId || 0),