highperfocused/khatru
1
0
Fork 0
mirror of https://github.com/fiatjaf/khatru.git synced 2025-04-07 11:28:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

never store ephemeral events.

Browse Source
This commit is contained in:
fiatjaf 2022-11-03 14:30:53 -03:00
parent 13a0c45fff
commit b903f72945
No known key found for this signature in database
GPG Key ID: BAD43C4BE5C1A3A1
2 changed files with 13 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
handlers.go
View File

@ -162,17 +162,21 @@ func handleWebsocket(relay Relay) func(http.ResponseWriter, *http.Request) {
return
}
if advancedSaver != nil {
advancedSaver.BeforeSave(&evt)
}
if 20000 <= evt.Kind && evt.Kind < 30000 {
// do not store ephemeral events
} else {
if advancedSaver != nil {
advancedSaver.BeforeSave(&evt)
}
if err := store.SaveEvent(&evt); err != nil {
notice = err.Error()
return
}
if err := store.SaveEvent(&evt); err != nil {
notice = err.Error()
return
}
if advancedSaver != nil {
advancedSaver.AfterSave(&evt)
if advancedSaver != nil {
advancedSaver.AfterSave(&evt)
}
}
notifyListeners(&evt)

7
storage/postgresql/save.go
View File

@ -4,7 +4,6 @@ import (
"encoding/json"
"fmt"
"strings"
"time"
"github.com/fiatjaf/go-nostr"
)
@ -35,11 +34,5 @@ func (b *PostgresBackend) SaveEvent(evt *nostr.Event) error {
return fmt.Errorf("failed to save event %s: %w", evt.ID, err)
}
// delete ephemeral events after a minute
go func() {
time.Sleep(75 * time.Second)
b.DB.Exec("DELETE FROM event WHERE id = $1", evt.ID)
}()
return nil
}