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\Config\ConfigCache
;
13 use Symfony\Component\DependencyInjection\ContainerBuilder
;
14 use Symfony\Component\DependencyInjection\ContainerInterface
;
15 use Symfony\Component\DependencyInjection\Definition
;
16 use Symfony\Component\DependencyInjection\Dumper\PhpDumper
;
17 use Symfony\Component\DependencyInjection\Reference
;
18 use Symfony\Component\EventDispatcher\ContainerAwareEventDispatcher
;
19 use Symfony\Component\EventDispatcher\DependencyInjection\RegisterListenersPass
;
21 // TODO use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
29 const SELF
= 'civi_container_factory';
32 * @var ContainerBuilder
34 private static $singleton;
38 * Whether to forcibly rebuild the entire container.
39 * @return \Symfony\Component\DependencyInjection\TaggedContainerInterface
41 public static function singleton($reset = FALSE) {
42 if ($reset || self
::$singleton === NULL) {
44 self
::$singleton = $c->loadContainer();
46 return self
::$singleton;
50 * Find a cached container definition or construct a new one.
52 * There are many weird contexts in which Civi initializes (eg different
53 * variations of multitenancy and different permutations of CMS/CRM bootstrap),
54 * and hook_container may fire a bit differently in each context. To mitigate
55 * risk of leaks between environments, we compute a unique envID
56 * (md5(DB_NAME, HTTP_HOST, SCRIPT_FILENAME, etc)) and use separate caches for
57 * each (eg "templates_c/CachedCiviContainer.$ENVID.php").
60 * - CIVICRM_CONTAINER_CACHE -- 'always' [default], 'never', 'auto'
63 * - CIVICRM_TEMPLATE_COMPILEDIR
65 * @return ContainerInterface
67 public function loadContainer() {
68 // Note: The container's raison d'etre is to manage construction of other
69 // services. Consequently, we assume a minimal service available -- the classloader
70 // has been setup, and civicrm.settings.php is loaded, but nothing else works.
72 $cacheMode = defined('CIVICRM_CONTAINER_CACHE') ? CIVICRM_CONTAINER_CACHE
: 'always';
74 // In pre-installation environments, don't bother with caching.
75 if (!defined('CIVICRM_TEMPLATE_COMPILEDIR') ||
!defined('CIVICRM_DSN') ||
$cacheMode === 'never' || \CRM_Utils_System
::isInUpgradeMode()) {
76 return $this->createContainer();
79 $envId = md5(implode(\CRM_Core_DAO
::VALUE_SEPARATOR
, array(
80 defined('CIVICRM_DOMAIN_ID') ? CIVICRM_DOMAIN_ID
: 1, // e.g. one database, multi URL
81 parse_url(CIVICRM_DSN
, PHP_URL_PATH
), // e.g. one codebase, multi database
82 \CRM_Utils_Array
::value('SCRIPT_FILENAME', $_SERVER, ''), // e.g. CMS vs extern vs installer
83 \CRM_Utils_Array
::value('HTTP_HOST', $_SERVER, ''), // e.g. name-based vhosts
84 \CRM_Utils_Array
::value('SERVER_PORT', $_SERVER, ''), // e.g. port-based vhosts
85 // Depending on deployment arch, these signals *could* be redundant, but who cares?
87 $file = CIVICRM_TEMPLATE_COMPILEDIR
. "/CachedCiviContainer.{$envId}.php";
88 $containerConfigCache = new ConfigCache($file, $cacheMode === 'auto');
90 if (!$containerConfigCache->isFresh()) {
91 $containerBuilder = $this->createContainer();
92 $containerBuilder->compile();
93 $dumper = new PhpDumper($containerBuilder);
94 $containerConfigCache->write(
95 $dumper->dump(array('class' => 'CachedCiviContainer')),
96 $containerBuilder->getResources()
101 $c = new \
CachedCiviContainer();
102 $c->set('service_container', $c);
107 * Construct a new container.
109 * @var ContainerBuilder
110 * @return \Symfony\Component\DependencyInjection\ContainerBuilder
112 public function createContainer() {
113 $civicrm_base_path = dirname(dirname(__DIR__
));
114 $container = new ContainerBuilder();
115 $container->addCompilerPass(new RegisterListenersPass('dispatcher'));
116 $container->addObjectResource($this);
117 $container->setParameter('civicrm_base_path', $civicrm_base_path);
118 //$container->set(self::SELF, $this);
119 $container->setDefinition(self
::SELF
, new Definition(
120 'Civi\Core\Container',
124 // TODO Move configuration to an external file; define caching structure
125 // if (empty($configDirectories)) {
126 // throw new \Exception(__CLASS__ . ': Missing required properties (civicrmRoot, configDirectories)');
128 // $locator = new FileLocator($configDirectories);
129 // $loaderResolver = new LoaderResolver(array(
130 // new YamlFileLoader($container, $locator)
132 // $delegatingLoader = new DelegatingLoader($loaderResolver);
133 // foreach (array('services.yml') as $file) {
134 // $yamlUserFiles = $locator->locate($file, NULL, FALSE);
135 // foreach ($yamlUserFiles as $file) {
136 // $delegatingLoader->load($file);
140 $container->setDefinition('lockManager', new Definition(
141 'Civi\Core\Lock\LockManager',
144 ->setFactoryService(self
::SELF
)->setFactoryMethod('createLockManager');
146 $container->setDefinition('angular', new Definition(
147 'Civi\Angular\Manager',
150 ->setFactoryService(self
::SELF
)->setFactoryMethod('createAngularManager');
152 $container->setDefinition('dispatcher', new Definition(
153 'Symfony\Component\EventDispatcher\ContainerAwareEventDispatcher',
154 array(new Reference('service_container'))
156 ->setFactoryService(self
::SELF
)->setFactoryMethod('createEventDispatcher');
158 $container->setDefinition('magic_function_provider', new Definition(
159 'Civi\API\Provider\MagicFunctionProvider',
163 $container->setDefinition('civi_api_kernel', new Definition(
165 array(new Reference('dispatcher'), new Reference('magic_function_provider'))
167 ->setFactoryService(self
::SELF
)->setFactoryMethod('createApiKernel');
169 $container->setDefinition('cxn_reg_client', new Definition(
170 'Civi\Cxn\Rpc\RegistrationClient',
173 ->setFactoryClass('CRM_Cxn_BAO_Cxn')->setFactoryMethod('createRegistrationClient');
175 $container->setDefinition('psr_log', new Definition('CRM_Core_Error_Log', array()));
177 foreach (array('settings', 'js_strings', 'community_messages') as $cacheName) {
178 $container->setDefinition("cache.{$cacheName}", new Definition(
179 'CRM_Utils_Cache_Interface',
182 'name' => $cacheName,
183 'type' => array('*memory*', 'SqlGroup', 'ArrayCache'),
186 ))->setFactoryClass('CRM_Utils_Cache')->setFactoryMethod('create');
189 $container->setDefinition('settings_manager', new Definition(
190 'Civi\Core\SettingsManager',
191 array(new Reference('cache.settings'))
194 $container->setDefinition('pear_mail', new Definition('Mail'))
195 ->setFactoryClass('CRM_Utils_Mail')->setFactoryMethod('createMailer');
197 // Expose legacy singletons as services in the container.
199 'resources' => 'CRM_Core_Resources',
200 'httpClient' => 'CRM_Utils_HttpClient',
201 'cache.default' => 'CRM_Utils_Cache',
202 // Maybe? 'config' => 'CRM_Core_Config',
203 // Maybe? 'smarty' => 'CRM_Core_Smarty',
205 foreach ($singletons as $name => $class) {
206 $container->setDefinition($name, new Definition(
209 ->setFactoryClass($class)->setFactoryMethod('singleton');
212 \CRM_Utils_Hook
::container($container);
218 * @return \Civi\Angular\Manager
220 public function createAngularManager() {
221 return new \Civi\Angular\
Manager(\CRM_Core_Resources
::singleton());
225 * @param ContainerInterface $container
226 * @return \Symfony\Component\EventDispatcher\EventDispatcher
228 public function createEventDispatcher($container) {
229 $dispatcher = new ContainerAwareEventDispatcher($container);
230 $dispatcher->addListener('hook_civicrm_post::Activity', array('\Civi\CCase\Events', 'fireCaseChange'));
231 $dispatcher->addListener('hook_civicrm_post::Case', array('\Civi\CCase\Events', 'fireCaseChange'));
232 $dispatcher->addListener('hook_civicrm_caseChange', array('\Civi\CCase\Events', 'delegateToXmlListeners'));
233 $dispatcher->addListener('hook_civicrm_caseChange', array('\Civi\CCase\SequenceListener', 'onCaseChange_static'));
234 $dispatcher->addListener('DAO::post-insert', array('\CRM_Core_BAO_RecurringEntity', 'triggerInsert'));
235 $dispatcher->addListener('DAO::post-update', array('\CRM_Core_BAO_RecurringEntity', 'triggerUpdate'));
236 $dispatcher->addListener('DAO::post-delete', array('\CRM_Core_BAO_RecurringEntity', 'triggerDelete'));
237 $dispatcher->addListener('hook_civicrm_unhandled_exception', array(
238 'CRM_Core_LegacyErrorHandler',
245 * @return LockManager
247 public function createLockManager() {
248 // Ideally, downstream implementers could override any definitions in
249 // the container. For now, we'll make-do with some define()s.
250 $lm = new LockManager();
252 ->register('/^cache\./', defined('CIVICRM_CACHE_LOCK') ? CIVICRM_CACHE_LOCK
: array('CRM_Core_Lock', 'createScopedLock'))
253 ->register('/^data\./', defined('CIVICRM_DATA_LOCK') ? CIVICRM_DATA_LOCK
: array('CRM_Core_Lock', 'createScopedLock'))
254 ->register('/^worker\.mailing\.send\./', defined('CIVICRM_WORK_LOCK') ? CIVICRM_WORK_LOCK
: array('CRM_Core_Lock', 'createCivimailLock'))
255 ->register('/^worker\./', defined('CIVICRM_WORK_LOCK') ? CIVICRM_WORK_LOCK
: array('CRM_Core_Lock', 'createScopedLock'));
257 // Registrations may use complex resolver expressions, but (as a micro-optimization)
258 // the default factory is specified as an array.
264 * @param \Symfony\Component\EventDispatcher\EventDispatcher $dispatcher
265 * @param $magicFunctionProvider
267 * @return \Civi\API\Kernel
269 public function createApiKernel($dispatcher, $magicFunctionProvider) {
270 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
ChainSubscriber());
271 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
TransactionSubscriber());
272 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
I18nSubscriber());
273 $dispatcher->addSubscriber($magicFunctionProvider);
274 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
PermissionCheck());
275 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
APIv3SchemaAdapter());
276 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
WrapperAdapter(array(
277 \CRM_Utils_API_HTMLInputCoder
::singleton(),
278 \CRM_Utils_API_NullOutputCoder
::singleton(),
279 \CRM_Utils_API_ReloadOption
::singleton(),
280 \CRM_Utils_API_MatchOption
::singleton(),
282 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
XDebugSubscriber());
283 $kernel = new \Civi\API\
Kernel($dispatcher);
285 $reflectionProvider = new \Civi\API\Provider\
ReflectionProvider($kernel);
286 $dispatcher->addSubscriber($reflectionProvider);
288 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
DynamicFKAuthorization(
291 array('create', 'get', 'delete'),
292 // Given a file ID, determine the entity+table it's attached to.
293 'SELECT if(cf.id,1,0) as is_valid, cef.entity_table, cef.entity_id
295 LEFT JOIN civicrm_entity_file cef ON cf.id = cef.file_id
297 // Get a list of custom fields (field_name,table_name,extends)
298 'SELECT concat("custom_",fld.id) as field_name,
299 grp.table_name as table_name,
300 grp.extends as extends
301 FROM civicrm_custom_field fld
302 INNER JOIN civicrm_custom_group grp ON fld.custom_group_id = grp.id
303 WHERE fld.data_type = "File"
305 array('civicrm_activity', 'civicrm_mailing', 'civicrm_contact', 'civicrm_grant')
308 $kernel->setApiProviders(array(
310 $magicFunctionProvider,