end2end

src/main/java/net/dancier/kikeriki/adapter/out/userinfo/UserInfoAdapter.java

@@ -0,0 +1,16 @@
+package net.dancier.kikeriki.adapter.out.userinfo;
+
+import net.dancier.kikeriki.application.port.UserInfoDto;
+import net.dancier.kikeriki.application.port.UserInfoPort;
+import org.springframework.stereotype.Component;
+
+@Component
+public class UserInfoAdapter implements UserInfoPort {
+ @Override
+ public UserInfoDto loadByDancerId(String dancerId) {
+ UserInfoDto userInfoDto = new UserInfoDto();
+ userInfoDto.setDancerId(dancerId);
+ userInfoDto.setEmailAddress("[email protected]");
+ return userInfoDto;
+ }
+}

src/main/java/net/dancier/kikeriki/application/CheckAndSendService.java

@@ -2,13 +2,17 @@
 
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
+import net.dancier.kikeriki.adapter.out.userinfo.UserInfoAdapter;
+import net.dancier.kikeriki.application.domain.model.messages.EmailSendingRequestedCommand;
 import net.dancier.kikeriki.application.domain.model.state.State;
 import net.dancier.kikeriki.application.port.StatePort;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
+import java.util.UUID;
 
 @Component
 @RequiredArgsConstructor
@@ -17,6 +21,10 @@ public class CheckAndSendService {
 
  private final StatePort statePort;
 
+ private final UserInfoAdapter userInfoAdapter;
+
+ private ApplicationEventPublisher applicationEventPublisher;
+
  @Transactional
  public void checkAndSend(String dancerId) {
  log.info("CheckAndSend for {}", dancerId);
@@ -28,5 +36,15 @@ public void checkAndSend(String dancerId) {
  }
  public void sendMail(String dancerId) {
  log.info("Sending InfoMail...");
+ String mailAddress = userInfoAdapter.loadByDancerId(dancerId).getEmailAddress();
+ EmailSendingRequestedCommand emailSendingRequestedCommand =
+ new EmailSendingRequestedCommand.EmailSendingRequestedCommandBuilder()
+ .setFrom("[email protected]")
+ .setId(UUID.randomUUID().toString())
+ .setTo(new String[]{mailAddress})
+ .setSubject("Infomail")
+ .setText("Hallo Welt")
+ .build();
+ applicationEventPublisher.publishEvent(emailSendingRequestedCommand);
  }
 }

src/main/java/net/dancier/kikeriki/application/port/UserInfoDto.java

@@ -0,0 +1,12 @@
+package net.dancier.kikeriki.application.port;
+
+import lombok.Data;
+
+@Data
+public class UserInfoDto {
+
+ private String dancerId;
+
+ private String emailAddress;
+
+}