Merge pull request #9 from jpobst/populate

Allow MavenCentral repo to bypass 100 artifact limit.

Author: jpobst

MavenNet/MavenCentralRepository.cs

@@ -56,6 +56,24 @@ protected override async Task<IEnumerable<Artifact>> GetArtifactsAsync(string gr
             return artifacts;
         }
 
+        // Optimization that avoids the Maven search, which also avoids the 100 row limit
+        protected override async Task<IEnumerable<Artifact>> GetArtifactsAsync(string groupId, params string[] artifactIds)
+        {
+            var artifacts = new List<Artifact>();
+
+            foreach (var aid in artifactIds) {
+                try {
+                    using (var s = await OpenMavenMetadataFile(groupId, aid).ConfigureAwait(false)) {
+                        var metadata = MavenMetadataParser.Parse(s);
+
+                        artifacts.Add(new Artifact(aid, groupId, metadata.AllVersions.ToArray()));
+                    }
+                } catch { }
+            }
+
+            return artifacts;
+        }
+
         protected override Task<IEnumerable<string>> GetGroupIdsAsync()
         {
             return Task.FromResult<IEnumerable<string>>(new List<string>());

MavenNet/MavenRepository.cs

@@ -41,6 +41,7 @@ public static FileBasedMavenRepository FromDirectory(string directoryPath)
         protected abstract Task<Stream> OpenFileAsync(string path);
         protected abstract Task<IEnumerable<string>> GetGroupIdsAsync();
         protected abstract Task<IEnumerable<Artifact>> GetArtifactsAsync(string groupId);
+        protected async virtual Task<IEnumerable<Artifact>> GetArtifactsAsync(string groupId, params string[] artifactIds) => (await GetArtifactsAsync(groupId)).Where(a => artifactIds.Contains(a.Id));
         protected abstract string CombinePaths(params string[] parts);
 
         public virtual async Task Refresh()
@@ -87,6 +88,25 @@ public virtual Task Refresh(params Group[] groups)
             return Task.CompletedTask;
         }
 
+        public virtual async Task Populate(string groupId, params string[] artifactIds)
+        {
+            var g = Groups.FirstOrDefault(a => a.Id == groupId);
+
+            if (g is null) {
+                g = new Group(groupId);
+                Groups.Add(g);
+            }
+
+            var artifacts = await GetArtifactsAsync(groupId, artifactIds).ConfigureAwait(false);
+
+            // Set a reference to this repository implementation
+            foreach (var a in artifacts)
+            {
+                a.Repository = this;
+                g.Artifacts.Add(a);
+            }
+        }
+
         public virtual Task<Stream> OpenArtifactPomFile(string groupId, string artifactId, string version)
         {
             var path = CombinePaths(CombinePaths(groupId.Split('.')), artifactId, version, artifactId + "-" + version + ".pom");