errors: Add initial error module.

Cargo.toml

@@ -10,3 +10,5 @@ serde = { version = "1.0", default-features = false }
 serde_json = "1.0.108"
 bitcoincore-rpc = { git = "https://github.com/rust-bitcoin/rust-bitcoincore-rpc.git" }
 bitcoin-simulator = { git = "https://github.com/chainwayxyz/bitcoin-simulator" }
+anyhow = "1.0.86"
+thiserror = "1.0.61"

src/client/rpc_api.rs

@@ -38,6 +38,22 @@ impl RpcApi for Client {
         );
     }
 
+    fn send_raw_transaction<R: bitcoincore_rpc::RawTx>(
+        &self,
+        tx: R,
+    ) -> bitcoincore_rpc::Result<bitcoin::Txid> {
+        let tx: Transaction = encode::deserialize_hex(&tx.raw_hex()).unwrap();
+
+        if let Err(e) = self.ledger.check_transaction(tx.clone()) {
+            return Err(bitcoincore_rpc::Error::Io(std::io::Error::other(format!(
+                "{e}"
+            ))));
+        }
+
+        self.ledger.add_transaction_unconditionally(tx.clone());
+
+        Ok(tx.compute_txid())
+    }
     fn get_raw_transaction(
         &self,
         txid: &bitcoin::Txid,
@@ -67,22 +83,6 @@ impl RpcApi for Client {
             blocktime: None,
         })
     }
-    fn send_raw_transaction<R: bitcoincore_rpc::RawTx>(
-        &self,
-        tx: R,
-    ) -> bitcoincore_rpc::Result<bitcoin::Txid> {
-        let tx: Transaction = encode::deserialize_hex(&tx.raw_hex()).unwrap();
-
-        self.ledger.add_transaction_unconditionally(tx.clone());
-
-        if !self.ledger.check_transaction(tx.clone()) {
-            return Err(bitcoincore_rpc::Error::Io(std::io::Error::other(
-                "Transaction not valid.",
-            )));
-        }
-
-        Ok(tx.compute_txid())
-    }
 
     fn get_transaction(
         &self,
@@ -207,19 +207,24 @@ mod tests {
     fn raw_transaction() {
         let rpc = Client::new("", bitcoincore_rpc::Auth::None).unwrap();
 
+        // Get some BTC.
+        let address = rpc.get_new_address(None, None).unwrap();
+        rpc.generate_to_address(101, address.assume_checked_ref())
+            .unwrap();
+        let prev_tx = rpc.ledger._get_transactions().get(0).unwrap().to_owned();
+
         // Insert raw transactions to Bitcoin.
         let txin = TxIn {
             previous_output: OutPoint {
-                txid: Txid::from_byte_array([0x45; 32]),
+                txid: prev_tx.compute_txid(),
                 vout: 0,
             },
-            sequence: bitcoin::transaction::Sequence::ENABLE_RBF_NO_LOCKTIME,
-            script_sig: ScriptBuf::default(),
-            witness: Witness::new(),
+            ..Default::default()
         };
+        println!("----- {:?}", txin.clone());
         let txout = TxOut {
             value: Amount::from_sat(0x1F),
-            script_pubkey: test_common::get_temp_address().script_pubkey(),
+            script_pubkey: address.assume_checked().script_pubkey(),
         };
         let inserted_tx1 = test_common::create_transaction(vec![txin], vec![txout]);
         rpc.send_raw_transaction(&inserted_tx1).unwrap();

src/ledger/errors.rs

@@ -0,0 +1,12 @@
+//! # Errors
+//!
+//! Errors that can be returned from ledger operations.
+
+use thiserror::Error;
+
+/// Ledger error types.
+#[derive(Error, Debug)]
+pub enum LedgerError {
+    #[error("Database returned an error: {0}")]
+    Database(anyhow::Error),
+}

src/ledger/mod.rs

@@ -12,6 +12,7 @@ use std::{
     sync::{Arc, Mutex},
 };
 
+mod errors;
 mod transactions;
 
 /// Adds a new item to a `Vec` member, guarded by a `Cell`.

src/ledger/transactions.rs

@@ -1,6 +1,6 @@
 //! # Transaction Related Ledger Operations
 
-use super::Ledger;
+use super::{errors::LedgerError, Ledger};
 use crate::{add_item, get_item};
 use bitcoin::{Transaction, TxOut, Txid};
 
@@ -37,17 +37,16 @@ impl Ledger {
         get_item!(self.transactions);
     }
     /// Checks if a transaction is OK or not.
-    pub fn check_transaction(&self, transaction: Transaction) -> bool {
-        if let Ok(()) = self
+    pub fn check_transaction(&self, transaction: Transaction) -> Result<(), LedgerError> {
+        match self
             .database
             .lock()
             .unwrap()
             .verify_transaction(&transaction)
         {
-            return true;
-        };
-
-        false
+            Ok(()) => Ok(()),
+            Err(e) => Err(LedgerError::Database(e)),
+        }
     }
 }