mirror of
https://github.com/scroll-tech/scroll.git
synced 2026-01-20 19:37:55 -05:00
85 lines
2.8 KiB
Go
85 lines
2.8 KiB
Go
package tests
|
|
|
|
import (
|
|
"context"
|
|
"math/big"
|
|
"testing"
|
|
|
|
"github.com/scroll-tech/go-ethereum/accounts/abi/bind"
|
|
"github.com/scroll-tech/go-ethereum/common"
|
|
geth_types "github.com/scroll-tech/go-ethereum/core/types"
|
|
"github.com/scroll-tech/go-ethereum/rpc"
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
"scroll-tech/common/types"
|
|
|
|
"scroll-tech/bridge/relayer"
|
|
"scroll-tech/bridge/watcher"
|
|
|
|
"scroll-tech/database"
|
|
"scroll-tech/database/migrate"
|
|
)
|
|
|
|
func testRelayL1MessageSucceed(t *testing.T) {
|
|
// Create db handler and reset db.
|
|
db, err := database.NewOrmFactory(base.DBConfig)
|
|
assert.NoError(t, err)
|
|
assert.NoError(t, migrate.ResetDB(db.GetDB().DB))
|
|
defer db.Close()
|
|
|
|
prepareContracts(t)
|
|
|
|
l1Cfg := bridgeApp.Config.L1Config
|
|
l2Cfg := bridgeApp.Config.L2Config
|
|
|
|
// Create L1Relayer
|
|
l1Relayer, err := relayer.NewLayer1Relayer(context.Background(), db, l1Cfg.RelayerConfig)
|
|
assert.NoError(t, err)
|
|
// Create L1Watcher
|
|
confirmations := rpc.LatestBlockNumber
|
|
l1Watcher := watcher.NewL1WatcherClient(context.Background(), l1Client, 0, confirmations, l1Cfg.L1MessengerAddress, l1Cfg.L1MessageQueueAddress, l1Cfg.ScrollChainContractAddress, db)
|
|
|
|
// Create L2Watcher
|
|
l2Watcher := watcher.NewL2WatcherClient(context.Background(), l2Client, confirmations, l2Cfg.L2MessengerAddress, l2Cfg.L2MessageQueueAddress, l2Cfg.WithdrawTrieRootSlot, db)
|
|
|
|
// send message through l1 messenger contract
|
|
nonce, err := l1MessengerInstance.MessageNonce(&bind.CallOpts{})
|
|
assert.NoError(t, err)
|
|
sendTx, err := l1MessengerInstance.SendMessage(l1Auth, l2Auth.From, big.NewInt(0), common.Hex2Bytes("00112233"), big.NewInt(0))
|
|
assert.NoError(t, err)
|
|
sendReceipt, err := bind.WaitMined(context.Background(), l1Client, sendTx)
|
|
assert.NoError(t, err)
|
|
if sendReceipt.Status != geth_types.ReceiptStatusSuccessful || err != nil {
|
|
t.Fatalf("Call failed")
|
|
}
|
|
|
|
// l1 watch process events
|
|
l1Watcher.FetchContractEvent()
|
|
|
|
// check db status
|
|
msg, err := db.GetL1MessageByQueueIndex(nonce.Uint64())
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, msg.Status, types.MsgPending)
|
|
assert.Equal(t, msg.Target, l2Auth.From.String())
|
|
|
|
// process l1 messages
|
|
l1Relayer.ProcessSavedEvents()
|
|
msg, err = db.GetL1MessageByQueueIndex(nonce.Uint64())
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, msg.Status, types.MsgSubmitted)
|
|
relayTxHash, err := db.GetRelayL1MessageTxHash(nonce.Uint64())
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, true, relayTxHash.Valid)
|
|
relayTx, _, err := l2Client.TransactionByHash(context.Background(), common.HexToHash(relayTxHash.String))
|
|
assert.NoError(t, err)
|
|
relayTxReceipt, err := bind.WaitMined(context.Background(), l2Client, relayTx)
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, len(relayTxReceipt.Logs), 1)
|
|
|
|
// fetch message relayed events
|
|
l2Watcher.FetchContractEvent()
|
|
msg, err = db.GetL1MessageByQueueIndex(nonce.Uint64())
|
|
assert.NoError(t, err)
|
|
assert.Equal(t, msg.Status, types.MsgConfirmed)
|
|
}
|