111 lines
3.3 KiB
Java
111 lines
3.3 KiB
Java
package mops.gruppen2.service;
|
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import mops.gruppen2.domain.EventDTO;
|
|
import mops.gruppen2.domain.Exceptions.EventException;
|
|
import mops.gruppen2.domain.Group;
|
|
import mops.gruppen2.domain.Visibility;
|
|
import mops.gruppen2.domain.event.CreateGroupEvent;
|
|
import mops.gruppen2.domain.event.Event;
|
|
import mops.gruppen2.repository.EventRepository;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.List;
|
|
|
|
@Service
|
|
public class EventService {
|
|
private final SerializationService serializationService;
|
|
private final EventRepository eventStore;
|
|
|
|
public EventService(SerializationService serializationService, EventRepository eventStore) {
|
|
this.serializationService = serializationService;
|
|
this.eventStore = eventStore;
|
|
}
|
|
|
|
/** sichert ein Event Objekt indem es ein EventDTO Objekt erzeugt
|
|
*
|
|
* @param event
|
|
*/
|
|
public void saveEvent(Event event){
|
|
EventDTO eventDTO = getDTO(event);
|
|
eventStore.save(eventDTO);
|
|
}
|
|
|
|
/** Erzeugt aus einem Event Objekt ein EventDTO Objekt.
|
|
* Ist die Gruppe öffentlich, dann wird die visibility auf true gesetzt.
|
|
*
|
|
* @param event
|
|
* @return EventDTO
|
|
*/
|
|
public EventDTO getDTO(Event event) {
|
|
EventDTO eventDTO = new EventDTO();
|
|
eventDTO.setGroup_id(event.getGroup_id());
|
|
eventDTO.setUser_id(event.getUser_id());
|
|
if(event instanceof CreateGroupEvent) {
|
|
if(((CreateGroupEvent) event).getGroupVisibility() == Visibility.PRIVATE) {
|
|
eventDTO.setVisibility(false);
|
|
}else {
|
|
eventDTO.setVisibility(true);
|
|
}
|
|
}
|
|
|
|
|
|
try {
|
|
eventDTO.setEvent_payload(serializationService.serializeEvent(event));
|
|
} catch (JsonProcessingException e) {
|
|
e.printStackTrace();
|
|
}
|
|
return eventDTO;
|
|
}
|
|
|
|
/** Sorgt dafür die Group_id immer um 1 zu erhöhen
|
|
*
|
|
* @return Gibt Long zurück
|
|
*/
|
|
public Long checkGroup() {
|
|
Long tmpId = 1L;
|
|
Iterable<EventDTO> eventDTOS = eventStore.findAll();
|
|
for (EventDTO event : eventDTOS) {
|
|
if (event.getGroup_id() == null) {
|
|
return tmpId;
|
|
}
|
|
if (tmpId <= event.getGroup_id()) {
|
|
tmpId++;
|
|
}
|
|
}
|
|
return tmpId;
|
|
}
|
|
|
|
/** Findet alle Events welche ab dem neuen Status hinzugekommen sind
|
|
*
|
|
* @param status
|
|
* @return Liste von Events
|
|
*/
|
|
public List<Event> getNewEvents(Long status){
|
|
Iterable<EventDTO> eventDTOS = eventStore.findNewEventSinceStatus(status);
|
|
|
|
return translateEventDTOs(eventDTOS);
|
|
}
|
|
|
|
/** Erzeugt aus einer Liste von eventDTOs eine Liste von Events
|
|
*
|
|
* @param eventDTOS
|
|
* @return Liste von Events
|
|
*/
|
|
public List<Event> translateEventDTOs(Iterable<EventDTO> eventDTOS){
|
|
List<Event> events = new ArrayList<>();
|
|
|
|
for (EventDTO eventDTO : eventDTOS) {
|
|
try {
|
|
events.add(serializationService.deserializeEvent(eventDTO.getEvent_payload()));
|
|
}catch (JsonProcessingException e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
return events;
|
|
}
|
|
|
|
|
|
}
|