PDO = new PDO('sqlite:'.BOT_TOPDIR.'/cache/functions.sqlite');
$this->PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->PDO->setAttribute(PDO::ATTR_ORACLE_NULLS, PDO::NULL_TO_STRING);
return;
}
$functions = array();
$modules = glob(BOT_TOPDIR.'/modules/*', GLOB_ONLYDIR);
foreach($modules as $dir) {
if(!is_file($dir.'/init.php')) {
continue;
}
$class = include_once($dir.'/init.php');
if(!$class || !class_exists($class, FALSE)) {
continue;
}
$init = new $class;
if(!($init instanceof BotModuleInit)) {
continue;
}
$row = $init->register();
if(!is_array($row)) {
$row = array();
}
foreach($row as $name => &$value) {
if(!is_array($value)) {
unset($row[$name]);
continue;
}
foreach($value as &$val) {
$val['dir'] = '/modules/'.basename($dir).'/';
$val['init'] = $class;
$val['file'] = $val['file'];
}
$name2 = funcs::utfToAscii(strtolower($name));
if($name != $name2) {
if(isset($row[$name2])) {
$row[$name2] = array_merge_recursive($row[$name2], $row[$name]);
}
else
{
$row[$name2] = $row[$name];
}
unset($row[$name]);
}
}
$functions = array_merge_recursive($functions, $row);
}
try {
$this->PDO = new PDO('sqlite:'.BOT_TOPDIR.'/cache/functions.sqlite');
$this->PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->PDO->setAttribute(PDO::ATTR_ORACLE_NULLS, PDO::NULL_TO_STRING);
$this->PDO->query('CREATE TABLE functions (
name VARCHAR(50),
priority INT,
dir VARCHAR(255),
init VARCHAR(255),
file VARCHAR(255),
class VARCHAR(255),
method VARCHAR(255),
params TEXT,
PRIMARY KEY (
name ASC,
priority ASC
)
)');
$this->PDO->query('CREATE INDEX file ON functions (dir, file)');
$st = $this->PDO->prepare('INSERT INTO functions (name, priority, dir, init, file, class, method, params) VALUES (?, ?, ?, ?, ?, ?, ?, ?)');
$this->PDO->beginTransaction();
foreach($functions as $name => $funcs) {
$name = funcs::utfToAscii(strtolower($name));
foreach($funcs as $priority => $func) {
if(!isset($func['params'])) {
$func['params'] = NULL;
}
$st->execute(array($name, $priority, $func['dir'], $func['init'], $func['file'], $func['class'], $func['method'], serialize($func['params'])));
}
}
$this->PDO->commit();
}
catch(Exception $e) {
@unlink(BOT_TOPDIR.'/cache/functions.sqlite');
throw $e;
}
}
/**
* Przetwarza wiadomość do bota
* @param BotMessage $msg Wiadomość
*/
function __construct(BotMessage $msg) {
try {
$this->init();
$st = $this->PDO->prepare('SELECT dir, file, class, method, params FROM functions WHERE name=? ORDER BY priority ASC');
$st->execute(array($msg->command));
$data1 = $st->fetchAll();
$st->execute(array('*'));
$data2 = $st->fetchAll();
$data = array_merge($data1, $data2);
unset($data1, $data2);
$return = NULL;
foreach($data as $func) {
if(!is_file(BOT_TOPDIR.$func['dir'].$func['file'])) {
$st = $this->PDO->prepare('DELETE FROM functions WHERE dir=? AND file=?');
$st->excecute(array($func['dir'], $func['file']));
continue;
}
require_once(BOT_TOPDIR.$func['dir'].$func['file']);
$class = new $func['class'];
$return = $class->$func['method']($msg, unserialize($func['params']));
if($return instanceof BotMsg) {
break;
}
}
if(!($return instanceof BotMsg)) {
$return = new BotMsg('Nieznane polecenie. Wpisz help by uzyskać listę komend.');
}
}
catch(Exception $e) {
$return = new BotMsg('Wystąpił błąd podczas przetwarzania poleceń. Komunikat:
'.nl2br($e));
}
try {
$class = substr(get_class($msg), strlen('BotMessage'));
if(!$class) {
throw new Exception('Wiadomość dostarczona za pomocą nieznanego interfejsu.');
}
$class = 'BotMsg'.$class;
try {
$class = new $class($return);
}
catch(Exception $e) {
$class = new $class(new BotMsg('Wystąpił błąd podczas przetwarzania poleceń. Komunikat:
'.nl2br($e)));
}
$class->sendPullResponse();
}
catch(Exception $e) {
echo 'Wystąpił błąd podczas przetwarzania poleceń. Komunikat: '.$e;
}
}
}
?>