CRM-13072 fix non return on civicrm_api3 wrapper - how did that sneak in?
[civicrm-core.git] / api / api.php
1 <?php
2
3 /**
4 * File for the CiviCRM APIv3 API wrapper
5 *
6 * @package CiviCRM_APIv3
7 * @subpackage API
8 *
9 * @copyright CiviCRM LLC (c) 2004-2013
10 * @version $Id: api.php 30486 2010-11-02 16:12:09Z shot $
11 */
12
13 /**
14 * @param string $entity
15 * type of entities to deal with
16 * @param string $action
17 * create, get, delete or some special action name.
18 * @param array $params
19 * array to be passed to function
20 */
21 function civicrm_api($entity, $action, $params, $extra = NULL) {
22 $apiWrappers = array(CRM_Core_HTMLInputCoder::singleton());
23 try {
24 require_once ('api/v3/utils.php');
25 require_once 'api/Exception.php';
26 if (!is_array($params)) {
27 throw new API_Exception('Input variable `params` is not an array', 2000);
28 }
29 _civicrm_api3_initialize();
30 $errorScope = CRM_Core_TemporaryErrorScope::useException();
31 $apiRequest = array();
32 $apiRequest['entity'] = CRM_Utils_String::munge($entity);
33 $apiRequest['action'] = CRM_Utils_String::munge($action);
34 $apiRequest['version'] = civicrm_get_api_version($params);
35 $apiRequest['params'] = $params;
36 $apiRequest['extra'] = $extra;
37 // look up function, file, is_generic
38 $apiRequest += _civicrm_api_resolve($apiRequest);
39 if (strtolower($action) == 'create' || strtolower($action) == 'delete') {
40 $apiRequest['is_transactional'] = 1;
41 $transaction = new CRM_Core_Transaction();
42 }
43
44 // support multi-lingual requests
45 if ($language = CRM_Utils_Array::value('option.language', $params)) {
46 _civicrm_api_set_locale($language);
47 }
48
49 _civicrm_api3_api_check_permission($apiRequest['entity'], $apiRequest['action'], $apiRequest['params']);
50
51 // we do this before we
52 _civicrm_api3_swap_out_aliases($apiRequest);
53 if (strtolower($action) != 'getfields') {
54 if (!CRM_Utils_Array::value('id', $apiRequest['params'])) {
55 $apiRequest['params'] = array_merge(_civicrm_api3_getdefaults($apiRequest), $apiRequest['params']);
56 }
57 //if 'id' is set then only 'version' will be checked but should still be checked for consistency
58 civicrm_api3_verify_mandatory($apiRequest['params'], NULL, _civicrm_api3_getrequired($apiRequest));
59 }
60
61 foreach ($apiWrappers as $apiWrapper) {
62 $apiRequest = $apiWrapper->fromApiInput($apiRequest);
63 }
64
65 $function = $apiRequest['function'];
66 if ($apiRequest['function'] && $apiRequest['is_generic']) {
67 // Unlike normal API implementations, generic implementations require explicit
68 // knowledge of the entity and action (as well as $params). Bundle up these bits
69 // into a convenient data structure.
70 $result = $function($apiRequest);
71 }
72 elseif ($apiRequest['function'] && !$apiRequest['is_generic']) {
73 _civicrm_api3_validate_fields($apiRequest['entity'], $apiRequest['action'], $apiRequest['params']);
74
75 $result = isset($extra) ? $function($apiRequest['params'], $extra) : $function($apiRequest['params']);
76 }
77 else {
78 return civicrm_api3_create_error("API (" . $apiRequest['entity'] . "," . $apiRequest['action'] . ") does not exist (join the API team and implement it!)");
79 }
80
81 foreach ($apiWrappers as $apiWrapper) {
82 $result = $apiWrapper->toApiOutput($apiRequest, $result);
83 }
84
85 if (CRM_Utils_Array::value('format.is_success', $apiRequest['params']) == 1) {
86 if ($result['is_error'] === 0) {
87 return 1;
88 }
89 else {
90 return 0;
91 }
92 }
93 if (CRM_Utils_Array::value('format.only_id', $apiRequest['params']) && isset($result['id'])) {
94 return $result['id'];
95 }
96 if (CRM_Utils_Array::value('is_error', $result, 0) == 0) {
97 _civicrm_api_call_nested_api($apiRequest['params'], $result, $apiRequest['action'], $apiRequest['entity'], $apiRequest['version']);
98 }
99 if (function_exists('xdebug_time_index')
100 && CRM_Utils_Array::value('debug', $apiRequest['params'])
101 // result would not be an array for getvalue
102 && is_array($result)
103 ) {
104 $result['xdebug']['peakMemory'] = xdebug_peak_memory_usage();
105 $result['xdebug']['memory'] = xdebug_memory_usage();
106 $result['xdebug']['timeIndex'] = xdebug_time_index();
107 }
108
109 return $result;
110 }
111 catch(PEAR_Exception $e) {
112 if (CRM_Utils_Array::value('format.is_success', $apiRequest['params']) == 1) {
113 return 0;
114 }
115 $error = $e->getCause();
116 if ($error instanceof DB_Error) {
117 $data["error_code"] = DB::errorMessage($error->getCode());
118 $data["sql"] = $error->getDebugInfo();
119 }
120 if (CRM_Utils_Array::value('debug', $apiRequest['params'])) {
121 $data['debug_info'] = $error->getUserInfo();
122 $data['trace'] = $e->getTraceAsString();
123 }
124 else{
125 $data['tip'] = "add debug=1 to your API call to have more info about the error";
126 }
127 $err = civicrm_api3_create_error($e->getMessage(), $data, $apiRequest);
128 if (CRM_Utils_Array::value('is_transactional', $apiRequest)) {
129 $transaction->rollback();
130 }
131 return $err;
132 }
133 catch (API_Exception $e){
134 if(!isset($apiRequest)){
135 $apiRequest = array();
136 }
137 if (CRM_Utils_Array::value('format.is_success', CRM_Utils_Array::value('params',$apiRequest)) == 1) {
138 return 0;
139 }
140 $data = $e->getExtraParams();
141 $data['entity'] = CRM_Utils_Array::value('entity', $apiRequest);
142 $data['action'] = CRM_Utils_Array::value('action', $apiRequest);
143 $err = civicrm_api3_create_error($e->getMessage(), $data, $apiRequest, $e->getCode());
144 if (CRM_Utils_Array::value('debug', CRM_Utils_Array::value('params',$apiRequest))
145 && empty($data['trace']) // prevent recursion
146 ) {
147 $err['trace'] = $e->getTraceAsString();
148 }
149 if (CRM_Utils_Array::value('is_transactional', $apiRequest)) {
150 $transaction->rollback();
151 }
152 return $err;
153 }
154 catch(Exception $e) {
155 if (CRM_Utils_Array::value('format.is_success', $apiRequest['params']) == 1) {
156 return 0;
157 }
158 $data = array();
159 $err = civicrm_api3_create_error($e->getMessage(), $data, $apiRequest, $e->getCode());
160 if (CRM_Utils_Array::value('debug', $apiRequest['params'])) {
161 $err['trace'] = $e->getTraceAsString();
162 }
163 if (CRM_Utils_Array::value('is_transactional', $apiRequest)) {
164 $transaction->rollback();
165 }
166 return $err;
167 }
168 }
169
170 /**
171 * Look up the implementation for a given API request
172 *
173 * @param $apiRequest array with keys:
174 * - entity: string, required
175 * - action: string, required
176 * - params: array
177 * - version: scalar, required
178 *
179 * @return array with keys
180 * - function: callback (mixed)
181 * - is_generic: boolean
182 */
183 function _civicrm_api_resolve($apiRequest) {
184 static $cache;
185 $cachekey = strtolower($apiRequest['entity']) . ':' . strtolower($apiRequest['action']) . ':' . $apiRequest['version'];
186 if (isset($cache[$cachekey])) {
187 return $cache[$cachekey];
188 }
189
190 $camelName = _civicrm_api_get_camel_name($apiRequest['entity'], $apiRequest['version']);
191 $actionCamelName = _civicrm_api_get_camel_name($apiRequest['action']);
192
193 // Determine if there is an entity-specific implementation of the action
194 $stdFunction = civicrm_api_get_function_name($apiRequest['entity'], $apiRequest['action'], $apiRequest['version']);
195 if (function_exists($stdFunction)) {
196 // someone already loaded the appropriate file
197 // FIXME: This has the affect of masking bugs in load order; this is included to provide bug-compatibility
198 $cache[$cachekey] = array('function' => $stdFunction, 'is_generic' => FALSE);
199 return $cache[$cachekey];
200 }
201
202 $stdFiles = array(
203 // By convention, the $camelName.php is more likely to contain the function, so test it first
204 'api/v' . $apiRequest['version'] . '/' . $camelName . '.php',
205 'api/v' . $apiRequest['version'] . '/' . $camelName . '/' . $actionCamelName . '.php',
206 );
207 foreach ($stdFiles as $stdFile) {
208 if (CRM_Utils_File::isIncludable($stdFile)) {
209 require_once $stdFile;
210 if (function_exists($stdFunction)) {
211 $cache[$cachekey] = array('function' => $stdFunction, 'is_generic' => FALSE);
212 return $cache[$cachekey];
213 }
214 }
215 }
216
217 // Determine if there is a generic implementation of the action
218 require_once 'api/v3/Generic.php';
219 # $genericFunction = 'civicrm_api3_generic_' . $apiRequest['action'];
220 $genericFunction = civicrm_api_get_function_name('generic', $apiRequest['action'], $apiRequest['version']);
221 $genericFiles = array(
222 // By convention, the Generic.php is more likely to contain the function, so test it first
223 'api/v' . $apiRequest['version'] . '/Generic.php',
224 'api/v' . $apiRequest['version'] . '/Generic/' . $actionCamelName . '.php',
225 );
226 foreach ($genericFiles as $genericFile) {
227 if (CRM_Utils_File::isIncludable($genericFile)) {
228 require_once $genericFile;
229 if (function_exists($genericFunction)) {
230 $cache[$cachekey] = array('function' => $genericFunction, 'is_generic' => TRUE);
231 return $cache[$cachekey];
232 }
233 }
234 }
235
236 $cache[$cachekey] = array('function' => FALSE, 'is_generic' => FALSE);
237 return $cache[$cachekey];
238 }
239 /**
240 * Version 3 wrapper for civicrm_api. Throws exception
241 * @param string $entity type of entities to deal with
242 * @param string $action create, get, delete or some special action name.
243 * @param array $params array to be passed to function
244 *
245 * @return array
246 *
247 */
248 function civicrm_api3($entity, $action, $params) {
249 $params['version'] = 3;
250 $result = civicrm_api($entity, $action, $params);
251 if($result['is_error']){
252 throw new CiviCRM_API3_Exception($result['error_message'], CRM_Utils_Array::value('error_code', $result, 'undefined'), $result);
253 }
254 return $result;
255 }
256
257 /**
258 * Load/require all files related to an entity.
259 *
260 * This should not normally be called because it's does a file-system scan; it's
261 * only appropriate when introspection is really required (eg for "getActions").
262 *
263 * @param string $entity
264 * @return void
265 */
266 function _civicrm_api_loadEntity($entity, $version = 3) {
267 /*
268 $apiRequest = array();
269 $apiRequest['entity'] = $entity;
270 $apiRequest['action'] = 'pretty sure it will never exist. Trick to [try to] force resolve to scan everywhere';
271 $apiRequest['version'] = $version;
272 // look up function, file, is_generic
273 $apiRequest = _civicrm_api_resolve($apiRequest);
274 */
275
276 $camelName = _civicrm_api_get_camel_name($entity, $version);
277
278 // Check for master entity file; to match _civicrm_api_resolve(), only load the first one
279 $stdFile = 'api/v' . $version . '/' . $camelName . '.php';
280 if (CRM_Utils_File::isIncludable($stdFile)) {
281 require_once $stdFile;
282 }
283
284 // Check for standalone action files; to match _civicrm_api_resolve(), only load the first one
285 $loaded_files = array(); // array($relativeFilePath => TRUE)
286 $include_dirs = array_unique(explode(PATH_SEPARATOR, get_include_path()));
287 foreach ($include_dirs as $include_dir) {
288 $action_dir = implode(DIRECTORY_SEPARATOR, array($include_dir, 'api', "v${version}", $camelName));
289 if (! is_dir($action_dir)) {
290 continue;
291 }
292
293 $iterator = new DirectoryIterator($action_dir);
294 foreach ($iterator as $fileinfo) {
295 $file = $fileinfo->getFilename();
296 if (array_key_exists($file, $loaded_files)) {
297 continue; // action provided by an earlier item on include_path
298 }
299
300 $parts = explode(".", $file);
301 if (end($parts) == "php" && !preg_match('/Tests?\.php$/', $file) ) {
302 require_once $action_dir . DIRECTORY_SEPARATOR . $file;
303 $loaded_files[$file] = TRUE;
304 }
305 }
306 }
307 }
308
309 /**
310 *
311 * @deprecated
312 */
313 function civicrm_api_get_function_name($entity, $action, $version = NULL) {
314
315 if (empty($version)) {
316 $version = civicrm_get_api_version();
317 }
318
319 $entity = _civicrm_api_get_entity_name_from_camel($entity);
320 return 'civicrm_api3' . '_' . $entity . '_' . $action;
321 }
322
323 /**
324 * We must be sure that every request uses only one version of the API.
325 *
326 * @param $desired_version : array or integer
327 * One chance to set the version number.
328 * After that, this version number will be used for the remaining request.
329 * This can either be a number, or an array(.., 'version' => $version, ..).
330 * This allows to directly pass the $params array.
331 */
332 function civicrm_get_api_version($desired_version = NULL) {
333
334 if (is_array($desired_version)) {
335 // someone gave the full $params array.
336 $params = $desired_version;
337 $desired_version = empty($params['version']) ? NULL : (int) $params['version'];
338 }
339 if (isset($desired_version) && is_integer($desired_version)) {
340 $_version = $desired_version;
341 }
342 else {
343 // we will set the default to version 3 as soon as we find that it works.
344 $_version = 3;
345 }
346 return $_version;
347 }
348
349 /**
350 * Check if the result is an error. Note that this function has been retained from
351 * api v2 for convenience but the result is more standardised in v3 and param
352 * 'format.is_success' => 1
353 * will result in a boolean success /fail being returned if that is what you need.
354 *
355 * @param array $params (reference ) input parameters
356 *
357 * @return boolean true if error, false otherwise
358 * @static void
359 * @access public
360 */
361 function civicrm_error($result) {
362 if (is_array($result)) {
363 return (array_key_exists('is_error', $result) &&
364 $result['is_error']
365 ) ? TRUE : FALSE;
366 }
367 return FALSE;
368 }
369
370 function _civicrm_api_get_camel_name($entity, $version = NULL) {
371 if (empty($version)) {
372 $version = civicrm_get_api_version();
373 }
374
375 $fragments = explode('_', $entity);
376 foreach ($fragments as & $fragment) {
377 $fragment = ucfirst($fragment);
378 }
379 // Special case: UFGroup, UFJoin, UFMatch, UFField
380 if ($fragments[0] === 'Uf') {
381 $fragments[0] = 'UF';
382 }
383 return implode('', $fragments);
384 }
385
386 /**
387 * Call any nested api calls
388 */
389 function _civicrm_api_call_nested_api(&$params, &$result, $action, $entity, $version) {
390 $entity = _civicrm_api_get_entity_name_from_camel($entity);
391 if(strtolower($action) == 'getsingle'){
392 // I don't understand the protocol here, but we don't want
393 // $result to be a recursive array
394 // $result['values'][0] = $result;
395 $oldResult = $result;
396 $result = array('values' => array(0 => $oldResult));
397 }
398 foreach ($params as $field => $newparams) {
399 if ((is_array($newparams) || $newparams === 1) && $field <> 'api.has_parent' && substr($field, 0, 3) == 'api') {
400
401 // 'api.participant.delete' => 1 is a valid options - handle 1 instead of an array
402 if ($newparams === 1) {
403 $newparams = array('version' => $version);
404 }
405 // can be api_ or api.
406 $separator = $field[3];
407 if (!($separator == '.' || $separator == '_')) {
408 continue;
409 }
410 $subAPI = explode($separator, $field);
411
412 $subaction = empty($subAPI[2]) ? $action : $subAPI[2];
413 $subParams = array(
414 'debug' => CRM_Utils_Array::value('debug', $params),
415 );
416 $subEntity = $subAPI[1];
417
418 foreach ($result['values'] as $idIndex => $parentAPIValues) {
419
420 if (strtolower($subEntity) != 'contact') {
421 //contact spits the dummy at activity_id so what else won't it like?
422 //set entity_id & entity table based on the parent's id & entity. e.g for something like
423 //note if the parent call is contact 'entity_table' will be set to 'contact' & 'id' to the contact id from
424 //the parent call.
425 //in this case 'contact_id' will also be set to the parent's id
426 $subParams["entity_id"] = $parentAPIValues['id'];
427 $subParams['entity_table'] = 'civicrm_' . _civicrm_api_get_entity_name_from_camel($entity);
428 $subParams[strtolower($entity) . "_id"] = $parentAPIValues['id'];
429 }
430 if (strtolower($entity) != 'contact' && CRM_Utils_Array::value(strtolower($subEntity . "_id"), $parentAPIValues)) {
431 //e.g. if event_id is in the values returned & subentity is event then pass in event_id as 'id'
432 //don't do this for contact as it does some wierd things like returning primary email &
433 //thus limiting the ability to chain email
434 //TODO - this might need the camel treatment
435 $subParams['id'] = $parentAPIValues[$subEntity . "_id"];
436 }
437
438 if (CRM_Utils_Array::value('entity_table', $result['values'][$idIndex]) == $subEntity) {
439 $subParams['id'] = $result['values'][$idIndex]['entity_id'];
440 }
441 // if we are dealing with the same entity pass 'id' through (useful for get + delete for example)
442 if (strtolower($entity) == strtolower($subEntity)) {
443 $subParams['id'] = $result['values'][$idIndex]['id'];
444 }
445
446
447 $subParams['version'] = $version;
448 if(!empty($params['check_permissions'])){
449 $subParams['check_permissions'] = $params['check_permissions'];
450 }
451 $subParams['sequential'] = 1;
452 $subParams['api.has_parent'] = 1;
453 if (array_key_exists(0, $newparams)) {
454 // it is a numerically indexed array - ie. multiple creates
455 foreach ($newparams as $entity => $entityparams) {
456 $subParams = array_merge($subParams, $entityparams);
457 _civicrm_api_replace_variables($subAPI[1], $subaction, $subParams, $result['values'][$idIndex], $separator);
458 $result['values'][$result['id']][$field][] = civicrm_api($subEntity, $subaction, $subParams);
459 if ($result['is_error'] === 1) {
460 throw new Exception($subEntity . ' ' . $subaction . 'call failed with' . $result['error_message']);
461 }
462 }
463 }
464 else {
465
466 $subParams = array_merge($subParams, $newparams);
467 _civicrm_api_replace_variables($subAPI[1], $subaction, $subParams, $result['values'][$idIndex], $separator);
468 $result['values'][$idIndex][$field] = civicrm_api($subEntity, $subaction, $subParams);
469 if (!empty($result['is_error'])) {
470 throw new Exception($subEntity . ' ' . $subaction . 'call failed with' . $result['error_message']);
471 }
472 }
473 }
474 }
475 }
476 if(strtolower($action) == 'getsingle'){
477 $result = $result['values'][0];
478 }
479 }
480
481 /**
482 * Swap out any $values vars - ie. the value after $value is swapped for the parent $result
483 * 'activity_type_id' => '$value.testfield',
484 'tag_id' => '$value.api.tag.create.id',
485 'tag1_id' => '$value.api.entity.create.0.id'
486 */
487 function _civicrm_api_replace_variables($entity, $action, &$params, &$parentResult, $separator = '.') {
488
489
490 foreach ($params as $field => $value) {
491
492 if (is_string($value) && substr($value, 0, 6) == '$value') {
493 $valuesubstitute = substr($value, 7);
494
495 if (!empty($parentResult[$valuesubstitute])) {
496 $params[$field] = $parentResult[$valuesubstitute];
497 }
498 else {
499
500 $stringParts = explode($separator, $value);
501 unset($stringParts[0]);
502
503 $fieldname = array_shift($stringParts);
504
505 //when our string is an array we will treat it as an array from that . onwards
506 $count = count($stringParts);
507 while ($count > 0) {
508 $fieldname .= "." . array_shift($stringParts);
509 if (array_key_exists($fieldname, $parentResult) && is_array($parentResult[$fieldname])) {
510 $arrayLocation = $parentResult[$fieldname];
511 foreach ($stringParts as $key => $value) {
512 $arrayLocation = CRM_Utils_Array::value($value, $arrayLocation);
513 }
514 $params[$field] = $arrayLocation;
515 }
516 $count = count($stringParts);
517 }
518 }
519 }
520 }
521 }
522
523 /**
524 * Convert possibly camel name to underscore separated entity name
525 *
526 * @param string $entity entity name in various formats e.g. Contribution, contribution, OptionValue, option_value, UFJoin, uf_join
527 * @return string $entity entity name in underscore separated format
528 *
529 * FIXME: Why isn't this called first thing in civicrm_api wrapper?
530 */
531 function _civicrm_api_get_entity_name_from_camel($entity) {
532 if ($entity == strtolower($entity)) {
533 return $entity;
534 }
535 else {
536 $entity = ltrim(strtolower(str_replace('U_F',
537 'uf',
538 // That's CamelCase, beside an odd UFCamel that is expected as uf_camel
539 preg_replace('/(?=[A-Z])/', '_$0', $entity)
540 )), '_');
541 }
542 return $entity;
543 }
544
545 /**
546 * Having a DAO object find the entity name
547 * @param object $bao DAO being passed in
548 */
549 function _civicrm_api_get_entity_name_from_dao($bao){
550 $daoName = str_replace("BAO", "DAO", get_class($bao));
551 return _civicrm_api_get_entity_name_from_camel(CRM_Core_DAO_AllCoreTables::getBriefName($daoName));
552 }
553
554 /**
555 * Sets the tsLocale and dbLocale for multi-lingual sites.
556 * Some code duplication from CRM/Core/BAO/ConfigSetting.php retrieve()
557 * to avoid regressions from refactoring.
558 */
559 function _civicrm_api_set_locale($lcMessagesRequest) {
560 // We must validate whether the locale is valid, otherwise setting a bad
561 // dbLocale could probably lead to sql-injection.
562 $domain = new CRM_Core_DAO_Domain();
563 $domain->id = CRM_Core_Config::domainID();
564 $domain->find(TRUE);
565
566 if ($domain->config_backend) {
567 $defaults = unserialize($domain->config_backend);
568
569 // are we in a multi-language setup?
570 $multiLang = $domain->locales ? TRUE : FALSE;
571 $lcMessages = NULL;
572
573 // on multi-lang sites based on request and civicrm_uf_match
574 if ($multiLang) {
575 $languageLimit = array();
576 if (array_key_exists('languageLimit', $defaults) && is_array($defaults['languageLimit'])) {
577 $languageLimit = $defaults['languageLimit'];
578 }
579
580 if (in_array($lcMessagesRequest, array_keys($languageLimit))) {
581 $lcMessages = $lcMessagesRequest;
582 }
583 else {
584 throw new API_Exception(ts('Language not enabled: %1', array(1 => $lcMessagesRequest)));
585 }
586 }
587
588 global $dbLocale;
589
590 // set suffix for table names - use views if more than one language
591 if ($lcMessages) {
592 $dbLocale = $multiLang && $lcMessages ? "_{$lcMessages}" : '';
593
594 // FIXME: an ugly hack to fix CRM-4041
595 global $tsLocale;
596 $tsLocale = $lcMessages;
597 }
598 }
599 }