add-customer and introducing JpaAttempt test helper

src/main/java/net/hostsharing/hsadminng/errors/RestResponseEntityExceptionHandler.java

@@ -0,0 +1,57 @@
+package net.hostsharing.hsadminng.errors;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Getter;
+import org.springframework.core.NestedExceptionUtils;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.orm.jpa.JpaSystemException;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.context.request.WebRequest;
+import org.springframework.web.servlet.mvc.method.annotation.ResponseEntityExceptionHandler;
+
+import java.time.LocalDateTime;
+
+@ControllerAdvice
+public class RestResponseEntityExceptionHandler
+    extends ResponseEntityExceptionHandler {
+
+    @ExceptionHandler(DataIntegrityViolationException.class)
+    protected ResponseEntity<CustomErrorResponse> handleConflict(
+        final RuntimeException exc, final WebRequest request) {
+
+        return new ResponseEntity<>(
+            new CustomErrorResponse(exc, HttpStatus.CONFLICT), HttpStatus.CONFLICT);
+    }
+
+    @ExceptionHandler(JpaSystemException.class)
+    protected ResponseEntity<CustomErrorResponse> handleJpaExceptions(
+        final RuntimeException exc, final WebRequest request) {
+
+        return new ResponseEntity<>(
+            new CustomErrorResponse(exc, HttpStatus.FORBIDDEN), HttpStatus.FORBIDDEN);
+    }
+}
+
+@Getter
+class CustomErrorResponse {
+
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd hh:mm:ss")
+    private final LocalDateTime timestamp;
+
+    private final HttpStatus status;
+
+    private final String message;
+
+    public CustomErrorResponse(final RuntimeException exc, final HttpStatus status) {
+        this.timestamp = LocalDateTime.now();
+        this.status = status;
+        this.message = firstLine(NestedExceptionUtils.getMostSpecificCause(exc).getMessage());
+    }
+
+    private String firstLine(final String message) {
+        return message.split("\\r|\\n|\\r\\n", 0)[0];
+    }
+}

src/main/java/net/hostsharing/hsadminng/hscustomer/CustomerController.java

@@ -2,16 +2,14 @@ package net.hostsharing.hsadminng.hscustomer;
 
 import net.hostsharing.hsadminng.context.Context;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestHeader;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.*;
 
 import javax.transaction.Transactional;
 import java.util.List;
+import java.util.UUID;
+
+@RestController
 
-@Controller
 public class CustomerController {
 
     @Autowired
@@ -20,18 +18,35 @@ public class CustomerController {
     @Autowired
     private CustomerRepository customerRepository;
 
-    @ResponseBody
-    @RequestMapping(value = "/api/customers", method = RequestMethod.GET)
+    @GetMapping(value = "/api/customers")
     @Transactional
     public List<CustomerEntity> listCustomers(
-            @RequestHeader(value = "current-user") String userName,
-            @RequestHeader(value="assumed-roles", required=false) String assumedRoles
+        @RequestHeader(value = "current-user") String userName,
+        @RequestHeader(value = "assumed-roles", required = false) String assumedRoles
     ) {
         context.setCurrentUser(userName);
-        if ( assumedRoles != null && !assumedRoles.isBlank() ) {
+        if (assumedRoles != null && !assumedRoles.isBlank()) {
             context.assumeRoles(assumedRoles);
         }
         return customerRepository.findAll();
     }
 
+    @PostMapping(value = "/api/customers")
+    @ResponseStatus
+    @Transactional
+    public CustomerEntity addCustomer(
+        @RequestHeader(value = "current-user") String userName,
+        @RequestHeader(value = "assumed-roles", required = false) String assumedRoles,
+        @RequestBody CustomerEntity customer
+    ) {
+        context.setCurrentUser(userName);
+        if (assumedRoles != null && !assumedRoles.isBlank()) {
+            context.assumeRoles(assumedRoles);
+        }
+        if (customer.getUuid() == null) {
+            customer.setUuid(UUID.randomUUID());
+        }
+        return customerRepository.save(customer);
+    }
+
 }

src/main/java/net/hostsharing/hsadminng/hscustomer/CustomerEntity.java

@@ -3,6 +3,7 @@ package net.hostsharing.hsadminng.hscustomer;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
+import lombok.Setter;
 
 import javax.persistence.*;
 import java.util.UUID;
@@ -10,6 +11,7 @@ import java.util.UUID;
 @Entity
 @Table(name = "customer_rv")
 @Getter
+@Setter
 @NoArgsConstructor
 @AllArgsConstructor
 public class CustomerEntity {

src/main/resources/db/changelog/2022-07-29-061-hs-customer-rbac.sql

@@ -210,7 +210,7 @@ create or replace function addCustomerNotAllowedForCurrentSubjects()
     language PLPGSQL
 as $$
 begin
-    raise exception 'add-customer not permitted for %', array_to_string(currentSubjects());
+    raise exception 'add-customer not permitted for %', array_to_string(currentSubjects(), ';', 'null');
 end; $$;
 
 /**