I implement some code to query the database for any changes and to send an event. Here's the code