Bring ZLib in locally. (#132)

Projects/ZLib/Utility.cs

@@ -0,0 +1,13 @@
+using System.Runtime.InteropServices;
+
+namespace Server
+{
+  internal static class RuntimeUtility
+  {
+    internal static readonly bool IsWindows = RuntimeInformation.IsOSPlatform(OSPlatform.Windows);
+    internal static readonly bool IsDarwin = RuntimeInformation.IsOSPlatform(OSPlatform.OSX);
+    internal static readonly bool IsFreeBSD = RuntimeInformation.IsOSPlatform(OSPlatform.FreeBSD);
+    internal static readonly bool IsLinux = RuntimeInformation.IsOSPlatform(OSPlatform.Linux) || IsFreeBSD;
+    internal static readonly bool IsUnix = IsDarwin || IsFreeBSD || IsLinux;
+  }
+}

Projects/ZLib/ZLib.cs

@@ -0,0 +1,208 @@
+using System;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+namespace Server.Compression
+{
+  public static class ZLib
+  {
+    public static readonly ICompressor Compressor;
+
+    static ZLib()
+    {
+      if (RuntimeUtility.IsUnix)
+        Compressor = new UnixCompressor();
+      else
+        Compressor = new Compressor();
+    }
+
+    public static int MaxPackSize(int sourceLength) => (int)Compressor.CompressBound((ulong)sourceLength);
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref int destLength, ReadOnlySpan<byte> source, int sourceLength)
+    {
+      var destLengthLong = (ulong)destLength;
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        var e = Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLengthLong, Unsafe.AsRef<int>(sPtr),
+          (ulong)sourceLength);
+        destLength = (int)destLengthLong;
+        return e;
+      }
+    }
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref int destLength, ReadOnlySpan<byte> source, ZLibQuality quality)
+    {
+      var destLengthLong = (ulong)destLength;
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        var e = Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLengthLong, Unsafe.AsRef<int>(sPtr),
+          (ulong)source.Length, quality);
+        destLength = (int)destLengthLong;
+        return e;
+      }
+    }
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref int destLength, ReadOnlySpan<byte> source, int sourceLength,
+      ZLibQuality quality)
+    {
+      var destLengthLong = (ulong)destLength;
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        var e = Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLengthLong, Unsafe.AsRef<int>(sPtr),
+          (ulong)sourceLength, quality);
+        destLength = (int)destLengthLong;
+        return e;
+      }
+    }
+
+    public static unsafe ZLibError Unpack(Span<byte> dest, ref int destLength, ReadOnlySpan<byte> source, int sourceLength)
+    {
+      var destLengthLong = (ulong)destLength;
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        var e = Compressor.Decompress(Unsafe.AsRef<int>(dPtr), ref destLengthLong, Unsafe.AsRef<int>(sPtr),
+          (ulong)sourceLength);
+        destLength = (int)destLengthLong;
+        return e;
+      }
+    }
+
+    public static ulong MaxPackSize(ulong sourceLength) => Compressor.CompressBound(sourceLength);
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref ulong destLength, ReadOnlySpan<byte> source, ulong sourceLength)
+    {
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        return Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLength, Unsafe.AsRef<int>(sPtr), sourceLength);
+      }
+    }
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref ulong destLength, ReadOnlySpan<byte> source,
+      ZLibQuality quality)
+    {
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        return Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLength, Unsafe.AsRef<int>(sPtr), (ulong)source.Length,
+          quality);
+      }
+    }
+
+    public static unsafe ZLibError Pack(Span<byte> dest, ref ulong destLength, ReadOnlySpan<byte> source, ulong sourceLength,
+      ZLibQuality quality)
+    {
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        return Compressor.Compress(Unsafe.AsRef<int>(dPtr), ref destLength, Unsafe.AsRef<int>(sPtr), sourceLength, quality);
+      }
+    }
+
+    public static unsafe ZLibError Unpack(Span<byte> dest, ref ulong destLength, ReadOnlySpan<byte> source,
+      ulong sourceLength)
+    {
+      fixed (byte* dPtr = &MemoryMarshal.GetReference(dest), sPtr = &MemoryMarshal.GetReference(source))
+      {
+        return Compressor.Decompress(Unsafe.AsRef<int>(dPtr), ref destLength, Unsafe.AsRef<int>(sPtr), sourceLength);
+      }
+    }
+  }
+
+  public interface ICompressor
+  {
+    string Version { get; }
+    ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+    ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength, ZLibQuality quality);
+    ZLibError Decompress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+    ulong CompressBound(ulong sourceLength);
+  }
+
+  public class Compressor : ICompressor
+  {
+    public string Version => SafeNativeMethods.zlibVersion();
+
+    public ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength) =>
+      SafeNativeMethods.compress(dest, ref destLength, source, sourceLength);
+
+    public ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength,
+      ZLibQuality quality) => SafeNativeMethods.compress2(dest, ref destLength, source, sourceLength, quality);
+
+    public ZLibError Decompress(in int dest, ref ulong destLength, in int source, ulong sourceLength) =>
+      SafeNativeMethods.uncompress(dest, ref destLength, source, sourceLength);
+
+    public ulong CompressBound(ulong sourceLength) => SafeNativeMethods.compressBound(sourceLength);
+
+    private static class SafeNativeMethods
+    {
+      [DllImport("zlib", CharSet = CharSet.Unicode)]
+      internal static extern string zlibVersion();
+
+      [DllImport("zlib")]
+      internal static extern ZLibError compress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+
+      [DllImport("zlib")]
+      internal static extern ZLibError compress2(in int dest, ref ulong destLength, in int source, ulong sourceLength,
+        ZLibQuality quality);
+
+      [DllImport("zlib")]
+      internal static extern ZLibError uncompress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+
+      [DllImport("zlib")]
+      internal static extern ulong compressBound(ulong sourceLen);
+    }
+  }
+
+  public class UnixCompressor : ICompressor
+  {
+    public string Version => SafeNativeMethods.zlibVersion();
+
+    public ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength) =>
+      SafeNativeMethods.compress(dest, ref destLength, source, sourceLength);
+
+    public ZLibError Compress(in int dest, ref ulong destLength, in int source, ulong sourceLength,
+      ZLibQuality quality) => SafeNativeMethods.compress2(dest, ref destLength, source, sourceLength, quality);
+
+    public ZLibError Decompress(in int dest, ref ulong destLength, in int source, ulong sourceLength) =>
+      SafeNativeMethods.uncompress(dest, ref destLength, source, sourceLength);
+
+    public ulong CompressBound(ulong sourceLength) => SafeNativeMethods.compressBound(sourceLength);
+
+    internal static class SafeNativeMethods
+    {
+      [DllImport("libz", CharSet = CharSet.Unicode)]
+      internal static extern string zlibVersion();
+
+      [DllImport("libz")]
+      internal static extern ZLibError compress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+
+      [DllImport("libz")]
+      internal static extern ZLibError compress2(in int dest, ref ulong destLength, in int source, ulong sourceLength,
+        ZLibQuality quality);
+
+      [DllImport("libz")]
+      internal static extern ZLibError uncompress(in int dest, ref ulong destLength, in int source, ulong sourceLength);
+
+      [DllImport("libz")]
+      internal static extern ulong compressBound(ulong sourceLen);
+    }
+  }
+
+  public enum ZLibError
+  {
+    VersionError = -6,
+    BufferError = -5,
+    MemoryError = -4,
+    DataError = -3,
+    StreamError = -2,
+    FileError = -1,
+    Okay = 0,
+    StreamEnd = 1,
+    NeedDictionary = 2
+  }
+
+  public enum ZLibQuality
+  {
+    Default = -1,
+    None = 0,
+    Speed = 1,
+    Size = 9
+  }
+}

Projects/ZLib/ZLib.csproj

@@ -0,0 +1,35 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <RuntimeIdentifiers>win-x64;linux-x64;osx-x64</RuntimeIdentifiers>
+    <PackageVersion>1.0.0</PackageVersion>
+    <RootNamespace>Server</RootNamespace>
+    <AssemblyName>ZLib.Bindings</AssemblyName>
+    <PlatformTarget>x64</PlatformTarget>
+    <LangVersion>8.0</LangVersion>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+    <IsPackable>true</IsPackable>
+    <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
+    <GeneratePackageOnBuild>false</GeneratePackageOnBuild>
+    <GenerateAssemblyInfo>false</GenerateAssemblyInfo>
+    <Configurations>Debug;Release;Analyze</Configurations>
+    <AssemblyVersion>1.0.0</AssemblyVersion>
+    <Platforms>x64</Platforms>
+  </PropertyGroup>
+  <ItemGroup>
+    <Content Include="runtimes\win-x64\native\zlib.dll">
+      <Pack>true</Pack>
+      <PackagePath>runtimes/win-x64/native</PackagePath>
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+    <Content Include="runtimes\osx-x64\native\libz.dylib">
+      <Pack>true</Pack>
+      <PackagePath>runtimes/osx-x64/native</PackagePath>
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+    <Content Include="runtimes\linux-x64\native\libz.so">
+      <Pack>true</Pack>
+      <PackagePath>runtimes/linux-x64/native</PackagePath>
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+  </ItemGroup>
+</Project>