package boltcache

import "strconv"

//添加一条日志
func (ls *LogStore) ApplyLog(logData []byte) {
	lastLogIndex := ls.getLastLog()
	ls.applyCh <- &Log{
		Index: lastLogIndex + 1,
		Data:  logData,
	}
	ls.setLastLog(lastLogIndex + 1)
}

type LogCon struct {
	conf *confLog
	Log  *Log
}

//获取缓存的数据
func (lc *LogCon) GetData() []byte {
	return lc.Log.Data
}

//提供给外层使用，按顺序获取缓存的日志
func (ls *LogStore) Get() *LogCon {
	idx, _ := ls.store.FirstIndex(confBucket)
	cLog := &confLog{}
	if err := ls.store.GetConfLog(idx, cLog); err == nil {
		u, _ := ls.store.FirstIndex(cLog.BucketName)
		log := &Log{}
		if err = ls.store.GetLog(cLog.BucketName, u, log); err == nil {
			log.Index = u
			cLog.Index = int(idx)
			return &LogCon{
				conf: cLog,
				Log:  log,
			}
		} else {
			if size, _ := ls.store.Size(confBucket); size > 1 {
				ls.Delete(&LogCon{
					conf: cLog,
					Log:  nil,
				})
			}
			ls.printLog("Get log err:", err)
		}
	} else {
		ls.printLog("Get conf idx:", idx, "err:", err)
	}
	return nil
}

// 遍历数据, 输出原始数据
func (ls *LogStore) ForEach(f func(v *LogCon) error) error {
	return ls.store.ForEach(f)
}

func (ls *LogStore) Size() int {
	start, _ := ls.store.FirstIndex(confBucket)
	end, _ := ls.store.LastIndex(confBucket)

	totalSize := 0

	for ; start <= end; start++ {
		bucketName := bucketPre + strconv.Itoa(int(start))
		bucketSize, err := ls.store.Size(bucketName)
		if err == nil {
			totalSize = totalSize + bucketSize
		}
	}

	return totalSize
}

//提供给外层使用，删除日志
func (ls *LogStore) Delete(lc *LogCon) error {
	return ls.store.Delete(lc)
}

func (ls *LogStore) Close() error {
	return ls.store.Close()
}