remove test tracing, expand tokio macro and use multithread

Author: Steve Lee (POWERSHELL HE/HIM) (from Dev Box)

dsc/tests/dsc_mcp.tests.ps1

@@ -17,16 +17,13 @@ Describe 'Tests for MCP server' {
             $mcp.StandardInput.WriteLine($request)
             $mcp.StandardInput.Flush()
             if (!$notify) {
-                write-verbose -verbose "peeking stdout"
                 while ($mcp.StandardOutput.Peek() -eq -1) {
                     Start-Sleep -Milliseconds 100
                 }
-                write-verbose -verbose "peeking stderr"
                 while ($mcp.StandardError.Peek() -ne -1) {
                     $stderr = $mcp.StandardError.ReadLine()
                     Write-Verbose -Verbose "MCP STDERR: $stderr"
                 }
-                write-verbose -verbose "reading stdout"
                 $stdout = $mcp.StandardOutput.ReadLine()
                 return ($stdout | ConvertFrom-Json -Depth 30)
             }
@@ -170,9 +167,7 @@ Describe 'Tests for MCP server' {
     }
 
     It 'Calling show_dsc_resource works' {
-        write-verbose -verbose "Listing resources to get a resource type"
-        $resource = (dsc resource list | Select-Object -First 1 | ConvertFrom-Json -Depth 20)
-        write-verbose -verbose "Using resource type '$($resource.type)' for show_dsc_resource test"
+        $resource = (dsc resource list | ConvertFrom-Json -Depth 20 | Select-Object -First 1)
 
         $mcpRequest = @{
             jsonrpc = "2.0"

dsc_lib/src/dscresources/command_resource.rs

@@ -745,22 +745,25 @@ async fn run_process_async(executable: &str, args: Option<Vec<String>>, input: O
 /// Will panic if tokio runtime can't be created.
 ///
 #[allow(clippy::implicit_hasher)]
-#[tokio::main]
-pub async fn invoke_command(executable: &str, args: Option<Vec<String>>, input: Option<&str>, cwd: Option<&str>, env: Option<HashMap<String, String>>, exit_codes: Option<&HashMap<i32, String>>) -> Result<(i32, String, String), DscError> {
-    trace!("{}", t!("dscresources.commandResource.commandInvoke", executable = executable, args = args : {:?}));
-    if let Some(cwd) = cwd {
-        trace!("{}", t!("dscresources.commandResource.commandCwd", cwd = cwd));
-    }
+pub fn invoke_command(executable: &str, args: Option<Vec<String>>, input: Option<&str>, cwd: Option<&str>, env: Option<HashMap<String, String>>, exit_codes: Option<&HashMap<i32, String>>) -> Result<(i32, String, String), DscError> {
+    tokio::runtime::Builder::new_multi_thread().enable_all().build().unwrap().block_on(
+        async {
+            trace!("{}", t!("dscresources.commandResource.commandInvoke", executable = executable, args = args : {:?}));
+            if let Some(cwd) = cwd {
+                trace!("{}", t!("dscresources.commandResource.commandCwd", cwd = cwd));
+            }
 
-    match run_process_async(executable, args, input, cwd, env, exit_codes).await {
-        Ok((code, stdout, stderr)) => {
-            Ok((code, stdout, stderr))
-        },
-        Err(err) => {
-            error!("{}", t!("dscresources.commandResource.runProcessError", executable = executable, error = err));
-            Err(err)
+            match run_process_async(executable, args, input, cwd, env, exit_codes).await {
+                Ok((code, stdout, stderr)) => {
+                    Ok((code, stdout, stderr))
+                },
+                Err(err) => {
+                    error!("{}", t!("dscresources.commandResource.runProcessError", executable = executable, error = err));
+                    Err(err)
+                }
+            }
         }
-    }
+    )
 }
 
 /// Process the arguments for a command resource.