Function CleanOldTEvents

pkg/telemetry/telemetry.go:307–318

(ctx context.Context)

}

func CleanOldTEvents(ctx context.Context) error {
	daysToKeep := 7
	if !IsTelemetryEnabled() {
		daysToKeep = 1
	}
	olderThan := time.Now().AddDate(0, 0, -daysToKeep).UnixMilli()
	return wstore.WithTx(ctx, func(tx *wstore.TxWrap) error {
		query := `DELETE FROM db_tevent WHERE ts < ?`
		tx.Exec(query, olderThan)
		return nil
	})
}

func GetNonUploadedTEvents(ctx context.Context, maxEvents int) ([]*telemetrydata.TEvent, error) {
	now := time.Now()