-
Notifications
You must be signed in to change notification settings - Fork 172
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: process from root linea (#5084)
* feat: claimMessage interface * chore: rebuild * feat: linea process from root * test: linea process from root unit tests * feat: deploy testnet linea hub connector * feat: hub subgraph for linea hub connector * chore: rename
- Loading branch information
1 parent
ecee8c2
commit f10e3a8
Showing
19 changed files
with
931 additions
and
69 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
59 changes: 59 additions & 0 deletions
59
packages/agents/lighthouse/src/tasks/processFromRoot/helpers/linea.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,59 @@ | ||
| import { createLoggingContext } from "@connext/nxtp-utils"; | ||
| import { BigNumber } from "ethers"; | ||
|
|
||
| import { LineaSDK } from "../../../mockable"; | ||
| import { AlreadyProcessed, NoRootAvailable } from "../errors"; | ||
| import { getContext } from "../processFromRoot"; | ||
|
|
||
| import { GetProcessArgsParams } from "."; | ||
|
|
||
| export const getProcessFromLineaRootArgs = async ({ | ||
| spokeChainId, | ||
| hubChainId, | ||
| hubProvider, | ||
| spokeProvider, | ||
| message: _message, | ||
| sendHash, | ||
| _requestContext, | ||
| }: GetProcessArgsParams): Promise<[BigNumber, string]> => { | ||
| const { logger } = getContext(); | ||
| const { requestContext, methodContext } = createLoggingContext(getProcessFromLineaRootArgs.name, _requestContext); | ||
| logger.info("Method start", requestContext, methodContext); | ||
|
|
||
| const sdk = new LineaSDK({ | ||
| l1RpcUrl: hubProvider, // L1 rpc url | ||
| l2RpcUrl: spokeProvider, // L2 rpc url | ||
| network: hubChainId === 1 ? "linea-mainnet" : "linea-goerli", // network you want to interact with (either linea-mainnet or linea-goerli) | ||
| mode: "read-only", // contract wrapper class mode (read-only or read-write), read-only: only read contracts state, read-write: read contracts state and claim messages | ||
| }); | ||
|
|
||
| // get Message Status | ||
| const messages = await sdk.getL2Contract().getMessagesByTransactionHash(sendHash); | ||
|
|
||
| if (!messages?.length) { | ||
| throw new NoRootAvailable(spokeChainId, hubChainId, requestContext, methodContext, { | ||
| error: `${sendHash} has no message sent`, | ||
| }); | ||
| } | ||
|
|
||
| // returns on-chain message status by message hash | ||
| const messageStatus = await sdk.getL1Contract().getMessageStatus(messages[0].messageHash); | ||
| logger.info("Got Message status on hub chain from linea", requestContext, methodContext, { | ||
| sendHash, | ||
| message: messages[0], | ||
| messageStatus, | ||
| }); | ||
|
|
||
| if (messageStatus === "CLAIMED") { | ||
| throw new AlreadyProcessed(spokeChainId, hubChainId, requestContext, methodContext, { | ||
| sendHash, | ||
| messageStatus, | ||
| }); | ||
| } else if (messageStatus === "CLAIMABLE") { | ||
| return [messages[0].messageNonce, messages[0].calldata]; | ||
| } else { | ||
| throw new NoRootAvailable(spokeChainId, hubChainId, requestContext, methodContext, { | ||
| error: `Linea Unknown message status`, | ||
| }); | ||
| } | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
140 changes: 140 additions & 0 deletions
140
packages/agents/lighthouse/test/tasks/processFromRoot/helpers/linea.spec.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,140 @@ | ||
| import { createRequestContext, expect, mkAddress, mkHash } from "@connext/nxtp-utils"; | ||
| import { stub, SinonStub } from "sinon"; | ||
| import { BigNumber } from "ethers"; | ||
|
|
||
| import * as MockableFns from "../../../../src/mockable"; | ||
| import { getProcessFromLineaRootArgs } from "../../../../src/tasks/processFromRoot/helpers"; | ||
| import { AlreadyProcessed, NoRootAvailable } from "../../../../src/tasks/processFromRoot/errors"; | ||
|
|
||
| let getL1Contract: SinonStub; | ||
| let getL2Contract: SinonStub; | ||
|
|
||
| class MockLineaSDK { | ||
| public getL1Contract = getL1Contract; | ||
| public getL2Contract = getL2Contract; | ||
| } | ||
|
|
||
| describe("Helpers: Linea", () => { | ||
| beforeEach(() => { | ||
| stub(MockableFns, "LineaSDK").value(MockLineaSDK); | ||
| }); | ||
|
|
||
| it("should throw error if no messages", async () => { | ||
| getL2Contract = stub().returns({ | ||
| getMessagesByTransactionHash: stub().resolves([]), | ||
| } as any); | ||
| await expect( | ||
| getProcessFromLineaRootArgs({ | ||
| spokeChainId: 1, | ||
| spokeDomainId: "1", | ||
| spokeProvider: "world", | ||
| hubChainId: 2, | ||
| hubDomainId: "2", | ||
| hubProvider: "hello", | ||
| sendHash: mkHash("0xbaa"), | ||
| blockNumber: 123, | ||
| message: mkHash("0xbbbb"), | ||
| _requestContext: createRequestContext("foo"), | ||
| }), | ||
| ).to.be.rejectedWith(NoRootAvailable); | ||
| }); | ||
|
|
||
| it("should throw error if already processed", async () => { | ||
| getL2Contract = stub().returns({ | ||
| getMessagesByTransactionHash: stub().resolves([ | ||
| { | ||
| messageSender: mkAddress("a"), | ||
| destination: mkAddress("b"), | ||
| fee: BigNumber.from(0), | ||
| value: BigNumber.from(0), | ||
| messageNonce: BigNumber.from(1), | ||
| calldata: "0x", | ||
| messageHash: mkHash("0xa"), | ||
| }, | ||
| ]), | ||
| } as any); | ||
| getL1Contract = stub().returns({ | ||
| getMessageStatus: stub().resolves("CLAIMED"), | ||
| }); | ||
| await expect( | ||
| getProcessFromLineaRootArgs({ | ||
| spokeChainId: 1, | ||
| spokeDomainId: "1", | ||
| spokeProvider: "world", | ||
| hubChainId: 2, | ||
| hubDomainId: "2", | ||
| hubProvider: "hello", | ||
| sendHash: mkHash("0xbaa"), | ||
| blockNumber: 123, | ||
| message: mkHash("0xbbbb"), | ||
| _requestContext: createRequestContext("foo"), | ||
| }), | ||
| ).to.be.rejectedWith(AlreadyProcessed); | ||
| }); | ||
|
|
||
| it("should throw error if unknown status", async () => { | ||
| getL2Contract = stub().returns({ | ||
| getMessagesByTransactionHash: stub().resolves([ | ||
| { | ||
| messageSender: mkAddress("a"), | ||
| destination: mkAddress("b"), | ||
| fee: BigNumber.from(0), | ||
| value: BigNumber.from(0), | ||
| messageNonce: BigNumber.from(1), | ||
| calldata: "0x", | ||
| messageHash: mkHash("0xa"), | ||
| }, | ||
| ]), | ||
| } as any); | ||
| getL1Contract = stub().returns({ | ||
| getMessageStatus: stub().resolves("UNKNOWN"), | ||
| }); | ||
| await expect( | ||
| getProcessFromLineaRootArgs({ | ||
| spokeChainId: 1, | ||
| spokeDomainId: "1", | ||
| spokeProvider: "world", | ||
| hubChainId: 2, | ||
| hubDomainId: "2", | ||
| hubProvider: "hello", | ||
| sendHash: mkHash("0xbaa"), | ||
| blockNumber: 123, | ||
| message: mkHash("0xbbbb"), | ||
| _requestContext: createRequestContext("foo"), | ||
| }), | ||
| ).to.be.rejectedWith(NoRootAvailable); | ||
| }); | ||
|
|
||
| it("should work", async () => { | ||
| getL2Contract = stub().returns({ | ||
| getMessagesByTransactionHash: stub().resolves([ | ||
| { | ||
| messageSender: mkAddress("a"), | ||
| destination: mkAddress("b"), | ||
| fee: BigNumber.from(0), | ||
| value: BigNumber.from(0), | ||
| messageNonce: BigNumber.from(1), | ||
| calldata: mkHash("0xa"), | ||
| messageHash: mkHash("0xb"), | ||
| }, | ||
| ]), | ||
| } as any); | ||
| getL1Contract = stub().returns({ | ||
| getMessageStatus: stub().resolves("CLAIMABLE"), | ||
| }); | ||
| const args = await getProcessFromLineaRootArgs({ | ||
| spokeChainId: 1, | ||
| spokeDomainId: "1", | ||
| spokeProvider: "world", | ||
| hubChainId: 2, | ||
| hubDomainId: "2", | ||
| hubProvider: "hello", | ||
| sendHash: mkHash("0xbaa"), | ||
| blockNumber: 123, | ||
| message: mkHash("0xbbbb"), | ||
| _requestContext: createRequestContext("foo"), | ||
| }); | ||
|
|
||
| expect(args).to.deep.eq([BigNumber.from(1), mkHash("0xa")]); | ||
| }); | ||
| }); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.