Хаблисты

<?php

set_time_limit ( 1800 );
require ('config.php');

#####timer
      $mtime = microtime();
      $mtime = explode(' ', $mtime);
      $mtime = $mtime[1] + $mtime[0];
      $starttime = $mtime;
#########

function debug($text){
    $name = 'log_'.date('H:m d-m').'.txt';
    $filename = 'log/'.$name;
    $handle = fopen($filename, 'a');
    fwrite($handle, $text);
    fclose($handle);    
}
      
function execute($sock, $str) {
      #echo "A: ".$str.'|'.PHP_EOL."<br>";

    $dedubg_info="A: ".$str."|".PHP_EOL."\r\n";
    debug($dedubg_info);

    socket_send($sock, $str.'|', strlen($str) + 1, NULL);
}

function lock2key($_LOCK) {

    $lockLength = strlen ($_LOCK);

    $h = ord($_LOCK{0}) ^ ord( $_LOCK{ $lockLength - 1} ) ^ ord( $_LOCK{ $lockLength - 2} ) ^ 5;
    while ($h > 255) {$h = $h - 256;}

    $h = (($h<<4) & 240) | (($h>>4) & 15);

    $a = $h;

    if ($a == '126' || // '~'
    $a == '124' || // '|'
    $a == '96' || // '`'
    $a == '36' || // '$'
    $a == '5' || // '^E'
    $a == '0') // NUL
    {
        $LockToKey = "/%DCN";

        if ($a < 100)
        $LockToKey .="0";
        if ($a < 10)
        $LockToKey .="0";
        $LockToKey .= $a;
        $LockToKey .= "%/";
    } else {
        $LockToKey = chr ($a);
    }

    for ($j = 1; $j < strlen($_LOCK); $j++) {
        $h = ord($_LOCK{$j}) ^ ord($_LOCK{$j-1});

        while ($h > 255) {$h = $h - 256;}

        $h = (($h<<4) & 240) | (($h>>4) & 15);
        $a = $h;

        if ($a == '126' || // '~'
        $a == '124' || // '|'
        $a == '96' || // '`'
        $a == '36' || // '$'
        $a == '5' || // '^E'
        $a == '0') // NUL
        {
            $LockToKey .= "/%DCN";

            if ($a < 100)
            $LockToKey .="0";
            if ($a < 10)
            $LockToKey .="0";
            $LockToKey .= $a;
            $LockToKey .= "%/";
        } else {
            $LockToKey .= chr ($a);
        }
    }

    return $LockToKey;
}

$mysql = mysql_connect($host, $user, $userpass) or die("<font color='red'>Ошибка соединения с MySQL!</font><br>");
mysql_select_db($bd, $mysql) or die("<font color='red'>Ошибка базы данных MySQL!</font><br>");

mysql_query("SET NAMES 'cp1251'");
mysql_query("SET CHARACTER SET 'cp1251'");

    $result = @mysql_query("SELECT * FROM `".$dbtable."` ORDER BY `".$dbtable."`.`ID` ASC LIMIT 0 , 30");
     while ($data = @mysql_fetch_assoc($result)) {

        $total_share= 0;
        $useri = 0;
        $infoyes = 1;
        $info='';
        $end = '';

    if ($fp=@fsockopen($data['Adres'],$data['Port'],$ERROR_NO,$ERROR_STR,5)) {
        fclose($fp);
        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if (!socket_connect($socket, $data['Adres'], $data['Port'])) {
            echo 'Error..';
            return;
        }

    echo "Starting ".$data['Adres']."<br>";

    while ($buffer = socket_read($socket, 2048, PHP_BINARY_READ)) {
            $linie = explode('|', $end.$buffer);
            $size = sizeof($linie);
            for ($i = 0; $i < $size; ++$i) {
                if ($i + 1 == $size) {
                    $end = $linie[$i];
                    break;
                }

         $user = explode(' ', $linie[$i]);

    #echo "Q: ".$linie[$i].PHP_EOL."<br>";

    $dedubg_info="Q: ".$linie[$i].PHP_EOL."\r\n";
    debug($dedubg_info);

            if(preg_match('#не поддерживает пинга#',$linie[$i])){
                echo $data['Adres']." не поддерживает пинга<br>";
                $info=0;
                break;
            }else{
                switch($user[0]) {
                case '$Lock':
                    execute($socket, '$Supports NoGetINFO NoHello UserIP2 Feed MCTo HubTopic ClientID MiniSlots GetZBlock ADCGet CHUNK GetCID BotINFO');
                    execute($socket, '$Key '.lock2key($user[1],$data['Port']));
                    execute($socket, '$ValidateNick '.$nick);
                break;
                case '$Hello':
                    if ($user[1] == $nick) {
                    execute($socket, '$Version 1,0091');
                    execute($socket, '$GetNickList');
                    execute($socket, '$MyINFO $ALL '.$nick.' Bot by dro <++ V:0.674,M:A,H:1/0/1,S:20>$ $LAN(T3).$alexandr@drozdin.ru$'.$myshare.'$');
                    #execute($socket, '$MyINFO $ALL '.$nick.' Bot by dro <FlylinkDC++ V:(r386),M:P,H:1/0/1,S:15>$ $100    $alexandr@drozdin.ru$670969607454$');
                    execute($socket, '$BotINFO {HubListPinger} hublist pinger');
                    }
                break;
                        case '$HubName':
                       $hubname = explode(' ', $linie[$i], 2);
                               $tmp = explode(' - ', $hubname[1], 2);
                                $hubname = $tmp[0];                                        
                       break;
                case '$HubINFO':
                    $hubinfo = $linie[$i];
                    break 3;
                break;
                case '$MyINFO':
                    $myinfo = explode('$', $linie[$i]);
                    if(isset($myinfo[6])){
                        $info[$myinfo[2]]= $myinfo[6];
                    }
                break;
                }
            }
        }
    }
    socket_close($socket);
    echo "End ".$data['Adres']."<br>";    
            
    $hubinfo = str_replace( "HubINFO ", "", $hubinfo);
    $hubinfo = explode('$', $hubinfo);
    $hubinfo[3] = str_replace(".px.", " ", $hubinfo[3]);

    $hubinfo[1] = str_replace("<", "<", $hubinfo[1]);
    $hubinfo[1] = str_replace(">", ">", $hubinfo[1]);
    $hubinfo[3] = str_replace("<", "<", $hubinfo[3]);
    $hubinfo[3] = str_replace(">", ">", $hubinfo[3]);
    
    if($hubinfo[1] == ''){
        $hubinfo[1] = $hubname;
        $hubinfo[3] = "Неудалось получить информацию о хабе";
    }
    
    if($info!=0){
        array_unique($info);
        $useri=count($info);
        $total_share=0;
        
        foreach($info as $share){
            $total_share=$share+$total_share;
        }
        $total_share=$total_share - $myshare;
    }else{
        $hubinfo[1] = $data['Adres'];
        $hubinfo[3] = "Возможно хаб не поддерживает пинги";
    }
    #print_r($info);
    unset($info);

    if ($infoyes == "1") {
        // mysql_query("UPDATE `".$dbtable."` SET Name = '".$hubinfo[1]."', Descr = '".$hubinfo[3]."',
                     // Maxusers = '".$hubinfo[4]."', MinShare = '".$hubinfo[5]."', MinSlots = '".$hubinfo[6]."',
                     // MaxHubs = '".$hubinfo[7]."', Soft = '".$hubinfo[8]."'  WHERE id = ".$data['ID']."");

        mysql_query("UPDATE `".$dbtable."` SET Name = '".$hubinfo[1]."',Descr = '".$hubinfo[3]."',
                     Maxusers = '".$hubinfo[4]."', MinShare = '".$hubinfo[5]."', MinSlots = '".$hubinfo[6]."',
                     MaxHubs = '".$hubinfo[7]."', Soft = '".$hubinfo[8]."'  WHERE id = ".$data['ID']."");
    }
    #$infoyes = "0";

    mysql_query("UPDATE `".$dbtable."` SET Users = ".$useri.", Status = 'Online', Share = ".floatval($total_share)." WHERE id = ".$data['ID']."");

    if ($useri > $data['Userspeak']){
        mysql_query("UPDATE `".$dbtable."` SET Userspeak = ".$useri." WHERE id = ".$data['ID']."");
    }

    if ($total_share > $data['Sharepeak']){
        mysql_query("UPDATE `".$dbtable."` SET Sharepeak = ".floatval($total_share)." WHERE id = ".$data['ID']."");
    }
    
}else{
    mysql_query("UPDATE `".$dbtable."` SET Status = 'Offline' WHERE id = ".$data['ID']."");
    mysql_query("UPDATE `".$dbtable."` SET Users = '0' WHERE id = ".$data['ID']."");
    mysql_query("UPDATE `".$dbtable."` SET Share = '0' WHERE id = ".$data['ID']."");
    }
}
mysql_query("UPDATE `lastupdate` set `time` = now()");
mysql_close($mysql);
########end timer
      $mtime = microtime();
      $mtime = explode(" ", $mtime);
      $mtime = $mtime[1] + $mtime[0];
      $endtime = $mtime;
      $totaltime = ($endtime - $starttime);
      echo 'This page was created in ' .$totaltime. ' seconds.';


?>