Fixed MissionObject Delta's, Synchronized MissionObject, Fixed MissionListRequest Opcode

This commit is contained in:
Waverunner
2013-12-07 17:58:49 -05:00
parent ff772a1f79
commit ae0b06f917
10 changed files with 411 additions and 138 deletions
+163
View File
@@ -21,29 +21,192 @@
******************************************************************************/
package services;
import java.nio.ByteOrder;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import main.NGECore;
import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import protocol.swg.objectControllerObjects.MissionListRequest;
import resources.common.Console;
import resources.common.TerminalType;
import resources.common.ObjControllerOpcodes;
import resources.objects.creature.CreatureObject;
import resources.objects.mission.MissionObject;
import resources.objects.tangible.TangibleObject;
import engine.clientdata.ClientFileManager;
import engine.clientdata.visitors.DatatableVisitor;
import engine.clients.Client;
import engine.resources.container.Traverser;
import engine.resources.objects.SWGObject;
import engine.resources.scene.Planet;
import engine.resources.service.INetworkDispatch;
import engine.resources.service.INetworkRemoteEvent;
public class MissionService implements INetworkDispatch {
private NGECore core;
public MissionService(NGECore core) {
this.core = core;
}
@Override
public void insertOpcodes(Map<Integer, INetworkRemoteEvent> swgOpcodes, Map<Integer, INetworkRemoteEvent> objControllerOpcodes) {
objControllerOpcodes.put(ObjControllerOpcodes.MISSION_LIST_REQUEST, new INetworkRemoteEvent() {
@Override
public void handlePacket(IoSession session, IoBuffer data) throws Exception {
data.order(ByteOrder.LITTLE_ENDIAN);
MissionListRequest request = new MissionListRequest();
request.deserialize(data);
Client client = core.getClient((Integer) session.getAttribute("connectionId"));
if(client == null || client.getSession() == null)
return;
SWGObject object = client.getParent();
if(object == null)
return;
SWGObject terminal = core.objectService.getObject(request.getTerminalId());
int terminalType = (int) terminal.getAttachment("terminalType");
if (terminalType == TerminalType.MISSION_GENERIC) {
populateMissions(core.objectService.getObject(request.getObjectId()), TerminalType.MISSION_GENERIC);
} else if (terminalType == TerminalType.MISSION_BOUNTYHUNTER) {
} else if (terminalType == TerminalType.MISSION_ENTERTAINER) {
} else if (terminalType == TerminalType.MISSION_ARTISAN) {
} else {
Console.println("ERROR: Unsupported terminal " + terminal.getObjectId());
}
}
});
}
private void populateMissions(final SWGObject player, int type) {
CreatureObject creature = (CreatureObject) player;
TangibleObject missionBag = (TangibleObject) creature.getSlottedObject("mission_bag");
final AtomicInteger deliveryCount = new AtomicInteger();
final AtomicInteger destroyCount = new AtomicInteger();
final int deliveryEntries = 30;
final Random ran = new Random();
final int bagSize = core.objectService.objsInContainer(creature, missionBag);
Console.println("Delivery Entries: " + deliveryEntries);
if (bagSize != 12) {
for(int missionsAdded = 0; missionsAdded < 12; missionsAdded++) {
MissionObject mission = (MissionObject) core.objectService.createObject("object/mission/shared_mission_object.iff", creature.getPlanet());
int textId = ran.nextInt(deliveryEntries);
Console.println("Random Int Value: " + textId);
Console.println("Now the value is: " + textId);
mission.setMissionLevel(5);
mission.setMissionStart(0, 0, 0, player.getPlanet().name);
mission.setMissionCreator("Waverunner");
mission.setMissionCredits(9000);
// TODO: Base this off of textId + f
mission.setTargetTemplateObject("object/tangible/mission/shared_mission_datadisk.iff");
// TODO: Base this off of textId + l
mission.setMissionTargetName("Osskscosco");
mission.setMissionDescription("mission/mission_deliver_neutral_easy", "m" + textId + "d");
mission.setMissionTitle("mission/mission_deliver_neutral_easy", "m" + textId + "t");
mission.setMissionType("deliver");
mission.setMissionDestination(-5962, 0, -6259, player.getPlanet().name);
deliveryCount.getAndIncrement();
missionBag._add(mission);
Console.println("Added mission " + missionsAdded);
}
return;
}
missionBag.viewChildren(player, false, false, new Traverser() {
@Override
public void process(SWGObject child) {
if (deliveryCount.get() == 6)
return;
MissionObject mission = (MissionObject) child;
int textId = ran.nextInt(deliveryEntries);
Console.println("Random Int Value: " + textId);
Console.println("Now the value is: " + textId);
mission.setMissionLevel(5);
mission.setMissionStart(0, 0, 0, player.getPlanet().name);
mission.setMissionCreator("Waverunner");
mission.setMissionCredits(9000);
// TODO: Base this off of textId + f
mission.setTargetTemplateObject("object/tangible/mission/shared_mission_datadisk.iff");
// TODO: Base this off of textId + l
mission.setMissionTargetName("Osskscosco");
mission.setMissionDescription("mission/mission_deliver_neutral_easy", "m" + textId + "d");
mission.setMissionTitle("mission/mission_deliver_neutral_easy", "m" + textId + "t");
mission.setMissionType("deliver");
mission.setMissionDestination(-5962, 0, -6259, player.getPlanet().name);
deliveryCount.getAndIncrement();
}
});
Console.println("Outside of the traverser now!");
}
// May want to create a map for the server with needed info
public int getNumberOfEntries(String stf) {
try {
DatatableVisitor stfFile = ClientFileManager.loadFile(stf, DatatableVisitor.class);
for (int s = 0; s < stfFile.getRowCount(); s++) {
String name = ((String) stfFile.getObject(s, 3));
Console.println("Name: " + name);
if (name.equals("number_of_entries")) {
int entryCount = ((int) stfFile.getObject(s, 4));
Console.println("Entry Count: " + entryCount);
return entryCount;
}
}
}
catch (InstantiationException | IllegalAccessException e) {
e.printStackTrace();
}
return 0;
}
@Override
public void shutdown() {