kemko/memes-telegram-integration
1
0
Fork 0
mirror of https://github.com/kemko/memes-telegram-integration.git synced 2026-01-01 15:55:41 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: handle more message types (#13)

Browse Source 
* feat: handle more message types

* feat: rename processMessage

Co-authored-by: Michael <161408495+michaelien@users.noreply.github.com>

* feat: rename processMessage

---------

Co-authored-by: Michael <161408495+michaelien@users.noreply.github.com>
This commit is contained in:
Patryk M
2024-05-29 05:05:50 +02:00
committed by GitHub
parent 7a632190a0
commit bc386b6539
1 changed files with 27 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
memogram.go
View File

@@ -95,7 +95,7 @@ func (s *Service) handler(ctx context.Context, b *bot.Bot, m *models.Update) {
if message.Caption != "" {
content = message.Caption
}
hasResource := message.Document != nil || len(message.Photo) > 0
hasResource := message.Document != nil || len(message.Photo) > 0 || message.Voice != nil || message.Video != nil
if content == "" && !hasResource {
b.SendMessage(ctx, &bot.SendMessageParams{
ChatID: m.Message.Chat.ID,
@@ -119,31 +119,20 @@ func (s *Service) handler(ctx context.Context, b *bot.Bot, m *models.Update) {
}
if message.Document != nil {
file, err := b.GetFile(ctx, &bot.GetFileParams{FileID: message.Document.FileID})
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to get file"))
return
s.processFileMessage(ctx, b, m, message.Document.FileID, memo)
}
_, err = s.saveResourceFromFile(ctx, file, memo)
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to save resource"))
return
if message.Voice != nil {
s.processFileMessage(ctx, b, m, message.Voice.FileID, memo)
}
if message.Video != nil {
s.processFileMessage(ctx, b, m, message.Video.FileID, memo)
}
if len(message.Photo) > 0 {
photo := message.Photo[len(message.Photo)-1]
file, err := b.GetFile(ctx, &bot.GetFileParams{FileID: photo.FileID})
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to get file"))
return
}
_, err = s.saveResourceFromFile(ctx, file, memo)
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to save resource"))
return
}
s.processFileMessage(ctx, b, m, photo.FileID, memo)
}
b.SendMessage(ctx, &bot.SendMessageParams{
@@ -211,6 +200,21 @@ func (s *Service) saveResourceFromFile(ctx context.Context, file *models.File, m
return resource, nil
}
func (s *Service) processFileMessage(ctx context.Context, b *bot.Bot, m *models.Update, fileID string, memo *v1pb.Memo) {
file, err := b.GetFile(ctx, &bot.GetFileParams{FileID: fileID})
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to get file"))
return
}
_, err = s.saveResourceFromFile(ctx, file, memo)
if err != nil {
s.sendError(b, m.Message.Chat.ID, errors.Wrap(err, "failed to save resource"))
return
}
}
func (s *Service) sendError(b *bot.Bot, chatID int64, err error) {
slog.Error("error", slog.Any("err", err))
b.SendMessage(context.Background(), &bot.SendMessageParams{