mirror of
https://github.com/krau/SaveAny-Bot.git
synced 2026-08-28 19:56:41 +08:00
fix: remove caching logic for Telegram messages in GetTGMessage function, close #40
This commit is contained in:
@@ -200,13 +200,7 @@ func FileFromMessage(ctx *ext.Context, chatID int64, messageID int, customFileNa
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GetTGMessage(ctx *ext.Context, chatId int64, messageID int) (*tg.Message, error) {
|
func GetTGMessage(ctx *ext.Context, chatId int64, messageID int) (*tg.Message, error) {
|
||||||
key := fmt.Sprintf("message:%d:%d", chatId, messageID)
|
|
||||||
common.Log.Debugf("Fetching message: %d", messageID)
|
common.Log.Debugf("Fetching message: %d", messageID)
|
||||||
var cachedMessage tg.Message
|
|
||||||
err := common.Cache.Get(key, &cachedMessage)
|
|
||||||
if err == nil {
|
|
||||||
return &cachedMessage, nil
|
|
||||||
}
|
|
||||||
messages, err := ctx.GetMessages(chatId, []tg.InputMessageClass{&tg.InputMessageID{ID: messageID}})
|
messages, err := ctx.GetMessages(chatId, []tg.InputMessageClass{&tg.InputMessageID{ID: messageID}})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -219,9 +213,6 @@ func GetTGMessage(ctx *ext.Context, chatId int64, messageID int) (*tg.Message, e
|
|||||||
if !ok {
|
if !ok {
|
||||||
return nil, fmt.Errorf("unexpected message type: %T", msg)
|
return nil, fmt.Errorf("unexpected message type: %T", msg)
|
||||||
}
|
}
|
||||||
if err := common.Cache.Set(key, tgMessage, 3600); err != nil {
|
|
||||||
common.Log.Errorf("Failed to cache message: %s", err)
|
|
||||||
}
|
|
||||||
return tgMessage, nil
|
return tgMessage, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -21,8 +21,6 @@ func initCache() {
|
|||||||
gob.Register(types.File{})
|
gob.Register(types.File{})
|
||||||
gob.Register(tg.InputDocumentFileLocation{})
|
gob.Register(tg.InputDocumentFileLocation{})
|
||||||
gob.Register(tg.InputPhotoFileLocation{})
|
gob.Register(tg.InputPhotoFileLocation{})
|
||||||
gob.Register(tg.Message{})
|
|
||||||
gob.Register(tg.PeerUser{})
|
|
||||||
Cache = &CommonCache{cache: freecache.NewCache(10 * 1024 * 1024)}
|
Cache = &CommonCache{cache: freecache.NewCache(10 * 1024 * 1024)}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user