implement tracking activity with amqp

Author: jamesjieye

front-end/src/modals/CardModal.vue

@@ -33,7 +33,7 @@
                 <div class="description" v-show="description && !editingDescription" v-html="descriptionHtml"></div>
               </div>
             </div>
-            <div class="wrapper attachments-wrapper" v-show="attachments.length">
+            <div class="wrapper attachments-wrapper" v-show="attachments.length || uploadingCount">
               <h5><font-awesome-icon icon="paperclip" class="icon"/> <span>Attachments</span></h5>
               <div class="wrapper-body">
                 <div class="uploading" v-show="uploadingCount"><font-awesome-icon icon="spinner" class="fa-spin" spin/>Uploading...</div>

pom.xml

@@ -65,6 +65,10 @@
         </exclusion>
       </exclusions>
     </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-amqp</artifactId>
+    </dependency>
     <dependency>
       <groupId>mysql</groupId>
       <artifactId>mysql-connector-java</artifactId>

setup/2.refactoring-database.sql

@@ -15,6 +15,9 @@ ALTER TABLE `task_agile`.`card` ADD CONSTRAINT `fk_card_board_board_id`
 ALTER TABLE `task_agile`.`activity` CHANGE COLUMN `board_id` `board_id` INT(11) NULL  COMMENT '' AFTER `card_id`;
 -- Change type to support integer value other than 0, 1
 ALTER TABLE `task_agile`.`activity` CHANGE COLUMN `type` `type` INT(11) NOT NULL COMMENT '' AFTER `board_id`;
+-- Add `ip_address` to activity table
+ALTER TABLE `task_agile`.`activity` ADD COLUMN `ip_address` VARCHAR(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' AFTER `detail`;
+
 -- Change file_type to be a varchar
 ALTER TABLE `task_agile`.`attachment` CHANGE COLUMN `file_type` `file_type` VARCHAR(32) NOT NULL DEFAULT ''  COMMENT '' AFTER `file_path`;
 -- Add thumbnail_created to attachment

src/main/java/com/taskagile/config/MessageConfiguration.java

@@ -0,0 +1,27 @@
+package com.taskagile.config;
+
+import org.springframework.amqp.core.Binding;
+import org.springframework.amqp.core.BindingBuilder;
+import org.springframework.amqp.core.FanoutExchange;
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MessageConfiguration {
+
+  @Bean
+  public FanoutExchange domainEventsExchange() {
+    return new FanoutExchange("ta.domain.events", true, false);
+  }
+
+  @Bean
+  public Queue activityTrackingQueue() {
+    return new Queue("ta.activity.tracking", true);
+  }
+
+  @Bean
+  public Binding bindingActivityTracking(FanoutExchange exchange, Queue activityTrackingQueue) {
+    return BindingBuilder.bind(activityTrackingQueue).to(exchange);
+  }
+}

src/main/java/com/taskagile/domain/application/ActivityService.java

@@ -0,0 +1,13 @@
+package com.taskagile.domain.application;
+
+import com.taskagile.domain.model.activity.Activity;
+
+public interface ActivityService {
+
+  /**
+   * Save an activity
+   *
+   * @param activity the activity instance
+   */
+  void saveActivity(Activity activity);
+}

src/main/java/com/taskagile/domain/application/BoardService.java

@@ -1,5 +1,6 @@
 package com.taskagile.domain.application;
 
+import com.taskagile.domain.application.commands.AddBoardMemberCommand;
 import com.taskagile.domain.application.commands.CreateBoardCommand;
 import com.taskagile.domain.model.board.Board;
 import com.taskagile.domain.model.board.BoardId;
@@ -47,10 +48,9 @@ public interface BoardService {
   /**
    * Add board member
    *
-   * @param boardId id of the board
-   * @param usernameOrEmailAddress username or email address
+   * @param command the command instance
    * @return newly added member user
    * @throws UserNotFoundException user by the usernameOrEmailAddress not found
    */
-  User addMember(BoardId boardId, String usernameOrEmailAddress) throws UserNotFoundException;
+  User addMember(AddBoardMemberCommand command) throws UserNotFoundException;
 }

src/main/java/com/taskagile/domain/application/TeamService.java

@@ -1,7 +1,6 @@
 package com.taskagile.domain.application;
 
 import com.taskagile.domain.application.commands.CreateTeamCommand;
-import com.taskagile.domain.model.board.Board;
 import com.taskagile.domain.model.team.Team;
 import com.taskagile.domain.model.team.TeamId;
 import com.taskagile.domain.model.user.UserId;

src/main/java/com/taskagile/domain/application/UserService.java

@@ -1,6 +1,6 @@
 package com.taskagile.domain.application;
 
-import com.taskagile.domain.application.commands.RegistrationCommand;
+import com.taskagile.domain.application.commands.RegisterCommand;
 import com.taskagile.domain.model.user.RegistrationException;
 import com.taskagile.domain.model.user.User;
 import com.taskagile.domain.model.user.UserId;
@@ -19,10 +19,10 @@ public interface UserService extends UserDetailsService {
   /**
    * Register a new user with username, email address, and password.
    *
-   * @param command instance of <code>RegistrationCommand</code>
+   * @param command instance of <code>RegisterCommand</code>
    * @throws RegistrationException when registration failed. Possible reasons are:
    *                               1) Username already exists
    *                               2) Email address already exists.
    */
-  void register(RegistrationCommand command) throws RegistrationException;
+  void register(RegisterCommand command) throws RegistrationException;
 }

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

@@ -0,0 +1,22 @@
+package com.taskagile.domain.application.commands;
+
+import com.taskagile.domain.model.board.BoardId;
+
+public class AddBoardMemberCommand extends UserCommand {
+
+  private BoardId boardId;
+  private String usernameOrEmailAddress;
+
+  public AddBoardMemberCommand(BoardId boardId, String usernameOrEmailAddress) {
+    this.boardId = boardId;
+    this.usernameOrEmailAddress = usernameOrEmailAddress;
+  }
+
+  public BoardId getBoardId() {
+    return boardId;
+  }
+
+  public String getUsernameOrEmailAddress() {
+    return usernameOrEmailAddress;
+  }
+}

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

@@ -1,19 +1,16 @@
 package com.taskagile.domain.application.commands;
 
 import com.taskagile.domain.model.card.CardId;
-import com.taskagile.domain.model.user.UserId;
 import org.springframework.web.multipart.MultipartFile;
 
-public class AddCardAttachmentCommand {
+public class AddCardAttachmentCommand extends UserCommand {
 
   private CardId cardId;
   private MultipartFile file;
-  private UserId userId;
 
-  public AddCardAttachmentCommand(long cardId, MultipartFile file, UserId userId) {
+  public AddCardAttachmentCommand(long cardId, MultipartFile file) {
     this.cardId = new CardId(cardId);
     this.file = file;
-    this.userId = userId;
   }
 
   public CardId getCardId() {
@@ -23,8 +20,4 @@ public CardId getCardId() {
   public MultipartFile getFile() {
     return file;
   }
-
-  public UserId getUserId() {
-    return userId;
-  }
 }