Implement persisted indexed merkle trees (#102)

.gitignore

@@ -3,3 +3,4 @@ test-ledger/
 # Added by cargo
 
 /target
+/.cargo

src/api/method/get_multiple_compressed_account_proofs.rs

@@ -1,13 +1,8 @@
-
-use crate::{
-    ingester::persist::persisted_state_tree::{
-        get_multiple_compressed_leaf_proofs, MerkleProofWithContext,
-    },
+use crate::ingester::persist::persisted_state_tree::{
+    get_multiple_compressed_leaf_proofs, MerkleProofWithContext,
 };
 
-use sea_orm::{
-    DatabaseConnection,
-};
+use sea_orm::DatabaseConnection;
 use serde::{Deserialize, Serialize};
 use utoipa::ToSchema;
 

src/dao/generated/indexed_trees.rs

@@ -6,10 +6,11 @@ use sea_orm::entity::prelude::*;
 #[sea_orm(table_name = "indexed_trees")]
 pub struct Model {
     #[sea_orm(primary_key, auto_increment = false)]
-    pub index: i64,
-    pub value: i64,
+    pub tree: Vec<u8>,
+    pub leaf_index: i64,
+    pub value: Vec<u8>,
     pub next_index: i64,
-    pub next_value: i64,
+    pub next_value: Vec<u8>,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

src/ingester/persist/mod.rs

@@ -44,11 +44,12 @@ pub async fn persist_state_update(
     }
     let StateUpdate {
         in_accounts,
-        out_accounts,
+        mut out_accounts,
         account_transactions,
         transactions,
     } = state_update;
 
+    out_accounts.sort_by(|a, b| a.seq.cmp(&b.seq));
     debug!(
         "Persisting state update with {} input accounts, {} output accounts",
         in_accounts.len(),