Skip to content

Commit ecaa87a

Browse files
committed
Revert "reporter: optional dispute monitor pause reporting while any dispute is open (#42)"
This reverts commit d20d496.
1 parent ff13b7d commit ecaa87a

4 files changed

Lines changed: 0 additions & 521 deletions

File tree

app.go

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ import (
1616
metricsclient "github.com/tellor-io/layer-daemons/metrics/client"
1717
pricefeedclient "github.com/tellor-io/layer-daemons/pricefeed/client"
1818
reporterclient "github.com/tellor-io/layer-daemons/reporter/client"
19-
"github.com/tellor-io/layer-daemons/reporter/dispute"
2019
daemonserver "github.com/tellor-io/layer-daemons/server"
2120
daemonservertypes "github.com/tellor-io/layer-daemons/server/types"
2221
pricefeedtypes "github.com/tellor-io/layer-daemons/server/types/pricefeed"
@@ -135,22 +134,6 @@ func NewApp(
135134

136135
exchangeQueryConfig := configs.ReadExchangeQueryConfigFile(homePath)
137136
marketParamsConfig := configs.ReadMarketParamsConfigFile(homePath)
138-
139-
// Dispute failsafe (opt-in via DISPUTE_MONITOR_ENABLED): before starting any other
140-
// component, refuse to run while there is an open, non-ignored dispute on the network.
141-
// Only create and run the monitor when it is enabled.
142-
if disputeCfg := dispute.LoadConfigFromEnv(rpcEndpoints); disputeCfg.Enabled {
143-
disputeMonitor := dispute.New(logger, disputeCfg)
144-
disputeMonitor.CheckBeforeStart(ctx) // panics if an open, non-ignored dispute exists
145-
appInstance.wg.Add(1)
146-
go func() {
147-
defer appInstance.wg.Done()
148-
disputeMonitor.Run(ctx) // keeps watching via events + the API
149-
}()
150-
} else {
151-
logger.Info("dispute monitor disabled")
152-
}
153-
154137
// Start pricefeed client for sending prices for the pricefeed server to consume. These prices
155138
// are retrieved via third-party APIs like Binance and then are encoded in-memory and
156139
// periodically sent via gRPC to a shared socket with the server.

reporter/dispute/config_env.go

Lines changed: 0 additions & 54 deletions
This file was deleted.

reporter/dispute/dispute.go

Lines changed: 0 additions & 266 deletions
This file was deleted.

0 commit comments

Comments
 (0)