feat: integrate basic step flow

Makefile

@@ -22,6 +22,8 @@ test:
 
 genmocks:
 	mockgen -source=./chains/evm/listener/events/handlers/deposit.go -destination=./mock/handlers.go -package mock
+	mockgen -source=./chains/evm/listener/listener.go -destination=./mock/listener.go -package mock
+	mockgen -source=./chains/evm/executor/step.go -destination=./mock/executor.go -package mock
 
 
 PLATFORMS := linux/amd64 darwin/amd64 darwin/arm64 linux/arm

chains/evm/abi/spectre.go

@@ -0,0 +1,246 @@
+// The Licensed Work is (c) 2023 Sygma
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package abi
+
+const SpectreABI = `[
+	{
+		"inputs": [
+			{
+				"internalType": "address",
+				"name": "_stepVerifierAddress",
+				"type": "address"
+			},
+			{
+				"internalType": "address",
+				"name": "_committeeUpdateVerifierAddress",
+				"type": "address"
+			},
+			{
+				"internalType": "uint256",
+				"name": "_initialSyncPeriod",
+				"type": "uint256"
+			},
+			{
+				"internalType": "bytes32",
+				"name": "_initialSyncCommitteePoseidon",
+				"type": "bytes32"
+			},
+			{
+				"internalType": "uint256",
+				"name": "_slotsPerPeriod",
+				"type": "uint256"
+			}
+		],
+		"stateMutability": "nonpayable",
+		"type": "constructor"
+	},
+	{
+		"inputs": [
+			{
+				"internalType": "uint256",
+				"name": "",
+				"type": "uint256"
+			}
+		],
+		"name": "blockHeaderRoots",
+		"outputs": [
+			{
+				"internalType": "bytes32",
+				"name": "",
+				"type": "bytes32"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	},
+	{
+		"inputs": [],
+		"name": "committeeUpdateVerifier",
+		"outputs": [
+			{
+				"internalType": "contract CommitteeUpdateVerifier",
+				"name": "",
+				"type": "address"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	},
+	{
+		"inputs": [
+			{
+				"internalType": "uint256",
+				"name": "",
+				"type": "uint256"
+			}
+		],
+		"name": "executionStateRoots",
+		"outputs": [
+			{
+				"internalType": "bytes32",
+				"name": "",
+				"type": "bytes32"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	},
+	{
+		"inputs": [],
+		"name": "head",
+		"outputs": [
+			{
+				"internalType": "uint256",
+				"name": "",
+				"type": "uint256"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	},
+	{
+		"inputs": [
+			{
+				"components": [
+					{
+						"internalType": "bytes32",
+						"name": "syncCommitteeSSZ",
+						"type": "bytes32"
+					},
+					{
+						"internalType": "bytes32",
+						"name": "syncCommitteePoseidon",
+						"type": "bytes32"
+					}
+				],
+				"internalType": "struct RotateLib.RotateInput",
+				"name": "rotateInput",
+				"type": "tuple"
+			},
+			{
+				"internalType": "bytes",
+				"name": "rotateProof",
+				"type": "bytes"
+			},
+			{
+				"components": [
+					{
+						"internalType": "uint64",
+						"name": "attestedSlot",
+						"type": "uint64"
+					},
+					{
+						"internalType": "uint64",
+						"name": "finalizedSlot",
+						"type": "uint64"
+					},
+					{
+						"internalType": "uint64",
+						"name": "participation",
+						"type": "uint64"
+					},
+					{
+						"internalType": "bytes32",
+						"name": "finalizedHeaderRoot",
+						"type": "bytes32"
+					},
+					{
+						"internalType": "bytes32",
+						"name": "executionPayloadRoot",
+						"type": "bytes32"
+					}
+				],
+				"internalType": "struct SyncStepLib.SyncStepInput",
+				"name": "stepInput",
+				"type": "tuple"
+			},
+			{
+				"internalType": "bytes",
+				"name": "stepProof",
+				"type": "bytes"
+			}
+		],
+		"name": "rotate",
+		"outputs": [],
+		"stateMutability": "nonpayable",
+		"type": "function"
+	},
+	{
+		"inputs": [
+			{
+				"components": [
+					{
+						"internalType": "uint64",
+						"name": "attestedSlot",
+						"type": "uint64"
+					},
+					{
+						"internalType": "uint64",
+						"name": "finalizedSlot",
+						"type": "uint64"
+					},
+					{
+						"internalType": "uint64",
+						"name": "participation",
+						"type": "uint64"
+					},
+					{
+						"internalType": "bytes32",
+						"name": "finalizedHeaderRoot",
+						"type": "bytes32"
+					},
+					{
+						"internalType": "bytes32",
+						"name": "executionPayloadRoot",
+						"type": "bytes32"
+					}
+				],
+				"internalType": "struct SyncStepLib.SyncStepInput",
+				"name": "input",
+				"type": "tuple"
+			},
+			{
+				"internalType": "bytes",
+				"name": "proof",
+				"type": "bytes"
+			}
+		],
+		"name": "step",
+		"outputs": [],
+		"stateMutability": "nonpayable",
+		"type": "function"
+	},
+	{
+		"inputs": [],
+		"name": "stepVerifier",
+		"outputs": [
+			{
+				"internalType": "contract SyncStepVerifier",
+				"name": "",
+				"type": "address"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	},
+	{
+		"inputs": [
+			{
+				"internalType": "uint256",
+				"name": "",
+				"type": "uint256"
+			}
+		],
+		"name": "syncCommitteePoseidons",
+		"outputs": [
+			{
+				"internalType": "bytes32",
+				"name": "",
+				"type": "bytes32"
+			}
+		],
+		"stateMutability": "view",
+		"type": "function"
+	}
+]`

chains/evm/contracts/spectre.go

@@ -0,0 +1,38 @@
+// The Licensed Work is (c) 2023 Sygma
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package contracts
+
+import (
+	"strings"
+
+	ethereumABI "github.com/ethereum/go-ethereum/accounts/abi"
+	"github.com/ethereum/go-ethereum/common"
+
+	"github.com/sygmaprotocol/spectre-node/chains/evm/abi"
+	"github.com/sygmaprotocol/spectre-node/chains/evm/message"
+	coreContracts "github.com/sygmaprotocol/sygma-core/chains/evm/contracts"
+	"github.com/sygmaprotocol/sygma-core/chains/evm/transactor"
+)
+
+type Spectre struct {
+	coreContracts.Contract
+}
+
+func NewSpectreContract(
+	address common.Address,
+	transactor transactor.Transactor,
+) *Spectre {
+	a, _ := ethereumABI.JSON(strings.NewReader(abi.SpectreABI))
+	return &Spectre{
+		Contract: coreContracts.NewContract(address, a, nil, nil, transactor),
+	}
+}
+
+func (c *Spectre) Step(args message.SyncStepInput, poseidonCommitment [32]byte, opts transactor.TransactOptions) (*common.Hash, error) {
+	return c.ExecuteTransaction(
+		"step",
+		opts,
+		args, poseidonCommitment,
+	)
+}

chains/evm/executor/step.go

@@ -0,0 +1,40 @@
+// The Licensed Work is (c) 2023 Sygma
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package executor
+
+import (
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/rs/zerolog/log"
+	"github.com/sygmaprotocol/spectre-node/chains/evm/message"
+	"github.com/sygmaprotocol/sygma-core/chains/evm/transactor"
+	"github.com/sygmaprotocol/sygma-core/relayer/proposal"
+)
+
+type StepSubmitter interface {
+	Step(args message.SyncStepInput, poseidonCommitment [32]byte, opts transactor.TransactOptions) (*common.Hash, error)
+}
+
+type EVMStepExecutor struct {
+	domainID uint8
+
+	stepSubmitter StepSubmitter
+}
+
+func NewEVMStepExecutor(domainID uint8, stepSubmitter StepSubmitter) *EVMStepExecutor {
+	return &EVMStepExecutor{
+		stepSubmitter: stepSubmitter,
+		domainID:      domainID,
+	}
+}
+
+func (e *EVMStepExecutor) Execute(props []*proposal.Proposal) error {
+	stepData := props[0].Data.(message.StepData)
+	hash, err := e.stepSubmitter.Step(stepData.Args, stepData.Proof, transactor.TransactOptions{})
+	if err != nil {
+		return err
+	}
+
+	log.Info().Uint8("domainID", e.domainID).Msgf("Sent EVM step with hash: %s", hash)
+	return nil
+}

chains/evm/executor/step_test.go

@@ -0,0 +1,54 @@
+// The Licensed Work is (c) 2023 Sygma
+// SPDX-License-Identifier: LGPL-3.0-only
+
+package executor_test
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/stretchr/testify/suite"
+	"github.com/sygmaprotocol/spectre-node/chains/evm/executor"
+	"github.com/sygmaprotocol/spectre-node/chains/evm/message"
+	"github.com/sygmaprotocol/spectre-node/mock"
+	"github.com/sygmaprotocol/sygma-core/relayer/proposal"
+	"go.uber.org/mock/gomock"
+)
+
+type StepTestSuite struct {
+	suite.Suite
+
+	mockStepSubmitter *mock.MockStepSubmitter
+	executor          *executor.EVMStepExecutor
+}
+
+func TestRunStepTestSuite(t *testing.T) {
+	suite.Run(t, new(StepTestSuite))
+}
+
+func (s *StepTestSuite) SetupTest() {
+	ctrl := gomock.NewController(s.T())
+	s.mockStepSubmitter = mock.NewMockStepSubmitter(ctrl)
+	s.executor = executor.NewEVMStepExecutor(1, s.mockStepSubmitter)
+}
+
+func (s *StepTestSuite) Test_Execute_SubmissionFails() {
+	s.mockStepSubmitter.EXPECT().Step(gomock.Any(), gomock.Any(), gomock.Any()).Return(nil, fmt.Errorf("error"))
+
+	err := s.executor.Execute([]*proposal.Proposal{{
+		Data: message.StepData{},
+	}})
+
+	s.NotNil(err)
+}
+
+func (s *StepTestSuite) Test_Execute_Successful() {
+	s.mockStepSubmitter.EXPECT().Step(gomock.Any(), gomock.Any(), gomock.Any()).Return(&common.Hash{}, nil)
+
+	err := s.executor.Execute([]*proposal.Proposal{{
+		Data: message.StepData{},
+	}})
+
+	s.Nil(err)
+}