feat: simple IPC test

.github/scripts/install_test_binaries.sh

@@ -0,0 +1,51 @@
+#!/usr/bin/env bash
+# Installs Solc and Geth binaries
+# Note: intended for use only with CI (x86_64 Ubuntu, MacOS or Windows)
+set -e
+
+GETH_BUILD=${GETH_BUILD:-"1.11.2-73b01f40"}
+
+BIN_DIR=${BIN_DIR:-"$HOME/bin"}
+
+PLATFORM="$(uname -s | awk '{print tolower($0)}')"
+if [ "$PLATFORM" != "linux" ] && [ "$PLATFORM" != "darwin" ]; then
+    EXT=".exe"
+fi
+
+main() {
+    mkdir -p "$BIN_DIR"
+    cd "$BIN_DIR"
+    export PATH="$BIN_DIR:$PATH"
+    if [ "$GITHUB_PATH" ]; then
+        echo "$BIN_DIR" >> "$GITHUB_PATH"
+    fi
+
+    install_geth
+
+    echo ""
+    echo "Installed Geth:"
+    geth version
+}
+
+# Installs geth from https://geth.ethereum.org/downloads
+install_geth() {
+    case "$PLATFORM" in
+        linux|darwin)
+            name="geth-$PLATFORM-amd64-$GETH_BUILD"
+            curl -s "https://gethstore.blob.core.windows.net/builds/$name.tar.gz" | tar -xzf -
+            mv -f "$name/geth" ./
+            rm -rf "$name"
+            chmod +x geth
+            ;;
+        *)
+            name="geth-windows-amd64-$GETH_BUILD"
+            zip="$name.zip"
+            curl -so "$zip" "https://gethstore.blob.core.windows.net/builds/$zip"
+            unzip "$zip"
+            mv -f "$name/geth.exe" ./
+            rm -rf "$name" "$zip"
+            ;;
+    esac
+}
+
+main

.github/workflows/ci.yml

@@ -31,6 +31,9 @@ jobs:
         uses: foundry-rs/foundry-toolchain@v1
         with:
           version: nightly
+      - name: Install test binaries
+        shell: bash
+        run: ./.github/scripts/install_test_binaries.sh
       - uses: Swatinem/rust-cache@v2
         with:
           cache-on-failure: true

crates/rpc-client/Cargo.toml

@@ -38,6 +38,9 @@ alloy-primitives.workspace = true
 alloy-transport-ws.workspace = true
 test-log = { version = "0.2.13", default-features = false, features = ["trace"] }
 tracing-subscriber = { version = "0.3.17", features = ["std", "env-filter"] }
+ethers-core = "2.0.10"
+alloy-transport-ipc = { workspace = true, features = ["mock"] }
+tempfile = "3"
 
 [features]
 default = ["reqwest"]

crates/rpc-client/tests/it/ipc.rs

@@ -0,0 +1,38 @@
+use std::borrow::Cow;
+
+use alloy_primitives::U64;
+use alloy_pubsub::PubSubFrontend;
+use alloy_rpc_client::{ClientBuilder, RpcCall, RpcClient};
+use alloy_transport_ipc::IpcConnect;
+use ethers_core::utils::{Geth, GethInstance};
+use tempfile::NamedTempFile;
+
+async fn connect() -> (RpcClient<PubSubFrontend>, GethInstance) {
+    let temp_file = NamedTempFile::new().unwrap();
+    let path = temp_file.into_temp_path().to_path_buf();
+    let geth = Geth::new().block_time(1u64).ipc_path(&path).spawn();
+
+    // [Windows named pipes](https://learn.microsoft.com/en-us/windows/win32/ipc/named-pipes)
+    // are located at `\\<machine_address>\pipe\<pipe_name>`.
+    #[cfg(windows)]
+    let path = format!(r"\\.\pipe\{}", path.display());
+
+    let connector: IpcConnect<_> = path.into();
+
+    let client = ClientBuilder::default().pubsub(connector).await.unwrap();
+
+    (client, geth)
+}
+
+#[test_log::test(tokio::test)]
+async fn it_makes_a_request() {
+    let (client, _geth) = connect().await;
+
+    let params: Cow<'static, _> = Cow::Owned(vec![]);
+
+    let req: RpcCall<_, Cow<'static, Vec<String>>, U64> = client.prepare("eth_blockNumber", params);
+
+    let timeout = tokio::time::timeout(std::time::Duration::from_secs(2), req);
+
+    timeout.await.unwrap().unwrap();
+}

crates/rpc-client/tests/it/main.rs

@@ -5,3 +5,6 @@ mod http;
 
 #[cfg(feature = "pubsub")]
 mod ws;
+
+#[cfg(feature = "pubsub")]
+mod ipc;

crates/rpc-types/src/eth/filter.rs

@@ -736,7 +736,7 @@ impl FilteredParams {
     }
 
     /// Returns `true` if the bloom matches the topics
-    pub fn matches_topics(bloom: Bloom, topic_filters: &Vec<BloomFilter>) -> bool {
+    pub fn matches_topics(bloom: Bloom, topic_filters: &[BloomFilter]) -> bool {
         if topic_filters.is_empty() {
             return true;
         }