ipfs: only provide CIDs that have expired

SiaFoundation · May 13, 2024 · 4e8ac2a · 4e8ac2a
1 parent e96ac5d
commit 4e8ac2a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/ipfs/provide.go b/ipfs/provide.go
@@ -103,7 +103,13 @@ func (r *Reprovider) Run(ctx context.Context, interval, timeout time.Duration, b
 
 				announced := make([]cid.Cid, 0, len(cids))
 				keys := make([]multihash.Multihash, 0, len(cids))
+				minAnnouncement := time.Now().Add(-interval)
 				for _, c := range cids {
+					// only provide CIDs that have not been provided within the
+					// last interval
+					if c.LastAnnouncement.After(minAnnouncement) {
+						break
+					}
 					keys = append(keys, c.CID.Hash())
 					announced = append(announced, c.CID)
 				}