2020-01-11 18:28:48 +01:00
|
|
|
package envoy.server.processors;
|
2019-12-30 14:53:40 +01:00
|
|
|
|
2020-01-06 13:58:28 +01:00
|
|
|
import java.io.IOException;
|
2020-01-11 18:28:48 +01:00
|
|
|
import java.util.Date;
|
|
|
|
import java.util.List;
|
2020-01-18 13:28:54 +01:00
|
|
|
import java.util.stream.Collectors;
|
2020-01-06 13:58:28 +01:00
|
|
|
|
|
|
|
import envoy.data.Contacts;
|
2019-12-30 14:53:40 +01:00
|
|
|
import envoy.data.LoginCredentials;
|
2020-01-11 18:28:48 +01:00
|
|
|
import envoy.data.Message.MessageStatus;
|
2019-12-30 14:53:40 +01:00
|
|
|
import envoy.data.User;
|
2020-01-11 18:28:48 +01:00
|
|
|
import envoy.server.ConnectionManager;
|
|
|
|
import envoy.server.ObjectProcessor;
|
|
|
|
import envoy.server.data.Message;
|
|
|
|
import envoy.server.database.PersistenceManager;
|
2020-01-06 13:58:28 +01:00
|
|
|
import envoy.server.net.ObjectWriteProxy;
|
2019-12-30 14:53:40 +01:00
|
|
|
|
|
|
|
/**
|
2019-12-30 15:15:25 +01:00
|
|
|
* This {@link ObjectProcessor} handles {@link LoginCredentials}.<br>
|
|
|
|
* <br>
|
2019-12-30 14:53:40 +01:00
|
|
|
* Project: <strong>envoy-server-standalone</strong><br>
|
|
|
|
* File: <strong>LoginCredentialProcessor.java</strong><br>
|
|
|
|
* Created: <strong>30.12.2019</strong><br>
|
2019-12-30 15:15:25 +01:00
|
|
|
*
|
2019-12-30 14:53:40 +01:00
|
|
|
* @author Kai S. K. Engelbart
|
2020-01-18 23:50:41 +01:00
|
|
|
* @author Maximilian Käfer
|
2019-12-30 15:15:25 +01:00
|
|
|
* @since Envoy Server Standalone v0.1-alpha
|
2019-12-30 14:53:40 +01:00
|
|
|
*/
|
2020-01-06 13:58:28 +01:00
|
|
|
public class LoginCredentialProcessor implements ObjectProcessor<LoginCredentials> {
|
2019-12-30 14:53:40 +01:00
|
|
|
|
2020-01-18 23:50:41 +01:00
|
|
|
private PersistenceManager persistenceManager = PersistenceManager.getPersistenceManager();
|
2019-12-30 14:53:40 +01:00
|
|
|
|
2019-12-30 15:15:25 +01:00
|
|
|
@Override
|
|
|
|
public Class<LoginCredentials> getInputClass() { return LoginCredentials.class; }
|
|
|
|
|
2019-12-30 14:53:40 +01:00
|
|
|
@Override
|
2020-01-06 13:58:28 +01:00
|
|
|
public void process(LoginCredentials input, long socketId, ObjectWriteProxy writeProxy) throws IOException {
|
2020-01-03 17:11:38 +01:00
|
|
|
System.out.println(String.format("Received login credentials %s from socket ID %d", input, socketId));
|
2020-01-06 13:58:28 +01:00
|
|
|
|
|
|
|
// Create user
|
2020-01-18 23:50:41 +01:00
|
|
|
User user = null;
|
|
|
|
|
|
|
|
if (input.isRegistration()) {
|
|
|
|
envoy.server.data.User dbUser = new envoy.server.data.User();
|
|
|
|
dbUser.setName(input.getName());
|
|
|
|
dbUser.setLastSeen(new Date());
|
|
|
|
dbUser.setStatus(User.UserStatus.ONLINE);
|
|
|
|
dbUser.setPasswordHash(input.getPasswordHash());
|
|
|
|
persistenceManager.addUser(dbUser);
|
|
|
|
user = dbUser.toCommonUser();
|
|
|
|
}else {
|
|
|
|
// TODO: Implement error when user does not exist
|
|
|
|
envoy.server.data.User requestedUser = persistenceManager.getUserByName(input.getName());
|
|
|
|
if (input.getPasswordHash() == requestedUser.getPasswordHash()) {
|
|
|
|
user = requestedUser.toCommonUser();
|
|
|
|
} else {
|
|
|
|
// TODO: Wrong Password Response
|
|
|
|
}
|
|
|
|
}
|
2020-01-03 17:11:38 +01:00
|
|
|
ConnectionManager.getInstance().registerUser(socketId, user.getId());
|
2020-01-06 13:58:28 +01:00
|
|
|
|
|
|
|
// Create contacts
|
2020-01-18 13:28:54 +01:00
|
|
|
List<User> users = PersistenceManager.getPersistenceManager()
|
|
|
|
.getContacts(new envoy.server.data.User(user))
|
|
|
|
.stream()
|
|
|
|
.map(envoy.server.data.User::toCommonUser)
|
|
|
|
.collect(Collectors.toList());
|
|
|
|
Contacts contacts = new Contacts(user.getId(), users);
|
2020-01-06 13:58:28 +01:00
|
|
|
|
|
|
|
// Complete handshake
|
|
|
|
System.out.println("Sending user...");
|
|
|
|
writeProxy.write(socketId, user);
|
|
|
|
System.out.println("Sending contacts...");
|
|
|
|
writeProxy.write(socketId, contacts);
|
2020-01-18 09:55:12 +01:00
|
|
|
System.out.println("Acquiring pending messages for the client...");
|
2020-01-11 18:28:48 +01:00
|
|
|
List<Message> pendingMessages = PersistenceManager.getPersistenceManager().getUnreadMessages(new envoy.server.data.User(user));
|
2020-01-18 09:55:12 +01:00
|
|
|
for (Message msg : pendingMessages) {
|
|
|
|
System.out.println("Sending message " + msg.toString());
|
|
|
|
writeProxy.write(socketId, msg);
|
2020-01-11 18:28:48 +01:00
|
|
|
msg.setReceivedDate(new Date());
|
|
|
|
msg.setStatus(MessageStatus.RECEIVED);
|
|
|
|
PersistenceManager.getPersistenceManager().updateMessage(msg);
|
2020-01-18 09:55:12 +01:00
|
|
|
}
|
2019-12-30 14:53:40 +01:00
|
|
|
}
|
|
|
|
}
|