diff options
author | ValdikSS <iam@valdikss.org.ru> | 2022-03-19 13:34:46 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-03-19 11:34:46 +0100 |
commit | c51753cab1319f6df9f859896b7ad9aa9e104041 (patch) | |
tree | 093761ff94c838af1253f25421e5664332d3c2ee /bridge | |
parent | b3be2e208cb373207d6199cac5a9fc92be073e7a (diff) | |
download | matterbridge-msglm-c51753cab1319f6df9f859896b7ad9aa9e104041.tar.gz matterbridge-msglm-c51753cab1319f6df9f859896b7ad9aa9e104041.tar.bz2 matterbridge-msglm-c51753cab1319f6df9f859896b7ad9aa9e104041.zip |
Fix for complex-formatted Telegram text (#1765)
* Telegram: handle entities before everything
* Telegram: use runes for text entities
* Telegram: use proper offset and runes for links
* Telegram: put newline after backticks for pre
* Telegram: use utf16 for entity processing
Diffstat (limited to 'bridge')
-rw-r--r-- | bridge/telegram/handlers.go | 28 |
1 files changed, 16 insertions, 12 deletions
diff --git a/bridge/telegram/handlers.go b/bridge/telegram/handlers.go index df3d6f8f..7710f106 100644 --- a/bridge/telegram/handlers.go +++ b/bridge/telegram/handlers.go @@ -187,6 +187,9 @@ func (b *Btelegram) handleRecv(updates <-chan tgbotapi.Update) { rmsg.ID = strconv.Itoa(message.MessageID) rmsg.Channel = strconv.FormatInt(message.Chat.ID, 10) + // handle entities (adding URLs) + b.handleEntities(&rmsg, message) + // handle username b.handleUsername(&rmsg, message) @@ -202,9 +205,6 @@ func (b *Btelegram) handleRecv(updates <-chan tgbotapi.Update) { // quote the previous message b.handleQuoting(&rmsg, message) - // handle entities (adding URLs) - b.handleEntities(&rmsg, message) - if rmsg.Text != "" || len(rmsg.Extra) > 0 { // Comment the next line out due to avoid removing empty lines in Telegram // rmsg.Text = helper.RemoveEmptyNewLines(rmsg.Text) @@ -489,46 +489,50 @@ func (b *Btelegram) handleEntities(rmsg *config.Message, message *tgbotapi.Messa // for now only do URL replacements for _, e := range message.Entities { + + asRunes := utf16.Encode([]rune(rmsg.Text)) + if e.Type == "text_link" { + offset := e.Offset + indexMovedBy url, err := e.ParseURL() if err != nil { b.Log.Errorf("entity text_link url parse failed: %s", err) continue } utfEncodedString := utf16.Encode([]rune(rmsg.Text)) - if e.Offset+e.Length > len(utfEncodedString) { - b.Log.Errorf("entity length is too long %d > %d", e.Offset+e.Length, len(utfEncodedString)) + if offset+e.Length > len(utfEncodedString) { + b.Log.Errorf("entity length is too long %d > %d", offset+e.Length, len(utfEncodedString)) continue } - link := utf16.Decode(utfEncodedString[e.Offset : e.Offset+e.Length]) - rmsg.Text = strings.Replace(rmsg.Text, string(link), url.String(), 1) + rmsg.Text = string(utf16.Decode(asRunes[:offset+e.Length])) + " (" + url.String() + ")" + string(utf16.Decode(asRunes[offset+e.Length:])) + indexMovedBy += len(url.String()) + 3 } if e.Type == "code" { offset := e.Offset + indexMovedBy - rmsg.Text = rmsg.Text[:offset] + "`" + rmsg.Text[offset:offset+e.Length] + "`" + rmsg.Text[offset+e.Length:] + rmsg.Text = string(utf16.Decode(asRunes[:offset])) + "`" + string(utf16.Decode(asRunes[offset:offset+e.Length])) + "`" + string(utf16.Decode(asRunes[offset+e.Length:])) indexMovedBy += 2 } if e.Type == "pre" { offset := e.Offset + indexMovedBy - rmsg.Text = rmsg.Text[:offset] + "```\n" + rmsg.Text[offset:offset+e.Length] + "\n```" + rmsg.Text[offset+e.Length:] + rmsg.Text = string(utf16.Decode(asRunes[:offset])) + "```\n" + string(utf16.Decode(asRunes[offset:offset+e.Length])) + "```\n" + string(utf16.Decode(asRunes[offset+e.Length:])) indexMovedBy += 8 } if e.Type == "bold" { offset := e.Offset + indexMovedBy - rmsg.Text = rmsg.Text[:offset] + "*" + rmsg.Text[offset:offset+e.Length] + "*" + rmsg.Text[offset+e.Length:] + rmsg.Text = string(utf16.Decode(asRunes[:offset])) + "*" + string(utf16.Decode(asRunes[offset:offset+e.Length])) + "*" + string(utf16.Decode(asRunes[offset+e.Length:])) indexMovedBy += 2 } if e.Type == "italic" { offset := e.Offset + indexMovedBy - rmsg.Text = rmsg.Text[:offset] + "_" + rmsg.Text[offset:offset+e.Length] + "_" + rmsg.Text[offset+e.Length:] + rmsg.Text = string(utf16.Decode(asRunes[:offset])) + "_" + string(utf16.Decode(asRunes[offset:offset+e.Length])) + "_" + string(utf16.Decode(asRunes[offset+e.Length:])) indexMovedBy += 2 } if e.Type == "strike" { offset := e.Offset + indexMovedBy - rmsg.Text = rmsg.Text[:offset] + "~" + rmsg.Text[offset:offset+e.Length] + "~" + rmsg.Text[offset+e.Length:] + rmsg.Text = string(utf16.Decode(asRunes[:offset])) + "~" + string(utf16.Decode(asRunes[offset:offset+e.Length])) + "~" + string(utf16.Decode(asRunes[offset+e.Length:])) indexMovedBy += 2 } } |