PhutilAWSFuture.php
View Options

	<?php

	abstract class PhutilAWSFuture extends FutureProxy {

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

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

	public function setData($data) {
	$this->data = $data;
	return $this;
	}

	public function getData() {
	return $this->data;
	}

	protected function getParameters() {
	return array();
	}

	public function addHeader($key, $value) {
	$this->headers[] = array($key, $value);
	return $this;
	}

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

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

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

	foreach ($this->headers as $header) {
	list($key, $value) = $header;
	$future->addHeader($key, $value);
	}

	$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)
	->setSignContent($this->shouldSignContent())
	->signRequest($future);
	}

	protected function shouldSignContent() {
	return false;
	}

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

	}

File Metadata

Mime Type: text/x-php
Expires: Mar 24 2025, 11:07 (7 w, 21 h ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1217142
Default Alt Text: PhutilAWSFuture.php (3 KB)

PhutilAWSFuture.php
No OneTemporary
Actions

PhutilAWSFuture.php
View Options

File Metadata

Event Timeline

PhutilAWSFuture.phpNo OneTemporaryActions

PhutilAWSFuture.phpView Options

File Metadata

Event Timeline

PhutilAWSFuture.php
No OneTemporary
Actions

PhutilAWSFuture.php
View Options