build(deps): bump github.com/knadh/koanf/v2 from 2.1.1 to 2.1.2

Bumps [github.com/knadh/koanf/v2](https://github.com/knadh/koanf) from 2.1.1 to 2.1.2.
- [Release notes](https://github.com/knadh/koanf/releases)
- [Commits](https://github.com/knadh/koanf/compare/v2.1.1...v2.1.2)

---
updated-dependencies:
- dependency-name: github.com/knadh/koanf/v2
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

Dockerfile

@@ -1,4 +1,4 @@
-FROM golang:1.23.3-bookworm as build
+FROM golang:1.23.0-bookworm as build
 
 ENV CGO_ENABLED=1
 

README.md

@@ -2,21 +2,18 @@
 
 ![GitHub Tag](https://img.shields.io/github/v/tag/grassrootseconomics/eth-indexer)
 
-A lightweight Postgres chain indexer designed to couple with
-[eth-tracker](https://github.com/grassrootseconomics/eth-tracker) to index all
-relevant GE related blockchain data on any EVM chain.
+A lightweight Postgres chain indexer designed to couple with [eth-tracker](https://github.com/grassrootseconomics/eth-tracker) to index all relevant GE related blockchain data on any EVM chain.
 
 ## Getting Started
 
 ### Prerequisites
 
-- Git
-- Docker
-- Postgres server
-- Access to a `eth-tracker` instance
+* Git
+* Docker
+* Postgres server
+* Access to a `eth-tracker` instance
 
-See [docker-compose.yaml](dev/docker-compose.yaml) for an example on how to run
-and deploy a single instance.
+See [docker-compose.yaml](dev/docker-compose.yaml) for an example on how to run and deploy a single instance.
 
 ### 1. Build the Docker image
 
@@ -37,9 +34,7 @@ For an example, see `dev/docker-compose.postgres.yaml`.
 
 ### 3. Update config values
 
-See `.env.example` on how to override default values defined in `config.toml`
-using env variables. Alternatively, mount your own config.toml either during
-build time or Docker runtime.
+See `.env.example` on how to override default values defined in `config.toml` using env variables. Alternatively, mount your own config.toml either during build time or Docker runtime.
 
 ```bash
 # Override only specific config values
@@ -49,10 +44,10 @@ mv .env.example .env
 
 Special env variables:
 
-- DEV=*
+* DEV=*
+
+Refer to [`config.toml`](config.toml) to understand different config value settings.
 
-Refer to [`config.toml`](config.toml) to understand different config value
-settings.
 
 ### 4. Run the indexer
 
@@ -63,4 +58,4 @@ docker compose up
 
 ## License
 
-[AGPL-3.0](LICENSE).
+[AGPL-3.0](LICENSE).

cmd/service/main.go

@@ -12,12 +12,12 @@ import (
 	"syscall"
 	"time"
 
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/api"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/cache"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/handler"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/store"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/sub"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/util"
+	"github.com/grassrootseconomics/eth-indexer/internal/api"
+	"github.com/grassrootseconomics/eth-indexer/internal/cache"
+	"github.com/grassrootseconomics/eth-indexer/internal/handler"
+	"github.com/grassrootseconomics/eth-indexer/internal/store"
+	"github.com/grassrootseconomics/eth-indexer/internal/sub"
+	"github.com/grassrootseconomics/eth-indexer/internal/util"
 	"github.com/grassrootseconomics/ethutils"
 	"github.com/knadh/koanf/v2"
 )

cmd/service/router.go

@@ -1,8 +1,8 @@
 package main
 
 import (
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/handler"
-	"github.com/grassrootseconomics/eth-indexer/v2/pkg/router"
+	"github.com/grassrootseconomics/eth-indexer/internal/handler"
+	"github.com/grassrootseconomics/eth-indexer/pkg/router"
 )
 
 func bootstrapRouter(handlerContainer *handler.Handler) *router.Router {
@@ -20,7 +20,7 @@ func bootstrapRouter(handlerContainer *handler.Handler) *router.Router {
 	)
 	router.RegisterRoute(
 		"TRACKER.TOKEN_BURN",
-		handlerContainer.IndexTokenBurn,
+		handlerContainer.IndexTokenMint,
 		handlerContainer.AddToken,
 	)
 	router.RegisterRoute(
@@ -38,15 +38,6 @@ func bootstrapRouter(handlerContainer *handler.Handler) *router.Router {
 		handlerContainer.IndexFaucetGive,
 		handlerContainer.FaucetHealthCheck,
 	)
-	router.RegisterRoute(
-		"TRACKER.OWNERSHIP_TRANSFERRED",
-		handlerContainer.IndexOwnershipChange,
-	)
-
-	router.RegisterRoute(
-		"TRACKER.INDEX_REMOVE",
-		handlerContainer.IndexRemove,
-	)
 
 	return router
 }

go.mod

@@ -1,6 +1,6 @@
-module github.com/grassrootseconomics/eth-indexer/v2
+module github.com/grassrootseconomics/eth-indexer
 
-go 1.23.3
+go 1.23.0
 
 require (
 	github.com/VictoriaMetrics/metrics v1.35.1
@@ -15,7 +15,7 @@ require (
 	github.com/knadh/koanf/parsers/toml v0.1.0
 	github.com/knadh/koanf/providers/env v1.0.0
 	github.com/knadh/koanf/providers/file v1.1.2
-	github.com/knadh/koanf/v2 v2.1.1
+	github.com/knadh/koanf/v2 v2.1.2
 	github.com/lmittmann/w3 v0.17.1
 	github.com/nats-io/nats.go v1.37.0
 	github.com/puzpuzpuz/xsync/v3 v3.4.0
@@ -39,7 +39,7 @@ require (
 	github.com/ethereum/c-kzg-4844 v1.0.0 // indirect
 	github.com/fsnotify/fsnotify v1.7.0 // indirect
 	github.com/go-ole/go-ole v1.3.0 // indirect
-	github.com/go-viper/mapstructure/v2 v2.0.0-alpha.1 // indirect
+	github.com/go-viper/mapstructure/v2 v2.2.1 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/gorilla/websocket v1.5.0 // indirect
 	github.com/holiman/uint256 v1.3.1 // indirect

go.sum

@@ -74,8 +74,8 @@ github.com/go-ole/go-ole v1.2.5/go.mod h1:pprOEPIfldk/42T2oK7lQ4v4JSDwmV0As9GaiU
 github.com/go-ole/go-ole v1.3.0 h1:Dt6ye7+vXGIKZ7Xtk4s6/xVdGDQynvom7xCFEdWr6uE=
 github.com/go-ole/go-ole v1.3.0/go.mod h1:5LS6F96DhAwUc7C+1HLexzMXY1xGRSryjyPPKW6zv78=
 github.com/go-sql-driver/mysql v1.4.0/go.mod h1:zAC/RDZ24gD3HViQzih4MyKcchzm+sOG5ZlKdlhCg5w=
-github.com/go-viper/mapstructure/v2 v2.0.0-alpha.1 h1:TQcrn6Wq+sKGkpyPvppOz99zsMBaUOKXq6HSv655U1c=
-github.com/go-viper/mapstructure/v2 v2.0.0-alpha.1/go.mod h1:oJDH3BJKyqBA2TXFhDsKDGDTlndYOZ6rGS0BRZIxGhM=
+github.com/go-viper/mapstructure/v2 v2.2.1 h1:ZAaOCxANMuZx5RCeg0mBdEZk7DZasvvZIxtHqx8aGss=
+github.com/go-viper/mapstructure/v2 v2.2.1/go.mod h1:oJDH3BJKyqBA2TXFhDsKDGDTlndYOZ6rGS0BRZIxGhM=
 github.com/gofrs/flock v0.8.1 h1:+gYjHKf32LDeiEEFhQaotPbLuUXjY5ZqxKgXy7n59aw=
 github.com/gofrs/flock v0.8.1/go.mod h1:F1TvTiK9OcQqauNUHlbJvyl9Qa1QvF/gOUDKA14jxHU=
 github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
@@ -129,8 +129,8 @@ github.com/knadh/koanf/providers/env v1.0.0 h1:ufePaI9BnWH+ajuxGGiJ8pdTG0uLEUWC7
 github.com/knadh/koanf/providers/env v1.0.0/go.mod h1:mzFyRZueYhb37oPmC1HAv/oGEEuyvJDA98r3XAa8Gak=
 github.com/knadh/koanf/providers/file v1.1.2 h1:aCC36YGOgV5lTtAFz2qkgtWdeQsgfxUkxDOe+2nQY3w=
 github.com/knadh/koanf/providers/file v1.1.2/go.mod h1:/faSBcv2mxPVjFrXck95qeoyoZ5myJ6uxN8OOVNJJCI=
-github.com/knadh/koanf/v2 v2.1.1 h1:/R8eXqasSTsmDCsAyYj+81Wteg8AqrV9CP6gvsTsOmM=
-github.com/knadh/koanf/v2 v2.1.1/go.mod h1:4mnTRbZCK+ALuBXHZMjDfG9y714L7TykVnZkXbMU3Es=
+github.com/knadh/koanf/v2 v2.1.2 h1:I2rtLRqXRy1p01m/utEtpZSSA6dcJbgGVuE27kW2PzQ=
+github.com/knadh/koanf/v2 v2.1.2/go.mod h1:Gphfaen0q1Fc1HTgJgSTC4oRX9R2R5ErYMZJy8fLJBo=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=

internal/handler/add_contract.go

@@ -47,7 +47,7 @@ func (h *Handler) AddToken(ctx context.Context, event event.Event) error {
 
 	if err := h.chainProvider.Client.CallCtx(
 		ctx,
-		eth.CallFunc(contractAddress, sinkAddressGetter).Returns(&sinkAddress),
+		eth.CallFunc(contractAddress, decimalsGetter).Returns(&tokenDecimals),
 	); err != nil {
 		// This will most likely revert if the contract does not have a sinkAddress
 		// Instead of handling the error we just ignore it and set the value to 0

internal/handler/handler.go

@@ -3,8 +3,8 @@ package handler
 import (
 	"log/slog"
 
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/cache"
-	"github.com/grassrootseconomics/eth-indexer/v2/internal/store"
+	"github.com/grassrootseconomics/eth-indexer/internal/cache"
+	"github.com/grassrootseconomics/eth-indexer/internal/store"
 	"github.com/grassrootseconomics/ethutils"
 )
 

internal/handler/index_remove.go

@@ -1,11 +0,0 @@
-package handler
-
-import (
-	"context"
-
-	"github.com/grassrootseconomics/eth-tracker/pkg/event"
-)
-
-func (h *Handler) IndexRemove(ctx context.Context, event event.Event) error {
-	return h.store.RemoveContractAddress(ctx, event)
-}

internal/handler/ownership.go

@@ -1,11 +0,0 @@
-package handler
-
-import (
-	"context"
-
-	"github.com/grassrootseconomics/eth-tracker/pkg/event"
-)
-
-func (h *Handler) IndexOwnershipChange(ctx context.Context, event event.Event) error {
-	return h.store.InsertOwnershipChange(ctx, event)
-}

internal/store/pg.go

@@ -29,18 +29,15 @@ type (
 	}
 
 	queries struct {
-		InsertTx              string `query:"insert-tx"`
-		InsertTokenTransfer   string `query:"insert-token-transfer"`
-		InsertTokenMint       string `query:"insert-token-mint"`
-		InsertTokenBurn       string `query:"insert-token-burn"`
-		InsertFaucetGive      string `query:"insert-faucet-give"`
-		InsertPoolSwap        string `query:"insert-pool-swap"`
-		InsertPoolDeposit     string `query:"insert-pool-deposit"`
-		InsertOwnershipChange string `query:"insert-ownership-change"`
-		InsertToken           string `query:"insert-token"`
-		InsertPool            string `query:"insert-pool"`
-		RemovePool            string `query:"remove-pool"`
-		RemoveToken           string `query:"remove-token"`
+		InsertTx            string `query:"insert-tx"`
+		InsertTokenTransfer string `query:"insert-token-transfer"`
+		InsertTokenMint     string `query:"insert-token-mint"`
+		InsertTokenBurn     string `query:"insert-token-burn"`
+		InsertFaucetGive    string `query:"insert-faucet-give"`
+		InsertPoolSwap      string `query:"insert-pool-swap"`
+		InsertPoolDeposit   string `query:"insert-pool-deposit"`
+		InsertToken         string `query:"insert-token"`
+		InsertPool          string `query:"insert-pool"`
 	}
 )
 
@@ -202,25 +199,6 @@ func (pg *Pg) InsertPoolDeposit(ctx context.Context, eventPayload event.Event) e
 	})
 }
 
-func (pg *Pg) InsertOwnershipChange(ctx context.Context, eventPayload event.Event) error {
-	return pg.executeTransaction(ctx, func(tx pgx.Tx) error {
-		txID, err := pg.insertTx(ctx, tx, eventPayload)
-		if err != nil {
-			return err
-		}
-
-		_, err = tx.Exec(
-			ctx,
-			pg.queries.InsertOwnershipChange,
-			txID,
-			eventPayload.Payload["previousOwner"].(string),
-			eventPayload.Payload["newOwner"].(string),
-			eventPayload.ContractAddress,
-		)
-		return err
-	})
-}
-
 func (pg *Pg) InsertToken(ctx context.Context, contractAddress string, name string, symbol string, decimals uint8, sinkAddress string) error {
 	return pg.executeTransaction(ctx, func(tx pgx.Tx) error {
 		_, err := tx.Exec(
@@ -249,30 +227,6 @@ func (pg *Pg) InsertPool(ctx context.Context, contractAddress string, name strin
 	})
 }
 
-func (pg *Pg) RemoveContractAddress(ctx context.Context, eventPayload event.Event) error {
-	return pg.executeTransaction(ctx, func(tx pgx.Tx) error {
-		_, err := tx.Exec(
-			ctx,
-			pg.queries.RemovePool,
-			eventPayload.Payload["address"].(string),
-		)
-		if err != nil {
-			return err
-		}
-
-		_, err = tx.Exec(
-			ctx,
-			pg.queries.RemoveToken,
-			eventPayload.Payload["address"].(string),
-		)
-		if err != nil {
-			return err
-		}
-
-		return nil
-	})
-}
-
 func (pg *Pg) insertTx(ctx context.Context, tx pgx.Tx, eventPayload event.Event) (int, error) {
 	var txID int
 	if err := tx.QueryRow(

internal/store/store.go

@@ -15,10 +15,8 @@ type (
 		InsertFaucetGive(context.Context, event.Event) error
 		InsertPoolSwap(context.Context, event.Event) error
 		InsertPoolDeposit(context.Context, event.Event) error
-		InsertOwnershipChange(context.Context, event.Event) error
 		InsertToken(context.Context, string, string, string, uint8, string) error
 		InsertPool(context.Context, string, string, string) error
-		RemoveContractAddress(context.Context, event.Event) error
 		Pool() *pgxpool.Pool
 		Close()
 	}

internal/sub/jetstream.go

@@ -6,7 +6,7 @@ import (
 	"log/slog"
 	"time"
 
-	"github.com/grassrootseconomics/eth-indexer/v2/pkg/router"
+	"github.com/grassrootseconomics/eth-indexer/pkg/router"
 	"github.com/nats-io/nats.go"
 	"github.com/nats-io/nats.go/jetstream"
 )

migrations/002_track_ownership_change.sql

@@ -1,7 +0,0 @@
-CREATE TABLE IF NOT EXISTS ownership_change (
-  id INT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
-  tx_id INT REFERENCES tx(id),
-  previous_owner VARCHAR(42) NOT NULL DEFAULT '0x0000000000000000000000000000000000000000',
-  new_owner VARCHAR(42) NOT NULL DEFAULT '0x0000000000000000000000000000000000000000',
-  contract_address VARCHAR(42) NOT NULL DEFAULT '0x0000000000000000000000000000000000000000'
-);

migrations/003_add_removed_status.sql

@@ -1,5 +0,0 @@
-ALTER TABLE tokens
-ADD COLUMN removed BOOLEAN NOT NULL DEFAULT false;
-
-ALTER TABLE pools
-ADD COLUMN removed BOOLEAN NOT NULL DEFAULT false;

queries.sql

@@ -104,18 +104,6 @@ INSERT INTO pool_deposit(
     contract_address
 ) VALUES($1, $2, $3, $4, $5) ON CONFLICT DO NOTHING
 
---name: insert-ownership-change
--- $1: tx_id
--- $2: previous_owner
--- $3: new_owner
--- $4: contract_address
-INSERT INTO ownership_change(
-    tx_id,
-    previous_owner,
-    new_owner,
-    contract_address
-) VALUES($1, $2, $3, $4) ON CONFLICT DO NOTHING
-
 --name: insert-token
 -- $1: contract_address
 -- $2: token_name
@@ -134,16 +122,8 @@ INSERT INTO tokens(
 -- $1: contract_address
 -- $2: pool_name
 -- $3: pool_symbol
-INSERT INTO pools(
+INSERT INTO tokens(
 	contract_address,
     pool_name,
     pool_symbol
 ) VALUES ($1, $2, $3) ON CONFLICT DO NOTHING
-
---name: remove-pool
--- $1: contract_address
-UPDATE pools SET removed = true WHERE contract_address = $1
-
---name: remove-token
--- $1: contract_address
-UPDATE tokens SET removed = true WHERE contract_address = $1