Pay many recipients in one transaction.

import { createPublicClient, createWalletClient, http, type Address } from "viem";
import { sepolia } from "viem/chains";
import { privateKeyToAccount } from "viem/accounts";
import { createSepoliaEncryptor, ensureOperator } from "@tokenops/sdk/fhe";
import { createConfidentialDisperseClient } from "@tokenops/sdk/fhe-disperse";

const account = privateKeyToAccount(process.env.PRIVATE_KEY as `0x${string}`);
const rpcUrl = process.env.RPC_URL!;
const publicClient = createPublicClient({ chain: sepolia, transport: http(rpcUrl) });
const walletClient = createWalletClient({ account, chain: sepolia, transport: http(rpcUrl) });

const encryptor = await createSepoliaEncryptor({ rpcUrl });

try {
  // The singleton address resolves from DEPLOYED_ADDRESSES on Sepolia and mainnet.
  const client = createConfidentialDisperseClient({ publicClient, walletClient, encryptor });
  const token = process.env.TOKEN as Address;

  // 1. Register once: deploys your two subwallets and approves them for `token`.
  if (!(await client.isRegistered(account.address))) {
    const { wallets } = await client.register({ token });
    console.log("Subwallets:", wallets);
  } else if (!(await client.hasApprovedSubwallets({ user: account.address, token })).both) {
    // register approved the subwallets only for the token it was given.
    await client.approveTokenOnWallets({ token });
  }

  // 2. Every mode pulls from your balance through the singleton, so approve it as
  //    an ERC-7984 operator. Sends setOperator only when the grant is missing.
  await ensureOperator({
    publicClient,
    walletClient,
    token,
    spender: client.address,
    deadline: BigInt(Math.floor(Date.now() / 1000) + 3600), // one hour
  });

  const recipients: Address[] = ["0xRecipient1", "0xRecipient2"];
  const amounts = [1_000_000n, 500_000n]; // base units; the test tokens use 6 decimals

  // 3. Preflight: registration, both approvals, fee vs ETH balance, batch and
  //    input-proof limits, per-recipient checks.
  const report = await client.preflightDisperse({
    user: account.address,
    token,
    recipients,
    amounts,
    mode: "wallet",
  });
  if (!report.ready) {
    // TokenOpsSdkError[]: branch on error.code, or render error.message.
    throw new Error(report.blockerErrors.map((e) => e.message).join("; "));
  }

  // 4. Encrypt + disperse. Throws ReceiptEventNotFoundError if the tx reverted.
  const { hash, distributions } = await client.disperse({
    token,
    mode: "wallet",
    recipients,
    amounts,
  });
  console.log(hash, distributions.length);
} finally {
  encryptor.terminate();
}