"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; } }