Rewrite to composer package

composer require gullevek/amazon-incentives
2021-10-21 09:55:32 +09:00
parent 94ea118731
commit 6f9bf781f2
23 changed files with 814 additions and 147 deletions
--- a/src/Client/Client.php
+++ b/src/Client/Client.php
@@ -0,0 +1,108 @@
+<?php
+
+namespace gullevek\AmazonIncentives\Client;
+
+use gullevek\AmazonIncentives\Exceptions\AmazonErrors;
+use gullevek\AmazonIncentives\Debug\AmazonDebug;
+
+class Client implements ClientInterface
+{
+	// instead of JsonResponse::HTTP_OK
+	private const HTTP_OK = 200;
+
+	/**
+	 *
+	 * @param string $url The URL being requested, including domain and protocol
+	 * @param array $headers Headers to be used in the request
+	 * @param array|string $params Can be nested for arrays and hashes
+	 *
+	 *
+	 * @return String
+	 */
+	public function request(string $url, array $headers, $params): string
+	{
+		$handle = curl_init($url);
+		curl_setopt($handle, CURLOPT_POST, true);
+		curl_setopt($handle, CURLOPT_HTTPHEADER, $headers);
+		// curl_setopt($handle, CURLOPT_FAILONERROR, true);
+		curl_setopt($handle, CURLOPT_POSTFIELDS, $params);
+		curl_setopt($handle, CURLOPT_RETURNTRANSFER, true);
+		$result = curl_exec($handle);
+
+		if ($result === false) {
+			$err = curl_errno($handle);
+			$message = curl_error($handle);
+			$this->handleCurlError($url, $err, $message);
+		}
+
+		if (curl_getinfo($handle, CURLINFO_HTTP_CODE) !== self::HTTP_OK) {
+			$err = curl_errno($handle);
+			AmazonDebug::writeLog(['CURL_REQUEST_RESULT' => $result]);
+			// extract all the error codes from Amazon
+			$result_ar = json_decode($result, true);
+			// if message is 'Rate exceeded', set different error
+			if (($result_ar['message'] ?? '') == 'Rate exceeded') {
+				$error_status = 'RESEND';
+				$error_code = 'T001';
+				$error_type = 'RateExceeded';
+				$message = $result_ar['message'];
+			} else {
+				// for all other error messages
+				$error_status = $result_ar['agcodResponse']['status'] ?? 'FAILURE';
+				$error_code = $result_ar['errorCode'] ?? 'E999';
+				$error_type = $result_ar['errorType'] ?? 'OtherUnknownError';
+				$message = $result_ar['message'] ?? 'Unknown error occured';
+			}
+			// throw Error here with all codes
+			throw AmazonErrors::getError(
+				$error_status,
+				$error_code,
+				$error_type,
+				$message,
+				$err
+			);
+		}
+		return $result;
+	}
+
+	/**
+	 * Undocumented function
+	 *
+	 * @param string $url
+	 * @param string $errno
+	 * @param string $message
+	 * @return void
+	 */
+	private function handleCurlError(string $url, int $errno, string $message): void
+	{
+		switch ($errno) {
+			case CURLE_COULDNT_CONNECT:
+			case CURLE_COULDNT_RESOLVE_HOST:
+			case CURLE_OPERATION_TIMEOUTED:
+				$message = 'Could not connect to AWS (' . $url . ').  Please check your '
+					. 'internet connection and try again. [' . $message . ']';
+				break;
+			case CURLE_SSL_CACERT:
+			case CURLE_SSL_PEER_CERTIFICATE:
+				$message = 'Could not verify AWS SSL certificate.  Please make sure '
+					. 'that your network is not intercepting certificates.  '
+					. '(Try going to ' . $url . 'in your browser.)  '
+					. '[' . $message . ']';
+				break;
+			case 0:
+			default:
+				$message = 'Unexpected error communicating with AWS: ' . $message;
+		}
+
+		// throw an error like in the normal reqeust, but set to CURL error
+		throw AmazonErrors::getError(
+			'FAILURE',
+			'C001',
+			'CurlError',
+			$message,
+			$errno
+		);
+	}
+}
+
+// __END__