Envoy project
diff --git a/drop_all_tables.sql b/drop_all_tables.sql
new file mode 100644
index 0000000..9eb29c1
--- /dev/null
+++ b/drop_all_tables.sql
@@ -0,0 +1,5 @@
+DROP SCHEMA public CASCADE;
+CREATE SCHEMA public;
+GRANT ALL ON SCHEMA public TO postgres;
+GRANT ALL ON SCHEMA public TO envoy;
+GRANT ALL ON SCHEMA public TO public;
diff --git a/pom.xml b/pom.xml
new file mode 100755
index 0000000..046ec55
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,92 @@
++ *
+ * Project: envoy-server-standalone
+ * File: Startup.java
+ * Created: 24.12.2019
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class Startup { + + /** + * Initializes the logger with a new config instance. + * + * @since Envoy Server Standalone v0.1-beta + */ + private static void initLogging() { + final var items = new HashMap
+ * File: ConfigItem.java
+ * Created: 28 Jan 2020
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +@Entity +@Table(name = "configuration") +public class ConfigItem { + + @Id + private String key; + private String value; + + /** + * Creates an instance of @link{ConfigItem}. + * + * @since Envoy Server Standalone v0.1-alpha + */ + public ConfigItem() {} + + /** + * Creates an instance of @link{ConfigItem}. + * + * @param key the name of this {@link ConfigItem} + * @param value the value of this {@link ConfigItem} + * @since Envoy Server Standalone v0.1-alpha + */ + public ConfigItem(String key, String value) { + this.key = key; + this.value = value; + } + + /** + * @return the key + * @since Envoy Server Standalone v0.1-alpha + */ + public String getKey() { return key; } + + /** + * @param key the key to set + * @since Envoy Server Standalone v0.1-alpha + */ + public void setKey(String key) { this.key = key; } + + /** + * @return the value + * @since Envoy Server Standalone v0.1-alpha + */ + public String getValue() { return value; } + + /** + * @param value the value to set + * @since Envoy Server Standalone v0.1-alpha + */ + public void setValue(String value) { this.value = value; } +} diff --git a/src/main/java/envoy/server/data/Contact.java b/src/main/java/envoy/server/data/Contact.java new file mode 100644 index 0000000..c802837 --- /dev/null +++ b/src/main/java/envoy/server/data/Contact.java @@ -0,0 +1,107 @@ +package envoy.server.data; + +import java.time.LocalDateTime; +import java.util.Set; + +import javax.persistence.*; + +/** + * This class acts as a superclass for all contacts, being {@link User}s and + * {@link Group}s.
+ *
+ * Project: envoy-server-standalone
+ * File: Contact.java
+ * Created: 24.03.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ + +@Entity +@Table(name = "contacts") +@Inheritance(strategy = InheritanceType.SINGLE_TABLE) +public abstract class Contact { + + @Id + @GeneratedValue + protected long id; + protected String name; + + @Column(name = "creation_date") + private LocalDateTime creationDate; + + @ManyToMany(fetch = FetchType.EAGER) + protected Set
+ *
+ * Project: envoy-server-standalone
+ * File: Group.java
+ * Created: 24.03.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +@Entity +@NamedQueries({ + @NamedQuery( + name = Group.findByName, + query = "SELECT g FROM Group g WHERE g.name = :name" + ), + @NamedQuery( + name = Group.findPendingGroups, + query = "SELECT g FROM Group g WHERE g.creationDate > :lastSeen AND :user MEMBER OF g.contacts" + ) +}) +public class Group extends Contact { + + /** + * Named query retrieving a group by name (parameter {@code :name}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String findByName = "Group.findByName"; + + /** + * Named query retrieving all pending groups for a specific user (parameter {@code :user}, {@code :lastSeen}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String findPendingGroups = "Group.findPendingGroups"; + + @Override + public envoy.data.Group toCommon() { + return new envoy.data.Group(id, name, contacts.parallelStream().map(User.class::cast).map(User::toFlatCommon).collect(Collectors.toSet())); + } + + @Override + protected envoy.data.Group toFlatCommon() { return toCommon(); } +} diff --git a/src/main/java/envoy/server/data/GroupMessage.java b/src/main/java/envoy/server/data/GroupMessage.java new file mode 100644 index 0000000..90ad823 --- /dev/null +++ b/src/main/java/envoy/server/data/GroupMessage.java @@ -0,0 +1,104 @@ +package envoy.server.data; + +import java.time.LocalDateTime; +import java.util.HashMap; +import java.util.Map; + +import javax.persistence.*; + +import envoy.data.Group; + +/** + * Project: envoy-server-standalone
+ * File: GroupMessage.java
+ * Created: 18.04.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-beta + */ +@Entity +@NamedQuery( + name = GroupMessage.getPendingGroupMsg, + query = "SELECT m FROM GroupMessage m JOIN m.memberMessageStatus s WHERE (KEY(s) = :userId) AND ((m.creationDate > :lastSeen)" + + "OR ((m.status = envoy.data.Message$MessageStatus.RECEIVED) AND (m.receivedDate > :lastSeen))" + + "OR ((m.status = envoy.data.Message$MessageStatus.READ) AND (m.readDate > :lastSeen))" + + "OR ((m.lastStatusChangeDate > :lastSeen)))" +) +public class GroupMessage extends Message { + + /** + * Named query retrieving pending group messages sent to a group containing a + * specific user (parameter {@code userId}) that were sent after a certain time + * stamp (parameter {@code :lastSeen}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String getPendingGroupMsg = "GroupMessage.getPendingGroupMsg"; + + @ElementCollection + private Map
+ * It will be referenced as "database message" to clarify between the different + * message objects.
+ *
+ * Project: envoy-server-standalone
+ * File: Message.java
+ * Created: 02.01.2020
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +@Entity +@Table(name = "messages") +@Inheritance(strategy = InheritanceType.SINGLE_TABLE) +@NamedQuery( + name = Message.getPending, + query = "SELECT m FROM Message m WHERE (m.recipient = :user AND m.status = envoy.data.Message$MessageStatus.SENT) " + + "OR (m.sender = :user) AND ((m.status = envoy.data.Message$MessageStatus.RECEIVED) AND (m.receivedDate > :lastSeen)" + + "OR (m.status = envoy.data.Message$MessageStatus.READ) AND (m.readDate > :lastSeen))" +) +public class Message { + + /** + * Named query retrieving pending messages for a user (parameter {@code :user}) + * which was last seen after a specific date (parameter {@code :lastSeen}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String getPending = "Message.getPending"; + + @Id + protected long id; + + @ManyToOne + @JoinColumn + protected User sender; + + @ManyToOne + @JoinColumn + protected Contact recipient; + + @Column(name = "creation_date") + protected LocalDateTime creationDate; + + @Column(name = "received_date") + protected LocalDateTime receivedDate; + + @Column(name = "read_date") + protected LocalDateTime readDate; + + protected String text; + protected envoy.data.Message.MessageStatus status; + protected AttachmentType attachmentType; + protected byte[] attachment; + protected boolean forwarded; + + /** + * The constructor for a database object. + * + * @since Envoy Server Standalone v0.1-alpha + */ + public Message() {} + + /** + * Constructs a database message from a common message. + * + * @param message the {@link envoy.data.Message} to convert into a database + * {@link Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public Message(envoy.data.Message message) { + PersistenceManager persistenceManager = PersistenceManager.getInstance(); + id = message.getID(); + status = message.getStatus(); + text = message.getText(); + creationDate = message.getCreationDate(); + receivedDate = message.getReceivedDate(); + readDate = message.getReadDate(); + sender = persistenceManager.getUserByID(message.getSenderID()); + recipient = persistenceManager.getContactByID(message.getRecipientID()); + forwarded = message.isForwarded(); + if (message.hasAttachment()) { + attachment = message.getAttachment().getData(); + attachmentType = message.getAttachment().getType(); + } + } + + /** + * Converts this message into an instance of {@link envoy.data.Message}. + * + * @return a {@link envoy.data.Message} containing the same values as this + * message + * @since Envoy Server Standalone v0.1-alpha + */ + public envoy.data.Message toCommon() { + return prepareBuilder().build(); + } + + /** + * @return a message builder containing the state of this message + * @since Envoy Server Standalone v0.1-beta + */ + MessageBuilder prepareBuilder() { + var builder = new MessageBuilder(sender.getID(), recipient.getID(), id).setText( + text) + .setCreationDate(creationDate) + .setReceivedDate(receivedDate) + .setReadDate(readDate) + .setStatus(status) + .setForwarded(forwarded); + if (attachment != null) builder.setAttachment(new Attachment(attachment, attachmentType)); + return builder; + } + + /** + * Sets the message status to {@link MessageStatus#RECEIVED} and sets the + * current time stamp as the received date. + * + * @since Envoy Server Standalone v0.1-beta + */ + public void received() { + receivedDate = LocalDateTime.now(); + status = RECEIVED; + } + + /** + * Sets the message status to {@link MessageStatus#READ} and sets the + * current time stamp as the read date. + * + * @since Envoy Server Standalone v0.1-beta + */ + public void read() { + readDate = LocalDateTime.now(); + status = READ; + } + + /** + * @return the id of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public long getID() { return id; } + + /** + * @param id the id to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getID() + */ + public void setId(long id) { this.id = id; } + + /** + * @return the sender of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public User getSender() { return sender; } + + /** + * @param sender the sender to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getSender() + */ + public void setSender(User sender) { this.sender = sender; } + + /** + * @return the recipient of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public Contact getRecipient() { return recipient; } + + /** + * @param recipient the recipient to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getRecipient() + */ + public void setRecipient(User recipient) { this.recipient = recipient; } + + /** + * @return the date at which a {link envoy.data.Message} has been created + * @since Envoy Server Standalone v0.1-alpha + */ + public LocalDateTime getCreationDate() { return creationDate; } + + /** + * @param creationDate the creation date to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getCreationDate() + */ + public void setCreationDate(LocalDateTime creationDate) { this.creationDate = creationDate; } + + /** + * @return the date at which a {link envoy.data.Message} has been received by + * the server + * @since Envoy Server Standalone v0.1-alpha + */ + public LocalDateTime getReceivedDate() { return receivedDate; } + + /** + * @param receivedDate the received date to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getReceivedDate() + */ + public void setReceivedDate(LocalDateTime receivedDate) { this.receivedDate = receivedDate; } + + /** + * @return the date at which a {link envoy.data.Message} has been read + * @since Envoy Server Standalone v0.1-alpha + */ + public LocalDateTime getReadDate() { return readDate; } + + /** + * @param readDate the read date to set + * @since Envoy Server Standalone v0.1-alpha + * @see Message#getReadDate() + */ + public void setReadDate(LocalDateTime readDate) { this.readDate = readDate; } + + /** + * @return the status of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public envoy.data.Message.MessageStatus getStatus() { return status; } + + /** + * @param status the new status of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public void setStatus(envoy.data.Message.MessageStatus status) { this.status = status; } + + /** + * @return the text content of a {link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public String getText() { return text; } + + /** + * @param text the new text content of a {@link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public void setText(String text) { this.text = text; } + + /** + * @return the attachment of a {@link envoy.data.Message} + * @since Envoy Server Standalone v0.1-alpha + */ + public byte[] getAttachment() { return attachment; } + + /** + * @param attachment the new attachment + * @since Envoy Server Standalone v0.1-alpha + */ + public void setAttachment(byte[] attachment) { this.attachment = attachment; } + + /** + * @return the attachmentType + * @since Envoy Server Standalone v0.1-beta + */ + public AttachmentType getAttachmentType() { return attachmentType; } + + /** + * @param attachmentType the attachmentType to set + * @since Envoy Server Standalone v0.1-beta + */ + public void setAttachmentType(AttachmentType attachmentType) { this.attachmentType = attachmentType; } + + /** + * @return whether this message is a forwarded message + * @since Envoy Server Standalone v0.1-alpha + */ + public boolean isForwarded() { return forwarded; } + + /** + * @param forwarded this message should be a forwarded message. + * @since Envoy Server Standalone v0.1-alpha + */ + public void setForwarded(boolean forwarded) { this.forwarded = forwarded; } +} diff --git a/src/main/java/envoy/server/data/PersistenceManager.java b/src/main/java/envoy/server/data/PersistenceManager.java new file mode 100755 index 0000000..3432846 --- /dev/null +++ b/src/main/java/envoy/server/data/PersistenceManager.java @@ -0,0 +1,281 @@ +package envoy.server.data; + +import java.time.LocalDateTime; +import java.util.List; + +import javax.persistence.EntityManager; +import javax.persistence.EntityTransaction; +import javax.persistence.Persistence; + +import envoy.data.User.UserStatus; +import envoy.server.net.ConnectionManager; + +/** + * Project: envoy-server-standalone
+ * File: PersistenceManager.java
+ * Created: 1 Jan 2020
+ * + * @author Leon Hofmeister + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +public class PersistenceManager { + + private final EntityManager entityManager = Persistence.createEntityManagerFactory("envoy").createEntityManager(); + private final EntityTransaction transaction = entityManager.getTransaction(); + + private static final PersistenceManager persistenceManager = new PersistenceManager(); + + /** + * Creates the singleton instance of the @link{PersistenceManager}. + * + * @since Envoy Server Standalone v0.1-alpha + */ + private PersistenceManager() { + Runtime.getRuntime().addShutdownHook(new Thread(() -> { + transaction.begin(); + ConnectionManager.getInstance() + .getOnlineUsers() + .stream() + .map(this::getUserByID) + .forEach(user -> { user.setStatus(UserStatus.OFFLINE); user.setLastSeen(LocalDateTime.now()); entityManager.merge(user); }); + transaction.commit(); + })); + } + + /** + * @return the {@link PersistenceManager} singleton + * @since Envoy Server Standalone v0.1-alpha + */ + public static PersistenceManager getInstance() { return persistenceManager; } + + /** + * Adds a {@link Contact} to the database. + * + * @param contact the {@link Contact} to add to the database + * @since Envoy Server Standalone v0.1-alpha + */ + public void addContact(Contact contact) { persist(contact); } + + /** + * Adds a {@link Message} to the database. + * + * @param message the {@link Message} to add to the database + * @since Envoy Server Standalone v0.1-alpha + */ + public void addMessage(Message message) { persist(message); } + + /** + * Adds a {@link ConfigItem} to the database. + * + * @param configItem the {@link ConfigItem} to add to the database + * @since Envoy Server Standalone v0.1-alpha + */ + public void addConfigItem(ConfigItem configItem) { persist(configItem); } + + /** + * Updates a {@link Contact} in the database + * + * @param contact the {@link Contact} to add to the database + * @since Envoy Server Standalone v0.1-alpha + */ + public void updateContact(Contact contact) { merge(contact); } + + /** + * Updates a {@link Message} in the database. + * + * @param message the message to update + * @since Envoy Server Standalone v0.1-alpha + */ + public void updateMessage(Message message) { merge(message); } + + /** + * Updates a {@link ConfigItem} in the database. + * + * @param configItem the configItem to update + * @since Envoy Server Standalone v0.1-alpha + */ + public void updateConfigItem(ConfigItem configItem) { merge(configItem); } + + /** + * Deletes a {@link Contact} in the database. + * + * @param contact the {@link Contact} to delete + * @since Envoy Server Standalone v0.1-alpha + */ + public void deleteContact(Contact contact) { remove(contact); } + + /** + * Deletes a {@link Message} in the database. + * + * @param message the {@link Message} to delete + * @since Envoy Server Standalone v0.1-alpha + */ + public void deleteMessage(Message message) { remove(message); } + + /** + * Searches for a {@link User} with a specific ID. + * + * @param id the id to search for + * @return the user with the specified ID or {@code null} if none was found + * @since Envoy Server Standalone v0.1-alpha + */ + public User getUserByID(long id) { return entityManager.find(User.class, id); } + + /** + * Searches for a {@link Group} with a specific ID. + * + * @param id the id to search for + * @return the group with the specified ID or {@code null} if none was found + * @since Envoy Server Standalone v0.1-beta + */ + public Group getGroupByID(long id) { return entityManager.find(Group.class, id); } + + /** + * Searches for a {@link Contact} with a specific ID. + * + * @param id the id to search for + * @return the contact with the specified ID or {@code null} if none was found + * @since Envoy Server Standalone v0.1-beta + */ + public Contact getContactByID(long id) { return entityManager.find(Contact.class, id); } + + /** + * Searched for a {@link User} with a specific name. + * + * @param name the name of the user + * @return the user with the specified name + * @since Envoy Server Standalone v0.1-alpha + */ + public User getUserByName(String name) { + return (User) entityManager.createNamedQuery(User.findByName).setParameter("name", name).getSingleResult(); + } + + /** + * Searched for a {@link Group} with a specific name. + * + * @param name the name of the group + * @return the group with the specified name + * @since Envoy Server Standalone v0.1-alpha + */ + public Group getGroupByName(String name) { + return (Group) entityManager.createNamedQuery(Group.findByName).setParameter("name", name).getSingleResult(); + } + + /** + * Searches for a {@link Message} with a specific id. + * + * @param id the id to search for + * @return the message with the specified ID or {@code null} if none is found + * @since Envoy Server Standalone v0.1-alpha + */ + public Message getMessageByID(long id) { return entityManager.find(Message.class, id); } + + /** + * @param key the name of this {@link ConfigItem} + * @return the {@link ConfigItem} with the given name + * @since Envoy Server Standalone v0.1-alpha + */ + public ConfigItem getConfigItemByID(String key) { return entityManager.find(ConfigItem.class, key); } + + /** + * Returns all messages received while being offline or the ones that have + * changed. + * + * @param user the user who wants to receive his unread messages + * @return all messages that the client does not yet have (unread messages) + * @since Envoy Server Standalone v0.1-alpha + */ + public List
+ *
+ * Project: envoy-server-standalone
+ * File: User.java
+ * Created: 02.01.2020
+ * + * @author Kai S. K. Engelbart + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +@Entity +@NamedQueries({ + @NamedQuery( + name = User.findByName, + query = "SELECT u FROM User u WHERE u.name = :name" + ), + @NamedQuery( + name = User.findContacts, + query = "SELECT u.contacts FROM User u WHERE u = :user" + ), + @NamedQuery( + name = User.searchByName, + query = "SELECT u FROM User u WHERE (lower(u.name) LIKE lower(:searchPhrase) AND u <> :context AND :context NOT MEMBER OF u.contacts)" + ) +}) +public class User extends Contact { + + /** + * Named query retrieving a user by name (parameter {@code :name}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String findByName = "User.findByName"; + + /** + * Named query retrieving the contacts of a given user (parameter + * {@code :user}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String findContacts = "User.findContacts"; + + /** + * Named query searching for users with a name like a search phrase (parameter + * {@code :searchPhrase}) that are not in the contact list of a given user + * (parameter {@code :context}). + * + * @since Envoy Server Standalone v0.1-beta + */ + public static final String searchByName = "User.searchByName"; + + @Column(name = "password_hash") + private String passwordHash; + + @Column(name = "last_seen") + private LocalDateTime lastSeen; + + private UserStatus status; + + @Override + public envoy.data.User toCommon() { + return new envoy.data.User(id, name, status, contacts.parallelStream().map(Contact::toFlatCommon).collect(Collectors.toSet())); + } + + @Override + protected envoy.data.User toFlatCommon() { return new envoy.data.User(id, name, status, Set.of()); } + + /** + * @return the password hash + * @since Envoy Server Standalone v0.1-beta + */ + public String getPasswordHash() { return passwordHash; } + + /** + * @param passwordHash the password hash to set + * @since Envoy Server Standalone v0.1-beta + */ + public void setPasswordHash(String passwordHash) { this.passwordHash = passwordHash; } + + /** + * @return the last date the user has been online + * @since Envoy Server Standalone v0.1-alpha + */ + public LocalDateTime getLastSeen() { return lastSeen; } + + /** + * @param lastSeen the latest date at which the user has been online to set + * @since Envoy Server Standalone v0.1-alpha + */ + public void setLastSeen(LocalDateTime lastSeen) { this.lastSeen = lastSeen; } + + /** + * @return the status + * @since Envoy Server Standalone v0.1-alpha + */ + public UserStatus getStatus() { return status; } + + /** + * @param status the status to set + * @since Envoy Server Standalone v0.1-alpha + */ + public void setStatus(UserStatus status) { this.status = status; } +} diff --git a/src/main/java/envoy/server/data/package-info.java b/src/main/java/envoy/server/data/package-info.java new file mode 100755 index 0000000..acbd83e --- /dev/null +++ b/src/main/java/envoy/server/data/package-info.java @@ -0,0 +1,9 @@ +/** + * This package contains classes related to persistence. + * + * @author Kai S. K. Engelbart + * @author Leon Hofmeister + * @author Maximilian Käfer + * @since Envoy v0.1-alpha + */ +package envoy.server.data; diff --git a/src/main/java/envoy/server/net/ConnectionManager.java b/src/main/java/envoy/server/net/ConnectionManager.java new file mode 100755 index 0000000..e0ce7ed --- /dev/null +++ b/src/main/java/envoy/server/net/ConnectionManager.java @@ -0,0 +1,115 @@ +package envoy.server.net; + +import java.time.LocalDateTime; +import java.util.*; +import java.util.stream.Collectors; + +import com.jenkov.nioserver.ISocketIdListener; + +import envoy.data.User.UserStatus; +import envoy.server.data.Group; +import envoy.server.data.PersistenceManager; +import envoy.server.processors.UserStatusChangeProcessor; + +/** + * Project: envoy-server-standalone
+ * File: ConnectionManager.java
+ * Created: 03.01.2020
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class ConnectionManager implements ISocketIdListener { + + /** + * Contains all socket IDs that have not yet performed a handshake / acquired + * their corresponding user ID. + * + * @since Envoy Server Standalone v0.1-alpha + */ + private Set
+ *
+ * Project: envoy-server-standalone
+ * File: ObjectMessageProcessor.java
+ * Created: 28.12.2019
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class ObjectMessageProcessor implements IMessageProcessor { + + private final Set
+ *
+ * Project: envoy-server-standalone
+ * File: ObjectMessageReader.java
+ * Created: 28.12.2019
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class ObjectMessageReader implements IMessageReader { + + private List
+ *
+ * Project: envoy-server-standalone
+ * File: ObjectWriteProxy.java
+ * Created: 04.01.2020
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class ObjectWriteProxy { + + private final WriteProxy writeProxy; + + private static final ConnectionManager connectionManager = ConnectionManager.getInstance(); + private static final Logger logger = EnvoyLog.getLogger(ObjectWriteProxy.class); + + /** + * Creates an instance of {@link ObjectWriteProxy}. + * + * @param writeProxy the {@link WriteProxy} to write objects to another client + * @since Envoy Server Standalone v0.1-alpha + */ + public ObjectWriteProxy(WriteProxy writeProxy) { this.writeProxy = writeProxy; } + + /** + * @param recipientSocketID the socket id of the recipient + * @param obj the object to return to the client + * @throws RuntimeException if the serialization of the object failed (this is + * highly unlikely) + * @since Envoy Server Standalone v0.1-alpha + */ + public void write(long recipientSocketID, Object obj) { + // Create message targeted at the client + final Message response = writeProxy.getMessage(); + response.socketId = recipientSocketID; + logger.fine("Sending " + obj); + + try { + + // Serialize object to byte array + final byte[] objBytes = SerializationUtils.writeToByteArray(obj); + + // Acquire object length in bytes + final byte[] objLen = SerializationUtils.intToBytes(objBytes.length); + + response.writeToMessage(objLen); + response.writeToMessage(objBytes); + writeProxy.enqueue(response); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + + /** + * Sends an object to all contact in a set that are online. + * + * @param contacts the contacts to send the object to + * @param message the object to send + * @since Envoy Server Standalone v0.1-beta + */ + public void writeToOnlineContacts(Set contacts, Object message) { writeToOnlineContacts(contacts.stream(), message); } + + /** + * Sends an object to all contact in a set that are online. + * + * @param contacts the contacts to send the object to + * @param message the object to send + * @since Envoy Server Standalone v0.1-beta + */ + public void writeToOnlineContacts(Stream contacts, Object message) { + contacts.map(Contact::getID).filter(connectionManager::isOnline).map(connectionManager::getSocketID).forEach(id -> write(id, message)); + } +} diff --git a/src/main/java/envoy/server/net/package-info.java b/src/main/java/envoy/server/net/package-info.java new file mode 100755 index 0000000..b527a76 --- /dev/null +++ b/src/main/java/envoy/server/net/package-info.java @@ -0,0 +1,9 @@ +/** + * This package contains all classes related to client connection management. + * + * @author Kai S. K. Engelbart + * @author Leon Hofmeister + * @author Maximilian Käfer + * @since Envoy v0.1-alpha + */ +package envoy.server.net; diff --git a/src/main/java/envoy/server/package-info.java b/src/main/java/envoy/server/package-info.java new file mode 100755 index 0000000..4994f65 --- /dev/null +++ b/src/main/java/envoy/server/package-info.java @@ -0,0 +1,9 @@ +/** + * This package contains the class that manages application startup. + * + * @author Kai S. K. Engelbart + * @author Leon Hofmeister + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +package envoy.server; diff --git a/src/main/java/envoy/server/processors/ContactOperationProcessor.java b/src/main/java/envoy/server/processors/ContactOperationProcessor.java new file mode 100755 index 0000000..4363f60 --- /dev/null +++ b/src/main/java/envoy/server/processors/ContactOperationProcessor.java @@ -0,0 +1,47 @@ +package envoy.server.processors; + +import java.util.logging.Logger; + +import envoy.event.ElementOperation; +import envoy.event.contact.ContactOperation; +import envoy.server.data.PersistenceManager; +import envoy.server.net.ConnectionManager; +import envoy.server.net.ObjectWriteProxy; +import envoy.util.EnvoyLog; + +/** + * Project: envoy-server-standalone
+ * File: ContactOperationProcessor.java
+ * Created: 08.02.2020
+ * + * @author Kai S. K. Engelbart + * @since Envoy Server Standalone v0.1-alpha + */ +public class ContactOperationProcessor implements ObjectProcessor
+ * File: ContactSearchProcessor.java
+ * Created: 08.02.2020
+ * + * @author Kai S. K. Engelbart + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +public class ContactSearchProcessor implements ObjectProcessor
+ * File: GroupCreationProcessor.java
+ * Created: 26.03.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-beta + */ +public class GroupCreationProcessor implements ObjectProcessor
+ * File: GroupMessageProcessor.java
+ * Created: 18.04.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-beta + */ +public class GroupMessageProcessor implements ObjectProcessor
+ * File: GroupMessageStatusChangeProcessor.java
+ * Created: 03.07.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-beta + */ +public class GroupMessageStatusChangeProcessor implements ObjectProcessor
+ * File: GroupResizeProcessor.java
+ * Created: 03.04.2020
+ * + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-beta + */ +public class GroupResizeProcessor implements ObjectProcessor
+ * File: IDGeneratorRequestProcessor.java
+ * Created: 28 Jan 2020
+ * + * @author Kai S. K. Engelbart + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +public class IDGeneratorRequestProcessor implements ObjectProcessor
+ *
+ * Project: envoy-server-standalone
+ * File: LoginCredentialProcessor.java
+ * Created: 30.12.2019
+ * + * @author Kai S. K. Engelbart + * @author Maximilian Käfer + * @since Envoy Server Standalone v0.1-alpha + */ +public final class LoginCredentialProcessor implements ObjectProcessor
+ * Project: envoy-server-standalone
+ * Project: envoy-server-standalone
+ * Project: envoy-server-standalone
+ * Project: envoy-server-standalone
+ * Project: envoy-server-standalone
+ * File: MessageProcessor.java
+ * Created: 30.12.2019
+ *
+ * @author Kai S. K. Engelbart
+ * @author Maximilian Käfer
+ * @since Envoy Server Standalone v0.1-alpha
+ */
+public class MessageProcessor implements ObjectProcessor
+ * File: MessageStatusChangeProcessor.java
+ * Created: 10 Jan 2020
+ *
+ * @author Leon Hofmeister
+ * @since Envoy Server Standalone v0.1-alpha
+ */
+public class MessageStatusChangeProcessor implements ObjectProcessor
+ * File: NameChangeProcessor.java
+ * Created: 26 Mar 2020
+ *
+ * @author Leon Hofmeister
+ * @since Envoy Server Standalone v0.1-beta
+ */
+public class NameChangeProcessor implements ObjectProcessor
+ *
+ * Project: envoy-server-standalone
+ * File: ObjectProcessor.java
+ * Created: 30.12.2019
+ *
+ * @author Kai S. K. Engelbart
+ * @param
+ * File: UserStatusChangeProcessor.java
+ * Created: 1 Feb 2020
+ *
+ * @author Leon Hofmeister
+ * @since Envoy Server Standalone v0.1-alpha
+ */
+public class UserStatusChangeProcessor implements ObjectProcessor
+ * File: PasswordUtil.java
+ * Created: 10.07.2020
+ *
+ * @author Kai S. K. Engelbart
+ * @since Envoy Server Standalone v0.1-beta
+ */
+public class PasswordUtil {
+
+ private static final int ITERATIONS = 1000;
+ private static final int KEY_LENGTH = 64 * 8;
+ private static final String SALT_ALGORITHM = "SHA1PRNG";
+ private static final String SECRET_KEY_ALGORITHM = "PBKDF2WithHmacSHA1";
+
+ private PasswordUtil() {}
+
+ /**
+ * Validates a password against a stored password hash
+ *
+ * @param current the password to validate
+ * @param stored the hash to validate against
+ * @return {@code true} if the password is correct
+ * @since Envoy Server Standalone v0.1-beta
+ */
+ public static boolean validate(String current, String stored) {
+ try {
+ String[] parts = stored.split(":");
+ int iterations = Integer.parseInt(parts[0]);
+ byte[] salt = fromHex(parts[1]);
+ byte[] hash = fromHex(parts[2]);
+
+ var spec = new PBEKeySpec(current.toCharArray(), salt, iterations, KEY_LENGTH);
+ var skf = SecretKeyFactory.getInstance(SECRET_KEY_ALGORITHM);
+ byte[] testHash = skf.generateSecret(spec).getEncoded();
+
+ int diff = hash.length ^ testHash.length;
+ for (int i = 0; i < hash.length && i < testHash.length; ++i)
+ diff |= hash[i] ^ testHash[i];
+
+ return diff == 0;
+ } catch (GeneralSecurityException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * Creates a parameterized salted password hash.
+ *
+ * @param password the password to hash
+ * @return a result string in the form of {@code iterations:salt:hash}
+ * @since Envoy Server Standalone v0.1-beta
+ */
+ public static String hash(String password) {
+ try {
+ byte[] salt = salt();
+ var spec = new PBEKeySpec(password.toCharArray(), salt, ITERATIONS, KEY_LENGTH);
+ var skf = SecretKeyFactory.getInstance(SECRET_KEY_ALGORITHM);
+ byte[] hash = skf.generateSecret(spec).getEncoded();
+ return ITERATIONS + ":" + toHex(salt) + ":" + toHex(hash);
+ } catch (GeneralSecurityException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ private static byte[] salt() throws NoSuchAlgorithmException {
+ SecureRandom sr = SecureRandom.getInstance(SALT_ALGORITHM);
+ byte[] salt = new byte[16];
+ sr.nextBytes(salt);
+ return salt;
+ }
+
+ private static String toHex(byte[] bytes) {
+ String hex = new BigInteger(1, bytes).toString(16);
+ int padding = bytes.length * 2 - hex.length();
+ return padding > 0 ? String.format("%0" + padding + "d", 0) + hex : hex;
+ }
+
+ private static byte[] fromHex(String hex) {
+ byte[] bytes = new byte[hex.length() / 2];
+ for (int i = 0; i < bytes.length; ++i)
+ bytes[i] = (byte) Integer.parseInt(hex.substring(2 * i, 2 * i + 2), 16);
+ return bytes;
+ }
+}
diff --git a/src/main/java/envoy/server/util/VersionUtil.java b/src/main/java/envoy/server/util/VersionUtil.java
new file mode 100644
index 0000000..8f623e1
--- /dev/null
+++ b/src/main/java/envoy/server/util/VersionUtil.java
@@ -0,0 +1,94 @@
+package envoy.server.util;
+
+import java.util.regex.Pattern;
+
+/**
+ * Implements a comparison algorithm between Envoy versions and defines minimal
+ * and maximal client versions compatible with this server.
+ *
+ * File: VersionUtil.java
+ * Created: 23.06.2020
+ *
+ * @author Kai S. K. Engelbart
+ * @since Envoy Server Standalone v0.1-beta
+ */
+public class VersionUtil {
+
+ /**
+ * The minimal client version compatible with this server.
+ *
+ * @since Envoy Server Standalone v0.1-beta
+ */
+ public static final String MIN_CLIENT_VERSION = "0.1-beta";
+
+ /**
+ * The maximal client version compatible with this server.
+ *
+ * @since Envoy Server Standalone v0.1-beta
+ */
+ public static final String MAX_CLIENT_VERSION = "0.1-beta";
+
+ private static final Pattern versionPattern = Pattern.compile("(?
+ * File: package-info.java
+ * Created: 23.06.2020
+ *
+ * @author Kai S. K. Engelbart
+ * @since Envoy Server Standalone v0.1-beta
+ */
+package envoy.server.util;
diff --git a/src/main/java/module-info.java b/src/main/java/module-info.java
new file mode 100755
index 0000000..860f1df
--- /dev/null
+++ b/src/main/java/module-info.java
@@ -0,0 +1,20 @@
+/**
+ * This module contains all classes defining the server application of the Envoy
+ * project.
+ *
+ * @author Kai S. K. Engelbart
+ * @author Leon Hofmeister
+ * @author Maximilian Käfer
+ * @since Envoy Server Standalone v0.1-beta
+ */
+module envoy.server {
+
+ opens envoy.server.data;
+
+ requires transitive envoy.common;
+ requires transitive java.nio.server;
+ requires transitive java.persistence;
+ requires transitive java.sql;
+ requires transitive org.hibernate.orm.core;
+
+}
diff --git a/src/main/resources/META-INF/persistence.xml b/src/main/resources/META-INF/persistence.xml
new file mode 100755
index 0000000..8e0af7e
--- /dev/null
+++ b/src/main/resources/META-INF/persistence.xml
@@ -0,0 +1,27 @@
+