diff --git a/src/main/java/org/sadtech/social/core/repository/EventRepository.java b/src/main/java/org/sadtech/social/core/repository/EventRepository.java deleted file mode 100644 index 1661718..0000000 --- a/src/main/java/org/sadtech/social/core/repository/EventRepository.java +++ /dev/null @@ -1,18 +0,0 @@ -package org.sadtech.social.core.repository; - -import java.util.Queue; - -/** - * Обработка событий социальной сети. - * - * @author upagge [08/07/2019] - */ -public interface EventRepository { - - void add(T dataObject); - - void cleanAll(); - - Queue getEventQueue(); - -} diff --git a/src/main/java/org/sadtech/social/core/repository/impl/jpa/EventRepositoryJpaImpl.java b/src/main/java/org/sadtech/social/core/repository/impl/jpa/EventRepositoryJpaImpl.java deleted file mode 100644 index c7bea8d..0000000 --- a/src/main/java/org/sadtech/social/core/repository/impl/jpa/EventRepositoryJpaImpl.java +++ /dev/null @@ -1,42 +0,0 @@ -package org.sadtech.social.core.repository.impl.jpa; - -import com.google.gson.JsonObject; -import org.sadtech.social.core.domain.jpa.JsonObjectId; -import org.sadtech.social.core.repository.EventRepository; -import org.sadtech.social.core.repository.jpa.EventRepositoryJpa; - -import java.util.List; -import java.util.Queue; -import java.util.concurrent.ConcurrentLinkedQueue; -import java.util.stream.Collectors; - -/** - * TODO: Добавить описание класса. - * - * @author upagge [28/07/2019] - */ -public class EventRepositoryJpaImpl implements EventRepository { - - private final EventRepositoryJpa eventRepositoryJpa; - - public EventRepositoryJpaImpl(EventRepositoryJpa eventRepositoryJpa) { - this.eventRepositoryJpa = eventRepositoryJpa; - } - - @Override - public void add(JsonObject dataObject) { - eventRepositoryJpa.saveAndFlush(new JsonObjectId(dataObject)); - } - - @Override - public void cleanAll() { - eventRepositoryJpa.deleteAll(); - } - - @Override - public Queue getEventQueue() { - List allEvent = eventRepositoryJpa.findAll(); - eventRepositoryJpa.deleteAll(allEvent); - return allEvent.stream().map(JsonObjectId::getJsonObject).collect(Collectors.toCollection(ConcurrentLinkedQueue::new)); - } -} diff --git a/src/main/java/org/sadtech/social/core/repository/impl/local/EventRepositoryQueue.java b/src/main/java/org/sadtech/social/core/repository/impl/local/EventRepositoryQueue.java deleted file mode 100644 index 8fee934..0000000 --- a/src/main/java/org/sadtech/social/core/repository/impl/local/EventRepositoryQueue.java +++ /dev/null @@ -1,26 +0,0 @@ -package org.sadtech.social.core.repository.impl.local; - -import com.google.gson.JsonObject; -import org.sadtech.social.core.repository.EventRepository; - -import java.util.Queue; -import java.util.concurrent.ConcurrentLinkedQueue; - -public class EventRepositoryQueue implements EventRepository { - - private final Queue jsonObjects = new ConcurrentLinkedQueue<>(); - - @Override - public void add(JsonObject jsonObject) { - jsonObjects.offer(jsonObject); - } - - @Override - public void cleanAll() { - jsonObjects.clear(); - } - - public Queue getEventQueue() { - return jsonObjects; - } -} diff --git a/src/main/java/org/sadtech/social/core/repository/jpa/EventRepositoryJpa.java b/src/main/java/org/sadtech/social/core/repository/jpa/EventRepositoryJpa.java deleted file mode 100644 index bb46f75..0000000 --- a/src/main/java/org/sadtech/social/core/repository/jpa/EventRepositoryJpa.java +++ /dev/null @@ -1,15 +0,0 @@ -package org.sadtech.social.core.repository.jpa; - -import org.sadtech.social.core.domain.jpa.JsonObjectId; -import org.springframework.data.jpa.repository.JpaRepository; -import org.springframework.stereotype.Repository; - -/** - * TODO: Добавить описание интерфейса. - * - * @author upagge [28/07/2019] - */ -@Repository -public interface EventRepositoryJpa extends JpaRepository { - -} diff --git a/src/main/java/org/sadtech/social/core/service/RawEventService.java b/src/main/java/org/sadtech/social/core/service/RawEventService.java deleted file mode 100644 index ce7da07..0000000 --- a/src/main/java/org/sadtech/social/core/service/RawEventService.java +++ /dev/null @@ -1,20 +0,0 @@ -package org.sadtech.social.core.service; - -import com.google.gson.JsonObject; - -import java.util.Queue; - -/** - * Интерфейс для взаимодействия с событиями социальной сети. - * - * @author upagge [08/07/2019] - */ -public interface RawEventService { - - void cleanAll(); - - void add(JsonObject jsonObject); - - Queue getJsonObjects(); - -} \ No newline at end of file diff --git a/src/main/java/org/sadtech/social/core/service/impl/RawEventServiceImpl.java b/src/main/java/org/sadtech/social/core/service/impl/RawEventServiceImpl.java deleted file mode 100644 index 44ad42d..0000000 --- a/src/main/java/org/sadtech/social/core/service/impl/RawEventServiceImpl.java +++ /dev/null @@ -1,34 +0,0 @@ -package org.sadtech.social.core.service.impl; - -import com.google.gson.JsonObject; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.sadtech.social.core.repository.EventRepository; -import org.sadtech.social.core.service.RawEventService; - -import java.util.Queue; - -@Slf4j -@RequiredArgsConstructor -public class RawEventServiceImpl implements RawEventService { - - private final EventRepository eventRepository; - - @Override - public void cleanAll() { - eventRepository.cleanAll(); - log.info("Репозиторий событий очищен"); - } - - @Override - public void add(JsonObject jsonObject) { - eventRepository.add(jsonObject); - log.info("Событие отправленно в репозиторий"); - } - - @Override - public Queue getJsonObjects() { - return eventRepository.getEventQueue(); - } - -}