Add first Exchange Command (#18)

* First Exchange command to create and delete 
* Fix Plurals 
* Add semaphore to sync the close

Signed-off-by: Gabriele Santomaggio <[email protected]>

---------

Signed-off-by: Gabriele Santomaggio <[email protected]>

Makefile

@@ -0,0 +1,43 @@
+all: format test
+
+format:
+	dotnet format $(CURDIR)/rabbitmq-amqp-dotnet-client.sln
+
+build:
+	dotnet build $(CURDIR)/Build.csproj
+
+test: build
+	dotnet test -c Debug $(CURDIR)/Tests/Tests.csproj --no-build --logger:"console;verbosity=detailed" /p:AltCover=true
+
+rabbitmq-server-start:
+	 ./.ci/ubuntu/gha-setup.sh start
+
+rabbitmq-server-stop:
+	 ./.ci/ubuntu/gha-setup.sh stop
+
+
+# TODO:
+## publish the documentation on github pages
+## you should execute this command only on the `main` branch
+# publish-github-pages:
+# 	## Create the PDF
+# 	docker run  -it -v $(shell pwd)/docs/:/client_doc/  asciidoctor/docker-asciidoctor /bin/bash -c "cd /client_doc/asciidoc &&  asciidoctor-pdf index.adoc"
+# 	## Create the HTML
+# 	docker run  -it -v $(shell pwd)/docs/:/client_doc/  asciidoctor/docker-asciidoctor /bin/bash -c "cd /client_doc/asciidoc &&  asciidoctor index.adoc"
+# 	## copy the PDF and HTML to temp folder
+# 	rm -rf docs/temp
+# 	mkdir -p docs/temp
+# 	cp docs/asciidoc/index.pdf docs/temp/dotnet-stream-client.pdf
+# 	cp docs/asciidoc/index.html docs/temp/index.html
+# 	## check out the gh-pages branch
+# 	git checkout gh-pages
+# 	## copy the PDF and HTML to the root folder
+# 	mv docs/temp/dotnet-stream-client.pdf stable/dotnet-stream-client.pdf
+# 	mv docs/temp/index.html stable/htmlsingle/index.html
+# 	## commit and push
+# 	git add stable/dotnet-stream-client.pdf
+# 	git add stable/htmlsingle/index.html
+# 	git commit -m "Update the documentation"
+# 	git push origin gh-pages
+# 	## go back to the main branch
+# 	git checkout main

RabbitMQ.AMQP.Client/ByteCapacity.cs

@@ -80,8 +80,16 @@ public long ToBytes()
 
     public bool Equals(ByteCapacity? other)
     {
-        if (ReferenceEquals(null, other)) return false;
-        if (ReferenceEquals(this, other)) return true;
+        if (ReferenceEquals(null, other))
+        {
+            return false;
+        }
+
+        if (ReferenceEquals(this, other))
+        {
+            return true;
+        }
+
         return _bytes == other._bytes;
     }
-}
+}

RabbitMQ.AMQP.Client/IAddressBuilder.cs

@@ -10,4 +10,4 @@ public interface IAddressBuilder<out T>
     T Queue(string queue);
 
     T Key(string key);
-}
+}

RabbitMQ.AMQP.Client/IClosable.cs

@@ -29,4 +29,4 @@ public interface IClosable // TODO: Create an abstract class with the event and
     public delegate void LifeCycleCallBack(object sender, State previousState, State currentState, Error? failureCause);
 
     event LifeCycleCallBack ChangeState;
-}
+}

RabbitMQ.AMQP.Client/IConnection.cs

@@ -6,4 +6,4 @@ public interface IConnection
 {
     IManagement Management();
     Task ConnectAsync();
-}
+}

RabbitMQ.AMQP.Client/IConnectionSettings.cs

@@ -16,4 +16,4 @@ public interface IConnectionSettings
     string Scheme();
 
     string ConnectionName();
-}
+}

RabbitMQ.AMQP.Client/IEntities.cs

@@ -43,3 +43,23 @@ public interface IQueueDeletion
     // TODO consider returning a QueueStatus object with some info after deletion
     Task<IEntityInfo> Delete(string name);
 }
+
+public interface IExchangeSpecification : IEntityDeclaration<IExchangeInfo>
+{
+    IExchangeSpecification Name(string name);
+
+    IExchangeSpecification AutoDelete(bool autoDelete);
+
+    IExchangeSpecification Type(ExchangeType type);
+
+    IExchangeSpecification Type(string type);
+
+    IExchangeSpecification Argument(string key, object value);
+}
+
+
+public interface IExchangeDeletion
+{
+    // TODO consider returning a ExchangeStatus object with some info after deletion
+    Task<IEntityInfo> Delete(string name);
+}

RabbitMQ.AMQP.Client/IQueueInfo.cs → RabbitMQ.AMQP.Client/IEntitiesInfo.cs

@@ -28,4 +28,17 @@ public interface IQueueInfo : IEntityInfo
     ulong MessageCount();
 
     uint ConsumerCount();
-}
+}
+
+
+public enum ExchangeType
+{
+    DIRECT,
+    FANOUT,
+    TOPIC,
+    HEADERS
+}
+
+public interface IExchangeInfo : IEntityInfo
+{
+}

RabbitMQ.AMQP.Client/IManagement.cs

@@ -11,6 +11,12 @@ public interface IManagement : IClosable
 
     IQueueDeletion QueueDeletion();
 
+    IExchangeSpecification Exchange();
+
+    IExchangeSpecification Exchange(string name);
+
+    IExchangeDeletion ExchangeDeletion();
+
     ITopologyListener TopologyListener();
 }
 

RabbitMQ.AMQP.Client/IMessage.cs

@@ -16,4 +16,4 @@ public interface IMessage
     string Subject();
     IMessage Subject(string subject);
 
-}
+}

RabbitMQ.AMQP.Client/IPublisher.cs

@@ -23,4 +23,4 @@ public interface IPublisher : IClosable
 {
     Task Publish(IMessage message,
         OutcomeDescriptorCallback outcomeCallback); // TODO: Add CancellationToken and callBack
-}
+}

RabbitMQ.AMQP.Client/IPublisherBuilder.cs

@@ -6,4 +6,4 @@ public interface IPublisherBuilder : IAddressBuilder<IPublisherBuilder>
 
     IPublisherBuilder MaxInflightMessages(int maxInFlight);
     IPublisher Build();
-}
+}

RabbitMQ.AMQP.Client/IRecoveryConfiguration.cs

@@ -60,4 +60,4 @@ public interface IBackOffDelayPolicy
     /// or when the user wants to disable the backoff delay policy.
     /// </summary>
     bool IsActive();
-}
+}

RabbitMQ.AMQP.Client/ITopologyListener.cs

@@ -9,4 +9,4 @@ public interface ITopologyListener
     void Clear();
 
     int QueueCount();
-}
+}

RabbitMQ.AMQP.Client/Impl/AbstractClosable.cs

@@ -17,11 +17,15 @@ protected void ThrowIfClosed()
 
     protected void OnNewStatus(State newState, Error? error)
     {
-        if (State == newState) return;
+        if (State == newState)
+        {
+            return;
+        }
+
         var oldStatus = State;
         State = newState;
         ChangeState?.Invoke(this, oldStatus, newState, error);
     }
 
     public event IClosable.LifeCycleCallBack? ChangeState;
-}
+}