1
// Setup: npm install alchemy-sdk
2
import { Alchemy, AlchemySubscription } from "alchemy-sdk";
3
4
// Optional config object, but defaults to demo api-key and eth-mainnet.
5
const settings = {
6
  apiKey: "demo", // Replace with your Alchemy API Key.
7
  network: Network.ETH_MAINNET, // Replace with your network.
8
};
9
10
const alchemy = new Alchemy(settings);
11
12
// Subscription for new blocks on Eth Mainnet.
13
alchemy.ws.on("block", (blockNumber) =>
14
  console.log("The latest block number is", blockNumber)
15
);
16
17
// Subscription for Alchemy's pendingTransactions Enhanced API
18
alchemy.ws.on(
19
  {
20
    method: AlchemySubscription.PENDING_TRANSACTIONS,
21
    toAddress: "vitalik.eth",
22
  },
23
  (tx) => console.log(tx)
24
);

1
import { Alchemy } from "alchemy-sdk";
2
const alchemy = new Alchemy();
3
4
// Subscribe to new blocks, or newHeads
5
alchemy.ws.on("block", (blockNumber) =>
6
  console.log("Latest block:", blockNumber)
7
);

1
import { Alchemy, AlchemySubscription } from "alchemy-sdk";
2
const alchemy = new Alchemy();
3
4
// Subscription for Alchemy's Mined Transactions  API
5
alchemy.ws.on(
6
  {
7
    method: AlchemySubscription.MINED_TRANSACTIONS,
8
    addresses: [
9
      {
10
        from: "0x473780deaf4a2ac070bbba936b0cdefe7f267dfc",
11
        to: "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",
12
      },
13
      {
14
        to: "0x473780deaf4a2ac070bbba936b0cdefe7f267dfc",
15
      },
16
    ],
17
    includeRemoved: true,
18
    hashesOnly: false,
19
  },
20
  (tx) => console.log(tx)
21
);

1
import { Alchemy, AlchemySubscription } from "alchemy-sdk";
2
const alchemy = new Alchemy();
3
4
// Subscription for Alchemy's pendingTransactions API
5
alchemy.ws.on(
6
  {
7
    method: AlchemySubscription.PENDING_TRANSACTIONS,
8
    toAddress: "vitalik.eth",
9
    fromAddress: "vitalik.eth",
10
  },
11
  (tx) => console.log(tx)
12
);

1
import { Alchemy } from "alchemy-sdk";
2
const alchemy = new Alchemy();
3
4
const txHash = "0xfc89ec10998a74c37a107535ca1cf8714edad409bff40d6da9e8a436cef6daad";
5
6
// Subscription for a specific transaction to be mined
7
alchemy.ws.on(
8
  txHash,
9
  (tx) => console.log(tx)
10
);

1
import { Alchemy } from "alchemy-sdk";
2
const alchemy = new Alchemy();
3
4
// This filter could also be generated with the Contract or
5
// Interface API. If address is not specified, any address
6
// matches and if topics is not specified, any log matches
7
const filter = {
8
  address: "dai.tokens.ethers.eth",
9
  topics: [
10
    utils.id("Transfer(address,address,uint256)")
11
  ]
12
}
13
alchemy.ws.on(filter, (log, event) => {
14
  // Emitted whenever a DAI token transfer occurs
15
})
16
17
// Notice this is an array of topic-sets and is identical to
18
// using a filter with no address (i.e. match any address)
19
const topicSets = [
20
  utils.id("Transfer(address,address,uint256)"),
21
  null,
22
  [
23
    hexZeroPad(myAddress, 32),
24
    hexZeroPad(myOtherAddress, 32)
25
  ]
26
]
27
alchemy.ws.on(topicSets, (log, event) => {
28
  // Emitted any token is sent TO either address
29
})