refactor(UTXOTag): make Outpoint property non-nullable to enforce dat…

…a integrity refactor(IUTXOTagRepository): rename GetTagByKeyAndOutpoint to GetByKeyAndOutpoint for consistency feat(IUTXOTagRepository): add GetByKeyValue method to query UTXOTags by key and value
Elenpay · Jun 28, 2024 · 1ff1f20 · 1ff1f20
1 parent eb8f9f7
commit 1ff1f20
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 3 deletions.
diff --git a/src/Data/Models/UTXOTag.cs b/src/Data/Models/UTXOTag.cs
@@ -7,5 +7,5 @@ public class UTXOTag : Entity
     public string Value { get; set; }
 
     // Outpoint of the UTXO in format "hash-index"
-    public string? Outpoint { get; set; }
+    public string Outpoint { get; set; }
 }
diff --git a/src/Data/Repositories/Interfaces/IUTXOTagRepository.cs b/src/Data/Repositories/Interfaces/IUTXOTagRepository.cs
@@ -6,7 +6,9 @@ public interface IUTXOTagRepository
 {
     Task<UTXOTag?> GetByOutpoint(string outpoint);
 
-    Task<UTXOTag?> GetTagByKeyAndOutpoint(string key, string outpoint);
+    Task<UTXOTag?> GetByKeyAndOutpoint(string key, string outpoint);
+
+    Task<List<UTXOTag>> GetByKeyValue(string key, string value);
 
     Task<(bool, string?)> AddAsync(UTXOTag type);
 

diff --git a/src/Data/Repositories/UTXOTagRepository.cs b/src/Data/Repositories/UTXOTagRepository.cs
@@ -26,13 +26,21 @@ public UTXOTagRepository(IRepository<UTXOTag> repository,
         return await applicationDbContext.UTXOTags.FirstOrDefaultAsync(x => x.Outpoint == outpoint);
     }
 
-    public async Task<UTXOTag?> GetTagByKeyAndOutpoint(string key, string outpoint)
+    public async Task<UTXOTag?> GetByKeyAndOutpoint(string key, string outpoint)
     {
         await using var applicationDbContext = await _dbContextFactory.CreateDbContextAsync();
 
         return await applicationDbContext.UTXOTags.FirstOrDefaultAsync(x => x.Key == key && x.Outpoint == outpoint);
     }
 
+    public Task<List<UTXOTag>> GetByKeyValue(string key, string value)
+    {
+        using var applicationDbContext = _dbContextFactory.CreateDbContext();
+
+        return applicationDbContext.UTXOTags
+            .Where(x => x.Key == key && x.Value == value).ToListAsync();
+    }
+
     public async Task<(bool, string?)> AddAsync(UTXOTag type)
     {
         await using var applicationDbContext = await _dbContextFactory.CreateDbContextAsync();