12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274 |
- <?php
- // This file is auto-generated, don't edit it. Thanks.
- namespace Darabonba\OpenApi;
- use AlibabaCloud\Tea\Utils\Utils;
- use AlibabaCloud\Tea\Exception\TeaError;
- use AlibabaCloud\Credentials\Credential;
- use \Exception;
- use AlibabaCloud\Tea\Exception\TeaUnableRetryError;
- use AlibabaCloud\Tea\Tea;
- use AlibabaCloud\Tea\Request;
- use AlibabaCloud\OpenApiUtil\OpenApiUtilClient;
- use AlibabaCloud\Tea\XML\XML;
- use Darabonba\GatewaySpi\Client;
- use AlibabaCloud\Credentials\Credential\Config;
- use Darabonba\OpenApi\Models\OpenApiRequest;
- use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
- use Darabonba\OpenApi\Models\Params;
- use Darabonba\GatewaySpi\Models\InterceptorContext\configuration;
- use Darabonba\GatewaySpi\Models\InterceptorContext;
- use Darabonba\GatewaySpi\Models\AttributeMap;
- use Darabonba\GatewaySpi\Models\InterceptorContext\response;
- /**
- * This is for OpenApi SDK
- */
- class OpenApiClient
- {
- protected $_endpoint;
- protected $_regionId;
- protected $_protocol;
- protected $_method;
- protected $_userAgent;
- protected $_endpointRule;
- protected $_endpointMap;
- protected $_suffix;
- protected $_readTimeout;
- protected $_connectTimeout;
- protected $_httpProxy;
- protected $_httpsProxy;
- protected $_socks5Proxy;
- protected $_socks5NetWork;
- protected $_noProxy;
- protected $_network;
- protected $_productId;
- protected $_maxIdleConns;
- protected $_endpointType;
- protected $_openPlatformEndpoint;
- protected $_credential;
- protected $_signatureVersion;
- protected $_signatureAlgorithm;
- protected $_headers;
- protected $_spi;
- protected $_globalParameters;
- protected $_key;
- protected $_cert;
- protected $_ca;
- protected $_disableHttp2;
- /**
- * Init client with Config
- * @param config config contains the necessary information to create a client
- */
- public function __construct($config)
- {
- if (Utils::isUnset($config)) {
- throw new TeaError([
- "code" => "ParameterMissing",
- "message" => "'config' can not be unset"
- ]);
- }
- if (!Utils::empty_($config->accessKeyId) && !Utils::empty_($config->accessKeySecret)) {
- if (!Utils::empty_($config->securityToken)) {
- $config->type = "sts";
- } else {
- $config->type = "access_key";
- }
- $credentialConfig = new Config([
- "accessKeyId" => $config->accessKeyId,
- "type" => $config->type,
- "accessKeySecret" => $config->accessKeySecret
- ]);
- $credentialConfig->securityToken = $config->securityToken;
- $this->_credential = new Credential($credentialConfig);
- } else if (!Utils::empty_($config->bearerToken)) {
- $cc = new Config([
- "type" => "bearer",
- "bearerToken" => $config->bearerToken
- ]);
- $this->_credential = new Credential($cc);
- } else if (!Utils::isUnset($config->credential)) {
- $this->_credential = $config->credential;
- }
- $this->_endpoint = $config->endpoint;
- $this->_endpointType = $config->endpointType;
- $this->_network = $config->network;
- $this->_suffix = $config->suffix;
- $this->_protocol = $config->protocol;
- $this->_method = $config->method;
- $this->_regionId = $config->regionId;
- $this->_userAgent = $config->userAgent;
- $this->_readTimeout = $config->readTimeout;
- $this->_connectTimeout = $config->connectTimeout;
- $this->_httpProxy = $config->httpProxy;
- $this->_httpsProxy = $config->httpsProxy;
- $this->_noProxy = $config->noProxy;
- $this->_socks5Proxy = $config->socks5Proxy;
- $this->_socks5NetWork = $config->socks5NetWork;
- $this->_maxIdleConns = $config->maxIdleConns;
- $this->_signatureVersion = $config->signatureVersion;
- $this->_signatureAlgorithm = $config->signatureAlgorithm;
- $this->_globalParameters = $config->globalParameters;
- $this->_key = $config->key;
- $this->_cert = $config->cert;
- $this->_ca = $config->ca;
- $this->_disableHttp2 = $config->disableHttp2;
- }
- /**
- * Encapsulate the request and invoke the network
- * @param string $action api name
- * @param string $version product version
- * @param string $protocol http or https
- * @param string $method e.g. GET
- * @param string $authType authorization type e.g. AK
- * @param string $bodyType response body type e.g. String
- * @param OpenApiRequest $request object of OpenApiRequest
- * @param RuntimeOptions $runtime which controls some details of call api, such as retry times
- * @return array the response
- * @throws TeaError
- * @throws Exception
- * @throws TeaUnableRetryError
- */
- public function doRPCRequest($action, $version, $protocol, $method, $authType, $bodyType, $request, $runtime)
- {
- $request->validate();
- $runtime->validate();
- $_runtime = [
- "timeouted" => "retry",
- "key" => Utils::defaultString($runtime->key, $this->_key),
- "cert" => Utils::defaultString($runtime->cert, $this->_cert),
- "ca" => Utils::defaultString($runtime->ca, $this->_ca),
- "readTimeout" => Utils::defaultNumber($runtime->readTimeout, $this->_readTimeout),
- "connectTimeout" => Utils::defaultNumber($runtime->connectTimeout, $this->_connectTimeout),
- "httpProxy" => Utils::defaultString($runtime->httpProxy, $this->_httpProxy),
- "httpsProxy" => Utils::defaultString($runtime->httpsProxy, $this->_httpsProxy),
- "noProxy" => Utils::defaultString($runtime->noProxy, $this->_noProxy),
- "socks5Proxy" => Utils::defaultString($runtime->socks5Proxy, $this->_socks5Proxy),
- "socks5NetWork" => Utils::defaultString($runtime->socks5NetWork, $this->_socks5NetWork),
- "maxIdleConns" => Utils::defaultNumber($runtime->maxIdleConns, $this->_maxIdleConns),
- "retry" => [
- "retryable" => $runtime->autoretry,
- "maxAttempts" => Utils::defaultNumber($runtime->maxAttempts, 3)
- ],
- "backoff" => [
- "policy" => Utils::defaultString($runtime->backoffPolicy, "no"),
- "period" => Utils::defaultNumber($runtime->backoffPeriod, 1)
- ],
- "ignoreSSL" => $runtime->ignoreSSL
- ];
- $_lastRequest = null;
- $_lastException = null;
- $_now = time();
- $_retryTimes = 0;
- while (Tea::allowRetry(@$_runtime["retry"], $_retryTimes, $_now)) {
- if ($_retryTimes > 0) {
- $_backoffTime = Tea::getBackoffTime(@$_runtime["backoff"], $_retryTimes);
- if ($_backoffTime > 0) {
- Tea::sleep($_backoffTime);
- }
- }
- $_retryTimes = $_retryTimes + 1;
- try {
- $_request = new Request();
- $_request->protocol = Utils::defaultString($this->_protocol, $protocol);
- $_request->method = $method;
- $_request->pathname = "/";
- $globalQueries = [];
- $globalHeaders = [];
- if (!Utils::isUnset($this->_globalParameters)) {
- $globalParams = $this->_globalParameters;
- if (!Utils::isUnset($globalParams->queries)) {
- $globalQueries = $globalParams->queries;
- }
- if (!Utils::isUnset($globalParams->headers)) {
- $globalHeaders = $globalParams->headers;
- }
- }
- $extendsHeaders = [];
- $extendsQueries = [];
- if (!Utils::isUnset($runtime->extendsParameters)) {
- $extendsParameters = $runtime->extendsParameters;
- if (!Utils::isUnset($extendsParameters->headers)) {
- $extendsHeaders = $extendsParameters->headers;
- }
- if (!Utils::isUnset($extendsParameters->queries)) {
- $extendsQueries = $extendsParameters->queries;
- }
- }
- $_request->query = Tea::merge([
- "Action" => $action,
- "Format" => "json",
- "Version" => $version,
- "Timestamp" => OpenApiUtilClient::getTimestamp(),
- "SignatureNonce" => Utils::getNonce()
- ], $globalQueries, $extendsQueries, $request->query);
- $headers = $this->getRpcHeaders();
- if (Utils::isUnset($headers)) {
- // endpoint is setted in product client
- $_request->headers = Tea::merge([
- "host" => $this->_endpoint,
- "x-acs-version" => $version,
- "x-acs-action" => $action,
- "user-agent" => $this->getUserAgent()
- ], $globalHeaders, $extendsHeaders);
- } else {
- $_request->headers = Tea::merge([
- "host" => $this->_endpoint,
- "x-acs-version" => $version,
- "x-acs-action" => $action,
- "user-agent" => $this->getUserAgent()
- ], $globalHeaders, $extendsHeaders, $headers);
- }
- if (!Utils::isUnset($request->body)) {
- $m = Utils::assertAsMap($request->body);
- $tmp = Utils::anyifyMapValue(OpenApiUtilClient::query($m));
- $_request->body = Utils::toFormString($tmp);
- $_request->headers["content-type"] = "application/x-www-form-urlencoded";
- }
- if (!Utils::equalString($authType, "Anonymous")) {
- $credentialType = $this->getType();
- if (Utils::equalString($credentialType, "bearer")) {
- $bearerToken = $this->getBearerToken();
- $_request->query["BearerToken"] = $bearerToken;
- $_request->query["SignatureType"] = "BEARERTOKEN";
- } else {
- $accessKeyId = $this->getAccessKeyId();
- $accessKeySecret = $this->getAccessKeySecret();
- $securityToken = $this->getSecurityToken();
- if (!Utils::empty_($securityToken)) {
- $_request->query["SecurityToken"] = $securityToken;
- }
- $_request->query["SignatureMethod"] = "HMAC-SHA1";
- $_request->query["SignatureVersion"] = "1.0";
- $_request->query["AccessKeyId"] = $accessKeyId;
- $t = null;
- if (!Utils::isUnset($request->body)) {
- $t = Utils::assertAsMap($request->body);
- }
- $signedParam = Tea::merge($_request->query, OpenApiUtilClient::query($t));
- $_request->query["Signature"] = OpenApiUtilClient::getRPCSignature($signedParam, $_request->method, $accessKeySecret);
- }
- }
- $_lastRequest = $_request;
- $_response = Tea::send($_request, $_runtime);
- if (Utils::is4xx($_response->statusCode) || Utils::is5xx($_response->statusCode)) {
- $_res = Utils::readAsJSON($_response->body);
- $err = Utils::assertAsMap($_res);
- $requestId = self::defaultAny(@$err["RequestId"], @$err["requestId"]);
- @$err["statusCode"] = $_response->statusCode;
- throw new TeaError([
- "code" => "" . (string) (self::defaultAny(@$err["Code"], @$err["code"])) . "",
- "message" => "code: " . (string) ($_response->statusCode) . ", " . (string) (self::defaultAny(@$err["Message"], @$err["message"])) . " request id: " . (string) ($requestId) . "",
- "data" => $err,
- "description" => "" . (string) (self::defaultAny(@$err["Description"], @$err["description"])) . "",
- "accessDeniedDetail" => self::defaultAny(@$err["AccessDeniedDetail"], @$err["accessDeniedDetail"])
- ]);
- }
- if (Utils::equalString($bodyType, "binary")) {
- $resp = [
- "body" => $_response->body,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- return $resp;
- } else if (Utils::equalString($bodyType, "byte")) {
- $byt = Utils::readAsBytes($_response->body);
- return [
- "body" => $byt,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "string")) {
- $str = Utils::readAsString($_response->body);
- return [
- "body" => $str,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "json")) {
- $obj = Utils::readAsJSON($_response->body);
- $res = Utils::assertAsMap($obj);
- return [
- "body" => $res,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "array")) {
- $arr = Utils::readAsJSON($_response->body);
- return [
- "body" => $arr,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else {
- return [
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- }
- } catch (Exception $e) {
- if (!($e instanceof TeaError)) {
- $e = new TeaError([], $e->getMessage(), $e->getCode(), $e);
- }
- if (Tea::isRetryable($e)) {
- $_lastException = $e;
- continue;
- }
- throw $e;
- }
- }
- throw new TeaUnableRetryError($_lastRequest, $_lastException);
- }
- /**
- * Encapsulate the request and invoke the network
- * @param string $action api name
- * @param string $version product version
- * @param string $protocol http or https
- * @param string $method e.g. GET
- * @param string $authType authorization type e.g. AK
- * @param string $pathname pathname of every api
- * @param string $bodyType response body type e.g. String
- * @param OpenApiRequest $request object of OpenApiRequest
- * @param RuntimeOptions $runtime which controls some details of call api, such as retry times
- * @return array the response
- * @throws TeaError
- * @throws Exception
- * @throws TeaUnableRetryError
- */
- public function doROARequest($action, $version, $protocol, $method, $authType, $pathname, $bodyType, $request, $runtime)
- {
- $request->validate();
- $runtime->validate();
- $_runtime = [
- "timeouted" => "retry",
- "key" => Utils::defaultString($runtime->key, $this->_key),
- "cert" => Utils::defaultString($runtime->cert, $this->_cert),
- "ca" => Utils::defaultString($runtime->ca, $this->_ca),
- "readTimeout" => Utils::defaultNumber($runtime->readTimeout, $this->_readTimeout),
- "connectTimeout" => Utils::defaultNumber($runtime->connectTimeout, $this->_connectTimeout),
- "httpProxy" => Utils::defaultString($runtime->httpProxy, $this->_httpProxy),
- "httpsProxy" => Utils::defaultString($runtime->httpsProxy, $this->_httpsProxy),
- "noProxy" => Utils::defaultString($runtime->noProxy, $this->_noProxy),
- "socks5Proxy" => Utils::defaultString($runtime->socks5Proxy, $this->_socks5Proxy),
- "socks5NetWork" => Utils::defaultString($runtime->socks5NetWork, $this->_socks5NetWork),
- "maxIdleConns" => Utils::defaultNumber($runtime->maxIdleConns, $this->_maxIdleConns),
- "retry" => [
- "retryable" => $runtime->autoretry,
- "maxAttempts" => Utils::defaultNumber($runtime->maxAttempts, 3)
- ],
- "backoff" => [
- "policy" => Utils::defaultString($runtime->backoffPolicy, "no"),
- "period" => Utils::defaultNumber($runtime->backoffPeriod, 1)
- ],
- "ignoreSSL" => $runtime->ignoreSSL
- ];
- $_lastRequest = null;
- $_lastException = null;
- $_now = time();
- $_retryTimes = 0;
- while (Tea::allowRetry(@$_runtime["retry"], $_retryTimes, $_now)) {
- if ($_retryTimes > 0) {
- $_backoffTime = Tea::getBackoffTime(@$_runtime["backoff"], $_retryTimes);
- if ($_backoffTime > 0) {
- Tea::sleep($_backoffTime);
- }
- }
- $_retryTimes = $_retryTimes + 1;
- try {
- $_request = new Request();
- $_request->protocol = Utils::defaultString($this->_protocol, $protocol);
- $_request->method = $method;
- $_request->pathname = $pathname;
- $globalQueries = [];
- $globalHeaders = [];
- if (!Utils::isUnset($this->_globalParameters)) {
- $globalParams = $this->_globalParameters;
- if (!Utils::isUnset($globalParams->queries)) {
- $globalQueries = $globalParams->queries;
- }
- if (!Utils::isUnset($globalParams->headers)) {
- $globalHeaders = $globalParams->headers;
- }
- }
- $extendsHeaders = [];
- $extendsQueries = [];
- if (!Utils::isUnset($runtime->extendsParameters)) {
- $extendsParameters = $runtime->extendsParameters;
- if (!Utils::isUnset($extendsParameters->headers)) {
- $extendsHeaders = $extendsParameters->headers;
- }
- if (!Utils::isUnset($extendsParameters->queries)) {
- $extendsQueries = $extendsParameters->queries;
- }
- }
- $_request->headers = Tea::merge([
- "date" => Utils::getDateUTCString(),
- "host" => $this->_endpoint,
- "accept" => "application/json",
- "x-acs-signature-nonce" => Utils::getNonce(),
- "x-acs-signature-method" => "HMAC-SHA1",
- "x-acs-signature-version" => "1.0",
- "x-acs-version" => $version,
- "x-acs-action" => $action,
- "user-agent" => Utils::getUserAgent($this->_userAgent)
- ], $globalHeaders, $extendsHeaders, $request->headers);
- if (!Utils::isUnset($request->body)) {
- $_request->body = Utils::toJSONString($request->body);
- $_request->headers["content-type"] = "application/json; charset=utf-8";
- }
- $_request->query = Tea::merge($globalQueries, $extendsQueries);
- if (!Utils::isUnset($request->query)) {
- $_request->query = Tea::merge($_request->query, $request->query);
- }
- if (!Utils::equalString($authType, "Anonymous")) {
- $credentialType = $this->getType();
- if (Utils::equalString($credentialType, "bearer")) {
- $bearerToken = $this->getBearerToken();
- $_request->headers["x-acs-bearer-token"] = $bearerToken;
- $_request->headers["x-acs-signature-type"] = "BEARERTOKEN";
- } else {
- $accessKeyId = $this->getAccessKeyId();
- $accessKeySecret = $this->getAccessKeySecret();
- $securityToken = $this->getSecurityToken();
- if (!Utils::empty_($securityToken)) {
- $_request->headers["x-acs-accesskey-id"] = $accessKeyId;
- $_request->headers["x-acs-security-token"] = $securityToken;
- }
- $stringToSign = OpenApiUtilClient::getStringToSign($_request);
- $_request->headers["authorization"] = "acs " . $accessKeyId . ":" . OpenApiUtilClient::getROASignature($stringToSign, $accessKeySecret) . "";
- }
- }
- $_lastRequest = $_request;
- $_response = Tea::send($_request, $_runtime);
- if (Utils::equalNumber($_response->statusCode, 204)) {
- return [
- "headers" => $_response->headers
- ];
- }
- if (Utils::is4xx($_response->statusCode) || Utils::is5xx($_response->statusCode)) {
- $_res = Utils::readAsJSON($_response->body);
- $err = Utils::assertAsMap($_res);
- $requestId = self::defaultAny(@$err["RequestId"], @$err["requestId"]);
- $requestId = self::defaultAny($requestId, @$err["requestid"]);
- @$err["statusCode"] = $_response->statusCode;
- throw new TeaError([
- "code" => "" . (string) (self::defaultAny(@$err["Code"], @$err["code"])) . "",
- "message" => "code: " . (string) ($_response->statusCode) . ", " . (string) (self::defaultAny(@$err["Message"], @$err["message"])) . " request id: " . (string) ($requestId) . "",
- "data" => $err,
- "description" => "" . (string) (self::defaultAny(@$err["Description"], @$err["description"])) . "",
- "accessDeniedDetail" => self::defaultAny(@$err["AccessDeniedDetail"], @$err["accessDeniedDetail"])
- ]);
- }
- if (Utils::equalString($bodyType, "binary")) {
- $resp = [
- "body" => $_response->body,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- return $resp;
- } else if (Utils::equalString($bodyType, "byte")) {
- $byt = Utils::readAsBytes($_response->body);
- return [
- "body" => $byt,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "string")) {
- $str = Utils::readAsString($_response->body);
- return [
- "body" => $str,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "json")) {
- $obj = Utils::readAsJSON($_response->body);
- $res = Utils::assertAsMap($obj);
- return [
- "body" => $res,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "array")) {
- $arr = Utils::readAsJSON($_response->body);
- return [
- "body" => $arr,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else {
- return [
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- }
- } catch (Exception $e) {
- if (!($e instanceof TeaError)) {
- $e = new TeaError([], $e->getMessage(), $e->getCode(), $e);
- }
- if (Tea::isRetryable($e)) {
- $_lastException = $e;
- continue;
- }
- throw $e;
- }
- }
- throw new TeaUnableRetryError($_lastRequest, $_lastException);
- }
- /**
- * Encapsulate the request and invoke the network with form body
- * @param string $action api name
- * @param string $version product version
- * @param string $protocol http or https
- * @param string $method e.g. GET
- * @param string $authType authorization type e.g. AK
- * @param string $pathname pathname of every api
- * @param string $bodyType response body type e.g. String
- * @param OpenApiRequest $request object of OpenApiRequest
- * @param RuntimeOptions $runtime which controls some details of call api, such as retry times
- * @return array the response
- * @throws TeaError
- * @throws Exception
- * @throws TeaUnableRetryError
- */
- public function doROARequestWithForm($action, $version, $protocol, $method, $authType, $pathname, $bodyType, $request, $runtime)
- {
- $request->validate();
- $runtime->validate();
- $_runtime = [
- "timeouted" => "retry",
- "key" => Utils::defaultString($runtime->key, $this->_key),
- "cert" => Utils::defaultString($runtime->cert, $this->_cert),
- "ca" => Utils::defaultString($runtime->ca, $this->_ca),
- "readTimeout" => Utils::defaultNumber($runtime->readTimeout, $this->_readTimeout),
- "connectTimeout" => Utils::defaultNumber($runtime->connectTimeout, $this->_connectTimeout),
- "httpProxy" => Utils::defaultString($runtime->httpProxy, $this->_httpProxy),
- "httpsProxy" => Utils::defaultString($runtime->httpsProxy, $this->_httpsProxy),
- "noProxy" => Utils::defaultString($runtime->noProxy, $this->_noProxy),
- "socks5Proxy" => Utils::defaultString($runtime->socks5Proxy, $this->_socks5Proxy),
- "socks5NetWork" => Utils::defaultString($runtime->socks5NetWork, $this->_socks5NetWork),
- "maxIdleConns" => Utils::defaultNumber($runtime->maxIdleConns, $this->_maxIdleConns),
- "retry" => [
- "retryable" => $runtime->autoretry,
- "maxAttempts" => Utils::defaultNumber($runtime->maxAttempts, 3)
- ],
- "backoff" => [
- "policy" => Utils::defaultString($runtime->backoffPolicy, "no"),
- "period" => Utils::defaultNumber($runtime->backoffPeriod, 1)
- ],
- "ignoreSSL" => $runtime->ignoreSSL
- ];
- $_lastRequest = null;
- $_lastException = null;
- $_now = time();
- $_retryTimes = 0;
- while (Tea::allowRetry(@$_runtime["retry"], $_retryTimes, $_now)) {
- if ($_retryTimes > 0) {
- $_backoffTime = Tea::getBackoffTime(@$_runtime["backoff"], $_retryTimes);
- if ($_backoffTime > 0) {
- Tea::sleep($_backoffTime);
- }
- }
- $_retryTimes = $_retryTimes + 1;
- try {
- $_request = new Request();
- $_request->protocol = Utils::defaultString($this->_protocol, $protocol);
- $_request->method = $method;
- $_request->pathname = $pathname;
- $globalQueries = [];
- $globalHeaders = [];
- if (!Utils::isUnset($this->_globalParameters)) {
- $globalParams = $this->_globalParameters;
- if (!Utils::isUnset($globalParams->queries)) {
- $globalQueries = $globalParams->queries;
- }
- if (!Utils::isUnset($globalParams->headers)) {
- $globalHeaders = $globalParams->headers;
- }
- }
- $extendsHeaders = [];
- $extendsQueries = [];
- if (!Utils::isUnset($runtime->extendsParameters)) {
- $extendsParameters = $runtime->extendsParameters;
- if (!Utils::isUnset($extendsParameters->headers)) {
- $extendsHeaders = $extendsParameters->headers;
- }
- if (!Utils::isUnset($extendsParameters->queries)) {
- $extendsQueries = $extendsParameters->queries;
- }
- }
- $_request->headers = Tea::merge([
- "date" => Utils::getDateUTCString(),
- "host" => $this->_endpoint,
- "accept" => "application/json",
- "x-acs-signature-nonce" => Utils::getNonce(),
- "x-acs-signature-method" => "HMAC-SHA1",
- "x-acs-signature-version" => "1.0",
- "x-acs-version" => $version,
- "x-acs-action" => $action,
- "user-agent" => Utils::getUserAgent($this->_userAgent)
- ], $globalHeaders, $extendsHeaders, $request->headers);
- if (!Utils::isUnset($request->body)) {
- $m = Utils::assertAsMap($request->body);
- $_request->body = OpenApiUtilClient::toForm($m);
- $_request->headers["content-type"] = "application/x-www-form-urlencoded";
- }
- $_request->query = Tea::merge($globalQueries, $extendsQueries);
- if (!Utils::isUnset($request->query)) {
- $_request->query = Tea::merge($_request->query, $request->query);
- }
- if (!Utils::equalString($authType, "Anonymous")) {
- $credentialType = $this->getType();
- if (Utils::equalString($credentialType, "bearer")) {
- $bearerToken = $this->getBearerToken();
- $_request->headers["x-acs-bearer-token"] = $bearerToken;
- $_request->headers["x-acs-signature-type"] = "BEARERTOKEN";
- } else {
- $accessKeyId = $this->getAccessKeyId();
- $accessKeySecret = $this->getAccessKeySecret();
- $securityToken = $this->getSecurityToken();
- if (!Utils::empty_($securityToken)) {
- $_request->headers["x-acs-accesskey-id"] = $accessKeyId;
- $_request->headers["x-acs-security-token"] = $securityToken;
- }
- $stringToSign = OpenApiUtilClient::getStringToSign($_request);
- $_request->headers["authorization"] = "acs " . $accessKeyId . ":" . OpenApiUtilClient::getROASignature($stringToSign, $accessKeySecret) . "";
- }
- }
- $_lastRequest = $_request;
- $_response = Tea::send($_request, $_runtime);
- if (Utils::equalNumber($_response->statusCode, 204)) {
- return [
- "headers" => $_response->headers
- ];
- }
- if (Utils::is4xx($_response->statusCode) || Utils::is5xx($_response->statusCode)) {
- $_res = Utils::readAsJSON($_response->body);
- $err = Utils::assertAsMap($_res);
- @$err["statusCode"] = $_response->statusCode;
- throw new TeaError([
- "code" => "" . (string) (self::defaultAny(@$err["Code"], @$err["code"])) . "",
- "message" => "code: " . (string) ($_response->statusCode) . ", " . (string) (self::defaultAny(@$err["Message"], @$err["message"])) . " request id: " . (string) (self::defaultAny(@$err["RequestId"], @$err["requestId"])) . "",
- "data" => $err,
- "description" => "" . (string) (self::defaultAny(@$err["Description"], @$err["description"])) . "",
- "accessDeniedDetail" => self::defaultAny(@$err["AccessDeniedDetail"], @$err["accessDeniedDetail"])
- ]);
- }
- if (Utils::equalString($bodyType, "binary")) {
- $resp = [
- "body" => $_response->body,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- return $resp;
- } else if (Utils::equalString($bodyType, "byte")) {
- $byt = Utils::readAsBytes($_response->body);
- return [
- "body" => $byt,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "string")) {
- $str = Utils::readAsString($_response->body);
- return [
- "body" => $str,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "json")) {
- $obj = Utils::readAsJSON($_response->body);
- $res = Utils::assertAsMap($obj);
- return [
- "body" => $res,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($bodyType, "array")) {
- $arr = Utils::readAsJSON($_response->body);
- return [
- "body" => $arr,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else {
- return [
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- }
- } catch (Exception $e) {
- if (!($e instanceof TeaError)) {
- $e = new TeaError([], $e->getMessage(), $e->getCode(), $e);
- }
- if (Tea::isRetryable($e)) {
- $_lastException = $e;
- continue;
- }
- throw $e;
- }
- }
- throw new TeaUnableRetryError($_lastRequest, $_lastException);
- }
- /**
- * Encapsulate the request and invoke the network
- * @param Params $params
- * @param OpenApiRequest $request object of OpenApiRequest
- * @param RuntimeOptions $runtime which controls some details of call api, such as retry times
- * @return array the response
- * @throws TeaError
- * @throws Exception
- * @throws TeaUnableRetryError
- */
- public function doRequest($params, $request, $runtime)
- {
- $params->validate();
- $request->validate();
- $runtime->validate();
- $_runtime = [
- "timeouted" => "retry",
- "key" => Utils::defaultString($runtime->key, $this->_key),
- "cert" => Utils::defaultString($runtime->cert, $this->_cert),
- "ca" => Utils::defaultString($runtime->ca, $this->_ca),
- "readTimeout" => Utils::defaultNumber($runtime->readTimeout, $this->_readTimeout),
- "connectTimeout" => Utils::defaultNumber($runtime->connectTimeout, $this->_connectTimeout),
- "httpProxy" => Utils::defaultString($runtime->httpProxy, $this->_httpProxy),
- "httpsProxy" => Utils::defaultString($runtime->httpsProxy, $this->_httpsProxy),
- "noProxy" => Utils::defaultString($runtime->noProxy, $this->_noProxy),
- "socks5Proxy" => Utils::defaultString($runtime->socks5Proxy, $this->_socks5Proxy),
- "socks5NetWork" => Utils::defaultString($runtime->socks5NetWork, $this->_socks5NetWork),
- "maxIdleConns" => Utils::defaultNumber($runtime->maxIdleConns, $this->_maxIdleConns),
- "retry" => [
- "retryable" => $runtime->autoretry,
- "maxAttempts" => Utils::defaultNumber($runtime->maxAttempts, 3)
- ],
- "backoff" => [
- "policy" => Utils::defaultString($runtime->backoffPolicy, "no"),
- "period" => Utils::defaultNumber($runtime->backoffPeriod, 1)
- ],
- "ignoreSSL" => $runtime->ignoreSSL
- ];
- $_lastRequest = null;
- $_lastException = null;
- $_now = time();
- $_retryTimes = 0;
- while (Tea::allowRetry(@$_runtime["retry"], $_retryTimes, $_now)) {
- if ($_retryTimes > 0) {
- $_backoffTime = Tea::getBackoffTime(@$_runtime["backoff"], $_retryTimes);
- if ($_backoffTime > 0) {
- Tea::sleep($_backoffTime);
- }
- }
- $_retryTimes = $_retryTimes + 1;
- try {
- $_request = new Request();
- $_request->protocol = Utils::defaultString($this->_protocol, $params->protocol);
- $_request->method = $params->method;
- $_request->pathname = $params->pathname;
- $globalQueries = [];
- $globalHeaders = [];
- if (!Utils::isUnset($this->_globalParameters)) {
- $globalParams = $this->_globalParameters;
- if (!Utils::isUnset($globalParams->queries)) {
- $globalQueries = $globalParams->queries;
- }
- if (!Utils::isUnset($globalParams->headers)) {
- $globalHeaders = $globalParams->headers;
- }
- }
- $extendsHeaders = [];
- $extendsQueries = [];
- if (!Utils::isUnset($runtime->extendsParameters)) {
- $extendsParameters = $runtime->extendsParameters;
- if (!Utils::isUnset($extendsParameters->headers)) {
- $extendsHeaders = $extendsParameters->headers;
- }
- if (!Utils::isUnset($extendsParameters->queries)) {
- $extendsQueries = $extendsParameters->queries;
- }
- }
- $_request->query = Tea::merge($globalQueries, $extendsQueries, $request->query);
- // endpoint is setted in product client
- $_request->headers = Tea::merge([
- "host" => $this->_endpoint,
- "x-acs-version" => $params->version,
- "x-acs-action" => $params->action,
- "user-agent" => $this->getUserAgent(),
- "x-acs-date" => OpenApiUtilClient::getTimestamp(),
- "x-acs-signature-nonce" => Utils::getNonce(),
- "accept" => "application/json"
- ], $globalHeaders, $extendsHeaders, $request->headers);
- if (Utils::equalString($params->style, "RPC")) {
- $headers = $this->getRpcHeaders();
- if (!Utils::isUnset($headers)) {
- $_request->headers = Tea::merge($_request->headers, $headers);
- }
- }
- $signatureAlgorithm = Utils::defaultString($this->_signatureAlgorithm, "ACS3-HMAC-SHA256");
- $hashedRequestPayload = OpenApiUtilClient::hexEncode(OpenApiUtilClient::hash(Utils::toBytes(""), $signatureAlgorithm));
- if (!Utils::isUnset($request->stream)) {
- $tmp = Utils::readAsBytes($request->stream);
- $hashedRequestPayload = OpenApiUtilClient::hexEncode(OpenApiUtilClient::hash($tmp, $signatureAlgorithm));
- $_request->body = $tmp;
- $_request->headers["content-type"] = "application/octet-stream";
- } else {
- if (!Utils::isUnset($request->body)) {
- if (Utils::equalString($params->reqBodyType, "byte")) {
- $byteObj = Utils::assertAsBytes($request->body);
- $hashedRequestPayload = OpenApiUtilClient::hexEncode(OpenApiUtilClient::hash($byteObj, $signatureAlgorithm));
- $_request->body = $byteObj;
- } else if (Utils::equalString($params->reqBodyType, "json")) {
- $jsonObj = Utils::toJSONString($request->body);
- $hashedRequestPayload = OpenApiUtilClient::hexEncode(OpenApiUtilClient::hash(Utils::toBytes($jsonObj), $signatureAlgorithm));
- $_request->body = $jsonObj;
- $_request->headers["content-type"] = "application/json; charset=utf-8";
- } else {
- $m = Utils::assertAsMap($request->body);
- $formObj = OpenApiUtilClient::toForm($m);
- $hashedRequestPayload = OpenApiUtilClient::hexEncode(OpenApiUtilClient::hash(Utils::toBytes($formObj), $signatureAlgorithm));
- $_request->body = $formObj;
- $_request->headers["content-type"] = "application/x-www-form-urlencoded";
- }
- }
- }
- $_request->headers["x-acs-content-sha256"] = $hashedRequestPayload;
- if (!Utils::equalString($params->authType, "Anonymous")) {
- $authType = $this->getType();
- if (Utils::equalString($authType, "bearer")) {
- $bearerToken = $this->getBearerToken();
- $_request->headers["x-acs-bearer-token"] = $bearerToken;
- if (Utils::equalString($params->style, "RPC")) {
- $_request->query["SignatureType"] = "BEARERTOKEN";
- } else {
- $_request->headers["x-acs-signature-type"] = "BEARERTOKEN";
- }
- } else {
- $accessKeyId = $this->getAccessKeyId();
- $accessKeySecret = $this->getAccessKeySecret();
- $securityToken = $this->getSecurityToken();
- if (!Utils::empty_($securityToken)) {
- $_request->headers["x-acs-accesskey-id"] = $accessKeyId;
- $_request->headers["x-acs-security-token"] = $securityToken;
- }
- $_request->headers["Authorization"] = OpenApiUtilClient::getAuthorization($_request, $signatureAlgorithm, $hashedRequestPayload, $accessKeyId, $accessKeySecret);
- }
- }
- $_lastRequest = $_request;
- $_response = Tea::send($_request, $_runtime);
- if (Utils::is4xx($_response->statusCode) || Utils::is5xx($_response->statusCode)) {
- $_res = Utils::readAsJSON($_response->body);
- $err = Utils::assertAsMap($_res);
- @$err["statusCode"] = $_response->statusCode;
- throw new TeaError([
- "code" => "" . (string) (self::defaultAny(@$err["Code"], @$err["code"])) . "",
- "message" => "code: " . (string) ($_response->statusCode) . ", " . (string) (self::defaultAny(@$err["Message"], @$err["message"])) . " request id: " . (string) (self::defaultAny(@$err["RequestId"], @$err["requestId"])) . "",
- "data" => $err,
- "description" => "" . (string) (self::defaultAny(@$err["Description"], @$err["description"])) . "",
- "accessDeniedDetail" => self::defaultAny(@$err["AccessDeniedDetail"], @$err["accessDeniedDetail"])
- ]);
- }
- if (Utils::equalString($params->bodyType, "binary")) {
- $resp = [
- "body" => $_response->body,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- return $resp;
- } else if (Utils::equalString($params->bodyType, "byte")) {
- $byt = Utils::readAsBytes($_response->body);
- return [
- "body" => $byt,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($params->bodyType, "string")) {
- $str = Utils::readAsString($_response->body);
- return [
- "body" => $str,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($params->bodyType, "json")) {
- $obj = Utils::readAsJSON($_response->body);
- $res = Utils::assertAsMap($obj);
- return [
- "body" => $res,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else if (Utils::equalString($params->bodyType, "array")) {
- $arr = Utils::readAsJSON($_response->body);
- return [
- "body" => $arr,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- } else {
- $anything = Utils::readAsString($_response->body);
- return [
- "body" => $anything,
- "headers" => $_response->headers,
- "statusCode" => $_response->statusCode
- ];
- }
- } catch (Exception $e) {
- if (!($e instanceof TeaError)) {
- $e = new TeaError([], $e->getMessage(), $e->getCode(), $e);
- }
- if (Tea::isRetryable($e)) {
- $_lastException = $e;
- continue;
- }
- throw $e;
- }
- }
- throw new TeaUnableRetryError($_lastRequest, $_lastException);
- }
- /**
- * Encapsulate the request and invoke the network
- * @param Params $params
- * @param OpenApiRequest $request object of OpenApiRequest
- * @param RuntimeOptions $runtime which controls some details of call api, such as retry times
- * @return array the response
- * @throws TeaError
- * @throws Exception
- * @throws TeaUnableRetryError
- */
- public function execute($params, $request, $runtime)
- {
- $params->validate();
- $request->validate();
- $runtime->validate();
- $_runtime = [
- "timeouted" => "retry",
- "key" => Utils::defaultString($runtime->key, $this->_key),
- "cert" => Utils::defaultString($runtime->cert, $this->_cert),
- "ca" => Utils::defaultString($runtime->ca, $this->_ca),
- "readTimeout" => Utils::defaultNumber($runtime->readTimeout, $this->_readTimeout),
- "connectTimeout" => Utils::defaultNumber($runtime->connectTimeout, $this->_connectTimeout),
- "httpProxy" => Utils::defaultString($runtime->httpProxy, $this->_httpProxy),
- "httpsProxy" => Utils::defaultString($runtime->httpsProxy, $this->_httpsProxy),
- "noProxy" => Utils::defaultString($runtime->noProxy, $this->_noProxy),
- "socks5Proxy" => Utils::defaultString($runtime->socks5Proxy, $this->_socks5Proxy),
- "socks5NetWork" => Utils::defaultString($runtime->socks5NetWork, $this->_socks5NetWork),
- "maxIdleConns" => Utils::defaultNumber($runtime->maxIdleConns, $this->_maxIdleConns),
- "retry" => [
- "retryable" => $runtime->autoretry,
- "maxAttempts" => Utils::defaultNumber($runtime->maxAttempts, 3)
- ],
- "backoff" => [
- "policy" => Utils::defaultString($runtime->backoffPolicy, "no"),
- "period" => Utils::defaultNumber($runtime->backoffPeriod, 1)
- ],
- "ignoreSSL" => $runtime->ignoreSSL,
- "disableHttp2" => self::defaultAny($this->_disableHttp2, false)
- ];
- $_lastRequest = null;
- $_lastException = null;
- $_now = time();
- $_retryTimes = 0;
- while (Tea::allowRetry(@$_runtime["retry"], $_retryTimes, $_now)) {
- if ($_retryTimes > 0) {
- $_backoffTime = Tea::getBackoffTime(@$_runtime["backoff"], $_retryTimes);
- if ($_backoffTime > 0) {
- Tea::sleep($_backoffTime);
- }
- }
- $_retryTimes = $_retryTimes + 1;
- try {
- $_request = new Request();
- // spi = new Gateway();//Gateway implements SPI,这一步在产品 SDK 中实例化
- $headers = $this->getRpcHeaders();
- $globalQueries = [];
- $globalHeaders = [];
- if (!Utils::isUnset($this->_globalParameters)) {
- $globalParams = $this->_globalParameters;
- if (!Utils::isUnset($globalParams->queries)) {
- $globalQueries = $globalParams->queries;
- }
- if (!Utils::isUnset($globalParams->headers)) {
- $globalHeaders = $globalParams->headers;
- }
- }
- $extendsHeaders = [];
- $extendsQueries = [];
- if (!Utils::isUnset($runtime->extendsParameters)) {
- $extendsParameters = $runtime->extendsParameters;
- if (!Utils::isUnset($extendsParameters->headers)) {
- $extendsHeaders = $extendsParameters->headers;
- }
- if (!Utils::isUnset($extendsParameters->queries)) {
- $extendsQueries = $extendsParameters->queries;
- }
- }
- $requestContext = new \Darabonba\GatewaySpi\Models\InterceptorContext\request([
- "headers" => Tea::merge($globalHeaders, $extendsHeaders, $request->headers, $headers),
- "query" => Tea::merge($globalQueries, $extendsQueries, $request->query),
- "body" => $request->body,
- "stream" => $request->stream,
- "hostMap" => $request->hostMap,
- "pathname" => $params->pathname,
- "productId" => $this->_productId,
- "action" => $params->action,
- "version" => $params->version,
- "protocol" => Utils::defaultString($this->_protocol, $params->protocol),
- "method" => Utils::defaultString($this->_method, $params->method),
- "authType" => $params->authType,
- "bodyType" => $params->bodyType,
- "reqBodyType" => $params->reqBodyType,
- "style" => $params->style,
- "credential" => $this->_credential,
- "signatureVersion" => $this->_signatureVersion,
- "signatureAlgorithm" => $this->_signatureAlgorithm,
- "userAgent" => $this->getUserAgent()
- ]);
- $configurationContext = new configuration([
- "regionId" => $this->_regionId,
- "endpoint" => Utils::defaultString($request->endpointOverride, $this->_endpoint),
- "endpointRule" => $this->_endpointRule,
- "endpointMap" => $this->_endpointMap,
- "endpointType" => $this->_endpointType,
- "network" => $this->_network,
- "suffix" => $this->_suffix
- ]);
- $interceptorContext = new InterceptorContext([
- "request" => $requestContext,
- "configuration" => $configurationContext
- ]);
- $attributeMap = new AttributeMap([]);
- // 1. spi.modifyConfiguration(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
- $this->_spi->modifyConfiguration($interceptorContext, $attributeMap);
- // 2. spi.modifyRequest(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
- $this->_spi->modifyRequest($interceptorContext, $attributeMap);
- $_request->protocol = $interceptorContext->request->protocol;
- $_request->method = $interceptorContext->request->method;
- $_request->pathname = $interceptorContext->request->pathname;
- $_request->query = $interceptorContext->request->query;
- $_request->body = $interceptorContext->request->stream;
- $_request->headers = $interceptorContext->request->headers;
- $_lastRequest = $_request;
- $_response = Tea::send($_request, $_runtime);
- $responseContext = new response([
- "statusCode" => $_response->statusCode,
- "headers" => $_response->headers,
- "body" => $_response->body
- ]);
- $interceptorContext->response = $responseContext;
- // 3. spi.modifyResponse(context: SPI.InterceptorContext, attributeMap: SPI.AttributeMap);
- $this->_spi->modifyResponse($interceptorContext, $attributeMap);
- return [
- "headers" => $interceptorContext->response->headers,
- "statusCode" => $interceptorContext->response->statusCode,
- "body" => $interceptorContext->response->deserializedBody
- ];
- } catch (Exception $e) {
- if (!($e instanceof TeaError)) {
- $e = new TeaError([], $e->getMessage(), $e->getCode(), $e);
- }
- if (Tea::isRetryable($e)) {
- $_lastException = $e;
- continue;
- }
- throw $e;
- }
- }
- throw new TeaUnableRetryError($_lastRequest, $_lastException);
- }
- /**
- * @param Params $params
- * @param OpenApiRequest $request
- * @param RuntimeOptions $runtime
- * @return array
- * @throws TeaError
- */
- public function callApi($params, $request, $runtime)
- {
- if (Utils::isUnset($params)) {
- throw new TeaError([
- "code" => "ParameterMissing",
- "message" => "'params' can not be unset"
- ]);
- }
- if (Utils::isUnset($this->_signatureAlgorithm) || !Utils::equalString($this->_signatureAlgorithm, "v2")) {
- return $this->doRequest($params, $request, $runtime);
- } else if (Utils::equalString($params->style, "ROA") && Utils::equalString($params->reqBodyType, "json")) {
- return $this->doROARequest($params->action, $params->version, $params->protocol, $params->method, $params->authType, $params->pathname, $params->bodyType, $request, $runtime);
- } else if (Utils::equalString($params->style, "ROA")) {
- return $this->doROARequestWithForm($params->action, $params->version, $params->protocol, $params->method, $params->authType, $params->pathname, $params->bodyType, $request, $runtime);
- } else {
- return $this->doRPCRequest($params->action, $params->version, $params->protocol, $params->method, $params->authType, $params->bodyType, $request, $runtime);
- }
- }
- /**
- * Get user agent
- * @return string user agent
- */
- public function getUserAgent()
- {
- $userAgent = Utils::getUserAgent($this->_userAgent);
- return $userAgent;
- }
- /**
- * Get accesskey id by using credential
- * @return string accesskey id
- */
- public function getAccessKeyId()
- {
- if (Utils::isUnset($this->_credential)) {
- return '';
- }
- $accessKeyId = $this->_credential->getAccessKeyId();
- return $accessKeyId;
- }
- /**
- * Get accesskey secret by using credential
- * @return string accesskey secret
- */
- public function getAccessKeySecret()
- {
- if (Utils::isUnset($this->_credential)) {
- return '';
- }
- $secret = $this->_credential->getAccessKeySecret();
- return $secret;
- }
- /**
- * Get security token by using credential
- * @return string security token
- */
- public function getSecurityToken()
- {
- if (Utils::isUnset($this->_credential)) {
- return '';
- }
- $token = $this->_credential->getSecurityToken();
- return $token;
- }
- /**
- * Get bearer token by credential
- * @return string bearer token
- */
- public function getBearerToken()
- {
- if (Utils::isUnset($this->_credential)) {
- return '';
- }
- $token = $this->_credential->getBearerToken();
- return $token;
- }
- /**
- * Get credential type by credential
- * @return string credential type e.g. access_key
- */
- public function getType()
- {
- if (Utils::isUnset($this->_credential)) {
- return '';
- }
- $authType = $this->_credential->getType();
- return $authType;
- }
- /**
- * If inputValue is not null, return it or return defaultValue
- * @param mixed $inputValue users input value
- * @param mixed $defaultValue default value
- * @return any the final result
- */
- public static function defaultAny($inputValue, $defaultValue)
- {
- if (Utils::isUnset($inputValue)) {
- return $defaultValue;
- }
- return $inputValue;
- }
- /**
- * If the endpointRule and config.endpoint are empty, throw error
- * @param \Darabonba\OpenApi\Models\Config $config config contains the necessary information to create a client
- * @return void
- * @throws TeaError
- */
- public function checkConfig($config)
- {
- if (Utils::empty_($this->_endpointRule) && Utils::empty_($config->endpoint)) {
- throw new TeaError([
- "code" => "ParameterMissing",
- "message" => "'config.endpoint' can not be empty"
- ]);
- }
- }
- /**
- * set gateway client
- * @param Client $spi
- * @return void
- */
- public function setGatewayClient($spi)
- {
- $this->_spi = $spi;
- }
- /**
- * set RPC header for debug
- * @param string[] $headers headers for debug, this header can be used only once.
- * @return void
- */
- public function setRpcHeaders($headers)
- {
- $this->_headers = $headers;
- }
- /**
- * get RPC header for debug
- * @return array
- */
- public function getRpcHeaders()
- {
- $headers = $this->_headers;
- $this->_headers = null;
- return $headers;
- }
- }
|