-
-
Notifications
You must be signed in to change notification settings - Fork 30
/
SyncCommand.java
62 lines (52 loc) · 2.29 KB
/
SyncCommand.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
package net.aufdemrand.denizencore.scripts.commands.core;
import net.aufdemrand.denizencore.DenizenCore;
import net.aufdemrand.denizencore.exceptions.CommandExecutionException;
import net.aufdemrand.denizencore.exceptions.InvalidArgumentsException;
import net.aufdemrand.denizencore.scripts.ScriptEntry;
import net.aufdemrand.denizencore.scripts.commands.BracedCommand;
import net.aufdemrand.denizencore.scripts.commands.Holdable;
import net.aufdemrand.denizencore.scripts.queues.ScriptQueue;
import net.aufdemrand.denizencore.scripts.queues.core.InstantQueue;
import net.aufdemrand.denizencore.utilities.scheduling.OneTimeSchedulable;
import java.util.List;
public class SyncCommand extends BracedCommand implements Holdable {
@Override
public void onEnable() {
setBraced();
}
@Override
public void parseArgs(ScriptEntry scriptEntry) throws InvalidArgumentsException {
scriptEntry.addObject("braces", getBracedCommands(scriptEntry));
}
@Override
public void execute(ScriptEntry scriptEntry) throws CommandExecutionException {
ScriptQueue residingQueue = scriptEntry.getResidingQueue();
final InstantQueue queue = InstantQueue.getQueue(ScriptQueue.getNextId("SYNC_COMMAND"));
queue.addEntries(((List<BracedData>) scriptEntry.getObject("braces")).get(0).value);
queue.getAllDefinitions().putAll(residingQueue.getAllDefinitions());
// Setup a callback if the queue is being waited on
if (scriptEntry.shouldWaitFor()) {
// Record the ScriptEntry
final ScriptEntry se = scriptEntry;
queue.callBack(new Runnable() {
@Override
public void run() {
se.setFinished(true);
}
});
}
// If the current queue is asynchronous, delay this queue until the next tick
if (residingQueue.run_async) {
DenizenCore.schedule(new OneTimeSchedulable(new Runnable() {
@Override
public void run() {
queue.start();
}
}, 0));
}
else {
// TODO: warn user about running SyncCommand when already sync?
queue.start();
}
}
}