summaryrefslogtreecommitdiffstats
path: root/bridge/matrix
diff options
context:
space:
mode:
authorSimon THOBY <simonthoby@live.fr>2020-11-13 23:42:14 +0100
committerGitHub <noreply@github.com>2020-11-13 23:42:14 +0100
commit662359908b84d3a38010773ac70ca05478508fd5 (patch)
treeb092feb17b3fa885d0f0f6bd855566e3be22f44b /bridge/matrix
parent0d99766686c2fb25bd31b099a8b03172b99dad96 (diff)
downloadmatterbridge-msglm-662359908b84d3a38010773ac70ca05478508fd5.tar.gz
matterbridge-msglm-662359908b84d3a38010773ac70ca05478508fd5.tar.bz2
matterbridge-msglm-662359908b84d3a38010773ac70ca05478508fd5.zip
Allow message edits on matrix (#1286)
based on https://github.com/Half-Shot/matrix-doc/blob/hs/1695-message-edits-proposal/proposals/1695-message-edits.md
Diffstat (limited to 'bridge/matrix')
-rw-r--r--bridge/matrix/matrix.go87
1 files changed, 86 insertions, 1 deletions
diff --git a/bridge/matrix/matrix.go b/bridge/matrix/matrix.go
index d33c3d8f..fa2a3f80 100644
--- a/bridge/matrix/matrix.go
+++ b/bridge/matrix/matrix.go
@@ -112,6 +112,22 @@ retry:
return nil
}
+type SubTextMessage struct {
+ MsgType string `json:"msgtype"`
+ Body string `json:"body"`
+}
+
+type MessageRelation struct {
+ EventID string `json:"event_id"`
+ Type string `json:"rel_type"`
+}
+
+type EditedMessage struct {
+ NewContent SubTextMessage `json:"m.new_content"`
+ RelatedTo MessageRelation `json:"m.relates_to"`
+ matrix.TextMessage
+}
+
func (b *Bmatrix) Send(msg config.Message) (string, error) {
b.Log.Debugf("=> Receiving %#v", msg)
@@ -160,7 +176,32 @@ func (b *Bmatrix) Send(msg config.Message) (string, error) {
}
// Edit message if we have an ID
- // matrix has no editing support
+ if msg.ID != "" {
+ rmsg := EditedMessage{TextMessage: matrix.TextMessage{
+ Body: username.plain + msg.Text,
+ MsgType: "m.text",
+ }}
+ if b.GetBool("HTMLDisable") {
+ rmsg.TextMessage.FormattedBody = username.formatted + "* " + msg.Text
+ } else {
+ rmsg.Format = "org.matrix.custom.html"
+ rmsg.TextMessage.FormattedBody = username.formatted + "* " + helper.ParseMarkdown(msg.Text)
+ }
+ rmsg.NewContent = SubTextMessage{
+ Body: rmsg.TextMessage.Body,
+ MsgType: "m.text",
+ }
+ rmsg.RelatedTo = MessageRelation{
+ EventID: msg.ID,
+ Type: "m.replace",
+ }
+ _, err := b.mc.SendMessageEvent(channel, "m.room.message", rmsg)
+ if err != nil {
+ return "", err
+ }
+
+ return msg.ID, nil
+ }
// Use notices to send join/leave events
if msg.Event == config.EventJoinLeave {
@@ -216,6 +257,45 @@ func (b *Bmatrix) handlematrix() {
}()
}
+func interface2Struct(in interface{}, out interface{}) error {
+ jsonObj, err := json.Marshal(in)
+ if err != nil {
+ return err
+ }
+
+ return json.Unmarshal(jsonObj, out)
+}
+
+func (b *Bmatrix) handleEdit(ev *matrix.Event, rmsg config.Message) bool {
+ relationInterface, present := ev.Content["m.relates_to"]
+ newContentInterface, present2 := ev.Content["m.new_content"]
+ if !(present && present2) {
+ return false
+ }
+
+ var relation MessageRelation
+ if err := interface2Struct(relationInterface, &relation); err != nil {
+ b.Log.Warnf("Couldn't parse 'm.relates_to' object with value %#v", relationInterface)
+ return false
+ }
+
+ var newContent SubTextMessage
+ if err := interface2Struct(newContentInterface, &newContent); err != nil {
+ b.Log.Warnf("Couldn't parse 'm.new_content' object with value %#v", newContentInterface)
+ return false
+ }
+
+ if relation.Type != "m.replace" {
+ return false
+ }
+
+ rmsg.ID = relation.EventID
+ rmsg.Text = newContent.Body
+ b.Remote <- rmsg
+
+ return true
+}
+
func (b *Bmatrix) handleEvent(ev *matrix.Event) {
b.Log.Debugf("== Receiving event: %#v", ev)
if ev.Sender != b.UserID {
@@ -264,6 +344,11 @@ func (b *Bmatrix) handleEvent(ev *matrix.Event) {
rmsg.Event = config.EventUserAction
}
+ // Is it an edit?
+ if b.handleEdit(ev, rmsg) {
+ return
+ }
+
// Do we have attachments
if b.containsAttachment(ev.Content) {
err := b.handleDownloadFile(&rmsg, ev.Content)