<?php
class DefaultAcsClient implements IAcsClient
{
public $iClientProfile;
public $__urlTestFlag__;
private $locationService;
private $ramRoleArnService;
private $ecsRamRoleService;
public function __construct($iClientProfile)
{
$this->iClientProfile = $iClientProfile;
$this->__urlTestFlag__ = false;
$this->locationService = new LocationService($this->iClientProfile);
if ($this->iClientProfile->isRamRoleArn()) {
$this->ramRoleArnService = new RamRoleArnService($this->iClientProfile);
}
if ($this->iClientProfile->isEcsRamRole()) {
$this->ecsRamRoleService = new EcsRamRoleService($this->iClientProfile);
}
}
public function getAcsResponse($request, $iSigner = null, $credential = null, $autoRetry = true, $maxRetryNumber = 3)
{
$httpResponse = $this->doActionImpl($request, $iSigner, $credential, $autoRetry, $maxRetryNumber);
$respObject = $this->parseAcsResponse($httpResponse->getBody(), $request->getAcceptFormat());
if (false == $httpResponse->isSuccess()) {
$this->buildApiException($respObject, $httpResponse->getStatus());
}
return $respObject;
}
private function doActionImpl($request, $iSigner = null, $credential = null, $autoRetry = true, $maxRetryNumber = 3)
{
if (null == $this->iClientProfile && (null == $iSigner || null == $credential
|| null == $request->getRegionId() || null == $request->getAcceptFormat())) {
throw new ClientException("No active profile found.", "SDK.InvalidProfile");
}
if (null == $iSigner) {
$iSigner = $this->iClientProfile->getSigner();
}
if (null == $credential) {
$credential = $this->iClientProfile->getCredential();
}
if ($this->iClientProfile->isRamRoleArn()) {
$credential = $this->ramRoleArnService->getSessionCredential();
}
if ($this->iClientProfile->isEcsRamRole()) {
$credential = $this->ecsRamRoleService->getSessionCredential();
}
if (null == $credential) {
throw new ClientException("Incorrect user credentials.", "SDK.InvalidCredential");
}
$request = $this->prepareRequest($request);
$domain = null;
if (null != $request->getLocationServiceCode())
{
$domain = $this->locationService->findProductDomain($request->getRegionId(), $request->getLocationServiceCode(), $request->getLocationEndpointType(), $request->getProduct());
}
if ($domain == null)
{
$domain = EndpointProvider::findProductDomain($request->getRegionId(), $request->getProduct());
}
if (null == $domain) {
throw new ClientException("Can not find endpoint to access.", "SDK.InvalidRegionId");
}
$requestUrl = $request->composeUrl($iSigner, $credential, $domain);
if ($this->__urlTestFlag__) {
throw new ClientException($requestUrl, "URLTestFlagIsSet");
}
if (count($request->getDomainParameter())>0) {
$httpResponse = HttpHelper::curl($requestUrl, $request->getMethod(), $request->getDomainParameter(), $request->getHeaders());
} else {
$httpResponse = HttpHelper::curl($requestUrl, $request->getMethod(), $request->getContent(), $request->getHeaders());
}
$retryTimes = 1;
while (500 <= $httpResponse->getStatus() && $autoRetry && $retryTimes < $maxRetryNumber) {
$requestUrl = $request->composeUrl($iSigner, $credential, $domain);
if (count($request->getDomainParameter())>0) {
$httpResponse = HttpHelper::curl($requestUrl, $request->getMethod(), $request->getDomainParameter(), $request->getHeaders());
} else {
$httpResponse = HttpHelper::curl($requestUrl, $request->getMethod(), $request->getContent(), $request->getHeaders());
}
$retryTimes ++;
}
return $httpResponse;
}
public function doAction($request, $iSigner = null, $credential = null, $autoRetry = true, $maxRetryNumber = 3)
{
trigger_error("doAction() is deprecated. Please use getAcsResponse() instead.", E_USER_NOTICE);
return $this->doActionImpl($request, $iSigner, $credential, $autoRetry, $maxRetryNumber);
}
private function prepareRequest($request)
{
if (null == $request->getRegionId()) {
$request->setRegionId($this->iClientProfile->getRegionId());
}
if (null == $request->getAcceptFormat()) {
$request->setAcceptFormat($this->iClientProfile->getFormat());
}
if (null == $request->getMethod()) {
$request->setMethod("GET");
}
return $request;
}
private function buildApiException($respObject, $httpStatus)
{
throw new ServerException($respObject->Message, $respObject->Code, $httpStatus, $respObject->RequestId);
}
private function parseAcsResponse($body, $format)
{
if ("JSON" == $format) {
$respObject = json_decode($body);
} elseif ("XML" == $format) {
$respObject = @simplexml_load_string($body);
} elseif ("RAW" == $format) {
$respObject = $body;
}
return $respObject;
}
}