initial commit - consumer

.gitignore

+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

.mvn/wrapper/maven-wrapper.properties

+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.6/apache-maven-3.8.6-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar

README.md

+# WebClient
+
+
+#### Config:
+Config have webclient configuration.
+
+#### Constants:
+
+#### Runner:
+test the API and get the results accordingly. 
+Here we are using Runner classes to test each method in a 
+separate Runner class.
+
+

mvnw.cmd

+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Maven Start Up Batch script
+@REM
+@REM Required ENV vars:
+@REM JAVA_HOME - location of a JDK home dir
+@REM
+@REM Optional ENV vars
+@REM M2_HOME - location of maven2's installed home dir
+@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
+@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
+@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
+@REM     e.g. to debug Maven itself, use
+@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+@REM ----------------------------------------------------------------------------
+
+@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
+@echo off
+@REM set title of command window
+title %0
+@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
+@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
+
+@REM set %HOME% to equivalent of $HOME
+if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
+
+@REM Execute a user defined script before this one
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
+@REM check for pre script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
+if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
+:skipRcPre
+
+@setlocal
+
+set ERROR_CODE=0
+
+@REM To isolate internal variables from possible post scripts, we use another setlocal
+@setlocal
+
+@REM ==== START VALIDATION ====
+if not "%JAVA_HOME%" == "" goto OkJHome
+
+echo.
+echo Error: JAVA_HOME not found in your environment. >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+:OkJHome
+if exist "%JAVA_HOME%\bin\java.exe" goto init
+
+echo.
+echo Error: JAVA_HOME is set to an invalid directory. >&2
+echo JAVA_HOME = "%JAVA_HOME%" >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+@REM ==== END VALIDATION ====
+
+:init
+
+@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
+@REM Fallback to current working directory if not found.
+
+set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
+IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
+
+set EXEC_DIR=%CD%
+set WDIR=%EXEC_DIR%
+:findBaseDir
+IF EXIST "%WDIR%"\.mvn goto baseDirFound
+cd ..
+IF "%WDIR%"=="%CD%" goto baseDirNotFound
+set WDIR=%CD%
+goto findBaseDir
+
+:baseDirFound
+set MAVEN_PROJECTBASEDIR=%WDIR%
+cd "%EXEC_DIR%"
+goto endDetectBaseDir
+
+:baseDirNotFound
+set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
+cd "%EXEC_DIR%"
+
+:endDetectBaseDir
+
+IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
+
+@setlocal EnableExtensions EnableDelayedExpansion
+for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
+@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
+
+:endReadAdditionalConfig
+
+SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
+set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
+set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+
+FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
+    IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
+)
+
+@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
+if exist %WRAPPER_JAR% (
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Found %WRAPPER_JAR%
+    )
+) else (
+    if not "%MVNW_REPOURL%" == "" (
+        SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+    )
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Couldn't find %WRAPPER_JAR%, downloading it ...
+        echo Downloading from: %DOWNLOAD_URL%
+    )
+
+    powershell -Command "&{"^
+		"$webclient = new-object System.Net.WebClient;"^
+		"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
+		"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
+		"}"^
+		"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
+		"}"
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Finished downloading %WRAPPER_JAR%
+    )
+)
+@REM End of extension
+
+@REM Provide a "standardized" way to retrieve the CLI args that will
+@REM work with both Windows and non-Windows executions.
+set MAVEN_CMD_LINE_ARGS=%*
+
+%MAVEN_JAVA_EXE% ^
+  %JVM_CONFIG_MAVEN_PROPS% ^
+  %MAVEN_OPTS% ^
+  %MAVEN_DEBUG_OPTS% ^
+  -classpath %WRAPPER_JAR% ^
+  "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
+  %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
+if ERRORLEVEL 1 goto error
+goto end
+
+:error
+set ERROR_CODE=1
+
+:end
+@endlocal & set ERROR_CODE=%ERROR_CODE%
+
+if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
+@REM check for post script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
+if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
+:skipRcPost
+
+@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
+if "%MAVEN_BATCH_PAUSE%"=="on" pause
+
+if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
+
+cmd /C exit /B %ERROR_CODE%

pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.7.9</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+	<groupId>com.lokesh</groupId>
+	<artifactId>webclient-demo</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<name>webclient-demo</name>
+	<description>Demo project for Spring Boot</description>
+	<properties>
+		<java.version>11</java.version>
+	</properties>
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-webflux</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<optional>true</optional>
+		</dependency>
+		<!-- REST API Documentation: Swagger Libraries -->
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-boot-starter</artifactId>
+			<version>3.0.0</version>
+		</dependency>
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger-ui</artifactId>
+			<version>3.0.0</version>
+		</dependency>
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger2</artifactId>
+			<version>3.0.0</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>io.projectreactor</groupId>
+			<artifactId>reactor-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+				<configuration>
+					<excludes>
+						<exclude>
+							<groupId>org.projectlombok</groupId>
+							<artifactId>lombok</artifactId>
+						</exclude>
+					</excludes>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

src/main/java/com/lokesh/webclientconsumer/WebclientDemoApplication.java

+package com.lokesh.webclientconsumer;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Building REST client Application
+ * @Author Lokesh Singh
+ */
+@SpringBootApplication
+public class WebclientDemoApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(WebclientDemoApplication.class, args);
+	}
+//	@Bean
+//	CommandLineRunner run(AnimalService animalService){
+//		return args -> {
+//			animalService.getAnimals()
+//					.subscribe(System.out::println);
+//		};
+//	}
+}

src/main/java/com/lokesh/webclientconsumer/config/SwaggerConfig.java

+package com.lokesh.webclientconsumer.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+import springfox.documentation.swagger2.annotations.EnableSwagger2WebFlux;
+
+import static springfox.documentation.builders.PathSelectors.regex;
+
+@Configuration
+@EnableSwagger2
+@Profile("default")
+public class SwaggerConfig {
+//    @Bean
+//    public Docket configSwagger() {
+//        return new Docket(DocumentationType.SWAGGER_2)
+//                .select()
+//                .apis(RequestHandlerSelectors.basePackage("com.lokesh.webclientconsumer.controller"))
+//                .paths(regex("/controller.*"))
+//                .build();
+////                .apiInfo(apiInfo())
+////                .useDefaultResponseMessages(false);
+//    }
+
+    private ApiInfo apiInfo() {
+//        return new ApiInfoBuilder().title("Microservices Webclient").description(
+//                        "API documentation for service one reactive service with mongo database")
+//                .termsOfServiceUrl("#")
+//                .license("Apache License 2.0")
+//                .licenseUrl("#").version("5.0.0")
+//                .build();
+        return null;
+    }
+}

src/main/java/com/lokesh/webclientconsumer/config/WebClientConfig.java

+package com.lokesh.webclientconsumer.config;
+
+public class WebClientConfig {
+
+}

src/main/java/com/lokesh/webclientconsumer/constants/AnimalConstants.java

+package com.lokesh.webclientconsumer.constants;
+
+public class AnimalConstants {
+    public static final String BASE_URL = "http://localhost:8081/api/v1/";
+    public static final String GET_ALL_ANIMALS = "/animal";
+    public static final String GET_ANIMAL_BYID = "/animal/{id}";
+}

src/main/java/com/lokesh/webclientconsumer/constants/TaskConstants.java

+package com.lokesh.webclientconsumer.constants;
+
+public class TaskConstants {
+    public static final String BASE_URL = "http://localhost:8088/api/v1/task";
+}

src/main/java/com/lokesh/webclientconsumer/constants/UserConstants.java

+package com.lokesh.webclientconsumer.constants;
+
+public class UserConstants {
+    public static final String BASE_URL = "http://localhost:8089/api/user";
+    public static final String GET_ALL_USERS = "/users";
+
+    public static final String GET_USER_BY_ID = "/users/{id}";
+}

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

+package com.lokesh.webclientconsumer.controller;
+
+import com.lokesh.webclientconsumer.model.Animal;
+import com.lokesh.webclientconsumer.service.AnimalService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Slf4j
+@RestController
+@RequestMapping(value = "/animal")
+public class AnimalController {
+    @Autowired
+    private AnimalService animalService;
+
+    @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    @ResponseStatus(HttpStatus.OK)
+    public Flux<Animal> getAnimal() {
+        return animalService.getAnimals();
+    }
+
+    @GetMapping(value = "/{id}")
+    public Mono<Animal> findById(@PathVariable("id") String id) {
+        try{
+            return animalService.findById(id);
+        } catch (Exception e) {
+            log.error("Exception find in findById() method.");
+            throw e;
+        }
+    }
+    @PostMapping(MediaType.APPLICATION_JSON_VALUE)
+    public Mono<Animal> postAnimal(@RequestBody Animal animal) {
+        return this.animalService.save(animal);
+    }
+}

src/main/java/com/lokesh/webclientconsumer/controller/TaskController.java

+package com.lokesh.webclientconsumer.controller;
+
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.service.TaskService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
+import org.springframework.data.mongodb.core.aggregation.Aggregation;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Slf4j
+@RestController
+@RequestMapping("/todos")
+public class TaskController {
+    @Autowired
+    private TaskService taskService;
+    @Autowired
+    private ReactiveMongoTemplate mongoTemplate;
+
+    @GetMapping(produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
+    @ResponseStatus(HttpStatus.OK)
+    public Flux<Task> getTasks() {
+        return taskService.getTasks();
+    }
+
+    @GetMapping("/{emailId}")
+    public Mono<Task> findTaskByEmailId(@PathVariable("emailId") String emailId) {
+        return taskService.findTaskByEmailId(emailId);
+    }
+    @GetMapping("/tasks")
+    public Flux<Task> getUserTask() {
+//        return mongoTemplate.aggregate(Aggregation.newAggregation(
+//                Aggregation.lookup("users", "user_id", "_id", "user"),
+//                Aggregation.project()
+//                        .and("task_title").as("title")
+//                        .and("task_desc").as("description")
+//                        .and("task_completed").as("completed")
+//                        .and("name").as("userName")
+//        ), "tasks", Task.class);
+
+        return mongoTemplate.aggregate(
+                Aggregation.newAggregation(
+                        Aggregation.lookup("users", "user_id", "_id", "user"),
+                        Aggregation.project("")
+                ), "tasks", Task.class
+        );
+    }
+
+//    @GetMapping(value = "/tasks/{id}")
+//    public Task getTaskWithUser(@PathVariable String emailId) {
+//        return this.taskService.getTasksWithUser(emailId);
+//    }
+}

src/main/java/com/lokesh/webclientconsumer/controller/UserController.java

+package com.lokesh.webclientconsumer.controller;
+
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.model.User;
+import com.lokesh.webclientconsumer.service.TaskService;
+import com.lokesh.webclientconsumer.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.util.function.Tuple2;
+
+@RestController
+@RequestMapping(value = "/users")
+public class UserController {
+    @Autowired
+    private UserService userService;
+
+    @Autowired
+    private TaskService taskService;
+    @GetMapping(produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    @ResponseStatus(HttpStatus.OK)
+    public Flux<User> getAllUsers() {
+        return userService.getAllUsers();
+    }
+
+    @GetMapping(value = "/{id}")
+    public Mono<Tuple2<User, Object>> findUserAndTaskByUserId(@PathVariable("id") String userId) {
+        // get user object with respective user task
+        Mono<Tuple2<User, Object>> monoUser = this.getUserById(userId)
+                .zipWhen(user -> {
+                    Mono<Task> userTask = this.getTaskByEmailId(user.getEmailId());
+                    return userTask;
+                });
+        return monoUser;
+    }
+
+    private Mono<Task> getTaskByEmailId(String emailId) {
+        return taskService.findTaskByEmailId(emailId);
+    }
+
+    private Mono<User> getUserById(String userId) {
+        return userService.getUserById(userId);
+    }
+}

src/main/java/com/lokesh/webclientconsumer/controller/UserTaskController.java

+package com.lokesh.webclientconsumer.controller;
+
+import com.lokesh.webclientconsumer.model.UserTask;
+import com.lokesh.webclientconsumer.service.UserService;
+import com.lokesh.webclientconsumer.service.UserTaskService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping(value = "usertask")
+public class UserTaskController {
+
+
+    //@GetMapping(value = "/{id}")
+//    Mono<UserTask> findUserTaskByUserId(@PathVariable("id") String id) {
+//        return userService.getUserAndTaskByUserId(id);
+//    }
+//    private WebClient userTaskWebClient = WebClient.create("http://localhost:8090");
+//
+//    Flux<UserTask> userTaskFlux = userTaskWebClient.get()
+//            .uri("/user-task")
+//            .retrieve()
+//            .bodyToFlux(UserTask.class);
+
+    private UserTaskService userTaskService;
+
+    @GetMapping()
+    Flux<UserTask> findAll() {
+        return userTaskService.getUserTasks();
+    }
+}

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

+package com.lokesh.webclientconsumer.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/webclientconsumer/model/Task.java

+package com.lokesh.webclientconsumer.model;
+
+import lombok.*;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.index.Indexed;
+import org.springframework.data.mongodb.core.mapping.DBRef;
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.mongodb.core.mapping.Field;
+
+import java.util.List;
+
+@Data
+@Getter
+@Setter
+@Document(collection = "tasks")
+@NoArgsConstructor
+@AllArgsConstructor
+public class Task {
+    @Id
+    private String taskId;
+    @Field("task_title")
+    private String title;
+    @Field("task_desc")
+    private List<String> description;
+    @Field("task_completed")
+    private boolean completed;
+    @Indexed
+    @DBRef
+    @Field("email_id")
+    private String emailId;
+}

src/main/java/com/lokesh/webclientconsumer/model/User.java

+package com.lokesh.webclientconsumer.model;
+
+import lombok.*;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.index.Indexed;
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.data.mongodb.core.mapping.Field;
+
+@Data
+@Getter
+@Setter
+@Document(collection = "users")
+@NoArgsConstructor
+@AllArgsConstructor
+public class User {
+    @Id
+    private String userId;
+    @Field("user_name")
+    private String name;
+    @Indexed(unique = true)
+    @Field("email_id")
+    private String emailId;
+
+//    private Task task;
+}

src/main/java/com/lokesh/webclientconsumer/model/UserTask.java

+package com.lokesh.webclientconsumer.model;
+
+import lombok.*;
+
+@Data
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+public class UserTask {
+//    private String id;
+//    private String name;
+//    private String emailId;
+//    private String taskId;
+    private User user;
+    private Task task;
+
+}

src/main/java/com/lokesh/webclientconsumer/runner/GetAllAnimalRunner.java

+package com.lokesh.webclientconsumer.runner;
+
+import com.lokesh.webclientconsumer.model.Animal;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+
+@Component
+public class GetAllAnimalRunner implements CommandLineRunner {
+    private static final String baseUrl = "http://localhost:8081/api/v1/";
+
+    @Override
+    public void run(String... args) throws Exception{
+        WebClient client = WebClient.create(baseUrl);
+        Flux<Animal> animalFlux = client
+                .get()
+                .uri("/animal")
+                .retrieve()
+                .bodyToFlux(Animal.class);
+        animalFlux.doOnNext(System.out::println).blockLast();
+    }
+}
+

src/main/java/com/lokesh/webclientconsumer/runner/GetAllTaskRunner.java

+package com.lokesh.webclientconsumer.runner;
+
+import com.lokesh.webclientconsumer.model.Task;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+
+import static com.lokesh.webclientconsumer.constants.TaskConstants.BASE_URL;
+
+@Component
+public class GetAllTaskRunner implements CommandLineRunner {
+
+
+    @Override
+    public void run(String... args) throws Exception {
+        WebClient client = WebClient.create(BASE_URL);
+        Flux<Task> taskFlux = client
+                .get()
+                .uri("/tasks")
+                .retrieve()
+                .bodyToFlux(Task.class);
+        taskFlux.doOnNext(System.out::println).blockLast();
+    }
+}

src/main/java/com/lokesh/webclientconsumer/runner/GetAllUserRunner.java

+package com.lokesh.webclientconsumer.runner;
+
+import com.lokesh.webclientconsumer.constants.UserConstants;
+import com.lokesh.webclientconsumer.model.User;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+
+import static com.lokesh.webclientconsumer.constants.UserConstants.GET_ALL_USERS;
+
+@Component
+public class GetAllUserRunner implements CommandLineRunner {
+    @Override
+    public void run(String... args) throws Exception {
+        WebClient client = WebClient.create(UserConstants.BASE_URL);
+        Flux<User> userFlux = client
+                .get()
+                .uri(GET_ALL_USERS)
+                .retrieve()
+                .bodyToFlux(User.class);
+        userFlux.doOnNext(System.out::println).blockLast();
+    }
+}

src/main/java/com/lokesh/webclientconsumer/runner/GetAllUserTaskRunner.java

+package com.lokesh.webclientconsumer.runner;
+
+import com.lokesh.webclientconsumer.constants.UserConstants;
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.model.User;
+import com.lokesh.webclientconsumer.model.UserTask;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+
+import static com.lokesh.webclientconsumer.constants.TaskConstants.BASE_URL;
+import static com.lokesh.webclientconsumer.constants.UserConstants.GET_ALL_USERS;
+
+@Component
+public class GetAllUserTaskRunner implements CommandLineRunner {
+
+    @Override
+    public void run(String... args) throws Exception {
+        WebClient userClient = WebClient.create(UserConstants.BASE_URL);
+        WebClient taskClient = WebClient.create(BASE_URL);
+
+        Flux<User> userFlux = userClient
+                .get()
+                .uri(GET_ALL_USERS)
+                .retrieve()
+                .bodyToFlux(User.class);
+
+        Flux<Task> taskFlux = taskClient
+                .get()
+                .uri("/tasks")
+                .retrieve()
+                .bodyToFlux(Task.class);
+
+
+        System.out.println(userFlux.zipWith(taskFlux));;
+    }
+}

src/main/java/com/lokesh/webclientconsumer/service/AnimalService.java

+package com.lokesh.webclientconsumer.service;
+
+import com.lokesh.webclientconsumer.model.Animal;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface AnimalService {
+    Flux<Animal> getAnimals();
+
+    Mono<Animal> findById(String id);
+
+    Mono<Animal> save(Animal animal);
+}

src/main/java/com/lokesh/webclientconsumer/service/TaskService.java

+package com.lokesh.webclientconsumer.service;
+
+import com.lokesh.webclientconsumer.model.Task;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface TaskService {
+    Flux<Task> getTasks();
+
+    Mono<Task> findTaskByEmailId(String emailId);
+
+//    Task getTasksWithUser(String taskId);
+}

src/main/java/com/lokesh/webclientconsumer/service/UserService.java

+package com.lokesh.webclientconsumer.service;
+
+import com.lokesh.webclientconsumer.model.User;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+public interface UserService {
+    Flux<User> getAllUsers();
+
+//    Mono<User> getUserAndTaskByUserId(String id);
+    Mono<User> getUserById(String id);
+}

src/main/java/com/lokesh/webclientconsumer/service/UserTaskService.java

+package com.lokesh.webclientconsumer.service;
+
+import com.lokesh.webclientconsumer.model.UserTask;
+import reactor.core.publisher.Flux;
+
+public interface UserTaskService {
+    Flux<UserTask> getUserTasks();
+}

src/main/java/com/lokesh/webclientconsumer/service/impl/AnimalServiceImpl.java

+package com.lokesh.webclientconsumer.service.impl;
+
+import com.lokesh.webclientconsumer.model.Animal;
+import com.lokesh.webclientconsumer.service.AnimalService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import org.springframework.web.reactive.function.client.WebClientResponseException;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import static com.lokesh.webclientconsumer.constants.AnimalConstants.*;
+
+@Slf4j
+@Service
+public class AnimalServiceImpl implements AnimalService {
+    private WebClient client = WebClient.create(BASE_URL);
+
+    public Flux<Animal> getAnimals() {
+        return client.get()
+                .uri(GET_ALL_ANIMALS)
+                .retrieve()
+                .bodyToFlux(Animal.class);
+    }
+
+    @Override
+    public Mono<Animal> findById(String id) {
+        try {
+            return client.get()
+                    .uri(GET_ANIMAL_BYID, id)
+                    .retrieve()
+                    .bodyToMono(Animal.class);
+        } catch (WebClientResponseException wcre) {
+            log.error("Error response code is { } and response body is { }", wcre.getRawStatusCode(), wcre.getResponseBodyAsString());
+            log.error("Exception in method retrieveAllInvoices()", wcre);
+            throw wcre;
+        } catch (Exception ex) {
+            log.error("Exception find in findById() method.");
+            throw ex;
+        }
+    }
+
+    @Override
+    public Mono<Animal> save(Animal animal) {
+        return client.post()
+                .uri("/animal")
+                .retrieve()
+                .bodyToMono(Animal.class);
+    }
+}

src/main/java/com/lokesh/webclientconsumer/service/impl/TaskServiceImpl.java

+package com.lokesh.webclientconsumer.service.impl;
+
+import com.lokesh.webclientconsumer.constants.TaskConstants;
+import com.lokesh.webclientconsumer.constants.UserConstants;
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.model.User;
+import com.lokesh.webclientconsumer.service.TaskService;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import static com.lokesh.webclientconsumer.constants.TaskConstants.BASE_URL;
+
+
+@Service
+public class TaskServiceImpl implements TaskService {
+
+    private WebClient taskClient = WebClient.create(TaskConstants.BASE_URL);
+
+    private WebClient userClient = WebClient.create(UserConstants.BASE_URL);
+    public Flux<Task> getTasks() {
+        return taskClient.get()
+                .uri("/tasks")
+                .retrieve()
+                .bodyToFlux(Task.class);
+    }
+    public Mono<Task> findTaskByEmailId(String emailId) {
+        return taskClient.get()
+                .uri("/{emailId}", emailId)
+                .retrieve()
+                .bodyToMono(Task.class);
+    }
+
+//    @Override
+//    public Task getTasksWithUser(String taskId) {
+//
+//        Task task = taskClient.get()
+//                .uri("/{id}", taskId)
+//                .retrieve()
+//                .bodyToMono(Task.class)
+//                .block();
+//
+//        User user = userClient.get()
+//                .uri("/users/{id}", task.getUserId())
+//                .retrieve()
+//                .bodyToMono(User.class)
+//                .block();
+//
+//        task.setUser(user);
+//        return task;
+//    }
+}

src/main/java/com/lokesh/webclientconsumer/service/impl/UserServiceImpl.java

+package com.lokesh.webclientconsumer.service.impl;
+
+import com.fasterxml.jackson.databind.util.BeanUtil;
+import com.lokesh.webclientconsumer.constants.TaskConstants;
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.model.User;
+import com.lokesh.webclientconsumer.model.UserTask;
+import com.lokesh.webclientconsumer.service.UserService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import static com.lokesh.webclientconsumer.constants.UserConstants.BASE_URL;
+import static com.lokesh.webclientconsumer.constants.UserConstants.GET_ALL_USERS;
+
+@Service
+public class UserServiceImpl implements UserService {
+    private WebClient userClient = WebClient.create(BASE_URL);
+
+    private WebClient taskClient = WebClient.create(TaskConstants.BASE_URL);
+    public Flux<User> getAllUsers() {
+        return userClient.get()
+                .uri(GET_ALL_USERS)
+                .retrieve()
+                .bodyToFlux(User.class);
+    }
+
+    @Override
+    public Mono<User> getUserById(String id) {
+
+        return userClient.get()
+                .uri("/{id}", id)
+                .retrieve()
+                .bodyToMono(User.class);
+    }
+
+//    @Override
+//    public Mono<User> getUserAndTaskByUserId(String id) {
+//        Mono<User> userMono = userClient.get().uri("/{id}").retrieve().bodyToMono(User.class);
+//
+////        Mono<Task> taskMono = taskClient.get().uri("/{emailId}").retrieve().bodyToMono(Task.class);
+//        Mono<Task> taskMono = taskClient.getTas
+//        UserTask userTask = new UserTask();
+//        BeanUtils.copyProperties();
+//    }
+}

src/main/java/com/lokesh/webclientconsumer/service/impl/UserTaskServiceImpl.java

+package com.lokesh.webclientconsumer.service.impl;
+
+import com.lokesh.webclientconsumer.model.Task;
+import com.lokesh.webclientconsumer.model.User;
+import com.lokesh.webclientconsumer.model.UserTask;
+import com.lokesh.webclientconsumer.service.TaskService;
+import com.lokesh.webclientconsumer.service.UserService;
+import com.lokesh.webclientconsumer.service.UserTaskService;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+
+@Service
+public class UserTaskServiceImpl implements UserTaskService {
+    private UserService userService;
+    private TaskService taskService;
+
+
+    public UserTaskServiceImpl(UserService userService, TaskService taskService) {
+        this.userService = userService;
+        this.taskService = taskService;
+    }
+
+    public Flux<UserTask> getUserTasks() {
+        Flux<User> users = userService.getAllUsers();
+        System.out.println(users);
+        Flux<Task> tasks = taskService.getTasks();
+
+        return Flux.zip(users, tasks)
+                .map(tuple -> new UserTask(tuple.getT1(), tuple.getT2()));
+    }
+}

src/main/resources/application.properties

+server.port:8090
\ No newline at end of file

src/test/java/com/lokesh/webclientconsumer/WebclientDemoApplicationTests.java

+package com.lokesh.webclientconsumer;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class WebclientDemoApplicationTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}