Initial commit

Author: agocke

.gitignore

@@ -0,0 +1,5 @@
+<Project>
+    <PropertyGroup>
+        <UseArtifactsOutput>true</UseArtifactsOutput>
+    </PropertyGroup>
+</Project>

Directory.Build.props

@@ -0,0 +1,37 @@
+// See https://aka.ms/new-console-template for more information
+using System;
+using System.Security.Cryptography;
+using BenchmarkDotNet.Attributes;
+using BenchmarkDotNet.Running;
+
+namespace MsgPack.Benchmarks;
+
+public class MessagePackUnit
+{
+    private const int N = 10000;
+    private readonly byte[] data;
+
+    private readonly SHA256 sha256 = SHA256.Create();
+    private readonly MD5 md5 = MD5.Create();
+
+    public MessagePackUnit()
+    {
+        data = new byte[N];
+        new Random(42).NextBytes(data);
+    }
+
+    [Benchmark]
+    public byte[] Sha256() => sha256.ComputeHash(data);
+
+    [Benchmark]
+    public byte[] Md5() => md5.ComputeHash(data);
+}
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        var summary = BenchmarkRunner.Run<MessagePackUnit>();
+    }
+}
+

bench/Program.cs

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net9.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="BenchmarkDotNet" Version="0.14.0" />
+  </ItemGroup>
+
+</Project>

bench/bench.csproj

@@ -0,0 +1,28 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.0.31903.59
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Serde.MsgPack.Tests", "tests\Serde.MsgPack.Tests.csproj", "{FC991F6B-67EA-4C86-9BDE-70914D06BA5A}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Serde.MsgPack", "src\Serde.MsgPack.csproj", "{C765AC6A-ACF0-415E-BA83-E05D8CFDF5D9}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{FC991F6B-67EA-4C86-9BDE-70914D06BA5A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FC991F6B-67EA-4C86-9BDE-70914D06BA5A}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FC991F6B-67EA-4C86-9BDE-70914D06BA5A}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{FC991F6B-67EA-4C86-9BDE-70914D06BA5A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{C765AC6A-ACF0-415E-BA83-E05D8CFDF5D9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{C765AC6A-ACF0-415E-BA83-E05D8CFDF5D9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{C765AC6A-ACF0-415E-BA83-E05D8CFDF5D9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{C765AC6A-ACF0-415E-BA83-E05D8CFDF5D9}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+EndGlobal

bench/dotnet

@@ -0,0 +1,29 @@
+
+using System;
+using System.Buffers;
+using System.Runtime.CompilerServices;
+
+namespace Serde.IO;
+
+internal interface IByteReader
+{
+    public const short EndOfStream = -1;
+
+    /// <summary>
+    /// Reads a byte without advancing the stream, or returns <see cref="EndOfStream"/> if the end
+    /// of the stream has been reached.
+    /// </summary>
+    short Peek();
+
+    /// <summary>
+    /// Reads a byte and advances the stream, or returns <see cref="EndOfStream"/> if the end of the
+    /// stream has been reached.
+    /// </summary>
+    short Next();
+
+    /// <summary>
+    /// Advances the stream by <paramref name="count"/> bytes. The caller should ensure there is
+    /// enough remaining data in the stream.
+    /// </summary>
+    void Advance(int count = 1);
+}

serde.msgpack.sln

@@ -0,0 +1,24 @@
+using Serde;
+
+namespace Serde.MsgPack;
+
+public static class MsgPackSerializer
+{
+    public static byte[] Serialize<T>(T value)
+        where T : ISerialize<T>
+    {
+        using var buffer = new ScratchBuffer();
+        var writer = new MsgPackWriter(buffer);
+        value.Serialize(value, writer);
+        return buffer.Span.ToArray();
+    }
+
+    public static byte[] Serialize<T, U>(T value, U proxy)
+        where U : ISerialize<T>
+    {
+        using var buffer = new ScratchBuffer();
+        var writer = new MsgPackWriter(buffer);
+        proxy.Serialize(value, writer);
+        return buffer.Span.ToArray();
+    }
+}

src/IByteReader.cs

@@ -0,0 +1,15 @@
+
+namespace Serde.MsgPack;
+
+partial class MsgPackWriter : ISerializeCollection
+{
+    void ISerializeCollection.End(ISerdeInfo typeInfo)
+    {
+        // No action needed, all collections are length-prefixed
+    }
+
+    void ISerializeCollection.SerializeElement<T, U>(T value, U serialize)
+    {
+        serialize.Serialize(value, this);
+    }
+}

src/MsgPackSerializer.cs

@@ -0,0 +1,17 @@
+
+using Serde;
+
+namespace Serde.MsgPack;
+
+partial class MsgPackWriter : ISerializeType
+{
+    void ISerializeType.End()
+    {
+        // No action needed, all collections are length-prefixed
+    }
+
+    void ISerializeType.SerializeField<T, U>(ISerdeInfo typeInfo, int index, T value, U serialize)
+    {
+        serialize.Serialize(value, this);
+    }
+}