Skip to content

fix(evm): buffer arbitrum gasPrice/maxFeePerGas to prevent base-fee-drift tx failures #1282

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

Merged
kaladinlight merged 2 commits into from
Jul 10, 2026
Merged

fix(evm): buffer arbitrum gasPrice/maxFeePerGas to prevent base-fee-drift tx failures #1282

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c246b14
fix(evm): buffer arbitrum gasPrice/maxFeePerGas to prevent base-fee-d…
kaladinlight Jul 10, 2026
07940ac
fix(evm): enforce fee multiplier arity with tuple types
kaladinlight Jul 10, 2026
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
10 changes: 9 additions & 1 deletion node/coinstacks/arbitrum/api/src/controller.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,15 @@ const alchemyClient = createPublicClient({
transport: http(`https://arb-mainnet.g.alchemy.com/v2/${ALCHEMY_API_KEY}`),
})

export const service = new MoralisService({ chain: EvmChain.ARBITRUM, logger, client, rpcUrl })
export const service = new MoralisService({
chain: EvmChain.ARBITRUM,
logger,
client,
rpcUrl,
baseFeeMultiplier: [1.5, 2, 3],
gasPriceMultiplier: [1.1, 1.2, 1.5],
})

export const cache = new EventCache({ client, alchemyClient, logger })

// assign service to be used for all instances of EVM
Expand Down
18 changes: 14 additions & 4 deletions node/coinstacks/common/api/src/evm/moralisService.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,11 @@ const FEE_HISTORY_BLOCK_COUNT = 100
// reward percentiles used to estimate [slow, average, fast] priority fees respectively
const REWARD_PERCENTILES = [50, 70, 90]

// multiplier applied to the next base fee when calculating maxFeePerGas so the tx stays valid as the base fee rises
const BASE_FEE_MULTIPLIER = 2
// default per-tier multipliers [slow, average, fast] for base fee
const DEFAULT_BASE_FEE_MULTIPLIER: [number, number, number] = [2, 2, 2]

// default per-tier multipliers [slow, average, fast] for gas price
const DEFAULT_GAS_PRICE_MULTIPLIER: [number, number, number] = [1, 1, 1]

// drop priority fees above the median by this factor to keep outliers (mev/overpayers) from skewing estimates
const OUTLIER_THRESHOLD_MULTIPLIER = 10
Expand All @@ -52,6 +55,8 @@ export interface MoralisServiceArgs {
rpcUrl: string
explorerApiUrl?: URL
minPriorityFee?: string
baseFeeMultiplier?: [number, number, number]
gasPriceMultiplier?: [number, number, number]
}

export class MoralisService implements Omit<BaseAPI, 'getInfo'>, API, AddressSubscriptionClient {
Expand All @@ -61,6 +66,8 @@ export class MoralisService implements Omit<BaseAPI, 'getInfo'>, API, AddressSub
private readonly rpcUrl: string
private readonly explorerApiUrl: URL
private readonly minPriorityFee: string
private readonly baseFeeMultiplier: [number, number, number]
private readonly gasPriceMultiplier: [number, number, number]

private secret?: string
private streamId?: string
Expand All @@ -82,6 +89,8 @@ export class MoralisService implements Omit<BaseAPI, 'getInfo'>, API, AddressSub
this.rpcUrl = args.rpcUrl
this.explorerApiUrl = args.explorerApiUrl ?? new URL('about:blank')
this.minPriorityFee = args.minPriorityFee ?? '0'
this.baseFeeMultiplier = args.baseFeeMultiplier ?? DEFAULT_BASE_FEE_MULTIPLIER
this.gasPriceMultiplier = args.gasPriceMultiplier ?? DEFAULT_GAS_PRICE_MULTIPLIER

void Moralis.start({ evmApiBaseUrl: INDEXER_URL, apiKey: INDEXER_API_KEY })
void Moralis.Streams.setSettings({ region: 'us-east-1' })
Expand Down Expand Up @@ -386,10 +395,11 @@ export class MoralisService implements Omit<BaseAPI, 'getInfo'>, API, AddressSub
let maxPriorityFeePerGas = BigNumber(this.minPriorityFee)
const [slow, average, fast] = REWARD_PERCENTILES.map((_, index): Fees => {
maxPriorityFeePerGas = BigNumber.max(estimatePriorityFee(index), maxPriorityFeePerGas)
const maxFeePerGas = baseFeePerGas.times(BASE_FEE_MULTIPLIER).plus(maxPriorityFeePerGas)
const maxFeePerGas = baseFeePerGas.times(this.baseFeeMultiplier[index]).plus(maxPriorityFeePerGas)
const gasPrice = baseFeePerGas.times(this.gasPriceMultiplier[index]).plus(maxPriorityFeePerGas)
Comment thread
kaladinlight marked this conversation as resolved.

return {
gasPrice: baseFeePerGas.plus(maxPriorityFeePerGas).toFixed(0),
gasPrice: gasPrice.toFixed(0),
maxFeePerGas: maxFeePerGas.toFixed(0),
maxPriorityFeePerGas: maxPriorityFeePerGas.toFixed(0),
}
Expand Down
Loading