Added AccountLookupController

bank-acct/acct.commons/src/main/java/co/marcuss/acct/commons/dto/BaseResponse.java

@@ -4,10 +4,55 @@
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.text.MessageFormat;
+
 @Data
 @NoArgsConstructor
 @AllArgsConstructor
 public class BaseResponse {
 
     private String message;
+
+    protected BaseResponse(BaseResponseBuilder<?, ?> b) {
+        this.message = b.message;
+    }
+
+    public static BaseResponseBuilder<?, ?> builder() {
+        return new BaseResponseBuilderImpl();
+    }
+
+    public static abstract class BaseResponseBuilder<C extends BaseResponse, B extends BaseResponseBuilder<C, B>> {
+        private String message;
+
+        public B message(String message) {
+            this.message = message;
+            return self();
+        }
+
+        public B message(String pattern, Object ... arguments) {
+            this.message = MessageFormat.format(pattern, arguments);
+            return self();
+        }
+
+        protected abstract B self();
+
+        public abstract C build();
+
+        public String toString() {
+            return "BaseResponse.BaseResponseBuilder(message=" + this.message + ")";
+        }
+    }
+
+    private static final class BaseResponseBuilderImpl extends BaseResponseBuilder<BaseResponse, BaseResponseBuilderImpl> {
+        private BaseResponseBuilderImpl() {
+        }
+
+        protected BaseResponseBuilderImpl self() {
+            return this;
+        }
+
+        public BaseResponse build() {
+            return new BaseResponse(this);
+        }
+    }
 }

bank-acct/acct.query/src/main/java/co/marcuss/acct/query/api/controller/AccountLookupController.java

@@ -0,0 +1,114 @@
+package co.marcuss.acct.query.api.controller;
+
+import co.marcuss.acct.query.api.dto.AccountLookupResponse;
+import co.marcuss.acct.query.api.dto.EqualityType;
+import co.marcuss.acct.query.api.queries.FindAccountByHolderQuery;
+import co.marcuss.acct.query.api.queries.FindAccountByIdQuery;
+import co.marcuss.acct.query.api.queries.FindAccountWithBalanceQuery;
+import co.marcuss.acct.query.api.queries.FindAllAccountsQuery;
+import co.marcuss.acct.query.domain.BankAccount;
+import co.marcuss.cqrs.core.infrastructure.QueryDispatcher;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping(path = "api/v1/bank-account")
+public class AccountLookupController {
+
+
+    private final QueryDispatcher queryDispatcher;
+
+    @Autowired
+    public AccountLookupController(QueryDispatcher queryDispatcher) {
+        this.queryDispatcher = queryDispatcher;
+    }
+
+    @GetMapping
+    public ResponseEntity<AccountLookupResponse> getAllAccounts() {
+        FindAllAccountsQuery query = new FindAllAccountsQuery();
+        try {
+            List<BankAccount> bankAccounts = queryDispatcher.sendQuery(query);
+            return buildSuccessfulResponse(bankAccounts);
+        }
+        catch (IllegalStateException e) {
+            return buildClientErrorResponse(e);
+        }
+        catch (Exception e) {
+            return buildServerErrorResponse(e);
+        }
+    }
+
+    @GetMapping(path = "/id/{id}")
+    public ResponseEntity<AccountLookupResponse> getAccountsById(@PathVariable String id) {
+        FindAccountByIdQuery query = new FindAccountByIdQuery(id);
+        try {
+            List<BankAccount> bankAccounts = queryDispatcher.sendQuery(query);
+            return buildSuccessfulResponse(bankAccounts);
+        }
+        catch (IllegalStateException e) {
+            return buildClientErrorResponse(e);
+        }
+        catch (Exception e) {
+            return buildServerErrorResponse(e);
+        }
+    }
+
+    @GetMapping(path = "/holder/{holder}")
+    public ResponseEntity<AccountLookupResponse> getAccountsByHolder(@PathVariable String holder) {
+        FindAccountByHolderQuery query = new FindAccountByHolderQuery(holder);
+        try {
+            List<BankAccount> bankAccounts = queryDispatcher.sendQuery(query);
+            return buildSuccessfulResponse(bankAccounts);
+        }
+        catch (IllegalStateException e) {
+            return buildClientErrorResponse(e);
+        }
+        catch (Exception e) {
+            return buildServerErrorResponse(e);
+        }
+    }
+
+    @GetMapping(path = "/withBalance/{equalityType}/{balance}")
+    public ResponseEntity<AccountLookupResponse> getAccountWithBalance(@PathVariable(value = "equalityType") EqualityType equalityType, @PathVariable(value = "balance") BigDecimal balance) {
+        FindAccountWithBalanceQuery query = new FindAccountWithBalanceQuery(equalityType, balance);
+        try {
+            List<BankAccount> bankAccounts = queryDispatcher.sendQuery(query);
+            return buildSuccessfulResponse(bankAccounts);
+        }
+        catch (IllegalStateException e) {
+            return buildClientErrorResponse(e);
+        }
+        catch (Exception e) {
+            return buildServerErrorResponse(e);
+        }
+    }
+
+
+    private ResponseEntity<AccountLookupResponse> buildSuccessfulResponse(List<BankAccount> bankAccounts) {
+        if (bankAccounts.isEmpty()) {
+            return new ResponseEntity<>(new AccountLookupResponse("No accounts found"), HttpStatus.NO_CONTENT);
+        }
+        return new ResponseEntity<>(AccountLookupResponse.builder().accounts(bankAccounts).message("Successfully returned {0} accounts.", bankAccounts.size()).build(), HttpStatus.OK);
+    }
+
+    private ResponseEntity<AccountLookupResponse> buildClientErrorResponse(IllegalStateException e) {
+        log.warn("Bad Request Caused By: {}", e.getMessage());
+        return new ResponseEntity<>(AccountLookupResponse.builder().message("Bad Request Caused By: {}", e.getMessage()).build(), HttpStatus.BAD_REQUEST);
+    }
+
+    private ResponseEntity<AccountLookupResponse> buildServerErrorResponse(Exception e) {
+        log.error("Error in account lookup request.", e);
+        log.info("Error in account lookup account request.");
+        return new ResponseEntity<>(new AccountLookupResponse("Server failed to fulfill the request."), HttpStatus.INTERNAL_SERVER_ERROR);
+    }
+}

bank-acct/acct.query/src/main/java/co/marcuss/acct/query/api/dto/AccountLookupResponse.java

@@ -0,0 +1,23 @@
+package co.marcuss.acct.query.api.dto;
+
+import co.marcuss.acct.commons.dto.BaseResponse;
+import co.marcuss.acct.query.domain.BankAccount;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+import java.util.List;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@AllArgsConstructor
+public class AccountLookupResponse extends BaseResponse {
+
+    private List<BankAccount> accounts;
+
+    public AccountLookupResponse(String message) {
+        super(message);
+    }
+}