public void Job_CheckStreamingProgress_ExpectSuccess()

in DUTRemoteTests/JobTests.cs [107:165]

• 40 lines of code
• 2 McCabe index (conditional complexity)

        public void Job_CheckStreamingProgress_ExpectSuccess()
        {
            var old_files = Directory.GetFiles(Path.GetTempPath()).Where((x) => x.Contains("SimpleRemote-JobOutput-"));
            old_files.ToList().ForEach(x => File.Delete(x));

            var self = IPAddress.Loopback;
            var completionPort = 0;
            var progressPort = 0;
            string receivedMessage = null;

            // completion server items
            var completionServer = new TcpListener(self, completionPort);
            completionServer.Start(1);
            completionPort = ((IPEndPoint)completionServer.Server.LocalEndPoint).Port;
            var completionClient = completionServer.AcceptTcpClientAsync();

            // progress server items
            var progressServer = new TcpListener(self, progressPort);
            progressServer.Start(1);
            progressPort = ((IPEndPoint)progressServer.Server.LocalEndPoint).Port;
            var progressClient = progressServer.AcceptTcpClientAsync();

            // start streaming job
            var id = remoteFunctions.StartJobWithProgress(self.ToString(), completionPort, progressPort, "systeminfo.exe");

            // wait for completion

            if (!completionClient.Wait(10 * 1000))
            {
                completionServer.Stop();
                progressServer.Stop();
                Assert.Fail("Timed out waiting for callback.");
            }

            remoteFunctions.GetJobResult(id);

            using (var reader = new StreamReader(progressClient.Result.GetStream()))
            {
                receivedMessage = reader.ReadToEnd();
            }

            // clean all sockets.
            progressClient.Result.Dispose();
            completionClient.Result.Dispose();

            progressServer.Stop();
            completionServer.Stop();

            Assert.IsTrue(receivedMessage.Contains("OS Name:"), "Missing expected text from progress stream.");

            // confirm there's a log file.
            var files = Directory.GetFiles(Path.GetTempPath()).Where((x) => x.Contains("SimpleRemote-JobOutput-"));
            Assert.IsTrue(files.Count() == 1, "Incorrect number of fallback logs found.");
            var file = files.First();

            var fileText = File.ReadAllText(file);
            Assert.IsTrue(fileText.Contains("OS Name:"), "Missing expected text from progress file.");
            Assert.IsTrue(fileText.Contains("systeminfo.exe"), "Missing called process name from progress file.");
        }