Check parent RPC version on startup

Author: stevenroose

src/validation.cpp

@@ -2228,16 +2228,18 @@ bool BitcoindRPCCheck(const bool init)
     vblocksToReconsiderAgain.clear();
     pblocktree->WriteInvalidBlockQueue(vblocksToReconsider);
 
-    //Next, check for working rpc
+    // Next, check for working and valid rpc
     if (GetBoolArg("-validatepegin", DEFAULT_VALIDATE_PEGIN)) {
         // During init try until a non-RPC_IN_WARMUP result
         while (true) {
             try {
+                // The first thing we have to check is the version of the node.
                 UniValue params(UniValue::VARR);
-                params.push_back(UniValue(0));
-                UniValue reply = CallRPC("getblockhash", params, true);
-                UniValue error = find_value(reply, "error");
+                UniValue reply = CallRPC("getnetworkinfo", params, true);
+                UniValue error = reply["error"];
                 if (!error.isNull()) {
+                    // On the first call, it's possible to node is still in 
+                    // warmup; in that case, just wait and retry.
                     if (error["code"].get_int() == RPC_IN_WARMUP) {
                         MilliSleep(1000);
                         continue;
@@ -2248,6 +2250,21 @@ bool BitcoindRPCCheck(const bool init)
                     }
                 }
                 UniValue result = reply["result"];
+                if (!result.isObject() || !result.get_obj()["version"].isNum() ||
+                        result.get_obj()["version"].get_int() < MIN_PARENT_RPC_VERSION) {
+                    LogPrintf("ERROR: Parent chain daemon too old; need version 0.16.2.\n");
+                    return false;
+                }
+
+                // Then check the genesis block to correspond to parent chain.
+                params.push_back(UniValue(0));
+                reply = CallRPC("getblockhash", params, true);
+                error = reply["error"];
+                if (!error.isNull()) {
+                    LogPrintf("ERROR: Bitcoind RPC check returned 'error' response.\n");
+                    return false;
+                }
+                result = reply["result"];
                 if (!result.isStr() || result.get_str() != Params().ParentGenesisBlockHash().GetHex()) {
                     LogPrintf("ERROR: Invalid parent genesis block hash response via RPC. Contacting wrong parent daemon?\n");
                     return false;
@@ -2303,7 +2320,7 @@ bool BitcoindRPCCheck(const bool init)
 
         //Write back remaining blocks
         pblocktree->WriteInvalidBlockQueue(vblocksToReconsiderAgain);
-        }
+    }
     return true;
 }
 

src/validation.h

@@ -149,6 +149,10 @@ static const int MAX_UNCONNECTING_HEADERS = 10;
 
 static const bool DEFAULT_PEERBLOOMFILTERS = false;
 
+/** The minimum RPC version for the parent chain.
+ *  We need v0.16.2 to get the nTx field in getblockheader. */
+static const int MIN_PARENT_RPC_VERSION = 160200; // 0.16.2
+
 struct BlockHasher
 {
     size_t operator()(const uint256& hash) const { return hash.GetCheapHash(); }