chore: Update slinky version (#1768)

(cherry picked from commit 6abbc72)

# Conflicts:
#	protocol/mocks/OracleClient.go
#	protocol/x/prices/keeper/slinky_adapter_test.go

protocol/app/app.go

@@ -93,7 +93,6 @@ import (
 	"github.com/gorilla/mux"
 	"github.com/rakyll/statik/fs"
 	"github.com/spf13/cast"
-	"go.uber.org/zap"
 	"google.golang.org/grpc"
 
 	// App
@@ -1545,15 +1544,8 @@ func (app *App) initOracle(pricesTxDecoder process.UpdateMarketPriceTxDecoder) {
 			compression.NewDefaultVoteExtensionCodec(),
 			compression.NewZLibCompressor(),
 		),
-		// We are not using the slinky PreBlocker, so there is no need to pass in PreBlocker here for
-		// VE handler to work properly.
-		// Currently the clob PreBlocker assumes that it will only be called during the normal ABCI
-		// PreBlocker step. Passing in the app PreBlocker here will break that assumption by causing
-		// the clob PreBlocker to be called unexpectedly. This to leads improperly initialized clob state
-		// which results in the next block being committed incorrectly.
-		func(_ sdk.Context, _ *abci.RequestFinalizeBlock) (*sdk.ResponsePreBlock, error) {
-			return nil, nil
-		},
+		// TODO we can move the UpdateMarketPrices in extend vote to this in the future.
+		vote_extensions.NoopPriceApplier{},
 		app.oracleMetrics,
 	)
 
@@ -1576,19 +1568,6 @@ func (app *App) initOracleMetrics(appOpts servertypes.AppOptions) {
 	if err != nil {
 		panic(err)
 	}
-	// run prometheus metrics
-	if cfg.MetricsEnabled {
-		promLogger, err := zap.NewProduction()
-		if err != nil {
-			panic(err)
-		}
-		app.oraclePrometheusServer, err = promserver.NewPrometheusServer(cfg.PrometheusServerAddress, promLogger)
-		if err != nil {
-			panic(err)
-		}
-		// start the prometheus server
-		go app.oraclePrometheusServer.Start()
-	}
 	app.oracleMetrics = oracleMetrics
 }
 

protocol/app/vote_extensions/expected_keepers.go

@@ -15,5 +15,4 @@ type PricesKeeper interface {
 		ctx sdk.Context,
 		updates []*pricestypes.MsgUpdateMarketPrices_MarketPrice,
 	) (err error)
-	GetPrevBlockCPCounter(ctx sdk.Context) (uint64, error)
 }

protocol/app/vote_extensions/extend_vote_handler.go

@@ -2,6 +2,8 @@ package vote_extensions
 
 import (
 	"fmt"
+	slinkytypes "github.com/skip-mev/slinky/pkg/types"
+	"math/big"
 
 	cometabci "github.com/cometbft/cometbft/abci/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -19,6 +21,16 @@ type ExtendVoteHandler struct {
 	PricesKeeper            PricesKeeper
 }
 
+type NoopPriceApplier struct{}
+
+func (n NoopPriceApplier) ApplyPricesFromVoteExtensions(
+	_ sdk.Context, _ *cometabci.RequestFinalizeBlock) (map[slinkytypes.CurrencyPair]*big.Int, error) {
+	return nil, nil
+}
+func (n NoopPriceApplier) GetPricesForValidator(_ sdk.ConsAddress) map[slinkytypes.CurrencyPair]*big.Int {
+	return nil
+}
+
 // ExtendVoteHandler returns a sdk.ExtendVoteHandler, responsible for the following:
 //  1. Decoding the x/prices MsgUpdateMarketPrices in the current block - fail on errors
 //  2. Validating the proposed MsgUpdateMarketPrices in accordance with the ProcessProposal check

protocol/cmd/dydxprotocold/cmd/config.go

@@ -55,11 +55,10 @@ func initAppConfig() (string, *DydxAppConfig) {
 	appConfig := DydxAppConfig{
 		Config: *srvCfg,
 		Oracle: oracleconfig.AppConfig{
-			Enabled:                 true,
-			OracleAddress:           "localhost:8080",
-			ClientTimeout:           time.Second * 2,
-			MetricsEnabled:          false,
-			PrometheusServerAddress: "",
+			Enabled:        true,
+			OracleAddress:  "localhost:8080",
+			ClientTimeout:  time.Second * 2,
+			MetricsEnabled: false,
 		},
 	}
 

protocol/daemons/flags/flags.go

@@ -112,11 +112,10 @@ func GetDefaultDaemonFlags() DaemonFlags {
 			},
 			Slinky: SlinkyFlags{
 				AppConfig: oracleconfig.AppConfig{
-					Enabled:                 true,
-					OracleAddress:           "localhost:8080",
-					ClientTimeout:           time.Second * 2,
-					MetricsEnabled:          true,
-					PrometheusServerAddress: "0.0.0.0:8001",
+					Enabled:        true,
+					OracleAddress:  "localhost:8080",
+					ClientTimeout:  time.Second * 2,
+					MetricsEnabled: true,
 				},
 			},
 		}
@@ -218,11 +217,6 @@ func AddDaemonFlagsToCmd(
 		df.Slinky.AppConfig.MetricsEnabled,
 		"Enable the oracle metrics reporting for Slinky.",
 	)
-	cmd.Flags().String(
-		FlagOraclePrometheusServerAddress,
-		df.Slinky.AppConfig.PrometheusServerAddress,
-		"The address of the exposed prometheus address for Slinky metrics.",
-	)
 }
 
 // GetDaemonFlagValuesFromOptions gets all daemon flag values from the `AppOptions` struct.
@@ -316,11 +310,6 @@ func GetDaemonFlagValuesFromOptions(
 			result.Slinky.AppConfig.MetricsEnabled = v
 		}
 	}
-	if option := appOpts.Get(FlagOraclePrometheusServerAddress); option != nil {
-		if v, err := cast.ToStringE(option); err == nil {
-			result.Slinky.AppConfig.PrometheusServerAddress = v
-		}
-	}
 
 	return result
 }

protocol/daemons/types/grpc_client.go

@@ -29,12 +29,12 @@ func (g *GrpcClientImpl) NewGrpcConnection(
 	ctx context.Context,
 	socketAddress string,
 ) (*grpc.ClientConn, error) {
-	return grpc.DialContext(
+	return grpc.DialContext( //nolint:staticcheck
 		ctx,
 		socketAddress,
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
 		// https://github.com/grpc/grpc-go/blob/master/dialoptions.go#L264
-		grpc.WithBlock(),
+		grpc.WithBlock(), //nolint:staticcheck
 		grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
 			// Create a custom `net.Dialer` in order to specify `unix` as the desired network.
 			var dialer net.Dialer
@@ -48,11 +48,11 @@ func (g *GrpcClientImpl) NewTcpConnection(
 	ctx context.Context,
 	endpoint string,
 ) (*grpc.ClientConn, error) {
-	return grpc.DialContext(
+	return grpc.DialContext( //nolint:staticcheck
 		ctx,
 		endpoint,
 		grpc.WithTransportCredentials(insecure.NewCredentials()),
-		grpc.WithBlock(),
+		grpc.WithBlock(), //nolint:staticcheck
 	)
 }