Add Autobahn fullnode (CON-309)

.github/workflows/integration-test.yml

@@ -547,10 +547,82 @@ jobs:
           path: integration_test/rpc_tests/reports/merged
           if-no-files-found: ignore
 
+  # Autobahn integration suite (Autobahn Basic) — boots its own cluster via
+  # TestMain (docker-cluster-start / -stop), so it runs in a separate job
+  # rather than as a matrix entry that would share the integration-tests
+  # cluster.
+  autobahn-integration-tests:
+    name: Integration Test (Autobahn Basic)
+    runs-on: ubuntu-large
+    timeout-minutes: 45
+    needs: prepare-cluster
+    permissions:
+      packages: read
+      contents: read
+    env:
+      GHCR_LOCALNODE: ghcr.io/sei-protocol/sei-chain-integration-test-localnode
+      GHCR_RPCNODE: ghcr.io/sei-protocol/sei-chain-integration-test-rpcnode
+    steps:
+      - uses: actions/checkout@v5
+      - uses: actions/setup-go@v6
+        with:
+          go-version: '1.25.6'
+      - name: Install jq
+        run: sudo apt-get install -y jq
+      - name: Login to Docker Hub
+        uses: docker/login-action@v3
+        if: env.DOCKERHUB_USERNAME != ''
+        env:
+          DOCKERHUB_USERNAME: ${{ secrets.DOCKERHUB_USERNAME }}
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v3
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+      - name: Download integration CI artifacts
+        uses: actions/download-artifact@v4
+        with:
+          name: integration-ci-artifacts
+      - name: Load prebuilt seid and pull Docker images
+        run: |
+          tar -xzf integration-build.tar.gz
+          docker pull "${GHCR_LOCALNODE}:${{ github.run_id }}"
+          docker pull "${GHCR_RPCNODE}:${{ github.run_id }}"
+          docker tag "${GHCR_LOCALNODE}:${{ github.run_id }}" sei-chain/localnode
+          docker tag "${GHCR_RPCNODE}:${{ github.run_id }}" sei-chain/rpcnode
+      - name: Run autobahn integration tests
+        run: make autobahn-integration-test
+      - name: Print node logs on failure
+        if: ${{ failure() }}
+        run: |
+          set -euo pipefail
+          for c in sei-node-0 sei-node-1 sei-node-2 sei-node-3 sei-rpc-node; do
+            echo "==================== ${c} (docker logs tail) ===================="
+            docker logs --tail 200 "${c}" || true
+          done
+      - name: Collect logs directory
+        if: ${{ always() }}
+        run: |
+          mkdir -p artifacts/sei-autobahn-integration
+          if [ -d build/generated/logs ]; then
+            cp -r build/generated/logs artifacts/sei-autobahn-integration/
+          fi
+      - name: Upload logs directory
+        if: ${{ always() }}
+        uses: actions/upload-artifact@v4
+        with:
+          name: integration-logs-autobahn-integration
+          path: artifacts/sei-autobahn-integration
+          if-no-files-found: warn
+
   integration-test-check:
     name: Integration Test Check
     runs-on: ubuntu-latest
-    needs: [prepare-cluster, integration-tests]
+    needs: [prepare-cluster, integration-tests, autobahn-integration-tests]
     if: always()
     steps:
       - name: Verify prepare and test jobs succeeded
@@ -563,4 +635,8 @@ jobs:
             echo "integration-tests job did not succeed (${{ needs.integration-tests.result }})"
             exit 1
           fi
+          if [[ "${{ needs.autobahn-integration-tests.result }}" != "success" ]]; then
+            echo "autobahn-integration-tests job did not succeed (${{ needs.autobahn-integration-tests.result }})"
+            exit 1
+          fi
           echo "All integration test jobs passed."

Makefile

@@ -6,7 +6,7 @@
 # - Prefer tag if bases are equal; otherwise use whichever base is newer.
 BRANCH_NAME := $(shell git rev-parse --abbrev-ref HEAD)
 BRANCH_VERSION := $(shell echo "$(BRANCH_NAME)" | sed -E -n 's|.*(v[0-9]+\.[0-9]+\.[0-9]+[-A-Za-z0-9._]*).*|\1|p')
-TAG_VERSION := $(shell echo $(shell git describe --tags))
+TAG_VERSION := $(shell echo $(shell git describe --tags 2>/dev/null))
 VERSION := $(shell \
 	bv="$(BRANCH_VERSION)"; tv="$(TAG_VERSION)"; \
 	bb=$$(echo "$$bv" | sed 's/^\(v[0-9][0-9]*\.[0-9][0-9]*\.[0-9][0-9]*\).*/\1/'); \
@@ -225,13 +225,13 @@ build-docker-node:
 .PHONY: build-docker-node
 
 build-rpc-node:
-	@cd docker && docker build --tag sei-chain/rpcnode rpcnode --platform linux/x86_64
+	@cd docker && docker build --tag sei-chain/rpcnode rpcnode --platform $(DOCKER_PLATFORM)
 .PHONY: build-rpc-node
 
-# Integration-test CI: verify images loaded from prepare-cluster artifacts.
+# Integration-test CI: verify images pulled from GHCR by the matrix job.
 ensure-integration-ci-images:
-	@docker image inspect sei-chain/localnode >/dev/null 2>&1 || (echo "sei-chain/localnode image missing; load integration-docker-images.tar.zst from prepare-cluster" && exit 1)
-	@docker image inspect sei-chain/rpcnode >/dev/null 2>&1 || (echo "sei-chain/rpcnode image missing; load integration-docker-images.tar.zst from prepare-cluster" && exit 1)
+	@docker image inspect sei-chain/localnode >/dev/null 2>&1 || (echo "sei-chain/localnode image missing; pull from GHCR (see prepare-cluster job)" && exit 1)
+	@docker image inspect sei-chain/rpcnode >/dev/null 2>&1 || (echo "sei-chain/rpcnode image missing; pull from GHCR (see prepare-cluster job)" && exit 1)
 .PHONY: ensure-integration-ci-images
 
 # Build seid once inside the localnode image (integration-test prepare job).
@@ -279,7 +279,7 @@ run-local-node: kill-sei-node build-docker-node
 	-v $(PROJECT_HOME):/sei-protocol/sei-chain:Z \
 	-v $(GO_PKG_PATH)/mod:/root/go/pkg/mod:Z \
 	-v $(shell go env GOCACHE):/root/.cache/go-build:Z \
-	--platform linux/x86_64 \
+	--platform $(DOCKER_PLATFORM) \
 	sei-chain/localnode
 .PHONY: run-local-node
 
@@ -296,9 +296,11 @@ run-rpc-node: build-rpc-node
 	-v $(GO_PKG_PATH)/mod:/root/go/pkg/mod:Z \
 	-v $(shell go env GOCACHE):/root/.cache/go-build:Z \
 	-p 26668-26670:26656-26658 \
-	--platform linux/x86_64 \
+	--platform $(DOCKER_PLATFORM) \
 	--env GIGA_STORAGE=${GIGA_STORAGE} \
 	--env GIGA_FLATKV_ONLY=${GIGA_FLATKV_ONLY} \
+	--env AUTOBAHN=${AUTOBAHN} \
+	--env CLUSTER_SIZE=${CLUSTER_SIZE} \
 	--env RECEIPT_BACKEND=${RECEIPT_BACKEND} \
 	sei-chain/rpcnode
 .PHONY: run-rpc-node
@@ -315,10 +317,12 @@ run-rpc-node-skipbuild: build-rpc-node
 	-v $(GO_PKG_PATH)/mod:/root/go/pkg/mod:Z \
 	-v $(shell go env GOCACHE):/root/.cache/go-build:Z \
 	-p 26668-26670:26656-26658 \
-	--platform linux/x86_64 \
+	--platform $(DOCKER_PLATFORM) \
 	--env SKIP_BUILD=true \
 	--env GIGA_STORAGE=${GIGA_STORAGE} \
 	--env GIGA_FLATKV_ONLY=${GIGA_FLATKV_ONLY} \
+	--env AUTOBAHN=${AUTOBAHN} \
+	--env CLUSTER_SIZE=${CLUSTER_SIZE} \
 	--env RECEIPT_BACKEND=${RECEIPT_BACKEND} \
 	sei-chain/rpcnode
 .PHONY: run-rpc-node
@@ -345,7 +349,7 @@ run-rpc-node-integration-ci: kill-rpc-node ensure-integration-ci-images
 	-v $(GO_PKG_PATH)/mod:/root/go/pkg/mod:Z \
 	-v $(shell go env GOCACHE):/root/.cache/go-build:Z \
 	-p 26668-26670:26656-26658 \
-	--platform linux/x86_64 \
+	--platform $(DOCKER_PLATFORM) \
 	--env SKIP_BUILD=true \
 	--env GIGA_STORAGE=${GIGA_STORAGE} \
 	--env GIGA_FLATKV_ONLY=${GIGA_FLATKV_ONLY} \

docker/rpcnode/scripts/step1_configure_init.sh

@@ -1,4 +1,14 @@
 #!/usr/bin/env sh
+#
+# rpcnode init script for the integration-test docker setup. NOT a
+# production deploy script. Best-effort by design — curl probes against
+# the validator RPC are allowed to fail (the script proceeds with
+# whatever values came back, the container then converges as the cluster
+# stabilises). The few cases where we DO want fail-fast — genesis file
+# missing after the bounded wait, autobahn validator dirs missing — are
+# guarded by explicit `if [ ! -f ]; exit 1` checks below. Don't add
+# `set -e`: it makes those transient curl probes fatal and breaks
+# init when the cluster is still warming up.
 
 # Set up GO PATH
 echo "Configure and initialize environment"
@@ -7,14 +17,30 @@ echo "Configure and initialize environment"
 seid version # Uncomment the below line if there are any dependency issues
 # ldd build/seid
 
-# Initialize validator node
+# Initialize validator node. --overwrite so this is safe to re-run inside
+# a recycled container; the script writes new configs over whatever was
+# already on the previous run.
 MONIKER="sei-rpc-node"
-seid init --chain-id sei "$MONIKER"
+seid init --overwrite --chain-id sei "$MONIKER"
+
+# Wait for the chain genesis.json (validator step3 writes it). The test
+# setup may spawn the rpc node in parallel with the cluster, so this can
+# still be missing here — poll up to 5 minutes.
+GENESIS_SRC="build/generated/genesis.json"
+i=0
+while [ ! -f "$GENESIS_SRC" ] && [ "$i" -lt 300 ]; do
+  sleep 1
+  i=$((i + 1))
+done
+if [ ! -f "$GENESIS_SRC" ]; then
+  echo "ERROR: $GENESIS_SRC missing after 5 minutes; aborting." >&2
+  exit 1
+fi
 
 # Copy configs
 cp docker/rpcnode/config/app.toml ~/.sei/config/app.toml
 cp docker/rpcnode/config/config.toml ~/.sei/config/config.toml
-cp build/generated/genesis.json ~/.sei/config/genesis.json
+cp "$GENESIS_SRC" ~/.sei/config/genesis.json
 
 # Apply Giga Storage overrides so the RPC node's app hash matches the validators.
 GIGA_STORAGE=${GIGA_STORAGE:-false}
@@ -59,6 +85,55 @@ if [ -n "$RECEIPT_BACKEND" ]; then
   fi
 fi
 
+# Generate Autobahn (GigaRouter) config when the validators are running
+# Autobahn consensus. The RPC node uses mode = "full" (see config.toml),
+# which makes it an fullnode autobahn participant — loads the committee
+# for routing only and forwards eth_sendRawTransaction to the shard owner.
+# Reuse the validator node directories under build/generated/ (mounted
+# into the container) so the committee description matches the cluster.
+AUTOBAHN=${AUTOBAHN:-false}
+if [ "$AUTOBAHN" = "true" ]; then
+  echo "Generating Autobahn config for RPC node (fullnode via mode=full)..."
+  AUTOBAHN_CONFIG="$HOME/.sei/config/autobahn.json"
+
+  # Default to 4 (the docker-compose cluster size) when CLUSTER_SIZE is unset.
+  CLUSTER_SIZE=${CLUSTER_SIZE:-4}
+  NODE_DIRS=""
+  i=0
+  while [ "$i" -lt "$CLUSTER_SIZE" ]; do
+    NODE_DIRS="$NODE_DIRS build/generated/node_${i}"
+    i=$((i + 1))
+  done
+
+  # Wait for each validator dir to be fully populated. gen-autobahn-config
+  # reads validator_pubkey, node_pubkey, autobahn_address, evmrpc_url; the
+  # rpc container can be spawned in parallel with the cluster, so any of
+  # these may not yet exist. Poll up to 5 minutes for evmrpc_url.txt (the
+  # autobahn-specific file each validator step writes last).
+  for d in $NODE_DIRS; do
+    i=0
+    while [ ! -f "$d/evmrpc_url.txt" ] && [ "$i" -lt 300 ]; do
+      sleep 1
+      i=$((i + 1))
+    done
+    if [ ! -f "$d/evmrpc_url.txt" ]; then
+      echo "ERROR: $d/evmrpc_url.txt missing after 5 minutes; aborting." >&2
+      exit 1
+    fi
+  done
+
+  seid tendermint gen-autobahn-config $NODE_DIRS --output "$AUTOBAHN_CONFIG"
+
+  # Inject autobahn-config-file as a top-level key in config.toml. It must
+  # precede any [section] header so the TOML parser sees it at root scope.
+  if grep -q "autobahn-config-file" ~/.sei/config/config.toml; then
+    sed -i 's|autobahn-config-file = .*|autobahn-config-file = "'"$AUTOBAHN_CONFIG"'"|' ~/.sei/config/config.toml
+  else
+    sed -i '1s|^|autobahn-config-file = "'"$AUTOBAHN_CONFIG"'"\n|' ~/.sei/config/config.toml
+  fi
+  echo "Autobahn config written to $AUTOBAHN_CONFIG (fullnode via mode=full)"
+fi
+
 # Override state sync configs
 STATE_SYNC_RPC="192.168.10.10:26657"
 STATE_SYNC_PEER="2f9846450b7a3dcf4af1ac0082e3279c16744df8@172.31.9.18:26656,ec98c4a28a2023f4f976828c8a8e7127bfef4e1b@172.31.4.96:26656,b03014d67384fb0ef6ad992c77cefe4f9d2c1640@172.31.4.219:26656"

evmrpc/block_txcount_parity_test.go

@@ -17,6 +17,7 @@ import (
 	"github.com/sei-protocol/sei-chain/sei-cosmos/client"
 	sdk "github.com/sei-protocol/sei-chain/sei-cosmos/types"
 	tmbytes "github.com/sei-protocol/sei-chain/sei-tendermint/libs/bytes"
+	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/utils"
 	tmmock "github.com/sei-protocol/sei-chain/sei-tendermint/rpc/client/mock"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/coretypes"
 	tmtypes "github.com/sei-protocol/sei-chain/sei-tendermint/types"
@@ -40,8 +41,8 @@ func (*parityTxCountTMClient) EvmTxByHash(common.Hash) (tmtypes.Tx, bool) {
 	return nil, false
 }
 
-func (*parityTxCountTMClient) EvmProxy(common.Address) (*url.URL, bool) {
-	return nil, false
+func (*parityTxCountTMClient) EvmProxy(common.Address) utils.Option[*url.URL] {
+	return utils.None[*url.URL]()
 }
 
 func (c *parityTxCountTMClient) Block(_ context.Context, h *int64) (*coretypes.ResultBlock, error) {

evmrpc/height_availability_test.go

@@ -13,6 +13,7 @@ import (
 	"github.com/sei-protocol/sei-chain/sei-cosmos/client"
 	sdk "github.com/sei-protocol/sei-chain/sei-cosmos/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/bytes"
+	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/utils"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/client/mock"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/coretypes"
 	tmtypes "github.com/sei-protocol/sei-chain/sei-tendermint/types"
@@ -38,8 +39,8 @@ func (*heightTestClient) EvmTxByHash(common.Hash) (tmtypes.Tx, bool) {
 	return nil, false
 }
 
-func (*heightTestClient) EvmProxy(common.Address) (*url.URL, bool) {
-	return nil, false
+func (*heightTestClient) EvmProxy(common.Address) utils.Option[*url.URL] {
+	return utils.None[*url.URL]()
 }
 
 func newHeightTestClient(highHeight, earliest, latest int64) *heightTestClient {

evmrpc/send.go

@@ -92,7 +92,7 @@ func (s *SendAPI) SendRawTransaction(ctx context.Context, input hexutil.Bytes) (
 	// but we still need to handle it.
 	sender, senderErr := getSender(tx, s.keeper.ChainID(s.ctxProvider(LatestCtxHeight)))
 	if senderErr == nil {
-		if url, ok := s.tmClient.EvmProxy(sender); ok {
+		if url, ok := s.tmClient.EvmProxy(sender).Get(); ok {
 			recordRedirectedRequest(ctx, "eth_sendRawTransaction", string(s.connectionType))
 			// HTTP transport pooling already happens globally underneath net/http, so
 			// creating a fresh RPC client per proxied request is fine here. If we

evmrpc/send_test.go

@@ -30,11 +30,11 @@ type sendProxyClient struct {
 	proxyURL *url.URL
 }
 
-func (c *sendProxyClient) EvmProxy(common.Address) (*url.URL, bool) {
+func (c *sendProxyClient) EvmProxy(common.Address) utils.Option[*url.URL] {
 	if c.proxyURL == nil {
-		return nil, false
+		return utils.None[*url.URL]()
 	}
-	return c.proxyURL, true
+	return utils.Some(c.proxyURL)
 }
 
 func TestMnemonicToPrivateKey(t *testing.T) {

evmrpc/setup_test.go

@@ -31,6 +31,7 @@ import (
 	sdkerrors "github.com/sei-protocol/sei-chain/sei-cosmos/types/errors"
 	abci "github.com/sei-protocol/sei-chain/sei-tendermint/abci/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/bytes"
+	tmutils "github.com/sei-protocol/sei-chain/sei-tendermint/libs/utils"
 	types2 "github.com/sei-protocol/sei-chain/sei-tendermint/proto/tendermint/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/client/mock"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/coretypes"
@@ -158,8 +159,8 @@ func (*MockClient) EvmTxByHash(hash common.Hash) (tmtypes.Tx, bool) {
 	return tx, true
 }
 
-func (*MockClient) EvmProxy(common.Address) (*url.URL, bool) {
-	return nil, false
+func (*MockClient) EvmProxy(common.Address) tmutils.Option[*url.URL] {
+	return tmutils.None[*url.URL]()
 }
 
 func NewMockClientWithLatest(latest int64) *MockClient {

evmrpc/simulate_test.go

@@ -30,6 +30,7 @@ import (
 	receipt "github.com/sei-protocol/sei-chain/sei-db/ledger_db/receipt"
 	abci "github.com/sei-protocol/sei-chain/sei-tendermint/abci/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/bytes"
+	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/utils"
 	tenderminttypes "github.com/sei-protocol/sei-chain/sei-tendermint/proto/tendermint/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/client/mock"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/coretypes"
@@ -882,8 +883,8 @@ func (c *fixedBlockClient) EvmTxByHash(common.Hash) (tmtypes.Tx, bool) {
 	return nil, false
 }
 
-func (c *fixedBlockClient) EvmProxy(common.Address) (*url.URL, bool) {
-	return nil, false
+func (c *fixedBlockClient) EvmProxy(common.Address) utils.Option[*url.URL] {
+	return utils.None[*url.URL]()
 }
 
 func (c *fixedBlockClient) Block(_ context.Context, _ *int64) (*coretypes.ResultBlock, error) {

evmrpc/tests/mock_client.go

@@ -16,6 +16,7 @@ import (
 	"github.com/sei-protocol/sei-chain/evmrpc"
 	abci "github.com/sei-protocol/sei-chain/sei-tendermint/abci/types"
 	tmbytes "github.com/sei-protocol/sei-chain/sei-tendermint/libs/bytes"
+	"github.com/sei-protocol/sei-chain/sei-tendermint/libs/utils"
 	tmproto "github.com/sei-protocol/sei-chain/sei-tendermint/proto/tendermint/types"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/client/mock"
 	"github.com/sei-protocol/sei-chain/sei-tendermint/rpc/coretypes"
@@ -45,8 +46,8 @@ func (*MockClient) EvmTxByHash(common.Hash) (tmtypes.Tx, bool) {
 	return nil, false
 }
 
-func (c *MockClient) EvmProxy(common.Address) (*url.URL, bool) {
-	return nil, false
+func (c *MockClient) EvmProxy(common.Address) utils.Option[*url.URL] {
+	return utils.None[*url.URL]()
 }
 
 func (c *MockClient) Block(_ context.Context, h *int64) (*coretypes.ResultBlock, error) {

evmrpc/tx.go

@@ -346,7 +346,7 @@ func (t *TransactionAPI) GetTransactionCount(ctx context.Context, address common
 	}()
 
 	if blockNrOrHash.BlockHash == nil && *blockNrOrHash.BlockNumber == rpc.PendingBlockNumber {
-		if url, ok := t.tmClient.EvmProxy(address); ok {
+		if url, ok := t.tmClient.EvmProxy(address).Get(); ok {
 			recordRedirectedRequest(ctx, "eth_getTransactionCount", string(t.connectionType))
 
 			// HTTP transport pooling already happens globally underneath net/http, so