animal rest api added

README.md

@@ -2,4 +2,5 @@
 learning exercise repository.
 
 ## Spring boot
+differnce between reactive stack and servlet stack
 ![img.png](img.png)

pom.xml

@@ -21,7 +21,16 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-webflux</artifactId>
 		</dependency>
-
+<!--		No need extra configuration class, Spring Boot will enable reactive support for MongoDB in this project.
+			ReactiveMongoTemplate and ReactiveMongoRepository will be configured automatically.-->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

src/main/java/com/lokesh/webfluxdemo/config/MongoConfig.java

+package com.lokesh.webfluxdemo.config;
+
+import com.mongodb.reactivestreams.client.MongoClient;
+import com.mongodb.reactivestreams.client.MongoClients;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration;
+import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories;
+
+@EnableReactiveMongoRepositories(basePackageClasses = {MongoConfig.class})
+public class MongoConfig extends AbstractReactiveMongoConfiguration {
+
+    @Value("${mongo.uri}")
+    String mongoUri;
+    @Bean
+    public MongoClient mongoClient() {
+        return MongoClients.create();
+    }
+    @Override
+    protected String getDatabaseName() {
+        return "animal";
+    }
+}

src/main/java/com/lokesh/webfluxdemo/controller/AnimalController.java

+package com.lokesh.webfluxdemo.controller;
+
+import com.lokesh.webfluxdemo.model.Animal;
+import com.lokesh.webfluxdemo.repository.AnimalRepository;
+import com.lokesh.webfluxdemo.resource.AnimalResource;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+
+import java.time.Duration;
+
+@RestController
+@RequestMapping("/api/v1/animal")
+public class AnimalController {
+    @Autowired
+    private AnimalRepository animalRepository;
+
+    @GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
+    public Flux<AnimalResource> findAll() {
+        return animalRepository.findAll()
+                .map(AnimalResource::new)
+                .delayElements(Duration.ofSeconds(1L));
+    }
+}

src/main/java/com/lokesh/webfluxdemo/controller/EmployeeController.java

@@ -12,19 +12,19 @@ import reactor.core.publisher.Mono;
 @RestController
 @RequestMapping("/employees")
 public class EmployeeController {
-    private final EmployeeRepository employeeRepository;
-
-    public EmployeeController(EmployeeRepository employeeRepository) {
-        this.employeeRepository = employeeRepository;
-    }
-
-    @GetMapping("/{id}")
-    private Mono<Employee> getEmployeeById(@PathVariable String id) {
-        return employeeRepository.findEmployeeById(id);
-    }
-
-    @GetMapping
-    private Flux<Employee> getAllEmployees() {
-        return employeeRepository.findAllEmployees();
-    }
+//    private final EmployeeRepository employeeRepository;
+//
+//    public EmployeeController(EmployeeRepository employeeRepository) {
+//        this.employeeRepository = employeeRepository;
+//    }
+//
+//    @GetMapping("/{id}")
+//    private Mono<Employee> getEmployeeById(@PathVariable String id) {
+//        return employeeRepository.findEmployeeById(id);
+//    }
+//
+//    @GetMapping
+//    private Flux<Employee> getAllEmployees() {
+//        return employeeRepository.findAllEmployees();
+//    }
 }

src/main/java/com/lokesh/webfluxdemo/ExampleHandler.java → src/main/java/com/lokesh/webfluxdemo/functionalapi/ExampleHandler.java

-package com.lokesh.webfluxdemo;
+package com.lokesh.webfluxdemo.functionalapi;
 
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Component;

src/main/java/com/lokesh/webfluxdemo/ExampleRouter.java → src/main/java/com/lokesh/webfluxdemo/functionalapi/ExampleRouter.java

-package com.lokesh.webfluxdemo;
+package com.lokesh.webfluxdemo.functionalapi;
 
+import com.lokesh.webfluxdemo.functionalapi.ExampleHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.http.MediaType;

src/main/java/com/lokesh/webfluxdemo/model/Animal.java

+package com.lokesh.webfluxdemo.model;
+
+import lombok.*;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+@Data
+@Builder
+@Document
+@ToString
+@NoArgsConstructor
+@AllArgsConstructor
+public class Animal {
+    @Id
+    private String id;
+
+    private String name;
+
+    private String kingdom;
+}

src/main/java/com/lokesh/webfluxdemo/repository/AnimalRepository.java

+package com.lokesh.webfluxdemo.repository;
+
+import com.lokesh.webfluxdemo.model.Animal;
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AnimalRepository extends ReactiveMongoRepository<Animal, String> {
+}

src/main/java/com/lokesh/webfluxdemo/resource/AnimalResource.java

+package com.lokesh.webfluxdemo.resource;
+
+import com.lokesh.webfluxdemo.model.Animal;
+import lombok.Data;
+
+@Data
+public class AnimalResource {
+    private String id;
+
+    private String name;
+
+    private String kingdom;
+
+    public AnimalResource(Animal animal) {
+        this.id = animal.getId();
+        this.name = animal.getName();
+        this.kingdom = animal.getKingdom();
+    }
+}

src/main/java/com/lokesh/webfluxdemo/sampledata/DataIntializer.java

+package com.lokesh.webfluxdemo.sampledata;
+
+import com.lokesh.webfluxdemo.model.Animal;
+import com.lokesh.webfluxdemo.repository.AnimalRepository;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Flux;
+
+@Component
+@Slf4j
+public class DataIntializer implements CommandLineRunner {
+    private final AnimalRepository animalRepository;
+
+    public DataIntializer(AnimalRepository animalRepository){
+        this.animalRepository = animalRepository;
+    }
+
+    @Override
+    public void run(String[] args) {
+        log.info("start data initialization...");
+        this.animalRepository
+                .deleteAll()
+                .thenMany(
+                        Flux.just("Cat", "Dog", "Horse", "Cow")
+                                .flatMap(
+                                        name -> this.animalRepository.save(Animal.builder().name(name).kingdom("Vertebrate").build())
+                                )
+                )
+                .log()
+                .subscribe(
+                        null,
+                        null,
+                        () -> log.info("done initialization...")
+                );
+    }
+}

src/main/resources/application.yml

+spring:
+  data:
+    mongodb:
+      uri: mongodb://localhost:27017/animal
\ No newline at end of file