portal.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788
  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. if portal.IsPrivateChat() {
  355. // TODO handle own messages in private chats properly
  356. return nil
  357. }
  358. return portal.user.GetPuppetByJID(portal.user.JID()).Intent()
  359. } else if portal.IsPrivateChat() {
  360. return portal.MainIntent()
  361. } else if len(info.SenderJid) == 0 {
  362. return nil
  363. }
  364. return portal.user.GetPuppetByJID(info.SenderJid).Intent()
  365. }
  366. func (portal *Portal) SetReply(content *gomatrix.Content, info whatsapp.MessageInfo) {
  367. if len(info.QuotedMessageID) == 0 {
  368. return
  369. }
  370. message := portal.bridge.DB.Message.GetByJID(portal.Owner, info.QuotedMessageID)
  371. if message != nil {
  372. event, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  373. if err != nil {
  374. portal.log.Warnln("Failed to get reply target:", err)
  375. return
  376. }
  377. content.SetReply(event)
  378. }
  379. return
  380. }
  381. func (portal *Portal) ParseWhatsAppFormat(input string) string {
  382. output := html.EscapeString(input)
  383. for regex, replacement := range portal.user.waReplString {
  384. output = regex.ReplaceAllString(output, replacement)
  385. }
  386. for regex, replacer := range portal.user.waReplFunc {
  387. output = regex.ReplaceAllStringFunc(output, replacer)
  388. }
  389. return output
  390. }
  391. func (portal *Portal) HandleTextMessage(message whatsapp.TextMessage) {
  392. if portal.IsDuplicate(message.Info.Id) {
  393. return
  394. }
  395. err := portal.CreateMatrixRoom()
  396. if err != nil {
  397. portal.log.Errorln("Failed to create portal room:", err)
  398. return
  399. }
  400. intent := portal.GetMessageIntent(message.Info)
  401. if intent == nil {
  402. return
  403. }
  404. content := gomatrix.Content{
  405. Body: message.Text,
  406. MsgType: gomatrix.MsgText,
  407. }
  408. htmlBody := portal.ParseWhatsAppFormat(message.Text)
  409. if htmlBody != message.Text {
  410. content.FormattedBody = htmlBody
  411. content.Format = gomatrix.FormatHTML
  412. }
  413. portal.SetReply(&content, message.Info)
  414. intent.UserTyping(portal.MXID, false, 0)
  415. resp, err := intent.SendMassagedMessageEvent(portal.MXID, gomatrix.EventMessage, content, int64(message.Info.Timestamp*1000))
  416. if err != nil {
  417. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  418. return
  419. }
  420. portal.MarkHandled(message.Info.Id, resp.EventID)
  421. portal.log.Debugln("Handled message", message.Info.Id, "->", resp.EventID)
  422. }
  423. func (portal *Portal) HandleMediaMessage(download func() ([]byte, error), thumbnail []byte, info whatsapp.MessageInfo, mimeType, caption string) {
  424. if portal.IsDuplicate(info.Id) {
  425. return
  426. }
  427. err := portal.CreateMatrixRoom()
  428. if err != nil {
  429. portal.log.Errorln("Failed to create portal room:", err)
  430. return
  431. }
  432. intent := portal.GetMessageIntent(info)
  433. if intent == nil {
  434. return
  435. }
  436. data, err := download()
  437. if err != nil {
  438. portal.log.Errorln("Failed to download media:", err)
  439. return
  440. }
  441. uploaded, err := intent.UploadBytes(data, mimeType)
  442. if err != nil {
  443. portal.log.Errorln("Failed to upload media:", err)
  444. return
  445. }
  446. if len(caption) == 0 {
  447. caption = info.Id
  448. exts, _ := mime.ExtensionsByType(mimeType)
  449. if exts != nil && len(exts) > 0 {
  450. caption += exts[0]
  451. }
  452. }
  453. content := gomatrix.Content{
  454. Body: caption,
  455. URL: uploaded.ContentURI,
  456. Info: &gomatrix.FileInfo{
  457. Size: len(data),
  458. MimeType: mimeType,
  459. },
  460. }
  461. portal.SetReply(&content, info)
  462. if thumbnail != nil {
  463. thumbnailMime := http.DetectContentType(thumbnail)
  464. uploadedThumbnail, _ := intent.UploadBytes(thumbnail, thumbnailMime)
  465. if uploadedThumbnail != nil {
  466. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI
  467. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  468. content.Info.ThumbnailInfo = &gomatrix.FileInfo{
  469. Size: len(thumbnail),
  470. Width: cfg.Width,
  471. Height: cfg.Height,
  472. MimeType: thumbnailMime,
  473. }
  474. }
  475. }
  476. switch strings.ToLower(strings.Split(mimeType, "/")[0]) {
  477. case "image":
  478. content.MsgType = gomatrix.MsgImage
  479. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  480. content.Info.Width = cfg.Width
  481. content.Info.Height = cfg.Height
  482. case "video":
  483. content.MsgType = gomatrix.MsgVideo
  484. case "audio":
  485. content.MsgType = gomatrix.MsgAudio
  486. default:
  487. content.MsgType = gomatrix.MsgFile
  488. }
  489. intent.UserTyping(portal.MXID, false, 0)
  490. resp, err := intent.SendMassagedMessageEvent(portal.MXID, gomatrix.EventMessage, content, int64(info.Timestamp*1000))
  491. if err != nil {
  492. portal.log.Errorfln("Failed to handle message %s: %v", info.Id, err)
  493. return
  494. }
  495. portal.MarkHandled(info.Id, resp.EventID)
  496. portal.log.Debugln("Handled message", info.Id, "->", resp.EventID)
  497. }
  498. func makeMessageID() *string {
  499. b := make([]byte, 10)
  500. rand.Read(b)
  501. str := strings.ToUpper(hex.EncodeToString(b))
  502. return &str
  503. }
  504. func (portal *Portal) downloadThumbnail(evt *gomatrix.Event) []byte {
  505. if evt.Content.Info == nil || len(evt.Content.Info.ThumbnailURL) == 0 {
  506. return nil
  507. }
  508. thumbnail, err := portal.MainIntent().DownloadBytes(evt.Content.Info.ThumbnailURL)
  509. if err != nil {
  510. portal.log.Errorln("Failed to download thumbnail in %s: %v", evt.ID, err)
  511. return nil
  512. }
  513. thumbnailType := http.DetectContentType(thumbnail)
  514. var img image.Image
  515. switch thumbnailType {
  516. case "image/png":
  517. img, err = png.Decode(bytes.NewReader(thumbnail))
  518. case "image/gif":
  519. img, err = gif.Decode(bytes.NewReader(thumbnail))
  520. case "image/jpeg":
  521. return thumbnail
  522. default:
  523. return nil
  524. }
  525. var buf bytes.Buffer
  526. err = jpeg.Encode(&buf, img, &jpeg.Options{
  527. Quality: jpeg.DefaultQuality,
  528. })
  529. if err != nil {
  530. portal.log.Errorln("Failed to re-encode thumbnail in %s: %v", evt.ID, err)
  531. return nil
  532. }
  533. return buf.Bytes()
  534. }
  535. func (portal *Portal) preprocessMatrixMedia(evt *gomatrix.Event, mediaType whatsapp.MediaType) *MediaUpload {
  536. if evt.Content.Info == nil {
  537. evt.Content.Info = &gomatrix.FileInfo{}
  538. }
  539. caption := evt.Content.Body
  540. exts, err := mime.ExtensionsByType(evt.Content.Info.MimeType)
  541. for _, ext := range exts {
  542. if strings.HasSuffix(caption, ext) {
  543. caption = ""
  544. break
  545. }
  546. }
  547. content, err := portal.MainIntent().DownloadBytes(evt.Content.URL)
  548. if err != nil {
  549. portal.log.Errorfln("Failed to download media in %s: %v", evt.ID, err)
  550. return nil
  551. }
  552. url, mediaKey, fileEncSHA256, fileSHA256, fileLength, err := portal.user.Conn.Upload(bytes.NewReader(content), mediaType)
  553. if err != nil {
  554. portal.log.Errorfln("Failed to upload media in %s: %v", evt.ID, err)
  555. return nil
  556. }
  557. return &MediaUpload{
  558. Caption: caption,
  559. URL: url,
  560. MediaKey: mediaKey,
  561. FileEncSHA256: fileEncSHA256,
  562. FileSHA256: fileSHA256,
  563. FileLength: fileLength,
  564. Thumbnail: portal.downloadThumbnail(evt),
  565. }
  566. }
  567. type MediaUpload struct {
  568. Caption string
  569. URL string
  570. MediaKey []byte
  571. FileEncSHA256 []byte
  572. FileSHA256 []byte
  573. FileLength uint64
  574. Thumbnail []byte
  575. }
  576. func (portal *Portal) GetMessage(jid types.WhatsAppMessageID) *waProto.WebMessageInfo {
  577. node, err := portal.user.Conn.LoadMessagesBefore(portal.JID, jid, 1)
  578. if err != nil {
  579. return nil
  580. }
  581. msgs, ok := node.Content.([]interface{})
  582. if !ok {
  583. return nil
  584. }
  585. msg, ok := msgs[0].(*waProto.WebMessageInfo)
  586. if !ok {
  587. return nil
  588. }
  589. node, err = portal.user.Conn.LoadMessagesAfter(portal.JID, msg.GetKey().GetId(), 1)
  590. if err != nil {
  591. return nil
  592. }
  593. msgs, ok = node.Content.([]interface{})
  594. if !ok {
  595. return nil
  596. }
  597. msg, _ = msgs[0].(*waProto.WebMessageInfo)
  598. return msg
  599. }
  600. func (portal *Portal) HandleMatrixMessage(evt *gomatrix.Event) {
  601. ts := uint64(evt.Timestamp / 1000)
  602. status := waProto.WebMessageInfo_ERROR
  603. fromMe := true
  604. info := &waProto.WebMessageInfo{
  605. Key: &waProto.MessageKey{
  606. FromMe: &fromMe,
  607. Id: makeMessageID(),
  608. RemoteJid: &portal.JID,
  609. },
  610. MessageTimestamp: &ts,
  611. Message: &waProto.Message{},
  612. Status: &status,
  613. }
  614. ctxInfo := &waProto.ContextInfo{}
  615. replyToID := evt.Content.GetReplyTo()
  616. if len(replyToID) > 0 {
  617. evt.Content.RemoveReplyFallback()
  618. msg := portal.bridge.DB.Message.GetByMXID(replyToID)
  619. if msg != nil {
  620. origMsg := portal.GetMessage(msg.JID)
  621. if origMsg != nil {
  622. ctxInfo.StanzaId = &msg.JID
  623. replyMsgSender := origMsg.GetParticipant()
  624. if origMsg.GetKey().GetFromMe() {
  625. replyMsgSender = portal.user.JID()
  626. }
  627. ctxInfo.Participant = &replyMsgSender
  628. ctxInfo.QuotedMessage = []*waProto.Message{origMsg.Message}
  629. }
  630. }
  631. }
  632. var err error
  633. switch evt.Content.MsgType {
  634. case gomatrix.MsgText, gomatrix.MsgEmote:
  635. text := evt.Content.Body
  636. if evt.Content.Format == gomatrix.FormatHTML {
  637. text = portal.user.htmlParser.Parse(evt.Content.FormattedBody)
  638. }
  639. if evt.Content.MsgType == gomatrix.MsgEmote {
  640. text = "/me " + text
  641. }
  642. ctxInfo.MentionedJid = mentionRegex.FindAllString(text, -1)
  643. for index, mention := range ctxInfo.MentionedJid {
  644. ctxInfo.MentionedJid[index] = mention[1:] + whatsappExt.NewUserSuffix
  645. }
  646. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil {
  647. info.Message.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  648. Text: &text,
  649. ContextInfo: ctxInfo,
  650. }
  651. } else {
  652. info.Message.Conversation = &text
  653. }
  654. case gomatrix.MsgImage:
  655. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaImage)
  656. if media == nil {
  657. return
  658. }
  659. info.Message.ImageMessage = &waProto.ImageMessage{
  660. Caption: &media.Caption,
  661. JpegThumbnail: media.Thumbnail,
  662. Url: &media.URL,
  663. MediaKey: media.MediaKey,
  664. Mimetype: &evt.Content.GetInfo().MimeType,
  665. FileEncSha256: media.FileEncSHA256,
  666. FileSha256: media.FileSHA256,
  667. FileLength: &media.FileLength,
  668. }
  669. case gomatrix.MsgVideo:
  670. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaVideo)
  671. if media == nil {
  672. return
  673. }
  674. duration := uint32(evt.Content.GetInfo().Duration)
  675. info.Message.VideoMessage = &waProto.VideoMessage{
  676. Caption: &media.Caption,
  677. JpegThumbnail: media.Thumbnail,
  678. Url: &media.URL,
  679. MediaKey: media.MediaKey,
  680. Mimetype: &evt.Content.GetInfo().MimeType,
  681. Seconds: &duration,
  682. FileEncSha256: media.FileEncSHA256,
  683. FileSha256: media.FileSHA256,
  684. FileLength: &media.FileLength,
  685. }
  686. case gomatrix.MsgAudio:
  687. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaAudio)
  688. if media == nil {
  689. return
  690. }
  691. duration := uint32(evt.Content.GetInfo().Duration)
  692. info.Message.AudioMessage = &waProto.AudioMessage{
  693. Url: &media.URL,
  694. MediaKey: media.MediaKey,
  695. Mimetype: &evt.Content.GetInfo().MimeType,
  696. Seconds: &duration,
  697. FileEncSha256: media.FileEncSHA256,
  698. FileSha256: media.FileSHA256,
  699. FileLength: &media.FileLength,
  700. }
  701. case gomatrix.MsgFile:
  702. media := portal.preprocessMatrixMedia(evt, whatsapp.MediaDocument)
  703. if media == nil {
  704. return
  705. }
  706. info.Message.DocumentMessage = &waProto.DocumentMessage{
  707. Url: &media.URL,
  708. MediaKey: media.MediaKey,
  709. Mimetype: &evt.Content.GetInfo().MimeType,
  710. FileEncSha256: media.FileEncSHA256,
  711. FileSha256: media.FileSHA256,
  712. FileLength: &media.FileLength,
  713. }
  714. default:
  715. portal.log.Debugln("Unhandled Matrix event:", evt)
  716. return
  717. }
  718. err = portal.user.Conn.Send(info)
  719. portal.MarkHandled(info.GetKey().GetId(), evt.ID)
  720. if err != nil {
  721. portal.log.Errorfln("Error handling Matrix event %s: %v", evt.ID, err)
  722. } else {
  723. portal.log.Debugln("Handled Matrix event:", evt)
  724. }
  725. }