bug/SKALE-3662 Adding libzmq

ZMQClient.cpp

@@ -40,32 +40,26 @@ shared_ptr <ZMQMessage> ZMQClient::doRequestReply(Json::Value &_req) {
     CHECK_STATE(reqStr.at(reqStr.size() - 1) == '}');
 
 
-
     auto resultStr = doZmqRequestReply(reqStr);
 
-
-
+    try {
 
     CHECK_STATE(resultStr.size() > 5)
     CHECK_STATE(resultStr.front() == '{')
     CHECK_STATE(resultStr.back() == '}')
 
 
-    cerr << resultStr;
-
-
-    try {
 
         return ZMQMessage::parse(resultStr.c_str(), resultStr.size(), false);
     } catch (std::exception & e) {
 
         cerr << "Error:" << e.what() << endl;
-
         sleep(10);
         throw;
     } catch (...) {
         cerr << "Error!" << endl;
         sleep(10);
+        throw;
     }
 
 }
@@ -78,7 +72,7 @@ string ZMQClient::doZmqRequestReply(string &_req) {
         reconnect();
     CHECK_STATE(clientSocket);
 
-    cerr << "ZMQ client sending:" << _req;
+    spdlog::info("ZMQ client sending: \n {}" , _req);
 
     s_send(*clientSocket, _req);
 
@@ -90,7 +84,13 @@ string ZMQClient::doZmqRequestReply(string &_req) {
         //  If we got a reply, process it
         if (items[0].revents & ZMQ_POLLIN) {
             string reply = s_recv(*clientSocket);
-            cerr << "ZMQ client received received reply:" <<  reply << endl;
+
+            CHECK_STATE(reply.size() > 5);
+            reply = reply.substr(0, reply.size() - 1);
+            spdlog::info("ZMQ client received reply:{}",  reply);
+            CHECK_STATE(reply.front() == '{');
+            CHECK_STATE(reply.back() == '}');
+
             return reply;
         } else {
             spdlog::error("W: no response from server, retrying...");

ZMQMessage.cpp

@@ -58,8 +58,6 @@ shared_ptr <ZMQMessage> ZMQMessage::parse(const char* _msg,
     CHECK_STATE(_msg[_size - 1] == '}');
     CHECK_STATE(_msg[0] == '{');
 
-    cerr << _msg << endl;
-
     auto d = make_shared<rapidjson::Document>();
 
     d->Parse(_msg);
@@ -98,7 +96,7 @@ shared_ptr <ZMQMessage> ZMQMessage::buildResponse(string& _type, shared_ptr<rapi
     if (_type == ZMQMessage::BLS_SIGN_RSP) {
         return
                 make_shared<BLSSignRspMessage>(_d);
-    } else if (_type == ZMQMessage::ECDSA_SIGN_REQ) {
+    } else if (_type == ZMQMessage::ECDSA_SIGN_RSP) {
         return
                 make_shared<ECDSASignRspMessage>(_d);
     } else {