from rethinkdb import RethinkDB
import time
import random
import os
import uuid
import string

def random_file_path_uuid(base_dir="/tmp", extension="json"):
    uid = uuid.uuid4()
    return os.path.join(base_dir, str(uid)[:2], str(uid)[2:4], f"{uid}.{extension}")


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

while True:
    doc = {
        "type": "filepath",
        "value": random_file_path_uuid(),
        "size": random.randint(10,40),
        "ts": r.now()
    }

    time.sleep(2)
    res = r.table("events").insert(doc).run()
    print("Inserted:", res["generated_keys"][0])

    time.sleep(2)
    r.table("events").filter({'id': res["generated_keys"][0]}).update({"value": random.randint(20,42)}).run()
    print("updated:", res["generated_keys"][0])

    time.sleep(2)
    r.table("events").filter({'id': res["generated_keys"][0]}).delete().run()
    print("deleted:", res["generated_keys"][0])