proto: get transaction input accepts only one account, fixes #103

block-producer/src/server/api.rs

@@ -70,7 +70,7 @@ impl Store for DefaultStore {
         proven_tx: SharedProvenTx,
     ) -> Result<TxInputs, TxInputsError> {
         let request = tonic::Request::new(GetTransactionInputsRequest {
-            account_ids: vec![proven_tx.account_id().into()],
+            account_id: Some(proven_tx.account_id().into()),
             nullifiers: proven_tx
                 .consumed_notes()
                 .iter()
@@ -87,8 +87,7 @@ impl Store for DefaultStore {
 
         let account_hash = {
             let account_state = response
-                .account_states
-                .first()
+                .account_state
                 .ok_or(TxInputsError::MalformedResponse("account_states empty".to_string()))?;
 
             let account_id_from_store: AccountId = account_state

proto/proto/requests.proto

@@ -48,7 +48,7 @@ message GetBlockInputsRequest {
 }
 
 message GetTransactionInputsRequest {
-    repeated account_id.AccountId account_ids = 1;
+    account_id.AccountId account_id = 1;
     repeated digest.Digest nullifiers = 2;
 }
 

proto/proto/responses.proto

@@ -97,7 +97,7 @@ message NullifierTransactionInputRecord {
 }
 
 message GetTransactionInputsResponse {
-    repeated AccountTransactionInputRecord account_states = 1;
+    AccountTransactionInputRecord account_state = 1;
     repeated NullifierTransactionInputRecord nullifiers = 2;
 }
 

proto/src/generated/requests.rs

@@ -67,8 +67,8 @@ pub struct GetBlockInputsRequest {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetTransactionInputsRequest {
-    #[prost(message, repeated, tag = "1")]
-    pub account_ids: ::prost::alloc::vec::Vec<super::account_id::AccountId>,
+    #[prost(message, optional, tag = "1")]
+    pub account_id: ::core::option::Option<super::account_id::AccountId>,
     #[prost(message, repeated, tag = "2")]
     pub nullifiers: ::prost::alloc::vec::Vec<super::digest::Digest>,
 }

proto/src/generated/responses.rs

@@ -129,8 +129,8 @@ pub struct NullifierTransactionInputRecord {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct GetTransactionInputsResponse {
-    #[prost(message, repeated, tag = "1")]
-    pub account_states: ::prost::alloc::vec::Vec<AccountTransactionInputRecord>,
+    #[prost(message, optional, tag = "1")]
+    pub account_state: ::core::option::Option<AccountTransactionInputRecord>,
     #[prost(message, repeated, tag = "2")]
     pub nullifiers: ::prost::alloc::vec::Vec<NullifierTransactionInputRecord>,
 }

store/src/server/api.rs

@@ -186,16 +186,16 @@ impl api_server::Api for StoreApi {
         let request = request.into_inner();
 
         let nullifiers = validate_nullifiers(&request.nullifiers)?;
-        let account_ids: Vec<u64> = request.account_ids.iter().map(|e| e.id).collect();
+        let account_id = request.account_id.ok_or(invalid_argument("Account_id missing"))?.id;
 
-        let (accounts, nullifiers_blocks) = self
+        let (account, nullifiers_blocks) = self
             .state
-            .get_transaction_inputs(&account_ids, &nullifiers)
+            .get_transaction_inputs(account_id, &nullifiers)
             .await
             .map_err(internal_error)?;
 
         Ok(Response::new(GetTransactionInputsResponse {
-            account_states: convert(accounts),
+            account_state: Some(account.into()),
             nullifiers: convert(nullifiers_blocks),
         }))
     }

store/src/state.rs

@@ -404,21 +404,15 @@ impl State {
 
     pub async fn get_transaction_inputs(
         &self,
-        account_ids: &[AccountId],
+        account_id: AccountId,
         nullifiers: &[RpoDigest],
-    ) -> Result<(Vec<AccountState>, Vec<NullifierStateForTransactionInput>), anyhow::Error> {
+    ) -> Result<(AccountState, Vec<NullifierStateForTransactionInput>), anyhow::Error> {
         let inner = self.inner.read().await;
 
-        let accounts: Vec<_> = account_ids
-            .iter()
-            .cloned()
-            .map(|id| {
-                Ok(AccountState {
-                    account_id: id,
-                    account_hash: inner.account_tree.get_leaf(id)?,
-                })
-            })
-            .collect::<Result<Vec<AccountState>, MerkleError>>()?;
+        let account = AccountState {
+            account_id,
+            account_hash: inner.account_tree.get_leaf(account_id)?,
+        };
 
         let nullifier_blocks = nullifiers
             .iter()
@@ -434,7 +428,7 @@ impl State {
             })
             .collect();
 
-        Ok((accounts, nullifier_blocks))
+        Ok((account, nullifier_blocks))
     }
 }