PhutilAWSFuture.php
d6744fb71561production

PhutilAWSFuture.php
View Options

			<?php

			abstract class PhutilAWSFuture extends FutureProxy {

			private $future;
			private $accessKey;
			private $secretKey;
			private $region;
			private $httpMethod = 'GET';
			private $path = '/';
			private $params = array();
			private $endpoint;

			abstract public function getServiceName();

			public function __construct() {
			parent::__construct(null);
			}

			public function setAccessKey($access_key) {
			$this->accessKey = $access_key;
			return $this;
			}

			public function getAccessKey() {
			return $this->accessKey;
			}

			public function setSecretKey(PhutilOpaqueEnvelope $secret_key) {
			$this->secretKey = $secret_key;
			return $this;
			}

			public function getSecretKey() {
			return $this->secretKey;
			}

			public function getRegion() {
			return $this->region;
			}

			public function setRegion($region) {
			$this->region = $region;
			return $this;
			}

			public function setEndpoint($endpoint) {
			$this->endpoint = $endpoint;
			return $this;
			}

			public function getEndpoint() {
			return $this->endpoint;
			}

			public function setHTTPMethod($method) {
			$this->httpMethod = $method;
			return $this;
			}

			public function getHTTPMethod() {
			return $this->httpMethod;
			}

			public function setPath($path) {
			$this->path = $path;
			return $this;
			}

			public function getPath() {
			return $this->path;
			}

			protected function getParameters() {
			$params = $this->params;
			return $params;
			}

			protected function getProxiedFuture() {
			if (!$this->future) {
			$params = $this->getParameters();
			$method = $this->getHTTPMethod();
			$host = $this->getEndpoint();
			$path = $this->getPath();

			$uri = id(new PhutilURI("https://{$host}/"))
			->setPath($path)
			->setQueryParams($params);

			$future = id(new HTTPSFuture($uri))
			->setMethod($method);

			$this->signRequest($future);

			$this->future = $future;
			}

			return $this->future;
			}

			protected function signRequest(HTTPSFuture $future) {
			$access_key = $this->getAccessKey();
			$secret_key = $this->getSecretKey();

			$region = $this->getRegion();

			id(new PhutilAWSv4Signature())
			->setRegion($region)
			->setService($this->getServiceName())
			->setAccessKey($access_key)
			->setSecretKey($secret_key)
			->signRequest($future);
			}

			protected function didReceiveResult($result) {
			list($status, $body, $headers) = $result;

			try {
			$xml = @(new SimpleXMLElement($body));
			} catch (Exception $ex) {
			$xml = null;
			}

			if ($status->isError() \|\| !$xml) {
			if (!($status instanceof HTTPFutureHTTPResponseStatus)) {
			throw $status;
			}

			$params = array(
			'body' => $body,
			);
			if ($xml) {
			$params['RequestID'] = $xml->RequestID[0];
			$errors = array($xml->Error);
			foreach ($errors as $error) {
			$params['Errors'][] = array($error->Code, $error->Message);
			}
			}

			throw new PhutilAWSException($status->getStatusCode(), $params);
			}

			return $xml;
			}

			}

libphutil/src/future/aws/PhutilAWSFuture.phpd6744fb71561production

PhutilAWSFuture.phpView Options

libphutil/src/future/aws/PhutilAWSFuture.php
d6744fb71561production

PhutilAWSFuture.php
View Options