nop

opencv-motion-detect/evcloudsvc.cpp

@@ -31,6 +31,12 @@ using namespace zmqhelper;
 #define KEY_RELEASE_BUNDLE "release_bundle"
 
 #define NUM_MAX_REPORT_HISTORY 5
+// + evcloudsvc
+const string mqtt_topic_response = "evsuits/response/";
+const string mqtt_topic_report = "evsuits/report/";
+const string mqtt_topic_subscribe = "evsuits/request/";
+const string mqtt_topic_lastwill = "evsuits/lastwill/";
+const char kcArrMqttUrl[] = "tcp://admin:vJ3zHqWrHbrqxVMT@evcloudsvc.ilabservice.cloud:11883";
 
 class EvCloudSvc {
 private:
@@ -54,6 +60,7 @@ private:
     recursive_mutex mutIpcStatus;
     json allIssues;
 
+    MqttHelper *mqClient = nullptr;
 
     json buildIssuesForIpc(string ipcSn, json &v)
     {
@@ -1800,6 +1807,19 @@ public:
         this->peerData["mgr2ipc"] = json();
         this->peerData["modulecls"] = json();
 
+        // setup mqtt
+        char *pEnv = getenv("MQTT_URL");
+        if(!pEnv){
+            pEnv = (char*)kcArrMqttUrl;
+        }
+        string mqttUrl = string(pEnv);
+        string mqId= "evcloudsvc";
+        mqClient = MqttMgr::get_instance(mqttUrl, mqId, mqtt_topic_lastwill + mqId, mqtt_topic_report + mqId);
+        if(mqClient == nullptr){
+            spdlog::error("failed to connect to mqtt: {}", mqttUrl);
+            exit(1);
+        }
+
         spdlog::info("evcloudsvc boot");
         loadConfigMap();
         char *strEnv = getenv("HTTP_PORT");

opencv-motion-detect/mqtt_helper.hpp

@@ -28,6 +28,7 @@ using namespace std;
 using namespace nlohmann;
 
 #define EV_MAX_PRINTABLE_SIZE 512
+const string kIdPrefix = "EVB-";
 
 extern void on_connected(void* context, MQTTAsync_successData* response);
 extern void on_connlost(void *context, char *cause);
@@ -148,7 +149,7 @@ public:
 
         spdlog::debug("mqtt url: proto: {}, host: {}, port: {}, user: {}, pass: {}", uri.Protocol, uri.Host, uri.Port, uri.User, uri.Password);
 
-        if(MQTTASYNC_SUCCESS != MQTTAsync_create(&client, addr.c_str(), ("EVC"+id).c_str(), MQTTCLIENT_PERSISTENCE_NONE, NULL)) {
+        if(MQTTASYNC_SUCCESS != MQTTAsync_create(&client, addr.c_str(), (kIdPrefix+id).c_str(), MQTTCLIENT_PERSISTENCE_NONE, NULL)) {
             msg = "failed to async create mqtt";
             spdlog::error(msg);
             throw StrException(msg);