Merge branch 'main' of https://github.com/prescriptiveanalytics/Ai.Hg…

…b.Dat
prescriptiveanalytics · Feb 1, 2024 · 21ba80a · 21ba80a
2 parents b49be56 + abc7120
commit 21ba80a
Show file tree

Hide file tree

Showing 41 changed files with 72 additions and 72 deletions.
diff --git a/src/DistributedApplicationTools.sln → src/Ai.Hgb.Dat.sln b/src/DistributedApplicationTools.sln → src/Ai.Hgb.Dat.sln
diff --git a/src/Communication/Broker/IBroker.cs b/src/Communication/Broker/IBroker.cs
@@ -1,6 +1,6 @@
-using DAT.Configuration;
+using Ai.Hgb.Dat.Configuration;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public interface IBroker : IDisposable {
     HostAddress Address { get; }
 

diff --git a/src/Communication/Broker/MqttBroker.cs b/src/Communication/Broker/MqttBroker.cs
@@ -1,4 +1,4 @@
-using DAT.Configuration;
+using Ai.Hgb.Dat.Configuration;
 using MQTTnet;
 using MQTTnet.Server;
 using MQTTnet.AspNetCore;
@@ -8,7 +8,7 @@
 using Microsoft.Extensions.DependencyInjection;
 
 // https://blog.behroozbc.ir/c-mqtt-broker-using-mqttnet-version-4
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public sealed class MqttBroker : IBroker {
     public HostAddress Address {
       get { return address; }

diff --git a/src/Communication/Communication.csproj b/src/Communication/Communication.csproj
@@ -3,8 +3,8 @@
   <PropertyGroup>
     <TargetFramework>net7.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
-    <AssemblyName>DAT.$(MSBuildProjectName)</AssemblyName>
-    <RootNamespace>DAT.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>    
+    <AssemblyName>Ai.Hgb.Dat.$(MSBuildProjectName)</AssemblyName>
+    <RootNamespace>Ai.Hgb.Dat.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>    
     <AssemblyVersion></AssemblyVersion>
   </PropertyGroup>
 

diff --git a/src/Communication/DataStructures.cs b/src/Communication/DataStructures.cs
@@ -1,9 +1,9 @@
-using DAT.Configuration;
-using DAT.Utils;
+using Ai.Hgb.Dat.Configuration;
+using Ai.Hgb.Dat.Utils;
 using MemoryPack;
 using System.Net.Mime;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
 
   public interface IMessage : ICloneable {
     string ClientId { get; set; }

diff --git a/src/Communication/InterfaceStore.cs b/src/Communication/InterfaceStore.cs
@@ -1,6 +1,6 @@
 using System.Text;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
 
   public enum CommunicationMode {
     Publish,

diff --git a/src/Communication/PayloadConverter/IPayloadConverter.cs b/src/Communication/PayloadConverter/IPayloadConverter.cs
@@ -1,4 +1,4 @@
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public interface IPayloadConverter {
     byte[] Serialize<T>(T payload);
 

diff --git a/src/Communication/PayloadConverter/JsonPayloadConverter.cs b/src/Communication/PayloadConverter/JsonPayloadConverter.cs
@@ -1,7 +1,7 @@
 using System.Text;
 using System.Text.Json;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class JsonPayloadConverter : IPayloadConverter {
     public T Deserialize<T>(byte[] payload) {
       if (payload == null) return default(T);

diff --git a/src/Communication/PayloadConverter/MemoryPackPayloadConverter.cs b/src/Communication/PayloadConverter/MemoryPackPayloadConverter.cs
@@ -5,7 +5,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class MemoryPackPayloadConverter : IPayloadConverter {
     public T Deserialize<T>(byte[] payload) {
       return MemoryPackSerializer.Deserialize<T>(payload);

diff --git a/src/Communication/PayloadConverter/PayloadConverter.cs b/src/Communication/PayloadConverter/PayloadConverter.cs
@@ -1,11 +1,11 @@
-using DAT.Configuration;
+using Ai.Hgb.Dat.Configuration;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class PayloadConverter {
     private static Dictionary<PayloadFormat, Type> payloadFormatDict
       = new Dictionary<PayloadFormat, Type>

diff --git a/src/Communication/PayloadConverter/YamlPayloadConverter.cs b/src/Communication/PayloadConverter/YamlPayloadConverter.cs
@@ -5,7 +5,7 @@
 using System.Threading.Tasks;
 using YamlDotNet.Serialization;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class YamlPayloadConverter : IPayloadConverter {
 
     private ISerializer ser;

diff --git a/src/Communication/Sockets/ApachekafkaSocket.cs b/src/Communication/Sockets/ApachekafkaSocket.cs
@@ -1,13 +1,13 @@
 using Confluent.Kafka;
-using DAT.Configuration;
-using DAT.Utils;
+using Ai.Hgb.Dat.Configuration;
+using Ai.Hgb.Dat.Utils;
 using Microsoft.Extensions.Configuration;
 using MQTTnet;
 using System.Net;
 using System.Net.Sockets;
 using System.Xml.Linq;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class ApachekafkaSocket : ISocket {
 
     public SocketConfiguration Configuration {

diff --git a/src/Communication/Sockets/DynamicSocket.cs b/src/Communication/Sockets/DynamicSocket.cs
@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Communication.Sockets {
+namespace Ai.Hgb.Dat.Communication.Sockets {
   public class DynamicSocket {
 
     // TBD: hosts different sockets and dynamically at runtime (optionally also autonomously) decides which to use

diff --git a/src/Communication/Sockets/ISocket.cs b/src/Communication/Sockets/ISocket.cs
@@ -1,7 +1,7 @@
-using DAT.Configuration;
-using DAT.Utils;
+using Ai.Hgb.Dat.Configuration;
+using Ai.Hgb.Dat.Utils;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   /// <summary>
   /// This interface describes the base functionality all socket implementations must provide. 
   /// </summary>

diff --git a/src/Communication/Sockets/MqttSocket.cs b/src/Communication/Sockets/MqttSocket.cs
@@ -1,6 +1,6 @@
 using Confluent.Kafka;
-using DAT.Configuration;
-using DAT.Utils;
+using Ai.Hgb.Dat.Configuration;
+using Ai.Hgb.Dat.Utils;
 using MQTTnet;
 using MQTTnet.Client;
 using MQTTnet.Extensions.ManagedClient;
@@ -9,7 +9,7 @@
 using System;
 using System.Net.Mime;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class MqttSocket : ISocket {
 
     public SocketConfiguration Configuration {      
@@ -139,7 +139,7 @@ public object Clone() {
         BlockingActionExecution);
     }
 
-    private void Configuration_ConfigurationChanged(object sender, EventArgs<DAT.Configuration.IConfiguration> e) {      
+    private void Configuration_ConfigurationChanged(object sender, EventArgs<Ai.Hgb.Dat.Configuration.IConfiguration> e) {      
       Console.WriteLine("Udating socket now...");
       var newConfiguration = e.Value as SocketConfiguration;
 

diff --git a/src/Communication/Sockets/SharedMemorySocket.cs b/src/Communication/Sockets/SharedMemorySocket.cs
@@ -8,7 +8,7 @@
 using System.Threading.Tasks;
 using YamlDotNet.Core.Tokens;
 
-namespace DAT.Communication.Sockets {
+namespace Ai.Hgb.Dat.Communication.Sockets {
   public class SharedMemorySocket {
 
     public string Id { get => id; set => id = value; }

diff --git a/src/Communication/Sockets/Socket.cs b/src/Communication/Sockets/Socket.cs
@@ -1,11 +1,11 @@
-using DAT.Configuration;
+using Ai.Hgb.Dat.Configuration;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Communication {
+namespace Ai.Hgb.Dat.Communication {
   public class Socket {
     private static Dictionary<SocketType, Type> socketTypeDict
   = new Dictionary<SocketType, Type>

diff --git a/src/Configuration/Configuration.csproj b/src/Configuration/Configuration.csproj
@@ -4,8 +4,8 @@
     <TargetFramework>net7.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-    <AssemblyName>DAT.$(MSBuildProjectName)</AssemblyName>
-    <RootNamespace>DAT.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>
+    <AssemblyName>Ai.Hgb.Dat.$(MSBuildProjectName)</AssemblyName>
+    <RootNamespace>Ai.Hgb.Dat.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>
   </PropertyGroup>
 
 	<PropertyGroup>

diff --git a/src/Configuration/Configurations/BrokerConfiguration.cs b/src/Configuration/Configurations/BrokerConfiguration.cs
@@ -1,4 +1,4 @@
-using DAT.Utils;
+using Ai.Hgb.Dat.Utils;
 using System;
 using System.Collections.Generic;
 using System.Linq;
@@ -7,7 +7,7 @@
 using System.Threading.Tasks;
 using System.Xml.Linq;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class BrokerConfiguration : IConfiguration {
     public string Type { get; set; }
     public string Url { get; set; }

diff --git a/src/Configuration/Configurations/Configuration.cs b/src/Configuration/Configurations/Configuration.cs
@@ -1,11 +1,11 @@
-using DAT.Utils;
+using Ai.Hgb.Dat.Utils;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class Configuration : IConfiguration {
     public string Type { get; set; }
     public string Url { get; set; }

diff --git a/src/Configuration/Configurations/IConfiguration.cs b/src/Configuration/Configurations/IConfiguration.cs
@@ -1,6 +1,6 @@
-using DAT.Utils;
+using Ai.Hgb.Dat.Utils;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public interface IConfiguration : ICloneable {    
 
     string Type { get; set; }

diff --git a/src/Configuration/Configurations/SocketConfiguration.cs b/src/Configuration/Configurations/SocketConfiguration.cs
@@ -1,11 +1,11 @@
-using DAT.Utils;
+using Ai.Hgb.Dat.Utils;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class SocketConfiguration : IConfiguration {
     public string Type { get; set; }
     public string Url { get; set; }

diff --git a/src/Configuration/DataStructures.cs b/src/Configuration/DataStructures.cs
@@ -6,7 +6,7 @@
 using System.Threading.Tasks;
 using YamlDotNet.Serialization;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class HostAddress {
     public HostAddress() { }
 

diff --git a/src/Configuration/Monitor.cs b/src/Configuration/Monitor.cs
@@ -7,7 +7,7 @@
 using System.Threading.Tasks;
 using YamlDotNet.Core;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class Monitor<T> : BackgroundService where T : IConfiguration {
     public T Configuration { get { return configuration; } set { configuration = value; } }
     public IParser Parser { get { return parser; } private set { parser = value; } }
@@ -25,7 +25,7 @@ public Monitor(IParser parser) {
     }
 
     public void Initialize(string uri) {
-      parser = DAT.Configuration.Parser.GetParser(uri);      
+      parser = Ai.Hgb.Dat.Configuration.Parser.GetParser(uri);      
       configuration = parser.Parse<T>(uri);
       monitorIntervalMilliseconds = Configuration.MonitorIntervalMilliseconds;
       cts = new CancellationTokenSource();

diff --git a/src/Configuration/Parser/IParser.cs b/src/Configuration/Parser/IParser.cs
@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public interface IParser {
     IConfiguration Parse(string uri);
 

diff --git a/src/Configuration/Parser/Parser.cs b/src/Configuration/Parser/Parser.cs
@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public static class Parser {
 
     private static YamlParser yamlParser = null;

diff --git a/src/Configuration/Parser/SidlParser.cs b/src/Configuration/Parser/SidlParser.cs
@@ -4,7 +4,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class SidlParser : IParser {
     public IConfiguration Parse(string uri) {
       throw new NotImplementedException();

diff --git a/src/Configuration/Parser/YamlParser.cs b/src/Configuration/Parser/YamlParser.cs
@@ -6,7 +6,7 @@
 using YamlDotNet.Serialization;
 using YamlDotNet.Serialization.NamingConventions;
 
-namespace DAT.Configuration {
+namespace Ai.Hgb.Dat.Configuration {
   public class YamlParser : IParser {
 
     private ISerializer ser;

diff --git a/src/DemoApp/Configurations/ConsumerConfig.yml b/src/DemoApp/Configurations/ConsumerConfig.yml
@@ -21,4 +21,4 @@ PayloadType: json
 DefaultSubscriptionOptions:
   Topic: docs
   QosLevel: ExactlyOnce
-  ContentTypeFullName: DAT.DemoApp.Document
+  ContentTypeFullName: Ai.Hgb.Dat.DemoApp.Document
diff --git a/src/DemoApp/Configurations/ServerSocket.yml b/src/DemoApp/Configurations/ServerSocket.yml
@@ -26,7 +26,7 @@ DefaultPublicationOptions:
 DefaultSubscriptionOptions:
   Topic: docs
   QosLevel: ExactlyOnce
-  ContentTypeFullName: DAT.DemoApp.Document
+  ContentTypeFullName: Ai.Hgb.Dat.DemoApp.Document
 
 DefaultRequestOptions:
   Topic: docs

diff --git a/src/DemoApp/Configurations/SocketConfig.yml b/src/DemoApp/Configurations/SocketConfig.yml
@@ -26,7 +26,7 @@ DefaultPublicationOptions:
 DefaultSubscriptionOptions:
   Topic: docs
   QosLevel: ExactlyOnce
-  ContentTypeFullName: DAT.DemoApp.Document
+  ContentTypeFullName: Ai.Hgb.Dat.DemoApp.Document
 
 DefaultRequestOptions:
   Topic: docs

diff --git a/src/DemoApp/DataStructures.cs b/src/DemoApp/DataStructures.cs
@@ -5,7 +5,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.DemoApp {
+namespace Ai.Hgb.Dat.DemoApp {
   public struct Document {
 
     public string Id { get; set; }

diff --git a/src/DemoApp/DemoApp.csproj b/src/DemoApp/DemoApp.csproj
@@ -4,8 +4,8 @@
     <OutputType>Exe</OutputType>
     <TargetFramework>net7.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
-    <AssemblyName>DAT.$(MSBuildProjectName)</AssemblyName>
-    <RootNamespace>DAT.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>
+    <AssemblyName>Ai.Hgb.Dat.$(MSBuildProjectName)</AssemblyName>
+    <RootNamespace>Ai.Hgb.Dat.$(MSBuildProjectName.Replace(" ", "_"))</RootNamespace>
     <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
   </PropertyGroup>
 

diff --git a/src/DemoApp/PerformanceTestSuite.cs b/src/DemoApp/PerformanceTestSuite.cs
@@ -1,15 +1,15 @@
-using DAT.Communication;
-using DAT.Communication.Sockets;
-using DAT.Configuration;
-using DAT.Utils;
+using Ai.Hgb.Dat.Communication;
+using Ai.Hgb.Dat.Communication.Sockets;
+using Ai.Hgb.Dat.Configuration;
+using Ai.Hgb.Dat.Utils;
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
-namespace DAT.DemoApp {
+namespace Ai.Hgb.Dat.DemoApp {
   public class PerformanceTestSuite {
 
     public static void RunSuite() {