Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use MessageType class of Microsoft.TestPlatform.Protocol package

Best Vstest code snippet using Microsoft.TestPlatform.Protocol.MessageType

TestRequestHandler.cs

Source:TestRequestHandler.cs

...121        }122        /// <inheritdoc />123        public void SendTestCases(IEnumerable<TestCase> discoveredTestCases)124        {125            var data = this.dataSerializer.SerializePayload(MessageType.TestCasesFound, discoveredTestCases, this.protocolVersion);126            this.SendData(data);127        }128        /// <inheritdoc />129        public void SendTestRunStatistics(TestRunChangedEventArgs testRunChangedArgs)130        {131            var data = this.dataSerializer.SerializePayload(MessageType.TestRunStatsChange, testRunChangedArgs, this.protocolVersion);132            this.SendData(data);133        }134        /// <inheritdoc />135        public void SendLog(TestMessageLevel messageLevel, string message)136        {137            var data = this.dataSerializer.SerializePayload(138                    MessageType.TestMessage,139                    new TestMessagePayload { MessageLevel = messageLevel, Message = message },140                    this.protocolVersion);141            this.SendData(data);142        }143        /// <inheritdoc />144        public void SendExecutionComplete(145                TestRunCompleteEventArgs testRunCompleteArgs,146                TestRunChangedEventArgs lastChunkArgs,147                ICollection<AttachmentSet> runContextAttachments,148                ICollection<string> executorUris)149        {150            // When we abort the run we might have saved the error before we gave the handler the chance to abort151            // if the handler does not return with any new error we report the original one.152            if (testRunCompleteArgs.IsAborted && testRunCompleteArgs.Error == null && this.messageProcessingUnrecoverableError != null)153            {154                var curentArgs = testRunCompleteArgs;155                testRunCompleteArgs = new TestRunCompleteEventArgs(156                    curentArgs.TestRunStatistics,157                    curentArgs.IsCanceled,158                    curentArgs.IsAborted,159                    this.messageProcessingUnrecoverableError,160                    curentArgs.AttachmentSets, curentArgs.ElapsedTimeInRunningTests161                    );162            }163            var data = this.dataSerializer.SerializePayload(164                    MessageType.ExecutionComplete,165                    new TestRunCompletePayload166                    {167                        TestRunCompleteArgs = testRunCompleteArgs,168                        LastRunTests = lastChunkArgs,169                        RunAttachments = runContextAttachments,170                        ExecutorUris = executorUris171                    },172                    this.protocolVersion);173            this.SendData(data);174        }175        /// <inheritdoc />176        public void DiscoveryComplete(DiscoveryCompleteEventArgs discoveryCompleteEventArgs, IEnumerable<TestCase> lastChunk)177        {178            var data = this.dataSerializer.SerializePayload(179                    MessageType.DiscoveryComplete,180                    new DiscoveryCompletePayload181                    {182                        TotalTests = discoveryCompleteEventArgs.TotalCount,183                        LastDiscoveredTests = discoveryCompleteEventArgs.IsAborted ? null : lastChunk,184                        IsAborted = discoveryCompleteEventArgs.IsAborted,185                        Metrics = discoveryCompleteEventArgs.Metrics186                    },187                    this.protocolVersion);188            this.SendData(data);189        }190        /// <inheritdoc />191        public int LaunchProcessWithDebuggerAttached(TestProcessStartInfo testProcessStartInfo)192        {193            var waitHandle = new ManualResetEventSlim(false);194            Message ackMessage = null;195            this.onLaunchAdapterProcessWithDebuggerAttachedAckReceived = (ackRawMessage) =>196            {197                ackMessage = ackRawMessage;198                waitHandle.Set();199            };200            var data = dataSerializer.SerializePayload(MessageType.LaunchAdapterProcessWithDebuggerAttached,201                testProcessStartInfo, protocolVersion);202            this.SendData(data);203            EqtTrace.Verbose("Waiting for LaunchAdapterProcessWithDebuggerAttached ack");204            waitHandle.Wait();205            this.onLaunchAdapterProcessWithDebuggerAttachedAckReceived = null;206            return this.dataSerializer.DeserializePayload<int>(ackMessage);207        }208        /// <inheritdoc />209        public bool AttachDebuggerToProcess(int pid)210        {211            // If an attach request is issued but there is no support for attaching on the other212            // side of the communication channel, we simply return and let the caller know the213            // request failed.214            if (this.protocolVersion < ObjectModelConstants.MinimumProtocolVersionWithDebugSupport)215            {216                return false;217            }218            Message ackMessage = null;219            var waitHandle = new ManualResetEventSlim(false);220            this.onAttachDebuggerAckRecieved = (ackRawMessage) =>221            {222                ackMessage = ackRawMessage;223                waitHandle.Set();224            };225            var data = dataSerializer.SerializePayload(226                MessageType.AttachDebugger,227                new TestProcessAttachDebuggerPayload(pid),228                protocolVersion);229            this.SendData(data);230            EqtTrace.Verbose("Waiting for AttachDebuggerToProcess ack ...");231            waitHandle.Wait();232            this.onAttachDebuggerAckRecieved = null;233            return this.dataSerializer.DeserializePayload<bool>(ackMessage);234        }235        public void OnMessageReceived(object sender, MessageReceivedEventArgs messageReceivedArgs)236        {237            var message = this.dataSerializer.DeserializeMessage(messageReceivedArgs.Data);238            if (EqtTrace.IsInfoEnabled)239            {240                EqtTrace.Info("TestRequestHandler.OnMessageReceived: received message: {0}", message);241            }242            switch (message.MessageType)243            {244                case MessageType.VersionCheck:245                    try246                    {247                        var version = this.dataSerializer.DeserializePayload<int>(message);248                        // choose the highest version that we both support249                        var negotiatedVersion = Math.Min(version, highestSupportedVersion);250                        // BUT don't choose 3, because protocol version 3 has performance problems in 16.7.1-16.8. Those problems are caused251                        // by choosing payloadSerializer instead of payloadSerializer2 for protocol version 3.252                        //253                        // We cannot just update the code to choose the new serializer, because then that change would apply only to testhost.254                        // Testhost is is delivered by Microsoft.NET.Test.SDK nuget package, and can be used with an older vstest.console.255                        // An older vstest.console, that supports protocol version 3, would serialize its messages using payloadSerializer,256                        // but the fixed testhost would serialize it using payloadSerializer2, resulting in incompatible messages.257                        //258                        // Instead we must downgrade to protocol version 2 when 3 would be negotiated. Or higher when higher version259                        // would be negotiated.260                        if (negotiatedVersion != 3)261                        {262                            this.protocolVersion = negotiatedVersion;263                        }264                        else265                        {266                            var flag = Environment.GetEnvironmentVariable("VSTEST_DISABLE_PROTOCOL_3_VERSION_DOWNGRADE");267                            var flagIsEnabled = flag != null && flag != "0";268                            var dowgradeIsDisabled = flagIsEnabled;269                            if (dowgradeIsDisabled)270                            {271                                this.protocolVersion = negotiatedVersion;272                            }273                            else274                            {275                                this.protocolVersion = 2;276                            }277                        }278                        // Send the negotiated protocol to request sender279                        this.channel.Send(this.dataSerializer.SerializePayload(MessageType.VersionCheck, this.protocolVersion));280                        // Can only do this after InitializeCommunication because TestHost cannot "Send Log" unless communications are initialized281                        if (!string.IsNullOrEmpty(EqtTrace.LogFile))282                        {283                            this.SendLog(TestMessageLevel.Informational, string.Format(CrossPlatResources.TesthostDiagLogOutputFile, EqtTrace.LogFile));284                        }285                        else if (!string.IsNullOrEmpty(EqtTrace.ErrorOnInitialization))286                        {287                            this.SendLog(TestMessageLevel.Warning, EqtTrace.ErrorOnInitialization);288                        }289                    }290                    catch (Exception ex)291                    {292                        this.messageProcessingUnrecoverableError = ex;293                        EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);294                        EqtTrace.Error(ex);295                        goto case MessageType.AbortTestRun;296                    }297                    break;298                case MessageType.DiscoveryInitialize:299                    {300                        try301                        {302                            this.testHostManagerFactoryReady.Wait();303                            var discoveryEventsHandler = new TestDiscoveryEventHandler(this);304                            var pathToAdditionalExtensions = this.dataSerializer.DeserializePayload<IEnumerable<string>>(message);305                            Action job = () =>306                            {307                                EqtTrace.Info("TestRequestHandler.OnMessageReceived: Running job '{0}'.", message.MessageType);308                                testHostManagerFactory.GetDiscoveryManager().Initialize(pathToAdditionalExtensions, discoveryEventsHandler);309                            };310                            jobQueue.QueueJob(job, 0);311                        }312                        catch (Exception ex)313                        {314                            this.messageProcessingUnrecoverableError = ex;315                            EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);316                            EqtTrace.Error(ex);317                            goto case MessageType.AbortTestRun;318                        }319                        break;320                    }321                case MessageType.StartDiscovery:322                    {323                        try324                        {325                            this.testHostManagerFactoryReady.Wait();326                            var discoveryEventsHandler = new TestDiscoveryEventHandler(this);327                            var discoveryCriteria = this.dataSerializer.DeserializePayload<DiscoveryCriteria>(message);328                            Action job = () =>329                            {330                                EqtTrace.Info("TestRequestHandler.OnMessageReceived: Running job '{0}'.", message.MessageType);331                                testHostManagerFactory.GetDiscoveryManager()332                                    .DiscoverTests(discoveryCriteria, discoveryEventsHandler);333                            };334                            jobQueue.QueueJob(job, 0);335                        }336                        catch (Exception ex)337                        {338                            this.messageProcessingUnrecoverableError = ex;339                            EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);340                            EqtTrace.Error(ex);341                            goto case MessageType.AbortTestRun;342                        }343                        break;344                    }345                case MessageType.ExecutionInitialize:346                    {347                        try348                        {349                            this.testHostManagerFactoryReady.Wait();350                            var testInitializeEventsHandler = new TestInitializeEventsHandler(this);351                            var pathToAdditionalExtensions = this.dataSerializer.DeserializePayload<IEnumerable<string>>(message);352                            Action job = () =>353                            {354                                EqtTrace.Info("TestRequestHandler.OnMessageReceived: Running job '{0}'.", message.MessageType);355                                testHostManagerFactory.GetExecutionManager().Initialize(pathToAdditionalExtensions, testInitializeEventsHandler);356                            };357                            jobQueue.QueueJob(job, 0);358                        }359                        catch (Exception ex)360                        {361                            this.messageProcessingUnrecoverableError = ex;362                            EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);363                            EqtTrace.Error(ex);364                            goto case MessageType.AbortTestRun;365                        }366                        break;367                    }368                case MessageType.StartTestExecutionWithSources:369                    {370                        try371                        {372                            var testRunEventsHandler = new TestRunEventsHandler(this);373                            this.testHostManagerFactoryReady.Wait();374                            var testRunCriteriaWithSources = this.dataSerializer.DeserializePayload<TestRunCriteriaWithSources>(message);375                            Action job = () =>376                            {377                                EqtTrace.Info("TestRequestHandler.OnMessageReceived: Running job '{0}'.", message.MessageType);378                                testHostManagerFactory.GetExecutionManager()379                                .StartTestRun(380                                    testRunCriteriaWithSources.AdapterSourceMap,381                                    testRunCriteriaWithSources.Package,382                                    testRunCriteriaWithSources.RunSettings,383                                    testRunCriteriaWithSources.TestExecutionContext,384                                    this.GetTestCaseEventsHandler(testRunCriteriaWithSources.RunSettings),385                                    testRunEventsHandler);386                            };387                            jobQueue.QueueJob(job, 0);388                        }389                        catch (Exception ex)390                        {391                            this.messageProcessingUnrecoverableError = ex;392                            EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);393                            EqtTrace.Error(ex);394                            goto case MessageType.AbortTestRun;395                        }396                        break;397                    }398                case MessageType.StartTestExecutionWithTests:399                    {400                        try401                        {402                            var testRunEventsHandler = new TestRunEventsHandler(this);403                            this.testHostManagerFactoryReady.Wait();404                            var testRunCriteriaWithTests =405                                this.dataSerializer.DeserializePayload<TestRunCriteriaWithTests>(message);406                            Action job = () =>407                            {408                                EqtTrace.Info("TestRequestHandler.OnMessageReceived: Running job '{0}'.", message.MessageType);409                                testHostManagerFactory.GetExecutionManager()410                                .StartTestRun(411                                    testRunCriteriaWithTests.Tests,412                                    testRunCriteriaWithTests.Package,413                                    testRunCriteriaWithTests.RunSettings,414                                    testRunCriteriaWithTests.TestExecutionContext,415                                    this.GetTestCaseEventsHandler(testRunCriteriaWithTests.RunSettings),416                                    testRunEventsHandler);417                            };418                            jobQueue.QueueJob(job, 0);419                        }420                        catch (Exception ex)421                        {422                            this.messageProcessingUnrecoverableError = ex;423                            EqtTrace.Error("Failed processing message {0}, aborting test run.", message.MessageType);424                            EqtTrace.Error(ex);425                            goto case MessageType.AbortTestRun;426                        }427                        break;428                    }429                case MessageType.CancelTestRun:430                    jobQueue.Pause();431                    this.testHostManagerFactoryReady.Wait();432                    testHostManagerFactory.GetExecutionManager().Cancel(new TestRunEventsHandler(this));433                    break;434                case MessageType.LaunchAdapterProcessWithDebuggerAttachedCallback:435                    this.onLaunchAdapterProcessWithDebuggerAttachedAckReceived?.Invoke(message);436                    break;437                case MessageType.AttachDebuggerCallback:438                    this.onAttachDebuggerAckRecieved?.Invoke(message);439                    break;440                case MessageType.AbortTestRun:441                    try442                    {443                        jobQueue.Pause();444                        this.testHostManagerFactoryReady.Wait();445                        testHostManagerFactory.GetExecutionManager().Abort(new TestRunEventsHandler(this));446                    }447                    catch (Exception ex)448                    {449                        EqtTrace.Error("Failed processing message {0}. Stopping communication.", message.MessageType);450                        EqtTrace.Error(ex);451                        sessionCompleted.Set();452                        this.Close();453                    }454                    break;455                case MessageType.SessionEnd:456                    {457                        EqtTrace.Info("Session End message received from server. Closing the connection.");458                        sessionCompleted.Set();459                        this.Close();460                        break;461                    }462                case MessageType.SessionAbort:463                    {464                        // Don't do anything for now.465                        break;466                    }467                default:468                    {469                        EqtTrace.Info("Invalid Message types");470                        break;471                    }472            }473        }474        private ITestCaseEventsHandler GetTestCaseEventsHandler(string runSettings)475        {476            ITestCaseEventsHandler testCaseEventsHandler = null;...

ProxyBaseManagerTests.cs

Source:ProxyBaseManagerTests.cs

...70                    s => s.Connected += null,71                    this.mockCommunicationEndpoint.Object,72                    new ConnectedEventArgs(this.mockChannel.Object));73            });74            this.SetupChannelMessage(MessageType.VersionCheck, MessageType.VersionCheck, this.protocolConfig.Version);75            this.testRequestSender.InitializeCommunication();76        }77        public void SetupChannelMessage<TPayload>(string messageType, string returnMessageType, TPayload returnPayload)78        {79            this.mockChannel.Setup(mc => mc.Send(It.Is<string>(s => s.Contains(messageType))))80                .Callback(() => this.mockChannel.Raise(c => c.MessageReceived += null, this.mockChannel.Object, new MessageReceivedEventArgs { Data = messageType }));81            this.mockDataSerializer.Setup(ds => ds.SerializePayload(It.Is<string>(s => s.Equals(messageType)), It.IsAny<object>())).Returns(messageType);82            this.mockDataSerializer.Setup(ds => ds.SerializePayload(It.Is<string>(s => s.Equals(messageType)), It.IsAny<object>(), It.IsAny<int>())).Returns(messageType);83            this.mockDataSerializer.Setup(ds => ds.DeserializeMessage(It.Is<string>(s => s.Equals(messageType)))).Returns(new Message { MessageType = returnMessageType });84            this.mockDataSerializer.Setup(ds => ds.DeserializePayload<TPayload>(It.Is<Message>(m => m.MessageType.Equals(messageType)))).Returns(returnPayload);85        }86        public void RaiseMessageReceived(string data)87        {88            this.mockChannel.Raise(c => c.MessageReceived += null, this.mockChannel.Object,89                new MessageReceivedEventArgs { Data = data });90        }91        protected ProxyDiscoveryManager GetProxyDiscoveryManager()92        {93            this.SetupAndInitializeTestRequestSender();94            var testDiscoveryManager = new ProxyDiscoveryManager(95                mockRequestData.Object,96                testRequestSender,97                mockTestHostManager.Object,98                mockDataSerializer.Object,...

MessageType

Using AI Code Generation

1using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;2using Microsoft.VisualStudio.TestPlatform.ObjectModel;3using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;4using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;5using System;6using System.Collections.Generic;7using System.IO;8using System.Linq;9using System.Text;10using System.Threading.Tasks;11{12    {13        static void Main(string[] args)14        {15            var testHostLauncher = TestPlatform.CreateTestHostLauncher();16            var testHost = testHostLauncher.LaunchTestHost(new TestProcessStartInfo17            {18                ExecutablePath = @"C:\Program Files (x86)\Microsoft Visual Studio\2017\Enterprise\Common7\IDE\CommonExtensions\Microsoft\TestWindow\vstest.console.exe",19                EnvironmentVariables = new Dictionary<string, string>()20            });21            var testPlatform = TestPlatform.Create();22            var testRunRequest = testPlatform.CreateTestRunRequest();23            testRunRequest.DiscoverySettings.DiscoveryAdaptersPath = @"C:\Users\username\Documents\Visual Studio 2017\Projects\test\test\bin\Debug";24            testRunRequest.RunSettings = File.ReadAllText(@"C:\Users\username\Documents\Visual Studio 2017\Projects\test\test\bin\Debug\test.runsettings");25            testRunRequest.OnTestRunMessage += (sender, e) =>26            {27                Console.WriteLine(e.Message);28                if (e.Message.Contains(MessageType.TestResult))29                {30                    Console.WriteLine("Test result received");31                }32            };33            testRunRequest.OnRunStatsChange += (sender, e) =>

MessageType

Using AI Code Generation

1using Microsoft.TestPlatform.CommunicationUtilities.ObjectModel;2using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;3using Microsoft.VisualStudio.TestPlatform.ObjectModel;4using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;5using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;6using System;7using System.Collections.Generic;8using System.Linq;9using System.Text;10using System.Threading.Tasks;11{12    {13        public void DiscoverTests(IEnumerable<string> sources, IDiscoveryContext discoveryContext, IMessageLogger logger, ITestCaseDiscoverySink discoverySink)14        {15            var testCases = new List<TestCase>();16            foreach (var source in sources)17            {18            }19            var message = new DiscoveryCompleteMessage(testCases, false);20            var rawMessage = JsonDataSerializer.Instance.SerializePayload(MessageType.DiscoveryComplete, message);21            logger.SendMessage(TestMessageLevel.Informational, rawMessage);22        }23    }24}25using Microsoft.TestPlatform.CommunicationUtilities.ObjectModel;26using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities;27using Microsoft.VisualStudio.TestPlatform.ObjectModel;28using Microsoft.VisualStudio.TestPlatform.ObjectModel.Client;29using Microsoft.VisualStudio.TestPlatform.ObjectModel.Logging;30using System;31using System.Collections.Generic;32using System.Linq;33using System.Text;34using System.Threading.Tasks;35{36    {37        public void Cancel()38        {39        }40        public void RunTests(IEnumerable<string> sources, IRunContext runContext, IFrameworkHandle frameworkHandle)41        {42            var runSettings = runContext.RunSettings;43            var sourcesToRun = runContext.TestSources;44            var runTestsInIsolation = runContext.IsBeingDebugged;45            var testExecutionContext = runContext.GetTestExecutionContext();46            var parallelRunSettings = runContext.GetParallelRunSettings();47            var runTestsInParallel = parallelRunSettings != null && parallelRunSettings.MaxCpuCount > 1;48            var totalNumberOfTestCases = runContext.TotalNumberOfTests;49            var runEventsHandler = new TestRunEventsHandler(frameworkHandle);50            var testRunCriteria = new TestRunCriteria(sources, runContext.TestRunSettings);51            var testRunConfiguration = new TestRunConfiguration(runTestsInIsolation, runTests

MessageType

Using AI Code Generation

1string message = "Hello World!";2var messagePayload = new MessagePayload() { MessageType = MessageType.TestMessage, Payload = message };3var messageSender = new MessageSender();4messageSender.Send(messagePayload);5string message = "Hello World!";6var messagePayload = new MessagePayload() { MessageType = MessageType.TestMessage, Payload = message };7var messageSender = new MessageSender();8messageSender.Send(messagePayload);

MessageType

Using AI Code Generation

1{2    "Payload": {3    }4}5{6    "Payload": {7    }8}9{10    "Payload": {11    }12}13{14    "Payload": {15    }16}17{18    "Payload": {19    }20}21{22    "Payload": {23    }24}25{26    "Payload": {27    }28}29{

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.