X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=Civi%2FTest%2FApi3TestTrait.php;h=1c99c0490b42d3e61f84014020a4704a7d43216e;hb=ff93f0ab952152f0eb2edc6c32b5ee156724005e;hp=5386e93969dcfe902f011afc02881274435215a8;hpb=085d8bc50399130290953d45b146ce0f48a6cf1a;p=civicrm-core.git diff --git a/Civi/Test/Api3TestTrait.php b/Civi/Test/Api3TestTrait.php index 5386e93969..1c99c0490b 100644 --- a/Civi/Test/Api3TestTrait.php +++ b/Civi/Test/Api3TestTrait.php @@ -2,6 +2,8 @@ namespace Civi\Test; +use Civi\API\Exception\NotImplementedException; + /** * Class Api3TestTrait * @package Civi\Test @@ -14,6 +16,15 @@ namespace Civi\Test; */ trait Api3TestTrait { + /** + * Get the api versions to test. + * + * @return array + */ + public function versionThreeAndFour() { + return [[3], [4]]; + } + /** * Api version - easier to override than just a define * @var int @@ -66,7 +77,7 @@ trait Api3TestTrait { $prefix .= ': '; } if ($expectedError && !empty($apiResult['is_error'])) { - $this->assertEquals($expectedError, $apiResult['error_message'], 'api error message not as expected' . $prefix); + $this->assertContains($expectedError, $apiResult['error_message'], 'api error message not as expected' . $prefix); } $this->assertEquals(1, $apiResult['is_error'], "api call should have failed but it succeeded " . $prefix . (print_r($apiResult, TRUE))); $this->assertNotEmpty($apiResult['error_message']); @@ -92,7 +103,7 @@ trait Api3TestTrait { if (!empty($apiResult['trace'])) { $errorMessage .= "\n" . print_r($apiResult['trace'], TRUE); } - $this->assertEquals(0, $apiResult['is_error'], $prefix . $errorMessage); + $this->assertEmpty(\CRM_Utils_Array::value('is_error', $apiResult), $prefix . $errorMessage); } /** @@ -132,7 +143,7 @@ trait Api3TestTrait { * * @return array|int */ - public function callAPISuccess($entity, $action, $params, $checkAgainst = NULL) { + public function callAPISuccess($entity, $action, $params = [], $checkAgainst = NULL) { $params = array_merge([ 'version' => $this->_apiversion, 'debug' => 1, @@ -158,10 +169,13 @@ trait Api3TestTrait { * This function exists to wrap api getValue function & check the result * so we can ensure they succeed & throw exceptions without litterering the test with checks * There is a type check in this + * * @param string $entity * @param array $params - * @param null $count - * @throws \Exception + * @param int $count + * + * @throws \CRM_Core_Exception + * * @return array|int */ public function callAPISuccessGetCount($entity, $params, $count = NULL) { @@ -171,7 +185,7 @@ trait Api3TestTrait { ]; $result = $this->civicrm_api($entity, 'getcount', $params); if (!is_int($result) || !empty($result['is_error']) || isset($result['values'])) { - throw new \Exception('Invalid getcount result : ' . print_r($result, TRUE) . " type :" . gettype($result)); + throw new \CRM_Core_Exception('Invalid getcount result : ' . print_r($result, TRUE) . " type :" . gettype($result)); } if (is_int($count)) { $this->assertEquals($count, $result, "incorrect count returned from $entity getcount"); @@ -194,7 +208,8 @@ trait Api3TestTrait { * - array * - object * - * @throws \Exception + * @throws \CRM_Core_Exception + * * @return array|int */ public function callAPISuccessGetSingle($entity, $params, $checkAgainst = NULL) { @@ -203,8 +218,8 @@ trait Api3TestTrait { ]; $result = $this->civicrm_api($entity, 'getsingle', $params); if (!is_array($result) || !empty($result['is_error']) || isset($result['values'])) { - $unfilteredResult = $this->civicrm_api($entity, 'get', $params); - throw new \Exception( + $unfilteredResult = $this->civicrm_api($entity, 'get', ['version' => $this->_apiversion]); + throw new \CRM_Core_Exception( 'Invalid getsingle result' . print_r($result, TRUE) . "\n entity: $entity . \n params \n " . print_r($params, TRUE) . "\n entities retrieved with blank params \n" . print_r($unfilteredResult, TRUE) @@ -234,6 +249,7 @@ trait Api3TestTrait { * - object * * @return array|int + * @throws \CRM_Core_Exception */ public function callAPISuccessGetValue($entity, $params, $type = NULL) { $params += [ @@ -242,10 +258,10 @@ trait Api3TestTrait { ]; $result = $this->civicrm_api($entity, 'getvalue', $params); if (is_array($result) && (!empty($result['is_error']) || isset($result['values']))) { - throw new \Exception('Invalid getvalue result' . print_r($result, TRUE)); + throw new \CRM_Core_Exception('Invalid getvalue result' . print_r($result, TRUE)); } if ($type) { - if ($type == 'integer') { + if ($type === 'integer') { // api seems to return integers as strings $this->assertTrue(is_numeric($result), "expected a numeric value but got " . print_r($result, 1)); } @@ -264,8 +280,392 @@ trait Api3TestTrait { * @param array $params * @return array|int */ - public function civicrm_api($entity, $action, $params) { + public function civicrm_api($entity, $action, $params = []) { + if (\CRM_Utils_Array::value('version', $params) == 4) { + return $this->runApi4Legacy($entity, $action, $params); + } return civicrm_api($entity, $action, $params); } + /** + * Emulate v3 syntax so we can run api3 tests on v4 + * + * @param $v3Entity + * @param $v3Action + * @param array $v3Params + * @return array|int + * @throws \API_Exception + * @throws \CiviCRM_API3_Exception + * @throws \Exception + */ + public function runApi4Legacy($v3Entity, $v3Action, $v3Params = []) { + $v4Entity = self::convertEntityNameToApi4($v3Entity); + $v4Action = $v3Action = strtolower($v3Action); + $v4Params = ['checkPermissions' => isset($v3Params['check_permissions']) ? (bool) $v3Params['check_permissions'] : FALSE]; + $sequential = !empty($v3Params['sequential']); + $options = \_civicrm_api3_get_options_from_params($v3Params, in_array($v4Entity, ['Contact', 'Participant', 'Event', 'Group', 'Contribution', 'Membership'])); + $indexBy = in_array($v3Action, ['get', 'create', 'replace']) && !$sequential ? 'id' : NULL; + $onlyId = !empty($v3Params['format.only_id']); + $onlySuccess = !empty($v3Params['format.is_success']); + if (!empty($v3Params['filters']['is_current']) || !empty($v3Params['isCurrent'])) { + $v4Params['current'] = TRUE; + } + $language = !empty($v3Params['options']['language']) ? $v3Params['options']['language'] : \CRM_Utils_Array::value('option.language', $v3Params); + if ($language) { + $v4Params['language'] = $language; + } + $toRemove = ['option.', 'return', 'api.', 'format.']; + $chains = []; + $custom = []; + foreach ($v3Params as $key => $val) { + foreach ($toRemove as $remove) { + if (strpos($key, $remove) === 0) { + if ($remove == 'api.') { + $chains[$key] = $val; + } + unset($v3Params[$key]); + } + } + } + + $v3Fields = civicrm_api3($v3Entity, 'getfields', ['action' => $v3Action])['values']; + + // Fix 'null' + foreach ($v3Params as $key => $val) { + if ($val === 'null') { + $v3Params[$key] = NULL; + } + } + + if ($v4Entity == 'Setting') { + $indexBy = NULL; + $v4Params['domainId'] = \CRM_Utils_Array::value('domain_id', $v3Params); + if ($v3Action == 'getfields') { + if (!empty($v3Params['name'])) { + $v3Params['filters']['name'] = $v3Params['name']; + } + foreach (\CRM_Utils_Array::value('filters', $v3Params, []) as $filter => $val) { + $v4Params['where'][] = [$filter, '=', $val]; + } + } + if ($v3Action == 'create') { + $v4Action = 'set'; + } + if ($v3Action == 'revert') { + $v4Params['select'] = (array) $v3Params['name']; + } + if ($v3Action == 'getvalue') { + $options['return'] = [$v3Params['name'] => 1]; + $v3Params = []; + } + \CRM_Utils_Array::remove($v3Params, 'domain_id', 'name'); + } + + \CRM_Utils_Array::remove($v3Params, 'options', 'debug', 'version', 'sort', 'offset', 'rowCount', 'check_permissions', 'sequential', 'filters', 'isCurrent'); + + // Work around ugly hack in v3 Domain api + if ($v4Entity == 'Domain') { + $v3Fields['version'] = ['name' => 'version', 'api.aliases' => ['domain_version']]; + unset($v3Fields['domain_version']); + } + + foreach ($v3Fields as $name => $field) { + // Resolve v3 aliases + foreach (\CRM_Utils_Array::value('api.aliases', $field, []) as $alias) { + if (isset($v3Params[$alias])) { + $v3Params[$field['name']] = $v3Params[$alias]; + unset($v3Params[$alias]); + } + } + // Convert custom field names + if (strpos($name, 'custom_') === 0 && is_numeric($name[7])) { + // Strictly speaking, using titles instead of names is incorrect, but it works for + // unit tests where names and titles are identical and saves an extra db lookup. + $custom[$field['groupTitle']][$field['title']] = $name; + $v4FieldName = $field['groupTitle'] . '.' . $field['title']; + if (isset($v3Params[$name])) { + $v3Params[$v4FieldName] = $v3Params[$name]; + unset($v3Params[$name]); + } + if (isset($options['return'][$name])) { + $options['return'][$v4FieldName] = 1; + unset($options['return'][$name]); + } + } + } + + switch ($v3Action) { + case 'getcount': + $v4Params['select'] = ['row_count']; + // No break - keep processing as get + case 'getsingle': + case 'getvalue': + $v4Action = 'get'; + // No break - keep processing as get + case 'get': + if ($options['return'] && $v3Action !== 'getcount') { + $v4Params['select'] = array_keys($options['return']); + } + if ($options['limit'] && $v4Entity != 'Setting') { + $v4Params['limit'] = $options['limit']; + } + if ($options['offset']) { + $v4Params['offset'] = $options['offset']; + } + if ($options['sort']) { + foreach (explode(',', $options['sort']) as $sort) { + list($sortField, $sortDir) = array_pad(explode(' ', trim($sort)), 2, 'ASC'); + $v4Params['orderBy'][$sortField] = $sortDir; + } + } + break; + + case 'replace': + if (empty($v3Params['values'])) { + $v4Action = 'delete'; + } + else { + $v4Params['records'] = $v3Params['values']; + } + unset($v3Params['values']); + break; + + case 'create': + case 'update': + if (!empty($v3Params['id'])) { + $v4Action = 'update'; + $v4Params['where'][] = ['id', '=', $v3Params['id']]; + } + + $v4Params['values'] = $v3Params; + unset($v4Params['values']['id']); + break; + + case 'delete': + if (!empty($v3Params['id'])) { + $v4Params['where'][] = ['id', '=', $v3Params['id']]; + } + break; + + case 'getoptions': + $indexBy = 0; + $v4Action = 'getFields'; + $v4Params += [ + 'where' => [['name', '=', $v3Params['field']]], + 'loadOptions' => TRUE, + ]; + break; + + case 'getfields': + $v4Action = 'getFields'; + if (!empty($v3Params['action']) || !empty($v3Params['api_action'])) { + $v4Params['action'] = !empty($v3Params['action']) ? $v3Params['action'] : $v3Params['api_action']; + } + $indexBy = !$sequential ? 'name' : NULL; + break; + } + + // Ensure this api4 entity/action exists + try { + $actionInfo = \civicrm_api4($v4Entity, 'getActions', ['checkPermissions' => FALSE, 'where' => [['name', '=', $v4Action]]]); + } + catch (NotImplementedException $e) { + // For now we'll mark the test incomplete if a v4 entity doesn't exit yet + $this->markTestIncomplete($e->getMessage()); + } + if (!isset($actionInfo[0])) { + throw new \Exception("Api4 $v4Entity $v4Action does not exist."); + } + + // Migrate special params like fix_address + foreach ($actionInfo[0]['params'] as $v4ParamName => $paramInfo) { + // camelCase in api4, lower_case in api3 + $v3ParamName = strtolower(preg_replace('/(?=[A-Z])/', '_$0', $v4ParamName)); + if (isset($v3Params[$v3ParamName])) { + $v4Params[$v4ParamName] = $v3Params[$v3ParamName]; + unset($v3Params[$v3ParamName]); + if ($paramInfo['type'][0] == 'bool') { + $v4Params[$v4ParamName] = (bool) $v4Params[$v4ParamName]; + } + } + } + + // Build where clause for 'getcount', 'getsingle', 'getvalue', 'get' & 'replace' + if ($v4Action == 'get' || $v3Action == 'replace') { + foreach ($v3Params as $key => $val) { + $op = '='; + if (is_array($val) && count($val) == 1 && array_intersect_key($val, array_flip(\CRM_Core_DAO::acceptedSQLOperators()))) { + foreach ($val as $op => $newVal) { + $val = $newVal; + } + } + $v4Params['where'][] = [$key, $op, $val]; + } + } + + try { + $result = \civicrm_api4($v4Entity, $v4Action, $v4Params, $indexBy); + } + catch (\Exception $e) { + return $onlySuccess ? 0 : [ + 'is_error' => 1, + 'error_message' => $e->getMessage(), + 'version' => 4, + ]; + } + + if (($v3Action == 'getsingle' || $v3Action == 'getvalue') && count($result) != 1) { + return $onlySuccess ? 0 : [ + 'is_error' => 1, + 'error_message' => "Expected one $v4Entity but found " . count($result), + 'count' => count($result), + ]; + } + + if ($onlySuccess) { + return 1; + } + + if ($v3Action == 'getcount') { + return $result->count(); + } + + if ($onlyId) { + return $result->first()['id']; + } + + if ($v3Action == 'getvalue' && $v4Entity == 'Setting') { + return \CRM_Utils_Array::value('value', $result->first()); + } + + if ($v3Action == 'getvalue') { + return \CRM_Utils_Array::value(array_keys($options['return'])[0], $result->first()); + } + + // Mimic api3 behavior when using 'replace' action to delete all + if ($v3Action == 'replace' && $v4Action == 'delete') { + $result->exchangeArray([]); + } + + if ($v3Action == 'getoptions') { + return [ + 'is_error' => 0, + 'count' => $result['options'] ? count($result['options']) : 0, + 'values' => $result['options'] ?: [], + 'version' => 4, + ]; + } + + // Emulate the weird return format of api3 settings + if (($v3Action == 'get' || $v3Action == 'create') && $v4Entity == 'Setting') { + $settings = []; + foreach ($result as $item) { + $settings[$item['domain_id']][$item['name']] = $item['value']; + } + $result->exchangeArray($sequential ? array_values($settings) : $settings); + } + + foreach ($result as $index => $row) { + // Run chains + foreach ($chains as $key => $params) { + $result[$index][$key] = $this->runApi4LegacyChain($key, $params, $v4Entity, $row, $sequential); + } + // Resolve custom field names + foreach ($custom as $group => $fields) { + if (isset($row[$group])) { + foreach ($fields as $field => $v3FieldName) { + if (isset($row[$group][$field])) { + $result[$index][$v3FieldName] = $row[$group][$field]; + } + } + unset($result[$index][$group]); + } + } + } + + if ($v3Action == 'getsingle') { + return $result->first(); + } + + return [ + 'is_error' => 0, + 'version' => 4, + 'count' => count($result), + 'values' => (array) $result, + 'id' => is_object($result) && count($result) == 1 ? \CRM_Utils_Array::value('id', $result->first()) : NULL, + ]; + } + + /** + * @param string $key + * @param mixed $params + * @param string $mainEntity + * @param array $result + * @param bool $sequential + * @return array + * @throws \API_Exception + */ + protected function runApi4LegacyChain($key, $params, $mainEntity, $result, $sequential) { + // Handle an array of multiple calls using recursion + if (is_array($params) && isset($params[0]) && is_array($params[0])) { + $results = []; + foreach ($params as $chain) { + $results[] = $this->runApi4LegacyChain($key, $chain, $mainEntity, $result, $sequential); + } + return $results; + } + + // Handle single api call + list(, $chainEntity, $chainAction) = explode('.', $key); + $lcChainEntity = \_civicrm_api_get_entity_name_from_camel($chainEntity); + $chainEntity = self::convertEntityNameToApi4($chainEntity); + $lcMainEntity = \_civicrm_api_get_entity_name_from_camel($mainEntity); + $params = is_array($params) ? $params : []; + + // Api3 expects this to be inherited + $params += ['sequential' => $sequential]; + + // Replace $value.field_name + foreach ($params as $name => $param) { + if (is_string($param) && strpos($param, '$value.') === 0) { + $param = substr($param, 7); + $params[$name] = \CRM_Utils_Array::value($param, $result); + } + } + + try { + $getFields = civicrm_api4($chainEntity, 'getFields', ['select' => ['name']], 'name'); + } + catch (NotImplementedException $e) { + $this->markTestIncomplete($e->getMessage()); + } + + // Emulate the string-fu guesswork that api3 does + if ($chainEntity == $mainEntity && empty($params['id']) && !empty($result['id'])) { + $params['id'] = $result['id']; + } + elseif (empty($params['id']) && !empty($result[$lcChainEntity . '_id'])) { + $params['id'] = $result[$lcChainEntity . '_id']; + } + elseif (!empty($result['id']) && isset($getFields[$lcMainEntity . '_id']) && empty($params[$lcMainEntity . '_id'])) { + $params[$lcMainEntity . '_id'] = $result['id']; + } + return $this->runApi4Legacy($chainEntity, $chainAction, $params); + } + + /** + * Fix the naming differences between api3 & api4 entities. + * + * @param string $legacyName + * @return string + */ + public static function convertEntityNameToApi4($legacyName) { + $api4Name = \CRM_Utils_String::convertStringToCamel($legacyName); + $map = [ + 'Im' => 'IM', + 'Acl' => 'ACL', + ]; + return \CRM_Utils_Array::value($api4Name, $map, $api4Name); + } + }