Merge pull request #1 from buildersoftdev/feature/core-structure

Feature/core structure

src/Buildersoft.Messaging/Abstraction/IMessagingClient.cs

@@ -0,0 +1,14 @@
+using Buildersoft.Messaging.Builder;
+using Microsoft.Extensions.Logging;
+using System;
+
+namespace Buildersoft.Messaging.Abstraction
+{
+    public interface IMessagingClient
+    {
+        IMessagingClient GetClient();
+        IMessagingClient Build();
+        MessagingClientBuilder GetBuilder();
+        ILoggerFactory GetLoggerFactory();
+    }
+}

src/Buildersoft.Messaging/Abstraction/IMessagingConsumer.cs

@@ -0,0 +1,20 @@
+using Andy.X.Client.Events.Consumers;
+using System.Threading;
+
+namespace Buildersoft.Messaging.Abstraction
+{
+    public interface IMessagingConsumer<T>
+    {
+        delegate bool MessageReceivedHandler(object sender, MessageReceivedArgs<T> messageReceivedArgs);
+        event MessageReceivedHandler MessageReceived;
+
+        delegate void StatusChangedHandler(object sender, string status);
+        event StatusChangedHandler StatusChanged;
+
+        void StopConsuming();
+        void StartConsuming();
+        string GetInitializedConsumerName();
+        string GetConsumerState();
+        CancellationTokenSource GetCancellationTokenSource();
+    }
+}

src/Buildersoft.Messaging/Abstraction/IMessagingProducer.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Buildersoft.Messaging.Abstraction
+{
+    public interface IMessagingProducer<T>
+    {
+        delegate void StatusChangedHandler(object sender, string status);
+        event StatusChangedHandler StatusChanged;
+
+        Task<Guid> SendAsync(T tEntity, string key = "");
+        CancellationTokenSource GetCancellationTokenSource();
+    }
+}

src/Buildersoft.Messaging/App/Andy/AndyClient.cs

@@ -0,0 +1,29 @@
+using Buildersoft.Messaging.Abstraction;
+using Buildersoft.Messaging.Builder;
+using Microsoft.Extensions.Logging;
+
+namespace Buildersoft.Messaging.App.Andy
+{
+    public class AndyClient : IMessagingClient
+    {
+        public IMessagingClient Build()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public MessagingClientBuilder GetBuilder()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMessagingClient GetClient()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public ILoggerFactory GetLoggerFactory()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Andy/AndyConsumer.cs

@@ -0,0 +1,36 @@
+using Buildersoft.Messaging.Abstraction;
+using System.Threading;
+
+namespace Buildersoft.Messaging.App.Andy
+{
+    public class AndyConsumer<T> : IMessagingConsumer<T>
+    {
+        public event IMessagingConsumer<T>.MessageReceivedHandler MessageReceived;
+        public event IMessagingConsumer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetConsumerState()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetInitializedConsumerName()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StartConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StopConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Andy/AndyProducer.cs

@@ -0,0 +1,22 @@
+using Buildersoft.Messaging.Abstraction;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Buildersoft.Messaging.App.Andy
+{
+    public class AndyProducer<T> : IMessagingProducer<T>
+    {
+        public event IMessagingProducer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<Guid> SendAsync(T tEntity, string key = "")
+        {
+            throw new NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Kafka/KafkaClient.cs

@@ -0,0 +1,29 @@
+using Buildersoft.Messaging.Abstraction;
+using Buildersoft.Messaging.Builder;
+using Microsoft.Extensions.Logging;
+
+namespace Buildersoft.Messaging.App.Kafka
+{
+    public class KafkaClient : IMessagingClient
+    {
+        public IMessagingClient Build()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public MessagingClientBuilder GetBuilder()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMessagingClient GetClient()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public ILoggerFactory GetLoggerFactory()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Kafka/KafkaConsumer.cs

@@ -0,0 +1,36 @@
+using Buildersoft.Messaging.Abstraction;
+using System.Threading;
+
+namespace Buildersoft.Messaging.App.Kafka
+{
+    public class KafkaConsumer<T> : IMessagingConsumer<T>
+    {
+        public event IMessagingConsumer<T>.MessageReceivedHandler MessageReceived;
+        public event IMessagingConsumer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetConsumerState()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetInitializedConsumerName()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StartConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StopConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Kafka/KafkaProducer.cs

@@ -0,0 +1,22 @@
+using Buildersoft.Messaging.Abstraction;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Buildersoft.Messaging.App.Kafka
+{
+    public class KafkaProducer<T> : IMessagingProducer<T>
+    {
+        public event IMessagingProducer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<Guid> SendAsync(T tEntity, string key = "")
+        {
+            throw new NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Pulsar/PulsarClient.cs

@@ -0,0 +1,29 @@
+using Buildersoft.Messaging.Abstraction;
+using Buildersoft.Messaging.Builder;
+using Microsoft.Extensions.Logging;
+
+namespace Buildersoft.Messaging.App.Pulsar
+{
+    public class PulsarClient : IMessagingClient
+    {
+        public IMessagingClient Build()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public MessagingClientBuilder GetBuilder()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMessagingClient GetClient()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public ILoggerFactory GetLoggerFactory()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Pulsar/PulsarConsumer.cs

@@ -0,0 +1,36 @@
+using Buildersoft.Messaging.Abstraction;
+using System.Threading;
+
+namespace Buildersoft.Messaging.App.Pulsar
+{
+    public class PulsarConsumer<T> : IMessagingConsumer<T>
+    {
+        public event IMessagingConsumer<T>.MessageReceivedHandler MessageReceived;
+        public event IMessagingConsumer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetConsumerState()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public string GetInitializedConsumerName()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StartConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public void StopConsuming()
+        {
+            throw new System.NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/App/Pulsar/PulsarProducer.cs

@@ -0,0 +1,22 @@
+using Buildersoft.Messaging.Abstraction;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Buildersoft.Messaging.App.Pulsar
+{
+    public class PulsarProducer<T> : IMessagingProducer<T>
+    {
+        public event IMessagingProducer<T>.StatusChangedHandler StatusChanged;
+
+        public CancellationTokenSource GetCancellationTokenSource()
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<Guid> SendAsync(T tEntity, string key = "")
+        {
+            throw new NotImplementedException();
+        }
+    }
+}

src/Buildersoft.Messaging/Builder/MessagingClientBuilder.cs

@@ -0,0 +1,14 @@
+using Buildersoft.Messaging.Configuration;
+
+namespace Buildersoft.Messaging.Builder
+{
+    public class MessagingClientBuilder
+    {
+        public MessagingClientConfiguration MessagingConfiguration { get; private set; }
+
+        public MessagingClientBuilder(MessagingClientConfiguration messagingConfiguration)
+        {
+            MessagingConfiguration = messagingConfiguration;
+        }
+    }
+}

src/Buildersoft.Messaging/Builder/MessagingConsumerBuilder.cs

@@ -0,0 +1,14 @@
+using Buildersoft.Messaging.Configuration;
+
+namespace Buildersoft.Messaging.Builder
+{
+    public class MessagingConsumerBuilder<T>
+    {
+        public MessagingConsumerConfiguration<T> MessagingConsumerConfiguration { get; private set; }
+
+        public MessagingConsumerBuilder(MessagingConsumerConfiguration<T> messagingConsumerConfiguration)
+        {
+            MessagingConsumerConfiguration = messagingConsumerConfiguration;
+        }
+    }
+}

src/Buildersoft.Messaging/Builder/MessagingProducerBuilder.cs

@@ -0,0 +1,14 @@
+using Buildersoft.Messaging.Configuration;
+
+namespace Buildersoft.Messaging.Builder
+{
+    public class MessagingProducerBuilder<T>
+    {
+        public MessagingProducerConfiguration<T> MessagingProducerConfiguration { get; private set; }
+
+        public MessagingProducerBuilder(MessagingProducerConfiguration<T> messagingProducerConfiguration)
+        {
+            MessagingProducerConfiguration = messagingProducerConfiguration;
+        }
+    }
+}

src/Buildersoft.Messaging/Buildersoft.Messaging.csproj

@@ -4,4 +4,11 @@
     <TargetFramework>net5.0</TargetFramework>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Buildersoft.Andy.X.Client" Version="2.0.2-preview" />
+    <PackageReference Include="Confluent.Kafka" Version="1.7.0" />
+    <PackageReference Include="DotPulsar" Version="1.1.2" />
+    <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="5.0.0" />
+  </ItemGroup>
+
 </Project>