gx_head/engine/jsonrpc.cpp

/*
 * Copyright (C) 2013 Andreas Degert
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#include "jsonrpc.h"
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/types.h>
#include <sys/socket.h>
#if HAVE_BLUEZ
#include <bluetooth/bluetooth.h>
#include <bluetooth/rfcomm.h>
#endif

#include "jsonrpc_methods.cc"

const char *engine_state_to_string(gx_engine::GxEngineState s) {
    switch (s) {
    case gx_engine::kEngineOff: return "stopped";
    case gx_engine::kEngineOn: return "running";
    case gx_engine::kEngineBypass: return "bypassed";
    }
    assert(false);
    return 0;
}

gx_engine::GxEngineState string_to_engine_state(const std::string& s) {
    if (s == "stopped") {
        return gx_engine::kEngineOff;
    }
    if (s == "running") {
        return gx_engine::kEngineOn;
    }
    if (s == "bypassed") {
        return gx_engine::kEngineBypass;
    }
    assert(false);
    return gx_engine::kEngineOff;
}

class RpcError: public exception {
public:
    int code;
    Glib::ustring message;
public:
    RpcError(int code_, Glib::ustring message_): code(code_), message(message_) {}
    ~RpcError() throw() { }
    virtual const char* what() const throw() { return message.c_str(); }
};


class JsonString: public JsonValue {
private:
    Glib::ustring string;
    JsonString(Glib::ustring s): JsonValue(), string(s) {}
    ~JsonString() {}
    friend class JsonArray;
    virtual const Glib::ustring& getString() const;
};

class JsonFloat: public JsonValue {
private:
    double value;
    JsonFloat(double v): value(v) {}
    ~JsonFloat() {}
    friend class JsonArray;
    virtual double getFloat() const;
};

class JsonInt: public JsonValue {
private:
    int value;
    JsonInt(int v): value(v) {}
    ~JsonInt() {}
    friend class JsonArray;
    virtual double getFloat() const;
    virtual int getInt() const;
};

class JsonObject: public JsonValue {
private:
    streampos position;
    gx_system::JsonParser& jp;
    JsonObject(gx_system::JsonParser& jp_): JsonValue(), position(jp_.get_streampos()), jp(jp_) {}
    ~JsonObject() {}
    friend class JsonArray;
    virtual gx_system::JsonSubParser getSubParser() const;
};

JsonArray::~JsonArray() {
    for (iterator i = begin(); i != end(); ++i) {
        delete *i;
    }
}

JsonValue *JsonArray::operator[](unsigned int i) {
    if (i >= size()) {
        throw RpcError(-32602, "Invalid param -- wrong argument count");
    }
    return std::vector<JsonValue*>::operator[](i);
}

void JsonArray::append(gx_system::JsonParser& jp) {
    if (jp.peek() == gx_system::JsonParser::value_string) {
        jp.next();
        push_back(new JsonString(jp.current_value()));
    } else if (jp.peek() == gx_system::JsonParser::value_number) {
        jp.next();
        std::string str = jp.current_value();
        char *endptr;
        int n = strtol(str.c_str(), &endptr, 10);
        if (*endptr == '\0') {
            push_back(new JsonInt(n));
        } else {
            istringstream b(str.c_str());
            float f;
            b >> f;
            push_back(new JsonFloat(f));
        }
    } else if (jp.peek() & (gx_system::JsonParser::begin_array|gx_system::JsonParser::begin_object)) {
        push_back(new JsonObject(jp));
        jp.skip_object();
    } else {
        throw gx_system::JsonException("unexpected token");
    }
}

double JsonValue::getFloat() const {
    throw RpcError(-32602, "Invalid param -- float expected");
}

int JsonValue::getInt() const {
    throw RpcError(-32602, "Invalid param -- int expected");
}

const Glib::ustring& JsonValue::getString() const {
    throw RpcError(-32602, "Invalid param -- string expected");
}

gx_system::JsonSubParser JsonValue::getSubParser() const {
    throw RpcError(-32602, "Invalid param -- object expected");
}

double JsonFloat::getFloat() const {
    return value;
}

double JsonInt::getFloat() const {
    return value;
}

int JsonInt::getInt() const {
    return value;
}

const Glib::ustring& JsonString::getString() const {
    return string;
}

gx_system::JsonSubParser JsonObject::getSubParser() const {
    return gx_system::JsonSubParser(jp, position);
}


/****************************************************************
 ** class UiBuilderVirt
 */

class CmdConnection;

class UiBuilderVirt: public UiBuilder {
private:
    static gx_system::JsonWriter *jw;
    static const gx_system::CmdlineOptions *options;
    static void openTabBox_(const char* label);
    static void openVerticalBox_(const char* label);
    static void openVerticalBox1_(const char* label);
    static void openVerticalBox2_(const char* label);
    static void openHorizontalBox_(const char* label);
    static void openHorizontalhideBox_(const char* label);
    static void openHorizontalTableBox_(const char* label);
    static void openFrameBox_(const char* label);
    static void openFlipLabelBox_(const char* label);
    static void openpaintampBox_(const char* label);
    static void insertSpacer_();
    static void set_next_flags_(int flags);
    static void create_big_rackknob_(const char *id, const char *label);
    static void create_mid_rackknob_(const char *id, const char *label);
    static void create_small_rackknob_(const char *id, const char *label);
    static void create_small_rackknobr_(const char *id, const char *label);
    static void create_master_slider_(const char *id, const char *label);
    static void create_feedback_slider_(const char *id, const char *label);
    static void create_selector_no_caption_(const char *id);
    static void create_selector_(const char *id, const char *label);
    static void create_simple_meter_(const char *id);
    static void create_simple_c_meter_(const char *id,const char *idl, const char *label);
    static void create_spin_value_(const char *id, const char *label);
    static void create_switch_no_caption_(const char *sw_type,const char * id);
    static void create_feedback_switch_(const char *sw_type,const char * id);
    static void create_fload_switch_(const char *sw_type,const char * id,const char * idf);
    static void create_switch_(const char *sw_type,const char * id, const char *label);
    static void create_wheel_(const char * id, const char *label);
    static void create_port_display_(const char *id, const char *label);
    static void create_p_display_(const char *id, const char *idl, const char *idh);
    static void create_simple_spin_value_(const char *id);
    static void create_eq_rackslider_no_caption_(const char *id);
    static void closeBox_();
    static void load_glade_(const char *data);
    static void load_glade_file_(const char *fname);
public:
    UiBuilderVirt(gx_system::JsonWriter *jw, const gx_system::CmdlineOptions *options, PluginDef *pd);
    ~UiBuilderVirt();
};


/****************************************************************
 ** class CmdConnection
 */

const static int InterfaceVersionMajor = 1;
const static int InterfaceVersionMinor = 1;

CmdConnection::CmdConnection(GxService& serv_, const Glib::RefPtr<Gio::SocketConnection>& connection_)
    : serv(serv_),
      connection(connection_),
      outgoing(),
      current_offset(0),
      midi_config_mode(false),
      flags(),
      maxlevel() {
    gx_engine::ParamMap& pmap = serv.settings.get_param();
    for (gx_engine::ParamMap::iterator i = pmap.begin(); i != pmap.end(); ++i) {
        if (i->second->isMaxlevel()) {
            maxlevel[i->first] = i->second->getFloat().get_value();
        }
    }
    jp.start_parser();
}

CmdConnection::~CmdConnection() {
    if (midi_config_mode) {
        serv.jack.get_engine().controller_map.set_config_mode(false, -1);
    }

}

static struct {
    const char *token;
    CmdConnection::msg_type start;
    CmdConnection::msg_type end;
} token_range[] = {
    { "all", (CmdConnection::msg_type)0, (CmdConnection::msg_type)(CmdConnection::END_OF_FLAGS-1) },
    { "preset", CmdConnection::f_preset_changed, CmdConnection::f_preset_changed },
    { "state", CmdConnection::f_state_changed, CmdConnection::f_state_changed },
    { "freq", CmdConnection::f_freq_changed, CmdConnection::f_freq_changed },
    { "display", CmdConnection::f_display, CmdConnection::f_display_state },
    { "tuner", CmdConnection::f_selection_done, CmdConnection::f_selection_done },
    { "presetlist_changed", CmdConnection::f_presetlist_changed, CmdConnection::f_presetlist_changed },
    { "logger", CmdConnection::f_log_message, CmdConnection::f_log_message },
    { "midi", CmdConnection::f_midi_changed, CmdConnection::f_midi_value_changed },
    { "param", CmdConnection::f_parameter_change_notify, CmdConnection::f_parameter_change_notify },
    { "plugins_changed", CmdConnection::f_plugins_changed, CmdConnection::f_plugins_changed },
    { "misc", CmdConnection::f_misc_msg, CmdConnection::f_misc_msg },
    { "units_changed", CmdConnection::f_units_changed, CmdConnection::f_units_changed },
};

bool CmdConnection::find_token(const Glib::ustring& token, msg_type *start, msg_type *end) {
    for (unsigned int i = 0; i < sizeof(token_range) / sizeof(token_range[0]); ++i) {
        if (token == token_range[i].token) {
            *start = token_range[i].start;
            *end = token_range[i].end;
            return true;
        }
    }
    return false;
}

void CmdConnection::listen(const Glib::ustring& tp) {
    msg_type start, end;
    if (!find_token(tp, &start, &end)) {
        cerr << "unknown listen token: " << tp << endl;
        return;
    }
    for (int i = start; i <= end; i++) {
        activate(i, true);
    }
}

void CmdConnection::unlisten(const Glib::ustring& tp) {
    msg_type start, end;
    if (!find_token(tp, &start, &end)) {
        cerr << "unknown listen token: " << tp << endl;
        return;
    }
    for (int i = start; i <= end; i++) {
        activate(i, false);
    }
}

void CmdConnection::send_notify_end(gx_system::JsonStringWriter& jw, bool send_out) {
    jw.send_notify_end();
    if (send_out) {
        jw.finish();
        send(jw);
    }
}

static void write_plugin_state(gx_system::JsonWriter& jw, gx_engine::Plugin *i) {
    jw.begin_object();
    jw.write_kv("id", i->get_pdef()->id);
    jw.write_kv("on_off", i->get_on_off());
    jw.write_kv("box_visible", i->get_box_visible());
    jw.write_kv("position", i->get_position());
    jw.write_kv("post_pre", i->get_effect_post_pre());
    jw.write_kv("stereo", (i->get_pdef()->flags & PGN_STEREO) == PGN_STEREO);
    const char *p;
    p = i->get_pdef()->category;
    if (p) {
        jw.write_kv("category", p);
    }
    p = i->get_pdef()->name;
    if (p) {
        jw.write_kv("name", p);
    }
    p = i->get_pdef()->shortname;
    if (p) {
        jw.write_kv("shortname", p);
    }
    p = i->get_pdef()->description;
    if (p) {
        jw.write_kv("description", p);
    }
    jw.end_object();
}

static void write_parameter_state(gx_system::JsonWriter& jw, const gx_engine::Parameter& p) {
    jw.begin_object();
    if (p.hasRange()) {
        jw.write_kv("lower_bound", p.getLowerAsFloat());
        jw.write_kv("upper_bound", p.getUpperAsFloat());
        jw.write_kv("step", p.getStepAsFloat());
    }
    const value_pair *pairs = p.getValueNames();
    if (pairs) {
        jw.write_key("value_names");
        jw.begin_array();
        for (; pairs->value_id; pairs++) {
            jw.begin_array();
            jw.write(pairs->value_id);
            jw.write(p.value_label(*pairs));
            jw.end_array();
        }
        jw.end_array();
    }
    jw.write_kv("name", p.l_name());
    jw.write_kv("group", p.l_group());
    jw.write_kv("type", p.get_typename());
    gx_engine::Parameter::ctrl_type t = p.getControlType();
    if (t == gx_engine::Parameter::Continuous) {
        jw.write_key("ctl_continous");
        jw.write(1);
    } else if (t == gx_engine::Parameter::Switch) {
        jw.write_key("ctl_switch");
        jw.write(1);
    } else if (t == gx_engine::Parameter::Enum) {
        jw.write_key("ctl_enum");
        jw.write(1);
    }
    jw.write_key("value");
    jw.begin_object();
    p.writeJSON(jw);
    jw.end_object();
    jw.end_object();
}

static inline bool unit_match(const Glib::ustring& id, const Glib::ustring& prefix, const char** gl) {
    if (id.compare(0, prefix.size(), prefix) == 0) {
        return true;
    }
    if (!gl) {
        return false;
    }
    while (*gl) {
        const char *p = *gl;
        if (p[0] == '.') {
            p += 1;
            int n = strlen(p);
            if (strncmp(id.c_str(), p, n) == 0 && id[n] == '.') {
                return true;
            }
        }
        gl += 2;
    }
    return false;
}

#define START_FUNCTION_SWITCH(v)    switch (v) {
#define FUNCTION(n)                 break; case RPCM_##n:
#define PROCEDURE(n)                break; case RPNM_##n:
#define END_FUNCTION_SWITCH(s)      break; default: s; }

void CmdConnection::call(gx_system::JsonWriter& jw, const methodnames *mn, JsonArray& params) {
    START_FUNCTION_SWITCH(mn->m_id);

    FUNCTION(get) {
        gx_engine::ParamMap& param = serv.settings.get_param();
        jw.begin_object();
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            const Glib::ustring& attr = (*i)->getString();
            if (!param.hasId(attr)) {
                jw.write_key(attr);
                if (attr == "sys.active_mono_plugins") {
                    list<gx_engine::Plugin*> l;
                    serv.jack.get_engine().pluginlist.ordered_mono_list(l, PGN_MODE_NORMAL);
                    jw.begin_array();
                    for (list<gx_engine::Plugin*>::iterator i = l.begin(); i != l.end(); ++i) {
                        write_plugin_state(jw, *i);
                    }
                    jw.end_array();
                } else if (attr == "sys.active_stereo_plugins") {
                    list<gx_engine::Plugin*> l;
                    serv.jack.get_engine().pluginlist.ordered_stereo_list(l, PGN_MODE_NORMAL);
                    jw.begin_array();
                    for (list<gx_engine::Plugin*>::iterator i = l.begin(); i != l.end(); ++i) {
                        write_plugin_state(jw, *i);
                    }
                    jw.end_array();
                } else if (attr == "sys.visible_mono_plugins") {
                    list<gx_engine::Plugin*> l;
                    const int bits = (PGN_GUI|gx_engine::PGNI_DYN_POSITION);
                    serv.jack.get_engine().pluginlist.ordered_list(l, false, bits, bits);
                    jw.begin_array();
                    for (list<gx_engine::Plugin*>::iterator i = l.begin(); i != l.end(); ++i) {
                        write_plugin_state(jw, *i);
                    }
                    jw.end_array();
                } else if (attr == "sys.visible_stereo_plugins") {
                    list<gx_engine::Plugin*> l;
                    const int bits = (PGN_GUI|gx_engine::PGNI_DYN_POSITION);
                    serv.jack.get_engine().pluginlist.ordered_list(l, true, bits, bits);
                    jw.begin_array();
                    for (list<gx_engine::Plugin*>::iterator i = l.begin(); i != l.end(); ++i) {
                        write_plugin_state(jw, *i);
                    }
                    jw.end_array();
                } else {
                    jw.write("unknown");
                }
                continue;
            }
            param[attr].writeJSON(jw);
        }
        jw.end_object();
    }

    FUNCTION(parameterlist) {
        serv.settings.get_param().writeJSON(jw);
    }

    FUNCTION(pluginlist) {
        serv.jack.get_engine().pluginlist.writeJSON(jw);
    }

    FUNCTION(plugin_load_ui) {
        PluginDef *pd = serv.jack.get_engine().pluginlist.lookup_plugin(params[0]->getString())->get_pdef();
        if (!pd->load_ui) {
            jw.write_null();
        } else {
            UiBuilderVirt bld(&jw, &serv.settings.get_options(), pd);
            jw.begin_array();
            pd->load_ui(bld, params[1]->getInt());
            jw.end_array();
        }
    }

    FUNCTION(get_rack_unit_order) {
        std::vector<std::string>& ul = serv.settings.get_rack_unit_order(params[0]->getInt());
        jw.begin_array();
        for (std::vector<std::string>::iterator i = ul.begin(); i != ul.end(); ++i) {
            jw.write(*i);
        }
        jw.end_array();
    }

    FUNCTION(get_parameter) {
        gx_engine::ParamMap& param = serv.settings.get_param();
        jw.begin_object();
        if (params.size() == 0) {
            for (gx_engine::ParamMap::iterator i = param.begin(); i != param.end(); ++i) {
                jw.write_key(i->first);
                write_parameter_state(jw, *i->second);
            }
        } else {
            for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
                const Glib::ustring& attr = (*i)->getString();
                if (param.hasId(attr)) {
                    jw.write_key(attr);
                    write_parameter_state(jw, param[attr]);
                }
            }
        }
        jw.end_object();
    }

    FUNCTION(get_parameter_value) {
        gx_engine::ParamMap& param = serv.settings.get_param();
        const Glib::ustring& id = params[0]->getString();
        float f = 0.0;
        if (param[id.substr(0,id.find_last_of(".")+1)+"on_off"].getInt().get_value())
            f = param[id].getFloat().get_value();
        jw.begin_array();
        jw.write(f);
        jw.end_array();
    }

    FUNCTION(get_bank) {
        gx_system::PresetFile* pf = serv.settings.banks.get_file(params[0]->getString());
        if (!pf) {
            throw RpcError(-32602, "Invalid params -- unknown bank");
        }
        pf->writeJSON_remote(jw);
    }

    FUNCTION(banks) {
        gx_system::PresetBanks& banks = serv.settings.banks;
        jw.begin_array();
        for (gx_system::PresetBanks::iterator i = banks.begin(); i != banks.end(); ++i) {
            (*i)->writeJSON_remote(jw);
        }
        jw.end_array();
    }

    FUNCTION(presets) {
        gx_system::PresetFile* pf = serv.settings.banks.get_file(params[0]->getString());
        if (!pf) {
            throw RpcError(-32602, "Invalid params -- unknown bank");
        }
        jw.begin_array();
        for (gx_system::PresetFile::iterator i = pf->begin(); i != pf->end(); ++i) {
            jw.write(i->name);
        }
        jw.end_array();
    }

    FUNCTION(bank_insert_content) {
        gx_system::PresetFile *f = serv.settings.bank_insert_content(params[0]->getString(), params[1]->getString(), params[2]->getInt());
        if (f) {
            f->writeJSON_remote(jw);
        }
    }

    FUNCTION(bank_insert_new) {
        gx_system::PresetFile *f = serv.settings.bank_insert_new(params[0]->getString());
        f->writeJSON_remote(jw);
    }

    FUNCTION(rename_bank) {
        Glib::ustring newname = params[1]->getString();
        jw.begin_array();
        jw.write(serv.settings.rename_bank(params[0]->getString(), newname));
        jw.write(newname);
        jw.end_array();
    }

    FUNCTION(rename_preset) {
        jw.write(
            serv.settings.rename_preset(
                *serv.settings.banks.get_file(params[0]->getString()), params[1]->getString(), params[2]->getString()));
    }

    FUNCTION(bank_check_reparse) {
        jw.write(serv.settings.banks.check_reparse());
    }

    FUNCTION(bank_get_filename) {
        jw.write(serv.settings.banks.get_file(params[0]->getString())->get_filename());
    }

    FUNCTION(bank_get_contents) {
        const std::string& fname = serv.settings.banks.get_file(params[0]->getString())->get_filename();
        jw.begin_array();
        jw.write(fname);
        stringstream s;
        s << ifstream(fname.c_str()).rdbuf();
        jw.write(s.str());
        jw.end_array();
    }

    FUNCTION(convert_preset) {
        jw.write(serv.settings.convert_preset(*serv.settings.banks.get_file(params[0]->getString())));
    }

    FUNCTION(bank_remove) {
        jw.write(serv.settings.remove_bank(params[0]->getString()));
    }

    FUNCTION(get_midi_controller_map) {
        serv.jack.get_engine().controller_map.writeJSON(jw);
    }

    FUNCTION(get_last_midi_control_value) {
        jw.begin_object();
        jw.write(serv.jack.get_engine().controller_map.get_last_midi_control_value(params[0]->getInt()));
        jw.end_object();
    }

    FUNCTION(midi_get_config_mode) {
        bool mode = serv.jack.get_engine().controller_map.get_config_mode();
        jw.begin_array();
        jw.write(mode);
        jw.write(mode ? serv.jack.get_engine().controller_map.get_current_control() : -1);
        jw.end_array();
    }

    FUNCTION(midi_size) {
        jw.write(serv.jack.get_engine().controller_map.size());
    }

    FUNCTION(get_midi_feedback) {
        jw.begin_object();
        jw.write(serv.settings.get_options().system_midiout);
        jw.end_object();
    }

    FUNCTION(getstate) {
        gx_engine::GxEngineState s = serv.jack.get_engine().get_state();
        jw.write(engine_state_to_string(s));
    }

    FUNCTION(getversion) {
        jw.begin_array();
        jw.write(InterfaceVersionMajor);
        jw.write(InterfaceVersionMinor);
        jw.write(GX_VERSION);
        jw.end_array();
    }

    FUNCTION(get_tuning) {
        jw.begin_object();
        jw.write_kv("frequency", serv.jack.get_engine().tuner.get_freq());
        jw.write_kv("note", serv.jack.get_engine().tuner.get_note());
        jw.end_object();
    }

    FUNCTION(get_tuner_freq) {
        jw.write(serv.jack.get_engine().tuner.get_freq());
    }

    FUNCTION(get_tuner_note) {
        jw.write(serv.jack.get_engine().tuner.get_note());
    }

    FUNCTION(get_oscilloscope_mul_buffer) {
        jw.write(serv.jack.get_engine().oscilloscope.get_mul_buffer());
    }

    FUNCTION(get_tuner_switcher_active) {
        jw.write(serv.tuner_switcher.get_active());
    }

    FUNCTION(jack_cpu_load) {
        jw.write(serv.jack.get_jcpu_load());
    }

    FUNCTION(load_impresp_dirs) {
        std::vector<gx_system::FileName> dirs;
        gx_system::list_subdirs(serv.settings.get_options().get_IR_pathlist(), dirs);
        jw.begin_array();
        for (std::vector<gx_system::FileName>::iterator i = dirs.begin(); i != dirs.end(); ++i) {
            jw.begin_array();
            jw.write(i->filename);
            jw.write(i->displayname);
            jw.end_array();
        }
        jw.end_array();
    }

    FUNCTION(read_audio) {
        unsigned int audio_size;
        int audio_chan, audio_type, audio_form, audio_rate;
        float *buffer;
        bool ret = gx_engine::read_audio(params[0]->getString(), &audio_size, &audio_chan,
                                         &audio_type, &audio_form, &audio_rate, &buffer);
        if (!ret) {
            return;
        }
        jw.begin_array();
        jw.write(audio_size);
        jw.write(audio_chan);
        jw.write(audio_type);
        jw.write(audio_form);
        jw.write(audio_rate);
        jw.begin_array();
        for (unsigned int i = 0; i < audio_size*audio_chan; i++) {
            jw.write(buffer[i]);
        }
        jw.end_array();
        jw.end_array();
        delete[] buffer;
    }

    FUNCTION(load_ladspalist) {
        std::vector<std::string> old_not_found;
        ladspa::LadspaPluginList pluginlist;
        pluginlist.load(serv.settings.get_options(), old_not_found);
        jw.begin_array();
        for (std::vector<std::string>::iterator i = old_not_found.begin(); i != old_not_found.end(); ++i) {
            jw.write(*i);
        }
        jw.end_array();
        pluginlist.writeJSON(jw);
    }

    FUNCTION(ladspaloader_update_plugins) {
        serv.ladspaloader_update_plugins(&jw, this);
    }

    FUNCTION(plugin_preset_list_load) {
        gx_preset::UnitPresetList presetnames;
        serv.settings.plugin_preset_list_load(
            serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString())->get_pdef(),
            presetnames);
        jw.begin_array();
        for (gx_preset::UnitPresetList::iterator i = presetnames.begin(); i != presetnames.end(); ++i) {
            jw.begin_array();
            jw.write(i->name);
            jw.write(i->is_set);
            jw.end_array();
        }
        jw.end_array();
    }

    FUNCTION(queryunit) {
        if (params.size() != 1) {
            throw RpcError(-32602, "Invalid params -- 1 parameter expected");
        }
        gx_engine::Plugin *p = serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString());
        if (!p) {
            throw RpcError(-32602, "Invalid params -- plugin not found");
        }
        Glib::ustring unitprefix = p->get_pdef()->id;
        unitprefix += ".";
        const char **gl = p->get_pdef()->groups;
        gx_engine::ParamMap& param = serv.settings.get_param();
        jw.begin_object();
        for (gx_engine::ParamMap::iterator i = param.begin(); i != param.end(); ++i) {
            if (unit_match(i->first, unitprefix, gl)) {
                jw.write_key(i->first);
                write_parameter_state(jw, *i->second);
            }
        }
        jw.end_object();
    }

    FUNCTION(desc) {
        gx_engine::ParamMap& param = serv.settings.get_param();
        jw.begin_object();
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            const Glib::ustring& attr = (*i)->getString();
            jw.write_key(attr);
            if (!param.hasId(attr)) {
                jw.write("unknown");
                continue;
            }
            write_parameter_state(jw, param[attr]);
        }
        jw.end_object();
    }

    FUNCTION(list) {
        const Glib::ustring& prefix = params[0]->getString();
        gx_engine::ParamMap& param = serv.settings.get_param();
        jw.begin_array();
        for (gx_engine::ParamMap::iterator i = param.begin(); i != param.end(); ++i) {
            if (i->first.compare(0, prefix.size(), prefix) == 0) {
                jw.write(i->first);
            }
        }
        jw.end_array();
    }

    END_FUNCTION_SWITCH(cerr << "Method not found: " << mn->name << endl; assert(false));
}

static void save_preset(gx_preset::GxSettings& settings, const Glib::ustring& bank,
                        const Glib::ustring& preset) {
    gx_system::PresetFile *pf = settings.banks.get_file(bank);
    if (!pf) {
        Glib::ustring newbank = bank;
        std::string newfile;
        settings.banks.make_bank_unique(newbank, &newfile);
        pf = new gx_system::PresetFile();
        if (pf->create_file(newbank, newfile, gx_system::PresetFile::PRESET_FILE, 0)) {
            settings.banks.insert(pf);
        } else {
            delete pf;
            throw RpcError(-32001, "bank not found");
        }
    }
    if (!pf->is_mutable()) {
        throw RpcError(-32001, "bank is immutable");
    }
    settings.save(*pf, preset);
}

void CmdConnection::notify(gx_system::JsonStringWriter& jw, const methodnames *mn, JsonArray& params) {
    START_FUNCTION_SWITCH(mn->m_id);

    PROCEDURE(insert_rack_unit) {
        Glib::ustring unit = params[0]->getString();
        gx_engine::Plugin *pl = serv.jack.get_engine().pluginlist.find_plugin(unit);
        if (!pl) {
            throw RpcError(-32602, Glib::ustring::compose("Invalid param -- unit %1 unknown", unit));
        }
        bool stereo = params[2]->getInt();
        serv.settings.insert_rack_unit(unit, params[1]->getString(), stereo);
        gx_engine::Parameter& p = serv.settings.get_param()[pl->id_box_visible()];
        p.set_blocked(true);
        pl->set_box_visible(true);
        p.set_blocked(false);
        serv.send_rack_changed(stereo, this);
    }

    PROCEDURE(remove_rack_unit) {
        Glib::ustring unit = params[0]->getString();
        gx_engine::Plugin *pl = serv.jack.get_engine().pluginlist.find_plugin(unit);
        if (!pl) {
            throw RpcError(-32602, Glib::ustring::compose("Invalid param -- unit %1 unknown", unit));
        }
        bool stereo = params[1]->getInt();
        if (serv.settings.remove_rack_unit(params[0]->getString(), stereo)) {
            gx_engine::Parameter *p;
            p = &serv.settings.get_param()[pl->id_box_visible()];
            p->set_blocked(true);
            pl->set_box_visible(false);
            p->set_blocked(false);
            p = &serv.settings.get_param()[pl->id_on_off()];
            p->set_blocked(true);
            pl->set_on_off(false);
            p->set_blocked(false);
            serv.send_rack_changed(stereo, this);
        }
    }

    PROCEDURE(bank_reorder) {
        std::vector<Glib::ustring> neworder;
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            neworder.push_back((*i)->getString());
        }
        serv.settings.banks.reorder(neworder);
    }

    PROCEDURE(reorder_preset) {
        std::vector<Glib::ustring> neworder;
        for (JsonArray::iterator i = params.begin()+1; i != params.end(); ++i) {
            neworder.push_back((*i)->getString());
        }
        serv.settings.reorder_preset(*serv.settings.banks.get_file(params[0]->getString()), neworder);
    }

    PROCEDURE(erase_preset) {
        serv.settings.erase_preset(*serv.settings.banks.get_file(params[0]->getString()), params[1]->getString());
    }

    PROCEDURE(bank_set_flag) {
        serv.settings.banks.get_file(params[0]->getString())->set_flag(params[1]->getInt(), params[2]->getInt());
        serv.settings.signal_presetlist_changed()();
    }

    PROCEDURE(pf_append) {
        serv.settings.append(
            *serv.settings.banks.get_file(params[0]->getString()), params[1]->getString(),
            *serv.settings.banks.get_file(params[2]->getString()), params[3]->getString());
    }

    PROCEDURE(pf_insert_before) {
        serv.settings.insert_before(
            *serv.settings.banks.get_file(params[0]->getString()), params[1]->getString(),
            *serv.settings.banks.get_file(params[2]->getString()), params[3]->getString(),
            params[4]->getString());
    }

    PROCEDURE(pf_insert_after) {
        serv.settings.insert_after(
            *serv.settings.banks.get_file(params[0]->getString()), params[1]->getString(),
            *serv.settings.banks.get_file(params[2]->getString()), params[3]->getString(),
            params[4]->getString());
    }

    PROCEDURE(bank_save) {
        serv.settings.banks.save();
    }

    PROCEDURE(pf_save) {
        serv.settings.save(*serv.settings.banks.get_file(params[0]->getString()), params[1]->getString());
    }

    PROCEDURE(plugin_preset_list_sync_set) {
        gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
        send_notify_begin((*jw), "set");
        serv.settings.plugin_preset_list_sync_set(
            serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString())->get_pdef(),
            params[1]->getInt(), params[2]->getString());
    broadcast_data bd = {jw,CmdConnection::f_parameter_change_notify,0};
    serv.broadcast_list.push(bd);
    }

    PROCEDURE(plugin_preset_list_set) {
        gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
        send_notify_begin((*jw), "set");
        serv.settings.plugin_preset_list_set(
            serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString())->get_pdef(),
            params[1]->getInt(), params[2]->getString());
    broadcast_data bd = {jw,CmdConnection::f_parameter_change_notify,0};
    serv.broadcast_list.push(bd);
    }

    PROCEDURE(plugin_preset_list_save) {
        serv.settings.plugin_preset_list_save(
            serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString())->get_pdef(),
            params[1]->getString());
    }

    PROCEDURE(plugin_preset_list_remove) {
        serv.settings.plugin_preset_list_remove(
            serv.jack.get_engine().pluginlist.find_plugin(params[0]->getString())->get_pdef(),
            params[1]->getString());
    }

    PROCEDURE(midi_set_config_mode) {
        midi_config_mode = params[0]->getInt();
        serv.jack.get_engine().controller_map.set_config_mode(midi_config_mode, params[1]->getInt());
    }

    PROCEDURE(request_midi_value_update) {
        serv.jack.get_engine().controller_map.request_midi_value_update();
    }

    PROCEDURE(midi_deleteParameter) {
        serv.jack.get_engine().controller_map.deleteParameter(
            serv.settings.get_param()[params[0]->getString()]);
    }

    PROCEDURE(midi_set_current_control) {
        serv.jack.get_engine().controller_map.set_current_control(params[0]->getInt());
    }

    PROCEDURE(midi_modifyCurrent) {
        serv.jack.get_engine().controller_map.modifyCurrent(
            serv.settings.get_param()[params[0]->getString()], params[1]->getFloat(),
            params[2]->getFloat(), params[3]->getInt(), params[4]->getInt());
    }

    PROCEDURE(set_midi_channel) {
        serv.jack.get_engine().controller_map.set_midi_channel(params[0]->getInt());
    }

    PROCEDURE(set_last_midi_control_value) {
        serv.jack.get_engine().controller_map.set_last_midi_control_value(params[0]->getInt(),params[1]->getInt());
    }

    PROCEDURE(set_midi_feedback) {
        serv.settings.get_options().system_midiout = params[0]->getInt();
    }

    PROCEDURE(set) {
        if (params.size() & 1) {
            throw RpcError(-32602, "Invalid param -- array length must be even");
        }
        gx_engine::ParamMap& param = serv.settings.get_param();
        for (unsigned int i = 0; i < params.size(); i += 2) {
            const Glib::ustring& attr = params[i]->getString();
            if (param.hasId(attr)) {
                gx_engine::Parameter& p = param[attr];
                p.set_blocked(true);
                JsonValue *v = params[i+1];
                if (p.isFloat()) {
                    gx_engine::FloatParameter& pf = p.getFloat();
                    float f;
                    if (p.getControlType() == gx_engine::Parameter::Enum && dynamic_cast<JsonString*>(v)) {
                        f = pf.idx_from_id(v->getString());
                    } else {
                        f = v->getFloat();
                    }
                    pf.set(f);
                } else if (p.isInt()) {
                    gx_engine::IntParameter& pi = p.getInt();
                    int i;
                    if (p.getControlType() == gx_engine::Parameter::Enum && dynamic_cast<JsonString*>(v)) {
                        i = pi.idx_from_id(v->getString());
                    } else {
                        i = v->getInt();
                    }
                    pi.set(i);
                } else if (p.isBool()) {
                    p.getBool().set(v->getInt());
                } else if (p.isFile()) {
                    p.getFile().set(Gio::File::create_for_path(v->getString()));
                } else if (p.isString()) {
                    p.getString().set(v->getString());
                } else if (dynamic_cast<gx_engine::JConvParameter*>(&p) != 0) {
                    gx_engine::GxJConvSettings s;
                    gx_system::JsonSubParser jps = v->getSubParser();
                    s.readJSON(jps);
                    dynamic_cast<gx_engine::JConvParameter*>(&p)->set(s);
                } else if (dynamic_cast<gx_engine::SeqParameter*>(&p) != 0) {
                    gx_engine::GxSeqSettings s;
                    gx_system::JsonSubParser jps = v->getSubParser();
                    s.readJSON(jps);
                    dynamic_cast<gx_engine::SeqParameter*>(&p)->set(s);
                } else {
                    throw RpcError(-32602, "Invalid param -- unknown variable");
                }
                p.set_blocked(false);
            }
        }
        if (serv.broadcast_listeners(f_parameter_change_notify, this)) {
            gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
            send_notify_begin((*jw), "set");
            for (unsigned int i = 0; i < params.size(); i += 2) {
                jw->write(params[i]->getString());
                JsonValue *v = params[i+1];
                if (dynamic_cast<JsonFloat*>(v)) {
                    jw->write(v->getFloat());
                } else if (dynamic_cast<JsonInt*>(v)) {
                    jw->write(v->getInt());
                } else if (dynamic_cast<JsonString*>(v)) {
                    jw->write(v->getString());
                } else if (dynamic_cast<JsonObject*>(v)) {
                    v->getSubParser().copy_object((*jw));
                }
            }
        broadcast_data bd = {jw,CmdConnection::f_parameter_change_notify,this};
        serv.broadcast_list.push(bd);
        }
        serv.save_state();
    }

    PROCEDURE(get_updates) {
        gx_engine::ParamMap& param = serv.settings.get_param();
        gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
        send_notify_begin((*jw), "set");
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            gx_engine::Parameter& p = param[(*i)->getString()];
            jw->write(p.id());
            if (p.isMaxlevel()) {
                serv.update_maxlevel(p.id());
                float& f = maxlevel[p.id()];
                jw->write(f);
                f = 0;
            } else if (p.isFloat()) {
                jw->write(p.getFloat().get_value());
            } else {
                auto o = dynamic_cast<gx_engine::OscParameter*>(&p);
                assert(o);
                o->get_value().writeJSON((*jw));
            }
        }
    broadcast_data bd = {jw,CmdConnection::f_parameter_change_notify,0};
    serv.broadcast_list.push(bd);
    }

    PROCEDURE(setpreset) {
        gx_system::PresetFile* pf = serv.settings.banks.get_file(params[0]->getString());
        serv.settings.load_preset(pf, params[1]->getString());
        serv.save_state();
    }

    PROCEDURE(create_default_scratch_preset) {
        serv.settings.create_default_scratch_preset();
    }

    PROCEDURE(sendcc) {
        serv.jack.send_midi_cc(params[0]->getInt(),params[1]->getInt(),params[2]->getInt(),params[3]->getInt());
    }

    PROCEDURE(setstate) {
        serv.jack.get_engine().set_state(string_to_engine_state(params[0]->getString()));
        serv.jack.get_engine().check_module_lists();
    }

    PROCEDURE(switch_tuner) {
        serv.jack.get_engine().tuner.used_for_display(params[0]->getInt());
        serv.jack.get_engine().check_module_lists();
    }

    PROCEDURE(tuner_switcher_activate) {
        serv.tuner_switcher.activate(params[0]->getInt());
    }

    PROCEDURE(tuner_switcher_deactivate) {
        serv.tuner_switcher.deactivate();
    }

    PROCEDURE(tuner_switcher_toggle) {
        serv.tuner_switcher.toggle(params[0]->getInt());
    }

    PROCEDURE(reload_impresp_list) {
        gx_system::JsonStringWriter jw;
        std::string path = params[0]->getString();
        gx_system::IRFileListing l(path);
        send_notify_begin(jw, "impresp_list");
        jw.write(path);
        for (std::vector<gx_system::FileName>::iterator i = l.get_listing().begin(); i != l.get_listing().end(); ++i) {
            jw.begin_array();
            jw.write(i->filename);
            jw.write(i->displayname);
            jw.end_array();
        }
        send_notify_end(jw);
    }

    PROCEDURE(set_jack_insert) {
        serv.jack.set_jack_insert(params[0]->getInt());
    }

    PROCEDURE(save_ladspalist) {
        gx_system::JsonSubParser jps = params[0]->getSubParser();
        ladspa::LadspaPluginList pluginlist;
        pluginlist.readJSON(jps);
        pluginlist.save(serv.settings.get_options());
    }

    PROCEDURE(shutdown) {
        connection->close();
        serv.quit_mainloop();
    }

    PROCEDURE(listen) {
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            CmdConnection::listen((*i)->getString());
        }
    }

    PROCEDURE(unlisten) {
        for (JsonArray::iterator i = params.begin(); i != params.end(); ++i) {
            CmdConnection::unlisten((*i)->getString());
        }
    }

    PROCEDURE(save_current) {
        if (!serv.settings.setting_is_preset()) {
            throw RpcError(-32001, "no current preset");
        }
        save_preset(serv.settings, serv.settings.get_current_bank(), serv.settings.get_current_name());
    }

    PROCEDURE(save_preset) {
        save_preset(serv.settings, params[0]->getString(), params[1]->getString());
    }

    PROCEDURE(tuner_used_for_display) {
        serv.jack.get_engine().tuner.used_for_display(params[0]->getInt());
    }

    PROCEDURE(tuner_used_by_midi) {
        serv.jack.get_engine().tuner.used_by_midi(params[0]->getInt());
    }

    PROCEDURE(set_oscilloscope_mul_buffer) {
        serv.jack.get_engine().oscilloscope.set_mul_buffer(
            params[0]->getInt(), serv.jack.get_jack_bs());
    }

    PROCEDURE(insert_param) {
        gx_engine::ParamMap& param = serv.settings.get_param();
    const Glib::ustring& id = params[0]->getString();
    const Glib::ustring& tb = params[1]->getString();
    if (!param.hasId(id)) {
        gx_engine::BoolParameter& sp = param.reg_par(
          id, tb, (bool*)0, false, false)->getBool();
        sp.setSavable(false);
        }
    }

    END_FUNCTION_SWITCH(cerr << "Method not found: " << mn->name << endl; assert(false));
}

void CmdConnection::write_error(gx_system::JsonWriter& jw, int code, const char *message) {
    jw.write_key("error");
    jw.begin_object();
    jw.write_kv("code", code);
    jw.write_kv("message", message);
    jw.end_object();
}

bool CmdConnection::request(gx_system::JsonStringParser& jp, gx_system::JsonStringWriter& jw, bool batch_start) {
    Glib::ustring method;
    JsonArray params;
    Glib::ustring id;
    jp.next(gx_system::JsonParser::begin_object);
    while (jp.peek() != gx_system::JsonParser::end_object) {
        jp.next(gx_system::JsonParser::value_key);
        if (jp.current_value() == "jsonrpc") {
            jp.next(gx_system::JsonParser::value_string);
            if (jp.current_value() != "2.0") {
                throw RpcError(-32600,"Invalid Request");
            }
        } else if (jp.current_value() == "method") {
            jp.next(gx_system::JsonParser::value_string);
            method = jp.current_value();
        } else if (jp.current_value() == "params") {
            if (jp.peek() == gx_system::JsonParser::begin_array) {
                jp.next(gx_system::JsonParser::begin_array);
                while (jp.peek() != gx_system::JsonParser::end_array) {
                    params.append(jp);
                }
                jp.next(gx_system::JsonParser::end_array);
            } else if (jp.peek() == gx_system::JsonParser::begin_object) {
                throw RpcError(-32000,"by-name parameters not implemented");
            } else {
                throw RpcError(-32600,"Invalid Request");
            }
        } else if (jp.current_value() == "id") {
            if (jp.peek() != gx_system::JsonParser::value_string &&
                jp.peek() != gx_system::JsonParser::value_number) {
                throw RpcError(-32600,"Invalid Request");
            }
            jp.next();
            id = jp.current_value();
        } else {
            throw RpcError(-32600,"Invalid Request");
        }
    }
    jp.next(gx_system::JsonParser::end_object);
    const methodnames *p = Perfect_Hash::in_word_set(method.c_str(), method.size());
    if (!p) {
        throw RpcError(-32601, Glib::ustring::compose("Method not found -- '%1'", method));
    }
    try {
        if (id.empty()) {
            notify(jw, p, params);
            return false;
        } else {
            if (batch_start) {
                jw.begin_array();
            }
            jw.begin_object();
            jw.write_kv("jsonrpc", "2.0");
            jw.write_kv("id", id);
            jw.write_key("result");
            call(jw, p, params);
            jw.end_object();
            return true;
        }
    } catch(const RpcError& e) {
        throw RpcError(e.code, Glib::ustring(p->name) + ": " + e.message);
    }
}

void CmdConnection::error_response(gx_system::JsonWriter& jw, int code, const char *message) {
    jw.begin_object();
    jw.write_kv("jsonrpc", "2.0");
    jw.write_key("id");
    jw.write_null();
    write_error(jw, code, message);
    jw.end_object();
}

static bool sendbytes(int fd, const std::string& s, unsigned int *off) {
    unsigned int len = s.size() - *off;
    int n = write(fd, s.c_str() + *off, len);
    if (n <= 0) {
        return false;
    }
    len -= n;
    if (len > 0) {
        *off += n;
    } else {
        *off = 0;
    }
    return true;
}

bool CmdConnection::on_data_out(Glib::IOCondition cond) {
    int fd = connection->get_socket()->get_fd();
    while (outgoing.size() > 0) {
        if (!sendbytes(fd, outgoing.front(), &current_offset)) {
            return true;
        }
        if (current_offset == 0) {
            outgoing.pop_front();
        }
    }
    return false;
}

bool CmdConnection::on_data_in(Glib::IOCondition cond) {
    Glib::RefPtr<Gio::Socket> sock = connection->get_socket();
    char buf[1000];
    while (true) {
        int n;
        try {
            n = sock->receive(buf, sizeof(buf));
        } catch(Glib::Error& e) {
            if (e.code() == Gio::Error::WOULD_BLOCK) {
                return true;
            }
            serv.remove_connection(this);
            return false;
        }
        if (n <= 0) {
            serv.remove_connection(this);
            return false;
        }
        char *p = buf;
        while (n-- > 0) {
            jp.put(*p);
            if (*p == '\n') {
                process(jp);
                jp.reset();
            }
            p++;
        }
    }
}

void CmdConnection::send(gx_system::JsonStringWriter& jw) {
    std::string s = jw.get_string();
    if (outgoing.size() == 0) {
        assert(current_offset == 0);
        ssize_t len = s.size();
        ssize_t n = write(connection->get_socket()->get_fd(), s.c_str(), len);
        if (n == len) {
            return;
        }
        current_offset = max<ssize_t>(0, n);
    }
    outgoing.push_back(s);
    Glib::signal_io().connect(
        sigc::mem_fun(this, &CmdConnection::on_data_out),
        connection->get_socket()->get_fd(), Glib::IO_OUT);
}

void CmdConnection::process(gx_system::JsonStringParser& jp) {
    try {
        gx_system::JsonStringWriter jw;
        bool resp = false;
        // jp.peek() doesn't work at start of stream
        if (jp.peek_first_char() == '[') {
            jp.next(gx_system::JsonParser::begin_array);
            while (jp.peek() != gx_system::JsonParser::end_array) {
                resp = request(jp, jw, !resp) || resp;
            }
            if (resp) {
                jw.end_array();
            }
            jp.next(gx_system::JsonParser::end_array);
        } else {
            resp = request(jp, jw, false);
        }
        if (!resp) {
            return;
        }
        jw.finish();
        send(jw);
    } catch (gx_system::JsonException& e) {
        gx_print_error(
            "JSON-RPC", Glib::ustring::compose("error: %1, request: '%2'",
                                               e.what(), jp.get_string()));
        gx_system::JsonStringWriter jw;
        error_response(jw, -32700, "Parse Error");
        jw.finish();
        send(jw);
    } catch (RpcError& e) {
        gx_system::JsonStringWriter jw;
        error_response(jw, e.code, e.message);
        jw.finish();
        send(jw);
    }
}


/****************************************************************
 ** class UiBuilderVirt implementation
 */

gx_system::JsonWriter *UiBuilderVirt::jw = 0;
const gx_system::CmdlineOptions *UiBuilderVirt::options = 0;

UiBuilderVirt::UiBuilderVirt(gx_system::JsonWriter *jw_, const gx_system::CmdlineOptions *options_, PluginDef *pd)
    : UiBuilder() {
    plugin = pd;
    jw = jw_;
    options = options_;
    openTabBox = openTabBox_;
    openVerticalBox = openVerticalBox_;
    openVerticalBox1 = openVerticalBox1_;
    openVerticalBox2 = openVerticalBox2_;
    openHorizontalBox = openHorizontalBox_;
    openHorizontalhideBox = openHorizontalhideBox_;
    openHorizontalTableBox = openHorizontalTableBox_;
    openFrameBox = openFrameBox_;
    openFlipLabelBox = openFlipLabelBox_;
    openpaintampBox = openpaintampBox_;
    closeBox = closeBox_;
    load_glade = load_glade_;
    load_glade_file = load_glade_file_;
    create_master_slider = create_master_slider_;
    create_feedback_slider = create_feedback_slider_;
    create_big_rackknob = create_big_rackknob_;
    create_mid_rackknob = create_mid_rackknob_;
    create_small_rackknob = create_small_rackknob_;
    create_small_rackknobr = create_small_rackknobr_;
    create_simple_meter = create_simple_meter_;
    create_simple_c_meter = create_simple_c_meter_;
    create_spin_value = create_spin_value_;
    create_switch = create_switch_;
    create_wheel = create_wheel_;
    create_switch_no_caption = create_switch_no_caption_;
    create_feedback_switch = create_feedback_switch_;
    create_selector = create_selector_;
    create_selector_no_caption = create_selector_no_caption_;
    create_port_display = create_port_display_;
    create_p_display = create_p_display_;
    create_simple_spin_value = create_simple_spin_value_;
    create_eq_rackslider_no_caption = create_eq_rackslider_no_caption_;
    create_fload_switch = create_fload_switch_;
    insertSpacer = insertSpacer_;
    set_next_flags = set_next_flags_;
}

UiBuilderVirt::~UiBuilderVirt() {
}

void UiBuilderVirt::openTabBox_(const char* label) {
    jw->begin_array();
    jw->write("openTabBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openVerticalBox_(const char* label) {
    jw->begin_array();
    jw->write("openVerticalBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openVerticalBox1_(const char* label) {
    jw->begin_array();
    jw->write("openVerticalBox1");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openVerticalBox2_(const char* label) {
    jw->begin_array();
    jw->write("openVerticalBox2");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openHorizontalhideBox_(const char* label) {
    jw->begin_array();
    jw->write("openHorizontalhideBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openHorizontalTableBox_(const char* label) {
    jw->begin_array();
    jw->write("openHorizontalTableBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openFrameBox_(const char* label) {
    jw->begin_array();
    jw->write("openFrameBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openFlipLabelBox_(const char* label) {
    jw->begin_array();
    jw->write("openFlipLabelBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openpaintampBox_(const char* label) {
    jw->begin_array();
    jw->write("openpaintampBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::openHorizontalBox_(const char* label) {
    jw->begin_array();
    jw->write("openHorizontalBox");
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::insertSpacer_() {
    jw->begin_array();
    jw->write("insertSpacer");
    jw->end_array();
}

void UiBuilderVirt::set_next_flags_(int flags) {
    jw->begin_array();
    jw->write("set_next_flags");
    jw->write(flags);
    jw->end_array();
}

void UiBuilderVirt::create_big_rackknob_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_big_rackknob");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_mid_rackknob_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_mid_rackknob");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_small_rackknob_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_small_rackknob");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_small_rackknobr_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_small_rackknobr");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_feedback_slider_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_feedback_slider");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_master_slider_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_master_slider");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_selector_no_caption_(const char *id) {
    jw->begin_array();
    jw->write("create_selector_no_caption");
    jw->write(id);
    jw->end_array();
}

void UiBuilderVirt::create_selector_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_selector");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_simple_meter_(const char *id) {
    jw->begin_array();
    jw->write("create_simple_meter");
    jw->write(id);
    jw->end_array();
}
void UiBuilderVirt::create_simple_c_meter_(const char *id, const char *idl, const char *label) {
    jw->begin_array();
    jw->write("create_simple_c_meter");
    jw->write(id);
    jw->write(idl);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_spin_value_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_spin_value");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_switch_no_caption_(const char *sw_type, const char * id) {
    jw->begin_array();
    jw->write("create_switch_no_caption");
    jw->write(sw_type);
    jw->write(id);
    jw->end_array();
}

void UiBuilderVirt::create_feedback_switch_(const char *sw_type, const char * id) {
    jw->begin_array();
    jw->write("create_feedback_switch");
    jw->write(sw_type);
    jw->write(id);
    jw->end_array();
}

void UiBuilderVirt::create_fload_switch_(const char *sw_type, const char * id, const char * idf) {
    jw->begin_array();
    jw->write("create_fload_switch");
    jw->write(sw_type);
    jw->write(id);
    jw->write(idf);
    jw->end_array();
}

void UiBuilderVirt::create_switch_(const char *sw_type, const char * id, const char *label) {
    jw->begin_array();
    jw->write("create_switch");
    jw->write(sw_type);
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_wheel_(const char * id, const char *label) {
    jw->begin_array();
    jw->write("create_wheel");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_port_display_(const char *id, const char *label) {
    jw->begin_array();
    jw->write("create_port_display");
    jw->write(id);
    jw->write(label);
    jw->end_array();
}

void UiBuilderVirt::create_p_display_(const char *id, const char *idl, const char *idh) {
    jw->begin_array();
    jw->write("create_p_display");
    jw->write(id);
    jw->write(idl);
    jw->write(idh);
    jw->end_array();
}

void UiBuilderVirt::create_simple_spin_value_(const char *id) {
    jw->begin_array();
    jw->write("create_simple_spin_value");
    jw->write(id);
    jw->end_array();
}

void UiBuilderVirt::create_eq_rackslider_no_caption_(const char *id) {
    jw->begin_array();
    jw->write("create_eq_rackslider_no_caption");
    jw->write(id);
    jw->end_array();
}

void UiBuilderVirt::closeBox_() {
    jw->begin_array();
    jw->write("closeBox");
    jw->end_array();
}

void UiBuilderVirt::load_glade_(const char *data) {
    jw->begin_array();
    jw->write("load_glade");
    jw->write(data);
    jw->end_array();
}

void UiBuilderVirt::load_glade_file_(const char *fname) {
    std::string path = options->get_builder_filepath(fname);
    std::string data(
        std::istreambuf_iterator<char>(std::ifstream(path.c_str()).rdbuf()),
        std::istreambuf_iterator<char>());
    jw->begin_array();
    jw->write("load_glade");
    jw->write(data);
    jw->end_array();
}


/****************************************************************
 ** class GxService
 */

GxService::GxService(gx_preset::GxSettings& settings_, gx_jack::GxJack& jack_,
                     TunerSwitcher& tunerswitcher_, sigc::slot<void> quit_mainloop_,
                     const Glib::ustring& host, int *port)
    : Gio::SocketService(),
      settings(settings_),
      jack(jack_),
      tuner_switcher(tunerswitcher_),
      quit_mainloop(quit_mainloop_),
      oldest_unsaved(0),
      last_change(0),
      save_conn(),
      connection_list(),
      broadcast_list(),
      jwc(0),
      preg_map(0),
      maxlevel() {
    if (*port == 0) {
        *port = add_any_inet_port();
    } else {
        add_inet_port(*port);
    }
    if (host.compare(0, 3, "BT:") == 0) {
        create_bluetooth_sockets(host.substr(3));
    }
    settings.signal_selection_changed().connect(
        sigc::mem_fun(*this, &GxService::preset_changed));
    jack.get_engine().signal_state_change().connect(
        sigc::mem_fun(*this, &GxService::on_engine_state_change));
    jack.get_engine().tuner.signal_freq_changed().connect(
        sigc::mem_fun(this, &GxService::on_tuner_freq_changed));
    tuner_switcher.signal_display().connect(
        sigc::mem_fun(this, &GxService::display));
    tuner_switcher.signal_set_state().connect(
        sigc::mem_fun(this, &GxService::set_display_state));
    tuner_switcher.signal_selection_done().connect(
        sigc::mem_fun(this, &GxService::on_selection_done));
    settings.signal_presetlist_changed().connect(
        sigc::mem_fun(this, &GxService::on_presetlist_changed));
    GxLogger::get_logger().signal_message().connect(
        sigc::mem_fun(this, &GxService::on_log_message));
    GxLogger::get_logger().unplug_queue();
    jack.get_engine().controller_map.signal_changed().connect(
        sigc::mem_fun(this, &GxService::on_midi_changed));
    jack.get_engine().controller_map.signal_midi_value_changed().connect(
        sigc::mem_fun(this, &GxService::on_midi_value_changed));
    settings.signal_rack_unit_order_changed().connect(
        sigc::mem_fun(this, &GxService::on_rack_unit_changed));
    gx_engine::ParamMap& pmap = settings.get_param();
    pmap.signal_insert_remove().connect(
        sigc::mem_fun(this, &GxService::on_param_insert_remove));
    for (gx_engine::ParamMap::iterator i = pmap.begin(); i != pmap.end(); ++i) {
        if (i->second->isMaxlevel()) {
            maxlevel[i->first] = i->second->getFloat().get_value();
        } else {
            connect_value_changed_signal(i->second);
        }
    }
    Glib::signal_idle().connect(
            sigc::mem_fun(this, &GxService::idle_broadcast_handler));
}

GxService::~GxService() {
    gx_system::JsonStringWriter jws;
    jws.send_notify_begin("server_shutdown");
    broadcast(jws, CmdConnection::f_misc_msg);
    for (std::list<CmdConnection*>::iterator i = connection_list.begin(); i != connection_list.end(); ++i) {
        delete *i;
    }
    while (!broadcast_list.empty()) {
        broadcast_data bd = broadcast_list.front();
        gx_system::JsonStringWriter *jw = bd.jw;
        delete jw;
        broadcast_list.pop();
    }
}

#if HAVE_BLUEZ
static Glib::RefPtr<Gio::Socket> create_one_bluetooth_socket(
    const Glib::ustring& device, int channel) {
    sockaddr_rc loc_addr = { 0 };
    int s = socket(AF_BLUETOOTH, SOCK_STREAM, BTPROTO_RFCOMM);
    loc_addr.rc_family = AF_BLUETOOTH;
    // bind socket to the first available local bluetooth adapter
    bdaddr_t bdaddr = {{0, 0, 0, 0, 0, 0}}; //*BDADDR_ANY;
    loc_addr.rc_bdaddr = bdaddr;
    loc_addr.rc_channel = (uint8_t)channel;
    bind(s, (struct sockaddr *)&loc_addr, sizeof(loc_addr));
    listen(s, 1);
    return Gio::Socket::create_from_fd(s);
}

void GxService::create_bluetooth_sockets(const Glib::ustring& host) {
    int channels = 1;
    if (host.size() > 3) {
        channels = host[3] - '0';
        if (channels < 1) {
            channels = 1;
        } else if (channels > 9) {
            channels = 9;
        }
        }
    for (int i = 1; i <= channels; i++) {
        add_socket(create_one_bluetooth_socket(host, i));
    }
    gx_print_info(
        _("server"),
        Glib::ustring::compose(
            _("listening on bluetooth socket (%1 channel)"),
            channels));
}
#else // !HAVE_BLUEZ
void GxService::create_bluetooth_sockets(const Glib::ustring& host) {
    gx_print_fatal(
        _("server"),
        _("Bluetooth not available; rebuild Guitarix with Bluetooth support"));
}
#endif // HAVE_BLUEZ

void GxService::ladspaloader_write_changes(gx_system::JsonWriter& jw, std::vector<ChangedPlugin>& changed_plugins) {
    serialize_parameter_change(jw);
    // updated plugins
    jw.begin_array();
    for (std::vector<ChangedPlugin>::iterator i = changed_plugins.begin(); i != changed_plugins.end(); ++i) {
        jw.begin_array();
        jw.write(i->status);
        if (i->status == gx_engine::PluginChange::remove) {
            jw.write(i->id);
        } else {
            jack.get_engine().pluginlist.lookup_plugin(i->id)->writeJSON(jw);
        }
        jw.end_array();
    }
    jw.end_array();
}

//static
void GxService::add_changed_plugin(gx_engine::Plugin* pl, gx_engine::PluginChange::pc v, std::vector<ChangedPlugin>& vec) {
    if (pl) {
        vec.push_back(ChangedPlugin(pl->get_pdef()->id, v));
    }
}

void GxService::ladspaloader_update_plugins(gx_system::JsonWriter *jw, CmdConnection *cmd) {
    preg_map = new std::map<std::string,bool>;
    std::vector<ChangedPlugin> changed_plugins;
    sigc::connection conn = jack.get_engine().signal_plugin_changed().connect(
        sigc::bind(sigc::ptr_fun(add_changed_plugin), sigc::ref(changed_plugins)));
    gx_system::JsonStringWriter jwp; /* capture parameter changes and ignore them;
                                        they are already sent as part of changed parameter data */
    jwc = &jwp;
    jack.get_engine().ladspaloader_update_plugins();
    jwc = 0;
    conn.disconnect();
    if (jw) {
        jw->begin_array();
        ladspaloader_write_changes(*jw, changed_plugins);
        jw->end_array();
    }
    if (broadcast_listeners(CmdConnection::f_plugins_changed, cmd)) {
        gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
        jw->send_notify_begin("plugins_changed");
        ladspaloader_write_changes((*jw), changed_plugins);
    broadcast_data bd = {jw,CmdConnection::f_log_message,0};
    broadcast_list.push(bd);
    }
    delete preg_map;
    preg_map = 0;
}

void GxService::send_rack_changed(bool stereo, CmdConnection *cmd) {
    static bool rack_unit_change_blocked = false;
    if (rack_unit_change_blocked) {
        return;
    }
    if (cmd) {
        rack_unit_change_blocked = true;
        settings.signal_rack_unit_order_changed()(stereo);
        rack_unit_change_blocked = false;
    }
    if (!broadcast_listeners(CmdConnection::f_units_changed, cmd)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("rack_units_changed");
    std::vector<std::string>& ul = settings.get_rack_unit_order(stereo);
    jw->begin_array();
    jw->write(stereo);
    for (std::vector<std::string>::iterator i = ul.begin(); i != ul.end(); ++i) {
        jw->write(*i);
    }
    jw->end_array();
    broadcast_data bd = {jw,CmdConnection::f_log_message,0};
    broadcast_list.push(bd);
}

void GxService::on_rack_unit_changed(bool stereo) {
    send_rack_changed(stereo, 0);
}

void GxService::connect_value_changed_signal(gx_engine::Parameter *p) {
    if (p->isInt()) {
        p->getInt().signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    } else if (p->isBool()) {
        p->getBool().signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    } else if (p->isFloat()) {
        p->getFloat().signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    } else if (p->isString()) {
        p->getString().signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    } else if (dynamic_cast<gx_engine::JConvParameter*>(p) != 0) {
        dynamic_cast<gx_engine::JConvParameter*>(p)->signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    } else if (dynamic_cast<gx_engine::SeqParameter*>(p) != 0) {
        dynamic_cast<gx_engine::SeqParameter*>(p)->signal_changed().connect(
            sigc::hide(
                sigc::bind(
                    sigc::mem_fun(this, &GxService::on_param_value_changed), p)));
    }
}

void GxService::on_param_insert_remove(gx_engine::Parameter *p, bool inserted) {
    if (preg_map) {
        (*preg_map)[p->id()] = inserted;
    }
    if (inserted) {
        connect_value_changed_signal(p);
    }
}

void GxService::on_param_value_changed(gx_engine::Parameter *p) {
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    if (p->get_blocked()) {
        return;
    }
    jw->send_notify_begin("set");
    jw->write(p->id());
    if (p->isInt()) {
        jw->write(p->getInt().get_value());
    } else if (p->isBool()) {
        jw->write(p->getBool().get_value());
    } else if (p->isFloat()) {
        jw->write(p->getFloat().get_value());
    } else if (p->isString()) {
        jw->write(p->getString().get_value());
    } else if (dynamic_cast<gx_engine::JConvParameter*>(p) != 0) {
        dynamic_cast<gx_engine::JConvParameter*>(p)->get_value().writeJSON(*jw);
    } else if (dynamic_cast<gx_engine::SeqParameter*>(p) != 0) {
        dynamic_cast<gx_engine::SeqParameter*>(p)->get_value().writeJSON(*jw);
    } else {
        assert(false);
    }
    broadcast_data bd = {jw,CmdConnection::f_parameter_change_notify,0};
    broadcast_list.push(bd);
}

void GxService::on_midi_changed() {
    if (!broadcast_listeners(CmdConnection::f_midi_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("midi_changed");
    jack.get_engine().controller_map.writeJSON(*jw);
    broadcast_data bd = {jw,CmdConnection::f_midi_changed,0};
    broadcast_list.push(bd);
}

void GxService::on_midi_value_changed(int ctl, int value) {
    if (!broadcast_listeners(CmdConnection::f_midi_value_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("midi_value_changed");
    jw->begin_array();
    jw->write(ctl);
    jw->write(value);
    jw->end_array();
    broadcast_data bd = {jw,CmdConnection::f_midi_value_changed,0};
    broadcast_list.push(bd);
}

void GxService::on_log_message(const string& msg, GxLogger::MsgType tp, bool plugged) {
    if (plugged || !broadcast_listeners(CmdConnection::f_log_message)) {
        return;
    }
    const char *tpname;
    switch (tp) {
        case GxLogger::kInfo:    tpname = "info"; break;
        case GxLogger::kWarning: tpname = "warning"; break;
        case GxLogger::kError:   tpname = "error"; break;
        default: tpname = "unknown"; break;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("message");
    jw->write(tpname);
    jw->write(msg);
    broadcast_data bd = {jw,CmdConnection::f_log_message,0};
    broadcast_list.push(bd);
}

void GxService::on_selection_done(bool v) {
    if (!broadcast_listeners(CmdConnection::f_selection_done)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("show_tuner");
    jw->write(v);
    broadcast_data bd = {jw,CmdConnection::f_selection_done,0};
    broadcast_list.push(bd);
}

void GxService::on_presetlist_changed() {
    if (!broadcast_listeners(CmdConnection::f_presetlist_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("presetlist_changed");
    broadcast_data bd = {jw,CmdConnection::f_presetlist_changed,0};
    broadcast_list.push(bd);
}

void GxService::on_engine_state_change(gx_engine::GxEngineState state) {
    if (!broadcast_listeners(CmdConnection::f_state_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("state_changed");
    jw->write(engine_state_to_string(state));
    broadcast_data bd = {jw,CmdConnection::f_state_changed,0};
    broadcast_list.push(bd);
}

void GxService::preset_changed() {
    if (!broadcast_listeners(CmdConnection::f_preset_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("preset_changed");
    if (settings.setting_is_preset()) {
        jw->write(settings.get_current_bank());
        jw->write(settings.get_current_name());
    } else {
        jw->write("");
        jw->write("");
    }
    broadcast_data bd = {jw,CmdConnection::f_preset_changed,0};
    broadcast_list.push(bd);
}

void GxService::on_tuner_freq_changed() {
    if (!broadcast_listeners(CmdConnection::f_freq_changed)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("tuner_changed");
    jw->write(jack.get_engine().tuner.get_freq());
    jw->write(jack.get_engine().tuner.get_note());
    broadcast_data bd = {jw,CmdConnection::f_freq_changed,0};
    broadcast_list.push(bd);
}

void GxService::display(const Glib::ustring& bank, const Glib::ustring& preset) {
    if (!broadcast_listeners(CmdConnection::f_display)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("display_bank_preset");
    jw->write(bank);
    jw->write(preset);
    broadcast_data bd = {jw,CmdConnection::f_display,0};
    broadcast_list.push(bd);
}

void GxService::set_display_state(TunerSwitcher::SwitcherState state) {
    if (!broadcast_listeners(CmdConnection::f_display_state)) {
        return;
    }
    gx_system::JsonStringWriter *jw = new gx_system::JsonStringWriter;
    jw->send_notify_begin("set_display_state");
    switch (state) {
        case TunerSwitcher::normal_mode: jw->write("normal_mode"); break;
        case TunerSwitcher::wait_start: jw->write("wait_start"); break;
        case TunerSwitcher::listening: jw->write("listening"); break;
        case TunerSwitcher::wait_stop: jw->write("wait_stop"); break;
        default: assert(false); break;
    }
    broadcast_data bd = {jw,CmdConnection::f_display_state,0};
    broadcast_list.push(bd);
}

void GxService::remove_connection(CmdConnection *p) {
    for (std::list<CmdConnection*>::iterator i = connection_list.begin(); i != connection_list.end(); ++i) {
        if (*i == p) {
            connection_list.erase(i);
            delete p;
            return;
        }
    }
    assert(false);
}

//FIXME: this belongs into GxSettings
void GxService::save_state() {
    if (!settings.get_options().get_opt_autosave()) {
        return;
    }
    static const int min_idle = 10;  // seconds; after this idle time save state
    static const int max_delay = 30; // seconds; maximum age of unsaved data
    time_t now = time(NULL);
    if (oldest_unsaved == 0) {
        oldest_unsaved = last_change = now;
        save_conn = Glib::signal_timeout().connect_seconds(sigc::bind_return(sigc::mem_fun(this, &GxService::save_state),false), min_idle);
        return;
    }
    if (now - oldest_unsaved >= max_delay || now - last_change >= min_idle) {
        settings.save_to_state();
        sync();
        oldest_unsaved = 0;
        save_conn.disconnect();
    } else {
        last_change = now;
        if (oldest_unsaved == 0) {
            oldest_unsaved = now;
        }
        save_conn.disconnect();
        save_conn = Glib::signal_timeout().connect_seconds(sigc::bind_return(sigc::mem_fun(this, &GxService::save_state),false), min_idle);
    }
}

bool GxService::on_incoming(const Glib::RefPtr<Gio::SocketConnection>& connection,
                            const Glib::RefPtr<Glib::Object>& source_object) {
    CmdConnection *cc = new CmdConnection(*this, connection);
    connection_list.push_back(cc);
    Glib::RefPtr<Gio::Socket> sock = connection->get_socket();
    sock->set_blocking(false);
    int flag = 1;
    if (setsockopt(sock->get_fd(), IPPROTO_TCP, TCP_NODELAY, &flag, sizeof(int)))
        gx_print_error("GxMachineRemote","setsockopt(IPPROTO_TCP, TCP_NODELAY) failed");
    Glib::signal_io().connect(
        sigc::mem_fun(cc, &CmdConnection::on_data_in),
        sock->get_fd(), Glib::IO_IN);
    return true;
}

void GxService::serialize_parameter_change(gx_system::JsonWriter& jw) {
    jw.begin_array();
    for (std::map<std::string,bool>::iterator i = preg_map->begin(); i != preg_map->end(); ++i) {
        if (!i->second) {
            jw.write(i->first);
        }
    }
    jw.end_array();
    jw.begin_array();
    for (std::map<std::string,bool>::iterator i = preg_map->begin(); i != preg_map->end(); ++i) {
        if (i->second) {
            settings.get_param().writeJSON_one(jw, &settings.get_param()[i->first]);
        }
    }
    jw.end_array();
}

bool GxService::broadcast_listeners(CmdConnection::msg_type n, CmdConnection *sender) {
    for (std::list<CmdConnection*>::iterator p = connection_list.begin(); p != connection_list.end(); ++p) {
        if (*p != sender && (*p)->is_activated(n)) {
            return true;
        }
    }
    return false;
}

void GxService::broadcast(gx_system::JsonStringWriter& jw, CmdConnection::msg_type n, CmdConnection *sender) {
    jw.send_notify_end();
    jw.finish();
    for (std::list<CmdConnection*>::iterator p = connection_list.begin(); p != connection_list.end(); ++p) {
        if (*p != sender && (*p)->is_activated(n)) {
            (*p)->send(jw);
        }
    }
}

// collect all broadcast messages in a queue and send them one by one every 20ms
bool GxService::idle_broadcast_handler() {
    //for (unsigned int i = 0; i < broadcast_list.size(); ++i) {
    while (!broadcast_list.empty()) {
        broadcast_data bd = broadcast_list.front();
        gx_system::JsonStringWriter *jw = bd.jw;
        CmdConnection::msg_type n = bd.n;
        CmdConnection *sender = bd.sender;
        broadcast(*jw, n, sender);
        delete jw;
        broadcast_list.pop();
        usleep(2000);
    }
    usleep(2000);
    return true;
}

float GxService::update_maxlevel(const std::string& id, bool reset) {
    gx_engine::FloatParameter& p = settings.get_param()[id].getFloat();
    float v = p.get_value();
    p.set_zero();
    for (std::list<CmdConnection*>::iterator p = connection_list.begin(); p != connection_list.end(); ++p) {
        (*p)->update_maxlevel(id, v);
    }
    float& m = maxlevel[id];
    if (reset) {
        v = max(v, m);
        m = 0;
    } else {
        m = max(m, v);
    }
    return v;
}