Web3 Functions, after Gelato.

import { Web3Function, Web3FunctionContext } from '@gelatonetwork/web3-functions-sdk'
import { Contract } from '@ethersproject/contracts'

const ORACLE_ABI = [
  'function lastUpdated() view returns (uint256)',
  'function updatePrice(uint256)',
]

Web3Function.onRun(async (context: Web3FunctionContext) => {
  const { userArgs, multiChainProvider, secrets } = context
  const provider = multiChainProvider.default()
  const oracle = new Contract(userArgs.oracle as string, ORACLE_ABI, provider)

  const lastUpdated = Number(await oracle.lastUpdated())
  if (Date.now() / 1000 < lastUpdated + 3600) {
    return { canExec: false, message: 'Time not elapsed' }
  }

  // fetchPrice is your existing API helper
  const price = await fetchPrice(await secrets.get('PRICE_API_KEY'))

  return {
    canExec: true,
    callData: [{
      to: userArgs.oracle as string,
      data: oracle.interface.encodeFunctionData('updatePrice', [price]),
    }],
  }
})

import { defineTask, z } from '@thyme-labs/sdk'
import { encodeFunctionData, parseAbi } from 'viem'

const abi = parseAbi([
  'function lastUpdated() view returns (uint256)',
  'function updatePrice(uint256)',
])

export default defineTask({
  schema: z.object({ oracle: z.address() }),
  async run(ctx) {
    const lastUpdated = await ctx.client.readContract({
      address: ctx.args.oracle,
      abi,
      functionName: 'lastUpdated',
    })
    if (Date.now() / 1000 < Number(lastUpdated) + 3600) {
      return { canExec: false, message: 'Time not elapsed' }
    }

    // fetchPrice is your existing API helper
    const price = await fetchPrice(ctx.secrets.PRICE_API_KEY)

    return {
      canExec: true,
      calls: [{
        to: ctx.args.oracle,
        data: encodeFunctionData({
          abi,
          functionName: 'updatePrice',
          args: [price],
        }),
      }],
    }
  },
})