Subscriber topic fix and library loader

.gitignore

@@ -0,0 +1,27 @@
+# Build results
+[Dd]ebug/
+[Dd]ebugPublic/
+[Rr]elease/
+[Rr]eleases/
+x64/
+x86/
+bld/
+[Bb]in/
+[Oo]bj/
+[Ll]og/
+
+**/obj/
+
+*.obj
+
+# Visual Studio >=2015 cache/options directory
+.vs/
+
+# idea
+.idea/
+
+# VSCode
+.vscode/
+
+# cache
+.cache

CSZeroMQ.sln

@@ -2,7 +2,9 @@
 Microsoft Visual Studio Solution File, Format Version 12.00
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CSZeroMQ", "CSZeroMQ\CSZeroMQ.csproj", "{8AF25931-AD99-4F75-9796-D7BBD19E25BC}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CSZeroMQ.ExampleApp", "CSZeroMQ.ExampleApp\CSZeroMQ.ExampleApp.csproj", "{85E8C051-962E-42A0-8EE9-E833F558B5F0}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CSZeroMQSubscriber", "CSZeroMQSubscriber\CSZeroMQSubscriber.csproj", "{47BED99C-53C7-4ABE-8654-692916F13696}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "CSZeroMQPublisher", "CSZeroMQPublisher\CSZeroMQPublisher.csproj", "{68053A27-C5D0-4CC7-9693-9B27F710A4DC}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -14,9 +16,13 @@ Global
 		{8AF25931-AD99-4F75-9796-D7BBD19E25BC}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{8AF25931-AD99-4F75-9796-D7BBD19E25BC}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{8AF25931-AD99-4F75-9796-D7BBD19E25BC}.Release|Any CPU.Build.0 = Release|Any CPU
-		{85E8C051-962E-42A0-8EE9-E833F558B5F0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{85E8C051-962E-42A0-8EE9-E833F558B5F0}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{85E8C051-962E-42A0-8EE9-E833F558B5F0}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{85E8C051-962E-42A0-8EE9-E833F558B5F0}.Release|Any CPU.Build.0 = Release|Any CPU
+		{47BED99C-53C7-4ABE-8654-692916F13696}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{47BED99C-53C7-4ABE-8654-692916F13696}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{47BED99C-53C7-4ABE-8654-692916F13696}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{47BED99C-53C7-4ABE-8654-692916F13696}.Release|Any CPU.Build.0 = Release|Any CPU
+		{68053A27-C5D0-4CC7-9693-9B27F710A4DC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{68053A27-C5D0-4CC7-9693-9B27F710A4DC}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{68053A27-C5D0-4CC7-9693-9B27F710A4DC}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{68053A27-C5D0-4CC7-9693-9B27F710A4DC}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal

CSZeroMQ/CSZeroMQ.csproj

@@ -14,8 +14,12 @@
         <Authors>jgcodes2020</Authors>
 
     </PropertyGroup>
-
     <ItemGroup>
+        <EmbeddedResource Include="runtimes\win10_x64\native\libzmq-v143-mt-4_3_5.dll" />
+        <EmbeddedResource Include="runtimes\linux_x64\native\libzmq.so" />
+        <EmbeddedResource Include="runtimes\osx_x64\native\libzmq.dylib" />
+    </ItemGroup>
+    <!--ItemGroup>
         <Content Include="runtimes\win10-x64\native\libzmq.dll">
             <PackagePath>runtimes/win10-x64/native/libzmq.dll</PackagePath>
             <Pack>true</Pack>
@@ -31,5 +35,12 @@
             <Pack>true</Pack>
             <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
         </Content>
+    </ItemGroup-->
+
+    <ItemGroup>
+      <PackageReference Include="NativeLibraryManager" Version="1.0.23" />
+      <PackageReference Include="Serilog" Version="4.0.2-dev-02220" />
+      <PackageReference Include="Serilog.Extensions.Logging" Version="8.0.1-dev-10398" />
+      <PackageReference Include="Serilog.Sinks.Console" Version="6.0.0" />
     </ItemGroup>
 </Project>

CSZeroMQ/Constants/SocketOption.cs

@@ -182,6 +182,8 @@ public enum SocketOptionString : int
     SocksProxy = 68,
     [StringSockOptDescriptor(false)]
     ZapDomain = 55,
+    [StringSockOptDescriptor(true)]
+    Subscribe = 6,
 }
 
 public enum SocketOptionBin : int

CSZeroMQ/Native/NativeLibLoader.cs

@@ -0,0 +1,47 @@
+using Microsoft.Extensions.Logging;
+using NativeLibraryManager;
+using Serilog.Extensions.Logging;
+using System.Reflection;
+
+
+namespace CSZeroMQ.Native;
+
+public static class NativeLibLoader
+{
+    private static readonly LibraryManager LibManager;
+    private static readonly LoggerFactory Factory = new LoggerFactory(new[] {new SerilogLoggerProvider() });
+    private static readonly ResourceAccessor Accessor = new ResourceAccessor(Assembly.GetExecutingAssembly());
+    static NativeLibLoader()
+    {
+        try
+        {
+            LibManager = new LibraryManager(
+                Factory,
+                new LibraryItem(Platform.MacOs, Bitness.x64,
+                    new LibraryFile("libzmq.dylib", Accessor.Binary("runtimes.osx_x64.native.libzmq.dylib"))),
+                new LibraryItem(Platform.Windows, Bitness.x64,
+                    new LibraryFile("libzmq.dll", Accessor.Binary("runtimes.win10_x64.native.libzmq-v143-mt-4_3_5.dll"))),
+                new LibraryItem(Platform.Linux, Bitness.x64, 
+                    new LibraryFile("libzmq.so", Accessor.Binary("runtimes.linux_x64.native.libzmq.so")))
+            );
+        }
+        catch (Exception e)
+        {
+            Console.WriteLine(e);
+            throw new Exception("Loading Native Library Issue");
+        }
+    }
+
+    public static void LoadLibrary()
+    {
+        try
+        {
+            LibManager.LoadNativeLibrary();
+        }
+        catch (Exception e)
+        {
+            Console.WriteLine(e);
+            throw new Exception("Loading Native Library Issue");
+        }
+    }
+}

CSZeroMQ/Native/ZMQ.gen.cs

@@ -1,5 +1,6 @@
 using System.Runtime.InteropServices;
 
+
 namespace CSZeroMQ.Native
 {
     public unsafe partial struct zmq_msg_t
@@ -35,9 +36,15 @@ public unsafe partial struct win_zmq_pollitem_t
     public partial struct iovec
     {
     }
-
-    public static unsafe partial class ZMQ
+    
+    public unsafe class ZMQ
     {
+        static ZMQ()
+        {
+            // Load the native library when the ZMQ class is accessed for the first time
+            NativeLibLoader.LoadLibrary();
+        }
+
         [DllImport("libzmq", CallingConvention = CallingConvention.Cdecl, ExactSpelling = true, SetLastError = true)]
         public static extern int zmq_errno();
 

CSZeroMQ/ZMQContext.cs

@@ -1,4 +1,3 @@
-using CSZeroMQ.Constants;
 using CSZeroMQ.Native;
 using static CSZeroMQ.Native.ZMQ;