Auto-Redeem + Expiry-Based Slack Alerts

.env.sample

@@ -2,6 +2,7 @@ NODE_ENV=
 
 RETRYABLE_MONITORING_SLACK_TOKEN=
 RETRYABLE_MONITORING_SLACK_CHANNEL=
+PRIVATE_KEY=
 
 BATCH_POSTER_MONITORING_SLACK_TOKEN=
 BATCH_POSTER_MONITORING_SLACK_CHANNEL=

packages/retryable-monitor/core/redeemRetryable.ts

@@ -0,0 +1,43 @@
+import { providers, Wallet } from 'ethers'
+import {
+  ParentTransactionReceipt,
+  ParentToChildMessageStatus,
+} from '@arbitrum/sdk'
+import { getConfig, DEFAULT_CONFIG_PATH } from '../../utils'
+import dotenv from 'dotenv'
+
+dotenv.config()
+
+export const redeemRetryable = async (parentTxHash: string): Promise<string> => {
+  const config = getConfig({ configPath: DEFAULT_CONFIG_PATH })
+
+  for (const childChain of config.childChains) {
+    try {
+      const parentChainProvider = new providers.JsonRpcProvider(childChain.parentRpcUrl)
+      const receipt = await parentChainProvider.getTransactionReceipt(parentTxHash)
+      if (!receipt) continue // not found on this chain
+
+      // If we found the receipt, this is our matching chain
+      const childChainProvider = new providers.JsonRpcProvider(childChain.orbitRpcUrl)
+      const wallet = new Wallet(process.env.PRIVATE_KEY!, childChainProvider)
+
+      const parentReceipt = new ParentTransactionReceipt(receipt)
+      const messages = await parentReceipt.getParentToChildMessages(wallet)
+      const message = messages[0]
+
+      const result = await message.getSuccessfulRedeem()
+      if (result.status === ParentToChildMessageStatus.REDEEMED) {
+        return result.childTxReceipt.transactionHash
+      }
+
+      const tx = await message.redeem()
+      const redeemReceipt = await tx.waitForRedeem()
+      return redeemReceipt.transactionHash
+    } catch (err) {
+      // Catch and move to next chain silently
+      continue
+    }
+  }
+
+  throw new Error(`❌ Parent tx ${parentTxHash} not found on any known parent chain.`)
+}

packages/retryable-monitor/handlers/notion/alertUntriagedRetraybles.ts

@@ -1,5 +1,6 @@
 import { notionClient, databaseId } from './createNotionClient'
 import { postSlackMessage } from '../slack/postSlackMessage'
+import { redeemRetryable } from '../../core/redeemRetryable'
 
 const formatDate = (iso: string | undefined) => {
   if (!iso) return '(unknown)'
@@ -69,10 +70,37 @@ export const alertUntriagedNotionRetryables = async () => {
         message = `⚠️ Retryable ticket needs triage:\n• Retryable: ${retryableUrl}\n• Timeout: ${timeoutStr}\n• Parent Tx: ${parentTx}\n• Deposit: ${deposit}\n→ Please review and decide whether to redeem or ignore.`
       }
     } else if (decision === 'Should Redeem') {
-      if (!isNearExpiry(timeoutRaw)) continue
-      message = `🚨 Retryable marked for redemption and nearing expiry:\n• Retryable: ${retryableUrl}\n• Timeout: ${timeoutStr}\n• Parent Tx: ${parentTx}\n• Deposit: ${deposit}\n→ Check why it hasn't been executed.`
-    } else {
-      continue
+      const isUnder24h = isNearExpiry(timeoutRaw, 24)
+      const isOver4DaysLeft = hoursLeft > 96
+
+      if (isUnder24h) {
+        message = `🚨 Retryable marked for redemption and nearing expiry:\n• Retryable: ${retryableUrl}\n• Timeout: ${timeoutStr}\n• Parent Tx: ${parentTx}\n• Deposit: ${deposit}\n→ Check why it hasn't been executed.`
+      } else if (isOver4DaysLeft) {
+        try {
+          await redeemRetryable(parentTx)
+
+          await notionClient.pages.update({
+            page_id: page.id,
+            properties: {
+              State: {
+                select: { name: 'Bot Success' },
+              },
+            },
+          })
+        } catch (err) {
+          await notionClient.pages.update({
+            page_id: page.id,
+            properties: {
+              State: {
+                select: { name: 'Bot Failed' },
+              },
+            },
+          })
+        }
+        continue // no Slack message
+      } else {
+        continue // not under 24h or over 4d, skip
+      }
     }
 
     await postSlackMessage({ message })