feat: add ethereum support (#912)

Author: mduthey

Cargo.lock

@@ -20,7 +20,7 @@ zeromq = ["zmq"]
 u5c = ["utxorpc", "futures"]
 mithril = ["mithril-client"]
 hydra = ["tungstenite", "tokio-tungstenite", "futures-util", "bytes"]
-eth = ["futures-util"]
+eth = ["futures-util", "alloy"]
 btc = ["bitcoind-async-client", "corepc-types"]
 # elasticsearch = auto feature flag
 # kafka = auto feature flag
@@ -86,9 +86,7 @@ bytes = { version = "1.7.2", optional = true }
 zmq = { version = "0.10.0", optional = true }
 bitcoind-async-client = { version = "0.6.0", optional = true }
 corepc-types = { version = "0.10.1", optional = true }
-
-# TODO(p): add feature
-alloy = { version = "1.0.38", features = ["full"] }
+alloy = { version = "1.0.38", features = ["provider-ws"], optional = true }
 
 [dev-dependencies]
 goldenfile = "1.7.3"

Cargo.toml

@@ -39,7 +39,12 @@ The data pipeline is implemented by the [Gasket](https://github.com/construkts/g
 
 ### CLI to Watch Live Transactions
 
-You can run `oura watch cardano <socket>` to print Cardano transaction data into the terminal from the tip of a local or remote node, or `oura watch bitcoin <rpc_host>` to watch Bitcoin blockchain events. These commands are useful as debugging tools for developers or if you're just curious to see what's going on in the network (for example, to see airdrops as they happen or oracles posting new information).
+You can run:
+- `oura watch cardano <socket>` to print Cardano transaction data into the terminal from the tip of a local or remote node
+- `oura watch bitcoin <rpc_host>` to watch Bitcoin blockchain events
+- `oura watch ethereum <url>` to watch Ethereum blockchain events via WebSocket.
+
+These commands are useful as debugging tools for developers or if you're just curious to see what's going on in the network (for example, to see airdrops as they happen or oracles posting new information).
 
 ### As a Bridge to Other Persistence Mechanisms
 

README.md

@@ -24,7 +24,12 @@ The data pipeline makes heavy use (maybe a bit too much) of multi-threading and
 
 ### CLI to Watch Live Transactions
 
-You can run `oura watch cardano <socket>` to print Cardano transaction data into the terminal from the tip of a local or remote node, or `oura watch bitcoin <rpc_host>` to watch Bitcoin blockchain events. These commands are useful as debugging tools for developers or if you're just curious to see what's going on in the network (for example, to see airdrops as they happen or oracles posting new information).
+You can run: 
+- `oura watch cardano <socket>` to print Cardano transaction data into the terminal from the tip of a local or remote node
+- `oura watch bitcoin <rpc_host>` to watch Bitcoin blockchain events
+- `oura watch ethereum <url>` to watch Ethereum blockchain events via WebSocket.
+
+These commands are useful as debugging tools for developers or if you're just curious to see what's going on in the network (for example, to see airdrops as they happen or oracles posting new information).
 
 ### As a Bridge to Other Persistence Mechanisms
 

docs/v3/index.mdx

@@ -1,7 +1,5 @@
 ---
 title: Bitcoin RPC
-sidebar:
-  label: Bitcoin
 ---
 
 The Bitcoin RPC source connects to a Bitcoin Core node via JSON-RPC to fetch block data. It polls the node at regular intervals to detect new blocks and streams them through the Oura pipeline.
@@ -12,7 +10,7 @@ The following snippet shows an example of how to set up a Bitcoin RPC source:
 
 ```toml
 [source]
-type = "Bitcoin"
+type = "bitcoin-rpc"
 rpc_url = "http://localhost:8332"
 rpc_user = "myuser"
 rpc_password = "mypassword"
@@ -21,7 +19,7 @@ rpc_interval = 30
 
 ### Section `source`:
 
-- `type`: this field must be set to the literal value `Bitcoin`.
+- `type`: this field must be set to the literal value `bitcoin-rpc`.
 - `rpc_url`: the URL of the Bitcoin RPC server (required).
 - `rpc_user`: username for RPC authentication (optional).
 - `rpc_password`: password for RPC authentication (optional).
@@ -37,7 +35,7 @@ The Bitcoin RPC source supports optional authentication. If your Bitcoin node re
 
 ```toml
 [source]
-type = "Bitcoin"
+type = "bitcoin-rpc"
 rpc_url = "http://localhost:8332"
 rpc_user = "bitcoinrpc"
 rpc_password = "mypassword123"
@@ -48,7 +46,7 @@ rpc_interval = 30
 
 ```toml
 [source]
-type = "Bitcoin"
+type = "bitcoin-rpc"
 rpc_url = "http://public-bitcoin-node.example.com:8332"
 rpc_interval = 60
 ```
@@ -57,7 +55,7 @@ rpc_interval = 60
 
 ```toml
 [source]
-type = "Bitcoin"
+type = "bitcoin-rpc"
 rpc_url = "http://localhost:18332"
 rpc_user = "testuser"
 rpc_password = "testpass"