feat: remove kvindexer (#129)

* remove kvindexer

* fix lint

Author: beer-1

app/app.go

@@ -67,10 +67,6 @@ import (
 	"github.com/initia-labs/miniwasm/app/keepers"
 	"github.com/initia-labs/miniwasm/app/upgrades/v1_1_1"
 
-	// kvindexer
-	kvindexermodule "github.com/initia-labs/kvindexer/x/kvindexer"
-	kvindexerkeeper "github.com/initia-labs/kvindexer/x/kvindexer/keeper"
-
 	// unnamed import of statik for swagger UI support
 	_ "github.com/initia-labs/miniwasm/client/docs/statik"
 )
@@ -117,18 +113,12 @@ type MinitiaApp struct {
 
 	// Override of BaseApp's CheckTx
 	checkTxHandler blockchecktx.CheckTx
-
-	// indexer keeper for graceful shutdown
-	kvIndexerKeeper *kvindexerkeeper.Keeper
-	// indexer module for grpc-gateway registration
-	kvIndexerModule *kvindexermodule.AppModuleBasic
 }
 
 // NewMinitiaApp returns a reference to an initialized Initia.
 func NewMinitiaApp(
 	logger log.Logger,
 	db dbm.DB,
-	kvindexerDB dbm.DB,
 	traceStore io.Writer,
 	loadLatest bool,
 	wasmOpts []wasmkeeper.Option,
@@ -247,17 +237,6 @@ func NewMinitiaApp(
 		tmos.Exit(err.Error())
 	}
 
-	// setup indexer
-	if kvIndexerKeeper, kvIndexerModule, streamingManager, err := setupIndexer(app, appOpts, encodingConfig, kvindexerDB); err != nil {
-		tmos.Exit(err.Error())
-	} else if kvIndexerKeeper != nil && kvIndexerModule != nil && streamingManager != nil {
-		// register kvindexer keeper and module, and register services
-		app.SetKVIndexer(kvIndexerKeeper, kvIndexerModule)
-
-		// override base-app's streaming manager
-		app.SetStreamingManager(*streamingManager)
-	}
-
 	// Only register upgrade handlers when loading the latest version of the app.
 	// This optimization skips unnecessary handler registration during app initialization.
 	//
@@ -392,13 +371,6 @@ func (app *MinitiaApp) setPostHandler() {
 	app.SetPostHandler(postHandler)
 }
 
-// SetKVIndexer sets the kvindexer keeper and module for the app and registers the services.
-func (app *MinitiaApp) SetKVIndexer(kvIndexerKeeper *kvindexerkeeper.Keeper, kvIndexerModule *kvindexermodule.AppModuleBasic) {
-	app.kvIndexerKeeper = kvIndexerKeeper
-	app.kvIndexerModule = kvIndexerModule
-	app.kvIndexerModule.RegisterServices(app.configurator)
-}
-
 // Name returns the name of the App
 func (app *MinitiaApp) Name() string { return app.BaseApp.Name() }
 
@@ -500,11 +472,6 @@ func (app *MinitiaApp) RegisterAPIRoutes(apiSvr *api.Server, apiConfig config.AP
 	// Register grpc-gateway routes for all modules.
 	app.BasicModuleManager.RegisterGRPCGatewayRoutes(clientCtx, apiSvr.GRPCGatewayRouter)
 
-	// Register grpc-gateway routes for indexer module.
-	if app.kvIndexerModule != nil {
-		app.kvIndexerModule.RegisterGRPCGatewayRoutes(clientCtx, apiSvr.GRPCGatewayRouter)
-	}
-
 	// register swagger API from root so that other applications can override easily
 	if apiConfig.Swagger {
 		RegisterSwaggerAPI(apiSvr.Router)
@@ -570,12 +537,6 @@ func GetMaccPerms() map[string][]string {
 // Close closes the underlying baseapp, the oracle service, and the prometheus server if required.
 // This method blocks on the closure of both the prometheus server, and the oracle-service
 func (app *MinitiaApp) Close() error {
-	if app.kvIndexerKeeper != nil {
-		if err := app.kvIndexerKeeper.Close(); err != nil {
-			return err
-		}
-	}
-
 	if err := app.BaseApp.Close(); err != nil {
 		return err
 	}

app/app_test.go

@@ -68,7 +68,7 @@ func TestInitGenesisOnMigration(t *testing.T) {
 	db := dbm.NewMemDB()
 	logger := log.NewLogger(os.Stdout)
 	app := NewMinitiaApp(
-		logger, db, getOrCreateMemDB(nil), nil, true, []wasmkeeper.Option{}, EmptyAppOptions{homeDir: t.TempDir()})
+		logger, db, nil, true, []wasmkeeper.Option{}, EmptyAppOptions{homeDir: t.TempDir()})
 	ctx := app.NewContextLegacy(true, cmtproto.Header{Height: app.LastBlockHeight()})
 
 	// Create a mock module. This module will serve as the new module we're
@@ -124,7 +124,7 @@ func TestGetKey(t *testing.T) {
 	db := dbm.NewMemDB()
 	app := NewMinitiaApp(
 		log.NewLogger(os.Stdout),
-		db, dbm.NewMemDB(), nil, true, []wasmkeeper.Option{}, EmptyAppOptions{homeDir: t.TempDir()})
+		db, nil, true, []wasmkeeper.Option{}, EmptyAppOptions{homeDir: t.TempDir()})
 
 	require.NotEmpty(t, app.GetKey(banktypes.StoreKey))
 	require.NotEmpty(t, app.GetMemKey(capabilitytypes.MemStoreKey))

app/encoding.go

@@ -26,7 +26,6 @@ func tempApp() *MinitiaApp {
 	return NewMinitiaApp(
 		log.NewNopLogger(),
 		dbm.NewMemDB(),
-		dbm.NewMemDB(),
 		nil,
 		false,
 		[]wasmkeeper.Option{},

app/indexer.go

@@ -100,7 +100,6 @@ import (
 	forwarding "github.com/noble-assets/forwarding/v2"
 	forwardingkeeper "github.com/noble-assets/forwarding/v2/keeper"
 	forwardingtypes "github.com/noble-assets/forwarding/v2/types"
-	// kvindexer
 )
 
 type AppKeepers struct {

app/keepers/keepers.go

@@ -58,7 +58,6 @@ func setup(homeDir string, db *dbm.DB, withGenesis bool) (*MinitiaApp, GenesisSt
 	app := NewMinitiaApp(
 		log.NewNopLogger(),
 		getOrCreateMemDB(db),
-		getOrCreateMemDB(nil),
 		nil,
 		true,
 		[]wasmkeeper.Option{},

app/test_helpers.go

@@ -161,21 +161,6 @@
         }
       }
     },
-    {
-      "url": "./tmp-swagger-gen/indexer/info/query.swagger.json"
-    },
-    {
-      "url": "./tmp-swagger-gen/indexer/block/v1/query.swagger.json"
-    },
-    {
-      "url": "./tmp-swagger-gen/indexer/tx/v1/query.swagger.json"
-    },
-    {
-      "url": "./tmp-swagger-gen/indexer/nft/v1/query.swagger.json"
-    },
-    {
-      "url": "./tmp-swagger-gen/indexer/pair/v1/query.swagger.json"
-    },
     {
       "url": "./tmp-swagger-gen/connect/oracle/v2/query.swagger.json"
     },