v0.7.2

.github/workflows/govulncheck.yml

@@ -20,7 +20,7 @@ jobs:
       - name: Setup Go
         uses: actions/setup-go@4a3601121dd01d1626a1e23e37211e3254c1c06c # v6.4
         with:
-          go-version: "1.25.11"
+          go-version: "1.26.4"
 
       - name: Setup Go Vulncheck
         run: go install golang.org/x/vuln/cmd/govulncheck@latest

.gitignore

@@ -53,4 +53,4 @@ server.key
 
 # Docker
 .dockerignore
-docker-compose-local.yml
+docker-compose-local.yml

CHANGELOG.md

@@ -4,6 +4,52 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.1.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
+## [0.7.2] - 2026-06-30
+
+This version does include some minor fixes, some caused by the overall change of the database schema.
+There were multiple refactors which should improve the maintainability and readability of the codebase.
+
+### Added
+
+- Feat(indexer): add option to accept log level as a flag in the cli [7c295e2](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/7c295e276a6d10f7f0ca6af5a35041721089debe)
+- Feat: add initial support for the ssl to postgres [395d536](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/395d5361d5c52bde384fa31ce0afd05574970690)
+
+### Changes
+
+- Chore: small text corrections [dae2116](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/dae211697cc5f588644a02829d4c4c71060f3073)
+- Refac(indexer/orchestrator): historic run awaits the context now [72fad55](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/72fad55adc9c16173f5745fa5c5417e49e2e717e)
+- Deps: update chi and gnark-crypto [6088cec](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/6088ceccde2f489828c47fcf6fbb4f3f4474b93f)
+- Refac(indexer/schema):adjust aggregate tables similarly to db tables [5c48476](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/5c484764f2138c4c125fb4e3c823f84dcb12c7eb)
+- Chore(data_processor): remove dead code [f55e7ce](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/f55e7ce535e2dbb54e4f76291f883cb85d20926f)
+- Refac(schema&cli): move setup logic closer to schema [35324dd](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/35324dddf59968cc0e766b35ee0cc6997fce37a9)
+- Refac(pkgs/schema): add data type assertion and reflaction testing [21b01eb](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/21b01eb9a72756721fd010cc464ed79c37f90f42)
+- Refac(indexer/decoder): add registry based system [d998fd1](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/d998fd12990cc1472e1dd88b8598d6f4bff768ff)
+- Refac: use message interface for data grouping [ecafb9e](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/ecafb9e61927e09064d83cc8cd622e05326f051f)
+- Refac(pkgs/schema): add generics for inserting data [eca95f9](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/eca95f9d419977a79121c35b7523d4b080b9473e)
+- Refac(pkgs/schema): move the copy the row logic closer to the schemas [cd43e3b](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/cd43e3bbe2ca566b2a5a40b4116c35758af16918)
+- Refac(pkgs): rename sql_data_types to schema [8874feb](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/8874feb9ee8face4188a19deafbf8bada2feef36)
+- Docs: update grammer and add quick start section [46f9d0b](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/46f9d0b79b42dd64da847d008e64ce00e9165144)
+- Change(api): add function that will provide a mean block prod value [5531175](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/553117588e78686056b23633a7719862a042c8dc)
+
+### Fixed
+
+- Fix(indexer/dp): return errors if processing message fails [2426e89](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/2426e89195563f95c71240ad25c9fe68b09abd84)
+- Fix(indexer): a bug where the database pool closes before the ingestion [076f3f5](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/076f3f5f2417085cfd5266de54e1da5924f72372)
+- Fix(indexer/cli): add missing tables for adding privilages to the user [74be438](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/74be438702ec7197b3d7be7c0dabe6e45ac60b76)
+- Fix(ci): revert the go version for govulncheck [13ba5fc](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/13ba5fc2e0403c767c3a41e1eeab864e2d111099)
+- Fix(api): fix empty volume response [3011c77](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/3011c7747e814545701f5134442a1ff7d3522f70)
+
+### Tests and Code Check
+
+- Audit(coderabbit): add additional error handle for query block prod [814b575](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/814b575a33ee5e9db689e311ccef7b2a140e2546)
+- Audit(coderabbit): add buildDSN for database connection [dc810b4](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/dc810b41d6061cd74cada3771c4c787979d5ba0b)
+- Audit(sonarqube): adjust code to use variable instead of typed in params [747da47](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/747da477ff6481ebd020d7eafe0af9cefa60eebd)
+- Audit(sonarqube): drop complexity for some api handler function [f29123c](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/f29123c1ceddc03462a6ae59817bc08233725458)
+- Audit(sonarqube): reduce complexity of copyraw test [62070b5](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/62070b5c06fd98882e2888d93a10ce1ed29921f7)
+- Audit(sonarqube): drop complexity of aggregation table test [b7b03c0](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/b7b03c05854ab34a5d2a8afeceafa8b7e47e5f63)
+- Test(pkgs/schema): add validation for aggregate tables [bf55820](https://github.com/Cogwheel-Validator/spectra-gnoland-indexer/commit/bf55820063fa9ae7b38d05359855859bb7879495)
+
 ## [0.7.1] - 2026-06-24
 
 This version should add support to process new Gnoland testnet 13. Added support for Auth message

Makefile

@@ -71,3 +71,17 @@ train-zstd:
 	@read -p "Enter the amount of events to collect (default: 10000): " amount; \
 	amount=$${amount:-10000}; \
 	go run compression/cmd/main.go --config training-config.yml --amount $$amount --chain-name gnoland --dict-path ./pkgs/dict_loader/events.zstd.bin
+
+########################################################
+# Add changes to the CHANGELOG.md
+########################################################
+
+.PHONY: changelog
+changelog:
+	@echo "Adding changes to the CHANGELOG.md"
+	@read -p "Enter new git tag that the changes are associated with: " tag; \
+	new_tag=$${tag}; \
+	last_tag=$$(git describe --tags --abbrev=0 --match "v*" | tail -n 1); \
+	last_tag+="..HEAD"; \
+	git cliff $$last_tag --tag $$new_tag --prepend CHANGELOG.md
+	@echo "Changes added to CHANGELOG.md"

README.md

@@ -21,6 +21,7 @@ not the best choice. And finally the nodes are not the best when it comes to sto
 ## Table of content
 
 - [Table of content](#table-of-content)
+- [Quick Start](#quick-start)
 - [The solution](#the-solution)
 - [Why TimescaleDB? And can it work on other SQL databases?](#why-timescaledb-and-can-it-work-on-other-sql-databases)
 - [How does the indexer work?](#how-does-the-indexer-work)
@@ -34,6 +35,78 @@ not the best choice. And finally the nodes are not the best when it comes to sto
   - [🐞 Cons](#-cons)
 - [In depth documentation](#in-depth-documentation)
 
+## Quick Start
+
+The fastest way to get the indexer running is with Docker Compose for the database and a local binary for setup and ingestion.
+
+**Prerequisites:** Go 1.26+ and Docker with Docker Compose.
+
+### 1. Clone and build
+
+```bash
+git clone https://github.com/Cogwheel-Validator/spectra-gnoland-indexer.git
+cd spectra-gnoland-indexer
+make build-indexer
+```
+
+### 2. Configure
+
+```bash
+cp config.yml.example config.yml
+```
+
+Open `config.yml` and set the `rpc` field to your Gnoland node RPC endpoint (e.g. `https://gnoland-testnet-rpc.cogwheel.zone`). Make sure `chain_name` matches the name you want to use for the database.
+
+### 3. Start the database
+
+```bash
+docker compose up -d timescaledb
+```
+
+This starts a TimescaleDB instance on port 5432 with the default password `12345678`. Change the password in `docker-compose.yml` for any non-local deployment.
+
+### 4. Initialize the database
+
+```bash
+./build/indexer setup create-db \
+  --db-host localhost --db-port 5432 \
+  --db-user postgres --db-name postgres \
+  --ssl-mode disable --new-db-name gnoland --chain-name gnoland
+```
+
+When prompted, enter the postgres password. This creates the schema and all necessary tables.
+
+Optionally create a dedicated writer user:
+
+```bash
+./build/indexer setup create-user writer \
+  --db-host localhost --db-port 5432 \
+  --db-user postgres --db-name postgres \
+  --ssl-mode disable --privilege writer
+```
+
+### 5. Run the indexer
+
+**Historic mode** — index a specific block range (useful for initial sync):
+
+```bash
+./build/indexer run historic --config config.yml --from-height 1 --to-height 50000
+```
+
+**Live mode** — follow the chain tip in real time after historic sync is done:
+
+```bash
+./build/indexer run live --config config.yml
+```
+
+If you want to start from the current chain tip without syncing history, add `--skip-db-check`:
+
+```bash
+./build/indexer run live --config config.yml --skip-db-check
+```
+
+For production deployment, systemd service examples, Docker usage, and configuration details see [docs/setup.md](docs/setup.md).
+
 ## The solution
 
 The data in the blockchain is mostly tied to blocks, however when any kind of analytics is needed we need some

api/config/types.go

@@ -33,6 +33,9 @@ type ApiEnv struct {
 	ApiDbPassword                  string        `env:"API_DB_PASSWORD" envDefault:"12345678"`
 	ApiDbName                      string        `env:"API_DB_NAME" envDefault:"gnoland"`
 	ApiDbSslmode                   string        `env:"API_DB_SSLMODE" envDefault:"disable"`
+	ApiDbSslRootCert               string        `env:"API_DB_SSLROOTCERT" envDefault:""`
+	ApiDbSslCert                   string        `env:"API_DB_SSLCERT" envDefault:""`
+	ApiDbSslKey                    string        `env:"API_DB_SSLKEY" envDefault:""`
 	ApiDbPoolMaxConns              int           `env:"API_DB_POOL_MAX_CONNS" envDefault:"50"`
 	ApiDbPoolMinConns              int           `env:"API_DB_POOL_MIN_CONNS" envDefault:"10"`
 	ApiDbPoolMaxConnLifetime       time.Duration `env:"API_DB_POOL_MAX_CONN_LIFETIME" envDefault:"10m"`

api/handlers/address.go

@@ -56,17 +56,11 @@ func (h *AddressHandler) GetAddressTxs(
 	ctx context.Context,
 	input *humatypes.AddressGetInput,
 ) (*humatypes.AddressGetOutput, error) {
-	var fromTs, toTs *time.Time
-	if !input.FromTimestamp.IsZero() {
-		fromTs = &input.FromTimestamp
-	}
-	if !input.ToTimestamp.IsZero() {
-		toTs = &input.ToTimestamp
-	}
-	if (fromTs == nil) != (toTs == nil) {
-		return nil, badRequest("from_timestamp and to_timestamp must both be set or both be unset")
+	fromTs, toTs, err := parseTimestampPair(input.FromTimestamp, input.ToTimestamp)
+	if err != nil {
+		return nil, err
 	}
-	timestampMode := fromTs != nil && toTs != nil
+	timestampMode := fromTs != nil
 
 	var limit *uint64
 	if input.Limit != 0 {
@@ -91,57 +85,70 @@ func (h *AddressHandler) GetAddressTxs(
 	}
 
 	addressTxs, hasMore, err := h.db.GetAddressTxs(
-		ctx,
-		input.Address,
-		h.chainName,
-		fromTs,
-		toTs,
-		limit,
-		cursor,
-		direction,
+		ctx, input.Address, h.chainName, fromTs, toTs, limit, cursor, direction,
 	)
 	if err != nil {
 		return nil, mapDbError("GetAddressTxs", "address not found", err)
 	}
 
-	body := humatypes.AddressTxsBody{
-		AddressTxs: *addressTxs,
+	body, err := buildAddressTxsBody(*addressTxs, hasMore, direction, cursor)
+	if err != nil {
+		return nil, err
 	}
+	return &humatypes.AddressGetOutput{Body: body}, nil
+}
 
-	if len(*addressTxs) > 0 {
-		rows := *addressTxs
-		newest := rows[0]
-		oldest := rows[len(rows)-1]
-		newestCur, err := makeTxCursor(newest.BlockHeight, newest.Hash)
-		if err != nil {
-			return nil, internalError("GetAddressTxs.makeTxCursor", err)
-		}
-		oldestCur, err := makeTxCursor(oldest.BlockHeight, oldest.Hash)
-		if err != nil {
-			return nil, internalError("GetAddressTxs.makeTxCursor", err)
-		}
+func parseTimestampPair(from, to time.Time) (*time.Time, *time.Time, error) {
+	var fromPtr, toPtr *time.Time
+	if !from.IsZero() {
+		fromPtr = &from
+	}
+	if !to.IsZero() {
+		toPtr = &to
+	}
+	if (fromPtr == nil) != (toPtr == nil) {
+		return nil, nil, badRequest("from_timestamp and to_timestamp must both be set or both be unset")
+	}
+	return fromPtr, toPtr, nil
+}
 
-		switch direction {
-		case database.Next:
-			body.HasNext = hasMore
-			if hasMore {
-				body.NextCursor = &oldestCur
-			}
-			if cursor != nil {
-				body.HasPrev = true
-				body.PrevCursor = &newestCur
-			}
-		case database.Prev:
-			body.HasPrev = hasMore
-			if hasMore {
-				body.PrevCursor = &newestCur
-			}
-			body.HasNext = true
+func buildAddressTxsBody(
+	rows []database.AddressTx,
+	hasMore bool,
+	direction database.Direction,
+	cursor *string,
+) (humatypes.AddressTxsBody, error) {
+	body := humatypes.AddressTxsBody{AddressTxs: rows}
+	if len(rows) == 0 {
+		return body, nil
+	}
+
+	newestCur, err := makeTxCursor(rows[0].BlockHeight, rows[0].Hash)
+	if err != nil {
+		return body, internalError("GetAddressTxs.makeTxCursor", err)
+	}
+	oldestCur, err := makeTxCursor(rows[len(rows)-1].BlockHeight, rows[len(rows)-1].Hash)
+	if err != nil {
+		return body, internalError("GetAddressTxs.makeTxCursor", err)
+	}
+
+	switch direction {
+	case database.Next:
+		body.HasNext = hasMore
+		if hasMore {
 			body.NextCursor = &oldestCur
 		}
+		if cursor != nil {
+			body.HasPrev = true
+			body.PrevCursor = &newestCur
+		}
+	case database.Prev:
+		body.HasPrev = hasMore
+		if hasMore {
+			body.PrevCursor = &newestCur
+		}
+		body.HasNext = true
+		body.NextCursor = &oldestCur
 	}
-
-	return &humatypes.AddressGetOutput{
-		Body: body,
-	}, nil
+	return body, nil
 }