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 }