mirror of
https://github.com/collinsmith/riiablo.git
synced 2025-07-04 15:27:30 +07:00
Decoupled network sync code from NetworkedGameScreen into ClientNetworkReceiver
This commit is contained in:
Collin Smith
264
core/src/com/riiablo/engine/client/ClientNetworkReceiver.java
Normal file
264
core/src/com/riiablo/engine/client/ClientNetworkReceiver.java
Normal file
@ -0,0 +1,264 @@
|
|||||||
|
package com.riiablo.engine.client;
|
||||||
|
|
||||||
|
import com.artemis.ComponentMapper;
|
||||||
|
import com.artemis.annotations.All;
|
||||||
|
import com.artemis.annotations.Wire;
|
||||||
|
import com.artemis.systems.IntervalSystem;
|
||||||
|
import com.badlogic.gdx.Gdx;
|
||||||
|
import com.badlogic.gdx.math.Vector2;
|
||||||
|
import com.badlogic.gdx.net.Socket;
|
||||||
|
import com.badlogic.gdx.physics.box2d.Body;
|
||||||
|
import com.riiablo.CharData;
|
||||||
|
import com.riiablo.CharacterClass;
|
||||||
|
import com.riiablo.Riiablo;
|
||||||
|
import com.riiablo.engine.Dirty;
|
||||||
|
import com.riiablo.engine.Engine;
|
||||||
|
import com.riiablo.engine.EntityFactory;
|
||||||
|
import com.riiablo.engine.server.CofManager;
|
||||||
|
import com.riiablo.engine.server.component.Angle;
|
||||||
|
import com.riiablo.engine.server.component.Box2DBody;
|
||||||
|
import com.riiablo.engine.server.component.CofAlphas;
|
||||||
|
import com.riiablo.engine.server.component.CofComponents;
|
||||||
|
import com.riiablo.engine.server.component.CofTransforms;
|
||||||
|
import com.riiablo.engine.server.component.Networked;
|
||||||
|
import com.riiablo.engine.server.component.Player;
|
||||||
|
import com.riiablo.engine.server.component.Position;
|
||||||
|
import com.riiablo.engine.server.component.Velocity;
|
||||||
|
import com.riiablo.map.Map;
|
||||||
|
import com.riiablo.net.packet.d2gs.Connection;
|
||||||
|
import com.riiablo.net.packet.d2gs.D2GS;
|
||||||
|
import com.riiablo.net.packet.d2gs.D2GSData;
|
||||||
|
import com.riiablo.net.packet.d2gs.Disconnect;
|
||||||
|
import com.riiablo.net.packet.d2gs.Sync;
|
||||||
|
import com.riiablo.net.packet.d2gs.SyncData;
|
||||||
|
import com.riiablo.util.ArrayUtils;
|
||||||
|
import com.riiablo.util.DebugUtils;
|
||||||
|
import com.riiablo.widget.TextArea;
|
||||||
|
|
||||||
|
import java.io.InputStream;
|
||||||
|
import java.nio.ByteBuffer;
|
||||||
|
import java.nio.channels.Channels;
|
||||||
|
import java.nio.channels.ReadableByteChannel;
|
||||||
|
import java.util.Arrays;
|
||||||
|
|
||||||
|
@All(Networked.class)
|
||||||
|
public class ClientNetworkReceiver extends IntervalSystem {
|
||||||
|
private static final String TAG = "ClientNetworkReceiver";
|
||||||
|
|
||||||
|
protected ComponentMapper<Networked> mNetworked;
|
||||||
|
protected ComponentMapper<CofComponents> mCofComponents;
|
||||||
|
protected ComponentMapper<CofTransforms> mCofTransforms;
|
||||||
|
protected ComponentMapper<CofAlphas> mCofAlphas;
|
||||||
|
protected ComponentMapper<Position> mPosition;
|
||||||
|
protected ComponentMapper<Velocity> mVelocity;
|
||||||
|
protected ComponentMapper<Angle> mAngle;
|
||||||
|
protected ComponentMapper<Player> mPlayer;
|
||||||
|
protected ComponentMapper<Box2DBody> mBox2DBody;
|
||||||
|
|
||||||
|
protected CofManager cofs;
|
||||||
|
protected NetworkIdManager syncIds;
|
||||||
|
|
||||||
|
@Wire(name="client.socket")
|
||||||
|
protected Socket socket;
|
||||||
|
|
||||||
|
@Wire(name = "factory")
|
||||||
|
protected EntityFactory factory;
|
||||||
|
|
||||||
|
@Wire(name = "map")
|
||||||
|
protected Map map;
|
||||||
|
|
||||||
|
@Wire(name = "output")
|
||||||
|
protected TextArea output;
|
||||||
|
|
||||||
|
private final ByteBuffer buffer = ByteBuffer.allocate(8192);
|
||||||
|
|
||||||
|
public ClientNetworkReceiver() {
|
||||||
|
super(null, 1 / 60f);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected void processSystem() {
|
||||||
|
InputStream in = socket.getInputStream();
|
||||||
|
try {
|
||||||
|
while (in.available() > 0) {
|
||||||
|
ReadableByteChannel channel = Channels.newChannel(in);
|
||||||
|
buffer.clear();
|
||||||
|
channel.read(buffer);
|
||||||
|
buffer.limit(buffer.position()).rewind();
|
||||||
|
D2GS packet = D2GS.getRootAsD2GS(buffer);
|
||||||
|
System.out.println("packet type " + D2GSData.name(packet.dataType()));
|
||||||
|
process(packet);
|
||||||
|
}
|
||||||
|
} catch (Throwable t) {
|
||||||
|
Gdx.app.error(TAG, t.getMessage(), t);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void process(D2GS packet) {
|
||||||
|
switch (packet.dataType()) {
|
||||||
|
case D2GSData.Connection:
|
||||||
|
Connection(packet);
|
||||||
|
break;
|
||||||
|
case D2GSData.Disconnect:
|
||||||
|
Disconnect(packet);
|
||||||
|
break;
|
||||||
|
case D2GSData.Sync:
|
||||||
|
Synchronize(packet);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
Gdx.app.error(TAG, "Unknown packet type: " + packet.dataType());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void Connection(D2GS packet) {
|
||||||
|
Connection connection = (Connection) packet.data(new Connection());
|
||||||
|
String charName = connection.charName();
|
||||||
|
int charClass = connection.charClass();
|
||||||
|
|
||||||
|
output.appendText(Riiablo.string.format(3641, charName));
|
||||||
|
output.appendText("\n");
|
||||||
|
|
||||||
|
CharData charData = new CharData().createD2S(charName, CharacterClass.get(charClass));
|
||||||
|
|
||||||
|
Vector2 origin = map.find(Map.ID.TOWN_ENTRY_1);
|
||||||
|
if (origin == null) origin = map.find(Map.ID.TOWN_ENTRY_2);
|
||||||
|
if (origin == null) origin = map.find(Map.ID.TP_LOCATION);
|
||||||
|
Map.Zone zone = map.getZone(origin);
|
||||||
|
int entityId = factory.createPlayer(map, zone, charData, origin);
|
||||||
|
syncIds.put(connection.entityId(), entityId);
|
||||||
|
int[] component = mCofComponents.get(entityId).component;
|
||||||
|
for (int i = 0; i < 16; i++) component[i] = connection.cofComponents(i);
|
||||||
|
float[] alpha = mCofAlphas.get(entityId).alpha;
|
||||||
|
for (int i = 0; i < 16; i++) alpha[i] = connection.cofAlphas(i);
|
||||||
|
byte[] transform = mCofTransforms.get(entityId).transform;
|
||||||
|
for (int i = 0; i < 16; i++) transform[i] = (byte) connection.cofTransforms(i);
|
||||||
|
|
||||||
|
int alphaFlags = Dirty.NONE;
|
||||||
|
int transformFlags = Dirty.NONE;
|
||||||
|
cofs.setMode(entityId, Engine.Player.MODE_TN);
|
||||||
|
cofs.setWClass(entityId, Engine.WEAPON_1HS); // TODO...
|
||||||
|
for (int i = 0; i < 16; i++) {
|
||||||
|
cofs.setComponent(entityId, i, connection.cofComponents(i));
|
||||||
|
}
|
||||||
|
for (int i = 0; i < 16; i++) {
|
||||||
|
alphaFlags |= cofs.setAlpha(entityId, i, connection.cofAlphas(i));
|
||||||
|
transformFlags |= cofs.setTransform(entityId, i, (byte) connection.cofTransforms(i));
|
||||||
|
}
|
||||||
|
|
||||||
|
cofs.updateAlpha(entityId, alphaFlags);
|
||||||
|
cofs.updateTransform(entityId, transformFlags);
|
||||||
|
cofs.setMode(entityId, Engine.Player.MODE_TN, true);
|
||||||
|
|
||||||
|
System.out.println(" " + DebugUtils.toByteArray(ArrayUtils.toByteArray(component)));
|
||||||
|
System.out.println(" " + Arrays.toString(alpha));
|
||||||
|
System.out.println(" " + DebugUtils.toByteArray(transform));
|
||||||
|
}
|
||||||
|
|
||||||
|
private void Disconnect(D2GS packet) {
|
||||||
|
Disconnect disconnect = (Disconnect) packet.data(new Disconnect());
|
||||||
|
int serverEntityId = disconnect.entityId();
|
||||||
|
System.out.println("serverEntityId=" + serverEntityId);
|
||||||
|
int entityId = syncIds.get(serverEntityId);
|
||||||
|
|
||||||
|
CharData data = mPlayer.get(entityId).data;
|
||||||
|
|
||||||
|
output.appendText(Riiablo.string.format(3642, data.getD2S().header.name));
|
||||||
|
output.appendText("\n");
|
||||||
|
|
||||||
|
world.delete(entityId);
|
||||||
|
}
|
||||||
|
|
||||||
|
private com.riiablo.net.packet.d2gs.Player findPlayer(Sync s) {
|
||||||
|
for (int i = 0, len = s.dataTypeLength(); i < len; i++) {
|
||||||
|
if (s.dataType(i) == SyncData.Player) {
|
||||||
|
return (com.riiablo.net.packet.d2gs.Player) s.data(new com.riiablo.net.packet.d2gs.Player(), i);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void Synchronize(D2GS packet) {
|
||||||
|
Sync sync = (Sync) packet.data(new Sync());
|
||||||
|
int entityId = syncIds.get(sync.entityId());
|
||||||
|
if (entityId == Engine.INVALID_ENTITY) {
|
||||||
|
com.riiablo.net.packet.d2gs.Player player = findPlayer(sync);
|
||||||
|
CharData charData = new CharData().createD2S(player.charName(), CharacterClass.get(player.charClass()));
|
||||||
|
|
||||||
|
// TODO: assert entity id is player
|
||||||
|
// TODO: add support for other entity types
|
||||||
|
Vector2 origin = map.find(Map.ID.TOWN_ENTRY_1);
|
||||||
|
if (origin == null) origin = map.find(Map.ID.TOWN_ENTRY_2);
|
||||||
|
if (origin == null) origin = map.find(Map.ID.TP_LOCATION);
|
||||||
|
Map.Zone zone = map.getZone(origin);
|
||||||
|
entityId = factory.createPlayer(map, zone, charData, origin);
|
||||||
|
syncIds.put(sync.entityId(), entityId);
|
||||||
|
|
||||||
|
cofs.setMode(entityId, Engine.Player.MODE_TN);
|
||||||
|
cofs.setWClass(entityId, Engine.WEAPON_1HS); // TODO...
|
||||||
|
}
|
||||||
|
|
||||||
|
int flags1 = Dirty.NONE;
|
||||||
|
int flags2 = Dirty.NONE;
|
||||||
|
Gdx.app.log(TAG, "syncing " + entityId);
|
||||||
|
for (int i = 0, len = sync.dataTypeLength(); i < len; i++) {
|
||||||
|
switch (sync.dataType(i)) {
|
||||||
|
case SyncData.Class:
|
||||||
|
case SyncData.Player:
|
||||||
|
break;
|
||||||
|
case SyncData.CofComponents: {
|
||||||
|
com.riiablo.net.packet.d2gs.CofComponents data = (com.riiablo.net.packet.d2gs.CofComponents) sync.data(new com.riiablo.net.packet.d2gs.CofComponents(), i);
|
||||||
|
for (int j = 0, s0 = data.componentLength(); j < s0; j++) {
|
||||||
|
cofs.setComponent(entityId, j, data.component(j));
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case SyncData.CofTransforms: {
|
||||||
|
com.riiablo.net.packet.d2gs.CofTransforms data = (com.riiablo.net.packet.d2gs.CofTransforms) sync.data(new com.riiablo.net.packet.d2gs.CofTransforms(), i);
|
||||||
|
for (int j = 0, s0 = data.transformLength(); j < s0; j++) {
|
||||||
|
flags1 |= cofs.setTransform(entityId, j, (byte) data.transform(j));
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case SyncData.CofAlphas: {
|
||||||
|
com.riiablo.net.packet.d2gs.CofAlphas data = (com.riiablo.net.packet.d2gs.CofAlphas) sync.data(new com.riiablo.net.packet.d2gs.CofAlphas(), i);
|
||||||
|
for (int j = 0, s0 = data.alphaLength(); j < s0; j++) {
|
||||||
|
flags2 |= cofs.setAlpha(entityId, j, data.alpha(j));
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case SyncData.Position: {
|
||||||
|
Vector2 position = mPosition.get(entityId).position;
|
||||||
|
com.riiablo.net.packet.d2gs.Position data = (com.riiablo.net.packet.d2gs.Position) sync.data(new com.riiablo.net.packet.d2gs.Position(), i);
|
||||||
|
position.x = data.x();
|
||||||
|
position.y = data.y();
|
||||||
|
Body body = mBox2DBody.get(entityId).body;
|
||||||
|
body.setTransform(position, body.getAngle());
|
||||||
|
//Gdx.app.log(TAG, " " + position);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case SyncData.Velocity: {
|
||||||
|
Vector2 velocity = mVelocity.get(entityId).velocity;
|
||||||
|
com.riiablo.net.packet.d2gs.Velocity data = (com.riiablo.net.packet.d2gs.Velocity) sync.data(new com.riiablo.net.packet.d2gs.Velocity(), i);
|
||||||
|
velocity.x = data.x();
|
||||||
|
velocity.y = data.y();
|
||||||
|
//Gdx.app.log(TAG, " " + velocity);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case SyncData.Angle: {
|
||||||
|
Vector2 angle = mAngle.get(entityId).target;
|
||||||
|
com.riiablo.net.packet.d2gs.Angle data = (com.riiablo.net.packet.d2gs.Angle) sync.data(new com.riiablo.net.packet.d2gs.Angle(), i);
|
||||||
|
angle.x = data.x();
|
||||||
|
angle.y = data.y();
|
||||||
|
//Gdx.app.log(TAG, " " + angle);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
Gdx.app.error(TAG, "Unknown packet type: " + SyncData.name(sync.dataType(i)));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
cofs.updateTransform(entityId, flags1);
|
||||||
|
cofs.updateAlpha(entityId, flags2);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -496,6 +496,8 @@ public class GameScreen extends ScreenAdapter implements GameLoadingScreen.Loada
|
|||||||
.register("shapes", Riiablo.shapes)
|
.register("shapes", Riiablo.shapes)
|
||||||
.register("stage", stage)
|
.register("stage", stage)
|
||||||
.register("scaledStage", scaledStage)
|
.register("scaledStage", scaledStage)
|
||||||
|
.register("input", input)
|
||||||
|
.register("output", output)
|
||||||
;
|
;
|
||||||
if (socket != null) config.register("client.socket", socket);
|
if (socket != null) config.register("client.socket", socket);
|
||||||
engine = Riiablo.engine = new World(config);
|
engine = Riiablo.engine = new World(config);
|
||||||
|
|||||||
@ -1,45 +1,10 @@
|
|||||||
package com.riiablo.screen;
|
package com.riiablo.screen;
|
||||||
|
|
||||||
import com.artemis.ComponentMapper;
|
|
||||||
import com.artemis.Entity;
|
|
||||||
import com.artemis.WorldConfigurationBuilder;
|
import com.artemis.WorldConfigurationBuilder;
|
||||||
import com.badlogic.gdx.Gdx;
|
|
||||||
import com.badlogic.gdx.math.Vector2;
|
|
||||||
import com.badlogic.gdx.net.Socket;
|
import com.badlogic.gdx.net.Socket;
|
||||||
import com.badlogic.gdx.physics.box2d.Body;
|
|
||||||
import com.riiablo.CharData;
|
import com.riiablo.CharData;
|
||||||
import com.riiablo.CharacterClass;
|
import com.riiablo.engine.client.ClientNetworkReceiver;
|
||||||
import com.riiablo.Riiablo;
|
|
||||||
import com.riiablo.engine.Dirty;
|
|
||||||
import com.riiablo.engine.Engine;
|
|
||||||
import com.riiablo.engine.client.ClientEntityFactory;
|
|
||||||
import com.riiablo.engine.client.ClientNetworkSyncronizer;
|
import com.riiablo.engine.client.ClientNetworkSyncronizer;
|
||||||
import com.riiablo.engine.client.NetworkIdManager;
|
|
||||||
import com.riiablo.engine.server.CofManager;
|
|
||||||
import com.riiablo.engine.server.component.Angle;
|
|
||||||
import com.riiablo.engine.server.component.Box2DBody;
|
|
||||||
import com.riiablo.engine.server.component.CofAlphas;
|
|
||||||
import com.riiablo.engine.server.component.CofComponents;
|
|
||||||
import com.riiablo.engine.server.component.CofTransforms;
|
|
||||||
import com.riiablo.engine.server.component.Networked;
|
|
||||||
import com.riiablo.engine.server.component.Player;
|
|
||||||
import com.riiablo.engine.server.component.Position;
|
|
||||||
import com.riiablo.engine.server.component.Velocity;
|
|
||||||
import com.riiablo.map.Map;
|
|
||||||
import com.riiablo.net.packet.d2gs.Connection;
|
|
||||||
import com.riiablo.net.packet.d2gs.D2GS;
|
|
||||||
import com.riiablo.net.packet.d2gs.D2GSData;
|
|
||||||
import com.riiablo.net.packet.d2gs.Disconnect;
|
|
||||||
import com.riiablo.net.packet.d2gs.Sync;
|
|
||||||
import com.riiablo.net.packet.d2gs.SyncData;
|
|
||||||
import com.riiablo.util.ArrayUtils;
|
|
||||||
import com.riiablo.util.DebugUtils;
|
|
||||||
|
|
||||||
import java.io.InputStream;
|
|
||||||
import java.nio.ByteBuffer;
|
|
||||||
import java.nio.channels.Channels;
|
|
||||||
import java.nio.channels.ReadableByteChannel;
|
|
||||||
import java.util.Arrays;
|
|
||||||
|
|
||||||
public class NetworkedGameScreen extends GameScreen {
|
public class NetworkedGameScreen extends GameScreen {
|
||||||
private static final String TAG = "NetworkedGameScreen";
|
private static final String TAG = "NetworkedGameScreen";
|
||||||
@ -47,219 +12,22 @@ public class NetworkedGameScreen extends GameScreen {
|
|||||||
|
|
||||||
private Socket socket;
|
private Socket socket;
|
||||||
|
|
||||||
protected ComponentMapper<Networked> mNetworked;
|
|
||||||
protected ComponentMapper<Player> mPlayer;
|
|
||||||
protected NetworkIdManager sync;
|
|
||||||
protected CofManager cofs;
|
|
||||||
|
|
||||||
public NetworkedGameScreen(CharData charData, Socket socket) {
|
public NetworkedGameScreen(CharData charData, Socket socket) {
|
||||||
super(charData, socket);
|
super(charData, socket);
|
||||||
this.socket = socket;
|
this.socket = socket;
|
||||||
sync = engine.getSystem(NetworkIdManager.class);
|
|
||||||
cofs = engine.getSystem(CofManager.class);
|
|
||||||
mPlayer = engine.getMapper(Player.class);
|
|
||||||
mNetworked = engine.getMapper(Networked.class);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected WorldConfigurationBuilder getWorldConfigurationBuilder() {
|
protected WorldConfigurationBuilder getWorldConfigurationBuilder() {
|
||||||
WorldConfigurationBuilder builder = super.getWorldConfigurationBuilder();
|
WorldConfigurationBuilder builder = super.getWorldConfigurationBuilder();
|
||||||
|
builder.with(WorldConfigurationBuilder.Priority.HIGH, new ClientNetworkReceiver());
|
||||||
builder.with(new ClientNetworkSyncronizer());
|
builder.with(new ClientNetworkSyncronizer());
|
||||||
return builder;
|
return builder;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public void render(float delta) {
|
|
||||||
InputStream in = socket.getInputStream();
|
|
||||||
try {
|
|
||||||
if (in.available() > 0) {
|
|
||||||
ReadableByteChannel channelIn = Channels.newChannel(in);
|
|
||||||
ByteBuffer buffer = ByteBuffer.allocate(4096);
|
|
||||||
channelIn.read(buffer);
|
|
||||||
buffer.rewind();
|
|
||||||
D2GS data = D2GS.getRootAsD2GS(buffer);
|
|
||||||
System.out.println("packet type " + D2GSData.name(data.dataType()));
|
|
||||||
process(data);
|
|
||||||
}
|
|
||||||
} catch (Throwable t) {
|
|
||||||
Gdx.app.error(TAG, t.getMessage(), t);
|
|
||||||
}
|
|
||||||
|
|
||||||
super.render(delta);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void dispose() {
|
public void dispose() {
|
||||||
super.dispose();
|
super.dispose();
|
||||||
socket.dispose();
|
socket.dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
private void process(D2GS packet) {
|
|
||||||
switch (packet.dataType()) {
|
|
||||||
case D2GSData.Connection:
|
|
||||||
Connection(packet);
|
|
||||||
break;
|
|
||||||
case D2GSData.Disconnect:
|
|
||||||
Disconnect(packet);
|
|
||||||
break;
|
|
||||||
case D2GSData.Sync:
|
|
||||||
Synchronize(packet);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
Gdx.app.error(TAG, "Unknown packet type: " + packet.dataType());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void Connection(D2GS packet) {
|
|
||||||
Connection connection = (Connection) packet.data(new Connection());
|
|
||||||
String charName = connection.charName();
|
|
||||||
int charClass = connection.charClass();
|
|
||||||
|
|
||||||
output.appendText(Riiablo.string.format(3641, charName));
|
|
||||||
output.appendText("\n");
|
|
||||||
|
|
||||||
CharData charData = new CharData().createD2S(charName, CharacterClass.get(charClass));
|
|
||||||
|
|
||||||
Vector2 origin = map.find(Map.ID.TOWN_ENTRY_1);
|
|
||||||
if (origin == null) origin = map.find(Map.ID.TOWN_ENTRY_2);
|
|
||||||
if (origin == null) origin = map.find(Map.ID.TP_LOCATION);
|
|
||||||
Map.Zone zone = map.getZone(origin);
|
|
||||||
int entityId = engine.getSystem(ClientEntityFactory.class).createPlayer(map, zone, charData, origin);
|
|
||||||
sync.put(connection.entityId(), entityId);
|
|
||||||
Entity entity = engine.getEntity(entityId);
|
|
||||||
int[] component = entity.getComponent(CofComponents.class).component;
|
|
||||||
for (int i = 0; i < 16; i++) component[i] = connection.cofComponents(i);
|
|
||||||
float[] alpha = entity.getComponent(CofAlphas.class).alpha;
|
|
||||||
for (int i = 0; i < 16; i++) alpha[i] = connection.cofAlphas(i);
|
|
||||||
byte[] transform = entity.getComponent(CofTransforms.class).transform;
|
|
||||||
for (int i = 0; i < 16; i++) transform[i] = (byte) connection.cofTransforms(i);
|
|
||||||
|
|
||||||
int alphaFlags = Dirty.NONE;
|
|
||||||
int transformFlags = Dirty.NONE;
|
|
||||||
cofs.setMode(entityId, Engine.Player.MODE_TN);
|
|
||||||
cofs.setWClass(entityId, Engine.WEAPON_1HS); // TODO...
|
|
||||||
for (int i = 0; i < 16; i++) {
|
|
||||||
cofs.setComponent(entityId, i, connection.cofComponents(i));
|
|
||||||
}
|
|
||||||
for (int i = 0; i < 16; i++) {
|
|
||||||
alphaFlags |= cofs.setAlpha(entityId, i, connection.cofAlphas(i));
|
|
||||||
transformFlags |= cofs.setTransform(entityId, i, (byte) connection.cofTransforms(i));
|
|
||||||
}
|
|
||||||
|
|
||||||
cofs.updateAlpha(entityId, alphaFlags);
|
|
||||||
cofs.updateTransform(entityId, transformFlags);
|
|
||||||
cofs.setMode(entityId, Engine.Player.MODE_TN, true);
|
|
||||||
|
|
||||||
System.out.println(" " + DebugUtils.toByteArray(ArrayUtils.toByteArray(component)));
|
|
||||||
System.out.println(" " + Arrays.toString(alpha));
|
|
||||||
System.out.println(" " + DebugUtils.toByteArray(transform));
|
|
||||||
}
|
|
||||||
|
|
||||||
private void Disconnect(D2GS packet) {
|
|
||||||
Disconnect disconnect = (Disconnect) packet.data(new Disconnect());
|
|
||||||
int serverEntityId = disconnect.entityId();
|
|
||||||
System.out.println("serverEntityId=" + serverEntityId);
|
|
||||||
int entityId = sync.get(serverEntityId);
|
|
||||||
|
|
||||||
CharData data = mPlayer.get(entityId).data;
|
|
||||||
|
|
||||||
output.appendText(Riiablo.string.format(3642, data.getD2S().header.name));
|
|
||||||
output.appendText("\n");
|
|
||||||
|
|
||||||
engine.delete(entityId);
|
|
||||||
}
|
|
||||||
|
|
||||||
private com.riiablo.net.packet.d2gs.Player findPlayer(Sync s) {
|
|
||||||
for (int i = 0, len = s.dataTypeLength(); i < len; i++) {
|
|
||||||
if (s.dataType(i) == SyncData.Player) {
|
|
||||||
return (com.riiablo.net.packet.d2gs.Player) s.data(new com.riiablo.net.packet.d2gs.Player(), i);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void Synchronize(D2GS packet) {
|
|
||||||
Sync s = (Sync) packet.data(new Sync());
|
|
||||||
int entityId = sync.get(s.entityId());
|
|
||||||
if (entityId == Engine.INVALID_ENTITY) {
|
|
||||||
com.riiablo.net.packet.d2gs.Player player = findPlayer(s);
|
|
||||||
CharData charData = new CharData().createD2S(player.charName(), CharacterClass.get(player.charClass()));
|
|
||||||
|
|
||||||
// TODO: assert entity id is player
|
|
||||||
// TODO: add support for other entity types
|
|
||||||
Vector2 origin = map.find(Map.ID.TOWN_ENTRY_1);
|
|
||||||
if (origin == null) origin = map.find(Map.ID.TOWN_ENTRY_2);
|
|
||||||
if (origin == null) origin = map.find(Map.ID.TP_LOCATION);
|
|
||||||
Map.Zone zone = map.getZone(origin);
|
|
||||||
entityId = factory.createPlayer(map, zone, charData, origin);
|
|
||||||
sync.put(s.entityId(), entityId);
|
|
||||||
|
|
||||||
cofs.setMode(entityId, Engine.Player.MODE_TN);
|
|
||||||
cofs.setWClass(entityId, Engine.WEAPON_1HS); // TODO...
|
|
||||||
}
|
|
||||||
|
|
||||||
int flags1 = Dirty.NONE;
|
|
||||||
int flags2 = Dirty.NONE;
|
|
||||||
Gdx.app.log(TAG, "syncing " + entityId);
|
|
||||||
for (int i = 0, len = s.dataTypeLength(); i < len; i++) {
|
|
||||||
switch (s.dataType(i)) {
|
|
||||||
case SyncData.Class:
|
|
||||||
case SyncData.Player:
|
|
||||||
break;
|
|
||||||
case SyncData.CofComponents: {
|
|
||||||
com.riiablo.net.packet.d2gs.CofComponents data = (com.riiablo.net.packet.d2gs.CofComponents) s.data(new com.riiablo.net.packet.d2gs.CofComponents(), i);
|
|
||||||
for (int j = 0, s0 = data.componentLength(); j < s0; j++) {
|
|
||||||
cofs.setComponent(entityId, j, data.component(j));
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case SyncData.CofTransforms: {
|
|
||||||
com.riiablo.net.packet.d2gs.CofTransforms data = (com.riiablo.net.packet.d2gs.CofTransforms) s.data(new com.riiablo.net.packet.d2gs.CofTransforms(), i);
|
|
||||||
for (int j = 0, s0 = data.transformLength(); j < s0; j++) {
|
|
||||||
flags1 |= cofs.setTransform(entityId, j, (byte) data.transform(j));
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case SyncData.CofAlphas: {
|
|
||||||
com.riiablo.net.packet.d2gs.CofAlphas data = (com.riiablo.net.packet.d2gs.CofAlphas) s.data(new com.riiablo.net.packet.d2gs.CofAlphas(), i);
|
|
||||||
for (int j = 0, s0 = data.alphaLength(); j < s0; j++) {
|
|
||||||
flags2 |= cofs.setAlpha(entityId, j, data.alpha(j));
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case SyncData.Position: {
|
|
||||||
Vector2 position = engine.getMapper(Position.class).get(entityId).position;
|
|
||||||
com.riiablo.net.packet.d2gs.Position data = (com.riiablo.net.packet.d2gs.Position) s.data(new com.riiablo.net.packet.d2gs.Position(), i);
|
|
||||||
position.x = data.x();
|
|
||||||
position.y = data.y();
|
|
||||||
Body body = engine.getMapper(Box2DBody.class).get(entityId).body;
|
|
||||||
body.setTransform(position, body.getAngle());
|
|
||||||
//Gdx.app.log(TAG, " " + position);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case SyncData.Velocity: {
|
|
||||||
Vector2 velocity = engine.getMapper(Velocity.class).get(entityId).velocity;
|
|
||||||
com.riiablo.net.packet.d2gs.Velocity data = (com.riiablo.net.packet.d2gs.Velocity) s.data(new com.riiablo.net.packet.d2gs.Velocity(), i);
|
|
||||||
velocity.x = data.x();
|
|
||||||
velocity.y = data.y();
|
|
||||||
//Gdx.app.log(TAG, " " + velocity);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case SyncData.Angle: {
|
|
||||||
Vector2 angle = engine.getMapper(Angle.class).get(entityId).target;
|
|
||||||
com.riiablo.net.packet.d2gs.Angle data = (com.riiablo.net.packet.d2gs.Angle) s.data(new com.riiablo.net.packet.d2gs.Angle(), i);
|
|
||||||
angle.x = data.x();
|
|
||||||
angle.y = data.y();
|
|
||||||
//Gdx.app.log(TAG, " " + angle);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
default:
|
|
||||||
Gdx.app.error(TAG, "Unknown packet type: " + SyncData.name(s.dataType(i)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
cofs.updateTransform(entityId, flags1);
|
|
||||||
cofs.updateAlpha(entityId, flags2);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user