package mindustry.mod; import arc.*; import arc.assets.*; import arc.audio.*; import arc.files.*; import arc.mock.*; import arc.struct.*; import arc.util.*; import arc.util.Log.*; import mindustry.*; import mindustry.mod.Mods.*; import rhino.*; import rhino.module.*; import rhino.module.provider.*; import java.io.*; import java.net.*; import java.util.regex.*; public class Scripts implements Disposable{ private final Seq blacklist = Seq.with(".net.", "java.net", "files", "reflect", "javax", "rhino", "file", "channels", "jdk", "runtime", "util.os", "rmi", "security", "org.", "sun.", "beans", "sql", "http", "exec", "compiler", "process", "system", ".awt", "socket", "classloader", "oracle", "invoke", "java.util.function", "java.util.stream", "org."); private final Seq whitelist = Seq.with("mindustry.net", "netserver", "netclient", "com.sun.proxy.$proxy", "mindustry.gen.", "mindustry.logic."); private final Context context; private final Scriptable scope; private boolean errored; LoadedMod currentMod = null; public Scripts(){ Time.mark(); context = Vars.platform.getScriptContext(); context.setClassShutter(type -> !blacklist.contains(type.toLowerCase()::contains) || whitelist.contains(type.toLowerCase()::contains)); context.getWrapFactory().setJavaPrimitiveWrap(false); context.setLanguageVersion(Context.VERSION_ES6); scope = new ImporterTopLevel(context); new RequireBuilder() .setModuleScriptProvider(new SoftCachingModuleScriptProvider(new ScriptModuleProvider())) .setSandboxed(true).createRequire(context, scope).install(scope); if(!run(Core.files.internal("scripts/global.js").readString(), "global.js", false)){ errored = true; } Log.debug("Time to load script engine: @", Time.elapsed()); } public boolean hasErrored(){ return errored; } public String runConsole(String text){ try{ Object o = context.evaluateString(scope, text, "console.js", 1, null); if(o instanceof NativeJavaObject) o = ((NativeJavaObject)o).unwrap(); if(o instanceof Undefined) o = "undefined"; return String.valueOf(o); }catch(Throwable t){ return getError(t); } } private String getError(Throwable t){ t.printStackTrace(); return t.getClass().getSimpleName() + (t.getMessage() == null ? "" : ": " + t.getMessage()); } public void log(String source, String message){ log(LogLevel.info, source, message); } public void log(LogLevel level, String source, String message){ Log.log(level, "[@]: @", source, message); } //region utility mod functions public String readString(String path){ return Vars.tree.get(path, true).readString(); } public byte[] readBytes(String path){ return Vars.tree.get(path, true).readBytes(); } public Sound loadSound(String soundName){ if(Vars.headless) return new MockSound(); String name = "sounds/" + soundName; String path = Vars.tree.get(name + ".ogg").exists() && !Vars.ios ? name + ".ogg" : name + ".mp3"; if(Core.assets.contains(path, Sound.class)) return Core.assets.get(path, Sound.class); ModLoadingSound sound = new ModLoadingSound(); AssetDescriptor desc = Core.assets.load(path, Sound.class); desc.loaded = result -> sound.sound = (Sound)result; desc.errored = Throwable::printStackTrace; return sound; } public Music loadMusic(String soundName){ if(Vars.headless) return new MockMusic(); String name = "music/" + soundName; String path = Vars.tree.get(name + ".ogg").exists() && !Vars.ios ? name + ".ogg" : name + ".mp3"; if(Core.assets.contains(path, Music.class)) return Core.assets.get(path, Music.class); ModLoadingMusic sound = new ModLoadingMusic(); AssetDescriptor desc = Core.assets.load(path, Music.class); desc.loaded = result -> sound.music = (Music)result; desc.errored = Throwable::printStackTrace; return sound; } //endregion public void run(LoadedMod mod, Fi file){ currentMod = mod; run(file.readString(), file.name(), true); currentMod = null; } private boolean run(String script, String file, boolean wrap){ try{ if(currentMod != null){ //inject script info into file context.evaluateString(scope, "modName = \"" + currentMod.name + "\"\nscriptName = \"" + file + "\"", "initscript.js", 1, null); } context.evaluateString(scope, wrap ? "(function(){'use strict';\n" + script + "\n})();" : script, file, 0, null); return true; }catch(Throwable t){ if(currentMod != null){ file = currentMod.name + "/" + file; } log(LogLevel.err, file, "" + getError(t)); return false; } } @Override public void dispose(){ Context.exit(); } private class ScriptModuleProvider extends UrlModuleSourceProvider{ private Pattern directory = Pattern.compile("^(.+?)/(.+)"); public ScriptModuleProvider(){ super(null, null); } @Override public ModuleSource loadSource(String moduleId, Scriptable paths, Object validator) throws URISyntaxException{ if(currentMod == null) return null; return loadSource(moduleId, currentMod.root.child("scripts"), validator); } private ModuleSource loadSource(String moduleId, Fi root, Object validator) throws URISyntaxException{ Matcher matched = directory.matcher(moduleId); if(matched.find()){ LoadedMod required = Vars.mods.locateMod(matched.group(1)); String script = matched.group(2); if(required == null){ // Mod not found, treat it as a folder Fi dir = root.child(matched.group(1)); if(!dir.exists()) return null; // Mod and folder not found return loadSource(script, dir, validator); } currentMod = required; return loadSource(script, required.root.child("scripts"), validator); } Fi module = root.child(moduleId + ".js"); if(!module.exists() || module.isDirectory()) return null; return new ModuleSource( new InputStreamReader(new ByteArrayInputStream((module.readString()).getBytes())), null, new URI(moduleId), root.file().toURI(), validator); } } }