Rodeos filter current_time() 📦

libraries/rodeos/include/b1/rodeos/callbacks/system.hpp

@@ -0,0 +1,40 @@
+#pragma once
+
+#include <b1/rodeos/callbacks/basic.hpp>
+#include <b1/rodeos/get_state_row.hpp>
+
+namespace b1::rodeos {
+
+// for filter callback. query callback for current_time is in query.hpp
+
+template <typename Derived>
+struct system_callbacks {
+   Derived& derived() { return static_cast<Derived&>(*this); }
+
+   auto load_block_info() {
+      auto& state = derived().get_state();
+
+      block_info_kv table{ { derived().get_db_view_state() } };
+      if (table.primary_index.begin() != table.primary_index.end()) {
+         return table.primary_index.begin().value();
+      }
+      throw std::runtime_error("system callback database is missing block_info_v0");
+   }
+
+   int64_t current_time() {
+      auto block_info = load_block_info();
+      return std::visit(
+            [](auto& b) { //
+               return b.timestamp.to_time_point().time_since_epoch().count();
+            },
+            block_info);
+   }
+
+   template <typename Rft>
+   static void register_callbacks() {
+      // todo: preconditions
+      RODEOS_REGISTER_CALLBACK(Rft, Derived, current_time);
+   }
+}; // system_callbacks
+
+} // namespace b1::rodeos

libraries/rodeos/include/b1/rodeos/callbacks/unimplemented_filter.hpp

@@ -11,14 +11,6 @@ struct unimplemented_filter_callbacks {
       throw std::runtime_error("wasm called " + std::string(name) + ", which is unimplemented");
    }
 
-   // system_api
-   int64_t current_time() { return unimplemented<int64_t>("current_time"); }
-
-   template <typename Rft>
-   static void register_callbacks() {
-      // todo: preconditions
-      RODEOS_REGISTER_CALLBACK(Rft, Derived, current_time);
-   }
 }; // unimplemented_filter_callbacks
 
 } // namespace b1::rodeos

libraries/rodeos/include/b1/rodeos/filter.hpp

@@ -7,6 +7,7 @@
 #include <b1/rodeos/callbacks/crypto.hpp>
 #include <b1/rodeos/callbacks/filter.hpp>
 #include <b1/rodeos/callbacks/memory.hpp>
+#include <b1/rodeos/callbacks/system.hpp>
 #include <b1/rodeos/callbacks/unimplemented.hpp>
 #include <b1/rodeos/callbacks/unimplemented_filter.hpp>
 #ifdef EOSIO_EOS_VM_OC_RUNTIME_ENABLED
@@ -64,7 +65,7 @@ struct callbacks : b1::rodeos::chaindb_callbacks<callbacks>,
                    b1::rodeos::filter_callbacks<callbacks>,
                    b1::rodeos::memory_callbacks<callbacks>,
                    b1::rodeos::unimplemented_callbacks<callbacks>,
-                   b1::rodeos::unimplemented_filter_callbacks<callbacks> {
+                   b1::rodeos::system_callbacks<callbacks> {
    filter::filter_state&      filter_state;
    b1::rodeos::chaindb_state& chaindb_state;
    b1::rodeos::db_view_state& db_view_state;
@@ -89,8 +90,8 @@ inline void register_callbacks() {
    b1::rodeos::db_callbacks<callbacks>::register_callbacks<rhf_t>();
    b1::rodeos::filter_callbacks<callbacks>::register_callbacks<rhf_t>();
    b1::rodeos::memory_callbacks<callbacks>::register_callbacks<rhf_t>();
+   b1::rodeos::system_callbacks<callbacks>::register_callbacks<rhf_t>();
    b1::rodeos::unimplemented_callbacks<callbacks>::register_callbacks<rhf_t>();
-   b1::rodeos::unimplemented_filter_callbacks<callbacks>::register_callbacks<rhf_t>();
 }
 
 } // namespace b1::rodeos::filter