lookback sectors deadlines (#598)

Signed-off-by: turuslan <[email protected]>

Author: turuslan

core/codec/cbor/light_reader/amt_walk.hpp

@@ -12,7 +12,21 @@ namespace fc::codec::cbor::light_reader {
   struct AmtWalk : Walk {
     using Walk::Walk;
 
+    bool visit() {
+      if (!load()) {
+        return false;
+      }
+      BytesIn value;
+      while (next(value)) {
+        // note: ignoring value
+      }
+      return empty();
+    }
+
     inline bool load() {
+      if (next_cid != 0) {
+        return true;
+      }
       cbor::CborToken token;
       if (!Walk::next()) {
         return false;

core/codec/cbor/light_reader/miner_actor_reader.hpp

@@ -95,4 +95,44 @@ namespace fc::codec::cbor::light_reader {
     }
     return std::make_tuple(*miner_info, *sectors, *deadlines);
   }
+
+  template <typename F>
+  inline bool minerDeadlines(const CbIpldPtr &ipld,
+                             const CbCid &_deadlines,
+                             const F &f) {
+    Bytes deadlines_cbor;
+    if (!ipld->get(_deadlines, deadlines_cbor)) {
+      return false;
+    }
+    BytesIn deadlines_input{deadlines_cbor};
+    cbor::CborToken token;
+    if (!read(token, deadlines_input).listCount()) {
+      return false;
+    }
+    if (!read(token, deadlines_input).listCount()) {
+      return false;
+    }
+    Bytes deadline_cbor;
+    for (size_t n{*token.listCount()}; n != 0; --n) {
+      const CbCid *_deadline = nullptr;
+      if (!cbor::readCborBlake(_deadline, deadlines_input)) {
+        return false;
+      }
+      if (!ipld->get(*_deadline, deadline_cbor)) {
+        return false;
+      }
+      BytesIn deadline_input{deadline_cbor};
+      if (!read(token, deadline_input).listCount()) {
+        return false;
+      }
+      const CbCid *_partitions = nullptr;
+      if (!cbor::readCborBlake(_partitions, deadline_input)) {
+        return false;
+      }
+      if (!f(*_deadline, *_partitions)) {
+        return false;
+      }
+    }
+    return true;
+  }
 }  // namespace fc::codec::cbor::light_reader

core/storage/compacter/lookback.hpp

@@ -7,10 +7,12 @@
 
 #include "codec/cbor/light_reader/actor.hpp"
 #include "codec/cbor/light_reader/address.hpp"
+#include "codec/cbor/light_reader/amt_walk.hpp"
 #include "codec/cbor/light_reader/hamt_walk.hpp"
 #include "codec/cbor/light_reader/miner_actor_reader.hpp"
 #include "codec/cbor/light_reader/state_tree.hpp"
 #include "codec/cbor/light_reader/storage_power_actor_reader.hpp"
+#include "common/append.hpp"
 #include "storage/compacter/queue.hpp"
 #include "vm/actor/codes.hpp"
 
@@ -46,6 +48,18 @@ namespace fc::storage::compacter {
       const auto &[info, sectors, deadlines]{_r.value()};
       copy.push_back(head);
       copy.push_back(info);
+      recurse.push_back(sectors);
+      copy.push_back(deadlines);
+      codec::cbor::light_reader::minerDeadlines(
+          ipld, deadlines, [&](const CbCid &deadline, const CbCid &partitions) {
+            copy.push_back(deadline);
+            codec::cbor::light_reader::AmtWalk walk{ipld, partitions};
+            if (!walk.visit()) {
+              return false;
+            }
+            append(copy, walk.cids);
+            return true;
+          });
       return;
     }
     if (ACTOR_CODE_IS(kStoragePowerCodeId)) {