Implement "quorum memberof" (#3004)

* Implement BuildQuorumInfo and call it from quorum_info

* Add type to result of BuildQuorumInfo

* Implement "quorum memberof"

src/rpc/rpcquorums.cpp

@@ -76,6 +76,41 @@ void quorum_info_help()
     );
 }
 
+UniValue BuildQuorumInfo(const llmq::CQuorumCPtr& quorum, bool includeMembers, bool includeSkShare)
+{
+    UniValue ret(UniValue::VOBJ);
+
+    ret.push_back(Pair("height", quorum->height));
+    ret.push_back(Pair("type", quorum->params.name));
+    ret.push_back(Pair("quorumHash", quorum->qc.quorumHash.ToString()));
+    ret.push_back(Pair("minedBlock", quorum->minedBlockHash.ToString()));
+
+    if (includeMembers) {
+        UniValue membersArr(UniValue::VARR);
+        for (size_t i = 0; i < quorum->members.size(); i++) {
+            auto& dmn = quorum->members[i];
+            UniValue mo(UniValue::VOBJ);
+            mo.push_back(Pair("proTxHash", dmn->proTxHash.ToString()));
+            mo.push_back(Pair("valid", quorum->qc.validMembers[i]));
+            if (quorum->qc.validMembers[i]) {
+                CBLSPublicKey pubKey = quorum->GetPubKeyShare(i);
+                if (pubKey.IsValid()) {
+                    mo.push_back(Pair("pubKeyShare", pubKey.ToString()));
+                }
+            }
+            membersArr.push_back(mo);
+        }
+
+        ret.push_back(Pair("members", membersArr));
+    }
+    ret.push_back(Pair("quorumPublicKey", quorum->qc.quorumPublicKey.ToString()));
+    CBLSSecretKey skShare = quorum->GetSkShare();
+    if (includeSkShare && skShare.IsValid()) {
+        ret.push_back(Pair("secretKeyShare", skShare.ToString()));
+    }
+    return ret;
+}
+
 UniValue quorum_info(const JSONRPCRequest& request)
 {
     if (request.fHelp || (request.params.size() != 3 && request.params.size() != 4))
@@ -101,35 +136,7 @@ UniValue quorum_info(const JSONRPCRequest& request)
         throw JSONRPCError(RPC_INVALID_PARAMETER, "quorum not found");
     }
 
-    UniValue ret(UniValue::VOBJ);
+    return BuildQuorumInfo(quorum, true, includeSkShare);
-
-    ret.push_back(Pair("height", quorum->height));
-    ret.push_back(Pair("quorumHash", quorum->qc.quorumHash.ToString()));
-    ret.push_back(Pair("minedBlock", quorum->minedBlockHash.ToString()));
-
-    UniValue membersArr(UniValue::VARR);
-    for (size_t i = 0; i < quorum->members.size(); i++) {
-        auto& dmn = quorum->members[i];
-        UniValue mo(UniValue::VOBJ);
-        mo.push_back(Pair("proTxHash", dmn->proTxHash.ToString()));
-        mo.push_back(Pair("valid", quorum->qc.validMembers[i]));
-        if (quorum->qc.validMembers[i]) {
-            CBLSPublicKey pubKey = quorum->GetPubKeyShare(i);
-            if (pubKey.IsValid()) {
-                mo.push_back(Pair("pubKeyShare", pubKey.ToString()));
-            }
-        }
-        membersArr.push_back(mo);
-    }
-
-    ret.push_back(Pair("members", membersArr));
-    ret.push_back(Pair("quorumPublicKey", quorum->qc.quorumPublicKey.ToString()));
-    CBLSSecretKey skShare = quorum->GetSkShare();
-    if (includeSkShare && skShare.IsValid()) {
-        ret.push_back(Pair("secretKeyShare", skShare.ToString()));
-    }
-
-    return ret;
 }
 
 void quorum_dkgstatus_help()
@@ -182,6 +189,59 @@ UniValue quorum_dkgstatus(const JSONRPCRequest& request)
     return ret;
 }
 
+void quorum_memberof_help()
+{
+    throw std::runtime_error(
+            "quorum memberof \"proTxHash\"\n"
+            "Checks which quorums the given masternode is a member of.\n"
+            "\nArguments:\n"
+            "1. \"proTxHash\"                (string, required) ProTxHash of the masternode.\n"
+    );
+}
+
+UniValue quorum_memberof(const JSONRPCRequest& request)
+{
+    if (request.fHelp || (request.params.size() != 2)) {
+        quorum_memberof_help();
+    }
+
+    uint256 protxHash = ParseHashV(request.params[1], "proTxHash");
+
+    const CBlockIndex* pindexTip;
+    {
+        LOCK(cs_main);
+        pindexTip = chainActive.Tip();
+    }
+
+    auto mnList = deterministicMNManager->GetListForBlock(pindexTip->GetBlockHash());
+    auto dmn = mnList.GetMN(protxHash);
+    if (!dmn) {
+        throw JSONRPCError(RPC_INVALID_PARAMETER, "masternode not found");
+    }
+
+    std::set<std::pair<Consensus::LLMQType, uint256>> quorumHashes;
+    for (const auto& p : Params().GetConsensus().llmqs) {
+        auto& params = p.second;
+        auto quorums = llmq::quorumManager->ScanQuorums(params.type, params.signingActiveQuorumCount);
+        for (auto& quorum : quorums) {
+            for (auto& m : quorum->members) {
+                if (m->proTxHash == dmn->proTxHash) {
+                    quorumHashes.emplace(params.type, quorum->qc.quorumHash);
+                }
+            }
+        }
+    }
+
+    UniValue result(UniValue::VARR);
+    for (auto& p : quorumHashes) {
+        auto quorum = llmq::quorumManager->GetQuorum(p.first, p.second);
+        assert(quorum);
+        result.push_back(BuildQuorumInfo(quorum, false, false));
+    }
+
+    return result;
+}
+
 void quorum_sign_help()
 {
     throw std::runtime_error(
@@ -318,6 +378,7 @@ UniValue quorum_dkgsimerror(const JSONRPCRequest& request)
             "  info              - Return information about a quorum\n"
             "  dkgsimerror       - Simulates DKG errors and malicious behavior.\n"
             "  dkgstatus         - Return the status of the current DKG process\n"
+            "  memberof          - Checks which quorums the given masternode is a member of\n"
             "  sign              - Threshold-sign a message\n"
             "  hasrecsig         - Test if a valid recovered signature is present\n"
             "  getrecsig         - Get a recovered signature\n"
@@ -342,6 +403,8 @@ UniValue quorum(const JSONRPCRequest& request)
         return quorum_info(request);
     } else if (command == "dkgstatus") {
         return quorum_dkgstatus(request);
+    } else if (command == "memberof") {
+        return quorum_memberof(request);
     } else if (command == "sign" || command == "hasrecsig" || command == "getrecsig" || command == "isconflicting") {
         return quorum_sigs_cmd(request);
     } else if (command == "dkgsimerror") {