Use EasyNamedPipes for dotnet test protocol

Directory.Packages.props

@@ -32,6 +32,7 @@
     <MicrosoftCodeAnalysisAnalyzerTestingVersion>1.1.3-beta1.24423.1</MicrosoftCodeAnalysisAnalyzerTestingVersion>
   </PropertyGroup>
   <ItemGroup Label="Analyzers">
+    <PackageVersion Include="EasyNamedPipes.SourceGenerator" Version="1.0.0-beta.2" />
     <PackageVersion Include="Microsoft.CodeAnalysis.BannedApiAnalyzers" Version="$(MicrosoftCodeAnalysisBannedApiAnalyzersVersion)" />
     <PackageVersion Include="Microsoft.CodeAnalysis.PublicApiAnalyzers" Version="$(MicrosoftCodeAnalysisPublicApiAnalyzersVersion)" />
     <PackageVersion Include="Microsoft.VisualStudio.Threading.Analyzers" Version="17.14.15" />
@@ -40,10 +41,8 @@
   <ItemGroup Label="Product dependencies">
     <!-- If this gets updated, please revise if the explicit dependency on System.Diagnostics.DiagnosticSource is still needed -->
     <PackageVersion Include="Microsoft.ApplicationInsights" Version="2.23.0" />
-
     <!-- This comes transitvely via Microsoft.ApplicationInsights, but we want to upgrade it because 5.0.0 is not maintained -->
     <PackageVersion Include="System.Diagnostics.DiagnosticSource" Version="6.0.0" />
-
     <PackageVersion Include="Microsoft.Build.Framework" Version="$(MicrosoftBuildVersion)" />
     <PackageVersion Include="Microsoft.Build.Utilities.Core" Version="$(MicrosoftBuildVersion)" />
     <PackageVersion Include="Microsoft.CodeAnalysis" Version="$(MicrosoftCodeAnalysisVersion)" />
@@ -94,4 +93,4 @@
   <ItemGroup Label="Declared by MSTest.Sdk but not used directly">
     <PackageVersion Include="Microsoft.Playwright.MSTest.v4" Version="$(MicrosoftPlaywrightVersion)" />
   </ItemGroup>
-</Project>
+</Project>

src/Platform/Microsoft.Testing.Platform/IPC/Serializers/RegisterSerializers.cs

@@ -29,11 +29,11 @@
         namedPipeBase.RegisterSerializer(new VoidResponseSerializer(), typeof(VoidResponse));
         namedPipeBase.RegisterSerializer(new TestHostProcessExitRequestSerializer(), typeof(TestHostProcessExitRequest));
         namedPipeBase.RegisterSerializer(new TestHostProcessPIDRequestSerializer(), typeof(TestHostProcessPIDRequest));
-        namedPipeBase.RegisterSerializer(new CommandLineOptionMessagesSerializer(), typeof(CommandLineOptionMessages));
-        namedPipeBase.RegisterSerializer(new DiscoveredTestMessagesSerializer(), typeof(DiscoveredTestMessages));
-        namedPipeBase.RegisterSerializer(new TestResultMessagesSerializer(), typeof(TestResultMessages));
-        namedPipeBase.RegisterSerializer(new FileArtifactMessagesSerializer(), typeof(FileArtifactMessages));
-        namedPipeBase.RegisterSerializer(new TestSessionEventSerializer(), typeof(TestSessionEvent));
-        namedPipeBase.RegisterSerializer(new HandshakeMessageSerializer(), typeof(HandshakeMessage));
+        namedPipeBase.RegisterSerializer(CommandLineOptionMessagesSerializer.Instance, typeof(CommandLineOptionMessages));
+        namedPipeBase.RegisterSerializer(DiscoveredTestMessagesSerializer.Instance, typeof(DiscoveredTestMessages));
+        namedPipeBase.RegisterSerializer(TestResultMessagesSerializer.Instance, typeof(TestResultMessages));
+        namedPipeBase.RegisterSerializer(FileArtifactMessagesSerializer.Instance, typeof(FileArtifactMessages));
+        namedPipeBase.RegisterSerializer(TestSessionEventSerializer.Instance, typeof(TestSessionEvent));
+        namedPipeBase.RegisterSerializer(HandshakeMessageSerializer.Instance, typeof(HandshakeMessage));
     }
 }

src/Platform/Microsoft.Testing.Platform/Microsoft.Testing.Platform.csproj

@@ -83,6 +83,7 @@ This package provides the core platform and the .NET implementation of the proto
   </ItemGroup>
 
   <ItemGroup>
+    <PackageReference Include="EasyNamedPipes.SourceGenerator" />
     <PackageReference Include="Polyfill" PrivateAssets="all" />
   </ItemGroup>
 

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/CommandLineOptionMessages.cs

@@ -1,8 +1,17 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record CommandLineOptionMessage(string? Name, string? Description, bool? IsHidden, bool? IsBuiltIn);
+internal sealed record CommandLineOptionMessage(
+    [property: PipePropertyId(1)] string? Name,
+    [property: PipePropertyId(2)] string? Description,
+    [property: PipePropertyId(3)] bool? IsHidden,
+    [property: PipePropertyId(4)] bool? IsBuiltIn);
 
-internal sealed record CommandLineOptionMessages(string? ModulePath, CommandLineOptionMessage[]? CommandLineOptionMessageList) : IRequest;
+[PipeSerializableMessage("DotNetTestProtocol", 3)]
+internal sealed record CommandLineOptionMessages(
+    [property: PipePropertyId(1)] string? ModulePath,
+    [property: PipePropertyId(2)] CommandLineOptionMessage[]? CommandLineOptionMessageList) : IRequest;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/DiscoveredTestMessages.cs

@@ -1,10 +1,26 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 using Microsoft.Testing.Platform.Extensions.Messages;
 
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record DiscoveredTestMessage(string? Uid, string? DisplayName, string? FilePath, int? LineNumber, string? Namespace, string? TypeName, string? MethodName, string[]? ParameterTypeFullNames, TestMetadataProperty[] Traits);
+internal sealed record DiscoveredTestMessage(
+    [property: PipePropertyId(1)] string? Uid,
+    [property: PipePropertyId(2)] string? DisplayName,
+    [property: PipePropertyId(3)] string? FilePath,
+    [property: PipePropertyId(4)] int? LineNumber,
+    [property: PipePropertyId(5)] string? Namespace,
+    [property: PipePropertyId(6)] string? TypeName,
+    [property: PipePropertyId(7)] string? MethodName,
+    [property: PipePropertyId(8)] string[]? ParameterTypeFullNames,
+    [property: PipePropertyId(9)] TestMetadataProperty[] Traits);
 
-internal sealed record DiscoveredTestMessages(string? ExecutionId, string? InstanceId, DiscoveredTestMessage[] DiscoveredMessages) : IRequest;
+[PipeSerializableMessage("DotNetTestProtocol", 5)]
+internal sealed record DiscoveredTestMessages(
+    [property: PipePropertyId(1)] string? ExecutionId,
+    [property: PipePropertyId(2)] string? InstanceId,
+    [property: PipePropertyId(3)] DiscoveredTestMessage[] DiscoveredMessages)
+    : IRequest;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/FileArtifactMessages.cs

@@ -1,8 +1,21 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record FileArtifactMessage(string? FullPath, string? DisplayName, string? Description, string? TestUid, string? TestDisplayName, string? SessionUid);
+internal sealed record FileArtifactMessage(
+    [property: PipePropertyId(1)] string? FullPath,
+    [property: PipePropertyId(2)] string? DisplayName,
+    [property: PipePropertyId(3)] string? Description,
+    [property: PipePropertyId(4)] string? TestUid,
+    [property: PipePropertyId(5)] string? TestDisplayName,
+    [property: PipePropertyId(6)] string? SessionUid);
 
-internal sealed record FileArtifactMessages(string? ExecutionId, string? InstanceId, FileArtifactMessage[] FileArtifacts) : IRequest;
+[PipeSerializableMessage("DotNetTestProtocol", 7)]
+internal sealed record FileArtifactMessages(
+    [property: PipePropertyId(1)] string? ExecutionId,
+    [property: PipePropertyId(2)] string? InstanceId,
+    [property: PipePropertyId(3)] FileArtifactMessage[] FileArtifacts)
+    : IRequest;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/HandshakeMessage.cs

@@ -1,6 +1,11 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record HandshakeMessage(Dictionary<byte, string>? Properties) : IRequest, IResponse;
+[PipeSerializableMessage("DotNetTestProtocol", 9)]
+internal sealed record HandshakeMessage(
+    [property: PipePropertyId(1)] Dictionary<byte, string>? Properties)
+    : IRequest, IResponse;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/TestResultMessages.cs

@@ -1,12 +1,40 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record SuccessfulTestResultMessage(string? Uid, string? DisplayName, byte? State, long? Duration, string? Reason, string? StandardOutput, string? ErrorOutput, string? SessionUid);
+internal sealed record SuccessfulTestResultMessage(
+    [property: PipePropertyId(1)] string? Uid,
+    [property: PipePropertyId(2)] string? DisplayName,
+    [property: PipePropertyId(3)] byte? State,
+    [property: PipePropertyId(4)] long? Duration,
+    [property: PipePropertyId(5)] string? Reason,
+    [property: PipePropertyId(6)] string? StandardOutput,
+    [property: PipePropertyId(7)] string? ErrorOutput,
+    [property: PipePropertyId(8)] string? SessionUid);
 
-internal sealed record FailedTestResultMessage(string? Uid, string? DisplayName, byte? State, long? Duration, string? Reason, ExceptionMessage[]? Exceptions, string? StandardOutput, string? ErrorOutput, string? SessionUid);
+internal sealed record FailedTestResultMessage(
+    [property: PipePropertyId(1)] string? Uid,
+    [property: PipePropertyId(2)] string? DisplayName,
+    [property: PipePropertyId(3)] byte? State,
+    [property: PipePropertyId(4)] long? Duration,
+    [property: PipePropertyId(5)] string? Reason,
+    [property: PipePropertyId(6)] ExceptionMessage[]? Exceptions,
+    [property: PipePropertyId(7)] string? StandardOutput,
+    [property: PipePropertyId(8)] string? ErrorOutput,
+    [property: PipePropertyId(9)] string? SessionUid);
 
-internal sealed record ExceptionMessage(string? ErrorMessage, string? ErrorType, string? StackTrace);
+internal sealed record ExceptionMessage(
+    [property: PipePropertyId(1)] string? ErrorMessage,
+    [property: PipePropertyId(2)] string? ErrorType,
+    [property: PipePropertyId(3)] string? StackTrace);
 
-internal sealed record TestResultMessages(string? ExecutionId, string? InstanceId, SuccessfulTestResultMessage[] SuccessfulTestMessages, FailedTestResultMessage[] FailedTestMessages) : IRequest;
+[PipeSerializableMessage("DotNetTestProtocol", 6)]
+internal sealed record TestResultMessages(
+    [property: PipePropertyId(1)] string? ExecutionId,
+    [property: PipePropertyId(2)] string? InstanceId,
+    [property: PipePropertyId(3)] SuccessfulTestResultMessage[] SuccessfulTestMessages,
+    [property: PipePropertyId(4)] FailedTestResultMessage[] FailedTestMessages)
+    : IRequest;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/Models/TestSessionEvent.cs

@@ -1,6 +1,13 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
 
+using EasyNamedPipes;
+
 namespace Microsoft.Testing.Platform.IPC.Models;
 
-internal sealed record TestSessionEvent(byte? SessionType, string? SessionUid, string? ExecutionId) : IRequest;
+[PipeSerializableMessage("DotNetTestProtocol", 8)]
+internal sealed record TestSessionEvent(
+    [property: PipePropertyId(1)] byte? SessionType,
+    [property: PipePropertyId(2)] string? SessionUid,
+    [property: PipePropertyId(3)] string? ExecutionId)
+    : IRequest;

src/Platform/Microsoft.Testing.Platform/ServerMode/DotnetTest/IPC/ObjectFieldIds.cs

@@ -22,14 +22,6 @@ internal static class TestHostProcessPIDRequestFieldsId
     public const int MessagesSerializerId = 2;
 }
 
-internal static class CommandLineOptionMessagesFieldsId
-{
-    public const int MessagesSerializerId = 3;
-
-    public const ushort ModulePath = 1;
-    public const ushort CommandLineOptionMessageList = 2;
-}
-
 internal static class CommandLineOptionMessageFieldsId
 {
     public const ushort Name = 1;
@@ -38,15 +30,6 @@ internal static class CommandLineOptionMessageFieldsId
     public const ushort IsBuiltIn = 4;
 }
 
-internal static class DiscoveredTestMessagesFieldsId
-{
-    public const int MessagesSerializerId = 5;
-
-    public const ushort ExecutionId = 1;
-    public const ushort InstanceId = 2;
-    public const ushort DiscoveredTestMessageList = 3;
-}
-
 internal static class DiscoveredTestMessageFieldsId
 {
     public const ushort Uid = 1;
@@ -59,84 +42,3 @@ internal static class DiscoveredTestMessageFieldsId
     public const ushort Traits = 8;
     public const ushort ParameterTypeFullNames = 9;
 }
-
-internal static class TraitMessageFieldsId
-{
-    public const ushort Key = 1;
-    public const ushort Value = 2;
-}
-
-internal static class TestResultMessagesFieldsId
-{
-    public const int MessagesSerializerId = 6;
-
-    public const ushort ExecutionId = 1;
-    public const ushort InstanceId = 2;
-    public const ushort SuccessfulTestMessageList = 3;
-    public const ushort FailedTestMessageList = 4;
-}
-
-internal static class SuccessfulTestResultMessageFieldsId
-{
-    public const ushort Uid = 1;
-    public const ushort DisplayName = 2;
-    public const ushort State = 3;
-    public const ushort Duration = 4;
-    public const ushort Reason = 5;
-    public const ushort StandardOutput = 6;
-    public const ushort ErrorOutput = 7;
-    public const ushort SessionUid = 8;
-}
-
-internal static class FailedTestResultMessageFieldsId
-{
-    public const ushort Uid = 1;
-    public const ushort DisplayName = 2;
-    public const ushort State = 3;
-    public const ushort Duration = 4;
-    public const ushort Reason = 5;
-    public const ushort ExceptionMessageList = 6;
-    public const ushort StandardOutput = 7;
-    public const ushort ErrorOutput = 8;
-    public const ushort SessionUid = 9;
-}
-
-internal static class ExceptionMessageFieldsId
-{
-    public const ushort ErrorMessage = 1;
-    public const ushort ErrorType = 2;
-    public const ushort StackTrace = 3;
-}
-
-internal static class FileArtifactMessagesFieldsId
-{
-    public const int MessagesSerializerId = 7;
-
-    public const ushort ExecutionId = 1;
-    public const ushort InstanceId = 2;
-    public const ushort FileArtifactMessageList = 3;
-}
-
-internal static class FileArtifactMessageFieldsId
-{
-    public const ushort FullPath = 1;
-    public const ushort DisplayName = 2;
-    public const ushort Description = 3;
-    public const ushort TestUid = 4;
-    public const ushort TestDisplayName = 5;
-    public const ushort SessionUid = 6;
-}
-
-internal static class TestSessionEventFieldsId
-{
-    public const int MessagesSerializerId = 8;
-
-    public const ushort SessionType = 1;
-    public const ushort SessionUid = 2;
-    public const ushort ExecutionId = 3;
-}
-
-internal static class HandshakeMessageFieldsId
-{
-    public const int MessagesSerializerId = 9;
-}