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

Adjusted to event system refactoring

Browse Source
This commit is contained in:
Kai S. K. Engelbart 2020-02-11 17:17:45 +01:00
parent 31c80492df
commit 4909a65464
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/envoy/server/processors/ContactsRequestEventProcessor.java
View File

@ -5,6 +5,7 @@ import java.util.stream.Collectors;
import envoy.data.Contacts; import envoy.data.Contacts;
import envoy.event.ContactSearchRequest; import envoy.event.ContactSearchRequest;
import envoy.event.ContactSearchResult;
import envoy.server.ConnectionManager; import envoy.server.ConnectionManager;
import envoy.server.ObjectProcessor; import envoy.server.ObjectProcessor;
import envoy.server.data.User; import envoy.server.data.User;
@ -32,7 +33,7 @@ public class ContactsRequestEventProcessor implements ObjectProcessor<ContactSea
@Override @Override
public void process(ContactSearchRequest request, long socketId, ObjectWriteProxy writeProxy) throws IOException { public void process(ContactSearchRequest request, long socketId, ObjectWriteProxy writeProxy) throws IOException {
writeProxy.write(socketId, writeProxy.write(socketId,
new Contacts(PersistenceManager.getPersistenceManager() new ContactSearchResult(PersistenceManager.getPersistenceManager()
.searchUsers(request.get(), ConnectionManager.getInstance().getUserIdBySocketId(socketId)) .searchUsers(request.get(), ConnectionManager.getInstance().getUserIdBySocketId(socketId))
.stream() .stream()
.map(User::toCommonUser) .map(User::toCommonUser)