add source certificat renewal

Dative-GPI · Nov 9, 2023 · 59ce6b5 · 59ce6b5
1 parent 2ea5e2e
commit 59ce6b5
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 2 deletions.
diff --git a/Foundation.SourceClients/FoundationRoutes.cs b/Foundation.SourceClients/FoundationRoutes.cs
@@ -3,6 +3,7 @@ namespace Foundation.SourceClients.Services
     public static class FoundationRoutes
     {
         public const string ACCOUNT_PATH = "/api/v1/source-accounts";
+        public const string RENEW_PATH = "/api/v1/source-accounts/renew";
         public const string LOGIN_PATH = "/api/v1/source-accounts/login";
         public const string SOURCE_PATH = "/api/sources/v1/sources";
     }

diff --git a/Foundation.SourceClients/Services/FoundationAccountClient.cs b/Foundation.SourceClients/Services/FoundationAccountClient.cs
@@ -43,10 +43,10 @@ public async Task<X509Certificate2> Create(string token, string machineId, Cance
                 token, _client.BaseAddress + ACCOUNT_PATH
             );
 
-            var response = await _client.PostAsJsonAsync(ACCOUNT_PATH, new { Token = token, MachineId = machineId });
+            var response = await _client.PostAsJsonAsync(ACCOUNT_PATH, new { Token = token, MachineId = machineId }, cancellationToken: ct);
             response.EnsureSuccessStatusCode();
 
-            var payload = await response.Content.ReadFromJsonAsync<CredentialPayload>();
+            var payload = await response.Content.ReadFromJsonAsync<CredentialPayload>(cancellationToken: ct);
             var secret = Convert.FromBase64String(payload.Secret);
 
             var certificate = new X509Certificate2(secret);
@@ -135,6 +135,24 @@ private async Task<string> ReceiveBearerToken(ClientWebSocket client, Memory<byt
 
             return token;
         }
+
+        public async Task<X509Certificate2> RenewCertificate(CancellationToken ct)
+        {
+            _logger.LogInformation(
+                "Renewing credential on {uri}",
+                _client.BaseAddress + RENEW_PATH
+            );
+
+            var response = await _client.PostAsJsonAsync(RENEW_PATH, ct);
+            response.EnsureSuccessStatusCode();
+
+            var payload = await response.Content.ReadFromJsonAsync<CredentialPayload>(cancellationToken: ct);
+            var secret = Convert.FromBase64String(payload.Secret);
+
+            var certificate = new X509Certificate2(secret);
+
+            return certificate;
+        }
     }
 
     public class CredentialPayload