Add capability to generate seed blocks over RPC

src/omnicore/omnicore.cpp

@@ -2892,6 +2892,30 @@ int mastercore::ClassAgnosticWalletTXBuilder(const std::string& senderAddress, c
 #endif
 }
 
+std::set<int> CMPTxList::GetSeedBlocks(int startHeight, int endHeight)
+{
+    std::set<int> setSeedBlocks;
+
+    if (!pdb) return setSeedBlocks;
+
+    Iterator* it = NewIterator();
+
+    for (it->SeekToFirst(); it->Valid(); it->Next()) {
+        std::string itData = it->value().ToString();
+        std::vector<std::string> vstr;
+        boost::split(vstr, itData, boost::is_any_of(":"), token_compress_on);
+        if (4 != vstr.size()) continue; // unexpected number of tokens
+        int block = atoi(vstr[1]);
+        if (block >= startHeight && block <= endHeight) {
+            setSeedBlocks.insert(block);
+        }
+    }
+
+    delete it;
+
+    return setSeedBlocks;
+}
+
 void CMPTxList::LoadActivations(int blockHeight)
 {
     if (!pdb) return;

src/omnicore/omnicore.h

@@ -244,6 +244,7 @@ class CMPTxList : public CDBBase
     bool exists(const uint256 &txid);
     bool getTX(const uint256 &txid, string &value);
 
+    std::set<int> GetSeedBlocks(int startHeight, int endHeight);
     void LoadAlerts(int blockHeight);
     void LoadActivations(int blockHeight);
 

src/omnicore/rpc.cpp

@@ -144,6 +144,65 @@ bool BalanceToJSON(const std::string& address, uint32_t property, Object& balanc
     }
 }
 
+// generate a list of seed blocks based on the data in LevelDB
+Value omni_getseedblocks(const Array& params, bool fHelp)
+{
+    if (fHelp || params.size() < 2 || params.size() > 3)
+        throw runtime_error(
+            "omni_getseedblocks startblock endblock\n"
+            "\nReturns a list of blocks containing Omni transactions for use in seed block filtering.\n"
+            "\nWARNING: The Exodus crowdsale is not stored in LevelDB, thus this is currently only safe to use to generate seed blocks after block 255365"
+            "\nArguments:\n"
+            "1. startblock           (number, required) the first block to look for Omni transactions (inclusive)\n"
+            "2. endblock             (number, required) the last block to look for Omni transactions (inclusive)\n"
+            "3. stringify            (bool, optional) whether to output one continuous string of seed blocks for easier inclusion in seedblocks.cpp\n"
+            "\nResult:\n"
+            "[                           (array of JSON objects)\n"
+            "  {\n"
+            "    \"seedblock\" : blockheight,    (number) the blockheight of the seed block\n"
+            "  },\n"
+            "  ...\n"
+            "]\n"
+            "\nExamples:\n"
+            + HelpExampleCli("omni_getseedblocks", "290000 300000")
+            + HelpExampleRpc("omni_getseedblocks", "290000, 300000")
+        );
+
+    int startHeight = params[0].get_int();
+    int endHeight = params[1].get_int();
+    bool overrideOutput = false;
+    if (params.size() > 2) overrideOutput = params[2].get_bool();
+
+    RequireHeightInChain(startHeight);
+    RequireHeightInChain(endHeight);
+
+    std::set<int> setSeedBlocks = p_txlistdb->GetSeedBlocks(startHeight, endHeight);
+
+    Array response;
+    std::string stringifiedOutput;
+
+    for (std::set<int>::const_iterator it = setSeedBlocks.begin(); it != setSeedBlocks.end(); ++it) {
+        if (!overrideOutput) {
+            Object seedBlockObj;
+            seedBlockObj.push_back(Pair("seedblock", *it));
+            response.push_back(seedBlockObj);
+        } else {
+            stringifiedOutput += strprintf("%d, ", *it);
+        }
+    }
+
+    if (!overrideOutput) {
+        return response;
+    } else {
+        Object stringifiedResponse;
+        if (stringifiedOutput.size()>2) { // remove trailing ", "
+            stringifiedOutput.erase(stringifiedOutput.size()-2);
+        }
+        stringifiedResponse.push_back(Pair("seedblocks", stringifiedOutput));
+        return stringifiedResponse;
+    }
+}
+
 // obtain the payload for a transaction
 Value omni_getpayload(const Array& params, bool fHelp)
 {

src/rpcclient.cpp

@@ -129,6 +129,9 @@ static const CRPCConvertParam vRPCConvertParams[] =
     { "omni_listblocktransactions", 0 },
     { "omni_getorderbook", 0 },
     { "omni_getorderbook", 1 },
+    { "omni_getseedblocks", 0 },
+    { "omni_getseedblocks", 1 },
+    { "omni_getseedblocks", 2 },
 
     /* Omni Core - transaction calls */
     { "omni_send", 2 },

src/rpcserver.cpp

@@ -378,6 +378,7 @@ static const CRPCCommand vRPCCommands[] =
     { "omni layer (data retrieval)",         "omni_gettradehistoryforpair",     &omni_gettradehistoryforpair,     false,      true,       false },
     { "omni layer (data retrieval)",         "omni_getcurrentconsensushash",    &omni_getcurrentconsensushash,    false,      true,       false },
     { "omni layer (data retrieval)",         "omni_getpayload",                 &omni_getpayload,                 false,      true,       false },
+    { "omni layer (data retrieval)",         "omni_getseedblocks",              &omni_getseedblocks,              false,      true,       false },
 #ifdef ENABLE_WALLET
     { "omni layer (data retrieval)",         "omni_listtransactions",           &omni_listtransactions,           false,      true,       true },
 

src/rpcserver.h

@@ -249,6 +249,7 @@ extern json_spirit::Value omni_gettradehistoryforaddress(const json_spirit::Arra
 extern json_spirit::Value omni_gettradehistoryforpair(const json_spirit::Array& params, bool fHelp);
 extern json_spirit::Value omni_getcurrentconsensushash(const json_spirit::Array& params, bool fHelp);
 extern json_spirit::Value omni_getpayload(const json_spirit::Array& params, bool fHelp);
+extern json_spirit::Value omni_getseedblocks(const json_spirit::Array& params, bool fHelp);
 
 /* Omni Core configuration calls */
 extern json_spirit::Value omni_setautocommit(const json_spirit::Array& params, bool fHelp);