fix(api): add authorization token for function request

refs #273
agrc · Dec 13, 2023 · dc689f8 · dc689f8
1 parent b39b50b
commit dc689f8
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 0 deletions.
diff --git a/build/Packages.targets b/build/Packages.targets
@@ -35,6 +35,7 @@
 
     <!-- Cloud -->
     <PackageReference Update="Google.Cloud.Storage.V1" Version="4.7.0" />
+    <PackageReference Update="Google.Apis.Auth" Version ="1.64.0" />
 
     <!-- Email -->
     <PackageReference Update="SendGrid" Version="9.28.1" />

diff --git a/src/api/Features/Inventories/InventoryCommands.cs b/src/api/Features/Inventories/InventoryCommands.cs
@@ -7,6 +7,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using api.Infrastructure;
+using Google.Apis.Auth.OAuth2;
 using MediatR;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
@@ -251,8 +252,17 @@ public async Task<HttpContent> Handle(Command request, CancellationToken cancell
 
             var payload = new ReportPayload(new InventoryPayload(site.Inventories.Single(), site), site.Contacts.Select(x => new ContactPayload(x)));
 
+            _log.Debug("Requesting Application Default Credentials");
+
+            var credential = await GoogleCredential.GetApplicationDefaultAsync(cancellationToken);
+            var accessToken = await credential.UnderlyingCredential.GetAccessTokenForRequestAsync(cancellationToken: cancellationToken);
+
+            _client.DefaultRequestHeaders.Authorization = new("Bearer", accessToken);
+
             var response = await _client.PostAsJsonAsync(_functionUrl, payload, cancellationToken);
 
+            response.EnsureSuccessStatusCode();
+
             return response.Content;
         }
     }

diff --git a/src/api/api.csproj b/src/api/api.csproj
@@ -34,6 +34,7 @@
     <PackageReference Include="Serilog.Sinks.GoogleCloudLogging" />
     <PackageReference Include="System.Text.Encoding.CodePages" />
     <PackageReference Include="Google.Cloud.Storage.V1" />
+    <PackageReference Include="Google.Apis.Auth" />
     <PackageReference Include="SendGrid" />
     <PackageReference Include="SendGrid.Extensions.DependencyInjection" />
   </ItemGroup>