Make IceBox watcher report more reliable (#122)

Author: zivkan

GithubIssueTagger/GraphQL/GitHubGraphQLClient.cs

@@ -32,18 +32,74 @@ public GitHubGraphQLClient(GitHubPat pat, string userAgent)
 
         public async Task<GraphQLResponse<T>?> SendAsync<T>(GraphQLRequest request)
         {
-            using var httpResponse = await HttpClient.PostAsJsonAsync(requestUri: (string?)null, request);
+            HttpResponseMessage? httpResponse;
 
-            var rateLimitLimit = httpResponse.Headers.GetValues("X-RateLimit-Limit").SingleOrDefault();
-            var rateLimitRemaining = httpResponse.Headers.GetValues("X-RateLimit-Remaining").SingleOrDefault();
-            var rateLimitReset = long.Parse(httpResponse.Headers.GetValues("X-RateLimit-Reset").Single());
-            var resetTime = DateTime.UnixEpoch.AddSeconds(rateLimitReset);
-            Console.WriteLine($"GraphQL HTTP rate-limit = {rateLimitLimit}, remaining = {rateLimitRemaining}, reset = {resetTime:o}");
+            int attempt = 0;
+            int maxAttempts = 5;
+            TimeSpan delay = TimeSpan.FromSeconds(1);
 
-            using var stream = await httpResponse.Content.ReadAsStreamAsync();
-            GraphQLResponse<T>? response = await JsonSerializer.DeserializeAsync<GraphQLResponse<T>>(stream);
+            for (;;)
+            {
+                httpResponse = null;
+                try
+                {
+                    httpResponse = await HttpClient.PostAsJsonAsync(requestUri: (string?)null, request);
+
+                    var rateLimitLimit = httpResponse.Headers.GetValues("X-RateLimit-Limit").SingleOrDefault();
+                    var rateLimitRemaining = httpResponse.Headers.GetValues("X-RateLimit-Remaining").SingleOrDefault();
+                    var rateLimitReset = long.Parse(httpResponse.Headers.GetValues("X-RateLimit-Reset").Single());
+                    var resetTime = DateTime.UnixEpoch.AddSeconds(rateLimitReset);
+                    Console.WriteLine($"GraphQL HTTP rate-limit = {rateLimitLimit}, remaining = {rateLimitRemaining}, reset = {resetTime:o}");
+
+                    using var stream = await httpResponse.Content.ReadAsStreamAsync();
+                    GraphQLResponse<T>? response = await JsonSerializer.DeserializeAsync<GraphQLResponse<T>>(stream);
+
+                    httpResponse.Dispose();
+
+                    return response;
+                }
+                catch (Exception ex)
+                {
+                    Console.WriteLine($"GraphQL HTTP error: {ex.Message}");
+
+                    TimeSpan retryAfter = delay;
+                    if (httpResponse != null)
+                    {
+                        Console.WriteLine(httpResponse);
 
-            return response;
+                        if (httpResponse.Content.Headers.ContentLength < 2000)
+                        {
+                            var body = await httpResponse.Content.ReadAsStringAsync();
+                            Console.WriteLine(body);
+                        }
+
+                        if (httpResponse.Headers?.RetryAfter?.Date != null)
+                        {
+                            retryAfter = httpResponse.Headers.RetryAfter.Date.Value - DateTime.UtcNow;
+                            if (retryAfter < TimeSpan.Zero)
+                            {
+                                retryAfter = delay;
+                            }
+                        }
+                        else if (httpResponse.Headers?.RetryAfter?.Delta != null)
+                        {
+                            retryAfter = httpResponse.Headers.RetryAfter.Delta.Value;
+                        }
+
+                        httpResponse.Dispose();
+                    }
+
+                    if (attempt >= maxAttempts)
+                    {
+                        throw;
+                    }
+
+                    Console.WriteLine($"GraphQL HTTP retrying in {retryAfter.TotalSeconds} seconds...");
+                    await Task.Delay(retryAfter);
+                    attempt++;
+                    delay += delay;
+                }
+            }
         }
     }
 }

GithubIssueTagger/Reports/IceBox/IceBoxResource.resx

@@ -119,15 +119,15 @@
   </resheader>
   <assembly alias="System.Windows.Forms" name="System.Windows.Forms, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089" />
   <data name="AddLabelToIssue" type="System.Resources.ResXFileRef, System.Windows.Forms">
-    <value>addlabeltoissue.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
+    <value>AddLabelToIssue.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
   </data>
   <data name="GetIssues" type="System.Resources.ResXFileRef, System.Windows.Forms">
     <value>GetIssues.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
   </data>
   <data name="GetLabeledEvents" type="System.Resources.ResXFileRef, System.Windows.Forms">
-    <value>getlabeledevents.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
+    <value>GetLabeledEvents.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
   </data>
   <data name="GetLabelId" type="System.Resources.ResXFileRef, System.Windows.Forms">
-    <value>getlabelid.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
+    <value>GetLabelId.graphql;System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089;utf-8</value>
   </data>
 </root>