Moar skin stuff

Author: 7kasper

src/protocolsupportpocketstuff/ProtocolSupportPocketStuff.java

@@ -19,7 +19,7 @@
 import protocolsupportpocketstuff.hacks.holograms.HologramsPacketListener;
 import protocolsupportpocketstuff.hacks.itemframes.ItemFramesPacketListener;
 import protocolsupportpocketstuff.hacks.skulls.SkullTilePacketListener;
-import protocolsupportpocketstuff.metadata.MetadataProvider;
+import protocolsupportpocketstuff.metadata.EntityMetadataProvider;
 import protocolsupportpocketstuff.modals.ModalReceiver;
 import protocolsupportpocketstuff.packet.PEReceiver;
 import protocolsupportpocketstuff.resourcepacks.ResourcePackListener;
@@ -61,7 +61,7 @@ public void onEnable() {
 		PocketStuffAPI.registerPacketListeners(new PocketInfoReceiver());
 		PocketStuffAPI.registerPacketListeners(new ModalReceiver());
 		// = Metadata = \\
-		PEMetaProviderSPI.setProvider(new MetadataProvider());
+		PEMetaProviderSPI.setProvider(new EntityMetadataProvider());
 		// = ResourcePacks = \\
 		if (!PocketStuffAPI.getResourcePackManager().isEmpty()) {
 			ResourcePackListener provider = new ResourcePackListener();

src/protocolsupportpocketstuff/api/entity/PocketMetadata.java

@@ -8,7 +8,7 @@
 import protocolsupport.protocol.utils.datawatcher.objects.DataWatcherObjectString;
 import protocolsupport.utils.CollectionsUtils;
 import protocolsupportpocketstuff.api.util.PocketCon;
-import protocolsupportpocketstuff.metadata.MetadataProvider;
+import protocolsupportpocketstuff.metadata.EntityMetadataProvider;
 import protocolsupportpocketstuff.packet.play.EntityDataPacket;
 
 import java.util.concurrent.ConcurrentHashMap;
@@ -68,7 +68,7 @@ public static void setInteractText(Entity entity, String interactText) {
 	 * @param interactText
 	 */
 	public static void setInteractText(int entityId, String interactText) {
-		if (interactText.equals(MetadataProvider.DEFAULTINTERACT)) {
+		if (interactText.equals(EntityMetadataProvider.DEFAULTINTERACT)) {
 			entityInteracts.remove(entityId);
 		} else {
 			entityInteracts.put(entityId, interactText);

src/protocolsupportpocketstuff/api/skins/SkinUtils.java

@@ -82,12 +82,12 @@ public static void updateSkin(Player player, byte[] skin, SkinDataWrapper skinda
 				//removes the entity and display the new skin
 				onlinePlayer.hidePlayer(ProtocolSupportPocketStuff.getInstance(), player);
 				onlinePlayer.showPlayer(ProtocolSupportPocketStuff.getInstance(), player);
-				Bukkit.getScheduler().runTaskLater(ProtocolSupportPocketStuff.getInstance(), () -> {
-					//sends skin packet to dynamically update PE skins.
-					if (PocketPlayer.isPocketPlayer(onlinePlayer)) {
+				if (PocketPlayer.isPocketPlayer(onlinePlayer)) {
+					Bukkit.getScheduler().runTaskLater(ProtocolSupportPocketStuff.getInstance(), () -> {
+						//sends skin packet to dynamically update PE skins.
 						PocketPlayer.sendSkin(onlinePlayer, player.getUniqueId(), skin, isSlim);
-					}
-				}, 5l);
+					}, 5l);
+				}
 			});
 		});
 	}

…cketstuff/metadata/MetadataProvider.java …uff/metadata/EntityMetadataProvider.javasrc/protocolsupportpocketstuff/metadata/MetadataProvider.java renamed to src/protocolsupportpocketstuff/metadata/EntityMetadataProvider.java src/protocolsupportpocketstuff/metadata/MetadataProvider.java renamed to src/protocolsupportpocketstuff/metadata/EntityMetadataProvider.java

@@ -6,7 +6,7 @@
 
 import java.util.UUID;
 
-public class MetadataProvider extends PEMetaProvider {
+public class EntityMetadataProvider extends PEMetaProvider {
 
 	public static final String DEFAULTINTERACT = "Interact";
 

src/protocolsupportpocketstuff/packet/handshake/ClientLoginPacket.java

@@ -16,10 +16,15 @@
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.util.Base64;
+import java.util.List;
+import java.util.Map;
+
+import com.google.common.reflect.TypeToken;
 
 public class ClientLoginPacket extends PEPacket {
 
 	private int protocolVersion;
+	private Map<String, JsonObject> chain;
 	private JsonObject jsonPayload;
 
 	public ClientLoginPacket() { }
@@ -46,7 +51,10 @@ private JsonObject decodeToken(String token) {
 	public void readFromClientData(Connection connection, ByteBuf clientData) {
 		protocolVersion = clientData.readInt(); //protocol version
 		ByteBuf logindata = Unpooled.wrappedBuffer(ArraySerializer.readByteArray(clientData, connection.getVersion()));
-		logindata.skipBytes(logindata.readIntLE()); //skip chain data
+		chain = GsonUtils.GSON.fromJson(
+				new InputStreamReader(new ByteBufInputStream(logindata, logindata.readIntLE())),
+				new TypeToken<Map<String, List<String>>>() { private static final long serialVersionUID = 1L; }.getType()
+		);
 		try { //decode skin data
 			InputStream inputStream = new ByteBufInputStream(logindata, logindata.readIntLE());
 			ByteArrayOutputStream result = new ByteArrayOutputStream();
@@ -67,6 +75,10 @@ public int getProtocolVersion() {
 		return protocolVersion;
 	}
 
+	public Map<String, JsonObject> getChain() {
+		return chain;
+	}
+
 	public JsonObject getJsonPayload() {
 		return jsonPayload;
 	}

src/protocolsupportpocketstuff/skin/PcToPeProvider.java

@@ -1,6 +1,7 @@
 package protocolsupportpocketstuff.skin;
 
 import protocolsupport.api.unsafe.peskins.PESkinsProvider;
+import protocolsupportpocketstuff.ProtocolSupportPocketStuff;
 import protocolsupportpocketstuff.storage.Skins;
 
 import java.util.function.Consumer;
@@ -11,7 +12,8 @@ public class PcToPeProvider extends PESkinsProvider {
 
 	@Override
 	public byte[] getSkinData(String url) {
-		if (skins.hasPeSkin(url)) {
+		ProtocolSupportPocketStuff.getInstance().debug("Instantly returning skin: " + url);
+		if (skins.hasPcSkin(url)) {
 			return skins.getPcSkin(url);
 		}
 		return null;

src/protocolsupportpocketstuff/skin/PeToPcProvider.java

@@ -14,6 +14,7 @@
 import protocolsupportpocketstuff.api.util.PocketPacketListener;
 import protocolsupportpocketstuff.packet.handshake.ClientLoginPacket;
 import protocolsupportpocketstuff.packet.play.SkinPacket;
+import protocolsupportpocketstuff.util.PacketUtils;
 import protocolsupportpocketstuff.util.StuffUtils;
 
 public class PeToPcProvider implements PocketPacketListener, Listener {
@@ -27,23 +28,24 @@ public void onConnect(Connection connection, ClientLoginPacket packet) {
 		String skinData = packet.getJsonPayload().get("SkinData").getAsString();
 		byte[] skinByteArray = Base64.getDecoder().decode(skinData);
 		boolean slim = packet.getJsonPayload().get("SkinGeometryName").getAsString().equals("geometry.humanoid.customSlim");
+		plugin.debug("SLIM: " + slim + " DATA LENGTH: " + skinByteArray.length);
 		new MineskinThread(skinByteArray, slim, (skindata) -> {
+			//TODO rewrite when PS properties event is more sane.
 			if (connection.getPlayer() == null) {
 				plugin.debug("MEta added!");
 				connection.addMetadata(StuffUtils.APPLY_SKIN_ON_JOIN_KEY, skindata);
-			} else {
+			}
+			new PacketUtils.RunWhenOnline(connection, () -> {
 				plugin.debug("Dynamic skin update!");
 				SkinUtils.updateSkin(connection.getPlayer(), skinByteArray, skindata, slim);
-			}
+			}, 2).start();
 		}).start();
 	}
 
 	@PocketPacketHandler
 	public void onSkinChange(Connection connection, SkinPacket packet) {
-		//boolean slim = packet.getSkinName().equals("skin.Standard.CustomSlim");
 		System.out.println(packet.getGeometryId());
 		boolean slim = packet.getGeometryId().equals("geometry.humanoid.customSlim");
-		plugin.debug(slim + "sdkfjsdlfj");
 		new MineskinThread(packet.getSkinData(), slim, (skindata) -> {
 			plugin.debug("Dynamic skin update!");
 			SkinUtils.updateSkin(connection.getPlayer(), packet.getSkinData(), skindata, slim);

src/protocolsupportpocketstuff/storage/Skins.java

@@ -87,6 +87,7 @@ public boolean hasPcSkin(String url) {
 	 * @return true if the skin was cached
 	 */
 	public boolean hasPeSkin(String uuid) {
+		System.out.println("MEEp" + uuid);
 		return pcSkinCache.containsKey(uuid);
 	}
 

src/protocolsupportpocketstuff/util/PacketUtils.java

@@ -0,0 +1,35 @@
+package protocolsupportpocketstuff.util;
+
+import protocolsupport.api.Connection;
+
+public class PacketUtils {
+
+	public static class RunWhenOnline extends Thread {
+
+		private Connection connection;
+		private Runnable run;
+		private int maxtries;
+
+		public RunWhenOnline(Connection connection, Runnable run, int maxtries) {
+			this.connection = connection;
+			this.run = run;
+			this.maxtries = maxtries;
+		}
+
+		@Override
+		public void run() {
+			super.run();
+			int tries = 0;
+			while(connection.getPlayer() == null) {
+				try {
+					tries++;
+					if (tries > maxtries) { return; }
+					Thread.sleep(1000l);
+				} catch (InterruptedException e) { }
+			}
+			run.run();
+		}
+
+	}
+
+}

src/protocolsupportpocketstuff/util/PocketInfoReceiver.java

@@ -13,9 +13,11 @@ public class PocketInfoReceiver implements PocketPacketListener {
 	@PocketPacketHandler
 	public void onConnect(Connection connection, ClientLoginPacket packet) {
 		JsonObject clientPayload = packet.getJsonPayload();
+		//Map<String, JsonObject> chain = packet.getChain();
 		HashMap<String, Object> clientInfo = new HashMap<>();
 		// "In general you shouldn't really expect the payload to be sent with psbpe" -Shevchik
-		if (clientPayload != null) {
+		if (/*chain != null &&*/ clientPayload != null) {
+			//clientInfo.put("PocketUUID", );
 			clientInfo.put("ClientRandomId", clientPayload.get("ClientRandomId").getAsLong());
 			clientInfo.put("DeviceModel", clientPayload.get("DeviceModel").getAsString());
 			clientInfo.put("DeviceOS", clientPayload.get("DeviceOS").getAsInt());