Matthias/sqlx

.github/workflows/cont_integration.yml

@@ -130,3 +130,32 @@ jobs:
         with:
           token: ${{ secrets.GITHUB_TOKEN }}
           args: --all-features --all-targets -- -D warnings
+
+  build-examples:
+    name: Build Examples
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        example-dir:
+          - example_cli
+          - example_bitcoind_rpc_polling
+          - example_electrum
+          - example_esplora
+          - wallet_electrum
+          - wallet_esplora_async
+          - wallet_esplora_blocking
+          - wallet_rpc
+    steps:
+      - name: checkout
+        uses: actions/checkout@v2
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          override: true
+          profile: minimal
+      - name: Rust Cache
+        uses: Swatinem/[email protected]
+      - name: Build
+        working-directory: example-crates/${{ matrix.example-dir }}
+        run: cargo build

Cargo.toml

@@ -16,6 +16,7 @@ members = [
     "example-crates/wallet_electrum",
     "example-crates/wallet_esplora_blocking",
     "example-crates/wallet_esplora_async",
+    "example-crates/wallet_esplora_async_sqlx",
     "example-crates/wallet_rpc",
 ]
 

crates/chain/Cargo.toml

@@ -23,6 +23,7 @@ miniscript = { version = "12.0.0", optional = true, default-features = false }
 # Feature dependencies
 rusqlite = { version = "0.31.0", features = ["bundled"], optional = true }
 serde_json = {version = "1", optional = true }
+sqlx = { version = "0.8.0", default-features = false, features = ["runtime-tokio-rustls", "postgres", "json", "chrono", "uuid", "sqlx-macros", "migrate"], optional= true }
 
 [dev-dependencies]
 rand = "0.8"
@@ -33,3 +34,4 @@ default = ["std", "miniscript"]
 std = ["bitcoin/std", "miniscript?/std"]
 serde = ["dep:serde", "bitcoin/serde", "miniscript?/serde"]
 rusqlite = ["std", "dep:rusqlite", "serde", "serde_json"]
+sqlx = ["std", "dep:sqlx", "serde", "serde_json"]

crates/chain/src/lib.rs

@@ -57,13 +57,17 @@ pub use indexer::keychain_txout;
 pub use spk_iter::*;
 #[cfg(feature = "rusqlite")]
 pub mod rusqlite_impl;
+#[cfg(feature = "sqlx")]
+pub mod sqlx_impl;
 pub mod spk_client;
 
 #[allow(unused_imports)]
 #[macro_use]
 extern crate alloc;
 #[cfg(feature = "rusqlite")]
 pub extern crate rusqlite;
+#[cfg(feature = "sqlx")]
+pub extern crate sqlx;
 #[cfg(feature = "serde")]
 pub extern crate serde;
 
@@ -113,6 +117,13 @@ pub type KeychainIndexed<K, T> = ((K, u32), T);
 /// A wrapper that we use to impl remote traits for types in our crate or dependency crates.
 pub struct Impl<T>(pub T);
 
+impl<T> Impl<T> {
+    /// Returns the inner `T`.
+    pub fn into_inner(self) -> T {
+        self.0
+    }
+}
+
 impl<T> From<T> for Impl<T> {
     fn from(value: T) -> Self {
         Self(value)

crates/chain/src/persist.rs

@@ -45,7 +45,7 @@ pub trait PersistWith<Db>: Staged + Sized {
     ) -> Result<(), Self::PersistError>;
 }
 
-type FutureResult<'a, T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'a>>;
+pub type FutureResult<'a, T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'a>>;
 
 /// Trait that persists the type with an async `Db`.
 pub trait PersistAsyncWith<Db>: Staged + Sized {