Progress on WrapperPlayServerEntityMetadata
This commit is contained in:
retrooper committed
1 parent
2840cf3146
commit
c29146ee25
1 file changed
+237
+237
@@ -0,0 +1,237 @@
|
||||
/*
|
||||
* This file is part of packetevents - https://github.com/retrooper/packetevents
|
||||
* Copyright (C) 2021 retrooper and contributors
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU 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 General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
package io.github.retrooper.packetevents.wrapper.play.server;
|
||||
|
||||
import io.github.retrooper.packetevents.event.impl.PacketSendEvent;
|
||||
import io.github.retrooper.packetevents.protocol.packettype.PacketType;
|
||||
import io.github.retrooper.packetevents.utils.Vector3f;
|
||||
import io.github.retrooper.packetevents.utils.Vector3i;
|
||||
import io.github.retrooper.packetevents.wrapper.PacketWrapper;
|
||||
import net.minecraft.server.v1_9_R1.DataWatcher;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Optional;
|
||||
import java.util.function.BiConsumer;
|
||||
import java.util.function.Function;
|
||||
|
||||
public class WrapperPlayServerEntityMetadata extends PacketWrapper<WrapperPlayServerEntityMetadata> {
|
||||
private int entityID;
|
||||
private List<WatchableObject> watchableObjects;
|
||||
|
||||
public WrapperPlayServerEntityMetadata(PacketSendEvent event) {
|
||||
super(event);
|
||||
}
|
||||
|
||||
public WrapperPlayServerEntityMetadata(int entityID, List<WatchableObject> watchableObjects) {
|
||||
super(PacketType.Play.Server.ENTITY_METADATA);
|
||||
this.entityID = entityID;
|
||||
this.watchableObjects = watchableObjects;
|
||||
net.minecraft.server.v1_9_R1.PacketPlayOutEntityMetadata em00;
|
||||
}
|
||||
|
||||
private List<WatchableObject> serializeWatchableObjectsLegacy() {
|
||||
List<WatchableObject> list = new ArrayList<>();
|
||||
//1.7.10 -> 1.8.8 code
|
||||
for (byte b0 = readByte(); b0 != 127; b0 = readByte()) {
|
||||
int i = (b0 & 224) >> 5;
|
||||
int j = b0 & 31;
|
||||
WatchableObject watchableObject = null;
|
||||
switch (i) {
|
||||
case 0:
|
||||
//TODO Confirm j and i order
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.BYTE, readByte());
|
||||
break;
|
||||
case 1:
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.SHORT, readShort());
|
||||
break;
|
||||
case 2:
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.INTEGER, readInt());
|
||||
break;
|
||||
case 3:
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.FLOAT, readFloat());
|
||||
break;
|
||||
case 4:
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.STRING, readString());
|
||||
break;
|
||||
case 5:
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.ITEM_STACK, readItemStack());
|
||||
break;
|
||||
case 6: {
|
||||
int x = readInt();
|
||||
int y = readInt();
|
||||
int z = readInt();
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.POSITION, new Vector3i(x, y, z));
|
||||
break;
|
||||
}
|
||||
case 7: {
|
||||
float x = readFloat();
|
||||
float y = readFloat();
|
||||
float z = readFloat();
|
||||
watchableObject = new WatchableObject(j, WatchableObject.Type.ROTATION, new Vector3f(x, y, z));
|
||||
break;
|
||||
}
|
||||
}
|
||||
list.add(watchableObject);
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
private List<WatchableObject> serializeWatchableObjects() {
|
||||
List<WatchableObject> list = new ArrayList<>();
|
||||
short short0;
|
||||
while ((short0 = readUnsignedByte()) != 255) {
|
||||
|
||||
short typeID = readUnsignedByte();
|
||||
WatchableObject.Type type = WatchableObject.Type.values()[typeID];
|
||||
list.add(new WatchableObject(-1, type, value));
|
||||
|
||||
list.add(new DataWatcher.Item(datawatcherserializer.a(short0), datawatcherserializer.a(packetdataserializer)));
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void readData() {
|
||||
entityID = readInt();
|
||||
watchableObjects = serializeWatchableObjectsLegacy();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void readData(WrapperPlayServerEntityMetadata wrapper) {
|
||||
entityID = wrapper.entityID;
|
||||
watchableObjects = wrapper.watchableObjects;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void writeData() {
|
||||
|
||||
}
|
||||
|
||||
public static class WatchableObject {
|
||||
|
||||
public enum Type {
|
||||
BYTE(PacketWrapper::readByte,
|
||||
(packetWrapper, o) -> {
|
||||
packetWrapper.writeByte((int) o);
|
||||
}
|
||||
),
|
||||
INTEGER(PacketWrapper::readVarInt,
|
||||
(packetWrapper, o) -> {
|
||||
packetWrapper.writeVarInt((int) o);
|
||||
}),
|
||||
FLOAT(PacketWrapper::readFloat,
|
||||
(packetWrapper, o) -> {
|
||||
packetWrapper.writeFloat((float) o);
|
||||
}),
|
||||
STRING(PacketWrapper::readString,
|
||||
(packetWrapper, o) -> {
|
||||
packetWrapper.writeString((String) o);
|
||||
}),
|
||||
//TODO Make some Chat abstraction
|
||||
//TODO Double check string size on newer versions
|
||||
CHAT(PacketWrapper::readString,
|
||||
(packetWrapper, o) -> {
|
||||
packetWrapper.writeString((String) o);
|
||||
}),
|
||||
OPTIONAL_CHAT(packetWrapper -> {
|
||||
if (packetWrapper.readBoolean()) {
|
||||
return Optional.of(packetWrapper.readString());
|
||||
} else {
|
||||
return Optional.empty();
|
||||
}
|
||||
}, (packetWrapper, o) -> {
|
||||
Optional<String> optString = (Optional<String>) o;
|
||||
if (optString.isPresent()) {
|
||||
packetWrapper.writeBoolean(true);
|
||||
packetWrapper.writeString(optString.get());
|
||||
}
|
||||
else {
|
||||
packetWrapper.writeBoolean(false);
|
||||
}
|
||||
}),
|
||||
ITEM_STACK,
|
||||
BOOLEAN,
|
||||
//3 floats
|
||||
ROTATION,
|
||||
//blockposition
|
||||
POSITION,
|
||||
OPTIONAL_POSITION,
|
||||
//Var int
|
||||
DIRECTION,
|
||||
OPTIONAL_UUID,
|
||||
OPTIONAL_BLOCK_TYPE_ID,
|
||||
//1.9 has the above
|
||||
NBT,
|
||||
PARTICLE,
|
||||
VILLAGER_DATA,
|
||||
OPTIONAL_INTEGER,
|
||||
POSE,
|
||||
|
||||
//Not present on 1.9+
|
||||
@Deprecated
|
||||
SHORT;
|
||||
|
||||
private Function<PacketWrapper<?>, Object> readDataConsumer;
|
||||
private BiConsumer<PacketWrapper<?>, Object> writeDataConsumer;
|
||||
|
||||
Type(Function<PacketWrapper<?>, Object> readDataConsumer, BiConsumer<PacketWrapper<?>, Object> writeDataConsumer) {
|
||||
this.readDataConsumer = readDataConsumer;
|
||||
this.writeDataConsumer = writeDataConsumer;
|
||||
}
|
||||
|
||||
public static final Type[] VALUES = values();
|
||||
}
|
||||
|
||||
private int index;
|
||||
//TODO Make enum for type
|
||||
private Type type;
|
||||
private Object value;
|
||||
|
||||
public WatchableObject(int index, Type type, Object value) {
|
||||
this.index = index;
|
||||
this.type = type;
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
public int getIndex() {
|
||||
return index;
|
||||
}
|
||||
|
||||
public void setIndex(int index) {
|
||||
this.index = index;
|
||||
}
|
||||
|
||||
public Type getType() {
|
||||
return type;
|
||||
}
|
||||
|
||||
public void setType(Type type) {
|
||||
this.type = type;
|
||||
}
|
||||
|
||||
public Object getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public void setValue(Object value) {
|
||||
this.value = value;
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user