diff --git a/bot_test.go b/bot_test.go index 1e1a72d..b1f6db9 100644 --- a/bot_test.go +++ b/bot_test.go @@ -128,16 +128,4 @@ func TestSender(t *testing.T) { bot.Block() } -func TestHotReloadStorage(t *testing.T) { - bot := DefaultBot(Desktop) - bot.MessageHandler = func(msg *Message) { - if msg.IsText() && msg.Content == "ping" { - msg.ReplyText("pong") - } - } - if err := bot.HotLogin(NewJsonFileHotReloadStorage("test.json")); err != nil { - t.Error(err) - return - } - bot.Block() -} + diff --git a/stroage.go b/stroage.go index 35045d8..a3e30b0 100644 --- a/stroage.go +++ b/stroage.go @@ -1,7 +1,6 @@ package openwechat import ( - "bytes" "encoding/json" "errors" "io" @@ -28,6 +27,7 @@ type HotReloadStorage io.ReadWriteCloser // JsonFileHotReloadStorage 实现HotReloadStorage接口 // 默认以json文件的形式存储 +// Deprecated type JsonFileHotReloadStorage struct { FileName string file *os.File @@ -58,6 +58,9 @@ func (j *JsonFileHotReloadStorage) Close() error { return nil } +// NewJsonFileHotReloadStorage 创建JsonFileHotReloadStorage +// Deprecated +// use os.File instead func NewJsonFileHotReloadStorage(filename string) HotReloadStorage { return &JsonFileHotReloadStorage{FileName: filename} } @@ -68,13 +71,9 @@ func NewHotReloadStorageItem(storage HotReloadStorage) (*HotReloadStorageItem, e if storage == nil { return nil, errors.New("storage can't be nil") } - var buffer bytes.Buffer - if _, err := buffer.ReadFrom(storage); err != nil { - return nil, err - } var item HotReloadStorageItem - if err := json.NewDecoder(&buffer).Decode(&item); err != nil { + if err := json.NewDecoder(storage).Decode(&item); err != nil { return nil, err } return &item, nil