The project is based on a aiohttp, asyncio, custom async scheduler and AsyncEventEmitter.

Every 30 seconds, the scheduler calls def poll from BlockcypherAPI, poll in turn calls a number of other functions. These functions make emit, which our decorators run.

💲 git clone https://github.com/dotX12/EventFisher/
💲 cd EventFisher
💲 pip3 install -r requirements.txt
💲 python3 main.py

I have implemented a simple but high-quality example. Every 30 seconds we check whether new transactions have come to our wallet, as well as whether the network commission has changed. If any of this is fulfilled, an "emit" will be made, which will trigger decorators and call our functions, which in turn will do something. In these functions, you can log, add to the database, send message to users, etc.

    async def get_info_medium_fee(self):
        resp = await self.request('GET', MAIN_INFO_BTC)
        if self.medium_fee != resp['medium_fee_per_kb']:
            self.medium_fee = resp['medium_fee_per_kb']
            self.emit('new_btc_medium_fee')
            # Will call the event handler that belongs to this decorator 
            # @event.on('new_btc_medium_fee')

@event.on('new_btc_medium_fee')
def btc_new_price():
    print(f'BTC NEW MEDIUM FEE: {event.medium_fee}')

An example was also added for the telebot library, which sends information to the user when the decorator is triggered.

@event.on('new_transaction')
def new_transaction():
    bot.send_message(ADMIN_ID, f'New Transaction! TX Hash: {event.tx["tx_hash"]}')


@event.on('new_btc_medium_fee')
def btc_new_price():
    bot.send_message(ADMIN_ID, f'BTC NEW MEDIUM FEE: {event.medium_fee}')