import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
import org.springframework.http.ResponseEntity;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import java.time.LocalDateTime;
+import static de.juplo.boot.data.jdbc.UserEvent.Type.CREATED;
+import static de.juplo.boot.data.jdbc.UserEvent.Type.DELETED;
+
@RestController
@Transactional
@RequestMapping("/users")
private final UserRepository repository;
+ private final ApplicationEventPublisher publisher;
- public UserController(UserRepository repository) {
+ public UserController(
+ UserRepository repository,
+ ApplicationEventPublisher publisher)
+ {
this.repository = repository;
+ this.publisher = publisher;
}
String sanitizedUsername = UserController.sanitize(username);
User user = new User(sanitizedUsername, LocalDateTime.now(), false);
repository.save(user);
+ publisher.publishEvent(new UserEvent(this, CREATED, sanitizedUsername));
UriComponents uri =
builder
.fromCurrentRequest()
return ResponseEntity.notFound().build();
repository.delete(user);
+ publisher.publishEvent(new UserEvent(this, DELETED, username));
return ResponseEntity.ok(user);
}