Class RemoteEditor

src/main/java/fielded/RemoteEditor.java:46–1338

connects to that WebSocket and does things via those message buses

/**
 * connects to that WebSocket and does things via those message buses
 */
public class RemoteEditor extends Box {

    static public final Dict.Prop<EditorUtils> editorUtils = new Dict.Prop<EditorUtils>("editorUtils").toCanon()
            .doc("utility class for manipulating the editor at a high level");

    static public final Dict.Prop<Supplier<Map<Pair<String, String>, Runnable>>> hotkeyCommands = new Dict.Prop<>("hotkeyCommands").type()
            .doc("commands injected into the editor as hotkey menuSpecs")
            .toCanon();
    static public final Dict.Prop<RemoteEditor> editor = new Dict.Prop<>("editor").type()
            .doc("the (remote) editor object")
            .toCanon();
    static public final Dict.Prop<Function<Box, Consumer<String>>> outputFactory = new Dict.Prop<>("outputFactory");
    static public final Dict.Prop<Function<Box, Consumer<Pair<Integer, String>>>> outputErrorFactory = new Dict.Prop<>("outputErrorFactory");
    static public final Dict.Prop<Function<Box, BiConsumer<String, JSONObject>>> outputMessageFactory = new Dict.Prop<>("outputMessageFactory");

    static public final Dict.Prop<String> defaultEditorProperty = new Dict.Prop<String>("defaultEditorProperty").type()
            .doc("The property that the editor will switch to. Will default to 'code' if not set.");
    private final Server server;

    private String socketName;

    private final MessageQueue<Quad<Dict.Prop, Box, Object, Object>, String> queue;
    private final Watches watches;
    public List<Consumer<String>> logStack = new ArrayList<>();
    public List<Consumer<String>> errorStack = new ArrayList<>();
    public HashMap<String, String> previousClipboards = new LinkedHashMap<>();
    Commands commandHelper = new Commands();

    RateLimitingQueue<String, Pair<String, String>> rater = new RateLimitingQueue<>(20, 100) {

        Deque<Long> overflowedAt = new LinkedList<>();

        @Override
        protected String groupFor(Pair<String, String> stringRunnablePair) {
            return stringRunnablePair.first;
        }

        String lastSend = "";
        boolean warned = false;
        long prevTick = RunLoop.tick;

        @Override
        protected void send(String key, Collection<Pair<String, String>> value) {

//			if (value.size() == 0) return;

            int index = 0;
            for (Pair<String, String> v : value) {
                System.out.println(" --> " + v.second);
                server.send(socketName, "_messageBus.publish('" + key + "', " + v.second + ")");
                if (index++ > 4) {
                    System.out.println(" limit exceeded (" + value.size() + ")");
                    //TODO, notify...
                    break;
                }
            }
//			}