Instant notification data is posted as JSON

Author: amacneil

src/Message/CompletePurchaseRequest.php

@@ -13,9 +13,16 @@ class CompletePurchaseRequest extends FetchTransactionRequest
 {
     public function getData()
     {
-        // check both GET and POST
-        $order = $this->httpRequest->request->get('order') ?:
-            $this->httpRequest->query->get('order');
+        // check GET
+        $order = $this->httpRequest->query->get('order');
+
+        // check JSON POST data
+        if (!$order && $this->httpRequest->getContent()) {
+            $content = json_decode($this->httpRequest->getContent(), true);
+            if (isset($content['order'])) {
+                $order = $content['order'];
+            }
+        }
 
         if (empty($order['id'])) {
             throw new InvalidRequestException('Missing Order ID');

tests/Message/CompletePurchaseRequestTest.php

@@ -3,6 +3,7 @@
 namespace Omnipay\Coinbase\Message;
 
 use Omnipay\Tests\TestCase;
+use Symfony\Component\HttpFoundation\Request as HttpRequest;
 
 class CompletePurchaseRequestTest extends TestCase
 {
@@ -30,8 +31,15 @@ public function testGetDataGet()
 
     public function testGetDataPost()
     {
-        $this->httpRequest->request->replace(
-            array('order' => array('id' => '9XMWP4YG'))
+        // post data is sent as JSON
+        $content = '{"order":{"id":"9XMWP4YG","created_at":"2014-05-11T22:15:41-07:00","status":"completed"}}';
+        $this->httpRequest = new HttpRequest(array(), array(), array(), array(), array(), array(), $content);
+        $this->request = new CompletePurchaseRequest($this->getHttpClient(), $this->httpRequest);
+        $this->request->initialize(
+            array(
+                'apiKey' => 'abc123',
+                'secret' => 'shhh',
+            )
         );
 
         $data = $this->request->getData();
@@ -49,7 +57,7 @@ public function testGetDataInvalid()
 
     public function testSendSuccess()
     {
-        $this->httpRequest->request->replace(
+        $this->httpRequest->query->replace(
             array('order' => array('id' => '9XMWP4YG'))
         );
         $this->setMockHttpResponse('FetchTransactionSuccess.txt');
@@ -63,7 +71,7 @@ public function testSendSuccess()
 
     public function testSendFailure()
     {
-        $this->httpRequest->request->replace(
+        $this->httpRequest->query->replace(
             array('order' => array('id' => '9XMWP4YG'))
         );
         $this->setMockHttpResponse('FetchTransactionFailure.txt');