mirror of
https://github.com/ProjectSWGCore/NGECore2.git
synced 2026-10-02 17:12:58 -04:00
NGECore2 Code
This commit is contained in:
Light2
@@ -0,0 +1,426 @@
|
||||
/*******************************************************************************
|
||||
* Copyright (c) 2013 <Project SWG>
|
||||
*
|
||||
* This File is part of NGECore2.
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Lesser General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU Lesser General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Lesser General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
* Using NGEngine to work with NGECore2 is making a combined work based on NGEngine.
|
||||
* Therefore all terms and conditions of the GNU Lesser General Public License cover the combination.
|
||||
******************************************************************************/
|
||||
package services.chat;
|
||||
|
||||
import java.nio.ByteOrder;
|
||||
import java.sql.Timestamp;
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
import java.util.Random;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.ScheduledExecutorService;
|
||||
|
||||
import org.apache.mina.core.buffer.IoBuffer;
|
||||
import org.apache.mina.core.session.IoSession;
|
||||
|
||||
import com.sleepycat.je.Transaction;
|
||||
import com.sleepycat.persist.EntityCursor;
|
||||
|
||||
import engine.clients.Client;
|
||||
import engine.resources.config.Config;
|
||||
import engine.resources.config.DefaultConfig;
|
||||
import engine.resources.database.ObjectDatabase;
|
||||
import engine.resources.objects.SWGObject;
|
||||
import engine.resources.scene.Point3D;
|
||||
import engine.resources.service.INetworkDispatch;
|
||||
import engine.resources.service.INetworkRemoteEvent;
|
||||
import resources.common.*;
|
||||
|
||||
import protocol.swg.ChatDeletePersistentMessage;
|
||||
import protocol.swg.ChatInstantMessageToCharacter;
|
||||
import protocol.swg.ChatInstantMessagetoClient;
|
||||
import protocol.swg.ChatOnSendInstantMessage;
|
||||
import protocol.swg.ChatOnSendPersistentMessage;
|
||||
import protocol.swg.ChatPersistentMessageToClient;
|
||||
import protocol.swg.ChatPersistentMessageToServer;
|
||||
import protocol.swg.ChatRequestPersistentMessage;
|
||||
import protocol.swg.ObjControllerMessage;
|
||||
import protocol.swg.objectControllerObjects.PlayerEmote;
|
||||
import protocol.swg.objectControllerObjects.SpatialChat;
|
||||
import main.NGECore;
|
||||
|
||||
|
||||
public class ChatService implements INetworkDispatch {
|
||||
|
||||
private NGECore core;
|
||||
private ObjectDatabase mailODB;
|
||||
|
||||
public ChatService(NGECore core) {
|
||||
this.core = core;
|
||||
core.commandService.registerCommand("spatialchatinternal");
|
||||
core.commandService.registerCommand("socialinternal");
|
||||
mailODB = core.getMailODB();
|
||||
}
|
||||
|
||||
public void handleSpatialChat(SWGObject speaker, SWGObject target, String chatMessage, short chatType, short moodId) {
|
||||
|
||||
long targetId;
|
||||
|
||||
if(target == null)
|
||||
targetId = 0;
|
||||
else
|
||||
targetId = target.getObjectID();
|
||||
|
||||
//System.out.println(chatMessage);
|
||||
//System.out.println(chatType);
|
||||
//System.out.println(moodId);
|
||||
|
||||
SpatialChat spatialChat = new SpatialChat(speaker.getObjectID(), targetId, chatMessage, chatType, moodId);
|
||||
ObjControllerMessage objControllerMessage = new ObjControllerMessage(0x0B, spatialChat);
|
||||
|
||||
Client speakerClient = speaker.getClient();
|
||||
|
||||
if(speakerClient == null || speakerClient.getSession() == null)
|
||||
return;
|
||||
|
||||
speakerClient.getSession().write(objControllerMessage.serialize());
|
||||
|
||||
if(speaker.getObservers().isEmpty())
|
||||
return;
|
||||
|
||||
HashSet<Client> observers = new HashSet<Client>(speaker.getObservers());
|
||||
|
||||
Point3D position = speaker.getPosition();
|
||||
|
||||
for(Client client : observers) {
|
||||
float distance = client.getParent().getPosition().getDistance2D(position);
|
||||
if(client != null && client.getSession() != null && distance <= 80) {
|
||||
spatialChat.setDestinationId(client.getParent().getObjectID());
|
||||
ObjControllerMessage objControllerMessage2 = new ObjControllerMessage(0x0B, spatialChat);
|
||||
client.getSession().write(objControllerMessage2.serialize());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void handleEmote(SWGObject speaker, SWGObject target, short emoteId) {
|
||||
|
||||
long targetId;
|
||||
|
||||
if(target == null)
|
||||
targetId = 0;
|
||||
else
|
||||
targetId = target.getObjectID();
|
||||
|
||||
PlayerEmote emote = new PlayerEmote(speaker.getObjectID(), targetId, emoteId);
|
||||
ObjControllerMessage objControllerMessage = new ObjControllerMessage(0x0B, emote);
|
||||
//System.out.println("Emote ID: " + emoteId);
|
||||
Client speakerClient = speaker.getClient();
|
||||
|
||||
if(speakerClient == null || speakerClient.getSession() == null)
|
||||
return;
|
||||
|
||||
speakerClient.getSession().write(objControllerMessage.serialize());
|
||||
|
||||
if(speaker.getObservers().isEmpty())
|
||||
return;
|
||||
|
||||
HashSet<Client> observers = new HashSet<Client>(speaker.getObservers());
|
||||
|
||||
Point3D position = speaker.getPosition();
|
||||
|
||||
for(Client client : observers) {
|
||||
float distance = client.getParent().getPosition().getDistance2D(position);
|
||||
if(client != null && client.getSession() != null && distance <= 80) {
|
||||
emote.setDestinationId(client.getParent().getObjectID());
|
||||
ObjControllerMessage objControllerMessage2 = new ObjControllerMessage(0x0B, emote);
|
||||
client.getSession().write(objControllerMessage2.serialize());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void insertOpcodes( Map<Integer, INetworkRemoteEvent> swgOpcodes, Map<Integer, INetworkRemoteEvent> objControllerOpcodes) {
|
||||
|
||||
swgOpcodes.put(Opcodes.ChatInstantMessageToCharacter, new INetworkRemoteEvent() {
|
||||
|
||||
@Override
|
||||
public void handlePacket(IoSession session, IoBuffer data) throws Exception {
|
||||
|
||||
data = data.order(ByteOrder.LITTLE_ENDIAN);
|
||||
data.position(0);
|
||||
|
||||
ChatInstantMessageToCharacter chatInstantMsg = new ChatInstantMessageToCharacter();
|
||||
chatInstantMsg.deserialize(data);
|
||||
String firstName = chatInstantMsg.getRecipient();
|
||||
|
||||
Client client = core.getClient((Integer) session.getAttribute("connectionId"));
|
||||
|
||||
if(client == null)
|
||||
return;
|
||||
|
||||
SWGObject sender = client.getParent();
|
||||
|
||||
if(sender == null)
|
||||
return;
|
||||
|
||||
|
||||
|
||||
SWGObject recipient = getObjectByFirstName(firstName);
|
||||
|
||||
if(recipient == null || recipient.getClient() == null || recipient.getClient().getSession() == null) {
|
||||
ChatOnSendInstantMessage response = new ChatOnSendInstantMessage(4, chatInstantMsg.getSequence());
|
||||
//System.out.println(response.serialize().getHexDump());
|
||||
session.write(response.serialize());
|
||||
} else {
|
||||
ChatOnSendInstantMessage response = new ChatOnSendInstantMessage(0, chatInstantMsg.getSequence());
|
||||
session.write(response.serialize());
|
||||
ChatInstantMessagetoClient msg = new ChatInstantMessagetoClient(chatInstantMsg.getGalaxy(), chatInstantMsg.getMessage(), sender.getCustomName().split(" ")[0]);
|
||||
recipient.getClient().getSession().write(msg.serialize());
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
swgOpcodes.put(Opcodes.ChatPersistentMessageToServer, new INetworkRemoteEvent() {
|
||||
|
||||
@Override
|
||||
public void handlePacket(IoSession session, IoBuffer data) throws Exception {
|
||||
|
||||
data = data.order(ByteOrder.LITTLE_ENDIAN);
|
||||
data.position(0);
|
||||
|
||||
ChatPersistentMessageToServer packet = new ChatPersistentMessageToServer();
|
||||
packet.deserialize(data);
|
||||
|
||||
Client client = core.getClient((Integer) session.getAttribute("connectionId"));
|
||||
|
||||
if(client == null)
|
||||
return;
|
||||
|
||||
SWGObject sender = client.getParent();
|
||||
|
||||
if(sender == null)
|
||||
return;
|
||||
|
||||
SWGObject recipient = getObjectByFirstName(packet.getRecipient());
|
||||
|
||||
if(recipient == null || recipient.getSlottedObject("ghost" ) == null) {
|
||||
ChatOnSendPersistentMessage response = new ChatOnSendPersistentMessage(4, packet.getCounter());
|
||||
session.write(response.serialize());
|
||||
//System.out.println(packet.getRecipient());
|
||||
} else {
|
||||
Date date = new Date();
|
||||
Mail mail = new Mail();
|
||||
mail.setMailId(generateMailId());
|
||||
mail.setMessage(packet.getMessage());
|
||||
mail.setRecieverId(recipient.getObjectID());
|
||||
mail.setSenderName(sender.getCustomName().split(" ")[0]);
|
||||
mail.setStatus(Mail.NEW);
|
||||
mail.setSubject(packet.getSubject());
|
||||
mail.setTimeStamp((int) (date.getTime() / 1000));
|
||||
|
||||
storePersistentMessage(mail);
|
||||
|
||||
if(recipient.getClient() != null) {
|
||||
sendPersistentMessageHeader(recipient.getClient(), mail);
|
||||
}
|
||||
|
||||
ChatOnSendPersistentMessage response = new ChatOnSendPersistentMessage(0, packet.getCounter());
|
||||
session.write(response.serialize());
|
||||
}
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
swgOpcodes.put(Opcodes.ChatRequestPersistentMessage, new INetworkRemoteEvent() {
|
||||
|
||||
@Override
|
||||
public void handlePacket(IoSession session, IoBuffer data) throws Exception {
|
||||
|
||||
data = data.order(ByteOrder.LITTLE_ENDIAN);
|
||||
data.position(0);
|
||||
|
||||
ChatRequestPersistentMessage packet = new ChatRequestPersistentMessage();
|
||||
packet.deserialize(data);
|
||||
|
||||
Client client = core.getClient((Integer) session.getAttribute("connectionId"));
|
||||
|
||||
if(client == null)
|
||||
return;
|
||||
|
||||
SWGObject obj = client.getParent();
|
||||
Mail mail = mailODB.get(new Integer(packet.getMailId()), Integer.class, Mail.class);
|
||||
|
||||
if(obj == null || mail == null)
|
||||
return;
|
||||
|
||||
if(mail.getRecieverId() != obj.getObjectID())
|
||||
return;
|
||||
|
||||
mail.setStatus(Mail.READ);
|
||||
|
||||
sendPersistentMessage(client, mail);
|
||||
|
||||
storePersistentMessage(mail);
|
||||
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
swgOpcodes.put(Opcodes.ChatDeletePersistentMessage, new INetworkRemoteEvent() {
|
||||
|
||||
@Override
|
||||
public void handlePacket(IoSession session, IoBuffer data) throws Exception {
|
||||
|
||||
data = data.order(ByteOrder.LITTLE_ENDIAN);
|
||||
data.position(0);
|
||||
|
||||
ChatDeletePersistentMessage packet = new ChatDeletePersistentMessage();
|
||||
packet.deserialize(data);
|
||||
|
||||
Client client = core.getClient((Integer) session.getAttribute("connectionId"));
|
||||
|
||||
if(client == null)
|
||||
return;
|
||||
|
||||
SWGObject obj = client.getParent();
|
||||
Mail mail = mailODB.get(new Integer(packet.getMailId()), Integer.class, Mail.class);
|
||||
|
||||
if(obj == null || mail == null)
|
||||
return;
|
||||
|
||||
if(mail.getRecieverId() != obj.getObjectID())
|
||||
return;
|
||||
|
||||
deletePersistentMessage(mail);
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
public void sendPersistentMessageHeader(Client client, Mail mail) {
|
||||
|
||||
if(client.getSession() == null)
|
||||
return;
|
||||
|
||||
Config config = new Config();
|
||||
config.setFilePath("nge.cfg");
|
||||
if (!(config.loadConfigFile())) {
|
||||
config = DefaultConfig.getConfig();
|
||||
}
|
||||
|
||||
//System.out.println(config.getString("GALAXY_NAME"));
|
||||
|
||||
ChatPersistentMessageToClient msg = new ChatPersistentMessageToClient(mail.getSenderName(), config.getString("GALAXY_NAME"), mail.getMailId()
|
||||
,(byte) 1, "", mail.getSubject(), mail.getStatus(), mail.getTimeStamp());
|
||||
|
||||
client.getSession().write(msg.serialize());
|
||||
}
|
||||
|
||||
public void sendPersistentMessage(Client client, Mail mail) {
|
||||
|
||||
if(client.getSession() == null)
|
||||
return;
|
||||
|
||||
Config config = new Config();
|
||||
config.setFilePath("nge.cfg");
|
||||
if (!(config.loadConfigFile())) {
|
||||
config = DefaultConfig.getConfig();
|
||||
}
|
||||
|
||||
//System.out.println(config.getString("GALAXY_NAME"));
|
||||
|
||||
ChatPersistentMessageToClient msg = new ChatPersistentMessageToClient(mail.getSenderName(), config.getString("GALAXY_NAME"), mail.getMailId()
|
||||
,(byte) 0, mail.getMessage(), mail.getSubject(), mail.getStatus(), mail.getTimeStamp());
|
||||
|
||||
client.getSession().write(msg.serialize());
|
||||
}
|
||||
|
||||
|
||||
public void storePersistentMessage(Mail mail) {
|
||||
Transaction txn = mailODB.getEnvironment().beginTransaction(null, null);
|
||||
mailODB.put(mail, Integer.class, Mail.class, txn);
|
||||
txn.commitSync();
|
||||
}
|
||||
|
||||
public void deletePersistentMessage(Mail mail) {
|
||||
Transaction txn = mailODB.getEnvironment().beginTransaction(null, null);
|
||||
mailODB.delete(new Integer(mail.getMailId()), Integer.class, Mail.class, txn);
|
||||
txn.commitSync();
|
||||
}
|
||||
|
||||
public void loadMailHeaders(Client client) {
|
||||
|
||||
SWGObject obj = client.getParent();
|
||||
|
||||
if(obj == null || client.getSession() == null)
|
||||
return;
|
||||
|
||||
EntityCursor<Mail> cursor = mailODB.getCursor(Integer.class, Mail.class);
|
||||
|
||||
for(Mail mail : cursor) {
|
||||
|
||||
if(mail.getRecieverId() == obj.getObjectID())
|
||||
sendPersistentMessageHeader(client, mail);
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void shutdown() {
|
||||
|
||||
}
|
||||
|
||||
public SWGObject getObjectByFirstName(String name) {
|
||||
ConcurrentHashMap<Integer, Client> clients = core.getActiveConnectionsMap();
|
||||
|
||||
for(Client client : clients.values()) {
|
||||
if(client.getParent() == null)
|
||||
continue;
|
||||
|
||||
String fullName = client.getParent().getCustomName();
|
||||
String firstName = fullName.split(" ")[0];
|
||||
|
||||
if(firstName.equalsIgnoreCase(name))
|
||||
return client.getParent();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public int generateMailId() {
|
||||
Random rand = new Random();
|
||||
|
||||
int id = rand.nextInt();
|
||||
|
||||
if(mailODB.contains(new Integer(id), Integer.class, Mail.class))
|
||||
return generateMailId();
|
||||
else
|
||||
return id;
|
||||
}
|
||||
|
||||
public Mail getMailById(int mailId) {
|
||||
|
||||
Mail mail = mailODB.get(new Integer(mailId), Integer.class, Mail.class);
|
||||
return mail;
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user