portal.go 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2020 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. "html"
  23. "image"
  24. "image/gif"
  25. "image/jpeg"
  26. "image/png"
  27. "math"
  28. "math/rand"
  29. "mime"
  30. "net/http"
  31. "reflect"
  32. "strings"
  33. "sync"
  34. "time"
  35. "github.com/pkg/errors"
  36. log "maunium.net/go/maulogger/v2"
  37. "maunium.net/go/mautrix/crypto/attachment"
  38. "github.com/Rhymen/go-whatsapp"
  39. waProto "github.com/Rhymen/go-whatsapp/binary/proto"
  40. "maunium.net/go/mautrix"
  41. "maunium.net/go/mautrix/appservice"
  42. "maunium.net/go/mautrix/event"
  43. "maunium.net/go/mautrix/format"
  44. "maunium.net/go/mautrix/id"
  45. "maunium.net/go/mautrix/pushrules"
  46. "maunium.net/go/mautrix-whatsapp/database"
  47. "maunium.net/go/mautrix-whatsapp/types"
  48. "maunium.net/go/mautrix-whatsapp/whatsapp-ext"
  49. )
  50. func (bridge *Bridge) GetPortalByMXID(mxid id.RoomID) *Portal {
  51. bridge.portalsLock.Lock()
  52. defer bridge.portalsLock.Unlock()
  53. portal, ok := bridge.portalsByMXID[mxid]
  54. if !ok {
  55. return bridge.loadDBPortal(bridge.DB.Portal.GetByMXID(mxid), nil)
  56. }
  57. return portal
  58. }
  59. func (bridge *Bridge) GetPortalByJID(key database.PortalKey) *Portal {
  60. bridge.portalsLock.Lock()
  61. defer bridge.portalsLock.Unlock()
  62. portal, ok := bridge.portalsByJID[key]
  63. if !ok {
  64. return bridge.loadDBPortal(bridge.DB.Portal.GetByJID(key), &key)
  65. }
  66. return portal
  67. }
  68. func (bridge *Bridge) GetAllPortals() []*Portal {
  69. return bridge.dbPortalsToPortals(bridge.DB.Portal.GetAll())
  70. }
  71. func (bridge *Bridge) GetAllPortalsByJID(jid types.WhatsAppID) []*Portal {
  72. return bridge.dbPortalsToPortals(bridge.DB.Portal.GetAllByJID(jid))
  73. }
  74. func (bridge *Bridge) dbPortalsToPortals(dbPortals []*database.Portal) []*Portal {
  75. bridge.portalsLock.Lock()
  76. defer bridge.portalsLock.Unlock()
  77. output := make([]*Portal, len(dbPortals))
  78. for index, dbPortal := range dbPortals {
  79. if dbPortal == nil {
  80. continue
  81. }
  82. portal, ok := bridge.portalsByJID[dbPortal.Key]
  83. if !ok {
  84. portal = bridge.loadDBPortal(dbPortal, nil)
  85. }
  86. output[index] = portal
  87. }
  88. return output
  89. }
  90. func (bridge *Bridge) loadDBPortal(dbPortal *database.Portal, key *database.PortalKey) *Portal {
  91. if dbPortal == nil {
  92. if key == nil {
  93. return nil
  94. }
  95. dbPortal = bridge.DB.Portal.New()
  96. dbPortal.Key = *key
  97. dbPortal.Insert()
  98. }
  99. portal := bridge.NewPortal(dbPortal)
  100. bridge.portalsByJID[portal.Key] = portal
  101. if len(portal.MXID) > 0 {
  102. bridge.portalsByMXID[portal.MXID] = portal
  103. }
  104. return portal
  105. }
  106. func (portal *Portal) GetUsers() []*User {
  107. return nil
  108. }
  109. func (bridge *Bridge) NewPortal(dbPortal *database.Portal) *Portal {
  110. portal := &Portal{
  111. Portal: dbPortal,
  112. bridge: bridge,
  113. log: bridge.Log.Sub(fmt.Sprintf("Portal/%s", dbPortal.Key)),
  114. recentlyHandled: [recentlyHandledLength]types.WhatsAppMessageID{},
  115. messages: make(chan PortalMessage, 128),
  116. }
  117. go portal.handleMessageLoop()
  118. return portal
  119. }
  120. const recentlyHandledLength = 100
  121. type PortalMessage struct {
  122. chat string
  123. source *User
  124. data interface{}
  125. timestamp uint64
  126. }
  127. type Portal struct {
  128. *database.Portal
  129. bridge *Bridge
  130. log log.Logger
  131. roomCreateLock sync.Mutex
  132. recentlyHandled [recentlyHandledLength]types.WhatsAppMessageID
  133. recentlyHandledLock sync.Mutex
  134. recentlyHandledIndex uint8
  135. backfillLock sync.Mutex
  136. backfilling bool
  137. lastMessageTs uint64
  138. privateChatBackfillInvitePuppet func()
  139. messages chan PortalMessage
  140. isPrivate *bool
  141. hasRelaybot *bool
  142. }
  143. const MaxMessageAgeToCreatePortal = 5 * 60 // 5 minutes
  144. func (portal *Portal) handleMessageLoop() {
  145. for msg := range portal.messages {
  146. if len(portal.MXID) == 0 {
  147. if msg.timestamp+MaxMessageAgeToCreatePortal < uint64(time.Now().Unix()) {
  148. portal.log.Debugln("Not creating portal room for incoming message as the message is too old.")
  149. continue
  150. }
  151. portal.log.Debugln("Creating Matrix room from incoming message")
  152. err := portal.CreateMatrixRoom(msg.source)
  153. if err != nil {
  154. portal.log.Errorln("Failed to create portal room:", err)
  155. return
  156. }
  157. }
  158. portal.backfillLock.Lock()
  159. portal.handleMessage(msg)
  160. portal.backfillLock.Unlock()
  161. }
  162. }
  163. func (portal *Portal) handleMessage(msg PortalMessage) {
  164. if len(portal.MXID) == 0 {
  165. portal.log.Warnln("handleMessage called even though portal.MXID is empty")
  166. return
  167. }
  168. switch data := msg.data.(type) {
  169. case whatsapp.TextMessage:
  170. portal.HandleTextMessage(msg.source, data)
  171. case whatsapp.ImageMessage:
  172. portal.HandleMediaMessage(msg.source, mediaMessage{
  173. base: base{data.Download, data.Info, data.ContextInfo, data.Type},
  174. thumbnail: data.Thumbnail,
  175. caption: data.Caption,
  176. })
  177. case whatsapp.StickerMessage:
  178. portal.HandleMediaMessage(msg.source, mediaMessage{
  179. base: base{data.Download, data.Info, data.ContextInfo, data.Type},
  180. sendAsSticker: true,
  181. })
  182. case whatsapp.VideoMessage:
  183. portal.HandleMediaMessage(msg.source, mediaMessage{
  184. base: base{data.Download, data.Info, data.ContextInfo, data.Type},
  185. thumbnail: data.Thumbnail,
  186. caption: data.Caption,
  187. length: data.Length,
  188. })
  189. case whatsapp.AudioMessage:
  190. portal.HandleMediaMessage(msg.source, mediaMessage{
  191. base: base{data.Download, data.Info, data.ContextInfo, data.Type},
  192. length: data.Length,
  193. })
  194. case whatsapp.DocumentMessage:
  195. portal.HandleMediaMessage(msg.source, mediaMessage{
  196. base: base{data.Download, data.Info, data.ContextInfo, data.Type},
  197. thumbnail: data.Thumbnail,
  198. fileName: data.Title,
  199. })
  200. case whatsapp.ContactMessage:
  201. portal.HandleContactMessage(msg.source, data)
  202. case whatsapp.LocationMessage:
  203. portal.HandleLocationMessage(msg.source, data)
  204. case whatsappExt.MessageRevocation:
  205. portal.HandleMessageRevoke(msg.source, data)
  206. case FakeMessage:
  207. portal.HandleFakeMessage(msg.source, data)
  208. default:
  209. portal.log.Warnln("Unknown message type:", reflect.TypeOf(msg.data))
  210. }
  211. }
  212. func (portal *Portal) isRecentlyHandled(id types.WhatsAppMessageID) bool {
  213. start := portal.recentlyHandledIndex
  214. for i := start; i != start; i = (i - 1) % recentlyHandledLength {
  215. if portal.recentlyHandled[i] == id {
  216. return true
  217. }
  218. }
  219. return false
  220. }
  221. func (portal *Portal) isDuplicate(id types.WhatsAppMessageID) bool {
  222. msg := portal.bridge.DB.Message.GetByJID(portal.Key, id)
  223. if msg != nil {
  224. return true
  225. }
  226. return false
  227. }
  228. func init() {
  229. gob.Register(&waProto.Message{})
  230. }
  231. func (portal *Portal) markHandled(source *User, message *waProto.WebMessageInfo, mxid id.EventID) {
  232. msg := portal.bridge.DB.Message.New()
  233. msg.Chat = portal.Key
  234. msg.JID = message.GetKey().GetId()
  235. msg.MXID = mxid
  236. msg.Timestamp = message.GetMessageTimestamp()
  237. if message.GetKey().GetFromMe() {
  238. msg.Sender = source.JID
  239. } else if portal.IsPrivateChat() {
  240. msg.Sender = portal.Key.JID
  241. } else {
  242. msg.Sender = message.GetKey().GetParticipant()
  243. if len(msg.Sender) == 0 {
  244. msg.Sender = message.GetParticipant()
  245. }
  246. }
  247. msg.Content = message.Message
  248. msg.Insert()
  249. portal.recentlyHandledLock.Lock()
  250. index := portal.recentlyHandledIndex
  251. portal.recentlyHandledIndex = (portal.recentlyHandledIndex + 1) % recentlyHandledLength
  252. portal.recentlyHandledLock.Unlock()
  253. portal.recentlyHandled[index] = msg.JID
  254. }
  255. func (portal *Portal) getMessageIntent(user *User, info whatsapp.MessageInfo) *appservice.IntentAPI {
  256. if info.FromMe {
  257. return portal.bridge.GetPuppetByJID(user.JID).IntentFor(portal)
  258. } else if portal.IsPrivateChat() {
  259. return portal.MainIntent()
  260. } else if len(info.SenderJid) == 0 {
  261. if len(info.Source.GetParticipant()) != 0 {
  262. info.SenderJid = info.Source.GetParticipant()
  263. } else {
  264. return nil
  265. }
  266. }
  267. return portal.bridge.GetPuppetByJID(info.SenderJid).IntentFor(portal)
  268. }
  269. func (portal *Portal) startHandling(source *User, info whatsapp.MessageInfo) *appservice.IntentAPI {
  270. // TODO these should all be trace logs
  271. if portal.lastMessageTs > info.Timestamp+1 {
  272. portal.log.Debugfln("Not handling %s: message is older (%d) than last bridge message (%d)", info.Id, info.Timestamp, portal.lastMessageTs)
  273. } else if portal.isRecentlyHandled(info.Id) {
  274. portal.log.Debugfln("Not handling %s: message was recently handled", info.Id)
  275. } else if portal.isDuplicate(info.Id) {
  276. portal.log.Debugfln("Not handling %s: message is duplicate", info.Id)
  277. } else {
  278. portal.log.Debugfln("Starting handling of %s (ts: %d)", info.Id, info.Timestamp)
  279. portal.lastMessageTs = info.Timestamp
  280. return portal.getMessageIntent(source, info)
  281. }
  282. return nil
  283. }
  284. func (portal *Portal) finishHandling(source *User, message *waProto.WebMessageInfo, mxid id.EventID) {
  285. portal.markHandled(source, message, mxid)
  286. portal.sendDeliveryReceipt(mxid)
  287. portal.log.Debugln("Handled message", message.GetKey().GetId(), "->", mxid)
  288. }
  289. func (portal *Portal) SyncParticipants(metadata *whatsappExt.GroupInfo) {
  290. changed := false
  291. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  292. if err != nil {
  293. levels = portal.GetBasePowerLevels()
  294. changed = true
  295. }
  296. for _, participant := range metadata.Participants {
  297. user := portal.bridge.GetUserByJID(participant.JID)
  298. portal.userMXIDAction(user, portal.ensureMXIDInvited)
  299. puppet := portal.bridge.GetPuppetByJID(participant.JID)
  300. err := puppet.IntentFor(portal).EnsureJoined(portal.MXID)
  301. if err != nil {
  302. portal.log.Warnfln("Failed to make puppet of %s join %s: %v", participant.JID, portal.MXID, err)
  303. }
  304. expectedLevel := 0
  305. if participant.IsSuperAdmin {
  306. expectedLevel = 95
  307. } else if participant.IsAdmin {
  308. expectedLevel = 50
  309. }
  310. changed = levels.EnsureUserLevel(puppet.MXID, expectedLevel) || changed
  311. if user != nil {
  312. changed = levels.EnsureUserLevel(user.MXID, expectedLevel) || changed
  313. }
  314. }
  315. if changed {
  316. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  317. if err != nil {
  318. portal.log.Errorln("Failed to change power levels:", err)
  319. }
  320. }
  321. }
  322. func (portal *Portal) UpdateAvatar(user *User, avatar *whatsappExt.ProfilePicInfo, updateInfo bool) bool {
  323. if avatar == nil {
  324. var err error
  325. avatar, err = user.Conn.GetProfilePicThumb(portal.Key.JID)
  326. if err != nil {
  327. portal.log.Errorln(err)
  328. return false
  329. }
  330. }
  331. if avatar.Status != 0 {
  332. return false
  333. }
  334. if portal.Avatar == avatar.Tag {
  335. return false
  336. }
  337. data, err := avatar.DownloadBytes()
  338. if err != nil {
  339. portal.log.Warnln("Failed to download avatar:", err)
  340. return false
  341. }
  342. mimeType := http.DetectContentType(data)
  343. resp, err := portal.MainIntent().UploadBytes(data, mimeType)
  344. if err != nil {
  345. portal.log.Warnln("Failed to upload avatar:", err)
  346. return false
  347. }
  348. portal.AvatarURL = resp.ContentURI
  349. if len(portal.MXID) > 0 {
  350. _, err = portal.MainIntent().SetRoomAvatar(portal.MXID, resp.ContentURI)
  351. if err != nil {
  352. portal.log.Warnln("Failed to set room topic:", err)
  353. return false
  354. }
  355. }
  356. portal.Avatar = avatar.Tag
  357. if updateInfo {
  358. portal.UpdateBridgeInfo()
  359. }
  360. return true
  361. }
  362. func (portal *Portal) UpdateName(name string, setBy types.WhatsAppID, updateInfo bool) bool {
  363. if portal.Name != name {
  364. intent := portal.MainIntent()
  365. if len(setBy) > 0 {
  366. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  367. }
  368. _, err := intent.SetRoomName(portal.MXID, name)
  369. if err == nil {
  370. portal.Name = name
  371. if updateInfo {
  372. portal.UpdateBridgeInfo()
  373. }
  374. return true
  375. }
  376. portal.log.Warnln("Failed to set room name:", err)
  377. }
  378. return false
  379. }
  380. func (portal *Portal) UpdateTopic(topic string, setBy types.WhatsAppID, updateInfo bool) bool {
  381. if portal.Topic != topic {
  382. intent := portal.MainIntent()
  383. if len(setBy) > 0 {
  384. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  385. }
  386. _, err := intent.SetRoomTopic(portal.MXID, topic)
  387. if err == nil {
  388. portal.Topic = topic
  389. if updateInfo {
  390. portal.UpdateBridgeInfo()
  391. }
  392. return true
  393. }
  394. portal.log.Warnln("Failed to set room topic:", err)
  395. }
  396. return false
  397. }
  398. func (portal *Portal) UpdateMetadata(user *User) bool {
  399. if portal.IsPrivateChat() {
  400. return false
  401. } else if portal.IsStatusBroadcastRoom() {
  402. update := false
  403. update = portal.UpdateName("WhatsApp Status Broadcast", "", false) || update
  404. update = portal.UpdateTopic("WhatsApp status updates from your contacts", "", false) || update
  405. return update
  406. }
  407. metadata, err := user.Conn.GetGroupMetaData(portal.Key.JID)
  408. if err != nil {
  409. portal.log.Errorln(err)
  410. return false
  411. }
  412. if metadata.Status != 0 {
  413. // 401: access denied
  414. // 404: group does (no longer) exist
  415. // 500: ??? happens with status@broadcast
  416. // TODO: update the room, e.g. change priority level
  417. // to send messages to moderator
  418. return false
  419. }
  420. portal.SyncParticipants(metadata)
  421. update := false
  422. update = portal.UpdateName(metadata.Name, metadata.NameSetBy, false) || update
  423. update = portal.UpdateTopic(metadata.Topic, metadata.TopicSetBy, false) || update
  424. return update
  425. }
  426. func (portal *Portal) userMXIDAction(user *User, fn func(mxid id.UserID)) {
  427. if user == nil {
  428. return
  429. }
  430. if user == portal.bridge.Relaybot {
  431. for _, mxid := range portal.bridge.Config.Bridge.Relaybot.InviteUsers {
  432. fn(mxid)
  433. }
  434. } else {
  435. fn(user.MXID)
  436. }
  437. }
  438. func (portal *Portal) ensureMXIDInvited(mxid id.UserID) {
  439. err := portal.MainIntent().EnsureInvited(portal.MXID, mxid)
  440. if err != nil {
  441. portal.log.Warnfln("Failed to ensure %s is invited to %s: %v", mxid, portal.MXID, err)
  442. }
  443. }
  444. func (portal *Portal) ensureUserInvited(user *User) {
  445. portal.userMXIDAction(user, portal.ensureMXIDInvited)
  446. customPuppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  447. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  448. _ = customPuppet.CustomIntent().EnsureJoined(portal.MXID)
  449. }
  450. }
  451. func (portal *Portal) Sync(user *User, contact whatsapp.Contact) {
  452. portal.log.Infoln("Syncing portal for", user.MXID)
  453. if user.IsRelaybot {
  454. yes := true
  455. portal.hasRelaybot = &yes
  456. }
  457. if len(portal.MXID) == 0 {
  458. if !portal.IsPrivateChat() {
  459. portal.Name = contact.Name
  460. }
  461. err := portal.CreateMatrixRoom(user)
  462. if err != nil {
  463. portal.log.Errorln("Failed to create portal room:", err)
  464. return
  465. }
  466. } else {
  467. portal.ensureUserInvited(user)
  468. }
  469. if portal.IsPrivateChat() {
  470. return
  471. }
  472. update := false
  473. update = portal.UpdateMetadata(user) || update
  474. if !portal.IsStatusBroadcastRoom() {
  475. update = portal.UpdateAvatar(user, nil, false) || update
  476. }
  477. if update {
  478. portal.Update()
  479. portal.UpdateBridgeInfo()
  480. }
  481. }
  482. func (portal *Portal) GetBasePowerLevels() *event.PowerLevelsEventContent {
  483. anyone := 0
  484. nope := 99
  485. invite := 99
  486. if portal.bridge.Config.Bridge.AllowUserInvite {
  487. invite = 0
  488. }
  489. return &event.PowerLevelsEventContent{
  490. UsersDefault: anyone,
  491. EventsDefault: anyone,
  492. RedactPtr: &anyone,
  493. StateDefaultPtr: &nope,
  494. BanPtr: &nope,
  495. InvitePtr: &invite,
  496. Users: map[id.UserID]int{
  497. portal.MainIntent().UserID: 100,
  498. },
  499. Events: map[string]int{
  500. event.StateRoomName.Type: anyone,
  501. event.StateRoomAvatar.Type: anyone,
  502. event.StateTopic.Type: anyone,
  503. },
  504. }
  505. }
  506. func (portal *Portal) ChangeAdminStatus(jids []string, setAdmin bool) {
  507. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  508. if err != nil {
  509. levels = portal.GetBasePowerLevels()
  510. }
  511. newLevel := 0
  512. if setAdmin {
  513. newLevel = 50
  514. }
  515. changed := false
  516. for _, jid := range jids {
  517. puppet := portal.bridge.GetPuppetByJID(jid)
  518. changed = levels.EnsureUserLevel(puppet.MXID, newLevel) || changed
  519. user := portal.bridge.GetUserByJID(jid)
  520. if user != nil {
  521. changed = levels.EnsureUserLevel(user.MXID, newLevel) || changed
  522. }
  523. }
  524. if changed {
  525. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  526. if err != nil {
  527. portal.log.Errorln("Failed to change power levels:", err)
  528. }
  529. }
  530. }
  531. func (portal *Portal) RestrictMessageSending(restrict bool) {
  532. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  533. if err != nil {
  534. levels = portal.GetBasePowerLevels()
  535. }
  536. if restrict {
  537. levels.EventsDefault = 50
  538. } else {
  539. levels.EventsDefault = 0
  540. }
  541. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  542. if err != nil {
  543. portal.log.Errorln("Failed to change power levels:", err)
  544. }
  545. }
  546. func (portal *Portal) RestrictMetadataChanges(restrict bool) {
  547. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  548. if err != nil {
  549. levels = portal.GetBasePowerLevels()
  550. }
  551. newLevel := 0
  552. if restrict {
  553. newLevel = 50
  554. }
  555. changed := false
  556. changed = levels.EnsureEventLevel(event.StateRoomName, newLevel) || changed
  557. changed = levels.EnsureEventLevel(event.StateRoomAvatar, newLevel) || changed
  558. changed = levels.EnsureEventLevel(event.StateTopic, newLevel) || changed
  559. if changed {
  560. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  561. if err != nil {
  562. portal.log.Errorln("Failed to change power levels:", err)
  563. }
  564. }
  565. }
  566. func (portal *Portal) BackfillHistory(user *User, lastMessageTime uint64) error {
  567. if !portal.bridge.Config.Bridge.RecoverHistory {
  568. return nil
  569. }
  570. endBackfill := portal.beginBackfill()
  571. defer endBackfill()
  572. lastMessage := portal.bridge.DB.Message.GetLastInChat(portal.Key)
  573. if lastMessage == nil {
  574. return nil
  575. }
  576. if lastMessage.Timestamp >= lastMessageTime {
  577. portal.log.Debugln("Not backfilling: no new messages")
  578. return nil
  579. }
  580. lastMessageID := lastMessage.JID
  581. lastMessageFromMe := lastMessage.Sender == user.JID
  582. portal.log.Infoln("Backfilling history since", lastMessageID, "for", user.MXID)
  583. for len(lastMessageID) > 0 {
  584. portal.log.Debugln("Backfilling history: 50 messages after", lastMessageID)
  585. resp, err := user.Conn.LoadMessagesAfter(portal.Key.JID, lastMessageID, lastMessageFromMe, 50)
  586. if err != nil {
  587. return err
  588. }
  589. messages, ok := resp.Content.([]interface{})
  590. if !ok || len(messages) == 0 {
  591. break
  592. }
  593. portal.handleHistory(user, messages)
  594. lastMessageProto, ok := messages[len(messages)-1].(*waProto.WebMessageInfo)
  595. if ok {
  596. lastMessageID = lastMessageProto.GetKey().GetId()
  597. lastMessageFromMe = lastMessageProto.GetKey().GetFromMe()
  598. }
  599. }
  600. portal.log.Infoln("Backfilling finished")
  601. return nil
  602. }
  603. func (portal *Portal) beginBackfill() func() {
  604. portal.backfillLock.Lock()
  605. portal.backfilling = true
  606. var privateChatPuppetInvited bool
  607. var privateChatPuppet *Puppet
  608. if portal.IsPrivateChat() && portal.bridge.Config.Bridge.InviteOwnPuppetForBackfilling {
  609. privateChatPuppet = portal.bridge.GetPuppetByJID(portal.Key.Receiver)
  610. portal.privateChatBackfillInvitePuppet = func() {
  611. if privateChatPuppetInvited {
  612. return
  613. }
  614. privateChatPuppetInvited = true
  615. _, _ = portal.MainIntent().InviteUser(portal.MXID, &mautrix.ReqInviteUser{UserID: privateChatPuppet.MXID})
  616. _ = privateChatPuppet.DefaultIntent().EnsureJoined(portal.MXID)
  617. }
  618. }
  619. return func() {
  620. portal.backfilling = false
  621. portal.privateChatBackfillInvitePuppet = nil
  622. portal.backfillLock.Unlock()
  623. if privateChatPuppet != nil && privateChatPuppetInvited {
  624. _, _ = privateChatPuppet.DefaultIntent().LeaveRoom(portal.MXID)
  625. }
  626. }
  627. }
  628. func (portal *Portal) disableNotifications(user *User) {
  629. if !portal.bridge.Config.Bridge.HistoryDisableNotifs {
  630. return
  631. }
  632. puppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  633. if puppet == nil || puppet.customIntent == nil {
  634. return
  635. }
  636. portal.log.Debugfln("Disabling notifications for %s for backfilling", user.MXID)
  637. ruleID := fmt.Sprintf("net.maunium.silence_while_backfilling.%s", portal.MXID)
  638. err := puppet.customIntent.PutPushRule("global", pushrules.OverrideRule, ruleID, &mautrix.ReqPutPushRule{
  639. Actions: []pushrules.PushActionType{pushrules.ActionDontNotify},
  640. Conditions: []pushrules.PushCondition{{
  641. Kind: pushrules.KindEventMatch,
  642. Key: "room_id",
  643. Pattern: string(portal.MXID),
  644. }},
  645. })
  646. if err != nil {
  647. portal.log.Warnfln("Failed to disable notifications for %s while backfilling: %v", user.MXID, err)
  648. }
  649. }
  650. func (portal *Portal) enableNotifications(user *User) {
  651. if !portal.bridge.Config.Bridge.HistoryDisableNotifs {
  652. return
  653. }
  654. puppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  655. if puppet == nil || puppet.customIntent == nil {
  656. return
  657. }
  658. portal.log.Debugfln("Re-enabling notifications for %s after backfilling", user.MXID)
  659. ruleID := fmt.Sprintf("net.maunium.silence_while_backfilling.%s", portal.MXID)
  660. err := puppet.customIntent.DeletePushRule("global", pushrules.OverrideRule, ruleID)
  661. if err != nil {
  662. portal.log.Warnfln("Failed to re-enable notifications for %s after backfilling: %v", user.MXID, err)
  663. }
  664. }
  665. func (portal *Portal) FillInitialHistory(user *User) error {
  666. if portal.bridge.Config.Bridge.InitialHistoryFill == 0 {
  667. return nil
  668. }
  669. endBackfill := portal.beginBackfill()
  670. defer endBackfill()
  671. if portal.privateChatBackfillInvitePuppet != nil {
  672. portal.privateChatBackfillInvitePuppet()
  673. }
  674. n := portal.bridge.Config.Bridge.InitialHistoryFill
  675. portal.log.Infoln("Filling initial history, maximum", n, "messages")
  676. var messages []interface{}
  677. before := ""
  678. fromMe := true
  679. chunkNum := 1
  680. for n > 0 {
  681. count := 50
  682. if n < count {
  683. count = n
  684. }
  685. portal.log.Debugfln("Fetching chunk %d (%d messages / %d cap) before message %s", chunkNum, count, n, before)
  686. resp, err := user.Conn.LoadMessagesBefore(portal.Key.JID, before, fromMe, count)
  687. if err != nil {
  688. return err
  689. }
  690. chunk, ok := resp.Content.([]interface{})
  691. if !ok || len(chunk) == 0 {
  692. portal.log.Infoln("Chunk empty, starting handling of loaded messages")
  693. break
  694. }
  695. messages = append(chunk, messages...)
  696. portal.log.Debugfln("Fetched chunk and received %d messages", len(chunk))
  697. n -= len(chunk)
  698. key := chunk[0].(*waProto.WebMessageInfo).GetKey()
  699. before = key.GetId()
  700. fromMe = key.GetFromMe()
  701. if len(before) == 0 {
  702. portal.log.Infoln("No message ID for first message, starting handling of loaded messages")
  703. break
  704. }
  705. }
  706. portal.disableNotifications(user)
  707. portal.handleHistory(user, messages)
  708. portal.enableNotifications(user)
  709. portal.log.Infoln("Initial history fill complete")
  710. return nil
  711. }
  712. func (portal *Portal) handleHistory(user *User, messages []interface{}) {
  713. portal.log.Infoln("Handling", len(messages), "messages of history")
  714. for _, rawMessage := range messages {
  715. message, ok := rawMessage.(*waProto.WebMessageInfo)
  716. if !ok {
  717. portal.log.Warnln("Unexpected non-WebMessageInfo item in history response:", rawMessage)
  718. continue
  719. }
  720. data := whatsapp.ParseProtoMessage(message)
  721. if data == nil {
  722. portal.log.Warnln("Message", message.GetKey().GetId(), "failed to parse during backfilling")
  723. continue
  724. }
  725. if portal.privateChatBackfillInvitePuppet != nil && message.GetKey().GetFromMe() && portal.IsPrivateChat() {
  726. portal.privateChatBackfillInvitePuppet()
  727. }
  728. portal.handleMessage(PortalMessage{portal.Key.JID, user, data, message.GetMessageTimestamp()})
  729. }
  730. }
  731. type BridgeInfoSection struct {
  732. ID string `json:"id"`
  733. DisplayName string `json:"display_name,omitempty"`
  734. AvatarURL id.ContentURIString `json:"avatar_url,omitempty"`
  735. ExternalURL string `json:"external_url,omitempty"`
  736. }
  737. type BridgeInfoContent struct {
  738. BridgeBot id.UserID `json:"bridgebot"`
  739. Creator id.UserID `json:"creator,omitempty"`
  740. Protocol BridgeInfoSection `json:"protocol"`
  741. Network *BridgeInfoSection `json:"network,omitempty"`
  742. Channel BridgeInfoSection `json:"channel"`
  743. }
  744. var (
  745. StateBridgeInfo = event.Type{Type: "m.bridge", Class: event.StateEventType}
  746. StateHalfShotBridgeInfo = event.Type{Type: "uk.half-shot.bridge", Class: event.StateEventType}
  747. )
  748. func (portal *Portal) getBridgeInfo() (string, BridgeInfoContent) {
  749. bridgeInfo := BridgeInfoContent{
  750. BridgeBot: portal.bridge.Bot.UserID,
  751. Creator: portal.MainIntent().UserID,
  752. Protocol: BridgeInfoSection{
  753. ID: "whatsapp",
  754. DisplayName: "WhatsApp",
  755. AvatarURL: id.ContentURIString(portal.bridge.Config.AppService.Bot.Avatar),
  756. ExternalURL: "https://www.whatsapp.com/",
  757. },
  758. Channel: BridgeInfoSection{
  759. ID: portal.Key.JID,
  760. DisplayName: portal.Name,
  761. AvatarURL: portal.AvatarURL.CUString(),
  762. },
  763. }
  764. bridgeInfoStateKey := fmt.Sprintf("net.maunium.whatsapp://whatsapp/%s", portal.Key.JID)
  765. return bridgeInfoStateKey, bridgeInfo
  766. }
  767. func (portal *Portal) UpdateBridgeInfo() {
  768. if len(portal.MXID) == 0 {
  769. portal.log.Debugln("Not updating bridge info: no Matrix room created")
  770. return
  771. }
  772. portal.log.Debugln("Updating bridge info...")
  773. stateKey, content := portal.getBridgeInfo()
  774. _, err := portal.MainIntent().SendStateEvent(portal.MXID, StateBridgeInfo, stateKey, content)
  775. if err != nil {
  776. portal.log.Warnln("Failed to update m.bridge:", err)
  777. }
  778. _, err = portal.MainIntent().SendStateEvent(portal.MXID, StateHalfShotBridgeInfo, stateKey, content)
  779. if err != nil {
  780. portal.log.Warnln("Failed to update uk.half-shot.bridge:", err)
  781. }
  782. }
  783. func (portal *Portal) CreateMatrixRoom(user *User) error {
  784. portal.roomCreateLock.Lock()
  785. defer portal.roomCreateLock.Unlock()
  786. if len(portal.MXID) > 0 {
  787. return nil
  788. }
  789. intent := portal.MainIntent()
  790. if err := intent.EnsureRegistered(); err != nil {
  791. return err
  792. }
  793. portal.log.Infoln("Creating Matrix room. Info source:", user.MXID)
  794. var metadata *whatsappExt.GroupInfo
  795. if portal.IsPrivateChat() {
  796. puppet := portal.bridge.GetPuppetByJID(portal.Key.JID)
  797. if portal.bridge.Config.Bridge.PrivateChatPortalMeta {
  798. portal.Name = puppet.Displayname
  799. portal.AvatarURL = puppet.AvatarURL
  800. portal.Avatar = puppet.Avatar
  801. } else {
  802. portal.Name = ""
  803. }
  804. portal.Topic = "WhatsApp private chat"
  805. } else if portal.IsStatusBroadcastRoom() {
  806. portal.Name = "WhatsApp Status Broadcast"
  807. portal.Topic = "WhatsApp status updates from your contacts"
  808. } else {
  809. var err error
  810. metadata, err = user.Conn.GetGroupMetaData(portal.Key.JID)
  811. if err == nil && metadata.Status == 0 {
  812. portal.Name = metadata.Name
  813. portal.Topic = metadata.Topic
  814. }
  815. portal.UpdateAvatar(user, nil, false)
  816. }
  817. bridgeInfoStateKey, bridgeInfo := portal.getBridgeInfo()
  818. initialState := []*event.Event{{
  819. Type: event.StatePowerLevels,
  820. Content: event.Content{
  821. Parsed: portal.GetBasePowerLevels(),
  822. },
  823. }, {
  824. Type: StateBridgeInfo,
  825. Content: event.Content{Parsed: bridgeInfo},
  826. StateKey: &bridgeInfoStateKey,
  827. }, {
  828. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  829. Type: StateHalfShotBridgeInfo,
  830. Content: event.Content{Parsed: bridgeInfo},
  831. StateKey: &bridgeInfoStateKey,
  832. }}
  833. if !portal.AvatarURL.IsEmpty() {
  834. initialState = append(initialState, &event.Event{
  835. Type: event.StateRoomAvatar,
  836. Content: event.Content{
  837. Parsed: event.RoomAvatarEventContent{URL: portal.AvatarURL},
  838. },
  839. })
  840. }
  841. invite := []id.UserID{user.MXID}
  842. if user.IsRelaybot {
  843. invite = portal.bridge.Config.Bridge.Relaybot.InviteUsers
  844. }
  845. if portal.bridge.Config.Bridge.Encryption.Default {
  846. initialState = append(initialState, &event.Event{
  847. Type: event.StateEncryption,
  848. Content: event.Content{
  849. Parsed: event.EncryptionEventContent{Algorithm: id.AlgorithmMegolmV1},
  850. },
  851. })
  852. portal.Encrypted = true
  853. if portal.IsPrivateChat() {
  854. invite = append(invite, portal.bridge.Bot.UserID)
  855. }
  856. }
  857. resp, err := intent.CreateRoom(&mautrix.ReqCreateRoom{
  858. Visibility: "private",
  859. Name: portal.Name,
  860. Topic: portal.Topic,
  861. Invite: invite,
  862. Preset: "private_chat",
  863. IsDirect: portal.IsPrivateChat(),
  864. InitialState: initialState,
  865. })
  866. if err != nil {
  867. return err
  868. }
  869. portal.MXID = resp.RoomID
  870. portal.Update()
  871. portal.bridge.portalsLock.Lock()
  872. portal.bridge.portalsByMXID[portal.MXID] = portal
  873. portal.bridge.portalsLock.Unlock()
  874. // We set the memberships beforehand to make sure the encryption key exchange in initial backfill knows the users are here.
  875. for _, user := range invite {
  876. portal.bridge.StateStore.SetMembership(portal.MXID, user, event.MembershipInvite)
  877. }
  878. if metadata != nil {
  879. portal.SyncParticipants(metadata)
  880. } else {
  881. customPuppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  882. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  883. _ = customPuppet.CustomIntent().EnsureJoined(portal.MXID)
  884. }
  885. }
  886. user.addPortalToCommunity(portal)
  887. if portal.IsPrivateChat() {
  888. puppet := user.bridge.GetPuppetByJID(portal.Key.JID)
  889. user.addPuppetToCommunity(puppet)
  890. if portal.bridge.Config.Bridge.Encryption.Default {
  891. err = portal.bridge.Bot.EnsureJoined(portal.MXID)
  892. if err != nil {
  893. portal.log.Errorln("Failed to join created portal with bridge bot for e2be:", err)
  894. }
  895. }
  896. }
  897. err = portal.FillInitialHistory(user)
  898. if err != nil {
  899. portal.log.Errorln("Failed to fill history:", err)
  900. }
  901. return nil
  902. }
  903. func (portal *Portal) IsPrivateChat() bool {
  904. if portal.isPrivate == nil {
  905. val := strings.HasSuffix(portal.Key.JID, whatsappExt.NewUserSuffix)
  906. portal.isPrivate = &val
  907. }
  908. return *portal.isPrivate
  909. }
  910. func (portal *Portal) HasRelaybot() bool {
  911. if portal.bridge.Relaybot == nil {
  912. return false
  913. } else if portal.hasRelaybot == nil {
  914. val := portal.bridge.Relaybot.IsInPortal(portal.Key)
  915. portal.hasRelaybot = &val
  916. }
  917. return *portal.hasRelaybot
  918. }
  919. func (portal *Portal) IsStatusBroadcastRoom() bool {
  920. return portal.Key.JID == "status@broadcast"
  921. }
  922. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  923. if portal.IsPrivateChat() {
  924. return portal.bridge.GetPuppetByJID(portal.Key.JID).DefaultIntent()
  925. }
  926. return portal.bridge.Bot
  927. }
  928. func (portal *Portal) SetReply(content *event.MessageEventContent, info whatsapp.ContextInfo) {
  929. if len(info.QuotedMessageID) == 0 {
  930. return
  931. }
  932. message := portal.bridge.DB.Message.GetByJID(portal.Key, info.QuotedMessageID)
  933. if message != nil {
  934. evt, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  935. if err != nil {
  936. portal.log.Warnln("Failed to get reply target:", err)
  937. return
  938. }
  939. content.SetReply(evt)
  940. }
  941. return
  942. }
  943. func (portal *Portal) HandleMessageRevoke(user *User, message whatsappExt.MessageRevocation) {
  944. msg := portal.bridge.DB.Message.GetByJID(portal.Key, message.Id)
  945. if msg == nil {
  946. return
  947. }
  948. var intent *appservice.IntentAPI
  949. if message.FromMe {
  950. if portal.IsPrivateChat() {
  951. intent = portal.bridge.GetPuppetByJID(user.JID).CustomIntent()
  952. } else {
  953. intent = portal.bridge.GetPuppetByJID(user.JID).IntentFor(portal)
  954. }
  955. } else if len(message.Participant) > 0 {
  956. intent = portal.bridge.GetPuppetByJID(message.Participant).IntentFor(portal)
  957. }
  958. if intent == nil {
  959. intent = portal.MainIntent()
  960. }
  961. _, err := intent.RedactEvent(portal.MXID, msg.MXID)
  962. if err != nil {
  963. portal.log.Errorln("Failed to redact %s: %v", msg.JID, err)
  964. return
  965. }
  966. msg.Delete()
  967. }
  968. func (portal *Portal) HandleFakeMessage(source *User, message FakeMessage) {
  969. if portal.isRecentlyHandled(message.ID) {
  970. return
  971. }
  972. content := event.MessageEventContent{
  973. MsgType: event.MsgNotice,
  974. Body: message.Text,
  975. }
  976. if message.Alert {
  977. content.MsgType = event.MsgText
  978. }
  979. _, err := portal.sendMainIntentMessage(content)
  980. if err != nil {
  981. portal.log.Errorfln("Failed to handle fake message %s: %v", message.ID, err)
  982. return
  983. }
  984. portal.recentlyHandledLock.Lock()
  985. index := portal.recentlyHandledIndex
  986. portal.recentlyHandledIndex = (portal.recentlyHandledIndex + 1) % recentlyHandledLength
  987. portal.recentlyHandledLock.Unlock()
  988. portal.recentlyHandled[index] = message.ID
  989. }
  990. func (portal *Portal) sendMainIntentMessage(content interface{}) (*mautrix.RespSendEvent, error) {
  991. return portal.sendMessage(portal.MainIntent(), event.EventMessage, content, 0)
  992. }
  993. func (portal *Portal) sendMessage(intent *appservice.IntentAPI, eventType event.Type, content interface{}, timestamp int64) (*mautrix.RespSendEvent, error) {
  994. wrappedContent := event.Content{Parsed: content}
  995. if timestamp != 0 && intent.IsCustomPuppet {
  996. wrappedContent.Raw = map[string]interface{}{
  997. "net.maunium.whatsapp.puppet": intent.IsCustomPuppet,
  998. }
  999. }
  1000. if portal.Encrypted && portal.bridge.Crypto != nil {
  1001. encrypted, err := portal.bridge.Crypto.Encrypt(portal.MXID, eventType, wrappedContent)
  1002. if err != nil {
  1003. return nil, errors.Wrap(err, "failed to encrypt event")
  1004. }
  1005. eventType = event.EventEncrypted
  1006. wrappedContent.Parsed = encrypted
  1007. }
  1008. if timestamp == 0 {
  1009. return intent.SendMessageEvent(portal.MXID, eventType, &wrappedContent)
  1010. } else {
  1011. return intent.SendMassagedMessageEvent(portal.MXID, eventType, &wrappedContent, timestamp)
  1012. }
  1013. }
  1014. func (portal *Portal) HandleTextMessage(source *User, message whatsapp.TextMessage) {
  1015. intent := portal.startHandling(source, message.Info)
  1016. if intent == nil {
  1017. return
  1018. }
  1019. content := &event.MessageEventContent{
  1020. Body: message.Text,
  1021. MsgType: event.MsgText,
  1022. }
  1023. portal.bridge.Formatter.ParseWhatsApp(content)
  1024. portal.SetReply(content, message.ContextInfo)
  1025. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1026. resp, err := portal.sendMessage(intent, event.EventMessage, content, int64(message.Info.Timestamp*1000))
  1027. if err != nil {
  1028. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  1029. return
  1030. }
  1031. portal.finishHandling(source, message.Info.Source, resp.EventID)
  1032. }
  1033. func (portal *Portal) HandleLocationMessage(source *User, message whatsapp.LocationMessage) {
  1034. intent := portal.startHandling(source, message.Info)
  1035. if intent == nil {
  1036. return
  1037. }
  1038. url := message.Url
  1039. if len(url) == 0 {
  1040. url = fmt.Sprintf("https://maps.google.com/?q=%.5f,%.5f", message.DegreesLatitude, message.DegreesLongitude)
  1041. }
  1042. name := message.Name
  1043. if len(name) == 0 {
  1044. latChar := 'N'
  1045. if message.DegreesLatitude < 0 {
  1046. latChar = 'S'
  1047. }
  1048. longChar := 'E'
  1049. if message.DegreesLongitude < 0 {
  1050. longChar = 'W'
  1051. }
  1052. name = fmt.Sprintf("%.4f° %c %.4f° %c", math.Abs(message.DegreesLatitude), latChar, math.Abs(message.DegreesLongitude), longChar)
  1053. }
  1054. content := &event.MessageEventContent{
  1055. MsgType: event.MsgLocation,
  1056. Body: fmt.Sprintf("Location: %s\n%s\n%s", name, message.Address, url),
  1057. Format: event.FormatHTML,
  1058. FormattedBody: fmt.Sprintf("Location: <a href='%s'>%s</a><br>%s", url, name, message.Address),
  1059. GeoURI: fmt.Sprintf("geo:%.5f,%.5f", message.DegreesLatitude, message.DegreesLongitude),
  1060. }
  1061. if len(message.JpegThumbnail) > 0 {
  1062. thumbnailMime := http.DetectContentType(message.JpegThumbnail)
  1063. uploadedThumbnail, _ := intent.UploadBytes(message.JpegThumbnail, thumbnailMime)
  1064. if uploadedThumbnail != nil {
  1065. cfg, _, _ := image.DecodeConfig(bytes.NewReader(message.JpegThumbnail))
  1066. content.Info = &event.FileInfo{
  1067. ThumbnailInfo: &event.FileInfo{
  1068. Size: len(message.JpegThumbnail),
  1069. Width: cfg.Width,
  1070. Height: cfg.Height,
  1071. MimeType: thumbnailMime,
  1072. },
  1073. ThumbnailURL: uploadedThumbnail.ContentURI.CUString(),
  1074. }
  1075. }
  1076. }
  1077. portal.SetReply(content, message.ContextInfo)
  1078. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1079. resp, err := portal.sendMessage(intent, event.EventMessage, content, int64(message.Info.Timestamp*1000))
  1080. if err != nil {
  1081. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  1082. return
  1083. }
  1084. portal.finishHandling(source, message.Info.Source, resp.EventID)
  1085. }
  1086. func (portal *Portal) HandleContactMessage(source *User, message whatsapp.ContactMessage) {
  1087. intent := portal.startHandling(source, message.Info)
  1088. if intent == nil {
  1089. return
  1090. }
  1091. fileName := fmt.Sprintf("%s.vcf", message.DisplayName)
  1092. data := []byte(message.Vcard)
  1093. mimeType := "text/vcard"
  1094. data, uploadMimeType, file := portal.encryptFile(data, mimeType)
  1095. uploadResp, err := intent.UploadBytesWithName(data, uploadMimeType, fileName)
  1096. if err != nil {
  1097. portal.log.Errorfln("Failed to upload vcard of %s: %v", message.DisplayName, err)
  1098. return
  1099. }
  1100. content := &event.MessageEventContent{
  1101. Body: fileName,
  1102. MsgType: event.MsgFile,
  1103. File: file,
  1104. Info: &event.FileInfo{
  1105. MimeType: mimeType,
  1106. Size: len(message.Vcard),
  1107. },
  1108. }
  1109. if content.File != nil {
  1110. content.File.URL = uploadResp.ContentURI.CUString()
  1111. } else {
  1112. content.URL = uploadResp.ContentURI.CUString()
  1113. }
  1114. portal.SetReply(content, message.ContextInfo)
  1115. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1116. resp, err := portal.sendMessage(intent, event.EventMessage, content, int64(message.Info.Timestamp*1000))
  1117. if err != nil {
  1118. portal.log.Errorfln("Failed to handle message %s: %v", message.Info.Id, err)
  1119. return
  1120. }
  1121. portal.finishHandling(source, message.Info.Source, resp.EventID)
  1122. }
  1123. func (portal *Portal) sendMediaBridgeFailure(source *User, intent *appservice.IntentAPI, info whatsapp.MessageInfo, downloadErr error) {
  1124. portal.log.Errorfln("Failed to download media for %s: %v", info.Id, downloadErr)
  1125. resp, err := portal.sendMessage(intent, event.EventMessage, &event.MessageEventContent{
  1126. MsgType: event.MsgNotice,
  1127. Body: "Failed to bridge media",
  1128. }, int64(info.Timestamp*1000))
  1129. if err != nil {
  1130. portal.log.Errorfln("Failed to send media download error message for %s: %v", info.Id, err)
  1131. } else {
  1132. portal.finishHandling(source, info.Source, resp.EventID)
  1133. }
  1134. }
  1135. func (portal *Portal) encryptFile(data []byte, mimeType string) ([]byte, string, *event.EncryptedFileInfo) {
  1136. if !portal.Encrypted {
  1137. return data, mimeType, nil
  1138. }
  1139. file := &event.EncryptedFileInfo{
  1140. EncryptedFile: *attachment.NewEncryptedFile(),
  1141. URL: "",
  1142. }
  1143. return file.Encrypt(data), "application/octet-stream", file
  1144. }
  1145. type base struct {
  1146. download func() ([]byte, error)
  1147. info whatsapp.MessageInfo
  1148. context whatsapp.ContextInfo
  1149. mimeType string
  1150. }
  1151. type mediaMessage struct {
  1152. base
  1153. thumbnail []byte
  1154. caption string
  1155. fileName string
  1156. length uint32
  1157. sendAsSticker bool
  1158. }
  1159. func (portal *Portal) HandleMediaMessage(source *User, msg mediaMessage) {
  1160. intent := portal.startHandling(source, msg.info)
  1161. if intent == nil {
  1162. return
  1163. }
  1164. data, err := msg.download()
  1165. if err == whatsapp.ErrMediaDownloadFailedWith404 || err == whatsapp.ErrMediaDownloadFailedWith410 {
  1166. portal.log.Warnfln("Failed to download media for %s: %v. Calling LoadMediaInfo and retrying download...", msg.info.Id, err)
  1167. _, err = source.Conn.LoadMediaInfo(msg.info.RemoteJid, msg.info.Id, msg.info.FromMe)
  1168. if err != nil {
  1169. portal.sendMediaBridgeFailure(source, intent, msg.info, errors.Wrap(err, "failed to load media info"))
  1170. return
  1171. }
  1172. data, err = msg.download()
  1173. }
  1174. if err == whatsapp.ErrNoURLPresent {
  1175. portal.log.Debugfln("No URL present error for media message %s, ignoring...", msg.info.Id)
  1176. return
  1177. } else if err != nil {
  1178. portal.sendMediaBridgeFailure(source, intent, msg.info, err)
  1179. return
  1180. }
  1181. // synapse doesn't handle webp well, so we convert it. This can be dropped once https://github.com/matrix-org/synapse/issues/4382 is fixed
  1182. if msg.mimeType == "image/webp" {
  1183. img, err := decodeWebp(bytes.NewReader(data))
  1184. if err != nil {
  1185. portal.log.Errorfln("Failed to decode media for %s: %v", err)
  1186. return
  1187. }
  1188. var buf bytes.Buffer
  1189. err = png.Encode(&buf, img)
  1190. if err != nil {
  1191. portal.log.Errorfln("Failed to convert media for %s: %v", err)
  1192. return
  1193. }
  1194. data = buf.Bytes()
  1195. msg.mimeType = "image/png"
  1196. }
  1197. var width, height int
  1198. if strings.HasPrefix(msg.mimeType, "image/") {
  1199. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  1200. width, height = cfg.Width, cfg.Height
  1201. }
  1202. data, uploadMimeType, file := portal.encryptFile(data, msg.mimeType)
  1203. uploaded, err := intent.UploadBytes(data, uploadMimeType)
  1204. if err != nil {
  1205. portal.log.Errorfln("Failed to upload media for %s: %v", err)
  1206. return
  1207. }
  1208. if msg.fileName == "" {
  1209. msg.fileName = msg.info.Id
  1210. exts, _ := mime.ExtensionsByType(msg.mimeType)
  1211. if exts != nil && len(exts) > 0 {
  1212. msg.fileName += exts[0]
  1213. }
  1214. }
  1215. content := &event.MessageEventContent{
  1216. Body: msg.fileName,
  1217. File: file,
  1218. Info: &event.FileInfo{
  1219. Size: len(data),
  1220. MimeType: msg.mimeType,
  1221. Width: width,
  1222. Height: height,
  1223. Duration: int(msg.length),
  1224. },
  1225. }
  1226. if content.File != nil {
  1227. content.File.URL = uploaded.ContentURI.CUString()
  1228. } else {
  1229. content.URL = uploaded.ContentURI.CUString()
  1230. }
  1231. portal.SetReply(content, msg.context)
  1232. if msg.thumbnail != nil && portal.bridge.Config.Bridge.WhatsappThumbnail {
  1233. thumbnailMime := http.DetectContentType(msg.thumbnail)
  1234. thumbnailCfg, _, _ := image.DecodeConfig(bytes.NewReader(msg.thumbnail))
  1235. thumbnailSize := len(msg.thumbnail)
  1236. thumbnail, thumbnailUploadMime, thumbnailFile := portal.encryptFile(msg.thumbnail, thumbnailMime)
  1237. uploadedThumbnail, err := intent.UploadBytes(thumbnail, thumbnailUploadMime)
  1238. if err != nil {
  1239. portal.log.Warnfln("Failed to upload thumbnail for %s: %v", msg.info.Id, err)
  1240. } else if uploadedThumbnail != nil {
  1241. if thumbnailFile != nil {
  1242. thumbnailFile.URL = uploadedThumbnail.ContentURI.CUString()
  1243. content.Info.ThumbnailFile = thumbnailFile
  1244. } else {
  1245. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI.CUString()
  1246. }
  1247. content.Info.ThumbnailInfo = &event.FileInfo{
  1248. Size: thumbnailSize,
  1249. Width: thumbnailCfg.Width,
  1250. Height: thumbnailCfg.Height,
  1251. MimeType: thumbnailMime,
  1252. }
  1253. }
  1254. }
  1255. switch strings.ToLower(strings.Split(msg.mimeType, "/")[0]) {
  1256. case "image":
  1257. if !msg.sendAsSticker {
  1258. content.MsgType = event.MsgImage
  1259. }
  1260. case "video":
  1261. content.MsgType = event.MsgVideo
  1262. case "audio":
  1263. content.MsgType = event.MsgAudio
  1264. default:
  1265. content.MsgType = event.MsgFile
  1266. }
  1267. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1268. ts := int64(msg.info.Timestamp * 1000)
  1269. eventType := event.EventMessage
  1270. if msg.sendAsSticker {
  1271. eventType = event.EventSticker
  1272. }
  1273. resp, err := portal.sendMessage(intent, eventType, content, ts)
  1274. if err != nil {
  1275. portal.log.Errorfln("Failed to handle message %s: %v", msg.info.Id, err)
  1276. return
  1277. }
  1278. if len(msg.caption) > 0 {
  1279. captionContent := &event.MessageEventContent{
  1280. Body: msg.caption,
  1281. MsgType: event.MsgNotice,
  1282. }
  1283. portal.bridge.Formatter.ParseWhatsApp(captionContent)
  1284. _, err := portal.sendMessage(intent, event.EventMessage, captionContent, ts)
  1285. if err != nil {
  1286. portal.log.Warnfln("Failed to handle caption of message %s: %v", msg.info.Id, err)
  1287. }
  1288. // TODO store caption mxid?
  1289. }
  1290. portal.finishHandling(source, msg.info.Source, resp.EventID)
  1291. }
  1292. func makeMessageID() *string {
  1293. b := make([]byte, 10)
  1294. rand.Read(b)
  1295. str := strings.ToUpper(hex.EncodeToString(b))
  1296. return &str
  1297. }
  1298. func (portal *Portal) downloadThumbnail(content *event.MessageEventContent, id id.EventID) []byte {
  1299. if len(content.GetInfo().ThumbnailURL) == 0 {
  1300. return nil
  1301. }
  1302. mxc, err := content.GetInfo().ThumbnailURL.Parse()
  1303. if err != nil {
  1304. portal.log.Errorln("Malformed thumbnail URL in %s: %v", id, err)
  1305. }
  1306. thumbnail, err := portal.MainIntent().DownloadBytes(mxc)
  1307. if err != nil {
  1308. portal.log.Errorln("Failed to download thumbnail in %s: %v", id, err)
  1309. return nil
  1310. }
  1311. thumbnailType := http.DetectContentType(thumbnail)
  1312. var img image.Image
  1313. switch thumbnailType {
  1314. case "image/png":
  1315. img, err = png.Decode(bytes.NewReader(thumbnail))
  1316. case "image/gif":
  1317. img, err = gif.Decode(bytes.NewReader(thumbnail))
  1318. case "image/jpeg":
  1319. return thumbnail
  1320. default:
  1321. return nil
  1322. }
  1323. var buf bytes.Buffer
  1324. err = jpeg.Encode(&buf, img, &jpeg.Options{
  1325. Quality: jpeg.DefaultQuality,
  1326. })
  1327. if err != nil {
  1328. portal.log.Errorln("Failed to re-encode thumbnail in %s: %v", id, err)
  1329. return nil
  1330. }
  1331. return buf.Bytes()
  1332. }
  1333. func (portal *Portal) preprocessMatrixMedia(sender *User, relaybotFormatted bool, content *event.MessageEventContent, eventID id.EventID, mediaType whatsapp.MediaType) *MediaUpload {
  1334. var caption string
  1335. if relaybotFormatted {
  1336. caption = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  1337. }
  1338. var file *event.EncryptedFileInfo
  1339. rawMXC := content.URL
  1340. if content.File != nil {
  1341. file = content.File
  1342. rawMXC = file.URL
  1343. }
  1344. mxc, err := rawMXC.Parse()
  1345. if err != nil {
  1346. portal.log.Errorln("Malformed content URL in %s: %v", eventID, err)
  1347. return nil
  1348. }
  1349. data, err := portal.MainIntent().DownloadBytes(mxc)
  1350. if err != nil {
  1351. portal.log.Errorfln("Failed to download media in %s: %v", eventID, err)
  1352. return nil
  1353. }
  1354. if file != nil {
  1355. data, err = file.Decrypt(data)
  1356. if err != nil {
  1357. portal.log.Errorfln("Failed to decrypt media in %s: %v", eventID, err)
  1358. return nil
  1359. }
  1360. }
  1361. url, mediaKey, fileEncSHA256, fileSHA256, fileLength, err := sender.Conn.Upload(bytes.NewReader(data), mediaType)
  1362. if err != nil {
  1363. portal.log.Errorfln("Failed to upload media in %s: %v", eventID, err)
  1364. return nil
  1365. }
  1366. return &MediaUpload{
  1367. Caption: caption,
  1368. URL: url,
  1369. MediaKey: mediaKey,
  1370. FileEncSHA256: fileEncSHA256,
  1371. FileSHA256: fileSHA256,
  1372. FileLength: fileLength,
  1373. Thumbnail: portal.downloadThumbnail(content, eventID),
  1374. }
  1375. }
  1376. type MediaUpload struct {
  1377. Caption string
  1378. URL string
  1379. MediaKey []byte
  1380. FileEncSHA256 []byte
  1381. FileSHA256 []byte
  1382. FileLength uint64
  1383. Thumbnail []byte
  1384. }
  1385. func (portal *Portal) sendMatrixConnectionError(sender *User, eventID id.EventID) bool {
  1386. if !sender.HasSession() {
  1387. portal.log.Debugln("Ignoring event", eventID, "from", sender.MXID, "as user has no session")
  1388. return true
  1389. } else if !sender.IsConnected() {
  1390. portal.log.Debugln("Ignoring event", eventID, "from", sender.MXID, "as user is not connected")
  1391. inRoom := ""
  1392. if portal.IsPrivateChat() {
  1393. inRoom = " in your management room"
  1394. }
  1395. reconnect := fmt.Sprintf("Use `%s reconnect`%s to reconnect.", portal.bridge.Config.Bridge.CommandPrefix, inRoom)
  1396. if sender.IsLoginInProgress() {
  1397. reconnect = "You have a login attempt in progress, please wait."
  1398. }
  1399. msg := format.RenderMarkdown("\u26a0 You are not connected to WhatsApp, so your message was not bridged. "+reconnect, true, false)
  1400. msg.MsgType = event.MsgNotice
  1401. _, err := portal.sendMainIntentMessage(msg)
  1402. if err != nil {
  1403. portal.log.Errorln("Failed to send bridging failure message:", err)
  1404. }
  1405. return true
  1406. }
  1407. return false
  1408. }
  1409. func (portal *Portal) addRelaybotFormat(sender *User, content *event.MessageEventContent) bool {
  1410. member := portal.MainIntent().Member(portal.MXID, sender.MXID)
  1411. if len(member.Displayname) == 0 {
  1412. member.Displayname = string(sender.MXID)
  1413. }
  1414. if content.Format != event.FormatHTML {
  1415. content.FormattedBody = strings.Replace(html.EscapeString(content.Body), "\n", "<br/>", -1)
  1416. content.Format = event.FormatHTML
  1417. }
  1418. data, err := portal.bridge.Config.Bridge.Relaybot.FormatMessage(content, sender.MXID, member)
  1419. if err != nil {
  1420. portal.log.Errorln("Failed to apply relaybot format:", err)
  1421. }
  1422. content.FormattedBody = data
  1423. return true
  1424. }
  1425. func (portal *Portal) convertMatrixMessage(sender *User, evt *event.Event) (*waProto.WebMessageInfo, *User) {
  1426. content, ok := evt.Content.Parsed.(*event.MessageEventContent)
  1427. if !ok {
  1428. portal.log.Debugfln("Failed to handle event %s: unexpected parsed content type %T", evt.ID, evt.Content.Parsed)
  1429. return nil, sender
  1430. }
  1431. ts := uint64(evt.Timestamp / 1000)
  1432. status := waProto.WebMessageInfo_ERROR
  1433. fromMe := true
  1434. info := &waProto.WebMessageInfo{
  1435. Key: &waProto.MessageKey{
  1436. FromMe: &fromMe,
  1437. Id: makeMessageID(),
  1438. RemoteJid: &portal.Key.JID,
  1439. },
  1440. MessageTimestamp: &ts,
  1441. Message: &waProto.Message{},
  1442. Status: &status,
  1443. }
  1444. ctxInfo := &waProto.ContextInfo{}
  1445. replyToID := content.GetReplyTo()
  1446. if len(replyToID) > 0 {
  1447. content.RemoveReplyFallback()
  1448. msg := portal.bridge.DB.Message.GetByMXID(replyToID)
  1449. if msg != nil && msg.Content != nil {
  1450. ctxInfo.StanzaId = &msg.JID
  1451. ctxInfo.Participant = &msg.Sender
  1452. ctxInfo.QuotedMessage = msg.Content
  1453. }
  1454. }
  1455. relaybotFormatted := false
  1456. if sender.NeedsRelaybot(portal) {
  1457. if !portal.HasRelaybot() {
  1458. if sender.HasSession() {
  1459. portal.log.Debugln("Database says", sender.MXID, "not in chat and no relaybot, but trying to send anyway")
  1460. } else {
  1461. portal.log.Debugln("Ignoring message from", sender.MXID, "in chat with no relaybot")
  1462. return nil, sender
  1463. }
  1464. } else {
  1465. relaybotFormatted = portal.addRelaybotFormat(sender, content)
  1466. sender = portal.bridge.Relaybot
  1467. }
  1468. }
  1469. if evt.Type == event.EventSticker {
  1470. content.MsgType = event.MsgImage
  1471. }
  1472. switch content.MsgType {
  1473. case event.MsgText, event.MsgEmote, event.MsgNotice:
  1474. text := content.Body
  1475. if content.Format == event.FormatHTML {
  1476. text = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  1477. }
  1478. if content.MsgType == event.MsgEmote && !relaybotFormatted {
  1479. text = "/me " + text
  1480. }
  1481. ctxInfo.MentionedJid = mentionRegex.FindAllString(text, -1)
  1482. for index, mention := range ctxInfo.MentionedJid {
  1483. ctxInfo.MentionedJid[index] = mention[1:] + whatsappExt.NewUserSuffix
  1484. }
  1485. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil {
  1486. info.Message.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  1487. Text: &text,
  1488. ContextInfo: ctxInfo,
  1489. }
  1490. } else {
  1491. info.Message.Conversation = &text
  1492. }
  1493. case event.MsgImage:
  1494. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsapp.MediaImage)
  1495. if media == nil {
  1496. return nil, sender
  1497. }
  1498. info.Message.ImageMessage = &waProto.ImageMessage{
  1499. Caption: &media.Caption,
  1500. JpegThumbnail: media.Thumbnail,
  1501. Url: &media.URL,
  1502. MediaKey: media.MediaKey,
  1503. Mimetype: &content.GetInfo().MimeType,
  1504. FileEncSha256: media.FileEncSHA256,
  1505. FileSha256: media.FileSHA256,
  1506. FileLength: &media.FileLength,
  1507. }
  1508. case event.MsgVideo:
  1509. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsapp.MediaVideo)
  1510. if media == nil {
  1511. return nil, sender
  1512. }
  1513. duration := uint32(content.GetInfo().Duration)
  1514. info.Message.VideoMessage = &waProto.VideoMessage{
  1515. Caption: &media.Caption,
  1516. JpegThumbnail: media.Thumbnail,
  1517. Url: &media.URL,
  1518. MediaKey: media.MediaKey,
  1519. Mimetype: &content.GetInfo().MimeType,
  1520. Seconds: &duration,
  1521. FileEncSha256: media.FileEncSHA256,
  1522. FileSha256: media.FileSHA256,
  1523. FileLength: &media.FileLength,
  1524. }
  1525. case event.MsgAudio:
  1526. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsapp.MediaAudio)
  1527. if media == nil {
  1528. return nil, sender
  1529. }
  1530. duration := uint32(content.GetInfo().Duration)
  1531. info.Message.AudioMessage = &waProto.AudioMessage{
  1532. Url: &media.URL,
  1533. MediaKey: media.MediaKey,
  1534. Mimetype: &content.GetInfo().MimeType,
  1535. Seconds: &duration,
  1536. FileEncSha256: media.FileEncSHA256,
  1537. FileSha256: media.FileSHA256,
  1538. FileLength: &media.FileLength,
  1539. }
  1540. case event.MsgFile:
  1541. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsapp.MediaDocument)
  1542. if media == nil {
  1543. return nil, sender
  1544. }
  1545. info.Message.DocumentMessage = &waProto.DocumentMessage{
  1546. Url: &media.URL,
  1547. FileName: &content.Body,
  1548. MediaKey: media.MediaKey,
  1549. Mimetype: &content.GetInfo().MimeType,
  1550. FileEncSha256: media.FileEncSHA256,
  1551. FileSha256: media.FileSHA256,
  1552. FileLength: &media.FileLength,
  1553. }
  1554. default:
  1555. portal.log.Debugln("Unhandled Matrix event %s: unknown msgtype %s", evt.ID, content.MsgType)
  1556. return nil, sender
  1557. }
  1558. return info, sender
  1559. }
  1560. func (portal *Portal) wasMessageSent(sender *User, id string) bool {
  1561. _, err := sender.Conn.LoadMessagesAfter(portal.Key.JID, id, true, 0)
  1562. if err != nil {
  1563. if err != whatsapp.ErrServerRespondedWith404 {
  1564. portal.log.Warnfln("Failed to check if message was bridged without response: %v", err)
  1565. }
  1566. return false
  1567. }
  1568. return true
  1569. }
  1570. func (portal *Portal) sendErrorMessage(sendErr error) id.EventID {
  1571. resp, err := portal.sendMainIntentMessage(event.MessageEventContent{
  1572. MsgType: event.MsgNotice,
  1573. Body: fmt.Sprintf("\u26a0 Your message may not have been bridged: %v", sendErr),
  1574. })
  1575. if err != nil {
  1576. portal.log.Warnfln("Failed to send bridging error message:", err)
  1577. return ""
  1578. }
  1579. return resp.EventID
  1580. }
  1581. func (portal *Portal) sendDeliveryReceipt(eventID id.EventID) {
  1582. if portal.bridge.Config.Bridge.DeliveryReceipts {
  1583. err := portal.bridge.Bot.MarkRead(portal.MXID, eventID)
  1584. if err != nil {
  1585. portal.log.Debugfln("Failed to send delivery receipt for %s: %v", eventID, err)
  1586. }
  1587. }
  1588. }
  1589. var timeout = errors.New("message sending timed out")
  1590. func (portal *Portal) HandleMatrixMessage(sender *User, evt *event.Event) {
  1591. if !portal.HasRelaybot() && (
  1592. (portal.IsPrivateChat() && sender.JID != portal.Key.Receiver) ||
  1593. portal.sendMatrixConnectionError(sender, evt.ID)) {
  1594. return
  1595. }
  1596. portal.log.Debugfln("Received event %s", evt.ID)
  1597. info, sender := portal.convertMatrixMessage(sender, evt)
  1598. if info == nil {
  1599. return
  1600. }
  1601. portal.markHandled(sender, info, evt.ID)
  1602. portal.log.Debugln("Sending event", evt.ID, "to WhatsApp")
  1603. errChan := make(chan error, 1)
  1604. go sender.Conn.SendRaw(info, errChan)
  1605. var err error
  1606. var errorEventID id.EventID
  1607. select {
  1608. case err = <-errChan:
  1609. case <-time.After(time.Duration(portal.bridge.Config.Bridge.ConnectionTimeout) * time.Second):
  1610. if portal.bridge.Config.Bridge.FetchMessageOnTimeout && portal.wasMessageSent(sender, info.Key.GetId()) {
  1611. portal.log.Debugln("Matrix event %s was bridged, but response didn't arrive within timeout")
  1612. portal.sendDeliveryReceipt(evt.ID)
  1613. } else {
  1614. portal.log.Warnfln("Response when bridging Matrix event %s is taking long to arrive", evt.ID)
  1615. errorEventID = portal.sendErrorMessage(timeout)
  1616. }
  1617. err = <-errChan
  1618. }
  1619. if err != nil {
  1620. portal.log.Errorfln("Error handling Matrix event %s: %v", evt.ID, err)
  1621. portal.sendErrorMessage(err)
  1622. } else {
  1623. portal.log.Debugfln("Handled Matrix event %s", evt.ID)
  1624. portal.sendDeliveryReceipt(evt.ID)
  1625. }
  1626. if errorEventID != "" {
  1627. _, err = portal.MainIntent().RedactEvent(portal.MXID, errorEventID)
  1628. if err != nil {
  1629. portal.log.Warnfln("Failed to redact timeout warning message %s: %v", errorEventID, err)
  1630. }
  1631. }
  1632. }
  1633. func (portal *Portal) HandleMatrixRedaction(sender *User, evt *event.Event) {
  1634. if portal.IsPrivateChat() && sender.JID != portal.Key.Receiver {
  1635. return
  1636. }
  1637. msg := portal.bridge.DB.Message.GetByMXID(evt.Redacts)
  1638. if msg == nil || msg.Sender != sender.JID {
  1639. return
  1640. }
  1641. ts := uint64(evt.Timestamp / 1000)
  1642. status := waProto.WebMessageInfo_PENDING
  1643. protoMsgType := waProto.ProtocolMessage_REVOKE
  1644. fromMe := true
  1645. info := &waProto.WebMessageInfo{
  1646. Key: &waProto.MessageKey{
  1647. FromMe: &fromMe,
  1648. Id: makeMessageID(),
  1649. RemoteJid: &portal.Key.JID,
  1650. },
  1651. MessageTimestamp: &ts,
  1652. Message: &waProto.Message{
  1653. ProtocolMessage: &waProto.ProtocolMessage{
  1654. Type: &protoMsgType,
  1655. Key: &waProto.MessageKey{
  1656. FromMe: &fromMe,
  1657. Id: &msg.JID,
  1658. RemoteJid: &portal.Key.JID,
  1659. },
  1660. },
  1661. },
  1662. Status: &status,
  1663. }
  1664. errChan := make(chan error, 1)
  1665. go sender.Conn.SendRaw(info, errChan)
  1666. var err error
  1667. select {
  1668. case err = <-errChan:
  1669. case <-time.After(time.Duration(portal.bridge.Config.Bridge.ConnectionTimeout) * time.Second):
  1670. portal.log.Warnfln("Response when bridging Matrix redaction %s is taking long to arrive", evt.ID)
  1671. err = <-errChan
  1672. }
  1673. if err != nil {
  1674. portal.log.Errorfln("Error handling Matrix redaction %s: %v", evt.ID, err)
  1675. } else {
  1676. portal.log.Debugln("Handled Matrix redaction %s of %s", evt.ID, evt.Redacts)
  1677. portal.sendDeliveryReceipt(evt.ID)
  1678. }
  1679. }
  1680. func (portal *Portal) Delete() {
  1681. portal.Portal.Delete()
  1682. portal.bridge.portalsLock.Lock()
  1683. delete(portal.bridge.portalsByJID, portal.Key)
  1684. if len(portal.MXID) > 0 {
  1685. delete(portal.bridge.portalsByMXID, portal.MXID)
  1686. }
  1687. portal.bridge.portalsLock.Unlock()
  1688. }
  1689. func (portal *Portal) Cleanup(puppetsOnly bool) {
  1690. if len(portal.MXID) == 0 {
  1691. return
  1692. }
  1693. if portal.IsPrivateChat() {
  1694. _, err := portal.MainIntent().LeaveRoom(portal.MXID)
  1695. if err != nil {
  1696. portal.log.Warnln("Failed to leave private chat portal with main intent:", err)
  1697. }
  1698. return
  1699. }
  1700. intent := portal.MainIntent()
  1701. members, err := intent.JoinedMembers(portal.MXID)
  1702. if err != nil {
  1703. portal.log.Errorln("Failed to get portal members for cleanup:", err)
  1704. return
  1705. }
  1706. for member, _ := range members.Joined {
  1707. if member == intent.UserID {
  1708. continue
  1709. }
  1710. puppet := portal.bridge.GetPuppetByMXID(member)
  1711. if puppet != nil {
  1712. _, err = puppet.DefaultIntent().LeaveRoom(portal.MXID)
  1713. if err != nil {
  1714. portal.log.Errorln("Error leaving as puppet while cleaning up portal:", err)
  1715. }
  1716. } else if !puppetsOnly {
  1717. _, err = intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: member, Reason: "Deleting portal"})
  1718. if err != nil {
  1719. portal.log.Errorln("Error kicking user while cleaning up portal:", err)
  1720. }
  1721. }
  1722. }
  1723. _, err = intent.LeaveRoom(portal.MXID)
  1724. if err != nil {
  1725. portal.log.Errorln("Error leaving with main intent while cleaning up portal:", err)
  1726. }
  1727. }
  1728. func (portal *Portal) HandleMatrixLeave(sender *User) {
  1729. if portal.IsPrivateChat() {
  1730. portal.log.Debugln("User left private chat portal, cleaning up and deleting...")
  1731. portal.Delete()
  1732. portal.Cleanup(false)
  1733. return
  1734. }
  1735. }
  1736. func (portal *Portal) HandleMatrixKick(sender *User, event *event.Event) {
  1737. // TODO
  1738. }