Method RemoteEditor

src/main/java/fielded/RemoteEditor.java:116–936

(Server server, String sn, Watches watches, MessageQueue<Quad<Dict.Prop, Box, Object, Object>, String> queue)

    AtomicReference<String> completionHelp = new AtomicReference<>("");


    public RemoteEditor(Server server, String sn, Watches watches, MessageQueue<Quad<Dict.Prop, Box, Object, Object>, String> queue) {
        this.server = server;
        this.socketName = sn; // we now let this vary on request
        this.queue = queue;
        this.watches = watches;
        this.properties.put(editor, this);
        this.properties.put(Boxes.dontSave, true);

        this.properties.putToMap(Boxes.insideRunLoop, "main.__watch_service__", this::update);
        this.properties.put(editorUtils, new EditorUtils(this));

        watches.addWatch(Mouse.isSelected, "selection.changed");
        watches.addWatch(LinuxWindowTricks.lostFocus, "focus.editor");

        queue.register(Predicate.isEqual("selection.changed"), (c) -> {
            Log.log("remote.trace", () -> " selection changed message ");
            selectionHasChanged = true;
        });

        queue.register(Predicate.isEqual("focus.editor"), (c) -> {
            Log.log("remote.trace", () -> " sending focus request ");
            server.send(socketName, "_messageBus.publish('focus', {})");
        });

        server.addHandlerLast(x -> x.equals("log"), (s, socket, address, payload) -> {

            if (logStack.size() > 0) logStack.get(logStack.size() - 1)
                    .accept("" + payload);

            return payload;
        });

        server.addHandlerLast(x -> x.equals("error"), (s, socket, address, payload) -> {

            if (logStack.size() > 0) errorStack.get(errorStack.size() - 1)
                    .accept("" + payload);

            return payload;
        });

        server.addHandlerLast(Predicate.isEqual("focus.window"), () -> socketName, (s, socket, address, payload) -> {
            find(Boxes.window, both()).findFirst()
                    .ifPresent(w -> w.requestRaise());
            return payload;
        });

        this.properties.put(outputFactory, x -> newOutput(x, "box.output", (m) -> new JSONStringer().object()
                .key("type")
                .value("success")
                .key("message")
                .value(m)
                .key("append")
                .value(true)
                .key("tick")
                .value(RunLoop.getTick())
                .endObject()
                .toString()));