from rethinkdb import RethinkDB

r = RethinkDB()
r.connect( host='192.156.213.164', port=28015, db='test', user='redbteam', password='password.01' ).repl()

#all changes
#feed = r.table("events").changes().run()
print("Listening for changes...")

#only new changes
feed = r.table("events") \
        .changes() \
        .filter(lambda c:
            (c["old_val"] == None) & (c["new_val"] != None)
        ) \
        .run()

#exclude old records
feed = r.table("events") \
        .changes(include_initial=False) \
        .filter(lambda c: c["old_val"] == None) \
        .run()

for change in feed:
    new = change.get("new_val")
    if new:  # insert o update
        print(
            "exec_calib_pipe -> "
            + str(new['type'])
            + "="
            + str(new['value'])
            + " [" + str(new['size']) + "MB] ..."
        )
    
# solo nuove righe e non updates
# feed = r.table("events").changes(include_initial=False).run()