cleanup older fund manager logs (#1856)

Author: LexLuthr

db/funds.go

@@ -188,3 +188,14 @@ func (f *FundsDB) TotalTagged(ctx context.Context) (*TotalTagged, error) {
 
 	return tt, nil
 }
+
+func (f *FundsDB) CleanupLogs(ctx context.Context, daysOld int) error {
+
+	t := time.Now()
+	td := t.AddDate(0, 0, -1*daysOld)
+
+	qry := "DELETE from FundsLogs WHERE DealUUID IN (SELECT DISTINCT DealUUID FROM FundsLogs WHERE CreatedAt < ?)"
+
+	_, err := f.db.ExecContext(ctx, qry, td)
+	return err
+}

fundmanager/fundmanager.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"time"
 
 	"github.com/filecoin-project/boost-gfm/storagemarket"
 	"github.com/filecoin-project/boost/db"
@@ -254,3 +255,24 @@ func toSharedBalance(bal api.MarketBalance) storagemarket.Balance {
 		Available: big.Sub(bal.Escrow, bal.Locked),
 	}
 }
+
+func (m *FundManager) LogCleanup(ctx context.Context, FundsLogDurationDays int) {
+
+	// Create a ticker with an hour tick
+	ticker := time.NewTicker(time.Hour)
+	defer ticker.Stop()
+
+	for {
+		select {
+		case <-ticker.C:
+			log.Infof("Cleaning logs older than %d days from fundsDB ", FundsLogDurationDays)
+			err := m.db.CleanupLogs(ctx, FundsLogDurationDays)
+			if err != nil {
+				log.Errorf("Failed to cleanup old logs from fundsDB: %s", err)
+			}
+
+		case <-ctx.Done():
+			return
+		}
+	}
+}

storagemarket/provider.go

@@ -487,9 +487,10 @@ func (p *Provider) Start() error {
 	// Start the transfer limiter
 	go p.xferLimiter.run(p.ctx)
 
-	// Start hourly deal log cleanup
+	// Start hourly deal and funds log cleanup
 	if p.config.DealLogDurationDays > 0 {
 		go p.dealLogger.LogCleanup(p.ctx, p.config.DealLogDurationDays)
+		go p.fundManager.LogCleanup(p.ctx, p.config.DealLogDurationDays)
 	}
 
 	log.Infow("storage provider: started")