mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-03 04:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Use map[string]time.Duration to specify different expiry times

Browse source
This commit is contained in:
Till Faelligen 2022-04-28 16:06:08 +02:00
parent 778b981879
commit 3bc192a7d5
1 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
federationapi/storage/shared/storage_edus.go
View file

@ -27,10 +27,9 @@ import (
// expireEDUTypes contains EDUs which can/should be expired after a given time // expireEDUTypes contains EDUs which can/should be expired after a given time
// if the target server isn't reachable for some reason. // if the target server isn't reachable for some reason.
var expireEDUTypes = map[string]struct{}{ var expireEDUTypes = map[string]time.Duration{
gomatrixserverlib.MTyping: {}, gomatrixserverlib.MTyping: time.Minute,
gomatrixserverlib.MPresence: {}, gomatrixserverlib.MPresence: time.Minute * 10,
gomatrixserverlib.MReceipt: {},
} }
// AssociateEDUWithDestination creates an association that the // AssociateEDUWithDestination creates an association that the
@ -43,9 +42,9 @@ func (d *Database) AssociateEDUWithDestination(
eduType string, eduType string,
) error { ) error {
var expiresAt *gomatrixserverlib.Timestamp var expiresAt *gomatrixserverlib.Timestamp
if _, ok := expireEDUTypes[eduType]; ok { if duration, ok := expireEDUTypes[eduType]; ok {
// Keep EDUs for at least one hour before deleting them // Keep EDUs for at least x minutes before deleting them
ts := gomatrixserverlib.AsTimestamp(time.Now().Add(time.Hour)) ts := gomatrixserverlib.AsTimestamp(time.Now().Add(duration))
expiresAt = &ts expiresAt = &ts
} }
return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {