Added version route and version command line argument

indexer/context/context.go

@@ -16,6 +16,8 @@ type IndexerContext interface {
 }
 
 type IndexerFlags struct {
+	Version bool
+
 	ConfigFileName string
 
 	// Set start epoch for voting cronjob to this value, overrides config and database value,
@@ -33,8 +35,7 @@ type indexerContext struct {
 	flags  *IndexerFlags
 }
 
-func BuildContext() (IndexerContext, error) {
-	flags := parseIndexerFlags()
+func BuildContext(flags *IndexerFlags) (IndexerContext, error) {
 	cfg, err := config.BuildConfig(flags.ConfigFileName)
 	if err != nil {
 		return nil, err
@@ -59,13 +60,15 @@ func (c *indexerContext) DB() *gorm.DB { return c.db }
 
 func (c *indexerContext) Flags() *IndexerFlags { return c.flags }
 
-func parseIndexerFlags() *IndexerFlags {
+func ParseIndexerFlags() *IndexerFlags {
 	cfgFlag := flag.String("config", globalConfig.CONFIG_FILE, "Configuration file (toml format)")
+	versionFlag := flag.Bool("version", false, "Print version information and exit")
 	resetVotingFlag := flag.Int64("reset-voting", 0, "Set start epoch for voting cronjob to this value, overrides config and database value, valid values are > 0")
 	resetMirrorFlag := flag.Int64("reset-mirroring", 0, "Set start epoch for mirroring cronjob to this value, overrides config and database value, valid values are > 0")
 	flag.Parse()
 
 	return &IndexerFlags{
+		Version:            *versionFlag,
 		ConfigFileName:     *cfgFlag,
 		ResetVotingCronjob: *resetVotingFlag,
 		ResetMirrorCronjob: *resetMirrorFlag,

indexer/main/indexer.go

@@ -13,7 +13,14 @@ import (
 )
 
 func main() {
-	ctx, err := context.BuildContext()
+	flags := context.ParseIndexerFlags()
+
+	if flags.Version {
+		fmt.Printf("Flare P-chain indexer version %s\n", shared.ApplicationVersion)
+		return
+	}
+
+	ctx, err := context.BuildContext(flags)
 	if err != nil {
 		fmt.Printf("%v\n", err)
 		return

indexer/shared/constants.go

@@ -0,0 +1,5 @@
+package shared
+
+const (
+	ApplicationVersion = "2.0.0"
+)

indexer/shared/metrics.go

@@ -51,6 +51,7 @@ func InitMetricsServer(cfg *config.MetricsConfig) {
 
 	r.Path("/metrics").Handler(promhttp.Handler())
 	r.Path("/health").HandlerFunc(healthHandler)
+	r.Path("/version").HandlerFunc(versionHandler)
 
 	srv := &http.Server{
 		Addr:    cfg.PrometheusAddress,
@@ -70,6 +71,14 @@ func healthHandler(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
+func versionHandler(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "text/plain")
+	_, err := w.Write([]byte(ApplicationVersion))
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+	}
+}
+
 func writeHealthResponse(w http.ResponseWriter) (err error) {
 	ok, err := getHealthStatus()
 	if err != nil {