From eaa41aa75ad759cf45f086e6d1509a064aafe29a Mon Sep 17 00:00:00 2001 From: Believethehype <1097224+believethehype@users.noreply.github.com> Date: Tue, 20 Aug 2024 18:33:32 +0200 Subject: [PATCH] fixes --- nostr_dvm/utils/nut_wallet_utils.py | 71 ++- tests/discovery_test.py | 701 ++++++++++++++++++++++++++++ 2 files changed, 768 insertions(+), 4 deletions(-) create mode 100644 tests/discovery_test.py diff --git a/nostr_dvm/utils/nut_wallet_utils.py b/nostr_dvm/utils/nut_wallet_utils.py index f87eedc..d2f1ec0 100644 --- a/nostr_dvm/utils/nut_wallet_utils.py +++ b/nostr_dvm/utils/nut_wallet_utils.py @@ -28,6 +28,7 @@ class NutWallet(object): self.a: str = "" self.legacy_encryption: bool = False # Use Nip04 instead of Nip44, for reasons, turn to False ASAP. self.trust_unknown_mints: bool = False + self.missing_balance_strategy: str = "mint" #swap to use existing tokens from other mints (fees!) or mint to mint from lightning class NutMint(object): @@ -45,6 +46,7 @@ class NutMint(object): return balance + class NutZapWallet: async def client_connect(self, relay_list): @@ -519,10 +521,19 @@ class NutZapWallet: return await self.update_nut_wallet(nut_wallet, [mint_url], client, keys) - async def handle_low_balance_on_mint(self, nut_wallet, mint_url, mint, amount, client, keys): - mint_amount = amount - mint.available_balance() - reserved_fees = 0 - await self.mint_cashu(nut_wallet, mint_url, client, keys, mint_amount+reserved_fees) + async def handle_low_balance_on_mint(self, nut_wallet, outgoing_mint_url, mint, amount, client, keys): + + required_amount = amount - mint.available_balance() + if nut_wallet.missing_balance_strategy == "mint": + await self.mint_cashu(nut_wallet, outgoing_mint_url, client, keys, required_amount) + + elif nut_wallet.missing_balance_strategy == "swap": + for nutmint in nut_wallet.nutmints: + estimated_fees = 3 + if nutmint.available_balance() > required_amount+estimated_fees: + await self.swap(required_amount, nutmint.mint_url, outgoing_mint_url) + break + async def send_nut_zap(self, amount, comment, nut_wallet: NutWallet, zapped_event, zapped_user, client: Client, @@ -766,6 +777,58 @@ class NutZapWallet: total_amount - estimated_fees) + " (Fees: " + str(estimated_fees) + ") " + nut_wallet.unit + bcolors.ENDC) + async def swap(self, amountinsats, outgoing_mint_url, incoming_mint_url): + from cashu.wallet.cli.cli_helpers import print_mint_balances + from cashu.wallet.wallet import Wallet + # print("Select the mint to swap from:") + # outgoing_wallet = await get_mint_wallet(ctx, force_select=True) + + outgoing_wallet = await Wallet.with_db( + url=outgoing_mint_url, + db="db/Sender", + name="sender", + ) + + print("Select the mint to swap to:") + # incoming_wallet = await get_mint_wallet(ctx, force_select=True) + + incoming_wallet = await Wallet.with_db( + url=incoming_mint_url, + db="db/Receiver", + name="reeciver", + ) + + await incoming_wallet.load_mint() + await outgoing_wallet.load_mint() + + if incoming_wallet.url == outgoing_wallet.url: + raise Exception("mints for swap have to be different") + + print("Incoming Mint units: " + incoming_wallet.unit.name) + + assert amountinsats > 0, "amount is not positive" + + # request invoice from incoming mint + invoice = await incoming_wallet.request_mint(amountinsats) + + # pay invoice from outgoing mint + quote = await outgoing_wallet.melt_quote(invoice.bolt11) + total_amount = quote.amount + quote.fee_reserve + if outgoing_wallet.available_balance < total_amount: + raise Exception("balance too low") + send_proofs, fees = await outgoing_wallet.select_to_send( + outgoing_wallet.proofs, total_amount, set_reserved=True + ) + await outgoing_wallet.melt( + send_proofs, invoice.bolt11, quote.fee_reserve, quote.quote + ) + + # mint token in incoming mint + await incoming_wallet.mint(amountinsats, id=invoice.id) + + await incoming_wallet.load_proofs(reload=True) + await print_mint_balances(incoming_wallet, show_mints=True) + async def set_profile(self, name, about, lud16, image, client, keys): metadata = Metadata() \ .set_name(name) \ diff --git a/tests/discovery_test.py b/tests/discovery_test.py new file mode 100644 index 0000000..ab4fd4e --- /dev/null +++ b/tests/discovery_test.py @@ -0,0 +1,701 @@ +import json +import os +import threading +from pathlib import Path + +import dotenv +from nostr_sdk import init_logger, LogLevel, Keys, NostrLibrary + +from nostr_dvm.tasks.content_discovery_currently_latest_longform import DicoverContentLatestLongForm +from nostr_dvm.tasks.content_discovery_currently_latest_wiki import DicoverContentLatestWiki +from nostr_dvm.tasks.content_discovery_currently_popular_gallery import DicoverContentCurrentlyPopularGallery +from nostr_dvm.tasks.content_discovery_currently_popular_mostr import DicoverContentCurrentlyPopularMostr +from nostr_dvm.tasks.content_discovery_currently_popular_nonfollowers import DicoverContentCurrentlyPopularNonFollowers +from nostr_dvm.tasks.content_discovery_latest_one_per_follower import Discoverlatestperfollower +from nostr_dvm.tasks.content_discovery_update_db_only import DicoverContentDBUpdateScheduler + +#os.environ["RUST_BACKTRACE"] = "full" +from nostr_dvm.subscription import Subscription +from nostr_dvm.tasks.content_discovery_currently_popular import DicoverContentCurrentlyPopular +from nostr_dvm.tasks.content_discovery_currently_popular_by_top_zaps import DicoverContentCurrentlyPopularZaps +from nostr_dvm.tasks.content_discovery_currently_popular_followers import DicoverContentCurrentlyPopularFollowers +from nostr_dvm.tasks.content_discovery_currently_popular_topic import DicoverContentCurrentlyPopularbyTopic +from nostr_dvm.tasks.discovery_trending_notes_nostrband import TrendingNotesNostrBand +from nostr_dvm.utils.admin_utils import AdminConfig +from nostr_dvm.utils.dvmconfig import build_default_config, DVMConfig +from nostr_dvm.utils.mediasource_utils import organize_input_media_data +from nostr_dvm.utils.nip88_utils import NIP88Config, check_and_set_d_tag_nip88, check_and_set_tiereventid_nip88 +from nostr_dvm.utils.nip89_utils import create_amount_tag, NIP89Config, check_and_set_d_tag +from nostr_dvm.utils.nostr_utils import check_and_set_private_key +from nostr_dvm.utils.outbox_utils import AVOID_OUTBOX_RELAY_LIST +from nostr_dvm.utils.zap_utils import check_and_set_ln_bits_keys + + +rebroadcast_NIP89 = True # Announce NIP89 on startup Only do this if you know what you're doing. +rebroadcast_NIP65_Relay_List = True +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 +log_level = LogLevel.INFO + + + +RECONCILE_DB_RELAY_LIST = [ "wss://relay.nostr.net", "wss://relay.nostr.bg", "wss://relay.damus.io", "wss://nostr.oxtr.dev"] +RELAY_LIST = ["wss://relay.primal.net", + "wss://nostr.mom", "wss://nostr.oxtr.dev", + "wss://relay.nostr.net" + ] + +if use_logger: + init_logger(log_level) + + +def build_db_scheduler(name, identifier, admin_config, options, image, description, update_rate=600, cost=0, + processing_msg=None, update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.LOGLEVEL = LogLevel.INFO + dvm_config.RECONCILE_DB_RELAY_LIST = RECONCILE_DB_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + + # Activate these to use a subscription based model instead + # dvm_config.SUBSCRIPTION_REQUIRED = True + # dvm_config.SUBSCRIPTION_DAILY_COST = 1 + dvm_config.FIX_COST = cost + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": description, + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + return DicoverContentDBUpdateScheduler(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_gallery(name, identifier, admin_config, options, image, cost=0, update_rate=180, processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.LOGLEVEL = LogLevel.INFO + # dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.LOGLEVEL = LogLevel.DEBUG + dvm_config.RECONCILE_DB_RELAY_LIST = RECONCILE_DB_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.FIX_COST = cost + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show popular gallery entries", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": True, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 200)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + return DicoverContentCurrentlyPopularGallery(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + + +def build_example_nostrband(name, identifier, admin_config, image, about, custom_processing_msg): + 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_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.LOGLEVEL = LogLevel.INFO + #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + # Add NIP89 + + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": about, + "amount": "Free", + "encryptionSupported": True, + "cashuAccepted": True, + "nip90Params": {} + } + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + return TrendingNotesNostrBand(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config) + + +def build_longform(name, identifier, admin_config, options, cost=0, update_rate=180, processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_OUTBOX_RELAY_LIST + dvm_config.RECONCILE_DB_RELAY_LIST = RECONCILE_DB_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.LOGLEVEL = LogLevel.INFO + # Activate these to use a subscription based model instead + # dvm_config.SUBSCRIPTION_REQUIRED = True + # dvm_config.SUBSCRIPTION_DAILY_COST = 1 + dvm_config.FIX_COST = cost + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + admin_config.LUD16 = dvm_config.LN_ADDRESS + + image = "https://image.nostr.build/d30a75c438a8b0815b5c65b494988da26fce719f4138058929fa52d2a2dc3433.jpg" + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show the latest longform notes.", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + # admin_config.UPDATE_PROFILE = False + + # admin_config.REBROADCAST_NIP89 = False + + return DicoverContentLatestLongForm(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_wiki(name, identifier, admin_config, options, cost=0, update_rate=180, processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_OUTBOX_RELAY_LIST + dvm_config.RECONCILE_DB_RELAY_LIST = RECONCILE_DB_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.LOGLEVEL = LogLevel.INFO + # Activate these to use a subscription based model instead + # dvm_config.SUBSCRIPTION_REQUIRED = True + # dvm_config.SUBSCRIPTION_DAILY_COST = 1 + dvm_config.FIX_COST = cost + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + admin_config.LUD16 = dvm_config.LN_ADDRESS + + image = "https://i.nostr.build/ctfc5o47ICm56TOv.jpg" + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show the latest wikifreedia entries.", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + # admin_config.UPDATE_PROFILE = False + + # admin_config.REBROADCAST_NIP89 = False + + return DicoverContentLatestWiki(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_topic(name, identifier, admin_config, options, image, description, update_rate=600, cost=0, + processing_msg=None, update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.FIX_COST = cost + dvm_config.LOGLEVEL = LogLevel.INFO + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": description, + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + return DicoverContentCurrentlyPopularbyTopic(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_popular(name, identifier, admin_config, options, image, cost=0, update_rate=180, processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.LOGLEVEL = LogLevel.INFO + # dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.FIX_COST = cost + #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_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show notes that are currently popular", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 200)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + return DicoverContentCurrentlyPopular(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_popular_followers(name, identifier, admin_config, options, image, cost=0, update_rate=300, + processing_msg=None, update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.LOGLEVEL = LogLevel.INFO + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every x seconds + 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_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show notes that are currently popular from people you follow", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": True, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + return DicoverContentCurrentlyPopularFollowers(name=name, dvm_config=dvm_config, nip89config=nip89config, + options=options, + admin_config=admin_config) + +def build_example_popular_non_followers(name, identifier, admin_config, options, image, cost=0, update_rate=300, + processing_msg=None, update_db=True): + + + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.LOGLEVEL = LogLevel.DEBUG + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + # Activate these to use a subscription based model instead + dvm_config.FIX_COST = cost + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + dvm_config.AVOID_PAID_OUTBOX_RELAY_LIST = AVOID_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.SUBSCRIPTION_REQUIRED = True + admin_config.LUD16 = dvm_config.LN_ADDRESS + admin_config.REBROADCAST_NIP88 = False + #admin_config.REBROADCAST_NIP89 = True + admin_config.UPDATE_PROFILE = False + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show notes that are currently popular from people you do not follow", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "subscription": True, + "personalized": False, + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + nip88config = NIP88Config() + nip88config.DTAG = check_and_set_d_tag_nip88(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip88config.TIER_EVENT = check_and_set_tiereventid_nip88(identifier, "1") + nip89config.NAME = name + nip88config.IMAGE = nip89info["image"] + nip88config.TITLE = name + nip88config.AMOUNT_DAILY = 100 + nip88config.AMOUNT_MONTHLY = 2000 + nip88config.CONTENT = "Subscribe to the DVM for unlimited use during your subscription" + nip88config.PERK1DESC = "Unlimited requests" + nip88config.PERK2DESC = "Support NostrDVM & NostrSDK development" + nip88config.PAYMENT_VERIFIER_PUBKEY = "5b5c045ecdf66fb540bdf2049fe0ef7f1a566fa427a4fe50d400a011b65a3a7e" + + #admin_config.FETCH_NIP88 = True + #admin_config.EVENTID = "63a791cdc7bf78c14031616963105fce5793f532bb231687665b14fb6d805fdb" + admin_config.PRIVKEY = dvm_config.PRIVATE_KEY + + return DicoverContentCurrentlyPopularNonFollowers(name=name, dvm_config=dvm_config, nip89config=nip89config, + nip88config=nip88config, + admin_config=admin_config, + options=options) + + +def build_example_top_zapped(name, identifier, admin_config, options, image, cost=0, update_rate=180, + processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.SHOWLOG = True + dvm_config.LOGLEVEL = LogLevel.INFO + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + 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_OUTBOX_RELAY_LIST + dvm_config.RELAY_LIST = RELAY_LIST + #dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show notes that are currently zapped the most.", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 100)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + + # admin_config.UPDATE_PROFILE = False + # admin_config.REBROADCAST_NIP89 = False + + return DicoverContentCurrentlyPopularZaps(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_mostr(name, identifier, admin_config, options, image, cost=0, update_rate=180, processing_msg=None, + update_db=True): + + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.LOGLEVEL = LogLevel.INFO + # dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = update_db + dvm_config.RELAY_LIST = RELAY_LIST + dvm_config.RECONCILE_DB_RELAY_LIST = ["wss://nfrelay.app/?user=activitypub"] + + dvm_config.LOGLEVEL = LogLevel.DEBUG + dvm_config.FIX_COST = cost + # 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.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show notes from Mostr.pub and Momostr.pink that are currently popular on Nostr", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 200)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + return DicoverContentCurrentlyPopularMostr(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + +def build_example_oneperfollow(name, identifier, admin_config, options, image, cost=0, update_rate=180, processing_msg=None, + update_db=True): + dvm_config = build_default_config(identifier) + dvm_config.USE_OWN_VENV = False + dvm_config.LOGLEVEL = LogLevel.INFO + # dvm_config.SHOWLOG = True + dvm_config.SCHEDULE_UPDATES_SECONDS = update_rate # Every 10 minutes + dvm_config.UPDATE_DATABASE = False + dvm_config.LOGLEVEL = LogLevel.DEBUG + dvm_config.FIX_COST = cost + dvm_config.RELAY_LIST = ["wss://relay.damus.io", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg", "wss://relay.primal.net"] + # "wss://relay.nostr.net"] + dvm_config.CUSTOM_PROCESSING_MESSAGE = processing_msg + # dvm_config.RELAY_LIST = ["wss://dvms.f7z.io", + # "wss://nostr.mom", "wss://nostr.oxtr.dev", "wss://relay.nostr.bg" + # ] + admin_config.LUD16 = dvm_config.LN_ADDRESS + + # Add NIP89 + nip89info = { + "name": name, + "image": image, + "picture": image, + "about": "I show the single latest note of people you follow", + "lud16": dvm_config.LN_ADDRESS, + "encryptionSupported": True, + "cashuAccepted": True, + "personalized": False, + "amount": create_amount_tag(cost), + "nip90Params": { + "max_results": { + "required": False, + "values": [], + "description": "The number of maximum results to return (default currently 200)" + } + } + } + + nip89config = NIP89Config() + nip89config.DTAG = check_and_set_d_tag(identifier, name, dvm_config.PRIVATE_KEY, nip89info["image"]) + nip89config.CONTENT = json.dumps(nip89info) + return Discoverlatestperfollower(name=name, dvm_config=dvm_config, nip89config=nip89config, + admin_config=admin_config, options=options) + + + +def playground(): + + + #DB Scheduler, do not announce, just use it to update the DB for the other DVMs. + admin_config_db_scheduler= AdminConfig() + options_animal = { + "db_name": "db/nostr_recent_notes.db", + "db_since": 48 * 60 * 60, # 48h since gmt, + "personalized": False, + "logger": False} + image = "" + about = "I just update the Database based on my schedule" + db_scheduler = build_db_scheduler("DB Scheduler", + "db_scheduler", + admin_config_db_scheduler, options_animal, + image=image, + description=about, + update_rate=global_update_rate, + cost=0, + update_db=True) + db_scheduler.run() + + + + + + + + # Popular top zapped + admin_config_top_zaps = AdminConfig() + admin_config_top_zaps.REBROADCAST_NIP89 = rebroadcast_NIP89 + admin_config_top_zaps.REBROADCAST_NIP65_RELAY_LIST = rebroadcast_NIP65_Relay_List + admin_config_top_zaps.UPDATE_PROFILE = update_profile + # admin_config_top_zaps.DELETE_NIP89 = True + # admin_config_top_zaps.PRIVKEY = "" + # admin_config_top_zaps.EVENTID = "05a6de88e15aa6c8b4c8ec54481f885f397a30761ff2799958e5c5ee9ad6917b" + # admin_config_top_zaps.POW = True + custom_processing_msg = ["Looking for most zapped notes", "Let's see which notes people currently zap..", + "Let's find valuable notes. #value4value"] + update_db = False + + options_top_zapped = { + "db_name": "db/nostr_recent_notes.db", + "db_since": 60 * 60 * 2, # 8h since gmt, + } + cost = 0 + image = "https://image.nostr.build/c6879f458252641d04d0aa65fd7f1e005a4f7362fd407467306edc2f4acdb113.jpg" + discovery_topzaps = build_example_top_zapped("Top Zapped notes", + "discovery_content_top_zaps", + admin_config=admin_config_top_zaps, + options=options_top_zapped, + image=image, + cost=cost, + update_rate=global_update_rate, + processing_msg=custom_processing_msg, + update_db=update_db) + + discovery_topzaps.run() + + + + + + +if __name__ == '__main__': + env_path = Path('.env') + if not env_path.is_file(): + with open('.env', 'w') as f: + print("Writing new .env file") + f.write('') + if env_path.is_file(): + print(f'loading environment from {env_path.resolve()}') + dotenv.load_dotenv(env_path, verbose=True, override=True) + else: + raise FileNotFoundError(f'.env file not found at {env_path} ') + playground()