Get Active Admin Operation

operation: ActiveAdminOperation | null

import { ethers } from 'ethers';

const STREAM_FACTORY_ABI = [
  'function withdrawFunds((address stream,address to,uint256 amount) params,bytes32 salt,uint40 deadline,bytes signature) external',
  'function addFunds((address stream,uint256 netAmount,uint256 feeAmount) params,bytes32 salt,uint40 deadline,bytes signature) external',
];

const ERC20_ABI = [
  'function approve(address spender, uint256 amount) external returns (bool)',
];

function base64ToBytes(value: string): Uint8Array {
  return Uint8Array.from(atob(value), (char) => char.charCodeAt(0));
}

// Backend: decide whether there is anything to submit.
const response = await fetch(
  `https://earn.turtle.xyz/v2/streams/${streamId}/admin-operations/active`,
  { headers: { 'X-API-Key': process.env.TURTLE_SECRET_KEY! } }
);
const { operation } = await response.json();

const canSubmit =
  operation !== null &&
  operation.confirmedTxHash === null &&
  operation.txParams.params.deadline > Date.now() / 1000;

// Wallet: the stream admin (operation.txParams.sender) on operation.txParams.chainId.
// streamFactoryAddress is the StreamFactory for operation.txParams.chainId.
// rewardTokenAddress is the stream's rewardToken.address from Get Streams.
if (canSubmit) {
  const { params, salt, deadline, signature } = operation.txParams.params;
  const streamFactory = new ethers.Contract(streamFactoryAddress, STREAM_FACTORY_ABI, signer);

  let tx;
  switch (operation.type) {
    case 'withdraw':
      tx = await streamFactory.withdrawFunds(
        { stream: params.stream, to: params.to, amount: params.amount },
        salt,
        deadline,
        base64ToBytes(signature),
      );
      break;

    case 'add_funds': {
      // addFunds pulls netAmount + feeAmount of the reward token from the admin wallet.
      const rewardToken = new ethers.Contract(rewardTokenAddress, ERC20_ABI, signer);
      const approveTx = await rewardToken.approve(
        streamFactoryAddress,
        BigInt(params.netAmount) + BigInt(params.feeAmount),
      );
      await approveTx.wait();

      tx = await streamFactory.addFunds(
        { stream: params.stream, netAmount: params.netAmount, feeAmount: params.feeAmount },
        salt,
        deadline,
        base64ToBytes(signature),
      );
      break;
    }

    default:
      throw new Error(`Unsupported admin operation type: ${operation.type}`);
  }

  await tx.wait();
}