irc_class.php

<?php

/* 
 * (с) 2018 Грибов Павел
 * http://грибовы.рф * 
 * Если исходный код найден в сети - значит лицензия GPL v.3 * 
 * В противном случае - код собственность ГК Яртелесервис, Мультистрим, Телесервис, Телесервис плюс * 
 */

class Tirc{
    var $debug=false;
    var $server="localhost";
    var $port=6667;    
    var $errno0;
    var $errstr="";
    var $timeout=10;
    var $socket;
    var $nick="noname";
    var $chanel="noname";
    
    /**
     *  Внутрення функция для логов
     */
    private function putlog($st){
        if ($this->debug==true) echo date("H-i-s")." : ".trim($st)."\n";
    }
    
    /**
     * Конструктор класса. Вызывается при создании экземпляра
     * @param type $server  - хост сервера
     * @param type $port    - порт сервера
     */
    function __construct($server, $port,$debug=false) {
            $this->server = $server;
            $this->port = $port;
            $this->debug=$debug;
            $this->putlog("лог в режиме DEBUG");
            $this->putlog("сервер $server, порт $port");
    }	    
    /**
     *  Соединение с сервером. Возврат - результат
     * @return type
     */
    function connect(){
        $this->putlog("пробуем соедениться с irc сервером");        
        $this->socket=stream_socket_client("tcp://$this->server:$this->port", $this->errno, $this->errstr,$this->timeout,STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT);
        $this->putlog("возврат: errno: $this->errno, errstr: $this->errstr, socket: $this->socket");              
        return $this->socket;        
    }
    /**
     * Разрыв соединения с сервером. Возврат - результат
     */
    function disconnect(){
        $this->putlog("пробуем закрыть соединение с сервером $this->socket");
        $ret=fclose($this->socket);
        $this->putlog("результат: $ret");
    }
    /**
     *  Послать команду серверу. Возврат false или количество посланый байт
     * @param type $command
     * @return type
     */
    function send($command){
        $this->putlog("пробуем послать команду сервер $command");
        $ret=fwrite($this->socket, $command);
        $this->putlog("результат: $ret");
        return $ret;
    }
    function Join($chanel){
        $this->chanel=$chanel;
        $res=$this->send("JOIN :#$chanel\r\n");        
        return $res;
    }
    function is_ping($line){         
        if(strstr($line, 'PING')) {
            $this->putlog("получен PING");
            return true;         
        }            
        
    }
    function pong(){         
        $this->send("PONG :".$this->server."\r\n");         
        $this->putlog("отправлен PONG");
    }    
    function is_msg($line){ 
        if(strstr($line, 'PRIVMSG')) return true;         
    }        
    function SetNick($nick){
        $this->nick=$nick;
        $ret=$this->send("NICK $nick\r\n");
        return $ret;
    }
    function User($name){        
        $ret=$this->send("USER $name $this->server bla :$name\r\n");        
        return $ret;
    }
    function listChans(){
        $ret=$this->send("LIST\r\n");         
        return $ret;
    }    
    function sendmessage($target, $msg){ 
        $ret=$this->send("PRIVMSG $target :$msg\r\n");         
        return $ret;
    }    
    function loop($onMessage){
        while (!feof($this->socket)) {
             $res = fgets($this->socket, 256); // ждем сообщений
             $onMessage($res);
             if($this->is_ping($res)) $this->pong();
        };
    }
}