portal.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2018 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 main
  17. import (
  18. "bytes"
  19. "encoding/hex"
  20. "fmt"
  21. "html"
  22. "image"
  23. "image/gif"
  24. "image/jpeg"
  25. "image/png"
  26. "math/rand"
  27. "mime"
  28. "net/http"
  29. "strings"
  30. "sync"
  31. "github.com/Rhymen/go-whatsapp"
  32. waProto "github.com/Rhymen/go-whatsapp/binary/proto"
  33. "maunium.net/go/gomatrix"
  34. log "maunium.net/go/maulogger"
  35. "maunium.net/go/mautrix-appservice"
  36. "maunium.net/go/mautrix-whatsapp/database"
  37. "maunium.net/go/mautrix-whatsapp/types"
  38. "maunium.net/go/mautrix-whatsapp/whatsapp-ext"
  39. )
  40. func (user *User) GetPortalByMXID(mxid types.MatrixRoomID) *Portal {
  41. user.portalsLock.Lock()
  42. defer user.portalsLock.Unlock()
  43. portal, ok := user.portalsByMXID[mxid]
  44. if !ok {
  45. dbPortal := user.bridge.DB.Portal.GetByMXID(mxid)
  46. if dbPortal == nil || dbPortal.Owner != user.ID {
  47. return nil
  48. }
  49. portal = user.NewPortal(dbPortal)
  50. user.portalsByJID[portal.JID] = portal
  51. if len(portal.MXID) > 0 {
  52. user.portalsByMXID[portal.MXID] = portal
  53. }
  54. }
  55. return portal
  56. }
  57. func (user *User) GetPortalByJID(jid types.WhatsAppID) *Portal {
  58. user.portalsLock.Lock()
  59. defer user.portalsLock.Unlock()
  60. portal, ok := user.portalsByJID[jid]
  61. if !ok {
  62. dbPortal := user.bridge.DB.Portal.GetByJID(user.ID, jid)
  63. if dbPortal == nil {
  64. dbPortal = user.bridge.DB.Portal.New()
  65. dbPortal.JID = jid
  66. dbPortal.Owner = user.ID
  67. dbPortal.Insert()
  68. }
  69. portal = user.NewPortal(dbPortal)
  70. user.portalsByJID[portal.JID] = portal
  71. if len(portal.MXID) > 0 {
  72. user.portalsByMXID[portal.MXID] = portal
  73. }
  74. }
  75. return portal
  76. }
  77. func (user *User) GetAllPortals() []*Portal {
  78. user.portalsLock.Lock()
  79. defer user.portalsLock.Unlock()
  80. dbPortals := user.bridge.DB.Portal.GetAll(user.ID)
  81. output := make([]*Portal, len(dbPortals))
  82. for index, dbPortal := range dbPortals {
  83. portal, ok := user.portalsByJID[dbPortal.JID]
  84. if !ok {
  85. portal = user.NewPortal(dbPortal)
  86. user.portalsByJID[dbPortal.JID] = portal
  87. if len(dbPortal.MXID) > 0 {
  88. user.portalsByMXID[dbPortal.MXID] = portal
  89. }
  90. }
  91. output[index] = portal
  92. }
  93. return output
  94. }
  95. func (user *User) NewPortal(dbPortal *database.Portal) *Portal {
  96. return &Portal{
  97. Portal: dbPortal,
  98. user: user,
  99. bridge: user.bridge,
  100. log: user.log.Sub(fmt.Sprintf("Portal/%s", dbPortal.JID)),
  101. }
  102. }
  103. type Portal struct {
  104. *database.Portal
  105. user *User
  106. bridge *Bridge
  107. log log.Logger
  108. roomCreateLock sync.Mutex
  109. }
  110. func (portal *Portal) SyncParticipants(metadata *whatsappExt.GroupInfo) {
  111. changed := false
  112. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  113. if err != nil {
  114. levels = portal.GetBasePowerLevels()
  115. changed = true
  116. }
  117. for _, participant := range metadata.Participants {
  118. puppet := portal.user.GetPuppetByJID(participant.JID)
  119. puppet.Intent().EnsureJoined(portal.MXID)
  120. expectedLevel := 0
  121. if participant.IsSuperAdmin {
  122. expectedLevel = 95
  123. } else if participant.IsAdmin {
  124. expectedLevel = 50
  125. }
  126. changed = levels.EnsureUserLevel(puppet.MXID, expectedLevel) || changed
  127. if participant.JID == portal.user.JID() {
  128. changed = levels.EnsureUserLevel(portal.user.ID, expectedLevel) || changed
  129. }
  130. }
  131. if changed {
  132. portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  133. }
  134. }
  135. func (portal *Portal) UpdateAvatar(avatar *whatsappExt.ProfilePicInfo) bool {
  136. if avatar == nil {
  137. var err error
  138. avatar, err = portal.user.Conn.GetProfilePicThumb(portal.JID)
  139. if err != nil {
  140. portal.log.Errorln(err)
  141. return false
  142. }
  143. }
  144. if portal.Avatar == avatar.Tag {
  145. return false
  146. }
  147. data, err := avatar.DownloadBytes()
  148. if err != nil {
  149. portal.log.Errorln("Failed to download avatar:", err)
  150. return false
  151. }
  152. mimeType := http.DetectContentType(data)
  153. resp, err := portal.MainIntent().UploadBytes(data, mimeType)
  154. if err != nil {
  155. portal.log.Errorln("Failed to upload avatar:", err)
  156. return false
  157. }
  158. _, err = portal.MainIntent().SetRoomAvatar(portal.MXID, resp.ContentURI)
  159. if err != nil {
  160. portal.log.Warnln("Failed to set room topic:", err)
  161. return false
  162. }
  163. portal.Avatar = avatar.Tag
  164. return true
  165. }
  166. func (portal *Portal) UpdateName(name string, setBy types.WhatsAppID) bool {
  167. if portal.Name != name {
  168. intent := portal.user.GetPuppetByJID(setBy).Intent()
  169. _, err := intent.SetRoomName(portal.MXID, name)
  170. if err == nil {
  171. portal.Name = name
  172. return true
  173. }
  174. portal.log.Warnln("Failed to set room name:", err)
  175. }
  176. return false
  177. }
  178. func (portal *Portal) UpdateTopic(topic string, setBy types.WhatsAppID) bool {
  179. if portal.Topic != topic {
  180. intent := portal.user.GetPuppetByJID(setBy).Intent()
  181. _, err := intent.SetRoomTopic(portal.MXID, topic)
  182. if err == nil {
  183. portal.Topic = topic
  184. return true
  185. }
  186. portal.log.Warnln("Failed to set room topic:", err)
  187. }
  188. return false
  189. }
  190. func (portal *Portal) UpdateMetadata() bool {
  191. metadata, err := portal.user.Conn.GetGroupMetaData(portal.JID)
  192. if err != nil {
  193. portal.log.Errorln(err)
  194. return false
  195. }
  196. portal.SyncParticipants(metadata)
  197. update := false
  198. update = portal.UpdateName(metadata.Name, metadata.NameSetBy) || update
  199. update = portal.UpdateTopic(metadata.Topic, metadata.TopicSetBy) || update
  200. return update
  201. }
  202. func (portal *Portal) Sync(contact whatsapp.Contact) {
  203. if len(portal.MXID) == 0 {
  204. if !portal.IsPrivateChat() {
  205. portal.Name = contact.Name
  206. }
  207. err := portal.CreateMatrixRoom()
  208. if err != nil {
  209. portal.log.Errorln("Failed to create portal room:", err)
  210. return
  211. }
  212. }
  213. if portal.IsPrivateChat() {
  214. return
  215. }
  216. update := false
  217. update = portal.UpdateMetadata() || update
  218. update = portal.UpdateAvatar(nil) || update
  219. if update {
  220. portal.Update()
  221. }
  222. }
  223. func (portal *Portal) GetBasePowerLevels() *gomatrix.PowerLevels {
  224. anyone := 0
  225. nope := 99
  226. return &gomatrix.PowerLevels{
  227. UsersDefault: anyone,
  228. EventsDefault: anyone,
  229. RedactPtr: &anyone,
  230. StateDefaultPtr: &nope,
  231. BanPtr: &nope,
  232. InvitePtr: &nope,
  233. Users: map[string]int{
  234. portal.MainIntent().UserID: 100,
  235. },
  236. Events: map[gomatrix.EventType]int{
  237. gomatrix.StateRoomName: anyone,
  238. gomatrix.StateRoomAvatar: anyone,
  239. gomatrix.StateTopic: anyone,
  240. },
  241. }
  242. }
  243. func (portal *Portal) ChangeAdminStatus(jids []string, setAdmin bool) {
  244. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  245. if err != nil {
  246. levels = portal.GetBasePowerLevels()
  247. }
  248. newLevel := 0
  249. if setAdmin {
  250. newLevel = 50
  251. }
  252. changed := false
  253. for _, jid := range jids {
  254. puppet := portal.user.GetPuppetByJID(jid)
  255. changed = levels.EnsureUserLevel(puppet.MXID, newLevel) || changed
  256. if jid == portal.user.JID() {
  257. changed = levels.EnsureUserLevel(portal.user.ID, newLevel) || changed
  258. }
  259. }
  260. if changed {
  261. portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  262. }
  263. }
  264. func (portal *Portal) RestrictMessageSending(restrict bool) {
  265. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  266. if err != nil {
  267. levels = portal.GetBasePowerLevels()
  268. }
  269. if restrict {
  270. levels.EventsDefault = 50
  271. } else {
  272. levels.EventsDefault = 0
  273. }
  274. portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  275. }
  276. func (portal *Portal) RestrictMetadataChanges(restrict bool) {
  277. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  278. if err != nil {
  279. levels = portal.GetBasePowerLevels()
  280. }
  281. newLevel := 0
  282. if restrict {
  283. newLevel = 50
  284. }
  285. changed := false
  286. changed = levels.EnsureEventLevel(gomatrix.StateRoomName, true, newLevel) || changed
  287. changed = levels.EnsureEventLevel(gomatrix.StateRoomAvatar, true, newLevel) || changed
  288. changed = levels.EnsureEventLevel(gomatrix.StateTopic, true, newLevel) || changed
  289. if changed {
  290. portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  291. }
  292. }
  293. func (portal *Portal) CreateMatrixRoom() error {
  294. portal.roomCreateLock.Lock()
  295. defer portal.roomCreateLock.Unlock()
  296. if len(portal.MXID) > 0 {
  297. return nil
  298. }
  299. name := portal.Name
  300. topic := portal.Topic
  301. isPrivateChat := false
  302. invite := []string{portal.user.ID}
  303. if portal.IsPrivateChat() {
  304. name = ""
  305. topic = "WhatsApp private chat"
  306. isPrivateChat = true
  307. }
  308. resp, err := portal.MainIntent().CreateRoom(&gomatrix.ReqCreateRoom{
  309. Visibility: "private",
  310. Name: name,
  311. Topic: topic,
  312. Invite: invite,
  313. Preset: "private_chat",
  314. IsDirect: isPrivateChat,
  315. InitialState: []*gomatrix.Event{{
  316. Type: gomatrix.StatePowerLevels,
  317. Content: gomatrix.Content{
  318. PowerLevels: *portal.GetBasePowerLevels(),
  319. },
  320. }},
  321. })
  322. if err != nil {
  323. return err
  324. }
  325. portal.MXID = resp.RoomID
  326. portal.Update()
  327. return nil
  328. }
  329. func (portal *Portal) IsPrivateChat() bool {
  330. return strings.HasSuffix(portal.JID, whatsappExt.NewUserSuffix)
  331. }
  332. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  333. if portal.IsPrivateChat() {
  334. return portal.user.GetPuppetByJID(portal.JID).Intent()
  335. }
  336. return portal.bridge.AppService.BotIntent()
  337. }
  338. func (portal *Portal) IsDuplicate(id types.WhatsAppMessageID) bool {
  339. msg := portal.bridge.DB.Message.GetByJID(portal.Owner, id)
  340. if msg != nil {
  341. return true
  342. }
  343. return false
  344. }
  345. func (portal *Portal) MarkHandled(jid types.WhatsAppMessageID, mxid types.MatrixEventID) {
  346. msg := portal.bridge.DB.Message.New()
  347. msg.Owner = portal.Owner
  348. msg.JID = jid
  349. msg.MXID = mxid
  350. msg.Insert()
  351. }
  352. func (portal *Portal) GetMessageIntent(info whatsapp.MessageInfo) *appservice.IntentAPI {
  353. if info.FromMe {
  354. return portal.user.GetPuppetByJID(portal.user.JID()).Intent()
  355. } else if portal.IsPrivateChat() {
  356. return portal.MainIntent()
  357. }
  358. return portal.user.GetPuppetByJID(info.SenderJid).Intent()
  359. }
  360. func (portal *Portal) SetReply(content *gomatrix.Content, info whatsapp.MessageInfo) {
  361. if len(info.QuotedMessageID) == 0 {
  362. return
  363. }
  364. message := portal.bridge.DB.Message.GetByJID(portal.Owner, info.QuotedMessageID)
  365. if message != nil {
  366. event, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  367. if err != nil {
  368. portal.log.Warnln("Failed to get reply target:", err)
  369. return
  370. }
  371. content.SetReply(event)
  372. }
  373. return
  374. }
  375. func (portal *Portal) ParseWhatsAppFormat(input string) string {
  376. output := html.EscapeString(input)
  377. for regex, replacement := range portal.user.waReplString {
  378. output = regex.ReplaceAllString(output, replacement)
  379. }
  380. for regex, replacer := range portal.user.waReplFunc {
  381. output = regex.ReplaceAllStringFunc(output, replacer)
  382. }
  383. return output
  384. }
  385. func (portal *Portal) HandleTextMessage(message whatsapp.TextMessage) {
  386. if portal.IsDuplicate(message.Info.Id) {
  387. return
  388. }
  389. err := portal.CreateMatrixRoom()
  390. if err != nil {
  391. portal.log.Errorln("Failed to create portal room:", err)
  392. return
  393. }
  394. intent := portal.GetMessageIntent(message.Info)
  395. if intent == nil {
  396. return
  397. }
  398. content := gomatrix.Content{
  399. Body: message.Text,
  400. MsgType: gomatrix.MsgText,
  401. }
  402. htmlBody := portal.ParseWhatsAppFormat(message.Text)
  403. if htmlBody != message.Text {
  404. content.FormattedBody = htmlBody
  405. content.Format = gomatrix.FormatHTML
  406. }
  407. portal.SetReply(&content, message.Info)
  408. intent.UserTyping(portal.MXID, false, 0)
  409. resp, err := intent.SendMassagedMessageEvent(portal.MXID, gomatrix.EventMessage, content, int64(message.Info.Timestamp*1000))
  410. if err != nil {
  411. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  412. return
  413. }
  414. portal.MarkHandled(message.Info.Id, resp.EventID)
  415. portal.log.Debugln("Handled message", message.Info.Id, "->", resp.EventID)
  416. }
  417. func (portal *Portal) HandleMediaMessage(download func() ([]byte, error), thumbnail []byte, info whatsapp.MessageInfo, mimeType, caption string) {
  418. if portal.IsDuplicate(info.Id) {
  419. return
  420. }
  421. err := portal.CreateMatrixRoom()
  422. if err != nil {
  423. portal.log.Errorln("Failed to create portal room:", err)
  424. return
  425. }
  426. intent := portal.GetMessageIntent(info)
  427. if intent == nil {
  428. return
  429. }
  430. data, err := download()
  431. if err != nil {
  432. portal.log.Errorln("Failed to download media:", err)
  433. return
  434. }
  435. uploaded, err := intent.UploadBytes(data, mimeType)
  436. if err != nil {
  437. portal.log.Errorln("Failed to upload media:", err)
  438. return
  439. }
  440. if len(caption) == 0 {
  441. caption = info.Id
  442. exts, _ := mime.ExtensionsByType(mimeType)
  443. if exts != nil && len(exts) > 0 {
  444. caption += exts[0]
  445. }
  446. }
  447. content := gomatrix.Content{
  448. Body: caption,
  449. URL: uploaded.ContentURI,
  450. Info: &gomatrix.FileInfo{
  451. Size: len(data),
  452. MimeType: mimeType,
  453. },
  454. }
  455. portal.SetReply(&content, info)
  456. if thumbnail != nil {
  457. thumbnailMime := http.DetectContentType(thumbnail)
  458. uploadedThumbnail, _ := intent.UploadBytes(thumbnail, thumbnailMime)
  459. if uploadedThumbnail != nil {
  460. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI
  461. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  462. content.Info.ThumbnailInfo = &gomatrix.FileInfo{
  463. Size: len(thumbnail),
  464. Width: cfg.Width,
  465. Height: cfg.Height,
  466. MimeType: thumbnailMime,
  467. }
  468. }
  469. }
  470. switch strings.ToLower(strings.Split(mimeType, "/")[0]) {
  471. case "image":
  472. content.MsgType = gomatrix.MsgImage
  473. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  474. content.Info.Width = cfg.Width
  475. content.Info.Height = cfg.Height
  476. case "video":
  477. content.MsgType = gomatrix.MsgVideo
  478. case "audio":
  479. content.MsgType = gomatrix.MsgAudio
  480. default:
  481. content.MsgType = gomatrix.MsgFile
  482. }
  483. intent.UserTyping(portal.MXID, false, 0)
  484. resp, err := intent.SendMassagedMessageEvent(portal.MXID, gomatrix.EventMessage, content, int64(info.Timestamp*1000))
  485. if err != nil {
  486. portal.log.Errorfln("Failed to handle message %s: %v", info.Id, err)
  487. return
  488. }
  489. portal.MarkHandled(info.Id, resp.EventID)
  490. portal.log.Debugln("Handled message", info.Id, "->", resp.EventID)
  491. }
  492. func makeMessageID() *string {
  493. b := make([]byte, 10)
  494. rand.Read(b)
  495. str := strings.ToUpper(hex.EncodeToString(b))
  496. return &str
  497. }
  498. func (portal *Portal) downloadThumbnail(evt *gomatrix.Event) []byte {
  499. if evt.Content.Info == nil || len(evt.Content.Info.ThumbnailURL) == 0 {
  500. return nil
  501. }
  502. thumbnail, err := portal.MainIntent().DownloadBytes(evt.Content.Info.ThumbnailURL)
  503. if err != nil {
  504. portal.log.Errorln("Failed to download thumbnail in %s: %v", evt.ID, err)
  505. return nil
  506. }
  507. thumbnailType := http.DetectContentType(thumbnail)
  508. var img image.Image
  509. switch thumbnailType {
  510. case "image/png":
  511. img, err = png.Decode(bytes.NewReader(thumbnail))
  512. case "image/gif":
  513. img, err = gif.Decode(bytes.NewReader(thumbnail))
  514. case "image/jpeg":
  515. return thumbnail
  516. default:
  517. return nil
  518. }
  519. var buf bytes.Buffer
  520. err = jpeg.Encode(&buf, img, &jpeg.Options{
  521. Quality: jpeg.DefaultQuality,
  522. })
  523. if err != nil {
  524. portal.log.Errorln("Failed to re-encode thumbnail in %s: %v", evt.ID, err)
  525. return nil
  526. }
  527. return buf.Bytes()
  528. }
  529. func (portal *Portal) preprocessMatrixMedia(evt *gomatrix.Event, mediaType whatsapp.MediaType) *MediaUpload {
  530. if evt.Content.Info == nil {
  531. evt.Content.Info = &gomatrix.FileInfo{}
  532. }
  533. caption := evt.Content.Body
  534. exts, err := mime.ExtensionsByType(evt.Content.Info.MimeType)
  535. for _, ext := range exts {
  536. if strings.HasSuffix(caption, ext) {
  537. caption = ""
  538. break
  539. }
  540. }
  541. content, err := portal.MainIntent().DownloadBytes(evt.Content.URL)
  542. if err != nil {
  543. portal.log.Errorln("Failed to download media in %s: %v", evt.ID, err)
  544. return nil
  545. }
  546. url, mediaKey, fileEncSHA256, fileSHA256, fileLength, err := portal.user.Conn.Upload(bytes.NewReader(content), mediaType)
  547. if err != nil {
  548. portal.log.Error("Failed to upload media in %s: %v", evt.ID, err)
  549. return nil
  550. }
  551. return &MediaUpload{
  552. Caption: caption,
  553. URL: url,
  554. MediaKey: mediaKey,
  555. FileEncSHA256: fileEncSHA256,
  556. FileSHA256: fileSHA256,
  557. FileLength: fileLength,
  558. Thumbnail: portal.downloadThumbnail(evt),
  559. }
  560. }
  561. type MediaUpload struct {
  562. Caption string
  563. URL string
  564. MediaKey []byte
  565. FileEncSHA256 []byte
  566. FileSHA256 []byte
  567. FileLength uint64
  568. Thumbnail []byte
  569. }
  570. func (portal *Portal) GetMessage(jid types.WhatsAppMessageID) *waProto.WebMessageInfo {
  571. node, err := portal.user.Conn.LoadMessagesBefore(portal.JID, jid, 1)
  572. if err != nil {
  573. return nil
  574. }
  575. msgs, ok := node.Content.([]interface{})
  576. if !ok {
  577. return nil
  578. }
  579. msg, ok := msgs[0].(*waProto.WebMessageInfo)
  580. if !ok {
  581. return nil
  582. }
  583. node, err = portal.user.Conn.LoadMessagesAfter(portal.JID, msg.GetKey().GetId(), 1)
  584. if err != nil {
  585. return nil
  586. }
  587. msgs, ok = node.Content.([]interface{})
  588. if !ok {
  589. return nil
  590. }
  591. msg, _ = msgs[0].(*waProto.WebMessageInfo)
  592. return msg
  593. }
  594. func (portal *Portal) HandleMatrixMessage(evt *gomatrix.Event) {
  595. ts := uint64(evt.Timestamp / 1000)
  596. status := waProto.WebMessageInfo_ERROR
  597. fromMe := true
  598. info := &waProto.WebMessageInfo{
  599. Key: &waProto.MessageKey{
  600. FromMe: &fromMe,
  601. Id: makeMessageID(),
  602. RemoteJid: &portal.JID,
  603. },
  604. MessageTimestamp: &ts,
  605. Message: &waProto.Message{},
  606. Status: &status,
  607. }
  608. ctxInfo := &waProto.ContextInfo{}
  609. replyToID := evt.Content.GetReplyTo()
  610. if len(replyToID) > 0 {
  611. evt.Content.RemoveReplyFallback()
  612. msg := portal.bridge.DB.Message.GetByMXID(replyToID)
  613. if msg != nil {
  614. origMsg := portal.GetMessage(msg.JID)
  615. if origMsg != nil {
  616. ctxInfo.StanzaId = &msg.JID
  617. replyMsgSender := origMsg.GetParticipant()
  618. if origMsg.GetKey().GetFromMe() {
  619. replyMsgSender = portal.user.JID()
  620. }
  621. ctxInfo.Participant = &replyMsgSender
  622. ctxInfo.QuotedMessage = []*waProto.Message{origMsg.Message}
  623. }
  624. }
  625. }
  626. var err error
  627. switch evt.Content.MsgType {
  628. case gomatrix.MsgText, gomatrix.MsgEmote:
  629. text := evt.Content.Body
  630. if evt.Content.Format == gomatrix.FormatHTML {
  631. text = portal.user.htmlParser.Parse(evt.Content.FormattedBody)
  632. }
  633. if evt.Content.MsgType == gomatrix.MsgEmote {
  634. text = "/me " + text
  635. }
  636. ctxInfo.MentionedJid = mentionRegex.FindAllString(text, -1)
  637. for index, mention := range ctxInfo.MentionedJid {
  638. ctxInfo.MentionedJid[index] = mention[1:] + whatsappExt.NewUserSuffix
  639. }
  640. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil {
  641. info.Message.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  642. Text: &text,
  643. ContextInfo: ctxInfo,
  644. }
  645. } else {
  646. info.Message.Conversation = &text
  647. }
  648. case gomatrix.MsgImage:
  649. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaImage)
  650. if media == nil {
  651. return
  652. }
  653. info.Message.ImageMessage = &waProto.ImageMessage{
  654. Caption: &media.Caption,
  655. JpegThumbnail: media.Thumbnail,
  656. Url: &media.URL,
  657. MediaKey: media.MediaKey,
  658. Mimetype: &evt.Content.GetInfo().MimeType,
  659. FileEncSha256: media.FileEncSHA256,
  660. FileSha256: media.FileSHA256,
  661. FileLength: &media.FileLength,
  662. }
  663. case gomatrix.MsgVideo:
  664. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaVideo)
  665. if media == nil {
  666. return
  667. }
  668. duration := uint32(evt.Content.GetInfo().Duration)
  669. info.Message.VideoMessage = &waProto.VideoMessage{
  670. Caption: &media.Caption,
  671. JpegThumbnail: media.Thumbnail,
  672. Url: &media.URL,
  673. MediaKey: media.MediaKey,
  674. Mimetype: &evt.Content.GetInfo().MimeType,
  675. Seconds: &duration,
  676. FileEncSha256: media.FileEncSHA256,
  677. FileSha256: media.FileSHA256,
  678. FileLength: &media.FileLength,
  679. }
  680. case gomatrix.MsgAudio:
  681. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaAudio)
  682. if media == nil {
  683. return
  684. }
  685. duration := uint32(evt.Content.GetInfo().Duration)
  686. info.Message.AudioMessage = &waProto.AudioMessage{
  687. Url: &media.URL,
  688. MediaKey: media.MediaKey,
  689. Mimetype: &evt.Content.GetInfo().MimeType,
  690. Seconds: &duration,
  691. FileEncSha256: media.FileEncSHA256,
  692. FileSha256: media.FileSHA256,
  693. FileLength: &media.FileLength,
  694. }
  695. case gomatrix.MsgFile:
  696. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaDocument)
  697. if media == nil {
  698. return
  699. }
  700. info.Message.DocumentMessage = &waProto.DocumentMessage{
  701. Url: &media.URL,
  702. MediaKey: media.MediaKey,
  703. Mimetype: &evt.Content.GetInfo().MimeType,
  704. FileEncSha256: media.FileEncSHA256,
  705. FileSha256: media.FileSHA256,
  706. FileLength: &media.FileLength,
  707. }
  708. default:
  709. portal.log.Debugln("Unhandled Matrix event:", evt)
  710. return
  711. }
  712. err = portal.user.Conn.Send(info)
  713. portal.MarkHandled(info.GetKey().GetId(), evt.ID)
  714. if err != nil {
  715. portal.log.Errorfln("Error handling Matrix event %s: %v", evt.ID, err)
  716. } else {
  717. portal.log.Debugln("Handled Matrix event:", evt)
  718. }
  719. }