Catana image bucket

containers/compose.yml

@@ -37,6 +37,19 @@ services:
       - 5672:5672
       - 15672:15672
 
+
+  image-bucket:
+    container_name: image-bucket
+    image: minio/minio
+    ports:
+      - 9000:9000
+      - 9001:9001
+    environment:
+      MINIO_ACCESS_KEY: rares
+      MINIO_SECRET_KEY: rares2004
+    command: server /data --console-address ":9001"
+
+
   # Nginx
   core-services:
     container_name: core-services
@@ -58,6 +71,3 @@ services:
       - core-services
       - event-service
 
-
-
-

containers/minio-data/.minio.sys/format.json

@@ -0,0 +1 @@
+{"version":"1","format":"xl-single","id":"2a2cd0d2-1eda-4f64-8c91-38d886f82fd0","xl":{"version":"3","this":"24c80554-3569-4f1f-a94d-f1e472d04a42","sets":[["24c80554-3569-4f1f-a94d-f1e472d04a42"]],"distributionAlgo":"SIPMOD+PARITY"}}

image-service/pom.xml

@@ -17,4 +17,42 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>io.minio</groupId>
+            <artifactId>minio</artifactId>
+            <version>8.5.2</version>
+        </dependency>
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <version>3.0.0</version>
+        </dependency>
+        <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>net.coobird</groupId>
+            <artifactId>thumbnailator</artifactId>
+            <version>0.4.14</version> <!-- or the latest version -->
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>6.2.0</version> <!-- or latest version -->
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+        </dependency>
+    </dependencies>
+
 </project>

image-service/src/main/java/com/stackbytes/Main.java

@@ -1,7 +1,11 @@
 package com.stackbytes;
 
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
 public class Main {
     public static void main(String[] args) {
-        System.out.println("Hello world!");
+        SpringApplication.run(Main.class, args);
     }
 }

image-service/src/main/java/com/stackbytes/configs/MinioConfig.java

@@ -0,0 +1,24 @@
+package com.stackbytes.configs;
+
+import io.minio.MinioClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MinioConfig {
+
+    @Value("${minio.username}")
+    private String username;
+
+    @Value("${minio.password}")
+    private String password;
+
+    @Bean
+    public MinioClient minioClient() {
+        return MinioClient.builder()
+                .endpoint("http://localhost:9000")
+                .credentials(username, password)
+                .build();
+    }
+}

image-service/src/main/java/com/stackbytes/controllers/ImageController.java

@@ -0,0 +1,45 @@
+package com.stackbytes.controllers;
+
+import com.stackbytes.models.dto.InsertImageResponseDto;
+import com.stackbytes.services.ImageService;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+@RestController
+public class ImageController {
+
+    private final ImageService imageService;
+
+    public ImageController(ImageService imageService) {
+        this.imageService = imageService;
+    }
+
+    @PostMapping("/insert")
+    public ResponseEntity<InsertImageResponseDto> insertImage(@RequestParam("file")MultipartFile file, @RequestParam("name") String name, @RequestParam("isProfilePicture") boolean isProfilePicture){
+        InsertImageResponseDto response = imageService.insertImage(file, name, isProfilePicture);
+        if(response.isSuccess()){
+            return ResponseEntity.ok(response);
+        }
+        return ResponseEntity.status(HttpStatus.NOT_FOUND).body(response);
+    }
+
+    @PostMapping("/insert-reduced")
+    public ResponseEntity<InsertImageResponseDto> insertReducedImage(@RequestParam("file")MultipartFile file, @RequestParam("name") String name, @RequestParam("isProfilePicture") boolean isProfilePicture) {
+        InsertImageResponseDto response = imageService.insertReducedImage(file, name, isProfilePicture);
+        if(response.isSuccess()){
+            return ResponseEntity.ok(response);
+        }
+        return ResponseEntity.status(HttpStatus.NOT_FOUND).body(response);
+    }
+
+    @PostMapping("/insert-avatar")
+    public ResponseEntity<InsertImageResponseDto> insertAvatarImage(@RequestParam("file")MultipartFile file, @RequestParam("name") String name, @RequestParam("reduced") boolean reduced) {
+        InsertImageResponseDto response = imageService.insertAvatarImage(file, name, reduced);
+        if(response.isSuccess()){
+            return ResponseEntity.ok(response);
+        }
+        return ResponseEntity.status(HttpStatus.NOT_FOUND).body(response);
+    }
+}

image-service/src/main/java/com/stackbytes/models/Image.java

@@ -0,0 +1,16 @@
+package com.stackbytes.models;
+
+import lombok.Builder;
+import lombok.Data;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+@Document(collection = "images")
+@Data
+@Builder
+public class Image {
+    @Id
+    private String id;
+
+    private String name;
+}

image-service/src/main/java/com/stackbytes/models/dto/InsertImageResponseDto.java

@@ -0,0 +1,11 @@
+package com.stackbytes.models.dto;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class InsertImageResponseDto {
+    private boolean success;
+    private String message;
+}

image-service/src/main/java/com/stackbytes/services/ImageService.java

@@ -0,0 +1,169 @@
+package com.stackbytes.services;
+
+import com.stackbytes.models.Image;
+import com.stackbytes.models.dto.InsertImageResponseDto;
+import io.minio.MinioClient;
+import io.minio.PutObjectArgs;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+@Service
+public class ImageService {
+
+    private final MinioClient minioClient;
+
+    private final MongoTemplate mongoTemplate;
+
+    private final ReduceSizeService reduceSizeService;
+    public ImageService(MinioClient minioClient, MongoTemplate mongoTemplate, ReduceSizeService reduceSizeService) {
+        this.minioClient = minioClient;
+        this.mongoTemplate = mongoTemplate;
+        this.reduceSizeService = reduceSizeService;
+    }
+
+    public InsertImageResponseDto insertImage(MultipartFile multipartFile, String name, boolean isProfilePicture) {
+
+        if(multipartFile == null){
+            return InsertImageResponseDto.builder().success(false).message("Multipart file is null").build();
+        }
+
+        String contentType = multipartFile.getContentType();
+
+        if(contentType == null || !contentType.startsWith("image")){
+            return InsertImageResponseDto.builder().success(false).message("Invalid content type").build();
+        }
+
+        if(isProfilePicture) {
+            Image image = Image.builder().name(name).build();
+            Image insertedImage = mongoTemplate.insert(image);
+            try {
+                minioClient.putObject(
+                  PutObjectArgs.builder()
+                          .bucket("profile-pictures")
+                          .stream(multipartFile.getInputStream(), multipartFile.getSize(), -1)
+                          .contentType(contentType)
+                          .object(insertedImage.getId())
+                            .build()
+                );
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+            return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+        } else {
+            Image image = Image.builder().name(name).build();
+            Image insertedImage = mongoTemplate.insert(image);
+            try {
+                minioClient.putObject(
+                  PutObjectArgs.builder()
+                          .bucket("others")
+                          .stream(multipartFile.getInputStream(), multipartFile.getSize(), -1)
+                          .contentType(contentType)
+                          .object(insertedImage.getId())
+                            .build()
+                );
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+            return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+        }
+    }
+
+    public InsertImageResponseDto insertReducedImage(MultipartFile multipartFile, String name, boolean isProfilePicture) {
+        if(multipartFile == null){
+            return InsertImageResponseDto.builder().success(false).message("Multipart file is null").build();
+        }
+
+        String contentType = multipartFile.getContentType();
+
+        if(contentType == null || !contentType.startsWith("image")){
+            return InsertImageResponseDto.builder().success(false).message("Invalid content type").build();
+        }
+
+        if(isProfilePicture) {
+            Image image = Image.builder().name(name).build();
+            Image insertedImage = mongoTemplate.insert(image);
+
+            try {
+                MultipartFile reducedImage = reduceSizeService.reduceSize(multipartFile);
+                minioClient.putObject(
+                  PutObjectArgs.builder()
+                          .bucket("profile-pictures-reduced")
+                          .stream(reducedImage.getInputStream(), reducedImage.getSize(), -1)
+                          .contentType(contentType)
+                          .object(insertedImage.getId())
+                            .build()
+                );
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+            return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+        } else {
+            Image image = Image.builder().name(name).build();
+            Image insertedImage = mongoTemplate.insert(image);
+
+            try {
+                MultipartFile reducedImage = reduceSizeService.reduceSize(multipartFile);
+
+                minioClient.putObject(
+                        PutObjectArgs.builder()
+                                .bucket("others-reduced")
+                                .stream(reducedImage.getInputStream(), reducedImage.getSize(), -1) // Pass the size explicitly
+                                .contentType(reducedImage.getContentType())
+                                .object(insertedImage.getId())
+                                .build()
+                );
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+            return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+        }
+    }
+
+    public InsertImageResponseDto insertAvatarImage(MultipartFile multipartFile, String name, boolean reduced) {
+
+        if(multipartFile == null){
+            return InsertImageResponseDto.builder().success(false).message("Multipart file is null").build();
+        }
+
+        String contentType = multipartFile.getContentType();
+
+        if(contentType == null || !contentType.startsWith("image")){
+            return InsertImageResponseDto.builder().success(false).message("Invalid content type").build();
+        }
+
+        Image image = Image.builder().name(name).build();
+        Image insertedImage = mongoTemplate.insert(image);
+
+        if(reduced) {
+            try {
+                MultipartFile reducedImage = reduceSizeService.reduceSize(multipartFile);
+                minioClient.putObject(
+                  PutObjectArgs.builder()
+                          .bucket("avatars-reduced")
+                          .stream(reducedImage.getInputStream(), reducedImage.getSize(), -1)
+                          .contentType(contentType)
+                          .object(insertedImage.getId())
+                            .build()
+                );
+                return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+        } else {
+            try {
+                minioClient.putObject(
+                  PutObjectArgs.builder()
+                          .bucket("avatars")
+                          .stream(multipartFile.getInputStream(), multipartFile.getSize(), -1)
+                          .contentType(contentType)
+                          .object(insertedImage.getId())
+                            .build()
+                );
+                return InsertImageResponseDto.builder().success(true).message(insertedImage.getId()).build();
+            } catch (Exception e) {
+                return InsertImageResponseDto.builder().success(false).message("Error : " + e.getMessage()).build();
+            }
+        }
+    }
+}