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
;
17 // TODO use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
25 const SELF
= 'civi_container_factory';
28 * @var ContainerBuilder
30 private static $singleton;
34 * Whether to forcibly rebuild the entire container.
35 * @return \Symfony\Component\DependencyInjection\TaggedContainerInterface
37 public static function singleton($reset = FALSE) {
38 if ($reset || self
::$singleton === NULL) {
40 self
::$singleton = $c->createContainer();
42 return self
::$singleton;
46 * @var ContainerBuilder
47 * @return \Symfony\Component\DependencyInjection\ContainerBuilder
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);
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)');
59 // $locator = new FileLocator($configDirectories);
60 // $loaderResolver = new LoaderResolver(array(
61 // new YamlFileLoader($container, $locator)
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);
71 $container->setDefinition('lockManager', new Definition(
72 '\Civi\Core\Lock\LockManager',
75 ->setFactoryService(self
::SELF
)->setFactoryMethod('createLockManager');
77 $container->setDefinition('angular', new Definition(
78 '\Civi\Angular\Manager',
81 ->setFactoryService(self
::SELF
)->setFactoryMethod('createAngularManager');
83 $container->setDefinition('dispatcher', new Definition(
84 '\Symfony\Component\EventDispatcher\EventDispatcher',
87 ->setFactoryService(self
::SELF
)->setFactoryMethod('createEventDispatcher');
89 $container->setDefinition('magic_function_provider', new Definition(
90 '\Civi\API\Provider\MagicFunctionProvider',
94 $container->setDefinition('civi_api_kernel', new Definition(
96 array(new Reference('dispatcher'), new Reference('magic_function_provider'))
98 ->setFactoryService(self
::SELF
)->setFactoryMethod('createApiKernel');
100 $container->setDefinition('cxn_reg_client', new Definition(
101 '\Civi\Cxn\Rpc\RegistrationClient',
104 ->setFactoryClass('CRM_Cxn_BAO_Cxn')->setFactoryMethod('createRegistrationClient');
106 // Expose legacy singletons as services in the container.
108 'resources' => 'CRM_Core_Resources',
109 'httpClient' => 'CRM_Utils_HttpClient',
110 // Maybe? 'config' => 'CRM_Core_Config',
111 // Maybe? 'smarty' => 'CRM_Core_Smarty',
113 foreach ($singletons as $name => $class) {
114 $container->setDefinition($name, new Definition(
117 ->setFactoryClass($class)->setFactoryMethod('singleton');
124 * @return \Civi\Angular\Manager
126 public function createAngularManager() {
127 return new \Civi\Angular\
Manager(\CRM_Core_Resources
::singleton());
131 * @return \Symfony\Component\EventDispatcher\EventDispatcher
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',
150 * @return LockManager
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();
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'));
162 // Registrations may use complex resolver expressions, but (as a micro-optimization)
163 // the default factory is specified as an array.
169 * @param \Symfony\Component\EventDispatcher\EventDispatcher $dispatcher
170 * @param $magicFunctionProvider
172 * @return \Civi\API\Kernel
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(),
187 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
XDebugSubscriber());
188 $kernel = new \Civi\API\
Kernel($dispatcher);
190 $reflectionProvider = new \Civi\API\Provider\
ReflectionProvider($kernel);
191 $dispatcher->addSubscriber($reflectionProvider);
193 $dispatcher->addSubscriber(new \Civi\API\Subscriber\
DynamicFKAuthorization(
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
200 LEFT JOIN civicrm_entity_file cef ON cf.id = cef.file_id
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"
210 array('civicrm_activity', 'civicrm_mailing', 'civicrm_contact', 'civicrm_grant')
213 $kernel->setApiProviders(array(
215 $magicFunctionProvider,