package monitor

import (
	"gitee.com/liucxer/ceph-tools/pkg/host_client"
	"github.com/sirupsen/logrus"
	"io/ioutil"
	"regexp"
	"strconv"
	"strings"
)

func GetHostFree(client *host_client.HostClient) (MonitorResultItem, error) {
	var (
		res MonitorResultItem
		err error
	)
	bts, err := client.ExecCmd("free -m")
	if err != nil {
		res.Error = err.Error()
		return res, err
	}

	freeInt, err := DecodeByte(bts)
	if err != nil {
		res.Error = err.Error()
		return res, err
	}

	if freeInt < 5*1024 {
		res.IsOk = false
		res.Error = strconv.Itoa(int(freeInt/1024)) + "G"
		res.Success = strconv.Itoa(int(freeInt/1024)) + "G"
	} else {
		res.IsOk = true
		res.Error = strconv.Itoa(int(freeInt/1024)) + "G"
		res.Success = strconv.Itoa(int(freeInt/1024)) + "G"
	}

	return res, err
}

func DecodeFree() (int64, error) {
	var (
		free int64
	)
	bts, err := ioutil.ReadFile("/Users/liucx/Documents/gopath/src/gitee.com/liucxer/ceph-tools/pkg/monitor/free_data.json")
	if err != nil {
		return free, err
	}
	return DecodeByte(bts)
}
func DecodeByte(bts []byte) (int64, error) {
	var (
		free    int64
		freeStr string
	)
	str := string(bts)
	list := strings.Split(str, "\n")
	for _, item := range list {
		if strings.Contains(item, "Mem") {
			re := regexp.MustCompile(`\s+`)
			result := re.ReplaceAllString(item, " ")
			subList := strings.Split(result, " ")
			freeStr = subList[3]
		}
	}

	freeInt, err := strconv.Atoi(freeStr)
	if err != nil {
		logrus.Errorf("strconv.Atoi err:%v, freeStr:%s", err, freeStr)
		return free, err
	}

	free = int64(freeInt)
	return free, err
}