controller, service and repo added

Author: dStrange6

catalog-service/pom.xml

@@ -122,6 +122,12 @@
 			<version>5.5.6</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<version>1.18.42</version>
+			<scope>provided</scope>
+		</dependency>
 
 	</dependencies>
 
@@ -131,11 +137,17 @@
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-compiler-plugin</artifactId>
 				<configuration>
+
 					<annotationProcessorPaths>
 						<path>
 							<groupId>org.springframework.boot</groupId>
 							<artifactId>spring-boot-configuration-processor</artifactId>
 						</path>
+						<path>
+							<groupId>org.projectlombok</groupId>
+							<artifactId>lombok</artifactId>
+							<version>1.18.42</version>
+						</path>
 					</annotationProcessorPaths>
 				</configuration>
 			</plugin>

catalog-service/src/main/java/com/mayank/catalog_service/ApplicationProperties.java

@@ -0,0 +1,13 @@
+package com.mayank.catalog_service;
+
+import jakarta.validation.constraints.Min;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.bind.DefaultValue;
+
+@ConfigurationProperties(prefix = "catalog")
+public record ApplicationProperties(
+        @DefaultValue("10")
+        @Min(1)
+        int pageSize
+) {
+}

catalog-service/src/main/java/com/mayank/catalog_service/CatalogServiceApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
 
 @SpringBootApplication
+@ConfigurationPropertiesScan
 public class CatalogServiceApplication {
 
     public static void main(String[] args) {

catalog-service/src/main/java/com/mayank/catalog_service/domain/PagedResult.java

@@ -0,0 +1,14 @@
+package com.mayank.catalog_service.domain;
+
+import java.util.List;
+
+public record PagedResult<T>(
+    List<T> data,
+    long totalElements,
+    int pageNumber,
+    int totalPages,
+    boolean isFirst,
+    boolean isLast,
+    boolean hasNext,
+    boolean hasPrevious) {}
+

catalog-service/src/main/java/com/mayank/catalog_service/domain/Product.java

@@ -0,0 +1,10 @@
+package com.mayank.catalog_service.domain;
+
+import java.math.BigDecimal;
+
+public record Product(
+        String code,
+        String name,
+        String description,
+        String imageUrl,
+        BigDecimal price) { }

catalog-service/src/main/java/com/mayank/catalog_service/domain/ProductEntity.java

@@ -0,0 +1,37 @@
+package com.mayank.catalog_service.domain;
+
+import jakarta.persistence.*;
+import jakarta.validation.constraints.DecimalMin;
+import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.NotNull;
+import lombok.*;
+
+import java.math.BigDecimal;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Entity
+@Table(name = "products")
+public class ProductEntity
+{
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "product_id_generator")
+    @SequenceGenerator(name = "product_id_generator", sequenceName = "product_id_seq")
+    private Long id;
+
+    @Column(nullable = false, unique = true)
+    @NotEmpty(message = "Product code is required")
+    private String code;
+
+    @Column(nullable = false)
+    @NotEmpty(message = "Product name is required")
+    private String name;
+
+    private String description;
+    private String imageUrl;
+
+    @Column(nullable = false)
+    @NotNull(message = "Product price is required") @DecimalMin("0.1")
+    private BigDecimal price;
+}

catalog-service/src/main/java/com/mayank/catalog_service/domain/ProductMapper.java

@@ -0,0 +1,15 @@
+package com.mayank.catalog_service.domain;
+
+public class ProductMapper
+{
+    static Product toProduct(ProductEntity productEntity)
+    {
+        return new Product(
+          productEntity.getCode(),
+          productEntity.getName(),
+          productEntity.getDescription(),
+          productEntity.getImageUrl(),
+          productEntity.getPrice()
+        );
+    }
+}

catalog-service/src/main/java/com/mayank/catalog_service/domain/ProductRepository.java

@@ -0,0 +1,8 @@
+package com.mayank.catalog_service.domain;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+interface ProductRepository extends JpaRepository<ProductEntity, Long> {
+}

catalog-service/src/main/java/com/mayank/catalog_service/domain/ProductService.java

@@ -0,0 +1,41 @@
+package com.mayank.catalog_service.domain;
+
+import com.mayank.catalog_service.ApplicationProperties;
+import jakarta.transaction.Transactional;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Service;
+
+@Service
+@Transactional
+public class ProductService
+{
+    private final ProductRepository productRepository;
+    private final ApplicationProperties applicationProperties;
+
+    public ProductService(ProductRepository productRepository, ApplicationProperties applicationProperties) {
+        this.productRepository = productRepository;
+        this.applicationProperties = applicationProperties;
+    }
+
+    public PagedResult<Product> getProducts(int pageNo)
+    {
+        Sort sort = Sort.by("name").ascending();
+        pageNo = pageNo <= 1 ? 0 : pageNo - 1;
+        Pageable pageable = PageRequest.of(pageNo, applicationProperties.pageSize(), sort);
+        Page<Product> productsPage = productRepository.findAll(pageable).map(ProductMapper::toProduct);
+
+        return new PagedResult<>(
+                productsPage.getContent(),
+                productsPage.getTotalElements(),
+                productsPage.getNumber() + 1,
+                productsPage.getTotalPages(),
+                productsPage.isFirst(),
+                productsPage.isLast(),
+                productsPage.hasNext(),
+                productsPage.hasPrevious()
+        );
+    }
+}

catalog-service/src/main/java/com/mayank/catalog_service/web/controllers/ProductController.java

@@ -0,0 +1,29 @@
+package com.mayank.catalog_service.web.controllers;
+
+import com.mayank.catalog_service.domain.PagedResult;
+import com.mayank.catalog_service.domain.Product;
+import com.mayank.catalog_service.domain.ProductService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/api/products")
+public class ProductController
+{
+    private final ProductService productService;
+
+    public ProductController(ProductService productService) {
+        this.productService = productService;
+    }
+
+    @GetMapping
+    PagedResult<Product> getProducts(@RequestParam(name="page", defaultValue = "1")int pageNo)
+    {
+        return productService.getProducts(pageNo);
+    }
+
+}