Adding support for Gateway Mollie Connect

README.md

@@ -23,6 +23,7 @@ composer require league/omnipay omnipay/mollie
 The following gateways are provided by this package:
 
 * Mollie
+* Mollie_Connect
 
 For general usage instructions, please see the main [Omnipay](https://github.com/thephpleague/omnipay)
 repository.

src/ConnectGateway.php

@@ -0,0 +1,161 @@
+<?php
+
+namespace Omnipay\Mollie;
+
+use Omnipay\Common\AbstractGateway;
+use Omnipay\Common\Message\RequestInterface;
+use Omnipay\Mollie\Message\Request\ConnectCompletePurchaseRequest;
+use Omnipay\Mollie\Message\Request\ConnectCreateCustomerRequest;
+use Omnipay\Mollie\Message\Request\ConnectFetchCustomerRequest;
+use Omnipay\Mollie\Message\Request\ConnectFetchIssuersRequest;
+use Omnipay\Mollie\Message\Request\ConnectFetchPaymentMethodsRequest;
+use Omnipay\Mollie\Message\Request\ConnectFetchTransactionRequest;
+use Omnipay\Mollie\Message\Request\ConnectPurchaseRequest;
+use Omnipay\Mollie\Message\Request\ConnectRefundRequest;
+use Omnipay\Mollie\Message\Request\ConnectUpdateCustomerRequest;
+
+class ConnectGateway extends AbstractGateway
+{
+    /**
+     * @return string
+     */
+    public function getName()
+    {
+        return 'Mollie Connect';
+    }
+
+    /**
+     * @return array
+     */
+    public function getDefaultParameters()
+    {
+        return array(
+            'apiKey' => ''
+        );
+    }
+
+    /**
+     * @return string
+     */
+    public function getApiKey()
+    {
+        return $this->getParameter('apiKey');
+    }
+
+    /**
+     * @param  string $value
+     * @return $this
+     */
+    public function setApiKey($value)
+    {
+        return $this->setParameter('apiKey', $value);
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectFetchIssuersRequest
+     */
+    public function fetchIssuers(array $parameters = [])
+    {
+        /** @var ConnectFetchIssuersRequest $request */
+        $request = $this->createRequest(ConnectFetchIssuersRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectFetchPaymentMethodsRequest
+     */
+    public function fetchPaymentMethods(array $parameters = [])
+    {
+        /** @var ConnectFetchPaymentMethodsRequest $request */
+        $request = $this->createRequest(ConnectFetchPaymentMethodsRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectFetchTransactionRequest
+     */
+    public function fetchTransaction(array $parameters = [])
+    {
+        /** @var ConnectFetchTransactionRequest $request */
+        $request = $this->createRequest(ConnectFetchTransactionRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectPurchaseRequest
+     */
+    public function purchase(array $parameters = [])
+    {
+        /** @var ConnectPurchaseRequest $request */
+        $request = $this->createRequest(ConnectPurchaseRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return CompletePurchaseRequest
+     */
+    public function completePurchase(array $parameters = [])
+    {
+        /** @var ConnectCompletePurchaseRequest $request */
+        $request = $this->createRequest(ConnectCompletePurchaseRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectRefundRequest
+     */
+    public function refund(array $parameters = [])
+    {
+        /** @var ConnectRefundRequest $request */
+        $request = $this->createRequest(ConnectRefundRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectCreateCustomerRequest
+     */
+    public function createCustomer(array $parameters = [])
+    {
+        /** @var ConnectCreateCustomerRequest $request */
+        $request = $this->createRequest(ConnectCreateCustomerRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectUpdateCustomerRequest
+     */
+    public function updateCustomer(array $parameters = [])
+    {
+        /** @var ConnectUpdateCustomerRequest $request */
+        $request = $this->createRequest(ConnectUpdateCustomerRequest::class, $parameters);
+
+        return $request;
+    }
+
+    /**
+     * @param  array $parameters
+     * @return ConnectFetchCustomerRequest
+     */
+    public function fetchCustomer(array $parameters = [])
+    {
+        /** @var ConnectFetchCustomerRequest $request */
+        $request = $this->createRequest(ConnectFetchCustomerRequest::class, $parameters);
+
+        return $request;
+    }
+}

src/Message/Request/AbstractMollieRequest.php

@@ -41,6 +41,23 @@ public function setApiKey($value)
         return $this->setParameter('apiKey', $value);
     }
 
+    /**
+     * @return string
+     */
+    public function getProfileId()
+    {
+        return $this->getParameter('profileId');
+    }
+
+    /**
+     * @param string $value
+     * @return $this
+     */
+    public function setProfileId($value)
+    {
+        return $this->setParameter('profileId', $value);
+    }
+
     /**
      * @param string $value
      * @return $this

src/Message/Request/ConnectCompletePurchaseRequest.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Omnipay\Mollie\Message\Request;
+
+use Omnipay\Common\Exception\InvalidRequestException;
+use Omnipay\Mollie\Message\Response\CompletePurchaseResponse;
+
+/**
+ * Retrieve a single payment object by its payment token.
+ *
+ * @see https://docs.mollie.com/reference/v2/payments-api/get-payment
+ * @see https://docs.mollie.com/reference/v2/payments-api/get-payment#mollie-connect-oauth-parameters
+ */
+class ConnectCompletePurchaseRequest extends CompletePurchaseRequest
+{
+    /**
+     * @return array
+     * @throws InvalidRequestException
+     */
+    public function getData()
+    {
+        $this->validate('apiKey');
+
+        $data = [];
+        $data['id'] = $this->getTransactionReference();
+
+        if ($this->getTestMode()) {
+            $data['testmode'] = $this->getTestMode();
+        }
+
+        if (!isset($data['id'])) {
+            $data['id'] = $this->httpRequest->request->get('id');
+        }
+
+        if (empty($data['id'])) {
+            throw new InvalidRequestException("The transactionReference parameter is required");
+        }
+
+        return $data;
+    }
+
+    /**
+     * @param array $data
+     * @return CompletePurchaseResponse
+     */
+    public function sendData($data)
+    {
+        $queryString = isset($data['testmode']) ? '?testmode=' . var_export($data['testmode'], true) : '';
+
+        $response = $this->sendRequest(self::GET, '/payments/' . $data['id'] . $queryString);
+
+        return $this->response = new CompletePurchaseResponse($this, $response);
+    }
+}

src/Message/Request/ConnectCreateCustomerRequest.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace Omnipay\Mollie\Message\Request;
+
+use Omnipay\Common\Exception\InvalidRequestException;
+use Omnipay\Common\Message\AbstractRequest;
+use Omnipay\Mollie\Message\Response\CreateCustomerResponse;
+
+/**
+ * Creates a simple minimal representation of a customer in the Mollie API.
+ *
+ * @see https://docs.mollie.com/reference/v2/customers-api/create-customer
+ * @see https://docs.mollie.com/reference/v2/customers-api/create-customer#mollie-connect-oauth-parameters
+ */
+class ConnectCreateCustomerRequest extends CreateCustomerRequest
+{
+    /**
+     * @return array
+     * @throws InvalidRequestException
+     */
+    public function getData()
+    {
+        $this->validate('apiKey', 'description', 'email');
+
+        $data                = [];
+        $data['name']        = $this->getDescription();
+        $data['email']       = $this->getEmail();
+        $data['locale']      = $this->getLocale();
+
+        if ($this->getMetadata()) {
+            $data['metadata'] = $this->getMetadata();
+        }
+
+        if ($this->getTestMode()) {
+            $data['testmode'] = $this->getTestMode();
+        }
+
+        return $data;
+    }
+
+    /**
+     * @param array $data
+     * @return CreateCustomerResponse
+     */
+    public function sendData($data)
+    {
+        $response = $this->sendRequest(self::POST, '/customers', $data);
+
+        return $this->response = new CreateCustomerResponse($this, $response);
+    }
+}

src/Message/Request/ConnectFetchCustomerRequest.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Omnipay\Mollie\Message\Request;
+
+use Omnipay\Common\Exception\InvalidRequestException;
+use Omnipay\Common\Message\AbstractRequest;
+use Omnipay\Mollie\Message\Response\FetchCustomerResponse;
+
+/**
+ * Retrieve a single customer by its ID.
+ *
+ * @see https://docs.mollie.com/reference/v2/customers-api/get-customer
+ * @see https://docs.mollie.com/reference/v2/customers-api/get-customer#mollie-connect-oauth-parameters
+ */
+class ConnectFetchCustomerRequest extends FetchCustomerRequest
+{
+    /**
+     * @return array
+     * @throws InvalidRequestException
+     */
+    public function getData()
+    {
+        $this->validate('apiKey', 'customerReference');
+
+        $data = [];
+
+        if ($this->getTestMode()) {
+            $data['testmode'] = $this->getTestMode();
+        }
+
+        return $data;
+    }
+
+    /**
+     * @param array $data
+     * @return FetchCustomerResponse
+     */
+    public function sendData($data)
+    {
+        $queryString = isset($data['testmode']) ? '?testmode=' . var_export($data['testmode'], true) : '';
+
+        $response = $this->sendRequest(self::GET, '/customers/' . $this->getCustomerReference() . $queryString);
+
+        return $this->response = new FetchCustomerResponse($this, $response);
+    }
+}