mykola/tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

retracker: implemented proxy-announcing to all trackers registered in database & retrieve peers to database.

Browse source
This commit is contained in:
mykola2312 2022-03-18 20:12:30 +02:00
parent 063e9531bb
commit 7e874e5c0d
2 changed files with 44 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
announce.php
View file

@ -1,8 +1,7 @@
<?php <?php
require("../php/config.php"); require("../php/config.php");
require("network.php"); require("network.php");
require("bencoder.php"); require("tracker.php");
require("peer.php");
$DB_NAME = "torrent"; $DB_NAME = "torrent";
$ANN_MIN_INTERVAL = 15; $ANN_MIN_INTERVAL = 15;
$ANN_INTERVAL = 60; $ANN_INTERVAL = 60;
@ -19,16 +18,6 @@ function do_error($msg)
die($msg); die($msg);
} }
function hash_decode($urldata)
{
return bin2hex(rawurldecode($urldata));
}
function hash_encode($str)
{
return hex2bin($str);
}
if (!isset($_GET["info_hash"])) { if (!isset($_GET["info_hash"])) {
bad_request("No info_hash"); bad_request("No info_hash");
@ -67,14 +56,36 @@ if (isset($_GET["port"])) {
} }
$externalIp = get_external_ip(); $externalIp = get_external_ip();
$clientPeer = new Peer($hash, is_loopback($ip) ? $externalIp : $ip, $port);
$conn = new PDO("mysql:host=$DB_HOST;dbname=$DB_NAME", $DB_USER, $DB_PASS); $conn = new PDO("mysql:host=$DB_HOST;dbname=$DB_NAME", $DB_USER, $DB_PASS);
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$stmt = $conn->prepare("REPLACE INTO `peers` (info_hash, ip, port, update_time) VALUES (:info_hash, :ip, :port, :update_time)"); $peers = array();
$peer = new Peer($hash, is_loopback($ip) ? $externalIp : $ip, $port); array_push($peers, $clientPeer);
$peer->bind($stmt);
$stmt = $conn->prepare("SELECT * FROM `trackers`");
$stmt->execute(); $stmt->execute();
$trackers = $stmt->fetchAll(PDO::FETCH_CLASS, Tracker::class);
foreach($trackers as $tracker) {
$remotePeers = $tracker->announce($hash,
$clientPeer->getIp(), $clientPeer->getPort(),
isset($_GET["peer_id"]) ? $_GET["peer_id"] : null,
isset($_GET["uploaded"]) ? $_GET["uploaded"] : 0,
isset($_GET["downloaded"]) ? $_GET["downloaded"] : 0,
isset($_GET["left"]) ? $_GET["left"] : 0
);
if ($remotePeers != false) {
$peers = array_merge($peers, $remotePeers);
}
}
foreach($peers as $peer) {
$stmt = $conn->prepare("REPLACE INTO `peers` (info_hash, ip, port, update_time) VALUES (:info_hash, :ip, :port, :update_time)");
$peer->bind($stmt);
$stmt->execute();
}
$peers = ''; $peers = '';

18
peer.php
View file

@ -1,5 +1,15 @@
<?php <?php
function hash_decode($urldata)
{
return bin2hex(rawurldecode($urldata));
}
function hash_encode($str)
{
return hex2bin($str);
}
class Peer { class Peer {
protected $info_hash; protected $info_hash;
protected $ip; protected $ip;
@ -21,6 +31,14 @@ class Peer {
$stmt->bindValue(":port", $this->port, PDO::PARAM_INT); $stmt->bindValue(":port", $this->port, PDO::PARAM_INT);
$stmt->bindValue(":update_time", $this->update_time, PDO::PARAM_STR); $stmt->bindValue(":update_time", $this->update_time, PDO::PARAM_STR);
} }
public function getIp() {
return $this->ip;
}
public function getPort() {
return $this->port;
}
} }
?> ?>