Webhook v2 support

src/Accounts.php

@@ -4,7 +4,7 @@
 
 class Accounts
 {
-    const ENDPOINT = 'accounts';
+    const ENDPOINT = '1.0/accounts';
 
     /**
      * @var Client

src/Client.php

@@ -10,7 +10,6 @@
 class Client
 {
 
-    const REVOLUT_API_VERSION = '1.0';
     const REVOLUT_SANDBOX_ENDPOINT = 'https://sandbox-b2b.revolut.com/api/';
     const REVOLUT_PRODUCTION_ENDPOINT = 'https://b2b.revolut.com/api/';
 
@@ -84,6 +83,11 @@ class Client
      */
     public $webhooks;
 
+    /**
+     * @var WebhooksV2
+     */
+    public $webhooksV2;
+
     /**
      * Client constructor.
      * @param AccessToken $accessToken
@@ -108,6 +112,7 @@ public function __construct(AccessToken $accessToken, $mode = 'production', arra
         $this->rates = new Rates($this);
         $this->exchanges = new Exchanges($this);
         $this->webhooks = new Webhooks($this);
+        $this->webhooksV2 = new WebhooksV2($this);
     }
 
     /**
@@ -125,16 +130,16 @@ private function initiateHttpClient()
     {
         $options = [
             'headers' => [
-                'Authorization' => 'Bearer ' . $this->accessToken->getToken(),
-            ]
+                'Authorization' => 'Bearer '.$this->accessToken->getToken(),
+            ],
         ];
 
         $this->httpClient = new GuzzleClient(array_replace_recursive($this->clientOptions, $options));
     }
 
-    private function buildBaseUrl()
+    private function getBaseUrl()
     {
-        return $this->baseUrl.self::REVOLUT_API_VERSION.'/';
+        return $this->baseUrl;
     }
 
     /**
@@ -157,7 +162,8 @@ private function handleResponse(Response $response)
      */
     public function post($endpoint, $json)
     {
-        $response = $this->httpClient->request('POST', $this->buildBaseUrl().$endpoint, ['json' => $json]);
+        $response = $this->httpClient->request('POST', $this->getBaseUrl().$endpoint, ['json' => $json]);
+
         return $this->handleResponse($response);
     }
 
@@ -169,7 +175,8 @@ public function post($endpoint, $json)
      */
     public function patch($endpoint, $json)
     {
-        $response = $this->httpClient->request('PATCH', $this->buildBaseUrl().$endpoint, ['json' => $json]);
+        $response = $this->httpClient->request('PATCH', $this->getBaseUrl().$endpoint, ['json' => $json]);
+
         return $this->handleResponse($response);
     }
 
@@ -180,7 +187,8 @@ public function patch($endpoint, $json)
      */
     public function get($endpoint)
     {
-        $response = $this->httpClient->request('GET', $this->buildBaseUrl().$endpoint);
+        $response = $this->httpClient->request('GET', $this->getBaseUrl().$endpoint);
+
         return $this->handleResponse($response);
     }
 
@@ -191,7 +199,8 @@ public function get($endpoint)
      */
     public function delete($endpoint)
     {
-        $response = $this->httpClient->request('DELETE', $this->buildBaseUrl().$endpoint);
+        $response = $this->httpClient->request('DELETE', $this->getBaseUrl().$endpoint);
+
         return $this->handleResponse($response);
     }
 }

src/Counterparties.php

@@ -4,7 +4,7 @@
 
 class Counterparties
 {
-    const ENDPOINT = 'counterparty';
+    const ENDPOINT = '1.0/counterparty';
 
     /**
      * @var Client

src/Exchanges.php

@@ -4,7 +4,7 @@
 
 class Exchanges
 {
-    const ENDPOINT = 'exchange';
+    const ENDPOINT = '1.0/exchange';
 
     /**
      * @var Client

src/PaymentDrafts.php

@@ -4,7 +4,7 @@
 
 class PaymentDrafts
 {
-    const ENDPOINT = 'payment-drafts';
+    const ENDPOINT = '1.0/payment-drafts';
 
     /**
      * @var Client

src/Payments.php

@@ -4,7 +4,7 @@
 
 class Payments
 {
-    const ENDPOINT = 'pay';
+    const ENDPOINT = '1.0/pay';
 
     /**
      * @var Client

src/Rates.php

@@ -4,7 +4,7 @@
 
 class Rates
 {
-    const ENDPOINT = 'rate';
+    const ENDPOINT = '1.0/rate';
 
     /**
      * @var Client

src/Transactions.php

@@ -4,7 +4,7 @@
 
 class Transactions
 {
-    const ENDPOINT = 'transaction';
+    const ENDPOINT = '1.0/transaction';
 
     /**
      * @var Client

src/Transfers.php

@@ -4,7 +4,7 @@
 
 class Transfers
 {
-    const ENDPOINT = 'transfer';
+    const ENDPOINT = '1.0/transfer';
 
     /**
      * @var Client

src/Webhooks.php

@@ -4,7 +4,7 @@
 
 class Webhooks
 {
-    const ENDPOINT = 'webhook';
+    const ENDPOINT = '1.0/webhook';
 
     /**
      * @var Client

src/WebhooksV2.php

@@ -0,0 +1,122 @@
+<?php
+
+namespace RevolutPHP;
+
+class WebhooksV2
+{
+    const ENDPOINT = '2.0/webhooks';
+
+    /**
+     * @var Client
+     */
+    private $client;
+
+    /**
+     * Webhook constructor.
+     * @param Client $client
+     */
+    public function __construct(Client $client)
+    {
+        $this->client = $client;
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/create-webhook
+     *
+     * @param array $json
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function create(array $json)
+    {
+        return $this->client->post(self::ENDPOINT, $json);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/get-webhooks
+     *
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function all()
+    {
+        return $this->client->get(self::ENDPOINT);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/get-webhook
+     *
+     * @param string $id
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function get(string $id)
+    {
+        return $this->client->get(self::ENDPOINT.'/'.$id);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/update-webhook
+     *
+     * @param string $id
+     * @param array $json
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function update(string $id, array $json)
+    {
+        return $this->client->patch(self::ENDPOINT.'/'.$id, $json);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/delete-webhook
+     *
+     * @param string $id
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function delete(string $id)
+    {
+        return $this->client->delete(self::ENDPOINT.'/'.$id);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/rotate-webhook-signing-secret
+     *
+     * @param string $id
+     * @param array $json
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function rotateSigningSecret(string $id, array $json)
+    {
+        return $this->client->post(self::ENDPOINT.'/'.$id.'/rotate-signing-secret', $json);
+    }
+
+    /**
+     * @see https://developer.revolut.com/docs/business/failed-events
+     *
+     * @param string $id
+     * @param int|null $limit
+     * @param \DateTime|null $createdBefore
+     * @return mixed
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    public function getFailedEvents(string $id, int $limit = null, \DateTime $createdBefore = null)
+    {
+        $args = [];
+        if (null !== $limit) {
+            $args['limit'] = $limit;
+        }
+        if (null !== $createdBefore) {
+            $args['created_before'] = $createdBefore->format(\DateTime::ISO8601);
+        }
+
+        $query = http_build_query($args);
+
+        $endpoint = self::ENDPOINT.'/'.$id.'/failed-events';
+        $endpoint = implode('?', array_filter([$endpoint, $query]));
+
+        return $this->client->get($endpoint);
+    }
+}