big refacting of communitation architect

opencv-motion-detect/evdaemon.cpp

@@ -83,9 +83,7 @@ class EvDaemon{
                     if( (pid = fork()) == -1 ) {
                         spdlog::error("evdamon {} failed to fork subsytem - evmgr", this->devSn);
                     }else if(pid == 0) {
-                        // child
-                        // execl("./evmgr", "arg1", "arg2", (char *)0);
-                        ret += setenv("SN", v["sn"].get<string>().c_str(), 1);
+                        ret += setenv("GID", peerId.c_str(), 1);
                         ret += setenv("DR_PORT", to_string(portRouter).c_str(), 1);
                         if(ret < 0) {
                             spdlog::error("evdaemon {} failed to set env", this->devSn);
@@ -97,7 +95,7 @@ class EvDaemon{
                     }else{
                         // parent
                         spdlog::info("evdaemon {} created evmgr", this->devSn);
-                    }
+                    }                    
                 }
 
                 // startup other submodules
@@ -106,7 +104,14 @@ class EvDaemon{
                 for(auto &ipc : ipcs) {
                     json &modules = ipc["modules"];
                     for(auto &[mn, ml] : modules.items()) {
-                        //
+                        for(auto &m : ml) {
+                            if(m["sn"] != this->devSn) {
+                                continue;
+                            }
+                            if(m["enabled"].get<int>() != 0) {
+
+                            }
+                        }
                     }
                 }
             }

opencv-motion-detect/evmgr.cpp

@@ -40,7 +40,7 @@ private:
     void *pRouter = NULL;
     void *pCtxDealer = NULL, *pDealer = NULL;
     json config;
-    string devSn;
+    string devSn, ident;
     json peerStatus;
     unordered_map<string, queue<vector<vector<uint8_t> >> > cachedMsg;
     mutex cacheLock;
@@ -286,10 +286,16 @@ public:
             exit(1);
         }
 
-        strEnv = getenv("SN");
+        strEnv = getenv("GID");
         if(strEnv != NULL) {
-            config["sn"] = strEnv;
-            devSn = strEnv;
+            ident = strEnv;
+            auto v = cloudutils::split(ident, ':');
+            if(v.size() != 3||v[1] != "evmgr" || v[2] != "0") {
+                spdlog::error("evmgr received invalid gid: {}", ident);
+                exit(1);
+            }
+            config["sn"] = v[0];
+            devSn = v[0];
         }else{
             spdlog::error("evmgr failed to start. no SN set");
             exit(1);
@@ -297,7 +303,7 @@ public:
 
         //
         string addr = string("tcp://127.0.0.1:") + to_string(config["dr-port"]);
-        string ident = config["sn"].get<string>() + ":evmgr:0";
+        ident = config["sn"].get<string>() + ":evmgr:0";
         int ret = zmqhelper::setupDealer(&pCtxDealer, &pDealer, addr, ident);
         
         bool bConfigGot = false;