sources/IRCMain.php

   1 <?php
   2 /**
   3  *  This file is part of IrBot, irc robot.
   4  *  Copyright (C) 2007-2008  Bellière Ludovic
   5  *
   6  *  This program is free software: you can redistribute it and/or modify
   7  *  it under the terms of the GNU General Public License as published by
   8  *  the Free Software Foundation, either version 3 of the License, or
   9  *  (at your option) any later version.
  10  *
  11  *  This program is distributed in the hope that it will be useful,
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *  GNU General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU General Public License
  17  *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18  *
  19  */
  20
  21 require_once 'sources/IRCMain/Adapter.php';
  22
  23 class IRCMain extends IRCMain_Adapter {
  24
  25         public function __construct() {
  26                 $this->tick = tick::GetInstance();
  27         }
  28
  29         private function _authentification(Event $event) {
  30                 // TODO : create a better login process
  31
  32                 if ($event->getDataFor() == self::getConfig('nick')) {
  33                         if (preg_match('`^connect ([^ ]+) ([^ ]+)`',trim($event->getDataMessage()),$m)) {
  34                                 if ($m[1] == 'admin' && $m[2] == 'mypass') {
  35                                         $this->auth = true;
  36                                         self::notice($event->getDataSendBy(),'Vous êtes bien authentifié comme administrateur.');
  37                                 } else {
  38                                         self::notice($event->getDataSendBy(),'Erreur dans votre login et / ou mot de passe.');
  39                                         echo debug() ? 'l: '.$m[1].' p: '.$m[2]."\n":'';
  40                                 }
  41                                 return true;
  42                         }
  43                         return false;
  44                 }
  45         }
  46
  47         public function launch() {
  48                 parent::launch();
  49
  50                 $this->_pluginsInstance->add_command('core','shownick',0,'Show the current nick used (debug)','mixed');
  51                 $this->_pluginsInstance->add_command('core','nick',1,'Change the current nick','mixed');
  52                 $this->_pluginsInstance->add_command('core','quit',0,'Disconnect and stop the process','mixed');
  53                 $this->_pluginsInstance->add_command('core','restart',0,'Disconnect and restart the process','mixed');
  54                 $this->_pluginsInstance->add_command('core','help',0,'Hmm, je dois recoder cette fonction','mixed');
  55                 $this->_pluginsInstance->Init();
  56
  57                 try {
  58                         $this->_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  59                         if ($this->_socket === false) {
  60                                 throw new Exception('Impossible de créer le socket IRC !',0);
  61                         }
  62
  63                         if (self::$ip != "") {
  64                                 socket_bind($this->_socket, self::getConfig('ip'));
  65                         }
  66
  67                         $socketUp = socket_connect($this->_socket, self::getConfig('server'), self::getConfig('port'));
  68                         if ($socketUp===false) {
  69                                 throw new Exception('Impossible de se connecter au server IRC ! ('.socket_last_error().')' ,0);
  70                         }
  71
  72                         $this->connected = true;
  73
  74                         if (self::$connection_password !== false) {
  75                                 $this->put('PASS '.self::getConfig('password'));
  76                         }
  77                         // TODO : be sure for the validity of the connection password (what chain server return if fail ?)
  78
  79                         $this->put('USER '.self::getConfig('nick').' '.self::getConfig('nick').'@'.self::getConfig('ip').' '.self::getConfig('server').' :'.self::getConfig('nick'));
  80                         $this->put('NICK  '.self::getConfig('nick'));
  81
  82                         /*$this->tick->setTick('all5sec',5);
  83                         $this->tick->addJob('all5sec','hello chan','privmsg',array(self::$channel,"I'm a tick. I show this msg all 5sec."),0,$this);
  84                         */
  85
  86                         // Into the while !
  87                         while (1) {
  88
  89                                 // current data
  90                                 $this->incomingData = $this->getIncomingData();
  91
  92                                 if (!is_array($this->incomingData)) {
  93                                         $this->incomingData = array($this->incomingData);
  94                                 }
  95
  96                                 foreach ($this->incomingData as $data) {
  97                                         if (!empty($data)) {
  98                                                 $event = $this->event()->setIncoming($data);
  99
 100                                                 $action = $event->getAction();
 101
 102                                                 switch ($action) {
 103                                                         case Event::ACT_DISCONNECT:
 104                                                                 $this->disconnect('ERROR: Closing Link');
 105                                                                 sleep(3);
 106                                                                 throw new Exception('Closing Link.',1);
 107                                                                 break;
 108                                                         case Event::ACT_PING:
 109                                                                 $pong = split(':',$data);
 110                                                                 $this->put('PONG '.$pong[1]);
 111                                                         echo "PING :{$pong[1]}\nPONG {$pong[1]}\n\n";
 112                                                         break;
 113                                                         case Event::ACT_KICK:
 114                                                                 sleep(1);
 115                                                                 $this->joinChannel(self::getConfig('channel'));
 116                                                                 break;
 117                                                 }
 118
 119                                                 $this->dataInformation = $dataInformation = $event->getData();
 120
 121                                                 switch ($dataInformation['type']) {
 122
 123                                                         case Plugins_Command_Abstract::EVENT_PRIVMSG:
 124
 125                                                                 // ctcp
 126                                                                 if ($event->isCtcp()) {
 127                                                                         $ctcp = new IRCMain_Ctcp($action,$this);
 128                                                                         $responce = $ctcp->getResponce();
 129
 130                                                                         self::notice($event->getDataSendBy(),$this->ctcp($responce));
 131                                                                 } else {
 132                                                                         if (self::_authentification($event)) {
 133                                                                                 continue;
 134                                                                         }
 135                                                                 }
 136                                                                 break;
 137                                                         case 'NOTICE':
 138                                                                 break;
 139                                                 }
 140                                                 self::$plugins->set_event($event);
 141                                         }
 142                                 }
 143                         }
 144                 } catch (myRuntimeException $e) {
 145                         $x = $e->getMessage();
 146                         echo $x;
 147                         $x.= backtrace($e->getTrace());
 148                         file_put_contents('errorlog',$x);
 149                         //if ($e->_level < 2 || ($e->_level >= 256 && $e->_level < 1024)) {
 150                                 echo 'Error level : '.$e->_level."\n\n";
 151                                 throw new Exception('Error occured',0);
 152                         /*} else {
 153                                 echo 'Error level : '.$e->_level."\n\n\n\n";
 154                                 throw new Exception("Error occured. Please see errorlog for details.",1);
 155                         }*/
 156                 } catch (Exception $e) {
 157                         throw $e;
 158                 }
 159         }
 160
 161
 162
 163         public function getIncomingData() {
 164
 165                 $buffer = '';
 166                 socket_set_nonblock($this->C);
 167
 168                 while (1) {
 169                         //echo "TOC - ",time(),"\n";
 170                         //$this->tick->doAllTicks();
 171                         $buf = @socket_read($this->_socket, 4096);
 172
 173                         if (empty($buf)) {
 174                                 $this->_checkTimeout();
 175                                 sleep(1);
 176                                 continue;
 177                         }
 178
 179                         $this->_lastTimeData = mktime();
 180
 181                         if (!strpos($buf, "\n")) { //Si ne contient aucun retour, on bufferise
 182                                 $buffer = $buffer.$buf;
 183                                 $data = ""; //rien è envoyer
 184                         } else {
 185                                 //Si contient au moins un retour,
 186                                 //on vèrifie que le dernier caractère en est un
 187                                 if (substr($buf, -1, 1)  == "\n") {
 188                                         //alors on additionne ces donnèes au buffer
 189                                         $data = $buffer.$buf;
 190                                         $buffer = ""; //on vide le buffer
 191                                 } else  {
 192                                         //si le dernier caractère n'est pas un retour è la
 193                                         //ligne, alors on envoit tout jusqu'au dernier retour
 194                                         //puis on bufferise le reste
 195                                         $buffer = $buffer.substr($buf, strrchr($buf, "\n"));
 196                                         $data = substr($buf, 0, strrchr($buf, "\n"));
 197                                         $data = $buffer.$data;
 198                                         $buffer = ""; //on vide le buffer
 199                                 }
 200                         }
 201
 202                         if ($data != '') {
 203                                 $data = split("\n", $data);
 204                                 return $data;
 205                         }
 206
 207                         continue;
 208                 }
 209         }
 210 }
 211
 212 ?>