zdm/envoy
Archived
3
Fork 0
Code Issues 22 Pull Requests Releases 1 Wiki Activity

Send ContactOperationEvent to the added contact

Browse Source 
+ Updated formatter
This commit is contained in:
Kai S. K. Engelbart
2020-06-09 17:05:52 +02:00
parent 0c5645157b
commit f4301caba7
3 changed files with 367 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/envoy/server/processors/ContactOperationProcessor.java
View File

@@ -1,8 +1,8 @@
package envoy.server.processors;
import java.io.IOException;
import java.util.Arrays;
import envoy.event.ElementOperation;
import envoy.event.contact.ContactOperationEvent;
import envoy.server.data.PersistenceManager;
import envoy.server.net.ConnectionManager;
@@ -31,8 +31,9 @@ public class ContactOperationProcessor implements ObjectProcessor<ContactOperati
PersistenceManager.getInstance().addUserContact(userID, contactId);
// Notify the contact if online
if (ConnectionManager.getInstance().isOnline(contactId)) writeProxy.write(connectionManager.getSocketId(contactId),
Arrays.asList(PersistenceManager.getInstance().getUserByID(userID).toCommon()));
if (ConnectionManager.getInstance().isOnline(contactId))
writeProxy.write(connectionManager.getSocketId(contactId),
new ContactOperationEvent(PersistenceManager.getInstance().getUserByID(userID).toCommon(), ElementOperation.ADD));
break;
default:
System.err.printf("Received %s with an unsupported operation.%n", evt);