mirror of
https://bitbucket.org/projectswg/cucore.git
synced 2026-07-14 23:07:39 -04:00
332 lines
11 KiB
Java
332 lines
11 KiB
Java
package services.objects;
|
|
|
|
import intents.GalacticPacketIntent;
|
|
import intents.PlayerEventIntent;
|
|
import intents.swgobject_events.SWGObjectEventIntent;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.LinkedList;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import main.ProjectSWG;
|
|
import network.packets.swg.zone.HeartBeatMessage;
|
|
import network.packets.swg.zone.ParametersMessage;
|
|
import network.packets.swg.zone.UpdatePvpStatusMessage;
|
|
import network.packets.swg.zone.chat.ChatOnConnectAvatar;
|
|
import network.packets.swg.zone.chat.VoiceChatStatus;
|
|
import network.packets.swg.zone.insertion.ChatServerStatus;
|
|
import network.packets.swg.zone.insertion.CmdStartScene;
|
|
import network.packets.swg.zone.insertion.SelectCharacter;
|
|
import network.packets.swg.zone.object_controller.DataTransform;
|
|
import network.packets.swg.zone.object_controller.ObjectController;
|
|
import resources.Location;
|
|
import resources.Race;
|
|
import resources.Terrain;
|
|
import resources.client_info.ClientFactory;
|
|
import resources.client_info.visitors.ObjectData;
|
|
import resources.client_info.visitors.SlotArrangementData;
|
|
import resources.client_info.visitors.SlotDescriptorData;
|
|
import resources.control.Intent;
|
|
import resources.control.Manager;
|
|
import resources.objects.SWGObject;
|
|
import resources.objects.creature.CreatureObject;
|
|
import resources.objects.quadtree.QuadTree;
|
|
import resources.player.Player;
|
|
import resources.player.PlayerEvent;
|
|
import resources.player.PlayerState;
|
|
import resources.server_info.CachedObjectDatabase;
|
|
import resources.server_info.ObjectDatabase;
|
|
import resources.server_info.ObjectDatabase.Traverser;
|
|
import services.player.PlayerManager;
|
|
|
|
public class ObjectManager extends Manager {
|
|
|
|
private static final double AWARE_RANGE = 200;
|
|
|
|
private ClientFactory clientFac;
|
|
|
|
private ObjectDatabase<SWGObject> objects;
|
|
private Map <Terrain, QuadTree <SWGObject>> quadTree;
|
|
private long maxObjectId;
|
|
|
|
public ObjectManager() {
|
|
objects = new CachedObjectDatabase<SWGObject>("odb/objects.db");
|
|
quadTree = new HashMap<Terrain, QuadTree<SWGObject>>();
|
|
maxObjectId = 1;
|
|
}
|
|
|
|
@Override
|
|
public boolean initialize() {
|
|
registerForIntent(SWGObjectEventIntent.TYPE);
|
|
registerForIntent(GalacticPacketIntent.TYPE);
|
|
registerForIntent(PlayerEventIntent.TYPE);
|
|
loadQuadTree();
|
|
loadObjects();
|
|
clientFac = new ClientFactory();
|
|
return super.initialize();
|
|
}
|
|
|
|
private void loadQuadTree() {
|
|
for (Terrain t : Terrain.values()) {
|
|
quadTree.put(t, new QuadTree<SWGObject>(-8192, -8192, 8192, 8192));
|
|
}
|
|
}
|
|
|
|
private void loadObjects() {
|
|
long startLoad = System.nanoTime();
|
|
System.out.println("ObjectManager: Loading objects from ObjectDatabase...");
|
|
objects.load();
|
|
objects.traverse(new Traverser<SWGObject>() {
|
|
@Override
|
|
public void process(SWGObject obj) {
|
|
loadObject(obj);
|
|
if (obj.getObjectId() >= maxObjectId) {
|
|
maxObjectId = obj.getObjectId() + 1;
|
|
}
|
|
}
|
|
});
|
|
double loadTime = (System.nanoTime() - startLoad) / 1E6;
|
|
System.out.printf("ObjectManager: Finished loading %d objects. Time: %fms%n", objects.size(), loadTime);
|
|
}
|
|
|
|
private void loadObject(SWGObject obj) {
|
|
obj.setOwner(null);
|
|
Location l = obj.getLocation();
|
|
if (l.getTerrain() != null) {
|
|
QuadTree <SWGObject> tree = quadTree.get(l.getTerrain());
|
|
if (tree != null) {
|
|
tree.put(l.getX(), l.getZ(), obj);
|
|
} else {
|
|
System.err.println("ObjectManager: Unable to load QuadTree for object " + obj.getObjectId() + " and terrain: " + l.getTerrain());
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean terminate() {
|
|
objects.traverse(new Traverser<SWGObject>() {
|
|
@Override
|
|
public void process(SWGObject obj) {
|
|
obj.setOwner(null);
|
|
}
|
|
});
|
|
objects.save();
|
|
return super.terminate();
|
|
}
|
|
|
|
@Override
|
|
public void onIntentReceived(Intent i) {
|
|
if (i instanceof GalacticPacketIntent) {
|
|
processGalacticPacketIntent((GalacticPacketIntent) i);
|
|
} else if (i instanceof PlayerEventIntent) {
|
|
if (((PlayerEventIntent)i).getEvent() == PlayerEvent.PE_DISAPPEAR) {
|
|
SWGObject obj = ((PlayerEventIntent)i).getPlayer().getCreatureObject();
|
|
obj.setOwner(null);
|
|
obj.clearAware();
|
|
}
|
|
}
|
|
}
|
|
|
|
private void processGalacticPacketIntent(GalacticPacketIntent gpi) {
|
|
if (gpi.getPacket() instanceof SelectCharacter) {
|
|
PlayerManager pm = gpi.getPlayerManager();
|
|
String galaxy = gpi.getGalaxy().getName();
|
|
long characterId = ((SelectCharacter)gpi.getPacket()).getCharacterId();
|
|
zoneInCharacter(pm, galaxy, gpi.getNetworkId(), characterId);
|
|
} else if (gpi.getPacket() instanceof ObjectController) {
|
|
ObjectController controller = (ObjectController) gpi.getPacket();
|
|
if (controller.getControllerData() instanceof DataTransform) {
|
|
DataTransform trans = (DataTransform) controller.getControllerData();
|
|
SWGObject obj = getObjectById(controller.getObjectId());
|
|
moveObject(obj, trans);
|
|
}
|
|
}
|
|
}
|
|
|
|
public SWGObject getObjectById(long objectId) {
|
|
synchronized (objects) {
|
|
return objects.get(objectId);
|
|
}
|
|
}
|
|
|
|
public SWGObject deleteObject(long objId) {
|
|
synchronized (objects) {
|
|
SWGObject obj = objects.remove(objId);
|
|
if (obj == null)
|
|
return null;
|
|
Location loc = obj.getLocation();
|
|
if (loc != null && loc.getTerrain() != null) {
|
|
QuadTree <SWGObject> tree = quadTree.get(loc.getTerrain());
|
|
synchronized (tree) {
|
|
tree.remove(loc.getX(), loc.getZ(), obj);
|
|
}
|
|
}
|
|
for (SWGObject child : obj.getChildren())
|
|
if (child != null)
|
|
deleteObject(child.getObjectId());
|
|
for (SWGObject slot : obj.getSlots().values())
|
|
if (slot != null)
|
|
deleteObject(slot.getObjectId());
|
|
return obj;
|
|
}
|
|
}
|
|
|
|
public SWGObject createObject(String template) {
|
|
return createObject(template, null);
|
|
}
|
|
|
|
public SWGObject createObject(String template, Location l) {
|
|
synchronized (objects) {
|
|
long objectId = getNextObjectId();
|
|
SWGObject obj = ObjectCreator.createObjectFromTemplate(objectId, template);
|
|
if (obj == null) {
|
|
System.err.println("ObjectManager: Unable to create object with template " + template);
|
|
return null;
|
|
}
|
|
addObjectAttributes(obj, template);
|
|
obj.setTemplate(template);
|
|
obj.setLocation(l);
|
|
updateAwarenessForObject(obj);
|
|
addToQuadTree(obj);
|
|
objects.put(objectId, obj);
|
|
return obj;
|
|
}
|
|
}
|
|
|
|
private void addToQuadTree(SWGObject obj) {
|
|
if (obj == null)
|
|
return;
|
|
Location loc = obj.getLocation();
|
|
if (loc == null || loc.getTerrain() == null)
|
|
return;
|
|
QuadTree <SWGObject> tree = quadTree.get(loc.getTerrain());
|
|
synchronized (tree) {
|
|
tree.put(loc.getX(), loc.getZ(), obj);
|
|
}
|
|
}
|
|
|
|
private void removeFromQuadTree(SWGObject obj) {
|
|
if (obj == null)
|
|
return;
|
|
Location loc = obj.getLocation();
|
|
if (loc == null || loc.getTerrain() == null)
|
|
return;
|
|
double x = loc.getX();
|
|
double y = loc.getZ();
|
|
QuadTree <SWGObject> tree = quadTree.get(loc.getTerrain());
|
|
synchronized (tree) {
|
|
tree.remove(x, y, obj);
|
|
}
|
|
}
|
|
|
|
private void moveObject(SWGObject obj, DataTransform transform) {
|
|
removeFromQuadTree(obj);
|
|
Location newLocation = transform.getLocation();
|
|
newLocation.setTerrain(obj.getLocation().getTerrain());
|
|
|
|
if (newLocation != null)
|
|
obj.setLocation(newLocation);
|
|
|
|
updateAwarenessForObject(obj);
|
|
addToQuadTree(obj);
|
|
|
|
if (transform != null)
|
|
obj.sendDataTransforms(transform);
|
|
}
|
|
|
|
private void updateAwarenessForObject(SWGObject obj) {
|
|
Location location = obj.getLocation();
|
|
if (location == null || location.getTerrain() == null)
|
|
return;
|
|
List <Player> updatedAware = new LinkedList<Player>();
|
|
double x = location.getX();
|
|
double y = location.getZ();
|
|
QuadTree<SWGObject> tree = quadTree.get(location.getTerrain());
|
|
synchronized (tree) {
|
|
List <SWGObject> range = tree.getWithinRange(x, y, AWARE_RANGE);
|
|
for (SWGObject inRange : range) {
|
|
if (inRange.getOwner() != null && inRange.getObjectId() != obj.getObjectId()) {
|
|
updatedAware.add(inRange.getOwner());
|
|
}
|
|
}
|
|
}
|
|
obj.updateAwareness(updatedAware);
|
|
}
|
|
|
|
private void addObjectAttributes(SWGObject obj, String template) {
|
|
ObjectData attributes = (ObjectData) clientFac.getInfoFromFile(ClientFactory.formatToSharedFile(template));
|
|
|
|
obj.setStf((String) attributes.getAttribute(ObjectData.OBJ_STF));
|
|
obj.setDetailStf((String) attributes.getAttribute(ObjectData.DETAIL_STF));
|
|
obj.setVolume((Integer) attributes.getAttribute(ObjectData.VOLUME_LIMIT));
|
|
|
|
addSlotsToObject(obj, attributes);
|
|
}
|
|
|
|
private void addSlotsToObject(SWGObject obj, ObjectData attributes) {
|
|
if (attributes.getAttribute(ObjectData.SLOT_DESCRIPTOR) != null) {
|
|
// These are the slots that the object *HAS*
|
|
SlotDescriptorData descriptor = (SlotDescriptorData) clientFac.getInfoFromFile((String) attributes.getAttribute(ObjectData.SLOT_DESCRIPTOR));
|
|
|
|
for (String slotName : descriptor.getSlots()) {
|
|
obj.addObjectSlot(slotName, null);
|
|
}
|
|
}
|
|
|
|
if (attributes.getAttribute(ObjectData.ARRANGEMENT_FILE) != null) {
|
|
// This is what slots the object *USES*
|
|
SlotArrangementData arrangementData = (SlotArrangementData) clientFac.getInfoFromFile((String) attributes.getAttribute(ObjectData.ARRANGEMENT_FILE));
|
|
obj.setArrangment(arrangementData.getArrangement());
|
|
}
|
|
}
|
|
|
|
private void zoneInCharacter(PlayerManager playerManager, String galaxy, long netId, long characterId) {
|
|
Player player = playerManager.getPlayerFromNetworkId(netId);
|
|
if (player == null)
|
|
return;
|
|
verifyPlayerObjectsSet(player, characterId);
|
|
long objId = player.getCreatureObject().getObjectId();
|
|
Race race = ((CreatureObject) player.getCreatureObject()).getRace();
|
|
Location l = player.getCreatureObject().getLocation();
|
|
long time = (long)(ProjectSWG.getCoreTime()/1E3);
|
|
CreatureObject creature = (CreatureObject) player.getCreatureObject();
|
|
sendPacket(player, new HeartBeatMessage());
|
|
sendPacket(player, new ChatServerStatus(true));
|
|
sendPacket(player, new VoiceChatStatus());
|
|
sendPacket(player, new ParametersMessage());
|
|
sendPacket(player, new ChatOnConnectAvatar());
|
|
sendPacket(player, new CmdStartScene(false, objId, race, l, time));
|
|
sendPacket(player, new UpdatePvpStatusMessage(creature.getPvpType(), creature.getPvpFactionId(), creature.getObjectId()));
|
|
creature.createObject(player);
|
|
creature.clearAware();
|
|
updateAwarenessForObject(creature);
|
|
player.setPlayerState(PlayerState.ZONED_IN);
|
|
System.out.println("[" + player.getUsername() + "] " + player.getCharacterName() + " is zoning in");
|
|
new PlayerEventIntent(player, galaxy, PlayerEvent.PE_ZONE_IN).broadcast();
|
|
}
|
|
|
|
private void verifyPlayerObjectsSet(Player player, long characterId) {
|
|
if (player.getCreatureObject() != null && player.getPlayerObject() != null)
|
|
return;
|
|
SWGObject creature = objects.get(characterId);
|
|
if (creature == null) {
|
|
System.err.println("ObjectManager: Failed to start zone - CreatureObject could not be fetched from database [Character: " + characterId + " User: " + player.getUsername() + "]");
|
|
return;
|
|
}
|
|
player.setCreatureObject(creature);
|
|
creature.setOwner(player);
|
|
|
|
if (player.getPlayerObject() == null) {
|
|
System.err.println("FATAL: " + player.getUsername() + "'s CreatureObject has a null ghost!");
|
|
}
|
|
}
|
|
|
|
private long getNextObjectId() {
|
|
synchronized (objects) {
|
|
return maxObjectId++;
|
|
}
|
|
}
|
|
|
|
}
|