feat: micronaut products example

Author: keskiju

alternatives/server-micronaut-java/src/main/java/content/UserListener.java renamed to alternatives/server-micronaut-java/src/main/java/content/ProductListener.java

@@ -8,15 +8,15 @@
 import io.micronaut.configuration.kafka.annotation.Topic;
 
 @KafkaListener(offsetReset = OffsetReset.EARLIEST)
-public class UserListener {
+public class ProductListener {
 
   @Inject
   PostService postService;
 
-  @Topic("users")
-  public void receive(@KafkaKey String id, String username) {
-    postService.create(new Post(null, "User " + username + " was added!",
-        "Let's make him/her feel welcome", "System"));
+  @Topic("products")
+  public void receive(@KafkaKey String operation, String filter) {
+    postService.create(new Post(null, "Products fetch",
+        "Someone is interested of our products. Go and sell!", "System"));
   }
 
 }

alternatives/server-micronaut-java/src/main/java/management/User.java

@@ -0,0 +1,19 @@
+package products;
+
+public class Product {
+  public String id;
+  public String name;
+
+  public Product() {
+  }
+
+  public Product(String id, String name) {
+    this.id = id;
+    this.name = name;
+  }
+
+  public Product(Product product) {
+    this.id = product.id;
+    this.name = product.name;
+  }
+}

alternatives/server-micronaut-java/src/main/java/management/UserController.java

@@ -0,0 +1,29 @@
+package products;
+
+import io.micronaut.http.annotation.Controller;
+import io.micronaut.http.annotation.Get;
+
+import java.util.List;
+
+import javax.inject.Inject;
+
+import common.Envelope;
+
+@Controller("/products")
+public class ProductController {
+
+  public static class ProductsEnvelope extends Envelope<List<Product>> {
+    public ProductsEnvelope(List<Product> products) {
+      super(products);
+    }
+  }
+
+  @Inject
+  ProductService productService;
+
+  @Get("/")
+  public ProductsEnvelope fetch() {
+    return new ProductsEnvelope(productService.fetch());
+  }
+
+}

alternatives/server-micronaut-java/src/main/java/management/UserDAO.java

@@ -0,0 +1,20 @@
+package products;
+
+import java.util.Arrays;
+import java.util.List;
+
+import javax.inject.Singleton;
+
+/**
+ * Fake ProductDAO that does nothing
+ */
+@Singleton
+public class ProductDAO {
+
+  public List<Product> fetch() {
+    return Arrays.asList(
+        new Product("fj35-f3k4", "product1"),
+        new Product("gj33-f3k4", "product2"));
+  }
+
+}

alternatives/server-micronaut-java/src/main/java/management/UserService.java

@@ -1,13 +1,13 @@
-package management;
+package products;
 
 import io.micronaut.configuration.kafka.annotation.KafkaClient;
 import io.micronaut.configuration.kafka.annotation.KafkaKey;
 import io.micronaut.configuration.kafka.annotation.Topic;
 
 @KafkaClient
-public interface UserProducer {
+public interface ProductProducer {
 
-  @Topic("users")
-  void send(@KafkaKey String id, String username);
+  @Topic("products")
+  void send(@KafkaKey String id, String name);
 
 }

alternatives/server-micronaut-java/src/main/java/products/Product.java

@@ -0,0 +1,22 @@
+package products;
+
+import java.util.List;
+
+import javax.inject.Inject;
+import javax.inject.Singleton;
+
+@Singleton
+public class ProductService {
+
+  @Inject
+  ProductDAO productDAO;
+
+  @Inject
+  ProductProducer productProducer;
+
+  public List<Product> fetch() {
+    productProducer.send("fetch", "all");
+    return productDAO.fetch();
+  }
+
+}