eth_newBlockFilter | Arbitrum

Arbitrum API method that creates a filter that watches for new blocks on the blockchain. It returns a filter ID, which can be used to retrieve the results using the eth_getFilterChanges method. The eth_newBlockFilter method is useful for developers who must be notified of new blocks on the blockchain in real time.

​

Parameters

• none

​

Response

• result — a hexadecimal string representing the ID of the newly created filter

The filters created are stored on the blockchain client instance. The filter fill is automatically deleted if not polled within a certain time (5 minutes by default).

Use the following methods with the filter ID:

• eth_getFilterChanges to retrieve updates
• eth_uninstallFilter to remove the filter

​

eth_newBlockFilter code examples

const ethers = require('ethers');

const NODE_URL = "CHAINSTACK_NODE_URL";

const provider = new ethers.JsonRpcProvider(NODE_URL);



const createFilter = async () => {

  try {

    const filterId = await provider.send('eth_newBlockFilter', []);

    console.log(filterId); // the filter ID returned by eth_newFilter

    return filterId

  } catch (error) {

    console.log(error);

  }

};



createFilter();

​

Use case

One use case for eth_newBlockFilter in a simple DApp is to listen for new blocks and update the user interface with the latest block information.

When the DApp starts, it creates a new filter using eth_newBlockFilter to listen for new blocks. When a new block is added to the blockchain, the filter is triggered, and the DApp retrieves the latest block information using a Web3 library.

Here is an implementation of this use case using web3.py:

import time

from web3 import Web3  

node_url = "CHAINSTACK_NODE_URL" 

web3 = Web3(Web3.HTTPProvider(node_url))



# Set up a new blocks filter

def get_new_blocks():

    try:

        blocks_filter = web3.eth.filter('latest')



        # Split the string at the space character

        parts = str(blocks_filter).split(' ')



        # Extract the filter value from the second part

        filter_id = parts[2]



        return filter_id

    except Exception as e:

        print(e)



def watch_for_blocks(new_filter):

    # Wait for new blocks to arrive

    while True:

        # Retrieve the changes that match the filter

        changes = web3.eth.getFilterChanges(new_filter)



        # If there are no changes, wait for new blocks

        if len(changes) == 0:

            time.sleep(1)   # Wait for 1 second

            continue



        # Process the new blocks

        for change in changes:

            block = web3.eth.getBlock(change)

            print('New block:', block)



def main():

    # Create a new filter to watch for new blocks

    new_filter = get_new_blocks()

    print(new_filter)

    

    # Watch for new blocks

    watch_for_blocks(new_filter)



if __name__ == '__main__':

    main()

The code is divided into three main functions: get_new_blocks, watch_for_blocks, and main. Let’s take a closer look at each of them:

get_new_blocks is responsible for setting up a new filter to watch for new blocks. The try block sets up the filter by calling the eth.filter method of the web3.py library and passing it the string latest. The split method is then used to split the resulting string at each space character, and the second part of the resulting list is extracted as the filter ID. The filter ID is returned from the function.

watch_for_blocks is the function that watches for new blocks. It does this by first entering an infinite loop while True. Within this loop, the eth_getFilterChanges method is used to retrieve any changes that match the filter ID passed to the function. If there are no changes, the code waits for 1 second using the time.sleep method and then continues with the loop. If there are changes, the new blocks are processed by looping through them and calling the eth.getBlock method of the web3.py library to retrieve the details of each block. Finally, the details of the new blocks are printed on the console.

main is the function that ties everything together. It first calls get_new_blocks to set up a new filter to watch for new blocks, and then passes the resulting filter ID to watch_for_blocks to start watching for new blocks. The filter ID is also printed to the console to confirm that the filter has been set up correctly.