fix time check

jrick · Jul 8, 2024 · 68a8f91 · 68a8f91
1 parent 8e440cd
commit 68a8f91
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mixing/mixpool/mixpool.go b/mixing/mixpool/mixpool.go
@@ -1395,8 +1395,9 @@ func (p *Pool) checkAcceptKE(ke *wire.MsgMixKeyExchange) error {
 		return ruleError(ErrPeerPositionOutOfBounds)
 	}
 
+	now := time.Now()
 	keEpoch := time.Unix(int64(ke.Epoch), 0)
-	if keEpoch.Add(earlyKEDuration).Before(time.Now()) {
+	if now.Before(keEpoch) && now.Sub(keEpoch) > earlyKEDuration {
 		err := fmt.Errorf("KE received too early for stated epoch")
 		return ruleError(err)
 	}