chore: Add X-Goog-Api-Client metric header to outgoing requests

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Jwt/HttpPublicKeySourceTest.cs

@@ -44,6 +44,8 @@ public async Task GetPublicKeysWithoutCaching()
             Assert.Equal(2, keys.Count);
             Assert.Equal(2, handler.Calls);
             Assert.NotSame(keys, keys2);
+            JwtTestUtils.AssertRequest(handler.Requests[0]);
+            JwtTestUtils.AssertRequest(handler.Requests[1]);
         }
 
         [Fact]
@@ -77,6 +79,8 @@ public async Task GetPublicKeysWithCaching()
             Assert.Equal(2, keys.Count);
             Assert.Equal(2, handler.Calls);
             Assert.NotSame(keys, keys3);
+            JwtTestUtils.AssertRequest(handler.Requests[0]);
+            JwtTestUtils.AssertRequest(handler.Requests[1]);
         }
 
         [Fact]

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Jwt/IAMSignerTest.cs

@@ -57,6 +57,7 @@ public async Task Signer()
             Assert.Equal(Convert.ToBase64String(data), req.BytesToSign);
             Assert.Equal(2, handler.Calls);
             Assert.Equal("Bearer token", handler.LastRequestHeaders.Authorization?.ToString());
+            JwtTestUtils.AssertRequest(handler.Requests[1]);
         }
 
         [Fact]
@@ -112,6 +113,7 @@ public async Task Signer()
                 handler.LastRequestBody);
             Assert.Equal(Convert.ToBase64String(data), req.BytesToSign);
             Assert.Equal(1, handler.Calls);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Fact]

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Jwt/IdTokenVerificationTest.cs

@@ -434,6 +434,7 @@ public async Task RevokedToken(TestConfig config)
             this.CheckException(exception, expectedMessage, AuthErrorCode.RevokedIdToken);
             Assert.Equal(1, handler.Calls);
             config.AssertRevocationCheckRequest(handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Theory]
@@ -458,6 +459,7 @@ public async Task ValidUnrevokedToken(TestConfig config)
             Assert.Equal("testuser", decoded.Uid);
             Assert.Equal(1, handler.Calls);
             config.AssertRevocationCheckRequest(handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Theory]
@@ -484,6 +486,7 @@ public async Task CheckRevokedError(TestConfig config)
             Assert.NotNull(exception.HttpResponse);
             Assert.Equal(1, handler.Calls);
             config.AssertRevocationCheckRequest(handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Theory]

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Jwt/JwtTestUtils.cs

@@ -100,6 +100,11 @@ public static void AssertRevocationCheckRequest(string tenantId, string emulator
             Assert.Equal(expectedUrl, uri.ToString());
         }
 
+        internal static void AssertRequest(MockMessageHandler.IncomingRequest request)
+        {
+            Assert.Contains(HttpUtils.GetMetricsHeader(), request.Headers.GetValues("X-Goog-Api-Client"));
+        }
+
         private static ISigner CreateTestSigner(string filePath)
         {
             var credential = GoogleCredential.FromFile(filePath);

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Jwt/SessionCookieVerificationTest.cs

@@ -331,6 +331,7 @@ public async Task RevokedToken(TestConfig config)
             this.CheckException(exception, expectedMessage, AuthErrorCode.RevokedSessionCookie);
             Assert.Equal(1, handler.Calls);
             JwtTestUtils.AssertRevocationCheckRequest(null, handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Theory]
@@ -355,6 +356,7 @@ public async Task ValidUnrevokedToken(TestConfig config)
             Assert.Equal("testuser", decoded.Uid);
             Assert.Equal(1, handler.Calls);
             JwtTestUtils.AssertRevocationCheckRequest(null, handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         [Theory]
@@ -381,6 +383,7 @@ public async Task CheckRevokedError(TestConfig config)
             Assert.NotNull(exception.HttpResponse);
             Assert.Equal(1, handler.Calls);
             JwtTestUtils.AssertRevocationCheckRequest(null, handler.Requests[0].Url);
+            JwtTestUtils.AssertRequest(Assert.Single(handler.Requests));
         }
 
         private void CheckException(

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Multitenancy/TenantManagerTest.cs

@@ -690,6 +690,7 @@ internal void AssertRequest(
                 }
 
                 Assert.Contains(ClientVersion, request.Headers.GetValues("X-Client-Version"));
+                Assert.Contains(HttpUtils.GetMetricsHeader(), request.Headers.GetValues("X-Goog-Api-Client"));
             }
         }
 

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Providers/ProviderTestConfig.cs

@@ -109,6 +109,7 @@ internal void AssertRequest(
             var expectedPath = $"/v2/projects/{MockProjectId}{tenantInfo}/{expectedSuffix}";
             Assert.Equal(expectedPath, request.Url.PathAndQuery);
             Assert.Contains(ClientVersion, request.Headers.GetValues("X-Client-Version"));
+            Assert.Contains(HttpUtils.GetMetricsHeader(), request.Headers.GetValues("X-Goog-Api-Client"));
         }
 
         public class InvalidListOptions : IEnumerable<object[]>

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Users/EmailActionRequestTest.cs

@@ -372,6 +372,7 @@ private void AssertRequest(MockMessageHandler.IncomingRequest message)
             Assert.Equal(
                 FirebaseUserManager.ClientVersion,
                 message.Headers.GetValues(FirebaseUserManager.ClientVersionHeader).First());
+            Assert.Equal(HttpUtils.GetMetricsHeader(), message.Headers.GetValues("X-Goog-Api-Client").First());
         }
     }
 }

FirebaseAdmin/FirebaseAdmin.Tests/Auth/Users/FirebaseUserManagerTest.cs

@@ -2222,6 +2222,8 @@ internal void AssertRequest(
                     var expectedUrl = $"https://{IdToolkitUrl}{tenant}/{expectedSuffix}";
                     Assert.Equal(expectedUrl, request.Url.ToString());
                 }
+
+                Assert.Equal(HttpUtils.GetMetricsHeader(), request.Headers.GetValues("X-Goog-Api-Client").First());
             }
 
             private IDictionary<string, object> GetUserResponseDictionary(string response = null)

FirebaseAdmin/FirebaseAdmin.Tests/CountingMessageHandler.cs

@@ -41,4 +41,4 @@ protected sealed override Task<HttpResponseMessage> SendAsync(
         protected abstract Task<HttpResponseMessage> DoSendAsync(
             HttpRequestMessage request, int count, CancellationToken cancellationToken);
     }
-}
+}

FirebaseAdmin/FirebaseAdmin.Tests/FirebaseAdmin.Tests.csproj

@@ -28,6 +28,7 @@
     <PackageReference Include="StyleCop.Analyzers" Version="1.2.0-beta.556">
       <PrivateAssets>all</PrivateAssets>
     </PackageReference>
+    <AdditionalFiles Include="../../stylecop.json" />
   </ItemGroup>
   <ItemGroup>
     <ProjectReference Include="..\FirebaseAdmin\FirebaseAdmin.csproj" />

FirebaseAdmin/FirebaseAdmin.Tests/Messaging/FirebaseMessagingClientTest.cs

@@ -173,6 +173,7 @@ public async Task SendEachAsync()
             Assert.Equal("projects/fir-adminintegrationtests/messages/8580920590356323124", response.Responses[0].MessageId);
             Assert.Equal("projects/fir-adminintegrationtests/messages/5903525881088369386", response.Responses[1].MessageId);
             Assert.Equal(2, handler.Calls);
+            this.CheckHeaders(handler.LastRequestHeaders);
         }
 
         [Fact]
@@ -245,6 +246,7 @@ public async Task SendEachAsyncWithError()
             Assert.NotNull(exception.HttpResponse);
 
             Assert.Equal(2, handler.Calls);
+            this.CheckHeaders(handler.LastRequestHeaders);
         }
 
         [Fact]
@@ -311,6 +313,7 @@ public async Task SendEachAsyncWithErrorNoDetail()
             Assert.NotNull(exception.HttpResponse);
 
             Assert.Equal(2, handler.Calls);
+            this.CheckHeaders(handler.LastRequestHeaders);
         }
 
         [Fact]
@@ -404,6 +407,7 @@ public async Task SendAllAsync()
             Assert.Equal("fire-admin-dotnet", userAgent.Product.Name);
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, VersionHeader));
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, ApiFormatHeader));
+            Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, $"X-Goog-Api-Client: {HttpUtils.GetMetricsHeader()}"));
         }
 
         [Fact]
@@ -486,6 +490,7 @@ public async Task SendAllAsyncWithError()
             Assert.Equal(1, handler.Calls);
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, VersionHeader));
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, ApiFormatHeader));
+            Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, $"X-Goog-Api-Client: {HttpUtils.GetMetricsHeader()}"));
         }
 
         [Fact]
@@ -564,6 +569,7 @@ public async Task SendAllAsyncWithErrorNoDetail()
             Assert.Equal(1, handler.Calls);
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, VersionHeader));
             Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, ApiFormatHeader));
+            Assert.Equal(2, this.CountLinesWithPrefix(handler.LastRequestBody, $"X-Goog-Api-Client: {HttpUtils.GetMetricsHeader()}"));
         }
 
         [Fact]
@@ -778,6 +784,9 @@ private void CheckHeaders(HttpRequestHeaders header)
 
             var apiFormatHeader = header.GetValues("X-GOOG-API-FORMAT-VERSION").First();
             Assert.Equal("2", apiFormatHeader);
+
+            var metricsHeader = header.GetValues("X-Goog-Api-Client").First();
+            Assert.Equal(HttpUtils.GetMetricsHeader(), metricsHeader);
         }
 
         private int CountLinesWithPrefix(string body, string linePrefix)

FirebaseAdmin/FirebaseAdmin.Tests/MockHttpClientFactory.cs

@@ -31,4 +31,4 @@ protected override HttpMessageHandler CreateHandler(CreateHttpClientArgs args)
             return this.handler;
         }
     }
-}
+}

FirebaseAdmin/FirebaseAdmin.Tests/Util/ErrorHandlingHttpClientTest.cs

@@ -47,6 +47,7 @@ public async Task SuccessfulRequest()
             Assert.Single(response.Result);
             Assert.Equal("bar", response.Result["foo"]);
             Assert.Equal(1, handler.Calls);
+            Assert.Equal(HttpUtils.GetMetricsHeader(), handler.LastRequestHeaders.GetValues("X-Goog-Api-Client").First());
         }
 
         [Fact]
@@ -69,6 +70,7 @@ public async Task SuccessfulAuthorizedRequest()
             Assert.Single(response.Result);
             Assert.Equal("bar", response.Result["foo"]);
             Assert.Equal(1, handler.Calls);
+            Assert.Equal(HttpUtils.GetMetricsHeader(), handler.LastRequestHeaders.GetValues("X-Goog-Api-Client").First());
             Assert.Equal(
                 "Bearer test-token",
                 handler.LastRequestHeaders.GetValues("Authorization").First());
@@ -166,6 +168,7 @@ public async Task CustomDeserializer()
             Assert.Equal("bar", response.Result["foo"]);
             Assert.Equal(1, handler.Calls);
             Assert.Equal(1, deserializer.Count);
+            Assert.Equal(HttpUtils.GetMetricsHeader(), handler.LastRequestHeaders.GetValues("X-Goog-Api-Client").First());
         }
 
         [Fact]
@@ -244,6 +247,7 @@ public async Task RetryOnErrorResponse()
             Assert.Null(exception.InnerException);
             Assert.NotNull(exception.HttpResponse);
             Assert.Equal(5, handler.Calls);
+            Assert.Equal(HttpUtils.GetMetricsHeader(), handler.LastRequestHeaders.GetValues("X-Goog-Api-Client").First());
         }
 
         [Fact]
@@ -267,6 +271,7 @@ public async Task RetryOnNetworkError()
             Assert.Same(handler.Exception, exception.InnerException);
             Assert.Null(exception.HttpResponse);
             Assert.Equal(5, handler.Calls);
+            Assert.Equal(HttpUtils.GetMetricsHeader(), handler.LastRequestHeaders.GetValues("X-Goog-Api-Client").First());
         }
 
         [Fact]

FirebaseAdmin/FirebaseAdmin/Messaging/FirebaseMessagingClient.cs

@@ -404,6 +404,7 @@ public FCMClientServiceRequest(FCMClientService clientService, string restPath,
                 this.ModifyRequest = (request) =>
                 {
                     AddCommonHeaders(request);
+                    request.Headers.Add("X-Goog-Api-Client", HttpUtils.GetMetricsHeader());
                 };
                 this.InitParameters();
             }

FirebaseAdmin/FirebaseAdmin/Messaging/InstanceIdClient.cs

@@ -126,6 +126,7 @@ private async Task<TopicManagementResponse> SendInstanceIdRequest(
             };
 
             request.Headers.Add("access_token_auth", "true");
+            request.Headers.Add("X-Goog-Api-Client", HttpUtils.GetMetricsHeader());
 
             var response = await this.httpClient
                 .SendAndDeserializeAsync<InstanceIdServiceResponse>(request)

FirebaseAdmin/FirebaseAdmin/Util/ErrorHandlingHttpClient.cs

@@ -59,6 +59,7 @@ public void Dispose()
         internal async Task<DeserializedResponseInfo<TResult>> SendAndDeserializeAsync<TResult>(
             HttpRequestMessage request, CancellationToken cancellationToken = default)
         {
+            request.Headers.Add("X-Goog-Api-Client", HttpUtils.GetMetricsHeader());
             var info = await this.SendAndReadAsync(request, cancellationToken)
                 .ConfigureAwait(false);
             try

FirebaseAdmin/FirebaseAdmin/Util/HttpUtils.cs

@@ -12,6 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Net.Http;
@@ -51,6 +52,11 @@ internal static IList<string> CreateUpdateMask(object request)
             return mask;
         }
 
+        internal static string GetMetricsHeader()
+        {
+            return $"gl-dotnet/{Environment.Version} fire-admin/{FirebaseApp.GetSdkVersion()}";
+        }
+
         private static List<string> CreateUpdateMask(JObject dictionary)
         {
             var mask = new List<string>();