sync function listenToEvents(contractAddress, abi, jsonRpcProviderEndpoint, db) {
    const provider = new ethers.JsonRpcProvider(jsonRpcProviderEndpoint);
    const contract = new ethers.Contract(contractAddress, abi, provider);

    console.log("listening on contract at address: ", contractAddress)

    const eventListener = async (event) => {
        try {
            console.log(`New ${event.eventName} event emitted`);
            const { data, topics, transactionHash, index } = event.log;
            const evtDecoded = parseEvent(contract, event.eventName, data, topics, transactionHash, index);

            await processEvent(db, event.eventName, evtDecoded, eventHandlers);
        } catch (error) {
            console.error('Error occurred while processing event:', error);
        }
    };

    const startListening = () => {
        contract.on('*', eventListener)
            .then(() => {
                console.log('Event listener started.');
            })
            .catch((error) => {
                console.error('Error occurred while starting event listener:', error);
                // Handle the error and attempt reconnection
                setTimeout(startListening, 5000); // Retry connection after 5 seconds
            });
    };

    startListening();