Merge pull request #9 from SenseUnit/fix_ttl

Fix TTL
SenseUnit · Feb 23, 2024 · a06b30b · a06b30b
2 parents f08bedf + f4a60bd
commit a06b30b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/listener/group.go b/listener/group.go
@@ -11,6 +11,7 @@ import (
 	"github.com/SenseUnit/rgap/iface"
 	"github.com/SenseUnit/rgap/protocol"
 	"github.com/SenseUnit/rgap/psk"
+	"github.com/SenseUnit/rgap/util"
 	"github.com/jellydator/ttlcache/v3"
 )
 
@@ -104,7 +105,7 @@ func (g *Group) Ingest(a *protocol.Announcement) error {
 	expireAt := announceTime.Add(g.expire)
 	setItem := g.addrSet.Get(address)
 	if setItem == nil || setItem.ExpiresAt().Before(expireAt) {
-		g.addrSet.Set(address, struct{}{}, expireAt.Sub(now))
+		g.addrSet.Set(address, struct{}{}, util.Max(expireAt.Sub(now), 1))
 	}
 	return nil
 }