portal.go 98 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2021 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. "context"
  20. "encoding/gob"
  21. "encoding/json"
  22. "errors"
  23. "fmt"
  24. "html"
  25. "image"
  26. _ "image/gif"
  27. "image/jpeg"
  28. "image/png"
  29. "math"
  30. "mime"
  31. "net/http"
  32. "strconv"
  33. "strings"
  34. "sync"
  35. "time"
  36. "github.com/tidwall/gjson"
  37. "golang.org/x/image/draw"
  38. "golang.org/x/image/webp"
  39. "google.golang.org/protobuf/proto"
  40. log "maunium.net/go/maulogger/v2"
  41. "maunium.net/go/mautrix"
  42. "maunium.net/go/mautrix/appservice"
  43. "maunium.net/go/mautrix/crypto/attachment"
  44. "maunium.net/go/mautrix/event"
  45. "maunium.net/go/mautrix/format"
  46. "maunium.net/go/mautrix/id"
  47. "maunium.net/go/mautrix/util"
  48. "maunium.net/go/mautrix/util/ffmpeg"
  49. "go.mau.fi/whatsmeow"
  50. waProto "go.mau.fi/whatsmeow/binary/proto"
  51. "go.mau.fi/whatsmeow/types"
  52. "go.mau.fi/whatsmeow/types/events"
  53. "maunium.net/go/mautrix-whatsapp/database"
  54. )
  55. const StatusBroadcastTopic = "WhatsApp status updates from your contacts"
  56. const StatusBroadcastName = "WhatsApp Status Broadcast"
  57. const BroadcastTopic = "WhatsApp broadcast list"
  58. const UnnamedBroadcastName = "Unnamed broadcast list"
  59. const PrivateChatTopic = "WhatsApp private chat"
  60. var ErrStatusBroadcastDisabled = errors.New("status bridging is disabled")
  61. func (bridge *Bridge) GetPortalByMXID(mxid id.RoomID) *Portal {
  62. bridge.portalsLock.Lock()
  63. defer bridge.portalsLock.Unlock()
  64. portal, ok := bridge.portalsByMXID[mxid]
  65. if !ok {
  66. return bridge.loadDBPortal(bridge.DB.Portal.GetByMXID(mxid), nil)
  67. }
  68. return portal
  69. }
  70. func (bridge *Bridge) GetPortalByJID(key database.PortalKey) *Portal {
  71. bridge.portalsLock.Lock()
  72. defer bridge.portalsLock.Unlock()
  73. portal, ok := bridge.portalsByJID[key]
  74. if !ok {
  75. return bridge.loadDBPortal(bridge.DB.Portal.GetByJID(key), &key)
  76. }
  77. return portal
  78. }
  79. func (bridge *Bridge) GetAllPortals() []*Portal {
  80. return bridge.dbPortalsToPortals(bridge.DB.Portal.GetAll())
  81. }
  82. func (bridge *Bridge) GetAllPortalsByJID(jid types.JID) []*Portal {
  83. return bridge.dbPortalsToPortals(bridge.DB.Portal.GetAllByJID(jid))
  84. }
  85. func (bridge *Bridge) dbPortalsToPortals(dbPortals []*database.Portal) []*Portal {
  86. bridge.portalsLock.Lock()
  87. defer bridge.portalsLock.Unlock()
  88. output := make([]*Portal, len(dbPortals))
  89. for index, dbPortal := range dbPortals {
  90. if dbPortal == nil {
  91. continue
  92. }
  93. portal, ok := bridge.portalsByJID[dbPortal.Key]
  94. if !ok {
  95. portal = bridge.loadDBPortal(dbPortal, nil)
  96. }
  97. output[index] = portal
  98. }
  99. return output
  100. }
  101. func (bridge *Bridge) loadDBPortal(dbPortal *database.Portal, key *database.PortalKey) *Portal {
  102. if dbPortal == nil {
  103. if key == nil {
  104. return nil
  105. }
  106. dbPortal = bridge.DB.Portal.New()
  107. dbPortal.Key = *key
  108. dbPortal.Insert()
  109. }
  110. portal := bridge.NewPortal(dbPortal)
  111. bridge.portalsByJID[portal.Key] = portal
  112. if len(portal.MXID) > 0 {
  113. bridge.portalsByMXID[portal.MXID] = portal
  114. }
  115. return portal
  116. }
  117. func (portal *Portal) GetUsers() []*User {
  118. return nil
  119. }
  120. func (bridge *Bridge) newBlankPortal(key database.PortalKey) *Portal {
  121. portal := &Portal{
  122. bridge: bridge,
  123. log: bridge.Log.Sub(fmt.Sprintf("Portal/%s", key)),
  124. messages: make(chan PortalMessage, bridge.Config.Bridge.PortalMessageBuffer),
  125. receipts: make(chan PortalReceipt, bridge.Config.Bridge.PortalMessageBuffer),
  126. matrixMessages: make(chan PortalMatrixMessage, bridge.Config.Bridge.PortalMessageBuffer),
  127. mediaRetries: make(chan PortalMediaRetry, bridge.Config.Bridge.PortalMessageBuffer),
  128. mediaErrorCache: make(map[types.MessageID]*FailedMediaMeta),
  129. }
  130. go portal.handleMessageLoop()
  131. return portal
  132. }
  133. func (bridge *Bridge) NewManualPortal(key database.PortalKey) *Portal {
  134. portal := bridge.newBlankPortal(key)
  135. portal.Portal = bridge.DB.Portal.New()
  136. portal.Key = key
  137. return portal
  138. }
  139. func (bridge *Bridge) NewPortal(dbPortal *database.Portal) *Portal {
  140. portal := bridge.newBlankPortal(dbPortal.Key)
  141. portal.Portal = dbPortal
  142. return portal
  143. }
  144. const recentlyHandledLength = 100
  145. type fakeMessage struct {
  146. Sender types.JID
  147. Text string
  148. ID string
  149. Time time.Time
  150. Important bool
  151. }
  152. type PortalMessage struct {
  153. evt *events.Message
  154. undecryptable *events.UndecryptableMessage
  155. fake *fakeMessage
  156. source *User
  157. }
  158. type PortalReceipt struct {
  159. evt *events.Receipt
  160. source *User
  161. }
  162. type PortalMatrixMessage struct {
  163. evt *event.Event
  164. user *User
  165. }
  166. type PortalMediaRetry struct {
  167. evt *events.MediaRetry
  168. source *User
  169. }
  170. type recentlyHandledWrapper struct {
  171. id types.MessageID
  172. err database.MessageErrorType
  173. }
  174. type Portal struct {
  175. *database.Portal
  176. bridge *Bridge
  177. log log.Logger
  178. roomCreateLock sync.Mutex
  179. encryptLock sync.Mutex
  180. backfillLock sync.Mutex
  181. avatarLock sync.Mutex
  182. recentlyHandled [recentlyHandledLength]recentlyHandledWrapper
  183. recentlyHandledLock sync.Mutex
  184. recentlyHandledIndex uint8
  185. privateChatBackfillInvitePuppet func()
  186. currentlyTyping []id.UserID
  187. currentlyTypingLock sync.Mutex
  188. messages chan PortalMessage
  189. receipts chan PortalReceipt
  190. matrixMessages chan PortalMatrixMessage
  191. mediaRetries chan PortalMediaRetry
  192. mediaErrorCache map[types.MessageID]*FailedMediaMeta
  193. relayUser *User
  194. }
  195. func (portal *Portal) handleMessageLoopItem(msg PortalMessage) {
  196. if len(portal.MXID) == 0 {
  197. if msg.fake == nil && msg.undecryptable == nil && (msg.evt == nil || !containsSupportedMessage(msg.evt.Message)) {
  198. portal.log.Debugln("Not creating portal room for incoming message: message is not a chat message")
  199. return
  200. }
  201. portal.log.Debugln("Creating Matrix room from incoming message")
  202. err := portal.CreateMatrixRoom(msg.source, nil, false)
  203. if err != nil {
  204. portal.log.Errorln("Failed to create portal room:", err)
  205. return
  206. }
  207. }
  208. if msg.evt != nil {
  209. portal.handleMessage(msg.source, msg.evt)
  210. } else if msg.undecryptable != nil {
  211. portal.handleUndecryptableMessage(msg.source, msg.undecryptable)
  212. } else if msg.fake != nil {
  213. msg.fake.ID = "FAKE::" + msg.fake.ID
  214. portal.handleFakeMessage(*msg.fake)
  215. } else {
  216. portal.log.Warnln("Unexpected PortalMessage with no message: %+v", msg)
  217. }
  218. }
  219. func (portal *Portal) handleMatrixMessageLoopItem(msg PortalMatrixMessage) {
  220. portal.HandleMatrixReadReceipt(msg.user, "", time.UnixMilli(msg.evt.Timestamp), false)
  221. switch msg.evt.Type {
  222. case event.EventMessage, event.EventSticker:
  223. portal.HandleMatrixMessage(msg.user, msg.evt)
  224. case event.EventRedaction:
  225. portal.HandleMatrixRedaction(msg.user, msg.evt)
  226. default:
  227. portal.log.Warnln("Unsupported event type %+v in portal message channel", msg.evt.Type)
  228. }
  229. }
  230. func (portal *Portal) handleReceipt(receipt *events.Receipt, source *User) {
  231. // The order of the message ID array depends on the sender's platform, so we just have to find
  232. // the last message based on timestamp. Also, timestamps only have second precision, so if
  233. // there are many messages at the same second just mark them all as read, because we don't
  234. // know which one is last
  235. markAsRead := make([]*database.Message, 0, 1)
  236. var bestTimestamp time.Time
  237. for _, msgID := range receipt.MessageIDs {
  238. msg := portal.bridge.DB.Message.GetByJID(portal.Key, msgID)
  239. if msg == nil || msg.IsFakeMXID() {
  240. continue
  241. }
  242. if msg.Timestamp.After(bestTimestamp) {
  243. bestTimestamp = msg.Timestamp
  244. markAsRead = append(markAsRead[:0], msg)
  245. } else if msg != nil && msg.Timestamp.Equal(bestTimestamp) {
  246. markAsRead = append(markAsRead, msg)
  247. }
  248. }
  249. if receipt.Sender.User == source.JID.User {
  250. if len(markAsRead) > 0 {
  251. source.SetLastReadTS(portal.Key, markAsRead[0].Timestamp)
  252. } else {
  253. source.SetLastReadTS(portal.Key, receipt.Timestamp)
  254. }
  255. }
  256. intent := portal.bridge.GetPuppetByJID(receipt.Sender).IntentFor(portal)
  257. for _, msg := range markAsRead {
  258. err := intent.SetReadMarkers(portal.MXID, makeReadMarkerContent(msg.MXID, intent.IsCustomPuppet))
  259. if err != nil {
  260. portal.log.Warnfln("Failed to mark message %s as read by %s: %v", msg.MXID, intent.UserID, err)
  261. } else {
  262. portal.log.Debugfln("Marked %s as read by %s", msg.MXID, intent.UserID)
  263. }
  264. }
  265. }
  266. func (portal *Portal) handleMessageLoop() {
  267. for {
  268. select {
  269. case msg := <-portal.messages:
  270. portal.handleMessageLoopItem(msg)
  271. case receipt := <-portal.receipts:
  272. portal.handleReceipt(receipt.evt, receipt.source)
  273. case msg := <-portal.matrixMessages:
  274. portal.handleMatrixMessageLoopItem(msg)
  275. case retry := <-portal.mediaRetries:
  276. portal.handleMediaRetry(retry.evt, retry.source)
  277. }
  278. }
  279. }
  280. func containsSupportedMessage(waMsg *waProto.Message) bool {
  281. if waMsg == nil {
  282. return false
  283. }
  284. return waMsg.Conversation != nil || waMsg.ExtendedTextMessage != nil || waMsg.ImageMessage != nil ||
  285. waMsg.StickerMessage != nil || waMsg.AudioMessage != nil || waMsg.VideoMessage != nil ||
  286. waMsg.DocumentMessage != nil || waMsg.ContactMessage != nil || waMsg.LocationMessage != nil ||
  287. waMsg.LiveLocationMessage != nil || waMsg.GroupInviteMessage != nil || waMsg.ContactsArrayMessage != nil
  288. }
  289. func getMessageType(waMsg *waProto.Message) string {
  290. switch {
  291. case waMsg == nil:
  292. return "ignore"
  293. case waMsg.Conversation != nil, waMsg.ExtendedTextMessage != nil:
  294. return "text"
  295. case waMsg.ImageMessage != nil:
  296. return fmt.Sprintf("image %s", waMsg.GetImageMessage().GetMimetype())
  297. case waMsg.StickerMessage != nil:
  298. return fmt.Sprintf("sticker %s", waMsg.GetStickerMessage().GetMimetype())
  299. case waMsg.VideoMessage != nil:
  300. return fmt.Sprintf("video %s", waMsg.GetVideoMessage().GetMimetype())
  301. case waMsg.AudioMessage != nil:
  302. return fmt.Sprintf("audio %s", waMsg.GetAudioMessage().GetMimetype())
  303. case waMsg.DocumentMessage != nil:
  304. return fmt.Sprintf("document %s", waMsg.GetDocumentMessage().GetMimetype())
  305. case waMsg.ContactMessage != nil:
  306. return "contact"
  307. case waMsg.ContactsArrayMessage != nil:
  308. return "contact array"
  309. case waMsg.LocationMessage != nil:
  310. return "location"
  311. case waMsg.LiveLocationMessage != nil:
  312. return "live location start"
  313. case waMsg.GroupInviteMessage != nil:
  314. return "group invite"
  315. case waMsg.ReactionMessage != nil:
  316. return "reaction"
  317. case waMsg.ProtocolMessage != nil:
  318. switch waMsg.GetProtocolMessage().GetType() {
  319. case waProto.ProtocolMessage_REVOKE:
  320. return "revoke"
  321. case waProto.ProtocolMessage_EPHEMERAL_SETTING:
  322. return "disappearing timer change"
  323. case waProto.ProtocolMessage_APP_STATE_SYNC_KEY_SHARE, waProto.ProtocolMessage_HISTORY_SYNC_NOTIFICATION, waProto.ProtocolMessage_INITIAL_SECURITY_NOTIFICATION_SETTING_SYNC:
  324. return "ignore"
  325. default:
  326. return fmt.Sprintf("unknown_protocol_%d", waMsg.GetProtocolMessage().GetType())
  327. }
  328. case waMsg.ButtonsMessage != nil:
  329. return "buttons"
  330. case waMsg.ButtonsResponseMessage != nil:
  331. return "buttons response"
  332. case waMsg.TemplateMessage != nil:
  333. return "template"
  334. case waMsg.HighlyStructuredMessage != nil:
  335. return "highly structured template"
  336. case waMsg.TemplateButtonReplyMessage != nil:
  337. return "template button reply"
  338. case waMsg.InteractiveMessage != nil:
  339. return "interactive"
  340. case waMsg.ListMessage != nil:
  341. return "list"
  342. case waMsg.ProductMessage != nil:
  343. return "product"
  344. case waMsg.ListResponseMessage != nil:
  345. return "list response"
  346. case waMsg.OrderMessage != nil:
  347. return "order"
  348. case waMsg.InvoiceMessage != nil:
  349. return "invoice"
  350. case waMsg.SendPaymentMessage != nil, waMsg.RequestPaymentMessage != nil,
  351. waMsg.DeclinePaymentRequestMessage != nil, waMsg.CancelPaymentRequestMessage != nil,
  352. waMsg.PaymentInviteMessage != nil:
  353. return "payment"
  354. case waMsg.Call != nil:
  355. return "call"
  356. case waMsg.Chat != nil:
  357. return "chat"
  358. case waMsg.SenderKeyDistributionMessage != nil, waMsg.StickerSyncRmrMessage != nil:
  359. return "ignore"
  360. default:
  361. return "unknown"
  362. }
  363. }
  364. func pluralUnit(val int, name string) string {
  365. if val == 1 {
  366. return fmt.Sprintf("%d %s", val, name)
  367. } else if val == 0 {
  368. return ""
  369. }
  370. return fmt.Sprintf("%d %ss", val, name)
  371. }
  372. func naturalJoin(parts []string) string {
  373. if len(parts) == 0 {
  374. return ""
  375. } else if len(parts) == 1 {
  376. return parts[0]
  377. } else if len(parts) == 2 {
  378. return fmt.Sprintf("%s and %s", parts[0], parts[1])
  379. } else {
  380. return fmt.Sprintf("%s and %s", strings.Join(parts[:len(parts)-1], ", "), parts[len(parts)-1])
  381. }
  382. }
  383. func formatDuration(d time.Duration) string {
  384. const Day = time.Hour * 24
  385. var days, hours, minutes, seconds int
  386. days, d = int(d/Day), d%Day
  387. hours, d = int(d/time.Hour), d%time.Hour
  388. minutes, d = int(d/time.Minute), d%time.Minute
  389. seconds = int(d / time.Second)
  390. parts := make([]string, 0, 4)
  391. if days > 0 {
  392. parts = append(parts, pluralUnit(days, "day"))
  393. }
  394. if hours > 0 {
  395. parts = append(parts, pluralUnit(hours, "hour"))
  396. }
  397. if minutes > 0 {
  398. parts = append(parts, pluralUnit(seconds, "minute"))
  399. }
  400. if seconds > 0 {
  401. parts = append(parts, pluralUnit(seconds, "second"))
  402. }
  403. return naturalJoin(parts)
  404. }
  405. func (portal *Portal) convertMessage(intent *appservice.IntentAPI, source *User, info *types.MessageInfo, waMsg *waProto.Message) *ConvertedMessage {
  406. switch {
  407. case waMsg.Conversation != nil || waMsg.ExtendedTextMessage != nil:
  408. return portal.convertTextMessage(intent, source, waMsg)
  409. case waMsg.ImageMessage != nil:
  410. return portal.convertMediaMessage(intent, source, info, waMsg.GetImageMessage())
  411. case waMsg.StickerMessage != nil:
  412. return portal.convertMediaMessage(intent, source, info, waMsg.GetStickerMessage())
  413. case waMsg.VideoMessage != nil:
  414. return portal.convertMediaMessage(intent, source, info, waMsg.GetVideoMessage())
  415. case waMsg.AudioMessage != nil:
  416. return portal.convertMediaMessage(intent, source, info, waMsg.GetAudioMessage())
  417. case waMsg.DocumentMessage != nil:
  418. return portal.convertMediaMessage(intent, source, info, waMsg.GetDocumentMessage())
  419. case waMsg.ContactMessage != nil:
  420. return portal.convertContactMessage(intent, waMsg.GetContactMessage())
  421. case waMsg.ContactsArrayMessage != nil:
  422. return portal.convertContactsArrayMessage(intent, waMsg.GetContactsArrayMessage())
  423. case waMsg.LocationMessage != nil:
  424. return portal.convertLocationMessage(intent, waMsg.GetLocationMessage())
  425. case waMsg.LiveLocationMessage != nil:
  426. return portal.convertLiveLocationMessage(intent, waMsg.GetLiveLocationMessage())
  427. case waMsg.GroupInviteMessage != nil:
  428. return portal.convertGroupInviteMessage(intent, info, waMsg.GetGroupInviteMessage())
  429. case waMsg.ProtocolMessage != nil && waMsg.ProtocolMessage.GetType() == waProto.ProtocolMessage_EPHEMERAL_SETTING:
  430. portal.ExpirationTime = waMsg.ProtocolMessage.GetEphemeralExpiration()
  431. portal.Update()
  432. return &ConvertedMessage{
  433. Intent: intent,
  434. Type: event.EventMessage,
  435. Content: &event.MessageEventContent{
  436. Body: portal.formatDisappearingMessageNotice(),
  437. MsgType: event.MsgNotice,
  438. },
  439. }
  440. default:
  441. return nil
  442. }
  443. }
  444. func (portal *Portal) UpdateGroupDisappearingMessages(sender *types.JID, timestamp time.Time, timer uint32) {
  445. portal.ExpirationTime = timer
  446. portal.Update()
  447. intent := portal.MainIntent()
  448. if sender != nil {
  449. intent = portal.bridge.GetPuppetByJID(sender.ToNonAD()).IntentFor(portal)
  450. } else {
  451. sender = &types.EmptyJID
  452. }
  453. _, err := portal.sendMessage(intent, event.EventMessage, &event.MessageEventContent{
  454. Body: portal.formatDisappearingMessageNotice(),
  455. MsgType: event.MsgNotice,
  456. }, nil, timestamp.UnixMilli())
  457. if err != nil {
  458. portal.log.Warnfln("Failed to notify portal about disappearing message timer change by %s to %d", *sender, timer)
  459. }
  460. }
  461. func (portal *Portal) formatDisappearingMessageNotice() string {
  462. if portal.ExpirationTime == 0 {
  463. return "Turned off disappearing messages"
  464. } else {
  465. msg := fmt.Sprintf("Set the disappearing message timer to %s", formatDuration(time.Duration(portal.ExpirationTime)*time.Second))
  466. if !portal.bridge.Config.Bridge.DisappearingMessagesInGroups && portal.IsGroupChat() {
  467. msg += ". However, this bridge is not configured to disappear messages in group chats."
  468. }
  469. return msg
  470. }
  471. }
  472. const UndecryptableMessageNotice = "Decrypting message from WhatsApp failed, waiting for sender to re-send... " +
  473. "([learn more](https://faq.whatsapp.com/general/security-and-privacy/seeing-waiting-for-this-message-this-may-take-a-while))"
  474. var undecryptableMessageContent event.MessageEventContent
  475. func init() {
  476. undecryptableMessageContent = format.RenderMarkdown(UndecryptableMessageNotice, true, false)
  477. undecryptableMessageContent.MsgType = event.MsgNotice
  478. }
  479. func (portal *Portal) handleUndecryptableMessage(source *User, evt *events.UndecryptableMessage) {
  480. if len(portal.MXID) == 0 {
  481. portal.log.Warnln("handleUndecryptableMessage called even though portal.MXID is empty")
  482. return
  483. } else if portal.isRecentlyHandled(evt.Info.ID, database.MsgErrDecryptionFailed) {
  484. portal.log.Debugfln("Not handling %s (undecryptable): message was recently handled", evt.Info.ID)
  485. return
  486. } else if existingMsg := portal.bridge.DB.Message.GetByJID(portal.Key, evt.Info.ID); existingMsg != nil {
  487. portal.log.Debugfln("Not handling %s (undecryptable): message is duplicate", evt.Info.ID)
  488. return
  489. }
  490. intent := portal.getMessageIntent(source, &evt.Info)
  491. if !intent.IsCustomPuppet && portal.IsPrivateChat() && evt.Info.Sender.User == portal.Key.Receiver.User {
  492. portal.log.Debugfln("Not handling %s (undecryptable): user doesn't have double puppeting enabled", evt.Info.ID)
  493. return
  494. }
  495. content := undecryptableMessageContent
  496. resp, err := portal.sendMessage(intent, event.EventMessage, &content, nil, evt.Info.Timestamp.UnixMilli())
  497. if err != nil {
  498. portal.log.Errorln("Failed to send decryption error of %s to Matrix: %v", evt.Info.ID, err)
  499. }
  500. portal.finishHandling(nil, &evt.Info, resp.EventID, database.MsgErrDecryptionFailed)
  501. }
  502. func (portal *Portal) handleFakeMessage(msg fakeMessage) {
  503. if portal.isRecentlyHandled(msg.ID, database.MsgNoError) {
  504. portal.log.Debugfln("Not handling %s (fake): message was recently handled", msg.ID)
  505. return
  506. } else if existingMsg := portal.bridge.DB.Message.GetByJID(portal.Key, msg.ID); existingMsg != nil {
  507. portal.log.Debugfln("Not handling %s (fake): message is duplicate", msg.ID)
  508. return
  509. }
  510. intent := portal.bridge.GetPuppetByJID(msg.Sender).IntentFor(portal)
  511. if !intent.IsCustomPuppet && portal.IsPrivateChat() && msg.Sender.User == portal.Key.Receiver.User {
  512. portal.log.Debugfln("Not handling %s (fake): user doesn't have double puppeting enabled", msg.ID)
  513. return
  514. }
  515. msgType := event.MsgNotice
  516. if msg.Important {
  517. msgType = event.MsgText
  518. }
  519. resp, err := portal.sendMessage(intent, event.EventMessage, &event.MessageEventContent{
  520. MsgType: msgType,
  521. Body: msg.Text,
  522. }, nil, msg.Time.UnixMilli())
  523. if err != nil {
  524. portal.log.Errorfln("Failed to send %s to Matrix: %v", msg.ID, err)
  525. } else {
  526. portal.finishHandling(nil, &types.MessageInfo{
  527. ID: msg.ID,
  528. Timestamp: msg.Time,
  529. MessageSource: types.MessageSource{
  530. Sender: msg.Sender,
  531. },
  532. }, resp.EventID, database.MsgNoError)
  533. }
  534. }
  535. func (portal *Portal) handleMessage(source *User, evt *events.Message) {
  536. if len(portal.MXID) == 0 {
  537. portal.log.Warnln("handleMessage called even though portal.MXID is empty")
  538. return
  539. }
  540. msgID := evt.Info.ID
  541. msgType := getMessageType(evt.Message)
  542. if msgType == "ignore" {
  543. return
  544. } else if portal.isRecentlyHandled(msgID, database.MsgNoError) {
  545. portal.log.Debugfln("Not handling %s (%s): message was recently handled", msgID, msgType)
  546. return
  547. }
  548. existingMsg := portal.bridge.DB.Message.GetByJID(portal.Key, msgID)
  549. if existingMsg != nil {
  550. if existingMsg.Error == database.MsgErrDecryptionFailed {
  551. portal.log.Debugfln("Got decryptable version of previously undecryptable message %s (%s)", msgID, msgType)
  552. } else {
  553. portal.log.Debugfln("Not handling %s (%s): message is duplicate", msgID, msgType)
  554. return
  555. }
  556. }
  557. intent := portal.getMessageIntent(source, &evt.Info)
  558. if !intent.IsCustomPuppet && portal.IsPrivateChat() && evt.Info.Sender.User == portal.Key.Receiver.User {
  559. portal.log.Debugfln("Not handling %s (%s): user doesn't have double puppeting enabled", msgID, msgType)
  560. return
  561. }
  562. converted := portal.convertMessage(intent, source, &evt.Info, evt.Message)
  563. if converted != nil {
  564. if evt.Info.IsIncomingBroadcast() {
  565. if converted.Extra == nil {
  566. converted.Extra = map[string]interface{}{}
  567. }
  568. converted.Extra["fi.mau.whatsapp.source_broadcast_list"] = evt.Info.Chat.String()
  569. }
  570. var eventID id.EventID
  571. if existingMsg != nil {
  572. portal.MarkDisappearing(existingMsg.MXID, converted.ExpiresIn, false)
  573. converted.Content.SetEdit(existingMsg.MXID)
  574. } else if len(converted.ReplyTo) > 0 {
  575. portal.SetReply(converted.Content, converted.ReplyTo)
  576. }
  577. resp, err := portal.sendMessage(converted.Intent, converted.Type, converted.Content, converted.Extra, evt.Info.Timestamp.UnixMilli())
  578. if err != nil {
  579. portal.log.Errorfln("Failed to send %s to Matrix: %v", msgID, err)
  580. } else {
  581. portal.MarkDisappearing(resp.EventID, converted.ExpiresIn, false)
  582. eventID = resp.EventID
  583. }
  584. // TODO figure out how to handle captions with undecryptable messages turning decryptable
  585. if converted.Caption != nil && existingMsg == nil {
  586. resp, err = portal.sendMessage(converted.Intent, converted.Type, converted.Caption, nil, evt.Info.Timestamp.UnixMilli())
  587. if err != nil {
  588. portal.log.Errorfln("Failed to send caption of %s to Matrix: %v", msgID, err)
  589. } else {
  590. portal.MarkDisappearing(resp.EventID, converted.ExpiresIn, false)
  591. //eventID = resp.EventID
  592. }
  593. }
  594. if converted.MultiEvent != nil && existingMsg == nil {
  595. for index, subEvt := range converted.MultiEvent {
  596. resp, err = portal.sendMessage(converted.Intent, converted.Type, subEvt, nil, evt.Info.Timestamp.UnixMilli())
  597. if err != nil {
  598. portal.log.Errorfln("Failed to send sub-event %d of %s to Matrix: %v", index+1, msgID, err)
  599. } else {
  600. portal.MarkDisappearing(resp.EventID, converted.ExpiresIn, false)
  601. }
  602. }
  603. }
  604. if len(eventID) != 0 {
  605. portal.finishHandling(existingMsg, &evt.Info, eventID, converted.Error)
  606. }
  607. } else if msgType == "revoke" {
  608. portal.HandleMessageRevoke(source, &evt.Info, evt.Message.GetProtocolMessage().GetKey())
  609. if existingMsg != nil {
  610. _, _ = portal.MainIntent().RedactEvent(portal.MXID, existingMsg.MXID, mautrix.ReqRedact{
  611. Reason: "The undecryptable message was actually the deletion of another message",
  612. })
  613. existingMsg.UpdateMXID("net.maunium.whatsapp.fake::"+existingMsg.MXID, database.MsgNoError)
  614. }
  615. } else {
  616. portal.log.Warnfln("Unhandled message: %+v (%s)", evt.Info, msgType)
  617. if existingMsg != nil {
  618. _, _ = portal.MainIntent().RedactEvent(portal.MXID, existingMsg.MXID, mautrix.ReqRedact{
  619. Reason: "The undecryptable message contained an unsupported message type",
  620. })
  621. existingMsg.UpdateMXID("net.maunium.whatsapp.fake::"+existingMsg.MXID, database.MsgNoError)
  622. }
  623. return
  624. }
  625. portal.bridge.Metrics.TrackWhatsAppMessage(evt.Info.Timestamp, strings.Split(msgType, " ")[0])
  626. }
  627. func (portal *Portal) isRecentlyHandled(id types.MessageID, error database.MessageErrorType) bool {
  628. start := portal.recentlyHandledIndex
  629. lookingForMsg := recentlyHandledWrapper{id, error}
  630. for i := start; i != start; i = (i - 1) % recentlyHandledLength {
  631. if portal.recentlyHandled[i] == lookingForMsg {
  632. return true
  633. }
  634. }
  635. return false
  636. }
  637. func init() {
  638. gob.Register(&waProto.Message{})
  639. }
  640. func (portal *Portal) markHandled(msg *database.Message, info *types.MessageInfo, mxid id.EventID, isSent, recent bool, error database.MessageErrorType) *database.Message {
  641. if msg == nil {
  642. msg = portal.bridge.DB.Message.New()
  643. msg.Chat = portal.Key
  644. msg.JID = info.ID
  645. msg.MXID = mxid
  646. msg.Timestamp = info.Timestamp
  647. msg.Sender = info.Sender
  648. msg.Sent = isSent
  649. msg.Error = error
  650. if info.IsIncomingBroadcast() {
  651. msg.BroadcastListJID = info.Chat
  652. }
  653. msg.Insert()
  654. } else {
  655. msg.UpdateMXID(mxid, error)
  656. }
  657. if recent {
  658. portal.recentlyHandledLock.Lock()
  659. index := portal.recentlyHandledIndex
  660. portal.recentlyHandledIndex = (portal.recentlyHandledIndex + 1) % recentlyHandledLength
  661. portal.recentlyHandledLock.Unlock()
  662. portal.recentlyHandled[index] = recentlyHandledWrapper{msg.JID, error}
  663. }
  664. return msg
  665. }
  666. func (portal *Portal) getMessagePuppet(user *User, info *types.MessageInfo) *Puppet {
  667. if info.IsFromMe {
  668. return portal.bridge.GetPuppetByJID(user.JID)
  669. } else if portal.IsPrivateChat() {
  670. return portal.bridge.GetPuppetByJID(portal.Key.JID)
  671. } else {
  672. puppet := portal.bridge.GetPuppetByJID(info.Sender)
  673. puppet.SyncContact(user, true, "handling message")
  674. return puppet
  675. }
  676. }
  677. func (portal *Portal) getMessageIntent(user *User, info *types.MessageInfo) *appservice.IntentAPI {
  678. return portal.getMessagePuppet(user, info).IntentFor(portal)
  679. }
  680. func (portal *Portal) finishHandling(existing *database.Message, message *types.MessageInfo, mxid id.EventID, error database.MessageErrorType) {
  681. portal.markHandled(existing, message, mxid, true, true, error)
  682. portal.sendDeliveryReceipt(mxid)
  683. var suffix string
  684. if error == database.MsgErrDecryptionFailed {
  685. suffix = "(undecryptable message error notice)"
  686. } else if error == database.MsgErrMediaNotFound {
  687. suffix = "(media not found notice)"
  688. }
  689. portal.log.Debugln("Handled message", message.ID, "->", mxid, suffix)
  690. }
  691. func (portal *Portal) kickExtraUsers(participantMap map[types.JID]bool) {
  692. members, err := portal.MainIntent().JoinedMembers(portal.MXID)
  693. if err != nil {
  694. portal.log.Warnln("Failed to get member list:", err)
  695. return
  696. }
  697. for member := range members.Joined {
  698. jid, ok := portal.bridge.ParsePuppetMXID(member)
  699. if ok {
  700. _, shouldBePresent := participantMap[jid]
  701. if !shouldBePresent {
  702. _, err = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{
  703. UserID: member,
  704. Reason: "User had left this WhatsApp chat",
  705. })
  706. if err != nil {
  707. portal.log.Warnfln("Failed to kick user %s who had left: %v", member, err)
  708. }
  709. }
  710. }
  711. }
  712. }
  713. //func (portal *Portal) SyncBroadcastRecipients(source *User, metadata *whatsapp.BroadcastListInfo) {
  714. // participantMap := make(map[whatsapp.JID]bool)
  715. // for _, recipient := range metadata.Recipients {
  716. // participantMap[recipient.JID] = true
  717. //
  718. // puppet := portal.bridge.GetPuppetByJID(recipient.JID)
  719. // puppet.SyncContactIfNecessary(source)
  720. // err := puppet.DefaultIntent().EnsureJoined(portal.MXID)
  721. // if err != nil {
  722. // portal.log.Warnfln("Failed to make puppet of %s join %s: %v", recipient.JID, portal.MXID, err)
  723. // }
  724. // }
  725. // portal.kickExtraUsers(participantMap)
  726. //}
  727. func (portal *Portal) SyncParticipants(source *User, metadata *types.GroupInfo) {
  728. changed := false
  729. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  730. if err != nil {
  731. levels = portal.GetBasePowerLevels()
  732. changed = true
  733. }
  734. participantMap := make(map[types.JID]bool)
  735. for _, participant := range metadata.Participants {
  736. participantMap[participant.JID] = true
  737. puppet := portal.bridge.GetPuppetByJID(participant.JID)
  738. puppet.SyncContact(source, true, "group participant")
  739. user := portal.bridge.GetUserByJID(participant.JID)
  740. if user != nil && user != source {
  741. portal.ensureUserInvited(user)
  742. }
  743. if user == nil || !puppet.IntentFor(portal).IsCustomPuppet {
  744. err = puppet.IntentFor(portal).EnsureJoined(portal.MXID)
  745. if err != nil {
  746. portal.log.Warnfln("Failed to make puppet of %s join %s: %v", participant.JID, portal.MXID, err)
  747. }
  748. }
  749. expectedLevel := 0
  750. if participant.IsSuperAdmin {
  751. expectedLevel = 95
  752. } else if participant.IsAdmin {
  753. expectedLevel = 50
  754. }
  755. changed = levels.EnsureUserLevel(puppet.MXID, expectedLevel) || changed
  756. if user != nil {
  757. changed = levels.EnsureUserLevel(user.MXID, expectedLevel) || changed
  758. }
  759. }
  760. if changed {
  761. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  762. if err != nil {
  763. portal.log.Errorln("Failed to change power levels:", err)
  764. }
  765. }
  766. portal.kickExtraUsers(participantMap)
  767. }
  768. func (portal *Portal) UpdateAvatar(user *User, setBy types.JID, updateInfo bool) bool {
  769. portal.avatarLock.Lock()
  770. defer portal.avatarLock.Unlock()
  771. avatar, err := user.Client.GetProfilePictureInfo(portal.Key.JID, false)
  772. if err != nil {
  773. if !errors.Is(err, whatsmeow.ErrProfilePictureUnauthorized) {
  774. portal.log.Warnln("Failed to get avatar URL:", err)
  775. }
  776. return false
  777. } else if avatar == nil {
  778. if portal.Avatar == "remove" {
  779. return false
  780. }
  781. portal.AvatarURL = id.ContentURI{}
  782. avatar = &types.ProfilePictureInfo{ID: "remove"}
  783. } else if avatar.ID == portal.Avatar {
  784. return false
  785. } else if len(avatar.URL) == 0 {
  786. portal.log.Warnln("Didn't get URL in response to avatar query")
  787. return false
  788. } else {
  789. url, err := reuploadAvatar(portal.MainIntent(), avatar.URL)
  790. if err != nil {
  791. portal.log.Warnln("Failed to reupload avatar:", err)
  792. return false
  793. }
  794. portal.AvatarURL = url
  795. }
  796. if len(portal.MXID) > 0 {
  797. intent := portal.MainIntent()
  798. if !setBy.IsEmpty() {
  799. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  800. }
  801. _, err = intent.SetRoomAvatar(portal.MXID, portal.AvatarURL)
  802. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  803. _, err = portal.MainIntent().SetRoomAvatar(portal.MXID, portal.AvatarURL)
  804. }
  805. if err != nil {
  806. portal.log.Warnln("Failed to set room avatar:", err)
  807. return false
  808. }
  809. }
  810. portal.Avatar = avatar.ID
  811. if updateInfo {
  812. portal.UpdateBridgeInfo()
  813. }
  814. return true
  815. }
  816. func (portal *Portal) UpdateName(name string, setBy types.JID, updateInfo bool) bool {
  817. if name == "" && portal.IsBroadcastList() {
  818. name = UnnamedBroadcastName
  819. }
  820. if portal.Name != name {
  821. portal.log.Debugfln("Updating name %s -> %s", portal.Name, name)
  822. portal.Name = name
  823. intent := portal.MainIntent()
  824. if !setBy.IsEmpty() {
  825. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  826. }
  827. _, err := intent.SetRoomName(portal.MXID, name)
  828. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  829. _, err = portal.MainIntent().SetRoomName(portal.MXID, name)
  830. }
  831. if err == nil {
  832. if updateInfo {
  833. portal.UpdateBridgeInfo()
  834. }
  835. return true
  836. } else {
  837. portal.Name = ""
  838. portal.log.Warnln("Failed to set room name:", err)
  839. }
  840. }
  841. return false
  842. }
  843. func (portal *Portal) UpdateTopic(topic string, setBy types.JID, updateInfo bool) bool {
  844. if portal.Topic != topic {
  845. portal.log.Debugfln("Updating topic %s -> %s", portal.Topic, topic)
  846. portal.Topic = topic
  847. intent := portal.MainIntent()
  848. if !setBy.IsEmpty() {
  849. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  850. }
  851. _, err := intent.SetRoomTopic(portal.MXID, topic)
  852. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  853. _, err = portal.MainIntent().SetRoomTopic(portal.MXID, topic)
  854. }
  855. if err == nil {
  856. if updateInfo {
  857. portal.UpdateBridgeInfo()
  858. }
  859. return true
  860. } else {
  861. portal.Topic = ""
  862. portal.log.Warnln("Failed to set room topic:", err)
  863. }
  864. }
  865. return false
  866. }
  867. func (portal *Portal) UpdateMetadata(user *User, groupInfo *types.GroupInfo) bool {
  868. if portal.IsPrivateChat() {
  869. return false
  870. } else if portal.IsStatusBroadcastList() {
  871. update := false
  872. update = portal.UpdateName(StatusBroadcastName, types.EmptyJID, false) || update
  873. update = portal.UpdateTopic(StatusBroadcastTopic, types.EmptyJID, false) || update
  874. return update
  875. } else if portal.IsBroadcastList() {
  876. update := false
  877. //broadcastMetadata, err := user.Conn.GetBroadcastMetadata(portal.Key.JID)
  878. //if err == nil && broadcastMetadata.Status == 200 {
  879. // portal.SyncBroadcastRecipients(user, broadcastMetadata)
  880. // update = portal.UpdateName(broadcastMetadata.Name, "", nil, false) || update
  881. //} else {
  882. // user.Conn.Store.ContactsLock.RLock()
  883. // contact, _ := user.Conn.Store.Contacts[portal.Key.JID]
  884. // user.Conn.Store.ContactsLock.RUnlock()
  885. // update = portal.UpdateName(contact.Name, "", nil, false) || update
  886. //}
  887. //update = portal.UpdateTopic(BroadcastTopic, "", nil, false) || update
  888. return update
  889. }
  890. if groupInfo == nil {
  891. var err error
  892. groupInfo, err = user.Client.GetGroupInfo(portal.Key.JID)
  893. if err != nil {
  894. portal.log.Errorln("Failed to get group info:", err)
  895. return false
  896. }
  897. }
  898. portal.SyncParticipants(user, groupInfo)
  899. update := false
  900. update = portal.UpdateName(groupInfo.Name, groupInfo.NameSetBy, false) || update
  901. update = portal.UpdateTopic(groupInfo.Topic, groupInfo.TopicSetBy, false) || update
  902. if portal.ExpirationTime != groupInfo.DisappearingTimer {
  903. update = true
  904. portal.ExpirationTime = groupInfo.DisappearingTimer
  905. }
  906. portal.RestrictMessageSending(groupInfo.IsAnnounce)
  907. portal.RestrictMetadataChanges(groupInfo.IsLocked)
  908. return update
  909. }
  910. func (portal *Portal) ensureMXIDInvited(mxid id.UserID) {
  911. err := portal.MainIntent().EnsureInvited(portal.MXID, mxid)
  912. if err != nil {
  913. portal.log.Warnfln("Failed to ensure %s is invited to %s: %v", mxid, portal.MXID, err)
  914. }
  915. }
  916. func (portal *Portal) ensureUserInvited(user *User) bool {
  917. return user.ensureInvited(portal.MainIntent(), portal.MXID, portal.IsPrivateChat())
  918. }
  919. func (portal *Portal) UpdateMatrixRoom(user *User, groupInfo *types.GroupInfo) bool {
  920. if len(portal.MXID) == 0 {
  921. return false
  922. }
  923. portal.log.Infoln("Syncing portal for", user.MXID)
  924. portal.ensureUserInvited(user)
  925. go portal.addToSpace(user)
  926. update := false
  927. update = portal.UpdateMetadata(user, groupInfo) || update
  928. if !portal.IsPrivateChat() && !portal.IsBroadcastList() && portal.Avatar == "" {
  929. update = portal.UpdateAvatar(user, types.EmptyJID, false) || update
  930. }
  931. if update {
  932. portal.Update()
  933. portal.UpdateBridgeInfo()
  934. }
  935. return true
  936. }
  937. func (portal *Portal) GetBasePowerLevels() *event.PowerLevelsEventContent {
  938. anyone := 0
  939. nope := 99
  940. invite := 50
  941. if portal.bridge.Config.Bridge.AllowUserInvite {
  942. invite = 0
  943. }
  944. return &event.PowerLevelsEventContent{
  945. UsersDefault: anyone,
  946. EventsDefault: anyone,
  947. RedactPtr: &anyone,
  948. StateDefaultPtr: &nope,
  949. BanPtr: &nope,
  950. InvitePtr: &invite,
  951. Users: map[id.UserID]int{
  952. portal.MainIntent().UserID: 100,
  953. },
  954. Events: map[string]int{
  955. event.StateRoomName.Type: anyone,
  956. event.StateRoomAvatar.Type: anyone,
  957. event.StateTopic.Type: anyone,
  958. },
  959. }
  960. }
  961. func (portal *Portal) ChangeAdminStatus(jids []types.JID, setAdmin bool) id.EventID {
  962. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  963. if err != nil {
  964. levels = portal.GetBasePowerLevels()
  965. }
  966. newLevel := 0
  967. if setAdmin {
  968. newLevel = 50
  969. }
  970. changed := false
  971. for _, jid := range jids {
  972. puppet := portal.bridge.GetPuppetByJID(jid)
  973. changed = levels.EnsureUserLevel(puppet.MXID, newLevel) || changed
  974. user := portal.bridge.GetUserByJID(jid)
  975. if user != nil {
  976. changed = levels.EnsureUserLevel(user.MXID, newLevel) || changed
  977. }
  978. }
  979. if changed {
  980. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  981. if err != nil {
  982. portal.log.Errorln("Failed to change power levels:", err)
  983. } else {
  984. return resp.EventID
  985. }
  986. }
  987. return ""
  988. }
  989. func (portal *Portal) RestrictMessageSending(restrict bool) id.EventID {
  990. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  991. if err != nil {
  992. levels = portal.GetBasePowerLevels()
  993. }
  994. newLevel := 0
  995. if restrict {
  996. newLevel = 50
  997. }
  998. if levels.EventsDefault == newLevel {
  999. return ""
  1000. }
  1001. levels.EventsDefault = newLevel
  1002. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  1003. if err != nil {
  1004. portal.log.Errorln("Failed to change power levels:", err)
  1005. return ""
  1006. } else {
  1007. return resp.EventID
  1008. }
  1009. }
  1010. func (portal *Portal) RestrictMetadataChanges(restrict bool) id.EventID {
  1011. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  1012. if err != nil {
  1013. levels = portal.GetBasePowerLevels()
  1014. }
  1015. newLevel := 0
  1016. if restrict {
  1017. newLevel = 50
  1018. }
  1019. changed := false
  1020. changed = levels.EnsureEventLevel(event.StateRoomName, newLevel) || changed
  1021. changed = levels.EnsureEventLevel(event.StateRoomAvatar, newLevel) || changed
  1022. changed = levels.EnsureEventLevel(event.StateTopic, newLevel) || changed
  1023. if changed {
  1024. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  1025. if err != nil {
  1026. portal.log.Errorln("Failed to change power levels:", err)
  1027. } else {
  1028. return resp.EventID
  1029. }
  1030. }
  1031. return ""
  1032. }
  1033. func (portal *Portal) getBridgeInfo() (string, event.BridgeEventContent) {
  1034. bridgeInfo := event.BridgeEventContent{
  1035. BridgeBot: portal.bridge.Bot.UserID,
  1036. Creator: portal.MainIntent().UserID,
  1037. Protocol: event.BridgeInfoSection{
  1038. ID: "whatsapp",
  1039. DisplayName: "WhatsApp",
  1040. AvatarURL: portal.bridge.Config.AppService.Bot.ParsedAvatar.CUString(),
  1041. ExternalURL: "https://www.whatsapp.com/",
  1042. },
  1043. Channel: event.BridgeInfoSection{
  1044. ID: portal.Key.JID.String(),
  1045. DisplayName: portal.Name,
  1046. AvatarURL: portal.AvatarURL.CUString(),
  1047. },
  1048. }
  1049. bridgeInfoStateKey := fmt.Sprintf("net.maunium.whatsapp://whatsapp/%s", portal.Key.JID)
  1050. return bridgeInfoStateKey, bridgeInfo
  1051. }
  1052. func (portal *Portal) UpdateBridgeInfo() {
  1053. if len(portal.MXID) == 0 {
  1054. portal.log.Debugln("Not updating bridge info: no Matrix room created")
  1055. return
  1056. }
  1057. portal.log.Debugln("Updating bridge info...")
  1058. stateKey, content := portal.getBridgeInfo()
  1059. _, err := portal.MainIntent().SendStateEvent(portal.MXID, event.StateBridge, stateKey, content)
  1060. if err != nil {
  1061. portal.log.Warnln("Failed to update m.bridge:", err)
  1062. }
  1063. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  1064. _, err = portal.MainIntent().SendStateEvent(portal.MXID, event.StateHalfShotBridge, stateKey, content)
  1065. if err != nil {
  1066. portal.log.Warnln("Failed to update uk.half-shot.bridge:", err)
  1067. }
  1068. }
  1069. func (portal *Portal) CreateMatrixRoom(user *User, groupInfo *types.GroupInfo, isFullInfo bool) error {
  1070. portal.roomCreateLock.Lock()
  1071. defer portal.roomCreateLock.Unlock()
  1072. if len(portal.MXID) > 0 {
  1073. return nil
  1074. }
  1075. intent := portal.MainIntent()
  1076. if err := intent.EnsureRegistered(); err != nil {
  1077. return err
  1078. }
  1079. portal.log.Infoln("Creating Matrix room. Info source:", user.MXID)
  1080. //var broadcastMetadata *types.BroadcastListInfo
  1081. if portal.IsPrivateChat() {
  1082. puppet := portal.bridge.GetPuppetByJID(portal.Key.JID)
  1083. puppet.SyncContact(user, true, "creating private chat portal")
  1084. if portal.bridge.Config.Bridge.PrivateChatPortalMeta {
  1085. portal.Name = puppet.Displayname
  1086. portal.AvatarURL = puppet.AvatarURL
  1087. portal.Avatar = puppet.Avatar
  1088. } else {
  1089. portal.Name = ""
  1090. }
  1091. portal.Topic = PrivateChatTopic
  1092. } else if portal.IsStatusBroadcastList() {
  1093. if !portal.bridge.Config.Bridge.EnableStatusBroadcast {
  1094. portal.log.Debugln("Status bridging is disabled in config, not creating room after all")
  1095. return ErrStatusBroadcastDisabled
  1096. }
  1097. portal.Name = StatusBroadcastName
  1098. portal.Topic = StatusBroadcastTopic
  1099. } else if portal.IsBroadcastList() {
  1100. //var err error
  1101. //broadcastMetadata, err = user.Conn.GetBroadcastMetadata(portal.Key.JID)
  1102. //if err == nil && broadcastMetadata.Status == 200 {
  1103. // portal.Name = broadcastMetadata.Name
  1104. //} else {
  1105. // user.Conn.Store.ContactsLock.RLock()
  1106. // contact, _ := user.Conn.Store.Contacts[portal.Key.JID]
  1107. // user.Conn.Store.ContactsLock.RUnlock()
  1108. // portal.Name = contact.Name
  1109. //}
  1110. //if len(portal.Name) == 0 {
  1111. // portal.Name = UnnamedBroadcastName
  1112. //}
  1113. //portal.Topic = BroadcastTopic
  1114. portal.log.Debugln("Broadcast list is not yet supported, not creating room after all")
  1115. return fmt.Errorf("broadcast list bridging is currently not supported")
  1116. } else {
  1117. if groupInfo == nil || !isFullInfo {
  1118. foundInfo, err := user.Client.GetGroupInfo(portal.Key.JID)
  1119. if err != nil {
  1120. portal.log.Warnfln("Failed to get group info through %s: %v", user.JID, err)
  1121. } else {
  1122. groupInfo = foundInfo
  1123. isFullInfo = true
  1124. }
  1125. }
  1126. if groupInfo != nil {
  1127. portal.Name = groupInfo.Name
  1128. portal.Topic = groupInfo.Topic
  1129. }
  1130. portal.UpdateAvatar(user, types.EmptyJID, false)
  1131. }
  1132. bridgeInfoStateKey, bridgeInfo := portal.getBridgeInfo()
  1133. initialState := []*event.Event{{
  1134. Type: event.StatePowerLevels,
  1135. Content: event.Content{
  1136. Parsed: portal.GetBasePowerLevels(),
  1137. },
  1138. }, {
  1139. Type: event.StateBridge,
  1140. Content: event.Content{Parsed: bridgeInfo},
  1141. StateKey: &bridgeInfoStateKey,
  1142. }, {
  1143. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  1144. Type: event.StateHalfShotBridge,
  1145. Content: event.Content{Parsed: bridgeInfo},
  1146. StateKey: &bridgeInfoStateKey,
  1147. }}
  1148. if !portal.AvatarURL.IsEmpty() {
  1149. initialState = append(initialState, &event.Event{
  1150. Type: event.StateRoomAvatar,
  1151. Content: event.Content{
  1152. Parsed: event.RoomAvatarEventContent{URL: portal.AvatarURL},
  1153. },
  1154. })
  1155. }
  1156. var invite []id.UserID
  1157. if portal.bridge.Config.Bridge.Encryption.Default {
  1158. initialState = append(initialState, &event.Event{
  1159. Type: event.StateEncryption,
  1160. Content: event.Content{
  1161. Parsed: event.EncryptionEventContent{Algorithm: id.AlgorithmMegolmV1},
  1162. },
  1163. })
  1164. portal.Encrypted = true
  1165. if portal.IsPrivateChat() {
  1166. invite = append(invite, portal.bridge.Bot.UserID)
  1167. }
  1168. }
  1169. creationContent := make(map[string]interface{})
  1170. if !portal.bridge.Config.Bridge.FederateRooms {
  1171. creationContent["m.federate"] = false
  1172. }
  1173. resp, err := intent.CreateRoom(&mautrix.ReqCreateRoom{
  1174. Visibility: "private",
  1175. Name: portal.Name,
  1176. Topic: portal.Topic,
  1177. Invite: invite,
  1178. Preset: "private_chat",
  1179. IsDirect: portal.IsPrivateChat(),
  1180. InitialState: initialState,
  1181. CreationContent: creationContent,
  1182. })
  1183. if err != nil {
  1184. return err
  1185. }
  1186. portal.MXID = resp.RoomID
  1187. portal.Update()
  1188. portal.bridge.portalsLock.Lock()
  1189. portal.bridge.portalsByMXID[portal.MXID] = portal
  1190. portal.bridge.portalsLock.Unlock()
  1191. // We set the memberships beforehand to make sure the encryption key exchange in initial backfill knows the users are here.
  1192. for _, userID := range invite {
  1193. portal.bridge.StateStore.SetMembership(portal.MXID, userID, event.MembershipInvite)
  1194. }
  1195. portal.ensureUserInvited(user)
  1196. user.syncChatDoublePuppetDetails(portal, true)
  1197. go portal.addToSpace(user)
  1198. if groupInfo != nil {
  1199. portal.SyncParticipants(user, groupInfo)
  1200. if groupInfo.IsAnnounce {
  1201. portal.RestrictMessageSending(groupInfo.IsAnnounce)
  1202. }
  1203. if groupInfo.IsLocked {
  1204. portal.RestrictMetadataChanges(groupInfo.IsLocked)
  1205. }
  1206. }
  1207. //if broadcastMetadata != nil {
  1208. // portal.SyncBroadcastRecipients(user, broadcastMetadata)
  1209. //}
  1210. if portal.IsPrivateChat() {
  1211. puppet := user.bridge.GetPuppetByJID(portal.Key.JID)
  1212. if portal.bridge.Config.Bridge.Encryption.Default {
  1213. err = portal.bridge.Bot.EnsureJoined(portal.MXID)
  1214. if err != nil {
  1215. portal.log.Errorln("Failed to join created portal with bridge bot for e2be:", err)
  1216. }
  1217. }
  1218. user.UpdateDirectChats(map[id.UserID][]id.RoomID{puppet.MXID: {portal.MXID}})
  1219. }
  1220. firstEventResp, err := portal.MainIntent().SendMessageEvent(portal.MXID, PortalCreationDummyEvent, struct{}{})
  1221. if err != nil {
  1222. portal.log.Errorln("Failed to send dummy event to mark portal creation:", err)
  1223. } else {
  1224. portal.FirstEventID = firstEventResp.EventID
  1225. portal.Update()
  1226. }
  1227. return nil
  1228. }
  1229. func (portal *Portal) addToSpace(user *User) {
  1230. spaceID := user.GetSpaceRoom()
  1231. if len(spaceID) == 0 || user.IsInSpace(portal.Key) {
  1232. return
  1233. }
  1234. _, err := portal.bridge.Bot.SendStateEvent(spaceID, event.StateSpaceChild, portal.MXID.String(), &event.SpaceChildEventContent{
  1235. Via: []string{portal.bridge.Config.Homeserver.Domain},
  1236. })
  1237. if err != nil {
  1238. portal.log.Errorfln("Failed to add room to %s's personal filtering space (%s): %v", user.MXID, spaceID, err)
  1239. } else {
  1240. portal.log.Debugfln("Added room to %s's personal filtering space (%s)", user.MXID, spaceID)
  1241. user.MarkInSpace(portal.Key)
  1242. }
  1243. }
  1244. func (portal *Portal) IsPrivateChat() bool {
  1245. return portal.Key.JID.Server == types.DefaultUserServer
  1246. }
  1247. func (portal *Portal) IsGroupChat() bool {
  1248. return portal.Key.JID.Server == types.GroupServer
  1249. }
  1250. func (portal *Portal) IsBroadcastList() bool {
  1251. return portal.Key.JID.Server == types.BroadcastServer
  1252. }
  1253. func (portal *Portal) IsStatusBroadcastList() bool {
  1254. return portal.Key.JID == types.StatusBroadcastJID
  1255. }
  1256. func (portal *Portal) HasRelaybot() bool {
  1257. return portal.bridge.Config.Bridge.Relay.Enabled && len(portal.RelayUserID) > 0
  1258. }
  1259. func (portal *Portal) GetRelayUser() *User {
  1260. if !portal.HasRelaybot() {
  1261. return nil
  1262. } else if portal.relayUser == nil {
  1263. portal.relayUser = portal.bridge.GetUserByMXID(portal.RelayUserID)
  1264. }
  1265. return portal.relayUser
  1266. }
  1267. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  1268. if portal.IsPrivateChat() {
  1269. return portal.bridge.GetPuppetByJID(portal.Key.JID).DefaultIntent()
  1270. }
  1271. return portal.bridge.Bot
  1272. }
  1273. func (portal *Portal) SetReply(content *event.MessageEventContent, replyToID types.MessageID) bool {
  1274. if len(replyToID) == 0 {
  1275. return false
  1276. }
  1277. message := portal.bridge.DB.Message.GetByJID(portal.Key, replyToID)
  1278. if message == nil || message.IsFakeMXID() {
  1279. return false
  1280. }
  1281. evt, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  1282. if err != nil {
  1283. portal.log.Warnln("Failed to get reply target:", err)
  1284. content.RelatesTo = &event.RelatesTo{
  1285. EventID: message.MXID,
  1286. Type: event.RelReply,
  1287. }
  1288. return true
  1289. }
  1290. _ = evt.Content.ParseRaw(evt.Type)
  1291. if evt.Type == event.EventEncrypted {
  1292. decryptedEvt, err := portal.bridge.Crypto.Decrypt(evt)
  1293. if err != nil {
  1294. portal.log.Warnln("Failed to decrypt reply target:", err)
  1295. } else {
  1296. evt = decryptedEvt
  1297. }
  1298. }
  1299. content.SetReply(evt)
  1300. return true
  1301. }
  1302. func (portal *Portal) HandleMessageRevoke(user *User, info *types.MessageInfo, key *waProto.MessageKey) bool {
  1303. msg := portal.bridge.DB.Message.GetByJID(portal.Key, key.GetId())
  1304. if msg == nil || msg.IsFakeMXID() {
  1305. return false
  1306. }
  1307. intent := portal.bridge.GetPuppetByJID(info.Sender).IntentFor(portal)
  1308. redactionReq := mautrix.ReqRedact{Extra: map[string]interface{}{}}
  1309. if intent.IsCustomPuppet {
  1310. redactionReq.Extra[doublePuppetKey] = doublePuppetValue
  1311. }
  1312. _, err := intent.RedactEvent(portal.MXID, msg.MXID, redactionReq)
  1313. if err != nil {
  1314. if errors.Is(err, mautrix.MForbidden) {
  1315. _, err = portal.MainIntent().RedactEvent(portal.MXID, msg.MXID, redactionReq)
  1316. if err != nil {
  1317. portal.log.Errorln("Failed to redact %s: %v", msg.JID, err)
  1318. }
  1319. }
  1320. } else {
  1321. msg.Delete()
  1322. }
  1323. return true
  1324. }
  1325. func (portal *Portal) sendMainIntentMessage(content *event.MessageEventContent) (*mautrix.RespSendEvent, error) {
  1326. return portal.sendMessage(portal.MainIntent(), event.EventMessage, content, nil, 0)
  1327. }
  1328. func (portal *Portal) encrypt(content *event.Content, eventType event.Type) (event.Type, error) {
  1329. if portal.Encrypted && portal.bridge.Crypto != nil {
  1330. // TODO maybe the locking should be inside mautrix-go?
  1331. portal.encryptLock.Lock()
  1332. encrypted, err := portal.bridge.Crypto.Encrypt(portal.MXID, eventType, *content)
  1333. portal.encryptLock.Unlock()
  1334. if err != nil {
  1335. return eventType, fmt.Errorf("failed to encrypt event: %w", err)
  1336. }
  1337. eventType = event.EventEncrypted
  1338. content.Parsed = encrypted
  1339. }
  1340. return eventType, nil
  1341. }
  1342. const doublePuppetKey = "fi.mau.double_puppet_source"
  1343. const doublePuppetValue = "mautrix-whatsapp"
  1344. func (portal *Portal) sendMessage(intent *appservice.IntentAPI, eventType event.Type, content *event.MessageEventContent, extraContent map[string]interface{}, timestamp int64) (*mautrix.RespSendEvent, error) {
  1345. wrappedContent := event.Content{Parsed: content, Raw: extraContent}
  1346. if timestamp != 0 && intent.IsCustomPuppet {
  1347. if wrappedContent.Raw == nil {
  1348. wrappedContent.Raw = map[string]interface{}{}
  1349. }
  1350. if intent.IsCustomPuppet {
  1351. wrappedContent.Raw[doublePuppetKey] = doublePuppetValue
  1352. }
  1353. }
  1354. var err error
  1355. eventType, err = portal.encrypt(&wrappedContent, eventType)
  1356. if err != nil {
  1357. return nil, err
  1358. }
  1359. if intent.IsCustomPuppet {
  1360. wrappedContent.Raw = map[string]interface{}{doublePuppetKey: doublePuppetValue}
  1361. } else {
  1362. wrappedContent.Raw = nil
  1363. }
  1364. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1365. if timestamp == 0 {
  1366. return intent.SendMessageEvent(portal.MXID, eventType, &wrappedContent)
  1367. } else {
  1368. return intent.SendMassagedMessageEvent(portal.MXID, eventType, &wrappedContent, timestamp)
  1369. }
  1370. }
  1371. type ConvertedMessage struct {
  1372. Intent *appservice.IntentAPI
  1373. Type event.Type
  1374. Content *event.MessageEventContent
  1375. Extra map[string]interface{}
  1376. Caption *event.MessageEventContent
  1377. MultiEvent []*event.MessageEventContent
  1378. ReplyTo types.MessageID
  1379. ExpiresIn uint32
  1380. Error database.MessageErrorType
  1381. }
  1382. func (portal *Portal) convertTextMessage(intent *appservice.IntentAPI, source *User, msg *waProto.Message) *ConvertedMessage {
  1383. content := &event.MessageEventContent{
  1384. Body: msg.GetConversation(),
  1385. MsgType: event.MsgText,
  1386. }
  1387. var replyTo types.MessageID
  1388. var expiresIn uint32
  1389. extraAttrs := map[string]interface{}{}
  1390. if msg.GetExtendedTextMessage() != nil {
  1391. content.Body = msg.GetExtendedTextMessage().GetText()
  1392. contextInfo := msg.GetExtendedTextMessage().GetContextInfo()
  1393. if contextInfo != nil {
  1394. portal.bridge.Formatter.ParseWhatsApp(content, contextInfo.GetMentionedJid())
  1395. replyTo = contextInfo.GetStanzaId()
  1396. }
  1397. expiresIn = contextInfo.GetExpiration()
  1398. extraAttrs["com.beeper.linkpreviews"] = portal.convertURLPreviewToBeeper(intent, source, msg.GetExtendedTextMessage())
  1399. }
  1400. return &ConvertedMessage{
  1401. Intent: intent,
  1402. Type: event.EventMessage,
  1403. Content: content,
  1404. ReplyTo: replyTo,
  1405. ExpiresIn: expiresIn,
  1406. Extra: extraAttrs,
  1407. }
  1408. }
  1409. func (portal *Portal) convertLiveLocationMessage(intent *appservice.IntentAPI, msg *waProto.LiveLocationMessage) *ConvertedMessage {
  1410. content := &event.MessageEventContent{
  1411. Body: "Started sharing live location",
  1412. MsgType: event.MsgNotice,
  1413. }
  1414. if len(msg.GetCaption()) > 0 {
  1415. content.Body += ": " + msg.GetCaption()
  1416. }
  1417. return &ConvertedMessage{
  1418. Intent: intent,
  1419. Type: event.EventMessage,
  1420. Content: content,
  1421. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1422. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1423. }
  1424. }
  1425. func (portal *Portal) convertLocationMessage(intent *appservice.IntentAPI, msg *waProto.LocationMessage) *ConvertedMessage {
  1426. url := msg.GetUrl()
  1427. if len(url) == 0 {
  1428. url = fmt.Sprintf("https://maps.google.com/?q=%.5f,%.5f", msg.GetDegreesLatitude(), msg.GetDegreesLongitude())
  1429. }
  1430. name := msg.GetName()
  1431. if len(name) == 0 {
  1432. latChar := 'N'
  1433. if msg.GetDegreesLatitude() < 0 {
  1434. latChar = 'S'
  1435. }
  1436. longChar := 'E'
  1437. if msg.GetDegreesLongitude() < 0 {
  1438. longChar = 'W'
  1439. }
  1440. name = fmt.Sprintf("%.4f° %c %.4f° %c", math.Abs(msg.GetDegreesLatitude()), latChar, math.Abs(msg.GetDegreesLongitude()), longChar)
  1441. }
  1442. content := &event.MessageEventContent{
  1443. MsgType: event.MsgLocation,
  1444. Body: fmt.Sprintf("Location: %s\n%s\n%s", name, msg.GetAddress(), url),
  1445. Format: event.FormatHTML,
  1446. FormattedBody: fmt.Sprintf("Location: <a href='%s'>%s</a><br>%s", url, name, msg.GetAddress()),
  1447. GeoURI: fmt.Sprintf("geo:%.5f,%.5f", msg.GetDegreesLatitude(), msg.GetDegreesLongitude()),
  1448. }
  1449. if len(msg.GetJpegThumbnail()) > 0 {
  1450. thumbnailMime := http.DetectContentType(msg.GetJpegThumbnail())
  1451. uploadedThumbnail, _ := intent.UploadBytes(msg.GetJpegThumbnail(), thumbnailMime)
  1452. if uploadedThumbnail != nil {
  1453. cfg, _, _ := image.DecodeConfig(bytes.NewReader(msg.GetJpegThumbnail()))
  1454. content.Info = &event.FileInfo{
  1455. ThumbnailInfo: &event.FileInfo{
  1456. Size: len(msg.GetJpegThumbnail()),
  1457. Width: cfg.Width,
  1458. Height: cfg.Height,
  1459. MimeType: thumbnailMime,
  1460. },
  1461. ThumbnailURL: uploadedThumbnail.ContentURI.CUString(),
  1462. }
  1463. }
  1464. }
  1465. return &ConvertedMessage{
  1466. Intent: intent,
  1467. Type: event.EventMessage,
  1468. Content: content,
  1469. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1470. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1471. }
  1472. }
  1473. const inviteMsg = `%s<hr/>This invitation to join "%s" expires at %s. Reply to this message with <code>!wa accept</code> to accept the invite.`
  1474. const inviteMetaField = "fi.mau.whatsapp.invite"
  1475. func (portal *Portal) convertGroupInviteMessage(intent *appservice.IntentAPI, info *types.MessageInfo, msg *waProto.GroupInviteMessage) *ConvertedMessage {
  1476. expiry := time.Unix(msg.GetInviteExpiration(), 0)
  1477. htmlMessage := fmt.Sprintf(inviteMsg, html.EscapeString(msg.GetCaption()), msg.GetGroupName(), expiry)
  1478. content := &event.MessageEventContent{
  1479. MsgType: event.MsgText,
  1480. Body: format.HTMLToText(htmlMessage),
  1481. Format: event.FormatHTML,
  1482. FormattedBody: htmlMessage,
  1483. }
  1484. extraAttrs := map[string]interface{}{
  1485. inviteMetaField: map[string]interface{}{
  1486. "jid": msg.GetGroupJid(),
  1487. "code": msg.GetInviteCode(),
  1488. "expiration": strconv.FormatInt(msg.GetInviteExpiration(), 10),
  1489. "inviter": info.Sender.ToNonAD().String(),
  1490. },
  1491. }
  1492. return &ConvertedMessage{
  1493. Intent: intent,
  1494. Type: event.EventMessage,
  1495. Content: content,
  1496. Extra: extraAttrs,
  1497. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1498. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1499. }
  1500. }
  1501. func (portal *Portal) convertContactMessage(intent *appservice.IntentAPI, msg *waProto.ContactMessage) *ConvertedMessage {
  1502. fileName := fmt.Sprintf("%s.vcf", msg.GetDisplayName())
  1503. data := []byte(msg.GetVcard())
  1504. mimeType := "text/vcard"
  1505. data, uploadMimeType, file := portal.encryptFile(data, mimeType)
  1506. uploadResp, err := intent.UploadBytesWithName(data, uploadMimeType, fileName)
  1507. if err != nil {
  1508. portal.log.Errorfln("Failed to upload vcard of %s: %v", msg.GetDisplayName(), err)
  1509. return nil
  1510. }
  1511. content := &event.MessageEventContent{
  1512. Body: fileName,
  1513. MsgType: event.MsgFile,
  1514. File: file,
  1515. Info: &event.FileInfo{
  1516. MimeType: mimeType,
  1517. Size: len(msg.GetVcard()),
  1518. },
  1519. }
  1520. if content.File != nil {
  1521. content.File.URL = uploadResp.ContentURI.CUString()
  1522. } else {
  1523. content.URL = uploadResp.ContentURI.CUString()
  1524. }
  1525. return &ConvertedMessage{
  1526. Intent: intent,
  1527. Type: event.EventMessage,
  1528. Content: content,
  1529. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1530. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1531. }
  1532. }
  1533. func (portal *Portal) convertContactsArrayMessage(intent *appservice.IntentAPI, msg *waProto.ContactsArrayMessage) *ConvertedMessage {
  1534. name := msg.GetDisplayName()
  1535. if len(name) == 0 {
  1536. name = fmt.Sprintf("%d contacts", len(msg.GetContacts()))
  1537. }
  1538. contacts := make([]*event.MessageEventContent, 0, len(msg.GetContacts()))
  1539. for _, contact := range msg.GetContacts() {
  1540. converted := portal.convertContactMessage(intent, contact)
  1541. if converted != nil {
  1542. contacts = append(contacts, converted.Content)
  1543. }
  1544. }
  1545. return &ConvertedMessage{
  1546. Intent: intent,
  1547. Type: event.EventMessage,
  1548. Content: &event.MessageEventContent{
  1549. MsgType: event.MsgNotice,
  1550. Body: fmt.Sprintf("Sent %s", name),
  1551. },
  1552. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1553. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1554. MultiEvent: contacts,
  1555. }
  1556. }
  1557. func (portal *Portal) tryKickUser(userID id.UserID, intent *appservice.IntentAPI) error {
  1558. _, err := intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: userID})
  1559. if err != nil {
  1560. httpErr, ok := err.(mautrix.HTTPError)
  1561. if ok && httpErr.RespError != nil && httpErr.RespError.ErrCode == "M_FORBIDDEN" {
  1562. _, err = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: userID})
  1563. }
  1564. }
  1565. return err
  1566. }
  1567. func (portal *Portal) removeUser(isSameUser bool, kicker *appservice.IntentAPI, target id.UserID, targetIntent *appservice.IntentAPI) {
  1568. if !isSameUser || targetIntent == nil {
  1569. err := portal.tryKickUser(target, kicker)
  1570. if err != nil {
  1571. portal.log.Warnfln("Failed to kick %s from %s: %v", target, portal.MXID, err)
  1572. if targetIntent != nil {
  1573. _, _ = portal.leaveWithPuppetMeta(targetIntent)
  1574. }
  1575. }
  1576. } else {
  1577. _, err := portal.leaveWithPuppetMeta(targetIntent)
  1578. if err != nil {
  1579. portal.log.Warnfln("Failed to leave portal as %s: %v", target, err)
  1580. _, _ = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: target})
  1581. }
  1582. }
  1583. }
  1584. func (portal *Portal) HandleWhatsAppKick(source *User, senderJID types.JID, jids []types.JID) {
  1585. sender := portal.bridge.GetPuppetByJID(senderJID)
  1586. senderIntent := sender.IntentFor(portal)
  1587. for _, jid := range jids {
  1588. //if source != nil && source.JID.User == jid.User {
  1589. // portal.log.Debugln("Ignoring self-kick by", source.MXID)
  1590. // continue
  1591. //}
  1592. puppet := portal.bridge.GetPuppetByJID(jid)
  1593. portal.removeUser(puppet.JID == sender.JID, senderIntent, puppet.MXID, puppet.DefaultIntent())
  1594. if !portal.IsBroadcastList() {
  1595. user := portal.bridge.GetUserByJID(jid)
  1596. if user != nil {
  1597. var customIntent *appservice.IntentAPI
  1598. if puppet.CustomMXID == user.MXID {
  1599. customIntent = puppet.CustomIntent()
  1600. }
  1601. portal.removeUser(puppet.JID == sender.JID, senderIntent, user.MXID, customIntent)
  1602. }
  1603. }
  1604. }
  1605. }
  1606. func (portal *Portal) leaveWithPuppetMeta(intent *appservice.IntentAPI) (*mautrix.RespSendEvent, error) {
  1607. content := event.Content{
  1608. Parsed: event.MemberEventContent{
  1609. Membership: event.MembershipLeave,
  1610. },
  1611. Raw: map[string]interface{}{
  1612. doublePuppetKey: doublePuppetValue,
  1613. },
  1614. }
  1615. // Bypass IntentAPI, we don't want to EnsureJoined here
  1616. return intent.Client.SendStateEvent(portal.MXID, event.StateMember, intent.UserID.String(), &content)
  1617. }
  1618. func (portal *Portal) HandleWhatsAppInvite(source *User, senderJID *types.JID, jids []types.JID) (evtID id.EventID) {
  1619. intent := portal.MainIntent()
  1620. if senderJID != nil && !senderJID.IsEmpty() {
  1621. sender := portal.bridge.GetPuppetByJID(*senderJID)
  1622. intent = sender.IntentFor(portal)
  1623. }
  1624. for _, jid := range jids {
  1625. puppet := portal.bridge.GetPuppetByJID(jid)
  1626. puppet.SyncContact(source, true, "handling whatsapp invite")
  1627. content := event.Content{
  1628. Parsed: event.MemberEventContent{
  1629. Membership: "invite",
  1630. Displayname: puppet.Displayname,
  1631. AvatarURL: puppet.AvatarURL.CUString(),
  1632. },
  1633. Raw: map[string]interface{}{
  1634. doublePuppetKey: doublePuppetValue,
  1635. },
  1636. }
  1637. resp, err := intent.SendStateEvent(portal.MXID, event.StateMember, puppet.MXID.String(), &content)
  1638. if err != nil {
  1639. portal.log.Warnfln("Failed to invite %s as %s: %v", puppet.MXID, intent.UserID, err)
  1640. _ = portal.MainIntent().EnsureInvited(portal.MXID, puppet.MXID)
  1641. } else {
  1642. evtID = resp.EventID
  1643. }
  1644. err = puppet.DefaultIntent().EnsureJoined(portal.MXID)
  1645. if err != nil {
  1646. portal.log.Errorfln("Failed to ensure %s is joined: %v", puppet.MXID, err)
  1647. }
  1648. }
  1649. return
  1650. }
  1651. const failedMediaField = "fi.mau.whatsapp.failed_media"
  1652. type FailedMediaKeys struct {
  1653. Key []byte `json:"key"`
  1654. Length int `json:"length"`
  1655. Type whatsmeow.MediaType `json:"type"`
  1656. SHA256 []byte `json:"sha256"`
  1657. EncSHA256 []byte `json:"enc_sha256"`
  1658. }
  1659. type FailedMediaMeta struct {
  1660. Type event.Type `json:"type"`
  1661. Content *event.MessageEventContent `json:"content"`
  1662. ExtraContent map[string]interface{} `json:"extra_content,omitempty"`
  1663. Media FailedMediaKeys `json:"whatsapp_media"`
  1664. }
  1665. func shallowCopyMap(data map[string]interface{}) map[string]interface{} {
  1666. newMap := make(map[string]interface{}, len(data))
  1667. for key, value := range data {
  1668. newMap[key] = value
  1669. }
  1670. return newMap
  1671. }
  1672. func (portal *Portal) makeMediaBridgeFailureMessage(info *types.MessageInfo, bridgeErr error, converted *ConvertedMessage, keys *FailedMediaKeys) *ConvertedMessage {
  1673. portal.log.Errorfln("Failed to bridge media for %s: %v", info.ID, bridgeErr)
  1674. if keys != nil {
  1675. meta := &FailedMediaMeta{
  1676. Type: converted.Type,
  1677. Content: converted.Content,
  1678. ExtraContent: shallowCopyMap(converted.Extra),
  1679. Media: *keys,
  1680. }
  1681. converted.Extra[failedMediaField] = meta
  1682. portal.mediaErrorCache[info.ID] = meta
  1683. }
  1684. converted.Type = event.EventMessage
  1685. converted.Content = &event.MessageEventContent{
  1686. MsgType: event.MsgNotice,
  1687. Body: fmt.Sprintf("Failed to bridge media: %v", bridgeErr),
  1688. }
  1689. return converted
  1690. }
  1691. func (portal *Portal) encryptFile(data []byte, mimeType string) ([]byte, string, *event.EncryptedFileInfo) {
  1692. if !portal.Encrypted {
  1693. return data, mimeType, nil
  1694. }
  1695. file := &event.EncryptedFileInfo{
  1696. EncryptedFile: *attachment.NewEncryptedFile(),
  1697. URL: "",
  1698. }
  1699. return file.Encrypt(data), "application/octet-stream", file
  1700. }
  1701. type MediaMessage interface {
  1702. whatsmeow.DownloadableMessage
  1703. GetContextInfo() *waProto.ContextInfo
  1704. GetFileLength() uint64
  1705. GetMimetype() string
  1706. }
  1707. type MediaMessageWithThumbnail interface {
  1708. MediaMessage
  1709. GetJpegThumbnail() []byte
  1710. }
  1711. type MediaMessageWithCaption interface {
  1712. MediaMessage
  1713. GetCaption() string
  1714. }
  1715. type MediaMessageWithDimensions interface {
  1716. MediaMessage
  1717. GetHeight() uint32
  1718. GetWidth() uint32
  1719. }
  1720. type MediaMessageWithFileName interface {
  1721. MediaMessage
  1722. GetFileName() string
  1723. }
  1724. type MediaMessageWithDuration interface {
  1725. MediaMessage
  1726. GetSeconds() uint32
  1727. }
  1728. func (portal *Portal) convertMediaMessageContent(intent *appservice.IntentAPI, msg MediaMessage) *ConvertedMessage {
  1729. content := &event.MessageEventContent{
  1730. Info: &event.FileInfo{
  1731. MimeType: msg.GetMimetype(),
  1732. Size: int(msg.GetFileLength()),
  1733. },
  1734. }
  1735. messageWithDimensions, ok := msg.(MediaMessageWithDimensions)
  1736. if ok {
  1737. content.Info.Width = int(messageWithDimensions.GetWidth())
  1738. content.Info.Height = int(messageWithDimensions.GetHeight())
  1739. }
  1740. msgWithName, ok := msg.(MediaMessageWithFileName)
  1741. if ok && len(msgWithName.GetFileName()) > 0 {
  1742. content.Body = msgWithName.GetFileName()
  1743. } else {
  1744. mimeClass := strings.Split(msg.GetMimetype(), "/")[0]
  1745. switch mimeClass {
  1746. case "application":
  1747. content.Body = "file"
  1748. default:
  1749. content.Body = mimeClass
  1750. }
  1751. content.Body += util.ExtensionFromMimetype(msg.GetMimetype())
  1752. }
  1753. msgWithDuration, ok := msg.(MediaMessageWithDuration)
  1754. if ok {
  1755. content.Info.Duration = int(msgWithDuration.GetSeconds()) * 1000
  1756. }
  1757. messageWithThumbnail, ok := msg.(MediaMessageWithThumbnail)
  1758. if ok && messageWithThumbnail.GetJpegThumbnail() != nil && portal.bridge.Config.Bridge.WhatsappThumbnail {
  1759. thumbnailData := messageWithThumbnail.GetJpegThumbnail()
  1760. thumbnailMime := http.DetectContentType(thumbnailData)
  1761. thumbnailCfg, _, _ := image.DecodeConfig(bytes.NewReader(thumbnailData))
  1762. thumbnailSize := len(thumbnailData)
  1763. thumbnail, thumbnailUploadMime, thumbnailFile := portal.encryptFile(thumbnailData, thumbnailMime)
  1764. uploadedThumbnail, err := intent.UploadBytes(thumbnail, thumbnailUploadMime)
  1765. if err != nil {
  1766. portal.log.Warnfln("Failed to upload thumbnail: %v", err)
  1767. } else if uploadedThumbnail != nil {
  1768. if thumbnailFile != nil {
  1769. thumbnailFile.URL = uploadedThumbnail.ContentURI.CUString()
  1770. content.Info.ThumbnailFile = thumbnailFile
  1771. } else {
  1772. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI.CUString()
  1773. }
  1774. content.Info.ThumbnailInfo = &event.FileInfo{
  1775. Size: thumbnailSize,
  1776. Width: thumbnailCfg.Width,
  1777. Height: thumbnailCfg.Height,
  1778. MimeType: thumbnailMime,
  1779. }
  1780. }
  1781. }
  1782. _, isSticker := msg.(*waProto.StickerMessage)
  1783. switch strings.ToLower(strings.Split(msg.GetMimetype(), "/")[0]) {
  1784. case "image":
  1785. if !isSticker {
  1786. content.MsgType = event.MsgImage
  1787. }
  1788. case "video":
  1789. content.MsgType = event.MsgVideo
  1790. case "audio":
  1791. content.MsgType = event.MsgAudio
  1792. default:
  1793. content.MsgType = event.MsgFile
  1794. }
  1795. eventType := event.EventMessage
  1796. if isSticker {
  1797. eventType = event.EventSticker
  1798. }
  1799. audioMessage, ok := msg.(*waProto.AudioMessage)
  1800. extraContent := map[string]interface{}{}
  1801. if ok {
  1802. var waveform []int
  1803. if audioMessage.Waveform != nil {
  1804. waveform = make([]int, len(audioMessage.Waveform))
  1805. for i, part := range audioMessage.Waveform {
  1806. // TODO is 4 the right multiplier?
  1807. waveform[i] = int(part) * 4
  1808. }
  1809. }
  1810. extraContent["org.matrix.msc1767.audio"] = map[string]interface{}{
  1811. "duration": int(audioMessage.GetSeconds()) * 1000,
  1812. "waveform": waveform,
  1813. }
  1814. if audioMessage.GetPtt() {
  1815. extraContent["org.matrix.msc3245.voice"] = map[string]interface{}{}
  1816. }
  1817. }
  1818. messageWithCaption, ok := msg.(MediaMessageWithCaption)
  1819. var captionContent *event.MessageEventContent
  1820. if ok && len(messageWithCaption.GetCaption()) > 0 {
  1821. captionContent = &event.MessageEventContent{
  1822. Body: messageWithCaption.GetCaption(),
  1823. MsgType: event.MsgNotice,
  1824. }
  1825. portal.bridge.Formatter.ParseWhatsApp(captionContent, msg.GetContextInfo().GetMentionedJid())
  1826. }
  1827. return &ConvertedMessage{
  1828. Intent: intent,
  1829. Type: eventType,
  1830. Content: content,
  1831. Caption: captionContent,
  1832. ReplyTo: msg.GetContextInfo().GetStanzaId(),
  1833. ExpiresIn: msg.GetContextInfo().GetExpiration(),
  1834. Extra: extraContent,
  1835. }
  1836. }
  1837. func (portal *Portal) uploadMedia(intent *appservice.IntentAPI, data []byte, content *event.MessageEventContent) error {
  1838. data, uploadMimeType, file := portal.encryptFile(data, content.Info.MimeType)
  1839. uploaded, err := intent.UploadBytes(data, uploadMimeType)
  1840. if err != nil {
  1841. return err
  1842. }
  1843. if file != nil {
  1844. file.URL = uploaded.ContentURI.CUString()
  1845. content.File = file
  1846. } else {
  1847. content.URL = uploaded.ContentURI.CUString()
  1848. }
  1849. content.Info.Size = len(data)
  1850. if content.Info.Width == 0 && content.Info.Height == 0 && strings.HasPrefix(content.Info.MimeType, "image/") {
  1851. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  1852. content.Info.Width, content.Info.Height = cfg.Width, cfg.Height
  1853. }
  1854. return nil
  1855. }
  1856. func (portal *Portal) convertMediaMessage(intent *appservice.IntentAPI, source *User, info *types.MessageInfo, msg MediaMessage) *ConvertedMessage {
  1857. converted := portal.convertMediaMessageContent(intent, msg)
  1858. data, err := source.Client.Download(msg)
  1859. if errors.Is(err, whatsmeow.ErrMediaDownloadFailedWith404) || errors.Is(err, whatsmeow.ErrMediaDownloadFailedWith410) {
  1860. //portal.log.Warnfln("Failed to download media for %s: %v. Requesting retry", info.ID, err)
  1861. //err = source.Client.SendMediaRetryReceipt(info, msg.GetMediaKey())
  1862. //if err != nil {
  1863. // portal.log.Errorfln("Failed to send media retry receipt for %s: %v", info.ID, err)
  1864. //}
  1865. converted.Error = database.MsgErrMediaNotFound
  1866. return portal.makeMediaBridgeFailureMessage(info, err, converted, &FailedMediaKeys{
  1867. Key: msg.GetMediaKey(),
  1868. Length: int(msg.GetFileLength()),
  1869. Type: whatsmeow.GetMediaType(msg),
  1870. SHA256: msg.GetFileSha256(),
  1871. EncSHA256: msg.GetFileEncSha256(),
  1872. })
  1873. } else if errors.Is(err, whatsmeow.ErrNoURLPresent) {
  1874. portal.log.Debugfln("No URL present error for media message %s, ignoring...", info.ID)
  1875. return nil
  1876. } else if errors.Is(err, whatsmeow.ErrFileLengthMismatch) || errors.Is(err, whatsmeow.ErrInvalidMediaSHA256) {
  1877. portal.log.Warnfln("Mismatching media checksums in %s: %v. Ignoring because WhatsApp seems to ignore them too", info.ID, err)
  1878. } else if err != nil {
  1879. return portal.makeMediaBridgeFailureMessage(info, err, converted, nil)
  1880. }
  1881. err = portal.uploadMedia(intent, data, converted.Content)
  1882. if err != nil {
  1883. if errors.Is(err, mautrix.MTooLarge) {
  1884. return portal.makeMediaBridgeFailureMessage(info, errors.New("homeserver rejected too large file"), converted, nil)
  1885. } else if httpErr, ok := err.(mautrix.HTTPError); ok && httpErr.IsStatus(413) {
  1886. return portal.makeMediaBridgeFailureMessage(info, errors.New("proxy rejected too large file"), converted, nil)
  1887. } else {
  1888. return portal.makeMediaBridgeFailureMessage(info, fmt.Errorf("failed to upload media: %w", err), converted, nil)
  1889. }
  1890. }
  1891. return converted
  1892. }
  1893. func (portal *Portal) fetchMediaRetryEvent(msg *database.Message) (*FailedMediaMeta, error) {
  1894. errorMeta, ok := portal.mediaErrorCache[msg.JID]
  1895. if ok {
  1896. return errorMeta, nil
  1897. }
  1898. evt, err := portal.MainIntent().GetEvent(portal.MXID, msg.MXID)
  1899. if err != nil {
  1900. return nil, fmt.Errorf("failed to fetch event %s: %w", msg.MXID, err)
  1901. }
  1902. if evt.Type == event.EventEncrypted {
  1903. err = evt.Content.ParseRaw(evt.Type)
  1904. if err != nil {
  1905. return nil, fmt.Errorf("failed to parse encrypted content in %s: %w", msg.MXID, err)
  1906. }
  1907. evt, err = portal.bridge.Crypto.Decrypt(evt)
  1908. if err != nil {
  1909. return nil, fmt.Errorf("failed to decrypt event %s: %w", msg.MXID, err)
  1910. }
  1911. }
  1912. errorMetaResult := gjson.GetBytes(evt.Content.VeryRaw, strings.ReplaceAll(failedMediaField, ".", "\\."))
  1913. if !errorMetaResult.Exists() || !errorMetaResult.IsObject() {
  1914. return nil, fmt.Errorf("didn't find failed media metadata in %s", msg.MXID)
  1915. }
  1916. var errorMetaBytes []byte
  1917. if errorMetaResult.Index > 0 {
  1918. errorMetaBytes = evt.Content.VeryRaw[errorMetaResult.Index : errorMetaResult.Index+len(errorMetaResult.Raw)]
  1919. } else {
  1920. errorMetaBytes = []byte(errorMetaResult.Raw)
  1921. }
  1922. err = json.Unmarshal(errorMetaBytes, &errorMeta)
  1923. if err != nil {
  1924. return nil, fmt.Errorf("failed to unmarshal failed media metadata in %s: %w", msg.MXID, err)
  1925. }
  1926. return errorMeta, nil
  1927. }
  1928. func (portal *Portal) handleMediaRetry(retry *events.MediaRetry, source *User) {
  1929. msg := portal.bridge.DB.Message.GetByJID(portal.Key, retry.MessageID)
  1930. if msg == nil {
  1931. portal.log.Warnfln("Dropping media retry notification for unknown message %s", retry.MessageID)
  1932. return
  1933. } else if msg.Error != database.MsgErrMediaNotFound {
  1934. portal.log.Warnfln("Dropping media retry notification for non-errored message %s / %s", retry.MessageID, msg.MXID)
  1935. return
  1936. }
  1937. meta, err := portal.fetchMediaRetryEvent(msg)
  1938. if err != nil {
  1939. portal.log.Warnfln("Can't handle media retry notification for %s: %v", retry.MessageID, err)
  1940. return
  1941. }
  1942. retryData, err := whatsmeow.DecryptMediaRetryNotification(retry, meta.Media.Key)
  1943. if err != nil {
  1944. portal.log.Warnfln("Failed to handle media retry notification for %s: %v", retry.MessageID, err)
  1945. return
  1946. } else if retryData.GetResult() != waProto.MediaRetryNotification_SUCCESS {
  1947. portal.log.Warnfln("Got error response in media retry notification for %s: %s", retry.MessageID, waProto.MediaRetryNotification_MediaRetryNotificationResultType_name[int32(retryData.GetResult())])
  1948. return
  1949. }
  1950. var puppet *Puppet
  1951. if retry.FromMe {
  1952. puppet = portal.bridge.GetPuppetByJID(source.JID)
  1953. } else if retry.ChatID.Server == types.DefaultUserServer {
  1954. puppet = portal.bridge.GetPuppetByJID(retry.ChatID)
  1955. } else {
  1956. puppet = portal.bridge.GetPuppetByJID(retry.SenderID)
  1957. }
  1958. intent := puppet.IntentFor(portal)
  1959. data, err := source.Client.DownloadMediaWithPath(retryData.GetDirectPath(), meta.Media.EncSHA256, meta.Media.SHA256, meta.Media.Key, meta.Media.Length, meta.Media.Type, "")
  1960. if err != nil {
  1961. portal.log.Warnfln("Failed to download media in %s after retry notification: %v", retry.MessageID, err)
  1962. return
  1963. }
  1964. err = portal.uploadMedia(intent, data, meta.Content)
  1965. if err != nil {
  1966. portal.log.Warnfln("Failed to re-upload media for %s after retry notification: %v", retry.MessageID, err)
  1967. return
  1968. }
  1969. replaceContent := &event.MessageEventContent{
  1970. MsgType: meta.Content.MsgType,
  1971. Body: "* " + meta.Content.Body,
  1972. NewContent: meta.Content,
  1973. RelatesTo: &event.RelatesTo{
  1974. EventID: msg.MXID,
  1975. Type: event.RelReplace,
  1976. },
  1977. }
  1978. resp, err := portal.sendMessage(intent, meta.Type, replaceContent, meta.ExtraContent, time.Now().UnixMilli())
  1979. if err != nil {
  1980. portal.log.Warnfln("Failed to edit %s after retry notification for %s: %v", msg.MXID, retry.MessageID, err)
  1981. return
  1982. }
  1983. portal.log.Debugfln("Successfully edited %s -> %s after retry notification for %s", msg.MXID, resp.EventID, retry.MessageID)
  1984. msg.UpdateMXID(resp.EventID, database.MsgNoError)
  1985. }
  1986. func (portal *Portal) requestMediaRetry(user *User, eventID id.EventID) {
  1987. msg := portal.bridge.DB.Message.GetByMXID(eventID)
  1988. if msg == nil {
  1989. portal.log.Debugfln("%s requested a media retry for unknown event %s", user.MXID, eventID)
  1990. return
  1991. } else if msg.Error != database.MsgErrMediaNotFound {
  1992. portal.log.Debugfln("%s requested a media retry for non-errored event %s", user.MXID, eventID)
  1993. return
  1994. }
  1995. evt, err := portal.fetchMediaRetryEvent(msg)
  1996. if err != nil {
  1997. portal.log.Warnfln("Can't send media retry request for %s: %v", msg.JID, err)
  1998. return
  1999. }
  2000. err = user.Client.SendMediaRetryReceipt(&types.MessageInfo{
  2001. ID: msg.JID,
  2002. MessageSource: types.MessageSource{
  2003. IsFromMe: msg.Sender.User == user.JID.User,
  2004. IsGroup: !portal.IsPrivateChat(),
  2005. Sender: msg.Sender,
  2006. Chat: portal.Key.JID,
  2007. },
  2008. }, evt.Media.Key)
  2009. if err != nil {
  2010. portal.log.Warnfln("Failed to send media retry request for %s: %v", msg.JID, err)
  2011. } else {
  2012. portal.log.Debugfln("Sent media retry request for %s", msg.JID)
  2013. }
  2014. }
  2015. const thumbnailMaxSize = 72
  2016. const thumbnailMinSize = 24
  2017. func createJPEGThumbnailAndGetSize(source []byte) ([]byte, int, int, error) {
  2018. src, _, err := image.Decode(bytes.NewReader(source))
  2019. if err != nil {
  2020. return nil, 0, 0, fmt.Errorf("failed to decode thumbnail: %w", err)
  2021. }
  2022. imageBounds := src.Bounds()
  2023. width, height := imageBounds.Max.X, imageBounds.Max.Y
  2024. var img image.Image
  2025. if width <= thumbnailMaxSize && height <= thumbnailMaxSize {
  2026. // No need to resize
  2027. img = src
  2028. } else {
  2029. if width == height {
  2030. width = thumbnailMaxSize
  2031. height = thumbnailMaxSize
  2032. } else if width < height {
  2033. width /= height / thumbnailMaxSize
  2034. height = thumbnailMaxSize
  2035. } else {
  2036. height /= width / thumbnailMaxSize
  2037. width = thumbnailMaxSize
  2038. }
  2039. if width < thumbnailMinSize {
  2040. width = thumbnailMinSize
  2041. }
  2042. if height < thumbnailMinSize {
  2043. height = thumbnailMinSize
  2044. }
  2045. dst := image.NewRGBA(image.Rect(0, 0, width, height))
  2046. draw.NearestNeighbor.Scale(dst, dst.Rect, src, src.Bounds(), draw.Over, nil)
  2047. img = dst
  2048. }
  2049. var buf bytes.Buffer
  2050. err = jpeg.Encode(&buf, img, &jpeg.Options{Quality: jpeg.DefaultQuality})
  2051. if err != nil {
  2052. return nil, width, height, fmt.Errorf("failed to re-encode thumbnail: %w", err)
  2053. }
  2054. return buf.Bytes(), width, height, nil
  2055. }
  2056. func createJPEGThumbnail(source []byte) ([]byte, error) {
  2057. data, _, _, err := createJPEGThumbnailAndGetSize(source)
  2058. return data, err
  2059. }
  2060. func (portal *Portal) downloadThumbnail(original []byte, thumbnailURL id.ContentURIString, eventID id.EventID) ([]byte, error) {
  2061. if len(thumbnailURL) == 0 {
  2062. // just fall back to making thumbnail of original
  2063. } else if mxc, err := thumbnailURL.Parse(); err != nil {
  2064. portal.log.Warnfln("Malformed thumbnail URL in %s: %v (falling back to generating thumbnail from source)", eventID, err)
  2065. } else if thumbnail, err := portal.MainIntent().DownloadBytes(mxc); err != nil {
  2066. portal.log.Warnfln("Failed to download thumbnail in %s: %v (falling back to generating thumbnail from source)", eventID, err)
  2067. } else {
  2068. return createJPEGThumbnail(thumbnail)
  2069. }
  2070. return createJPEGThumbnail(original)
  2071. }
  2072. func (portal *Portal) convertWebPtoPNG(webpImage []byte) ([]byte, error) {
  2073. webpDecoded, err := webp.Decode(bytes.NewReader(webpImage))
  2074. if err != nil {
  2075. return nil, fmt.Errorf("failed to decode webp image: %w", err)
  2076. }
  2077. var pngBuffer bytes.Buffer
  2078. if err := png.Encode(&pngBuffer, webpDecoded); err != nil {
  2079. return nil, fmt.Errorf("failed to encode png image: %w", err)
  2080. }
  2081. return pngBuffer.Bytes(), nil
  2082. }
  2083. func (portal *Portal) preprocessMatrixMedia(sender *User, relaybotFormatted bool, content *event.MessageEventContent, eventID id.EventID, mediaType whatsmeow.MediaType) *MediaUpload {
  2084. var caption string
  2085. var mentionedJIDs []string
  2086. if relaybotFormatted {
  2087. caption, mentionedJIDs = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  2088. }
  2089. var file *event.EncryptedFileInfo
  2090. rawMXC := content.URL
  2091. if content.File != nil {
  2092. file = content.File
  2093. rawMXC = file.URL
  2094. }
  2095. mxc, err := rawMXC.Parse()
  2096. if err != nil {
  2097. portal.log.Errorln("Malformed content URL in %s: %v", eventID, err)
  2098. return nil
  2099. }
  2100. data, err := portal.MainIntent().DownloadBytes(mxc)
  2101. if err != nil {
  2102. portal.log.Errorfln("Failed to download media in %s: %v", eventID, err)
  2103. return nil
  2104. }
  2105. if file != nil {
  2106. data, err = file.Decrypt(data)
  2107. if err != nil {
  2108. portal.log.Errorfln("Failed to decrypt media in %s: %v", eventID, err)
  2109. return nil
  2110. }
  2111. }
  2112. if mediaType == whatsmeow.MediaVideo && content.GetInfo().MimeType == "image/gif" {
  2113. data, err = ffmpeg.ConvertBytes(data, ".mp4", []string{"-f", "gif"}, []string{
  2114. "-pix_fmt", "yuv420p", "-c:v", "libx264", "-movflags", "+faststart",
  2115. "-filter:v", "crop='floor(in_w/2)*2:floor(in_h/2)*2'",
  2116. }, content.GetInfo().MimeType)
  2117. if err != nil {
  2118. portal.log.Errorfln("Failed to convert gif to mp4 in %s: %v", eventID, err)
  2119. return nil
  2120. }
  2121. content.Info.MimeType = "video/mp4"
  2122. }
  2123. if mediaType == whatsmeow.MediaImage && content.GetInfo().MimeType == "image/webp" {
  2124. data, err = portal.convertWebPtoPNG(data)
  2125. if err != nil {
  2126. portal.log.Errorfln("Failed to convert webp to png in %s: %v", eventID, err)
  2127. return nil
  2128. }
  2129. content.Info.MimeType = "image/png"
  2130. }
  2131. uploadResp, err := sender.Client.Upload(context.Background(), data, mediaType)
  2132. if err != nil {
  2133. portal.log.Errorfln("Failed to upload media in %s: %v", eventID, err)
  2134. return nil
  2135. }
  2136. // Audio doesn't have thumbnails
  2137. var thumbnail []byte
  2138. if mediaType != whatsmeow.MediaAudio {
  2139. thumbnail, err = portal.downloadThumbnail(data, content.GetInfo().ThumbnailURL, eventID)
  2140. // Ignore format errors for non-image files, we don't care about those thumbnails
  2141. if err != nil && (!errors.Is(err, image.ErrFormat) || mediaType == whatsmeow.MediaImage) {
  2142. portal.log.Errorfln("Failed to generate thumbnail for %s: %v", eventID, err)
  2143. }
  2144. }
  2145. return &MediaUpload{
  2146. UploadResponse: uploadResp,
  2147. Caption: caption,
  2148. MentionedJIDs: mentionedJIDs,
  2149. Thumbnail: thumbnail,
  2150. FileLength: len(data),
  2151. }
  2152. }
  2153. type MediaUpload struct {
  2154. whatsmeow.UploadResponse
  2155. Caption string
  2156. MentionedJIDs []string
  2157. Thumbnail []byte
  2158. FileLength int
  2159. }
  2160. func (portal *Portal) addRelaybotFormat(sender *User, content *event.MessageEventContent) bool {
  2161. member := portal.MainIntent().Member(portal.MXID, sender.MXID)
  2162. if member == nil {
  2163. member = &event.MemberEventContent{}
  2164. }
  2165. if content.Format != event.FormatHTML {
  2166. content.FormattedBody = strings.Replace(html.EscapeString(content.Body), "\n", "<br/>", -1)
  2167. content.Format = event.FormatHTML
  2168. }
  2169. data, err := portal.bridge.Config.Bridge.Relay.FormatMessage(content, sender.MXID, *member)
  2170. if err != nil {
  2171. portal.log.Errorln("Failed to apply relaybot format:", err)
  2172. }
  2173. content.FormattedBody = data
  2174. return true
  2175. }
  2176. func addCodecToMime(mimeType, codec string) string {
  2177. mediaType, params, err := mime.ParseMediaType(mimeType)
  2178. if err != nil {
  2179. return mimeType
  2180. }
  2181. if _, ok := params["codecs"]; !ok {
  2182. params["codecs"] = codec
  2183. }
  2184. return mime.FormatMediaType(mediaType, params)
  2185. }
  2186. func parseGeoURI(uri string) (lat, long float64, err error) {
  2187. if !strings.HasPrefix(uri, "geo:") {
  2188. err = fmt.Errorf("uri doesn't have geo: prefix")
  2189. return
  2190. }
  2191. // Remove geo: prefix and anything after ;
  2192. coordinates := strings.Split(strings.TrimPrefix(uri, "geo:"), ";")[0]
  2193. if splitCoordinates := strings.Split(coordinates, ","); len(splitCoordinates) != 2 {
  2194. err = fmt.Errorf("didn't find exactly two numbers separated by a comma")
  2195. } else if lat, err = strconv.ParseFloat(splitCoordinates[0], 64); err != nil {
  2196. err = fmt.Errorf("latitude is not a number: %w", err)
  2197. } else if long, err = strconv.ParseFloat(splitCoordinates[1], 64); err != nil {
  2198. err = fmt.Errorf("longitude is not a number: %w", err)
  2199. }
  2200. return
  2201. }
  2202. func getUnstableWaveform(content map[string]interface{}) []byte {
  2203. audioInfo, ok := content["org.matrix.msc1767.audio"].(map[string]interface{})
  2204. if !ok {
  2205. return nil
  2206. }
  2207. waveform, ok := audioInfo["waveform"].([]interface{})
  2208. if !ok {
  2209. return nil
  2210. }
  2211. output := make([]byte, len(waveform))
  2212. var val float64
  2213. for i, part := range waveform {
  2214. val, ok = part.(float64)
  2215. if ok {
  2216. output[i] = byte(val / 4)
  2217. }
  2218. }
  2219. return output
  2220. }
  2221. func (portal *Portal) convertMatrixMessage(sender *User, evt *event.Event) (*waProto.Message, *User) {
  2222. content, ok := evt.Content.Parsed.(*event.MessageEventContent)
  2223. if !ok {
  2224. portal.log.Debugfln("Failed to handle event %s: unexpected parsed content type %T", evt.ID, evt.Content.Parsed)
  2225. return nil, sender
  2226. }
  2227. var msg waProto.Message
  2228. var ctxInfo waProto.ContextInfo
  2229. replyToID := content.GetReplyTo()
  2230. if len(replyToID) > 0 {
  2231. replyToMsg := portal.bridge.DB.Message.GetByMXID(replyToID)
  2232. if replyToMsg != nil && !replyToMsg.IsFakeJID() {
  2233. ctxInfo.StanzaId = &replyToMsg.JID
  2234. ctxInfo.Participant = proto.String(replyToMsg.Sender.ToNonAD().String())
  2235. // Using blank content here seems to work fine on all official WhatsApp apps.
  2236. //
  2237. // We could probably invent a slightly more accurate version of the quoted message
  2238. // by fetching the Matrix event and converting it to the WhatsApp format, but that's
  2239. // a lot of work and this works fine.
  2240. ctxInfo.QuotedMessage = &waProto.Message{Conversation: proto.String("")}
  2241. }
  2242. }
  2243. if portal.ExpirationTime != 0 {
  2244. ctxInfo.Expiration = proto.Uint32(portal.ExpirationTime)
  2245. }
  2246. relaybotFormatted := false
  2247. if !sender.IsLoggedIn() || (portal.IsPrivateChat() && sender.JID.User != portal.Key.Receiver.User) {
  2248. if !portal.HasRelaybot() {
  2249. portal.log.Warnln("Ignoring message from", sender.MXID, "in chat with no relaybot (convertMatrixMessage)")
  2250. return nil, sender
  2251. }
  2252. relaybotFormatted = portal.addRelaybotFormat(sender, content)
  2253. sender = portal.GetRelayUser()
  2254. }
  2255. if evt.Type == event.EventSticker {
  2256. content.MsgType = event.MsgImage
  2257. }
  2258. if content.MsgType == event.MsgImage && content.GetInfo().MimeType == "image/gif" {
  2259. content.MsgType = event.MsgVideo
  2260. }
  2261. switch content.MsgType {
  2262. case event.MsgText, event.MsgEmote, event.MsgNotice:
  2263. text := content.Body
  2264. if content.MsgType == event.MsgNotice && !portal.bridge.Config.Bridge.BridgeNotices {
  2265. return nil, sender
  2266. }
  2267. if content.Format == event.FormatHTML {
  2268. text, ctxInfo.MentionedJid = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  2269. }
  2270. if content.MsgType == event.MsgEmote && !relaybotFormatted {
  2271. text = "/me " + text
  2272. }
  2273. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil || ctxInfo.Expiration != nil || evt.Content.Raw["com.beeper.linkpreviews"] != nil {
  2274. msg.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  2275. Text: &text,
  2276. ContextInfo: &ctxInfo,
  2277. }
  2278. portal.convertURLPreviewToWhatsApp(sender, evt, msg.ExtendedTextMessage)
  2279. } else {
  2280. msg.Conversation = &text
  2281. }
  2282. case event.MsgImage:
  2283. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaImage)
  2284. if media == nil {
  2285. return nil, sender
  2286. }
  2287. ctxInfo.MentionedJid = media.MentionedJIDs
  2288. msg.ImageMessage = &waProto.ImageMessage{
  2289. ContextInfo: &ctxInfo,
  2290. Caption: &media.Caption,
  2291. JpegThumbnail: media.Thumbnail,
  2292. Url: &media.URL,
  2293. MediaKey: media.MediaKey,
  2294. Mimetype: &content.GetInfo().MimeType,
  2295. FileEncSha256: media.FileEncSHA256,
  2296. FileSha256: media.FileSHA256,
  2297. FileLength: proto.Uint64(uint64(media.FileLength)),
  2298. }
  2299. case event.MsgVideo:
  2300. gifPlayback := content.GetInfo().MimeType == "image/gif"
  2301. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaVideo)
  2302. if media == nil {
  2303. return nil, sender
  2304. }
  2305. duration := uint32(content.GetInfo().Duration / 1000)
  2306. ctxInfo.MentionedJid = media.MentionedJIDs
  2307. msg.VideoMessage = &waProto.VideoMessage{
  2308. ContextInfo: &ctxInfo,
  2309. Caption: &media.Caption,
  2310. JpegThumbnail: media.Thumbnail,
  2311. Url: &media.URL,
  2312. MediaKey: media.MediaKey,
  2313. Mimetype: &content.GetInfo().MimeType,
  2314. GifPlayback: &gifPlayback,
  2315. Seconds: &duration,
  2316. FileEncSha256: media.FileEncSHA256,
  2317. FileSha256: media.FileSHA256,
  2318. FileLength: proto.Uint64(uint64(media.FileLength)),
  2319. }
  2320. case event.MsgAudio:
  2321. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaAudio)
  2322. if media == nil {
  2323. return nil, sender
  2324. }
  2325. duration := uint32(content.GetInfo().Duration / 1000)
  2326. msg.AudioMessage = &waProto.AudioMessage{
  2327. ContextInfo: &ctxInfo,
  2328. Url: &media.URL,
  2329. MediaKey: media.MediaKey,
  2330. Mimetype: &content.GetInfo().MimeType,
  2331. Seconds: &duration,
  2332. FileEncSha256: media.FileEncSHA256,
  2333. FileSha256: media.FileSHA256,
  2334. FileLength: proto.Uint64(uint64(media.FileLength)),
  2335. }
  2336. _, isMSC3245Voice := evt.Content.Raw["org.matrix.msc3245.voice"]
  2337. if isMSC3245Voice {
  2338. msg.AudioMessage.Waveform = getUnstableWaveform(evt.Content.Raw)
  2339. msg.AudioMessage.Ptt = proto.Bool(true)
  2340. // hacky hack to add the codecs param that whatsapp seems to require
  2341. msg.AudioMessage.Mimetype = proto.String(addCodecToMime(content.GetInfo().MimeType, "opus"))
  2342. }
  2343. case event.MsgFile:
  2344. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaDocument)
  2345. if media == nil {
  2346. return nil, sender
  2347. }
  2348. msg.DocumentMessage = &waProto.DocumentMessage{
  2349. ContextInfo: &ctxInfo,
  2350. JpegThumbnail: media.Thumbnail,
  2351. Url: &media.URL,
  2352. Title: &content.Body,
  2353. FileName: &content.Body,
  2354. MediaKey: media.MediaKey,
  2355. Mimetype: &content.GetInfo().MimeType,
  2356. FileEncSha256: media.FileEncSHA256,
  2357. FileSha256: media.FileSHA256,
  2358. FileLength: proto.Uint64(uint64(media.FileLength)),
  2359. }
  2360. case event.MsgLocation:
  2361. lat, long, err := parseGeoURI(content.GeoURI)
  2362. if err != nil {
  2363. portal.log.Debugfln("Invalid geo URI on Matrix event %s: %v", evt.ID, err)
  2364. return nil, sender
  2365. }
  2366. msg.LocationMessage = &waProto.LocationMessage{
  2367. DegreesLatitude: &lat,
  2368. DegreesLongitude: &long,
  2369. Comment: &content.Body,
  2370. ContextInfo: &ctxInfo,
  2371. }
  2372. default:
  2373. portal.log.Debugfln("Unhandled Matrix event %s: unknown msgtype %s", evt.ID, content.MsgType)
  2374. return nil, sender
  2375. }
  2376. return &msg, sender
  2377. }
  2378. func (portal *Portal) sendErrorMessage(message string, confirmed bool) id.EventID {
  2379. certainty := "may not have been"
  2380. if confirmed {
  2381. certainty = "was not"
  2382. }
  2383. resp, err := portal.sendMainIntentMessage(&event.MessageEventContent{
  2384. MsgType: event.MsgNotice,
  2385. Body: fmt.Sprintf("\u26a0 Your message %s bridged: %v", certainty, message),
  2386. })
  2387. if err != nil {
  2388. portal.log.Warnfln("Failed to send bridging error message:", err)
  2389. return ""
  2390. }
  2391. return resp.EventID
  2392. }
  2393. func (portal *Portal) sendDeliveryReceipt(eventID id.EventID) {
  2394. if portal.bridge.Config.Bridge.DeliveryReceipts {
  2395. err := portal.bridge.Bot.MarkRead(portal.MXID, eventID)
  2396. if err != nil {
  2397. portal.log.Debugfln("Failed to send delivery receipt for %s: %v", eventID, err)
  2398. }
  2399. }
  2400. }
  2401. func (portal *Portal) generateMessageInfo(sender *User) *types.MessageInfo {
  2402. return &types.MessageInfo{
  2403. ID: whatsmeow.GenerateMessageID(),
  2404. Timestamp: time.Now(),
  2405. MessageSource: types.MessageSource{
  2406. Sender: sender.JID,
  2407. Chat: portal.Key.JID,
  2408. IsFromMe: true,
  2409. IsGroup: portal.Key.JID.Server == types.GroupServer || portal.Key.JID.Server == types.BroadcastServer,
  2410. },
  2411. }
  2412. }
  2413. func (portal *Portal) HandleMatrixMessage(sender *User, evt *event.Event) {
  2414. if !portal.canBridgeFrom(sender, "message") {
  2415. return
  2416. }
  2417. portal.log.Debugfln("Received event %s from %s", evt.ID, evt.Sender)
  2418. msg, sender := portal.convertMatrixMessage(sender, evt)
  2419. if msg == nil {
  2420. return
  2421. }
  2422. portal.MarkDisappearing(evt.ID, portal.ExpirationTime, true)
  2423. info := portal.generateMessageInfo(sender)
  2424. dbMsg := portal.markHandled(nil, info, evt.ID, false, true, database.MsgNoError)
  2425. portal.log.Debugln("Sending event", evt.ID, "to WhatsApp", info.ID)
  2426. ts, err := sender.Client.SendMessage(portal.Key.JID, info.ID, msg)
  2427. if err != nil {
  2428. portal.log.Errorfln("Error sending message: %v", err)
  2429. portal.sendErrorMessage(err.Error(), true)
  2430. status := appservice.StatusPermFailure
  2431. if errors.Is(err, whatsmeow.ErrBroadcastListUnsupported) {
  2432. status = appservice.StatusUnsupported
  2433. }
  2434. checkpoint := appservice.NewMessageSendCheckpoint(evt, appservice.StepRemote, status, 0)
  2435. checkpoint.Info = err.Error()
  2436. go checkpoint.Send(portal.bridge.AS)
  2437. } else {
  2438. portal.log.Debugfln("Handled Matrix event %s", evt.ID)
  2439. portal.bridge.AS.SendMessageSendCheckpoint(evt, appservice.StepRemote, 0)
  2440. portal.sendDeliveryReceipt(evt.ID)
  2441. dbMsg.MarkSent(ts)
  2442. }
  2443. }
  2444. func (portal *Portal) HandleMatrixRedaction(sender *User, evt *event.Event) {
  2445. if !portal.canBridgeFrom(sender, "redaction") {
  2446. return
  2447. }
  2448. portal.log.Debugfln("Received redaction %s from %s", evt.ID, evt.Sender)
  2449. senderLogIdentifier := sender.MXID
  2450. if !sender.HasSession() {
  2451. sender = portal.GetRelayUser()
  2452. senderLogIdentifier += " (through relaybot)"
  2453. }
  2454. msg := portal.bridge.DB.Message.GetByMXID(evt.Redacts)
  2455. if msg == nil {
  2456. portal.log.Debugfln("Ignoring redaction %s of unknown event by %s", evt.ID, senderLogIdentifier)
  2457. portal.bridge.AS.SendErrorMessageSendCheckpoint(evt, appservice.StepRemote, errors.New("target not found"), true, 0)
  2458. return
  2459. } else if msg.IsFakeJID() {
  2460. portal.log.Debugfln("Ignoring redaction %s of fake event by %s", evt.ID, senderLogIdentifier)
  2461. portal.bridge.AS.SendErrorMessageSendCheckpoint(evt, appservice.StepRemote, errors.New("target is a fake event"), true, 0)
  2462. return
  2463. } else if msg.Sender.User != sender.JID.User {
  2464. portal.log.Debugfln("Ignoring redaction %s of %s/%s by %s: message was sent by someone else (%s, not %s)", evt.ID, msg.MXID, msg.JID, senderLogIdentifier, msg.Sender, sender.JID)
  2465. portal.bridge.AS.SendErrorMessageSendCheckpoint(evt, appservice.StepRemote, errors.New("message was sent by someone else"), true, 0)
  2466. return
  2467. }
  2468. portal.log.Debugfln("Sending redaction %s of %s/%s to WhatsApp", evt.ID, msg.MXID, msg.JID)
  2469. _, err := sender.Client.RevokeMessage(portal.Key.JID, msg.JID)
  2470. if err != nil {
  2471. portal.log.Errorfln("Error handling Matrix redaction %s: %v", evt.ID, err)
  2472. portal.bridge.AS.SendErrorMessageSendCheckpoint(evt, appservice.StepRemote, err, true, 0)
  2473. } else {
  2474. portal.log.Debugfln("Handled Matrix redaction %s of %s", evt.ID, evt.Redacts)
  2475. portal.bridge.AS.SendMessageSendCheckpoint(evt, appservice.StepRemote, 0)
  2476. portal.sendDeliveryReceipt(evt.ID)
  2477. }
  2478. }
  2479. func (portal *Portal) HandleMatrixReadReceipt(sender *User, eventID id.EventID, receiptTimestamp time.Time, isExplicit bool) {
  2480. if !sender.IsLoggedIn() {
  2481. if isExplicit {
  2482. portal.log.Debugfln("Ignoring read receipt by %s: user is not connected to WhatsApp", sender.JID)
  2483. }
  2484. return
  2485. }
  2486. maxTimestamp := receiptTimestamp
  2487. // Implicit read receipts don't have an event ID that's already bridged
  2488. if isExplicit {
  2489. if message := portal.bridge.DB.Message.GetByMXID(eventID); message != nil {
  2490. maxTimestamp = message.Timestamp
  2491. }
  2492. }
  2493. prevTimestamp := sender.GetLastReadTS(portal.Key)
  2494. lastReadIsZero := false
  2495. if prevTimestamp.IsZero() {
  2496. prevTimestamp = maxTimestamp.Add(-2 * time.Second)
  2497. lastReadIsZero = true
  2498. }
  2499. messages := portal.bridge.DB.Message.GetMessagesBetween(portal.Key, prevTimestamp, maxTimestamp)
  2500. if len(messages) > 0 {
  2501. sender.SetLastReadTS(portal.Key, messages[len(messages)-1].Timestamp)
  2502. }
  2503. groupedMessages := make(map[types.JID][]types.MessageID)
  2504. for _, msg := range messages {
  2505. var key types.JID
  2506. if msg.IsFakeJID() || msg.Sender.User == sender.JID.User {
  2507. // Don't send read receipts for own messages or fake messages
  2508. continue
  2509. } else if !portal.IsPrivateChat() {
  2510. key = msg.Sender
  2511. } else if !msg.BroadcastListJID.IsEmpty() {
  2512. key = msg.BroadcastListJID
  2513. } // else: blank key (participant field isn't needed in direct chat read receipts)
  2514. groupedMessages[key] = append(groupedMessages[key], msg.JID)
  2515. }
  2516. // For explicit read receipts, log even if there are no targets. For implicit ones only log when there are targets
  2517. if len(groupedMessages) > 0 || isExplicit {
  2518. portal.log.Debugfln("Sending read receipts by %s (last read: %d, was zero: %t, explicit: %t): %v",
  2519. sender.JID, prevTimestamp.Unix(), lastReadIsZero, isExplicit, groupedMessages)
  2520. }
  2521. for messageSender, ids := range groupedMessages {
  2522. chatJID := portal.Key.JID
  2523. if messageSender.Server == types.BroadcastServer {
  2524. chatJID = messageSender
  2525. messageSender = portal.Key.JID
  2526. }
  2527. err := sender.Client.MarkRead(ids, receiptTimestamp, chatJID, messageSender)
  2528. if err != nil {
  2529. portal.log.Warnfln("Failed to mark %v as read by %s: %v", ids, sender.JID, err)
  2530. }
  2531. }
  2532. if isExplicit {
  2533. portal.ScheduleDisappearing()
  2534. }
  2535. }
  2536. func typingDiff(prev, new []id.UserID) (started, stopped []id.UserID) {
  2537. OuterNew:
  2538. for _, userID := range new {
  2539. for _, previousUserID := range prev {
  2540. if userID == previousUserID {
  2541. continue OuterNew
  2542. }
  2543. }
  2544. started = append(started, userID)
  2545. }
  2546. OuterPrev:
  2547. for _, userID := range prev {
  2548. for _, previousUserID := range new {
  2549. if userID == previousUserID {
  2550. continue OuterPrev
  2551. }
  2552. }
  2553. stopped = append(stopped, userID)
  2554. }
  2555. return
  2556. }
  2557. func (portal *Portal) setTyping(userIDs []id.UserID, state types.ChatPresence) {
  2558. for _, userID := range userIDs {
  2559. user := portal.bridge.GetUserByMXIDIfExists(userID)
  2560. if user == nil || !user.IsLoggedIn() {
  2561. continue
  2562. }
  2563. portal.log.Debugfln("Bridging typing change from %s to chat presence %s", state, user.MXID)
  2564. err := user.Client.SendChatPresence(state, portal.Key.JID)
  2565. if err != nil {
  2566. portal.log.Warnln("Error sending chat presence:", err)
  2567. }
  2568. }
  2569. }
  2570. func (portal *Portal) HandleMatrixTyping(newTyping []id.UserID) {
  2571. portal.currentlyTypingLock.Lock()
  2572. defer portal.currentlyTypingLock.Unlock()
  2573. startedTyping, stoppedTyping := typingDiff(portal.currentlyTyping, newTyping)
  2574. portal.currentlyTyping = newTyping
  2575. portal.setTyping(startedTyping, types.ChatPresenceComposing)
  2576. portal.setTyping(stoppedTyping, types.ChatPresencePaused)
  2577. }
  2578. func (portal *Portal) canBridgeFrom(sender *User, evtType string) bool {
  2579. if !sender.IsLoggedIn() {
  2580. if portal.HasRelaybot() {
  2581. return true
  2582. } else if sender.Session != nil {
  2583. portal.log.Debugln("Ignoring %s from %s as user is not connected", evtType, sender.MXID)
  2584. msg := format.RenderMarkdown(fmt.Sprintf("\u26a0 You are not connected to WhatsApp, so your %s was not bridged.", evtType), true, false)
  2585. msg.MsgType = event.MsgNotice
  2586. _, err := portal.sendMainIntentMessage(&msg)
  2587. if err != nil {
  2588. portal.log.Errorln("Failed to send bridging failure message:", err)
  2589. }
  2590. } else {
  2591. portal.log.Debugfln("Ignoring %s from non-logged-in user %s in chat with no relay user", evtType, sender.MXID)
  2592. }
  2593. return false
  2594. } else if portal.IsPrivateChat() && sender.JID.User != portal.Key.Receiver.User && !portal.HasRelaybot() {
  2595. portal.log.Debugfln("Ignoring %s from different user %s/%s in private chat with no relay user", evtType, sender.MXID, sender.JID)
  2596. return false
  2597. }
  2598. return true
  2599. }
  2600. func (portal *Portal) Delete() {
  2601. portal.Portal.Delete()
  2602. portal.bridge.portalsLock.Lock()
  2603. delete(portal.bridge.portalsByJID, portal.Key)
  2604. if len(portal.MXID) > 0 {
  2605. delete(portal.bridge.portalsByMXID, portal.MXID)
  2606. }
  2607. portal.bridge.portalsLock.Unlock()
  2608. }
  2609. func (portal *Portal) GetMatrixUsers() ([]id.UserID, error) {
  2610. members, err := portal.MainIntent().JoinedMembers(portal.MXID)
  2611. if err != nil {
  2612. return nil, fmt.Errorf("failed to get member list: %w", err)
  2613. }
  2614. var users []id.UserID
  2615. for userID := range members.Joined {
  2616. _, isPuppet := portal.bridge.ParsePuppetMXID(userID)
  2617. if !isPuppet && userID != portal.bridge.Bot.UserID {
  2618. users = append(users, userID)
  2619. }
  2620. }
  2621. return users, nil
  2622. }
  2623. func (portal *Portal) CleanupIfEmpty() {
  2624. users, err := portal.GetMatrixUsers()
  2625. if err != nil {
  2626. portal.log.Errorfln("Failed to get Matrix user list to determine if portal needs to be cleaned up: %v", err)
  2627. return
  2628. }
  2629. if len(users) == 0 {
  2630. portal.log.Infoln("Room seems to be empty, cleaning up...")
  2631. portal.Delete()
  2632. portal.Cleanup(false)
  2633. }
  2634. }
  2635. func (portal *Portal) Cleanup(puppetsOnly bool) {
  2636. if len(portal.MXID) == 0 {
  2637. return
  2638. }
  2639. if portal.IsPrivateChat() {
  2640. _, err := portal.MainIntent().LeaveRoom(portal.MXID)
  2641. if err != nil {
  2642. portal.log.Warnln("Failed to leave private chat portal with main intent:", err)
  2643. }
  2644. return
  2645. }
  2646. intent := portal.MainIntent()
  2647. members, err := intent.JoinedMembers(portal.MXID)
  2648. if err != nil {
  2649. portal.log.Errorln("Failed to get portal members for cleanup:", err)
  2650. return
  2651. }
  2652. for member := range members.Joined {
  2653. if member == intent.UserID {
  2654. continue
  2655. }
  2656. puppet := portal.bridge.GetPuppetByMXID(member)
  2657. if puppet != nil {
  2658. _, err = puppet.DefaultIntent().LeaveRoom(portal.MXID)
  2659. if err != nil {
  2660. portal.log.Errorln("Error leaving as puppet while cleaning up portal:", err)
  2661. }
  2662. } else if !puppetsOnly {
  2663. _, err = intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: member, Reason: "Deleting portal"})
  2664. if err != nil {
  2665. portal.log.Errorln("Error kicking user while cleaning up portal:", err)
  2666. }
  2667. }
  2668. }
  2669. _, err = intent.LeaveRoom(portal.MXID)
  2670. if err != nil {
  2671. portal.log.Errorln("Error leaving with main intent while cleaning up portal:", err)
  2672. }
  2673. }
  2674. func (portal *Portal) HandleMatrixLeave(sender *User) {
  2675. if portal.IsPrivateChat() {
  2676. portal.log.Debugln("User left private chat portal, cleaning up and deleting...")
  2677. portal.Delete()
  2678. portal.Cleanup(false)
  2679. return
  2680. } else if portal.bridge.Config.Bridge.BridgeMatrixLeave {
  2681. err := sender.Client.LeaveGroup(portal.Key.JID)
  2682. if err != nil {
  2683. portal.log.Errorfln("Failed to leave group as %s: %v", sender.MXID, err)
  2684. return
  2685. }
  2686. //portal.log.Infoln("Leave response:", <-resp)
  2687. }
  2688. portal.CleanupIfEmpty()
  2689. }
  2690. func (portal *Portal) HandleMatrixKick(sender *User, target *Puppet) {
  2691. _, err := sender.Client.UpdateGroupParticipants(portal.Key.JID, map[types.JID]whatsmeow.ParticipantChange{
  2692. target.JID: whatsmeow.ParticipantChangeRemove,
  2693. })
  2694. if err != nil {
  2695. portal.log.Errorfln("Failed to kick %s from group as %s: %v", target.JID, sender.MXID, err)
  2696. return
  2697. }
  2698. //portal.log.Infoln("Kick %s response: %s", puppet.JID, <-resp)
  2699. }
  2700. func (portal *Portal) HandleMatrixInvite(sender *User, target *Puppet) {
  2701. _, err := sender.Client.UpdateGroupParticipants(portal.Key.JID, map[types.JID]whatsmeow.ParticipantChange{
  2702. target.JID: whatsmeow.ParticipantChangeAdd,
  2703. })
  2704. if err != nil {
  2705. portal.log.Errorfln("Failed to add %s to group as %s: %v", target.JID, sender.MXID, err)
  2706. return
  2707. }
  2708. //portal.log.Infofln("Add %s response: %s", puppet.JID, <-resp)
  2709. }
  2710. func (portal *Portal) HandleMatrixMeta(sender *User, evt *event.Event) {
  2711. switch content := evt.Content.Parsed.(type) {
  2712. case *event.RoomNameEventContent:
  2713. if content.Name == portal.Name {
  2714. return
  2715. }
  2716. portal.Name = content.Name
  2717. err := sender.Client.SetGroupName(portal.Key.JID, content.Name)
  2718. if err != nil {
  2719. portal.log.Errorln("Failed to update group name:", err)
  2720. }
  2721. case *event.TopicEventContent:
  2722. if content.Topic == portal.Topic {
  2723. return
  2724. }
  2725. portal.Topic = content.Topic
  2726. err := sender.Client.SetGroupTopic(portal.Key.JID, "", "", content.Topic)
  2727. if err != nil {
  2728. portal.log.Errorln("Failed to update group description:", err)
  2729. }
  2730. case *event.RoomAvatarEventContent:
  2731. portal.avatarLock.Lock()
  2732. defer portal.avatarLock.Unlock()
  2733. if content.URL == portal.AvatarURL || (content.URL.IsEmpty() && portal.Avatar == "remove") {
  2734. return
  2735. }
  2736. var data []byte
  2737. var err error
  2738. if !content.URL.IsEmpty() {
  2739. data, err = portal.MainIntent().DownloadBytes(content.URL)
  2740. if err != nil {
  2741. portal.log.Errorfln("Failed to download updated avatar %s: %v", content.URL, err)
  2742. return
  2743. }
  2744. portal.log.Debugfln("%s set the group avatar to %s", sender.MXID, content.URL)
  2745. } else {
  2746. portal.log.Debugfln("%s removed the group avatar", sender.MXID)
  2747. }
  2748. newID, err := sender.Client.SetGroupPhoto(portal.Key.JID, data)
  2749. if err != nil {
  2750. portal.log.Errorfln("Failed to update group avatar: %v", err)
  2751. return
  2752. }
  2753. portal.log.Debugfln("Successfully updated group avatar to %s", newID)
  2754. portal.Avatar = newID
  2755. portal.AvatarURL = content.URL
  2756. portal.UpdateBridgeInfo()
  2757. portal.Update()
  2758. }
  2759. }