from cef_3M import sql, minioClient

# This should be run every hour or so to clean up old uploads
toDelete = sql.SqlExecuteFetchAll("SELECT *, NOW() FROM uploads WHERE expiry < NOW()")
for f in toDelete:
    minioClient.remove_object("uploads", f["hash"])
    sql.SqlExecute("DELETE FROM `uploads` WHERE `hash` = %s", f["hash"])
print(f"Deleted {len(toDelete)} old files")