Изменение домена с rosetta-im.com на rosetta.im
This commit is contained in:
RoyceDa
23
src/main/java/im/rosetta/service/Service.java
Normal file
23
src/main/java/im/rosetta/service/Service.java
Normal file
@@ -0,0 +1,23 @@
|
||||
package im.rosetta.service;
|
||||
|
||||
/**
|
||||
* Базовый класс для всех сервисов. Нужно чтобы унифицировать доступ к репозиториям,
|
||||
* а так же не раздувать логику в executor'ах. Так код в executor'ах будет чище и
|
||||
* проще для понимания. Для атомарных операций с сущностями сервисы не используются, они используются только для
|
||||
* более сложной логики, требующей взаимодействия с несколькими репозиториями или
|
||||
* иной бизнес-логики.
|
||||
* @param <T> тип репозитория
|
||||
*/
|
||||
public abstract class Service<T> {
|
||||
|
||||
private T repository;
|
||||
|
||||
public Service(T repository) {
|
||||
this.repository = repository;
|
||||
}
|
||||
|
||||
public T getRepository() {
|
||||
return repository;
|
||||
}
|
||||
|
||||
}
|
||||
102
src/main/java/im/rosetta/service/dispatch/DeviceDispatcher.java
Normal file
102
src/main/java/im/rosetta/service/dispatch/DeviceDispatcher.java
Normal file
@@ -0,0 +1,102 @@
|
||||
package im.rosetta.service.dispatch;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import im.rosetta.client.ClientManager;
|
||||
import im.rosetta.client.tags.ECIDevice;
|
||||
import im.rosetta.database.entity.Device;
|
||||
import im.rosetta.database.repository.DeviceRepository;
|
||||
import im.rosetta.packet.Packet23DeviceList;
|
||||
import im.rosetta.packet.runtime.DeviceSolution;
|
||||
import im.rosetta.packet.runtime.NetworkDevice;
|
||||
import im.rosetta.packet.runtime.NetworkStatus;
|
||||
import im.rosetta.service.services.DeviceService;
|
||||
|
||||
import io.orprotocol.ProtocolException;
|
||||
import io.orprotocol.client.Client;
|
||||
|
||||
/**
|
||||
* Диспетчер устройств, который отвечает за списки устройств в аккаунте
|
||||
*/
|
||||
public class DeviceDispatcher {
|
||||
|
||||
private ClientManager clientManager;
|
||||
private DeviceRepository deviceRepository = new DeviceRepository();
|
||||
private DeviceService deviceService = new DeviceService(deviceRepository);
|
||||
|
||||
public DeviceDispatcher(ClientManager clientManager) {
|
||||
this.clientManager = clientManager;
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправит список подключенных устройств всем авторизованным устройствам с publicKey
|
||||
* @param publicKey публичный ключ аккаунта, для которого нужно отправить список устройств
|
||||
*/
|
||||
public void sendDevices(String publicKey) throws ProtocolException {
|
||||
/**
|
||||
* Получаем список авторизованных устройств, а так же список устройств которые сейчас в сети
|
||||
*/
|
||||
List<Device> verifiedDevices = deviceService.getDevicesByPK(publicKey);
|
||||
List<ECIDevice> onlineDevices = this.getOnlineDevices(publicKey);
|
||||
|
||||
Map<String, NetworkDevice> byId = new HashMap<>();
|
||||
|
||||
/**
|
||||
* Верифицированные устройства, по умолчанию оффлайн, но верифицированные
|
||||
*/
|
||||
for (Device d : verifiedDevices) {
|
||||
String id = d.getDeviceId();
|
||||
NetworkDevice nd = new NetworkDevice();
|
||||
nd.setDeviceId(id);
|
||||
nd.setDeviceSolution(DeviceSolution.ACCEPT);
|
||||
nd.setNetworkStatus(NetworkStatus.OFFLINE);
|
||||
nd.setDeviceName(d.getDeviceName());
|
||||
nd.setDeviceOs(d.getDeviceOs());
|
||||
byId.put(id, nd);
|
||||
}
|
||||
|
||||
/**
|
||||
* Подгоняем онлайн статус, если усотройство верифицированно, то оно найдется
|
||||
* в Map, если устройства там нет соотвественно оно не верифицированно
|
||||
*/
|
||||
for (ECIDevice od : onlineDevices) {
|
||||
String id = od.getDeviceId();
|
||||
NetworkDevice nd = byId.get(id);
|
||||
if (nd == null) {
|
||||
nd = new NetworkDevice();
|
||||
nd.setDeviceId(id);
|
||||
nd.setDeviceSolution(DeviceSolution.DECLINE);
|
||||
nd.setDeviceName(od.getDeviceName());
|
||||
nd.setDeviceOs(od.getDeviceOs());
|
||||
byId.put(id, nd);
|
||||
}
|
||||
nd.setNetworkStatus(NetworkStatus.ONLINE);
|
||||
}
|
||||
|
||||
List<NetworkDevice> networkDevices = new ArrayList<>(byId.values());
|
||||
Packet23DeviceList packet = new Packet23DeviceList();
|
||||
packet.setDevices(networkDevices);
|
||||
this.clientManager.sendPacketToAuthorizedPK(publicKey, packet);
|
||||
}
|
||||
|
||||
/**
|
||||
* Получить список устройств которые сейчас в сети для публичного ключа (берутся и не авторизованные устройства, так как они тоже в сети)
|
||||
* @param publicKey публичный ключ аккаунта, для которого нужно получить список устройств которые сейчас в сети
|
||||
* @return список устройств которые сейчас в сети для публичного ключа
|
||||
*/
|
||||
private List<ECIDevice> getOnlineDevices(String publicKey) {
|
||||
List<ECIDevice> onlineDevices = new java.util.ArrayList<>();
|
||||
List<Client> clients = clientManager.getPKClients(publicKey);
|
||||
for(Client client : clients){
|
||||
ECIDevice deviceTag = client.getTag(ECIDevice.class);
|
||||
if(deviceTag != null){
|
||||
onlineDevices.add(deviceTag);
|
||||
}
|
||||
}
|
||||
return onlineDevices;
|
||||
}
|
||||
|
||||
}
|
||||
115
src/main/java/im/rosetta/service/dispatch/MessageDispatcher.java
Normal file
115
src/main/java/im/rosetta/service/dispatch/MessageDispatcher.java
Normal file
@@ -0,0 +1,115 @@
|
||||
package im.rosetta.service.dispatch;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import im.rosetta.Failures;
|
||||
import im.rosetta.client.ClientManager;
|
||||
import im.rosetta.client.tags.ECIAuthentificate;
|
||||
import im.rosetta.database.repository.BufferRepository;
|
||||
import im.rosetta.database.repository.GroupRepository;
|
||||
import im.rosetta.packet.base.PacketBaseDialog;
|
||||
import im.rosetta.service.services.BufferService;
|
||||
|
||||
import io.orprotocol.ProtocolException;
|
||||
import io.orprotocol.client.Client;
|
||||
import io.orprotocol.packet.PacketManager;
|
||||
|
||||
/**
|
||||
* Диспетчер сообщений, который отвечает за отправку сообщений получателям, а так же за сохранение сообщений в буфер для офлайн получателей и для синхронизации
|
||||
* Такой диспетчер нужен для того, чтобы не загромождать логику обработчиков сообщений, а так же для того, чтобы
|
||||
* централизовать логику отправки сообщений и сохранения их в буфер
|
||||
* Например, при отправке группового сообщения, диспетчер сам достает участников группы и
|
||||
* отправляет сообщение каждому участнику, а так же сохраняет сообщение в буфер для каждого участника, который офлайн
|
||||
*/
|
||||
public class MessageDispatcher {
|
||||
|
||||
private final GroupRepository groupRepository = new GroupRepository();
|
||||
private final ClientManager clientManager;
|
||||
private final BufferRepository bufferRepository = new BufferRepository();
|
||||
private final BufferService bufferService;
|
||||
|
||||
public MessageDispatcher(ClientManager clientManager, PacketManager packetManager) {
|
||||
this.clientManager = clientManager;
|
||||
this.bufferService = new BufferService(bufferRepository, packetManager);
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправляет групповое сообщение всем участникам группы, кроме отправителя
|
||||
* @param packet пакет с групповым сообщением
|
||||
*/
|
||||
public void sendGroup(PacketBaseDialog packet, Client client, ECIAuthentificate eciAuthentificate) throws ProtocolException {
|
||||
String toPublicKey = packet.getToPublicKey();
|
||||
List<String> groupMembersPublicKeys = this.groupRepository.findGroupMembers(toPublicKey.replace("#group:", ""));
|
||||
if(groupMembersPublicKeys.isEmpty()){
|
||||
/**
|
||||
* Если группа не найдена или в группе нет участников, то в такую отправить
|
||||
* сообщение нельзя
|
||||
*/
|
||||
client.disconnect(Failures.DATA_MISSMATCH);
|
||||
return;
|
||||
}
|
||||
if(!groupMembersPublicKeys.contains(eciAuthentificate.getPublicKey())){
|
||||
/**
|
||||
* Если отправитель не является участником группы, то он не может отправлять
|
||||
* сообщения в эту группу
|
||||
*/
|
||||
client.disconnect(Failures.USER_NOT_IN_GROUP);
|
||||
return;
|
||||
}
|
||||
/**
|
||||
* Отправляем всем участникам группы, кроме отправителя этот пакет, попутно не забывая проверить, а не один ли он в группе
|
||||
*/
|
||||
groupMembersPublicKeys.remove(eciAuthentificate.getPublicKey());
|
||||
if(groupMembersPublicKeys.isEmpty()){
|
||||
/**
|
||||
* Если отправитель был единственным участником группы, то отправлять сообщение некуда,
|
||||
* не кикаем пользователя
|
||||
*/
|
||||
return;
|
||||
}
|
||||
this.clientManager.sendPacketToAuthorizedPK(groupMembersPublicKeys, packet);
|
||||
|
||||
//TODO: Сохранить сообщение в буфер для группы, чтобы группы тоже синхронизировались
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправляет личное сообщение получателю
|
||||
* @param packet пакет с личным сообщением
|
||||
* @param client клиент отправляющий пакет
|
||||
* @param bufferizationNeed флаг указывающий на то, что сообщение нужно буфферизировать,
|
||||
* чтобы доставить пользователям если они не онлайн, если указать false то этот пакет получит
|
||||
* только пользователь который были в сети
|
||||
*/
|
||||
public void sendPeer(PacketBaseDialog packet, Client client, boolean bufferizationNeed) throws ProtocolException {
|
||||
String fromPublicKey = packet.getFromPublicKey();
|
||||
String toPublicKey = packet.getToPublicKey();
|
||||
this.clientManager.sendPacketToAuthorizedPK(toPublicKey, packet);
|
||||
|
||||
if(!bufferizationNeed){
|
||||
/**
|
||||
* Указан флаг, что буферизация не нужна, сообщения с этим флагом не будут доставлены если
|
||||
* оппонент оффлайн
|
||||
*/
|
||||
return;
|
||||
}
|
||||
/**
|
||||
* Сохраняем сообщение в буфер на случай если получатель офлайн, или нам нужна будет синхронизация сообщений для получателя
|
||||
*/
|
||||
this.bufferService.pushPacketToBuffer(fromPublicKey, toPublicKey, packet);
|
||||
}
|
||||
|
||||
/**
|
||||
* Отправляет личное сообщение получателю с буферизацией
|
||||
* @param packet пакет сообщения
|
||||
* @param client клиент отправляющий пакет
|
||||
* @throws ProtocolException
|
||||
*/
|
||||
public void sendPeer(PacketBaseDialog packet, Client client) throws ProtocolException {
|
||||
/**
|
||||
* По умолчанию буферизация включена, чтобы не терять сообщения
|
||||
*/
|
||||
this.sendPeer(packet, client, true);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
99
src/main/java/im/rosetta/service/services/BufferService.java
Normal file
99
src/main/java/im/rosetta/service/services/BufferService.java
Normal file
@@ -0,0 +1,99 @@
|
||||
package im.rosetta.service.services;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
import im.rosetta.client.tags.ECIAuthentificate;
|
||||
import im.rosetta.database.QuerySession;
|
||||
import im.rosetta.database.entity.Buffer;
|
||||
import im.rosetta.database.repository.BufferRepository;
|
||||
import im.rosetta.exception.UnauthorizedExeception;
|
||||
import im.rosetta.service.Service;
|
||||
|
||||
import io.orprotocol.ProtocolException;
|
||||
import io.orprotocol.client.Client;
|
||||
import io.orprotocol.packet.Packet;
|
||||
import io.orprotocol.packet.PacketManager;
|
||||
|
||||
public class BufferService extends Service<BufferRepository> {
|
||||
|
||||
private PacketManager packetManager;
|
||||
|
||||
public BufferService(BufferRepository repository, PacketManager packetManager) {
|
||||
super(repository);
|
||||
this.packetManager = packetManager;
|
||||
}
|
||||
|
||||
/**
|
||||
* Получить пакеты из буфера для клиента, которые были добавлены в буфер после fromTimestampMs. Если клиент не авторизован, возвращает пустой список.
|
||||
* @param client
|
||||
* @param fromTimestampMs
|
||||
* @return
|
||||
* @throws ProtocolException
|
||||
*/
|
||||
public List<Packet> getPacketsFromTime(Client client, long fromTimestampMs) throws ProtocolException, UnauthorizedExeception {
|
||||
ECIAuthentificate eciAuthentificate = client.getTag(ECIAuthentificate.class);
|
||||
if(eciAuthentificate == null || !eciAuthentificate.hasAuthorized()){
|
||||
/**
|
||||
* Если клиент не авторизован, то он не может получать пакеты из буфера, возвращаем пустой список
|
||||
*/
|
||||
throw new UnauthorizedExeception("Unauthorized client cannot get packets from buffer");
|
||||
}
|
||||
String toPublicKey = eciAuthentificate.getPublicKey();
|
||||
String hql = "FROM Buffer WHERE to = :to AND timestamp > :timestamp ORDER BY timestamp ASC";
|
||||
HashMap<String, Object> parameters = new HashMap<>();
|
||||
parameters.put("to", toPublicKey);
|
||||
parameters.put("timestamp", fromTimestampMs);
|
||||
List<Packet> packets = new ArrayList<>();
|
||||
try(QuerySession<Buffer> querySession = this.getRepository().buildQuery(hql, parameters)){
|
||||
List<Buffer> buffers = querySession.getQuery().list();
|
||||
for(Buffer buffer : buffers) {
|
||||
byte[] packetBytes = buffer.getPacket();
|
||||
Packet packet = this.packetManager.createPacket(packetBytes);
|
||||
packets.add(packet);
|
||||
}
|
||||
}
|
||||
return packets;
|
||||
}
|
||||
|
||||
/**
|
||||
* Добавить пакет в буфер для клиента с публичным ключом to. Если клиент не авторизован, выбрасывает UnauthorizedExeception
|
||||
* @param from публичный ключ отправителя пакета
|
||||
* @param to публичный ключ получателя пакета
|
||||
* @param packet пакет для добавления в буфер
|
||||
*/
|
||||
public void pushPacketToBuffer(String from, String to, Packet packet) {
|
||||
int packetId = this.packetManager.getPacketIdByClass(packet.getClass());
|
||||
packet.packetId = packetId;
|
||||
byte[] packetBytes = packet.write().getBuffer();
|
||||
Buffer buffer = new Buffer();
|
||||
buffer.setFrom(from);
|
||||
buffer.setTo(to);
|
||||
buffer.setTimestamp(System.currentTimeMillis());
|
||||
buffer.setPacketId(packetId);
|
||||
buffer.setPacket(packetBytes);
|
||||
this.getRepository().save(buffer);
|
||||
}
|
||||
|
||||
/**
|
||||
* Удаляет из буфера все пакеты для определенного клиента с публичным ключом to, которые были добавлены
|
||||
* в буфер после fromTimestampMs и имееют такой же тип пакета как и переданный packet
|
||||
* @param to публичный ключ получателя пакета
|
||||
* @param packet пакет, по типу которого будет происходить удаление из буфера
|
||||
* @param fromTimestampMs метка времени в миллисекундах, после которой были добавлены пакеты, которые нужно удалить
|
||||
*/
|
||||
public void deletePacketsFromBuffer(String to, Packet packet, long fromTimestampMs) {
|
||||
int packetId = this.packetManager.getPacketIdByClass(packet.getClass());
|
||||
String hql = "DELETE FROM Buffer WHERE to = :to AND packetId = :packetId AND timestamp > :timestamp";
|
||||
HashMap<String, Object> parameters = new HashMap<>();
|
||||
parameters.put("to", to);
|
||||
parameters.put("packetId", packetId);
|
||||
parameters.put("timestamp", fromTimestampMs);
|
||||
try(QuerySession<?> querySession = this.getRepository().buildQuery(hql, parameters, true)){
|
||||
querySession.getQuery().executeUpdate();
|
||||
querySession.commit();
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
48
src/main/java/im/rosetta/service/services/DeviceService.java
Normal file
48
src/main/java/im/rosetta/service/services/DeviceService.java
Normal file
@@ -0,0 +1,48 @@
|
||||
package im.rosetta.service.services;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import im.rosetta.database.entity.Device;
|
||||
import im.rosetta.database.entity.User;
|
||||
import im.rosetta.database.repository.DeviceRepository;
|
||||
import im.rosetta.service.Service;
|
||||
|
||||
public class DeviceService extends Service<DeviceRepository> {
|
||||
|
||||
public DeviceService(DeviceRepository repository) {
|
||||
super(repository);
|
||||
}
|
||||
|
||||
/**
|
||||
* Проверяет, верифицировано ли устройство с deviceId для пользователя user
|
||||
* @param deviceId ID устройства
|
||||
* @param user пользователь
|
||||
* @return true если устройство верифицировано, иначе false
|
||||
*/
|
||||
public boolean isDeviceVerifiedByUser(String deviceId, User user) {
|
||||
List<Device> devices = this.getRepository().findAll(user);
|
||||
if(devices.size() == 0) {
|
||||
/**
|
||||
* Если у пользователя нет устройств, значит текущее устройство верифицировано
|
||||
* такого быть не может, это избыточная проверка
|
||||
*/
|
||||
return true;
|
||||
}
|
||||
for(Device device : devices) {
|
||||
if(device.getDeviceId().equals(deviceId)) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Получить список устройств для публичного ключа
|
||||
* @param publicKey публичный ключ пользователя, для которого нужно получить список устройств
|
||||
* @return список устройств для публичного ключа
|
||||
*/
|
||||
public List<Device> getDevicesByPK(String publicKey) {
|
||||
return this.getRepository().findAllByField("publicKey", publicKey);
|
||||
}
|
||||
|
||||
}
|
||||
93
src/main/java/im/rosetta/service/services/UserService.java
Normal file
93
src/main/java/im/rosetta/service/services/UserService.java
Normal file
@@ -0,0 +1,93 @@
|
||||
package im.rosetta.service.services;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
import im.rosetta.client.tags.ECIAuthentificate;
|
||||
import im.rosetta.database.QuerySession;
|
||||
import im.rosetta.database.entity.User;
|
||||
import im.rosetta.database.repository.UserRepository;
|
||||
import im.rosetta.service.Service;
|
||||
|
||||
import io.orprotocol.client.Client;
|
||||
|
||||
public class UserService extends Service<UserRepository> {
|
||||
|
||||
public UserService(UserRepository repository) {
|
||||
super(repository);
|
||||
}
|
||||
|
||||
/**
|
||||
* Поиск пользователей по части имени пользователя и публичному ключу.
|
||||
* @param query часть имени пользователя
|
||||
* @param take сколько пользователей отдать
|
||||
* @return список пользователей, соответствующих запросу
|
||||
*/
|
||||
public List<User> searchUsers(String query, int take) {
|
||||
String hql = "FROM User WHERE username LIKE :query OR publicKey = :queryExact ORDER BY verified ASC";
|
||||
HashMap<String, Object> parameters = new HashMap<>();
|
||||
parameters.put("query", "%" + query + "%");
|
||||
parameters.put("queryExact", query);
|
||||
try(QuerySession<User> querySession = this.getRepository().buildQuery(hql, parameters)){
|
||||
return querySession.getQuery().setMaxResults(take).list();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Получает User из клиента, так же на всякий случай проверяется авторизован ли пользователь,
|
||||
* если нет то User не будет найден
|
||||
* @param client сетевой клиент
|
||||
* @return пользователь
|
||||
*/
|
||||
public User fromClient(Client client) {
|
||||
ECIAuthentificate eciAuthentificate = client.getTag(ECIAuthentificate.class);
|
||||
if(eciAuthentificate == null){
|
||||
return null;
|
||||
}
|
||||
if(!eciAuthentificate.hasAuthorized()){
|
||||
return null;
|
||||
}
|
||||
return this.getRepository().findByField("publicKey", eciAuthentificate.getPublicKey());
|
||||
}
|
||||
|
||||
/**
|
||||
* Проверяет занятость имени пользователя
|
||||
* @param username имя пользователя
|
||||
* @return true если имя занято, иначе false
|
||||
*/
|
||||
public boolean isUsernameTaken(String username) {
|
||||
User user = this.getRepository().findByField("username", username);
|
||||
return user != null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Подписывает пользователя на пуш уведомления, добавляя токен в его список токенов. Если токен уже был добавлен, то ничего не произойдет.
|
||||
* @param user пользователь, которого нужно подписать на пуш уведомления
|
||||
* @param notificationToken токен пуш уведомлений, который нужно добавить пользователю. Если токен уже был добавлен, то ничего не произойдет
|
||||
*/
|
||||
public void subscribeToPushNotifications(User user, String notificationToken) {
|
||||
List<String> tokens = user.getNotificationsTokens();
|
||||
if(tokens.contains(notificationToken)){
|
||||
return;
|
||||
}
|
||||
tokens.add(notificationToken);
|
||||
user.setNotificationsTokens(tokens);
|
||||
this.getRepository().update(user);
|
||||
}
|
||||
|
||||
/**
|
||||
* Отписывает пользователя от пуш уведомлений, удаляя токен из его списка токенов. Если токена не было, то ничего не произойдет.
|
||||
* @param user пользователь, которого нужно отписать от пуш уведомлений
|
||||
* @param notificationToken токен пуш уведомлений, который нужно удалить у пользователя. Если токена не было, то ничего не произойдет
|
||||
*/
|
||||
public void unsubscribeFromPushNotifications(User user, String notificationToken) {
|
||||
List<String> tokens = user.getNotificationsTokens();
|
||||
if(!tokens.contains(notificationToken)){
|
||||
return;
|
||||
}
|
||||
tokens.remove(notificationToken);
|
||||
user.setNotificationsTokens(tokens);
|
||||
this.getRepository().update(user);
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user