Skip to content

feat(e2e): Feequoter mcms e2e tests #113

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 3 commits into
base: develop
Choose a base branch
from
Draft

feat(e2e): Feequoter mcms e2e tests #113

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
6529746
add inspector to get opCount
rodrigombsoares Oct 10, 2025
392e36d
add mcms to fee_quoter ops
rodrigombsoares Oct 10, 2025
fe1d5d9
add feequoter tests
rodrigombsoares Oct 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
152 changes: 124 additions & 28 deletions deployment/ops/ccip/op_fee_quoter.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -100,24 +100,48 @@ var applyUpdatesHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps, input Fe
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to create fee quoter contract: %w", err)
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.ApplyFeeTokenUpdates(
b.GetContext(),
opts,
encodedCall, err := contract.Encoder().ApplyFeeTokenUpdates(
bind.Object{Id: input.StateObjectId},
bind.Object{Id: input.OwnerCapObjectId},
input.FeeTokensToRemove,
input.FeeTokensToAdd,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute fee quoter apply_fee_token_updates: %w", err)
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to encode ApplyFeeTokenUpdates call: %w", err)
}
call, err := sui_ops.ToTransactionCall(encodedCall, input.StateObjectId)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to convert encoded call to TransactionCall: %w", err)
}
if deps.Signer == nil {
b.Logger.Infow("Skipping execution of ApplyFeeTokenUpdates on FeeQuoter as per no Signer provided")
return sui_ops.OpTxResult[NoObjects]{
Digest: "",
PackageId: input.CCIPPackageId,
Objects: NoObjects{},
Call: call,
}, nil
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.Bound().ExecuteTransaction(
b.GetContext(),
opts,
encodedCall,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute ApplyFeeTokenUpdates on FeeQuoter: %w", err)
}

b.Logger.Infow("Fee token updates applied to CCIP FeeQuoter")

return sui_ops.OpTxResult[NoObjects]{
Digest: tx.Digest,
PackageId: input.CCIPPackageId,
}, err
Objects: NoObjects{},
Call: call,
}, nil
}

var FeeQuoterApplyFeeTokenUpdatesOp = cld_ops.NewOperation(
Expand Down Expand Up @@ -149,11 +173,7 @@ var applyTokenTransferFeeHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps,
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to create fee quoter contract: %w", err)
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.ApplyTokenTransferFeeConfigUpdates(
b.GetContext(),
opts,
encodedCall, err := contract.Encoder().ApplyTokenTransferFeeConfigUpdates(
bind.Object{Id: input.StateObjectId},
bind.Object{Id: input.OwnerCapObjectId},
input.DestChainSelector,
Expand All @@ -167,13 +187,41 @@ var applyTokenTransferFeeHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps,
input.RemoveTokens,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute fee quoter apply_token_transfer_fee_config_updates: %w", err)
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to encode ApplyTokenTransferFeeConfigUpdates call: %w", err)
}
call, err := sui_ops.ToTransactionCall(encodedCall, input.StateObjectId)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to convert encoded call to TransactionCall: %w", err)
}
if deps.Signer == nil {
b.Logger.Infow("Skipping execution of ApplyTokenTransferFeeConfigUpdates on FeeQuoter as per no Signer provided")
return sui_ops.OpTxResult[NoObjects]{
Digest: "",
PackageId: input.CCIPPackageId,
Objects: NoObjects{},
Call: call,
}, nil
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.Bound().ExecuteTransaction(
b.GetContext(),
opts,
encodedCall,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute ApplyTokenTransferFeeConfigUpdates on FeeQuoter: %w", err)
}

b.Logger.Infow("Token transfer fee config updates applied to CCIP FeeQuoter")

return sui_ops.OpTxResult[NoObjects]{
Digest: tx.Digest,
PackageId: input.CCIPPackageId,
}, err
Objects: NoObjects{},
Call: call,
}, nil
}

var FeeQuoterApplyTokenTransferFeeConfigUpdatesOp = cld_ops.NewOperation(
Expand Down Expand Up @@ -216,11 +264,7 @@ var applyDestChainConfigHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps,
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to create fee quoter contract: %w", err)
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.ApplyDestChainConfigUpdates(
b.GetContext(),
opts,
encodedCall, err := contract.Encoder().ApplyDestChainConfigUpdates(
bind.Object{Id: input.StateObjectId},
bind.Object{Id: input.OwnerCapObjectId},
input.DestChainSelector,
Expand All @@ -245,13 +289,41 @@ var applyDestChainConfigHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps,
input.NetworkFeeUsdCents,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute fee quoter apply_dest_chain_config_updates: %w", err)
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to encode ApplyDestChainConfigUpdates call: %w", err)
}
call, err := sui_ops.ToTransactionCall(encodedCall, input.StateObjectId)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to convert encoded call to TransactionCall: %w", err)
}
if deps.Signer == nil {
b.Logger.Infow("Skipping execution of ApplyDestChainConfigUpdates on FeeQuoter as per no Signer provided")
return sui_ops.OpTxResult[NoObjects]{
Digest: "",
PackageId: input.CCIPPackageId,
Objects: NoObjects{},
Call: call,
}, nil
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.Bound().ExecuteTransaction(
b.GetContext(),
opts,
encodedCall,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute ApplyDestChainConfigUpdates on FeeQuoter: %w", err)
}

b.Logger.Infow("Destination chain config updates applied to CCIP FeeQuoter")

return sui_ops.OpTxResult[NoObjects]{
Digest: tx.Digest,
PackageId: input.CCIPPackageId,
}, err
Objects: NoObjects{},
Call: call,
}, nil
}

var FeeQuoterApplyDestChainConfigUpdatesOp = cld_ops.NewOperation(
Expand All @@ -276,24 +348,48 @@ var applyPremiumMultiplierHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to create fee quoter contract: %w", err)
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.ApplyPremiumMultiplierWeiPerEthUpdates(
b.GetContext(),
opts,
encodedCall, err := contract.Encoder().ApplyPremiumMultiplierWeiPerEthUpdates(
bind.Object{Id: input.StateObjectId},
bind.Object{Id: input.OwnerCapObjectId},
input.Tokens,
input.PremiumMultiplierWeiPerEth,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute fee quoter apply_premium_multiplier_wei_per_eth_updates: %w", err)
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to encode ApplyPremiumMultiplierWeiPerEthUpdates call: %w", err)
}
call, err := sui_ops.ToTransactionCall(encodedCall, input.StateObjectId)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to convert encoded call to TransactionCall: %w", err)
}
if deps.Signer == nil {
b.Logger.Infow("Skipping execution of ApplyPremiumMultiplierWeiPerEthUpdates on FeeQuoter as per no Signer provided")
return sui_ops.OpTxResult[NoObjects]{
Digest: "",
PackageId: input.CCIPPackageId,
Objects: NoObjects{},
Call: call,
}, nil
}

opts := deps.GetCallOpts()
opts.Signer = deps.Signer
tx, err := contract.Bound().ExecuteTransaction(
b.GetContext(),
opts,
encodedCall,
)
if err != nil {
return sui_ops.OpTxResult[NoObjects]{}, fmt.Errorf("failed to execute ApplyPremiumMultiplierWeiPerEthUpdates on FeeQuoter: %w", err)
}

b.Logger.Infow("Premium multiplier wei per eth updates applied to CCIP FeeQuoter")

return sui_ops.OpTxResult[NoObjects]{
Digest: tx.Digest,
PackageId: input.CCIPPackageId,
}, err
Objects: NoObjects{},
Call: call,
}, nil
}

var FeeQuoterApplyPremiumMultiplierWeiPerEthUpdatesOp = cld_ops.NewOperation(
Expand Down
18 changes: 16 additions & 2 deletions deployment/ops/mcms/op_proposal_generate.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,13 @@ import (

"github.com/Masterminds/semver/v3"
cld_ops "github.com/smartcontractkit/chainlink-deployments-framework/operations"
sui_ops "github.com/smartcontractkit/chainlink-sui/deployment/ops"
"github.com/smartcontractkit/mcms"
suisdk "github.com/smartcontractkit/mcms/sdk/sui"
"github.com/smartcontractkit/mcms/types"
mcmstypes "github.com/smartcontractkit/mcms/types"

sui_ops "github.com/smartcontractkit/chainlink-sui/deployment/ops"
"github.com/smartcontractkit/chainlink-sui/relayer/signer"
)

var DefaultTimelockExpirationInHours = 72
Expand Down Expand Up @@ -88,7 +90,19 @@ var generateProposalHandler = func(b cld_ops.Bundle, deps sui_ops.OpTxDeps, inpu
}

validUntilMs := uint32(time.Now().Add(time.Duration(DefaultTimelockExpirationInHours) * time.Hour).Unix())
metadata, err := suisdk.NewChainMetadata(0, input.Role, input.MmcsPackageID, input.McmsStateObjID, input.AccountObjID, input.RegistryObjID, input.TimelockObjID)

// Get OP Count from inspector
devInspectSigner := signer.NewDevInspectSigner("0x0")
inspector, err := suisdk.NewInspector(deps.Client, devInspectSigner, input.MmcsPackageID, input.Role)
if err != nil {
return mcms.TimelockProposal{}, fmt.Errorf("failed to create inspector: %w", err)
}
opCount, err := inspector.GetOpCount(b.GetContext(), input.McmsStateObjID)
if err != nil {
return mcms.TimelockProposal{}, fmt.Errorf("failed to get op count: %w", err)
}

metadata, err := suisdk.NewChainMetadata(opCount, input.Role, input.MmcsPackageID, input.McmsStateObjID, input.AccountObjID, input.RegistryObjID, input.TimelockObjID)
if err != nil {
return mcms.TimelockProposal{}, fmt.Errorf("failed to create chain metadata: %w", err)
}
Expand Down
Loading
Loading