package dispatcher import ( "fmt" "html" "log" "strings" "github.com/gomarkdown/markdown" "github.com/matrix-org/gomatrix" "github.com/pushbits/server/internal/api" "github.com/pushbits/server/internal/model" ) // MessageFormat is a matrix message format type MessageFormat string // MsgType is a matrix msgtype type MsgType string // Define matrix constants const ( MessageFormatHTML = MessageFormat("org.matrix.custom.html") MsgTypeText = MsgType("m.text") ) // MessageEvent is the content of a matrix message event type MessageEvent struct { Body string `json:"body"` FormattedBody string `json:"formatted_body"` MsgType MsgType `json:"msgtype"` RelatesTo RelatesTo `json:"m.relates_to,omitempty"` Format MessageFormat `json:"format"` NewContent NewContent `json:"m.new_content,omitempty"` } // RelatesTo holds information about relations to other message events type RelatesTo struct { InReplyTo map[string]string `json:"m.in_reply_to,omitempty"` RelType string `json:"rel_type,omitempty"` EventID string `json:"event_id,omitempty"` } // NewContent holds information about an updated message event type NewContent struct { Body string `json:"body"` FormattedBody string `json:"formatted_body"` MsgType MsgType `json:"msgtype"` Format MessageFormat `json:"format"` } // SendNotification sends a notification to the specified user. func (d *Dispatcher) SendNotification(a *model.Application, n *model.Notification) (id string, err error) { log.Printf("Sending notification to room %s.", a.MatrixID) plainMessage := strings.TrimSpace(n.Message) plainTitle := strings.TrimSpace(n.Title) message := d.getFormattedMessage(n) title := d.getFormattedTitle(n) text := fmt.Sprintf("%s\n\n%s", plainTitle, plainMessage) formattedText := fmt.Sprintf("%s %s", title, message) respSendEvent, err := d.client.SendFormattedText(a.MatrixID, text, formattedText) return respSendEvent.EventID, err } // DeleteNotification sends a notification to the specified user that another notificaion is deleted func (d *Dispatcher) DeleteNotification(a *model.Application, n *model.DeleteNotification) error { log.Printf("Sending delete notification to room %s", a.MatrixID) var oldFormattedBody string var oldBody string // get the message we want to delete deleteMessage, err := d.getMessage(a, n.ID) if err != nil { log.Println(err) return api.ErrorMessageNotFound } oldBody, oldFormattedBody, err = bodiesFromMessage(deleteMessage) if err != nil { return err } // update the message with strikethrough newBody := fmt.Sprintf("%s\n- deleted", oldBody) newFormattedBody := fmt.Sprintf("%s
- deleted", oldFormattedBody) _, err = d.replaceMessage(a, newBody, newFormattedBody, deleteMessage.ID, oldBody, oldFormattedBody) if err != nil { return err } _, err = d.respondToMessage(a, "This message got deleted", "This message got deleted.", deleteMessage) return err } // HTML-formats the title func (d *Dispatcher) getFormattedTitle(n *model.Notification) string { trimmedTitle := strings.TrimSpace(n.Title) title := html.EscapeString(trimmedTitle) if d.formatting.ColoredTitle { title = d.coloredText(d.priorityToColor(n.Priority), title) } return "" + title + "

" } // Converts different syntaxes to a HTML-formatted message func (d *Dispatcher) getFormattedMessage(n *model.Notification) string { trimmedMessage := strings.TrimSpace(n.Message) message := strings.Replace(html.EscapeString(trimmedMessage), "\n", "
", -1) // default to text/plain if optionsDisplayRaw, ok := n.Extras["client::display"]; ok { optionsDisplay, ok := optionsDisplayRaw.(map[string]interface{}) if ok { if contentTypeRaw, ok := optionsDisplay["contentType"]; ok { contentType := fmt.Sprintf("%v", contentTypeRaw) log.Printf("Message content type: %s", contentType) switch contentType { case "html", "text/html": message = strings.Replace(trimmedMessage, "\n", "
", -1) case "markdown", "md", "text/md", "text/markdown": // allow HTML in Markdown message = string(markdown.ToHTML([]byte(trimmedMessage), nil, nil)) } } } } return message } // Maps priorities to hex colors func (d *Dispatcher) priorityToColor(prio int) string { switch { case prio < 0: return "#828282" case prio <= 3: // info - default color return "" case prio <= 10: // low - yellow return "#edd711" case prio <= 20: // mid - orange return "#ed6d11" case prio > 20: // high - red return "#ed1f11" } return "" } // Maps a priority to a color tag func (d *Dispatcher) coloredText(color string, text string) string { if color == "" { return text } return "" + text + "" } // Searches in the messages list for the given id func (d *Dispatcher) getMessage(a *model.Application, id string) (gomatrix.Event, error) { start := "" end := "" maxPages := 10 // maximum pages to request (10 messages per page) for i := 0; i < maxPages; i++ { messages, _ := d.client.Messages(a.MatrixID, start, end, 'b', 10) for _, event := range messages.Chunk { if event.ID == id { return event, nil } } start = messages.End } return gomatrix.Event{}, api.ErrorMessageNotFound } // Replaces the content of a matrix message func (d *Dispatcher) replaceMessage(a *model.Application, newBody, newFormattedBody string, messageID string, oldBody, oldFormattedBody string) (*gomatrix.RespSendEvent, error) { newMessage := NewContent{ Body: newBody, FormattedBody: newFormattedBody, MsgType: MsgTypeText, Format: MessageFormatHTML, } replaceRelation := RelatesTo{ RelType: "m.replace", EventID: messageID, } replaceEvent := MessageEvent{ Body: oldBody, FormattedBody: oldFormattedBody, MsgType: MsgTypeText, NewContent: newMessage, RelatesTo: replaceRelation, Format: MessageFormatHTML, } sendEvent, err := d.client.SendMessageEvent(a.MatrixID, "m.room.message", replaceEvent) if err != nil { log.Println(err) return nil, err } return sendEvent, nil } // Sends a notification in response to another matrix message event func (d *Dispatcher) respondToMessage(a *model.Application, body, formattedBody string, respondMessage gomatrix.Event) (*gomatrix.RespSendEvent, error) { oldBody, oldFormattedBody, err := bodiesFromMessage(respondMessage) if err != nil { return nil, err } // formatting according to https://matrix.org/docs/spec/client_server/latest#fallbacks-and-event-representation newFormattedBody := fmt.Sprintf("
In reply to %s
%s
\n
%s", respondMessage.RoomID, respondMessage.ID, respondMessage.Sender, respondMessage.Sender, oldFormattedBody, formattedBody) newBody := fmt.Sprintf("> <%s>%s\n\n%s", respondMessage.Sender, oldBody, body) notificationEvent := MessageEvent{ FormattedBody: newFormattedBody, Body: newBody, MsgType: MsgTypeText, Format: MessageFormatHTML, } notificationReply := make(map[string]string) notificationReply["event_id"] = respondMessage.ID notificationRelation := RelatesTo{ InReplyTo: notificationReply, } notificationEvent.RelatesTo = notificationRelation return d.client.SendMessageEvent(a.MatrixID, "m.room.message", notificationEvent) } // Extracts body and formatted body from a matrix message event func bodiesFromMessage(message gomatrix.Event) (body, formattedBody string, err error) { if val, ok := message.Content["body"]; ok { body, ok := val.(string) if !ok { return "", "", api.ErrorMessageNotFound } formattedBody = body } else { return "", "", api.ErrorMessageNotFound } if val, ok := message.Content["formatted_body"]; ok { body, ok := val.(string) if !ok { return "", "", api.ErrorMessageNotFound } formattedBody = body } return body, formattedBody, nil }