Add persistence filtering, ARM/otoken/buyback custom renderers, and remove transactionLogs from config-alert

Author: apexearth

src/notify/event/renderers/arm.ts

@@ -22,6 +22,10 @@ const armFunctions = {
   traderate1: viewFun('0xcf1de5d8', 'traderate1()', {}, p.uint256),
 }
 
+const erc4626Functions = {
+  convertToAssets: viewFun('0x07a2d13a', 'convertToAssets(uint256)', { shares: p.uint256 }, p.uint256),
+}
+
 class ArmContract extends ContractBase {
   traderate0() {
     return this.eth_call(armFunctions.traderate0, {})
@@ -31,12 +35,21 @@ class ArmContract extends ContractBase {
   }
 }
 
+class ERC4626Contract extends ContractBase {
+  convertToAssets(shares: bigint) {
+    return this.eth_call(erc4626Functions.convertToAssets, { shares })
+  }
+}
+
 interface ArmConfig {
   address: string
   symbol0: string
   symbol1: string
   token0: string
   token1: string
+  // ERC4626 vault token whose rate needs converting (e.g. sUSDe)
+  // When set, rates are adjusted by the vault's convertToAssets rate
+  vaultToken?: string
 }
 
 // Build lookup from ARM contract address to config
@@ -68,6 +81,7 @@ registerArm({
   symbol1: 'sUSDe',
   token0: addresses.tokens.USDe,
   token1: addresses.tokens.sUSDe,
+  vaultToken: addresses.tokens.sUSDe,
 })
 
 registerArm({
@@ -81,6 +95,26 @@ registerArm({
 // Cache traderates per ARM address
 const traderateCache = new Map<string, { traderate0: bigint; traderate1: bigint }>()
 
+// Cache vault exchange rate (e.g. sUSDe → USDe)
+const vaultRateCache = new Map<string, bigint>()
+const ONE = 10n ** 18n
+
+type RendererCtx = Parameters<Parameters<typeof registerEventRenderer>[1]>[0]['ctx']
+type RendererBlock = Parameters<Parameters<typeof registerEventRenderer>[1]>[0]['log']['block']
+
+async function getVaultRate(ctx: RendererCtx, block: RendererBlock, vaultToken: string): Promise<bigint> {
+  const cached = vaultRateCache.get(vaultToken)
+  if (cached) return cached
+  try {
+    const contract = new ERC4626Contract(ctx, block, vaultToken)
+    const rate = await contract.convertToAssets(ONE)
+    vaultRateCache.set(vaultToken, rate)
+    return rate
+  } catch {
+    return ONE // Fallback: assume 1:1
+  }
+}
+
 async function getTraderates(
   ctx: Parameters<Parameters<typeof registerEventRenderer>[1]>[0]['ctx'],
   block: Parameters<Parameters<typeof registerEventRenderer>[1]>[0]['log']['block'],
@@ -112,16 +146,27 @@ registerEventRenderer(TraderateChanged.topic, async (params) => {
     traderate1: data.traderate1,
   })
 
+  // For vault tokens (e.g. sUSDe), adjust rates to show USDe-equivalent value
+  let sellRate = 10n ** 72n / data.traderate0 // 1e36 precision
+  let buyRate = data.traderate1 // 1e36 precision
+  let rateLabel = `${arm.symbol1}/${arm.symbol0}`
+
+  if (arm.vaultToken) {
+    const vaultRate = await getVaultRate(params.ctx, params.log.block, arm.vaultToken)
+    // Multiply by vault rate to convert sUSDe amounts to USDe-equivalent
+    sellRate = (sellRate * vaultRate) / ONE
+    buyRate = (buyRate * vaultRate) / ONE
+    rateLabel = `${arm.symbol0}/${arm.symbol0}` // e.g. USDe/USDe
+  }
+
   renderEventDiscordEmbed(params, {
     fields: [
       {
-        name: `${formatAmount(10n ** 72n / data.traderate0, 36, { maximumFractionDigits: 8 })} ${arm.symbol1}/${
-          arm.symbol0
-        }`,
+        name: `${formatAmount(sellRate, 36, { maximumFractionDigits: 8 })} ${rateLabel}`,
         value: 'Sell Price',
       },
       {
-        name: `${formatAmount(data.traderate1, 36, { maximumFractionDigits: 8 })} ${arm.symbol1}/${arm.symbol0}`,
+        name: `${formatAmount(buyRate, 36, { maximumFractionDigits: 8 })} ${rateLabel}`,
         value: 'Buy Price',
       },
     ],
@@ -180,6 +225,18 @@ registerEventRenderer(erc20Abi.events.Transfer.topic, async (params) => {
       rate = Number(rates.traderate1) / 1e36
     }
 
+    // For vault tokens, convert output to underlying-equivalent for rate display
+    if (arm.vaultToken) {
+      const vaultRate = await getVaultRate(params.ctx, params.log.block, arm.vaultToken)
+      if (isToken0In) {
+        // Output is in vault token (sUSDe), convert to USDe-equivalent for rate
+        rate = (rate * Number(vaultRate)) / 1e18
+      } else {
+        // Input is vault token (sUSDe), adjust rate
+        rate = (rate * 1e18) / Number(vaultRate)
+      }
+    }
+
     fields.push({
       name: formatAmount(outAmount, 18, { maximumFractionDigits: 6 }),
       value: `${outSymbol} out`,

src/notify/event/renderers/otoken-buyback.ts

@@ -0,0 +1,32 @@
+import { event, indexed } from '@subsquid/evm-abi'
+import * as p from '@subsquid/evm-codec'
+
+import { discordIconOrName } from '../../const'
+import { registerEventRenderer } from '../event'
+import { renderEventDiscordEmbed } from './utils'
+import { formatAmount } from '../../../utils/formatAmount'
+
+const OTokenBuyback = event(
+  '0x298e4dbf1f6f43b0e8cd13394bba43125c8c376005b44b664a9fd2eaaeb44743',
+  'OTokenBuyback(address,address,uint256,uint256)',
+  { oToken: indexed(p.address), swappedFor: indexed(p.address), swapAmountIn: p.uint256, amountOut: p.uint256 },
+)
+
+// OTokenBuyback — shows oToken sent and token received with icons
+registerEventRenderer(OTokenBuyback.topic, async (params) => {
+  const data = OTokenBuyback.decode(params.log)
+  renderEventDiscordEmbed(params, {
+    fields: [
+      {
+        name: formatAmount(data.swapAmountIn),
+        value: `${discordIconOrName(data.oToken) ?? data.oToken} Sent`,
+        inline: true,
+      },
+      {
+        name: formatAmount(data.amountOut),
+        value: `${discordIconOrName(data.swappedFor) ?? data.swappedFor} Received`,
+        inline: true,
+      },
+    ],
+  })
+})

src/notify/event/renderers/otoken.ts

@@ -0,0 +1,55 @@
+import { ContractBase, event, viewFun } from '@subsquid/evm-abi'
+import * as p from '@subsquid/evm-codec'
+
+import { formatAmount } from '../../../utils/formatAmount'
+import { transactionLink } from '../../../utils/links'
+import { registerEventRenderer } from '../event'
+import { renderDiscordEmbed } from './utils'
+
+const TotalSupplyUpdatedHighres = event(
+  '0x41645eb819d3011b13f97696a8109d14bfcddfaca7d063ec0564d62a3e257235',
+  'TotalSupplyUpdatedHighres(uint256,uint256,uint256)',
+  { totalSupply: p.uint256, rebasingCredits: p.uint256, rebasingCreditsPerToken: p.uint256 },
+)
+
+const totalSupplyFn = viewFun('0x18160ddd', 'totalSupply()', {}, p.uint256)
+
+class OTokenContract extends ContractBase {
+  totalSupply() {
+    return this.eth_call(totalSupplyFn, {})
+  }
+}
+
+// TotalSupplyUpdatedHighres — shows previous, current, and diff
+registerEventRenderer(TotalSupplyUpdatedHighres.topic, async (params) => {
+  const data = TotalSupplyUpdatedHighres.decode(params.log)
+
+  let previousSupply: bigint | undefined
+  try {
+    const contract = new OTokenContract(params.ctx, { height: params.log.block.height - 1 }, params.log.address)
+    previousSupply = await contract.totalSupply()
+  } catch {
+    // RPC call failed — render without diff
+  }
+
+  const fields: { name: string; value: string; inline: boolean }[] = []
+  if (previousSupply !== undefined) {
+    const diff = data.totalSupply - previousSupply
+    fields.push(
+      { name: formatAmount(previousSupply), value: 'Previous', inline: true },
+      { name: formatAmount(data.totalSupply), value: 'Current', inline: true },
+      { name: formatAmount(diff), value: 'Diff', inline: true },
+    )
+  } else {
+    fields.push({ name: formatAmount(data.totalSupply), value: 'Total Supply', inline: true })
+  }
+
+  renderDiscordEmbed({
+    sortId: `${params.log.block.height}:${params.log.transactionIndex}:${params.log.logIndex}`,
+    topic: params.topic,
+    severity: params.severity,
+    title: `${params.name} - TotalSupplyUpdatedHighres`,
+    titleUrl: transactionLink(params.log.transactionHash, params.ctx.chain),
+    fields,
+  })
+})