Merge pull request #8 from Star-Academy/feature/get-all-transactions

Feature/get all transactions

src/Application/DTOs/TransactionCsv/GetAllTransactionsResponse.cs

@@ -0,0 +1,17 @@
+namespace Web.DTOs.Transaction;
+
+public class GetAllTransactionsResponse
+{
+    public List<TransactionDto> Transactions { get; set; } = new();
+
+    public class TransactionDto
+    {
+        public long TransactionId { get; set; }
+        public long SourceAccountId { get; set; }
+        public long DestinationAccountId { get; set; }
+        public decimal Amount { get; set; }
+        public DateTime Date { get; set; }
+        public string Type { get; set; } = string.Empty;
+    }
+
+}

src/Application/Interfaces/ITransactionRepository.cs

@@ -5,4 +5,5 @@ namespace Application.Interfaces;
 public interface ITransactionRepository
 {
     Task CreateBulkAsync(List<Transaction> transactions);
+    Task<List<Transaction>> GetAllTransactions();
 }

src/Application/Interfaces/Services/ITransactionService.cs

@@ -1,8 +1,10 @@
 using Application.DTOs;
+using Web.DTOs.Transaction;
 
 namespace Application.Interfaces.Services;
 
 public interface ITransactionService
 {
     Task AddTransactionsFromCsvAsync(string filePath);
+    Task<Result<GetAllTransactionsResponse>> GetAllTransactions();
 }

src/Application/Mappers/TransactionMapper.cs

@@ -0,0 +1,24 @@
+using Web.DTOs.Transaction;
+using Domain.Entities;
+
+namespace Application.Mappers
+{
+    public static class TransactionMapper
+    {
+        public static GetAllTransactionsResponse ToGetAllTransactionsResponse(this List<Transaction> transactions)
+        {
+            return new GetAllTransactionsResponse
+            {
+                Transactions = transactions.Select(transaction => new GetAllTransactionsResponse.TransactionDto
+                {
+                    TransactionId = transaction.TransactionId,
+                    SourceAccountId = transaction.SourceAccountId,
+                    DestinationAccountId = transaction.DestinationAccountId,
+                    Amount = transaction.Amount,
+                    Date = transaction.Date,
+                    Type = transaction.Type
+                }).ToList()
+            };
+        }
+    }
+}

src/Application/Services/TransactionService.cs

@@ -2,14 +2,16 @@
 using Application.DTOs.TransactionCsv;
 using Application.Interfaces;
 using Application.Interfaces.Services;
+using Application.Mappers;
 using Application.Services.SharedService;
 using Domain.Entities;
+using Web.DTOs.Transaction;
 
 namespace Application.Services;
 
 public class TransactionService : ITransactionService
 {
-    public readonly ITransactionRepository _transactionRepository;
+    private readonly ITransactionRepository _transactionRepository;
 
     public TransactionService(ITransactionRepository transactionRepository)
     {
@@ -32,4 +34,23 @@ public async Task AddTransactionsFromCsvAsync(string filePath)
 
         await _transactionRepository.CreateBulkAsync(transactions);
     }
+
+    public async Task<Result<GetAllTransactionsResponse>> GetAllTransactions()
+    {
+        try
+        {
+            var transactions = await _transactionRepository.GetAllTransactions();
+
+            if (transactions.Count == 0)
+            {
+                return Result<GetAllTransactionsResponse>.Fail("No transactions found");
+            }
+            var response = transactions.ToGetAllTransactionsResponse();
+            return Result<GetAllTransactionsResponse>.Ok(response);
+        }
+        catch (Exception ex)
+        {
+            return Result<GetAllTransactionsResponse>.Fail($"An error occurred: {ex.Message}");
+        }
+    }
 }

src/Infrastructure/Services/TransactionRepository.cs

@@ -1,6 +1,7 @@
 using Application.Interfaces;
 using Domain.Entities;
 using Infrastructure.Data;
+using Microsoft.EntityFrameworkCore;
 
 namespace Infrastructure.Services;
 
@@ -17,4 +18,9 @@ public async Task CreateBulkAsync(List<Transaction> transactions)
         await _dbContext.Transactions.AddRangeAsync(transactions);
         await _dbContext.SaveChangesAsync();
     }
+
+    public async Task<List<Transaction>> GetAllTransactions()
+    {
+        return await _dbContext.Transactions.ToListAsync();
+    }
 }

src/Web/Controllers/TransactionController.cs

@@ -1,6 +1,8 @@
 using Application.Interfaces.Services;
-using Infrastructure.Data;
+using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
+using Web.Helper;
+using Web.Mappers;
 
 namespace Web.Controllers;
 
@@ -32,4 +34,18 @@ public async Task<IActionResult> ImportTransactions([FromForm] IFormFile file)
 
         return Ok("Transactions imported successfully.");
     }
+
+    [HttpGet]
+    [Authorize]
+    public async Task<IActionResult> GetAllTransactions()
+    {
+        var allTransactions = await _transactionService.GetAllTransactions();
+        if (!allTransactions.Succeed)
+        {
+            return BadRequest(Errors.New(nameof(GetAllTransactions), allTransactions.Message));
+        }
+
+        var response = allTransactions.Value!;
+        return Ok(response.ToGotAllTransactionsDto());
+    }
 }

src/Web/DTOs/Transaction/GotAllTransactionsDto.cs

@@ -0,0 +1,13 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace Web.DTOs.Transaction;
+
+public class GotAllTransactionsDto
+{
+    public long TransactionId { get; set; }
+    public long SourceAccountId { get; set; }
+    public long DestinationAccountId { get; set; }
+    public decimal Amount { get; set; }
+    public DateTime Date { get; set; }
+    public string Type { get; set; } = string.Empty;
+}

src/Web/Mappers/TransactionMapper.cs

@@ -1,4 +1,4 @@
-using Domain.Entities;
+using Domain.Entities;
 using Web.DTOs.Transaction;
 
 namespace Web.Mappers;
@@ -17,4 +17,17 @@ public static TransactionDto ToTransactionDto(this Transaction transaction)
             Type = transaction.Type
         };
     }
+
+    public static List<GetAllTransactionsResponse.TransactionDto> ToGotAllTransactionsDto(this GetAllTransactionsResponse response)
+        {
+            return response.Transactions.Select(transaction => new GetAllTransactionsResponse.TransactionDto
+            {
+                TransactionId = transaction.TransactionId,
+                SourceAccountId = transaction.SourceAccountId,
+                DestinationAccountId = transaction.DestinationAccountId,
+                Amount = transaction.Amount,
+                Date = transaction.Date,
+                Type = transaction.Type
+            }).ToList();
+        }
 }