package monitor

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"strings"
)

func ClusterLogReadFile() error {
	path := "/Users/liucx/Documents/gopath/src/gitee.com/liucxer/ceph-tools/pkg/monitor/cluster.log"
	bts, err := ioutil.ReadFile(path)
	if err != nil {
		return err
	}

	list := strings.Split(string(bts), "\n")
	for _, item := range list {
		if !strings.Contains(item, "client_request") {
			continue
		}

		if strings.Contains(item, "dump_historic_ops") {
			continue
		}

		var ops Ops
		err = json.Unmarshal([]byte(item), &ops)
		if err != nil {
			return err
		}

		if ops.Duration < 5 {
			continue
		}

		if strings.Contains(ops.Description, "readdir") {
			bts, err := json.Marshal(ops)
			if err != nil {
				return err
			}
			fmt.Println(string(bts))
		}
	}

	return err
}