PART 3: Add UploadArchiveToGithubStorageWithMultiPart method

src/Octoshift/Services/GithubApi.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Linq;
 using System.Net;
 using System.Net.Http;
@@ -1047,6 +1048,33 @@ mutation abortRepositoryMigration(
         }
     }
 
+    public virtual async Task<string> UploadArchiveToGithubStorage(string org, bool isMultipart, string archiveName, Stream archiveContent)
+    {
+        using var httpContent = new StreamContent(archiveContent);
+        string response;
+
+        if (isMultipart)
+        {
+            var url = $"https://uploads.github.com/organizations/{org.EscapeDataString()}/gei/archive/blobs/uploads";
+
+            using var content = new MultipartFormDataContent
+            {
+                { httpContent, "archive", archiveName }
+            };
+
+            response = await _client.PostAsync(url, content);
+        }
+        else
+        {
+            var url = $"https://uploads.github.com/organizations/{org.EscapeDataString()}/gei/archive\\?name\\={archiveName}";
+
+            response = await _client.PostAsync(url, httpContent);
+        }
+
+        var data = JObject.Parse(response);
+        return "gei://archive/" + (string)data["archiveId"];
+    }
+
     private static object GetMannequinsPayload(string orgId)
     {
         var query = "query($id: ID!, $first: Int, $after: String)";

src/OctoshiftCLI.Tests/Octoshift/Services/GithubApiTests.cs

@@ -1,4 +1,5 @@
 using System;
+using System.IO;
 using System.Collections.Generic;
 using System.Collections.ObjectModel;
 using System.Linq;
@@ -3392,14 +3393,105 @@ await _githubApi.Invoking(api => api.AbortMigration(migrationId))
             .WithMessage(expectedErrorMessage);
     }
 
-    private string Compact(string source) =>
-        source
-            .Replace("\r", "")
-            .Replace("\n", "")
-            .Replace("\t", "")
-            .Replace("\\r", "")
-            .Replace("\\n", "")
-            .Replace("\\t", "")
-            .Replace(" ", "");
+    [Fact]
+    public async Task UploadArchiveToGithubStorage()
+    {
+        //Arange 
+        const string org = "org";
+        const bool isMultipart = false;
+        const string archiveName = "archiveName";
+
+        // Using a MemoryStream as a valid stream implementation
+        using var archiveContent = new MemoryStream(new byte[] { 1, 2, 3 });
+
+        var url = $"https://uploads.github.com/organizations/{org.EscapeDataString()}/gei/archive\\?name\\={archiveName}";
+
+        var expectedArchiveId = "123456";
+        var jsonResponse = $"{{ \"archiveId\": \"{expectedArchiveId}\" }}";
+        var payload = new
+        {
+            token = $"repoV2/{123}/{123}",
+            merge = true,
+            accessControlEntries = new[]
+            {
+                new
+                {
+                    descriptor = "",
+                    allow = 0,
+                    deny = 56828,
+                    extendedInfo = new
+                    {
+                        effectiveAllow = 0,
+                        effectiveDeny = 56828,
+                        inheritedAllow = 0,
+                        inheritedDeny = 56828
+                    }
+                }
+            }
+        };
+
+        _githubClientMock
+            .Setup(m => m.PostAsync(url, It.IsAny<HttpContent>()))
+            .ReturnsAsync(jsonResponse);
+
+        var expectedStringResponse = "gei://archive/" + expectedArchiveId;
+
+        // Act
+        var actualStringResponse = await _githubApi.UploadArchiveToGithubStorage(org, isMultipart, archiveName, archiveContent);
+
+        // Assert
+        expectedStringResponse.Should().Be(actualStringResponse);
+
+    }
 
+    [Fact]
+    public async Task UploadArchiveToGithubStorageWithMultiPart()
+    {
+        //Arange 
+        const string org = "org";
+        const bool isMultipart = true;
+        const string archiveName = "archiveName";
+
+        // Using a MemoryStream as a valid stream implementation
+        using var archiveContent = new MemoryStream(new byte[] { 1, 2, 3 });
+
+        var url = $"https://uploads.github.com/organizations/{org.EscapeDataString()}/gei/archive\\?name\\={archiveName}";
+
+        var expectedArchiveId = "123456";
+        var jsonResponse = $"{{ \"archiveId\": \"{expectedArchiveId}\" }}";
+        var payload = new
+        {
+            token = $"repoV2/{123}/{123}",
+            merge = true,
+            accessControlEntries = new[]
+            {
+                new
+                {
+                    descriptor = "",
+                    allow = 0,
+                    deny = 56828,
+                    extendedInfo = new
+                    {
+                        effectiveAllow = 0,
+                        effectiveDeny = 56828,
+                        inheritedAllow = 0,
+                        inheritedDeny = 56828
+                    }
+                }
+            }
+        };
+
+        _githubClientMock
+            .Setup(m => m.PostAsync(url, It.IsAny<HttpContent>()))
+            .ReturnsAsync(jsonResponse);
+
+        var expectedStringResponse = "gei://archive/" + expectedArchiveId;
+
+        // Act
+        var actualStringResponse = await _githubApi.UploadArchiveToGithubStorage(org, isMultipart, archiveName, archiveContent);
+
+        // Assert
+        expectedStringResponse.Should().Be(actualStringResponse);
+
+    }
 }