Concurrent installation

src/code/ContainerRegistryServerAPICalls.cs

@@ -81,6 +81,16 @@ public ContainerRegistryServerAPICalls(PSRepositoryInfo repository, PSCmdlet cmd
 
         #region Overridden Methods
 
+        public override Task<FindResults> FindVersionAsync(string packageName, string version, ResourceType type)
+        {
+            return null;    
+        }
+
+        public override Task<FindResults> FindVersionGlobbingAsync(string packageName, VersionRange versionRange, bool includePrerelease, ResourceType type, bool getOnlyLatest)
+        {
+            return null;    
+        }
+
         /// <summary>
         /// Find method which allows for searching for all packages from a repository and returns latest version for each.
         /// </summary>
@@ -146,6 +156,12 @@ public override FindResults FindName(string packageName, bool includePrerelease,
             return new FindResults(stringResponse: new string[] { }, hashtableResponse: pkgResult.ToArray(), responseType: containerRegistryFindResponseType);
         }
 
+
+        public override Task<FindResults> FindNameAsync(string packageName, bool includePrerelease, ResourceType type)
+        {
+            return null;    
+        }
+
         /// <summary>
         /// Find method which allows for searching for single name and tag and returns latest version.
         /// Name: no wildcard support

src/code/LocalServerApiCalls.cs

@@ -13,6 +13,7 @@
 using System.Net;
 using System.Management.Automation;
 using System.Runtime.ExceptionServices;
+using System.Threading.Tasks;
 
 namespace Microsoft.PowerShell.PSResourceGet.Cmdlets
 {
@@ -39,6 +40,15 @@ public LocalServerAPICalls (PSRepositoryInfo repository, PSCmdlet cmdletPassedIn
 
         #region Overridden Methods
 
+        public override Task<FindResults> FindVersionAsync(string packageName, string version, ResourceType type)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override Task<FindResults> FindVersionGlobbingAsync(string packageName, VersionRange versionRange, bool includePrerelease, ResourceType type, bool getOnlyLatest)
+        {
+            throw new NotImplementedException();
+        }
         /// <summary>
         /// Find method which allows for searching for all packages from a repository and returns latest version for each.
         /// Examples: Search -Repository PSGallery
@@ -109,6 +119,11 @@ public override FindResults FindName(string packageName, bool includePrerelease,
             return FindNameHelper(packageName, Utils.EmptyStrArray, includePrerelease, type, out errRecord);
         }
 
+        public override Task<FindResults> FindNameAsync(string packageName, bool includePrerelease, ResourceType type)
+        {
+            throw new NotImplementedException();
+        }
+
         /// <summary>
         /// Find method which allows for searching for single name and tag and returns latest version.
         /// Name: no wildcard support

src/code/NuGetServerAPICalls.cs

@@ -48,6 +48,15 @@ public NuGetServerAPICalls (PSRepositoryInfo repository, PSCmdlet cmdletPassedIn
 
         #region Overridden Methods
 
+        public override Task<FindResults> FindVersionAsync(string packageName, string version, ResourceType type)
+        {
+            throw new NotImplementedException();
+        }
+
+        public override Task<FindResults> FindVersionGlobbingAsync(string packageName, VersionRange versionRange, bool includePrerelease, ResourceType type, bool getOnlyLatest)
+        {
+            throw new NotImplementedException();
+        }
         /// <summary>
         /// Find method which allows for searching for all packages from a repository and returns latest version for each.
         /// Examples: Search -Repository MyNuGetServer
@@ -183,6 +192,11 @@ public override FindResults FindName(string packageName, bool includePrerelease,
             return new FindResults(stringResponse: new string[]{ response }, hashtableResponse: emptyHashResponses, responseType: FindResponseType);
         }
 
+        public override Task<FindResults> FindNameAsync(string packageName, bool includePrerelease, ResourceType type)
+        {
+            throw new NotImplementedException();
+        }
+
         /// <summary>
         /// Find method which allows for searching for single name and tag and returns latest version.
         /// Name: no wildcard support

src/code/ServerApiCall.cs

@@ -10,6 +10,7 @@
 using System.Text;
 using System.Runtime.ExceptionServices;
 using System.Management.Automation;
+using System.Threading.Tasks;
 
 namespace Microsoft.PowerShell.PSResourceGet.Cmdlets
 {
@@ -81,6 +82,13 @@ public ServerApiCall(PSRepositoryInfo repository, NetworkCredential networkCrede
         /// </summary>
         public abstract FindResults FindName(string packageName, bool includePrerelease, ResourceType type, out ErrorRecord errRecord);
 
+        /// <summary>
+        /// Find method which allows for async searching for package by single name and returns latest version.
+        /// Name: no wildcard support
+        /// Examples: Search "PowerShellGet"
+        /// </summary>
+        public abstract Task<FindResults> FindNameAsync(string packageName, bool includePrerelease, ResourceType type);
+
         /// <summary>
         /// Find method which allows for searching for package by single name and tag and returns latest version.
         /// Name: no wildcard support
@@ -95,6 +103,15 @@ public ServerApiCall(PSRepositoryInfo repository, NetworkCredential networkCrede
         /// </summary>
         public abstract FindResults FindNameGlobbing(string packageName, bool includePrerelease, ResourceType type, out ErrorRecord errRecord);
 
+        /// <summary>
+        /// Find method which allows for async searching for single name with version range.
+        /// Name: no wildcard support
+        /// Version: supports wildcards
+        /// Examples: Search "PowerShellGet" "[3.0.0.0, 5.0.0.0]"
+        ///           Search "PowerShellGet" "3.*"
+        /// </summary>
+        public abstract Task<FindResults> FindVersionGlobbingAsync(string packageName, VersionRange versionRange, bool includePrerelease, ResourceType type, bool getOnlyLatest);
+
         /// <summary>
         /// Find method which allows for searching for single name with wildcards and tag and returns latest version.
         /// Name: supports wildcards
@@ -118,6 +135,14 @@ public ServerApiCall(PSRepositoryInfo repository, NetworkCredential networkCrede
         /// </summary>
         public abstract FindResults FindVersion(string packageName, string version, ResourceType type, out ErrorRecord errRecord);
 
+        /// <summary>
+        /// Find method which allows for async searching for single name with specific version.
+        /// Name: no wildcard support
+        /// Version: no wildcard support
+        /// Examples: Search "PowerShellGet" "2.2.5"
+        /// </summary>
+        public abstract Task<FindResults> FindVersionAsync(string packageName, string version, ResourceType type);
+
         /// <summary>
         /// Find method which allows for searching for single name with specific version.
         /// Name: no wildcard support

src/code/Utils.cs

@@ -1342,37 +1342,99 @@ private static bool TryReadPSDataFile(
             out Hashtable dataFileInfo,
             out Exception error)
         {
+            dataFileInfo = null;
+            error = null;
             try
             {
                 if (filePath is null)
                 {
                     throw new PSArgumentNullException(nameof(filePath));
                 }
-
                 string contents = System.IO.File.ReadAllText(filePath);
-                var scriptBlock = System.Management.Automation.ScriptBlock.Create(contents);
-
-                // Ensure that the content script block is safe to convert into a PSDataFile Hashtable.
-                // This will throw for unsafe content.
-                scriptBlock.CheckRestrictedLanguage(
-                    allowedCommands: allowedCommands,
-                    allowedVariables: allowedVariables,
-                    allowEnvironmentVariables: allowEnvironmentVariables);
-
-                // Convert contents into PSDataFile Hashtable by executing content as script.
-                object result = scriptBlock.InvokeReturnAsIs();
-                if (result is PSObject psObject)
+
+                // Parallel.ForEach calls into this method.
+                // Each thread needs its own runspace created to provide a separate environment for operations to run independently.
+                // The runspace must be disposed when done and DefaultRunspace must be set/restored per-thread
+                // to prevent cross-contamination when thread-pool threads are reused across tests.
+                Runspace runspace = RunspaceFactory.CreateRunspace();
+                runspace.Open();
+                runspace.SessionStateProxy.LanguageMode = PSLanguageMode.ConstrainedLanguage;
+
+                // Save and set the default runspace for the current thread to prevent
+                // stale DefaultRunspace from a prior operation on this reused thread-pool thread.
+                Runspace previousDefaultRunspace = Runspace.DefaultRunspace;
+                try
                 {
-                    result = psObject.BaseObject;
-                }
+                    Runspace.DefaultRunspace = runspace;
 
-                dataFileInfo = (Hashtable)result;
-                error = null;
-                return true;
+                    using (System.Management.Automation.PowerShell pwsh = System.Management.Automation.PowerShell.Create())
+                    {
+                        pwsh.Runspace = runspace;
+
+                        var cmd = new Command(
+                            command: contents,
+                            isScript: true,
+                            useLocalScope: true);
+                        cmd.MergeMyResults(
+                            myResult: PipelineResultTypes.Error | PipelineResultTypes.Warning | PipelineResultTypes.Verbose | PipelineResultTypes.Debug | PipelineResultTypes.Information,
+                            toResult: PipelineResultTypes.Output);
+                        pwsh.Commands.AddCommand(cmd);
+
+                        try
+                        {
+                            // Invoke the pipeline and retrieve the results
+                            var results = pwsh.Invoke();
+
+                            if (results[0] is PSObject pwshObj)
+                            {
+                                switch (pwshObj.BaseObject)
+                                {
+                                    case ErrorRecord err:
+                                        //_cmdletPassedIn.WriteError(error);
+                                        break;
+
+                                    case WarningRecord warning:
+                                        //cmdlet.WriteWarning(warning.Message);
+                                        break;
+
+                                    case VerboseRecord verbose:
+                                        //cmdlet.WriteVerbose(verbose.Message);
+                                        break;
+
+                                    case DebugRecord debug:
+                                        //cmdlet.WriteDebug(debug.Message);
+                                        break;
+
+                                    case InformationRecord info:
+                                        //cmdlet.WriteInformation(info);
+                                        break;
+
+                                    case Hashtable result:
+                                        dataFileInfo = result;
+                                        return true;
+                                }
+                            }
+                        }
+                        catch (Exception ex)
+                        {
+                            error = ex;
+                        }
+                    }
+                    // Return false to indicate "we couldn't parse a valid Hashtable from this .psd1 file." 
+                    // The only success path is the 'case Hashtable result' branch above which does return true.
+                    return false;
+                }
+                finally
+                {
+                    // Always restore the previous default runspace and close/dispose
+                    // the per-thread runspace, even on success (return true) or exception paths.
+                    Runspace.DefaultRunspace = previousDefaultRunspace;
+                    runspace.Close();
+                    runspace.Dispose();
+                }
             }
             catch (Exception ex)
             {
-                dataFileInfo = null;
                 error = ex;
                 return false;
             }