highperfocused/khatru
1
0
Fork 0
mirror of https://github.com/fiatjaf/khatru.git synced 2025-03-31 16:08:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

move AfterSave method from relay to storage

Browse Source
This commit is contained in:
Gustavo Chain 2023-02-09 01:41:44 +01:00 committed by fiatjaf
parent c7d584da54
commit 304831f749
3 changed files with 12 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
basic/main.go
View File

@ -57,18 +57,6 @@ func (r *Relay) AcceptEvent(evt *nostr.Event) bool {
return true
}
func (r *Relay) BeforeSave(evt *nostr.Event) {
// do nothing
}
func (r *Relay) AfterSave(evt *nostr.Event) {
// delete all but the 100 most recent ones for each key
r.Storage().(*postgresql.PostgresBackend).DB.Exec(`DELETE FROM event WHERE pubkey = $1 AND kind = $2 AND created_at < (
SELECT created_at FROM event WHERE pubkey = $1
ORDER BY created_at DESC OFFSET 100 LIMIT 1
)`, evt.PubKey, evt.Kind)
}
func main() {
r := Relay{}
if err := envconfig.Process("", &r); err != nil {

12
expensive/main.go
View File

@ -70,18 +70,6 @@ func (r *Relay) AcceptEvent(evt *nostr.Event) bool {
return true
}
func (r *Relay) BeforeSave(evt *nostr.Event) {
// do nothing
}
func (r *Relay) AfterSave(evt *nostr.Event) {
// delete all but the 1000 most recent ones for each key
r.Storage().(*postgresql.PostgresBackend).DB.Exec(`DELETE FROM event WHERE pubkey = $1 AND kind = $2 AND created_at < (
SELECT created_at FROM event WHERE pubkey = $1
ORDER BY created_at DESC OFFSET 1000 LIMIT 1
)`, evt.PubKey, evt.Kind)
}
func main() {
r := Relay{}
if err := envconfig.Process("", &r); err != nil {

12
storage/postgresql/save.go
View File

@ -40,3 +40,15 @@ func (b *PostgresBackend) SaveEvent(evt *nostr.Event) error {
return nil
}
func (b *PostgresBackend) BeforeSave(evt *nostr.Event) {
// do nothing
}
func (b *PostgresBackend) AfterSave(evt *nostr.Event) {
// delete all but the 100 most recent ones for each key
b.DB.Exec(`DELETE FROM event WHERE pubkey = $1 AND kind = $2 AND created_at < (
SELECT created_at FROM event WHERE pubkey = $1
ORDER BY created_at DESC OFFSET 100 LIMIT 1
)`, evt.PubKey, evt.Kind)
}