Recipient API created (#35)

src/ProjectOrigin.Stamp.Server/Database/IUnitOfWork.cs

@@ -0,0 +1,11 @@
+using ProjectOrigin.Stamp.Server.Repositories;
+
+namespace ProjectOrigin.Stamp.Server.Database;
+
+public interface IUnitOfWork
+{
+    void Commit();
+    void Rollback();
+
+    IRecipientRepository RecipientRepository { get; }
+}

src/ProjectOrigin.Stamp.Server/Database/Postgres/PostgresConnectionFactory.cs

@@ -1,7 +1,6 @@
 using System.Data;
 using Microsoft.Extensions.Options;
 using Npgsql;
-using ProjectOrigin.Stamp.Server.Database.Postgres;
 
 namespace ProjectOrigin.Stamp.Server.Database.Postgres;
 

src/ProjectOrigin.Stamp.Server/Database/Postgres/Scripts/0001.sql

@@ -0,0 +1,6 @@
+CREATE TABLE IF NOT EXISTS Recipients (
+    id uuid NOT NULL PRIMARY KEY,
+    wallet_endpoint_reference_version integer NOT NULL,
+    wallet_endpoint_reference_endpoint VARCHAR(512) NOT NULL,
+    wallet_endpoint_reference_public_key bytea NOT NULL
+);

src/ProjectOrigin.Stamp.Server/Database/UnitOfWork.cs

@@ -0,0 +1,104 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using ProjectOrigin.Stamp.Server.Repositories;
+
+namespace ProjectOrigin.Stamp.Server.Database;
+
+public class UnitOfWork : IUnitOfWork, IDisposable
+{
+    private IRecipientRepository _recipientRepository = null!;
+
+    public IRecipientRepository RecipientRepository
+    {
+        get
+        {
+            return _recipientRepository ??= new RecipientRepository(_lazyTransaction.Value.Connection ?? throw new InvalidOperationException("Transaction is null."));
+        }
+    }
+
+    private readonly Dictionary<Type, object> _repositories = new Dictionary<Type, object>();
+    private readonly Lazy<IDbConnection> _lazyConnection;
+    private Lazy<IDbTransaction> _lazyTransaction;
+    private bool _disposed = false;
+
+    public UnitOfWork(IDbConnectionFactory connectionFactory)
+    {
+        _lazyConnection = new Lazy<IDbConnection>(() =>
+        {
+            var connection = connectionFactory.CreateConnection();
+            connection.Open();
+            return connection;
+        });
+
+        _lazyTransaction = new Lazy<IDbTransaction>(_lazyConnection.Value.BeginTransaction);
+    }
+
+    public void Commit()
+    {
+        if (!_lazyTransaction.IsValueCreated)
+            return;
+
+        try
+        {
+            _lazyTransaction.Value.Commit();
+        }
+        catch
+        {
+            _lazyTransaction.Value.Rollback();
+            throw;
+        }
+        finally
+        {
+            ResetUnitOfWork();
+        }
+    }
+
+    public void Rollback()
+    {
+        if (!_lazyTransaction.IsValueCreated)
+            return;
+
+        _lazyTransaction.Value.Rollback();
+
+        ResetUnitOfWork();
+    }
+
+    private void ResetUnitOfWork()
+    {
+        if (_lazyTransaction.IsValueCreated)
+            _lazyTransaction.Value.Dispose();
+
+        _lazyTransaction = new Lazy<IDbTransaction>(_lazyConnection.Value.BeginTransaction);
+
+        _repositories.Clear();
+    }
+
+    public void Dispose()
+    {
+        Dispose(true);
+        GC.SuppressFinalize(this);
+    }
+
+    ~UnitOfWork() => Dispose(false);
+
+    protected virtual void Dispose(bool disposing)
+    {
+        if (disposing && !_disposed)
+        {
+            _disposed = true;
+
+            if (_lazyTransaction.IsValueCreated)
+            {
+                _lazyTransaction.Value.Dispose();
+            }
+
+            if (_lazyConnection.IsValueCreated)
+            {
+                _lazyConnection.Value.Dispose();
+            }
+        }
+
+        _repositories.Clear();
+    }
+}

src/ProjectOrigin.Stamp.Server/Models/Recipient.cs

@@ -0,0 +1,12 @@
+using System;
+using ProjectOrigin.HierarchicalDeterministicKeys.Interfaces;
+
+namespace ProjectOrigin.Stamp.Server.Models;
+
+public class Recipient
+{
+    public required Guid Id { get; init; }
+    public required int WalletEndpointReferenceVersion { get; init; }
+    public required string WalletEndpointReferenceEndpoint { get; init; }
+    public required IHDPublicKey WalletEndpointReferencePublicKey { get; init; }
+}

src/ProjectOrigin.Stamp.Server/Properties/launchSettings.json

@@ -0,0 +1,12 @@
+{
+  "profiles": {
+    "ProjectOrigin.Stamp.Server": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "applicationUrl": "https://localhost:57881;http://localhost:57882"
+    }
+  }
+}

src/ProjectOrigin.Stamp.Server/Repositories/RecipientRepository.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Data;
+using System.Threading.Tasks;
+using Dapper;
+using ProjectOrigin.Stamp.Server.Models;
+
+namespace ProjectOrigin.Stamp.Server.Repositories;
+
+public interface IRecipientRepository
+{
+    Task<int> Create(Recipient recipient);
+    Task<Recipient?> Get(Guid id);
+}
+
+public class RecipientRepository : IRecipientRepository
+{
+    private readonly IDbConnection _connection;
+
+    public RecipientRepository(IDbConnection connection)
+    {
+        _connection = connection;
+    }
+
+    public Task<int> Create(Recipient recipient)
+    {
+        return _connection.ExecuteAsync(
+            @"INSERT INTO recipients (id, wallet_endpoint_reference_version, wallet_endpoint_reference_endpoint, wallet_endpoint_reference_public_key)
+                VALUES (@Id, @WalletEndpointReferenceVersion, @WalletEndpointReferenceEndpoint, @WalletEndpointReferencePublicKey)",
+            new
+            {
+                recipient.Id,
+                recipient.WalletEndpointReferenceVersion,
+                recipient.WalletEndpointReferenceEndpoint,
+                recipient.WalletEndpointReferencePublicKey
+            });
+    }
+
+    public Task<Recipient?> Get(Guid id)
+    {
+        return _connection.QueryFirstOrDefaultAsync<Recipient>(
+            @"SELECT id, wallet_endpoint_reference_version, wallet_endpoint_reference_endpoint, wallet_endpoint_reference_public_key
+                FROM recipients
+                WHERE id = @Id",
+            new { Id = id });
+    }
+}

src/ProjectOrigin.Stamp.Server/Services/REST/v1/RecipientController.cs

@@ -0,0 +1,88 @@
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Threading.Tasks;
+using ProjectOrigin.Stamp.Server.Database;
+using ProjectOrigin.Stamp.Server.Models;
+using ProjectOrigin.HierarchicalDeterministicKeys.Implementations;
+using Microsoft.AspNetCore.Http;
+
+namespace ProjectOrigin.Stamp.Server.Services.REST.v1;
+
+[ApiController]
+public class RecipientController : ControllerBase
+{
+    /// <summary>
+    /// Creates a new recipient
+    /// </summary>
+    /// <param name="unitOfWork"></param>
+    /// <param name="request">The create recipient request</param>
+    /// <response code="201">The recipient was created.</response>
+    [HttpPost]
+    [Route("v1/recipients")]
+    [Produces("application/json")]
+    [ProducesResponseType(StatusCodes.Status201Created)]
+    public async Task<ActionResult<CreateRecipientResponse>> CreateRecipient(
+        [FromServices] IUnitOfWork unitOfWork,
+        [FromBody] CreateRecipientRequest request)
+    {
+        var recipient = new Recipient
+        {
+            Id = Guid.NewGuid(),
+            WalletEndpointReferenceVersion = request.WalletEndpointReference.Version,
+            WalletEndpointReferenceEndpoint = request.WalletEndpointReference.Endpoint.ToString(),
+            WalletEndpointReferencePublicKey = new Secp256k1Algorithm().ImportHDPublicKey(request.WalletEndpointReference.PublicKey)
+        };
+
+        await unitOfWork.RecipientRepository.Create(recipient);
+
+        unitOfWork.Commit();
+
+        return Created(null as string, new CreateRecipientResponse
+        {
+            Id = recipient.Id
+        });
+    }
+}
+
+#region Records
+
+/// <summary>
+/// Request to create a new recipient.
+/// </summary>
+public record CreateRecipientRequest
+{
+    /// <summary>
+    /// The recipient wallet endpoint reference.
+    /// </summary>
+    public required WalletEndpointReferenceDto WalletEndpointReference { get; init; }
+}
+
+public record WalletEndpointReferenceDto
+{
+    /// <summary>
+    /// The version of the ReceiveSlice API.
+    /// </summary>
+    public required int Version { get; init; }
+
+    /// <summary>
+    /// The url endpoint of where the wallet is hosted.
+    /// </summary>
+    public required Uri Endpoint { get; init; }
+
+    /// <summary>
+    /// The public key used to generate sub-public-keys for each slice.
+    /// </summary>
+    public required byte[] PublicKey { get; init; }
+}
+
+/// <summary>
+/// Response to create a recipient.
+/// </summary>
+public record CreateRecipientResponse
+{
+    /// <summary>
+    /// The ID of the created recipient.
+    /// </summary>
+    public required Guid Id { get; init; }
+}
+#endregion

src/ProjectOrigin.Stamp.Server/Startup.cs

@@ -113,6 +113,7 @@ public void ConfigureServices(IServiceCollection services)
             o.ConfigureMassTransitTransport(_configuration.GetSection("MessageBroker").GetValid<MessageBrokerOptions>());
         });
 
+        services.AddScoped<IUnitOfWork, UnitOfWork>();
         services.AddSingleton<IDbConnectionFactory, PostgresConnectionFactory>();
 
         services.AddSwaggerGen(options =>

src/ProjectOrigin.Stamp.Test/Extensions/HttpClientExtensions.cs

@@ -0,0 +1,21 @@
+using System.Net.Http.Json;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace ProjectOrigin.Stamp.Test.Extensions;
+
+public static class HttpClientExtensions
+{
+    public static async Task<T?> ReadJson<T>(this HttpContent content)
+    {
+        var options = GetJsonSerializerOptions();
+        return await content.ReadFromJsonAsync<T>(options);
+    }
+
+    private static JsonSerializerOptions GetJsonSerializerOptions()
+    {
+        var options = new JsonSerializerOptions(JsonSerializerDefaults.Web);
+        options.Converters.Add(new JsonStringEnumConverter());
+        return options;
+    }
+}

src/ProjectOrigin.Stamp.Test/ProjectOrigin.Stamp.Test.csproj

@@ -6,4 +6,20 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="FluentAssertions" Version="6.12.0" />
+    <PackageReference Include="Microsoft.AspNetCore.TestHost" Version="8.0.4" />
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.9.0" />
+    <PackageReference Include="Testcontainers.PostgreSql" Version="3.8.0" />
+    <PackageReference Include="xunit" Version="2.8.0" />
+    <PackageReference Include="xunit.runner.visualstudio" Version="2.8.0">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\ProjectOrigin.Stamp.Server\ProjectOrigin.Stamp.Server.csproj" />
+  </ItemGroup>
+
 </Project>