highperfocused/nostrdvm
1
0
Fork 0
mirror of https://github.com/believethehype/nostrdvm.git synced 2025-10-05 19:52:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

update on this day

Browse Source
This commit is contained in:
dbth
2025-04-30 16:40:55 +02:00
committed by GitHub
parent ad1147eeba
commit 85c362eb1a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
nostr_dvm/tasks/content_discovery_on_this_day.py
View File

@@ -1,5 +1,6 @@
import json import json
import os import os
from datetime import timedelta
from nostr_sdk import Timestamp, Tag, Keys, Options, SecretKey, NostrSigner, NostrDatabase, \ from nostr_sdk import Timestamp, Tag, Keys, Options, SecretKey, NostrSigner, NostrDatabase, \
ClientBuilder, Filter, SyncOptions, SyncDirection, LogLevel, Kind, EventId ClientBuilder, Filter, SyncOptions, SyncDirection, LogLevel, Kind, EventId
@@ -30,7 +31,7 @@ class DicoverContentOnThisDay(DVMTaskInterface):
last_schedule: int last_schedule: int
db_since = 3600 db_since = 3600
db_name = "db/nostr_recent_notes.db" db_name = "db/nostr_recent_notes.db"
min_reactions = 2 min_reactions = 0
personalized = False personalized = False
result = "" result = ""
@@ -107,7 +108,7 @@ class DicoverContentOnThisDay(DVMTaskInterface):
database = NostrDatabase.lmdb(self.db_name) database = NostrDatabase.lmdb(self.db_name)
timestamp_since = Timestamp.now().as_secs() - self.db_since timestamp_since = Timestamp.now().as_secs() - self.db_since
timestamp_until = Timestamp.now().as_secs() - (self.db_since - (60+60*24)) timestamp_until = Timestamp.now().as_secs() - (self.db_since - (60*60*24))
since = Timestamp.from_secs(timestamp_since) since = Timestamp.from_secs(timestamp_since)
until = Timestamp.from_secs(timestamp_until) until = Timestamp.from_secs(timestamp_until)
@@ -201,6 +202,7 @@ class DicoverContentOnThisDay(DVMTaskInterface):
self.db_since) + " seconds.. this might take a while..") self.db_since) + " seconds.. this might take a while..")
dbopts = SyncOptions().direction(SyncDirection.DOWN) dbopts = SyncOptions().direction(SyncDirection.DOWN)
await cli.sync(filter1, dbopts) await cli.sync(filter1, dbopts)
await cli.fetch_events(filter1, timedelta(10))
await cli.database().delete(Filter().until(since)) # Clear old events so db doesn't get too full. await cli.database().delete(Filter().until(since)) # Clear old events so db doesn't get too full.
await cli.shutdown() await cli.shutdown()
if self.dvm_config.LOGLEVEL.value >= LogLevel.DEBUG.value: if self.dvm_config.LOGLEVEL.value >= LogLevel.DEBUG.value: