aljaz/haven
1
0
Fork 0
mirror of https://github.com/aljazceru/haven.git synced 2025-12-18 22:24:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

revert all this was a horrible idea

Browse Source
This commit is contained in:
Barry Deen
2024-09-24 14:43:56 -04:00
parent f006fbedf5
commit b53bb285e2
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
import.go
View File

@@ -46,6 +46,7 @@ func importOwnerNotes() {
ownerImportedNotes++ ownerImportedNotes++
} }
log.Println("📦 imported", ownerImportedNotes, "owner notes") log.Println("📦 imported", ownerImportedNotes, "owner notes")
time.Sleep(5 * time.Second)
startTime = startTime.Add(240 * time.Hour) startTime = startTime.Add(240 * time.Hour)
endTime = endTime.Add(240 * time.Hour) endTime = endTime.Add(240 * time.Hour)
@@ -66,15 +67,21 @@ func importTaggedNotes() {
fmt.Println("Error parsing start date:", err) fmt.Println("Error parsing start date:", err)
return return
} }
endTime := startTime.Add(240 * time.Hour)
for { for {
ctx, cancel := context.WithTimeout(ctx, 5*time.Second) ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
defer cancel() defer cancel()
startTimestamp := nostr.Timestamp(startTime.Unix())
endTimestamp := nostr.Timestamp(endTime.Unix())
filters := []nostr.Filter{{ filters := []nostr.Filter{{
Tags: nostr.TagMap{ Tags: nostr.TagMap{
"p": {nPubToPubkey(config.OwnerNpub)}, "p": {nPubToPubkey(config.OwnerNpub)},
}, },
Since: &startTimestamp,
Until: &endTimestamp,
}} }}
for ev := range pool.SubManyEose(ctx, config.ImportSeedRelays, filters) { for ev := range pool.SubManyEose(ctx, config.ImportSeedRelays, filters) {
@@ -92,6 +99,10 @@ func importTaggedNotes() {
} }
} }
log.Println("📦 imported", taggedImportedNotes, "tagged notes") log.Println("📦 imported", taggedImportedNotes, "tagged notes")
time.Sleep(5 * time.Second)
startTime = startTime.Add(240 * time.Hour)
endTime = endTime.Add(240 * time.Hour)
if startTime.After(time.Now()) { if startTime.After(time.Now()) {
log.Println("✅ tagged import complete. please restart the relay") log.Println("✅ tagged import complete. please restart the relay")