implement registration in domain model and repository

Author: jamesjieye

pom.xml

@@ -57,6 +57,11 @@
       <artifactId>spring-boot-starter-test</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>com.h2database</groupId>
+      <artifactId>h2</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>

src/main/java/com/taskagile/domain/application/commands/RegistrationCommand.java

@@ -1,12 +1,18 @@
 package com.taskagile.domain.application.commands;
 
+import org.springframework.util.Assert;
+
 public class RegistrationCommand {
 
   private String username;
   private String emailAddress;
   private String password;
 
   public RegistrationCommand(String username, String emailAddress, String password) {
+    Assert.hasText(username, "Parameter `username` must not be empty");
+    Assert.hasText(emailAddress, "Parameter `emailAddress` must not be empty");
+    Assert.hasText(password, "Parameter `password` must not be empty");
+
     this.username = username;
     this.emailAddress = emailAddress;
     this.password = password;

src/main/java/com/taskagile/domain/application/impl/UserServiceImpl.java

@@ -2,15 +2,52 @@
 
 import com.taskagile.domain.application.UserService;
 import com.taskagile.domain.application.commands.RegistrationCommand;
+import com.taskagile.domain.common.event.DomainEventPublisher;
+import com.taskagile.domain.common.mail.MailManager;
+import com.taskagile.domain.common.mail.MessageVariable;
 import com.taskagile.domain.model.user.RegistrationException;
+import com.taskagile.domain.model.user.RegistrationManagement;
+import com.taskagile.domain.model.user.User;
+import com.taskagile.domain.model.user.events.UserRegisteredEvent;
 import org.springframework.stereotype.Service;
+import org.springframework.util.Assert;
+
+import javax.transaction.Transactional;
 
 @Service
+@Transactional
 public class UserServiceImpl implements UserService {
 
+  private RegistrationManagement registrationManagement;
+  private DomainEventPublisher domainEventPublisher;
+  private MailManager mailManager;
+
+  public UserServiceImpl(RegistrationManagement registrationManagement,
+                         DomainEventPublisher domainEventPublisher,
+                         MailManager mailManager) {
+    this.registrationManagement = registrationManagement;
+    this.domainEventPublisher = domainEventPublisher;
+    this.mailManager = mailManager;
+  }
+
   @Override
   public void register(RegistrationCommand command) throws RegistrationException {
-    // TODO implement this
+    Assert.notNull(command, "Parameter `command` must not be null");
+    User newUser = registrationManagement.register(
+      command.getUsername(),
+      command.getEmailAddress(),
+      command.getPassword());
+
+    sendWelcomeMessage(newUser);
+    domainEventPublisher.publish(new UserRegisteredEvent(newUser));
   }
 
+  private void sendWelcomeMessage(User user) {
+    mailManager.send(
+      user.getEmailAddress(),
+      "Welcome to TaskAgile",
+      "welcome.ftl",
+      MessageVariable.from("user", user)
+    );
+  }
 }

src/main/java/com/taskagile/domain/common/event/DefaultDomainEventPublisher.java

@@ -0,0 +1,24 @@
+package com.taskagile.domain.common.event;
+
+import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.stereotype.Component;
+
+/**
+ * The default implementation of DomainEventPublisher that
+ * bases on Spring Application Event
+ */
+@Component
+public class DefaultDomainEventPublisher implements DomainEventPublisher {
+
+  private ApplicationEventPublisher actualPublisher;
+
+  public DefaultDomainEventPublisher(ApplicationEventPublisher actualPublisher) {
+    this.actualPublisher = actualPublisher;
+  }
+
+  @Override
+  public void publish(DomainEvent event) {
+    actualPublisher.publishEvent(event);
+  }
+
+}

src/main/java/com/taskagile/domain/common/event/DomainEvent.java

@@ -0,0 +1,23 @@
+package com.taskagile.domain.common.event;
+
+import org.springframework.context.ApplicationEvent;
+
+/**
+ * Domain event
+ */
+public abstract class DomainEvent extends ApplicationEvent {
+
+  private static final long serialVersionUID = -444783093811334147L;
+
+  public DomainEvent(Object source) {
+    super(source);
+  }
+
+  /**
+   * Get the timestamp this event occurred
+   */
+  public long occurredAt() {
+    // Return the underlying implementation's timestamp
+    return getTimestamp();
+  }
+}

src/main/java/com/taskagile/domain/common/event/DomainEventPublisher.java

@@ -0,0 +1,9 @@
+package com.taskagile.domain.common.event;
+
+public interface DomainEventPublisher {
+
+  /**
+   * Publish a domain event
+   */
+  void publish(DomainEvent event);
+}

src/main/java/com/taskagile/domain/common/mail/DefaultMailManager.java

@@ -0,0 +1,12 @@
+package com.taskagile.domain.common.mail;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class DefaultMailManager implements MailManager {
+
+  @Override
+  public void send(String emailAddress, String subject, String template, MessageVariable... variables) {
+    // TODO implement this
+  }
+}

src/main/java/com/taskagile/domain/common/mail/MailManager.java

@@ -0,0 +1,14 @@
+package com.taskagile.domain.common.mail;
+
+public interface MailManager {
+
+  /**
+   * Send a message to a recipient
+   *
+   * @param emailAddress the recipient's email address
+   * @param subject the subject key of the email
+   * @param template the template file name of the email
+   * @param variables message variables in the template file
+   */
+  void send(String emailAddress, String subject, String template, MessageVariable... variables);
+}

src/main/java/com/taskagile/domain/common/mail/MessageVariable.java

@@ -0,0 +1,47 @@
+package com.taskagile.domain.common.mail;
+
+import java.util.Objects;
+
+public class MessageVariable {
+  private String key;
+  private Object value;
+
+  private MessageVariable(String key, Object value) {
+    this.key = key;
+    this.value = value;
+  }
+
+  public static MessageVariable from(String key, Object value) {
+    return new MessageVariable(key, value);
+  }
+
+  public String getKey() {
+    return key;
+  }
+
+  public Object getValue() {
+    return value;
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) return true;
+    if (!(o instanceof MessageVariable)) return false;
+    MessageVariable that = (MessageVariable) o;
+    return Objects.equals(key, that.key) &&
+      Objects.equals(value, that.value);
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(key, value);
+  }
+
+  @Override
+  public String toString() {
+    return "MessageVariable{" +
+      "key='" + key + '\'' +
+      ", value=" + value +
+      '}';
+  }
+}

src/main/java/com/taskagile/domain/common/model/AbstractBaseEntity.java

@@ -0,0 +1,15 @@
+package com.taskagile.domain.common.model;
+
+import java.io.Serializable;
+
+public abstract class AbstractBaseEntity implements Serializable {
+
+  private static final long serialVersionUID = -1153931912966528994L;
+
+  public abstract boolean equals(Object obj);
+
+  public abstract int hashCode();
+
+  public abstract String toString();
+
+}