Add initial RPC calls using jsonrcp-client

json/integration_test/jsonrpc-client/Cargo.toml

@@ -0,0 +1,18 @@
+[package]
+name = "integration-test"
+version = "0.1.0"
+authors = ["Tobin C. Harding <me@tobin.cc>"]
+license = "CC0-1.0"
+edition = "2021"
+
+[dependencies]
+bitcoincore-rpc-json = { path = "../.." }
+
+anyhow = "1"
+jsonrpc_client = { version = "0.7", features = ["reqwest"] }
+reqwest = "0.11"
+tokio = { version = "1", features = [ "macros", "rt-multi-thread" ] }
+
+# Prevent this from interfering with workspaces.
+[workspace]
+members = ["."]

json/integration_test/jsonrpc-client/run.sh

@@ -0,0 +1,52 @@
+#!/bin/sh
+
+TESTDIR=/tmp/rust_bitcoincore_rpc_test
+
+if bitcoind -version | grep -q "v22"; then
+    echo "Starting two bitcoind v22 instances"
+else
+    echo "Currently tests are intended for Bitcoin Core v22"
+    exit 1
+fi
+
+rm -rf ${TESTDIR}
+mkdir -p ${TESTDIR}/1 ${TESTDIR}/2
+
+bitcoind -regtest \
+    -datadir=${TESTDIR}/1 \
+    -port=12348 \
+    -server=0 \
+    -printtoconsole=0 &
+PID1=$!
+
+# Make sure it's listening on its p2p port.
+sleep 1
+
+bitcoind -regtest \
+    -datadir=${TESTDIR}/2 \
+    -connect=127.0.0.1:12348 \
+    -rpcport=12349 \
+    -rpcuser=user \
+    -rpcpassword=password \
+    -server=1 \
+    -txindex=1 \
+    -printtoconsole=0 \
+    -zmqpubrawblock=tcp://0.0.0.0:28332 \
+    -zmqpubrawtx=tcp://0.0.0.0:28333 &
+PID2=$!
+
+# Let it connect to the other node.
+sleep 1
+
+echo "Two connected bitcoind instances running, hit port 12349"
+
+# RPC_URL=http://localhost:12349 \
+#     RPC_COOKIE=${TESTDIR}/2/regtest/.cookie \
+#     TESTDIR=${TESTDIR} \
+#     cargo run
+
+# RESULT=$?
+
+# kill -9 $PID1 $PID2
+
+# exit $RESULT

json/integration_test/jsonrpc-client/src/lib.rs

@@ -0,0 +1,3 @@
+//! Test the `bitcoincore-rpc-json` crate.
+
+pub mod v22;

json/integration_test/jsonrpc-client/src/main.rs

@@ -0,0 +1,36 @@
+use std::fmt;
+
+use anyhow::Result;
+use integration_test::v22::{self, BitcoindRpc};
+
+/// Set to `true` for verbose output.
+const VERBOSE: bool = true;
+
+#[tokio::main]
+async fn main() -> Result<()> {
+    let username = "user";
+    let password = "password";
+
+    let url = format!("http://{}:{}@localhost:12349", username, password);
+    println!("url: {}", url);
+
+    let client = v22::Client::new(url)?;
+
+    let res = client.getblockchaininfo().await?;
+    print(res);
+
+    let res = client.getnetworkinfo().await?;
+    print(res);
+
+    let res = client.getindexinfo().await?;
+    print(res);
+
+    Ok(())
+}
+
+/// Prints `res` if `VERBOSE` is set to `true`.
+fn print<T: fmt::Debug>(res: T) {
+    if VERBOSE {
+        println!("{:#?}", res);
+    }
+}

json/integration_test/jsonrpc-client/src/v22.rs

@@ -0,0 +1,34 @@
+//! Test the Bitcoin Core v22 JSON-RPC API.
+
+use anyhow;
+use bitcoincore_rpc_json::*;
+
+/// An RPC client.
+#[jsonrpc_client::implement(BitcoindRpc)]
+pub struct Client {
+    inner: reqwest::Client,
+    base_url: jsonrpc_client::Url,
+}
+
+impl Client {
+    /// Creates a new [`Client`].
+    pub fn new(base_url: String) -> anyhow::Result<Self> {
+        Ok(Self {
+            inner: reqwest::Client::new(),
+            base_url: base_url.parse()?,
+        })
+    }
+}
+
+/// Implement JSON-RPC call: `getblockchaininfo`.
+#[jsonrpc_client::api(version = "1.0")]
+pub trait BitcoindRpc {
+    /// Implement JSON-RPC call: `getblockchaininfo`.
+    async fn getblockchaininfo(&self) -> GetBlockchainInfoResult;
+
+    /// Implement JSON-RPC call: `getnetworkinfo`.
+    async fn getnetworkinfo(&self) -> GetNetworkInfoResult;
+
+    /// Implement JSON-RPC call: `getindexinfo`.
+    async fn getindexinfo(&self) -> GetIndexInfoResult;
+}