package mops.gruppen2.service; import mops.gruppen2.domain.Group; import mops.gruppen2.domain.GroupType; import mops.gruppen2.domain.Visibility; import mops.gruppen2.domain.dto.EventDTO; import mops.gruppen2.domain.event.Event; import mops.gruppen2.domain.exception.EventException; import mops.gruppen2.repository.EventRepository; import mops.gruppen2.security.Account; import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; @Service public class GroupService { private final EventService eventService; private final EventRepository eventRepository; public GroupService(EventService eventService, EventRepository eventRepository) { this.eventService = eventService; this.eventRepository = eventRepository; } /** * Sucht in der DB alle Zeilen raus welche eine der Gruppen_ids hat. * Wandelt die Zeilen in Events um und gibt davon eine Liste zurück. * * @param groupIds Liste an IDs * @return Liste an Events */ public List getGroupEvents(List groupIds) { List eventDTOS = new ArrayList<>(); for (UUID groupId : groupIds) { eventDTOS.addAll(eventRepository.findEventDTOByGroup_id(groupId.toString())); } return eventService.translateEventDTOs(eventDTOS); } /** * Erzeugt eine neue Map wo Gruppen aus den Events erzeugt und den Gruppen_ids zugeordnet werden. * Die Gruppen werden als Liste zurückgegeben * * @param events Liste an Events * @return Liste an Projizierten Gruppen * @throws EventException Projektionsfehler */ public List projectEventList(List events) throws EventException { Map groupMap = new HashMap<>(); events.parallelStream() .forEachOrdered(event -> event.apply(getOrCreateGroup(groupMap, event.getGroupId()))); return new ArrayList<>(groupMap.values()); } private Group getOrCreateGroup(Map groups, UUID groupId) { if (!groups.containsKey(groupId)) { groups.put(groupId, new Group()); } return groups.get(groupId); } /** * Wird verwendet bei der Suche nach Gruppen: Titel, Beschreibung werden benötigt. * Außerdem wird beachtet, ob der eingeloggte User bereits in entsprechenden Gruppen mitglied ist. * * @return Liste von projizierten Gruppen * @throws EventException Projektionsfehler */ public List getAllGroupWithVisibilityPublic(String userId) throws EventException { List groupEvents = eventService.translateEventDTOs(eventRepository.findAllEventsByType("CreateGroupEvent")); groupEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("UpdateGroupDescriptionEvent"))); groupEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("UpdateGroupTitleEvent"))); groupEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("DeleteGroupEvent"))); groupEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("UpdateUserMaxEvent"))); List visibleGroups = projectEventList(groupEvents); return visibleGroups.parallelStream() .filter(group -> group.getType() != null) .filter(group -> !eventService.userInGroup(group.getId(), userId)) .filter(group -> group.getVisibility() == Visibility.PUBLIC) .collect(Collectors.toList()); } /** * Wird verwendet beim Gruppe erstellen bei der Parent-Auswahl: nur Titel benötigt. * * @return * @throws EventException */ public List getAllLecturesWithVisibilityPublic() throws EventException { List createEvents = eventService.translateEventDTOs(eventRepository.findAllEventsByType("CreateGroupEvent")); createEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("DeleteGroupEvent"))); createEvents.addAll(eventService.translateEventDTOs(eventRepository.findAllEventsByType("UpdateGroupTitleEvent"))); List visibleGroups = projectEventList(createEvents); return visibleGroups.parallelStream() .filter(group -> group.getType() != null) .filter(group -> group.getType() == GroupType.LECTURE) .filter(group -> group.getVisibility() == Visibility.PUBLIC) .collect(Collectors.toList()); } /** * Filtert alle öffentliche Gruppen nach dem Suchbegriff und gibt diese als Liste von Gruppen zurück. * Groß und Kleinschreibung wird nicht beachtet. * * @param search Der Suchstring * @return Liste von projizierten Gruppen * @throws EventException Projektionsfehler */ public List findGroupWith(String search, Account account) throws EventException { if (search.isEmpty()) { return getAllGroupWithVisibilityPublic(account.getName()); } return getAllGroupWithVisibilityPublic(account.getName()) .parallelStream() .filter(group -> group.getTitle().toLowerCase().contains(search.toLowerCase()) || group.getDescription().toLowerCase().contains(search.toLowerCase())) .collect(Collectors.toList()); } }