crm.fsf.org/20131203/files/sites/all/modules-old/civicrm/Civi/Core/Container.php

   1 <?php
   2 namespace Civi\Core;
   3
   4 use Civi\Core\Lock\LockManager;
   5 use Doctrine\Common\Annotations\AnnotationReader;
   6 use Doctrine\Common\Annotations\AnnotationRegistry;
   7 use Doctrine\Common\Annotations\FileCacheReader;
   8 use Doctrine\Common\Cache\FilesystemCache;
   9 use Doctrine\ORM\EntityManager;
  10 use Doctrine\ORM\Mapping\Driver\AnnotationDriver;
  11 use Doctrine\ORM\Tools\Setup;
  12 use Symfony\Component\DependencyInjection\ContainerBuilder;
  13 use Symfony\Component\DependencyInjection\ContainerInterface;
  14 use Symfony\Component\DependencyInjection\Definition;
  15 use Symfony\Component\DependencyInjection\Reference;
  16
  17 // TODO use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
  18
  19 /**
  20  * Class Container
  21  * @package Civi\Core
  22  */
  23 class Container {
  24
  25   const SELF = 'civi_container_factory';
  26
  27   /**
  28    * @var ContainerBuilder
  29    */
  30   private static $singleton;
  31
  32   /**
  33    * @param bool $reset
  34    *   Whether to forcibly rebuild the entire container.
  35    * @return \Symfony\Component\DependencyInjection\TaggedContainerInterface
  36    */
  37   public static function singleton($reset = FALSE) {
  38     if ($reset || self::$singleton === NULL) {
  39       $c = new self();
  40       self::$singleton = $c->createContainer();
  41     }
  42     return self::$singleton;
  43   }
  44
  45   /**
  46    * @var ContainerBuilder
  47    * @return \Symfony\Component\DependencyInjection\ContainerBuilder
  48    */
  49   public function createContainer() {
  50     $civicrm_base_path = dirname(dirname(__DIR__));
  51     $container = new ContainerBuilder();
  52     $container->setParameter('civicrm_base_path', $civicrm_base_path);
  53     $container->set(self::SELF, $this);
  54
  55     // TODO Move configuration to an external file; define caching structure
  56     //    if (empty($configDirectories)) {
  57     //      throw new \Exception(__CLASS__ . ': Missing required properties (civicrmRoot, configDirectories)');
  58     //    }
  59     //    $locator = new FileLocator($configDirectories);
  60     //    $loaderResolver = new LoaderResolver(array(
  61     //      new YamlFileLoader($container, $locator)
  62     //    ));
  63     //    $delegatingLoader = new DelegatingLoader($loaderResolver);
  64     //    foreach (array('services.yml') as $file) {
  65     //      $yamlUserFiles = $locator->locate($file, NULL, FALSE);
  66     //      foreach ($yamlUserFiles as $file) {
  67     //        $delegatingLoader->load($file);
  68     //      }
  69     //    }
  70
  71     $container->setDefinition('lockManager', new Definition(
  72       '\Civi\Core\Lock\LockManager',
  73       array()
  74     ))
  75       ->setFactoryService(self::SELF)->setFactoryMethod('createLockManager');
  76
  77     $container->setDefinition('angular', new Definition(
  78       '\Civi\Angular\Manager',
  79       array()
  80     ))
  81       ->setFactoryService(self::SELF)->setFactoryMethod('createAngularManager');
  82
  83     $container->setDefinition('dispatcher', new Definition(
  84       '\Symfony\Component\EventDispatcher\EventDispatcher',
  85       array()
  86     ))
  87       ->setFactoryService(self::SELF)->setFactoryMethod('createEventDispatcher');
  88
  89     $container->setDefinition('magic_function_provider', new Definition(
  90       '\Civi\API\Provider\MagicFunctionProvider',
  91       array()
  92     ));
  93
  94     $container->setDefinition('civi_api_kernel', new Definition(
  95       '\Civi\API\Kernel',
  96       array(new Reference('dispatcher'), new Reference('magic_function_provider'))
  97     ))
  98       ->setFactoryService(self::SELF)->setFactoryMethod('createApiKernel');
  99
 100     $container->setDefinition('cxn_reg_client', new Definition(
 101       '\Civi\Cxn\Rpc\RegistrationClient',
 102       array()
 103     ))
 104       ->setFactoryClass('CRM_Cxn_BAO_Cxn')->setFactoryMethod('createRegistrationClient');
 105
 106     // Expose legacy singletons as services in the container.
 107     $singletons = array(
 108       'resources' => 'CRM_Core_Resources',
 109       'httpClient' => 'CRM_Utils_HttpClient',
 110       // Maybe? 'config' => 'CRM_Core_Config',
 111       // Maybe? 'smarty' => 'CRM_Core_Smarty',
 112     );
 113     foreach ($singletons as $name => $class) {
 114       $container->setDefinition($name, new Definition(
 115         $class
 116       ))
 117         ->setFactoryClass($class)->setFactoryMethod('singleton');
 118     }
 119
 120     return $container;
 121   }
 122
 123   /**
 124    * @return \Civi\Angular\Manager
 125    */
 126   public function createAngularManager() {
 127     return new \Civi\Angular\Manager(\CRM_Core_Resources::singleton());
 128   }
 129
 130   /**
 131    * @return \Symfony\Component\EventDispatcher\EventDispatcher
 132    */
 133   public function createEventDispatcher() {
 134     $dispatcher = new \Symfony\Component\EventDispatcher\EventDispatcher();
 135     $dispatcher->addListener('hook_civicrm_post::Activity', array('\Civi\CCase\Events', 'fireCaseChange'));
 136     $dispatcher->addListener('hook_civicrm_post::Case', array('\Civi\CCase\Events', 'fireCaseChange'));
 137     $dispatcher->addListener('hook_civicrm_caseChange', array('\Civi\CCase\Events', 'delegateToXmlListeners'));
 138     $dispatcher->addListener('hook_civicrm_caseChange', array('\Civi\CCase\SequenceListener', 'onCaseChange_static'));
 139     $dispatcher->addListener('DAO::post-insert', array('\CRM_Core_BAO_RecurringEntity', 'triggerInsert'));
 140     $dispatcher->addListener('DAO::post-update', array('\CRM_Core_BAO_RecurringEntity', 'triggerUpdate'));
 141     $dispatcher->addListener('DAO::post-delete', array('\CRM_Core_BAO_RecurringEntity', 'triggerDelete'));
 142     $dispatcher->addListener('hook_civicrm_unhandled_exception', array(
 143       'CRM_Core_LegacyErrorHandler',
 144       'handleException',
 145     ));
 146     return $dispatcher;
 147   }
 148
 149   /**
 150    * @return LockManager
 151    */
 152   public function createLockManager() {
 153     // Ideally, downstream implementers could override any definitions in
 154     // the container. For now, we'll make-do with some define()s.
 155     $lm = new LockManager();
 156     $lm
 157       ->register('/^cache\./', defined('CIVICRM_CACHE_LOCK') ? CIVICRM_CACHE_LOCK : array('CRM_Core_Lock', 'createScopedLock'))
 158       ->register('/^data\./', defined('CIVICRM_DATA_LOCK') ? CIVICRM_DATA_LOCK : array('CRM_Core_Lock', 'createScopedLock'))
 159       ->register('/^worker\.mailing\.send\./', defined('CIVICRM_WORK_LOCK') ? CIVICRM_WORK_LOCK : array('CRM_Core_Lock', 'createCivimailLock'))
 160       ->register('/^worker\./', defined('CIVICRM_WORK_LOCK') ? CIVICRM_WORK_LOCK : array('CRM_Core_Lock', 'createScopedLock'));
 161
 162     // Registrations may use complex resolver expressions, but (as a micro-optimization)
 163     // the default factory is specified as an array.
 164
 165     return $lm;
 166   }
 167
 168   /**
 169    * @param \Symfony\Component\EventDispatcher\EventDispatcher $dispatcher
 170    * @param $magicFunctionProvider
 171    *
 172    * @return \Civi\API\Kernel
 173    */
 174   public function createApiKernel($dispatcher, $magicFunctionProvider) {
 175     $dispatcher->addSubscriber(new \Civi\API\Subscriber\ChainSubscriber());
 176     $dispatcher->addSubscriber(new \Civi\API\Subscriber\TransactionSubscriber());
 177     $dispatcher->addSubscriber(new \Civi\API\Subscriber\I18nSubscriber());
 178     $dispatcher->addSubscriber($magicFunctionProvider);
 179     $dispatcher->addSubscriber(new \Civi\API\Subscriber\PermissionCheck());
 180     $dispatcher->addSubscriber(new \Civi\API\Subscriber\APIv3SchemaAdapter());
 181     $dispatcher->addSubscriber(new \Civi\API\Subscriber\WrapperAdapter(array(
 182       \CRM_Utils_API_HTMLInputCoder::singleton(),
 183       \CRM_Utils_API_NullOutputCoder::singleton(),
 184       \CRM_Utils_API_ReloadOption::singleton(),
 185       \CRM_Utils_API_MatchOption::singleton(),
 186     )));
 187     $dispatcher->addSubscriber(new \Civi\API\Subscriber\XDebugSubscriber());
 188     $kernel = new \Civi\API\Kernel($dispatcher);
 189
 190     $reflectionProvider = new \Civi\API\Provider\ReflectionProvider($kernel);
 191     $dispatcher->addSubscriber($reflectionProvider);
 192
 193     $dispatcher->addSubscriber(new \Civi\API\Subscriber\DynamicFKAuthorization(
 194       $kernel,
 195       'Attachment',
 196       array('create', 'get', 'delete'),
 197       // Given a file ID, determine the entity+table it's attached to.
 198       'SELECT if(cf.id,1,0) as is_valid, cef.entity_table, cef.entity_id
 199          FROM civicrm_file cf
 200          LEFT JOIN civicrm_entity_file cef ON cf.id = cef.file_id
 201          WHERE cf.id = %1',
 202       // Get a list of custom fields (field_name,table_name,extends)
 203       'SELECT concat("custom_",fld.id) as field_name,
 204         grp.table_name as table_name,
 205         grp.extends as extends
 206        FROM civicrm_custom_field fld
 207        INNER JOIN civicrm_custom_group grp ON fld.custom_group_id = grp.id
 208        WHERE fld.data_type = "File"
 209       ',
 210       array('civicrm_activity', 'civicrm_mailing', 'civicrm_contact', 'civicrm_grant')
 211     ));
 212
 213     $kernel->setApiProviders(array(
 214       $reflectionProvider,
 215       $magicFunctionProvider,
 216     ));
 217
 218     return $kernel;
 219   }
 220
 221 }