Listening for on-chain transfers with Webhooks

import express from 'express'
import axios from 'axios'

const app = express();
app.use(express.json());

app.post("/", (req, res) => {
  const data = req.body;
  const discordWebhookUrl = 'PUT_YOUR_DISCORD_URL_HERE'

  let messageContent = 'A new ' + data.eventType + ' event was received from the webhook: \n```'
  messageContent += JSON.stringify(data, null, 2)
  messageContent += '```\n'
  messageContent += `Data received at ${new Date().toLocaleString("en-US")}`

  const postData = {
    content: messageContent,
  }
  axios.post(discordWebhookUrl, postData).then(() => console.log('Successfully called discord.')).catch(console.log);

  res.sendStatus(200);
});


const PORT = 3000;
app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
});

import { Coinbase, Webhook, Wallet } from "@coinbase/coinbase-sdk";

// Change this to the path of your API key file (if downloaded) from CDP portal.
// Make sure your [API key](https://portal.cdp.coinbase.com/projects/api-keys) file path (if downloaded) matches the path on the code you just copied:
// `Coinbase.configureFromJson({ filePath: "~/Downloads/cdp_api_key.json" });`

// For better security, it is recommended to use environment variables instead of downloading the API key file.
Coinbase.configureFromJson({ filePath: "~/Downloads/cdp_api_key.json" });

// Change this URL to the one from Pinggy
const webhookNotificationUri = 'YOUR_NOTIFICATION_URL'


// Now create a couple of wallets:
let myWallet = await Wallet.create();
let anotherWallet = await Wallet.create();

// After you created the wallet, let's add some USDC funds to it:
const faucetTx = await myWallet.faucet(Coinbase.assets.Usdc);

// Wait for the faucet transaction to confirm.
await faucetTx.wait();

// Now use below code to get wallets addresses so we can use it for adding it to the webhook filter.
let myWalletAddress = await myWallet.getDefaultAddress();
const myWalletAddressId = myWalletAddress.getId();

await Webhook.create({
  networkId: Coinbase.networks.BaseSepolia,
    notificationUri: webhookNotificationUri,
    eventType: 'wallet_activity',
    eventTypeFilter: {
      addresses: [myWalletAddressId],
    },
});

// Sometimes funds take a few seconds to be available on the wallet, so let's wait 3 secs
await sleep(3000)

// For testing this above example, let's now create a transfer between both wallets we created:
// Create transfer from myWallet to anotherWallet
const transfer = await myWallet.createTransfer({
  amount: 0.0001,
  assetId: Coinbase.assets.Usdc,
  destination: anotherWallet,
  gasless: true, // for USDC, you can add gasless flag, so you don't need to add ETH funds for paying for gas fees
});

// Wait for the transfer to complete or fail on-chain
await transfer.wait({
  intervalSeconds: 1, // check for transfer completion each 1 second
  timeoutSeconds: 30, // keep checking for 30 seconds
});
console.log('Transfer was successful: ', transfer.toString());


function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}