stellar#4222: cleanup go fmt

sreuland · Feb 25, 2022 · 7804c74 · 7804c74
1 parent 4ba3775
commit 7804c74
Show file tree

Hide file tree

Showing 5 changed files with 31 additions and 31 deletions.
diff --git a/services/horizon/internal/ingest/filters/account.go b/services/horizon/internal/ingest/filters/account.go
@@ -21,7 +21,7 @@ type accountFilter struct {
 
 type AccountFilter interface {
 	processors.LedgerTransactionFilterer
-    RefreshAccountFilter(filterConfig *history.FilterConfig) (error)
+	RefreshAccountFilter(filterConfig *history.FilterConfig) error
 }
 
 func NewAccountFilter() AccountFilter {
@@ -31,18 +31,18 @@ func NewAccountFilter() AccountFilter {
 }
 
 // TODO:(fons) this code should probably be generic for all filters
-func (filter *accountFilter) RefreshAccountFilter(filterConfig *history.FilterConfig) (error) {
+func (filter *accountFilter) RefreshAccountFilter(filterConfig *history.FilterConfig) error {
 	// only need to re-initialize the filter config state(rules) if it's cached version(in  memory)
 	// is older than the incoming config version based on lastModified epoch timestamp
 	if filterConfig.LastModified > filter.lastModified {
 		var assetFilterRules AssetFilterRules
 		if err := json.Unmarshal([]byte(filterConfig.Rules), &assetFilterRules); err != nil {
 			return errors.Wrap(err, "unable to serialize asset filter rules")
 		}
-		
+
 		filter.whitelistedAccountsSet = listToMap(assetFilterRules.CanonicalWhitelist)
-		filter.lastModified           = filterConfig.LastModified
-		
+		filter.lastModified = filterConfig.LastModified
+
 	}
 
 	return nil

diff --git a/services/horizon/internal/ingest/filters/asset.go b/services/horizon/internal/ingest/filters/asset.go
@@ -30,7 +30,7 @@ type assetFilter struct {
 
 type AssetFilter interface {
 	processors.LedgerTransactionFilterer
-	RefreshAssetFilter(filterConfig *history.FilterConfig) (error)
+	RefreshAssetFilter(filterConfig *history.FilterConfig) error
 }
 
 func NewAssetFilter() AssetFilter {
@@ -39,17 +39,17 @@ func NewAssetFilter() AssetFilter {
 	}
 }
 
-func (filter *assetFilter) RefreshAssetFilter(filterConfig *history.FilterConfig) (error) {
+func (filter *assetFilter) RefreshAssetFilter(filterConfig *history.FilterConfig) error {
 	// only need to re-initialize the filter config state(rules) if it's cached version(in  memory)
 	// is older than the incoming config version based on lastModified epoch timestamp
 	if filterConfig.LastModified > filter.lastModified {
 		var assetFilterRules AssetFilterRules
 		if err := json.Unmarshal([]byte(filterConfig.Rules), &assetFilterRules); err != nil {
 			return errors.Wrap(err, "unable to serialize asset filter rules")
 		}
-		
+
 		filter.canonicalAssetsLookup = listToMap(assetFilterRules.CanonicalWhitelist)
-		filter.lastModified          = filterConfig.LastModified
+		filter.lastModified = filterConfig.LastModified
 	}
 
 	return nil

diff --git a/services/horizon/internal/ingest/filters/main.go b/services/horizon/internal/ingest/filters/main.go
@@ -17,28 +17,28 @@ const (
 )
 
 var (
-	supportedFilterNames           = []string{FilterAssetFilterName, FilterAccountFilterName}
-	LOG                            = log.WithFields(log.F{
+	supportedFilterNames = []string{FilterAssetFilterName, FilterAccountFilterName}
+	LOG                  = log.WithFields(log.F{
 		"filters": "load",
 	})
 )
 
 type filtersCache struct {
-    cachedFilters                  map[string]processors.LedgerTransactionFilterer
+	cachedFilters                  map[string]processors.LedgerTransactionFilterer
 	lastFilterConfigCheckUnixEpoch int64
 }
 
 type Filters interface {
-    GetFilters(filterQ history.QFilter, ctx context.Context) []processors.LedgerTransactionFilterer 
+	GetFilters(filterQ history.QFilter, ctx context.Context) []processors.LedgerTransactionFilterer
 }
 
 func NewFilters() Filters {
-     return &filtersCache{
-		 cachedFilters: map[string]processors.LedgerTransactionFilterer{
-			 FilterAssetFilterName: NewAccountFilter(),
-			 FilterAccountFilterName: NewAssetFilter(),
-		 },
-	 }
+	return &filtersCache{
+		cachedFilters: map[string]processors.LedgerTransactionFilterer{
+			FilterAssetFilterName:   NewAccountFilter(),
+			FilterAccountFilterName: NewAssetFilter(),
+		},
+	}
 }
 
 // Provide list of the active filters. Optimize performance by caching the list, only
@@ -93,8 +93,8 @@ func SupportedFilterNames(name string) bool {
 
 func (f *filtersCache) convertCacheToList() []processors.LedgerTransactionFilterer {
 	filters := []processors.LedgerTransactionFilterer{}
-    for _, filter := range f.cachedFilters {
-        filters = append(filters, filter)
-    }
-	return  filters
+	for _, filter := range f.cachedFilters {
+		filters = append(filters, filter)
+	}
+	return filters
 }
diff --git a/services/horizon/internal/ingest/mock_filter.go b/services/horizon/internal/ingest/mock_filter.go
@@ -15,4 +15,4 @@ type mockFilters struct {
 func (m *mockFilters) GetFilters(filterQ history.QFilter, ctx context.Context) []processors.LedgerTransactionFilterer {
 	a := m.Called(filterQ, ctx)
 	return a.Get(0).([]processors.LedgerTransactionFilterer)
-}
+}
diff --git a/services/horizon/internal/ingest/processor_runner_test.go b/services/horizon/internal/ingest/processor_runner_test.go
@@ -54,7 +54,7 @@ func TestProcessorRunnerRunHistoryArchiveIngestionGenesis(t *testing.T) {
 			NetworkPassphrase: network.PublicNetworkPassphrase,
 		},
 		historyQ: q,
-		filters: &mockFilters{},
+		filters:  &mockFilters{},
 	}
 
 	_, err := runner.RunGenesisStateIngestion()
@@ -118,7 +118,7 @@ func TestProcessorRunnerRunHistoryArchiveIngestionHistoryArchive(t *testing.T) {
 		config:         config,
 		historyQ:       q,
 		historyAdapter: historyAdapter,
-		filters: &mockFilters{},
+		filters:        &mockFilters{},
 	}
 
 	_, err := runner.RunHistoryArchiveIngestion(63, MaxSupportedProtocolVersion, bucketListHash)
@@ -153,7 +153,7 @@ func TestProcessorRunnerRunHistoryArchiveIngestionProtocolVersionNotSupported(t
 		config:         config,
 		historyQ:       q,
 		historyAdapter: historyAdapter,
-		filters: &mockFilters{},
+		filters:        &mockFilters{},
 	}
 
 	_, err := runner.RunHistoryArchiveIngestion(100, 200, xdr.Hash{})
@@ -173,7 +173,7 @@ func TestProcessorRunnerBuildChangeProcessor(t *testing.T) {
 	runner := ProcessorRunner{
 		ctx:      ctx,
 		historyQ: q,
-		filters: &mockFilters{},
+		filters:  &mockFilters{},
 	}
 
 	stats := &ingest.StatsChangeProcessor{}
@@ -195,7 +195,7 @@ func TestProcessorRunnerBuildChangeProcessor(t *testing.T) {
 	runner = ProcessorRunner{
 		ctx:      ctx,
 		historyQ: q,
-		filters: &mockFilters{},
+		filters:  &mockFilters{},
 	}
 
 	processor = buildChangeProcessor(runner.historyQ, stats, historyArchiveSource, 456)
@@ -293,7 +293,7 @@ func TestProcessorRunnerRunAllProcessorsOnLedger(t *testing.T) {
 		ctx:      ctx,
 		config:   config,
 		historyQ: q,
-		filters: &mockFilters{},
+		filters:  &mockFilters{},
 	}
 
 	_, err := runner.RunAllProcessorsOnLedger(ledger)
@@ -342,7 +342,7 @@ func TestProcessorRunnerRunAllProcessorsOnLedgerProtocolVersionNotSupported(t *t
 		ctx:      ctx,
 		config:   config,
 		historyQ: q,
-		filters: &mockFilters{},
+		filters:  &mockFilters{},
 	}
 
 	_, err := runner.RunAllProcessorsOnLedger(ledger)