Skip to content

T
TPS-Product-Service
Commit 9e8bc463 authored by Prangshu Maity's avatar Prangshu Maity
Browse files
Options

initial commit

parents
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 764 additions and 0 deletions
.gitattributes 0 → 100644
View file @ 9e8bc463
/mvnw text eol=lf
*.cmd text eol=crlf
.gitignore 0 → 100644
View file @ 9e8bc463
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 0 → 100644
View file @ 9e8bc463
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
wrapperVersion=3.3.2
distributionType=only-script
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.9/apache-maven-3.9.9-bin.zip
mvnw 0 → 100644
View file @ 9e8bc463
This diff is collapsed.
mvnw.cmd 0 → 100644
View file @ 9e8bc463
<# : batch portion
@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 http://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 Apache Maven Wrapper startup batch script, version 3.3.2
@REM
@REM Optional ENV vars
@REM MVNW_REPOURL - repo url base for downloading maven distribution
@REM MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
@REM MVNW_VERBOSE - true: enable verbose log; others: silence the output
@REM ----------------------------------------------------------------------------
@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
@SET __MVNW_CMD__=
@SET __MVNW_ERROR__=
@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
@SET PSModulePath=
@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
)
@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
@SET __MVNW_PSMODULEP_SAVE=
@SET __MVNW_ARG0_NAME__=
@SET MVNW_USERNAME=
@SET MVNW_PASSWORD=
@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
@echo Cannot start maven from wrapper >&2 && exit /b 1
@GOTO :EOF
: end batch / begin powershell #>
$ErrorActionPreference = "Stop"
if ($env:MVNW_VERBOSE -eq "true") {
$VerbosePreference = "Continue"
}
# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
if (!$distributionUrl) {
Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
}
switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
"maven-mvnd-*" {
$USE_MVND = $true
$distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
$MVN_CMD = "mvnd.cmd"
break
}
default {
$USE_MVND = $false
$MVN_CMD = $script -replace '^mvnw','mvn'
break
}
}
# apply MVNW_REPOURL and calculate MAVEN_HOME
# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
if ($env:MVNW_REPOURL) {
$MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
$distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
}
$distributionUrlName = $distributionUrl -replace '^.*/',''
$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
if ($env:MAVEN_USER_HOME) {
$MAVEN_HOME_PARENT = "$env:MAVEN_USER_HOME/wrapper/dists/$distributionUrlNameMain"
}
$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
exit $?
}
if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
}
# prepare tmp dir
$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
trap {
if ($TMP_DOWNLOAD_DIR.Exists) {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
}
New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
# Download and Install Apache Maven
Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
Write-Verbose "Downloading from: $distributionUrl"
Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
$webclient = New-Object System.Net.WebClient
if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
$webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
}
[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
# If specified, validate the SHA-256 sum of the Maven distribution zip file
$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
if ($distributionSha256Sum) {
if ($USE_MVND) {
Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
}
Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
}
}
# unzip and move
Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
try {
Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
} catch {
if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
Write-Error "fail to move MAVEN_HOME"
}
} finally {
try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
}
Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
pom.xml 0 → 100644
View file @ 9e8bc463
<?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>3.2.0</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.demo</groupId>
<artifactId>trendify-product</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springboot-reactive-mongo</name>
<description>Demo project for Spring Boot</description>
<url/>
<licenses>
<license/>
</licenses>
<developers>
<developer/>
</developers>
<scm>
<connection/>
<developerConnection/>
<tag/>
<url/>
</scm>
<properties>
<java.version>17</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>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--<dependency>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
<version>2.5.0</version>
</dependency>-->
<dependency>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-starter-webflux-ui</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<artifactId>reactor-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<annotationProcessorPaths>
<path>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</path>
</annotationProcessorPaths>
</configuration>
</plugin>
<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/nisum/SpringbootReactiveMongoApplication.java 0 → 100644
View file @ 9e8bc463
package com.nisum;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SpringbootReactiveMongoApplication {
public static void main(String[] args) {
SpringApplication.run(SpringbootReactiveMongoApplication.class, args);
}
}
src/main/java/com/nisum/config/SwaggerConfig.java 0 → 100644
View file @ 9e8bc463
package com.nisum.config;/*
package com.demo.springboot_reactive_mongo.config;
import io.swagger.v3.oas.annotations.info.Info;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@EnableOpenApi
public class SwaggerConfig {
@Bean
public Info apiInfo() {
return new Info()
.title("My API")
.version("1.0")
.description("API documentation for My Spring Boot application");
}
}*/
src/main/java/com/nisum/controller/ProductController.java 0 → 100644
View file @ 9e8bc463
package com.nisum.controller;
import com.nisum.dto.ProductDto;
import com.nisum.service.ProductService;
import jakarta.validation.Valid;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.List;
@RestController
@RequestMapping("/products")
public class ProductController {
@Autowired
private ProductService service;
@GetMapping("/allProducts")
public Flux<ProductDto> getAllProducts(){
return service.getAllProducts();
}
@GetMapping("/{id}")
public Mono<ProductDto> getProduct(@PathVariable String id){
return service.getProduct(id);
}
@GetMapping("/price/{id}")
public Mono<Double> getProductPrice(@PathVariable String id){
return service.getProductPrice(id);
}
@GetMapping("/product-range")
public Flux<ProductDto> getProductBetweenRange(@RequestParam("min") double min,@RequestParam double max){
return service.getProductInRange(min, max);
}
/*@PostMapping("/addProduct")
public Mono<ResponseEntity<ProductDto>> saveProduct(@RequestBody Mono<ProductDto> productDtoMono) {
return productDtoMono
.flatMap(productDto -> service.saveProduct(Mono.just(productDto)))
.map(savedProduct -> ResponseEntity.status(HttpStatus.CREATED).body(savedProduct));
}*/
@PostMapping("/addProducts")
public Mono<ResponseEntity<List<ProductDto>>> saveProducts(@RequestBody @Valid Flux<ProductDto> productDtoFlux) {
return productDtoFlux
.flatMap(productDto -> service.saveProduct(Mono.just(productDto))) // Save each product
.collectList() // Collect them into a List
.map(savedProducts -> ResponseEntity.status(HttpStatus.CREATED).body(savedProducts)); // Return 201 Created
}
@PutMapping ("/update/{id}")
public Mono<ProductDto> updateProduct(@RequestBody Mono<ProductDto> productDtoMono, @PathVariable String id){
return service.updateProduct(productDtoMono,id);
}
@DeleteMapping("/delete/{id}")
public Mono<Void> deleteProduct(@PathVariable String id){
return service.deleteProduct(id);
}
}
src/main/java/com/nisum/dto/ProductDto.java 0 → 100644
View file @ 9e8bc463
package com.nisum.dto;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Positive;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class ProductDto {
private String id;
@NotBlank(message = "Name cannot be empty")
private String name;
@Min(value = 1, message = "Quantity must be at least 1")
private int qty;
@Positive(message = "Price must be positive")
private double price;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getQty() {
return qty;
}
public void setQty(int qty) {
this.qty = qty;
}
public double getPrice() {
return price;
}
public void setPrice(double price) {
this.price = price;
}
}
src/main/java/com/nisum/entity/Product.java 0 → 100644
View file @ 9e8bc463
package com.nisum.entity;
import jakarta.validation.constraints.*;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection = "products")
public class Product{
@Id
private String id;
@NotNull(message = "Product name cannot be null")
@NotBlank(message = "Name cannot be blank or null.")
@Pattern(regexp = "^[a-zA-Z0-9 ]+$", message = "Name must not contain special characters.")
private String name;
@NotNull(message = "Qty should not be null,You should have order at least one ")
private int qty;
@NotNull(message = "Price cannot be null")
@Min(value = 0, message = "Price must be greater than or equal to 0")
@Max(value = 10000, message = "Price should be less than or equal to 10000")
private double price;
/* public Product(String id, String name, int qty) {
this.id=id;
this.name=name;
this.qty=qty;
}*/
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getQty() {
return qty;
}
public void setQty(int qty) {
this.qty = qty;
}
public double getPrice() {
return price;
}
public void setPrice(double price) {
this.price = price;
}
}
src/main/java/com/nisum/exception/DuplicateProductNameException.java 0 → 100644
View file @ 9e8bc463
package com.nisum.exception;
public class DuplicateProductNameException extends RuntimeException {
public DuplicateProductNameException(String message) {
super(message);
}
}
src/main/java/com/nisum/exception/GlobalExceptionHandler.java 0 → 100644
View file @ 9e8bc463
package com.nisum.exception;
import jakarta.validation.ConstraintViolationException;
import org.springframework.dao.IncorrectResultSizeDataAccessException;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.FieldError;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.bind.support.WebExchangeBindException;
import reactor.core.publisher.Mono;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@RestControllerAdvice
public class GlobalExceptionHandler {
@ExceptionHandler(WebExchangeBindException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public Mono<ResponseEntity<Map<String, Map<String, String>>>> handleValidationExceptions(WebExchangeBindException ex) {
// Get the list of validation errors
Map<String, Map<String, String>> errorMap = new HashMap<>();
// Extract the field errors and map them to a concise structure with errorCode and status
List<FieldError> fieldErrors = ex.getBindingResult().getFieldErrors();
for (FieldError fieldError : fieldErrors) {
Map<String, String> errorDetails = new HashMap<>();
errorDetails.put("errorCode", fieldError.getCode());
errorDetails.put("status", fieldError.getDefaultMessage());
errorMap.put(fieldError.getField(), errorDetails);
}
// Return the error messages
return Mono.just(ResponseEntity.badRequest().body(errorMap));
}
@ExceptionHandler(ConstraintViolationException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public Mono<ResponseEntity<String>> handleConstraintViolation(ConstraintViolationException ex) {
// Extract and return error message
return Mono.just(ResponseEntity.badRequest().body(ex.getMessage()));
}
@ExceptionHandler(IncorrectResultSizeDataAccessException.class)
public ResponseEntity<Map<String, String>> handleIncorrectResultSizeException(IncorrectResultSizeDataAccessException ex) {
Map<String, String> errorResponse = new HashMap<>();
errorResponse.put("Duplicate", "Duplicate product not allow");
//errorResponse.put("details", ex.getMessage());
return new ResponseEntity<>(errorResponse, HttpStatus.CONFLICT); // HTTP 409 Conflict
}
@ExceptionHandler(Exception.class)
@ResponseStatus(HttpStatus.NOT_FOUND)
public ResponseEntity<String> handleProductNotFound(Exception ex) {
return ResponseEntity.status(HttpStatus.NOT_FOUND).body(ex.getMessage());
}
}
src/main/java/com/nisum/repository/ProductRepository.java 0 → 100644
View file @ 9e8bc463
package com.nisum.repository;
import com.nisum.dto.ProductDto;
import com.nisum.entity.Product;
import org.springframework.data.domain.Range;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.stereotype.Repository;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@Repository
public interface ProductRepository extends ReactiveMongoRepository<Product,String> {
Flux<ProductDto> findByPriceBetween(Range<Double> priceRange);
Mono<Product> findByName(String name);
}
src/main/java/com/nisum/service/ProductService.java 0 → 100644
View file @ 9e8bc463
package com.nisum.service;
import com.nisum.dto.ProductDto;
import com.nisum.exception.DuplicateProductNameException;
import com.nisum.repository.ProductRepository;
import com.nisum.utils.AppUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Range;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@Service
public class ProductService {
@Autowired
private ProductRepository repository;
public Flux<ProductDto> getAllProducts(){
return repository.findAll().map(AppUtils::entityToDto);
}
public Mono<ProductDto> getProduct(String id){
return repository.findById(id).map(AppUtils::entityToDto);
}
public Mono<Double> getProductPrice(String id){
return repository.findById(id).map(AppUtils::entityToDto).map(dto -> dto.getPrice());
}
public Flux<ProductDto> getProductInRange(double min,double max){
return repository.findByPriceBetween(Range.closed(min,max));
}
/* public Mono<ProductDto> saveProduct(Mono<ProductDto> productDtoMono){
return productDtoMono.map(AppUtils::dtoToEntity)
.flatMap(repository::insert) //flatmap because it is using Mono of mono list
.map(AppUtils::entityToDto);
}*/
public Mono<ProductDto> saveProduct(Mono<ProductDto> productDtoMono) {
return productDtoMono
.flatMap(productDto -> repository.findByName(productDto.getName())
.flatMap(existingProduct -> Mono.error(new DuplicateProductNameException(
"Product with name" + productDto.getName() + "already exists")))) // Throw a custom exception
.switchIfEmpty(productDtoMono) // Proceed if the product name is unique
.map(productDto -> AppUtils.dtoToEntity((ProductDto) productDto))
// Convert DTO to Entity
.flatMap(repository::insert) // Save the new product entity
.map(AppUtils::entityToDto); // Convert entity back to DTO
}
public Mono<ProductDto> updateProduct(Mono<ProductDto> productDtoMono,String id){
return repository.findById(id)
.flatMap(p-> productDtoMono.map(AppUtils::dtoToEntity)
.doOnNext(e -> e.setId(id)))
.flatMap(repository::save)
.map(AppUtils::entityToDto);
}
public Mono<Void> deleteProduct(String id){
return repository.deleteById(id);
}
}
src/main/java/com/nisum/utils/AppUtils.java 0 → 100644
View file @ 9e8bc463
package com.nisum.utils;
import com.nisum.dto.ProductDto;
import com.nisum.entity.Product;
import org.springframework.beans.BeanUtils;
public class AppUtils {
public static ProductDto entityToDto(Product product) {
ProductDto productDto = new ProductDto();
BeanUtils.copyProperties(product,productDto);
return productDto;
}
public static Product dtoToEntity(ProductDto productDto) {
Product product = new Product ();
BeanUtils.copyProperties(productDto,product);
return product;
}
}
src/main/resources/application.properties 0 → 100644
View file @ 9e8bc463
spring.application.name=springboot-reactive-mongo
#springdoc.api-docs.path=/api-docs
#springdoc.swagger-ui.path=/swagger-ui/index.html
#server.servlet.context-path=/api
src/main/resources/application.yml 0 → 100644
View file @ 9e8bc463
spring:
data:
mongodb:
database : Productsdb
host: localhost
port: 27017
server:
port : 8081
product:
name:
pattern: ^[a-zA-Z0-9 ]+$
\ No newline at end of file
src/test/java/com/product_service/ProductServiceApplicationTests.java 0 → 100644
View file @ 9e8bc463
package com.product_service;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class ProductServiceApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment