diff --git a/nostr_dvm/tasks/search_users.py b/nostr_dvm/tasks/search_users.py index da0f178..c8a7848 100644 --- a/nostr_dvm/tasks/search_users.py +++ b/nostr_dvm/tasks/search_users.py @@ -27,10 +27,15 @@ class SearchUser(DVMTaskInterface): dvm_config: DVMConfig last_schedule: int = 0 db_name = "db/nostr_profiles.db" + relay = "wss://profiles.nostr1.com" + + async def init_dvm(self, name, dvm_config: DVMConfig, nip89config: NIP89Config, nip88config: NIP88Config = None, admin_config: AdminConfig = None, options=None): dvm_config.SCRIPT = os.path.abspath(__file__) + if self.options.get("relay"): + self.relay = self.options['relay'] await self.sync_db() async def is_input_supported(self, tags, client=None, dvm_config=None): @@ -81,7 +86,7 @@ class SearchUser(DVMTaskInterface): database = await NostrDatabase.sqlite(self.db_name) cli = ClientBuilder().database(database).signer(signer).opts(opts).build() - await cli.add_relay("wss://relay.damus.io") + await cli.add_relay(self.relay) # cli.add_relay("wss://atl.purplerelay.com") await cli.connect() @@ -145,8 +150,7 @@ class SearchUser(DVMTaskInterface): database = await NostrDatabase.sqlite(self.db_name) cli = ClientBuilder().signer(signer).database(database).opts(opts).build() - for relay in self.dvm_config.RECONCILE_DB_RELAY_LIST: - await cli.add_relay(relay) + await cli.add_relay(self.relay) await cli.connect() filter1 = Filter().kind(Kind(0)) @@ -202,7 +206,7 @@ def build_example(name, identifier, admin_config): nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) nip89config.CONTENT = json.dumps(nip89info) - options = {"relay": "wss://relay.damus.io"} + options = {"relay": "wss://profiles.nostr1.com"} return SearchUser(name=name, dvm_config=dvm_config, nip89config=nip89config, admin_config=admin_config, options=options) diff --git a/tests/search.py b/tests/search.py index 5bdf794..ad0bbec 100644 --- a/tests/search.py +++ b/tests/search.py @@ -19,12 +19,12 @@ rebroadcast_NIP89 = False # Announce NIP89 on startup Only do this if you know rebroadcast_NIP65_Relay_List = False update_profile = False -#use_logger = True +use_logger = True log_level = LogLevel.ERROR -#if use_logger: -# init_logger(log_level) +if use_logger: + init_logger(log_level) RELAY_LIST = ["wss://relay.primal.net", @@ -175,7 +175,7 @@ def build_user_search(name, identifier): nip89config = NIP89Config() nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) nip89config.CONTENT = json.dumps(nip89info) - options = {"relay": "wss://relay.damus.io"} + options = {"relay": "wss://profiles.nostr1.com"} return SearchUser(name=name, dvm_config=dvm_config, nip89config=nip89config, @@ -188,14 +188,14 @@ def build_user_search(name, identifier): def playground(): advanced_search = build_advanced_search("Nostr.band Search", - "discovery_content_search") + "discovery_content_search") advanced_search.run() advanced_search_wine = build_advanced_search_wine("Nostr.wine Search", "discovery_content_searchwine") advanced_search_wine.run() - #profile_search = build_user_search("Profile Searcher", "profile_search") - #profile_search.run() + profile_search = build_user_search("Profile Searcher", "profile_search") + profile_search.run() #keep_alive()