[Backend API] Implement endpoint for create event details #213

src/AzureOpenAIProxy.ApiApp/Endpoints/AdminEventEndpoints.cs

@@ -34,22 +34,20 @@ public static RouteHandlerBuilder AddNewAdminEvent(this WebApplication app)
                 return Results.BadRequest("Payload is null");
             }
 
-            //try
-            //{
-            //    var result = await service.CreateEvent(payload);
-
-            //    logger.LogInformation("Created a new event");
+            try
+            {
+                var result = await service.CreateEvent(payload);
 
-            //    return Results.Ok(result);
-            //}
-            //catch (Exception ex)
-            //{
-            //    logger.LogError(ex, "Failed to create a new event");
+                logger.LogInformation("Created a new event");
 
-            //    return Results.Problem(ex.Message, statusCode: StatusCodes.Status500InternalServerError);
-            //}
+                return Results.Ok(result);
+            }
+            catch (Exception ex)
+            {
+                logger.LogError(ex, "Failed to create a new event");
 
-            return await Task.FromResult(Results.Ok());
+                return Results.Problem(ex.Message, statusCode: StatusCodes.Status500InternalServerError);
+            }
         })
         .Accepts<AdminEventDetails>(contentType: "application/json")
         .Produces<AdminEventDetails>(statusCode: StatusCodes.Status200OK, contentType: "application/json")

src/AzureOpenAIProxy.ApiApp/Models/AdminEventDetails.cs

@@ -1,5 +1,8 @@
 using System.Text.Json.Serialization;
 
+using Azure;
+using Azure.Data.Tables;
+
 namespace AzureOpenAIProxy.ApiApp.Models;
 
 /// <summary>

src/AzureOpenAIProxy.ApiApp/Repositories/AdminEventRepository.cs

@@ -51,11 +51,18 @@
     /// <inheritdoc />
     public async Task<AdminEventDetails> CreateEvent(AdminEventDetails eventDetails)
     {
-        throw new NotImplementedException();
+        // 테이블 클라이언트
+        TableClient tableClient = await GetTableClientAsync();
+
+        // 데이터 저장
+        var createResponse = await tableClient.AddEntityAsync(eventDetails).ConfigureAwait(false);
+
+        // 저장한 엔티티 반환
+        return eventDetails;
     }
 
     /// <inheritdoc />
     public async Task<List<AdminEventDetails>> GetEvents()
     {
         throw new NotImplementedException();
     }
@@ -74,7 +81,7 @@
     }
 
     /// <inheritdoc />
     public async Task<AdminEventDetails> UpdateEvent(Guid eventId, AdminEventDetails eventDetails)
     {
         throw new NotImplementedException();
     }

src/AzureOpenAIProxy.ApiApp/Services/AdminEventService.cs

@@ -47,9 +47,13 @@ public class AdminEventService(IAdminEventRepository repository) : IAdminEventSe
     /// <inheritdoc />
     public async Task<AdminEventDetails> CreateEvent(AdminEventDetails eventDetails)
     {
-        var result = await this._repository.CreateEvent(eventDetails).ConfigureAwait(false);
-
-        return result;
+        // Validate
+        eventDetails.PartitionKey = PartitionKeys.EventDetails;
+        eventDetails.RowKey = eventDetails.EventId.ToString();
+
+        // Save
+        var response = await this._repository.CreateEvent(eventDetails).ConfigureAwait(false);
+        return response;
     }
 
     /// <inheritdoc />

src/AzureOpenAIProxy.ApiApp/appsettings.Development.sample.json

@@ -1,27 +1,30 @@
-{
-  "Logging": {
-    "LogLevel": {
-      "Default": "Information",
-      "Microsoft.AspNetCore": "Warning"
-    }
-  },
-
-  "Azure": {
-    "OpenAI": {
-      "Instances": [
-        {
-          "Endpoint": "https://{{location}}.api.cognitive.microsoft.com/",
-          "ApiKey": "{{api-key}}",
-          "DeploymentNames": [
-            "deployment-name-1",
-            "deployment-name-2"
-          ]
-        }
-      ]
-    },
-    "KeyVault": {
-      "VaultUri": "https://{{key-vault-name}}.vault.azure.net/",
-      "SecretName": "azure-openai-instances"
-    }
-  }
-}
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+
+  "Azure": {
+    "OpenAI": {
+      "Instances": [
+        {
+          "Endpoint": "https://{{location}}.api.cognitive.microsoft.com/",
+          "ApiKey": "{{api-key}}",
+          "DeploymentNames": [
+            "deployment-name-1",
+            "deployment-name-2"
+          ]
+        }
+      ]
+    },
+    "KeyVault": {
+      "VaultUri": "https://{{key-vault-name}}.vault.azure.net/",
+      "SecretNames": {
+        "OpenAI": "azure-openai-instances",
+        "Storage": "storage-connection-string"
+      }
+    }
+  }
+}

test/AzureOpenAIProxy.ApiApp.Tests/Repositories/AdminEventRepositoryTests.cs

@@ -37,7 +37,7 @@
         var tableServiceClient = default(TableServiceClient);
 
         // Act
         Action action = () => new AdminEventRepository(tableServiceClient, settings);
 
         // Assert
         action.Should().Throw<ArgumentNullException>();
@@ -51,26 +51,53 @@
         var tableServiceClient = Substitute.For<TableServiceClient>();
 
         // Act
         Action action = () => new AdminEventRepository(tableServiceClient, settings);
 
         // Assert
         action.Should().Throw<ArgumentNullException>();
     }
 
     [Fact]
-    public void Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Throw_Exception()
+    public async Task Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Return_Same_Instance()
     {
         // Arrange
         var settings = Substitute.For<StorageAccountSettings>();
         var tableServiceClient = Substitute.For<TableServiceClient>();
+        var tableClient = Substitute.For<TableClient>();
+        tableServiceClient.GetTableClient(Arg.Any<string>()).Returns(tableClient);
+        tableClient.AddEntityAsync<AdminEventDetails>(Arg.Any<AdminEventDetails>())
+            .Returns(Task.FromResult(default(Response)));
         var eventDetails = new AdminEventDetails();
         var repository = new AdminEventRepository(tableServiceClient, settings);
 
+        // Act  
+        var result = await repository.CreateEvent(eventDetails);
+
+        // Assert
+        result.Should().BeSameAs(eventDetails);
+    }
+
+    [Fact]
+    public async Task Given_Failure_In_Add_Entity_When_CreateEvent_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var settings = Substitute.For<StorageAccountSettings>();
+        var tableServiceClient = Substitute.For<TableServiceClient>();
+        var repository = new AdminEventRepository(tableServiceClient, settings);
+        var eventDetails = new AdminEventDetails();
+
+        var exception = new InvalidOperationException("Invalid Operation Error : check duplicate, null or empty values");
+
+        var tableClient = Substitute.For<TableClient>();
+        tableServiceClient.GetTableClient(Arg.Any<string>()).Returns(tableClient);
+        tableClient.AddEntityAsync<AdminEventDetails>(Arg.Any<AdminEventDetails>())
+            .ThrowsAsync(exception);
+
         // Act
-        Func<Task> func = async () => await repository.CreateEvent(eventDetails);
+        Func<Task> func = () => repository.CreateEvent(eventDetails);
 
         // Assert
-        func.Should().ThrowAsync<NotImplementedException>();
+        await func.Should().ThrowAsync<InvalidOperationException>();
     }
 
     [Fact]

test/AzureOpenAIProxy.ApiApp.Tests/Services/AdminEventServiceTests.cs

@@ -6,6 +6,8 @@
 
 using FluentAssertions;
 
+using Microsoft.AspNetCore.Authentication;
+
 using Microsoft.Extensions.DependencyInjection;
 
 using NSubstitute;
@@ -29,18 +31,42 @@ public void Given_ServiceCollection_When_AddAdminEventService_Invoked_Then_It_Sh
     }
 
     [Fact]
-    public void Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Throw_Exception()
+    public async Task Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Return_Same_Instance()
     {
         // Arrange
         var eventDetails = new AdminEventDetails();
         var repository = Substitute.For<IAdminEventRepository>();
         var service = new AdminEventService(repository);
 
+        repository.CreateEvent(Arg.Any<AdminEventDetails>()).Returns(eventDetails);
+
         // Act
-        Func<Task> func = async () => await service.CreateEvent(eventDetails);
+        var result = await service.CreateEvent(eventDetails);
 
         // Assert
-        func.Should().ThrowAsync<NotImplementedException>();
+        result.Should().BeEquivalentTo(
+            eventDetails,
+            options => options.Excluding(x => x.PartitionKey)
+                              .Excluding(x => x.RowKey)
+        );
+    }
+
+    [Fact]
+    public async Task Given_Failure_In_Add_Entity_When_CreateEvent_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var eventDetails = new AdminEventDetails();
+        var repository = Substitute.For<IAdminEventRepository>();
+        var service = new AdminEventService(repository);
+
+        var exception = new InvalidOperationException("Invalid Operation Error : check duplicate, null or empty values");
+        repository.CreateEvent(Arg.Any<AdminEventDetails>()).ThrowsAsync(exception);
+
+        // Act
+        Func<Task> func = () => service.CreateEvent(eventDetails);
+
+        // Assert
+        await func.Should().ThrowAsync<InvalidOperationException>();
     }
 
     [Fact]

test/AzureOpenAIProxy.AppHost.Tests/ApiApp/Endpoints/AdminGetEventsOpenApiTests.cs

@@ -8,7 +8,6 @@ namespace AzureOpenAIProxy.AppHost.Tests.ApiApp.Endpoints;
 
 public class AdminGetEventsOpenApiTests(AspireAppHostFixture host) : IClassFixture<AspireAppHostFixture>
 {
-    // TODO: [tae0y] 테스트코드 작성하기
     [Fact]
     public async Task Given_Resource_When_Invoked_Endpoint_Then_It_Should_Return_Path()
     {