diff --git a/app/app.go b/app/app.go index d68cf30c..e45a0274 100644 --- a/app/app.go +++ b/app/app.go @@ -189,11 +189,11 @@ func palomaClientConfig(palomaConfig config.Paloma) *ion.ChainClientConfig { &consensustypes.MsgSetPublicAccessData{}, &consensustypes.MsgSetErrorData{}, &palomatypes.MsgAddStatusUpdate{}, - &skywaytypes.MsgSendToEth{}, + &skywaytypes.MsgSendToRemote{}, &skywaytypes.MsgConfirmBatch{}, &skywaytypes.MsgSendToPalomaClaim{}, - &skywaytypes.MsgBatchSendToEthClaim{}, - &skywaytypes.MsgCancelSendToEth{}, + &skywaytypes.MsgBatchSendToRemoteClaim{}, + &skywaytypes.MsgCancelSendToRemote{}, &skywaytypes.MsgSubmitBadSignatureEvidence{}, }, }, diff --git a/chain/evm/client.go b/chain/evm/client.go index f27c8940..5aa3d743 100644 --- a/chain/evm/client.go +++ b/chain/evm/client.go @@ -109,7 +109,7 @@ type PalomaClienter interface { SetPublicAccessData(ctx context.Context, queueTypeName string, messageID uint64, valsetID uint64, data []byte) error SetErrorData(ctx context.Context, queueTypeName string, messageID uint64, data []byte) error QueryGetEVMValsetByID(ctx context.Context, id uint64, chainID string) (*types.Valset, error) - SendBatchSendToEVMClaim(ctx context.Context, claim skywaytypes.MsgBatchSendToEthClaim) error + SendBatchSendToEVMClaim(ctx context.Context, claim skywaytypes.MsgBatchSendToRemoteClaim) error SendSendToPalomaClaim(ctx context.Context, claim skywaytypes.MsgSendToPalomaClaim) error QueryLastObservedSkywayNonceByAddr(ctx context.Context, chainReferenceID string, orchestrator string) (uint64, error) QueryBatchRequestByNonce(ctx context.Context, nonce uint64, contract string) (skywaytypes.OutgoingTxBatch, error) diff --git a/chain/evm/compass.go b/chain/evm/compass.go index 99f6e9bc..24317eb2 100644 --- a/chain/evm/compass.go +++ b/chain/evm/compass.go @@ -865,7 +865,7 @@ func (t compass) provideTxProof(ctx context.Context, queueTypeName string, rawMs } func (t compass) submitBatchSendToEVMClaim(ctx context.Context, event chain.BatchSendEvent, orchestrator string) error { - msg := skywaytypes.MsgBatchSendToEthClaim{ + msg := skywaytypes.MsgBatchSendToRemoteClaim{ EventNonce: event.EventNonce, EthBlockHeight: event.EthBlockHeight, BatchNonce: event.BatchNonce, diff --git a/chain/evm/mocks/PalomaClienter.go b/chain/evm/mocks/PalomaClienter.go index ce795383..5f75d331 100644 --- a/chain/evm/mocks/PalomaClienter.go +++ b/chain/evm/mocks/PalomaClienter.go @@ -178,7 +178,7 @@ func (_m *PalomaClienter) QueryLastObservedSkywayNonceByAddr(ctx context.Context } // SendBatchSendToEVMClaim provides a mock function with given fields: ctx, claim -func (_m *PalomaClienter) SendBatchSendToEVMClaim(ctx context.Context, claim types.MsgBatchSendToEthClaim) error { +func (_m *PalomaClienter) SendBatchSendToEVMClaim(ctx context.Context, claim types.MsgBatchSendToRemoteClaim) error { ret := _m.Called(ctx, claim) if len(ret) == 0 { @@ -186,7 +186,7 @@ func (_m *PalomaClienter) SendBatchSendToEVMClaim(ctx context.Context, claim typ } var r0 error - if rf, ok := ret.Get(0).(func(context.Context, types.MsgBatchSendToEthClaim) error); ok { + if rf, ok := ret.Get(0).(func(context.Context, types.MsgBatchSendToRemoteClaim) error); ok { r0 = rf(ctx, claim) } else { r0 = ret.Error(0) @@ -254,7 +254,8 @@ func (_m *PalomaClienter) SetPublicAccessData(ctx context.Context, queueTypeName func NewPalomaClienter(t interface { mock.TestingT Cleanup(func()) -}) *PalomaClienter { +}, +) *PalomaClienter { mock := &PalomaClienter{} mock.Mock.Test(t) diff --git a/chain/evm/processor.go b/chain/evm/processor.go index 1a5d1000..5e88c224 100644 --- a/chain/evm/processor.go +++ b/chain/evm/processor.go @@ -224,7 +224,7 @@ func (p Processor) GetSendToPalomaEvents(ctx context.Context, orchestrator strin return p.compass.GetSendToPalomaEvents(ctx, orchestrator) } -func (p Processor) SubmitBatchSendToEthClaims(ctx context.Context, batchSendEvents []chain.BatchSendEvent, orchestrator string) error { +func (p Processor) SubmitBatchSendToRemoteClaims(ctx context.Context, batchSendEvents []chain.BatchSendEvent, orchestrator string) error { for _, batchSendEvent := range batchSendEvents { if err := p.compass.submitBatchSendToEVMClaim(ctx, batchSendEvent, orchestrator); err != nil { return err diff --git a/chain/mocks/Processor.go b/chain/mocks/Processor.go index 880510b0..b29ef0cf 100644 --- a/chain/mocks/Processor.go +++ b/chain/mocks/Processor.go @@ -232,8 +232,8 @@ func (_m *Processor) SignMessages(ctx context.Context, messages ...chain.QueuedM return r0, r1 } -// SubmitBatchSendToEthClaims provides a mock function with given fields: _a0, _a1, _a2 -func (_m *Processor) SubmitBatchSendToEthClaims(_a0 context.Context, _a1 []chain.BatchSendEvent, _a2 string) error { +// SubmitBatchSendToRemoteClaims provides a mock function with given fields: _a0, _a1, _a2 +func (_m *Processor) SubmitBatchSendToRemoteClaims(_a0 context.Context, _a1 []chain.BatchSendEvent, _a2 string) error { ret := _m.Called(_a0, _a1, _a2) var r0 error diff --git a/chain/paloma/skyway.go b/chain/paloma/skyway.go index 943836ea..50c679ae 100644 --- a/chain/paloma/skyway.go +++ b/chain/paloma/skyway.go @@ -93,7 +93,7 @@ func (c *Client) SkywayQueryBatchesForRelaying(ctx context.Context, chainReferen } // TODO: Combine with below method -func (c *Client) SendBatchSendToEVMClaim(ctx context.Context, claim skyway.MsgBatchSendToEthClaim) error { +func (c *Client) SendBatchSendToEVMClaim(ctx context.Context, claim skyway.MsgBatchSendToRemoteClaim) error { _, err := c.MessageSender.SendMsg(ctx, &claim, "", c.sendingOpts...) return err } diff --git a/chain/relayer.go b/chain/relayer.go index 9762ef76..bd2f1256 100644 --- a/chain/relayer.go +++ b/chain/relayer.go @@ -127,7 +127,7 @@ type Processor interface { // takes the "public evidence" from the message and gets the information back to the Paloma. ProvideEvidence(context.Context, queue.TypeName, []MessageWithSignatures) error - SubmitBatchSendToEthClaims(context.Context, []BatchSendEvent, string) error + SubmitBatchSendToRemoteClaims(context.Context, []BatchSendEvent, string) error SubmitSendToPalomaClaims(context.Context, []SendToPalomaEvent, string) error // it verifies if it's being connected to the right chain diff --git a/go.mod b/go.mod index 0f40ce41..a9e56790 100644 --- a/go.mod +++ b/go.mod @@ -29,7 +29,7 @@ require ( github.com/spf13/cobra v1.8.0 github.com/stretchr/testify v1.9.0 golang.org/x/exp v0.0.0-20240404231335-c0f41cb1a7a0 - golang.org/x/term v0.20.0 + golang.org/x/term v0.22.0 google.golang.org/grpc v1.65.0 google.golang.org/protobuf v1.34.1 gopkg.in/yaml.v2 v2.4.0 @@ -204,15 +204,15 @@ require ( go.opentelemetry.io/otel/metric v1.24.0 // indirect go.opentelemetry.io/otel/trace v1.24.0 // indirect go.uber.org/multierr v1.11.0 // indirect - golang.org/x/crypto v0.23.0 // indirect - golang.org/x/mod v0.17.0 // indirect - golang.org/x/net v0.25.0 // indirect + golang.org/x/crypto v0.25.0 // indirect + golang.org/x/mod v0.19.0 // indirect + golang.org/x/net v0.27.0 // indirect golang.org/x/oauth2 v0.20.0 // indirect golang.org/x/sync v0.7.0 // indirect - golang.org/x/sys v0.20.0 // indirect - golang.org/x/text v0.15.0 // indirect + golang.org/x/sys v0.22.0 // indirect + golang.org/x/text v0.16.0 // indirect golang.org/x/time v0.5.0 // indirect - golang.org/x/tools v0.21.0 // indirect + golang.org/x/tools v0.23.0 // indirect google.golang.org/api v0.169.0 // indirect google.golang.org/genproto v0.0.0-20240227224415-6ceb2ff114de // indirect google.golang.org/genproto/googleapis/api v0.0.0-20240528184218-531527333157 // indirect @@ -229,6 +229,7 @@ require ( replace ( // Link to op-geth, which is built on top of go-ethereum github.com/ethereum/go-ethereum => github.com/ethereum-optimism/op-geth v1.101311.0 + github.com/palomachain/paloma => github.com/palomachain/paloma v1.3.1-next.0.20240722145624-1b716af8f0b7 github.com/roodeag/arbitrum => github.com/palomachain/arb-geth v0.0.0-20230824112942-8e77a580a936 ) diff --git a/go.sum b/go.sum index 18565440..6472e2c8 100644 --- a/go.sum +++ b/go.sum @@ -949,8 +949,8 @@ github.com/ory/dockertest v3.3.5+incompatible/go.mod h1:1vX4m9wsvi00u5bseYwXaSnh github.com/pact-foundation/pact-go v1.0.4/go.mod h1:uExwJY4kCzNPcHRj+hCR/HBbOOIwwtUjcrb0b5/5kLM= github.com/palomachain/arb-geth v0.0.0-20230824112942-8e77a580a936 h1:fmQAgxcdYBxCZYczws/uxTVOYHZd4fNrOaoHp35HZMM= github.com/palomachain/arb-geth v0.0.0-20230824112942-8e77a580a936/go.mod h1:B2H2+2I4UiMR4hvAIaGLyYszNfSTYC8fWIw+kgfuFSQ= -github.com/palomachain/paloma v1.15.3 h1:8Fc1owzrICw4umjpDtVZx+FyxLjBDuMOwaBmvZgN+D0= -github.com/palomachain/paloma v1.15.3/go.mod h1:DoV4uEfnCumFTtRHkdie2usqDCxAqexXFl2HmIOWlhQ= +github.com/palomachain/paloma v1.3.1-next.0.20240722145624-1b716af8f0b7 h1:vYmcvqm/Os+b2URJNzGumgSmVYA0WcfjqAfp3gr7LmI= +github.com/palomachain/paloma v1.3.1-next.0.20240722145624-1b716af8f0b7/go.mod h1:91O0VRxBof+IXTZxSsSbk/lV2DSaWQIdUaoCBv6HXDo= github.com/pascaldekloe/goe v0.0.0-20180627143212-57f6aae5913c/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc= github.com/pascaldekloe/goe v0.1.0 h1:cBOtyMzM9HTpWjXfbbunk26uA6nG3a8n06Wieeh0MwY= github.com/pascaldekloe/goe v0.1.0/go.mod h1:lzWF7FIEvWOWxwDKqyGYQf6ZUaNfKdP144TG7ZOy1lc= @@ -1200,8 +1200,9 @@ golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPh golang.org/x/crypto v0.0.0-20200728195943-123391ffb6de/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= golang.org/x/crypto v0.19.0/go.mod h1:Iy9bg/ha4yyC70EfRS8jz+B6ybOBKMaSxLj6P6oBDfU= -golang.org/x/crypto v0.23.0 h1:dIJU/v2J8Mdglj/8rJ6UUOM3Zc9zLZxVZwwxMooUSAI= golang.org/x/crypto v0.23.0/go.mod h1:CKFgDieR+mRhux2Lsu27y0fO304Db0wZe70UKqHu0v8= +golang.org/x/crypto v0.25.0 h1:ypSNr+bnYL2YhwoMt2zPxHFmbAN1KZs/njMG3hxUp30= +golang.org/x/crypto v0.25.0/go.mod h1:T+wALwcMOSE0kXgUAnPAHqTLW+XHgcELELW8VaDgm/M= golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= golang.org/x/exp v0.0.0-20190306152737-a1d7652674e8/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= golang.org/x/exp v0.0.0-20190510132918-efd6b22b2522/go.mod h1:ZjyILWgesfNpC6sMxTJOJm9Kp84zZh5NQWvqDGG3Qr8= @@ -1242,8 +1243,8 @@ golang.org/x/mod v0.4.1/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= -golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA= -golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= +golang.org/x/mod v0.19.0 h1:fEdghXQSo20giMthA7cd28ZC+jts4amQ3YMXiP5oMQ8= +golang.org/x/mod v0.19.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= @@ -1306,8 +1307,9 @@ golang.org/x/net v0.1.0/go.mod h1:Cx3nUiGt4eDBEyega/BKRp+/AlGL8hYe7U9odMt2Cco= golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg= golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44= -golang.org/x/net v0.25.0 h1:d/OCCoBEUq33pjydKrGQhw7IlUPI2Oylr+8qLx49kac= golang.org/x/net v0.25.0/go.mod h1:JkAGAh7GEvH74S6FOH42FLoXpXbE/aqXSrIQjXgsiwM= +golang.org/x/net v0.27.0 h1:5K3Njcw06/l2y9vpGCSdcxWOYHOUk3dVNGDXN+FvAys= +golang.org/x/net v0.27.0/go.mod h1:dDi0PyhWNoiUOrAS8uXv/vnScO4wnHQO4mj9fn/RytE= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -1454,16 +1456,18 @@ golang.org/x/sys v0.8.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.11.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.12.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.17.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= -golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y= golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.22.0 h1:RI27ohtqKCnwULzJLqkv897zojh5/DwS/ENaMzUOaWI= +golang.org/x/sys v0.22.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= golang.org/x/term v0.8.0/go.mod h1:xPskH00ivmX89bAKVGSKKtLOWNx2+17Eiy94tnKShWo= golang.org/x/term v0.17.0/go.mod h1:lLRBjIVuehSbZlaOtGMbcMncT+aqLLLmKrsjNrUguwk= -golang.org/x/term v0.20.0 h1:VnkxpohqXaOBYJtBmEppKUG6mXpi+4O6purfc2+sMhw= golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY= +golang.org/x/term v0.22.0 h1:BbsgPEJULsl2fV/AT3v15Mjva5yXKQDyKf+TbDz7QJk= +golang.org/x/term v0.22.0/go.mod h1:F3qCibpT5AMpCRfhfT53vVJwhLtIVHhB9XDjfFvnMI4= golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= @@ -1477,8 +1481,9 @@ golang.org/x/text v0.4.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= -golang.org/x/text v0.15.0 h1:h1V/4gjBv8v9cjcR6+AR5+/cIYK5N/WAgiv4xlsEtAk= golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/text v0.16.0 h1:a94ExnEXNtEwYLGJSIUxnWoxoRz/ZcCsV63ROupILh4= +golang.org/x/text v0.16.0/go.mod h1:GhwF1Be+LQoKShO3cGOHzqOgRrGaYc9AvblQOmPVHnI= golang.org/x/time v0.0.0-20180412165947-fbb02b2291d2/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= @@ -1549,8 +1554,8 @@ golang.org/x/tools v0.1.4/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU= -golang.org/x/tools v0.21.0 h1:qc0xYgIbsSDt9EyWz05J5wfa7LOVW0YTLOXrqdLAWIw= -golang.org/x/tools v0.21.0/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk= +golang.org/x/tools v0.23.0 h1:SGsXPZ+2l4JsgaCKkx+FQ9YZ5XEtA1GZYuoDjenLjvg= +golang.org/x/tools v0.23.0/go.mod h1:pnu6ufv6vQkll6szChhK3C3L/ruaIv5eBeztNG8wtsI= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= diff --git a/relayer/skyway_batch_send_event_handler.go b/relayer/skyway_batch_send_event_handler.go index da77e504..3771d367 100644 --- a/relayer/skyway_batch_send_event_handler.go +++ b/relayer/skyway_batch_send_event_handler.go @@ -63,7 +63,7 @@ func (r *Relayer) handleBatchSendEvents(ctx context.Context, processors []chain. // Walk through the different batchSendEvents and do different things for different batchSendEvents logger.Info("claiming for ", len(batchSendEvents), " events") - err := p.SubmitBatchSendToEthClaims(ctx, batchSendEvents, r.palomaClient.GetCreator()) + err := p.SubmitBatchSendToRemoteClaims(ctx, batchSendEvents, r.palomaClient.GetCreator()) if err != nil { logger.WithError(err).Error("error submitting claim for events") return err