clearSubscriptions | Avalanche

const { ethers } = require("ethers");
const NODE_URL = "CHAINSTACK_WSS_URL";
const provider = new ethers.WebSocketProvider(NODE_URL);

async function clearSubscriptions() {
    try {
      await provider.removeAllListeners();
      console.log("Subscriptions were canceled successfully");
      return process.exit(1)

    } catch (error) {
      console.error("Failed to cancel subscriptions:", error);
      return process.exit(1)
    }
  }

clearSubscriptions()

const { ethers } = require("ethers");
const NODE_URL = "CHAINSTACK_WSS_URL";
const provider = new ethers.WebSocketProvider(NODE_URL);

async function subscribeToNewBlocks() {
    try {
        // Create a new subscription to the 'block' event
        provider.on("block", handleNewBlock);

        // Attach an event listener for any provider errors
        provider.on("error", handleError);

        console.log("New subscription created");
    } catch (error) {
        console.error(`Error subscribing to new blocks: ${error}`);
    }
}

/* Fallback functions to react to the different events */

// Event listener that logs the received block number
function handleNewBlock(blockNumber) {
    console.log(blockNumber);
}

// Event listener that logs any errors that occur
function handleError(error) {
    console.error(`Error receiving new blocks: ${error}`);
}

async function clearSubscriptions() {
    try {
        await provider.removeAllListeners();
        console.log("Subscriptions were canceled successfully");
        return process.exit(1)

    } catch (error) {
        console.error("Failed to cancel subscriptions:", error);
        return process.exit(1)
    }
}

async function main() {

    subscribeToNewBlocks();

    // Run clearSubscriptions() once after 60 seconds
    setTimeout(clearSubscriptions, 60000);
}

main()