Haiti/haiti-framework
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Удалил ненужный функционал

Browse Source 
Это все относится к реализациям социальной сети, но никак ни к абстрации
This commit is contained in:
Mark Struchkov 2019-07-28 21:41:28 +03:00
parent 8d1532b561
commit 0f08fa6a0e
6 changed files with 0 additions and 155 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/sadtech/social/core/repository/EventRepository.java
View File

@ -1,18 +0,0 @@
package org.sadtech.social.core.repository;
import java.util.Queue;
/**
* Обработка событий социальной сети.
*
* @author upagge [08/07/2019]
*/
public interface EventRepository<T> {
void add(T dataObject);
void cleanAll();
Queue<T> getEventQueue();
}

42
src/main/java/org/sadtech/social/core/repository/impl/jpa/EventRepositoryJpaImpl.java
View File

@ -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<JsonObject> {
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<JsonObject> getEventQueue() {
List<JsonObjectId> allEvent = eventRepositoryJpa.findAll();
eventRepositoryJpa.deleteAll(allEvent);
return allEvent.stream().map(JsonObjectId::getJsonObject).collect(Collectors.toCollection(ConcurrentLinkedQueue::new));
}
}

26
src/main/java/org/sadtech/social/core/repository/impl/local/EventRepositoryQueue.java
View File

@ -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<JsonObject> {
private final Queue<JsonObject> jsonObjects = new ConcurrentLinkedQueue<>();
@Override
public void add(JsonObject jsonObject) {
jsonObjects.offer(jsonObject);
}
@Override
public void cleanAll() {
jsonObjects.clear();
}
public Queue<JsonObject> getEventQueue() {
return jsonObjects;
}
}

15
src/main/java/org/sadtech/social/core/repository/jpa/EventRepositoryJpa.java
View File

@ -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<JsonObjectId, Integer> {
}

20
src/main/java/org/sadtech/social/core/service/RawEventService.java
View File

@ -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<JsonObject> getJsonObjects();
}

34
src/main/java/org/sadtech/social/core/service/impl/RawEventServiceImpl.java
View File

@ -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<JsonObject> eventRepository;
@Override
public void cleanAll() {
eventRepository.cleanAll();
log.info("Репозиторий событий очищен");
}
@Override
public void add(JsonObject jsonObject) {
eventRepository.add(jsonObject);
log.info("Событие отправленно в репозиторий");
}
@Override
public Queue<JsonObject> getJsonObjects() {
return eventRepository.getEventQueue();
}
}