Add gl2gh GitLab adapter

src/Octoshift/Models/GitlabProject.cs

@@ -0,0 +1,9 @@
+namespace Octoshift.Models;
+
+public record GitlabProject
+{
+    public string Id { get; init; }
+    public string Name { get; init; }
+    public string Path { get; init; }
+    public bool Archived { get; init; }
+}

src/Octoshift/Services/EnvironmentVariableProvider.cs

@@ -15,6 +15,7 @@ public class EnvironmentVariableProvider
     private const string AWS_REGION = "AWS_REGION";
     private const string BBS_USERNAME = "BBS_USERNAME";
     private const string BBS_PASSWORD = "BBS_PASSWORD";
+    private const string GITLAB_PAT = "GITLAB_PAT";
     private const string SMB_PASSWORD = "SMB_PASSWORD";
     private const string GEI_SKIP_STATUS_CHECK = "GEI_SKIP_STATUS_CHECK";
     private const string GEI_SKIP_VERSION_CHECK = "GEI_SKIP_VERSION_CHECK";
@@ -57,6 +58,9 @@ public virtual string BbsUsername(bool throwIfNotFound = true) =>
     public virtual string BbsPassword(bool throwIfNotFound = true) =>
         GetSecret(BBS_PASSWORD, throwIfNotFound);
 
+    public virtual string GitlabPat(bool throwIfNotFound = true) =>
+        GetSecret(GITLAB_PAT, throwIfNotFound);
+
     public virtual string SmbPassword(bool throwIfNotFound = true) =>
         GetSecret(SMB_PASSWORD, throwIfNotFound);
 

src/Octoshift/Services/GithubApi.cs

@@ -346,6 +346,30 @@ public virtual async Task<string> CreateBbsMigrationSource(string orgId)
         return (string)data["data"]["createMigrationSource"]["migrationSource"]["id"];
     }
 
+    public virtual async Task<string> CreateGitlabMigrationSource(string orgId)
+    {
+        var url = $"{_apiUrl}/graphql";
+
+        var query = "mutation createMigrationSource($name: String!, $url: String!, $ownerId: ID!, $type: MigrationSourceType!)";
+        var gql = "createMigrationSource(input: {name: $name, url: $url, ownerId: $ownerId, type: $type}) { migrationSource { id, name, url, type } }";
+
+        var payload = new
+        {
+            query = $"{query} {{ {gql} }}",
+            variables = new
+            {
+                name = "GitLab Source",
+                url = "https://not-used",
+                ownerId = orgId,
+                type = "GITLAB"
+            },
+            operationName = "createMigrationSource"
+        };
+
+        var data = await _client.PostGraphQLAsync(url, payload);
+        return (string)data["data"]["createMigrationSource"]["migrationSource"]["id"];
+    }
+
     public virtual async Task<string> CreateGhecMigrationSource(string orgId)
     {
         var url = $"{_apiUrl}/graphql";
@@ -534,6 +558,23 @@ public virtual async Task<string> StartBbsMigration(string migrationSourceId, st
         );
     }
 
+    public virtual async Task<string> StartGitlabMigration(string migrationSourceId, string gitlabRepoUrl, string orgId, string repo, string targetToken, string archiveUrl, string targetRepoVisibility = null)
+    {
+        return await StartMigration(
+            migrationSourceId,
+            gitlabRepoUrl,  // source repository URL
+            orgId,
+            repo,
+            "not-used",  // source access token
+            targetToken,
+            archiveUrl,
+            null,  // GitLab archive contains both git and metadata — GitHub falls back to gitArchiveUrl
+            false,  // skip releases
+            targetRepoVisibility,
+            false  // lock source
+        );
+    }
+
     public virtual async Task<(string State, string RepositoryName, int WarningsCount, string FailureReason, string MigrationLogUrl)> GetMigration(string migrationId)
     {
         var url = $"{_apiUrl}/graphql";

src/Octoshift/Services/GithubClient.cs

@@ -38,7 +38,7 @@ public GithubClient(OctoLogger log, HttpClient httpClient, IVersionProvider vers
         if (_httpClient != null)
         {
             _httpClient.DefaultRequestHeaders.Add("Accept", "application/vnd.github.v3+json");
-            _httpClient.DefaultRequestHeaders.Add("GraphQL-Features", "import_api,mannequin_claiming_emu,org_import_api");
+            _httpClient.DefaultRequestHeaders.Add("GraphQL-Features", "import_api,mannequin_claiming_emu,org_import_api,octoshift_ll_gitlab_self_serve");
             _httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", personalAccessToken);
             _httpClient.DefaultRequestHeaders.UserAgent.Add(new ProductInfoHeaderValue("OctoshiftCLI", versionProvider?.GetCurrentVersion()));
             if (versionProvider?.GetVersionComments() is { } comments)

src/Octoshift/Services/GitlabApi.cs

@@ -0,0 +1,175 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Newtonsoft.Json.Linq;
+using OctoshiftCLI.Extensions;
+
+namespace OctoshiftCLI.Services;
+
+public class GitlabApi
+{
+    private readonly GitlabClient _client;
+    private readonly string _gitlabBaseUrl;
+    private readonly OctoLogger _log;
+
+    public GitlabApi(GitlabClient client, string gitlabServerUrl, OctoLogger log)
+    {
+        _client = client;
+        _gitlabBaseUrl = gitlabServerUrl?.TrimEnd('/');
+        _log = log;
+    }
+
+    public virtual async Task<(string Version, bool Enterprise)> GetServerVersion()
+    {
+        var url = $"{_gitlabBaseUrl}/api/v4/version";
+
+        var content = await _client.GetAsync(url);
+        var data = JObject.Parse(content);
+
+        return ((string)data["version"], (bool?)data["enterprise"] ?? false);
+    }
+
+    public virtual async Task LogServerVersion()
+    {
+        var (version, enterprise) = await GetServerVersion();
+        if (!string.IsNullOrWhiteSpace(version))
+        {
+            var edition = enterprise ? "Enterprise" : "Community";
+            _log?.LogInformation($"GitLab version: {version} ({edition} Edition)");
+        }
+    }
+
+    public virtual async Task<string> StartExport(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}/export";
+
+        var exportResponse = await _client.PostAsync(url, new { });
+        var exportData = JObject.Parse(exportResponse);
+
+        return (string)exportData["message"];
+    }
+
+    public virtual async Task<(string ExportStatus, string DownloadUrl)> GetExport(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}/export";
+
+        var exportResponse = await _client.GetAsync(url);
+        var exportData = JObject.Parse(exportResponse);
+
+        return (
+            (string)exportData["export_status"],
+            (string)exportData["_links"]?["api_url"]
+        );
+    }
+
+    public virtual async Task DownloadExportArchive(string groupPath, string projectPath, string file)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}/export/download";
+
+        await _client.DownloadToFile(url, file);
+    }
+
+    public virtual async Task<IEnumerable<(long Id, string Path, string Name, bool Archived)>> GetProjects(string groupPath)
+    {
+        var encodedGroupPath = Uri.EscapeDataString(groupPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/groups/{encodedGroupPath}/projects?per_page=100";
+
+        return await _client.GetAllAsync(url)
+            .Select(x => ((long)x["id"], (string)x["path"], (string)x["name"], (bool)x["archived"]))
+            .ToListAsync();
+    }
+
+    public virtual async Task<(long Id, string Path, string Name)> GetGroup(string groupPath)
+    {
+        var encodedGroupPath = groupPath.EscapeDataString();
+        var url = $"{_gitlabBaseUrl}/api/v4/groups/{encodedGroupPath}";
+
+        var groupResponse = await _client.GetAsync(url);
+        var groupData = JObject.Parse(groupResponse);
+
+        return (
+            (long)groupData["id"],
+            (string)groupData["full_path"],
+            (string)groupData["name"]
+        );
+    }
+
+    public virtual async Task<IEnumerable<(long Id, string Path, string Name)>> GetGroups()
+    {
+        var url = $"{_gitlabBaseUrl}/api/v4/groups?per_page=100";
+
+        return await _client.GetAllAsync(url)
+            .Select(x => ((long)x["id"], (string)x["full_path"], (string)x["name"]))
+            .ToListAsync();
+    }
+
+    public virtual async Task<bool> GetIsProjectArchived(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}";
+
+        var projectResponse = await _client.GetAsync(url);
+        var projectData = JObject.Parse(projectResponse);
+
+        return (bool)projectData["archived"];
+    }
+
+    public virtual async Task<DateTimeOffset?> GetRepositoryLatestCommitDate(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}/repository/commits?per_page=1";
+
+        // Empty projects (no Git repo yet) return 404 here; treat as no commits.
+        var commitsResponse = await _client.GetOrNullForNotFoundAsync(url);
+        if (commitsResponse is null)
+        {
+            return null;
+        }
+
+        var commitsData = JArray.Parse(commitsResponse);
+        var lastCommittedDate = (string)commitsData.First?["committed_date"];
+
+        if (string.IsNullOrWhiteSpace(lastCommittedDate))
+        {
+            return null;
+        }
+
+        return DateTimeOffset.Parse(lastCommittedDate);
+    }
+
+    public virtual async Task<(long RepositorySize, long AttachmentsSize)> GetRepositoryAndAttachmentsSize(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}?statistics=true";
+
+        var projectResponse = await _client.GetAsync(url);
+        var projectData = JObject.Parse(projectResponse);
+        var projectStatistics = (JObject)projectData["statistics"];
+
+        var repositorySize = (long)projectStatistics["repository_size"];
+        var attachmentsSize = (long)projectStatistics["uploads_size"];
+
+        return (repositorySize, attachmentsSize);
+    }
+
+    public virtual async Task<int> GetMergeRequestCount(string groupPath, string projectPath)
+    {
+        var encodedProjectPath = GetEncodedProjectPath(groupPath, projectPath);
+        var url = $"{_gitlabBaseUrl}/api/v4/projects/{encodedProjectPath}/merge_requests?state=all&per_page=1&page=1";
+
+        var mrResponse = await _client.GetAsyncHttpResponseMessage(url);
+        var mrTotal = mrResponse.Headers.GetValues("X-Total").Single();
+
+        return int.Parse(mrTotal);
+    }
+
+    private static string GetEncodedProjectPath(string groupPath, string projectPath)
+    {
+        var pathWithNamespace = $"{groupPath}/{projectPath}";
+        return pathWithNamespace.EscapeDataString();
+    }
+}