mirror of
https://github.com/pmmp/PocketMine-MP.git
synced 2025-06-17 00:44:08 +00:00
245 lines
7.6 KiB
PHP
245 lines
7.6 KiB
PHP
<?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 ConsoleAPI{
|
|
private $loop, $server, $event, $help, $cmds, $alias;
|
|
function __construct(){
|
|
$this->help = array();
|
|
$this->cmds = array();
|
|
$this->alias = array();
|
|
$this->server = ServerAPI::request();
|
|
$this->last = microtime(true);
|
|
}
|
|
|
|
public function init(){
|
|
$this->event = $this->server->event("server.tick", array($this, "handle"));
|
|
$this->loop = new ConsoleLoop;
|
|
$this->loop->start();
|
|
$this->register("help", "[page|command name]", array($this, "defaultCommands"));
|
|
$this->register("status", "", array($this, "defaultCommands"));
|
|
$this->register("difficulty", "<0|1>", array($this, "defaultCommands"));
|
|
$this->register("invisible", "<on|off>", array($this, "defaultCommands"));
|
|
$this->register("say", "<message ...>", array($this, "defaultCommands"));
|
|
$this->register("save-all", "", array($this, "defaultCommands"));
|
|
$this->register("stop", "", array($this, "defaultCommands"));
|
|
$this->server->api->ban->cmdWhitelist("help");
|
|
}
|
|
|
|
function __destruct(){
|
|
$this->server->deleteEvent($this->event);
|
|
$this->loop->stop = true;
|
|
$this->loop->notify();
|
|
$this->loop->join();
|
|
}
|
|
|
|
public function defaultCommands($cmd, $params, $issuer, $alias){
|
|
$output = "";
|
|
switch($cmd){
|
|
case "invisible":
|
|
$p = strtolower(array_shift($params));
|
|
switch($p){
|
|
case "on":
|
|
case "true":
|
|
case "1":
|
|
$output .= "Server is invisible\n";
|
|
$this->server->api->setProperty("server-invisible", true);
|
|
break;
|
|
case "off":
|
|
case "false":
|
|
case "0":
|
|
$output .= "Server is visible\n";
|
|
$this->server->api->setProperty("server-invisible", false);
|
|
break;
|
|
default:
|
|
$output .= "Usage: /invisible <on | off>\n";
|
|
break;
|
|
}
|
|
break;
|
|
case "status":
|
|
if(!($issuer instanceof Player) and $issuer === "console"){
|
|
$this->server->debugInfo(true);
|
|
}
|
|
$info = $this->server->debugInfo();
|
|
$output .= "TPS: ".$info["tps"].", Memory usage: ".$info["memory_usage"]." (Peak ".$info["memory_peak_usage"].")\n";
|
|
break;
|
|
case "update-done":
|
|
$this->server->api->setProperty("last-update", time());
|
|
break;
|
|
case "stop":
|
|
$this->loop->stop = true;
|
|
$output .= "Stopping the server\n";
|
|
$this->server->close();
|
|
break;
|
|
case "difficulty":
|
|
$s = trim(array_shift($params));
|
|
if($s == "" or (((int) $s) !== 0 and ((int) $s) !== 1)){
|
|
$output .= "Usage: /difficulty <0|1>\n";
|
|
break;
|
|
}
|
|
$this->server->api->setProperty("difficulty", (int) $s);
|
|
$output .= "Difficulty changed to ".$this->server->difficulty."\n";
|
|
break;
|
|
case "say":
|
|
$s = implode(" ", $params);
|
|
if(trim($s) == ""){
|
|
$output .= "Usage: /say <message>\n";
|
|
break;
|
|
}
|
|
$this->server->api->chat->broadcast("[Server] ".$s);
|
|
break;
|
|
case "save-all":
|
|
$this->server->save();
|
|
break;
|
|
|
|
case "?":
|
|
if($issuer !== "console"){
|
|
break;
|
|
}
|
|
case "help":
|
|
if(isset($params[0]) and !is_numeric($params[0])){
|
|
$c = trim(strtolower($params[0]));
|
|
if(isset($this->help[$c]) or isset($this->alias[$c])){
|
|
$c = isset($this->help[$c]) ? $c : $this->alias[$c];
|
|
if($this->server->api->dhandle("console.command.".$c, array("cmd" => $c, "parameters" => array(), "issuer" => $issuer, "alias" => false)) === false
|
|
or $this->server->api->dhandle("console.command", array("cmd" => $c, "parameters" => array(), "issuer" => $issuer, "alias" => false)) === false){
|
|
break;
|
|
}
|
|
$output .= "Usage: /$c ".$this->help[$c]."\n";
|
|
break;
|
|
}
|
|
}
|
|
$cmds = array();
|
|
foreach($this->help as $c => $h){
|
|
if($this->server->api->dhandle("console.command.".$c, array("cmd" => $c, "parameters" => array(), "issuer" => $issuer, "alias" => false)) === false
|
|
or $this->server->api->dhandle("console.command", array("cmd" => $c, "parameters" => array(), "issuer" => $issuer, "alias" => false)) === false){
|
|
continue;
|
|
}
|
|
$cmds[$c] = $h;
|
|
}
|
|
|
|
$max = ceil(count($cmds) / 5);
|
|
$page = (int) (isset($params[0]) ? min($max, max(1, intval($params[0]))):1);
|
|
$output .= "- Showing help page $page of $max (/help <page>) -\n";
|
|
$current = 1;
|
|
foreach($cmds as $c => $h){
|
|
$curpage = (int) ceil($current / 5);
|
|
if($curpage === $page){
|
|
$output .= "/$c ".$h."\n";
|
|
}elseif($curpage > $page){
|
|
break;
|
|
}
|
|
++$current;
|
|
}
|
|
break;
|
|
default:
|
|
$output .= "Command doesn't exist! Use /help\n";
|
|
break;
|
|
}
|
|
return $output;
|
|
}
|
|
|
|
public function alias($alias, $cmd){
|
|
$this->alias[strtolower(trim($alias))] = trim($cmd);
|
|
return true;
|
|
}
|
|
|
|
public function register($cmd, $help, $callback){
|
|
if(!is_callable($callback)){
|
|
return false;
|
|
}
|
|
$cmd = strtolower(trim($cmd));
|
|
$this->cmds[$cmd] = $callback;
|
|
$this->help[$cmd] = $help;
|
|
ksort($this->help, SORT_NATURAL | SORT_FLAG_CASE);
|
|
}
|
|
|
|
public function run($line = "", $issuer = "console", $alias = false){
|
|
if($line != ""){
|
|
$params = explode(" ", $line);
|
|
$cmd = strtolower(array_shift($params));
|
|
if(isset($this->alias[$cmd])){
|
|
$this->run($this->alias[$cmd] . " " .implode(" ", $params), $issuer, $cmd);
|
|
return;
|
|
}
|
|
if($issuer instanceof Player){
|
|
console("[INFO] \"".$issuer->username."\" issued server command: $alias /$cmd ".implode(" ", $params));
|
|
}else{
|
|
console("[INFO] Issued server command: ".ltrim("$alias ")."/$cmd ".implode(" ", $params));
|
|
}
|
|
if($this->server->api->dhandle("console.command.".$cmd, array("cmd" => $cmd, "parameters" => $params, "issuer" => $issuer, "alias" => $alias)) === false
|
|
or $this->server->api->dhandle("console.command", array("cmd" => $cmd, "parameters" => $params, "issuer" => $issuer, "alias" => $alias)) === false){
|
|
$output = "You don't have permission to use this command.\n";
|
|
}else{
|
|
if(isset($this->cmds[$cmd]) and is_callable($this->cmds[$cmd])){
|
|
$output = @call_user_func($this->cmds[$cmd], $cmd, $params, $issuer, $alias);
|
|
}elseif($this->server->api->dhandle("console.command.unknown", array("cmd" => $cmd, "params" => $params, "issuer" => $issuer, "alias" => $alias)) !== false){
|
|
$output = $this->defaultCommands($cmd, $params, $issuer, $alias);
|
|
}
|
|
}
|
|
if($output != "" and ($issuer instanceof Player)){
|
|
$issuer->sendChat(trim($output));
|
|
}elseif($output != "" and $issuer === "console"){
|
|
$mes = explode("\n", trim($output));
|
|
foreach($mes as $m){
|
|
console("[CMD] ".$m);
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
public function handle($time){
|
|
if($this->loop->line !== false){
|
|
$line = trim($this->loop->line);
|
|
$this->loop->line = false;
|
|
$this->run($line, "console");
|
|
}else{
|
|
$this->loop->notify();
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
class ConsoleLoop extends Thread{
|
|
public $line;
|
|
public $stop;
|
|
public function __construct(){
|
|
$this->line = false;
|
|
$this->stop = false;
|
|
}
|
|
|
|
public function run(){
|
|
$fp = fopen("php://stdin", "r");
|
|
while($this->stop === false and ($line = fgets($fp)) !== false){
|
|
$this->line = $line;
|
|
$this->wait();
|
|
$this->line = false;
|
|
}
|
|
exit(0);
|
|
}
|
|
}
|