feat: Sync bank and staking features to mainnet

.github/workflows/release.yml

@@ -4,9 +4,6 @@ on:
 defaults:
   run:
     shell: bash
-permissions:
-  contents: write
-  packages: write
 
 
 jobs:

README.md

@@ -3,28 +3,36 @@
 BDJuno (shorthand for BigDipper Juno) is the [Juno](https://github.com/forbole/juno) implementation
 for [BigDipper](https://github.com/forbole/big-dipper).
 
-It extends the custom Juno behavior by adding different handlers and custom operations to make it easier for BigDipper
-showing the data inside the UI.
-
 All the chains' data that are queried from the RPC and gRPC endpoints are stored inside
 a [PostgreSQL](https://www.postgresql.org/) database on top of which [GraphQL](https://graphql.org/) APIs can then be
 created using [Hasura](https://hasura.io/).
 
-## Usage
+## Features specific to cheqd
+
+1. Indexing for [cheqd network] DIDs and Resources
+2. Changes to workflows/pipelines
+3. Optimised Dockerfile
+
+## Developer guide
+
+This section is reproduced as-is from upstream project.
+
+### Usage
+
 To know how to setup and run BDJuno, please refer to
 the [docs website](https://docs.bigdipper.live/cosmos-based/parser/overview/).
 
 ## Testing
+
 If you want to test the code, you can do so by running
 
 ```shell
-$ make test-unit
+make test-unit
 ```
 
 **Note**: Requires [Docker](https://docker.com).
 
 This will:
+
 1. Create a Docker container running a PostgreSQL database.
 2. Run all the tests using that database as support.
-
-

cmd/parse/bank/cmd.go

@@ -0,0 +1,20 @@
+package bank
+
+import (
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/spf13/cobra"
+)
+
+// NewBankCmd returns the Cobra command allowing to fix various things related to the x/bank module
+func NewBankCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "bank",
+		Short: "Fix things related to the x/bank module",
+	}
+
+	cmd.AddCommand(
+		supplyCmd(parseConfig),
+	)
+
+	return cmd
+}

cmd/parse/bank/supply.go

@@ -0,0 +1,46 @@
+package bank
+
+import (
+	"fmt"
+
+	modulestypes "github.com/forbole/bdjuno/v3/modules/types"
+
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/forbole/juno/v3/types/config"
+	"github.com/spf13/cobra"
+
+	"github.com/forbole/bdjuno/v3/database"
+	"github.com/forbole/bdjuno/v3/modules/bank"
+)
+
+// supplyCmd returns the Cobra command allowing to refresh x/bank total supply
+func supplyCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	return &cobra.Command{
+		Use:   "supply",
+		Short: "Refresh total supply",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			parseCtx, err := parsecmdtypes.GetParserContext(config.Cfg, parseConfig)
+			if err != nil {
+				return err
+			}
+
+			sources, err := modulestypes.BuildSources(config.Cfg.Node, parseCtx.EncodingConfig)
+			if err != nil {
+				return err
+			}
+
+			// Get the database
+			db := database.Cast(parseCtx.Database)
+
+			// Build bank module
+			bankModule := bank.NewModule(nil, sources.BankSource, parseCtx.EncodingConfig.Marshaler, db)
+
+			err = bankModule.UpdateSupply()
+			if err != nil {
+				return fmt.Errorf("error while getting latest bank supply: %s", err)
+			}
+
+			return nil
+		},
+	}
+}

cmd/parse/distribution/cmd.go

@@ -0,0 +1,20 @@
+package distribution
+
+import (
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/spf13/cobra"
+)
+
+// NewDistributionCmd returns the Cobra command allowing to fix various things related to the x/distribution module
+func NewDistributionCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "distribution",
+		Short: "Fix things related to the x/distribution module",
+	}
+
+	cmd.AddCommand(
+		communityPoolCmd(parseConfig),
+	)
+
+	return cmd
+}

cmd/parse/distribution/communitypool.go

@@ -0,0 +1,45 @@
+package distribution
+
+import (
+	"fmt"
+
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/forbole/juno/v3/types/config"
+	"github.com/spf13/cobra"
+
+	"github.com/forbole/bdjuno/v3/database"
+	"github.com/forbole/bdjuno/v3/modules/distribution"
+	modulestypes "github.com/forbole/bdjuno/v3/modules/types"
+)
+
+// communityPoolCmd returns the Cobra command allowing to refresh community pool
+func communityPoolCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	return &cobra.Command{
+		Use:   "community-pool",
+		Short: "Refresh community pool",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			parseCtx, err := parsecmdtypes.GetParserContext(config.Cfg, parseConfig)
+			if err != nil {
+				return err
+			}
+
+			sources, err := modulestypes.BuildSources(config.Cfg.Node, parseCtx.EncodingConfig)
+			if err != nil {
+				return err
+			}
+
+			// Get the database
+			db := database.Cast(parseCtx.Database)
+
+			// Build distribution module
+			distrModule := distribution.NewModule(sources.DistrSource, parseCtx.EncodingConfig.Marshaler, db)
+
+			err = distrModule.GetLatestCommunityPool()
+			if err != nil {
+				return fmt.Errorf("error while updating community pool: %s", err)
+			}
+
+			return nil
+		},
+	}
+}

cmd/parse/gov/proposal.go

@@ -4,6 +4,7 @@ import (
 	"encoding/hex"
 	"fmt"
 	"strconv"
+	"time"
 
 	modulestypes "github.com/forbole/bdjuno/v3/modules/types"
 	"github.com/rs/zerolog/log"
@@ -78,7 +79,7 @@ func proposalCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
 				return fmt.Errorf("error while getting chain latest block height: %s", err)
 			}
 
-			err = govModule.UpdateProposal(height, proposalID)
+			err = govModule.UpdateProposal(height, time.Now(), proposalID)
 			if err != nil {
 				return err
 			}

cmd/parse/mint/cmd.go

@@ -0,0 +1,20 @@
+package mint
+
+import (
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/spf13/cobra"
+)
+
+// NewMintCmd returns the Cobra command allowing to fix various things related to the x/mint module
+func NewMintCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "mint",
+		Short: "Fix things related to the x/mint module",
+	}
+
+	cmd.AddCommand(
+		inflationCmd(parseConfig),
+	)
+
+	return cmd
+}

cmd/parse/mint/inflation.go

@@ -0,0 +1,45 @@
+package mint
+
+import (
+	"fmt"
+
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/forbole/juno/v3/types/config"
+	"github.com/spf13/cobra"
+
+	"github.com/forbole/bdjuno/v3/database"
+	"github.com/forbole/bdjuno/v3/modules/mint"
+	modulestypes "github.com/forbole/bdjuno/v3/modules/types"
+)
+
+// inflationCmd returns the Cobra command allowing to refresh x/mint inflation
+func inflationCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	return &cobra.Command{
+		Use:   "inflation",
+		Short: "Refresh inflation",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			parseCtx, err := parsecmdtypes.GetParserContext(config.Cfg, parseConfig)
+			if err != nil {
+				return err
+			}
+
+			sources, err := modulestypes.BuildSources(config.Cfg.Node, parseCtx.EncodingConfig)
+			if err != nil {
+				return err
+			}
+
+			// Get the database
+			db := database.Cast(parseCtx.Database)
+
+			// Build mint module
+			mintModule := mint.NewModule(sources.MintSource, parseCtx.EncodingConfig.Marshaler, db)
+
+			err = mintModule.UpdateInflation()
+			if err != nil {
+				return fmt.Errorf("error while updating inflation: %s", err)
+			}
+
+			return nil
+		},
+	}
+}

cmd/parse/parse.go

@@ -9,8 +9,12 @@ import (
 	parsegenesis "github.com/forbole/juno/v3/cmd/parse/genesis"
 
 	parseauth "github.com/forbole/bdjuno/v3/cmd/parse/auth"
+	parsebank "github.com/forbole/bdjuno/v3/cmd/parse/bank"
+	parsedistribution "github.com/forbole/bdjuno/v3/cmd/parse/distribution"
 	parsefeegrant "github.com/forbole/bdjuno/v3/cmd/parse/feegrant"
 	parsegov "github.com/forbole/bdjuno/v3/cmd/parse/gov"
+	parsemint "github.com/forbole/bdjuno/v3/cmd/parse/mint"
+	parsepricefeed "github.com/forbole/bdjuno/v3/cmd/parse/pricefeed"
 	parsestaking "github.com/forbole/bdjuno/v3/cmd/parse/staking"
 	parsetransaction "github.com/forbole/juno/v3/cmd/parse/transactions"
 )
@@ -25,10 +29,14 @@ func NewParseCmd(parseCfg *parse.Config) *cobra.Command {
 
 	cmd.AddCommand(
 		parseauth.NewAuthCmd(parseCfg),
+		parsebank.NewBankCmd(parseCfg),
 		parseblocks.NewBlocksCmd(parseCfg),
+		parsedistribution.NewDistributionCmd(parseCfg),
 		parsefeegrant.NewFeegrantCmd(parseCfg),
 		parsegenesis.NewGenesisCmd(parseCfg),
 		parsegov.NewGovCmd(parseCfg),
+		parsemint.NewMintCmd(parseCfg),
+		parsepricefeed.NewPricefeedCmd(parseCfg),
 		parsestaking.NewStakingCmd(parseCfg),
 		parsetransaction.NewTransactionsCmd(parseCfg),
 	)

cmd/parse/pricefeed/cmd.go

@@ -0,0 +1,21 @@
+package pricefeed
+
+import (
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/spf13/cobra"
+)
+
+// NewPricefeedCmd returns the Cobra command allowing to refresh pricefeed
+func NewPricefeedCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "pricefeed",
+		Short: "Fix things related to the pricefeed module",
+	}
+
+	cmd.AddCommand(
+		priceCmd(parseConfig),
+		priceHistoryCmd(parseConfig),
+	)
+
+	return cmd
+}

cmd/parse/pricefeed/price.go

@@ -0,0 +1,44 @@
+package pricefeed
+
+import (
+	"fmt"
+
+	parsecmdtypes "github.com/forbole/juno/v3/cmd/parse/types"
+	"github.com/forbole/juno/v3/types/config"
+	"github.com/spf13/cobra"
+
+	"github.com/forbole/bdjuno/v3/database"
+	"github.com/forbole/bdjuno/v3/modules/pricefeed"
+)
+
+// priceCmd returns the Cobra command allowing to refresh token price
+func priceCmd(parseConfig *parsecmdtypes.Config) *cobra.Command {
+	return &cobra.Command{
+		Use:   "price",
+		Short: "Refresh token price",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			parseCtx, err := parsecmdtypes.GetParserContext(config.Cfg, parseConfig)
+			if err != nil {
+				return err
+			}
+
+			// Get the database
+			db := database.Cast(parseCtx.Database)
+
+			// Build pricefeed module
+			pricefeedModule := pricefeed.NewModule(config.Cfg, parseCtx.EncodingConfig.Marshaler, db)
+
+			err = pricefeedModule.RunAdditionalOperations()
+			if err != nil {
+				return fmt.Errorf("error while storing tokens: %s", err)
+			}
+
+			err = pricefeedModule.UpdatePrice()
+			if err != nil {
+				return fmt.Errorf("error while updating price: %s", err)
+			}
+
+			return nil
+		},
+	}
+}