sources/main-class.inc.php

   1 <?php
   2
   3 class main {
   4
   5         // Timeout avant une reconnexion
   6         public $socketTimeout = 280;
   7
   8         // Variables privées
   9         static public $instance = FALSE;
  10
  11         protected $C;
  12
  13         static $botVersion = '1.0';
  14         static $server;
  15         static $port;
  16         static $channel;
  17         static $myBotName;
  18         static $ip;
  19         static $domain;
  20         static $connection_password;
  21
  22         private $irc, $plugin;
  23         public $formater;
  24         public $base;
  25         public $msg;
  26         public $plugins = array();
  27         public $commands;
  28
  29         private $core_commands;
  30         private $users_list;
  31
  32         public static function GetInstance() {
  33                 if (!self::$instance) {
  34                         self::$instance = new main();
  35                 }
  36                 return self::$instance;
  37         }
  38
  39         private function __construct() {
  40                 // load config and other things
  41
  42                 $this->irc = new irc;
  43                 $this->plugin = new plugin;
  44                 $this->formater = text_format::GetInstance();
  45
  46                 // core plugin is an exeption in do_command
  47                 $this->plugin->add_command('core','shownick',0,'Show the current nick used (debug)');
  48                 $this->plugin->add_command('core','nick',1,'Change the current nick');
  49                 $this->plugin->add_command('core','quit',0,'Disconnect and stop the process');
  50                 $this->plugin->add_command('core','restart',0,'Disconnect and restart the process');
  51                 $this->plugin->add_command('core','help',0,'Hmm, je dois recoder cette fonction');
  52         }
  53
  54         public function launch() {
  55                 try {
  56                         $this->C = @fsockopen(self::$server, self::$port, $errno, $errstr, 10);
  57                         if (!$this->C) {
  58                                 throw new Exception('Impossible de se connecter au server IRC !',0);
  59                         }
  60
  61                         if (self::$connection_password !== false) {
  62                                 $this->put('PASS '.self::$connection_password);
  63                         }
  64                         // TODO : be sure for the validity of the connection password (what chain server return if fail ?)
  65
  66                         $this->put('USER '.self::$myBotName.' '.self::$myBotName.'@'.self::$ip.' '.self::$domain.' :XBOT');
  67                         $this->put('NICK  '.self::$myBotName);
  68
  69                         while (1) {
  70                                 $this->msg = $this->get();
  71                                 $this->irc->parse_get($msg);
  72
  73                                 $msg_info = $this->irc->get_msg_info();
  74
  75                                 switch ($msg_info['type']) {
  76
  77                                         case 'PRIVMSG':
  78
  79                                                 // ctcp
  80                                                 if ($msg_info['message'][0] == chr(001)) {
  81
  82                                                         list($cmd,$query) = explode(chr(032),$msg_info['message']);
  83
  84                                                         // we don't need this character
  85                                                         $cmd = str_replace(chr(001), "", $msg_info['message']);
  86
  87                                                         switch ($cmd) {
  88                                                                 case 'CLIENTINFO':
  89                                                                         self::notice($msg_info['from'],$this->formater->ctcp('PING VERSION TIME USERINFO CLIENTINFO'));
  90                                                                         break;
  91
  92                                                                 case 'VERSION':
  93                                                                         self::notice($msg_info['from'],$this->formater->ctcp('RPGBot version '.main::$botVersion.' - PHP  '.phpversion().' -- par Tornald et Bloodshed'));
  94                                                                         break;
  95
  96                                                                 case 'USERINFO':
  97                                                                         self::notice($msg_info['from'],$this->formater->ctcp('RPGBot'));
  98                                                                         break;
  99
 100                                                                 case 'TIME':
 101                                                                         self::notice($msg_info['from'],$this->formater->ctcp(date('Y-m-d H:i:s')));
 102                                                                         break;
 103
 104                                                                 case 'PING':
 105                                                                         self::notice($msg_info['from'],$this->formater->ctcp("PING ".$query));
 106                                                                         break;
 107                                                         }
 108                                                 } else {
 109                                                         if ($msg_info['to'] == main::$myBotName) {
 110                                                                 // auth proccess
 111                                                                 if (preg_match('`^connect ([^ ]+) ([^ ]+)`',$msg_info['message'],$m)) {
 112                                                                         if ($m[1] == 'admin' && $m[2] == 'mypass') {
 113                                                                                 $this->auth = true;
 114                                                                                 self::notice($msg_info['from'],'Vous êtes bien authentifié comme administrateur.');
 115                                                                         } else {
 116                                                                                 self::notice($msg_info['from'],'Erreur dans votre login et / ou mot de passe.');
 117                                                                         }
 118                                                                         continue;
 119                                                                 }
 120                                                         }
 121
 122                                                         if ($msg_info['message'][0] == '!') {
 123                                                                 $message = substr($msg_info['message'],1);
 124                                                                 $query = explode(' ',$message);
 125                                                                 $query_count = count($query);
 126
 127                                                                 if (isset($this->commands[$query[0]])) {
 128                                                                         if ($query_count > 1) {
 129                                                                                 if ($this->commands[$query[0]][$query[1]]['type'] == 'mixed' ||
 130                                                                                         $msg_info['to'] == main::$myBotName && $this->commands[$query[0]][$query[1]]['type'] == 'private' ||
 131                                                                                         $msg_info['to'] == main::$channel && $this->commands[$query[0]][$query[1]]['type'] == 'public') {
 132                                                                                         /*
 133                                                                                          * $query = array( plugins, method[, arg[, ...]] )
 134                                                                                          * !plugin method[ arg[ ...]]
 135                                                                                          */
 136                                                                                         call_user_func_array(array($this,'do_command'),array_merge(array('msg_info'=>$msg_info),$query));
 137                                                                                 }
 138                                                                         } else {
 139                                                                                 // no method : need a list of commands
 140                                                                                 $plugin = $message;
 141
 142                                                                                 $commands = self::list_command($plugin);
 143                                                                                 foreach ($commands as $command_info) {
 144                                                                                         if ($command_info['type'] == 'public') {
 145                                                                                                 $get_plugin_method = '!'.$plugin;
 146                                                                                         } else {
 147                                                                                                 $get_plugin_method = '/msg ' . main::$myBotName . ' !' . $plugin;
 148                                                                                         }
 149
 150                                                                                         $this->privmsg($msg_info['from'],$this->formater->bold('Command :')." $get_plugin_method {$command_info['method']}".(($command_info['accepted_args']>0)?' [some args...]':''));
 151
 152                                                                                         $help = explode("\n",$command_info['help']);
 153                                                                                         foreach($help as $help_msg) {
 154                                                                                                 $this->privmsg($msg_info['from'],$help_msg);
 155                                                                                         }
 156                                                                                 }
 157                                                                         }
 158                                                                 }
 159                                                         }
 160                                                 }
 161                                                 break;
 162                                         case 'NOTICE':
 163                                                 break;
 164                                         default:
 165                                                 break;
 166                                 }
 167
 168                         }
 169                 } catch (Exception $e) {
 170                         switch ($e->getCode()) {
 171                                 case 0: // stop
 172                                         echo "Processe restarting ...";
 173                                         return 0;
 174                                         break;
 175
 176                                 default:
 177                                         break;
 178                         }
 179                 }
 180         }
 181
 182         public function joinChannel($channel) {
 183                 $this->put('JOIN '.$channel);
 184                 echo "Join channel $channel ...\n";
 185         }
 186
 187         private function nick_change() {
 188                 echo "New nick : ".self::$myBotName."\n";
 189                 $this->put('NICK :'.self::$myBotName);
 190         }
 191
 192         public function newNick($new=false) {
 193                 switch ($new) {
 194                         case self::$myBotName:
 195                                 echo "New nick : [ERR] no changes :". self::$myBotName . ' == ' . $new ."\n";
 196                                 break;
 197                         case false:
 198                                 self::$myBotName .= '_';
 199                                 self::nick_change();
 200                                 break;
 201                         default:
 202                                 self::$myBotName = $new;
 203                                 self::nick_change();
 204                                 break;
 205                 }
 206         }
 207
 208         /**
 209          * Envoie une notice a un salon / utilisateur
 210          *
 211          * @param string $to
 212          * @param string $message
 213          */
 214         public function notice ($to,$message) {
 215                 self::put('NOTICE '.$to.' :'.$message."\n");
 216         }
 217
 218         /**
 219          * Envoie un message (PRIVMSG) a un salon / utilisateur
 220          *
 221          * @param string $to
 222          * @param string $message
 223          */
 224         public function privmsg ($to,$message) {
 225                 self::put('PRIVMSG '.$to.' :'.$message."\n");
 226         }
 227
 228         public function put($command) {
 229                 if (!is_resource($this->C)) {
 230                         throw new Exception('Connection lost...',1);
 231                 }
 232                 echo debug() ? '[->' . $command . "" : '';
 233                 fputs($this->C, $command . "\n");
 234                 return true;
 235         }
 236
 237         public function get() {
 238                 // Stream Timeout
 239                 stream_set_timeout($this->C, $this->socketTimeout);
 240
 241                 $tmp1 = time();
 242                 $content = fgets($this->C, 1024);
 243
 244                 echo debug() ? "<-]$content" : '';
 245
 246                 if ($content != '') {
 247                                 return $content;
 248                 }
 249
 250                 // TIMEOUT
 251                 if (time()-$tmp1 >= $this->socketTimeout) {
 252                         throw new Exception('TIMEOUT',0);
 253                 }
 254         }
 255
 256         public function disconnect($msg='EOL ;') {
 257                 echo 'Closing Link...'."\n";
 258                 $this->put('QUIT :'.$msg);
 259                 if (is_resource($this->C)) {
 260                         @fclose($this->C);
 261                 }
 262                 return true;
 263         }
 264
 265         private function load_user($file='users.db') {
 266                 echo "Loading users ...";
 267                 $ulist = explode("\n",file_get_contents($file));
 268                 foreach ($ulist as $user) {
 269                         list($uname,$upass,$uright) = explode(':',$user);
 270                         $this->users_list[$uname] = array($upass,$uright);
 271                 }
 272                 echo "\t\t\tdone.\n";
 273         }
 274 }
 275
 276 interface plugin {
 277
 278         public function __construct($main);
 279         public function commands_list();
 280         public function current_message($message);
 281 }
 282
 283 ?>