Emails idea

hla-product-ordering/backend/pom.xml

@@ -92,6 +92,11 @@
             <scope>test</scope>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-mail</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-configuration-processor</artifactId>

hla-product-ordering/backend/src/main/java/com/amigoscode/api/email/EmailController.java

@@ -0,0 +1,51 @@
+package com.amigoscode.api.email;
+
+
+import com.amigoscode.appservices.EmailApplicationService;
+import com.amigoscode.domain.email.Email;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RequiredArgsConstructor
+@RestController
+@RequestMapping(path = "/api/v1/emails",
+        produces = "application/json",
+        consumes = "application/json"
+)
+class EmailController {
+    private final EmailApplicationService emailService;
+
+    private final EmailDtoMapper emailMapper;
+
+    private final PageEmailDtoMapper pageEmailDtoMapper;
+
+    @GetMapping( path = "/{emailId}")
+    public ResponseEntity<EmailDto> getEmail(@PathVariable Integer emailId) {
+        Email email = emailService.findById(emailId);
+        return ResponseEntity
+                .ok(emailMapper.toDto(email));
+    }
+
+    @GetMapping
+    public ResponseEntity<PageEmailDto> getEmails(
+            @RequestParam(defaultValue = "0") int page,
+            @RequestParam(defaultValue = "3") int size
+    ) {
+        Pageable pageable = PageRequest.of(page, size);
+        PageEmailDto pageEmails = pageEmailDtoMapper.toPageDto(emailService.findAll(pageable));
+
+        return ResponseEntity.ok(pageEmails);
+    }
+
+    @PostMapping
+    public ResponseEntity<EmailDto> sendEmail(@RequestBody EmailDto dto){
+
+        Email sentEmail = emailService.send(emailMapper.toDomain(dto));
+        Email savedEmail = emailService.save(sentEmail);
+        return ResponseEntity
+                .ok(emailMapper.toDto(savedEmail));
+    }
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/api/email/EmailDto.java

@@ -0,0 +1,13 @@
+package com.amigoscode.api.email;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+
+public record EmailDto(
+    Integer id,
+    Integer providerId,
+    ZonedDateTime createdAt,
+    Integer userId,
+    String content,
+    List<Integer> orders
+) {}

hla-product-ordering/backend/src/main/java/com/amigoscode/api/email/EmailDtoMapper.java

@@ -0,0 +1,13 @@
+package com.amigoscode.api.email;
+
+import com.amigoscode.api.email.EmailDto;
+import com.amigoscode.domain.email.Email;
+import org.mapstruct.Mapper;
+
+@Mapper(componentModel = "spring")
+public interface EmailDtoMapper {
+
+    EmailDto toDto(Email domain);
+
+    Email toDomain(EmailDto dto);
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/api/email/PageEmailDto.java

@@ -0,0 +1,13 @@
+package com.amigoscode.api.email;
+
+import com.amigoscode.api.order.OrderDto;
+
+import java.util.List;
+
+public record PageEmailDto(
+    List<EmailDto> emails,
+    Integer currentPage,
+    Integer totalPages,
+    Long totalElements
+)
+{}

hla-product-ordering/backend/src/main/java/com/amigoscode/api/email/PageEmailDtoMapper.java

@@ -0,0 +1,26 @@
+package com.amigoscode.api.email;
+
+import com.amigoscode.api.email.EmailDto;
+import com.amigoscode.api.email.PageEmailDto;
+import com.amigoscode.domain.email.Email;
+import com.amigoscode.domain.email.PageEmail;
+import org.mapstruct.IterableMapping;
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.mapstruct.Named;
+
+import java.util.List;
+
+@Mapper(componentModel = "spring")
+public interface PageEmailDtoMapper {
+
+    @Mapping(target = "emails", qualifiedByName = "toEmailDtoList")
+    PageEmailDto toPageDto(PageEmail domain);
+
+    @Named("toEmailDtoList")
+    @IterableMapping(qualifiedByName = "emailToEmailDto")
+    List<EmailDto> toListDto(List<Email> emails);
+
+    @Named("emailToEmailDto")
+    EmailDto toDto(Email domain);
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/api/handler/CustomExceptionHandler.java

@@ -2,6 +2,8 @@
 
 
 import com.amigoscode.api.response.ErrorResponse;
+import com.amigoscode.domain.email.EmailAlreadyExistsException;
+import com.amigoscode.domain.email.EmailNotFoundException;
 import com.amigoscode.domain.patient.PatientNotFoundException;
 import com.amigoscode.domain.provider.ProviderAlreadyExistsException;
 import com.amigoscode.domain.provider.ProviderNotFoundException;
@@ -58,6 +60,16 @@ public final ResponseEntity<ErrorResponse> handleOrderAlreadyExistsException(Ord
         return buildResponse(ex, HttpStatus.CONFLICT);
     }
 
+    @ExceptionHandler(EmailNotFoundException.class)
+    public final ResponseEntity<ErrorResponse> handleEmailNotFoundException(EmailNotFoundException ex) {
+        return buildResponse(ex,  HttpStatus.NOT_FOUND);
+    }
+
+    @ExceptionHandler(EmailAlreadyExistsException.class)
+    public final ResponseEntity<ErrorResponse> handleEmailAlreadyExistsException(EmailAlreadyExistsException ex) {
+        return buildResponse(ex, HttpStatus.CONFLICT);
+    }
+
 
     @ExceptionHandler(ScheduleNotFoundException.class)
     public final ResponseEntity<ErrorResponse> handleScheduleNotFoundException(ScheduleNotFoundException ex) {

hla-product-ordering/backend/src/main/java/com/amigoscode/appservices/EmailApplicationService.java

@@ -0,0 +1,33 @@
+package com.amigoscode.appservices;
+
+import com.amigoscode.domain.email.Email;
+import com.amigoscode.domain.email.EmailNotFoundException;
+import com.amigoscode.domain.email.EmailService;
+import com.amigoscode.domain.email.PageEmail;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+public class EmailApplicationService {
+    private final EmailService emailService;
+
+    public Email findById(Integer id){
+        return emailService.findById(id);
+    }
+
+    public PageEmail findAll(Pageable pageable) { return emailService.findAll(pageable); }
+
+    @Transactional
+    public Email save(Email email) {
+        return emailService.save(email);
+    }
+
+    public Email send(Email email) {
+        return emailService.send(email);
+    }
+
+
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/config/DomainConfiguration.java

@@ -1,6 +1,8 @@
 package com.amigoscode.config;
 
-import com.amigoscode.appservices.IAuthenticationFacade;
+import com.amigoscode.domain.email.EmailRepository;
+import com.amigoscode.domain.email.EmailSender;
+import com.amigoscode.domain.email.EmailService;
 import com.amigoscode.domain.note.NoteRepository;
 import com.amigoscode.domain.note.NoteService;
 import com.amigoscode.domain.order.OrderRepository;
@@ -15,6 +17,10 @@
 import com.amigoscode.domain.user.UserService;
 import com.amigoscode.domain.version.VersionRepository;
 import com.amigoscode.domain.version.VersionService;
+import com.amigoscode.external.email.EmailSenderIAdapter;
+import com.amigoscode.external.storage.email.EmailEntityMapper;
+import com.amigoscode.external.storage.email.EmailStorageAdapter;
+import com.amigoscode.external.storage.email.JpaEmailRepository;
 import com.amigoscode.external.storage.note.JpaNoteRepository;
 import com.amigoscode.external.storage.note.NoteEntityMapper;
 import com.amigoscode.external.storage.note.NoteStorageAdapter;
@@ -38,6 +44,7 @@
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.mail.javamail.JavaMailSender;
 
 import java.time.Clock;
 
@@ -80,6 +87,20 @@ public OrderService orderService(OrderRepository orderRepository){
         return new OrderService(orderRepository);
     }
 
+    @Bean
+    public EmailRepository emailRepository(JpaEmailRepository jpaEmailRepository, EmailEntityMapper mapper){
+        return new EmailStorageAdapter(jpaEmailRepository, mapper);
+    }
+
+    @Bean
+    public EmailSender emailSender(JavaMailSender javaMailSender, ProviderService providerService){
+        return new EmailSenderIAdapter(javaMailSender, providerService);
+    }
+
+    @Bean
+    public EmailService emailService(EmailRepository emailRepository, EmailSender emailSender, OrderService orderService){
+        return new EmailService(emailRepository, emailSender, orderService);
+    }
     @Bean
     public ScheduleRepository scheduleRepository(JpaScheduleRepository jpaScheduleRepository, ScheduleEntityMapper mapper){
         return new ScheduleStorageAdapter(jpaScheduleRepository, mapper);

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/Email.java

@@ -0,0 +1,24 @@
+package com.amigoscode.domain.email;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
+
+import java.time.ZonedDateTime;
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+@ToString
+@EqualsAndHashCode
+public class Email {
+
+    private Integer id;
+    private Integer providerId;
+    private ZonedDateTime createdAt;
+    private Integer userId;
+    private String content;
+    private List<Integer> orders;
+
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/EmailAlreadyExistsException.java

@@ -0,0 +1,4 @@
+package com.amigoscode.domain.email;
+
+public class EmailAlreadyExistsException extends RuntimeException {
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/EmailNotFoundException.java

@@ -0,0 +1,4 @@
+package com.amigoscode.domain.email;
+
+public class EmailNotFoundException extends RuntimeException{
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/EmailRepository.java

@@ -0,0 +1,17 @@
+package com.amigoscode.domain.email;
+
+import com.amigoscode.domain.email.Email;
+import com.amigoscode.domain.email.PageEmail;
+import org.springframework.data.domain.Pageable;
+
+import java.util.Optional;
+
+public interface EmailRepository {
+    Optional<Email> findById(Integer id);
+
+    PageEmail findAll(Pageable pageable);
+
+    Email save(Email email);
+
+
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/EmailSender.java

@@ -0,0 +1,5 @@
+package com.amigoscode.domain.email;
+
+public interface EmailSender {
+    Email send(Email email);
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/EmailService.java

@@ -0,0 +1,65 @@
+package com.amigoscode.domain.email;
+
+import com.amigoscode.domain.order.Order;
+import com.amigoscode.domain.order.OrderService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.data.domain.Pageable;
+
+import java.util.List;
+
+@RequiredArgsConstructor
+public class EmailService {
+    private final EmailRepository emailRepository;
+    private final EmailSender emailSender;
+    private final OrderService orderService;
+
+
+    public Email findById(Integer id){
+        Email email =  emailRepository.findById(id).
+                orElseThrow(EmailNotFoundException::new);
+        List<Order> orders = orderService.findByEmailId(id);
+        email.setOrders(orders.stream().map(Order::getId).toList());
+        return email;
+    }
+
+    public PageEmail findAll(Pageable pageable) {
+        final PageEmail pageEmail = emailRepository.findAll(pageable);
+        for (Email email : pageEmail.getEmails()) {
+            List<Order> orders = orderService.findByEmailId(email.getId());
+            email.setOrders(orders.stream().map(Order::getId).toList());
+        }
+
+        return pageEmail;
+    }
+
+    public Email save(Email email) {
+        Email savedEmail = emailRepository.save(email);
+        savedEmail.setOrders(email.getOrders());
+        markOrdersAsSentByEmail(savedEmail);
+        return savedEmail;
+    }
+
+    public Email send(Email email) {
+        final String currentContent = email.getContent();
+        final List<Integer> ordersWithoutEmailId = email.getOrders()
+                .stream()
+                .filter(id -> orderService.findById(id).getEmailId() == null).toList();
+        email.setOrders(ordersWithoutEmailId);
+        // information needed to order products
+        String orderRelatedContent = email.getOrders().toString();
+        email.setContent(currentContent + " " + orderRelatedContent);
+
+        emailSender.send(email);
+
+        return email;
+    }
+
+    private void markOrdersAsSentByEmail (Email email) {
+        for (Integer id: email.getOrders()) {
+            Order order = orderService.findById(id);
+            order.setEmailId(email.getId());
+            orderService.update(order);
+        }
+    }
+
+}

hla-product-ordering/backend/src/main/java/com/amigoscode/domain/email/PageEmail.java

@@ -0,0 +1,16 @@
+package com.amigoscode.domain.email;
+
+
+import lombok.Value;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Value
+public class PageEmail implements Serializable {
+
+    List<Email> emails;
+    Integer currentPage;
+    Integer totalPages;
+    Long totalElements;
+}