feat: add support of the feemodel params.

README.md

@@ -49,7 +49,7 @@ This will:
 
 2. Build and start
 ```bash
-docker-compose up
+docker-compose build && docker-compose up
 ```
 
 * Open [hasura UI](http://localhost:8080/console) and check that it works correctly.

cmd/parse/gov/proposal.go

@@ -40,7 +40,7 @@ func proposalCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
 			db := database.Cast(parseCtx.Database)
 
 			// Build the gov module
-			govModule := gov.NewModule(sources.GovSource, nil, nil, nil, nil, nil, parseCtx.EncodingConfig.Marshaler, db)
+			govModule := gov.NewModule(sources.GovSource, nil, nil, nil, nil, nil, nil, parseCtx.EncodingConfig.Marshaler, db)
 
 			err = refreshProposalDetails(parseCtx, proposalID, govModule)
 			if err != nil {

config-sample.yaml

@@ -12,6 +12,7 @@ chain:
         - staking
         - distribution
         - actions
+        - feemodel
 node:
     type: remote
     config:

database/feemodel_params.go

@@ -0,0 +1,58 @@
+package database
+
+import (
+	"encoding/json"
+	"fmt"
+
+	feemodeltypes "github.com/CoreumFoundation/coreum/x/feemodel/types"
+	dbtypes "github.com/forbole/bdjuno/v3/database/types"
+	"github.com/forbole/bdjuno/v3/types"
+)
+
+// SaveFeeModelParams allows to store the given params into the database.
+func (db *Db) SaveFeeModelParams(params types.FeeModelParams) error {
+	paramsBz, err := json.Marshal(&params.Params)
+	if err != nil {
+		return fmt.Errorf("error while marshaling feemodel params: %s", err)
+	}
+
+	stmt := `
+INSERT INTO feemodel_params (params, height) 
+VALUES ($1, $2)
+ON CONFLICT (one_row_id) DO UPDATE 
+    SET params = excluded.params,
+        height = excluded.height
+WHERE feemodel_params.height <= excluded.height`
+
+	_, err = db.Sql.Exec(stmt, string(paramsBz), params.Height)
+	if err != nil {
+		return fmt.Errorf("error while storing feemodel params: %s", err)
+	}
+
+	return nil
+}
+
+// GetFeeModelParams returns the types.FeeModelParams instance containing the current params
+func (db *Db) GetFeeModelParams() (*types.FeeModelParams, error) {
+	var rows []dbtypes.FeeModelParamsRow
+	stmt := `SELECT * FROM feemodel_params LIMIT 1`
+	err := db.Sqlx.Select(&rows, stmt)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(rows) == 0 {
+		return nil, fmt.Errorf("no feemodel params found")
+	}
+
+	var feemodelParams feemodeltypes.Params
+	err = json.Unmarshal([]byte(rows[0].Params), &feemodelParams)
+	if err != nil {
+		return nil, err
+	}
+
+	return &types.FeeModelParams{
+		Params: feemodelParams,
+		Height: rows[0].Height,
+	}, nil
+}

database/feemodel_params_test.go

@@ -0,0 +1,47 @@
+package database_test
+
+import (
+	"encoding/json"
+
+	feemodeltypes "github.com/CoreumFoundation/coreum/x/feemodel/types"
+	dbtypes "github.com/forbole/bdjuno/v3/database/types"
+	"github.com/forbole/bdjuno/v3/types"
+)
+
+func (suite *DbTestSuite) TestSaveFeeModelParams() {
+	feemodelParams := feemodeltypes.DefaultParams()
+	err := suite.database.SaveFeeModelParams(types.NewFeeModelParams(feemodelParams, 10))
+	suite.Require().NoError(err)
+
+	var rows []dbtypes.FeeModelParamsRow
+	err = suite.database.Sqlx.Select(&rows, `SELECT * FROM feemodel_params`)
+	suite.Require().NoError(err)
+
+	suite.Require().Len(rows, 1)
+
+	var stored feemodeltypes.Params
+	err = json.Unmarshal([]byte(rows[0].Params), &stored)
+	suite.Require().NoError(err)
+	suite.Require().Equal(feemodelParams, stored)
+}
+
+func (suite *DbTestSuite) TestGetFeeModelParams() {
+	feemodelParams := feemodeltypes.DefaultParams()
+
+	paramsBz, err := json.Marshal(&feemodelParams)
+	suite.Require().NoError(err)
+
+	_, err = suite.database.Sql.Exec(
+		`INSERT INTO feemodel_params (params, height) VALUES ($1, $2)`,
+		string(paramsBz), 10,
+	)
+	suite.Require().NoError(err)
+
+	params, err := suite.database.GetFeeModelParams()
+	suite.Require().NoError(err)
+
+	suite.Require().Equal(&types.FeeModelParams{
+		Params: feemodelParams,
+		Height: 10,
+	}, params)
+}

database/schema/12-feemodel.sql

@@ -0,0 +1,10 @@
+/* ---- PARAMS ---- */
+
+CREATE TABLE feemodel_params
+(
+    one_row_id BOOLEAN NOT NULL DEFAULT TRUE PRIMARY KEY,
+    params     JSONB   NOT NULL,
+    height     BIGINT  NOT NULL,
+    CHECK (one_row_id)
+);
+CREATE INDEX feemodel_params_height_index ON feemodel_params (height);

database/types/feemodel_params.go

@@ -0,0 +1,8 @@
+package types
+
+// FeeModelParamsRow represents a single row inside the feemodel_params table
+type FeeModelParamsRow struct {
+	OneRowID bool   `db:"one_row_id"`
+	Params   string `db:"params"`
+	Height   int64  `db:"height"`
+}

go.mod

@@ -3,7 +3,7 @@ module github.com/forbole/bdjuno/v3
 go 1.18
 
 require (
-	github.com/CoreumFoundation/coreum v0.0.1-dev
+	github.com/CoreumFoundation/coreum v0.0.1-dev-1.0.20221221080541-af88eb7eecde
 	github.com/cosmos/cosmos-sdk v0.45.9
 	github.com/forbole/juno/v3 v3.4.1-0.20220912104021-a2cfbab251bc
 	github.com/go-co-op/gocron v1.13.0
@@ -58,6 +58,7 @@ require (
 	github.com/dvsekhvalnov/jose2go v1.5.0 // indirect
 	github.com/felixge/httpsnoop v1.0.2 // indirect
 	github.com/fsnotify/fsnotify v1.5.4 // indirect
+	github.com/gin-gonic/gin v1.7.0 // indirect
 	github.com/go-kit/kit v0.12.0 // indirect
 	github.com/go-kit/log v0.2.1 // indirect
 	github.com/go-logfmt/logfmt v0.5.1 // indirect
@@ -120,9 +121,7 @@ require (
 	github.com/syndtr/goleveldb v1.0.1-0.20210819022825-2ae1ddf74ef7 // indirect
 	github.com/tendermint/btcd v0.1.1 // indirect
 	github.com/tendermint/crypto v0.0.0-20191022145703-50d29ede1e15 // indirect
-	github.com/tendermint/fundraising v0.3.0 // indirect
 	github.com/tendermint/go-amino v0.16.0 // indirect
-	github.com/tendermint/spn v0.2.1-0.20220610090138-44b136f042c4 // indirect
 	github.com/tendermint/tm-db v0.6.7 // indirect
 	github.com/zondax/hid v0.9.0 // indirect
 	go.etcd.io/bbolt v1.3.6 // indirect