patch e2e test

warehouse/src/load.rs

@@ -2,14 +2,16 @@ use crate::table_structs::{WarehouseAccount, WarehouseState};
 use anyhow::Result;
 use sqlx::{sqlite::SqliteQueryResult, SqlitePool};
 
-pub async fn load_account_state(pool: &SqlitePool, accounts: Vec<WarehouseState>) -> Result<()> {
+pub async fn load_account_state(pool: &SqlitePool, accounts: &Vec<WarehouseState>) -> Result<i64> {
+    let mut rows = 0;
     // insert missing accounts
     for ws in accounts.iter() {
-        insert_one_account(pool, &ws.account).await?;
+        let res= insert_one_account(pool, &ws.account).await?;
+        rows = res.last_insert_rowid();
     }
 
     // increment the balance changes
-    Ok(())
+    Ok(rows)
 }
 
 pub async fn insert_one_account(pool: &SqlitePool, acc: &WarehouseAccount) -> Result<SqliteQueryResult> {

warehouse/tests/test_load.rs

@@ -1,7 +1,18 @@
+use std::path::PathBuf;
+
 use libra_types::exports::AccountAddress;
 use libra_warehouse::table_structs::WarehouseAccount;
+use libra_warehouse::extract::extract_v5_snapshot;
+
 use sqlx::SqlitePool;
 
+fn v5_state_manifest_fixtures_path() -> PathBuf {
+    let p = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
+    let project_root = p.parent().unwrap();
+    project_root.join("compatibility/fixtures/v5/state_ver_119757649.17a8/state.manifest")
+}
+
+
 #[sqlx::test]
 async fn insert_one_account(pool: SqlitePool) -> anyhow::Result<()> {
     libra_warehouse::migrate::maybe_init(&pool).await?;
@@ -17,3 +28,22 @@ async fn insert_one_account(pool: SqlitePool) -> anyhow::Result<()> {
 
     Ok(())
 }
+
+
+
+#[sqlx::test]
+
+async fn test_e2e_load_v5_snapshot(pool: SqlitePool) -> anyhow::Result<()> {
+    libra_warehouse::migrate::maybe_init(&pool).await?;
+
+    let manifest_file = v5_state_manifest_fixtures_path();
+    assert!(manifest_file.exists());
+    let wa_vec = extract_v5_snapshot(&manifest_file).await?;
+    // NOTE: the parsing drops 1 blob, which is the 0x1 account, because it would not have the DiemAccount struct on it as a user address would have.
+    assert!(wa_vec.len() == 17338);
+
+    let res = libra_warehouse::load::load_account_state(&pool, &wa_vec).await?;
+
+    assert!(res == 17338);
+    Ok(())
+}