portal.go 33 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211
  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 main
  17. import (
  18. "bytes"
  19. "encoding/gob"
  20. "encoding/hex"
  21. "fmt"
  22. "image"
  23. "image/gif"
  24. "image/jpeg"
  25. "image/png"
  26. "math/rand"
  27. "mime"
  28. "net/http"
  29. "strings"
  30. "sync"
  31. "time"
  32. "github.com/Rhymen/go-whatsapp"
  33. waProto "github.com/Rhymen/go-whatsapp/binary/proto"
  34. log "maunium.net/go/maulogger/v2"
  35. "maunium.net/go/mautrix"
  36. "maunium.net/go/mautrix-appservice"
  37. "maunium.net/go/mautrix-whatsapp/database"
  38. "maunium.net/go/mautrix-whatsapp/types"
  39. "maunium.net/go/mautrix-whatsapp/whatsapp-ext"
  40. )
  41. func (bridge *Bridge) GetPortalByMXID(mxid types.MatrixRoomID) *Portal {
  42. bridge.portalsLock.Lock()
  43. defer bridge.portalsLock.Unlock()
  44. portal, ok := bridge.portalsByMXID[mxid]
  45. if !ok {
  46. return bridge.loadDBPortal(bridge.DB.Portal.GetByMXID(mxid), nil)
  47. }
  48. return portal
  49. }
  50. func (bridge *Bridge) GetPortalByJID(key database.PortalKey) *Portal {
  51. bridge.portalsLock.Lock()
  52. defer bridge.portalsLock.Unlock()
  53. portal, ok := bridge.portalsByJID[key]
  54. if !ok {
  55. return bridge.loadDBPortal(bridge.DB.Portal.GetByJID(key), &key)
  56. }
  57. return portal
  58. }
  59. func (bridge *Bridge) GetAllPortals() []*Portal {
  60. bridge.portalsLock.Lock()
  61. defer bridge.portalsLock.Unlock()
  62. dbPortals := bridge.DB.Portal.GetAll()
  63. output := make([]*Portal, len(dbPortals))
  64. for index, dbPortal := range dbPortals {
  65. portal, ok := bridge.portalsByJID[dbPortal.Key]
  66. if !ok {
  67. portal = bridge.loadDBPortal(dbPortal, nil)
  68. }
  69. output[index] = portal
  70. }
  71. return output
  72. }
  73. func (bridge *Bridge) loadDBPortal(dbPortal *database.Portal, key *database.PortalKey) *Portal {
  74. if dbPortal == nil {
  75. if key == nil {
  76. return nil
  77. }
  78. dbPortal = bridge.DB.Portal.New()
  79. dbPortal.Key = *key
  80. dbPortal.Insert()
  81. }
  82. portal := bridge.NewPortal(dbPortal)
  83. bridge.portalsByJID[portal.Key] = portal
  84. if len(portal.MXID) > 0 {
  85. bridge.portalsByMXID[portal.MXID] = portal
  86. }
  87. return portal
  88. }
  89. func (portal *Portal) GetUsers() []*User {
  90. return nil
  91. }
  92. func (bridge *Bridge) NewPortal(dbPortal *database.Portal) *Portal {
  93. portal := &Portal{
  94. Portal: dbPortal,
  95. bridge: bridge,
  96. log: bridge.Log.Sub(fmt.Sprintf("Portal/%s", dbPortal.Key)),
  97. recentlyHandled: [recentlyHandledLength]types.WhatsAppMessageID{},
  98. messages: make(chan PortalMessage, 128),
  99. }
  100. go portal.handleMessageLoop()
  101. return portal
  102. }
  103. const recentlyHandledLength = 100
  104. type PortalMessage struct {
  105. chat string
  106. source *User
  107. data interface{}
  108. timestamp uint64
  109. }
  110. type Portal struct {
  111. *database.Portal
  112. bridge *Bridge
  113. log log.Logger
  114. avatarURL string
  115. roomCreateLock sync.Mutex
  116. recentlyHandled [recentlyHandledLength]types.WhatsAppMessageID
  117. recentlyHandledLock sync.Mutex
  118. recentlyHandledIndex uint8
  119. backfillLock sync.Mutex
  120. lastMessageTs uint64
  121. messages chan PortalMessage
  122. isPrivate *bool
  123. }
  124. const MaxMessageAgeToCreatePortal = 5 * 60 // 5 minutes
  125. func (portal *Portal) handleMessageLoop() {
  126. for msg := range portal.messages {
  127. if len(portal.MXID) == 0 {
  128. if msg.timestamp+MaxMessageAgeToCreatePortal < uint64(time.Now().Unix()) {
  129. portal.log.Debugln("Not creating portal room for incoming message as the message is too old.")
  130. continue
  131. }
  132. err := portal.CreateMatrixRoom(msg.source)
  133. if err != nil {
  134. portal.log.Errorln("Failed to create portal room:", err)
  135. return
  136. }
  137. }
  138. portal.backfillLock.Lock()
  139. portal.handleMessage(msg)
  140. portal.backfillLock.Unlock()
  141. }
  142. }
  143. func (portal *Portal) handleMessage(msg PortalMessage) {
  144. switch data := msg.data.(type) {
  145. case whatsapp.TextMessage:
  146. portal.HandleTextMessage(msg.source, data)
  147. case whatsapp.ImageMessage:
  148. portal.HandleMediaMessage(msg.source, data.Download, data.Thumbnail, data.Info, data.Type, data.Caption)
  149. case whatsapp.VideoMessage:
  150. portal.HandleMediaMessage(msg.source, data.Download, data.Thumbnail, data.Info, data.Type, data.Caption)
  151. case whatsapp.AudioMessage:
  152. portal.HandleMediaMessage(msg.source, data.Download, nil, data.Info, data.Type, "")
  153. case whatsapp.DocumentMessage:
  154. portal.HandleMediaMessage(msg.source, data.Download, data.Thumbnail, data.Info, data.Type, data.Title)
  155. case whatsappExt.MessageRevocation:
  156. portal.HandleMessageRevoke(msg.source, data)
  157. }
  158. }
  159. func (portal *Portal) isRecentlyHandled(id types.WhatsAppMessageID) bool {
  160. start := portal.recentlyHandledIndex
  161. for i := start; i != start; i = (i - 1) % recentlyHandledLength {
  162. if portal.recentlyHandled[i] == id {
  163. return true
  164. }
  165. }
  166. return false
  167. }
  168. func (portal *Portal) isDuplicate(id types.WhatsAppMessageID) bool {
  169. msg := portal.bridge.DB.Message.GetByJID(portal.Key, id)
  170. if msg != nil {
  171. return true
  172. }
  173. return false
  174. }
  175. func init() {
  176. gob.Register(&waProto.Message{})
  177. }
  178. func (portal *Portal) markHandled(source *User, message *waProto.WebMessageInfo, mxid types.MatrixEventID) {
  179. msg := portal.bridge.DB.Message.New()
  180. msg.Chat = portal.Key
  181. msg.JID = message.GetKey().GetId()
  182. msg.MXID = mxid
  183. msg.Timestamp = message.GetMessageTimestamp()
  184. if message.GetKey().GetFromMe() {
  185. msg.Sender = source.JID
  186. } else if portal.IsPrivateChat() {
  187. msg.Sender = portal.Key.JID
  188. } else {
  189. msg.Sender = message.GetKey().GetParticipant()
  190. if len(msg.Sender) == 0 {
  191. msg.Sender = message.GetParticipant()
  192. }
  193. }
  194. msg.Content = message.Message
  195. msg.Insert()
  196. portal.recentlyHandledLock.Lock()
  197. index := portal.recentlyHandledIndex
  198. portal.recentlyHandledIndex = (portal.recentlyHandledIndex + 1) % recentlyHandledLength
  199. portal.recentlyHandledLock.Unlock()
  200. portal.recentlyHandled[index] = msg.JID
  201. }
  202. func (portal *Portal) startHandling(info whatsapp.MessageInfo) bool {
  203. if portal.lastMessageTs > info.Timestamp+1 ||
  204. portal.isRecentlyHandled(info.Id) ||
  205. portal.isDuplicate(info.Id) {
  206. return false
  207. }
  208. portal.lastMessageTs = info.Timestamp
  209. return true
  210. }
  211. func (portal *Portal) finishHandling(source *User, message *waProto.WebMessageInfo, mxid types.MatrixEventID) {
  212. portal.markHandled(source, message, mxid)
  213. portal.log.Debugln("Handled message", message.GetKey().GetId(), "->", mxid)
  214. }
  215. func (portal *Portal) SyncParticipants(metadata *whatsappExt.GroupInfo) {
  216. changed := false
  217. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  218. if err != nil {
  219. levels = portal.GetBasePowerLevels()
  220. changed = true
  221. }
  222. for _, participant := range metadata.Participants {
  223. user := portal.bridge.GetUserByJID(participant.JID)
  224. if user != nil && !portal.bridge.AS.StateStore.IsInvited(portal.MXID, user.MXID) {
  225. _, err = portal.MainIntent().InviteUser(portal.MXID, &mautrix.ReqInviteUser{
  226. UserID: user.MXID,
  227. })
  228. if err != nil {
  229. portal.log.Warnfln("Failed to invite %s to %s: %v", user.MXID, portal.MXID, err)
  230. }
  231. }
  232. puppet := portal.bridge.GetPuppetByJID(participant.JID)
  233. err := puppet.IntentFor(portal).EnsureJoined(portal.MXID)
  234. if err != nil {
  235. portal.log.Warnfln("Failed to make puppet of %s join %s: %v", participant.JID, portal.MXID, err)
  236. }
  237. expectedLevel := 0
  238. if participant.IsSuperAdmin {
  239. expectedLevel = 95
  240. } else if participant.IsAdmin {
  241. expectedLevel = 50
  242. }
  243. changed = levels.EnsureUserLevel(puppet.MXID, expectedLevel) || changed
  244. if user != nil {
  245. changed = levels.EnsureUserLevel(user.MXID, expectedLevel) || changed
  246. }
  247. }
  248. if changed {
  249. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  250. if err != nil {
  251. portal.log.Errorln("Failed to change power levels:", err)
  252. }
  253. }
  254. }
  255. func (portal *Portal) UpdateAvatar(user *User, avatar *whatsappExt.ProfilePicInfo) bool {
  256. if avatar == nil {
  257. var err error
  258. avatar, err = user.Conn.GetProfilePicThumb(portal.Key.JID)
  259. if err != nil {
  260. portal.log.Errorln(err)
  261. return false
  262. }
  263. }
  264. if avatar.Status != 0 {
  265. return false
  266. }
  267. if portal.Avatar == avatar.Tag {
  268. return false
  269. }
  270. data, err := avatar.DownloadBytes()
  271. if err != nil {
  272. portal.log.Warnln("Failed to download avatar:", err)
  273. return false
  274. }
  275. mimeType := http.DetectContentType(data)
  276. resp, err := portal.MainIntent().UploadBytes(data, mimeType)
  277. if err != nil {
  278. portal.log.Warnln("Failed to upload avatar:", err)
  279. return false
  280. }
  281. portal.avatarURL = resp.ContentURI
  282. if len(portal.MXID) > 0 {
  283. _, err = portal.MainIntent().SetRoomAvatar(portal.MXID, resp.ContentURI)
  284. if err != nil {
  285. portal.log.Warnln("Failed to set room topic:", err)
  286. return false
  287. }
  288. }
  289. portal.Avatar = avatar.Tag
  290. return true
  291. }
  292. func (portal *Portal) UpdateName(name string, setBy types.WhatsAppID) bool {
  293. if portal.Name != name {
  294. intent := portal.MainIntent()
  295. if len(setBy) > 0 {
  296. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  297. }
  298. _, err := intent.SetRoomName(portal.MXID, name)
  299. if err == nil {
  300. portal.Name = name
  301. return true
  302. }
  303. portal.log.Warnln("Failed to set room name:", err)
  304. }
  305. return false
  306. }
  307. func (portal *Portal) UpdateTopic(topic string, setBy types.WhatsAppID) bool {
  308. if portal.Topic != topic {
  309. intent := portal.MainIntent()
  310. if len(setBy) > 0 {
  311. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  312. }
  313. _, err := intent.SetRoomTopic(portal.MXID, topic)
  314. if err == nil {
  315. portal.Topic = topic
  316. return true
  317. }
  318. portal.log.Warnln("Failed to set room topic:", err)
  319. }
  320. return false
  321. }
  322. func (portal *Portal) UpdateMetadata(user *User) bool {
  323. if portal.IsPrivateChat() {
  324. return false
  325. } else if portal.IsStatusBroadcastRoom() {
  326. update := false
  327. update = portal.UpdateName("WhatsApp Status Broadcast", "") || update
  328. update = portal.UpdateTopic("WhatsApp status updates from your contacts", "") || update
  329. return update
  330. }
  331. metadata, err := user.Conn.GetGroupMetaData(portal.Key.JID)
  332. if err != nil {
  333. portal.log.Errorln(err)
  334. return false
  335. }
  336. if metadata.Status != 0 {
  337. // 401: access denied
  338. // 404: group does (no longer) exist
  339. // 500: ??? happens with status@broadcast
  340. // TODO: update the room, e.g. change priority level
  341. // to send messages to moderator
  342. return false
  343. }
  344. portal.SyncParticipants(metadata)
  345. update := false
  346. update = portal.UpdateName(metadata.Name, metadata.NameSetBy) || update
  347. update = portal.UpdateTopic(metadata.Topic, metadata.TopicSetBy) || update
  348. return update
  349. }
  350. func (portal *Portal) Sync(user *User, contact whatsapp.Contact) {
  351. if portal.IsPrivateChat() {
  352. return
  353. }
  354. portal.log.Infoln("Syncing portal for", user.MXID)
  355. if len(portal.MXID) == 0 {
  356. portal.Name = contact.Name
  357. err := portal.CreateMatrixRoom(user)
  358. if err != nil {
  359. portal.log.Errorln("Failed to create portal room:", err)
  360. return
  361. }
  362. } else {
  363. err := portal.MainIntent().EnsureInvited(portal.MXID, user.MXID)
  364. if err != nil {
  365. portal.log.Warnfln("Failed to ensure %s is invited to %s: %v", user.MXID, portal.MXID, err)
  366. }
  367. }
  368. update := false
  369. update = portal.UpdateMetadata(user) || update
  370. if !portal.IsStatusBroadcastRoom() {
  371. update = portal.UpdateAvatar(user, nil) || update
  372. }
  373. if update {
  374. portal.Update()
  375. }
  376. }
  377. func (portal *Portal) GetBasePowerLevels() *mautrix.PowerLevels {
  378. anyone := 0
  379. nope := 99
  380. return &mautrix.PowerLevels{
  381. UsersDefault: anyone,
  382. EventsDefault: anyone,
  383. RedactPtr: &anyone,
  384. StateDefaultPtr: &nope,
  385. BanPtr: &nope,
  386. InvitePtr: &nope,
  387. Users: map[string]int{
  388. portal.MainIntent().UserID: 100,
  389. },
  390. Events: map[string]int{
  391. mautrix.StateRoomName.Type: anyone,
  392. mautrix.StateRoomAvatar.Type: anyone,
  393. mautrix.StateTopic.Type: anyone,
  394. },
  395. }
  396. }
  397. func (portal *Portal) ChangeAdminStatus(jids []string, setAdmin bool) {
  398. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  399. if err != nil {
  400. levels = portal.GetBasePowerLevels()
  401. }
  402. newLevel := 0
  403. if setAdmin {
  404. newLevel = 50
  405. }
  406. changed := false
  407. for _, jid := range jids {
  408. puppet := portal.bridge.GetPuppetByJID(jid)
  409. changed = levels.EnsureUserLevel(puppet.MXID, newLevel) || changed
  410. user := portal.bridge.GetUserByJID(jid)
  411. if user != nil {
  412. changed = levels.EnsureUserLevel(user.MXID, newLevel) || changed
  413. }
  414. }
  415. if changed {
  416. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  417. if err != nil {
  418. portal.log.Errorln("Failed to change power levels:", err)
  419. }
  420. }
  421. }
  422. func (portal *Portal) RestrictMessageSending(restrict bool) {
  423. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  424. if err != nil {
  425. levels = portal.GetBasePowerLevels()
  426. }
  427. if restrict {
  428. levels.EventsDefault = 50
  429. } else {
  430. levels.EventsDefault = 0
  431. }
  432. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  433. if err != nil {
  434. portal.log.Errorln("Failed to change power levels:", err)
  435. }
  436. }
  437. func (portal *Portal) RestrictMetadataChanges(restrict bool) {
  438. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  439. if err != nil {
  440. levels = portal.GetBasePowerLevels()
  441. }
  442. newLevel := 0
  443. if restrict {
  444. newLevel = 50
  445. }
  446. changed := false
  447. changed = levels.EnsureEventLevel(mautrix.StateRoomName, newLevel) || changed
  448. changed = levels.EnsureEventLevel(mautrix.StateRoomAvatar, newLevel) || changed
  449. changed = levels.EnsureEventLevel(mautrix.StateTopic, newLevel) || changed
  450. if changed {
  451. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  452. if err != nil {
  453. portal.log.Errorln("Failed to change power levels:", err)
  454. }
  455. }
  456. }
  457. func (portal *Portal) BackfillHistory(user *User, lastMessageTime uint64) error {
  458. if !portal.bridge.Config.Bridge.RecoverHistory {
  459. return nil
  460. }
  461. portal.backfillLock.Lock()
  462. defer portal.backfillLock.Unlock()
  463. lastMessage := portal.bridge.DB.Message.GetLastInChat(portal.Key)
  464. if lastMessage == nil {
  465. return nil
  466. }
  467. if lastMessage.Timestamp >= lastMessageTime {
  468. portal.log.Debugln("Not backfilling: no new messages")
  469. return nil
  470. }
  471. lastMessageID := lastMessage.JID
  472. lastMessageFromMe := lastMessage.Sender == user.JID
  473. portal.log.Infoln("Backfilling history since", lastMessageID, "for", user.MXID)
  474. for len(lastMessageID) > 0 {
  475. portal.log.Debugln("Backfilling history: 50 messages after", lastMessageID)
  476. resp, err := user.Conn.LoadMessagesAfter(portal.Key.JID, lastMessageID, lastMessageFromMe, 50)
  477. if err != nil {
  478. return err
  479. }
  480. messages, ok := resp.Content.([]interface{})
  481. if !ok || len(messages) == 0 {
  482. break
  483. }
  484. portal.handleHistory(user, messages)
  485. lastMessageProto, ok := messages[len(messages)-1].(*waProto.WebMessageInfo)
  486. if ok {
  487. lastMessageID = lastMessageProto.GetKey().GetId()
  488. lastMessageFromMe = lastMessageProto.GetKey().GetFromMe()
  489. }
  490. }
  491. portal.log.Infoln("Backfilling finished")
  492. return nil
  493. }
  494. func (portal *Portal) FillInitialHistory(user *User) error {
  495. if portal.bridge.Config.Bridge.InitialHistoryFill == 0 {
  496. return nil
  497. }
  498. portal.backfillLock.Lock()
  499. defer portal.backfillLock.Unlock()
  500. n := portal.bridge.Config.Bridge.InitialHistoryFill
  501. portal.log.Infoln("Filling initial history, maximum", n, "messages")
  502. var messages []interface{}
  503. before := ""
  504. fromMe := true
  505. chunkNum := 1
  506. for n > 0 {
  507. count := 100
  508. if n < count {
  509. count = n
  510. }
  511. portal.log.Debugfln("Fetching chunk %d (%d messages / %d cap) before message %s", chunkNum, count, n, before)
  512. resp, err := user.Conn.LoadMessagesBefore(portal.Key.JID, before, fromMe, count)
  513. if err != nil {
  514. return err
  515. }
  516. chunk, ok := resp.Content.([]interface{})
  517. if !ok {
  518. return fmt.Errorf("history response not a list")
  519. } else if len(chunk) == 0 {
  520. portal.log.Infoln("Chunk empty, starting handling of loaded messages")
  521. break
  522. }
  523. messages = append(messages, chunk...)
  524. portal.log.Debugfln("Fetched chunk and received %d messages", len(chunk))
  525. n -= len(chunk)
  526. key := chunk[0].(*waProto.WebMessageInfo).GetKey()
  527. before = key.GetId()
  528. fromMe = key.GetFromMe()
  529. if len(before) == 0 {
  530. portal.log.Infoln("No message ID for first message, starting handling of loaded messages")
  531. break
  532. }
  533. }
  534. portal.handleHistory(user, messages)
  535. return nil
  536. }
  537. func (portal *Portal) handleHistory(user *User, messages []interface{}) {
  538. portal.log.Infoln("Handling", len(messages), "messages of history")
  539. for _, rawMessage := range messages {
  540. message, ok := rawMessage.(*waProto.WebMessageInfo)
  541. if !ok {
  542. portal.log.Warnln("Unexpected non-WebMessageInfo item in history response:", rawMessage)
  543. continue
  544. }
  545. data := whatsapp.ParseProtoMessage(message)
  546. portal.handleMessage(PortalMessage{portal.Key.JID, user, data, message.GetMessageTimestamp()})
  547. }
  548. }
  549. func (portal *Portal) CreateMatrixRoom(user *User) error {
  550. portal.roomCreateLock.Lock()
  551. defer portal.roomCreateLock.Unlock()
  552. if len(portal.MXID) > 0 {
  553. return nil
  554. }
  555. intent := portal.MainIntent()
  556. if err := intent.EnsureRegistered(); err != nil {
  557. return err
  558. }
  559. portal.log.Infoln("Creating Matrix room. Info source:", user.MXID)
  560. var metadata *whatsappExt.GroupInfo
  561. isPrivateChat := false
  562. if portal.IsPrivateChat() {
  563. portal.Name = ""
  564. portal.Topic = "WhatsApp private chat"
  565. isPrivateChat = true
  566. } else if portal.IsStatusBroadcastRoom() {
  567. portal.Name = "WhatsApp Status Broadcast"
  568. portal.Topic = "WhatsApp status updates from your contacts"
  569. } else {
  570. var err error
  571. metadata, err = user.Conn.GetGroupMetaData(portal.Key.JID)
  572. if err == nil && metadata.Status == 0 {
  573. portal.Name = metadata.Name
  574. portal.Topic = metadata.Topic
  575. }
  576. portal.UpdateAvatar(user, nil)
  577. }
  578. initialState := []*mautrix.Event{{
  579. Type: mautrix.StatePowerLevels,
  580. Content: mautrix.Content{
  581. PowerLevels: portal.GetBasePowerLevels(),
  582. },
  583. }}
  584. if len(portal.avatarURL) > 0 {
  585. initialState = append(initialState, &mautrix.Event{
  586. Type: mautrix.StateRoomAvatar,
  587. Content: mautrix.Content{
  588. URL: portal.avatarURL,
  589. },
  590. })
  591. }
  592. resp, err := intent.CreateRoom(&mautrix.ReqCreateRoom{
  593. Visibility: "private",
  594. Name: portal.Name,
  595. Topic: portal.Topic,
  596. Invite: []string{user.MXID},
  597. Preset: "private_chat",
  598. IsDirect: isPrivateChat,
  599. InitialState: initialState,
  600. })
  601. if err != nil {
  602. return err
  603. }
  604. portal.MXID = resp.RoomID
  605. portal.Update()
  606. if metadata != nil {
  607. portal.SyncParticipants(metadata)
  608. }
  609. err = portal.FillInitialHistory(user)
  610. if err != nil {
  611. portal.log.Errorln("Failed to fill history:", err)
  612. }
  613. return nil
  614. }
  615. func (portal *Portal) IsPrivateChat() bool {
  616. if portal.isPrivate == nil {
  617. val := strings.HasSuffix(portal.Key.JID, whatsappExt.NewUserSuffix)
  618. portal.isPrivate = &val
  619. }
  620. return *portal.isPrivate
  621. }
  622. func (portal *Portal) IsStatusBroadcastRoom() bool {
  623. return portal.Key.JID == "status@broadcast"
  624. }
  625. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  626. if portal.IsPrivateChat() {
  627. return portal.bridge.GetPuppetByJID(portal.Key.JID).DefaultIntent()
  628. }
  629. return portal.bridge.Bot
  630. }
  631. func (portal *Portal) GetMessageIntent(user *User, info whatsapp.MessageInfo) *appservice.IntentAPI {
  632. if info.FromMe {
  633. if portal.IsPrivateChat() {
  634. return portal.bridge.GetPuppetByJID(user.JID).CustomIntent()
  635. }
  636. return portal.bridge.GetPuppetByJID(user.JID).IntentFor(portal)
  637. } else if portal.IsPrivateChat() {
  638. return portal.MainIntent()
  639. } else if len(info.SenderJid) == 0 {
  640. if len(info.Source.GetParticipant()) != 0 {
  641. info.SenderJid = info.Source.GetParticipant()
  642. } else {
  643. return nil
  644. }
  645. }
  646. return portal.bridge.GetPuppetByJID(info.SenderJid).IntentFor(portal)
  647. }
  648. func (portal *Portal) SetReply(content *mautrix.Content, info whatsapp.MessageInfo) {
  649. if len(info.QuotedMessageID) == 0 {
  650. return
  651. }
  652. message := portal.bridge.DB.Message.GetByJID(portal.Key, info.QuotedMessageID)
  653. if message != nil {
  654. event, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  655. if err != nil {
  656. portal.log.Warnln("Failed to get reply target:", err)
  657. return
  658. }
  659. event.Content.RemoveReplyFallback()
  660. content.SetReply(event)
  661. }
  662. return
  663. }
  664. func (portal *Portal) HandleMessageRevoke(user *User, message whatsappExt.MessageRevocation) {
  665. msg := portal.bridge.DB.Message.GetByJID(portal.Key, message.Id)
  666. if msg == nil {
  667. return
  668. }
  669. var intent *appservice.IntentAPI
  670. if message.FromMe {
  671. if portal.IsPrivateChat() {
  672. intent = portal.bridge.GetPuppetByJID(user.JID).CustomIntent()
  673. } else {
  674. intent = portal.bridge.GetPuppetByJID(user.JID).IntentFor(portal)
  675. }
  676. } else if len(message.Participant) > 0 {
  677. intent = portal.bridge.GetPuppetByJID(message.Participant).IntentFor(portal)
  678. }
  679. if intent == nil {
  680. intent = portal.MainIntent()
  681. }
  682. _, err := intent.RedactEvent(portal.MXID, msg.MXID)
  683. if err != nil {
  684. portal.log.Errorln("Failed to redact %s: %v", msg.JID, err)
  685. return
  686. }
  687. msg.Delete()
  688. }
  689. type MessageContent struct {
  690. *mautrix.Content
  691. IsCustomPuppet bool `json:"net.maunium.whatsapp.puppet,omitempty"`
  692. }
  693. func (portal *Portal) HandleTextMessage(source *User, message whatsapp.TextMessage) {
  694. if len(portal.MXID) == 0 {
  695. return
  696. }
  697. if !portal.startHandling(message.Info) {
  698. return
  699. }
  700. intent := portal.GetMessageIntent(source, message.Info)
  701. if intent == nil {
  702. return
  703. }
  704. content := &mautrix.Content{
  705. Body: message.Text,
  706. MsgType: mautrix.MsgText,
  707. }
  708. portal.bridge.Formatter.ParseWhatsApp(content)
  709. portal.SetReply(content, message.Info)
  710. _, _ = intent.UserTyping(portal.MXID, false, 0)
  711. resp, err := intent.SendMassagedMessageEvent(portal.MXID, mautrix.EventMessage, &MessageContent{content, intent.IsCustomPuppet}, int64(message.Info.Timestamp*1000))
  712. if err != nil {
  713. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  714. return
  715. }
  716. portal.finishHandling(source, message.Info.Source, resp.EventID)
  717. }
  718. func (portal *Portal) HandleMediaMessage(source *User, download func() ([]byte, error), thumbnail []byte, info whatsapp.MessageInfo, mimeType, caption string) {
  719. if len(portal.MXID) == 0 {
  720. return
  721. }
  722. if !portal.startHandling(info) {
  723. return
  724. }
  725. intent := portal.GetMessageIntent(source, info)
  726. if intent == nil {
  727. return
  728. }
  729. data, err := download()
  730. if err != nil {
  731. portal.log.Errorfln("Failed to download media for %s: %v", info.Id, err)
  732. return
  733. }
  734. uploaded, err := intent.UploadBytes(data, mimeType)
  735. if err != nil {
  736. portal.log.Errorfln("Failed to upload media for %s: %v", err)
  737. return
  738. }
  739. fileName := info.Id
  740. exts, _ := mime.ExtensionsByType(mimeType)
  741. if exts != nil && len(exts) > 0 {
  742. fileName += exts[0]
  743. }
  744. content := &mautrix.Content{
  745. Body: fileName,
  746. URL: uploaded.ContentURI,
  747. Info: &mautrix.FileInfo{
  748. Size: len(data),
  749. MimeType: mimeType,
  750. },
  751. }
  752. portal.SetReply(content, info)
  753. if thumbnail != nil {
  754. thumbnailMime := http.DetectContentType(thumbnail)
  755. uploadedThumbnail, _ := intent.UploadBytes(thumbnail, thumbnailMime)
  756. if uploadedThumbnail != nil {
  757. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI
  758. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  759. content.Info.ThumbnailInfo = &mautrix.FileInfo{
  760. Size: len(thumbnail),
  761. Width: cfg.Width,
  762. Height: cfg.Height,
  763. MimeType: thumbnailMime,
  764. }
  765. }
  766. }
  767. switch strings.ToLower(strings.Split(mimeType, "/")[0]) {
  768. case "image":
  769. content.MsgType = mautrix.MsgImage
  770. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  771. content.Info.Width = cfg.Width
  772. content.Info.Height = cfg.Height
  773. case "video":
  774. content.MsgType = mautrix.MsgVideo
  775. case "audio":
  776. content.MsgType = mautrix.MsgAudio
  777. default:
  778. content.MsgType = mautrix.MsgFile
  779. }
  780. _, _ = intent.UserTyping(portal.MXID, false, 0)
  781. ts := int64(info.Timestamp * 1000)
  782. resp, err := intent.SendMassagedMessageEvent(portal.MXID, mautrix.EventMessage, &MessageContent{content, intent.IsCustomPuppet}, ts)
  783. if err != nil {
  784. portal.log.Errorfln("Failed to handle message %s: %v", info.Id, err)
  785. return
  786. }
  787. if len(caption) > 0 {
  788. captionContent := &mautrix.Content{
  789. Body: caption,
  790. MsgType: mautrix.MsgNotice,
  791. }
  792. portal.bridge.Formatter.ParseWhatsApp(captionContent)
  793. _, err := intent.SendMassagedMessageEvent(portal.MXID, mautrix.EventMessage, &MessageContent{captionContent, intent.IsCustomPuppet}, ts)
  794. if err != nil {
  795. portal.log.Warnfln("Failed to handle caption of message %s: %v", info.Id, err)
  796. }
  797. // TODO store caption mxid?
  798. }
  799. portal.finishHandling(source, info.Source, resp.EventID)
  800. }
  801. func makeMessageID() *string {
  802. b := make([]byte, 10)
  803. rand.Read(b)
  804. str := strings.ToUpper(hex.EncodeToString(b))
  805. return &str
  806. }
  807. func (portal *Portal) downloadThumbnail(evt *mautrix.Event) []byte {
  808. if evt.Content.Info == nil || len(evt.Content.Info.ThumbnailURL) == 0 {
  809. return nil
  810. }
  811. thumbnail, err := portal.MainIntent().DownloadBytes(evt.Content.Info.ThumbnailURL)
  812. if err != nil {
  813. portal.log.Errorln("Failed to download thumbnail in %s: %v", evt.ID, err)
  814. return nil
  815. }
  816. thumbnailType := http.DetectContentType(thumbnail)
  817. var img image.Image
  818. switch thumbnailType {
  819. case "image/png":
  820. img, err = png.Decode(bytes.NewReader(thumbnail))
  821. case "image/gif":
  822. img, err = gif.Decode(bytes.NewReader(thumbnail))
  823. case "image/jpeg":
  824. return thumbnail
  825. default:
  826. return nil
  827. }
  828. var buf bytes.Buffer
  829. err = jpeg.Encode(&buf, img, &jpeg.Options{
  830. Quality: jpeg.DefaultQuality,
  831. })
  832. if err != nil {
  833. portal.log.Errorln("Failed to re-encode thumbnail in %s: %v", evt.ID, err)
  834. return nil
  835. }
  836. return buf.Bytes()
  837. }
  838. func (portal *Portal) preprocessMatrixMedia(sender *User, evt *mautrix.Event, mediaType whatsapp.MediaType) *MediaUpload {
  839. if evt.Content.Info == nil {
  840. evt.Content.Info = &mautrix.FileInfo{}
  841. }
  842. caption := evt.Content.Body
  843. exts, err := mime.ExtensionsByType(evt.Content.Info.MimeType)
  844. for _, ext := range exts {
  845. if strings.HasSuffix(caption, ext) {
  846. caption = ""
  847. break
  848. }
  849. }
  850. content, err := portal.MainIntent().DownloadBytes(evt.Content.URL)
  851. if err != nil {
  852. portal.log.Errorfln("Failed to download media in %s: %v", evt.ID, err)
  853. return nil
  854. }
  855. url, mediaKey, fileEncSHA256, fileSHA256, fileLength, err := sender.Conn.Upload(bytes.NewReader(content), mediaType)
  856. if err != nil {
  857. portal.log.Errorfln("Failed to upload media in %s: %v", evt.ID, err)
  858. return nil
  859. }
  860. return &MediaUpload{
  861. Caption: caption,
  862. URL: url,
  863. MediaKey: mediaKey,
  864. FileEncSHA256: fileEncSHA256,
  865. FileSHA256: fileSHA256,
  866. FileLength: fileLength,
  867. Thumbnail: portal.downloadThumbnail(evt),
  868. }
  869. }
  870. type MediaUpload struct {
  871. Caption string
  872. URL string
  873. MediaKey []byte
  874. FileEncSHA256 []byte
  875. FileSHA256 []byte
  876. FileLength uint64
  877. Thumbnail []byte
  878. }
  879. func (portal *Portal) HandleMatrixMessage(sender *User, evt *mautrix.Event) {
  880. if portal.IsPrivateChat() && sender.JID != portal.Key.Receiver {
  881. return
  882. }
  883. portal.log.Debugfln("Received event %s", evt.ID)
  884. ts := uint64(evt.Timestamp / 1000)
  885. status := waProto.WebMessageInfo_ERROR
  886. fromMe := true
  887. info := &waProto.WebMessageInfo{
  888. Key: &waProto.MessageKey{
  889. FromMe: &fromMe,
  890. Id: makeMessageID(),
  891. RemoteJid: &portal.Key.JID,
  892. },
  893. MessageTimestamp: &ts,
  894. Message: &waProto.Message{},
  895. Status: &status,
  896. }
  897. ctxInfo := &waProto.ContextInfo{}
  898. replyToID := evt.Content.GetReplyTo()
  899. if len(replyToID) > 0 {
  900. evt.Content.RemoveReplyFallback()
  901. msg := portal.bridge.DB.Message.GetByMXID(replyToID)
  902. if msg != nil && msg.Content != nil {
  903. ctxInfo.StanzaId = &msg.JID
  904. ctxInfo.Participant = &msg.Sender
  905. ctxInfo.QuotedMessage = msg.Content
  906. }
  907. }
  908. var err error
  909. switch evt.Content.MsgType {
  910. case mautrix.MsgText, mautrix.MsgEmote:
  911. text := evt.Content.Body
  912. if evt.Content.Format == mautrix.FormatHTML {
  913. text = portal.bridge.Formatter.ParseMatrix(evt.Content.FormattedBody)
  914. }
  915. if evt.Content.MsgType == mautrix.MsgEmote {
  916. text = "/me " + text
  917. }
  918. ctxInfo.MentionedJid = mentionRegex.FindAllString(text, -1)
  919. for index, mention := range ctxInfo.MentionedJid {
  920. ctxInfo.MentionedJid[index] = mention[1:] + whatsappExt.NewUserSuffix
  921. }
  922. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil {
  923. info.Message.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  924. Text: &text,
  925. ContextInfo: ctxInfo,
  926. }
  927. } else {
  928. info.Message.Conversation = &text
  929. }
  930. case mautrix.MsgImage:
  931. media := portal.preprocessMatrixMedia(sender, evt, whatsapp.MediaImage)
  932. if media == nil {
  933. return
  934. }
  935. info.Message.ImageMessage = &waProto.ImageMessage{
  936. Caption: &media.Caption,
  937. JpegThumbnail: media.Thumbnail,
  938. Url: &media.URL,
  939. MediaKey: media.MediaKey,
  940. Mimetype: &evt.Content.GetInfo().MimeType,
  941. FileEncSha256: media.FileEncSHA256,
  942. FileSha256: media.FileSHA256,
  943. FileLength: &media.FileLength,
  944. }
  945. case mautrix.MsgVideo:
  946. media := portal.preprocessMatrixMedia(sender, evt, whatsapp.MediaVideo)
  947. if media == nil {
  948. return
  949. }
  950. duration := uint32(evt.Content.GetInfo().Duration)
  951. info.Message.VideoMessage = &waProto.VideoMessage{
  952. Caption: &media.Caption,
  953. JpegThumbnail: media.Thumbnail,
  954. Url: &media.URL,
  955. MediaKey: media.MediaKey,
  956. Mimetype: &evt.Content.GetInfo().MimeType,
  957. Seconds: &duration,
  958. FileEncSha256: media.FileEncSHA256,
  959. FileSha256: media.FileSHA256,
  960. FileLength: &media.FileLength,
  961. }
  962. case mautrix.MsgAudio:
  963. media := portal.preprocessMatrixMedia(sender, evt, whatsapp.MediaAudio)
  964. if media == nil {
  965. return
  966. }
  967. duration := uint32(evt.Content.GetInfo().Duration)
  968. info.Message.AudioMessage = &waProto.AudioMessage{
  969. Url: &media.URL,
  970. MediaKey: media.MediaKey,
  971. Mimetype: &evt.Content.GetInfo().MimeType,
  972. Seconds: &duration,
  973. FileEncSha256: media.FileEncSHA256,
  974. FileSha256: media.FileSHA256,
  975. FileLength: &media.FileLength,
  976. }
  977. case mautrix.MsgFile:
  978. media := portal.preprocessMatrixMedia(sender, evt, whatsapp.MediaDocument)
  979. if media == nil {
  980. return
  981. }
  982. info.Message.DocumentMessage = &waProto.DocumentMessage{
  983. Url: &media.URL,
  984. MediaKey: media.MediaKey,
  985. Mimetype: &evt.Content.GetInfo().MimeType,
  986. FileEncSha256: media.FileEncSHA256,
  987. FileSha256: media.FileSHA256,
  988. FileLength: &media.FileLength,
  989. }
  990. default:
  991. portal.log.Debugln("Unhandled Matrix event:", evt)
  992. return
  993. }
  994. portal.markHandled(sender, info, evt.ID)
  995. portal.log.Debugln("Sending event", evt.ID, "to WhatsApp")
  996. _, err = sender.Conn.Send(info)
  997. if err != nil {
  998. portal.log.Errorfln("Error handling Matrix event %s: %v", evt.ID, err)
  999. } else {
  1000. portal.log.Debugln("Handled Matrix event:", evt)
  1001. }
  1002. }
  1003. func (portal *Portal) HandleMatrixRedaction(sender *User, evt *mautrix.Event) {
  1004. if portal.IsPrivateChat() && sender.JID != portal.Key.Receiver {
  1005. return
  1006. }
  1007. msg := portal.bridge.DB.Message.GetByMXID(evt.Redacts)
  1008. if msg.Sender != sender.JID {
  1009. return
  1010. }
  1011. ts := uint64(evt.Timestamp / 1000)
  1012. status := waProto.WebMessageInfo_PENDING
  1013. protoMsgType := waProto.ProtocolMessage_REVOKE
  1014. fromMe := true
  1015. info := &waProto.WebMessageInfo{
  1016. Key: &waProto.MessageKey{
  1017. FromMe: &fromMe,
  1018. Id: makeMessageID(),
  1019. RemoteJid: &portal.Key.JID,
  1020. },
  1021. MessageTimestamp: &ts,
  1022. Message: &waProto.Message{
  1023. ProtocolMessage: &waProto.ProtocolMessage{
  1024. Type: &protoMsgType,
  1025. Key: &waProto.MessageKey{
  1026. FromMe: &fromMe,
  1027. Id: &msg.JID,
  1028. RemoteJid: &portal.Key.JID,
  1029. },
  1030. },
  1031. },
  1032. Status: &status,
  1033. }
  1034. _, err := sender.Conn.Send(info)
  1035. if err != nil {
  1036. portal.log.Errorfln("Error handling Matrix redaction: %s: %v", evt.ID, err)
  1037. } else {
  1038. portal.log.Debugln("Handled Matrix redaction:", evt)
  1039. }
  1040. }
  1041. func (portal *Portal) Delete() {
  1042. portal.Portal.Delete()
  1043. delete(portal.bridge.portalsByJID, portal.Key)
  1044. if len(portal.MXID) > 0 {
  1045. delete(portal.bridge.portalsByMXID, portal.MXID)
  1046. }
  1047. }
  1048. func (portal *Portal) Cleanup(puppetsOnly bool) {
  1049. if len(portal.MXID) == 0 {
  1050. return
  1051. }
  1052. if portal.IsPrivateChat() {
  1053. _, err := portal.MainIntent().LeaveRoom(portal.MXID)
  1054. if err != nil {
  1055. portal.log.Warnln("Failed to leave private chat portal with main intent:", err)
  1056. }
  1057. return
  1058. }
  1059. intent := portal.MainIntent()
  1060. members, err := intent.JoinedMembers(portal.MXID)
  1061. if err != nil {
  1062. portal.log.Errorln("Failed to get portal members for cleanup:", err)
  1063. return
  1064. }
  1065. for member, _ := range members.Joined {
  1066. if member == intent.UserID {
  1067. continue
  1068. }
  1069. puppet := portal.bridge.GetPuppetByMXID(member)
  1070. if puppet != nil {
  1071. _, err = puppet.DefaultIntent().LeaveRoom(portal.MXID)
  1072. if err != nil {
  1073. portal.log.Errorln("Error leaving as puppet while cleaning up portal:", err)
  1074. }
  1075. } else if !puppetsOnly {
  1076. _, err = intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: member, Reason: "Deleting portal"})
  1077. if err != nil {
  1078. portal.log.Errorln("Error kicking user while cleaning up portal:", err)
  1079. }
  1080. }
  1081. }
  1082. _, err = intent.LeaveRoom(portal.MXID)
  1083. if err != nil {
  1084. portal.log.Errorln("Error leaving with main intent while cleaning up portal:", err)
  1085. }
  1086. }
  1087. func (portal *Portal) HandleMatrixLeave(sender *User) {
  1088. if portal.IsPrivateChat() {
  1089. portal.log.Debugln("User left private chat portal, cleaning up and deleting...")
  1090. portal.Delete()
  1091. portal.Cleanup(false)
  1092. return
  1093. }
  1094. }
  1095. func (portal *Portal) HandleMatrixKick(sender *User, event *mautrix.Event) {
  1096. // TODO
  1097. }