from cfspeedtest import CloudflareSpeedtest
from db import init_db, insert_result

def run_test_and_save():
    try:
        tester = CloudflareSpeedtest()
        results = tester.run_all(megabits=True) # returns SuiteResults
    except Exception:
        results = None  # Trigger a failed test record

    init_db()
    insert_result(results)

print("==== Running Speedtest ====")
run_test_and_save()
print("====  Speedtest ended  ====")