<?php
abstract class RoaAcsRequest extends AcsRequest
{
protected $uriPattern;
private $pathParameters = array();
private $domainParameters = array();
private $dateTimeFormat ="D, d M Y H:i:s \G\M\T";
private static $headerSeparator = "\n";
private static $querySeprator = "&";
function __construct($product, $version, $actionName, $locationServiceCode = null, $locationEndpointType = "openAPI")
{
parent::__construct($product, $version, $actionName, $locationServiceCode, $locationEndpointType);
$this->setVersion($version);
$this->initialize();
}
private function initialize()
{
$this->setMethod("RAW");
$this->setAcceptFormat("JSON");
}
public function composeUrl($iSigner, $credential, $domain)
{
$this->prepareHeader($iSigner);
$signString = $this->getMethod().self::$headerSeparator;
if (isset($this->headers["Accept"])) {
$signString = $signString.$this->headers["Accept"];
}
$signString = $signString.self::$headerSeparator;
if (isset($this->headers["Content-MD5"])) {
$signString = $signString.$this->headers["Content-MD5"];
}
$signString = $signString.self::$headerSeparator;
if (isset($this->headers["Content-Type"])) {
$signString = $signString.$this->headers["Content-Type"];
}
$signString = $signString.self::$headerSeparator;
if (isset($this->headers["Date"])) {
$signString = $signString.$this->headers["Date"];
}
$signString = $signString.self::$headerSeparator;
$uri = $this->replaceOccupiedParameters();
$signString = $signString.$this->buildCanonicalHeaders();
$queryString = $this->buildQueryString($uri);
$signString .= $queryString;
$this->headers["Authorization"] = "acs ".$credential->getAccessKeyId().":"
.$iSigner->signString($signString, $credential->getAccessSecret());
$requestUrl = $this->getProtocol()."://".$domain.$uri.$this->concatQueryString();
return $requestUrl;
}
private function concatQueryString() {
$sortMap = $this->queryParameters;
if(null == $sortMap || count($sortMap) == 0){
return "";
}
$queryString ="";
ksort($sortMap);
foreach ($sortMap as $sortMapKey => $sortMapValue) {
$queryString = $queryString.$sortMapKey;
if (isset($sortMapValue)) {
$queryString = $queryString."=".urlencode($sortMapValue);
}
$queryString .= self::$querySeprator;
}
if (count($sortMap) > 0) {
$queryString = substr($queryString, 0, strlen($queryString)-1);
}
return '?'.$queryString;
}
private function prepareHeader($iSigner)
{
$this->headers["Date"] = gmdate($this->dateTimeFormat);
if (null == $this->acceptFormat) {
$this->acceptFormat = "RAW";
}
$this->headers["Accept"] = $this->formatToAccept($this->getAcceptFormat());
$this->headers["x-acs-signature-method"] = $iSigner->getSignatureMethod();
$this->headers["x-acs-signature-version"] = $iSigner->getSignatureVersion();
$this->headers["x-acs-region-id"] = $this->regionId;
$content = $this->getContent();
if ($content != null) {
$this->headers["Content-MD5"] = base64_encode(md5($content, true));
}
$this->headers["Content-Type"] = "application/json;charset=utf-8";
}
private function replaceOccupiedParameters()
{
$result = $this->uriPattern;
foreach ($this->pathParameters as $pathParameterKey => $apiParameterValue) {
$target = "[".$pathParameterKey."]";
$result = str_replace($target, $apiParameterValue, $result);
}
return $result;
}
private function buildCanonicalHeaders()
{
$sortMap = array();
foreach ($this->headers as $headerKey => $headerValue) {
$key = strtolower($headerKey);
if (strpos($key, "x-acs-") === 0) {
$sortMap[$key] = $headerValue;
}
}
ksort($sortMap);
$headerString = "";
foreach ($sortMap as $sortMapKey => $sortMapValue) {
$headerString = $headerString.$sortMapKey.":".$sortMapValue.self::$headerSeparator;
}
return $headerString;
}
private function splitSubResource($uri)
{
$queIndex = strpos($uri, "?");
$uriParts = array();
if (null != $queIndex) {
array_push($uriParts, substr($uri, 0, $queIndex));
array_push($uriParts, substr($uri, $queIndex+1));
} else {
array_push($uriParts, $uri);
}
return $uriParts;
}
private function buildQueryString($uri)
{
$uriParts = $this->splitSubResource($uri);
$sortMap = $this->queryParameters;
if (isset($uriParts[1])) {
$sortMap[$uriParts[1]] = null;
}
$queryString = $uriParts[0];
if (count($sortMap) > 0) {
$queryString = $queryString."?";
}
ksort($sortMap);
foreach ($sortMap as $sortMapKey => $sortMapValue) {
$queryString = $queryString.$sortMapKey;
if (isset($sortMapValue)) {
$queryString = $queryString."=".$sortMapValue;
}
$queryString = $queryString.self::$querySeprator;
}
if (count($sortMap) > 0) {
$queryString = substr($queryString, 0, strlen($queryString)-1);
}
return $queryString;
}
private function formatToAccept($acceptFormat)
{
if ($acceptFormat == "JSON") {
return "application/json";
} elseif ($acceptFormat == "XML") {
return "application/xml";
}
return "application/octet-stream";
}
public function getPathParameters()
{
return $this->pathParameters;
}
public function putPathParameter($name, $value)
{
$this->pathParameters[$name] = $value;
}
public function getDomainParameter()
{
return $this->domainParameters;
}
public function putDomainParameters($name, $value)
{
$this->domainParameters[$name] = $value;
}
public function getUriPattern()
{
return $this->uriPattern;
}
public function setUriPattern($uriPattern)
{
return $this->uriPattern = $uriPattern;
}
public function setVersion($version)
{
$this->version = $version;
$this->headers["x-acs-version"] = $version;
}
}