feat: load customer wallets automatically

Author: AliEmre007

backend/src/main/java/com/payledger/platform/shared/api/OpenApiController.java

@@ -29,9 +29,9 @@ public Map<String, Object> apiDocs() {
     private Map<String, Object> paths() {
         return Map.ofEntries(
                 Map.entry("/api/v1/wallets", Map.of(
-                        "post", operation(
-                                "Create wallet",
-                                "Create an authenticated customer's wallet."
+                        "get", operation(
+                                "List my wallets",
+                                "Returns wallets owned by the authenticated customer."
                         )
                 )),
                 Map.entry("/api/v1/wallets/{walletId}/balance", Map.of(

backend/src/main/java/com/payledger/platform/wallet/api/WalletController.java

@@ -1,5 +1,7 @@
 package com.payledger.platform.wallet.api;
 
+import com.payledger.platform.identity.application.AuthenticatedCustomer;
+import com.payledger.platform.identity.application.CurrentCustomerService;
 import com.payledger.platform.wallet.application.WalletService;
 import jakarta.validation.Valid;
 import org.springframework.http.HttpStatus;
@@ -11,16 +13,22 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
 import java.util.UUID;
 
 @RestController
 @RequestMapping("/api/v1")
 public class WalletController {
 
     private final WalletService walletService;
+    private final CurrentCustomerService currentCustomerService;
 
-    public WalletController(WalletService walletService) {
+    public WalletController(
+            WalletService walletService,
+            CurrentCustomerService currentCustomerService
+    ) {
         this.walletService = walletService;
+        this.currentCustomerService = currentCustomerService;
     }
 
     @PostMapping("/customers/{customerId}/wallets")
@@ -39,4 +47,16 @@ public ResponseEntity<WalletResponse> createWallet(
     public WalletResponse getWallet(@PathVariable UUID walletId) {
         return WalletResponse.from(walletService.getWallet(walletId));
     }
+
+    @GetMapping("/wallets")
+    public List<WalletResponse> listMyWallets() {
+        AuthenticatedCustomer currentCustomer =
+                currentCustomerService.getCurrentCustomer();
+
+        return walletService
+                .listWalletsForCustomer(currentCustomer.customerId())
+                .stream()
+                .map(WalletResponse::from)
+                .toList();
+    }
 }

backend/src/main/java/com/payledger/platform/wallet/application/WalletService.java

@@ -14,6 +14,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Currency;
+import java.util.List;
 import java.util.Locale;
 import java.util.Map;
 import java.util.UUID;
@@ -101,6 +102,11 @@ public Wallet getWallet(UUID walletId) {
                 );
     }
 
+    @Transactional(readOnly = true)
+    public List<Wallet> listWalletsForCustomer(UUID customerId) {
+        return walletRepository.findByCustomerIdOrderByCurrencyAsc(customerId);
+    }
+
     private String normalizeCurrency(String requestedCurrency) {
         String currency = requestedCurrency.trim().toUpperCase(Locale.ROOT);
 

backend/src/main/java/com/payledger/platform/wallet/infrastructure/WalletRepository.java

@@ -3,10 +3,13 @@
 import com.payledger.platform.wallet.domain.Wallet;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
 
 public interface WalletRepository extends JpaRepository<Wallet, UUID> {
 
     Optional<Wallet> findByCustomerIdAndCurrency(UUID customerId, String currency);
+
+    List<Wallet> findByCustomerIdOrderByCurrencyAsc(UUID customerId);
 }

backend/src/test/java/com/payledger/platform/wallet/api/WalletBalanceApiIntegrationTest.java

@@ -120,6 +120,37 @@ void returnsAvailableBalanceAfterActiveHolds() throws Exception {
                 .andExpect(jsonPath("$.availableBalanceMinor").value(10_000));
     }
 
+    @Test
+    void listsOnlyWalletsOwnedByLinkedCustomer() throws Exception {
+        WalletContext tryWallet = createWallet("list-owned-try", "TRY");
+        Wallet usdWallet = walletService.createWallet(
+                tryWallet.customer().getId(),
+                "USD"
+        );
+        createTryWallet("list-other");
+
+        String subject = "wallet-list-subject-" + UUID.randomUUID();
+        customerIdentityService.linkKeycloakIdentity(
+                tryWallet.customer().getId(),
+                subject
+        );
+
+        mockMvc.perform(
+                        get("/api/v1/wallets")
+                                .with(com.payledger.platform.shared.security.TestJwtSupport.customerJwt(subject))
+                )
+                .andExpect(status().isOk())
+                .andExpect(jsonPath("$.length()").value(2))
+                .andExpect(jsonPath("$[0].customerId")
+                        .value(tryWallet.customer().getId().toString()))
+                .andExpect(jsonPath("$[1].customerId")
+                        .value(tryWallet.customer().getId().toString()))
+                .andExpect(jsonPath("$[?(@.id == '%s')]",
+                        tryWallet.wallet().getId().toString()).exists())
+                .andExpect(jsonPath("$[?(@.id == '%s')]",
+                        usdWallet.getId().toString()).exists());
+    }
+
     @Test
     void returns403WhenLinkedCustomerReadsAnotherCustomersBalance()
             throws Exception {
@@ -155,7 +186,23 @@ void returns403WhenJwtSubjectIsNotLinked() throws Exception {
                 .andExpect(jsonPath("$.code").value("IDENTITY_NOT_LINKED"));
     }
 
+    @Test
+    void listWalletsReturns403WhenJwtSubjectIsNotLinked() throws Exception {
+        mockMvc.perform(
+                        get("/api/v1/wallets")
+                                .with(com.payledger.platform.shared.security.TestJwtSupport.customerJwt(
+                                        "unlinked-wallet-list-subject-" + UUID.randomUUID()
+                                ))
+                )
+                .andExpect(status().isForbidden())
+                .andExpect(jsonPath("$.code").value("IDENTITY_NOT_LINKED"));
+    }
+
     private WalletContext createTryWallet(String label) {
+        return createWallet(label, "TRY");
+    }
+
+    private WalletContext createWallet(String label, String currency) {
         String suffix = UUID.randomUUID()
                 .toString()
                 .replace("-", "")
@@ -168,7 +215,7 @@ private WalletContext createTryWallet(String label) {
                 label + "-" + suffix + "@example.test"
         );
 
-        Wallet wallet = walletService.createWallet(customer.getId(), "TRY");
+        Wallet wallet = walletService.createWallet(customer.getId(), currency);
 
         LedgerAccount ledgerAccount = ledgerAccountRepository
                 .findByWalletId(wallet.getId())

frontend/src/api.ts

@@ -14,6 +14,7 @@ import type {
   SettlementBatch,
   TransferRequest,
   TransferResponse,
+  Wallet,
   WalletBalance,
   WalletStatement
 } from "./types";
@@ -23,6 +24,10 @@ type TokenProvider = () => Promise<string | null>;
 export class ApiClient {
   constructor(private readonly tokenProvider: TokenProvider) {}
 
+  myWallets(): Promise<Wallet[]> {
+    return this.request("/api/v1/wallets");
+  }
+
   walletBalance(walletId: string): Promise<WalletBalance> {
     return this.request(`/api/v1/wallets/${walletId}/balance`);
   }