feat(*): step 6

Author: aoudiamoncef

README.md

@@ -63,7 +63,7 @@ Steps:
 - Add a configuration property inside you `application.properties` file: `greeting=World` 
 - Modify `BookmarkResource` to read this configuration property and log it at startup:
   - Use `@ConfigProperty` to inject the property inside a `greeting` variable.
-  - Create a `@PostConstruct` method that log it via `log.info("Hello {}", greeting)` using [SLFJ](https://www.slf4j.org/).
+  - Create a `@PostConstruct` method that log it via `LOGGER.infof("Hello %s", greeting)` using [Jboss logging](https://docs.jboss.org/jbosslogging/latest/org/jboss/logging/Logger.html).
 - Test using `mvn quarkus:dev` you should see `Hello World` in the console.
 - Add a new line to `application.properties` file: `%dev.greeting=Dev` this is an override of the same property for the dev profile.
 - Test using `mvn quarkus:dev` you should see `Hello Dev` in the console.

bookmark-message-consumer/pom.xml

@@ -9,7 +9,7 @@
     <surefire-plugin.version>2.22.0</surefire-plugin.version>
     <maven.compiler.target>1.8</maven.compiler.target>
     <maven.compiler.source>1.8</maven.compiler.source>
-    <quarkus.version>0.22.0</quarkus.version>
+    <quarkus.version>1.0.1.Final</quarkus.version>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
   </properties>

bookmark-message-consumer/src/main/java/fr/loicmathieu/bookmarkit/BookmarkConsumer.java

@@ -1,18 +1,17 @@
 package fr.loicmathieu.bookmarkit;
 
 import org.eclipse.microprofile.reactive.messaging.Incoming;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.jboss.logging.Logger;
 
 import javax.enterprise.context.ApplicationScoped;
 
 @ApplicationScoped
 public class BookmarkConsumer {
 
-    private final Logger log = LoggerFactory.getLogger(BookmarkConsumer.class);
+    private static final Logger LOG = Logger.getLogger(BookmarkConsumer.class);
 
     @Incoming("bookmarks")
     public void process(String bookmark) {
-        log.info("Indexing a bookmark: {}", bookmark);
+        LOG.infof("Indexing a bookmark: %s", bookmark);
     }
 }

bookmark-message-consumer/src/test/java/fr/loicmathieu/bookmarkit/NativeBookmarkConsumerIT.java

@@ -9,7 +9,7 @@
     <surefire-plugin.version>2.22.0</surefire-plugin.version>
     <maven.compiler.target>1.8</maven.compiler.target>
     <maven.compiler.source>1.8</maven.compiler.source>
-    <quarkus.version>0.26.1</quarkus.version>
+    <quarkus.version>1.0.1.Final</quarkus.version>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
   </properties>
@@ -42,10 +42,13 @@
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-smallrye-health</artifactId>
     </dependency>
+    <!-- Step 5 dependencies -->
     <dependency>
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-jdbc-postgresql</artifactId>
     </dependency>
+    <!--/ Step 5 dependencies -->
+    <!-- Step 6 dependencies -->
     <dependency>
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-smallrye-metrics</artifactId>
@@ -79,6 +82,7 @@
       <artifactId>rest-assured</artifactId>
       <scope>test</scope>
     </dependency>
+    <!-- test dependencies-->
   </dependencies>
   <build>
     <plugins>

bookmark-message-consumer/target/classes/application.properties

@@ -0,0 +1,14 @@
+package fr.loicmathieu.bookmarkit;
+
+import org.eclipse.microprofile.health.HealthCheck;
+import org.eclipse.microprofile.health.HealthCheckResponse;
+import org.eclipse.microprofile.health.Readiness;
+
+@Readiness
+public class AppHealthCheck implements HealthCheck {
+
+    @Override
+    public HealthCheckResponse call() {
+        return HealthCheckResponse.builder().name("bookmark").withData("is", "always").up().build();
+    }
+}

bookmark-message-consumer/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

@@ -1,16 +1,19 @@
 package fr.loicmathieu.bookmarkit;
 
+import io.smallrye.reactive.messaging.annotations.Channel;
 import io.smallrye.reactive.messaging.annotations.Emitter;
-import io.smallrye.reactive.messaging.annotations.Stream;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.eclipse.microprofile.faulttolerance.Retry;
 import org.eclipse.microprofile.metrics.annotation.Counted;
 import org.eclipse.microprofile.metrics.annotation.Timed;
 import org.eclipse.microprofile.openapi.annotations.Operation;
-import org.eclipse.microprofile.reactive.messaging.Outgoing;
+import org.eclipse.microprofile.rest.client.inject.RestClient;
+import org.jboss.logging.Logger;
 
 import javax.annotation.PostConstruct;
-import javax.inject.Inject;
+import javax.annotation.PreDestroy;
 import javax.transaction.Transactional;
+import javax.validation.Valid;
 import javax.ws.rs.Consumes;
 import javax.ws.rs.DELETE;
 import javax.ws.rs.GET;
@@ -19,37 +22,47 @@
 import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
+import javax.ws.rs.core.Context;
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
+import javax.ws.rs.core.UriInfo;
 import java.net.URI;
 import java.util.List;
 
 @Path("/bookmarks")
 @Produces(MediaType.APPLICATION_JSON)
 @Consumes(MediaType.APPLICATION_JSON)
 public class BookmarkResource {
-    @ConfigProperty(name="greeting") String greeting;
 
-    @Inject @Stream("bookmarks") Emitter<Bookmark> emitter;
+    private static final Logger LOG = Logger.getLogger(BookmarkResource.class);
+
+    @ConfigProperty(name = "greeting")
+    private String greeting;
+
+    @Channel("bookmarks")
+    private Emitter<Bookmark> emitter;
+
+    @RestClient
+    GeoIpService geoIpService;
 
     @PostConstruct
-    void init(){
-        System.out.println("Hello " + greeting);
+    void init() {
+        LOG.infof("Hello %s", greeting);
     }
 
     @GET
     @Operation(summary = "List all bookmarks")
     @Counted(name = "listAll.count")
-    @Timed(name="listAll.time")
-    public List<Bookmark> listAll(){
+    @Timed(name = "listAll.time")
+    public List<Bookmark> listAll() {
         return Bookmark.listAll();
     }
 
     @GET
-    @Path("/{id}")
+    @Path("{id}")
     @Operation(summary = "Get a bookmark")
     @Counted(name = "get.count")
-    @Timed(name="get.time")
+    @Timed(name = "get.time")
     public Bookmark get(@PathParam("id") Long id) {
         return Bookmark.findById(id);
     }
@@ -58,34 +71,44 @@ public Bookmark get(@PathParam("id") Long id) {
     @Transactional
     @Operation(summary = "Create a bookmark")
     @Counted(name = "create.count")
-    @Timed(name="create.time")
-    public Response create(Bookmark bookmark){
-        bookmark.persist();
-        emitter.send(bookmark);
-        return Response.created(URI.create("/bookmarks/" + bookmark.id)).build();
+    @Timed(name = "create.time")
+    @Retry(maxRetries = 2)
+    public Response create(@Valid Bookmark bookmark) {
+        GeoIp geoIp = geoIpService.getIpInfos();
+        if (geoIp != null) {
+            bookmark.location = geoIp.city;
+            bookmark.persist();
+            this.emitter.send(bookmark);
+            return Response.status(Response.Status.CREATED).entity(bookmark).build();
+        } else {
+            return Response.status(Response.Status.INTERNAL_SERVER_ERROR).build();
+        }
     }
 
     @PUT
-    @Path("/{id}")
+    @Path("{id}")
     @Transactional
     @Operation(summary = "Update a bookmark")
     @Counted(name = "update.count")
-    @Timed(name="update.time")
-    public void update(Bookmark bookmark){
-        Bookmark existing = Bookmark.findById(bookmark.id);
-        existing.url = bookmark.url;
-        existing.description = bookmark.description;
-        existing.title = bookmark.title;
+    @Timed(name = "update.time")
+    public Response update(@Valid Bookmark bookmark, @PathParam("id") Long id, @Context UriInfo uriInfo) {
+        Bookmark entity = Bookmark.findById(id);
+        entity.description = bookmark.description;
+        entity.location = bookmark.location;
+        entity.title = bookmark.title;
+        entity.url = bookmark.url;
+        return Response.created(URI.create(uriInfo.getPath())).build();
     }
 
     @DELETE
-    @Path("/{id}")
+    @Path("{id}")
     @Transactional
     @Operation(summary = "Delete a bookmark")
     @Counted(name = "delete.count")
-    @Timed(name="delete.time")
-    public void delete(@PathParam("id")Long id){
-        Bookmark existing = Bookmark.findById(id);
-        existing.delete();
+    @Timed(name = "delete.time")
+    public Response delete(@PathParam("id") Long id) {
+        Bookmark bookmark = Bookmark.findById(id);
+        bookmark.delete();
+        return Response.noContent().build();
     }
 }

bookmark-service/pom.xml

@@ -0,0 +1,18 @@
+package fr.loicmathieu.bookmarkit;
+
+public class GeoIp {
+    public String query;
+    public String status;
+    public String country;
+    public String countryCode;
+    public String region;
+    public String regionName;
+    public String city;
+    public String zip;
+    public Double lat;
+    public Double lon;
+    public String timezone;
+    public String isp;
+    public String org;
+    public String as;
+}