[Admin] Add repository layer for admin events

src/AzureOpenAIProxy.ApiApp/Program.cs

@@ -1,5 +1,6 @@
 using AzureOpenAIProxy.ApiApp.Endpoints;
 using AzureOpenAIProxy.ApiApp.Extensions;
+using AzureOpenAIProxy.ApiApp.Repositories;
 using AzureOpenAIProxy.ApiApp.Services;
 
 var builder = WebApplication.CreateBuilder(args);
@@ -18,6 +19,9 @@
 // Add admin services
 builder.Services.AddAdminEventService();
 
+// Add admin repositories
+builder.Services.AddAdminEventRepository();
+
 var app = builder.Build();
 
 app.MapDefaultEndpoints();

src/AzureOpenAIProxy.ApiApp/Repositories/AdminEventRepository.cs

@@ -0,0 +1,85 @@
+using AzureOpenAIProxy.ApiApp.Models;
+
+namespace AzureOpenAIProxy.ApiApp.Repositories;
+
+/// <summary>
+/// This provides interfaces to the <see cref="AdminEventRepository"/> class.
+/// </summary>
+public interface IAdminEventRepository
+{
+    /// <summary>
+    /// Creates a new record of event details.
+    /// </summary>
+    /// <param name="eventDetails">Event details instance.</param>
+    /// <returns>Returns the event details instance created.</returns>
+    Task<AdminEventDetails> CreateEvent(AdminEventDetails eventDetails);
+
+    /// <summary>
+    /// Gets the list of events.
+    /// </summary>
+    /// <returns>Returns the list of events.</returns>
+    Task<List<AdminEventDetails>> GetEvents();
+
+    /// <summary>
+    /// Gets the event details.
+    /// </summary>
+    /// <param name="eventId">Event ID.</param>
+    /// <returns>Returns the event details record.</returns>
+    Task<AdminEventDetails> GetEvent(Guid eventId);
+
+    /// <summary>
+    /// Updates the event details.
+    /// </summary>
+    /// <param name="eventId">Event ID.</param>
+    /// <param name="eventDetails">Event details instance.</param>
+    /// <returns>Returns the updated record of the event details.</returns>
+    Task<AdminEventDetails> UpdateEvent(Guid eventId, AdminEventDetails eventDetails);
+}
+
+/// <summary>
+/// This represents the repository entity for the admin event.
+/// </summary>
+public class AdminEventRepository : IAdminEventRepository
+{
+    /// <inheritdoc />
+    public async Task<AdminEventDetails> CreateEvent(AdminEventDetails eventDetails)
+    {
+        throw new NotImplementedException();
+    }
+
+    /// <inheritdoc />
+    public async Task<List<AdminEventDetails>> GetEvents()
+    {
+        throw new NotImplementedException();
+    }
+
+    /// <inheritdoc />
+    public async Task<AdminEventDetails> GetEvent(Guid eventId)
+    {
+        throw new NotImplementedException();
+    }
+
+    /// <inheritdoc />
+    public async Task<AdminEventDetails> UpdateEvent(Guid eventId, AdminEventDetails eventDetails)
+    {
+        throw new NotImplementedException();
+    }
+}
+
+/// <summary>
+/// This represents the extension class for <see cref="IServiceCollection"/>
+/// </summary>
+public static class AdminEventRepositoryExtensions
+{
+    /// <summary>
+    /// Adds the <see cref="AdminEventRepository"/> instance to the service collection.
+    /// </summary>
+    /// <param name="services"><see cref="IServiceCollection"/> instance.</param>
+    /// <returns>Returns <see cref="IServiceCollection"/> instance.</returns>
+    public static IServiceCollection AddAdminEventRepository(this IServiceCollection services)
+    {
+        services.AddScoped<IAdminEventRepository, AdminEventRepository>();
+
+        return services;
+    }
+}

src/AzureOpenAIProxy.ApiApp/Services/AdminEventService.cs

@@ -1,4 +1,5 @@
 using AzureOpenAIProxy.ApiApp.Models;
+using AzureOpenAIProxy.ApiApp.Repositories;
 
 namespace AzureOpenAIProxy.ApiApp.Services;
 
@@ -39,30 +40,40 @@ public interface IAdminEventService
 /// <summary>
 /// This represents the service entity for admin event.
 /// </summary>
-public class AdminEventService : IAdminEventService
+public class AdminEventService(IAdminEventRepository repository) : IAdminEventService
 {
+    private readonly IAdminEventRepository _repository = repository ?? throw new ArgumentNullException(nameof(repository));
+
     /// <inheritdoc />
     public async Task<AdminEventDetails> CreateEvent(AdminEventDetails eventDetails)
     {
-        throw new NotImplementedException();
+        var result = await this._repository.CreateEvent(eventDetails).ConfigureAwait(false);
+
+        return result;
     }
 
     /// <inheritdoc />
     public async Task<List<AdminEventDetails>> GetEvents()
     {
-        throw new NotImplementedException();
+        var result = await this._repository.GetEvents().ConfigureAwait(false);
+
+        return result;
     }
 
     /// <inheritdoc />
     public async Task<AdminEventDetails> GetEvent(Guid eventId)
     {
-        throw new NotImplementedException();
+        var result = await this._repository.GetEvent(eventId).ConfigureAwait(false);
+
+        return result;
     }
 
     /// <inheritdoc />
     public async Task<AdminEventDetails> UpdateEvent(Guid eventId, AdminEventDetails eventDetails)
     {
-        throw new NotImplementedException();
+        var result = await this._repository.UpdateEvent(eventId, eventDetails).ConfigureAwait(false);
+
+        return result;
     }
 }
 

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

@@ -0,0 +1,80 @@
+using AzureOpenAIProxy.ApiApp.Models;
+using AzureOpenAIProxy.ApiApp.Repositories;
+
+using FluentAssertions;
+
+using Microsoft.Extensions.DependencyInjection;
+
+namespace AzureOpenAIProxy.ApiApp.Tests.Repositories;
+
+public class AdminEventRepositoryTests
+{
+    [Fact]
+    public void Given_ServiceCollection_When_AddAdminEventRepository_Invoked_Then_It_Should_Contain_AdminEventRepository()
+    {
+        // Arrange
+        var services = new ServiceCollection();
+
+        // Act
+        services.AddAdminEventRepository();
+
+        // Assert
+        services.SingleOrDefault(p => p.ServiceType == typeof(IAdminEventRepository)).Should().NotBeNull();
+    }
+
+    [Fact]
+    public void Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var eventDetails = new AdminEventDetails();
+        var repository = new AdminEventRepository();
+
+        // Act
+        Func<Task> func = async () => await repository.CreateEvent(eventDetails);
+
+        // Assert
+        func.Should().ThrowAsync<NotImplementedException>();
+    }
+
+    [Fact]
+    public void Given_Instance_When_GetEvents_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var repository = new AdminEventRepository();
+
+        // Act
+        Func<Task> func = async () => await repository.GetEvents();
+
+        // Assert
+        func.Should().ThrowAsync<NotImplementedException>();
+    }
+
+    [Fact]
+    public void Given_Instance_When_GetEvent_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var eventId = Guid.NewGuid();
+        var repository = new AdminEventRepository();
+
+        // Act
+        Func<Task> func = async () => await repository.GetEvent(eventId);
+
+        // Assert
+        func.Should().ThrowAsync<NotImplementedException>();
+    }
+
+    [Fact]
+    public void Given_Instance_When_UpdateEvent_Invoked_Then_It_Should_Throw_Exception()
+    {
+        // Arrange
+        var eventId = Guid.NewGuid();
+        var eventDetails = new AdminEventDetails();
+        var repository = new AdminEventRepository();
+
+        // Act
+        Func<Task> func = async () => await repository.UpdateEvent(eventId, eventDetails);
+
+        // Assert
+        func.Should().ThrowAsync<NotImplementedException>();
+    }
+}

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

@@ -1,10 +1,13 @@
 using AzureOpenAIProxy.ApiApp.Models;
+using AzureOpenAIProxy.ApiApp.Repositories;
 using AzureOpenAIProxy.ApiApp.Services;
 
 using FluentAssertions;
 
 using Microsoft.Extensions.DependencyInjection;
 
+using NSubstitute;
+
 namespace AzureOpenAIProxy.ApiApp.Tests.Services;
 
 public class AdminEventServiceTests
@@ -27,7 +30,8 @@ public void Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Throw_Excepti
     {
         // Arrange
         var eventDetails = new AdminEventDetails();
-        var service = new AdminEventService();
+        var repository = Substitute.For<IAdminEventRepository>();
+        var service = new AdminEventService(repository);
 
         // Act
         Func<Task> func = async () => await service.CreateEvent(eventDetails);
@@ -40,7 +44,8 @@ public void Given_Instance_When_CreateEvent_Invoked_Then_It_Should_Throw_Excepti
     public void Given_Instance_When_GetEvents_Invoked_Then_It_Should_Throw_Exception()
     {
         // Arrange
-        var service = new AdminEventService();
+        var repository = Substitute.For<IAdminEventRepository>();
+        var service = new AdminEventService(repository);
 
         // Act
         Func<Task> func = async () => await service.GetEvents();
@@ -54,7 +59,8 @@ public void Given_Instance_When_GetEvent_Invoked_Then_It_Should_Throw_Exception(
     {
         // Arrange
         var eventId = Guid.NewGuid();
-        var service = new AdminEventService();
+        var repository = Substitute.For<IAdminEventRepository>();
+        var service = new AdminEventService(repository);
 
         // Act
         Func<Task> func = async () => await service.GetEvent(eventId);
@@ -69,7 +75,8 @@ public void Given_Instance_When_UpdateEvent_Invoked_Then_It_Should_Throw_Excepti
         // Arrange
         var eventId = Guid.NewGuid();
         var eventDetails = new AdminEventDetails();
-        var service = new AdminEventService();
+        var repository = Substitute.For<IAdminEventRepository>();
+        var service = new AdminEventService(repository);
 
         // Act
         Func<Task> func = async () => await service.UpdateEvent(eventId, eventDetails);