2020-12-26 01:42:23 +08:00
< ? php
2022-03-19 14:55:43 +08:00
require '../include/bittorrent_announce.php' ;
$apiLocalHost = nexus_env ( 'TRACKER_API_LOCAL_HOST' );
if ( $apiLocalHost ) {
do_log ( " [TRACKER_API_LOCAL_HOST] $apiLocalHost " );
$response = request_local_api ( trim ( $apiLocalHost , '/' ) . '/api/announce' );
2022-03-18 19:59:27 +08:00
if ( empty ( $response )) {
2022-03-19 14:55:43 +08:00
err ( " error from TRACKER_API_LOCAL_HOST " );
2022-03-18 19:59:27 +08:00
} else {
exit ( benc_resp_raw ( $response ));
}
}
//continue the normal process
2022-03-19 14:55:43 +08:00
require ROOT_PATH . 'include/core.php' ;
2020-12-26 01:42:23 +08:00
dbconn_announce ();
2021-04-29 02:52:22 +08:00
do_log ( nexus_json_encode ( $_SERVER ));
2020-12-26 01:42:23 +08:00
//1. BLOCK ACCESS WITH WEB BROWSERS AND CHEATS!
$agent = $_SERVER [ " HTTP_USER_AGENT " ];
block_browser ();
2021-06-03 21:13:59 +08:00
//check authkey
if ( ! empty ( $_REQUEST [ 'authkey' ])) {
$arr = explode ( '|' , $_REQUEST [ 'authkey' ]);
if ( count ( $arr ) != 3 ) {
err ( 'Invalid authkey' );
}
$torrentId = $arr [ 0 ];
$uid = $arr [ 1 ];
$torrentRep = new \App\Repositories\TorrentRepository ();
try {
$decrypted = $torrentRep -> checkTrackerReportAuthKey ( $_REQUEST [ 'authkey' ]);
} catch ( \Exception $exception ) {
err ( $exception -> getMessage ());
}
if ( empty ( $decrypted )) {
err ( 'Invalid authkey' );
}
2022-03-31 16:28:08 +08:00
$userInfo = \Nexus\Database\NexusDB :: remember ( " announce_user_passkey_ $uid " , 600 , function () use ( $uid ) {
return \App\Models\User :: query () -> where ( 'id' , $uid ) -> first ([ 'id' , 'passkey' ]);
});
2021-06-03 21:13:59 +08:00
if ( ! $userInfo ) {
2021-06-03 21:18:36 +08:00
err ( 'Invalid authkey' );
2021-06-03 21:13:59 +08:00
}
$_GET [ 'passkey' ] = $userInfo -> passkey ;
}
2020-12-26 01:42:23 +08:00
//2. GET ANNOUNCE VARIABLES
// get string type passkey, info_hash, peer_id, event, ip from client
foreach ( array ( " passkey " , " info_hash " , " peer_id " , " event " ) as $x )
{
2021-01-20 20:06:48 +08:00
if ( isset ( $_GET [ $x ]))
2020-12-26 01:42:23 +08:00
$GLOBALS [ $x ] = $_GET [ $x ];
}
// get integer type port, downloaded, uploaded, left from client
foreach ( array ( " port " , " downloaded " , " uploaded " , " left " , " compact " , " no_peer_id " ) as $x )
{
2021-01-06 01:31:21 +08:00
$GLOBALS [ $x ] = intval ( $_GET [ $x ] ? ? 0 );
2020-12-26 01:42:23 +08:00
}
//check info_hash, peer_id and passkey
foreach ( array ( " passkey " , " info_hash " , " peer_id " , " port " , " downloaded " , " uploaded " , " left " ) as $x )
if ( ! isset ( $x )) err ( " Missing key: $x " );
foreach ( array ( " info_hash " , " peer_id " ) as $x )
if ( strlen ( $GLOBALS [ $x ]) != 20 ) err ( " Invalid $x ( " . strlen ( $GLOBALS [ $x ]) . " - " . rawurlencode ( $GLOBALS [ $x ]) . " ) " );
if ( strlen ( $passkey ) != 32 ) err ( " Invalid passkey ( " . strlen ( $passkey ) . " - $passkey ) " );
//4. GET IP AND CHECK PORT
$ip = getip (); // avoid to get the spoof ip from some agent
if ( ! $port || $port > 0xffff )
err ( " invalid port " );
if ( ! ip2long ( $ip )) //Disable compact announce with IPv6
$compact = 0 ;
// check port and connectable
if ( portblacklisted ( $port ))
err ( " Port $port is blacklisted. " );
//5. GET PEER LIST
// Number of peers that the client would like to receive from the tracker.This value is permitted to be zero. If omitted, typically defaults to 50 peers.
$rsize = 50 ;
foreach ( array ( " numwant " , " num want " , " num_want " ) as $k )
{
if ( isset ( $_GET [ $k ]))
{
2021-01-06 01:31:21 +08:00
$rsize = intval ( $_GET [ $k ] ? ? 0 );
2020-12-26 01:42:23 +08:00
break ;
}
}
// set if seeder based on left field
$seeder = ( $left == 0 ) ? " yes " : " no " ;
// check passkey
if ( ! $az = $Cache -> get_value ( 'user_passkey_' . $passkey . '_content' )){
2022-04-19 19:18:52 +08:00
$res = sql_query ( " SELECT id, downloadpos, enabled, uploaded, downloaded, class, parked, clientselect, showclienterror, passkey, donor, donoruntil FROM users WHERE passkey= " . sqlesc ( $passkey ) . " LIMIT 1 " );
2021-06-14 12:49:16 +08:00
$az = mysql_fetch_array ( $res );
do_log ( " [check passkey], currentUser: " . nexus_json_encode ( $az ), 'error' );
2020-12-26 01:42:23 +08:00
$Cache -> cache_value ( 'user_passkey_' . $passkey . '_content' , $az , 950 );
}
if ( ! $az ) err ( " Invalid passkey! Re-download the .torrent from $BASEURL " );
2021-01-06 01:31:21 +08:00
$userid = intval ( $az [ 'id' ] ? ? 0 );
2021-06-06 00:51:48 +08:00
unset ( $GLOBALS [ 'CURUSER' ]);
2021-06-14 12:49:16 +08:00
$CURUSER = $GLOBALS [ " CURUSER " ] = $az ;
2020-12-26 01:42:23 +08:00
//3. CHECK IF CLIENT IS ALLOWED
2022-02-25 19:12:14 +08:00
//$clicheck_res = check_client($peer_id,$agent,$client_familyid);
/**
* refactor check client
*
* @ since v1 . 6.0 - beta14
*/
$agentAllowRep = new \App\Repositories\AgentAllowRepository ();
$clicheck_res = '' ;
try {
$checkClientResult = $agentAllowRep -> checkClient ( $peer_id , $agent );
$client_familyid = $checkClientResult -> id ;
} catch ( \Exception $exception ) {
$clicheck_res = $exception -> getMessage ();
}
2020-12-26 01:42:23 +08:00
if ( $clicheck_res ){
if ( $az [ 'showclienterror' ] == 'no' )
{
2022-02-25 19:12:14 +08:00
// sql_query("UPDATE users SET showclienterror = 'yes' WHERE id = ".sqlesc($userid));
$USERUPDATESET [] = " showclienterror = 'yes' " ;
2020-12-26 01:42:23 +08:00
$Cache -> delete_value ( 'user_passkey_' . $passkey . '_content' );
}
err ( $clicheck_res );
}
elseif ( $az [ 'showclienterror' ] == 'yes' ){
$USERUPDATESET [] = " showclienterror = 'no' " ;
$Cache -> delete_value ( 'user_passkey_' . $passkey . '_content' );
}
// check torrent based on info_hash
2021-06-21 02:01:26 +08:00
$checkTorrentSql = " SELECT id, owner, sp_state, seeders, leechers, UNIX_TIMESTAMP(added) AS ts, banned, hr FROM torrents WHERE " . hash_where ( " info_hash " , $info_hash );
2020-12-26 01:42:23 +08:00
if ( ! $torrent = $Cache -> get_value ( 'torrent_hash_' . $info_hash . '_content' )){
2021-06-06 00:40:28 +08:00
$res = sql_query ( $checkTorrentSql );
2020-12-26 01:42:23 +08:00
$torrent = mysql_fetch_array ( $res );
$Cache -> cache_value ( 'torrent_hash_' . $info_hash . '_content' , $torrent , 350 );
}
2021-06-06 00:40:28 +08:00
if ( ! $torrent ) {
2021-06-06 01:30:59 +08:00
$firstNeedle = " info_hash= " ;
$queryString = $_SERVER [ 'QUERY_STRING' ];
$start = strpos ( $queryString , $firstNeedle ) + strlen ( $firstNeedle );
$end = strpos ( $queryString , " & " , $start );
$infoHashUrlEncode = substr ( $queryString , $start , $end - $start );
2021-06-09 15:11:02 +08:00
do_log ( " [TORRENT NOT EXISTS] $checkTorrentSql , params: $queryString " , 'error' );
do_log ( " [TORRENT NOT EXISTS] infoHashUrlEncode: $infoHashUrlEncode " , 'error' );
2021-06-06 01:30:59 +08:00
2021-06-06 00:40:28 +08:00
err ( " torrent not registered with this tracker " );
}
2020-12-26 01:42:23 +08:00
elseif ( $torrent [ 'banned' ] == 'yes' && $az [ 'class' ] < $seebanned_class ) err ( " torrent banned " );
// select peers info from peers table for this torrent
$torrentid = $torrent [ " id " ];
$numpeers = $torrent [ " seeders " ] + $torrent [ " leechers " ];
if ( $seeder == 'yes' ){ //Don't report seeds to other seeders
$only_leech_query = " AND seeder = 'no' " ;
$newnumpeers = $torrent [ " leechers " ];
}
else {
$only_leech_query = " " ;
$newnumpeers = $numpeers ;
}
if ( $newnumpeers > $rsize )
$limit = " ORDER BY RAND() LIMIT $rsize " ;
else $limit = " " ;
2022-03-28 15:58:12 +08:00
$announce_wait = \App\Repositories\TrackerRepository :: MIN_ANNOUNCE_WAIT_SECOND ;
2020-12-26 01:42:23 +08:00
$fields = " seeder, peer_id, ip, port, uploaded, downloaded, ( " . TIMENOW . " - UNIX_TIMESTAMP(last_action)) AS announcetime, UNIX_TIMESTAMP(prev_action) AS prevts " ;
2021-06-21 02:01:26 +08:00
//$peerlistsql = "SELECT ".$fields." FROM peers WHERE torrent = ".$torrentid." AND connectable = 'yes' ".$only_leech_query.$limit;
/**
* return all peers , include connectable no
* @ since 1.6 . 0 - beta12
*/
$peerlistsql = " SELECT " . $fields . " FROM peers WHERE torrent = " . $torrentid . $only_leech_query . $limit ;
2020-12-26 01:42:23 +08:00
$real_annnounce_interval = $announce_interval ;
if ( $anninterthreeage && ( $anninterthree > $announce_wait ) && ( TIMENOW - $torrent [ 'ts' ]) >= ( $anninterthreeage * 86400 ))
$real_annnounce_interval = $anninterthree ;
elseif ( $annintertwoage && ( $annintertwo > $announce_wait ) && ( TIMENOW - $torrent [ 'ts' ]) >= ( $annintertwoage * 86400 ))
$real_annnounce_interval = $annintertwo ;
2021-06-09 02:23:09 +08:00
//$resp = "d" . benc_str("interval") . "i" . $real_annnounce_interval . "e" . benc_str("min interval") . "i" . $announce_wait . "e". benc_str("complete") . "i" . $torrent["seeders"] . "e" . benc_str("incomplete") . "i" . $torrent["leechers"] . "e" . benc_str("peers");
$rep_dict = [
" interval " => ( int ) $real_annnounce_interval ,
" min interval " => ( int ) $announce_wait ,
" complete " => ( int ) $torrent [ " seeders " ],
" incomplete " => ( int ) $torrent [ " leechers " ],
" peers " => [] // By default it is a array object, only when `&compact=1` then it should be a string
];
if ( $compact == 1 ) {
$rep_dict [ 'peers' ] = '' ; // Change `peers` from array to string
$rep_dict [ 'peers6' ] = '' ; // If peer use IPv6 address , we should add packed string in `peers6`
}
2020-12-26 01:42:23 +08:00
2022-02-17 01:10:08 +08:00
//check ReAnnounce
$params = $_GET ;
unset ( $params [ 'key' ]);
2022-02-19 23:19:09 +08:00
$lockKey = md5 ( http_build_query ( $params ));
$redis = $Cache -> getRedis ();
2022-03-28 15:58:12 +08:00
if ( ! $redis -> set ( $lockKey , TIMENOW , [ 'nx' , 'ex' => 5 ])) {
2022-02-17 01:10:08 +08:00
do_log ( 'ReAnnounce' );
benc_resp ( $rep_dict );
exit ();
}
2020-12-26 01:42:23 +08:00
unset ( $self );
2022-02-19 23:19:09 +08:00
$res = sql_query ( $peerlistsql );
2021-06-09 02:23:09 +08:00
if ( isset ( $event ) && $event == " stopped " ) {
// Don't fetch peers for stopped event
} else {
// bencoding the peers info get for this announce
while ( $row = mysql_fetch_assoc ( $res )) {
$row [ " peer_id " ] = hash_pad ( $row [ " peer_id " ]);
// $peer_id is the announcer's peer_id while $row["peer_id"] is randomly selected from the peers table
if ( $row [ " peer_id " ] === $peer_id ) {
$self = $row ;
continue ;
2021-05-01 02:02:01 +08:00
}
2021-06-09 02:23:09 +08:00
if ( $compact == 1 ) {
$peerField = filter_var ( $row [ 'ip' ], FILTER_VALIDATE_IP , FILTER_FLAG_IPV6 ) ? 'peers6' : 'peers' ;
$rep_dict [ $peerField ] .= inet_pton ( $row [ " ip " ]) . pack ( " n " , $row [ " port " ]);
} else {
$peer = [
'ip' => $row [ " ip " ],
'port' => ( int ) $row [ " port " ]
];
if ( $no_peer_id == 1 ) $peer [ 'peer id' ] = $row [ " peer_id " ];
$rep_dict [ 'peers' ][] = $peer ;
}
}
2021-05-01 02:02:01 +08:00
}
2020-12-26 01:42:23 +08:00
$selfwhere = " torrent = $torrentid AND " . hash_where ( " peer_id " , $peer_id );
//no found in the above random selection
if ( ! isset ( $self ))
{
$res = sql_query ( " SELECT $fields FROM peers WHERE $selfwhere LIMIT 1 " );
$row = mysql_fetch_assoc ( $res );
if ( $row )
{
$self = $row ;
}
}
// min announce time
2021-06-14 12:49:16 +08:00
if ( isset ( $self ) && $self [ 'prevts' ] > ( TIMENOW - $announce_wait )) {
do_log ( sprintf (
'timezone: %s, self prevts(%s, %s) > now(%s, %s) - announce_wait(%s)' ,
ini_get ( 'date.timezone' ), $self [ 'prevts' ], date ( 'Y-m-d H:i:s' , $self [ 'prevts' ]), TIMENOW , date ( 'Y-m-d H:i:s' , TIMENOW ), $announce_wait
));
err ( 'There is a minimum announce time of ' . $announce_wait . ' seconds' );
}
2020-12-26 01:42:23 +08:00
// current peer_id, or you could say session with tracker not found in table peers
if ( ! isset ( $self ))
{
$valid = @ mysql_fetch_row ( @ sql_query ( " SELECT COUNT(*) FROM peers WHERE torrent= $torrentid AND userid= " . sqlesc ( $userid )));
if ( $valid [ 0 ] >= 1 && $seeder == 'no' ) err ( " You already are downloading the same torrent. You may only leech from one location at a time. " );
if ( $valid [ 0 ] >= 3 && $seeder == 'yes' ) err ( " You cannot seed the same torrent from more than 3 locations. " );
if ( $az [ " enabled " ] == " no " )
err ( " Your account is disabled! " );
elseif ( $az [ " parked " ] == " yes " )
err ( " Your account is parked! (Read the FAQ) " );
elseif ( $az [ " downloadpos " ] == " no " )
err ( " Your downloading priviledges have been disabled! (Read the rules) " );
if ( $az [ " class " ] < UC_VIP )
{
$ratio = (( $az [ " downloaded " ] > 0 ) ? ( $az [ " uploaded " ] / $az [ " downloaded " ]) : 1 );
$gigs = $az [ " downloaded " ] / ( 1024 * 1024 * 1024 );
if ( $waitsystem == " yes " )
{
if ( $gigs > 10 )
{
$elapsed = strtotime ( date ( " Y-m-d H:i:s " )) - $torrent [ " ts " ];
if ( $ratio < 0.4 ) $wait = 24 ;
elseif ( $ratio < 0.5 ) $wait = 12 ;
elseif ( $ratio < 0.6 ) $wait = 6 ;
elseif ( $ratio < 0.8 ) $wait = 3 ;
else $wait = 0 ;
if ( $elapsed < $wait )
err ( " Your ratio is too low! You need to wait " . mkprettytime ( $wait * 3600 - $elapsed ) . " to start, please read $BASEURL /faq.php#id46 for details " );
}
}
if ( $maxdlsystem == " yes " )
{
if ( $gigs > 10 )
if ( $ratio < 0.5 ) $max = 1 ;
elseif ( $ratio < 0.65 ) $max = 2 ;
elseif ( $ratio < 0.8 ) $max = 3 ;
elseif ( $ratio < 0.95 ) $max = 4 ;
else $max = 0 ;
if ( $max > 0 )
{
$res = sql_query ( " SELECT COUNT(*) AS num FROM peers WHERE userid=' $userid ' AND seeder='no' " ) or err ( " Tracker error 5 " );
$row = mysql_fetch_assoc ( $res );
if ( $row [ 'num' ] >= $max ) err ( " Your slot limit is reached! You may at most download $max torrents at the same time, please read $BASEURL /faq.php#id66 for details " );
}
}
}
}
else // continue an existing session
{
$upthis = $trueupthis = max ( 0 , $uploaded - $self [ " uploaded " ]);
$downthis = $truedownthis = max ( 0 , $downloaded - $self [ " downloaded " ]);
2021-03-12 20:50:55 +08:00
$announcetime = ( $self [ " seeder " ] == " yes " ? " seedtime = seedtime + { $self [ 'announcetime' ] } " : " leechtime = leechtime + { $self [ 'announcetime' ] } " );
2020-12-26 01:42:23 +08:00
$is_cheater = false ;
2021-04-29 02:52:22 +08:00
2020-12-26 01:42:23 +08:00
if ( $cheaterdet_security ){
if ( $az [ 'class' ] < $nodetect_security && $self [ 'announcetime' ] > 10 )
{
$is_cheater = check_cheater ( $userid , $torrent [ 'id' ], $upthis , $downthis , $self [ 'announcetime' ], $torrent [ 'seeders' ], $torrent [ 'leechers' ]);
}
}
2021-04-29 02:52:22 +08:00
2021-03-12 20:50:55 +08:00
do_log ( " upthis: $upthis , downthis: $downthis , announcetime: $announcetime , is_cheater: $is_cheater " );
2020-12-26 01:42:23 +08:00
if ( ! $is_cheater && ( $trueupthis > 0 || $truedownthis > 0 ))
{
$global_promotion_state = get_global_sp_state ();
if ( $global_promotion_state == 1 ) // Normal, see individual torrent
{
if ( $torrent [ 'sp_state' ] == 3 ) //2X
{
$USERUPDATESET [] = " uploaded = uploaded + 2* $trueupthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis " ;
}
elseif ( $torrent [ 'sp_state' ] == 4 ) //2X Free
{
$USERUPDATESET [] = " uploaded = uploaded + 2* $trueupthis " ;
}
elseif ( $torrent [ 'sp_state' ] == 6 ) //2X 50%
{
$USERUPDATESET [] = " uploaded = uploaded + 2* $trueupthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis /2 " ;
}
else {
if ( $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
if ( $torrent [ 'sp_state' ] == 2 ) //Free
{
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
}
elseif ( $torrent [ 'sp_state' ] == 5 ) //50%
{
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis /2 " ;
}
elseif ( $torrent [ 'sp_state' ] == 7 ) //30%
{
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis *3/10 " ;
}
elseif ( $torrent [ 'sp_state' ] == 1 ) //Normal
{
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis " ;
}
}
}
elseif ( $global_promotion_state == 2 ) //Free
{
if ( $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
}
elseif ( $global_promotion_state == 3 ) //2X
{
if ( $uploaderdouble_torrent > 2 && $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
else $upthis = 2 * $trueupthis ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis " ;
}
elseif ( $global_promotion_state == 4 ) //2X Free
{
if ( $uploaderdouble_torrent > 2 && $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
else $upthis = 2 * $trueupthis ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
}
elseif ( $global_promotion_state == 5 ){ // 50%
if ( $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis /2 " ;
}
elseif ( $global_promotion_state == 6 ){ //2X 50%
if ( $uploaderdouble_torrent > 2 && $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
else $upthis = 2 * $trueupthis ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis /2 " ;
}
elseif ( $global_promotion_state == 7 ){ //30%
if ( $torrent [ 'owner' ] == $userid && $uploaderdouble_torrent > 0 )
$upthis = $trueupthis * $uploaderdouble_torrent ;
$USERUPDATESET [] = " uploaded = uploaded + $upthis " ;
$USERUPDATESET [] = " downloaded = downloaded + $truedownthis *3/10 " ;
}
}
}
$dt = sqlesc ( date ( " Y-m-d H:i:s " ));
$updateset = array ();
// set non-type event
if ( ! isset ( $event ))
$event = " " ;
if ( isset ( $self ) && $event == " stopped " )
{
sql_query ( " DELETE FROM peers WHERE $selfwhere " ) or err ( " D Err " );
if ( mysql_affected_rows ())
{
$updateset [] = ( $self [ " seeder " ] == " yes " ? " seeders = seeders - 1 " : " leechers = leechers - 1 " );
sql_query ( " UPDATE snatched SET uploaded = uploaded + $trueupthis , downloaded = downloaded + $truedownthis , to_go = $left , $announcetime , last_action = " . $dt . " WHERE torrentid = $torrentid AND userid = $userid " ) or err ( " SL Err 1 " );
}
}
elseif ( isset ( $self ))
{
2021-01-20 20:06:48 +08:00
$finished = $finished_snatched = '' ;
2020-12-26 01:42:23 +08:00
if ( $event == " completed " )
{
//sql_query("UPDATE snatched SET finished = 'yes', completedat = $dt WHERE torrentid = $torrentid AND userid = $userid");
2021-01-20 20:06:48 +08:00
$finished .= " , finishedat = " . TIMENOW ;
2020-12-26 01:42:23 +08:00
$finished_snatched = " , completedat = " . $dt . " , finished = 'yes' " ;
$updateset [] = " times_completed = times_completed + 1 " ;
}
sql_query ( " UPDATE peers SET ip = " . sqlesc ( $ip ) . " , port = $port , uploaded = $uploaded , downloaded = $downloaded , to_go = $left , prev_action = last_action, last_action = $dt , seeder = ' $seeder ', agent = " . sqlesc ( $agent ) . " $finished WHERE $selfwhere " ) or err ( " PL Err 1 " );
if ( mysql_affected_rows ())
{
if ( $seeder <> $self [ " seeder " ])
$updateset [] = ( $seeder == " yes " ? " seeders = seeders + 1, leechers = leechers - 1 " : " seeders = seeders - 1, leechers = leechers + 1 " );
2021-06-21 02:01:26 +08:00
$snatchInfo = \App\Models\Snatch :: query ()
-> where ( 'torrentid' , $torrentid )
-> where ( 'userid' , $userid )
-> orderBy ( 'id' , 'desc' )
-> first ();
if ( $snatchInfo ) {
sql_query ( " UPDATE snatched SET uploaded = uploaded + $trueupthis , downloaded = downloaded + $truedownthis , to_go = $left , $announcetime , last_action = " . $dt . " $finished_snatched WHERE torrentid = $torrentid AND userid = $userid " ) or err ( " SL Err 2 " );
2022-03-28 19:52:10 +08:00
if (
$event == 'completed'
&& $az [ 'class' ] < \App\Models\HitAndRun :: MINIMUM_IGNORE_USER_CLASS
2022-04-19 21:03:45 +08:00
&& ( $az [ 'donor' ] == 'no' || ( ! empty ( $az [ 'donoruntil' ]) && $az [ 'donoruntil' ] != '0000-00-00 00:00:00' && $az [ 'donoruntil' ] < date ( " Y-m-d H:i:s " )))
2022-03-28 19:52:10 +08:00
) {
//think about H&R
2021-06-21 02:01:26 +08:00
$hrMode = get_setting ( 'hr.mode' );
if ( $hrMode == \App\Models\HitAndRun :: MODE_GLOBAL || ( $hrMode == \App\Models\HitAndRun :: MODE_MANUAL && $torrent [ 'hr' ] == \App\Models\Torrent :: HR_YES )) {
$sql = " insert into hit_and_runs (uid, torrent_id, snatched_id) values ( $userid , $torrentid , { $snatchInfo -> id } ) on duplicate key update updated_at = " . sqlesc ( date ( 'Y-m-d H:i:s' ));
$affectedRows = sql_query ( $sql );
do_log ( " [INSERT_H&R], $sql , affectedRows: $affectedRows " );
}
}
}
2020-12-26 01:42:23 +08:00
}
}
else
{
2022-02-01 16:05:44 +08:00
if ( $event != 'stopped' ) {
$isPeerExistResultSet = sql_query ( " select id from peers where $selfwhere limit 1 " );
if ( $isPeerExistResultSet && ! mysqli_fetch_assoc ( $isPeerExistResultSet )) {
if ( strlen ( $ip ) > 15 ) {
$sockres = @ pfsockopen ( " tcp://[ " . $ip . " ] " , $port , $errno , $errstr , 1 );
} else {
$sockres = @ pfsockopen ( $ip , $port , $errno , $errstr , 1 );
}
if ( ! $sockres )
{
$connectable = " no " ;
}
else
{
$connectable = " yes " ;
@ fclose ( $sockres );
}
2022-02-17 01:10:08 +08:00
$insertPeerSql = " INSERT INTO peers (torrent, userid, peer_id, ip, port, connectable, uploaded, downloaded, to_go, started, last_action, seeder, agent, downloadoffset, uploadoffset, passkey) VALUES ( $torrentid , $userid , " . sqlesc ( $peer_id ) . " , " . sqlesc ( $ip ) . " , $port , ' $connectable ', $uploaded , $downloaded , $left , $dt , $dt , ' $seeder ', " . sqlesc ( $agent ) . " , $downloaded , $uploaded , " . sqlesc ( $passkey ) . " ) " ;
do_log ( " [INSERT PEER] peer not exists for $selfwhere , do insert with $insertPeerSql " );
try {
sql_query ( $insertPeerSql ) or err ( " PL Err 2 " );
if ( mysql_affected_rows ())
{
$updateset [] = ( $seeder == " yes " ? " seeders = seeders + 1 " : " leechers = leechers + 1 " );
$check = @ mysql_fetch_row ( @ sql_query ( " SELECT COUNT(*) FROM snatched WHERE torrentid = $torrentid AND userid = $userid " ));
if ( ! $check [ '0' ])
sql_query ( " INSERT INTO snatched (torrentid, userid, ip, port, uploaded, downloaded, to_go, startdat, last_action) VALUES ( $torrentid , $userid , " . sqlesc ( $ip ) . " , $port , $uploaded , $downloaded , $left , $dt , $dt ) " ) or err ( " SL Err 4 " );
else
sql_query ( " UPDATE snatched SET to_go = $left , last_action = " . $dt . " WHERE torrentid = $torrentid AND userid = $userid " ) or err ( " SL Err 3.1 " );
}
} catch ( \Exception $exception ) {
do_log ( " [INSERT PEER] error: " . $exception -> getMessage ());
2022-02-01 16:05:44 +08:00
}
} else {
do_log ( " [INSERT PEER] peer already exists for $selfwhere . " );
}
2021-05-01 02:02:01 +08:00
} else {
2022-02-01 16:05:44 +08:00
do_log ( " [INSERT PEER] event = 'stopped', ignore. " );
2021-05-01 02:02:01 +08:00
}
2020-12-26 01:42:23 +08:00
}
2022-04-20 00:52:12 +08:00
if ( isset ( $event ) && ! empty ( $event )) {
2022-04-22 01:32:17 +08:00
$updateset [] = 'seeders = ' . get_row_count ( " peers " , " where torrent = $torrentid and to_go = 0 " );
$updateset [] = 'leechers = ' . get_row_count ( " peers " , " where torrent = $torrentid and to_go > 0 " );
2022-04-20 00:52:12 +08:00
}
2020-12-26 01:42:23 +08:00
if ( count ( $updateset )) // Update only when there is change in peer counts
{
$updateset [] = " visible = 'yes' " ;
$updateset [] = " last_action = $dt " ;
sql_query ( " UPDATE torrents SET " . join ( " , " , $updateset ) . " WHERE id = $torrentid " );
}
if ( $client_familyid != 0 && $client_familyid != $az [ 'clientselect' ])
$USERUPDATESET [] = " clientselect = " . sqlesc ( $client_familyid );
if ( count ( $USERUPDATESET ) && $userid )
{
sql_query ( " UPDATE users SET " . join ( " , " , $USERUPDATESET ) . " WHERE id = " . $userid );
}
2021-06-09 02:23:09 +08:00
benc_resp ( $rep_dict );
2020-12-26 01:42:23 +08:00
?>