136 lines
4.3 KiB
PHP
136 lines
4.3 KiB
PHP
<?php
|
|
// {{{ICINGA_LICENSE_HEADER}}}
|
|
// {{{ICINGA_LICENSE_HEADER}}}
|
|
|
|
namespace Icinga\Data;
|
|
|
|
use Icinga\Exception\ProgrammingError;
|
|
use Zend_Config;
|
|
use Icinga\Util\ConfigAwareFactory;
|
|
use Icinga\Exception\ConfigurationError;
|
|
use Icinga\Data\Db\DbConnection;
|
|
use Icinga\Protocol\Livestatus\Connection as LivestatusConnection;
|
|
use Icinga\Protocol\Statusdat\Reader as StatusdatReader;
|
|
use Icinga\Protocol\Ldap\Connection as LdapConnection;
|
|
use Icinga\Protocol\File\Reader as FileReader;
|
|
|
|
class ResourceFactory implements ConfigAwareFactory
|
|
{
|
|
/**
|
|
* @var Zend_Config
|
|
*/
|
|
private static $resources;
|
|
|
|
public static function setConfig($config)
|
|
{
|
|
self::$resources = $config;
|
|
}
|
|
|
|
/**
|
|
* Get the configuration for a specific resource
|
|
*
|
|
* @param $resourceName String The resource's name
|
|
*
|
|
* @return Zend_Config The configuration of the resource
|
|
* @throws \Icinga\Exception\ConfigurationError
|
|
*/
|
|
public static function getResourceConfig($resourceName)
|
|
{
|
|
self::assertResourcesExist();
|
|
if (($resourceConfig = self::$resources->get($resourceName)) === null) {
|
|
throw new ConfigurationError(
|
|
'Cannot load resource config "' . $resourceName . '". Resource does not exist'
|
|
);
|
|
}
|
|
return $resourceConfig;
|
|
}
|
|
|
|
/**
|
|
* Return the configuration of all existing resources, or get all resources of a given type.
|
|
*
|
|
* @param String|null $type Fetch only resources that have the given type.
|
|
*
|
|
* @return Zend_Config The configuration containing all resources
|
|
*/
|
|
public static function getResourceConfigs($type = null)
|
|
{
|
|
self::assertResourcesExist();
|
|
if (!isset($type)) {
|
|
return self::$resources;
|
|
} else {
|
|
$resources = array();
|
|
foreach (self::$resources as $name => $resource) {
|
|
if (strtolower($resource->type) === $type) {
|
|
$resources[$name] = $resource;
|
|
}
|
|
}
|
|
return new Zend_Config($resources);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Check if the existing resources are set. If not, throw an error.
|
|
*
|
|
* @throws \Icinga\Exception\ProgrammingError
|
|
*/
|
|
private static function assertResourcesExist()
|
|
{
|
|
if (!isset(self::$resources)) {
|
|
throw new ProgrammingError(
|
|
"The ResourceFactory must be initialised by setting a config, before it can be used"
|
|
);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create a single resource from the given configuration.
|
|
*
|
|
* NOTE: The factory does not test if the given configuration is valid and the resource is accessible, this
|
|
* depends entirely on the implementation of the returned resource.
|
|
*
|
|
* @param Zend_Config $config The configuration for the created resource.
|
|
*
|
|
* @return DbConnection|LdapConnection|LivestatusConnection|StatusdatReader An objects that can be used to access
|
|
* the given resource. The returned class depends on the configuration property 'type'.
|
|
* @throws \Icinga\Exception\ConfigurationError When an unsupported type is given
|
|
*/
|
|
public static function createResource(Zend_Config $config)
|
|
{
|
|
switch (strtolower($config->type)) {
|
|
case 'db':
|
|
$resource = new DbConnection($config);
|
|
break;
|
|
case 'ldap':
|
|
$resource = new LdapConnection($config);
|
|
break;
|
|
case 'statusdat':
|
|
$resource = new StatusdatReader($config);
|
|
break;
|
|
case 'livestatus':
|
|
$resource = new LivestatusConnection($config->socket);
|
|
break;
|
|
case 'file':
|
|
$resource = new FileReader($config);
|
|
break;
|
|
default:
|
|
throw new ConfigurationError('Unsupported resource type "' . $config->type . '"');
|
|
}
|
|
return $resource;
|
|
}
|
|
|
|
public static function ldapAvailable()
|
|
{
|
|
return extension_loaded('ldap');
|
|
}
|
|
|
|
public static function pgsqlAvailable()
|
|
{
|
|
return extension_loaded('pgsql');
|
|
}
|
|
|
|
public static function mysqlAvailable()
|
|
{
|
|
return extension_loaded('mysql');
|
|
}
|
|
}
|