This repository has been archived on 2020-05-27. You can view files and clone it, but cannot push or open issues/pull-requests.
nwnadmin/lib/NWNDriver.php

284 lines
7.7 KiB
PHP

<?php
require_once 'Horde/DataTree.php';
class NWNSettings extends DataTreeObject
{
var $_datatree;
function NWNSettings($name, $properties = null)
{
parent::DataTreeObject($name);
// dto settings
$this->data['type'] = 'nwnsettings';
$this->data['name'] = isset($properties['name']) ? $properties['name'] :
'';
// datatree initialization for persistent storage
global $conf;
$driver = $conf['datatree']['driver'];
$params = Horde::getDriverConfig('datatree', $driver);
$params = array_merge($params, array('group' => 'nwnadmin.settings'));
$this->_datatree = &DataTree::singleton($driver, $params);
// create the neccessary datatree node if it does not exist
if (!$this->_datatree->exists($this)) {
$this->_datatree->add($this);
}
}
/**
* Set the attributes of the object.
*
* @param array The attributes to set.
* @param boolean Determines whether the backend should
* be updated or not
*/
function setData($settings)
{
if (!is_array($settings)) {
return PEAR::raiseError("Settings are not an array!");
}
parent::setData($settings);
return $this->_datatree->updateData($this);
}
function &getSettings()
{
$rawsettings =
$this->_datatree->getAttributes($this->_datatree->getId($this));
$result = array();
foreach ($rawsettings as $setting) {
$result[$setting['name']] = $setting['value'];
}
return $result;
}
/**
* Map this object's attributes from the data array into a format
* that we can store in the attributes storage backend.
*
* @return array The attributes array.
*/
function _toAttributes()
{
foreach ($this->data as $key => $value) {
$attributes[] = array('name' => $key,
'key' => '',
'value' => $value);
}
return $attributes;
}
/**
* Take in a list of attributes from the backend and map it to our
* internal data array.
*
* @param array $attributes The list of attributes from the
* backend (attribute name, key,
* and value).
*/
function _fromAttributes($attributes)
{
foreach ($attributes as $attribute) {
$this->data[$attribute['name']] = $attribute['value'];
}
}
function &factory($name, $properties = null)
{
return $ret = &new NWNSettings($name, $properties);
}
function &singleton($name, $properties = null)
{
static $instance;
if (!isset($instance))
{
$instance = &NWNSettings::factory($name, $properties);
}
return $instance;
}
}
class NWNDriver
{
var $_settingsbackend;
function NWNDriver()
{
$this->_settingsbackend = &NWNSettings::singleton('nwnadmin.settings',
array('name' => 'nwnadmin.settings'));
}
function setData($settings)
{
return $this->_settingsbackend->setData($settings);
}
function &getParams()
{
return $this->_settingsbackend->getSettings();
}
function &factory()
{
return $ret = &new NWNDriver();
}
function &singleton()
{
static $instance;
if (!isset($instance))
{
$instance = &NWNDriver::factory();
}
return $instance;
}
function serverRunning()
{
global $conf;
static $command;
if (is_null($command) || empty($command)) {
$command = $conf['system']['ps'] . ' aux| ' .
$conf['system']['grep'] . ' ' .
$conf['server']['binary'] . ' | ' .
$conf['system']['grep'] . ' -v ' .
basename($conf['system']['grep']);
}
$result = shell_exec($command);
if (!empty($result)) {
$sets = preg_split('/\s+/', $result);
$result = $sets[1];
}
return $result;
}
function startServer()
{
if ($this->serverRunning()) {
return PEAR::raiseError("Server is up!");
}
global $conf;
chdir(NWNAdmin::getServerRoot());
$settings = &$this->_settingsbackend->getSettings();
unset($settings['module']);
$settingString = '';
foreach ($settings as $key => $val) {
if (!is_null($val) && $val !== '') {
$settingString .= sprintf(" -%s '%s' ", $key,
escapeshellcmd($val));
}
}
shell_exec(NWNAdmin::getServerExecutable() .$settingString . ' > ' .
$this->_getLog() . ' 2>&1 < ' . $this->_checkFifo() . ' &');
$this->_settingsbackend->setData($settings);
return true;
}
function stopServer()
{
global $conf;
shell_exec($conf['system']['echo'] . ' quit > ' . $this->_checkFifo());
return true;
}
function killServer()
{
if (!($pid = $this->serverRunning())) {
return PEAR::raiseError(_("Server is down!"));
}
return !posix_kill($pid, 9);
}
function sendCommand($command, $flush = false)
{
if (!$this->serverRunning()) {
return PEAR::raiseError(_("Server is down!"));
}
global $conf;
if ($flush) {
shell_exec(implode(' ', array($conf['system']['echo'], '>',
$this->_getLog())));
}
shell_exec(implode(' ', array($conf['system']['echo'],
escapeshellcmd($command), '>', $this->_checkFifo())));
return true;
}
function getLogContent()
{
$fp = fopen($this->_getLog(), 'r');
$data = fread($fp, filesize($this->_getLog()));
fclose($fp);
return $data;
}
function useModule($moduleName, $flush = false)
{
$settings = &$this->_settingsbackend->getSettings();
$settings['module'] = $moduleName;
if ($this->serverRunning()) {
$this->sendCommand('module ' . $moduleName, $flush);
sleep(2);
$result = $this->getLogContent();
$lines = explode("\n", $result);
$found = true;
foreach ($lines as $l) {
$l = trim($l);
if (!strpos($l, $moduleName) && strpos($l, 'Unable')) {
$found = false;
}
}
if (!$found) {
unset($settings['module']);
$this->_settingsbackend->setData($settings);
return PEAR::raiseError(_("Could not load the module!"));
}
} else {
return PEAR::raiseError(_("Server is not running!"));
}
$this->_settingsbackend->setData($settings);
return true;
}
function getModule()
{
$settings = &$this->_settingsbackend->getSettings();
if (!isset($settings['module'])) {
$settings['module'] = '';
}
return $settings['module'];
}
function _getLog()
{
static $logfile;
if (is_null($logfile)) {
$logfile = Horde::getTempDir() . '/nwnadmin.log';
}
return $logfile;
}
function _checkFifo()
{
static $fifoName;
if (is_null($fifoName) || empty($fifoName)) {
$fifoName = Horde::getTempDir() . '/nwnadmin-input';
}
if (!file_exists($fifoName) &&
!posix_mkfifo($fifoName, 0640)) {
$fifoName = '';
}
return $fifoName;
}
}