feat: add shim to target Vonage APIs (#254)

* build: update libraries, and include Vonage SDK

* feat: implement shim to target Vonage Video API

* feat: use either apikey or appid in all calls

* feat: add tests for StartArchive

note: these tests are pointless as just they assert the called url. The custom HttpClient is mocked, so all the logic is avoided...

* refactor: remove unused method

* feat: make GetOpenTokId public

* feat: add archiving features to the BlazorSampleApp

BlazorHelloWorld/Components/Pages/Home.razor

@@ -23,17 +23,32 @@
         <div id="subscribers">
         </div>
     </div>
+    <div>
+        <button class="btn btn-success" onclick="@StartArchiving" disabled="@isArchiving">Start archiving</button>
+        <button class="btn btn-danger" onclick="@StopArchiving" disabled="@(!isArchiving)">Stop archiving</button>
+    </div>
 </div>
 
 @code {
+    private bool isArchiving => this.archiveId != Guid.Empty;
+    private SessionCredentials session;
+    private Guid archiveId;
+
     protected override async Task OnAfterRenderAsync(bool firstRender)
     {
         await base.OnAfterRenderAsync(firstRender);
         if (firstRender)
         {
-            var session = Service.CreateSession();
-            await JavascriptRuntime.InvokeVoidAsync("initializeStream", Service.GetApiKey(), session.SessionId, session.Token);    
+            this.session = Service.CreateSession();
+            await JavascriptRuntime.InvokeVoidAsync("initializeStream", Service.GetOpenTokId(), session.SessionId, session.Token);    
         }
     }
 
+    private async Task StartArchiving()
+    {
+        var archive = await Service.StartArchiving(this.session.SessionId);
+        this.archiveId = archive.Id;
+    }
+
+    private Task StopArchiving() => Service.StopArchiving(this.archiveId.ToString());
 }

BlazorHelloWorld/Infrastructure/VideoService.cs

@@ -10,11 +10,28 @@ namespace BlazorHelloWorld.Infrastructure;
 public class VideoService
 {
     private readonly OpenTok openTok;
+    private readonly string apiKey;
 
     public VideoService(OpenTokOptions options)
     {
         ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12;
-        openTok = new OpenTok(Convert.ToInt32(options.ApiKey), options.ApiSecret);
+        this.openTok = InitializeClient(options);
+    }
+
+    private OpenTok InitializeClient(OpenTokOptions options)
+    {
+        if (!string.IsNullOrEmpty(options.ApplicationId) && !string.IsNullOrEmpty(options.PrivateKey))
+        {
+            return new OpenTok(options.ApplicationId, options.PrivateKey);
+        }
+
+        if (!string.IsNullOrEmpty(options.ApiKey) && !string.IsNullOrEmpty(options.ApiSecret) 
+            && int.TryParse(options.ApiKey, out var key))
+        {
+            return new OpenTok(key, options.ApiSecret);
+        }
+
+        throw new ArgumentException("Missing credentials");
     }
 
     public SessionCredentials CreateSession()
@@ -23,12 +40,19 @@ public SessionCredentials CreateSession()
         return new SessionCredentials(session.Id, session.GenerateToken());
     }
 
-    public int GetApiKey()
+    public string GetOpenTokId() => this.openTok.GetOpenTokId();
+
+    public async Task<Archive> StartArchiving(string sessionId)
+    {
+        return await openTok.StartArchiveAsync(sessionId);
+    }
+
+    public async Task StopArchiving(string archiveId)
     {
-        return openTok.ApiKey;
+        await openTok.StopArchiveAsync(archiveId);
     }
 }
 
-public record OpenTokOptions(string ApiKey, string ApiSecret);
+public record OpenTokOptions(string ApiKey, string ApiSecret, string ApplicationId, string PrivateKey);
 
 public record SessionCredentials(string SessionId, string Token);

BlazorHelloWorld/Program.cs

@@ -5,7 +5,7 @@
 var options = builder.Configuration.GetSection(nameof(OpenTokOptions)).Get<OpenTokOptions>();
 builder.Services.AddRazorComponents().AddInteractiveServerComponents();
 builder.Services.AddServerSideBlazor();
-builder.Services.AddSingleton<OpenTokOptions>(options);
+builder.Services.AddSingleton(options);
 builder.Services.AddScoped<VideoService>();
 var app = builder.Build();
 app.UseHttpsRedirection();

BlazorHelloWorld/appsettings.json

@@ -8,6 +8,8 @@
   "AllowedHosts": "*",
   "OpenTokOptions": {
     "ApiKey": "",
-    "ApiSecret": ""
+    "ApiSecret": "",
+    "ApplicationId": "",
+    "PrivateKey": ""
   }
 }

OpenTok/OpenTok.AudioConnector.cs

@@ -14,7 +14,7 @@ public partial class OpenTok
         public async Task<AudioConnector> StartAudioConnectorAsync(AudioConnectorStartRequest request)
         {
             var response = await this.Client.PostAsync(
-                $"v2/project/{this.ApiKey}/connect",
+                $"v2/project/{this.GetOpenTokId()}/connect",
                 GetHeaderDictionary("application/json"),
                 request.ToDataDictionary());
             return JsonConvert.DeserializeObject<AudioConnector>(response);
@@ -26,7 +26,7 @@ public async Task<AudioConnector> StartAudioConnectorAsync(AudioConnectorStartRe
         /// <param name="connectionId">The OpenTok connection ID for the Audio Connector WebSocket connection in the OpenTok session. See <see cref="AudioConnector.ConnectionId"/>.</param>
         public async Task StopAudioConnectorAsync(string connectionId) =>
             _ = await this.Client.PostAsync(
-                $"v2/project/{this.ApiKey}/connect/{connectionId}/stop",
+                $"v2/project/{this.GetOpenTokId()}/connect/{connectionId}/stop",
                 new Dictionary<string, string>(),
                 new Dictionary<string, object>());
     }

OpenTok/OpenTok.Render.cs

@@ -59,7 +59,7 @@ await this.Client.DeleteAsync(
 				this.BuildUrlWithRouteParameter(RenderEndpoint, renderId),
 				new Dictionary<string, string>());
 
-		private string BuildUrl(string endpoint) => $"v2/project/{this.ApiKey}{endpoint}";
+		private string BuildUrl(string endpoint) => $"v2/project/{this.GetOpenTokId()}{endpoint}";
 
 		private string BuildUrlWithQueryParameter(string endpoint, string queryParameter) =>
 			$"{this.BuildUrl(endpoint)}?{queryParameter}";