bug/SKALE-3662 Adding libzmq

ZMQClient.cpp

@@ -67,9 +67,6 @@ string ZMQClient::doZmqRequestReply(string &_req) {
             string reply = s_recv(*clientSocket);
             cerr << "Received!" + reply;
 
-            sleep(1000);
-
-
             return reply;
         } else {
             spdlog::error("W: no response from server, retrying...");
@@ -111,6 +108,8 @@ string ZMQClient::blsSignMessageHash(const std::string &keyShareName, const std:
     p["t"] = t;
     auto result = dynamic_pointer_cast<BLSSignRspMessage>(doRequestReply(p));
     CHECK_STATE(result);
+    CHECK_STATE(result->getStatus() == 0);
+
     return result->getSigShare();
 }
 
@@ -122,5 +121,7 @@ string ZMQClient::ecdsaSignMessageHash(int base, const std::string &keyName, con
     p["messageHash"] = messageHash;
     auto result = dynamic_pointer_cast<ECDSASignRspMessage>(doRequestReply(p));
     CHECK_STATE(result);
+    CHECK_STATE(result->getStatus() == 0);
+    sleep(5);
     return result->getSignature();
 }
\ No newline at end of file

ZMQMessage.h

@@ -56,6 +56,10 @@ public:
 
     uint64_t getUint64Rapid(const char *_name);
 
+    uint64_t getStatus() {
+        getUint64Rapid("status");
+    }
+
     static shared_ptr<ZMQMessage> parse(vector<uint8_t> &_msg, bool _isRequest);
     static shared_ptr <ZMQMessage> parse(const char* _msg, size_t _size, bool _isRequest);
 

testw.cpp

@@ -1146,6 +1146,8 @@ TEST_CASE_METHOD(TestFixtureNoReset, "ZMQ-ecdsa", "[zmq-ecdsa-run]") {
         throw;
     }
 
+
+
     try {
         PRINT_SRC_LINE
         auto sig = client.ecdsaSignMessageHash(16, keyName, SAMPLE_HASH);