refactor: remove "slinky" usages from the code

.github/actions/spelling/expect.txt

@@ -569,14 +569,14 @@ slashingkeeper
 slashingmodulev
 slashingtypes
 SLf
-slinkyabci
-slinkyabcimocks
-slinkyabcitypes
+connectabci
+connectabcimocks
+connectabcitypes
 slinkyd
-slinkygrpc
+connectgrpc
 slinkyhttp
 slinkymath
-slinkytypes
+connecttypes
 SMOLE
 solana
 solanago

.goreleaser.yml

@@ -1,10 +1,10 @@
 ---
-project_name: slinky
+project_name: connect
 
 release:
   github:
     owner: skip-mev
-    name: slinky
+    name: connect
   prerelease: true
 
 builds:

abci/preblock/oracle/preblock.go

@@ -14,10 +14,10 @@
 	abciaggregator "github.com/skip-mev/connect/v2/abci/strategies/aggregator"
 	"github.com/skip-mev/connect/v2/abci/strategies/codec"
 	"github.com/skip-mev/connect/v2/abci/strategies/currencypair"
-	slinkyabcitypes "github.com/skip-mev/connect/v2/abci/types"
+	connectabcitypes "github.com/skip-mev/connect/v2/abci/types"
 	"github.com/skip-mev/connect/v2/abci/ve"
 	"github.com/skip-mev/connect/v2/aggregator"
-	slinkytypes "github.com/skip-mev/connect/v2/pkg/types"
+	connecttypes "github.com/skip-mev/connect/v2/pkg/types"
 	servicemetrics "github.com/skip-mev/connect/v2/service/metrics"
 )
 
@@ -33,7 +33,7 @@
 
 	// keeper is the keeper for the oracle module. This is utilized to write
 	// oracle data to state.
-	keeper slinkyabcitypes.OracleKeeper
+	keeper connectabcitypes.OracleKeeper
 
 	// pa is the price applier that is used to decode vote-extensions, aggregate price reports, and write prices to state.
 	pa abciaggregator.PriceApplier
@@ -43,8 +43,8 @@
 // is responsible for writing oracle data included in vote extensions to state.
 func NewOraclePreBlockHandler(
 	logger log.Logger,
-	aggregateFn aggregator.AggregateFnFromContext[string, map[slinkytypes.CurrencyPair]*big.Int],
-	oracleKeeper slinkyabcitypes.OracleKeeper,
+	aggregateFn aggregator.AggregateFnFromContext[string, map[connecttypes.CurrencyPair]*big.Int],
+	oracleKeeper connectabcitypes.OracleKeeper,
 	metrics servicemetrics.Metrics,
 	strategy currencypair.CurrencyPairStrategy,
 	veCodec codec.VoteExtensionCodec,
@@ -93,7 +93,7 @@
 		}
 
 		start := time.Now()
-		var prices map[slinkytypes.CurrencyPair]*big.Int
+		var prices map[connecttypes.CurrencyPair]*big.Int
 		defer func() {
 			// only measure latency in Finalize
 			if ctx.ExecMode() == sdk.ExecModeFinalize {
@@ -103,7 +103,7 @@
 					"height", ctx.BlockHeight(),
 					"latency (seconds)", latency.Seconds(),
 				)
-				slinkyabcitypes.RecordLatencyAndStatus(h.metrics, latency, err, servicemetrics.PreBlock)
+				connectabcitypes.RecordLatencyAndStatus(h.metrics, latency, err, servicemetrics.PreBlock)
 
 				// record prices + ticker metrics per validator (only do so if there was no error writing the prices)
 				if err == nil && prices != nil {
@@ -165,7 +165,7 @@
 		}
 
 		start := time.Now()
-		var prices map[slinkytypes.CurrencyPair]*big.Int
+		var prices map[connecttypes.CurrencyPair]*big.Int
 		defer func() {
 			// only measure latency in Finalize
 			if ctx.ExecMode() == sdk.ExecModeFinalize {
@@ -175,7 +175,7 @@
 					"height", ctx.BlockHeight(),
 					"latency (seconds)", latency.Seconds(),
 				)
-				slinkyabcitypes.RecordLatencyAndStatus(h.metrics, latency, err, servicemetrics.PreBlock)
+				connectabcitypes.RecordLatencyAndStatus(h.metrics, latency, err, servicemetrics.PreBlock)
 
 				// record prices + ticker metrics per validator (only do so if there was no error writing the prices)
 				if err == nil && prices != nil {

abci/preblock/oracle/preblock_test.go

@@ -24,12 +24,12 @@ import (
 	currencypairmock "github.com/skip-mev/connect/v2/abci/strategies/currencypair/mocks"
 	"github.com/skip-mev/connect/v2/abci/testutils"
 	"github.com/skip-mev/connect/v2/abci/types"
-	slinkyabcimocks "github.com/skip-mev/connect/v2/abci/types/mocks"
+	connectabcimocks "github.com/skip-mev/connect/v2/abci/types/mocks"
 	vetypes "github.com/skip-mev/connect/v2/abci/ve/types"
 	"github.com/skip-mev/connect/v2/aggregator"
 	"github.com/skip-mev/connect/v2/pkg/math/voteweighted"
 	voteweightedmocks "github.com/skip-mev/connect/v2/pkg/math/voteweighted/mocks"
-	slinkytypes "github.com/skip-mev/connect/v2/pkg/types"
+	connecttypes "github.com/skip-mev/connect/v2/pkg/types"
 	servicemetrics "github.com/skip-mev/connect/v2/service/metrics"
 	metricmock "github.com/skip-mev/connect/v2/service/metrics/mocks"
 	"github.com/skip-mev/connect/v2/x/oracle/keeper"
@@ -43,7 +43,7 @@ type PreBlockTestSuite struct {
 
 	myVal         sdk.ConsAddress
 	ctx           sdk.Context
-	currencyPairs []slinkytypes.CurrencyPair
+	currencyPairs []connecttypes.CurrencyPair
 	genesis       oracletypes.GenesisState
 	key           *storetypes.KVStoreKey
 	transientKey  *storetypes.TransientStoreKey
@@ -63,7 +63,7 @@ func TestPreBlockTestSuite(t *testing.T) {
 func (s *PreBlockTestSuite) SetupTest() {
 	s.mm = &module.Manager{Modules: map[string]interface{}{}, OrderPreBlockers: make([]string, 0)}
 	s.myVal = sdk.ConsAddress("myVal")
-	s.currencyPairs = []slinkytypes.CurrencyPair{
+	s.currencyPairs = []connecttypes.CurrencyPair{
 		{
 			Base:  "BTC",
 			Quote: "ETH",
@@ -449,8 +449,8 @@ func (s *PreBlockTestSuite) TestPreBlockStatus() {
 		metrics := metricmock.NewMetrics(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -470,8 +470,8 @@ func (s *PreBlockTestSuite) TestPreBlockStatus() {
 		metrics := metricmock.NewMetrics(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -493,8 +493,8 @@ func (s *PreBlockTestSuite) TestPreBlockStatus() {
 		metrics := metricmock.NewMetrics(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -523,11 +523,11 @@ func (s *PreBlockTestSuite) TestPreBlockStatus() {
 		metrics := metricmock.NewMetrics(s.T())
 		extCodec := codecmock.NewExtendedCommitCodec(s.T())
 		veCodec := codecmock.NewVoteExtensionCodec(s.T())
-		mockOracleKeeper := slinkyabcimocks.NewOracleKeeper(s.T())
+		mockOracleKeeper := connectabcimocks.NewOracleKeeper(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -578,8 +578,8 @@ func (s *PreBlockTestSuite) TestValidatorReports() {
 		metrics := metricmock.NewMetrics(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -604,8 +604,8 @@ func (s *PreBlockTestSuite) TestValidatorReports() {
 		metrics := metricmock.NewMetrics(s.T())
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
 					return nil
 				}
 			},
@@ -638,17 +638,17 @@ func (s *PreBlockTestSuite) TestValidatorReports() {
 		val2 := sdk.ConsAddress("val2")
 		val3 := sdk.ConsAddress("val3")
 
-		mockOracleKeeper := slinkyabcimocks.NewOracleKeeper(s.T())
+		mockOracleKeeper := connectabcimocks.NewOracleKeeper(s.T())
 		currencyPairStrategyMock := currencypairmock.NewCurrencyPairStrategy(s.T())
 
-		btcUsd := slinkytypes.NewCurrencyPair("BTC", "USD")
-		mogUsd := slinkytypes.NewCurrencyPair("MOG", "USD")
+		btcUsd := connecttypes.NewCurrencyPair("BTC", "USD")
+		mogUsd := connecttypes.NewCurrencyPair("MOG", "USD")
 
 		handler := preblock.NewOraclePreBlockHandler(
 			log.NewTestLogger(s.T()),
-			func(_ sdk.Context) aggregator.AggregateFn[string, map[slinkytypes.CurrencyPair]*big.Int] {
-				return func(_ aggregator.AggregatedProviderData[string, map[slinkytypes.CurrencyPair]*big.Int]) map[slinkytypes.CurrencyPair]*big.Int {
-					return map[slinkytypes.CurrencyPair]*big.Int{
+			func(_ sdk.Context) aggregator.AggregateFn[string, map[connecttypes.CurrencyPair]*big.Int] {
+				return func(_ aggregator.AggregatedProviderData[string, map[connecttypes.CurrencyPair]*big.Int]) map[connecttypes.CurrencyPair]*big.Int {
+					return map[connecttypes.CurrencyPair]*big.Int{
 						// return default values
 						btcUsd: big.NewInt(1),
 						mogUsd: maxUint256,
@@ -675,7 +675,7 @@ func (s *PreBlockTestSuite) TestValidatorReports() {
 		currencyPairStrategyMock.On("GetDecodedPrice", s.ctx, mogUsd, mock.Anything).Return(maxUint256, nil)
 
 		// mock oracle keeper calls
-		mockOracleKeeper.On("GetAllCurrencyPairs", s.ctx).Return([]slinkytypes.CurrencyPair{btcUsd, mogUsd}, nil)
+		mockOracleKeeper.On("GetAllCurrencyPairs", s.ctx).Return([]connecttypes.CurrencyPair{btcUsd, mogUsd}, nil)
 		mockOracleKeeper.On("SetPriceForCurrencyPair", s.ctx, btcUsd, mock.Anything).Return(nil)
 		mockOracleKeeper.On("SetPriceForCurrencyPair", s.ctx, mogUsd, mock.Anything).Return(nil)
 

abci/preblock/oracle/utils.go

@@ -7,12 +7,12 @@ import (
 	cometproto "github.com/cometbft/cometbft/proto/tendermint/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 
-	slinkytypes "github.com/skip-mev/connect/v2/pkg/types"
+	connecttypes "github.com/skip-mev/connect/v2/pkg/types"
 	servicemetrics "github.com/skip-mev/connect/v2/service/metrics"
 )
 
 // recordPrice records all the given prices per ticker, and reports them as a float64.
-func (h *PreBlockHandler) recordPrices(prices map[slinkytypes.CurrencyPair]*big.Int) {
+func (h *PreBlockHandler) recordPrices(prices map[connecttypes.CurrencyPair]*big.Int) {
 	for ticker, price := range prices {
 		floatPrice, _ := price.Float64()
 		h.metrics.ObservePriceForTicker(ticker, floatPrice)

abci/proposals/proposals.go

@@ -11,7 +11,7 @@ import (
 
 	"github.com/skip-mev/connect/v2/abci/strategies/codec"
 	"github.com/skip-mev/connect/v2/abci/strategies/currencypair"
-	slinkyabci "github.com/skip-mev/connect/v2/abci/types"
+	connectabci "github.com/skip-mev/connect/v2/abci/types"
 	"github.com/skip-mev/connect/v2/abci/ve"
 	servicemetrics "github.com/skip-mev/connect/v2/service/metrics"
 )
@@ -114,12 +114,12 @@ func (h *ProposalHandler) PrepareProposalHandler() sdk.PrepareProposalHandler {
 				"slinky prepare proposal latency", (totalLatency - wrappedPrepareProposalLatency).Seconds(),
 			)
 
-			slinkyabci.RecordLatencyAndStatus(h.metrics, totalLatency-wrappedPrepareProposalLatency, err, servicemetrics.PrepareProposal)
+			connectabci.RecordLatencyAndStatus(h.metrics, totalLatency-wrappedPrepareProposalLatency, err, servicemetrics.PrepareProposal)
 		}()
 
 		if req == nil {
 			h.logger.Error("PrepareProposalHandler received a nil request")
-			err = slinkyabci.NilRequestError{
+			err = connectabci.NilRequestError{
 				Handler: servicemetrics.PrepareProposal,
 			}
 			return nil, err
@@ -162,7 +162,7 @@ func (h *ProposalHandler) PrepareProposalHandler() sdk.PrepareProposalHandler {
 					"commit_info", extInfo,
 					"err", err,
 				)
-				err = slinkyabci.CodecError{
+				err = connectabci.CodecError{
 					Err: err,
 				}
 
@@ -193,7 +193,7 @@ func (h *ProposalHandler) PrepareProposalHandler() sdk.PrepareProposalHandler {
 		wrappedPrepareProposalLatency = time.Since(wrappedPrepareProposalStartTime)
 		if err != nil {
 			h.logger.Error("failed to prepare proposal", "err", err)
-			err = slinkyabci.WrappedHandlerError{
+			err = connectabci.WrappedHandlerError{
 				Handler: servicemetrics.PrepareProposal,
 				Err:     err,
 			}
@@ -267,13 +267,13 @@ func (h *ProposalHandler) ProcessProposalHandler() sdk.ProcessProposalHandler {
 				"wrapped prepare proposal latency", wrappedProcessProposalLatency.Seconds(),
 				"slinky prepare proposal latency", (totalLatency - wrappedProcessProposalLatency).Seconds(),
 			)
-			slinkyabci.RecordLatencyAndStatus(h.metrics, totalLatency-wrappedProcessProposalLatency, err, servicemetrics.ProcessProposal)
+			connectabci.RecordLatencyAndStatus(h.metrics, totalLatency-wrappedProcessProposalLatency, err, servicemetrics.ProcessProposal)
 		}()
 
 		// this should never happen, but just in case
 		if req == nil {
 			h.logger.Error("ProcessProposalHandler received a nil request")
-			err = slinkyabci.NilRequestError{
+			err = connectabci.NilRequestError{
 				Handler: servicemetrics.ProcessProposal,
 			}
 			return nil, err
@@ -293,21 +293,21 @@ func (h *ProposalHandler) ProcessProposalHandler() sdk.ProcessProposalHandler {
 
 		if voteExtensionsEnabled {
 			// Ensure that the commit info was correctly injected into the proposal.
-			if len(req.Txs) < slinkyabci.NumInjectedTxs {
+			if len(req.Txs) < connectabci.NumInjectedTxs {
 				h.logger.Error("failed to process proposal: missing commit info", "num_txs", len(req.Txs))
-				err = slinkyabci.MissingCommitInfoError{}
+				err = connectabci.MissingCommitInfoError{}
 				return &cometabci.ResponseProcessProposal{Status: cometabci.ResponseProcessProposal_REJECT},
 					err
 			}
 
-			extCommitBz := req.Txs[slinkyabci.OracleInfoIndex]
+			extCommitBz := req.Txs[connectabci.OracleInfoIndex]
 
 			// Validate the vote extensions included in the proposal.
 			var extInfo cometabci.ExtendedCommitInfo
 			extInfo, err = h.extendedCommitCodec.Decode(extCommitBz)
 			if err != nil {
 				h.logger.Error("failed to unmarshal commit info", "err", err)
-				err = slinkyabci.CodecError{
+				err = connectabci.CodecError{
 					Err: err,
 				}
 				return &cometabci.ResponseProcessProposal{Status: cometabci.ResponseProcessProposal_REJECT},
@@ -334,16 +334,16 @@ func (h *ProposalHandler) ProcessProposalHandler() sdk.ProcessProposalHandler {
 
 			// Remove the extended commit info from the proposal if required
 			if !h.retainOracleDataInWrappedHandler {
-				injectedTx = req.Txs[slinkyabci.OracleInfoIndex]
-				req.Txs = req.Txs[slinkyabci.NumInjectedTxs:]
+				injectedTx = req.Txs[connectabci.OracleInfoIndex]
+				req.Txs = req.Txs[connectabci.NumInjectedTxs:]
 			}
 		}
 
 		// call the wrapped process-proposal
 		wrappedProcessProposalStartTime := time.Now()
 		resp, err = h.processProposalHandler(ctx, req)
 		if err != nil {
-			err = slinkyabci.WrappedHandlerError{
+			err = connectabci.WrappedHandlerError{
 				Handler: servicemetrics.ProcessProposal,
 				Err:     err,
 			}