Commit 89ca741a authored by Will Cory's avatar Will Cory

fix(sdk): check for both v0 and v1 messages when looking for RelayedMessages

test: add one

fix: linter

fix: Failed to save file to change failed ones too

fix: linter

Fix --fork-block-number to correct network block number

changeset
parent 2e64d046
---
'@eth-optimism/sdk': minor
---
Fixes issue with legacy withdrawal message status detection
...@@ -626,12 +626,12 @@ jobs: ...@@ -626,12 +626,12 @@ jobs:
name: anvil-l1 name: anvil-l1
background: true background: true
# atm this is goerli but we should use mainnet after bedrock is live # atm this is goerli but we should use mainnet after bedrock is live
command: anvil --fork-url $ANVIL_L1_FORK_URL --fork-block-number 9023108 command: anvil --fork-url $ANVIL_L1_FORK_URL --fork-block-number 9190101
- run: - run:
name: anvil-l2 name: anvil-l2
background: true background: true
# atm this is goerli but we should use mainnet after bedrock is live # atm this is goerli but we should use mainnet after bedrock is live
command: anvil --fork-url $ANVIL_L2_FORK_URL --port 9545 --fork-block-number 9504811 command: anvil --fork-url $ANVIL_L2_FORK_URL --port 9545 --fork-block-number 10756611
- run: - run:
name: build name: build
command: pnpm build command: pnpm build
......
...@@ -62,11 +62,11 @@ export const hashCrossDomainMessage = ( ...@@ -62,11 +62,11 @@ export const hashCrossDomainMessage = (
target: string, target: string,
value: BigNumber, value: BigNumber,
gasLimit: BigNumber, gasLimit: BigNumber,
data: string message: string
) => { ) => {
const { version } = decodeVersionedNonce(nonce) const { version } = decodeVersionedNonce(nonce)
if (version.eq(0)) { if (version.eq(0)) {
return hashCrossDomainMessagev0(target, sender, data, nonce) return hashCrossDomainMessagev0(target, sender, message, nonce)
} else if (version.eq(1)) { } else if (version.eq(1)) {
return hashCrossDomainMessagev1( return hashCrossDomainMessagev1(
nonce, nonce,
...@@ -74,7 +74,7 @@ export const hashCrossDomainMessage = ( ...@@ -74,7 +74,7 @@ export const hashCrossDomainMessage = (
target, target,
value, value,
gasLimit, gasLimit,
data message
) )
} }
throw new Error(`unknown version ${version.toString()}`) throw new Error(`unknown version ${version.toString()}`)
...@@ -85,16 +85,16 @@ export const hashCrossDomainMessage = ( ...@@ -85,16 +85,16 @@ export const hashCrossDomainMessage = (
* *
* @param target The target of the cross domain message * @param target The target of the cross domain message
* @param sender The sender of the cross domain message * @param sender The sender of the cross domain message
* @param data The data passed along with the cross domain message * @param message The message passed along with the cross domain message
* @param nonce The cross domain message nonce * @param nonce The cross domain message nonce
*/ */
export const hashCrossDomainMessagev0 = ( export const hashCrossDomainMessagev0 = (
target: string, target: string,
sender: string, sender: string,
data: string, message: string,
nonce: BigNumber nonce: BigNumber
) => { ) => {
return keccak256(encodeCrossDomainMessageV0(target, sender, data, nonce)) return keccak256(encodeCrossDomainMessageV0(target, sender, message, nonce))
} }
/** /**
...@@ -105,7 +105,7 @@ export const hashCrossDomainMessagev0 = ( ...@@ -105,7 +105,7 @@ export const hashCrossDomainMessagev0 = (
* @param target The target of the cross domain message * @param target The target of the cross domain message
* @param value The value being sent with the cross domain message * @param value The value being sent with the cross domain message
* @param gasLimit The gas limit of the cross domain execution * @param gasLimit The gas limit of the cross domain execution
* @param data The data passed along with the cross domain message * @param message The message passed along with the cross domain message
*/ */
export const hashCrossDomainMessagev1 = ( export const hashCrossDomainMessagev1 = (
nonce: BigNumber, nonce: BigNumber,
...@@ -113,10 +113,10 @@ export const hashCrossDomainMessagev1 = ( ...@@ -113,10 +113,10 @@ export const hashCrossDomainMessagev1 = (
target: string, target: string,
value: BigNumberish, value: BigNumberish,
gasLimit: BigNumberish, gasLimit: BigNumberish,
data: string message: string
) => { ) => {
return keccak256( return keccak256(
encodeCrossDomainMessageV1(nonce, sender, target, value, gasLimit, data) encodeCrossDomainMessageV1(nonce, sender, target, value, gasLimit, message)
) )
} }
...@@ -128,7 +128,7 @@ export const hashCrossDomainMessagev1 = ( ...@@ -128,7 +128,7 @@ export const hashCrossDomainMessagev1 = (
* @param target The target of the cross domain message * @param target The target of the cross domain message
* @param value The value being sent with the cross domain message * @param value The value being sent with the cross domain message
* @param gasLimit The gas limit of the cross domain execution * @param gasLimit The gas limit of the cross domain execution
* @param data The data passed along with the cross domain message * @param message The message passed along with the cross domain message
*/ */
export const hashWithdrawal = ( export const hashWithdrawal = (
nonce: BigNumber, nonce: BigNumber,
...@@ -136,7 +136,7 @@ export const hashWithdrawal = ( ...@@ -136,7 +136,7 @@ export const hashWithdrawal = (
target: string, target: string,
value: BigNumber, value: BigNumber,
gasLimit: BigNumber, gasLimit: BigNumber,
data: string message: string
): string => { ): string => {
const types = ['uint256', 'address', 'address', 'uint256', 'uint256', 'bytes'] const types = ['uint256', 'address', 'address', 'uint256', 'uint256', 'bytes']
const encoded = defaultAbiCoder.encode(types, [ const encoded = defaultAbiCoder.encode(types, [
...@@ -145,7 +145,7 @@ export const hashWithdrawal = ( ...@@ -145,7 +145,7 @@ export const hashWithdrawal = (
target, target,
value, value,
gasLimit, gasLimit,
data, message,
]) ])
return keccak256(encoded) return keccak256(encoded)
} }
......
...@@ -27,6 +27,8 @@ import { ...@@ -27,6 +27,8 @@ import {
decodeVersionedNonce, decodeVersionedNonce,
encodeVersionedNonce, encodeVersionedNonce,
getChainId, getChainId,
hashCrossDomainMessagev0,
hashCrossDomainMessagev1,
} from '@eth-optimism/core-utils' } from '@eth-optimism/core-utils'
import { getContractInterface, predeploys } from '@eth-optimism/contracts' import { getContractInterface, predeploys } from '@eth-optimism/contracts'
import * as rlp from 'rlp' import * as rlp from 'rlp'
...@@ -716,7 +718,18 @@ export class CrossChainMessenger { ...@@ -716,7 +718,18 @@ export class CrossChainMessenger {
message: MessageLike message: MessageLike
): Promise<MessageReceipt> { ): Promise<MessageReceipt> {
const resolved = await this.toCrossChainMessage(message) const resolved = await this.toCrossChainMessage(message)
const messageHash = hashCrossDomainMessage( // legacy withdrawals relayed prebedrock are v1
const messageHashV0 = hashCrossDomainMessagev0(
resolved.target,
resolved.sender,
resolved.message,
resolved.messageNonce
)
// bedrock withdrawals are v1
// legacy withdrawals relayed postbedrock are v1
// there is no good way to differentiate between the two types of legacy
// so what we will check for both
const messageHashV1 = hashCrossDomainMessagev1(
resolved.messageNonce, resolved.messageNonce,
resolved.sender, resolved.sender,
resolved.target, resolved.target,
...@@ -731,9 +744,15 @@ export class CrossChainMessenger { ...@@ -731,9 +744,15 @@ export class CrossChainMessenger {
? this.contracts.l2.L2CrossDomainMessenger ? this.contracts.l2.L2CrossDomainMessenger
: this.contracts.l1.L1CrossDomainMessenger : this.contracts.l1.L1CrossDomainMessenger
const relayedMessageEvents = await messenger.queryFilter( // this is safe because we can guarantee only one of these filters max will return something
messenger.filters.RelayedMessage(messageHash) const relayedMessageEvents = [
) ...(await messenger.queryFilter(
messenger.filters.RelayedMessage(messageHashV0)
)),
...(await messenger.queryFilter(
messenger.filters.RelayedMessage(messageHashV1)
)),
]
// Great, we found the message. Convert it into a transaction receipt. // Great, we found the message. Convert it into a transaction receipt.
if (relayedMessageEvents.length === 1) { if (relayedMessageEvents.length === 1) {
...@@ -749,9 +768,14 @@ export class CrossChainMessenger { ...@@ -749,9 +768,14 @@ export class CrossChainMessenger {
// We didn't find a transaction that relayed the message. We now attempt to find // We didn't find a transaction that relayed the message. We now attempt to find
// FailedRelayedMessage events instead. // FailedRelayedMessage events instead.
const failedRelayedMessageEvents = await messenger.queryFilter( const failedRelayedMessageEvents = [
messenger.filters.FailedRelayedMessage(messageHash) ...(await messenger.queryFilter(
) messenger.filters.FailedRelayedMessage(messageHashV0)
)),
...(await messenger.queryFilter(
messenger.filters.FailedRelayedMessage(messageHashV1)
)),
]
// A transaction can fail to be relayed multiple times. We'll always return the last // A transaction can fail to be relayed multiple times. We'll always return the last
// transaction that attempted to relay the message. // transaction that attempted to relay the message.
......
import { describe, expect, it } from 'vitest'
import { CrossChainMessenger, MessageStatus } from '../src'
import { l1Provider, l2Provider } from './testUtils/ethersProviders'
const crossChainMessenger = new CrossChainMessenger({
l1SignerOrProvider: l1Provider,
l2SignerOrProvider: l2Provider,
l1ChainId: 5,
l2ChainId: 420,
bedrock: true,
})
describe('prove message', () => {
it(`should be able to correctly find a finalized withdrawal`, async () => {
/**
* Tx hash of legacy withdrawal that was claimed
*
* @see https://goerli-optimism.etherscan.io/tx/0xda9e9c8dfc7718bc1499e1e64d8df6cddbabc46e819475a6c755db286a41b9fa
*/
const txWithdrawalHash =
'0xda9e9c8dfc7718bc1499e1e64d8df6cddbabc46e819475a6c755db286a41b9fa'
const txReceipt = await l2Provider.getTransactionReceipt(txWithdrawalHash)
expect(txReceipt).toBeDefined()
expect(await crossChainMessenger.getMessageStatus(txWithdrawalHash)).toBe(
MessageStatus.RELAYED
)
}, 20_000)
})
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment