import asg.cliche.Command; //导入依赖的package包/类
@Command
public String setPluginConfig(@Param(name = "plugin-name") String pluginName, @Param(name = "config") String config) {
    PluginType pluginType = MineCloud.instance().mongo()
            .repositoryBy(PluginType.class)
            .findFirst(pluginName);

    if (pluginType == null) {
        return "No found plugin by the name of " + pluginName;
    }

    if (!pluginType.configs().contains(config)) {
        return "No configs by the name of " + config + " was found!";
    }

    if (type.plugins() == null || !type.plugins().stream().anyMatch((p) -> p.name().equalsIgnoreCase(pluginName))) {
        return pluginName + " has not been added through add-plugin!";
    }

    type.plugins().stream()
            .filter((p) -> p.name().equalsIgnoreCase(pluginName))
            .findFirst().get()
            .setConfig(config);
    return "Successfully set config version to " + config;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public String push() {
    if (type.dedicatedRam() == 0 ||
            type.maxPlayers() == 0 ||
            type.preferredNode() == null ||
            type.mod() == null ||
            type.defaultWorld() == null) {
        return "Required fields (dedicatedRam, maxPlayers, preferredNode, defaultWorld) have not been set by the user! " +
                "Unable to push modifications";
    }

    MineCloud.instance().mongo()
            .repositoryBy(ServerType.class)
            .save(type);
    return "Successfully pushed modifications to database!";
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(name = "!show")
public List<String> show() {
    List<String> list = new ArrayList<>();
    list.add("Currently Modeling [Server Type] (" + type.name() + ")");
    list.add("===========================================");
    list.add("Listing Specifications...");
    list.add("- Maximum Amount of Players: " + type.maxPlayers());
    list.add("- Preferred Node: " + type.preferredNode().name());
    list.add("- Mod: " + type.mod());
    list.add("- Dedicated Ram (Per Server): " + type.dedicatedRam() + "MB");
    list.add("- Plugins: " + formatPlugins(type.plugins()));
    list.add("- Is Default: " + (type.defaultServer() ? "Yes" : "No"));
    list.add("- Default World: " + type.defaultWorld().name() + "(" + type.defaultWorld().version() + ")");
    list.add("- Worlds: " + formatWorlds(type.worlds()));
    list.add("- Timeout: " + type.timeOut());
    list.add("===========================================");
    list.add("If you're ready to go, type 'push'.");
    return list;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(name = "!show")
public List<String> show() {
    List<String> list = new ArrayList<>();
    list.add("Currently Modeling [Node Type] (" + type.name() + ")");
    list.add("===========================================");
    list.add("Listing Specifications...");
    list.add("- Ram: " + type.ram() + "MB");
    list.add("- CPU Specifications:");
    list.add("  Base Frequency: " + type.processor().baseFrequency());
    list.add("  Max Frequency: " + type.processor().maxFrequency());
    list.add("  Cores: " + type.processor().cores());
    list.add("  Threads: " + type.processor().threads());
    list.add("===========================================");
    list.add("If you're ready to go, type 'push'.");
    return list;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public String addBungee(@Param(name = "bungee-name") String bungeeName, @Param(name = "amount") int amount) {
    BungeeType bungeeType = MineCloud.instance().mongo()
            .repositoryBy(BungeeType.class)
            .findFirst(bungeeName);

    if (bungeeType == null) {
        return "No bungees found by the name of " + bungeeName;
    }

    if (type.bungeeMetadata() == null) {
        type.setBungees(new HashMap<>());
    }

    Map<BungeeType, Integer> bungeeTypes = type.bungeeMetadata();

    bungeeTypes.put(bungeeType, amount);
    type.setBungees(bungeeTypes);

    return "Successfully added " + bungeeName + " to Network";
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public String addServer(@Param(name = "server-name") String name, @Param(name = "min") int min, @Param(name = "max") int max) {
    ServerType serverType = MineCloud.instance().mongo()
            .repositoryBy(ServerType.class)
            .findFirst(name);

    if (serverType == null) {
        return "No server types found by the name of " + name;
    }

    if (type.serverMetadata() == null) {
        type.setServerMetadata(new ArrayList<>());
    }

    List<ServerNetworkMetadata> metadata = type.serverMetadata();
    ServerNetworkMetadata md = new ServerNetworkMetadata();

    md.setType(serverType);
    md.setMaximumAmount(max);
    md.setMinimumAmount(min);

    metadata.add(md);

    return "Successfully added " + name + " to Network!";
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public String removeBungee(@Param(name = "bungee-name") String bungee) {
    BungeeType bungeeType = MineCloud.instance().mongo()
            .repositoryBy(BungeeType.class)
            .findFirst(bungee);

    if (bungeeType == null) {
        return "No bungees found by the name of " + bungee;
    }

    if (type.bungeeMetadata() == null) {
        type.setBungees(new HashMap<>());
    }

    Map<BungeeType, Integer> bungeeTypes = type.bungeeMetadata();

    if (!bungeeTypes.keySet().stream()
            .anyMatch((bt) -> bt.name().equalsIgnoreCase(bungeeType.name()))) {
        return bungee + " is not on the network";
    }

    new HashSet<>(bungeeTypes.keySet()).stream()
            .filter((bt) -> bt.name().equalsIgnoreCase(bungeeType.name()))
            .forEach(bungeeTypes::remove);
    return bungee + " has been removed from the network!";
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public String removeServer(@Param(name = "server-name") String name) {
    ServerType serverType = MineCloud.instance().mongo()
            .repositoryBy(ServerType.class)
            .findFirst(name);

    if (serverType == null) {
        return "No server types found by the name of " + name;
    }

    if (type.serverMetadata() == null) {
        type.setServerMetadata(new ArrayList<>());
    }

    List<ServerNetworkMetadata> metadata = type.serverMetadata();
    Optional<ServerNetworkMetadata> optional = metadata.stream()
            .filter((sm) -> sm.type().name().equals(serverType.name()))
            .findFirst();

    if (!optional.isPresent()) {
        return name + " is not on the network!";
    }

    metadata.remove(optional.get());
    return name + " has been removed from the network!";
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(description = "Change the current directory")
public void changeDirectory(
        @Param(name = "index", description = "Index of folder you want to switch to, OR '..' to go back")
        String index) throws IOException, OneDriveException {

    OneFolder newCurrentFolder;
    if (index.equals("..")) {
        newCurrentFolder = currentFolder.getParentFolder();
    } else {
        newCurrentFolder = currentFolderFolders.get(index);
    }

    if (newCurrentFolder != null) {
        currentFolder = newCurrentFolder;
    }

    System.out.println("Changing folder to: " + currentFolder.getName());
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(name = "list children", abbrev = "ls")
public void listSubItems() throws IOException, OneDriveException {
    System.out.println("Listing children");

    this.currentFolderFiles = new HashMap<>();
    this.currentFolderFolders = new HashMap<>();
    this.currentFolderItems = convertToMap(currentFolder.getChildren(), OneFile.class);

    for (String s : this.currentFolderItems.keySet()) {
        OneItem item = this.currentFolderItems.get(s);
        if (item.isFile())
            this.currentFolderFiles.put(s, (OneFile) item);
        if (item.isFolder())
            this.currentFolderFolders.put(s, (OneFolder) item);
    }

    printItemList(currentFolderItems);
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(name = "remove",abbrev = "rm",description = "Deletes a file")
public void deleteItem(
        @Param(name = "index", description = "Index of file you want to delete")
        String index) throws IOException, OneDriveException {
    OneItem item = null;

    if (this.currentFolderFiles.containsKey(index))
        item = (OneItem) this.currentFolderFiles.get(index);

    if (this.currentFolderFolders.containsKey(index))
        item = (OneItem) this.currentFolderFolders.get(index);

    if (item != null) {
        System.out.println(String.format("Deleting %s", item.getName()));
        item.delete();
    } else {
        System.out.println("Can not find item with index '" + index + "'");
    }
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(name="invoke-object", abbrev="run")
public void invokeObject(int id, long param) throws NoSuchMethodException, SecurityException,
	IllegalAccessException, IllegalArgumentException, InvocationTargetException {
	
	if(!objects.containsKey(id)) {
		System.out.println("-- Unknown object --");
		return;
	}
	
	current = objects.get(id);
	runParam = param;
	
	new Thread() {
		
		@Override
		public void run() {
			current.run(runParam);
		}
		
	}.start();
	
	System.out.println("-- Done --");
	
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public void help() {
	System.out.println("Available commands are:");
	System.out.println("set <property> <value>");
	System.out.println("\t srchost <hostname:port>\t\t\t- address of the source server");
	System.out.println("\t tgthost <hostname:port>\t\t\t- address of the target server");
	System.out.println("\t loghost <hostname:port>\t\t\t- address of the log server");
	System.out.println("\t namespace <database.collection>\t- source collection namespace");
	System.out.println("\t targetns <database.collection>\t\t- target collection namespace");
	System.out.println("\t secondary <true/false>\t\t- use delayed secondaries for copy");
	System.out.println("\t reshard <true/false>\t\t\t- shard target collection on copy");
	System.out.println("\t key <shard key>\t\t\t- new shard key for clone");
	System.out.println("\t readBatch <integer>\t\t\t- number of documents to read per batch");
	System.out.println("\t writeBatch <integer>\t\t\t- number of documents to write per batch");
	System.out.println();
	System.out.println("conf\t\t\t\t\t\t- print current configuration");
	System.out.println("execute\t\t\t\t\t\t- run current configuration");
	System.out.println("shutdown\t\t\t\t\t- stop source/target synchronization");
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(abbrev = "o", description = "opens a existing run")
public ShellView open(@Param(name = "name", description = "the run name") String name) {
	ShellView rv = new ShellView();

	String path = rootDirectory + File.separator + name;

	unload(rv);

	if (runManager.exists(path)) {
		rv.addMsg("opened: " + name);
		run = name;
	} else {
		rv.addErr("failed to open run");
	}

	return rv;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public ShellView create(String name) {
	ShellView rv = new ShellView();

	String path = rootDirectory + File.separator + name;

	unload(rv);

	// check
	if (runManager.exists(path)) {
		rv.addErr("already existing run");
	} else {
		run = name;
		runManager.create(path);
		rv.addMsg("created: " + run);
		rv.addMsg("opened: " + run);
	}

	return rv;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(abbrev = "load")
public ShellView loadCsv(//
		@Param(name = "fileName", description = "file name with full path") String name,//
		@Param(name = "variables") String variables, //
		@Param(name = "sampleRate") double sampleRate) {
	ShellView rv = new ShellView();

	Set<String> columns = null;
	if (variables != null) {
		String[] split = variables.split(",");
		if (split != null && split.length > 0) {
			columns = Sets.newHashSet(split);
		}
	}

	loadCsv(name, columns, sampleRate, rv);
	return rv;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command
public ShellView sample(String source, String dest, double rate) {
	ShellView rv = new ShellView();

	String sourcePath = path(source, rv);
	String destPath = path(dest, rv);

	if (run == null) {
		rv.addErr("cannot load if no current run. Create or open one");
	} else {
		csvManager.copyCSV(sourcePath, destPath, null, rate);
		inspectCsv(destPath, 0, rv);
	}

	return rv;
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(abbrev = "print", description = "Print the value of a message in the environment")
public void print(
		@Param(name = "expr", description = "The name of the message to be printed or a value in the form <message>[/<field>]+") String msg) {

	if (msg.matches("`(.*)`")) {
		System.out.println(valueOf(msg.substring(1, msg.length() - 1)));
		return;
	}

	if (msg.contains("/")) {
		String[] parts = msg.split("\\/");
		IMCMessage m = vars.get(parts[0]);
		for (int i = 1; i < parts.length - 1; i++) {
			if (m == null)
				break;
			if (m.getTypeOf(parts[i]).equals("message"))
				m = m.getMessage(parts[i]);
		}
		if (m != null)
			System.out.println(m.getValue(parts[parts.length - 1]));
		else {
			System.out.println("null");
		}
	} else
		System.out.println(vars.get(msg));
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(abbrev = "create", description = "Create and add a new message to the environment")
public void create(
		@Param(name = "msg", description = "The name of the message (variable) to be created") String name,
		@Param(name = "type", description = "The type of the message to be created. Examples: Announce, EstimatedState, etc") String msgType)
		throws Exception {

	IMCMessage m = IMCDefinition.getInstance().create(msgType);
	if (m == null)
		throw new Exception("Message type not valid: '" + msgType + "'");

	if (!name.matches("[a-zA-Z_]\\w*")) {
		throw new Exception("Message identifier is not valid: '" + name
				+ "'.");
	}

	vars.put(name, m);
}
 

import asg.cliche.Command; //导入依赖的package包/类
@Command(abbrev = "change", description = "Change a message already stored in the environment")
public void change(
		@Param(name = "msg", description = "The name of the message to be changed") String name,
		@Param(name = "changes", description = "The changes to be performed in the form <field>=<value>") String... args)
		throws Exception {
	IMCMessage m = vars.get(name);

	if (m == null) {
		throw new Exception("Message not found in the current environment");
	}
	for (int i = 0; i < args.length; i++) {
		String[] parts = args[i].split("=");
		if (parts.length != 2) {
			throw new Exception("Malformed field attribution expression: '"
					+ args[i] + "'.");
		}
		String field = parts[0].trim();
		String value = parts[1].trim();
		setValue(m, field, value);
	}
	vars.put(name, m);
}