From 2a60d53e180bf1253a560e8bbfc589e0209c720e Mon Sep 17 00:00:00 2001
From: Adar Porat <adar.porat@gmail.com>
Date: Sun, 19 Apr 2015 11:26:31 -0400
Subject: [PATCH] added support for Amazon RVS service

---
 src/ReceiptValidator/Amazon/Response.php  | 112 ++++++++++++++++++++
 src/ReceiptValidator/Amazon/Validator.php | 123 ++++++++++++++++++++++
 2 files changed, 235 insertions(+)
 create mode 100644 src/ReceiptValidator/Amazon/Response.php
 create mode 100755 src/ReceiptValidator/Amazon/Validator.php

diff --git a/src/ReceiptValidator/Amazon/Response.php b/src/ReceiptValidator/Amazon/Response.php
new file mode 100644
index 0000000..bb45ba3
--- /dev/null
+++ b/src/ReceiptValidator/Amazon/Response.php
@@ -0,0 +1,112 @@
+<?php
+namespace ReceiptValidator\Amazon;
+
+use ReceiptValidator\RunTimeException;
+
+class Response
+{
+
+    /**
+     * Response Codes
+     *
+     * @var int
+     */
+    const RESULT_OK = 200;
+
+    // Amazon RVS Error: Invalid receiptID
+    const RESULT_INVALID_RECEIPT = 400;
+
+    // Amazon RVS Error: Invalid developerSecret
+    const RESULT_INVALID_DEVELOPER_SECRET = 496;
+
+    // Amazon RVS Error: Invalid userId
+    const RESULT_INVALID_USER_ID = 497;
+
+    // Amazon RVS Error: Internal Server Error
+    const RESULT_INTERNAL_ERROR = 500;
+
+
+    /**
+     * Result Code
+     *
+     * @var int
+     */
+    protected $_code;
+
+
+    /**
+     * receipt info
+     *
+     * @var array
+     */
+    protected $_receipt = [];
+
+
+
+    /**
+     * Constructor
+     *
+     * @param int $httpStatusCode
+     * @param array $jsonResponse
+     * @return Response
+     */
+    public function __construct($httpStatusCode = 200, $jsonResponse = null)
+    {
+        $this->_code = $httpStatusCode;
+
+        if ($jsonResponse !== null) {
+            $this->parseJsonResponse($jsonResponse);
+        }
+    }
+
+    /**
+     * Get Result Code
+     *
+     * @return int
+     */
+    public function getResultCode()
+    {
+        return $this->_code;
+    }
+
+    /**
+     * Get receipt info
+     *
+     * @return array
+     */
+    public function getReceipt()
+    {
+        return $this->_receipt;
+    }
+
+    /**
+     * returns if the receipt is valid or not
+     *
+     * @return boolean
+     */
+    public function isValid()
+    {
+        if ($this->_code == self::RESULT_OK) {
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Parse JSON Response
+     *
+     * @param string $jsonResponse
+     * @return Message
+     */
+    public function parseJsonResponse($jsonResponse = null)
+    {
+        if (!is_array($jsonResponse)) {
+            throw new RuntimeException('Response must be a scalar value');
+        }
+
+        $this->_receipt = $jsonResponse;
+
+        return $this;
+    }
+}
diff --git a/src/ReceiptValidator/Amazon/Validator.php b/src/ReceiptValidator/Amazon/Validator.php
new file mode 100755
index 0000000..52433ec
--- /dev/null
+++ b/src/ReceiptValidator/Amazon/Validator.php
@@ -0,0 +1,123 @@
+<?php
+namespace ReceiptValidator\Amazon;
+
+use Aws\CloudFront\Exception\Exception;
+use Guzzle\Http\Client as GuzzleClient;
+use ReceiptValidator\RunTimeException as RunTimeException;
+
+class Validator
+{
+
+    const ENDPOINT_SANDBOX = 'http://localhost:8080/RVSSandbox/';
+
+    const ENDPOINT_PRODUCTION = 'https://appstore-sdk.amazon.com/version/1.0/verifyReceiptId/';
+
+    /**
+     * endpoint url
+     *
+     * @var string
+     */
+    protected $_endpoint;
+
+    /**
+     * Guzzle http client
+     *
+     * @var \Guzzle\Http\Client
+     */
+    protected $_client = null;
+
+
+    /**
+     * @var string
+     */
+    protected $_userId = null;
+
+    /**
+     * @var string
+     */
+    protected $_receiptId = null;
+
+    /**
+     * @var string
+     */
+    protected $_developerSecret = null;
+
+    /**
+     * @var string
+     */
+    protected $_product_id = null;
+
+    public function __construct($endpoint = self::ENDPOINT_PRODUCTION)
+    {
+        if ($endpoint != self::ENDPOINT_PRODUCTION && $endpoint != self::ENDPOINT_SANDBOX) {
+            throw new RunTimeException("Invalid endpoint '{$endpoint}'");
+        }
+
+        $this->_endpoint = $endpoint;
+    }
+
+
+    /**
+     *
+     * @param string $userId
+     * @return \ReceiptValidator\Amazon\Validator
+     */
+    public function setUserId($userId)
+    {
+        $this->_userId = $userId;
+
+        return $this;
+    }
+
+    /**
+     *
+     * @param string $receiptId
+     * @return \ReceiptValidator\Amazon\Validator
+     */
+    public function setReceiptId($receiptId)
+    {
+        $this->_receiptId = $receiptId;
+
+        return $this;
+    }
+
+    /**
+     *
+     * @param int $developerSecret
+     * @return \ReceiptValidator\Amazon\Validator
+     */
+    public function setDeveloperSecret($developerSecret)
+    {
+        $this->_developerSecret = $developerSecret;
+
+        return $this;
+    }
+
+
+    /**
+     * returns the Guzzle client
+     *
+     * @return \Guzzle\Http\Client
+     */
+    protected function getClient()
+    {
+        if ($this->_client == null) {
+            $this->_client = new GuzzleClient($this->_endpoint);
+        }
+
+        return $this->_client;
+    }
+
+    /**
+     * validate the receipt data
+     *
+     * @return Response
+     */
+    public function validate()
+    {
+
+        $httpResponse = $this->getClient()->get(sprintf("developer/%s/user/%s/receiptId/%s", $this->_developerSecret, $this->_userId, $this->_receiptId), null, ['exceptions' => false])->send();
+
+        return new Response($httpResponse->getStatusCode(), $httpResponse->json());
+    }
+}