operator_info.go

package targets

import (
	"cosmos-validator-mission-control/config"
	"encoding/json"
	"log"
	"strconv"

	client "github.com/influxdata/influxdb1-client/v2"
)

// GetOperatorInfo to get validator information
func GetOperatorInfo(ops HTTPOptions, cfg *config.Config, c client.Client) {
	bp, err := createBatchPoints(cfg.InfluxDB.Database)
	if err != nil {
		return
	}
	var pts []*client.Point

	resp, err := HitHTTPTarget(ops)
	if err != nil {
		log.Printf("Error: %v", err)
		return
	}

	var validatorResp ValidatorResp
	err = json.Unmarshal(resp.Body, &validatorResp)
	if err != nil {
		log.Printf("Error: %v", err)
		return
	}

	var p0 *client.Point
	validatorStatus := validatorResp.Validator.Jailed
	if !validatorStatus {
		p0, err = createDataPoint("vcf_validator_status", map[string]string{}, map[string]interface{}{"status": 1})
	} else {
		p0, err = createDataPoint("vcf_validator_status", map[string]string{}, map[string]interface{}{"status": 0})
	}
	if err == nil {
		pts = append(pts, p0)
	}

	operatorAddress := validatorResp.Validator.OperatorAddress
	p1, err := createDataPoint("vcf_operator_address", map[string]string{}, map[string]interface{}{"address": operatorAddress})
	if err == nil {
		pts = append(pts, p1)
	}

	address := cfg.AccountAddress
	p2, err := createDataPoint("vcf_address", map[string]string{}, map[string]interface{}{"address": address})
	if err == nil {
		pts = append(pts, p2)
	}

	var fee float64
	f, err := strconv.ParseFloat(validatorResp.Validator.Commission.CommissionRates.Rate, 64)
	if err != nil {
		fee = 0
	} else {
		fee = f * 100
	}
	p3, err := createDataPoint("vcf_validator_fee", map[string]string{}, map[string]interface{}{"rate": fee})
	if err == nil {
		pts = append(pts, p3)
	}

	validatorDetails := validatorResp.Validator.Description
	p4, err := createDataPoint("vcf_validator_desc", map[string]string{"tag": "moniker"}, map[string]interface{}{"val": validatorDetails.Moniker})
	if err == nil {
		pts = append(pts, p4)
	}
	p7, err := createDataPoint("vcf_validator_desc", map[string]string{"tag": "website"}, map[string]interface{}{"val": validatorDetails.Website})
	if err == nil {
		pts = append(pts, p7)
	}
	p8, err := createDataPoint("vcf_validator_desc", map[string]string{"tag": "details"}, map[string]interface{}{"val": validatorDetails.Details})
	if err == nil {
		pts = append(pts, p8)
	}
	p9, err := createDataPoint("vcf_validator_desc", map[string]string{"tag": "identity"}, map[string]interface{}{"val": validatorDetails.Identity})
	if err == nil {
		pts = append(pts, p9)
	}

	var maxRate float64
	mr, err := strconv.ParseFloat(validatorResp.Validator.Commission.CommissionRates.MaxRate, 64)
	if err != nil {
		maxRate = 0
	} else {
		maxRate = mr * 100
	}
	p5, err := createDataPoint("vcf_validator_max_rate", map[string]string{}, map[string]interface{}{"rate": maxRate})
	if err == nil {
		pts = append(pts, p5)
	}

	var maxChangeRate float64
	mcr, err := strconv.ParseFloat(validatorResp.Validator.Commission.CommissionRates.MaxChangeRate, 64)
	if err != nil {
		log.Printf("error in atoi: %v", err)
		maxChangeRate = 0
	} else {
		maxChangeRate = mcr * 100
	}
	p6, err := createDataPoint("vcf_validator_max_change_rate", map[string]string{}, map[string]interface{}{"rate": maxChangeRate})
	if err == nil {
		pts = append(pts, p6)
	}

	bp.AddPoints(pts)
	_ = writeBatchPoints(c, bp)
	log.Printf("Ooperator Addr: %s \nAddress: %s \nFee: %f \nValidator Details: %v \nMax Rate: %f \nMax Change Rate: %f \nValidator Jailed Status: %t \n",
		operatorAddress, address, fee, validatorDetails, maxRate, maxChangeRate, validatorStatus)
}