406 lines
14 KiB
Java
406 lines
14 KiB
Java
package carpet.script;
|
|
|
|
import carpet.script.bundled.BundledModule;
|
|
import carpet.script.value.MapValue;
|
|
import carpet.script.value.StringValue;
|
|
import carpet.settings.CarpetSettings;
|
|
import carpet.CarpetServer;
|
|
import carpet.script.bundled.FileModule;
|
|
import carpet.script.bundled.ModuleInterface;
|
|
import carpet.script.exception.CarpetExpressionException;
|
|
import carpet.script.exception.ExpressionException;
|
|
import carpet.script.exception.InvalidCallbackException;
|
|
import carpet.script.value.Value;
|
|
import carpet.utils.Messenger;
|
|
import com.mojang.brigadier.arguments.StringArgumentType;
|
|
import com.mojang.brigadier.builder.LiteralArgumentBuilder;
|
|
import com.mojang.brigadier.exceptions.CommandSyntaxException;
|
|
import com.mojang.brigadier.tree.CommandNode;
|
|
import net.minecraft.server.command.ServerCommandSource;
|
|
import net.minecraft.util.math.BlockPos;
|
|
|
|
import java.io.File;
|
|
import java.util.ArrayList;
|
|
import java.util.Collections;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Locale;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
import java.util.stream.Collectors;
|
|
|
|
import static net.minecraft.server.command.CommandManager.argument;
|
|
import static net.minecraft.server.command.CommandManager.literal;
|
|
|
|
public class CarpetScriptServer
|
|
{
|
|
//make static for now, but will change that later:
|
|
public ScriptHost globalHost;
|
|
public Map<String, ScriptHost> modules;
|
|
long tickStart;
|
|
public boolean stopAll;
|
|
Set<String> holyMoly;
|
|
public CarpetEventServer events;
|
|
|
|
public static List<ModuleInterface> bundledModuleData = new ArrayList<ModuleInterface>(){{
|
|
add(new BundledModule("camera"));
|
|
add(new BundledModule("event_test"));
|
|
}};
|
|
|
|
public CarpetScriptServer()
|
|
{
|
|
globalHost = createMinecraftScriptHost(null, null, false, null);
|
|
events = new CarpetEventServer();
|
|
modules = new HashMap<>();
|
|
tickStart = 0L;
|
|
stopAll = false;
|
|
resetErrorSnooper();
|
|
holyMoly = CarpetServer.minecraft_server.getCommandManager().getDispatcher().getRoot().getChildren().stream().map(CommandNode::getName).collect(Collectors.toSet());
|
|
}
|
|
|
|
public void loadAllWorldScripts()
|
|
{
|
|
if (CarpetSettings.scriptsAutoload)
|
|
{
|
|
Messenger.m(CarpetServer.minecraft_server.getCommandSource(), "Auto-loading world scarpet apps");
|
|
for (String moduleName: listAvailableModules(false))
|
|
{
|
|
addScriptHost(CarpetServer.minecraft_server.getCommandSource(), moduleName, true, true);
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
ModuleInterface getModule(String name)
|
|
{
|
|
File folder = CarpetServer.minecraft_server.getLevelStorage().resolveFile(
|
|
CarpetServer.minecraft_server.getLevelName(), "scripts");
|
|
File[] listOfFiles = folder.listFiles();
|
|
if (listOfFiles != null)
|
|
for (File script : listOfFiles)
|
|
{
|
|
if (script.getName().equalsIgnoreCase(name+".sc"))
|
|
{
|
|
return new FileModule(script);
|
|
}
|
|
}
|
|
for (ModuleInterface moduleData : bundledModuleData)
|
|
{
|
|
if (moduleData.getName().equalsIgnoreCase(name))
|
|
{
|
|
return moduleData;
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
public List<String> listAvailableModules(boolean includeBuiltIns)
|
|
{
|
|
List<String> moduleNames = new ArrayList<>();
|
|
if (includeBuiltIns)
|
|
{
|
|
for (ModuleInterface mi : bundledModuleData)
|
|
{
|
|
moduleNames.add(mi.getName());
|
|
}
|
|
}
|
|
File folder = CarpetServer.minecraft_server.getLevelStorage().resolveFile(
|
|
CarpetServer.minecraft_server.getLevelName(), "scripts");
|
|
File[] listOfFiles = folder.listFiles();
|
|
if (listOfFiles == null)
|
|
return moduleNames;
|
|
for (File script : listOfFiles)
|
|
{
|
|
if (script.getName().endsWith(".sc"))
|
|
{
|
|
String name = script.getName().replaceFirst("\\.sc","").toLowerCase(Locale.ROOT);
|
|
moduleNames.add(name);
|
|
}
|
|
}
|
|
return moduleNames;
|
|
}
|
|
|
|
public ScriptHost getHostByName(String name)
|
|
{
|
|
if (name == null)
|
|
return globalHost;
|
|
return modules.get(name);
|
|
}
|
|
|
|
|
|
private ScriptHost createMinecraftScriptHost(String name, ModuleInterface module, boolean perPlayer, ServerCommandSource source)
|
|
{
|
|
ScriptHost host = new ScriptHost(name, module, perPlayer, null );
|
|
host.globalVariables.put("_x", (c, t) -> Value.ZERO);
|
|
host.globalVariables.put("_y", (c, t) -> Value.ZERO);
|
|
host.globalVariables.put("_z", (c, t) -> Value.ZERO);
|
|
// parse code and convert to expression
|
|
if (module != null)
|
|
{
|
|
try
|
|
{
|
|
String code = module.getCode();
|
|
if (code == null)
|
|
{
|
|
Messenger.m(source, "r Unable to load "+name+" app - code not found");
|
|
return null;
|
|
}
|
|
setChatErrorSnooper(source);
|
|
CarpetExpression ex = new CarpetExpression(code, source, new BlockPos(0, 0, 0));
|
|
ex.getExpr().asAModule();
|
|
ex.scriptRunCommand(host, new BlockPos(source.getPosition()));
|
|
}
|
|
catch (CarpetExpressionException e)
|
|
{
|
|
Messenger.m(source, "r Exception white evaluating expression at " + new BlockPos(source.getPosition()) + ": " + e.getMessage());
|
|
resetErrorSnooper();
|
|
return null;
|
|
}
|
|
}
|
|
return host;
|
|
}
|
|
|
|
public boolean addScriptHost(ServerCommandSource source, String name, boolean perPlayer, boolean autoload)
|
|
{
|
|
//TODO add per player modules to support player actions better on a server
|
|
name = name.toLowerCase(Locale.ROOT);
|
|
ModuleInterface module = getModule(name);
|
|
ScriptHost newHost = createMinecraftScriptHost(name, module, perPlayer, source);
|
|
if (newHost == null)
|
|
{
|
|
Messenger.m(source, "r Failed to add "+name+" app");
|
|
return false;
|
|
}
|
|
if (module == null)
|
|
{
|
|
Messenger.m(source, "r Unable to locate the app, but created empty "+name+" app instead");
|
|
modules.put(name, newHost);
|
|
return true;
|
|
}
|
|
String code = module.getCode();
|
|
if (module.getCode() == null)
|
|
{
|
|
Messenger.m(source, "r Unable to load "+name+" app - not found");
|
|
return false;
|
|
}
|
|
|
|
modules.put(name, newHost);
|
|
|
|
if (!addConfig(source, name) && autoload)
|
|
{
|
|
removeScriptHost(source, name);
|
|
return false;
|
|
}
|
|
addEvents(source, name);
|
|
addCommand(source, name);
|
|
return true;
|
|
}
|
|
|
|
|
|
private boolean addConfig(ServerCommandSource source, String hostName)
|
|
{
|
|
ScriptHost host = modules.get(hostName);
|
|
if (host == null || !host.globalFunctions.containsKey("__config"))
|
|
{
|
|
return false;
|
|
}
|
|
try
|
|
{
|
|
Value ret = host.callUDF(BlockPos.ORIGIN, source, host.globalFunctions.get("__config"), Collections.emptyList());
|
|
if (!(ret instanceof MapValue)) return false;
|
|
Map<Value, Value> config = ((MapValue) ret).getMap();
|
|
host.setPerPlayer(config.getOrDefault(new StringValue("scope"), new StringValue("player")).getString().equalsIgnoreCase("player"));
|
|
return config.getOrDefault(new StringValue("stay_loaded"), Value.FALSE).getBoolean();
|
|
}
|
|
catch (NullPointerException | InvalidCallbackException ignored)
|
|
{
|
|
}
|
|
return false;
|
|
}
|
|
private void addEvents(ServerCommandSource source, String hostName)
|
|
{
|
|
ScriptHost host = modules.get(hostName);
|
|
if (host == null)
|
|
{
|
|
return;
|
|
}
|
|
for (String fun : host.globalFunctions.keySet())
|
|
{
|
|
if (!fun.startsWith("__on_"))
|
|
continue;
|
|
String event = fun.replaceFirst("__on_","");
|
|
if (!CarpetEventServer.Event.byName.containsKey(event))
|
|
continue;
|
|
events.addEvent(event, hostName, fun);
|
|
}
|
|
}
|
|
|
|
|
|
private void addCommand(ServerCommandSource source, String hostName)
|
|
{
|
|
ScriptHost host = modules.get(hostName);
|
|
if (host == null)
|
|
{
|
|
return;
|
|
}
|
|
if (!host.globalFunctions.containsKey("__command"))
|
|
{
|
|
Messenger.m(source, "gi "+hostName+" app loaded.");
|
|
return;
|
|
}
|
|
if (holyMoly.contains(hostName))
|
|
{
|
|
Messenger.m(source, "gi "+hostName+" app loaded with no command.");
|
|
Messenger.m(source, "gi Tried to mask vanilla command.");
|
|
return;
|
|
}
|
|
|
|
LiteralArgumentBuilder<ServerCommandSource> command = literal(hostName).
|
|
requires((player) -> modules.containsKey(hostName)).
|
|
executes( (c) ->
|
|
{
|
|
Messenger.m(c.getSource(), "gi "+modules.get(hostName).retrieveForExecution(c.getSource()).call(c.getSource(),"__command", null, ""));
|
|
return 1;
|
|
});
|
|
|
|
for (String function : host.getPublicFunctions())
|
|
{
|
|
command = command.
|
|
then(literal(function).
|
|
requires((player) -> modules.containsKey(hostName) && modules.get(hostName).getPublicFunctions().contains(function)).
|
|
executes( (c) -> {
|
|
Messenger.m(
|
|
c.getSource(),
|
|
"gi "+modules.get(hostName).retrieveForExecution(c.getSource()).call(
|
|
c.getSource(),
|
|
function,
|
|
null,
|
|
""
|
|
)
|
|
);
|
|
return 1;
|
|
}).
|
|
then(argument("args...", StringArgumentType.greedyString()).
|
|
executes( (c) -> {
|
|
Messenger.m(
|
|
c.getSource(),
|
|
"gi "+modules.get(hostName).retrieveForExecution(c.getSource()).call(
|
|
c.getSource(),
|
|
function,
|
|
null,
|
|
StringArgumentType.getString(c, "args...")
|
|
)
|
|
);
|
|
return 1;
|
|
})));
|
|
}
|
|
Messenger.m(source, "gi "+hostName+" app loaded with /"+hostName+" command");
|
|
CarpetServer.minecraft_server.getCommandManager().getDispatcher().register(command);
|
|
CarpetServer.settingsManager.notifyPlayersCommandsChanged();
|
|
}
|
|
|
|
public void setChatErrorSnooper(ServerCommandSource source)
|
|
{
|
|
ExpressionException.errorSnooper = (expr, token, message) ->
|
|
{
|
|
try
|
|
{
|
|
source.getPlayer();
|
|
}
|
|
catch (CommandSyntaxException e)
|
|
{
|
|
return null;
|
|
}
|
|
String[] lines = expr.getCodeString().split("\n");
|
|
|
|
String shebang = message;
|
|
|
|
if (lines.length > 1)
|
|
{
|
|
shebang += " at line "+(token.lineno+1)+", pos "+(token.linepos+1);
|
|
}
|
|
else
|
|
{
|
|
shebang += " at pos "+(token.pos+1);
|
|
}
|
|
if (expr.getName() != null)
|
|
{
|
|
shebang += " in "+expr.getName()+"";
|
|
}
|
|
Messenger.m(source, "r "+shebang);
|
|
|
|
if (lines.length > 1 && token.lineno > 0)
|
|
{
|
|
Messenger.m(source, "l "+lines[token.lineno-1]);
|
|
}
|
|
Messenger.m(source, "l "+lines[token.lineno].substring(0, token.linepos), "r HERE>> ", "l "+
|
|
lines[token.lineno].substring(token.linepos));
|
|
|
|
if (lines.length > 1 && token.lineno < lines.length-1)
|
|
{
|
|
Messenger.m(source, "l "+lines[token.lineno+1]);
|
|
}
|
|
return new ArrayList<>();
|
|
};
|
|
}
|
|
public void resetErrorSnooper()
|
|
{
|
|
ExpressionException.errorSnooper=null;
|
|
}
|
|
|
|
public boolean removeScriptHost(ServerCommandSource source, String name)
|
|
{
|
|
name = name.toLowerCase(Locale.ROOT);
|
|
if (!modules.containsKey(name))
|
|
{
|
|
Messenger.m(source, "r No such app found: ", "wb " + name);
|
|
return false;
|
|
}
|
|
// stop all events associated with name
|
|
events.removeAllHostEvents(name);
|
|
modules.get(name).onClose();
|
|
modules.remove(name);
|
|
CarpetServer.settingsManager.notifyPlayersCommandsChanged();
|
|
Messenger.m(source, "gi Removed "+name+" app");
|
|
return true;
|
|
}
|
|
|
|
public boolean runas(ServerCommandSource source, String hostname, String udf_name, List<LazyValue> argv)
|
|
{
|
|
return runas(BlockPos.ORIGIN, source, hostname, udf_name, argv);
|
|
}
|
|
|
|
public boolean runas(BlockPos origin, ServerCommandSource source, String hostname, String udf_name, List<LazyValue> argv)
|
|
{
|
|
ScriptHost host = globalHost;
|
|
try
|
|
{
|
|
if (hostname != null)
|
|
host = modules.get(hostname).retrieveForExecution(source);
|
|
host.callUDF(origin, source, host.globalFunctions.get(udf_name), argv);
|
|
}
|
|
catch (NullPointerException | InvalidCallbackException npe)
|
|
{
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
public void tick()
|
|
{
|
|
events.tick();
|
|
for (ScriptHost host : modules.values())
|
|
{
|
|
host.tick();
|
|
}
|
|
}
|
|
|
|
public void onClose()
|
|
{
|
|
for (ScriptHost host : modules.values())
|
|
{
|
|
host.onClose();
|
|
}
|
|
}
|
|
}
|