Withdraw Funds

curl -X POST "https://earn.turtle.xyz/v2/streams/550e8400-e29b-41d4-a716-446655440000/withdrawals" \
  -H "X-API-Key: sk_live_xxxxx" \
  -H "Content-Type: application/json" \
  -d '{}'

{
  "message": "Successfully generated withdraw funds signature",
  "txParams": {
    "chainId": 8453,
    "sender": "0x1111111111111111111111111111111111111111",
    "params": {
      "params": {
        "stream": "0x2222222222222222222222222222222222222222",
        "to": "0x1111111111111111111111111111111111111111",
        "amount": "1500000000"
      },
      "salt": "0x3f9a6c2e1b7d4f8a0c5e9b2d6f1a4c8e7b3d0f5a9c2e6b1d4f8a7c3e0b5d9f2a",
      "deadline": 1790859600,
      "signature": "MEUCIA...base64..."
    }
  }
}

import { ethers } from 'ethers';

const STREAM_FACTORY_BY_CHAIN: Record<number, string> = {
  1: '0xf44399a74ee5ddef7fa3d064cf66b011ee4a6cae',
  56: '0x298d2967588b5c93a137ce1a05d0b8cfffb3c120',
  43114: '0x4559605e3003fda8c059e14af4f16ba9a004335a',
  8453: '0x4559605e3003fda8c059e14af4f16ba9a004335a',
  11155111: '0xdfdff939d728585ce8a2cf2d4166f043d917d8d2',
};

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

type WithdrawFundsTxParams = {
  chainId: number;
  sender: string;
  params: {
    params: { stream: string; to: string; amount: string };
    salt: string;
    deadline: number;
    signature: string;
  };
};

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

// txParams comes from your backend, which called
// POST /v2/streams/{id}/withdrawals with the secret key.
async function submitWithdrawal(txParams: WithdrawFundsTxParams) {
  const streamFactoryAddress = STREAM_FACTORY_BY_CHAIN[txParams.chainId];

  if (!streamFactoryAddress) {
    throw new Error(`Unsupported StreamFactory for chainId ${txParams.chainId}`);
  }

  if (Date.now() / 1000 >= txParams.params.deadline) {
    throw new Error('The withdrawal signature has expired; request a new one');
  }

  const provider = new ethers.BrowserProvider(window.ethereum);
  await provider.send('eth_requestAccounts', []);

  const signer = await provider.getSigner();
  const signerAddress = await signer.getAddress();
  const connectedChainId = Number((await provider.getNetwork()).chainId);

  if (signerAddress.toLowerCase() !== txParams.sender.toLowerCase()) {
    throw new Error(`Connected wallet ${signerAddress} is not the stream admin ${txParams.sender}`);
  }

  if (connectedChainId !== txParams.chainId) {
    throw new Error(`Connected chain ${connectedChainId} does not match txParams.chainId ${txParams.chainId}`);
  }

  const streamFactory = new ethers.Contract(
    streamFactoryAddress,
    STREAM_FACTORY_ABI,
    signer,
  );

  const withdrawTx = await streamFactory.withdrawFunds(
    {
      stream: txParams.params.params.stream,
      to: txParams.params.params.to,
      amount: txParams.params.params.amount,
    },
    txParams.params.salt,
    txParams.params.deadline,
    base64ToBytes(txParams.params.signature),
  );

  const receipt = await withdrawTx.wait();

  console.log('Withdrawal tx hash:', receipt?.hash);
}