root/announce.php

<?php</span>
<span class="code-lang">define('IN_ANNOUNCE', true);
$root_path = './';</span>
<span class="code-lang">require ($root_path . 'include/config.php');
require ($root_path . 'include/functions_announce.php');
require ($root_path . '/languages/lang_' . $config['default_lang'] . '/lang_announce.php');


$db->sql_return_on_error(true);

$updateset = $events_ary = array();
$current_time = time();
$completedat = 0;

//start receive and check main data from peer
$agent = ( isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : getenv('HTTP_USER_AGENT') );</span>
<span class="code-lang">
foreach ( array('passkey','info_hash','peer_id') AS $_null => $x) {
    if( isset($_GET[$x]) ) {
        $$x = (STRIP) ? stripslashes($_GET[$x]) : $_GET[$x];
     }
}

if ( strpos($passkey, '?') ) {
    $tmp = substr($passkey, strpos($passkey, '?'));
    $passkey = substr($passkey, 0, strpos($passkey, '?'));
    $tmpname = substr($tmp, 1, strpos($tmp, '=')-1);
    $tmpvalue = substr($tmp, strpos($tmp, '=')+1);
    $$tmpname = $tmpvalue;
}

if ( defined('USE_XBTT') ) {
    benc_resp_raw('Please redownload torrent from tracker');
}

foreach ( array('passkey','info_hash','peer_id') AS $_null => $x ) {
    if( !isset($$x) ) {
         err(sprintf($lang['announce_missing_key'], $x) );
     }
}

foreach ( array('port','downloaded','uploaded','left') AS $_null => $x ) {
    if ( isset($_GET[$x]) ) {
         $$x = 0 + $_GET[$x];
     }
    else {
         err(sprintf($lang['announce_missing_key'], $x) );
     }
}

preg_match_all('/event=([^&]*)/i', $_SERVER['QUERY_STRING'], $matches);</span>
<span class="code-lang">if ( sizeof($matches[1]) ) {
    $events_ary = $matches[1];
}

$compact = ( isset($_GET['compact']) ? 1 : 0 );

$no_peer_id = ( isset($_GET['no_peer_id']) ? 1 : 0 );

$rsize = 50;</span>
<span class="code-lang">
foreach( array('num want', 'numwant', 'num_want') AS $_null => $x ) {
    if ( isset($_GET[$x]) ) {
        $rsize = (int) $_GET[$x];
          break;
     }
}

if ( !$port || $port > 0xffff ) {
    err($lang['announce_invalid_port']);
}

foreach ( array('info_hash','peer_id') AS $_null => $x ) {
    if ( strlen($$x) != 20 ) {
            err(sprintf($lang['announce_invalid_parametr'], $x, strlen($$x), urlencode($$x)));
        }
}

if ( strlen($passkey) != 32 ) {
    err(sprintf($lang['announce_invalid_passkey'], strlen($passkey), $passkey));
}
//end receive and check main data from peer</span>
<span class="code-comment">
//start check bad clients
$bad_agents_arr = array('Gecko', 'Opera', 'MSIE', 'Links', 'Lynx', 'Mozilla', '0P3R4H');</span>
<span class="code-lang">for ( $i = 0; $i < sizeof($bad_agents_arr); ++$i ) {
    if ( strpos($agent, $bad_agents_arr[$i]) !== false ) {
        err($lang['announce_bad_client']);
    }
}

if ( strpos($peer_id, 'Torrent/3') && $agent == '0' ) {
    err($lang['announce_bad_client']);
}

if(substr($peer_id, 0, 4) == 'exbc' || substr($peer_id, 0, 3) == '-BC' || substr($peer_id, 1, 2) == 'TS' || substr($peer_id,-4) == 'UDP0' || substr($peer_id, 0, 3) == '-FG') {
    err($lang['announce_client_banned']);
}
if(substr($peer_id, 0, 1) == 'A') {
     if(substr($peer_id, 1, 3) < 300) {
            err($lang['announce_plz_update_client']);
     }
}
// start anti trackerpro (cheaters)
if ($_SERVER['HTTP_ACCEPT_ENCODING'] == 'identity' && substr($peer_id, 0, 6) == 'M4-1-3') {</span>
<span class="code-keyword">    err($lang['announce_bad_client']);
}
// end anti trackerpro (cheaters)</span>
<span class="code-comment">
//end check bad clients

$sql_priority = ($db_type == 'mysql') ? ' LOW_PRIORITY' : '';

//start select userdata for user
$sql = 'SELECT uid, uploaded, downloaded, class, hiddentorrents, parked, can_leech, torrents_limit, enabled FROM ' . USERS_TABLE . ' WHERE torrent_pass = ' . "'" . $db->sql_escape($passkey) . "'";</span>
<span class="code-lang">if( !($result = $db->sql_query($sql)) ) {
        err('user select error');
}
if ( !($userdata = $db->sql_fetchrow($result)) || !$userdata['enabled'] ) {
    err('Unknown passkey. Please redownload torrent from tracker');
}
$db->sql_freeresult($result);
//end select userdata for user</span>
<span class="code-comment">
//start select data for torrent
$sql = 'SELECT fid, banned, seeders + leechers AS numpeers, seeders, ctime, hidden, free FROM ' . TORRENTS_TABLE . ' WHERE ' . hash_where('info_hash', $info_hash);</span>
<span class="code-lang">if( !($result = $db->sql_query($sql)) ) {
        err('torrent select error');
}
if ( !($torrentdata = $db->sql_fetchrow($result)) ) {
    err('Torrent not registered with this tracker');
}
$db->sql_freeresult($result);
//end select data for torrent

$fields = 'peer_id, `left`, ip, port, uploaded, downloaded, uid, mtime';</span>
<span class="code-lang">
if ( $torrentdata['numpeers'] ) {

    $limit = ( $torrentdata['numpeers'] > $rsize ? ' LIMIT ' . $rsize : '' );

    $sql = 'SELECT ' . $fields . ' FROM ' . PEERS_TABLE . ' WHERE fid = ' . $torrentdata['fid'] . $limit;
    if( !($result = $db->sql_query($sql)) ) {
        err('peer select error');
    }

    $resp = 'd' . benc_str('interval') . 'i' . $config['announce_interval'] . 'e' . benc_str('min interval') . 'i' . $config['min_announce_interval'] . ( !$compact ? 'e' . benc_str('peers') . 'l' : 'e5:peers');
    $peer = array();
    $peer_num = 0;
    while ( $row = $db->sql_fetchrow($result) ) {
        $row['peer_id'] = hash_pad($row['peer_id']);
        $peer_id_replaced = str_replace(' ', '', $row['peer_id']);
        if ( $row['peer_id'] == $peer_id || $peer_id_replaced == $peer_id ) {
            $self = $row;
            continue;
        }
        if( !$compact ) {
            $resp .= 'd' . benc_str('ip') . benc_str($row['ip']);
            if ( !$no_peer_id ) {
                $resp .= benc_str('peer id') . benc_str($row['peer_id']);
            }
            $resp .= benc_str('port') . 'i' . $row['port'] . 'ee';
        }
        else {
            $peer_ip = explode('.', $row['ip']);
            $peer_ip = pack('C*', $peer_ip[0], $peer_ip[1], $peer_ip[2], $peer_ip[3]);
            $peer_port = pack('n*', intval($row['port']));
            $time = intval(($current_time % 7680) / 60);
            if( !$left ) {
                $time += 128;
            }
            $time = pack('C', $time);
            $peer[] = $time . $peer_ip . $peer_port;
            $peer_num++;
        }
    }
    $db->sql_freeresult($result);

    if ( !$compact ) {
        $resp .= 'ee';
    }
    else {
        $o = '';
        for( $i = 0; $i < $peer_num; $i++ ) {
            $o .= substr($peer[$i], 1, 6);
        }
        $resp .= benc_str($o) . 'e';
    }
}
else {
    $resp = 'd' . benc_str('interval') . 'i' . $config['announce_interval'] . 'e' . benc_str('min interval') . 'i' . $config['min_announce_interval'] . ( !$compact ? 'e' . benc_str('peers') . 'l' : 'e5:peers0:e');
}
$selfwhere = 'fid = ' . $torrentdata['fid'] . ' AND ' . hash_where('peer_id', $peer_id);</span>
<span class="code-lang">
if ( !isset($self) ) {
    $sql = 'SELECT ' . $fields . ' FROM ' . PEERS_TABLE . ' WHERE ' . $selfwhere;
        if( !$result = $db->sql_query($sql) ) {
                err('peer select error');
        }
        if ( $row = $db->sql_fetchrow($result) ) {
                $self = $row;
        }
        $db->sql_freeresult($result);
}

if ( in_array('completed', $events_ary) ) {
    $completedat = $current_time;
    $updateset[] = 'completed = completed + 1';
}

//start user not in peers table, it's first connect. let's insert data
if ( !isset($self) ) {</span>
<span class="code-keyword">    //start hidden torrent check
    if ( $torrentdata['hidden'] && ( !$userdata['hiddentorrents'] && $userdata['class'] < UC_MODERATOR ) ) {
        err('Hash not recognized with user! Hide!');
    }
    //end hidden torrent check

    //start seed & leech limits check
    /*$leech_count = $seed_count = 0;
    $sql = 'SELECT `left`, COUNT(*) AS c FROM ' . PEERS_TABLE . ' WHERE uid = ' . $userdata['uid'] . ' GROUP BY fid';
    $result = $db->sql_query($sql);
    if ( $row = $db->sql_fetchrow($result) ) {
        do {
            if ( $row['left'] ) {
                $leech_count = $leech_count + $row['c'];
            }
            else {
                $seed_count = $seed_count + $row['c'];
            }
        }
        while ( $row = $db->sql_fetchrow($result) );
    }
    $db->sql_freeresult($result);

    if ( $left ) {
        if ( !empty($userdata['torrents_limit']) && $userdata['can_leech'] && ( $leech_count >= $userdata['torrents_limit'] ) ) {
            err('Vi kachaete slishkom mnogo torrentov! Odnovremenno mozhno kachat ' . $userdata['torrents_limit'] . ' torrentov');
        }
     }
    elseif ( !empty($config['max_torrent_allow_seed']) && ( $seed_count >= $config['max_torrent_allow_seed'] ) && $userdata['class'] < UC_UPLOADER ) {
        err('Vi sidiruete slishkom mnogo torrentov. Odnovremenno mozhno sidirovat ' . $config['max_torrent_allow_seed'] . ' torrentov');
     }*/
    //end seed & leech limits check

    //start wait time check
    if ( $config['waittime'] && $left && $userdata['class'] < UC_VIP ) {
         $gigs = $userdata['uploaded'] / (1024*1024*1024);
        $elapsed = floor(($current_time - $torrentdata['ctime']) / 3600);
        $ratio = (($userdata['downloaded'] > 0) ? ($userdata['uploaded'] / $userdata['downloaded']) : 1);
        if ($ratio < 0.5 || $gigs < 5) {
            $wait = 48;
        }
        elseif ($ratio < 0.65 || $gigs < 6.5) {
            $wait = 24;
        }
        elseif ($ratio < 0.8 || $gigs < 8) {
            $wait = 12;
        }
        elseif ($ratio < 0.95 || $gigs < 9.5) {
            $wait = 6;
        }
        else {
             $wait = 0;
        }
        if ( $elapsed < $wait ) {
            err('Vam nado podozhdat (' . ($wait - $elapsed) . ' chasov) - Prochtite FAQ!');
        }
    }
     //end wait time check

    //start parked check
    if ( $userdata['parked'] ) {
        err('Error, your account is parked! Please read the FAQ!');
     }
     //end parked check

     //start can leech check
     if ( !$userdata['can_leech'] && $left ) {
         err('Vi ne mozhete kachat torrenti.');
     }
     //end can leech check

    //start insert data into peers table
    $sql = 'INSERT INTO ' . PEERS_TABLE . ' ' . $db->sql_build_array('INSERT', array(
            'fid'           => $torrentdata['fid'],
            'peer_id'       => $peer_id,
            'ip'        => $user_ip,
            'port'      => $port,
            'uploaded'      => $uploaded,
            'downloaded'    => $downloaded,
            '`left`'    => $left,
            'started'       => $current_time,
            'mtime'     => $current_time,
            'uid'       => $userdata['uid'],
            'useragent'     => $agent ));

    if ( $db->sql_query($sql) ) {
        if ( !$left ) {
            $updateset[] = 'seeders = seeders + 1';
            if ( !$torrentdata['seeders'] ) {
                $updateset[] = 'visible = 1';
            }
        }
        else {
            $updateset[] = 'leechers = leechers + 1';
        }
    }
    else {
        err('Insert peers error');
    }
    //end insert data into peers table


    //only for mysql

    $sql = 'INSERT INTO ' . SNATCHED_TABLE . ' ' . $db->sql_build_array('INSERT', array(
            'torrentid'     => $torrentdata['fid'],
            'userid'    => $userdata['uid'],
            'uploaded'      => $uploaded,
            'downloaded'    => $downloaded,
            'last_action'   => $current_time,
            'completedat' => $completedat,
        )) .
        ' ON DUPLICATE KEY UPDATE
        last_action = VALUES(last_action),
        uploaded = uploaded + VALUES(uploaded),
        downloaded = downloaded + VALUES(downloaded),
        completedat = if(values(completedat) = 0, completedat, ' . $current_time . ')';
    if ( !$db->sql_query($sql) ) {
        $error = $db->sql_error();
        err('Update snatched error');
    }

}
//end user not in peers table, it's first connect. let's insert data</span>
<span class="code-comment">
//start user already in peers table, it's first connect. let's update data
else {</span>
<span class="code-keyword">    $user_uploaded = $upthis = max(0, $uploaded - $self['uploaded']);
    $user_downloaded = $downthis = max(0, $downloaded - $self['downloaded']);
    $current_total_time = 0;
    if ( $torrentdata['free'] ) {
        switch ( $torrentdata['free'] ) {
            case 1:
                $user_downloaded = 0;
            break;
            case 2:
                $user_downloaded = round($user_downloaded * 0.50);
            break;
            case 4:
                $user_downloaded = round($user_downloaded * 0.75);
            break;
        }
    }

    if ( $userdata['class'] == UC_VIP ) {
        $user_uploaded = 0;
        $user_downloaded = 0;
    }

    if ( !$left && $self['mtime'] < $current_time ) {
        $sql = 'SELECT COUNT(*) AS count FROM ' . PEERS_TABLE . ' WHERE `left` = 0 AND uid = ' . $userdata['uid'];
        $result = $db->sql_query($sql);
        $count = ( $row = $db->sql_fetchrow($result) ) ? $row['count'] : 0;
        if ( $count ) {
            $current_total_time = round( ( ( $current_time - $self['mtime'] ) / $count ) );
        }
    }

    if ( $user_uploaded > 0 || $user_downloaded > 0 || $current_total_time > 0 ) {
        $sql = 'UPDATE' . $sql_priority . ' ' . USERS_TABLE . ' SET
                uploaded = uploaded + ' .  $user_uploaded . ',
                downloaded = downloaded + ' . $user_downloaded . ',
                total_seed_time = total_seed_time + ' . $current_total_time . '
                WHERE uid = ' . $userdata['uid'];
        if( !$db->sql_query($sql) ) {
            err('Up/Down Stats Error');
        }
        // Initial sanity check xMB/s for 1 second
        if( $upthis > 2097152 && $self['mtime'] < $current_time ) {
            //Work out time difference
            $endtime = $current_time;
            $starttime = $self['mtime'];
            $diff = ($endtime - $starttime);
            //Normalise to prevent divide by zero.
            $rate = ($upthis / ($diff + 1));
            //Currently 2MB/s. Increase to 5MB/s once finished testing.
            if ($rate > 2097152) {
                if ($userdata['class'] < UC_MODERATOR) {
                    $sql = 'INSERT INTO ' . CHEATERS_TABLE . ' ' . $db->sql_build_array('INSERT', array(
                           'added'     => $current_time,
                           'userid'    => $userdata['uid'],
                           'rate'      => $rate,
                           'beforeup'      => $userdata['uploaded'],
                           'upthis'    => $upthis,
                           'timediff'      => $diff,
                           'userip'    => $user_ip,
                           'torrentid'     => $torrentdata['fid'],
                           'che_useragent' => $agent,
                           'che_peer_id'   => $peer_id));
                    if( !($db->sql_query($sql)) ) {
                        err('Check Error');
                    }
                }
            }
        }
    }

    $upd_sql =  ( $upthis ? 'uploaded = uploaded + ' .  $upthis . ',' : '' );
    $upd_sql .= ( $downthis ? 'downloaded = downloaded + ' . $downthis . ',' : '' );
    $upd_sql .= ( $completedat ? 'completedat = ' . $completedat . ',' : '' );
    $sql = 'UPDATE' . $sql_priority . ' ' . SNATCHED_TABLE . ' SET ' . $upd_sql . ' last_action = ' . $current_time . ' WHERE torrentid = ' . $torrentdata['fid'] . ' AND userid = ' . $userdata['uid'];

    if( !$db->sql_query($sql) ) {
        err('Update snatched error');
    }

    if ( in_array('stopped', $events_ary) ) {
        $sql = 'DELETE FROM ' . PEERS_TABLE . ' WHERE ' . $selfwhere;
        $result = $db->sql_query($sql);
        if ( $db->sql_affectedrows($result) ) {
            if ( !$self['left'] ) {
                $updateset[] = 'seeders = seeders - 1';
                if ( $torrentdata['seeders'] == 1 ) {
                    $updateset[] = 'visible = 0';
                }
            }
            else {
                $updateset[] = 'leechers = leechers - 1';
            }
        }
     }
    else {
        $secs = $current_time - $self['mtime'];
        $uprate = ( $secs ? round($upthis / $secs) : 0 ); //we calculate upl speed for last session
        $downrate = ( $left ? ( $secs ? round($downthis / $secs) : 0 ) : 0 ); //we calculate down speed for last session

        $sql = 'UPDATE ' . PEERS_TABLE . ' SET ' . $db->sql_build_array('UPDATE', array(
               'uploaded'   => $uploaded,
               'upspeed'    => $uprate,
               'downloaded' => $downloaded,
               'downspeed'  => $downrate,
               'port'       => $port,
               '`left`'     => $left,
               'mtime'      => $current_time )) .
               ' WHERE ' . $selfwhere;

        if( !$db->sql_query($sql) ) {
            err('Update peers error');
        }
        if ( $db->sql_affectedrows() && $self['left'] != $left && !$left ) {
            $updateset[] = 'seeders = seeders + 1';
            $updateset[] = 'leechers = leechers - 1';
            if ( !$torrentdata['seeders'] ) {
                $updateset[] = 'visible = 1';
            }
        }
    }
}
//end user already in peers table, it's first connect. let's update data

if ( !$left ) {</span>
<span class="code-keyword">    $updateset[] = 'mtime = ' . $current_time;
}

if ( sizeof($updateset) ) {
    $sql = 'UPDATE' . $sql_priority . ' ' . TORRENTS_TABLE . ' SET ' . implode(',', $updateset) . ' WHERE fid = ' . $torrentdata['fid'];
    if( !($db->sql_query($sql)) ) {
        err('Update torrents error');
    }
}
benc_resp_raw($resp);
?>