skip miner txs

src/json_rescue_v5_extract.rs

@@ -53,7 +53,10 @@ pub fn extract_v5_json_rescue(
                 // wtxs.events
                 // wtxs.block_timestamp
 
-                tx_vec.push(wtxs);
+                // TODO: create arg to exclude miner txs
+                if wtxs.relation_label != RelationLabel::Miner {
+                    tx_vec.push(wtxs);
+                }
             }
             TransactionDataView::BlockMetadata { timestamp_usecs: _ } => {
                 // TODO get epoch events

src/json_rescue_v5_load.rs

@@ -83,7 +83,7 @@ pub async fn concurrent_decompress_and_extract(tgz_file: &Path, pool: &Graph) ->
         task::spawn(async move {
             let _permit = parse_semaphore.acquire().await.unwrap(); // Control parsing concurrency
             if let Ok((mut r, _e)) = extract_v5_json_rescue(&j) {
-                let drain: Vec<WarehouseTxMaster> = r.drain(..).collect();
+                let drain: Vec<WarehouseTxMaster> = std::mem::take(&mut r);
 
                 if !drain.is_empty() {
                     let _db_permit = semaphore.acquire().await.unwrap(); // Control DB insert concurrency
@@ -102,7 +102,7 @@ pub async fn concurrent_decompress_and_extract(tgz_file: &Path, pool: &Graph) ->
                     }
                 }
             }
-            Ok(())
+            Ok::<(), anyhow::Error>(())
         })
     });
 
@@ -151,7 +151,7 @@ pub async fn stream_decompress_and_extract(tgz_file: &Path, pool: &Graph) -> Res
                 let _parse_permit = parse_semaphore.acquire().await.unwrap();
 
                 if let Ok((mut records, _e)) = extract_v5_json_rescue(&j) {
-                    let batch = records.drain(..).collect::<Vec<_>>();
+                    let batch = std::mem::take(&mut records);
 
                     if !batch.is_empty() {
                         let _insert_permit = insert_semaphore.acquire().await.unwrap();

src/schema_transaction.rs

@@ -11,7 +11,7 @@ use libra_backwards_compatibility::sdk::{
 use libra_types::{exports::AccountAddress, move_resource::coin_register_event::CoinRegisterEvent};
 use serde::{Deserialize, Serialize};
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
 pub enum RelationLabel {
     Tx, // undefined tx
     Transfer(AccountAddress),