How to Monitor High-Value ERC20 Transfers in Real Time

const ERC20_transfer_ABI = [{
  "anonymous": false,
  "inputs": [
    { "indexed": true, "name": "from", "type": "address" },
    { "indexed": true, "name": "to", "type": "address" },
    { "indexed": false, "name": "value", "type": "uint256" },
  ],
  "name": "transfer",
  "type": "event",
}]; // valid abi of the event

const filter_ERC20 = {
  "and": [
    { "eq": ["from", "0x283af0b28c62c092c9727f1ee09c02ca627eb7f5"] },
    { "gt": ["value", "1000000000"] }, // Example of USDT (6 Decimals)
  ],
}; // only receive ERC20 contract transfers where sender is a specific address and the number of coins transferred is over 1000

const options = {
  chains: [EvmChain.ETHEREUM], // list of blockchains to monitor
  description: "monitor all ERC20 transfers", // your description
  tag: "ERC20_transfers", // give it a tag
  abi: ERC20_transfer_ABI,
  includeContractLogs: true,
  allAddresses: true,
  topic0: ["Transfer(address,address,uint256)"], // topic of the event
  advancedOptions: [
    {
      topic0: "Transfer(address,address,uint256)",
      filter: filter_ERC20
    },
  ],
  webhookUrl: "https://YOUR_WEBHOOK_URL", // webhook url to receive events,
};

const stream = await Moralis.Streams.add(options);

[
  {
    "topic0": "Transfer(address,address,uint256)",
    "filter": {
      "and": [
        { "eq": ["from", "0x283af0b28c62c092c9727f1ee09c02ca627eb7f5"] },
        { "gt": ["value", "1000000000"] }
      ]
    }
  }
]