63 public function __construct(
string $namespace,
string $name){
67 KnownTranslationFactory::pocketmine_command_timings_description(),
68 KnownTranslationFactory::pocketmine_command_timings_usage()
70 $this->setPermission(DefaultPermissionNames::COMMAND_TIMINGS);
74 if(count($args) !== 1){
78 $mode = strtolower($args[0]);
81 if(TimingsHandler::isEnabled()){
82 $sender->sendMessage(KnownTranslationFactory::pocketmine_command_timings_alreadyEnabled());
85 TimingsHandler::setEnabled();
86 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_enable());
89 }elseif($mode ===
"off"){
90 TimingsHandler::setEnabled(
false);
91 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_disable());
95 if(!TimingsHandler::isEnabled()){
96 $sender->sendMessage(KnownTranslationFactory::pocketmine_command_timings_timingsDisabled());
101 $paste = $mode ===
"paste";
103 if($mode ===
"reset"){
104 TimingsHandler::reload();
105 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_reset());
106 }elseif($mode ===
"merged" || $mode ===
"report" || $paste){
107 $timingsPromise = TimingsHandler::requestPrintTimings();
108 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_collect());
109 $timingsPromise->onCompletion(
110 fn(array $lines) => $paste ? $this->uploadReport($lines, $sender) : $this->createReportFile($lines, $sender),
124 private function createReportFile(array $lines,
CommandSender $sender) : void{
126 $timingFolder = Path::join($sender->getServer()->getDataPath(),
"timings");
128 if(!file_exists($timingFolder)){
129 mkdir($timingFolder, 0777);
131 $timings = Path::join($timingFolder,
"timings.txt");
132 while(file_exists($timings)){
133 $timings = Path::join($timingFolder,
"timings" . (++$index) .
".txt");
137 foreach($lines as $line){
138 fwrite($fileTimings, $line . PHP_EOL);
140 fclose($fileTimings);
142 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_timingsWrite($timings));
149 private function uploadReport(array $lines, CommandSender $sender) : void{
151 "browser" => $agent = $sender->getServer()->getName() .
" " . $sender->getServer()->getPocketMineVersion(),
152 "data" => implode(
"\n", $lines),
156 $host = $sender->getServer()->getConfigGroup()->getPropertyString(YmlServerProperties::TIMINGS_HOST,
"timings.pmmp.io");
158 $sender->getServer()->getAsyncPool()->submitTask(
new BulkCurlTask(
159 [
new BulkCurlTaskOperation(
160 "https://$host?upload=true",
164 CURLOPT_HTTPHEADER => [
165 "User-Agent: $agent",
166 "Content-Type: application/x-www-form-urlencoded"
168 CURLOPT_POST =>
true,
169 CURLOPT_POSTFIELDS => http_build_query($data),
170 CURLOPT_AUTOREFERER =>
false,
171 CURLOPT_FOLLOWLOCATION =>
false
174 function(array $results) use ($sender, $host) :
void{
176 if($sender instanceof Player && !$sender->isOnline()){
179 $result = $results[0];
180 if($result instanceof InternetException){
181 $sender->getServer()->getLogger()->logException($result);
184 $response = json_decode($result->getBody(),
true);
185 if(is_array($response) && isset($response[
"id"]) && (is_int($response[
"id"]) || is_string($response[
"id"]))){
186 $url =
"https://" . $host .
"/?id=" . $response[
"id"];
187 if(isset($response[
"access_token"]) && is_string($response[
"access_token"])){
188 $url .=
"&access_token=" . $response[
"access_token"];
190 $sender->getServer()->getLogger()->warning(
"Your chosen timings host does not support private reports. Anyone will be able to see your report if they guess the ID.");
192 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_timingsRead($url));
194 $sender->getServer()->getLogger()->debug(
"Invalid response from timings server (" . $result->getCode() .
"): " . $result->getBody());
195 Command::broadcastCommandMessage($sender, KnownTranslationFactory::pocketmine_command_timings_pasteError());