Add -oceanarchive flag

Author: Jouzo

lib/Cargo.lock

@@ -120,3 +120,6 @@ substrate-bn = "0.6"
 #### Ocean dependencies
 dftx-rs = { git = "https://github.com/Jouzo/dftx-rs.git" }
 bitcoin = "0.31"
+
+### Local crates
+ain-cpp-imports = { path = "./ain-cpp-imports" }

lib/Cargo.toml

@@ -55,5 +55,6 @@ pub mod ffi {
         fn getEvmValidationLruCacheCount() -> usize;
         fn isEthDebugRPCEnabled() -> bool;
         fn isEthDebugTraceRPCEnabled() -> bool;
+        fn isOceanEnabled() -> bool;
     }
 }

lib/ain-cpp-imports/src/bridge.rs

@@ -278,5 +278,10 @@ pub fn is_eth_debug_trace_rpc_enabled() -> bool {
     ffi::isEthDebugTraceRPCEnabled()
 }
 
+/// Checks if Ocean REST API is enabled
+pub fn is_ocean_rest_enabled() -> bool {
+    ffi::isOceanEnabled()
+}
+
 #[cfg(test)]
 mod tests {}

lib/ain-cpp-imports/src/lib.rs

@@ -4,7 +4,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-ain-cpp-imports = { path = "../ain-cpp-imports" }
+ain-cpp-imports.workspace = true
 ain-contracts = { path = "../ain-contracts" }
 
 evm = { workspace = true, default-features = false, features = ["with-serde", "tracing", "std"] }

lib/ain-evm/Cargo.toml

@@ -6,7 +6,7 @@ build = "build.rs"
 
 [dependencies]
 ain-evm = { path = "../ain-evm" }
-ain-cpp-imports = { path = "../ain-cpp-imports" }
+ain-cpp-imports.workspace = true
 ain-ocean = { path = "../ain-ocean" }
 cxx.workspace = true
 env_logger.workspace = true

lib/ain-grpc/Cargo.toml

@@ -6,6 +6,8 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+ain-cpp-imports.workspace = true
+
 axum.workspace = true
 hyper.workspace = true
 keccak-hash.workspace = true

lib/ain-ocean/Cargo.toml

@@ -1,4 +1,4 @@
-use axum::Router;
+use axum::{http::StatusCode, response::IntoResponse, Router};
 
 mod address;
 mod block;
@@ -13,8 +13,17 @@ mod rawtx;
 mod stats;
 mod tokens;
 mod transactions;
+use axum::routing::get;
+
+async fn ocean_not_activated() -> impl IntoResponse {
+    (StatusCode::FORBIDDEN, "Ocean is not activated")
+}
 
 pub fn ocean_router() -> Router {
+    if !ain_cpp_imports::is_ocean_rest_enabled() {
+        return Router::new().route("/*path", get(ocean_not_activated));
+    }
+
     Router::new()
         .nest("/address", address::router())
         .nest("/governance", governance::router())

lib/ain-ocean/src/api/mod.rs

@@ -33,15 +33,6 @@ impl Index for CreateMasternode {
             history: None,
         };
 
-        let mut file = std::fs::OpenOptions::new()
-            .write(true)
-            .create(true)
-            .append(true)
-            .open("/tmp/masternode")
-            .expect("Unable to open file");
-
-        writeln!(file, "{:?}", masternode).expect("Unable to write to file");
-
         Ok(())
     }
 

lib/ain-ocean/src/indexer/masternode.rs

@@ -14,6 +14,7 @@ pub(crate) trait Index {
 
 use bitcoin::BlockHash;
 use dftx_rs::{deserialize, Block, DfTx};
+use log::debug;
 
 pub(crate) struct BlockContext {
     height: u32,
@@ -23,6 +24,8 @@ pub(crate) struct BlockContext {
 }
 
 pub fn index_block(block: String, block_height: u32) -> Result<()> {
+    debug!("[index_block] Indexing block...");
+
     let hex = hex::decode(block)?;
     let block = deserialize::<Block>(&hex)?;
 
@@ -49,22 +52,22 @@ pub fn index_block(block: String, block_height: u32) -> Result<()> {
 
             match dftx {
                 DfTx::CreateMasternode(data) => data.index(&context, tx)?,
-                DfTx::UpdateMasternode(data) => data.index(&context, tx)?,
-                DfTx::ResignMasternode(data) => data.index(&context, tx)?,
-                DfTx::AppointOracle(data) => data.index(&context, tx)?,
-                DfTx::RemoveOracle(data) => data.index(&context, tx)?,
-                DfTx::UpdateOracle(data) => data.index(&context, tx)?,
-                DfTx::SetOracleData(data) => data.index(&context, tx)?,
-                DfTx::PoolSwap(data) => data.index(&context, tx)?,
-                DfTx::CompositeSwap(data) => data.index(&context, tx)?,
-                DfTx::PlaceAuctionBid(data) => data.index(&context, tx)?,
+                // DfTx::UpdateMasternode(data) => data.index(&context, tx)?,
+                // DfTx::ResignMasternode(data) => data.index(&context, tx)?,
+                // DfTx::AppointOracle(data) => data.index(&context, tx)?,
+                // DfTx::RemoveOracle(data) => data.index(&context, tx)?,
+                // DfTx::UpdateOracle(data) => data.index(&context, tx)?,
+                // DfTx::SetOracleData(data) => data.index(&context, tx)?,
+                // DfTx::PoolSwap(data) => data.index(&context, tx)?,
+                // DfTx::CompositeSwap(data) => data.index(&context, tx)?,
+                // DfTx::PlaceAuctionBid(data) => data.index(&context, tx)?,
                 _ => (),
             }
         }
     }
     Ok(())
 }
 
-pub fn invalidate_block() {
-    todo!()
+pub fn invalidate_block(block: String, block_height: u32) -> Result<()> {
+    Ok(())
 }