further refactor of eventhandling
Co-Authored-By: Talha Caliskan <killerber4t@users.noreply.github.com> Co-Authored-By: tomvahl <tomvahl@users.noreply.github.com> Co-Authored-By: xxnitram <xxnitram@users.noreply.github.com> Co-Authored-By: kasch309 <kasch309@users.noreply.github.com>
This commit is contained in:
@ -21,7 +21,7 @@ public class Group {
|
|||||||
private long id;
|
private long id;
|
||||||
private String title;
|
private String title;
|
||||||
private String description;
|
private String description;
|
||||||
private final List<User> members;
|
public List<User> members;
|
||||||
private final Map<String, Role> roles;
|
private final Map<String, Role> roles;
|
||||||
|
|
||||||
private GroupType type;
|
private GroupType type;
|
||||||
|
|||||||
@ -24,7 +24,8 @@ public class AddUserEvent extends Event {
|
|||||||
this.email = email;
|
this.email = email;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void apply(Group group, User user) {
|
public void apply(Group group) {
|
||||||
|
User user = new User(this.user_id, this.givenname, this.familyname, this.email);
|
||||||
group.getMembers().add(user);
|
group.getMembers().add(user);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -3,19 +3,27 @@ package mops.gruppen2.domain.event;
|
|||||||
import lombok.*;
|
import lombok.*;
|
||||||
import mops.gruppen2.domain.Group;
|
import mops.gruppen2.domain.Group;
|
||||||
import mops.gruppen2.domain.User;
|
import mops.gruppen2.domain.User;
|
||||||
|
import mops.gruppen2.domain.Group;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Entfernt ein einzelnes Mitglied einer Gruppe.
|
* Entfernt ein einzelnes Mitglied einer Gruppe.
|
||||||
*/
|
*/
|
||||||
@Getter
|
@Getter
|
||||||
public class DeleteUserEvent extends Event {
|
public class DeleteUserEvent extends Event {
|
||||||
public DeleteUserEvent(Long group_id, String user_id) {
|
public DeleteUserEvent(Long group_id, String user_id) {
|
||||||
super(group_id, user_id);
|
super(group_id, user_id);
|
||||||
}
|
}
|
||||||
|
|
||||||
public DeleteUserEvent() {}
|
public DeleteUserEvent() {
|
||||||
|
}
|
||||||
|
|
||||||
public void apply(Group group, User user) {
|
public void apply(Group group) {
|
||||||
group.getMembers().remove(user);
|
for (User user : group.getMembers()) {
|
||||||
|
if (user.getUser_id().equals(this.user_id)) {
|
||||||
|
group.members.remove(user);
|
||||||
|
group.getRoles().remove(user);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -6,11 +6,12 @@ import lombok.AllArgsConstructor;
|
|||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import lombok.NoArgsConstructor;
|
import lombok.NoArgsConstructor;
|
||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
|
import mops.gruppen2.domain.Group;
|
||||||
|
|
||||||
|
|
||||||
@Getter
|
@Getter
|
||||||
@AllArgsConstructor
|
|
||||||
@NoArgsConstructor
|
@NoArgsConstructor
|
||||||
|
@AllArgsConstructor
|
||||||
@JsonTypeInfo(
|
@JsonTypeInfo(
|
||||||
include = JsonTypeInfo.As.PROPERTY,
|
include = JsonTypeInfo.As.PROPERTY,
|
||||||
use = JsonTypeInfo.Id.NAME,
|
use = JsonTypeInfo.Id.NAME,
|
||||||
@ -30,8 +31,5 @@ public class Event {
|
|||||||
String user_id;
|
String user_id;
|
||||||
|
|
||||||
|
|
||||||
public Event(Long group_id,String user_id){
|
public void apply(Group group){}
|
||||||
this.group_id = group_id;
|
|
||||||
this.user_id = user_id;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,6 +1,7 @@
|
|||||||
package mops.gruppen2.domain.event;
|
package mops.gruppen2.domain.event;
|
||||||
|
|
||||||
import lombok.*;
|
import lombok.*;
|
||||||
|
import mops.gruppen2.domain.Exceptions.EventException;
|
||||||
import mops.gruppen2.domain.Exceptions.UserNotFoundException;
|
import mops.gruppen2.domain.Exceptions.UserNotFoundException;
|
||||||
import mops.gruppen2.domain.Group;
|
import mops.gruppen2.domain.Group;
|
||||||
import mops.gruppen2.domain.Role;
|
import mops.gruppen2.domain.Role;
|
||||||
@ -17,19 +18,14 @@ import java.util.Optional;
|
|||||||
public class UpdateRoleEvent extends Event {
|
public class UpdateRoleEvent extends Event {
|
||||||
|
|
||||||
Role newRole;
|
Role newRole;
|
||||||
|
|
||||||
public UpdateRoleEvent(Long event_id, Long group_id, String user_id, Role newRole) {
|
|
||||||
super(event_id, group_id, user_id);
|
|
||||||
this.newRole = newRole;
|
|
||||||
}
|
|
||||||
|
|
||||||
public UpdateRoleEvent(Long group_id, String user_id, Role newRole) {
|
public UpdateRoleEvent(Long group_id, String user_id, Role newRole) {
|
||||||
super(group_id, user_id);
|
super(group_id, user_id);
|
||||||
this.newRole = newRole;
|
this.newRole = newRole;
|
||||||
}
|
}
|
||||||
|
|
||||||
private void apply(Group group) throws UserNotFoundException {
|
public void apply(Group group) {
|
||||||
User user;
|
User user = new User(user_id, null, null, null);
|
||||||
|
|
||||||
Optional<User> userOptional = group.getMembers().stream()
|
Optional<User> userOptional = group.getMembers().stream()
|
||||||
.filter(u -> u.getUser_id().equals(user_id))
|
.filter(u -> u.getUser_id().equals(user_id))
|
||||||
@ -38,7 +34,6 @@ public class UpdateRoleEvent extends Event {
|
|||||||
if (userOptional.isPresent()) {
|
if (userOptional.isPresent()) {
|
||||||
user = userOptional.get();
|
user = userOptional.get();
|
||||||
} else {
|
} else {
|
||||||
throw new UserNotFoundException("Nutzer wurde nicht gefunden!");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if (group.getRoles().containsKey(user) && newRole == Role.MEMBER) {
|
if (group.getRoles().containsKey(user) && newRole == Role.MEMBER) {
|
||||||
|
|||||||
@ -43,8 +43,8 @@ public class ControllerService {
|
|||||||
eventService.saveEventList(eventList);
|
eventService.saveEventList(eventList);
|
||||||
}
|
}
|
||||||
|
|
||||||
public void addUser(Account account, Group group){
|
/*public void addUser(Account account, Group group){
|
||||||
AddUserEvent addUserEvent = new AddUserEvent(eventService.checkGroup(),group.getId(),account.getName(),account.getGivenname(),account.getFamilyname(),account.getEmail());
|
AddUserEvent addUserEvent = new AddUserEvent(eventService.checkGroup(),group.getId(),account.getName(),account.getGivenname(),account.getFamilyname(),account.getEmail());
|
||||||
eventService.saveEvent(addUserEvent);
|
eventService.saveEvent(addUserEvent);
|
||||||
}
|
}*/
|
||||||
}
|
}
|
||||||
|
|||||||
@ -49,7 +49,8 @@ public class GroupService {
|
|||||||
Map<Long, Group> groupMap = new HashMap<>();
|
Map<Long, Group> groupMap = new HashMap<>();
|
||||||
|
|
||||||
for (Event event : events) {
|
for (Event event : events) {
|
||||||
//getOrCreateGroup(groupMap, event.getGroup_id()).applyEvent(event);
|
Group group = getOrCreateGroup(groupMap, event.getGroup_id());
|
||||||
|
event.apply(group);
|
||||||
}
|
}
|
||||||
|
|
||||||
return new ArrayList<>(groupMap.values());
|
return new ArrayList<>(groupMap.values());
|
||||||
|
|||||||
@ -73,7 +73,6 @@ public class EventBuilder {
|
|||||||
String lastname = faker.name().lastName();
|
String lastname = faker.name().lastName();
|
||||||
|
|
||||||
return new AddUserEvent(
|
return new AddUserEvent(
|
||||||
faker.random().nextLong(),
|
|
||||||
group_id,
|
group_id,
|
||||||
user_id,
|
user_id,
|
||||||
firstname,
|
firstname,
|
||||||
@ -103,7 +102,6 @@ public class EventBuilder {
|
|||||||
Faker faker = new Faker();
|
Faker faker = new Faker();
|
||||||
|
|
||||||
return new DeleteUserEvent(
|
return new DeleteUserEvent(
|
||||||
faker.random().nextLong(),
|
|
||||||
group_id,
|
group_id,
|
||||||
user_id
|
user_id
|
||||||
);
|
);
|
||||||
@ -129,7 +127,6 @@ public class EventBuilder {
|
|||||||
Faker faker = new Faker();
|
Faker faker = new Faker();
|
||||||
|
|
||||||
return new UpdateGroupDescriptionEvent(
|
return new UpdateGroupDescriptionEvent(
|
||||||
faker.random().nextLong(),
|
|
||||||
group_id,
|
group_id,
|
||||||
faker.random().hex(),
|
faker.random().hex(),
|
||||||
faker.leagueOfLegends().quote()
|
faker.leagueOfLegends().quote()
|
||||||
@ -140,7 +137,6 @@ public class EventBuilder {
|
|||||||
Faker faker = new Faker();
|
Faker faker = new Faker();
|
||||||
|
|
||||||
return new UpdateGroupTitleEvent(
|
return new UpdateGroupTitleEvent(
|
||||||
faker.random().nextLong(),
|
|
||||||
group_id,
|
group_id,
|
||||||
faker.random().hex(),
|
faker.random().hex(),
|
||||||
faker.leagueOfLegends().champion()
|
faker.leagueOfLegends().champion()
|
||||||
@ -151,7 +147,6 @@ public class EventBuilder {
|
|||||||
Faker faker = new Faker();
|
Faker faker = new Faker();
|
||||||
|
|
||||||
return new UpdateRoleEvent(
|
return new UpdateRoleEvent(
|
||||||
faker.random().nextLong(),
|
|
||||||
group_id,
|
group_id,
|
||||||
user_id,
|
user_id,
|
||||||
role
|
role
|
||||||
|
|||||||
@ -0,0 +1,33 @@
|
|||||||
|
package mops.gruppen2.domain.event;
|
||||||
|
|
||||||
|
import mops.gruppen2.domain.Group;
|
||||||
|
import mops.gruppen2.domain.User;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
|
||||||
|
import static mops.gruppen2.domain.Role.MEMBER;
|
||||||
|
import static org.assertj.core.api.Assertions.assertThat;
|
||||||
|
import static org.junit.jupiter.api.Assertions.*;
|
||||||
|
|
||||||
|
class DeleteUserEventTest {
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void apply() {
|
||||||
|
Group group = new Group();
|
||||||
|
|
||||||
|
User user = new User("user1","Stein", "Speck", "@sdasd");
|
||||||
|
|
||||||
|
group.getMembers().add(user);
|
||||||
|
group.getRoles().put("user1", MEMBER);
|
||||||
|
|
||||||
|
User user2 = new User("user2","Rock", "Roll", "and");
|
||||||
|
|
||||||
|
group.getMembers().add(user2);
|
||||||
|
group.getRoles().put("user2", MEMBER);
|
||||||
|
|
||||||
|
Event event = new DeleteUserEvent(1L, "user1");
|
||||||
|
|
||||||
|
event.apply(group);
|
||||||
|
|
||||||
|
assertThat(group.getRoles().size()).isEqualTo(1);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -23,7 +23,7 @@ class SerializationServiceTest {
|
|||||||
|
|
||||||
@Test
|
@Test
|
||||||
void serializeEventTest() throws JsonProcessingException {
|
void serializeEventTest() throws JsonProcessingException {
|
||||||
Event event = new Event(1L,1L,"1");
|
Event event = new Event(1L,"1");
|
||||||
|
|
||||||
assertThat(serializationService.serializeEvent(event)).isEqualTo("{\"type\":\"Event\",\"event_id\":1,\"group_id\":1,\"user_id\":\"1\"}");
|
assertThat(serializationService.serializeEvent(event)).isEqualTo("{\"type\":\"Event\",\"event_id\":1,\"group_id\":1,\"user_id\":\"1\"}");
|
||||||
}
|
}
|
||||||
@ -66,7 +66,7 @@ class SerializationServiceTest {
|
|||||||
|
|
||||||
@Test
|
@Test
|
||||||
void deserializeUpdateRoleEventToRightClass() throws JsonProcessingException {
|
void deserializeUpdateRoleEventToRightClass() throws JsonProcessingException {
|
||||||
System.out.println(serializationService.serializeEvent(new UpdateRoleEvent(1L, 1L, "1", Role.ADMIN)));
|
System.out.println(serializationService.serializeEvent(new UpdateRoleEvent(1L, "1", Role.ADMIN)));
|
||||||
|
|
||||||
String json = "{\"type\":\"UpdateRoleEvent\",\"event_id\":1,\"group_id\":1,\"user_id\":1,\"newRole\":\"ADMIN\"}";
|
String json = "{\"type\":\"UpdateRoleEvent\",\"event_id\":1,\"group_id\":1,\"user_id\":1,\"newRole\":\"ADMIN\"}";
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user