Enviando imagem via endpoint

Author: jdc-developer

src/main/java/jdc/loja/LojaApplication.java

@@ -1,24 +1,17 @@
 package jdc.loja;
 
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
-import jdc.loja.services.S3Service;
-
 @SpringBootApplication
 public class LojaApplication implements CommandLineRunner {
-
-	@Autowired
-	private S3Service service;
 
 	public static void main(String[] args) {
 		SpringApplication.run(LojaApplication.class, args);
 	}
 
 	@Override
 	public void run(String... args) throws Exception {
-		service.uploadFile("C:\\dbz.jpg");
 	}
 }

src/main/java/jdc/loja/config/SecurityConfig.java

@@ -47,7 +47,8 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
 	};
 
 	private static final String[] PUBLIC_MATCHERS_POST = {
-			"/clientes/**",
+			"/clientes",
+			"/clientes/picture",
 			"/auth/forgot/**"
 	};
 

src/main/java/jdc/loja/resources/ClienteResource.java

@@ -17,6 +17,7 @@
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.servlet.support.ServletUriComponentsBuilder;
 
 import jdc.loja.domain.Cliente;
@@ -83,4 +84,10 @@ public ResponseEntity<Page<ClienteDTO>> findPage(
 		Page<ClienteDTO> listDto = list.map(obj -> new ClienteDTO(obj));
 		return ResponseEntity.ok().body(listDto);
 	}
+	
+	@RequestMapping(value="/picture", method=RequestMethod.POST)
+	public ResponseEntity<Void> uploadProfilePicture(@RequestParam(name="file") MultipartFile file) {
+		URI uri = service.uploadProfilePicture(file);
+		return ResponseEntity.created(uri).build();
+	}
 }

src/main/java/jdc/loja/services/ClienteService.java

@@ -1,5 +1,6 @@
 package jdc.loja.services;
 
+import java.net.URI;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
@@ -11,6 +12,7 @@
 import org.springframework.data.domain.Sort.Direction;
 import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
 
 import jdc.loja.domain.Cidade;
 import jdc.loja.domain.Cliente;
@@ -38,6 +40,9 @@ public class ClienteService {
 	@Autowired
 	private BCryptPasswordEncoder pe;
 
+	@Autowired
+	private S3Service s3;
+	
 	public Cliente find(Integer id) {
 
 		UserSS user = UserService.authenticated();
@@ -107,4 +112,8 @@ private void updateData(Cliente newObj, Cliente obj) {
 		newObj.setNome(obj.getNome());
 		newObj.setEmail(obj.getEmail());
 	}
+	
+	public URI uploadProfilePicture(MultipartFile multipartFile) {
+		return s3.uploadFile(multipartFile);
+	}
 }

src/main/java/jdc/loja/services/S3Service.java

@@ -1,40 +1,52 @@
 package jdc.loja.services;
 
-import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URI;
+import java.net.URISyntaxException;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
 
-import com.amazonaws.AmazonClientException;
-import com.amazonaws.AmazonServiceException;
 import com.amazonaws.services.s3.AmazonS3;
-import com.amazonaws.services.s3.model.PutObjectRequest;
+import com.amazonaws.services.s3.model.ObjectMetadata;
 
 @Service
 public class S3Service {
-	
+
 	private Logger LOG = LoggerFactory.getLogger(S3Service.class);
 
 	@Autowired
 	private AmazonS3 s3client;
-	
+
 	@Value("${s3.bucket}")
 	private String bucketName;
-	
-	public void uploadFile(String localFilePath) {
+
+	public URI uploadFile(MultipartFile multipartFile) {
+		try {
+			String filename = multipartFile.getOriginalFilename();
+			InputStream is = multipartFile.getInputStream();
+			String contentType = multipartFile.getContentType();
+			return uploadFile(is, filename, contentType);
+		} catch (IOException e) {
+			throw new RuntimeException("Erro de IO: " + e.getMessage());
+		}
+	}
+
+	public URI uploadFile(InputStream is, String filename, String contentType) {
 		try {
-			File file = new File(localFilePath);
+			ObjectMetadata meta = new ObjectMetadata();
+			meta.setContentType(contentType);
 			LOG.info("Iniciando upload");
-			s3client.putObject(new PutObjectRequest(bucketName, "teste.jpg", file));
+			s3client.putObject(bucketName, filename, is, meta);
 			LOG.info("Upload finalizado");
-		} catch (AmazonServiceException e) {
-			LOG.info("AmazonServiceException: " + e.getMessage());
-			LOG.info("Status code: " + e.getErrorCode());
-		} catch (AmazonClientException e) {
-			LOG.info("AmazonClientException: " + e.getMessage());
+			return s3client.getUrl(bucketName, filename).toURI();
+		} catch (URISyntaxException e) {
+			throw new RuntimeException("Erro ao converter URL para URI");
 		}
 	}
 }