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)
  }