fix stuck job detection

Author: elasticroentgen

GitHubApi.cs

@@ -157,7 +157,7 @@ public static async Task<bool> RemoveRunnerFromRepo(string repoName, string orgG
 
     }
 
-    public static async Task<GitHubJob> GetJobInfo(long stuckJobGithubJobId,string repoName, string orgGitHubToken)
+    public static async Task<GitHubJob> GetJobInfoForOrg(long stuckJobGithubJobId,string repoName, string orgGitHubToken)
     {
         using HttpClient client = new();
         client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/vnd.github+json"));
@@ -176,6 +176,27 @@ public static async Task<GitHubJob> GetJobInfo(long stuckJobGithubJobId,string r
         }
         Log.Warning($"Unable to get GH job info for {repoName}/{stuckJobGithubJobId}: [{response.StatusCode}] {response.ReasonPhrase}");
 
+        return null;
+    }
+    public static async Task<GitHubJob> GetJobInfoForRepo(long stuckJobGithubJobId,string repoName, string orgGitHubToken)
+    {
+        using HttpClient client = new();
+        client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/vnd.github+json"));
+        client.DefaultRequestHeaders.Add("X-GitHub-Api-Version", "2022-11-28");
+        client.DefaultRequestHeaders.Authorization = AuthenticationHeaderValue.Parse($"Bearer {orgGitHubToken}");
+        client.DefaultRequestHeaders.UserAgent.Add(new ProductInfoHeaderValue("hetzner-autoscale", "1"));
+
+        HttpResponseMessage response = await client.GetAsync(
+            $"https://api.github.com/repos/{repoName}/actions/jobs/{stuckJobGithubJobId}");
+        if(response.IsSuccessStatusCode)
+        {
+            string content = await response.Content.ReadAsStringAsync();
+            GitHubJob responseObject = JsonSerializer.Deserialize<GitHubJob>(content);
+            
+            return responseObject;
+        }
+        Log.Warning($"Unable to get GH job info for {repoName}/{stuckJobGithubJobId}: [{response.StatusCode}] {response.ReasonPhrase}");
+
         return null;
     }
 }

PoolManager.cs

@@ -286,7 +286,12 @@ private async Task CheckForStuckJobs(List<GithubTargetConfiguration> targetConfi
             }
 
             // check job on github
-            GitHubJob ghJob =  await GitHubApi.GetJobInfo(stuckJob.GithubJobId, owner.Name, owner.GitHubToken);
+            GitHubJob ghJob = owner.Target switch
+            {
+                TargetType.Repository => await GitHubApi.GetJobInfoForRepo(stuckJob.GithubJobId, owner.Name, owner.GitHubToken),
+                TargetType.Organization => await GitHubApi.GetJobInfoForOrg(stuckJob.GithubJobId, owner.Name, owner.GitHubToken),
+                _ => throw new ArgumentOutOfRangeException()
+            };
             if (ghJob == null || ghJob.Status != "queued")
             {
                 _logger.LogWarning($"job info for {stuckJob.JobId} not found or job not queued anymore.");