email event listeners and update names of data files (#47)

commons/src/main/java/io/flowinquiry/modules/teams/service/TeamService.java

@@ -7,6 +7,7 @@
 import io.flowinquiry.modules.teams.repository.TeamRepository;
 import io.flowinquiry.modules.teams.repository.TeamRoleRepository;
 import io.flowinquiry.modules.teams.service.dto.TeamDTO;
+import io.flowinquiry.modules.teams.service.event.NewTeamCreatedEvent;
 import io.flowinquiry.modules.teams.service.event.NewUsersAddedIntoTeamEvent;
 import io.flowinquiry.modules.teams.service.event.RemoveUserOutOfTeamEvent;
 import io.flowinquiry.modules.teams.service.mapper.TeamMapper;
@@ -67,7 +68,9 @@ public TeamService(
 
     public TeamDTO createTeam(TeamDTO teamDTO) {
         Team team = teamMapper.toEntity(teamDTO);
-        return teamMapper.toDto(teamRepository.save(team));
+        TeamDTO savedTeam = teamMapper.toDto(teamRepository.save(team));
+        eventPublisher.publishEvent(new NewTeamCreatedEvent(this, savedTeam));
+        return savedTeam;
     }
 
     public TeamDTO updateTeam(TeamDTO updatedTeam) {

commons/src/main/java/io/flowinquiry/modules/teams/service/event/NewTeamCreatedEvent.java

@@ -0,0 +1,15 @@
+package io.flowinquiry.modules.teams.service.event;
+
+import io.flowinquiry.modules.teams.service.dto.TeamDTO;
+import lombok.Getter;
+import org.springframework.context.ApplicationEvent;
+
+@Getter
+public class NewTeamCreatedEvent extends ApplicationEvent {
+    private final TeamDTO team;
+
+    public NewTeamCreatedEvent(Object source, TeamDTO team) {
+        super(source);
+        this.team = team;
+    }
+}

commons/src/main/java/io/flowinquiry/modules/teams/service/event/NewTeamRequestCreatedEvent.java

@@ -6,7 +6,7 @@
 
 @Getter
 public class NewTeamRequestCreatedEvent extends ApplicationEvent {
-    private TeamRequestDTO teamRequest;
+    private final TeamRequestDTO teamRequest;
 
     public NewTeamRequestCreatedEvent(Object source, TeamRequestDTO teamRequest) {
         super(source);

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewTeamCreatedEventListener.java

@@ -0,0 +1,18 @@
+package io.flowinquiry.modules.teams.service.listener;
+
+import io.flowinquiry.modules.teams.service.event.NewTeamRequestCreatedEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+public class NewTeamCreatedEventListener {
+
+    @Async("auditLogExecutor")
+    @Transactional
+    @EventListener
+    public void onNewTeamCreated(NewTeamRequestCreatedEvent event) {
+
+    }
+}

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewTeamRequestCreatedMailEventListener.java

@@ -0,0 +1,30 @@
+package io.flowinquiry.modules.teams.service.listener;
+
+import io.flowinquiry.config.FlowInquiryProperties;
+import io.flowinquiry.modules.collab.service.MailService;
+import io.flowinquiry.modules.teams.service.dto.TeamRequestDTO;
+import io.flowinquiry.modules.teams.service.event.NewTeamRequestCreatedEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+public class NewTeamRequestCreatedMailEventListener {
+
+    private final MailService mailService;
+    private final FlowInquiryProperties flowInquiryProperties;
+
+    public NewTeamRequestCreatedMailEventListener(MailService mailService, FlowInquiryProperties flowInquiryProperties) {
+        this.mailService = mailService;
+        this.flowInquiryProperties = flowInquiryProperties;
+    }
+
+    @Async("auditLogExecutor")
+    @Transactional
+    @EventListener
+    public void onNewTeamRequestCreated(NewTeamRequestCreatedEvent event) {
+        TeamRequestDTO teamRequestDTO = event.getTeamRequest();
+
+    }
+}

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewTeamRequestCreatedEventListener.java → commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewTeamRequestCreatedNotificationEventListener.java

@@ -23,12 +23,13 @@
 import static j2html.TagCreator.text;
 
 @Component
-public class NewTeamRequestCreatedEventListener {
+public class NewTeamRequestCreatedNotificationEventListener {
     private final NotificationRepository notificationRepository;
     private final TeamRepository teamRepository;
     private final ActivityLogRepository activityLogRepository;
 
-    public NewTeamRequestCreatedEventListener(
+
+    public NewTeamRequestCreatedNotificationEventListener(
             NotificationRepository notificationRepository,
             TeamRepository teamRepository,
             ActivityLogRepository activityLogRepository) {

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewUserAddedIntoTeamEmailEventListener.java

@@ -0,0 +1,18 @@
+package io.flowinquiry.modules.teams.service.listener;
+
+import io.flowinquiry.modules.teams.service.event.NewUsersAddedIntoTeamEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+public class NewUserAddedIntoTeamEmailEventListener {
+
+    @Async("auditLogExecutor")
+    @EventListener
+    @Transactional
+    public void onNewUsersAddedIntoTeam(NewUsersAddedIntoTeamEvent event) {
+
+    }
+}

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewUserAddedIntoTeamEventListener.java → commons/src/main/java/io/flowinquiry/modules/teams/service/listener/NewUserAddedIntoTeamNotificationEventListener.java

@@ -26,13 +26,13 @@
 import static j2html.TagCreator.ul;
 
 @Component
-public class NewUserAddedIntoTeamEventListener {
+public class NewUserAddedIntoTeamNotificationEventListener {
 
-    private ActivityLogRepository activityLogRepository;
-    private TeamRepository teamRepository;
-    private UserRepository userRepository;
+    private final ActivityLogRepository activityLogRepository;
+    private final TeamRepository teamRepository;
+    private final UserRepository userRepository;
 
-    public NewUserAddedIntoTeamEventListener(
+    public NewUserAddedIntoTeamNotificationEventListener(
             ActivityLogRepository activityLogRepository,
             TeamRepository teamRepository,
             UserRepository userRepository) {

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/RemoveUserOutOfTeamEmailEventListener.java

@@ -0,0 +1,18 @@
+package io.flowinquiry.modules.teams.service.listener;
+
+import io.flowinquiry.modules.teams.service.event.RemoveUserOutOfTeamEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+@Component
+public class RemoveUserOutOfTeamEmailEventListener {
+
+    @Async("auditLogExecutor")
+    @EventListener
+    @Transactional
+    public void onRemoveUserOutOfTeam(RemoveUserOutOfTeamEvent event) {
+
+    }
+}

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/RemoveUserOutOfTeamEventListener.java → commons/src/main/java/io/flowinquiry/modules/teams/service/listener/RemoveUserOutOfTeamNotificationEventListener.java

@@ -20,15 +20,13 @@
 import org.springframework.transaction.annotation.Transactional;
 
 @Component
-public class RemoveUserOutOfTeamEventListener {
+public class RemoveUserOutOfTeamNotificationEventListener {
 
     private final TeamRepository teamRepository;
-
     private final UserRepository userRepository;
-
     private final ActivityLogRepository activityLogRepository;
 
-    public RemoveUserOutOfTeamEventListener(
+    public RemoveUserOutOfTeamNotificationEventListener(
             TeamRepository teamRepository,
             UserRepository userRepository,
             ActivityLogRepository activityLogRepository) {

commons/src/main/java/io/flowinquiry/modules/teams/service/listener/TeamRequestWorkStateTransitionEventListener.java

@@ -25,11 +25,8 @@
 public class TeamRequestWorkStateTransitionEventListener {
 
     private final ActivityLogRepository activityLogRepository;
-
     private final TeamRequestRepository teamRequestRepository;
-
     private final WorkflowStateRepository workflowStateRepository;
-
     private final WorkflowTransitionHistoryService workflowTransitionHistoryService;
 
     public TeamRequestWorkStateTransitionEventListener(

tools/liquibase/src/main/resources/config/liquibase/tenant/changelog/000_initial_schema.xml

@@ -357,13 +357,13 @@
 	<changeSet author="flowinquiry"
 		id="000:05-insert-default-user-authority-data" context="dev,test">
 		<loadData
-			file="config/liquibase/tenant/data/fw_user_authority.csv"
+			file="config/liquibase/tenant/data/fw_user_authority_dev.csv"
 			separator=";" tableName="fw_user_authority"
 			usePreparedStatements="true">
 			<column name="user_id" type="numeric" />
 		</loadData>
 		<loadData
-			file="config/liquibase/tenant/data/fw_organization.csv"
+			file="config/liquibase/tenant/data/fw_organization_dev.csv"
 			tableName="fw_organization" usePreparedStatements="true"
 			separator=";">
 			<column name="id" type="NUMERIC" />
@@ -383,22 +383,10 @@
 			usePreparedStatements="true">
 			<column name="user_id" type="numeric" />
 		</loadData>
-		<loadData
-			file="config/liquibase/tenant/data/fw_organization.csv"
-			tableName="fw_organization" usePreparedStatements="true"
-			separator=";">
-			<column name="id" type="NUMERIC" />
-			<column name="name" type="STRING" />
-			<column name="logo_url" type="STRING" />
-			<column name="slogan" type="STRING" />
-			<column name="description" type="STRING" />
-		</loadData>
-		<sql>SELECT setval('fw_organization_id_seq', (SELECT MAX(id) FROM
-			fw_organization));</sql>
 	</changeSet>
 	<changeSet author="flowinquiry"
 		id="000:06-insert-default-fw-team-data" context="dev,test">
-		<loadData file="config/liquibase/tenant/data/fw_team.csv"
+		<loadData file="config/liquibase/tenant/data/fw_team_dev.csv"
 			tableName="fw_team" separator=";">
 			<column name="id" type="NUMERIC" />
 			<column name="name" type="STRING" />
@@ -421,7 +409,7 @@
 	<changeSet author="flowinquiry"
 		id="000:08-insert-default-fw-user-team-data" context="dev,test">
 		<loadData
-			file="config/liquibase/tenant/data/fw_user_team.csv"
+			file="config/liquibase/tenant/data/fw_user_team_dev.csv"
 			tableName="fw_user_team" separator=";">
 			<column name="user_id" type="NUMERIC" />
 			<column name="team_id" type="NUMERIC" />

tools/liquibase/src/main/resources/config/liquibase/tenant/changelog/001_request_workflow_tables.xml

@@ -355,8 +355,9 @@
 	</changeSet>
 	<changeSet author="flowinquiry"
 		id="001:01-insert-workflow-data" context="dev,test">
-		<loadData file="config/liquibase/tenant/data/fw_workflow.csv"
-			separator=";" tableName="fw_workflow" usePreparedStatements="true">
+		<loadData
+			file="config/liquibase/tenant/data/fw_workflow_dev.csv" separator=";"
+			tableName="fw_workflow" usePreparedStatements="true">
 			<column name="id" type="numeric" />
 			<column name="name" type="string" />
 			<column name="description" type="string" />
@@ -368,7 +369,7 @@
 	<changeSet author="flowinquiry"
 		id="001:02-insert-workflow-state-data" context="dev,test">
 		<loadData
-			file="config/liquibase/tenant/data/fw_workflow_state.csv"
+			file="config/liquibase/tenant/data/fw_workflow_state_dev.csv"
 			separator=";" tableName="fw_workflow_state"
 
 			usePreparedStatements="true">
@@ -384,7 +385,7 @@
 	<changeSet author="flowinquiry"
 		id="001:03-insert-workflow-transition-data" context="dev,test">
 		<loadData
-			file="config/liquibase/tenant/data/fw_workflow_transition.csv"
+			file="config/liquibase/tenant/data/fw_workflow_transition_dev.csv"
 			separator=";" tableName="fw_workflow_transition"
 			usePreparedStatements="true">
 			<column name="id" type="numeric" />
@@ -400,7 +401,7 @@
 	<changeSet author="flowinquiry"
 		id="001:04-insert-team-workflow-usage-data" context="dev,test">
 		<loadData
-			file="config/liquibase/tenant/data/fw_team_workflow_selection.csv"
+			file="config/liquibase/tenant/data/fw_team_workflow_selection_dev.csv"
 			separator=";" tableName="fw_team_workflow_selection"
 			usePreparedStatements="true">
 			<column name="id" type="numeric" />