subscribe to pendingTransactions with web3js

ws-web3js-subscribe.js

const Web3 = require('web3');
const RPC = 'wss://xxxx';
const options = {
    timeout: 30000, // ms
    headers: {},
    // Enable auto reconnection
    reconnect: {
        auto: true,
        delay: 5000, // ms
        maxAttempts: 5,
        onTimeout: false
    }
};

const web3 = new Web3(RPC, options);
web3.eth.subscribe('pendingTransactions')
    .on("connected", function (subscriptionId) {
        console.log('connected to WSS ID:', subscriptionId);
    })
    .on("data", async function (transaction) {
        if (transaction) {
            await web3.eth.getTransaction(transaction).then(tx => {
                if(tx) {
                    console.log(tx.hash);
                } else {
                    console.log('FAILED TO GET DATA');
                }
            })
        } else {
            console.log(`FAIL`);
        }
    });