Merge branch 'main' of github.com:GaloyMoney/cala into HEAD

cala-ledger/src/entry/mod.rs

@@ -6,10 +6,15 @@ use sqlx::PgPool;
 
 #[cfg(feature = "import")]
 use crate::primitives::DataSourceId;
-use crate::{ledger_operation::*, outbox::*, primitives::DataSource};
+use crate::{
+    ledger_operation::*,
+    outbox::*,
+    primitives::{AccountId, DataSource},
+};
 
 pub use entity::*;
 use error::*;
+pub use repo::entry_cursor::EntriesByCreatedAtCursor;
 use repo::*;
 
 #[derive(Clone)]
@@ -28,6 +33,17 @@ impl Entries {
         }
     }
 
+    pub async fn list_for_account_id(
+        &self,
+        account_id: AccountId,
+        query: es_entity::PaginatedQueryArgs<EntriesByCreatedAtCursor>,
+        direction: es_entity::ListDirection,
+    ) -> Result<es_entity::PaginatedQueryRet<Entry, EntriesByCreatedAtCursor>, EntryError> {
+        self.repo
+            .list_for_account_id_by_created_at(account_id, query, direction)
+            .await
+    }
+
     pub(crate) async fn create_all_in_op(
         &self,
         db: &mut LedgerOperation<'_>,

cala-ledger/src/entry/repo.rs

@@ -9,8 +9,8 @@ use super::{entity::*, error::*};
     entity = "Entry",
     err = "EntryError",
     columns(
+        account_id(ty = "AccountId", list_for, update(persist = false)),
         journal_id(ty = "JournalId", update(persist = false)),
-        account_id(ty = "AccountId", update(persist = false)),
         transaction_id(ty = "TransactionId", update(persist = false)),
         data_source_id(
             ty = "DataSourceId",

cala-ledger/src/ledger/mod.rs

@@ -134,6 +134,10 @@ impl CalaLedger {
         &self.balances
     }
 
+    pub fn entries(&self) -> &Entries {
+        &self.entries
+    }
+
     pub fn transactions(&self) -> &Transactions {
         &self.transactions
     }