Tooling for local london gethnode and local vrfv2 testing (#4986)

* local london gethnode

* Placate linter

core/scripts/vrfv2/deploy-vrfv2/main.go

@@ -0,0 +1,117 @@
+package main
+
+import (
+	"context"
+	"encoding/hex"
+	"fmt"
+	"math/big"
+	"time"
+
+	"github.com/ethereum/go-ethereum/accounts/abi/bind"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/ethereum/go-ethereum/ethclient"
+	"github.com/shopspring/decimal"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/link_token_interface"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/mock_v3_aggregator_contract"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/vrf_consumer_v2"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/vrf_coordinator_v2"
+	"github.com/smartcontractkit/chainlink/core/services/vrf"
+)
+
+func panicErr(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+var weiPerUnitLink = decimal.RequireFromString("10000000000000000")
+var waitForMine = 8 * time.Second
+
+func main() {
+	ec, err := ethclient.Dial("http://127.0.0.1:8545")
+	panicErr(err)
+
+	chainID := int64(34055)
+	// Preloaded devnet key https://github.com/smartcontractkit/devnet/blob/master/passwords.json
+	key, err := crypto.HexToECDSA("34d2ee6c703f755f9a205e322c68b8ff3425d915072ca7483190ac69684e548c")
+	panicErr(err)
+	user, err := bind.NewKeyedTransactorWithChainID(key, big.NewInt(chainID))
+	panicErr(err)
+
+	// --- First time deploy ----
+	// Fund oracle address
+	oracleAddress := "0x5f1bbb70AEeb5754BD68EdF856a7234B232e6858"
+	nonce, err := ec.PendingNonceAt(context.Background(), common.HexToAddress("9ca9d2d5e04012c9ed24c0e513c9bfaa4a2dd77f"))
+	panicErr(err)
+	gasPrice, err := ec.SuggestGasPrice(context.Background())
+	panicErr(err)
+	tx := types.NewTransaction(nonce, common.HexToAddress(oracleAddress), big.NewInt(500000000000000000), uint64(21000), gasPrice, nil)
+	signedTx, err := types.SignTx(tx, types.NewEIP155Signer(big.NewInt(chainID)), key)
+	panicErr(err)
+	err = ec.SendTransaction(context.Background(), signedTx)
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Deploy link
+	linkAddress, _, linkContract, err := link_token_interface.DeployLinkToken(
+		user, ec)
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Deploy feed
+	linkEthFeed, _, _, err :=
+		mock_v3_aggregator_contract.DeployMockV3AggregatorContract(
+			user, ec, 18, weiPerUnitLink.BigInt()) // 0.01 eth per link
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Deploy coordinator
+	coordinatorAddress, _, coordinatorContract, err :=
+		vrf_coordinator_v2.DeployVRFCoordinatorV2(
+			user, ec, linkAddress, common.Address{}, linkEthFeed)
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Set coordinators config
+	_, err = coordinatorContract.SetConfig(user,
+		uint16(1),    // minRequestConfirmations
+		uint32(1000), // 0.0001 link flat fee
+		uint32(1000000),
+		uint32(60*60*24),                       // stalenessSeconds
+		uint32(vrf.GasAfterPaymentCalculation), // gasAfterPaymentCalculation
+		big.NewInt(10000000000000000),          // 0.01 eth per link fallbackLinkPrice
+		big.NewInt(1000000000000000000),        // Minimum subscription balance 0.01 link
+	)
+	panicErr(err)
+	time.Sleep(waitForMine)
+	c, err := coordinatorContract.GetConfig(nil)
+	panicErr(err)
+	fmt.Printf("Coordinator config %+v\n", c)
+	// Deploy consumer
+	consumerContractAddress, _, consumerContract, err :=
+		vrf_consumer_v2.DeployVRFConsumerV2(
+			user, ec, coordinatorAddress, linkAddress)
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Transfer it a link
+	_, err = linkContract.Transfer(user, consumerContractAddress, big.NewInt(1000000000000000000)) // Actually, LINK
+	panicErr(err)
+	time.Sleep(waitForMine)
+	// Create an fund subscription with a link
+	_, err = consumerContract.TestCreateSubscriptionAndFund(user, big.NewInt(1000000000000000000))
+	panicErr(err)
+	time.Sleep(waitForMine)
+	subID, err := consumerContract.SSubId(nil)
+	panicErr(err)
+	fmt.Println("Sub ID", subID)
+	// Register the proving key
+	// Note the 04 is a version byte, it means uncompressed pubkey.
+	pubBytes, err := hex.DecodeString("046bef3bd2b3043e6c8a5d482ed22c23c9c31c05e854676e8856869a54fe781922578f695613f819b8fe71d49401a13470e495ebc62dda8d268a8615fb30e72b95")
+	panicErr(err)
+	pk, err := crypto.UnmarshalPubkey(pubBytes)
+	panicErr(err)
+	_, err = coordinatorContract.RegisterProvingKey(user, common.HexToAddress(oracleAddress), [2]*big.Int{pk.X, pk.Y})
+	panicErr(err)
+	sub, err := coordinatorContract.GetSubscription(nil, subID)
+	panicErr(err)
+	fmt.Printf("Sub %+v\n", sub)
+	fmt.Printf("Coordinator: %v, Link %v, Consumer %v, SubID %v", coordinatorAddress, linkAddress, consumerContractAddress, subID)
+}

core/scripts/vrfv2/get-randomness/main.go

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"fmt"
+	"math/big"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/ethclient"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/vrf_consumer_v2"
+)
+
+func panicErr(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+func main() {
+	consumerAddress := "0x9E79d9A7F68D136ec4c1C0187B97c271CEa6008B"
+	ec, err := ethclient.Dial("ws://127.0.0.1:8546")
+	panicErr(err)
+	consumer, err := vrf_consumer_v2.NewVRFConsumerV2(common.HexToAddress(consumerAddress), ec)
+	panicErr(err)
+	var rw []*big.Int
+	nw := 3
+	var r *big.Int
+	for i := 0; i < nw; i++ {
+		r, err = consumer.SRandomWords(nil, big.NewInt(int64(i)))
+		panicErr(err)
+		rw = append(rw, r)
+	}
+	gasAvail, err := consumer.SGasAvailable(nil)
+	panicErr(err)
+	fmt.Println("Random words", rw)
+	fmt.Println("Gas available", gasAvail)
+}

core/scripts/vrfv2/send-vrfv2-req/main.go

@@ -0,0 +1,37 @@
+package main
+
+import (
+	"math/big"
+	"time"
+
+	"github.com/ethereum/go-ethereum/accounts/abi/bind"
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/ethereum/go-ethereum/ethclient"
+	"github.com/smartcontractkit/chainlink/core/internal/gethwrappers/generated/vrf_consumer_v2"
+)
+
+func panicErr(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+func main() {
+	// Make a request to an already deployed setup
+	chainID := int64(34055)
+	key, err := crypto.HexToECDSA("34d2ee6c703f755f9a205e322c68b8ff3425d915072ca7483190ac69684e548c")
+	panicErr(err)
+	user, err := bind.NewKeyedTransactorWithChainID(key, big.NewInt(chainID))
+	panicErr(err)
+	ec, err := ethclient.Dial("http://127.0.0.1:8545")
+	panicErr(err)
+	consumerAddress := "0x9E79d9A7F68D136ec4c1C0187B97c271CEa6008B"
+	consumer, err := vrf_consumer_v2.NewVRFConsumerV2(common.HexToAddress(consumerAddress), ec)
+	panicErr(err)
+	// keyhash of offchain VRF proving key
+	provingKey := "0x801b8899c3169bec9413ce6003a0117a2683b5d50db25c209b19a6bb9375890f"
+	_, err = consumer.TestRequestRandomness(user, common.HexToHash(provingKey), uint64(1), uint16(2), uint32(300000), uint32(3))
+	panicErr(err)
+	time.Sleep(2 * time.Second)
+}

core/testdata/tomlspecs/vrf-v2-spec.toml

@@ -7,7 +7,7 @@ confirmations = 6
 publicKey = "0x49cf5e2bf04a57620ac3833c998b37e78c0c7ad89b6a9cbc4ce6dba31729930000"
 observationSource="""
 decode_log   [type=ethabidecodelog
-              abi="RandomWordsRequested(bytes32 indexed keyHash,uint256 preSeedAndRequestId,uint64 subId,uint16 minimumRequestConfirmations,uint32 callbackGasLimit,uint32 numWords,address indexed sender)"
+              abi="RandomWordsRequested(bytes32 indexed keyHash,uint256 requestId, uint256 preSeed,uint64 subId,uint16 minimumRequestConfirmations,uint32 callbackGasLimit,uint32 numWords,address indexed sender)"
               data="$(jobRun.logData)"
               topics="$(jobRun.logTopics)"]
 vrf          [type=vrfv2
@@ -22,6 +22,6 @@ estimate_gas [type=estimategaslimit
 submit_tx  [type=ethtx to="0xABA5eDc1a551E55b1A570c0e1f1055e5BE11eca7"
             data="$(vrf.output)"
             gasLimit="$(estimate_gas)"
-            txMeta="{\\"requestTxHash\\": $(jobRun.logTxHash),\\"requestID\\": $(vrf.requestID),\\"jobID\\": $(jobSpec.databaseID)}"]
+            txMeta=<{"requestTxHash": $(jobRun.logTxHash),"requestID": $(vrf.requestID),"jobID": $(jobSpec.databaseID)}>]
 decode_log->vrf->encode_tx->estimate_gas->submit_tx
 """

tools/gethnet-london/Dockerfile

@@ -0,0 +1,35 @@
+FROM ethereum/client-go:v1.10.8
+# docker build . -t smartcontract/gethnet:london
+WORKDIR /gethnet
+COPY node_password .
+COPY genesis.json .
+# Initializes genesis file with london forks enabled
+RUN geth --datadir /gethnet/datadir init genesis.json
+# Copy a prefunded devnet key into the keystore
+COPY keys/* /gethnet/datadir/keystore/
+EXPOSE 8545 8546 8547 30303 30303/udp
+ENTRYPOINT [ "geth" ]
+CMD [ \
+"--networkid=34055", \
+"--mine", \
+"--miner.threads=1", \
+"--miner.noverify", \
+"--miner.recommit=1s", \
+"--datadir=/gethnet/datadir", \
+"--fakepow", \
+"--nodiscover", \
+"--http", \
+"--http.addr=0.0.0.0", \
+"--http.port=8545", \
+"--port=30303", \
+"--http.corsdomain", "*", \
+"--http.api", "eth,web3,personal,net", \
+"--password=node_password", \
+"--ipcdisable", \
+"--unlock", "0", \
+"--allow-insecure-unlock", \
+"--ws", \
+"--ws.addr=0.0.0.0", \
+"--ws.port=8546", \
+"--ws.api","eth,web3,net,admin,debug,txpool" \
+]