#include "utils.hpp"


// cloudutils
namespace cloudutils {
/// [deprecated] ref: ../config.json
json registry(json &conf, string sn, string module)
{
    json ret;
    string api;
    try {
        api = conf.at("data").at(sn).at("apiCloud").get<string>() + "/register";
        Uri uri=Uri::Parse(api);
        if(uri.Host.empty()||uri.Port.empty()||uri.Protocol.find("http") == string::npos||uri.Path.empty()) {
            string msg = "registry error. invalid apiCloud in config: " + api;
            ret["code"] = 1;
            ret["msg"] = msg;
            spdlog::error(msg);
            return ret;
        }

        Params params;
        params.emplace("sn", sn);
        params.emplace("module", module);
        Client cli(uri.Host.c_str(), stoi(uri.Port));

        auto res = cli.Post("/register", Headers(), params, conf.dump(),  "text/json");
        spdlog::debug("{} {} registry res from cloud : {}", __FILE__, __LINE__, res->body);
        ret = json::parse(res->body);
    }
    catch(exception &e) {
        ret["code"] = -1;
        string msg = string(__FILE__) + ":" + to_string(__LINE__) + string(": registry exception - ") + e.what();
        ret["msg"] = msg;
        spdlog::error(msg);
    }

    // /Client cli;
    return ret;
}

/// req config
json reqConfig(json &info)
{
    json ret;
    string api;
    try {
        api = info.at("apiCloud").get<string>();
        Uri uri=Uri::Parse(api);
        string sn = info.at("sn").get<string>();
        if(uri.Host.empty()||uri.Port.empty()||uri.Protocol.find("http") == string::npos) {
            string msg = string(__FILE__) +":" + to_string(__LINE__) + ": request cloud configuration error. invalid apiCloud in info: " + api;
            ret["code"] = EVCLOUD_REQ_E_PARAM;
            ret["msg"] = msg;
            spdlog::error(msg);
            return ret;
        }

        Params params;
        params.emplace("sn", sn);
        Client cli(uri.Host.c_str(), stoi(uri.Port));

        auto res = cli.Get("/config", Headers(), params);
        if(res == nullptr || res->status != 200) {
            const char *msg = NULL;
            if(res == nullptr) {
                msg = (string("error to connect to server: ") + api + "/config").c_str();
                ret["code"] = EVCLOUD_REQ_E_CONN;
            }
            else {
                msg = httplib::detail::status_message(res->status);
                ret["code"] = res->status;
            }
            spdlog::debug("failed to reqConfig. {}", msg);
            ret["msg"] = msg;
        }
        else {
            spdlog::debug("{} {} registry res from cloud : {}", __FILE__, __LINE__, res->body);
            ret = json::parse(res->body);
        }
    }
    catch(exception &e) {
        ret["code"] = EVCLOUD_REQ_E_DATA;
        string msg = string(__FILE__) + ":" + to_string(__LINE__) + string(": registry exception - ") + e.what();
        ret["msg"] = msg;
        spdlog::error(msg);
    }

    // /Client cli;
    return ret;
}

} // namespace cloudutils


///
namespace strutils {

vector<string> split(const std::string& s, char delimiter)
{
    std::vector<std::string> tokens;
    std::string token;
    std::istringstream tokenStream(s);
    while (getline(tokenStream, token, delimiter)) {
        tokens.push_back(token);
    }
    return tokens;
}

bool isIpStr(string ip)
{
    int cnt = 3*4 + 3;
    if(ip.size() == 0 || ip.size() > cnt) {
        return false;
    }
    auto v = strutils::split(ip, '.');
    if(v.size() == 0 || v.size () != 4) {
        return false;
    }

    return true;
}

}//namespace strutils

namespace cfgutils {
int getPeerId(string modName, json& modElem, string &peerId, string &peerName)
{
    try {
        if(modName == "evmgr") {
            peerId = modElem["sn"].get<string>() + ":evmgr:0";
            peerName = modName;
        }
        else if(modName == "evml") {
            peerId = modElem["sn"].get<string>() + ":evml" + modElem["type"].get<string>() + ":" + to_string(modElem["iid"]);
            peerName = modName + modElem["type"].get<string>();
        }
        else {
            peerId = modElem["sn"].get<string>() + ":" + modName + ":" + to_string(modElem["iid"]);
            peerName = modName;
        }
    }
    catch(exception &e) {
        spdlog::error("failed to get gid for {} in {}: {}", modName, modElem.dump(), e.what());
        return -1;
    }

    return 0;
}

/// ret["data"] is json map. key: mod gid; value: 0 - disabled, 1 - enabled
/// ret["code"], ["msg"] indicates error if not 0.
/// ipcIdx: -1 - all IPCS, otherwise - ipc specified by ipcIdx
json getModuleGidsFromCfg(string sn, json &data, string caller, int ipcIdx)
{
    json ret;
    ret["code"] = 0;
    ret["msg"] = "ok";
    ret["data"] = json();
    string msg = "[warnning] we gracefully handled below errors, please correct them:\n";
    try {
        // lock_guard<mutex> lock(cacheLock);
        string peerId;
        for(auto &[k,v]:data.items()) {
            if(v.size() == 0) {
                continue;
            }
            if(v.count("sn") == 0|| v["sn"].size() == 0 || v.count("ipcs") == 0 || v["ipcs"].size() == 0) {
                msg += fmt::format( "\t\tcluster {} has no sn/ipcs field {}:{}", v.dump(), __FILE__, __LINE__);
                spdlog::warn(msg);
                ret["msg"] = msg;
                continue;
            }
            
            if(ipcIdx == -1) {
                if(k == sn || sn.empty()) {
                    peerId = v["sn"].get<string>() + ":evmgr:0";
                    ret["data"][peerId] = 1;
                }
            }


            // startup other submodules
            json &ipcs = v["ipcs"];
            int idx = 0;
            for(auto &ipc : ipcs) {
                if(ipcIdx != -1 && idx != ipcIdx) {
                    continue;
                }

                if(ipc.count("modules") == 0|| ipc["modules"].size() == 0) {
                    msg += fmt::format( "\t\tipc {} has no modules field. {}:{}", __FILE__, __LINE__, ipc.dump());
                    spdlog::warn(msg);
                    ret["msg"] = msg;
                    continue;
                }
                json &modules = ipc["modules"];
                for(auto &[mn, ml] : modules.items()) {
                    for(auto &m : ml) {
                        if(m.count("sn") == 0 || m["sn"].size() == 0 || m.count("iid") == 0 || (mn=="evml" && (m.count("type") == 0 || m["type"].size() == 0))) {
                            msg += fmt::format( "\t\tmodule {} has no sn/iid/type(evml only) field. {}:{}", m.dump(), __FILE__, __LINE__);
                            spdlog::warn(msg);
                            ret["msg"] = msg;
                            continue;
                        }

                        if(m["sn"] != sn && !sn.empty()) {
                            continue;
                        }

                        string peerName;
                        int iret = cfgutils::getPeerId(mn, m, peerId, peerName);
                        
                        if(iret != 0) {
                            // TODO: do we need to treat it more strictly, to make it fails fast???
                            spdlog::error("{}:{} {} getModuleGidsFromCfg for {} invalid config found in module {} of {}",__FILE__, __LINE__, caller, sn, m.dump(), data.dump());
                            continue;
                        }
                        else {
                            if(m.count("enabled") == 0 || m["enabled"] == 0) {
                                // disabled
                                ret["data"][peerId] = 0;
                            }else{
                                ret["data"][peerId] = 1;
                            }
                        }
                    }
                }

                if(ipcIdx != - 1) {
                    break;
                }

                idx++;
            }
        }
    }
    catch(exception &e) {
        string msg = fmt::format("{}:{} {} getModuleGidsFromCfg  exception {} in config {}",__FILE__, __LINE__, caller, sn, e.what(), data.dump());
        spdlog::error(msg);
        ret["msg"] = msg;
        ret["code"] = -1;
    }

    return ret;
}

json *findModuleConfig(string peerId, json &data)
{
    json *ret = NULL;
    auto pp = strutils::split(peerId, ':');
    if(pp.size() != 3) {
        spdlog::error("invalid peerId: {}", peerId);
        return ret;
    }

    string sn = pp[0];
    string modName = pp[1];
    string iid = pp[2];
    //
    string subMn = modName.substr(0,4);
    if(subMn == "evml") {
        subMn = modName.substr(4, modName.size());
    }
    else {
        subMn = "";
    }

    try {
        for(auto &[k,v]: data.items()) {
            // it's evmgr
            if(modName == "evmgr") {
                if(k == sn) {
                    ret = &v;
                    break;
                }
            }
            else {
                json &ipcs = v["ipcs"];

                for(auto &ipc: ipcs) {
                    json &modules = ipc["modules"];
                    // not evml
                    if(subMn.empty()) {
                        if(modules.count(modName) != 0) {
                            json &ml = modules[modName];
                            for(auto &m : ml) {
                                if(m["sn"] == sn && to_string(m["iid"]) == iid && m["enabled"] != 0) {
                                    ret = &v;
                                    break;
                                }
                            }
                        }
                    }
                    else {
                        if(modules.count("evml") != 0) {
                            json &ml = modules["evml"];
                            for(auto &m: ml) {
                                if(subMn == m["type"] && to_string(m[iid]) == iid && m["sn"] == sn && m["enabled"] != 0) {
                                    ret = &v;
                                    break;
                                }
                            }
                        }
                    }

                    if(ret != NULL) break;
                }
            }
        }
    }
    catch(exception &e) {
        spdlog::error("find module {} in {} exception: {}", peerId, data.dump(), e.what());
        return NULL;
    }

    return ret;
}

/// return json key: gid; value: 0 - disabled, 1 - removed, 2 - start, 3 - restart
json getModulesOperFromConfDiff(json& oldConfig, json &newConfig, json &diff, string sn) {
    /// key: gid; value: 0 - stop, 1 - start, 3 - restart
    json ret;
    ret["code"] = 0;
    ret["msg"] = "ok";
    ret["data"] = json();
    bool hasError = false;
    spdlog::info("{}:{}: matching {}, size:{}, type:{}", __FILE__, __LINE__, diff.dump(), diff.size(), diff.type_name());
    try{
        for(auto &d: diff) {
            spdlog::info("{}:{}: path: {}", __FILE__, __LINE__, d.dump());
            if(d.count("path") != 0) {
                string path_ = d["path"];
                bool matched = false;
                // match ipc config
                // eg: /NMXH73Y2/ipcs/0/addr
                // \\w+ could be: addr, user, password, port
                set<string> oprations{"add", "replace", "remove"};
                set<string> pullerTag{"addr", "user", "password", "proto", "port" /*, "sn"*/};

                // whole ipc
                if(!matched && !hasError) {
                    // /PSBV7GKN/ipcs/0"
                    // {"addr":"172.31.0.129","modules":{"evml":[{"area":200,"enabled":1,"entropy":0.3,"iid":1,"post":30,"pre":3,"sn":"PSBV7GKN","thresh":30,"type":"motion"}],"evpuller":[{"addr":"127.0.0.1","enabled":1,"iid":1,"portPub":5556,"sn":"PSBV7GKN"}],"evpusher":[{"enabled":0,"iid":1,"password":"","sn":"PSBV7GKN","token":"","urlDest":"rtsp://40.73.41.176/PSBV7GKN","user":""}],"evslicer":[{"enabled":1,"iid":1,"path":"slices","sn":"PSBV7GKN","videoServerAddr":"http://40.73.41.176:10009/upload/evtvideos/"}]},"password":"iLabService","port":554,"proto":"rtsp","sn":"iLabService","user":"admin"}
                    string  clusterRegStr = "/(\\w+)/ipcs/(\\d+)(?:/[^/]+)?";
                    std::regex clusterRegex(clusterRegStr);
                    std::smatch results;
                    if (std::regex_match(path_, results, clusterRegex)) {
                        if (results.size() == 3) {
                            spdlog::info("{}:{}: path matched ipc or ipc prop: {}",__FILE__, __LINE__, path_);
                            matched = true;
                            string mgrSn = results[1].str();
                            int ipcIdx = stoi(results[2].str());
                            json oldIpc, newIpc;
                            json oldMgr, newMgr;
                           
                            if(oldConfig[mgrSn]["ipcs"].size() >= ipcIdx+1){
                                oldIpc = oldConfig[mgrSn]["ipcs"][ipcIdx];
                                oldMgr[mgrSn] = json();
                                oldMgr[mgrSn]["ipcs"] = json();
                                oldMgr[mgrSn]["ipcs"].push_back(oldIpc);
                            }

                            if(newConfig[mgrSn]["ipcs"].size() >= ipcIdx+1){
                                newIpc = newConfig[mgrSn]["ipcs"][ipcIdx];
                                newMgr[mgrSn] = json();
                                newMgr[mgrSn]["ipcs"] = json();
                                newMgr[mgrSn]["ipcs"].push_back(newIpc);
                            }

                            if(newIpc.size() != 0 && newIpc.count("modules") != 0 && newIpc.count("addr") != 0) {
                                for(auto &[mn, v]: newIpc["modules"].items()) {
                                    string modName = mn;
                                    json &mods = v;
                                    int modIdx = 0;
                                    for(auto &modObj:mods) {
                                        string modSn = sn.empty()? modObj["sn"].get<string>(): sn;
                                        if(modObj["sn"].get<string>() == modSn){
                                            if(modName == "evml") {
                                                if(modObj.count("type") == 0) {
                                                    string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no type field", ipcIdx, modName, modIdx);
                                                    spdlog::error(msg);
                                                    hasError = true;
                                                    break;
                                                }else{
                                                    modName = modName + modObj["type"].get<string>();
                                                }
                                            }

                                            if(modObj.count("iid") == 0) {
                                                string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no iid field", ipcIdx, modName, modIdx);
                                                spdlog::error(msg);
                                                hasError = true;
                                                break;
                                            }

                                            string modGid = modSn + ":" + modName + ":" + to_string(modObj["iid"].get<int>());
                                            if(modObj.count("enabled") == 0 ||modObj["enabled"] == 0 ) {
                                                ret["data"][modGid] = 0; // disabled
                                            }else{
                                                ret["data"][modGid] = 2; // start
                                            } 
                                        }
                                        modIdx++;
                                    }
                                }      
                            }

                            if(oldIpc.size() != 0 && oldIpc.count("modules") != 0 && oldIpc.count("addr") != 0) {
                                for(auto &[mn,v]: oldIpc["modules"].items()) {
                                    string modName = mn;
                                    json &mods = v;
                                    int modIdx = 0;
                                    for(auto &modObj:mods) {
                                        string modSn = sn.empty()? modObj["sn"].get<string>(): sn;
                                        if(modObj["sn"].get<string>() == modSn){
                                            if(modName == "evml") {
                                                if(modObj.count("type") == 0) {
                                                    string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no type field", ipcIdx, modName, modIdx);
                                                    spdlog::error(msg);
                                                    hasError = true;
                                                    break;
                                                }else{
                                                    modName = modName + modObj["type"].get<string>();
                                                }
                                            }

                                            if(modObj.count("iid") == 0) {
                                                string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no iid field", ipcIdx, modName, modIdx);
                                                spdlog::error(msg);
                                                hasError = true;
                                                break;
                                            }

                                            string modGid = modSn + ":" + modName + ":" + to_string(modObj["iid"].get<int>());
                                            if(ret["data"].count(modGid) != 0 && ret["data"][modGid] == 2) {
                                                ret["data"][modGid] = 3; // restart
                                            }else{
                                                ret["data"][modGid] = 1; // perm stop
                                            } 
                                        }
                                        modIdx++;
                                    }
                                }      
                            }
                        }
                    }
                }

                // match module prop config
                if(!matched && !hasError) {
                    // /PSBV7GKN/ipcs/0/modules/evslicer/0/videoServerAddr
                    // /NMXH73Y2/ipcs/0/modules/evpusher/0/urlDest
                    string  moduleRegStr = "/(\\w+)/ipcs/(\\d+)/modules/(\\w+)/(\\d+)/([^/]+)";
                    std::regex moduleRegex(moduleRegStr);
                    std::smatch results;
                    if (std::regex_match(path_, results, moduleRegex)) {
                        if (results.size() == 6) {
                            matched = true;
                            spdlog::info("{}:{}: path matched module prop: {}", __FILE__, __LINE__, path_);
                            string mgrSn = results[1].str();
                            int ipcIdx = stoi(results[2].str());
                            int modIdx = stoi(results[4].str());
                            string modName = results[3].str();
                            string propName = results[5].str();
                            if(true){        //d["op"] == "replace"||d["op"] == "add" || d["op"] == "remove") {   
                                auto &oldMod = oldConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName][modIdx];
                                auto &newMod = newConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName][modIdx];
                                if(oldMod.count("iid") == 0 || newMod.count("iid") == 0) {
                                    string msg = fmt::format("invalid module config ipcs[{}]['modules'][{}][{}] having no iid field", ipcIdx, modName, modIdx);
                                    spdlog::error(msg);
                                    ret["msg"] = msg;
                                    hasError = true;
                                    break;
                                }else{
                                    if(modName == "evml") {
                                        if(newMod.count("type") == 0) {
                                            string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no type field", ipcIdx, modName, modIdx);
                                            spdlog::error(msg);
                                            hasError = true;
                                            break;
                                        }else{
                                            modName = modName + newMod["type"].get<string>();
                                        }
                                    }

                                    if(newMod.count("sn") == 0||oldMod.count("sn") == 0) {
                                        string msg = fmt::format("invalid module config ipcs[{}]['modules'][{}][{}] having no sn field", ipcIdx, modName, modIdx);
                                        spdlog::error(msg);
                                        hasError = true;
                                        break;
                                    }

                                    string oldSn = oldMod["sn"];
                                    string newSn = newMod["sn"];

                                    string oldGid = oldSn + ":" + modName + ":" + to_string(oldMod["iid"].get<int>());
                                    string newGid = newSn + ":" + modName + ":" + to_string(newMod["iid"].get<int>());

                                    if(oldGid != newGid) {
                                        ret["data"][oldGid] = 1; // perm stop
                                    }

                                    if(!sn.empty() && sn != newSn) {
                                        continue;
                                    }

                                    if(propName == "enabled") {
                                        if(newMod.count("enabled") == 0||newMod["enabled"].get<int>() == 0) {
                                            ret["data"][newGid] = 0; // disable
                                        }else{
                                            ret["data"][newGid] = 2; // start
                                        }
                                    }else{ // other prop modification  
                                        if(ret["data"].count(newGid) == 0 ||(ret["data"][newGid] != 0 && ret["data"][newGid] != 1)) {
                                            if(oldGid != newGid) {
                                                ret["data"][newGid] = 2; // start
                                            }else{
                                                ret["data"][newGid] = 3; // restart
                                            }
                                        }else{
                                            // no op
                                        }
                                    }
                                }
                            }
                        }
                    }
                }

                // whole submodule
                if(!matched && !hasError) {
                    // /PSBV7GKN/ipcs/0/modules/evpusher/0
                    // {"enabled":0,"iid":1,"password":"","sn":"PSBV7GKN","token":"","urlDest":"rtsp://40.73.41.176/PSBV7GKN","user":""}
                    string  moduleRegStr = "/(\\w+)/ipcs/(\\d+)/modules/(\\w+)/(\\d+)";
                    std::regex moduleRegex(moduleRegStr);
                    std::smatch results;
                    if (std::regex_match(path_, results, moduleRegex)) {
                        if (results.size() == 5) {
                            matched = true;
                            spdlog::info("{}:{}: path matched whole module: {}", __FILE__, __LINE__, path_);
                            string mgrSn = results[1].str();
                            int ipcIdx = stoi(results[2].str());
                            int modIdx = stoi(results[4].str());
                            string modName = results[3].str();
                            json oldModObj, newModObj;

                            if(oldConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName].size() >= modIdx +1) {
                                oldModObj = oldConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName][modIdx];
                            }

                            if(newConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName].size() >= modIdx +1){
                                newModObj = newConfig[mgrSn]["ipcs"][ipcIdx]["modules"][modName][modIdx];
                            }
                            
                            if(newModObj.size() != 0) {
                                string modSn = sn.empty()? newModObj["sn"].get<string>(): sn;
                                if(newModObj["sn"].get<string>() == modSn){
                                    if(modName == "evml") {
                                        if(newModObj.count("type") == 0) {
                                            string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no type field", ipcIdx, modName, modIdx);
                                            spdlog::error(msg);
                                            hasError = true;
                                            break;
                                        }else{
                                            modName = modName + newModObj["type"].get<string>();
                                        }
                                    }

                                    if(newModObj.count("iid") == 0) {
                                        string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no iid field", ipcIdx, modName, modIdx);
                                        spdlog::error(msg);
                                        hasError = true;
                                        break;
                                    }

                                    string modGid = modSn + ":" + modName + ":" + to_string(newModObj["iid"].get<int>());
                                    if(newModObj.count("enabled") == 0 ||newModObj["enabled"] == 0 ) {
                                        ret["data"][modGid] = 0; // disabled
                                    }else{
                                        ret["data"][modGid] = 2; // start
                                    } 
                                }
                            }

                            if(oldModObj.size() != 0) {
                                spdlog::info("old mod: {}", oldModObj.dump());
                                string modSn = sn.empty()? oldModObj["sn"].get<string>(): sn;
                                if(oldModObj["sn"].get<string>() == modSn){
                                    if(modName == "evml") {
                                        if(oldModObj.count("type") == 0) {
                                            string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no type field", ipcIdx, modName, modIdx);
                                            spdlog::error(msg);
                                            hasError = false; // TODO
                                            continue;
                                        }else{
                                            modName = modName + oldModObj["type"].get<string>();
                                        }
                                    }

                                    if(oldModObj.count("iid") == 0) {
                                        string msg = fmt::format("invalid evml module config ipcs[{}]['modules'][{}][{}] having no iid field", ipcIdx, modName, modIdx);
                                        spdlog::error(msg);
                                        hasError = false;
                                        continue;
                                    }

                                    string modGid = modSn + ":" + modName + ":" + to_string(oldModObj["iid"].get<int>());
                                    if(ret["data"].count(modGid) != 0 && ret["data"][modGid] == 2 ) {
                                        ret["data"][modGid] = 3; // restart
                                    }else{
                                        ret["data"][modGid] = 1; // perm stop
                                    }                     
                                }
                            }
                        }
                    }
                }

                // whole cluster
                if(!matched && !hasError) {
                    // /PSBV7GKN
                    // "value":{"addr":"127.0.0.1","apiCloud":"http://127.0.0.1:8089","ipcs":[{"addr":"172.31.0.129","modules":{"evml":[{"area":200,"enabled":1,"entropy":0.3,"iid":1,"post":30,"pre":3,"sn":"PSBV7GKN","thresh":30,"type":"motion"}],"evpuller":[{"addr":"127.0.0.1","enabled":1,"iid":1,"portPub":5556,"sn":"PSBV7GKN"}],"evpusher":[{"enabled":0,"iid":1,"password":"","sn":"PSBV7GKN","token":"","urlDest":"rtsp://40.73.41.176/PSBV7GKN","user":""}],"evslicer":[{"enabled":1,"iid":1,"path":"slices","sn":"PSBV7GKN","videoServerAddr":"http://40.73.41.176:10009/upload/evtvideos/"}]},"password":"iLabService","port":554,"proto":"rtsp","sn":"iLabService","user":"admin"}],"mqttCloud":"<cloud_addr>","portCloud":5556,"portRouter":5550,"proto":"zmq","sn":"PSBV7GKN"}
                    string  clusterRegStr = "/(\\w+)";
                    std::regex clusterRegex(clusterRegStr);
                    std::smatch results;
                    if (std::regex_match(path_, results, clusterRegex)) {
                        if (results.size() == 2) {
                            matched = true;
                            spdlog::info("{}:{}: path matched whole cluster: {}",__FILE__, __LINE__, path_);
                            string mgrSn = results[1].str();
                            json oldMgr, newMgr;

                            if(oldConfig.count(mgrSn) != 0) {
                                oldMgr[mgrSn] = json();
                                oldMgr[mgrSn] = oldConfig[mgrSn];
                            }

                            if(newConfig.count(mgrSn) != 0) {
                                newMgr[mgrSn] = json();
                                newMgr[mgrSn] = newConfig[mgrSn];
                            }
                            
                            if(newMgr.size() != 0) {
                                json jret = cfgutils::getModuleGidsFromCfg(sn, newMgr, "");
                                spdlog::info("{}:{} getModuleGidsFromCfg dump: {}", __FILE__, __LINE__, jret.dump());
                                if(jret["code"] != 0) {
                                    ret["msg"] = jret["msg"];
                                    hasError = false; // TODO:
                                    continue;
                                }else{
                                    if(jret["msg"] != "ok") {
                                        ret["msg"] = jret["msg"];
                                    }
                                    for(auto &[k,v]: jret["data"].items()) {
                                        if(ret["data"].count(string(k)) == 0||(ret["data"][string(k)] != 0 && ret["data"][string(k)] !=1)){
                                            ret["data"][string(k)] = int(v) == 0? int(v): int(v)+1;
                                        }
                                    }
                                }
                            }

                            if(oldMgr.size() != 0) {
                                json jret = cfgutils::getModuleGidsFromCfg(sn, oldMgr, "");
                                spdlog::info("{}:{} getModuleGidsFromCfg dump: {}", __FILE__, __LINE__, jret.dump());
                                if(jret["code"] != 0) {
                                    ret["msg"] = jret["msg"];
                                    hasError = false; // TODO:
                                    continue;
                                }else{
                                    if(jret["msg"] != "ok") {
                                        ret["msg"] = jret["msg"];
                                    }
                                    for(auto &[k, v]: jret["data"].items()) {
                                        if(ret["data"].count(string(k)) == 0){
                                            ret["data"][string(k)] = 1;
                                        }else{
                                            if(ret["data"][string(k)] == 2) { // change start to restart
                                                ret["data"][string(k)] = 3;
                                            }                                         
                                        }
                                    }
                                }
                            }
                        }
                    }
                } 
            }
        }
        if(hasError){
            ret["code"] = 1;
        }   
    }catch(exception &e) {
        string msg = fmt::format("{}:{}: exception: {}", __FILE__, __LINE__, e.what());
        ret["code"] = -1;
        ret["msg"] = msg;
        spdlog::error("{}:{}: exception: {}", __FILE__, __LINE__, msg);
    }

    return ret;
}
} // cfgutils