message.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2019 Tulir Asokan
  3. //
  4. // This program is free software: you can redistribute it and/or modify
  5. // it under the terms of the GNU Affero General Public License as published by
  6. // the Free Software Foundation, either version 3 of the License, or
  7. // (at your option) any later version.
  8. //
  9. // This program is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. // GNU Affero General Public License for more details.
  13. //
  14. // You should have received a copy of the GNU Affero General Public License
  15. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  16. package database
  17. import (
  18. "bytes"
  19. "strings"
  20. "database/sql"
  21. "encoding/json"
  22. waProto "github.com/Rhymen/go-whatsapp/binary/proto"
  23. log "maunium.net/go/maulogger/v2"
  24. "maunium.net/go/mautrix-whatsapp/types"
  25. )
  26. type MessageQuery struct {
  27. db *Database
  28. log log.Logger
  29. }
  30. func (mq *MessageQuery) CreateTable(dbType string) error {
  31. if strings.ToLower(dbType) == "postgres" {
  32. _, err := mq.db.Exec(`CREATE TABLE IF NOT EXISTS message (
  33. chat_jid VARCHAR(255),
  34. chat_receiver VARCHAR(255),
  35. jid VARCHAR(255),
  36. mxid VARCHAR(255) NOT NULL UNIQUE,
  37. sender VARCHAR(255) NOT NULL,
  38. content bytea NOT NULL,
  39. PRIMARY KEY (chat_jid, chat_receiver, jid),
  40. FOREIGN KEY (chat_jid, chat_receiver) REFERENCES portal(jid, receiver)
  41. )`)
  42. return err
  43. } else {
  44. _, err := mq.db.Exec(`CREATE TABLE IF NOT EXISTS message (
  45. chat_jid VARCHAR(255),
  46. chat_receiver VARCHAR(255),
  47. jid VARCHAR(255),
  48. mxid VARCHAR(255) NOT NULL UNIQUE,
  49. sender VARCHAR(255) NOT NULL,
  50. content BLOB NOT NULL,
  51. PRIMARY KEY (chat_jid, chat_receiver, jid),
  52. FOREIGN KEY (chat_jid, chat_receiver) REFERENCES portal(jid, receiver)
  53. )`)
  54. return err
  55. }
  56. }
  57. func (mq *MessageQuery) New() *Message {
  58. return &Message{
  59. db: mq.db,
  60. log: mq.log,
  61. }
  62. }
  63. func (mq *MessageQuery) GetAll(chat PortalKey) (messages []*Message) {
  64. rows, err := mq.db.Query("SELECT * FROM message WHERE chat_jid=$1 AND chat_receiver=$2", chat.JID, chat.Receiver)
  65. if err != nil || rows == nil {
  66. return nil
  67. }
  68. defer rows.Close()
  69. for rows.Next() {
  70. messages = append(messages, mq.New().Scan(rows))
  71. }
  72. return
  73. }
  74. func (mq *MessageQuery) GetByJID(chat PortalKey, jid types.WhatsAppMessageID) *Message {
  75. return mq.get("SELECT * FROM message WHERE chat_jid=$1 AND chat_receiver=$2 AND jid=$3", chat.JID, chat.Receiver, jid)
  76. }
  77. func (mq *MessageQuery) GetByMXID(mxid types.MatrixEventID) *Message {
  78. return mq.get("SELECT * FROM message WHERE mxid=$1", mxid)
  79. }
  80. func (mq *MessageQuery) get(query string, args ...interface{}) *Message {
  81. row := mq.db.QueryRow(query, args...)
  82. if row == nil {
  83. return nil
  84. }
  85. return mq.New().Scan(row)
  86. }
  87. type Message struct {
  88. db *Database
  89. log log.Logger
  90. Chat PortalKey
  91. JID types.WhatsAppMessageID
  92. MXID types.MatrixEventID
  93. Sender types.WhatsAppID
  94. Content *waProto.Message
  95. }
  96. func (msg *Message) Scan(row Scannable) *Message {
  97. var content []byte
  98. err := row.Scan(&msg.Chat.JID, &msg.Chat.Receiver, &msg.JID, &msg.MXID, &msg.Sender, &content)
  99. if err != nil {
  100. if err != sql.ErrNoRows {
  101. msg.log.Errorln("Database scan failed:", err)
  102. }
  103. return nil
  104. }
  105. msg.decodeBinaryContent(content)
  106. return msg
  107. }
  108. func (msg *Message) decodeBinaryContent(content []byte) {
  109. msg.Content = &waProto.Message{}
  110. reader := bytes.NewReader(content)
  111. dec := json.NewDecoder(reader)
  112. err := dec.Decode(msg.Content)
  113. if err != nil {
  114. msg.log.Warnln("Failed to decode message content:", err)
  115. }
  116. }
  117. func (msg *Message) encodeBinaryContent() []byte {
  118. var buf bytes.Buffer
  119. enc := json.NewEncoder(&buf)
  120. err := enc.Encode(msg.Content)
  121. if err != nil {
  122. msg.log.Warnln("Failed to encode message content:", err)
  123. }
  124. return buf.Bytes()
  125. }
  126. func (msg *Message) Insert() {
  127. _, err := msg.db.Exec("INSERT INTO message VALUES ($1, $2, $3, $4, $5, $6)", msg.Chat.JID, msg.Chat.Receiver, msg.JID, msg.MXID, msg.Sender, msg.encodeBinaryContent())
  128. if err != nil {
  129. msg.log.Warnfln("Failed to insert %s@%s: %v", msg.Chat, msg.JID, err)
  130. }
  131. }