portal.go 99 KB

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