Blobstream integration (#8)

* feat(celestiada): add DAVerifier type

* feat: add DaVerifier logic

* chore: forge init

* forge install: forge-std

v1.8.2

* forge install: blobstream-contracts

v4.1.0

* add BlobstreamVerifier contracts

- add /celestia/verify/:txHash endpoint

* deploy sepolia verifier contract and use public rpc

* add contribution

Author: 0xRampey

.gitmodules

@@ -0,0 +1,6 @@
+[submodule "celestiada/verify/contracts/lib/forge-std"]
+	path = celestiada/verify/contracts/lib/forge-std
+	url = https://github.com/foundry-rs/forge-std
+[submodule "celestiada/verify/contracts/lib/blobstream-contracts"]
+	path = celestiada/verify/contracts/lib/blobstream-contracts
+	url = https://github.com/celestiaorg/blobstream-contracts

README.md

@@ -76,5 +76,6 @@ cp .env.example .env
 
 ## Built with
 - `go-da` and `celestia-da` libraries from [Rollkit](https://github.com/rollkit/go-da)
+- `blobstreamx-example` repo from [CryptoKass](https://github.com/CryptoKass/blobstreamx-example)
 
 

celestiada/verify/bindings/BlobstreamVerifier/BlobstreamVerifier.go

@@ -0,0 +1,87 @@
+package verify
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/stackrlabs/go-daash/celestiada/verify/bindings/blobstreamx"
+
+	"github.com/ethereum/go-ethereum/accounts/abi/bind"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/ethclient"
+)
+
+const maxFilterRange = uint64(10_000)
+
+// GetDataCommitment returns the data commitment event matching the given height
+// within the last `blocks` blocks.
+// Example usage:
+//
+//	dataCommitment, err := GetDataCommitment(eth, 10000, 90_000 )
+//
+// Please note this method will make atleast blocks/maxFilterRange calls to the
+// Ethereum node
+func GetDataCommitment(eth *ethclient.Client, height int64, blocks uint64, blobstreamxContract common.Address) (*blobstreamx.BlobstreamXDataCommitmentStored, error) {
+	ctx := context.Background()
+
+	contract, err := blobstreamx.NewBlobstreamX(blobstreamxContract, eth)
+	if err != nil {
+		return nil, fmt.Errorf("failed to instantiate contract: %w", err)
+	}
+
+	head, err := eth.BlockNumber(ctx)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get block number: %w", err)
+	}
+
+	if uint64(head) < blocks {
+		blocks = uint64(head)
+	}
+
+	fmt.Printf("Scanning from Head block: %d Block Range: %d\n", head, blocks)
+
+	// Scan backwards
+	// Scan in chunks of `maxFilterRange` blocks
+	// Stop when we reach `head - scanRange`
+	for end := uint64(head); end > uint64(head)-blocks; end -= maxFilterRange {
+		start := end - maxFilterRange
+		if start < uint64(head)-blocks {
+			start = uint64(head) - blocks
+		}
+
+		dataCommitment, err := findMatchingDataCommitment(contract, start, end, height)
+		if err != nil {
+			return nil, fmt.Errorf("failed to find matching data commitment: %w", err)
+		}
+		if dataCommitment != nil {
+			return dataCommitment, nil
+		}
+	}
+
+	return nil, fmt.Errorf("no matching data commitment found")
+}
+
+func findMatchingDataCommitment(contract *blobstreamx.BlobstreamX, start uint64, end uint64, height int64) (*blobstreamx.BlobstreamXDataCommitmentStored, error) {
+	// fmt.Printf("Scanning blocks %d to %d\n", start, end)
+
+	// Filter events
+	events, err := contract.FilterDataCommitmentStored(&bind.FilterOpts{
+		Context: context.Background(),
+		Start:   start,
+		End:     &end,
+	}, nil, nil, nil)
+	if err != nil {
+		return nil, fmt.Errorf("failed to filter events: %w", err)
+	}
+	defer events.Close()
+
+	// loop through events and return the first matching event
+	for events.Next() {
+		e := events.Event
+		if int64(e.StartBlock) <= height && height < int64(e.EndBlock) {
+			return e, nil
+		}
+	}
+
+	return nil, nil
+}

celestiada/verify/bindings/BlobstreamX/BlobstreamX.go

@@ -0,0 +1,34 @@
+name: test
+
+on: workflow_dispatch
+
+env:
+  FOUNDRY_PROFILE: ci
+
+jobs:
+  check:
+    strategy:
+      fail-fast: true
+
+    name: Foundry project
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+        with:
+          submodules: recursive
+
+      - name: Install Foundry
+        uses: foundry-rs/foundry-toolchain@v1
+        with:
+          version: nightly
+
+      - name: Run Forge build
+        run: |
+          forge --version
+          forge build --sizes
+        id: build
+
+      - name: Run Forge tests
+        run: |
+          forge test -vvv
+        id: test

celestiada/verify/commitment.go

@@ -0,0 +1,14 @@
+# Compiler files
+cache/
+out/
+
+# Ignores development broadcast logs
+!/broadcast
+/broadcast/*/31337/
+/broadcast/**/dry-run/
+
+# Docs
+docs/
+
+# Dotenv file
+.env

celestiada/verify/contracts/.github/workflows/test.yml

@@ -0,0 +1,66 @@
+## Foundry
+
+**Foundry is a blazing fast, portable and modular toolkit for Ethereum application development written in Rust.**
+
+Foundry consists of:
+
+-   **Forge**: Ethereum testing framework (like Truffle, Hardhat and DappTools).
+-   **Cast**: Swiss army knife for interacting with EVM smart contracts, sending transactions and getting chain data.
+-   **Anvil**: Local Ethereum node, akin to Ganache, Hardhat Network.
+-   **Chisel**: Fast, utilitarian, and verbose solidity REPL.
+
+## Documentation
+
+https://book.getfoundry.sh/
+
+## Usage
+
+### Build
+
+```shell
+$ forge build
+```
+
+### Test
+
+```shell
+$ forge test
+```
+
+### Format
+
+```shell
+$ forge fmt
+```
+
+### Gas Snapshots
+
+```shell
+$ forge snapshot
+```
+
+### Anvil
+
+```shell
+$ anvil
+```
+
+### Deploy
+
+```shell
+$ forge script script/Counter.s.sol:CounterScript --rpc-url <your_rpc_url> --private-key <your_private_key>
+```
+
+### Cast
+
+```shell
+$ cast <subcommand>
+```
+
+### Help
+
+```shell
+$ forge --help
+$ anvil --help
+$ cast --help
+```

celestiada/verify/contracts/.gitignore

@@ -0,0 +1,6 @@
+[profile.default]
+src = "src"
+out = "out"
+libs = ["lib"]
+
+# See more config options https://github.com/foundry-rs/foundry/blob/master/crates/config/README.md#all-options