projectswg/Holocore
1
0
Fork 0
mirror of https://github.com/ProjectSWGCore/Holocore.git synced 2026-10-18 08:02:56 -04:00
Code Issues Projects Releases Wiki Activity

Zoning in a character now sends PlayerEvent.PE_ZONE_IN PlayerEventIntent to registered services, ChatService now receives zoning in intents, Persistent Message headers are now sent on login, Added default access level if it's not specified in the database (AccessLevel.PLAYER is default)

Browse Source
This commit is contained in:
Waverunner
2015-01-11 12:24:15 -05:00
parent 06575f5653
commit e4c1fa8277
4 changed files with 60 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/services/chat/ChatService.java
+45
View File
@@ -1,12 +1,16 @@
package services.chat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import intents.GalacticPacketIntent;
import intents.PlayerEventIntent;
import intents.chat.PersistentMessageIntent;
import intents.chat.SpatialChatIntent;
import network.packets.Packet;
import network.packets.swg.zone.ChatRequestRoomList;
import network.packets.swg.zone.chat.ChatDeletePersistentMessage;
import network.packets.swg.zone.chat.ChatInstantMessageToCharacter;
import network.packets.swg.zone.chat.ChatInstantMessageToClient;
import network.packets.swg.zone.chat.ChatOnSendInstantMessage;
@@ -40,6 +44,7 @@ public class ChatService extends Service {
registerForIntent(GalacticPacketIntent.TYPE);
registerForIntent(SpatialChatIntent.TYPE);
registerForIntent(PersistentMessageIntent.TYPE);
registerForIntent(PlayerEventIntent.TYPE);
mails.loadToCache();
mails.traverse(new Traverser<Mail>() {
@Override
@@ -66,12 +71,25 @@ public class ChatService extends Service {
((GalacticPacketIntent) i).getGalaxy().getName(), (ChatPersistentMessageToServer) p);
else if (p instanceof ChatRequestPersistentMessage)
handlePersistentMessageRequest(player, ((GalacticPacketIntent) i).getGalaxy().getName(), (ChatRequestPersistentMessage) p);
else if (p instanceof ChatDeletePersistentMessage)
deletePersistentMessage(((ChatDeletePersistentMessage) p).getMailId());
}
}
else if (i instanceof SpatialChatIntent)
handleSpatialChat((SpatialChatIntent) i);
else if (i instanceof PersistentMessageIntent)
handlePersistentMessageIntent((PersistentMessageIntent) i);
else if (i instanceof PlayerEventIntent)
handlePlayerEventIntent((PlayerEventIntent) i);
}
private void handlePlayerEventIntent(PlayerEventIntent intent) {
switch(intent.getEvent()) {
case PE_ZONE_IN:
sendPersistentMessageHeaders(intent.getPlayer(), intent.getGalaxy());
break;
default: break;
}
}
private void handleChatRoomListRequest(Player player, ChatRequestRoomList request) {
@@ -186,6 +204,29 @@ public class ChatService extends Service {
sendPersistentMessage(player, mail, MailFlagType.FULL_MESSAGE, galaxy);
}
private void sendPersistentMessageHeaders(Player player, String galaxy) {
if (player == null || player.getCreatureObject() == null)
return;
final long receiverId = player.getCreatureObject().getObjectId();
final List<Mail> playersMail = new ArrayList<Mail>();
mails.traverse(new Traverser<Mail>() {
@Override
public void process(Mail element) {
if (element.getReceiverId() == receiverId)
playersMail.add(element);
}
});
if (playersMail.isEmpty())
return;
for (Mail mail : playersMail) { sendPersistentMessage(player, mail, MailFlagType.HEADER_ONLY, galaxy); }
}
private void sendPersistentMessage(Player receiver, Mail mail, MailFlagType requestType, String galaxy) {
if (receiver == null || receiver.getCreatureObject() == null)
return;
@@ -209,6 +250,10 @@ public class ChatService extends Service {
receiver.sendPacket(packet);
}
private void deletePersistentMessage(int mailId) {
mails.remove(mailId);
}
private enum MailFlagType {
FULL_MESSAGE,
HEADER_ONLY;