laconicd/gql/status.go
Isha Venikar f23f691646 Add lint config and fix lint errors (#7)
* Add config file for linter

* Fix lint errors

* Fix gofumpt errors

* Fix pre-allocate slices lint error

* Remove unused lint rule

* Disable style check ID error

* Add gomodguard section in yml file

* Remove trailing white spaces

* Remove unnecessary comments

---------

Co-authored-by: Prathamesh Musale <prathamesh.musale0@gmail.com>
2024-07-16 09:25:39 +05:30

106 lines
2.9 KiB
Go

package gql
import (
"context"
"os"
"os/exec"
"strconv"
"strings"
"github.com/cosmos/cosmos-sdk/client"
)
// NodeDataPath is the path to the laconicd data folder.
var NodeDataPath = os.ExpandEnv("$HOME/.laconicd/data")
func getStatusInfo(client client.Context) (*NodeInfo, *SyncInfo, *ValidatorInfo, error) {
nodeClient, err := client.GetNode()
if err != nil {
return nil, nil, nil, err
}
nodeStatus, err := nodeClient.Status(context.Background())
if err != nil {
return nil, nil, nil, err
}
return &NodeInfo{
ID: string(nodeStatus.NodeInfo.ID()),
Network: nodeStatus.NodeInfo.Network,
Moniker: nodeStatus.NodeInfo.Moniker,
}, &SyncInfo{
LatestBlockHash: nodeStatus.SyncInfo.LatestBlockHash.String(),
LatestBlockHeight: strconv.FormatInt(nodeStatus.SyncInfo.LatestBlockHeight, 10),
LatestBlockTime: nodeStatus.SyncInfo.LatestBlockTime.String(),
CatchingUp: nodeStatus.SyncInfo.CatchingUp,
}, &ValidatorInfo{
Address: nodeStatus.ValidatorInfo.Address.String(),
VotingPower: strconv.FormatInt(nodeStatus.ValidatorInfo.VotingPower, 10),
ProposerPriority: nil,
}, nil
}
// nolint: all
func getNetInfo(_ client.Context) (string, []*PeerInfo, error) {
// TODO: Implement
// nodeClient, err := client.GetNode()
// if err != nil {
// return "", nil, err
// }
// netInfo, err := nodeClient.NetInfo(context.Background())
// if err != nil {
// return "", nil, err
// }
// peersInfo := make([]*PeerInfo, netInfo.NPeers)
// // TODO: find a way to get the peer information from nodeClient
// for index, peer := range netInfo.Peers {
// peersInfo[index] = &PeerInfo{
// Node: &NodeInfo{
// ID: string(peer.NodeInfo.ID()),
// // Moniker: peer.Node.Moniker,
// // Network: peer.Node.Network,
// },
// // IsOutbound: peer.IsOutbound,
// // RemoteIP: peer.RemoteIP,
// }
// }
// return strconv.FormatInt(int64(netInfo.NPeers), 10), peersInfo, nil
return strconv.FormatInt(int64(0), 10), []*PeerInfo{}, nil
}
func getValidatorSet(client client.Context) ([]*ValidatorInfo, error) {
nodeClient, err := client.GetNode()
if err != nil {
return nil, err
}
res, err := nodeClient.Validators(context.Background(), nil, nil, nil)
if err != nil {
return nil, err
}
validatorSet := make([]*ValidatorInfo, len(res.Validators))
for index, validator := range res.Validators {
proposerPriority := strconv.FormatInt(validator.ProposerPriority, 10)
validatorSet[index] = &ValidatorInfo{
Address: validator.Address.String(),
VotingPower: strconv.FormatInt(validator.VotingPower, 10),
ProposerPriority: &proposerPriority,
}
}
return validatorSet, nil
}
// GetDiskUsage returns disk usage for the given path.
func GetDiskUsage(dirPath string) (string, error) {
out, err := exec.Command("du", "-sh", dirPath).Output() // #nosec G204
if err != nil {
return "", err
}
return strings.Fields(string(out))[0], nil
}