portal.go 109 KB

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