From 032498999a1703424ab3b1fc4e11245b44d6ef8d Mon Sep 17 00:00:00 2001
From: Todd Fleming <todd.fleming@block.one>
Date: Thu, 4 Oct 2018 09:51:45 -0400
Subject: [PATCH] state history plugin: get_irreversible

---
 .../state_history_plugin.cpp                     | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/plugins/state_history_plugin/state_history_plugin.cpp b/plugins/state_history_plugin/state_history_plugin.cpp
index 7ef9a09fe..ff10add37 100644
--- a/plugins/state_history_plugin/state_history_plugin.cpp
+++ b/plugins/state_history_plugin/state_history_plugin.cpp
@@ -624,6 +624,17 @@ struct state_history_plugin_impl : std::enable_shared_from_this<state_history_pl
       }
    }
 
+   void get_irreversible(uint32_t block_num, irrev_state_log_header& header, bytes& deltas) {
+      uint64_t pos;
+      irreversible_index.seekg((block_num - irreversible_begin_block) * sizeof(pos));
+      irreversible_index.read((char*)&pos, sizeof(pos));
+      irreversible_log.seekg(pos);
+      irreversible_log.read((char*)&header, sizeof(header));
+      deltas.resize(header.size);
+      if (header.size)
+         irreversible_log.read(deltas.data(), header.size);
+   }
+
    struct session : std::enable_shared_from_this<session> {
       std::shared_ptr<state_history_plugin_impl> plugin;
       std::unique_ptr<ws::stream<tcp::socket>>   stream;
@@ -715,6 +726,11 @@ struct state_history_plugin_impl : std::enable_shared_from_this<state_history_pl
             result.found = true;
             result.deltas.assign(it->deltas.begin(), it->deltas.end());
             // dlog("    bytes: ${b}", ("b", result.deltas));
+         } else if (req.block_num >= plugin->irreversible_begin_block &&
+                    req.block_num < plugin->irreversible_end_block) {
+            irrev_state_log_header header;
+            plugin->get_irreversible(req.block_num, header, result.deltas);
+            result.found = true;
          }
          send(std::move(result));
       }
-- 
GitLab