chore(BUX-416) disable monitor

config.example.yaml

@@ -69,18 +69,6 @@ graphql:
     enabled: false
 import_block_headers: ""
 # Prefixed with "_", because it's unused by default
-_monitor:
-    auth_token: ""
-    bux_agent_url: ws://localhost:8000/websocket
-    debug: false
-    enabled: false
-    false_positive_rate: 0.01
-    load_monitored_destinations: false
-    max_number_of_destinations: 100000
-    monitor_days: 7
-    processor_type: bloom
-    save_transaction_destinations: true
-# Prefixed with "_", because it's unused by default
 _new_relic:
     domain_name: domain.com
     enabled: false

config/config.go

@@ -43,8 +43,6 @@ type AppConfig struct {
 	ImportBlockHeaders string `json:"import_block_headers" mapstructure:"import_block_headers"`
 	// Logging is the configuration for zerolog used in bux.
 	Logging *LoggingConfig `json:"logging" mapstructure:"logging"`
-	// Monitor is a monitor service related settings for legacy bitcoin addresses.
-	Monitor *MonitorOptions `json:"monitor" mapstructure:"monitor"`
 	// NewRelic is New Relic related settings.
 	NewRelic *NewRelicConfig `json:"new_relic" mapstructure:"new_relic"`
 	// Nodes is a config for BSV nodes, mAPI and Arc.
@@ -139,30 +137,6 @@ type GraphqlConfig struct {
 	Enabled bool `json:"enabled" mapstructure:"enabled"`
 }
 
-// MonitorOptions is the configuration for blockchain monitoring
-type MonitorOptions struct {
-	// AuthToken is a token to connect to the server with.
-	AuthToken string `json:"auth_token" mapstructure:"auth_token"`
-	// BuxAgentURL is the BUX agent server url address.
-	BuxAgentURL string `json:"bux_agent_url" mapstructure:"bux_agent_url"`
-	// Debug is the flag that says whether additional input from monitor should be produced.
-	Debug bool `json:"debug" mapstructure:"debug"`
-	// Enabled is the flag that enables monitor service.
-	Enabled bool `json:"enabled" mapstructure:"enabled"`
-	// FalsePositiveRate is the percentage of how many false positives we except.
-	FalsePositiveRate float64 `json:"false_positive_rate" mapstructure:"false_positive_rate"`
-	// LoadMonitoredDestinations is a flag that says whether to load monitored destinations.
-	LoadMonitoredDestinations bool `json:"load_monitored_destinations" mapstructure:"load_monitored_destinations"`
-	// MaxNumberOfDestinations is a number of destinations that the filter can hold (default: 100,000).
-	MaxNumberOfDestinations int `json:"max_number_of_destinations" mapstructure:"max_number_of_destinations"`
-	// MonitorDays is the number of days in the past that we should monitor an address (default: 7).
-	MonitorDays int `json:"monitor_days" mapstructure:"monitor_days"`
-	// ProcessorType is the type of processor to start monitor with. Default: bloom.
-	ProcessorType string `json:"processor_type" mapstructure:"processor_type"`
-	// SaveTransactionDestinations says whether to save destinations on monitored transactions.
-	SaveTransactionDestinations bool `json:"save_transaction_destinations" mapstructure:"save_transaction_destinations"`
-}
-
 // NewRelicConfig is the configuration for New Relic
 type NewRelicConfig struct {
 	// DomainName is used for hostname display.

config/defaults.go

@@ -18,7 +18,6 @@ func getDefaultAppConfig() *AppConfig {
 		GraphQL:            getGraphqlDefaults(),
 		ImportBlockHeaders: "",
 		Logging:            getLoggingDefaults(),
-		Monitor:            getMonitorDefaults(),
 		NewRelic:           getNewRelicDefaults(),
 		Nodes:              getNodesDefaults(),
 		Notifications:      getNotificationDefaults(),
@@ -107,21 +106,6 @@ func getLoggingDefaults() *LoggingConfig {
 	}
 }
 
-func getMonitorDefaults() *MonitorOptions {
-	return &MonitorOptions{
-		AuthToken:                   "",
-		BuxAgentURL:                 "ws://localhost:8000/websocket",
-		Debug:                       false,
-		Enabled:                     false,
-		FalsePositiveRate:           0.01,
-		LoadMonitoredDestinations:   false,
-		MaxNumberOfDestinations:     100000,
-		MonitorDays:                 7,
-		ProcessorType:               "bloom",
-		SaveTransactionDestinations: true,
-	}
-}
-
 func getNewRelicDefaults() *NewRelicConfig {
 	return &NewRelicConfig{
 		DomainName: "domain.com",

config/services.go

@@ -11,7 +11,6 @@ import (
 
 	"github.com/BuxOrg/bux"
 	"github.com/BuxOrg/bux-server/logging"
-	"github.com/BuxOrg/bux/chainstate"
 	"github.com/BuxOrg/bux/cluster"
 	"github.com/BuxOrg/bux/taskmanager"
 	"github.com/BuxOrg/bux/utils"
@@ -188,10 +187,6 @@ func (s *AppServices) loadBux(ctx context.Context, appConfig *AppConfig, testMod
 		options = append(options, bux.WithNotifications(appConfig.Notifications.WebhookEndpoint))
 	}
 
-	if options, err = loadMonitor(ctx, appConfig, options); err != nil {
-		return err
-	}
-
 	if appConfig.Nodes.UseMapiFeeQuotes {
 		options = append(options, bux.WithMinercraftFeeQuotes())
 	}
@@ -404,26 +399,6 @@ func loadTaskManager(appConfig *AppConfig, options []bux.ClientOps) []bux.Client
 	return options
 }
 
-func loadMonitor(ctx context.Context, appConfig *AppConfig, options []bux.ClientOps) ([]bux.ClientOps, error) {
-	if appConfig.Monitor != nil && appConfig.Monitor.Enabled {
-		if appConfig.Monitor.BuxAgentURL == "" {
-			err := errors.New("CentrifugeServer is required for monitoring to work")
-			return options, err
-		}
-		options = append(options, bux.WithMonitoring(ctx, &chainstate.MonitorOptions{
-			Debug:                       appConfig.Monitor.Debug,
-			BuxAgentURL:                 appConfig.Monitor.BuxAgentURL,
-			MonitorDays:                 appConfig.Monitor.MonitorDays,
-			AuthToken:                   appConfig.Monitor.AuthToken,
-			FalsePositiveRate:           appConfig.Monitor.FalsePositiveRate,
-			MaxNumberOfDestinations:     appConfig.Monitor.MaxNumberOfDestinations,
-			SaveTransactionDestinations: appConfig.Monitor.SaveTransactionDestinations,
-			LoadMonitoredDestinations:   appConfig.Monitor.LoadMonitoredDestinations,
-		}))
-	}
-	return options, nil
-}
-
 func loadBroadcastClientAPI(appConfig *AppConfig, options []bux.ClientOps) []bux.ClientOps {
 	if appConfig.Nodes.BroadcastClientAPIs != nil {
 		arcClientConfigs := splitBroadcastClientApis(appConfig.Nodes.BroadcastClientAPIs)