From 666e4948a0c0c0ae30f0640b334a9117bee77e80 Mon Sep 17 00:00:00 2001
From: Martijn Smidt <martijn@squeezely.tech>
Date: Tue, 25 Aug 2020 13:02:18 +0200
Subject: [PATCH] Adding binding management Fixed queue creation Fixed queue
 retrieval Added Response class with HTTP status codes for readability

---
 .gitignore                      |   3 +
 src/Bindings/Binding.php        | 182 ++++++++++++++++++++++++++++++++
 src/Bindings/BindingService.php | 127 ++++++++++++++++++++++
 src/Queue/QueueService.php      |  29 +++--
 src/Response.php                |  77 ++++++++++++++
 src/Vhost/VhostService.php      |   7 +-
 6 files changed, 412 insertions(+), 13 deletions(-)
 create mode 100644 .gitignore
 create mode 100644 src/Bindings/Binding.php
 create mode 100644 src/Bindings/BindingService.php
 create mode 100644 src/Response.php

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..6e51a97
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,3 @@
+composer.lock
+vendor/
+.idea/
\ No newline at end of file
diff --git a/src/Bindings/Binding.php b/src/Bindings/Binding.php
new file mode 100644
index 0000000..9621912
--- /dev/null
+++ b/src/Bindings/Binding.php
@@ -0,0 +1,182 @@
+<?php
+
+
+namespace Squeezely\RabbitMQ\Management\Bindings;
+
+
+class Binding {
+    public const DESTINATION_TYPE_EXCHANGE = 'exchange';
+    public const DESTINATION_TYPE_QUEUE = 'queue';
+
+    public const DESTINATION_TYPES = [
+        self::DESTINATION_TYPE_EXCHANGE,
+        self::DESTINATION_TYPE_QUEUE
+    ];
+
+
+    /** @var array */
+    private $data;
+
+    /**
+     * @var string
+     */
+    private $source = '';
+    /**
+     * @var array
+     */
+    private $arguments = '';
+    /**
+     * @var string
+     */
+    private $vhost = '';
+    /**
+     * @var string
+     */
+    private $destinationType = '';
+    /**
+     * @var string
+     */
+    private $destination = '';
+    /**
+     * @var string
+     */
+    private $routing_key = '';
+    /**
+     * @var string
+     */
+    private $propertiesKey = '';
+
+    /**
+     * Binding constructor.
+     *
+     * @param $data
+     */
+    public function __construct(array $data = []) {
+        $this->data = $data;
+
+        $this->source = $data['source'] ?? '';
+        $this->vhost = $data['vhost'] ?? '';
+        $this->destination = $data['destination'] ?? '';
+        $this->destinationType = $data['destination_type'] ?? '';
+        $this->routing_key = $data['routing_key'] ?? '';
+        $this->arguments = $data['arguments'] ?? [];
+        $this->propertiesKey = $data['properties_key'] ?? '';
+    }
+
+    /**
+     * @return bool
+     */
+    public function isDefaultExchangeBinding() {
+        if($this->data['source'] === '' && $this->data['destination'] === $this->data['routing_key']) {
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * @return string
+     */
+    public function getSource(): string {
+        return $this->source;
+    }
+
+    /**
+     * @param string $source
+     */
+    public function setSource(string $source): void {
+        $this->source = $source;
+    }
+
+    /**
+     * @return array
+     */
+    public function getArguments(): ?array {
+        return $this->arguments;
+    }
+
+    /**
+     * @param array $arguments
+     */
+    public function setArguments(?array $arguments): void {
+        $this->arguments = $arguments;
+    }
+
+    public function addArguments(string $key, $value): void {
+        $this->arguments[$key] = $value;
+    }
+
+    /**
+     * @return string
+     */
+    public function getVhost(): string {
+        return $this->vhost;
+    }
+
+    /**
+     * @param string $vhost
+     */
+    public function setVhost(string $vhost): void {
+        $this->vhost = $vhost;
+    }
+
+    /**
+     * @return string
+     */
+    public function getDestinationType(): string {
+        return $this->destinationType;
+    }
+
+    /**
+     * @param string $destinationType
+     */
+    public function setDestinationType(string $destinationType): void {
+        $this->destinationType = $destinationType;
+    }
+
+    /**
+     * @return string
+     */
+    public function getDestination(): string {
+        return $this->destination;
+    }
+
+    /**
+     * @param string $destination
+     */
+    public function setDestination(string $destination): void {
+        $this->destination = $destination;
+    }
+
+    /**
+     * @return string
+     */
+    public function getRoutingKey(): string {
+        return $this->routing_key;
+    }
+
+    /**
+     * @param string $routing_key
+     */
+    public function setRoutingKey(string $routing_key): void {
+        $this->routing_key = $routing_key;
+    }
+
+    public function getRawData(): array {
+        return $this->data;
+    }
+
+    /**
+     * @return string
+     */
+    public function getPropertiesKey(): string {
+        return $this->propertiesKey;
+    }
+
+    /**
+     * @param string $propertiesKey
+     */
+    public function setPropertiesKey(string $propertiesKey): void {
+        $this->propertiesKey = $propertiesKey;
+    }
+}
\ No newline at end of file
diff --git a/src/Bindings/BindingService.php b/src/Bindings/BindingService.php
new file mode 100644
index 0000000..efd5fae
--- /dev/null
+++ b/src/Bindings/BindingService.php
@@ -0,0 +1,127 @@
+<?php
+
+
+namespace Squeezely\RabbitMQ\Management\Bindings;
+
+
+use Exception;
+use GuzzleHttp\Exception\GuzzleException;
+use Squeezely\RabbitMQ\Management\Client;
+use Squeezely\RabbitMQ\Management\Queue\Queue;
+use Squeezely\RabbitMQ\Management\Response;
+
+class BindingService extends Client {
+
+    public function getAllBindings(?string $vhost = null) {
+        if($vhost !== null) {
+            $context = 'bindings/' . $vhost;
+        }
+        else {
+            $context = 'bindings';
+        }
+
+        try {
+            $rawBindings = $this->sendAuthenticatedRequest($context);
+        } catch(GuzzleException $e) {
+            return [];
+        }
+
+        $bindings = [];
+
+        foreach($rawBindings as $rawBinding) {
+            $binding = new Binding($rawBinding);
+            $bindings[] = $binding;
+        }
+
+        return $bindings;
+    }
+
+    /**
+     * @param Queue $queue
+     *
+     * @return Binding[]|null
+     * @throws Exception
+     */
+    public function getBindingsByQueue(Queue $queue) {
+        try {
+            $rawBindings = $this->sendAuthenticatedRequest('queues/' . $queue->getVhost() . '/' . $queue->getName() . '/bindings');
+        } catch(GuzzleException $e) {
+            return null;
+        }
+
+        $bindings = [];
+
+        foreach($rawBindings as $rawBinding) {
+            $bindings[] = new Binding($rawBinding);
+        }
+
+        return $bindings ?: null;
+    }
+
+    /**
+     * @param Binding $binding
+     *
+     * @return bool
+     * @throws GuzzleException
+     */
+    public function createBinding(Binding $binding) {
+        switch($binding->getDestinationType()) {
+            case Binding::DESTINATION_TYPE_QUEUE:
+                $context = 'bindings/' . $binding->getVhost() . '/e/' . $binding->getSource() . '/q/' . $binding->getDestination();
+                break;
+            case Binding::DESTINATION_TYPE_EXCHANGE:
+                $context = 'bindings/' . $binding->getVhost() . '/e/' . $binding->getSource() . '/e/' . $binding->getDestination();
+                break;
+            default:
+                throw new Exception('Binding destination type not implemented: ' . $binding->getDestinationType());
+        }
+
+        $additionConfig = [
+            'routing_key' => $binding->getRoutingKey(),
+            'arguments' => $binding->getArguments() ?: []
+        ];
+
+        try {
+            $res = $this->sendAuthenticatedRequest($context, 'POST', $additionConfig, false);
+        } catch(Exception $e){
+            var_dump((string) $e->getResponse()->getBody());
+        }
+        if($res->getStatusCode() == Response::HTTP_CREATED || $res->getStatusCode() == Response::HTTP_NO_CONTENT) {
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * @param Binding $binding
+     *
+     * @return bool
+     * @throws GuzzleException
+     */
+    public function deleteBinding(Binding $binding) {
+        switch($binding->getDestinationType()) {
+            case Binding::DESTINATION_TYPE_QUEUE:
+                $context = 'bindings/' . $binding->getVhost() . '/e/' . $binding->getSource() . '/q/' . $binding->getDestination() . '/' . $binding->getPropertiesKey();
+                break;
+            case Binding::DESTINATION_TYPE_EXCHANGE:
+                $context = 'bindings/' . $binding->getVhost() . '/e/' . $binding->getSource() . '/e/' . $binding->getDestination() . '/' . $binding->getPropertiesKey();
+                break;
+            default:
+                throw new Exception('Binding destination type not implemented: ' . $binding->getDestinationType());
+        }
+
+        $res = $this->sendAuthenticatedRequest(
+            $context,
+            'DELETE',
+            [],
+            false
+        );
+        if($res->getStatusCode() == Response::HTTP_CREATED || $res->getStatusCode() == Response::HTTP_NO_CONTENT) {
+            return true;
+        }
+
+        return false;
+    }
+
+}
\ No newline at end of file
diff --git a/src/Queue/QueueService.php b/src/Queue/QueueService.php
index 4112859..52472ac 100644
--- a/src/Queue/QueueService.php
+++ b/src/Queue/QueueService.php
@@ -4,9 +4,11 @@
 namespace Squeezely\RabbitMQ\Management\Queue;
 
 
+use Exception;
 use GuzzleHttp\Exception\GuzzleException;
-use GuzzleHttp\Psr7\Response;
+use Psr\Http\Message\ResponseInterface;
 use Squeezely\RabbitMQ\Management\Client;
+use Squeezely\RabbitMQ\Management\Response;
 
 class QueueService extends Client {
 
@@ -15,7 +17,7 @@ class QueueService extends Client {
      * @param string $vhost
      *
      * @return Queue|false
-     * @throws \Exception
+     * @throws Exception
      */
     public function getQueue(string $name, string $vhost) {
         try {
@@ -25,8 +27,7 @@ public function getQueue(string $name, string $vhost) {
         }
 
         if(isset($vhostGeneralData['name']) && $vhostGeneralData['name'] == $name) {
-            $queue = new Queue($vhostGeneralData, $this->getVhostPermissions($name), $this->getVhostTopicPermissions($name));
-            return $queue;
+            return new Queue($vhostGeneralData);
         }
 
         return false;
@@ -61,25 +62,33 @@ public function getQueues(string $vhost = null) {
      *
      * @param string $name
      * @param string $vHost
-     * @param array $additionConfig
+     * @param array  $additionConfig
+     *
      * @return bool
      * @throws GuzzleException
      */
     public function createQueue(string $name, string $vHost, array $additionConfig = []) {
-        /** @var Response $res */
-        $res = $this->sendAuthenticatedRequest('queues/' . '/' . $vHost . '/' . $name, 'PUT', $additionConfig, false);
-        if($res->getStatusCode() == 201 || $res->getStatusCode() == 204) {
+        /** @var ResponseInterface $res */
+        $res = $this->sendAuthenticatedRequest('queues/' . $vHost . '/' . $name, 'PUT', $additionConfig, false);
+        if($res->getStatusCode() == Response::HTTP_CREATED || $res->getStatusCode() == Response::HTTP_NO_CONTENT) {
             return true;
         }
 
         return false;
     }
 
+    /**
+     * @param Queue $queue
+     *
+     * @return bool
+     * @throws GuzzleException
+     */
     public function deleteQueue(Queue $queue) {
         $res = $this->sendAuthenticatedRequest('queues/' . $queue->getVhost() . '/' . $queue->getName(), 'DELETE', [], false);
-        if($res->getStatusCode() == 201 || $res->getStatusCode() == 204) {
+        if($res->getStatusCode() == Response::HTTP_CREATED || $res->getStatusCode() == Response::HTTP_NO_CONTENT) {
             return true;
         }
-    }
 
+        return false;
+    }
 }
\ No newline at end of file
diff --git a/src/Response.php b/src/Response.php
new file mode 100644
index 0000000..1666a75
--- /dev/null
+++ b/src/Response.php
@@ -0,0 +1,77 @@
+<?php
+
+
+namespace Squeezely\RabbitMQ\Management;
+
+
+class Response {
+    const HTTP_CONTINUE = 100;
+    const HTTP_SWITCHING_PROTOCOLS = 101;
+    const HTTP_PROCESSING = 102;            // RFC2518
+    const HTTP_EARLY_HINTS = 103;           // RFC8297
+    const HTTP_OK = 200;
+    const HTTP_CREATED = 201;
+    const HTTP_ACCEPTED = 202;
+    const HTTP_NON_AUTHORITATIVE_INFORMATION = 203;
+    const HTTP_NO_CONTENT = 204;
+    const HTTP_RESET_CONTENT = 205;
+    const HTTP_PARTIAL_CONTENT = 206;
+    const HTTP_MULTI_STATUS = 207;          // RFC4918
+    const HTTP_ALREADY_REPORTED = 208;      // RFC5842
+    const HTTP_IM_USED = 226;               // RFC3229
+    const HTTP_MULTIPLE_CHOICES = 300;
+    const HTTP_MOVED_PERMANENTLY = 301;
+    const HTTP_FOUND = 302;
+    const HTTP_SEE_OTHER = 303;
+    const HTTP_NOT_MODIFIED = 304;
+    const HTTP_USE_PROXY = 305;
+    const HTTP_RESERVED = 306;
+    const HTTP_TEMPORARY_REDIRECT = 307;
+    const HTTP_PERMANENTLY_REDIRECT = 308;  // RFC7238
+    const HTTP_BAD_REQUEST = 400;
+    const HTTP_UNAUTHORIZED = 401;
+    const HTTP_PAYMENT_REQUIRED = 402;
+    const HTTP_FORBIDDEN = 403;
+    const HTTP_NOT_FOUND = 404;
+    const HTTP_METHOD_NOT_ALLOWED = 405;
+    const HTTP_NOT_ACCEPTABLE = 406;
+    const HTTP_PROXY_AUTHENTICATION_REQUIRED = 407;
+    const HTTP_REQUEST_TIMEOUT = 408;
+    const HTTP_CONFLICT = 409;
+    const HTTP_GONE = 410;
+    const HTTP_LENGTH_REQUIRED = 411;
+    const HTTP_PRECONDITION_FAILED = 412;
+    const HTTP_REQUEST_ENTITY_TOO_LARGE = 413;
+    const HTTP_REQUEST_URI_TOO_LONG = 414;
+    const HTTP_UNSUPPORTED_MEDIA_TYPE = 415;
+    const HTTP_REQUESTED_RANGE_NOT_SATISFIABLE = 416;
+    const HTTP_EXPECTATION_FAILED = 417;
+    const HTTP_I_AM_A_TEAPOT = 418;                                               // RFC2324
+    const HTTP_MISDIRECTED_REQUEST = 421;                                         // RFC7540
+    const HTTP_UNPROCESSABLE_ENTITY = 422;                                        // RFC4918
+    const HTTP_LOCKED = 423;                                                      // RFC4918
+    const HTTP_FAILED_DEPENDENCY = 424;                                           // RFC4918
+
+    /**
+     * @deprecated
+     */
+    const HTTP_RESERVED_FOR_WEBDAV_ADVANCED_COLLECTIONS_EXPIRED_PROPOSAL = 425;   // RFC2817
+    const HTTP_TOO_EARLY = 425;                                                   // RFC-ietf-httpbis-replay-04
+    const HTTP_UPGRADE_REQUIRED = 426;                                            // RFC2817
+    const HTTP_PRECONDITION_REQUIRED = 428;                                       // RFC6585
+    const HTTP_TOO_MANY_REQUESTS = 429;                                           // RFC6585
+    const HTTP_REQUEST_HEADER_FIELDS_TOO_LARGE = 431;                             // RFC6585
+    const HTTP_UNAVAILABLE_FOR_LEGAL_REASONS = 451;
+    const HTTP_INTERNAL_SERVER_ERROR = 500;
+    const HTTP_NOT_IMPLEMENTED = 501;
+    const HTTP_BAD_GATEWAY = 502;
+    const HTTP_SERVICE_UNAVAILABLE = 503;
+    const HTTP_GATEWAY_TIMEOUT = 504;
+    const HTTP_VERSION_NOT_SUPPORTED = 505;
+    const HTTP_VARIANT_ALSO_NEGOTIATES_EXPERIMENTAL = 506;                        // RFC2295
+    const HTTP_INSUFFICIENT_STORAGE = 507;                                        // RFC4918
+    const HTTP_LOOP_DETECTED = 508;                                               // RFC5842
+    const HTTP_NOT_EXTENDED = 510;                                                // RFC2774
+    const HTTP_NETWORK_AUTHENTICATION_REQUIRED = 511;                             // RFC6585
+
+}
\ No newline at end of file
diff --git a/src/Vhost/VhostService.php b/src/Vhost/VhostService.php
index 59051b7..75d739a 100644
--- a/src/Vhost/VhostService.php
+++ b/src/Vhost/VhostService.php
@@ -5,8 +5,9 @@
 
 
 use GuzzleHttp\Exception\GuzzleException;
-use GuzzleHttp\Psr7\Response;
+use Psr\Http\Message\ResponseInterface;
 use Squeezely\RabbitMQ\Management\Client;
+use Squeezely\RabbitMQ\Management\Response;
 
 class VhostService extends Client {
 
@@ -63,9 +64,9 @@ public function createVhost(string $name, bool $enableTracing = false) {
             $body = ['tracing' => true];
         }
 
-        /** @var Response $res */
+        /** @var ResponseInterface $res */
         $res = $this->sendAuthenticatedRequest('vhosts/' . $name, 'PUT', $body, false);
-        if($res->getStatusCode() == 201 || $res->getStatusCode() == 204) {
+        if($res->getStatusCode() == Response::HTTP_CREATED || $res->getStatusCode() == Response::HTTP_NO_CONTENT) {
             return true;
         }