Moving files

2025-09-09 03:06:55 +00:00 · 2013-01-13 11:31:53 +01:00
parent 6d90249fbd
commit dff26611e5
41 changed files with 44 additions and 55 deletions
--- a/src/classes/network/MinecraftInterface.php
+++ b/src/classes/network/MinecraftInterface.php
@ -0,0 +1,136 @@
+<?php
+
+/*
+
+           -
+         /   \
+      /         \
+   /   PocketMine  \
+/          MP         \
+|\     @shoghicp     /|
+|.   \           /   .|
+| ..     \   /     .. |
+|    ..    |    ..    |
+|       .. | ..       |
+\          |          /
+   \       |       /
+      \    |    /
+         \ | /
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Lesser General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+
+*/
+
+class MinecraftInterface{
+	var $pstruct
+	var $name
+	var $client
+	var $dataName;
+	private $socket
+	private $data;
+	function __construct($server, $port = 25565, $listen = false, $client = true){
+		$this->socket = new UDPSocket($server, $port, (bool) $listen);
+		require("protocol/RakNet.php");
+		require("protocol/packetName.php");
+		require("protocol/current.php");
+		require("protocol/dataName.php");
+		$this->pstruct = $pstruct;
+		$this->name = $packetName;
+		$this->dataName = $dataName;
+		$this->client = (bool) $client;
+		$this->start = microtime(true);
+	}
+
+	public function close(){
+		return $this->socket->close();
+	}
+
+	protected function getStruct($pid){
+		if(isset($this->pstruct[$pid])){
+			return $this->pstruct[$pid];
+		}
+		return false;
+	}
+
+	protected function writeDump($pid, $raw, $data, $origin = "client", $ip = "", $port = 0){
+		if(LOG === true and DEBUG >= 3){
+			$p = "[".(microtime(true) - $this->start)."] [".((($origin === "client" and $this->client === true) or ($origin === "server" and $this->client === false)) ? "CLIENT->SERVER":"SERVER->CLIENT")." ".$ip.":".$port."]: ".(isset($data["id"]) ? "MC Packet ".$this->dataName[$pid]:$this->name[$pid])." (0x".Utils::strTohex(chr($pid)).") [length ".strlen($raw)."]".PHP_EOL;
+			$p .= Utils::hexdump($raw);
+			if(is_array($data)){
+				foreach($data as $i => $d){
+					$p .= $i ." => ".(!is_array($d) ? $this->pstruct[$pid][$i]."(".(($this->pstruct[$pid][$i] === "magic" or substr($this->pstruct[$pid][$i], 0, 7) === "special" or is_int($this->pstruct[$pid][$i])) ? Utils::strToHex($d):Utils::printable($d)).")":$this->pstruct[$pid][$i]."(\"".serialize(array_map("Utils::printable", $d))."\")").PHP_EOL;
+				}
+			}
+			$p .= PHP_EOL;
+			logg($p, "packets", false);
+		}
+
+	}
+
+	public function readPacket(){
+		$p = $this->popPacket();
+		if($p !== false){
+			return $p;
+		}
+		if($this->socket->connected === false){
+			return false;
+		}
+		$data = $this->socket->read();
+		if($data[3] === false){
+			return false;
+		}
+		$pid = ord($data[0]);
+		$struct = $this->getStruct($pid);
+		if($struct === false){
+			console("[ERROR] Unknown Packet ID 0x".Utils::strToHex(chr($pid)), true, true, 0);
+			$p = "[".(microtime(true) - $this->start)."] [".((($origin === "client" and $this->client === true) or ($origin === "server" and $this->client === false)) ? "CLIENT->SERVER":"SERVER->CLIENT")." ".$ip.":".$port."]: Error, bad packet id 0x".Utils::strTohex(chr($pid))." [length ".strlen($raw)."]".PHP_EOL;
+			$p .= Utils::hexdump($data[0]);
+			$p .= PHP_EOL;
+			logg($p, "packets", true, 2);
+			return false;
+		}
+
+		$packet = new Packet($pid, $struct, $data[0]);
+		$packet->parse();
+		$this->data[] = array($pid, $packet->data, $data[0], $data[1], $data[2]);
+		return $this->popPacket();
+	}
+
+	public function popPacket(){
+		if(count($this->data) > 0){
+			$p = array_shift($this->data);
+			if(isset($p[1]["packets"]) and is_array($p[1]["packets"])){
+				foreach($p[1]["packets"] as $d){
+					$this->data[] = array($p[0], $d[1], $d[2], $p[3], $p[4]);
+				}
+			}
+			$c = (isset($p[1]["id"]) ? true:false);
+			$p[2] = $c ? chr($p[1]["id"]).$p[2]:$p[2];
+			$this->writeDump(($c ? $p[1]["id"]:$p[0]), $p[2], $p[1], "server", $p[3], $p[4]);
+			return array("pid" => $p[0], "data" => $p[1], "raw" => $p[2], "ip" => $p[3], "port" => $p[4]);
+		}
+		return false;
+	}
+
+	public function writePacket($pid, $data = array(), $raw = false, $dest = false, $port = false){
+		$struct = $this->getStruct($pid);
+		if($raw === false){
+			$packet = new Packet($pid, $struct);
+			$packet->data = $data;
+			$packet->create();
+			$write = $this->socket->write($packet->raw, $dest, $port);
+			$this->writeDump($pid, $packet->raw, $data, "client", $dest, $port);
+		}else{
+			$write = $this->socket->write($data, $dest, $port);
+			$this->writeDump($pid, $data, false, "client", $dest, $port);
+		}
+		return true;
+	}
+
+}
+
+?>