in cpp/src/open_api.cpp [66:277]
map<string, boost::any> Alibabacloud_OpenApi::Client::doRPCRequest(
shared_ptr<string> action, shared_ptr<string> version,
shared_ptr<string> protocol, shared_ptr<string> method,
shared_ptr<string> authType, shared_ptr<string> bodyType,
shared_ptr<OpenApiRequest> request,
shared_ptr<Darabonba_Util::RuntimeOptions> runtime) {
request->validate();
runtime->validate();
shared_ptr<map<string, boost::any>> runtime_ = make_shared<
map<string, boost::any>>(map<string, boost::any>(
{{"timeouted", boost::any(string("retry"))},
{"readTimeout", boost::any(Darabonba_Util::Client::defaultNumber(
runtime->readTimeout, _readTimeout))},
{"connectTimeout", boost::any(Darabonba_Util::Client::defaultNumber(
runtime->connectTimeout, _connectTimeout))},
{"httpProxy", boost::any(string(Darabonba_Util::Client::defaultString(
runtime->httpProxy, _httpProxy)))},
{"httpsProxy", boost::any(string(Darabonba_Util::Client::defaultString(
runtime->httpsProxy, _httpsProxy)))},
{"noProxy", boost::any(string(Darabonba_Util::Client::defaultString(
runtime->noProxy, _noProxy)))},
{"maxIdleConns", boost::any(Darabonba_Util::Client::defaultNumber(
runtime->maxIdleConns, _maxIdleConns))},
{"retry", boost::any(map<string, boost::any>(
{{"retryable", !runtime->autoretry
? boost::any()
: boost::any(*runtime->autoretry)},
{"maxAttempts",
boost::any(Darabonba_Util::Client::defaultNumber(
runtime->maxAttempts, make_shared<int>(3)))}}))},
{"backoff",
boost::any(map<string, boost::any>(
{{"policy",
boost::any(string(Darabonba_Util::Client::defaultString(
runtime->backoffPolicy, make_shared<string>("no"))))},
{"period", boost::any(Darabonba_Util::Client::defaultNumber(
runtime->backoffPeriod, make_shared<int>(1)))}}))},
{"ignoreSSL", !runtime->ignoreSSL ? boost::any()
: boost::any(*runtime->ignoreSSL)}}));
shared_ptr<Darabonba::Request> _lastRequest;
shared_ptr<std::exception> _lastException;
shared_ptr<int> _now = make_shared<int>(0);
shared_ptr<int> _retryTimes = make_shared<int>(0);
while (Darabonba::Core::allowRetry(
make_shared<boost::any>((*runtime_)["retry"]), _retryTimes, _now)) {
if (*_retryTimes > 0) {
shared_ptr<int> _backoffTime =
make_shared<int>(Darabonba::Core::getBackoffTime(
make_shared<boost::any>((*runtime_)["backoff"]), _retryTimes));
if (*_backoffTime > 0) {
Darabonba::Core::sleep(_backoffTime);
}
}
_retryTimes = make_shared<int>(*_retryTimes + 1);
try {
shared_ptr<Darabonba::Request> request_ =
make_shared<Darabonba::Request>();
request_->protocol =
Darabonba_Util::Client::defaultString(_protocol, protocol);
request_->method = *method;
request_->pathname = "/";
request_->query = Darabonba::Converter::merge(
map<string, string>(
{{"Action", !action ? string() : *action},
{"Format", "json"},
{"Version", !version ? string() : *version},
{"Timestamp", Alibabacloud_OpenApiUtil::Client::getTimestamp()},
{"SignatureNonce", Darabonba_Util::Client::getNonce()}}),
!request->query ? map<string, string>() : *request->query);
shared_ptr<map<string, string>> headers =
make_shared<map<string, string>>(getRpcHeaders());
if (Darabonba_Util::Client::isUnset<map<string, string>>(headers)) {
// endpoint is setted in product client
request_->headers = {{"host", !_endpoint ? string() : *_endpoint},
{"x-acs-version", !version ? string() : *version},
{"x-acs-action", !action ? string() : *action},
{"user-agent", getUserAgent()}};
} else {
request_->headers = Darabonba::Converter::merge(
map<string, string>(
{{"host", !_endpoint ? string() : *_endpoint},
{"x-acs-version", !version ? string() : *version},
{"x-acs-action", !action ? string() : *action},
{"user-agent", getUserAgent()}}),
!headers ? map<string, string>() : *headers);
}
if (!Darabonba_Util::Client::isUnset<boost::any>(request->body)) {
shared_ptr<map<string, boost::any>> m =
make_shared<map<string, boost::any>>(
Darabonba_Util::Client::assertAsMap(request->body));
shared_ptr<map<string, boost::any>> tmp =
make_shared<map<string, boost::any>>(
Darabonba_Util::Client::anyifyMapValue(
make_shared<map<string, string>>(
Alibabacloud_OpenApiUtil::Client::query(m))));
request_->body = Darabonba::Converter::toStream(
Darabonba_Util::Client::toFormString(tmp));
request_->headers.insert(pair<string, string>(
"content-type", "application/x-www-form-urlencoded"));
}
if (!Darabonba_Util::Client::equalString(
authType, make_shared<string>("Anonymous"))) {
shared_ptr<string> accessKeyId = make_shared<string>(getAccessKeyId());
shared_ptr<string> accessKeySecret =
make_shared<string>(getAccessKeySecret());
shared_ptr<string> securityToken =
make_shared<string>(getSecurityToken());
if (!Darabonba_Util::Client::empty(securityToken)) {
request_->query.insert(
pair<string, string>("SecurityToken", *securityToken));
}
request_->query.insert(
pair<string, string>("SignatureMethod", "HMAC-SHA1"));
request_->query.insert(pair<string, string>("SignatureVersion", "1.0"));
request_->query.insert(
pair<string, string>("AccessKeyId", *accessKeyId));
shared_ptr<map<string, boost::any>> t;
if (!Darabonba_Util::Client::isUnset<boost::any>(request->body)) {
t = make_shared<map<string, boost::any>>(
Darabonba_Util::Client::assertAsMap(request->body));
}
shared_ptr<map<string, string>> signedParam =
make_shared<map<string, string>>(Darabonba::Converter::merge(
map<string, string>(), request_->query,
Alibabacloud_OpenApiUtil::Client::query(t)));
request_->query.insert(pair<string, string>(
"Signature", Alibabacloud_OpenApiUtil::Client::getRPCSignature(
signedParam, make_shared<string>(request_->method),
accessKeySecret)));
}
_lastRequest = request_;
shared_ptr<Darabonba::Response> response_ =
make_shared<Darabonba::Response>(
Darabonba::Core::doAction(request_, runtime_));
if (Darabonba_Util::Client::is4xx(
make_shared<int>(response_->statusCode)) ||
Darabonba_Util::Client::is5xx(
make_shared<int>(response_->statusCode))) {
shared_ptr<boost::any> _res = make_shared<boost::any>(
Darabonba_Util::Client::readAsJSON(response_->body));
shared_ptr<map<string, boost::any>> err =
make_shared<map<string, boost::any>>(
Darabonba_Util::Client::assertAsMap(_res));
shared_ptr<boost::any> requestId = make_shared<boost::any>(
Client::defaultAny((*err)["RequestId"],
(*err)["requestId"]));
BOOST_THROW_EXCEPTION(Darabonba::Error(map<string, boost::any>(
{{"code", boost::any(string(
Darabonba::Converter::toString(Client::defaultAny(
(*err)["Code"],
(*err)["code"]))))},
{"message",
boost::any(
string("code: ") +
string(boost::lexical_cast<string>(response_->statusCode)) +
string(", ") +
string(Darabonba::Converter::toString(Client::defaultAny(
(*err)["Message"],
(*err)["message"]))) +
string(" request id: ") +
string(Darabonba::Converter::toString(requestId)))},
{"data", !err ? boost::any() : boost::any(*err)}})));
}
if (Darabonba_Util::Client::equalString(bodyType,
make_shared<string>("binary"))) {
shared_ptr<map<string, boost::any>> resp =
make_shared<map<string, boost::any>>(map<string, boost::any>(
{{"body", !response_->body ? boost::any()
: boost::any(*response_->body)},
{"headers", boost::any(response_->headers)}}));
return *resp;
} else if (Darabonba_Util::Client::equalString(
bodyType, make_shared<string>("byte"))) {
shared_ptr<vector<uint8_t>> byt = make_shared<vector<uint8_t>>(
Darabonba_Util::Client::readAsBytes(response_->body));
return {{"body", !byt ? boost::any() : boost::any(*byt)},
{"headers", boost::any(response_->headers)}};
} else if (Darabonba_Util::Client::equalString(
bodyType, make_shared<string>("string"))) {
shared_ptr<string> str = make_shared<string>(
Darabonba_Util::Client::readAsString(response_->body));
return {{"body", !str ? boost::any() : boost::any(*str)},
{"headers", boost::any(response_->headers)}};
} else if (Darabonba_Util::Client::equalString(
bodyType, make_shared<string>("json"))) {
shared_ptr<boost::any> obj = make_shared<boost::any>(
Darabonba_Util::Client::readAsJSON(response_->body));
shared_ptr<map<string, boost::any>> res =
make_shared<map<string, boost::any>>(
Darabonba_Util::Client::assertAsMap(obj));
return {{"body", !res ? boost::any() : boost::any(*res)},
{"headers", boost::any(response_->headers)}};
} else if (Darabonba_Util::Client::equalString(
bodyType, make_shared<string>("array"))) {
shared_ptr<boost::any> arr = make_shared<boost::any>(
Darabonba_Util::Client::readAsJSON(response_->body));
return {{"body", !arr ? boost::any() : boost::any(*arr)},
{"headers", boost::any(response_->headers)}};
} else {
return {{"headers", response_->headers}};
}
} catch (std::exception &e) {
if (Darabonba::Core::isRetryable(e)) {
_lastException = make_shared<std::exception>(e);
continue;
}
throw;
}
}
BOOST_THROW_EXCEPTION(
Darabonba::UnretryableError(_lastRequest, _lastException));
}