processBytecode Contract

type TxIntent = {
  clientTxId: string
  bytecodes: Array<{
    chainId?: number
    to: string
    data: string
    value: string
    gasLimit?: string
  }>
  simulateError?: boolean
}

import type { UpdateTxStatus } from 'pods-sdk'

function groupByChainId(bytecodes: TxIntent['bytecodes']) {
  const grouped = new Map<number, TxIntent['bytecodes']>()
  for (const tx of bytecodes) {
    const chainId = tx.chainId ?? 0
    const list = grouped.get(chainId) ?? []
    list.push(tx)
    grouped.set(chainId, list)
  }
  return grouped
}

export async function processBytecode(
  payload: {
    clientTxId: string
    bytecodes: Array<{ chainId?: number; to: string; data: string; value: string; gasLimit?: string }>
  },
  ctx: { updateTxStatus: UpdateTxStatus }
) {
  const { clientTxId, bytecodes } = payload

  try {
    ctx.updateTxStatus({ type: 'HOST_ACK', clientTxId })

    for (const [chainId, legs] of groupByChainId(bytecodes)) {
      ctx.updateTxStatus({ type: 'SIGNATURE_PROMPTED', clientTxId })

      // One atomic submission for all legs on this chain (e.g. smart wallet sendTransaction({ calls }))
      const txHash = await sendBatchedTransactionWithWallet({ chainId, legs })
      ctx.updateTxStatus({ type: 'TX_SUBMITTED', clientTxId, chainId, txHash })

      const receipt = await waitForReceipt(txHash)
      if (receipt.status !== 1) {
        ctx.updateTxStatus({ type: 'TX_REVERTED', clientTxId, txHash, reason: 'Execution reverted' })
        return
      }

      ctx.updateTxStatus({
        type: 'TX_CONFIRMED',
        clientTxId,
        txHash,
        blockNumber: receipt.blockNumber,
        confirmations: 1
      })
    }

    ctx.updateTxStatus({ type: 'TX_FINALIZED', clientTxId })
  } catch (error: any) {
    if (error?.code === 4001 || error?.code === 'ACTION_REJECTED') {
      ctx.updateTxStatus({ type: 'SIGNATURE_DECLINED', clientTxId })
      return
    }

    ctx.updateTxStatus({
      type: 'SIGNATURE_ERROR',
      clientTxId,
      code: String(error?.code ?? 'UNKNOWN_ERROR'),
      message: String(error?.message ?? 'Transaction failed')
    })
  }
}