List users and connections

Author: christopher-dabrowski

dotnet/S03E05/GlobalUsings.cs

@@ -3,6 +3,3 @@
 global using Microsoft.Extensions.DependencyInjection;
 global using Microsoft.Extensions.Hosting;
 global using Microsoft.Extensions.Options;
-global using Common;
-global using Common.Models;
-global using Common.Services;

dotnet/S03E05/Models/DatabaseRequest.cs

@@ -0,0 +1,15 @@
+using System.Text.Json.Serialization;
+
+namespace S03E05.Models;
+
+public record DatabaseRequest
+{
+    [JsonPropertyName("task")]
+    public string Task { get; } = "database";
+
+    [JsonPropertyName("apikey")]
+    public required string ApiKey { get; init; }
+
+    [JsonPropertyName("query")]
+    public required string Query { get; init; }
+}

dotnet/S03E05/Models/DbConnection.cs

@@ -0,0 +1,12 @@
+namespace S03E05.Models;
+
+using System.Text.Json.Serialization;
+
+public record DbConnection
+{
+    [JsonPropertyName("user1_id")]
+    public required string User1Id { get; set; }
+
+    [JsonPropertyName("user2_id")]
+    public required string User2Id { get; set; }
+}

dotnet/S03E05/Models/DbResponse.cs

@@ -0,0 +1,10 @@
+namespace S03E05.Models;
+
+public record DbResponse<T>
+{
+    [JsonPropertyName("reply")]
+    public required IReadOnlyList<T> Reply { get; set; }
+
+    [JsonPropertyName("error")]
+    public required string Error { get; set; }
+}

dotnet/S03E05/Models/DbUser.cs

@@ -0,0 +1,22 @@
+namespace S03E05.Models;
+
+using System.Text.Json.Serialization;
+
+public record DbUser
+{
+    [JsonPropertyName("id")]
+    public required string Id { get; set; }
+
+    [JsonPropertyName("username")]
+    public required string Username { get; set; }
+
+    [JsonPropertyName("access_level")]
+    public required string AccessLevel { get; set; }
+
+    [JsonPropertyName("is_active")]
+    public required string IsActive { get; set; }
+
+    [JsonPropertyName("lastlog")]
+    public required DateTime LastLog { get; set; }
+}
+

dotnet/S03E05/Models/S03E05Options.cs

@@ -0,0 +1,11 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace S03E05.Models;
+
+public class S03E05Options
+{
+    public const string SectionName = "S03E05";
+
+    [Required]
+    public string DatabaseApiUrl { get; init; } = string.Empty;
+}

dotnet/S03E05/Program.cs

@@ -1,4 +1,6 @@
-using S03E05;
+using System.Net.Http.Json;
+using Common.AiDevsApi.Models;
+using S03E05;
 using S03E05.Models;
 
 var builder = Host.CreateApplicationBuilder(args);
@@ -10,6 +12,13 @@
 await using var scope = host.Services.CreateAsyncScope();
 var sp = scope.ServiceProvider;
 
+var dbUsers = await ListUsers();
+var dbConnections = await ListConnections();
+
+Console.WriteLine(JsonSerializer.Serialize(dbUsers));
+Console.WriteLine(JsonSerializer.Serialize(dbConnections));
+
+
 // Add task-specific logic here
 
 // var aiDevsApiService = sp.GetRequiredService<IAiDevsApiService>();
@@ -22,10 +31,30 @@
 // var taskResponseResult = await aiDevsApiService.VerifyTaskAnswerAsync(taskResponse);
 // Console.WriteLine(JsonSerializer.Serialize(taskResponseResult));
 
+async Task<IReadOnlyList<DbUser>> ListUsers()
+{
+    const string Command = "SELECT * FROM users";
+    var dbResponse = await RunDbCommand(Command);
+
+    var parsedResponse = JsonSerializer.Deserialize<DbResponse<DbUser>>(dbResponse)
+        ?? throw new InvalidOperationException("Invalid API response");
+    return parsedResponse.Reply;
+}
+
+async Task<IReadOnlyList<DbConnection>> ListConnections()
+{
+    const string Command = "SELECT * FROM connections";
+    var dbResponse = await RunDbCommand(Command);
+
+    var parsedResponse = JsonSerializer.Deserialize<DbResponse<DbConnection>>(dbResponse)
+        ?? throw new InvalidOperationException("Invalid API response");
+    return parsedResponse.Reply;
+}
+
 async Task<string> RunDbCommand(string command)
 {
     var aiDevsOptions = sp.GetRequiredService<IOptions<AiDevsApiOptions>>().Value;
-    var taskOptions = sp.GetRequiredService<IOptions<S03E03Options>>().Value;
+    var taskOptions = sp.GetRequiredService<IOptions<S03E05Options>>().Value;
 
     var dbRequest = new DatabaseRequest
     {

dotnet/S03E05/Properties/launchSettings.json

@@ -0,0 +1,11 @@
+{
+  "profiles": {
+    "S03E05": {
+      "commandName": "Project",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

dotnet/S03E05/ServiceCollectionExtensions.cs

@@ -1,16 +1,18 @@
+using Common.AiDevsApi.Extensions;
+using S03E05.Models;
+
 namespace S03E05;
 
 public static class ServiceCollectionExtensions
 {
     public static IServiceCollection AddS03E05(this IServiceCollection services)
     {
-        services
-            .AddCommonServices()
-            .Configure<S03E05Options>(options =>
-            {
-                // Configure task-specific options here
-            });
+        services.AddOptions<S03E05Options>()
+            .BindConfiguration(S03E05Options.SectionName)
+            .ValidateDataAnnotations()
+            .ValidateOnStart();
 
-        return services;
+        return services
+            .AddAiDevsApi();
     }
 }