From 306d09211ecfcd9b559c062675d4920118daccf7 Mon Sep 17 00:00:00 2001
From: Believethehype <1097224+believethehype@users.noreply.github.com>
Date: Tue, 4 Jun 2024 22:21:21 +0200
Subject: [PATCH] add relays to discovery example, add db.py test file (errors)

---
 tests/db.py        | 39 +++++++++++++++++++++++++++++++++++++++
 tests/discovery.py | 18 ++++++++++++++++++
 2 files changed, 57 insertions(+)
 create mode 100644 tests/db.py

diff --git a/tests/db.py b/tests/db.py
new file mode 100644
index 0000000..0ab2483
--- /dev/null
+++ b/tests/db.py
@@ -0,0 +1,39 @@
+from threading import Thread
+from nostr_sdk import Keys, Filter, ClientBuilder, NostrDatabase, NegentropyOptions, init_logger, LogLevel
+init_logger(LogLevel.INFO)
+keys = Keys.parse("nsec1ufnus6pju578ste3v90xd5m2decpuzpql2295m3sknqcjzyys9ls0qlc85")
+print(keys.public_key().to_bech32())
+
+
+
+def reconcile_db():
+    # Create/open SQLite database
+    database = NostrDatabase.sqlite("nostr.db")
+
+    # NOT AVAILABLE ON WINDOWS AT THE MOMENT!
+    # Create/open nostrdb database
+    # database = NostrDatabase.ndb("ndb")
+
+    client = ClientBuilder().database(database).build()
+
+    client.add_relay("wss://relay.damus.io")
+    client.add_relay("wss://atl.purplerelay.com")
+    client.connect()
+
+    # Negentropy reconciliation
+    f = Filter().author(keys.public_key())
+    opts = NegentropyOptions()
+    client.reconcile(f, opts)
+
+    do_some_work()
+
+def do_some_work():
+    database = NostrDatabase.sqlite("nostr.db")
+    f = Filter().author(keys.public_key()).limit(10)
+    events = database.query([f])
+
+    for event in events:
+        print(event.as_json())
+
+nostr_dvm_thread = Thread(target=reconcile_db)
+nostr_dvm_thread.start()
diff --git a/tests/discovery.py b/tests/discovery.py
index b897086..20590cf 100644
--- a/tests/discovery.py
+++ b/tests/discovery.py
@@ -28,6 +28,19 @@ update_profile = False
 global_update_rate = 120     # set this high on first sync so db can fully sync before another process trys to.
 use_logger = True
 
+AVOID_PAID_OUTBOX_RELAY_LIST = ["wss://nostrelay.yeghro.site", "wss://nostr.wine", "wss://filter.nostr.wine"
+                                                                                   "wss://nostr21.com",
+                                "wss://nostr.bitcoiner.social", "wss://nostr.orangepill.dev",
+                                "wss://relay.lnpay.me", "wss://relay.snort.social", "wss://relay.minds.com/nostr/v1/ws",
+                                "wss://nostr-pub.semisol.dev", "wss://mostr.pub", "wss://minds.com",
+                                "wss://yabu.me", "wss://relay.yozora.world", "wss://filter.nostr.wine/?global=all",
+                                "wss://eden.nostr.land",
+                                "wss://relay.orangepill.ovh", "wss://nostr.jcloud.es", "wss://af.purplerelay.com",
+                                "wss://za.purplerelay.com",
+                                "wss://relay.nostrich.land", "wss://relay.nostrplebs.com" "wss://relay.nostrich.land",
+
+                                ]
+
 #git_hash = NostrLibrary().git_hash_version()
 #print("GitHash " + git_hash)
 
@@ -81,6 +94,7 @@ def build_example_nostrband(name, identifier, admin_config, image, about, custom
     dvm_config: DVMConfig = build_default_config(identifier)
     dvm_config.USE_OWN_VENV = False
     dvm_config.CUSTOM_PROCESSING_MESSAGE = custom_processing_msg
+    dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_PAID_OUTBOX_RELAY_LIST
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io",
     #              "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg"
     #                         ]
@@ -114,6 +128,7 @@ def build_example_topic(name, identifier, admin_config, options, image, descript
     dvm_config.UPDATE_DATABASE = update_db
     dvm_config.FIX_COST = cost
     dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg
+    dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_PAID_OUTBOX_RELAY_LIST
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io",
     #                         "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg"
     #                         ]
@@ -158,6 +173,7 @@ def build_example_popular(name, identifier, admin_config, options, image, cost=0
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg",
     #"wss://relay.nostr.net"]
     dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg
+    dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_PAID_OUTBOX_RELAY_LIST
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io",
     #                         "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg"
     #                         ]
@@ -199,6 +215,7 @@ def build_example_popular_followers(name, identifier, admin_config, options, ima
     dvm_config.UPDATE_DATABASE = update_db
     dvm_config.FIX_COST = cost
     dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg
+    dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_PAID_OUTBOX_RELAY_LIST
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io",
     #                         "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg"
     #                         ]
@@ -243,6 +260,7 @@ def build_example_top_zapped(name, identifier, admin_config, options, image, cos
     dvm_config.UPDATE_DATABASE = update_db
     dvm_config.FIX_COST = cost
     dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg
+    dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_PAID_OUTBOX_RELAY_LIST
     #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io",
     #                         "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg"
     #                         ]