Import saturn branch history from rocketpool-go

bindings/README.md

@@ -0,0 +1,2 @@
+# rocketpool-go
+A Golang library for interacting with the Rocket Pool network.

bindings/azure-pipelines.yml

@@ -0,0 +1,36 @@
+# Go
+# Build your Go project.
+# Add steps that test, save build artifacts, deploy, and more:
+# https://docs.microsoft.com/azure/devops/pipelines/languages/go
+
+trigger:
+  branches:
+    include:
+      - '*'
+      - refs/tags/*
+
+pool:
+  vmImage: ubuntu-latest
+
+steps:
+- task: DownloadSecureFile@1
+  name: githubPEM
+  displayName: 'Download Github PEM'
+  inputs:
+    secureFile: 'rp-azure-pipeline-github.pem'
+- bash: |
+    eval $(ruby -e "require 'openssl'; require 'jwt'; private_pem = File.read(ENV['GITHUB_PEM_PATH']); private_key = OpenSSL::PKey::RSA.new(private_pem); payload = { iat: Time.now.to_i - 60, exp: Time.now.to_i + (10 * 60), iss: ENV['GITHUB_APP_ID'] }; jwt = JWT.encode(payload, private_key, 'RS256'); puts 'PUSH_JWT='+jwt;")
+    TOKEN=$(curl -s -X POST \
+      -H "Authorization: Bearer $PUSH_JWT" \
+      -H "Accept: application/vnd.github.v3+json" \
+      https://api.github.com/app/installations/$GITHUB_APP_INSTALLATION_ID/access_tokens \
+      | jq -r '.token')
+      git remote add github https://x-access-token:$TOKEN@github.com/rocket-pool/$REPO_NAME
+      git fetch github
+      git push github HEAD:$(Build.SourceBranch) -f --verbose
+      git push github HEAD:$(Build.SourceBranch) --tags --verbose
+  displayName: 'Push to Github'
+  env:
+    GITHUB_PEM_PATH: $(githubPEM.secureFilePath)
+    GITHUB_APP_ID: $(GITHUB_APP_ID)
+    GITHUB_APP_INSTALLATION_ID: $(GITHUB_APP_INSTALLATION_ID)

bindings/deposit/deposit-pool.go

@@ -0,0 +1,89 @@
+package deposit
+
+import (
+	"fmt"
+	"math/big"
+
+	"github.com/ethereum/go-ethereum/accounts/abi/bind"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/rocket-pool/smartnode/bindings/rocketpool"
+)
+
+// Estimate the gas required to exit the validator queue
+func EstimateExitQueueGas(rp *rocketpool.RocketPool, validatorIndex uint64, expressQueue bool, opts *bind.TransactOpts) (rocketpool.GasInfo, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, nil)
+	if err != nil {
+		return rocketpool.GasInfo{}, err
+	}
+	validatorIndexBig := big.NewInt(int64(validatorIndex))
+	return rocketDepositPool.GetTransactionGasInfo(opts, "exitQueue", validatorIndexBig, expressQueue)
+}
+
+// Exit the validator queue
+func ExitQueue(rp *rocketpool.RocketPool, validatorIndex uint64, expressQueue bool, opts *bind.TransactOpts) (common.Hash, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, nil)
+	if err != nil {
+		return common.Hash{}, err
+	}
+	validatorIndexBig := big.NewInt(int64(validatorIndex))
+	tx, err := rocketDepositPool.Transact(opts, "exitQueue", validatorIndexBig, expressQueue)
+	if err != nil {
+		return common.Hash{}, fmt.Errorf("error exiting validator queue: %w", err)
+	}
+	return tx.Hash(), nil
+}
+
+// Struct to hold queue top (address of the validator at the top of the queue and a boolean indicating if the assignment is possible)
+type QueueTop struct {
+	Receiver           common.Address `abi:"receiver"`
+	AssignmentPossible bool           `abi:"assignmentPossible"`
+	HeadMovedBlock     *big.Int       `abi:"headMovedBlock"`
+}
+
+func GetQueueTop(rp *rocketpool.RocketPool, opts *bind.CallOpts) (QueueTop, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, opts)
+	if err != nil {
+		return QueueTop{}, err
+	}
+	queueTop := new(QueueTop)
+	if err := rocketDepositPool.Call(opts, queueTop, "getQueueTop"); err != nil {
+		return QueueTop{}, fmt.Errorf("error getting queue top: %w", err)
+	}
+	return *queueTop, nil
+}
+
+func GetTotalQueueLength(rp *rocketpool.RocketPool, opts *bind.CallOpts) (uint32, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, opts)
+	if err != nil {
+		return 0, err
+	}
+	totalLength := new(*big.Int)
+	if err := rocketDepositPool.Call(opts, totalLength, "getTotalQueueLength"); err != nil {
+		return 0, fmt.Errorf("error getting total queue length: %w", err)
+	}
+	return uint32((*totalLength).Uint64()), nil
+}
+
+func GetExpressQueueLength(rp *rocketpool.RocketPool, opts *bind.CallOpts) (uint32, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, opts)
+	if err != nil {
+		return 0, err
+	}
+	length := new(*big.Int)
+	if err := rocketDepositPool.Call(opts, length, "getExpressQueueLength"); err != nil {
+		return 0, fmt.Errorf("error getting express queue length: %w", err)
+	}
+	return uint32((*length).Uint64()), nil
+}
+
+func GetStandardQueueLength(rp *rocketpool.RocketPool, opts *bind.CallOpts) (uint32, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, opts)
+	if err != nil {
+		return 0, err
+	}
+	length := new(*big.Int)
+	if err := rocketDepositPool.Call(opts, length, "getStandardQueueLength"); err != nil {
+		return 0, fmt.Errorf("error getting standard queue length: %w", err)
+	}
+	return uint32((*length).Uint64()), nil
+}

bindings/deposit/deposit.go

@@ -73,21 +73,21 @@ func Deposit(rp *rocketpool.RocketPool, opts *bind.TransactOpts) (common.Hash, e
 }
 
 // Estimate the gas of AssignDeposits
-func EstimateAssignDepositsGas(rp *rocketpool.RocketPool, opts *bind.TransactOpts) (rocketpool.GasInfo, error) {
+func EstimateAssignDepositsGas(rp *rocketpool.RocketPool, max *big.Int, opts *bind.TransactOpts) (rocketpool.GasInfo, error) {
 	rocketDepositPool, err := getRocketDepositPool(rp, nil)
 	if err != nil {
 		return rocketpool.GasInfo{}, err
 	}
-	return rocketDepositPool.GetTransactionGasInfo(opts, "assignDeposits")
+	return rocketDepositPool.GetTransactionGasInfo(opts, "assignDeposits", max)
 }
 
 // Assign deposits
-func AssignDeposits(rp *rocketpool.RocketPool, opts *bind.TransactOpts) (common.Hash, error) {
+func AssignDeposits(rp *rocketpool.RocketPool, max *big.Int, opts *bind.TransactOpts) (common.Hash, error) {
 	rocketDepositPool, err := getRocketDepositPool(rp, nil)
 	if err != nil {
 		return common.Hash{}, err
 	}
-	tx, err := rocketDepositPool.Transact(opts, "assignDeposits")
+	tx, err := rocketDepositPool.Transact(opts, "assignDeposits", max)
 	if err != nil {
 		return common.Hash{}, fmt.Errorf("error assigning deposits: %w", err)
 	}
@@ -102,3 +102,11 @@ func getRocketDepositPool(rp *rocketpool.RocketPool, opts *bind.CallOpts) (*rock
 	defer rocketDepositPoolLock.Unlock()
 	return rp.GetContract("rocketDepositPool", opts)
 }
+
+func GetRocketDepositPoolVersion(rp *rocketpool.RocketPool, opts *bind.CallOpts) (uint8, error) {
+	rocketDepositPool, err := getRocketDepositPool(rp, opts)
+	if err != nil {
+		return 0, err
+	}
+	return rocketpool.GetContractVersion(rp, *rocketDepositPool.Address, opts)
+}

bindings/go.mod

@@ -18,6 +18,7 @@ require (
 	github.com/bits-and-blooms/bitset v1.11.0 // indirect
 	github.com/btcsuite/btcd/btcec/v2 v2.3.2 // indirect
 	github.com/cespare/cp v1.1.1 // indirect
+	github.com/cespare/xxhash v1.1.0 // indirect
 	github.com/cespare/xxhash/v2 v2.3.0 // indirect
 	github.com/cheggaaa/pb/v3 v3.0.8 // indirect
 	github.com/cockroachdb/errors v1.11.1 // indirect
@@ -27,12 +28,13 @@ require (
 	github.com/crate-crypto/go-kzg-4844 v0.7.0 // indirect
 	github.com/deckarep/golang-set/v2 v2.5.0 // indirect
 	github.com/decred/dcrd/dcrec/secp256k1/v4 v4.3.0 // indirect
-	github.com/dgraph-io/ristretto v0.1.0 // indirect
+	github.com/dgraph-io/ristretto v0.0.4-0.20210318174700-74754f61e018 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
+	github.com/emicklei/dot v1.6.2 // indirect
 	github.com/emirpasic/gods v1.12.0 // indirect
 	github.com/ethereum/c-kzg-4844 v0.4.0 // indirect
 	github.com/fatih/color v1.14.1 // indirect
-	github.com/ferranbt/fastssz v0.1.3 // indirect
+	github.com/ferranbt/fastssz v0.1.4 // indirect
 	github.com/fsnotify/fsnotify v1.6.0 // indirect
 	github.com/gballet/go-libpcsclite v0.0.0-20191108122812-4678299bea08 // indirect
 	github.com/getsentry/sentry-go v0.25.0 // indirect
@@ -41,7 +43,6 @@ require (
 	github.com/go-git/go-git/v5 v5.3.0 // indirect
 	github.com/go-ole/go-ole v1.3.0 // indirect
 	github.com/go-stack/stack v1.8.1 // indirect
-	github.com/golang/glog v1.1.0 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/gorilla/websocket v1.5.3 // indirect
 	github.com/holiman/uint256 v1.2.4 // indirect
@@ -63,7 +64,6 @@ require (
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/princjef/mageutil v1.0.0 // indirect
 	github.com/prometheus/client_golang v1.20.0 // indirect
-	github.com/protolambda/zssz v0.1.5 // indirect
 	github.com/prysmaticlabs/go-bitfield v0.0.0-20240328144219-a1caa50c3a1e // indirect
 	github.com/rivo/uniseg v0.4.4 // indirect
 	github.com/rogpeppe/go-internal v1.11.0 // indirect
@@ -72,6 +72,7 @@ require (
 	github.com/sergi/go-diff v1.2.0 // indirect
 	github.com/shirou/gopsutil v3.21.11+incompatible // indirect
 	github.com/sirupsen/logrus v1.9.0 // indirect
+	github.com/spaolacci/murmur3 v1.1.0 // indirect
 	github.com/stretchr/testify v1.9.0 // indirect
 	github.com/supranational/blst v0.3.11 // indirect
 	github.com/syndtr/goleveldb v1.0.1-0.20220721030215-126854af5e6d // indirect