File Source for kernel.class.php

<?php
define('VER', 'phpIcqBot v0.1 alpha');
define('ICQBOT_EVENT_RESTART','Restart');
define('ICQBOT_EVENT_CONNECT','Connect');
define('ICQBOT_EVENT_DISCONNECT','Disconnect');
define('ICQBOT_EVENT_COMMAND','Command');
require_once './libs/WebIcqPro.class.php';
require_once './kernel/commands.class.php';
require_once './kernel/logs.class.php';
require_once './kernel/modules.class.php';
require_once './kernel/store.class.php';
require_once './kernel/store/store.flatfile.class.php';
require_once './kernel/users.class.php';
class IcqBot {
/**
* WebIcqPro class
*
* @var WebIcqPro
*/
public $proto;
public $uin;
private $pwd;
public $status;
/**
* Shows if phpIcqBot is working
*
* @var bool
*/
public $working;
/**
* IcqBot_Commands
*
* @var IcqBot_Commands
*/
private $comm;
/**
* Log class...
*
* @var IcqBot_Logs
*/
private $logs;
private $terminating = false;
/**
* Variable, if need to do restart
*
* @var bool
*/
private $restart = false;
/**
* Current configuration (modules, commands, etc)
*
* @var IcqBot_Conf
*/
private $conf;
public function __construct()
{
date_default_timezone_set('Asia/Yekaterinburg');
if (file_exists('./config.inc.php'))
{
require_once('./config.inc.php');
}
if (!defined('UIN'))
{
require './kernel/install.class.php';
$install = new IcqBot_Install();
if ($this->terminating = $install->work())
{
return;
}
if (file_exists('./config.inc.php'))
{
require_once('./config.inc.php');
}
if (!defined('UIN'))
{
$this->terminating = true;
echo "Some pity error.. Check permissions to write config.inc.php file.";
return;
}
}
$this->init();
//register_shutdown_function(array(&$this, "terminate"));
set_error_handler(array(&$this, 'errHandler'));
}
public function connect($uin = '', $pwd = '')
{
if ($this->terminating)
{
return;
}
if ($uin)
{
$this->uin = $uin;
$this->pwd = $pwd;
}
else
{
$this->uin = UIN;
$this->pwd = PASSWORD;
}
$this->logs->write('Connecting to ICQ server with UIN: '.$this->uin.', PWD: '.str_repeat('*',strlen($this->pwd)));
$result = $this->proto->connect($this->uin, $this->pwd);
if (!$result)
{
$this->logs->write('ICQ ERROR: '.$this->proto->error);
exit($this->proto->error);
}
$this->logs->write('Connected.');
$this->raiseEvent(ICQBOT_EVENT_CONNECT);
$this->comm->setStatus(STARTSTATUS);
return;
}
public function work()
{
if ($this->terminating)
{
return;
}
$this->connect();
$this->logs->write('Starting working cycle...');
$this->working = true;
while($this->proto->isConnected() && $this->working)
{
$this->logs->write('Working cycle.',LOGLEVEL_5);
$this->action($this->proto->readMessage());
flush();
$this->queue();
$this->cron();
sleep(1);
if ($this->restart)
{
$this->do_restart();
}
}
$this->logs->write('Working cycle finished.');
$this->deinit();
}
public function action($msg)
{
if (!isset($msg['from']) || !isset($msg['message']))
{
return false;
}
if (LOGLEVEL>=LOGLEVEL_4)
{
$this->logs->write('MSG: '.str_replace("\r"," ",str_replace("\n"," ",(print_r($msg,true)))),LOGLEVEL_4);
}
IcqBot_Users::load($msg['from'])->updateAccess();
if (substr($msg['message'],0,1) == CMD_PREF)
{
return $this->cmd($msg['from'], substr($msg['message'],1));
}
$this->logs->write('Unknown command from '.$msg['from'],LOGLEVEL_3);
return $this->comm->sendMsg($msg['from'],"Unknown command. Send ".CMD_PREF."help");
}
public function cmd($uin, $cmd)
{
if (strpos($cmd," ") !== false)
{
list($cmd, $params) = explode(" ",$cmd,2);
}
else
{
$params = '';
}
$this->logs->write("Cmd: $cmd, Uin: $uin",LOGLEVEL_3);
$this->commandModules($uin, $cmd, trim($params));
}
public function queue()
{
if (!($msg = array_shift($this->conf->msg_queue)))
{
return;
}
$this->proto->sendMessage($msg[0],$msg[1]);
}
public function logout($break = false)
{
$this->logs->write('Logging out.'.($break?' Break called.':''));
$this->proto->disconnect();
}
private function loadModules()
{
$modulesList = glob('./modules/*.module.php');
$cnt = 0;
$included_files = get_included_files();
foreach ($included_files as $n=>$f)
{
$included_files[$n]=basename($f);
}
if ($modulesList!==FALSE)
{
foreach ($modulesList as $module)
{
if ($this->loadModule($module, $included_files) === true)
{
$cnt++;
}
}
}
return $cnt;
}
public function loadModule($moduleName, &$included_files)
{
$m = false;
if (!preg_match('/([a-z0-9_]+)\.module\.php$/i',$moduleName,$m))
{
return false;
}
$this->logs->write("Loading module: ".$m[1].".module");
if (!in_array($m[1].'.module.php', $included_files))
{
$this->logs->write('File "'.$moduleName.'" is not included. Including...');
if (!file_exists('./modules/'.$m[1].'.module.php'))
{
$this->logs->write('ERROR: file "'.$moduleName.'" doesn\'t exists');
return 'ERROR: file "'.$moduleName.'" doesn\'t exists';
}
require './modules/'.$m[1].'.module.php';
}
$mod_name = 'IcqBot_Module_'.ucfirst(strtolower($m[1]));
if (!class_exists($mod_name))
{
$this->logs->write('ERROR: class "'.$mod_name.'" not found in "'.$moduleName.'".');
return 'ERROR: class "'.$mod_name.'" not found in "'.$moduleName.'".';
}
if (!is_subclass_of($mod_name, "IcqBot_Module"))
{
$this->logs->write('ERROR: class "'.$mod_name.'" is not child of IcqBot_Module class.');
return 'ERROR: class "'.$mod_name.'" is not child of IcqBot_Module class.';
}
if (key_exists($mod_name, $this->conf->modules))
{
$this->logs->write('ERROR: module "'.$mod_name.'" is already loaded.');
return 'ERROR: module "'.$mod_name.'" is already loaded.';
}
/** @var $mod IcqBot_Module **/
$this->conf->modules[$mod_name] = array("iface" => ($mod = new $mod_name ($this->comm, $this->logs)), "Commands"=>0, "Aliases"=>0);
if (is_subclass_of($mod, "IcqBot_ModuleAdmin"))
{
$mod->setIcqBot($this,$this->conf,$this->proto);
}
$mod->init();
$this->logs->write('Module "'.$m[1].'.module" loaded. Commands: '.$this->conf->modules[$mod_name]['Commands'].' '.
'Aliases: '.$this->conf->modules[$mod_name]['Aliases'].' ');
return true;
}
private function commandModules($uin, $cmd, $params)
{
if (!array_key_exists($cmd, $this->conf->commands))
{
return false;
}
$this->raiseEvent(ICQBOT_EVENT_COMMAND);
return call_user_func_array($this->conf->commands[$cmd], array($uin, $params));
}
public function terminate()
{
$this->logs->write('Error occurs... TERMINATING...');
$this->working = false;
$this->deinit();
}
public function errHandler($errno, $errstr, $errfile, $errline)
{
$err = "PHP ERROR $errstr ($errno in $errfile on $errline line)";
$this->logs->write($err, LOGLEVEL_0, '[r]', 'error.log');
}
public function restart()
{
$this->restart=true;
$this->raiseEvent(ICQBOT_EVENT_RESTART);
}
private function do_restart()
{
$this->logs->write('Restarting...');
$this->deinit();
$this->restart = false;
$this->init(true);
$this->connect();
$this->logs->write('Restart complete...');
}
private function init($restart = false)
{
$this->proto = new WebIcqPro();
$this->proto->setOption('UserAgent', 'miranda');
$this->logs = new IcqBot_Logs();
if (!$restart)
{
$this->logs->write("IcqBot started.");
}
else
{
$this->logs->write("IcqBot restarted.");
}
$this->logs->write("Loading modules...");
$this->conf = new IcqBot_Conf();
$this->conf->store = new IcqBot_Store_Flatfile($this->logs);
$this->comm = new IcqBot_Commands($this, $this->conf, $this->proto, $this->logs);
$totalLoaded = $this->loadModules();
$this->logs->write('Total modules loaded: '.$totalLoaded);
}
private function deinit()
{
$this->logs->write('Unloading modules...');
foreach($this->conf->modules as $mod_name=>$module)
{
$this->conf->modules[$mod_name]['iface']->deinit();
unset($this->conf->modules[$mod_name]['iface']);
unset($this->conf->modules[$mod_name]);
}
unset($this->conf->store);
unset($this->conf);
$this->logs->write('Disconnecting...');
$this->proto->disconnect();
$this->raiseEvent(ICQBOT_EVENT_DISCONNECT);
$this->logs->write('Unloading users...');
IcqBot_Users::saveAll();
IcqBot_Users::flushAll();
$this->logs->write('Unloading classes...');
unset($this->proto);
unset($this->comm);
$this->logs->write('Finished...');
unset($this->logs);
}
public function raiseEvent($event)
{
$i=0;
if (!isset($this->conf->events[ICQBOT_EVENT_RESTART]))
{
return 0;
}
foreach ($this->conf->events[ICQBOT_EVENT_RESTART] as $module)
{
call_user_func(array(&$module,"Event_".$event));
$i++;
}
return $i;
}
public function cron()
{
$t = time();
foreach ($this->conf->cron as $mod=>$ctime)
{
if ($ctime<=$t)
{
list($mod_name, $key) = explode('@',$mod,2);
call_user_func($this->conf->timer[$mod_name][$key]['callback'],$key);
$this->conf->cron[$mod]=$t+$this->conf->timer[$mod_name][$key]['interval'];
}
}
}
}
class IcqBot_Conf
{
/**
* Array of loaded modules
*
* @var array
*/
public $modules = array();
public $commands = array();
/**
* Outbound message queue
*
* @var array (to, msg)
*/
public $msg_queue = array();
public $cron = array();
public $timer = array();
public $events = array();
/**
* Storing class
*
* @var IcqBot_Store
*/
public $store;
}

	phpIcqBot

[ class tree: phpIcqBot ] [ index: phpIcqBot ] [ all elements ]

Source for file kernel.class.php