mirror of
https://github.com/believethehype/nostrdvm.git
synced 2025-03-17 21:31:52 +01:00
fixes
This commit is contained in:
parent
d5fef1a115
commit
981452a1d0
@ -4,7 +4,7 @@ from hashlib import sha256
|
|||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
import dotenv
|
import dotenv
|
||||||
from nostr_sdk import Tag, Keys, EventBuilder, Filter, Alphabet, PublicKey, Client, EventId
|
from nostr_sdk import Tag, Keys, EventBuilder, Filter, Alphabet, PublicKey, Client, EventId, SingleLetterTag
|
||||||
|
|
||||||
from nostr_dvm.utils.definitions import EventDefinitions
|
from nostr_dvm.utils.definitions import EventDefinitions
|
||||||
from nostr_dvm.utils.nostr_utils import send_event
|
from nostr_dvm.utils.nostr_utils import send_event
|
||||||
@ -69,7 +69,7 @@ def nip89_fetch_all_dvms(client):
|
|||||||
for i in range(5000, 5999):
|
for i in range(5000, 5999):
|
||||||
ktags.append(str(i))
|
ktags.append(str(i))
|
||||||
|
|
||||||
filter = Filter().kind(EventDefinitions.KIND_ANNOUNCEMENT).custom_tag(Alphabet.K, ktags)
|
filter = Filter().kind(EventDefinitions.KIND_ANNOUNCEMENT).custom_tag(SingleLetterTag.lowercase(Alphabet.K), ktags)
|
||||||
events = client.get_events_of([filter], timedelta(seconds=5))
|
events = client.get_events_of([filter], timedelta(seconds=5))
|
||||||
for event in events:
|
for event in events:
|
||||||
print(event.as_json())
|
print(event.as_json())
|
||||||
@ -80,7 +80,7 @@ def nip89_fetch_events_pubkey(client, pubkey, kind):
|
|||||||
# for i in range(5000, 5999):
|
# for i in range(5000, 5999):
|
||||||
# ktags.append(str(i))
|
# ktags.append(str(i))
|
||||||
nip89filter = (Filter().kind(EventDefinitions.KIND_ANNOUNCEMENT).author(PublicKey.from_hex(pubkey)).
|
nip89filter = (Filter().kind(EventDefinitions.KIND_ANNOUNCEMENT).author(PublicKey.from_hex(pubkey)).
|
||||||
custom_tag(Alphabet.K, ktags))
|
custom_tag(SingleLetterTag.lowercase(Alphabet.K), ktags))
|
||||||
events = client.get_events_of([nip89filter], timedelta(seconds=2))
|
events = client.get_events_of([nip89filter], timedelta(seconds=2))
|
||||||
|
|
||||||
dvms = {}
|
dvms = {}
|
||||||
|
@ -6,14 +6,14 @@ from typing import List
|
|||||||
|
|
||||||
import dotenv
|
import dotenv
|
||||||
from nostr_sdk import Filter, Client, Alphabet, EventId, Event, PublicKey, Tag, Keys, nip04_decrypt, Metadata, Options, \
|
from nostr_sdk import Filter, Client, Alphabet, EventId, Event, PublicKey, Tag, Keys, nip04_decrypt, Metadata, Options, \
|
||||||
Nip19Event
|
Nip19Event, SingleLetterTag
|
||||||
|
|
||||||
|
|
||||||
def get_event_by_id(event_id: str, client: Client, config=None) -> Event | None:
|
def get_event_by_id(event_id: str, client: Client, config=None) -> Event | None:
|
||||||
split = event_id.split(":")
|
split = event_id.split(":")
|
||||||
if len(split) == 3:
|
if len(split) == 3:
|
||||||
pk = PublicKey.from_hex(split[1])
|
pk = PublicKey.from_hex(split[1])
|
||||||
id_filter = Filter().author(pk).custom_tag(Alphabet.D, [split[2]])
|
id_filter = Filter().author(pk).custom_tag(SingleLetterTag.lowercase(Alphabet.D), [split[2]])
|
||||||
events = client.get_events_of([id_filter], timedelta(seconds=config.RELAY_TIMEOUT))
|
events = client.get_events_of([id_filter], timedelta(seconds=config.RELAY_TIMEOUT))
|
||||||
else:
|
else:
|
||||||
if str(event_id).startswith('note'):
|
if str(event_id).startswith('note'):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user