summaryrefslogtreecommitdiffstats
path: root/src/etc/inc/r53.class
diff options
context:
space:
mode:
authorJason McCormick <jason@mfamily.org>2016-08-30 22:06:57 -0400
committerJason McCormick <jason@mfamily.org>2016-08-30 22:06:57 -0400
commitcc5adcaa679686e54e4035fa5bc283b1cac085a2 (patch)
treec4ac7216d7a21e9055621002edf39d7125bb5f95 /src/etc/inc/r53.class
parentb947efe847b8529c15b862cf26acce4eec9f455e (diff)
downloadpfsense-cc5adcaa679686e54e4035fa5bc283b1cac085a2.zip
pfsense-cc5adcaa679686e54e4035fa5bc283b1cac085a2.tar.gz
initial commit of code -- having a signing error
Diffstat (limited to 'src/etc/inc/r53.class')
-rw-r--r--src/etc/inc/r53.class754
1 files changed, 0 insertions, 754 deletions
diff --git a/src/etc/inc/r53.class b/src/etc/inc/r53.class
deleted file mode 100644
index 89faa26..0000000
--- a/src/etc/inc/r53.class
+++ /dev/null
@@ -1,754 +0,0 @@
-<?php
-/**
-*
-* Copyright (c) 2011, Dan Myers.
-* Parts copyright (c) 2008, Donovan Schonknecht.
-* All rights reserved.
-*
-* Redistribution and use in source and binary forms, with or without
-* modification, are permitted provided that the following conditions are met:
-*
-* - Redistributions of source code must retain the above copyright notice,
-* this list of conditions and the following disclaimer.
-* - Redistributions in binary form must reproduce the above copyright
-* notice, this list of conditions and the following disclaimer in the
-* documentation and/or other materials provided with the distribution.
-*
-* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
-* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
-* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
-* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
-* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
-* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
-* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
-* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
-* POSSIBILITY OF SUCH DAMAGE.
-*
-* This is a modified BSD license (the third clause has been removed).
-* The BSD license may be found here:
-* http://www.opensource.org/licenses/bsd-license.php
-*
-* Amazon Route 53 is a trademark of Amazon.com, Inc. or its affiliates.
-*
-* Route53 is based on Donovan Schonknecht's Amazon S3 PHP class, found here:
-* http://undesigned.org.za/2007/10/22/amazon-s3-php-class
-*
-*/
-
-/**
-* Amazon Route53 PHP class
-*
-* @link http://sourceforge.net/projects/php-r53/
-* version 0.9.0
-*
-*/
-class Route53
-{
- const API_VERSION = '2010-10-01';
-
- protected $__accessKey; // AWS Access key
- protected $__secretKey; // AWS Secret key
- protected $__host;
-
- public function getAccessKey() { return $this->__accessKey; }
- public function getSecretKey() { return $this->__secretKey; }
- public function getHost() { return $this->__host; }
-
- protected $__verifyHost = 1;
- protected $__verifyPeer = 1;
-
- // verifyHost and verifyPeer determine whether curl verifies ssl certificates.
- // It may be necessary to disable these checks on certain systems.
- // These only have an effect if SSL is enabled.
- public function verifyHost() { return $this->__verifyHost; }
- public function enableVerifyHost($enable = true) { $this->__verifyHost = $enable; }
-
- public function verifyPeer() { return $this->__verifyPeer; }
- public function enableVerifyPeer($enable = true) { $this->__verifyPeer = $enable; }
-
- /**
- * Constructor
- *
- * @param string $accessKey Access key
- * @param string $secretKey Secret key
- * @return void
- */
- public function __construct($accessKey = null, $secretKey = null, $host = 'route53.amazonaws.com') {
- if ($accessKey !== null && $secretKey !== null) {
- $this->setAuth($accessKey, $secretKey);
- }
- $this->__host = $host;
- }
-
- /**
- * Set AWS access key and secret key
- *
- * @param string $accessKey Access key
- * @param string $secretKey Secret key
- * @return void
- */
- public function setAuth($accessKey, $secretKey) {
- $this->__accessKey = $accessKey;
- $this->__secretKey = $secretKey;
- }
-
- /**
- * Lists the hosted zones on the account
- *
- * @param string marker A pagination marker returned by a previous truncated call
- * @param int maxItems The maximum number of items per page. The service uses min($maxItems, 100).
- * @return A list of hosted zones
- */
- public function listHostedZones($marker = null, $maxItems = 100) {
- $rest = new Route53Request($this, 'hostedzone', 'GET');
-
- if($marker !== null) {
- $rest->setParameter('marker', $marker);
- }
- if($maxItems !== 100) {
- $rest->setParameter('maxitems', $maxItems);
- }
-
- $rest = $rest->getResponse();
- if($rest->error === false && $rest->code !== 200) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('listHostedZones', $rest->error);
- return false;
- }
-
- $response = array();
- if (!isset($rest->body))
- {
- return $response;
- }
-
- $zones = array();
- foreach($rest->body->HostedZones->HostedZone as $z)
- {
- $zones[] = $this->parseHostedZone($z);
- }
- $response['HostedZone'] = $zones;
-
- if(isset($rest->body->MaxItems)) {
- $response['MaxItems'] = (string)$rest->body->MaxItems;
- }
-
- if(isset($rest->body->IsTruncated)) {
- $response['IsTruncated'] = (string)$rest->body->IsTruncated;
- if($response['IsTruncated'] == 'true') {
- $response['NextMarker'] = (string)$rest->body->NextMarker;
- }
- }
-
- return $response;
- }
-
- /**
- * Retrieves information on a specified hosted zone
- *
- * @param string zoneId The id of the hosted zone, as returned by CreateHostedZoneResponse or ListHostedZoneResponse
- * In other words, if ListHostedZoneResponse shows the zone's Id as '/hostedzone/Z1PA6795UKMFR9',
- * then that full value should be passed here, including the '/hostedzone/' prefix.
- * @return A data structure containing information about the specified zone
- */
- public function getHostedZone($zoneId) {
- // we'll strip off the leading forward slash, so we can use it as the action directly.
- $zoneId = trim($zoneId, '/');
-
- $rest = new Route53Request($this, $zoneId, 'GET');
-
- $rest = $rest->getResponse();
- if($rest->error === false && $rest->code !== 200) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('getHostedZone', $rest->error);
- return false;
- }
-
- $response = array();
- if (!isset($rest->body))
- {
- return $response;
- }
-
- $response['HostedZone'] = $this->parseHostedZone($rest->body->HostedZone);
- $response['NameServers'] = $this->parseDelegationSet($rest->body->DelegationSet);
-
- return $response;
- }
-
- /**
- * Creates a new hosted zone
- *
- * @param string name The name of the hosted zone (e.g. "example.com.")
- * @param string reference A user-specified unique reference for this request
- * @param string comment An optional user-specified comment to attach to the zone
- * @return A data structure containing information about the newly created zone
- */
- public function createHostedZone($name, $reference, $comment = '') {
- // hosted zone names must end with a period, but people will forget this a lot...
- if(strrpos($name, '.') != (strlen($name) - 1)) {
- $name .= '.';
- }
-
- $data = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
- $data .= '<CreateHostedZoneRequest xmlns="https://route53.amazonaws.com/doc/'.Route53::API_VERSION."/\">\n";
- $data .= '<Name>'.$name."</Name>\n";
- $data .= '<CallerReference>'.$reference."</CallerReference>\n";
- if(strlen($comment) > 0) {
- $data .= "<HostedZoneConfig>\n";
- $data .= '<Comment>'.$comment."</Comment>\n";
- $data .= "</HostedZoneConfig>\n";
- }
- $data .= "</CreateHostedZoneRequest>\n";
-
- $rest = new Route53Request($this, 'hostedzone', 'POST', $data);
-
- $rest = $rest->getResponse();
-
- if($rest->error === false && !in_array($rest->code, array(200, 201, 202, 204)) ) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('createHostedZone', $rest->error);
- return false;
- }
-
- $response = array();
- if (!isset($rest->body))
- {
- return $response;
- }
-
- $response['HostedZone'] = $this->parseHostedZone($rest->body->HostedZone);
- $response['ChangeInfo'] = $this->parseChangeInfo($rest->body->ChangeInfo);
- $response['NameServers'] = $this->parseDelegationSet($rest->body->DelegationSet);
-
- return $response;
- }
-
- /**
- * Retrieves information on a specified hosted zone
- *
- * @param string zoneId The id of the hosted zone, as returned by CreateHostedZoneResponse or ListHostedZoneResponse
- * In other words, if ListHostedZoneResponse shows the zone's Id as '/hostedzone/Z1PA6795UKMFR9',
- * then that full value should be passed here, including the '/hostedzone/' prefix.
- * @return The change request data corresponding to this delete
- */
- public function deleteHostedZone($zoneId) {
- // we'll strip off the leading forward slash, so we can use it as the action directly.
- $zoneId = trim($zoneId, '/');
-
- $rest = new Route53Request($this, $zoneId, 'DELETE');
-
- $rest = $rest->getResponse();
- if($rest->error === false && $rest->code !== 200) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('deleteHostedZone', $rest->error);
- return false;
- }
-
- if (!isset($rest->body))
- {
- return array();
- }
-
- return $this->parseChangeInfo($rest->body->ChangeInfo);
- }
-
- /**
- * Retrieves a list of resource record sets for a given zone
- *
- * @param string zoneId The id of the hosted zone, as returned by CreateHostedZoneResponse or ListHostedZoneResponse
- * In other words, if ListHostedZoneResponse shows the zone's Id as '/hostedzone/Z1PA6795UKMFR9',
- * then that full value should be passed here, including the '/hostedzone/' prefix.
- * @param string type The type of resource record set to begin listing from. If this is specified, $name must also be specified.
- * Must be one of: A, AAAA, CNAME, MX, NS, PTR, SOA, SPF, SRV, TXT
- * @param string name The name at which to begin listing resource records (in the lexographic order of records).
- * @param int maxItems The maximum number of results to return. The service uses min($maxItems, 100).
- * @return The list of matching resource record sets
- */
- public function listResourceRecordSets($zoneId, $type = '', $name = '', $maxItems = 100) {
- // we'll strip off the leading forward slash, so we can use it as the action directly.
- $zoneId = trim($zoneId, '/');
-
- $rest = new Route53Request($this, $zoneId.'/rrset', 'GET');
-
- if(strlen($type) > 0) {
- $rest->setParameter('type', $type);
- }
- if(strlen($name) > 0) {
- $rest->setParameter('name', $name);
- }
- if($maxItems != 100) {
- $rest->setParameter('maxitems', $maxItems);
- }
-
- $rest = $rest->getResponse();
- if($rest->error === false && $rest->code !== 200) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('listResourceRecordSets', $rest->error);
- return false;
- }
-
- $response = array();
- if (!isset($rest->body))
- {
- return $response;
- }
-
- $recordSets = array();
- foreach($rest->body->ResourceRecordSets->ResourceRecordSet as $set) {
- $recordSets[] = $this->parseResourceRecordSet($set);
- }
-
- $response['ResourceRecordSets'] = $recordSets;
-
- if(isset($rest->body->MaxItems)) {
- $response['MaxItems'] = (string)$rest->body->MaxItems;
- }
-
- if(isset($rest->body->IsTruncated)) {
- $response['IsTruncated'] = (string)$rest->body->IsTruncated;
- if($response['IsTruncated'] == 'true') {
- $response['NextRecordName'] = (string)$rest->body->NextRecordName;
- $response['NextRecordType'] = (string)$rest->body->NextRecordType;
- }
- }
-
- return $response;
- }
-
- /**
- * Makes the specified resource record set changes (create or delete).
- *
- * @param string zoneId The id of the hosted zone, as returned by CreateHostedZoneResponse or ListHostedZoneResponse
- * In other words, if ListHostedZoneResponse shows the zone's Id as '/hostedzone/Z1PA6795UKMFR9',
- * then that full value should be passed here, including the '/hostedzone/' prefix.
- * @param array changes An array of change objects, as they are returned by the prepareChange utility method.
- * You may also pass a single change object.
- * @param string comment An optional comment to attach to the change request
- * @return The status of the change request
- */
- public function changeResourceRecordSets($zoneId, $changes, $comment = '') {
- // we'll strip off the leading forward slash, so we can use it as the action directly.
- $zoneId = trim($zoneId, '/');
-
- $data = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n";
- $data .= '<ChangeResourceRecordSetsRequest xmlns="https://route53.amazonaws.com/doc/'.Route53::API_VERSION."/\">\n";
- $data .= "<ChangeBatch>\n";
-
- if(strlen($comment) > 0) {
- $data .= '<Comment>'.$comment."</Comment>\n";
- }
-
- if(!is_array($changes)) {
- $changes = array($changes);
- }
-
- $data .= "<Changes>\n";
- foreach($changes as $change) {
- $data .= $change;
- }
- $data .= "</Changes>\n";
-
- $data .= "</ChangeBatch>\n";
- $data .= "</ChangeResourceRecordSetsRequest>\n";
-
- $rest = new Route53Request($this, $zoneId.'/rrset', 'POST', $data);
-
- $rest = $rest->getResponse();
- if($rest->error === false && !in_array($rest->code, array(200, 201, 202, 204))) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('changeResourceRecordSets', $rest->error);
- return false;
- }
-
- if (!isset($rest->body))
- {
- return array();
- }
-
- return $this->parseChangeInfo($rest->body->ChangeInfo);
- }
-
- /**
- * Retrieves information on a specified change request
- *
- * @param string changeId The id of the change, as returned by CreateHostedZoneResponse or ChangeResourceRecordSets
- * In other words, if CreateHostedZoneResponse showed the change's Id as '/change/C2682N5HXP0BZ4',
- * then that full value should be passed here, including the '/change/' prefix.
- * @return The status of the change request
- */
- public function getChange($changeId) {
- // we'll strip off the leading forward slash, so we can use it as the action directly.
- $zoneId = trim($changeId, '/');
-
- $rest = new Route53Request($this, $changeId, 'GET');
-
- $rest = $rest->getResponse();
- if($rest->error === false && $rest->code !== 200) {
- $rest->error = array('code' => $rest->code, 'message' => 'Unexpected HTTP status');
- }
- if($rest->error !== false) {
- $this->__triggerError('getChange', $rest->error);
- return false;
- }
-
- if (!isset($rest->body))
- {
- return array();
- }
-
- return $this->parseChangeInfo($rest->body->ChangeInfo);
- }
-
-
-
- /**
- * Utility function to parse a HostedZone tag structure
- */
- private function parseHostedZone($tag) {
- $zone = array();
- $zone['Id'] = (string)$tag->Id;
- $zone['Name'] = (string)$tag->Name;
- $zone['CallerReference'] = (string)$tag->CallerReference;
-
- // these might always be set, but check just in case, since
- // their values are option on CreateHostedZone requests
- if(isset($tag->Config) && isset($tag->Config->Comment)) {
- $zone['Config'] = array('Comment' => (string)$tag->Config->Comment);
- }
-
- return $zone;
- }
-
- /**
- * Utility function to parse a ChangeInfo tag structure
- */
- private function parseChangeInfo($tag) {
- $info = array();
- $info['Id'] = (string)$tag->Id;
- $info['Status'] = (string)$tag->Status;
- $info['SubmittedAt'] = (string)$tag->SubmittedAt;
- return $info;
- }
-
- /**
- * Utility function to parse a DelegationSet tag structure
- */
- private function parseDelegationSet($tag) {
- $servers = array();
- foreach($tag->NameServers->NameServer as $ns) {
- $servers[] = (string)$ns;
- }
- return $servers;
- }
-
- /**
- * Utility function to parse a ResourceRecordSet tag structure
- */
- private function parseResourceRecordSet($tag) {
- $rrs = array();
- $rrs['Name'] = (string)$tag->Name;
- $rrs['Type'] = (string)$tag->Type;
- $rrs['TTL'] = (string)$tag->TTL;
- $rrs['ResourceRecords'] = array();
- foreach($tag->ResourceRecords->ResourceRecord as $rr) {
- $rrs['ResourceRecords'][] = (string)$rr->Value;
- }
- return $rrs;
- }
-
- /**
- * Utility function to prepare a Change object for ChangeResourceRecordSets requests.
- * All fields are required.
- *
- * @param string action The action to perform. One of: CREATE, DELETE
- * @param string name The name to perform the action on.
- * If it does not end with '.', then AWS treats the name as relative to the zone root.
- * @param string type The type of record being modified.
- * Must be one of: A, AAAA, CNAME, MX, NS, PTR, SOA, SPF, SRV, TXT
- * @param int ttl The time-to-live value for this record, in seconds.
- * @param array records An array of resource records to attach to this change.
- * Each member of this array can either be a string, or an array of strings.
- * Passing an array of strings will attach multiple values to a single resource record.
- * If a single string is passed as $records instead of an array,
- * it will be treated as a single-member array.
- * @return object An opaque object containing the change request.
- * Do not write code that depends on the contents of this object, as it may change at any time.
- */
- public function prepareChange($action, $name, $type, $ttl, $records) {
- $change = "<Change>\n";
- $change .= '<Action>'.$action."</Action>\n";
- $change .= "<ResourceRecordSet>\n";
- $change .= '<Name>'.$name."</Name>\n";
- $change .= '<Type>'.$type."</Type>\n";
- $change .= '<TTL>'.$ttl."</TTL>\n";
- $change .= "<ResourceRecords>\n";
-
- if(!is_array($records)) {
- $records = array($records);
- }
-
- foreach($records as $record) {
- $change .= "<ResourceRecord>\n";
- if(is_array($record)) {
- foreach($record as $value) {
- $change .= '<Value>'.$value."</Value>\n";
- }
- }
- else {
- $change .= '<Value>'.$record."</Value>\n";
- }
- $change .= "</ResourceRecord>\n";
- }
-
- $change .= "</ResourceRecords>\n";
- $change .= "</ResourceRecordSet>\n";
- $change .= "</Change>\n";
-
- return $change;
- }
-
- /**
- * Trigger an error message
- *
- * @internal Used by member functions to output errors
- * @param array $error Array containing error information
- * @return string
- */
- public function __triggerError($functionname, $error)
- {
- if($error == false) {
- trigger_error(sprintf("Route53::%s(): Encountered an error, but no description given", $functionname), E_USER_WARNING);
- }
- else if(isset($error['curl']) && $error['curl'])
- {
- trigger_error(sprintf("Route53::%s(): %s %s", $functionname, $error['code'], $error['message']), E_USER_WARNING);
- }
- else if(isset($error['Error']))
- {
- $e = $error['Error'];
- $message = sprintf("Route53::%s(): %s - %s: %s\nRequest Id: %s\n", $functionname, $e['Type'], $e['Code'], $e['Message'], $error['RequestId']);
- trigger_error($message, E_USER_WARNING);
- }
- }
-
- /**
- * Callback handler for 503 retries.
- *
- * @internal Used by SimpleDBRequest to call the user-specified callback, if set
- * @param $attempt The number of failed attempts so far
- * @return The retry delay in microseconds, or 0 to stop retrying.
- */
- public function __executeServiceTemporarilyUnavailableRetryDelay($attempt)
- {
- if(is_callable($this->__serviceUnavailableRetryDelayCallback)) {
- $callback = $this->__serviceUnavailableRetryDelayCallback;
- return $callback($attempt);
- }
- return 0;
- }
-}
-
-final class Route53Request
-{
- private $r53, $action, $verb, $data, $parameters = array();
- public $response;
-
- /**
- * Constructor
- *
- * @param string $r53 The Route53 object making this request
- * @param string $action SimpleDB action
- * @param string $verb HTTP verb
- * @param string $data For POST requests, the data being posted (optional)
- * @return mixed
- */
- function __construct($r53, $action, $verb, $data = '') {
- $this->r53 = $r53;
- $this->action = $action;
- $this->verb = $verb;
- $this->data = $data;
- $this->response = new STDClass;
- $this->response->error = false;
- }
-
- /**
- * Set request parameter
- *
- * @param string $key Key
- * @param string $value Value
- * @param boolean $replace Whether to replace the key if it already exists (default true)
- * @return void
- */
- public function setParameter($key, $value, $replace = true) {
- if(!$replace && isset($this->parameters[$key]))
- {
- $temp = (array)($this->parameters[$key]);
- $temp[] = $value;
- $this->parameters[$key] = $temp;
- }
- else
- {
- $this->parameters[$key] = $value;
- }
- }
-
- /**
- * Get the response
- *
- * @return object | false
- */
- public function getResponse() {
-
- $params = array();
- foreach ($this->parameters as $var => $value)
- {
- if(is_array($value))
- {
- foreach($value as $v)
- {
- $params[] = $var.'='.$this->__customUrlEncode($v);
- }
- }
- else
- {
- $params[] = $var.'='.$this->__customUrlEncode($value);
- }
- }
-
- sort($params, SORT_STRING);
-
- $query = implode('&', $params);
-
- // must be in format 'Sun, 06 Nov 1994 08:49:37 GMT'
- $date = gmdate('D, d M Y H:i:s e');
-
- $headers = array();
- $headers[] = 'Date: '.$date;
- $headers[] = 'Host: '.$this->r53->getHost();
-
- $auth = 'AWS3-HTTPS AWSAccessKeyId='.$this->r53->getAccessKey();
- $auth .= ',Algorithm=HmacSHA256,Signature='.$this->__getSignature($date);
- $headers[] = 'X-Amzn-Authorization: '.$auth;
-
- $url = 'https://'.$this->r53->getHost().'/'.Route53::API_VERSION.'/'.$this->action.'?'.$query;
-
- // Basic setup
- $curl = curl_init();
- curl_setopt($curl, CURLOPT_USERAGENT, 'Route53/php');
-
- curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, ($this->r53->verifyHost() ? 1 : 0));
- curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, ($this->r53->verifyPeer() ? 1 : 0));
-
- curl_setopt($curl, CURLOPT_URL, $url);
- curl_setopt($curl, CURLOPT_RETURNTRANSFER, false);
- curl_setopt($curl, CURLOPT_WRITEFUNCTION, array(&$this, '__responseWriteCallback'));
- curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
-
- // Request types
- switch ($this->verb) {
- case 'GET': break;
- case 'POST':
- curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $this->verb);
- if(strlen($this->data) > 0) {
- curl_setopt($curl, CURLOPT_POSTFIELDS, $this->data);
- $headers[] = 'Content-Type: text/plain';
- $headers[] = 'Content-Length: '.strlen($this->data);
- }
- break;
- case 'DELETE':
- curl_setopt($curl, CURLOPT_CUSTOMREQUEST, 'DELETE');
- break;
- default: break;
- }
- curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
- curl_setopt($curl, CURLOPT_HEADER, false);
-
- // Execute, grab errors
- if (curl_exec($curl)) {
- $this->response->code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
- } else {
- $this->response->error = array(
- 'curl' => true,
- 'code' => curl_errno($curl),
- 'message' => curl_error($curl),
- 'resource' => $this->resource
- );
- }
-
- @curl_close($curl);
-
- // Parse body into XML
- if ($this->response->error === false && isset($this->response->body)) {
- $this->response->body = simplexml_load_string($this->response->body);
-
- // Grab Route53 errors
- if (!in_array($this->response->code, array(200, 201, 202, 204))
- && isset($this->response->body->Error)) {
- $error = $this->response->body->Error;
- $output = array();
- $output['curl'] = false;
- $output['Error'] = array();
- $output['Error']['Type'] = (string)$error->Type;
- $output['Error']['Code'] = (string)$error->Code;
- $output['Error']['Message'] = (string)$error->Message;
- $output['RequestId'] = (string)$this->response->body->RequestId;
-
- $this->response->error = $output;
- unset($this->response->body);
- }
- }
-
- return $this->response;
- }
-
- /**
- * CURL write callback
- *
- * @param resource &$curl CURL resource
- * @param string &$data Data
- * @return integer
- */
- private function __responseWriteCallback(&$curl, &$data) {
- $this->response->body .= $data;
- return strlen($data);
- }
-
- /**
- * Contributed by afx114
- * URL encode the parameters as per http://docs.amazonwebservices.com/AWSECommerceService/latest/DG/index.html?Query_QueryAuth.html
- * PHP's rawurlencode() follows RFC 1738, not RFC 3986 as required by Amazon. The only difference is the tilde (~), so convert it back after rawurlencode
- * See: http://www.morganney.com/blog/API/AWS-Product-Advertising-API-Requires-a-Signed-Request.php
- *
- * @param string $var String to encode
- * @return string
- */
- private function __customUrlEncode($var) {
- return str_replace('%7E', '~', rawurlencode($var));
- }
-
- /**
- * Generate the auth string using Hmac-SHA256
- *
- * @internal Used by SimpleDBRequest::getResponse()
- * @param string $string String to sign
- * @return string
- */
- private function __getSignature($string) {
- return base64_encode(hash_hmac('sha256', $string, $this->r53->getSecretKey(), true));
- }
-}
OpenPOWER on IntegriCloud