package fisher

import (
	"context"
	"sync"

	"gitee.com/cfh008/ioutils"
)

var recorder *ioutils.Recorder
var once sync.Once

func getStorageInstance() *ioutils.Recorder {
	return recorder
}

// 写入已经json序列化好的字符数组，字符串或者是可以进行json序列化的对象
func RecordData(data interface{}) (err error) {
	return ioutils.RecordData(getStorageInstance(), data)
}

func SetRecordWriter(writer ioutils.Writer) {
	ioutils.SetRecordWriter(getStorageInstance(), writer)
}

// 开启存储数据的服务，便于实现全局写数据
func StartRecoder(ctx context.Context, writer ioutils.Writer) {
	once.Do(func() {
		recorder = ioutils.StartRecorder(ctx, writer)
	})
}