portal.go 82 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2021 Tulir Asokan
  3. //
  4. // This program is free software: you can redistribute it and/or modify
  5. // it under the terms of the GNU Affero General Public License as published by
  6. // the Free Software Foundation, either version 3 of the License, or
  7. // (at your option) any later version.
  8. //
  9. // This program is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. // GNU Affero General Public License for more details.
  13. //
  14. // You should have received a copy of the GNU Affero General Public License
  15. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  16. package main
  17. import (
  18. "bytes"
  19. "context"
  20. "encoding/gob"
  21. "errors"
  22. "fmt"
  23. "html"
  24. "image"
  25. "image/gif"
  26. "image/jpeg"
  27. "image/png"
  28. "io"
  29. "math"
  30. "mime"
  31. "net/http"
  32. "os"
  33. "os/exec"
  34. "path/filepath"
  35. "strconv"
  36. "strings"
  37. "sync"
  38. "time"
  39. "golang.org/x/image/webp"
  40. "google.golang.org/protobuf/proto"
  41. "maunium.net/go/mautrix/format"
  42. "go.mau.fi/whatsmeow"
  43. waProto "go.mau.fi/whatsmeow/binary/proto"
  44. "go.mau.fi/whatsmeow/types"
  45. "go.mau.fi/whatsmeow/types/events"
  46. log "maunium.net/go/maulogger/v2"
  47. "maunium.net/go/mautrix"
  48. "maunium.net/go/mautrix/appservice"
  49. "maunium.net/go/mautrix/crypto/attachment"
  50. "maunium.net/go/mautrix/event"
  51. "maunium.net/go/mautrix/id"
  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) NewManualPortal(key database.PortalKey) *Portal {
  120. portal := &Portal{
  121. Portal: bridge.DB.Portal.New(),
  122. bridge: bridge,
  123. log: bridge.Log.Sub(fmt.Sprintf("Portal/%s", key)),
  124. messages: make(chan PortalMessage, bridge.Config.Bridge.PortalMessageBuffer),
  125. }
  126. portal.Key = key
  127. go portal.handleMessageLoop()
  128. return portal
  129. }
  130. func (bridge *Bridge) NewPortal(dbPortal *database.Portal) *Portal {
  131. portal := &Portal{
  132. Portal: dbPortal,
  133. bridge: bridge,
  134. log: bridge.Log.Sub(fmt.Sprintf("Portal/%s", dbPortal.Key)),
  135. messages: make(chan PortalMessage, bridge.Config.Bridge.PortalMessageBuffer),
  136. }
  137. go portal.handleMessageLoop()
  138. return portal
  139. }
  140. const recentlyHandledLength = 100
  141. type PortalMessage struct {
  142. evt *events.Message
  143. undecryptable *events.UndecryptableMessage
  144. source *User
  145. }
  146. type recentlyHandledWrapper struct {
  147. id types.MessageID
  148. err bool
  149. }
  150. type Portal struct {
  151. *database.Portal
  152. bridge *Bridge
  153. log log.Logger
  154. roomCreateLock sync.Mutex
  155. encryptLock sync.Mutex
  156. backfillLock sync.Mutex
  157. recentlyHandled [recentlyHandledLength]recentlyHandledWrapper
  158. recentlyHandledLock sync.Mutex
  159. recentlyHandledIndex uint8
  160. privateChatBackfillInvitePuppet func()
  161. messages chan PortalMessage
  162. relayUser *User
  163. }
  164. func (portal *Portal) handleMessageLoop() {
  165. for msg := range portal.messages {
  166. if len(portal.MXID) == 0 {
  167. if !portal.shouldCreateRoom(msg) {
  168. portal.log.Debugln("Not creating portal room for incoming message: message is not a chat message")
  169. continue
  170. }
  171. portal.log.Debugln("Creating Matrix room from incoming message")
  172. err := portal.CreateMatrixRoom(msg.source, nil)
  173. if err != nil {
  174. portal.log.Errorln("Failed to create portal room:", err)
  175. continue
  176. }
  177. }
  178. if msg.evt != nil {
  179. portal.handleMessage(msg.source, msg.evt)
  180. } else if msg.undecryptable != nil {
  181. portal.handleUndecryptableMessage(msg.source, msg.undecryptable)
  182. } else {
  183. portal.log.Warnln("Unexpected PortalMessage with no message: %+v", msg)
  184. }
  185. }
  186. }
  187. func (portal *Portal) shouldCreateRoom(msg PortalMessage) bool {
  188. if msg.undecryptable != nil {
  189. return true
  190. }
  191. waMsg := msg.evt.Message
  192. supportedMessages := []interface{}{
  193. waMsg.Conversation,
  194. waMsg.ExtendedTextMessage,
  195. waMsg.ImageMessage,
  196. waMsg.StickerMessage,
  197. waMsg.VideoMessage,
  198. waMsg.AudioMessage,
  199. waMsg.VideoMessage,
  200. waMsg.DocumentMessage,
  201. waMsg.ContactMessage,
  202. waMsg.LocationMessage,
  203. waMsg.GroupInviteMessage,
  204. }
  205. for _, message := range supportedMessages {
  206. if message != nil {
  207. return true
  208. }
  209. }
  210. return false
  211. }
  212. func (portal *Portal) getMessageType(waMsg *waProto.Message) string {
  213. switch {
  214. case waMsg == nil:
  215. return "ignore"
  216. case waMsg.Conversation != nil || waMsg.ExtendedTextMessage != nil:
  217. return "text"
  218. case waMsg.ImageMessage != nil:
  219. return fmt.Sprintf("image %s", waMsg.GetImageMessage().GetMimetype())
  220. case waMsg.StickerMessage != nil:
  221. return fmt.Sprintf("sticker %s", waMsg.GetStickerMessage().GetMimetype())
  222. case waMsg.VideoMessage != nil:
  223. return fmt.Sprintf("video %s", waMsg.GetVideoMessage().GetMimetype())
  224. case waMsg.AudioMessage != nil:
  225. return fmt.Sprintf("audio %s", waMsg.GetAudioMessage().GetMimetype())
  226. case waMsg.DocumentMessage != nil:
  227. return fmt.Sprintf("document %s", waMsg.GetDocumentMessage().GetMimetype())
  228. case waMsg.ContactMessage != nil:
  229. return "contact"
  230. case waMsg.LocationMessage != nil:
  231. return "location"
  232. case waMsg.GroupInviteMessage != nil:
  233. return "group invite"
  234. case waMsg.ProtocolMessage != nil:
  235. switch waMsg.GetProtocolMessage().GetType() {
  236. case waProto.ProtocolMessage_REVOKE:
  237. return "revoke"
  238. case waProto.ProtocolMessage_APP_STATE_SYNC_KEY_SHARE, waProto.ProtocolMessage_HISTORY_SYNC_NOTIFICATION, waProto.ProtocolMessage_INITIAL_SECURITY_NOTIFICATION_SETTING_SYNC:
  239. return "ignore"
  240. default:
  241. return "unknown_protocol"
  242. }
  243. default:
  244. return "unknown"
  245. }
  246. }
  247. func (portal *Portal) convertMessage(intent *appservice.IntentAPI, source *User, info *types.MessageInfo, waMsg *waProto.Message) *ConvertedMessage {
  248. switch {
  249. case waMsg.Conversation != nil || waMsg.ExtendedTextMessage != nil:
  250. return portal.convertTextMessage(intent, waMsg)
  251. case waMsg.ImageMessage != nil:
  252. return portal.convertMediaMessage(intent, source, info, waMsg.GetImageMessage())
  253. case waMsg.StickerMessage != nil:
  254. return portal.convertMediaMessage(intent, source, info, waMsg.GetStickerMessage())
  255. case waMsg.VideoMessage != nil:
  256. return portal.convertMediaMessage(intent, source, info, waMsg.GetVideoMessage())
  257. case waMsg.AudioMessage != nil:
  258. return portal.convertMediaMessage(intent, source, info, waMsg.GetAudioMessage())
  259. case waMsg.DocumentMessage != nil:
  260. return portal.convertMediaMessage(intent, source, info, waMsg.GetDocumentMessage())
  261. case waMsg.ContactMessage != nil:
  262. return portal.convertContactMessage(intent, waMsg.GetContactMessage())
  263. case waMsg.LocationMessage != nil:
  264. return portal.convertLocationMessage(intent, waMsg.GetLocationMessage())
  265. case waMsg.GroupInviteMessage != nil:
  266. return portal.convertGroupInviteMessage(intent, info, waMsg.GetGroupInviteMessage())
  267. default:
  268. return nil
  269. }
  270. }
  271. const UndecryptableMessageNotice = "Decrypting message from WhatsApp failed, waiting for sender to re-send... " +
  272. "([learn more](https://faq.whatsapp.com/general/security-and-privacy/seeing-waiting-for-this-message-this-may-take-a-while))"
  273. var undecryptableMessageContent event.MessageEventContent
  274. func init() {
  275. undecryptableMessageContent = format.RenderMarkdown(UndecryptableMessageNotice, true, false)
  276. undecryptableMessageContent.MsgType = event.MsgNotice
  277. }
  278. func (portal *Portal) handleUndecryptableMessage(source *User, evt *events.UndecryptableMessage) {
  279. if len(portal.MXID) == 0 {
  280. portal.log.Warnln("handleUndecryptableMessage called even though portal.MXID is empty")
  281. return
  282. } else if portal.isRecentlyHandled(evt.Info.ID, true) {
  283. portal.log.Debugfln("Not handling %s (undecryptable): message was recently handled", evt.Info.ID)
  284. return
  285. } else if existingMsg := portal.bridge.DB.Message.GetByJID(portal.Key, evt.Info.ID); existingMsg != nil {
  286. portal.log.Debugfln("Not handling %s (undecryptable): message is duplicate", evt.Info.ID)
  287. return
  288. }
  289. intent := portal.getMessageIntent(source, &evt.Info)
  290. content := undecryptableMessageContent
  291. resp, err := portal.sendMessage(intent, event.EventMessage, &content, nil, evt.Info.Timestamp.UnixMilli())
  292. if err != nil {
  293. portal.log.Errorln("Failed to send decryption error of %s to Matrix: %v", evt.Info.ID, err)
  294. }
  295. portal.finishHandling(nil, &evt.Info, resp.EventID, true)
  296. }
  297. func (portal *Portal) handleMessage(source *User, evt *events.Message) {
  298. if len(portal.MXID) == 0 {
  299. portal.log.Warnln("handleMessage called even though portal.MXID is empty")
  300. return
  301. }
  302. msgID := evt.Info.ID
  303. msgType := portal.getMessageType(evt.Message)
  304. if msgType == "ignore" {
  305. return
  306. } else if portal.isRecentlyHandled(msgID, false) {
  307. portal.log.Debugfln("Not handling %s (%s): message was recently handled", msgID, msgType)
  308. return
  309. }
  310. existingMsg := portal.bridge.DB.Message.GetByJID(portal.Key, msgID)
  311. if existingMsg != nil {
  312. if existingMsg.DecryptionError {
  313. portal.log.Debugfln("Got decryptable version of previously undecryptable message %s (%s)", msgID, msgType)
  314. } else {
  315. portal.log.Debugfln("Not handling %s (%s): message is duplicate", msgID, msgType)
  316. return
  317. }
  318. }
  319. intent := portal.getMessageIntent(source, &evt.Info)
  320. converted := portal.convertMessage(intent, source, &evt.Info, evt.Message)
  321. if converted != nil {
  322. var eventID id.EventID
  323. if existingMsg != nil {
  324. converted.Content.SetEdit(existingMsg.MXID)
  325. }
  326. resp, err := portal.sendMessage(converted.Intent, converted.Type, converted.Content, converted.Extra, evt.Info.Timestamp.UnixMilli())
  327. if err != nil {
  328. portal.log.Errorln("Failed to send %s to Matrix: %v", msgID, err)
  329. } else {
  330. eventID = resp.EventID
  331. }
  332. // TODO figure out how to handle captions with undecryptable messages turning decryptable
  333. if converted.Caption != nil && existingMsg == nil {
  334. resp, err = portal.sendMessage(converted.Intent, converted.Type, converted.Caption, nil, evt.Info.Timestamp.UnixMilli())
  335. if err != nil {
  336. portal.log.Errorln("Failed to send caption of %s to Matrix: %v", msgID, err)
  337. } else {
  338. eventID = resp.EventID
  339. }
  340. }
  341. if len(eventID) != 0 {
  342. portal.finishHandling(existingMsg, &evt.Info, resp.EventID, false)
  343. }
  344. } else if msgType == "revoke" {
  345. portal.HandleMessageRevoke(source, &evt.Info, evt.Message.GetProtocolMessage().GetKey())
  346. if existingMsg != nil {
  347. _, _ = portal.MainIntent().RedactEvent(portal.MXID, existingMsg.MXID, mautrix.ReqRedact{
  348. Reason: "The undecryptable message was actually the deletion of another message",
  349. })
  350. existingMsg.UpdateMXID("net.maunium.whatsapp.fake::"+existingMsg.MXID, false)
  351. }
  352. } else {
  353. portal.log.Warnfln("Unhandled message: %+v / %+v", evt.Info, evt.Message)
  354. if existingMsg != nil {
  355. _, _ = portal.MainIntent().RedactEvent(portal.MXID, existingMsg.MXID, mautrix.ReqRedact{
  356. Reason: "The undecryptable message contained an unsupported message type",
  357. })
  358. existingMsg.UpdateMXID("net.maunium.whatsapp.fake::"+existingMsg.MXID, false)
  359. }
  360. return
  361. }
  362. portal.bridge.Metrics.TrackWhatsAppMessage(evt.Info.Timestamp, strings.Split(msgType, " ")[0])
  363. }
  364. func (portal *Portal) isRecentlyHandled(id types.MessageID, decryptionError bool) bool {
  365. start := portal.recentlyHandledIndex
  366. lookingForMsg := recentlyHandledWrapper{id, decryptionError}
  367. for i := start; i != start; i = (i - 1) % recentlyHandledLength {
  368. if portal.recentlyHandled[i] == lookingForMsg {
  369. return true
  370. }
  371. }
  372. return false
  373. }
  374. func init() {
  375. gob.Register(&waProto.Message{})
  376. }
  377. func (portal *Portal) markHandled(msg *database.Message, info *types.MessageInfo, mxid id.EventID, isSent, recent, decryptionError bool) *database.Message {
  378. if msg == nil {
  379. msg = portal.bridge.DB.Message.New()
  380. msg.Chat = portal.Key
  381. msg.JID = info.ID
  382. msg.MXID = mxid
  383. msg.Timestamp = info.Timestamp
  384. msg.Sender = info.Sender
  385. msg.Sent = isSent
  386. msg.DecryptionError = decryptionError
  387. msg.Insert()
  388. } else {
  389. msg.UpdateMXID(mxid, decryptionError)
  390. }
  391. if recent {
  392. portal.recentlyHandledLock.Lock()
  393. index := portal.recentlyHandledIndex
  394. portal.recentlyHandledIndex = (portal.recentlyHandledIndex + 1) % recentlyHandledLength
  395. portal.recentlyHandledLock.Unlock()
  396. portal.recentlyHandled[index] = recentlyHandledWrapper{msg.JID, decryptionError}
  397. }
  398. return msg
  399. }
  400. func (portal *Portal) getMessagePuppet(user *User, info *types.MessageInfo) *Puppet {
  401. if info.IsFromMe {
  402. return portal.bridge.GetPuppetByJID(user.JID)
  403. } else if portal.IsPrivateChat() {
  404. return portal.bridge.GetPuppetByJID(portal.Key.JID)
  405. } else {
  406. puppet := portal.bridge.GetPuppetByJID(info.Sender)
  407. puppet.SyncContact(user, true)
  408. return puppet
  409. }
  410. }
  411. func (portal *Portal) getMessageIntent(user *User, info *types.MessageInfo) *appservice.IntentAPI {
  412. if info.IsFromMe {
  413. return portal.bridge.GetPuppetByJID(user.JID).IntentFor(portal)
  414. } else if portal.IsPrivateChat() {
  415. return portal.MainIntent()
  416. }
  417. puppet := portal.bridge.GetPuppetByJID(info.Sender)
  418. puppet.SyncContact(user, true)
  419. return puppet.IntentFor(portal)
  420. }
  421. func (portal *Portal) finishHandling(existing *database.Message, message *types.MessageInfo, mxid id.EventID, decryptionError bool) {
  422. portal.markHandled(existing, message, mxid, true, true, decryptionError)
  423. portal.sendDeliveryReceipt(mxid)
  424. if !decryptionError {
  425. portal.log.Debugln("Handled message", message.ID, "->", mxid)
  426. } else {
  427. portal.log.Debugln("Handled message", message.ID, "->", mxid, "(undecryptable message error notice)")
  428. }
  429. }
  430. func (portal *Portal) kickExtraUsers(participantMap map[types.JID]bool) {
  431. members, err := portal.MainIntent().JoinedMembers(portal.MXID)
  432. if err != nil {
  433. portal.log.Warnln("Failed to get member list:", err)
  434. return
  435. }
  436. for member := range members.Joined {
  437. jid, ok := portal.bridge.ParsePuppetMXID(member)
  438. if ok {
  439. _, shouldBePresent := participantMap[jid]
  440. if !shouldBePresent {
  441. _, err = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{
  442. UserID: member,
  443. Reason: "User had left this WhatsApp chat",
  444. })
  445. if err != nil {
  446. portal.log.Warnfln("Failed to kick user %s who had left: %v", member, err)
  447. }
  448. }
  449. }
  450. }
  451. }
  452. //func (portal *Portal) SyncBroadcastRecipients(source *User, metadata *whatsapp.BroadcastListInfo) {
  453. // participantMap := make(map[whatsapp.JID]bool)
  454. // for _, recipient := range metadata.Recipients {
  455. // participantMap[recipient.JID] = true
  456. //
  457. // puppet := portal.bridge.GetPuppetByJID(recipient.JID)
  458. // puppet.SyncContactIfNecessary(source)
  459. // err := puppet.DefaultIntent().EnsureJoined(portal.MXID)
  460. // if err != nil {
  461. // portal.log.Warnfln("Failed to make puppet of %s join %s: %v", recipient.JID, portal.MXID, err)
  462. // }
  463. // }
  464. // portal.kickExtraUsers(participantMap)
  465. //}
  466. func (portal *Portal) SyncParticipants(source *User, metadata *types.GroupInfo) {
  467. changed := false
  468. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  469. if err != nil {
  470. levels = portal.GetBasePowerLevels()
  471. changed = true
  472. }
  473. participantMap := make(map[types.JID]bool)
  474. for _, participant := range metadata.Participants {
  475. participantMap[participant.JID] = true
  476. puppet := portal.bridge.GetPuppetByJID(participant.JID)
  477. puppet.SyncContact(source, true)
  478. user := portal.bridge.GetUserByJID(participant.JID)
  479. if user != nil {
  480. portal.ensureUserInvited(user)
  481. }
  482. if user == nil || !puppet.IntentFor(portal).IsCustomPuppet {
  483. err = puppet.IntentFor(portal).EnsureJoined(portal.MXID)
  484. if err != nil {
  485. portal.log.Warnfln("Failed to make puppet of %s join %s: %v", participant.JID, portal.MXID, err)
  486. }
  487. }
  488. expectedLevel := 0
  489. if participant.JID == metadata.OwnerJID || participant.IsSuperAdmin {
  490. expectedLevel = 95
  491. } else if participant.IsAdmin {
  492. expectedLevel = 50
  493. }
  494. changed = levels.EnsureUserLevel(puppet.MXID, expectedLevel) || changed
  495. if user != nil {
  496. changed = levels.EnsureUserLevel(user.MXID, expectedLevel) || changed
  497. }
  498. }
  499. if changed {
  500. _, err = portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  501. if err != nil {
  502. portal.log.Errorln("Failed to change power levels:", err)
  503. }
  504. }
  505. portal.kickExtraUsers(participantMap)
  506. }
  507. func (portal *Portal) UpdateAvatar(user *User, setBy types.JID, updateInfo bool) bool {
  508. avatar, err := user.Client.GetProfilePictureInfo(portal.Key.JID, false)
  509. if err != nil {
  510. if !errors.Is(err, whatsmeow.ErrProfilePictureUnauthorized) {
  511. portal.log.Warnln("Failed to get avatar URL:", err)
  512. }
  513. return false
  514. } else if avatar == nil {
  515. if portal.Avatar == "remove" {
  516. return false
  517. }
  518. portal.AvatarURL = id.ContentURI{}
  519. avatar = &types.ProfilePictureInfo{ID: "remove"}
  520. } else if avatar.ID == portal.Avatar {
  521. return false
  522. } else if len(avatar.URL) == 0 {
  523. portal.log.Warnln("Didn't get URL in response to avatar query")
  524. return false
  525. } else {
  526. url, err := reuploadAvatar(portal.MainIntent(), avatar.URL)
  527. if err != nil {
  528. portal.log.Warnln("Failed to reupload avatar:", err)
  529. return false
  530. }
  531. portal.AvatarURL = url
  532. }
  533. if len(portal.MXID) > 0 {
  534. intent := portal.MainIntent()
  535. if !setBy.IsEmpty() {
  536. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  537. }
  538. _, err = intent.SetRoomAvatar(portal.MXID, portal.AvatarURL)
  539. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  540. _, err = portal.MainIntent().SetRoomAvatar(portal.MXID, portal.AvatarURL)
  541. }
  542. if err != nil {
  543. portal.log.Warnln("Failed to set room topic:", err)
  544. return false
  545. }
  546. }
  547. portal.Avatar = avatar.ID
  548. if updateInfo {
  549. portal.UpdateBridgeInfo()
  550. }
  551. return true
  552. }
  553. func (portal *Portal) UpdateName(name string, setBy types.JID, updateInfo bool) bool {
  554. if name == "" && portal.IsBroadcastList() {
  555. name = UnnamedBroadcastName
  556. }
  557. if portal.Name != name {
  558. portal.log.Debugfln("Updating name %s -> %s", portal.Name, name)
  559. portal.Name = name
  560. intent := portal.MainIntent()
  561. if !setBy.IsEmpty() {
  562. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  563. }
  564. _, err := intent.SetRoomName(portal.MXID, name)
  565. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  566. _, err = portal.MainIntent().SetRoomName(portal.MXID, name)
  567. }
  568. if err == nil {
  569. if updateInfo {
  570. portal.UpdateBridgeInfo()
  571. }
  572. return true
  573. } else {
  574. portal.Name = ""
  575. portal.log.Warnln("Failed to set room name:", err)
  576. }
  577. }
  578. return false
  579. }
  580. func (portal *Portal) UpdateTopic(topic string, setBy types.JID, updateInfo bool) bool {
  581. if portal.Topic != topic {
  582. portal.log.Debugfln("Updating topic %s -> %s", portal.Topic, topic)
  583. portal.Topic = topic
  584. intent := portal.MainIntent()
  585. if !setBy.IsEmpty() {
  586. intent = portal.bridge.GetPuppetByJID(setBy).IntentFor(portal)
  587. }
  588. _, err := intent.SetRoomTopic(portal.MXID, topic)
  589. if errors.Is(err, mautrix.MForbidden) && intent != portal.MainIntent() {
  590. _, err = portal.MainIntent().SetRoomTopic(portal.MXID, topic)
  591. }
  592. if err == nil {
  593. if updateInfo {
  594. portal.UpdateBridgeInfo()
  595. }
  596. return true
  597. } else {
  598. portal.Topic = ""
  599. portal.log.Warnln("Failed to set room topic:", err)
  600. }
  601. }
  602. return false
  603. }
  604. func (portal *Portal) UpdateMetadata(user *User) bool {
  605. if portal.IsPrivateChat() {
  606. return false
  607. } else if portal.IsStatusBroadcastList() {
  608. update := false
  609. update = portal.UpdateName(StatusBroadcastName, types.EmptyJID, false) || update
  610. update = portal.UpdateTopic(StatusBroadcastTopic, types.EmptyJID, false) || update
  611. return update
  612. } else if portal.IsBroadcastList() {
  613. update := false
  614. //broadcastMetadata, err := user.Conn.GetBroadcastMetadata(portal.Key.JID)
  615. //if err == nil && broadcastMetadata.Status == 200 {
  616. // portal.SyncBroadcastRecipients(user, broadcastMetadata)
  617. // update = portal.UpdateName(broadcastMetadata.Name, "", nil, false) || update
  618. //} else {
  619. // user.Conn.Store.ContactsLock.RLock()
  620. // contact, _ := user.Conn.Store.Contacts[portal.Key.JID]
  621. // user.Conn.Store.ContactsLock.RUnlock()
  622. // update = portal.UpdateName(contact.Name, "", nil, false) || update
  623. //}
  624. //update = portal.UpdateTopic(BroadcastTopic, "", nil, false) || update
  625. return update
  626. }
  627. metadata, err := user.Client.GetGroupInfo(portal.Key.JID)
  628. if err != nil {
  629. portal.log.Errorln("Failed to get group info:", err)
  630. return false
  631. }
  632. portal.SyncParticipants(user, metadata)
  633. update := false
  634. update = portal.UpdateName(metadata.Name, metadata.NameSetBy, false) || update
  635. update = portal.UpdateTopic(metadata.Topic, metadata.TopicSetBy, false) || update
  636. portal.RestrictMessageSending(metadata.IsAnnounce)
  637. portal.RestrictMetadataChanges(metadata.IsLocked)
  638. return update
  639. }
  640. func (portal *Portal) ensureMXIDInvited(mxid id.UserID) {
  641. err := portal.MainIntent().EnsureInvited(portal.MXID, mxid)
  642. if err != nil {
  643. portal.log.Warnfln("Failed to ensure %s is invited to %s: %v", mxid, portal.MXID, err)
  644. }
  645. }
  646. func (portal *Portal) ensureUserInvited(user *User) (ok bool) {
  647. inviteContent := event.Content{
  648. Parsed: &event.MemberEventContent{
  649. Membership: event.MembershipInvite,
  650. IsDirect: portal.IsPrivateChat(),
  651. },
  652. Raw: map[string]interface{}{},
  653. }
  654. customPuppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  655. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  656. inviteContent.Raw["fi.mau.will_auto_accept"] = true
  657. }
  658. _, err := portal.MainIntent().SendStateEvent(portal.MXID, event.StateMember, user.MXID.String(), &inviteContent)
  659. var httpErr mautrix.HTTPError
  660. if err != nil && errors.As(err, &httpErr) && httpErr.RespError != nil && strings.Contains(httpErr.RespError.Err, "is already in the room") {
  661. portal.bridge.StateStore.SetMembership(portal.MXID, user.MXID, event.MembershipJoin)
  662. ok = true
  663. } else if err != nil {
  664. portal.log.Warnfln("Failed to invite %s: %v", user.MXID, err)
  665. } else {
  666. ok = true
  667. }
  668. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  669. err = customPuppet.CustomIntent().EnsureJoined(portal.MXID)
  670. if err != nil {
  671. portal.log.Warnfln("Failed to auto-join portal as %s: %v", user.MXID, err)
  672. ok = false
  673. } else {
  674. ok = true
  675. }
  676. }
  677. return
  678. }
  679. func (portal *Portal) Sync(user *User, groupInfo *types.GroupInfo) bool {
  680. portal.log.Infoln("Syncing portal for", user.MXID)
  681. if len(portal.MXID) == 0 {
  682. err := portal.CreateMatrixRoom(user, groupInfo)
  683. if err != nil {
  684. portal.log.Errorln("Failed to create portal room:", err)
  685. return false
  686. }
  687. } else {
  688. portal.ensureUserInvited(user)
  689. }
  690. update := false
  691. update = portal.UpdateMetadata(user) || update
  692. if !portal.IsPrivateChat() && !portal.IsBroadcastList() && portal.Avatar == "" {
  693. update = portal.UpdateAvatar(user, types.EmptyJID, false) || update
  694. }
  695. if update {
  696. portal.Update()
  697. portal.UpdateBridgeInfo()
  698. }
  699. return true
  700. }
  701. func (portal *Portal) GetBasePowerLevels() *event.PowerLevelsEventContent {
  702. anyone := 0
  703. nope := 99
  704. invite := 50
  705. if portal.bridge.Config.Bridge.AllowUserInvite {
  706. invite = 0
  707. }
  708. return &event.PowerLevelsEventContent{
  709. UsersDefault: anyone,
  710. EventsDefault: anyone,
  711. RedactPtr: &anyone,
  712. StateDefaultPtr: &nope,
  713. BanPtr: &nope,
  714. InvitePtr: &invite,
  715. Users: map[id.UserID]int{
  716. portal.MainIntent().UserID: 100,
  717. },
  718. Events: map[string]int{
  719. event.StateRoomName.Type: anyone,
  720. event.StateRoomAvatar.Type: anyone,
  721. event.StateTopic.Type: anyone,
  722. },
  723. }
  724. }
  725. func (portal *Portal) ChangeAdminStatus(jids []types.JID, setAdmin bool) id.EventID {
  726. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  727. if err != nil {
  728. levels = portal.GetBasePowerLevels()
  729. }
  730. newLevel := 0
  731. if setAdmin {
  732. newLevel = 50
  733. }
  734. changed := false
  735. for _, jid := range jids {
  736. puppet := portal.bridge.GetPuppetByJID(jid)
  737. changed = levels.EnsureUserLevel(puppet.MXID, newLevel) || changed
  738. user := portal.bridge.GetUserByJID(jid)
  739. if user != nil {
  740. changed = levels.EnsureUserLevel(user.MXID, newLevel) || changed
  741. }
  742. }
  743. if changed {
  744. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  745. if err != nil {
  746. portal.log.Errorln("Failed to change power levels:", err)
  747. } else {
  748. return resp.EventID
  749. }
  750. }
  751. return ""
  752. }
  753. func (portal *Portal) RestrictMessageSending(restrict bool) id.EventID {
  754. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  755. if err != nil {
  756. levels = portal.GetBasePowerLevels()
  757. }
  758. newLevel := 0
  759. if restrict {
  760. newLevel = 50
  761. }
  762. if levels.EventsDefault == newLevel {
  763. return ""
  764. }
  765. levels.EventsDefault = newLevel
  766. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  767. if err != nil {
  768. portal.log.Errorln("Failed to change power levels:", err)
  769. return ""
  770. } else {
  771. return resp.EventID
  772. }
  773. }
  774. func (portal *Portal) RestrictMetadataChanges(restrict bool) id.EventID {
  775. levels, err := portal.MainIntent().PowerLevels(portal.MXID)
  776. if err != nil {
  777. levels = portal.GetBasePowerLevels()
  778. }
  779. newLevel := 0
  780. if restrict {
  781. newLevel = 50
  782. }
  783. changed := false
  784. changed = levels.EnsureEventLevel(event.StateRoomName, newLevel) || changed
  785. changed = levels.EnsureEventLevel(event.StateRoomAvatar, newLevel) || changed
  786. changed = levels.EnsureEventLevel(event.StateTopic, newLevel) || changed
  787. if changed {
  788. resp, err := portal.MainIntent().SetPowerLevels(portal.MXID, levels)
  789. if err != nil {
  790. portal.log.Errorln("Failed to change power levels:", err)
  791. } else {
  792. return resp.EventID
  793. }
  794. }
  795. return ""
  796. }
  797. func (portal *Portal) parseWebMessageInfo(webMsg *waProto.WebMessageInfo) *types.MessageInfo {
  798. info := types.MessageInfo{
  799. MessageSource: types.MessageSource{
  800. Chat: portal.Key.JID,
  801. IsFromMe: webMsg.GetKey().GetFromMe(),
  802. IsGroup: false,
  803. },
  804. ID: webMsg.GetKey().GetId(),
  805. PushName: webMsg.GetPushName(),
  806. Timestamp: time.Unix(int64(webMsg.GetMessageTimestamp()), 0),
  807. }
  808. var err error
  809. if info.IsFromMe {
  810. info.Sender = portal.Key.Receiver
  811. } else if portal.IsPrivateChat() {
  812. info.Sender = portal.Key.JID
  813. } else if webMsg.GetParticipant() != "" {
  814. info.Sender, err = types.ParseJID(webMsg.GetParticipant())
  815. } else if webMsg.GetKey().GetParticipant() != "" {
  816. info.Sender, err = types.ParseJID(webMsg.GetKey().GetParticipant())
  817. }
  818. if info.Sender.IsEmpty() {
  819. portal.log.Warnfln("Failed to get sender of message %s (parse error: %v)", info.ID, err)
  820. return nil
  821. }
  822. return &info
  823. }
  824. const backfillIDField = "fi.mau.whatsapp.backfill_msg_id"
  825. const doublePuppetField = "net.maunium.whatsapp.puppet"
  826. func (portal *Portal) wrapBatchEvent(info *types.MessageInfo, intent *appservice.IntentAPI, eventType event.Type, content *event.MessageEventContent, extraContent map[string]interface{}) (*event.Event, error) {
  827. if extraContent == nil {
  828. extraContent = map[string]interface{}{}
  829. }
  830. extraContent[backfillIDField] = info.ID
  831. if intent.IsCustomPuppet {
  832. extraContent[doublePuppetField] = intent.IsCustomPuppet
  833. }
  834. wrappedContent := event.Content{
  835. Parsed: content,
  836. Raw: extraContent,
  837. }
  838. newEventType, err := portal.encrypt(&wrappedContent, eventType)
  839. if err != nil {
  840. return nil, err
  841. }
  842. return &event.Event{
  843. Sender: intent.UserID,
  844. Type: newEventType,
  845. Timestamp: info.Timestamp.UnixMilli(),
  846. Content: wrappedContent,
  847. }, nil
  848. }
  849. func (portal *Portal) appendBatchEvents(converted *ConvertedMessage, info *types.MessageInfo, eventsArray *[]*event.Event, infoArray *[]*types.MessageInfo) error {
  850. mainEvt, err := portal.wrapBatchEvent(info, converted.Intent, converted.Type, converted.Content, converted.Extra)
  851. if err != nil {
  852. return err
  853. }
  854. if converted.Caption != nil {
  855. captionEvt, err := portal.wrapBatchEvent(info, converted.Intent, converted.Type, converted.Caption, nil)
  856. if err != nil {
  857. return err
  858. }
  859. *eventsArray = append(*eventsArray, mainEvt, captionEvt)
  860. *infoArray = append(*infoArray, nil, info)
  861. } else {
  862. *eventsArray = append(*eventsArray, mainEvt)
  863. *infoArray = append(*infoArray, info)
  864. }
  865. return nil
  866. }
  867. func (portal *Portal) finishBatch(eventIDs []id.EventID, infos []*types.MessageInfo) {
  868. if len(eventIDs) != len(infos) {
  869. portal.log.Errorfln("Length of event IDs (%d) and message infos (%d) doesn't match! Using slow path for mapping event IDs", len(eventIDs), len(infos))
  870. infoMap := make(map[types.MessageID]*types.MessageInfo, len(infos))
  871. for _, info := range infos {
  872. infoMap[info.ID] = info
  873. }
  874. for _, eventID := range eventIDs {
  875. if evt, err := portal.MainIntent().GetEvent(portal.MXID, eventID); err != nil {
  876. portal.log.Warnfln("Failed to get event %s to register it in the database: %v", eventID, err)
  877. } else if msgID, ok := evt.Content.Raw[backfillIDField].(string); !ok {
  878. portal.log.Warnfln("Event %s doesn't include the WhatsApp message ID", eventID)
  879. } else if info, ok := infoMap[types.MessageID(msgID)]; !ok {
  880. portal.log.Warnfln("Didn't find info of message %s (event %s) to register it in the database", msgID, eventID)
  881. } else {
  882. portal.markHandled(nil, info, eventID, true, false, false)
  883. }
  884. }
  885. } else {
  886. for i := 0; i < len(infos); i++ {
  887. if infos[i] != nil {
  888. portal.markHandled(nil, infos[i], eventIDs[i], true, false, false)
  889. }
  890. }
  891. portal.log.Infofln("Successfully sent %d events", len(eventIDs))
  892. }
  893. }
  894. func (portal *Portal) backfill(source *User, messages []*waProto.HistorySyncMsg) {
  895. portal.backfillLock.Lock()
  896. defer portal.backfillLock.Unlock()
  897. var historyBatch, newBatch mautrix.ReqBatchSend
  898. var historyBatchInfos, newBatchInfos []*types.MessageInfo
  899. firstMsgTimestamp := time.Unix(int64(messages[len(messages)-1].GetMessage().GetMessageTimestamp()), 0)
  900. historyBatch.StateEventsAtStart = make([]*event.Event, 1)
  901. newBatch.StateEventsAtStart = make([]*event.Event, 1)
  902. // TODO remove the dummy state events after https://github.com/matrix-org/synapse/pull/11188
  903. emptyStr := ""
  904. dummyStateEvent := event.Event{
  905. Type: BackfillDummyStateEvent,
  906. Sender: portal.MainIntent().UserID,
  907. StateKey: &emptyStr,
  908. Timestamp: firstMsgTimestamp.UnixMilli(),
  909. Content: event.Content{},
  910. }
  911. historyBatch.StateEventsAtStart[0] = &dummyStateEvent
  912. newBatch.StateEventsAtStart[0] = &dummyStateEvent
  913. addedMembers := make(map[id.UserID]*event.MemberEventContent)
  914. addMember := func(puppet *Puppet) {
  915. if _, alreadyAdded := addedMembers[puppet.MXID]; alreadyAdded {
  916. return
  917. }
  918. mxid := puppet.MXID.String()
  919. content := event.MemberEventContent{
  920. Membership: event.MembershipJoin,
  921. Displayname: puppet.Displayname,
  922. AvatarURL: puppet.AvatarURL.CUString(),
  923. }
  924. inviteContent := content
  925. inviteContent.Membership = event.MembershipInvite
  926. historyBatch.StateEventsAtStart = append(historyBatch.StateEventsAtStart, &event.Event{
  927. Type: event.StateMember,
  928. Sender: portal.MainIntent().UserID,
  929. StateKey: &mxid,
  930. Timestamp: firstMsgTimestamp.UnixMilli(),
  931. Content: event.Content{Parsed: &inviteContent},
  932. }, &event.Event{
  933. Type: event.StateMember,
  934. Sender: puppet.MXID,
  935. StateKey: &mxid,
  936. Timestamp: firstMsgTimestamp.UnixMilli(),
  937. Content: event.Content{Parsed: &content},
  938. })
  939. addedMembers[puppet.MXID] = &content
  940. }
  941. firstMessage := portal.bridge.DB.Message.GetFirstInChat(portal.Key)
  942. lastMessage := portal.bridge.DB.Message.GetLastInChat(portal.Key)
  943. var historyMaxTs, newMinTs time.Time
  944. if portal.FirstEventID != "" || portal.NextBatchID != "" {
  945. historyBatch.PrevEventID = portal.FirstEventID
  946. historyBatch.BatchID = portal.NextBatchID
  947. if firstMessage == nil && lastMessage == nil {
  948. historyMaxTs = time.Now()
  949. } else {
  950. historyMaxTs = firstMessage.Timestamp
  951. }
  952. }
  953. if lastMessage != nil {
  954. newBatch.PrevEventID = lastMessage.MXID
  955. newMinTs = lastMessage.Timestamp
  956. }
  957. portal.log.Infofln("Processing history sync with %d messages", len(messages))
  958. // The messages are ordered newest to oldest, so iterate them in reverse order.
  959. for i := len(messages) - 1; i >= 0; i-- {
  960. wrappedMsg := messages[i]
  961. webMsg := wrappedMsg.GetMessage()
  962. msgType := portal.getMessageType(webMsg.GetMessage())
  963. if msgType == "unknown" || msgType == "ignore" {
  964. if msgType == "unknown" {
  965. portal.log.Debugfln("Skipping message %s with unknown type in backfill", webMsg.GetKey().GetId())
  966. }
  967. continue
  968. }
  969. info := portal.parseWebMessageInfo(webMsg)
  970. if info == nil {
  971. continue
  972. }
  973. var batch *mautrix.ReqBatchSend
  974. var infos *[]*types.MessageInfo
  975. var history bool
  976. if !historyMaxTs.IsZero() && info.Timestamp.Before(historyMaxTs) {
  977. batch, infos, history = &historyBatch, &historyBatchInfos, true
  978. } else if !newMinTs.IsZero() && info.Timestamp.After(newMinTs) {
  979. batch, infos = &newBatch, &newBatchInfos
  980. } else {
  981. continue
  982. }
  983. puppet := portal.getMessagePuppet(source, info)
  984. var intent *appservice.IntentAPI
  985. if portal.Key.JID == puppet.JID {
  986. intent = puppet.DefaultIntent()
  987. } else {
  988. intent = puppet.IntentFor(portal)
  989. if intent.IsCustomPuppet && !portal.bridge.Config.Bridge.HistorySync.DoublePuppetBackfill {
  990. intent = puppet.DefaultIntent()
  991. addMember(puppet)
  992. }
  993. }
  994. converted := portal.convertMessage(intent, source, info, webMsg.GetMessage())
  995. if converted == nil {
  996. portal.log.Debugfln("Skipping unsupported message %s in backfill", info.ID)
  997. continue
  998. }
  999. if history && !portal.IsPrivateChat() && !portal.bridge.StateStore.IsInRoom(portal.MXID, puppet.MXID) {
  1000. addMember(puppet)
  1001. }
  1002. err := portal.appendBatchEvents(converted, info, &batch.Events, infos)
  1003. if err != nil {
  1004. portal.log.Errorfln("Error handling message %s during backfill: %v", info.ID, err)
  1005. }
  1006. }
  1007. if len(historyBatch.Events) > 0 && len(historyBatch.PrevEventID) > 0 {
  1008. portal.log.Infofln("Sending %d historical messages...", len(historyBatch.Events))
  1009. historyResp, err := portal.MainIntent().BatchSend(portal.MXID, &historyBatch)
  1010. if err != nil {
  1011. portal.log.Errorln("Error sending batch of historical messages:", err)
  1012. } else {
  1013. portal.finishBatch(historyResp.EventIDs, historyBatchInfos)
  1014. portal.NextBatchID = historyResp.NextBatchID
  1015. portal.Update()
  1016. // If batchID is non-empty, it means this is backfilling very old messages, and we don't need a post-backfill dummy.
  1017. if historyBatch.BatchID == "" {
  1018. portal.sendPostBackfillDummy(time.UnixMilli(historyBatch.Events[len(historyBatch.Events)-1].Timestamp))
  1019. }
  1020. }
  1021. }
  1022. if len(newBatch.Events) > 0 && len(newBatch.PrevEventID) > 0 {
  1023. portal.log.Debugln("Sending a dummy event to avoid forward extremity errors with forward backfill")
  1024. _, err := portal.MainIntent().SendMessageEvent(portal.MXID, ForwardBackfillDummyEvent, struct{}{})
  1025. if err != nil {
  1026. portal.log.Warnln("Error sending dummy event for forward backfill:", err)
  1027. }
  1028. portal.log.Infofln("Sending %d new messages...", len(newBatch.Events))
  1029. newResp, err := portal.MainIntent().BatchSend(portal.MXID, &newBatch)
  1030. if err != nil {
  1031. portal.log.Errorln("Error sending batch of new messages:", err)
  1032. } else {
  1033. portal.finishBatch(newResp.EventIDs, newBatchInfos)
  1034. portal.sendPostBackfillDummy(time.UnixMilli(newBatch.Events[len(newBatch.Events)-1].Timestamp))
  1035. }
  1036. }
  1037. }
  1038. func (portal *Portal) sendPostBackfillDummy(lastTimestamp time.Time) {
  1039. resp, err := portal.MainIntent().SendMessageEvent(portal.MXID, BackfillEndDummyEvent, struct{}{})
  1040. if err != nil {
  1041. portal.log.Errorln("Error sending post-backfill dummy event:", err)
  1042. return
  1043. }
  1044. msg := portal.bridge.DB.Message.New()
  1045. msg.Chat = portal.Key
  1046. msg.MXID = resp.EventID
  1047. msg.JID = types.MessageID(resp.EventID)
  1048. msg.Timestamp = lastTimestamp.Add(1 * time.Second)
  1049. msg.Sent = true
  1050. msg.Insert()
  1051. }
  1052. type BridgeInfoSection struct {
  1053. ID string `json:"id"`
  1054. DisplayName string `json:"displayname,omitempty"`
  1055. AvatarURL id.ContentURIString `json:"avatar_url,omitempty"`
  1056. ExternalURL string `json:"external_url,omitempty"`
  1057. }
  1058. type BridgeInfoContent struct {
  1059. BridgeBot id.UserID `json:"bridgebot"`
  1060. Creator id.UserID `json:"creator,omitempty"`
  1061. Protocol BridgeInfoSection `json:"protocol"`
  1062. Network *BridgeInfoSection `json:"network,omitempty"`
  1063. Channel BridgeInfoSection `json:"channel"`
  1064. }
  1065. var (
  1066. StateBridgeInfo = event.Type{Type: "m.bridge", Class: event.StateEventType}
  1067. StateHalfShotBridgeInfo = event.Type{Type: "uk.half-shot.bridge", Class: event.StateEventType}
  1068. )
  1069. func (portal *Portal) getBridgeInfo() (string, BridgeInfoContent) {
  1070. bridgeInfo := BridgeInfoContent{
  1071. BridgeBot: portal.bridge.Bot.UserID,
  1072. Creator: portal.MainIntent().UserID,
  1073. Protocol: BridgeInfoSection{
  1074. ID: "whatsapp",
  1075. DisplayName: "WhatsApp",
  1076. AvatarURL: id.ContentURIString(portal.bridge.Config.AppService.Bot.Avatar),
  1077. ExternalURL: "https://www.whatsapp.com/",
  1078. },
  1079. Channel: BridgeInfoSection{
  1080. ID: portal.Key.JID.String(),
  1081. DisplayName: portal.Name,
  1082. AvatarURL: portal.AvatarURL.CUString(),
  1083. },
  1084. }
  1085. bridgeInfoStateKey := fmt.Sprintf("net.maunium.whatsapp://whatsapp/%s", portal.Key.JID)
  1086. return bridgeInfoStateKey, bridgeInfo
  1087. }
  1088. func (portal *Portal) UpdateBridgeInfo() {
  1089. if len(portal.MXID) == 0 {
  1090. portal.log.Debugln("Not updating bridge info: no Matrix room created")
  1091. return
  1092. }
  1093. portal.log.Debugln("Updating bridge info...")
  1094. stateKey, content := portal.getBridgeInfo()
  1095. _, err := portal.MainIntent().SendStateEvent(portal.MXID, StateBridgeInfo, stateKey, content)
  1096. if err != nil {
  1097. portal.log.Warnln("Failed to update m.bridge:", err)
  1098. }
  1099. _, err = portal.MainIntent().SendStateEvent(portal.MXID, StateHalfShotBridgeInfo, stateKey, content)
  1100. if err != nil {
  1101. portal.log.Warnln("Failed to update uk.half-shot.bridge:", err)
  1102. }
  1103. }
  1104. var PortalCreationDummyEvent = event.Type{Type: "fi.mau.dummy.portal_created", Class: event.MessageEventType}
  1105. var BackfillDummyStateEvent = event.Type{Type: "fi.mau.dummy.blank_backfill_state", Class: event.StateEventType}
  1106. var BackfillEndDummyEvent = event.Type{Type: "fi.mau.dummy.backfill_end", Class: event.MessageEventType}
  1107. var ForwardBackfillDummyEvent = event.Type{Type: "fi.mau.dummy.pre_forward_backfill", Class: event.MessageEventType}
  1108. func (portal *Portal) CreateMatrixRoom(user *User, groupInfo *types.GroupInfo) error {
  1109. portal.roomCreateLock.Lock()
  1110. defer portal.roomCreateLock.Unlock()
  1111. if len(portal.MXID) > 0 {
  1112. return nil
  1113. }
  1114. intent := portal.MainIntent()
  1115. if err := intent.EnsureRegistered(); err != nil {
  1116. return err
  1117. }
  1118. portal.log.Infoln("Creating Matrix room. Info source:", user.MXID)
  1119. //var broadcastMetadata *types.BroadcastListInfo
  1120. if portal.IsPrivateChat() {
  1121. puppet := portal.bridge.GetPuppetByJID(portal.Key.JID)
  1122. puppet.SyncContact(user, true)
  1123. if portal.bridge.Config.Bridge.PrivateChatPortalMeta {
  1124. portal.Name = puppet.Displayname
  1125. portal.AvatarURL = puppet.AvatarURL
  1126. portal.Avatar = puppet.Avatar
  1127. } else {
  1128. portal.Name = ""
  1129. }
  1130. portal.Topic = PrivateChatTopic
  1131. } else if portal.IsStatusBroadcastList() {
  1132. if !portal.bridge.Config.Bridge.EnableStatusBroadcast {
  1133. portal.log.Debugln("Status bridging is disabled in config, not creating room after all")
  1134. return ErrStatusBroadcastDisabled
  1135. }
  1136. portal.Name = StatusBroadcastName
  1137. portal.Topic = StatusBroadcastTopic
  1138. } else if portal.IsBroadcastList() {
  1139. //var err error
  1140. //broadcastMetadata, err = user.Conn.GetBroadcastMetadata(portal.Key.JID)
  1141. //if err == nil && broadcastMetadata.Status == 200 {
  1142. // portal.Name = broadcastMetadata.Name
  1143. //} else {
  1144. // user.Conn.Store.ContactsLock.RLock()
  1145. // contact, _ := user.Conn.Store.Contacts[portal.Key.JID]
  1146. // user.Conn.Store.ContactsLock.RUnlock()
  1147. // portal.Name = contact.Name
  1148. //}
  1149. //if len(portal.Name) == 0 {
  1150. // portal.Name = UnnamedBroadcastName
  1151. //}
  1152. //portal.Topic = BroadcastTopic
  1153. portal.log.Debugln("Broadcast list is not yet supported, not creating room after all")
  1154. return fmt.Errorf("broadcast list bridging is currently not supported")
  1155. } else {
  1156. if groupInfo == nil {
  1157. var err error
  1158. groupInfo, err = user.Client.GetGroupInfo(portal.Key.JID)
  1159. if err != nil {
  1160. portal.log.Warnfln("Failed to get group info through %s: %v", user.JID, err)
  1161. }
  1162. }
  1163. if groupInfo != nil {
  1164. portal.Name = groupInfo.Name
  1165. portal.Topic = groupInfo.Topic
  1166. }
  1167. portal.UpdateAvatar(user, types.EmptyJID, false)
  1168. }
  1169. bridgeInfoStateKey, bridgeInfo := portal.getBridgeInfo()
  1170. initialState := []*event.Event{{
  1171. Type: event.StatePowerLevels,
  1172. Content: event.Content{
  1173. Parsed: portal.GetBasePowerLevels(),
  1174. },
  1175. }, {
  1176. Type: StateBridgeInfo,
  1177. Content: event.Content{Parsed: bridgeInfo},
  1178. StateKey: &bridgeInfoStateKey,
  1179. }, {
  1180. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  1181. Type: StateHalfShotBridgeInfo,
  1182. Content: event.Content{Parsed: bridgeInfo},
  1183. StateKey: &bridgeInfoStateKey,
  1184. }}
  1185. if !portal.AvatarURL.IsEmpty() {
  1186. initialState = append(initialState, &event.Event{
  1187. Type: event.StateRoomAvatar,
  1188. Content: event.Content{
  1189. Parsed: event.RoomAvatarEventContent{URL: portal.AvatarURL},
  1190. },
  1191. })
  1192. }
  1193. var invite []id.UserID
  1194. if portal.bridge.Config.Bridge.Encryption.Default {
  1195. initialState = append(initialState, &event.Event{
  1196. Type: event.StateEncryption,
  1197. Content: event.Content{
  1198. Parsed: event.EncryptionEventContent{Algorithm: id.AlgorithmMegolmV1},
  1199. },
  1200. })
  1201. portal.Encrypted = true
  1202. if portal.IsPrivateChat() {
  1203. invite = append(invite, portal.bridge.Bot.UserID)
  1204. }
  1205. }
  1206. resp, err := intent.CreateRoom(&mautrix.ReqCreateRoom{
  1207. Visibility: "private",
  1208. Name: portal.Name,
  1209. Topic: portal.Topic,
  1210. Invite: invite,
  1211. Preset: "private_chat",
  1212. IsDirect: portal.IsPrivateChat(),
  1213. InitialState: initialState,
  1214. })
  1215. if err != nil {
  1216. return err
  1217. }
  1218. portal.MXID = resp.RoomID
  1219. portal.Update()
  1220. portal.bridge.portalsLock.Lock()
  1221. portal.bridge.portalsByMXID[portal.MXID] = portal
  1222. portal.bridge.portalsLock.Unlock()
  1223. // We set the memberships beforehand to make sure the encryption key exchange in initial backfill knows the users are here.
  1224. for _, userID := range invite {
  1225. portal.bridge.StateStore.SetMembership(portal.MXID, userID, event.MembershipInvite)
  1226. }
  1227. portal.ensureUserInvited(user)
  1228. user.syncChatDoublePuppetDetails(portal, true)
  1229. if groupInfo != nil {
  1230. portal.SyncParticipants(user, groupInfo)
  1231. if groupInfo.IsAnnounce {
  1232. portal.RestrictMessageSending(groupInfo.IsAnnounce)
  1233. }
  1234. if groupInfo.IsLocked {
  1235. portal.RestrictMetadataChanges(groupInfo.IsLocked)
  1236. }
  1237. }
  1238. //if broadcastMetadata != nil {
  1239. // portal.SyncBroadcastRecipients(user, broadcastMetadata)
  1240. //}
  1241. if portal.IsPrivateChat() {
  1242. puppet := user.bridge.GetPuppetByJID(portal.Key.JID)
  1243. if portal.bridge.Config.Bridge.Encryption.Default {
  1244. err = portal.bridge.Bot.EnsureJoined(portal.MXID)
  1245. if err != nil {
  1246. portal.log.Errorln("Failed to join created portal with bridge bot for e2be:", err)
  1247. }
  1248. }
  1249. user.UpdateDirectChats(map[id.UserID][]id.RoomID{puppet.MXID: {portal.MXID}})
  1250. }
  1251. firstEventResp, err := portal.MainIntent().SendMessageEvent(portal.MXID, PortalCreationDummyEvent, struct{}{})
  1252. if err != nil {
  1253. portal.log.Errorln("Failed to send dummy event to mark portal creation:", err)
  1254. } else {
  1255. portal.FirstEventID = firstEventResp.EventID
  1256. portal.Update()
  1257. }
  1258. return nil
  1259. }
  1260. func (portal *Portal) IsPrivateChat() bool {
  1261. return portal.Key.JID.Server == types.DefaultUserServer
  1262. }
  1263. func (portal *Portal) IsBroadcastList() bool {
  1264. return portal.Key.JID.Server == types.BroadcastServer
  1265. }
  1266. func (portal *Portal) IsStatusBroadcastList() bool {
  1267. return portal.Key.JID == types.StatusBroadcastJID
  1268. }
  1269. func (portal *Portal) HasRelaybot() bool {
  1270. return portal.bridge.Config.Bridge.Relay.Enabled && len(portal.RelayUserID) > 0
  1271. }
  1272. func (portal *Portal) GetRelayUser() *User {
  1273. if !portal.HasRelaybot() {
  1274. return nil
  1275. } else if portal.relayUser == nil {
  1276. portal.relayUser = portal.bridge.GetUserByMXID(portal.RelayUserID)
  1277. }
  1278. return portal.relayUser
  1279. }
  1280. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  1281. if portal.IsPrivateChat() {
  1282. return portal.bridge.GetPuppetByJID(portal.Key.JID).DefaultIntent()
  1283. }
  1284. return portal.bridge.Bot
  1285. }
  1286. func (portal *Portal) SetReply(content *event.MessageEventContent, replyToID types.MessageID) {
  1287. if len(replyToID) == 0 {
  1288. return
  1289. }
  1290. message := portal.bridge.DB.Message.GetByJID(portal.Key, replyToID)
  1291. if message != nil && !message.IsFakeMXID() {
  1292. evt, err := portal.MainIntent().GetEvent(portal.MXID, message.MXID)
  1293. if err != nil {
  1294. portal.log.Warnln("Failed to get reply target:", err)
  1295. return
  1296. }
  1297. _ = evt.Content.ParseRaw(evt.Type)
  1298. if evt.Type == event.EventEncrypted {
  1299. decryptedEvt, err := portal.bridge.Crypto.Decrypt(evt)
  1300. if err != nil {
  1301. portal.log.Warnln("Failed to decrypt reply target:", err)
  1302. } else {
  1303. evt = decryptedEvt
  1304. }
  1305. }
  1306. content.SetReply(evt)
  1307. }
  1308. return
  1309. }
  1310. func (portal *Portal) HandleMessageRevoke(user *User, info *types.MessageInfo, key *waProto.MessageKey) bool {
  1311. msg := portal.bridge.DB.Message.GetByJID(portal.Key, key.GetId())
  1312. if msg == nil || msg.IsFakeMXID() {
  1313. return false
  1314. }
  1315. intent := portal.bridge.GetPuppetByJID(info.Sender).IntentFor(portal)
  1316. _, err := intent.RedactEvent(portal.MXID, msg.MXID)
  1317. if err != nil {
  1318. if errors.Is(err, mautrix.MForbidden) {
  1319. _, err = portal.MainIntent().RedactEvent(portal.MXID, msg.MXID)
  1320. if err != nil {
  1321. portal.log.Errorln("Failed to redact %s: %v", msg.JID, err)
  1322. }
  1323. }
  1324. } else {
  1325. msg.Delete()
  1326. }
  1327. return true
  1328. }
  1329. func (portal *Portal) sendMainIntentMessage(content *event.MessageEventContent) (*mautrix.RespSendEvent, error) {
  1330. return portal.sendMessage(portal.MainIntent(), event.EventMessage, content, nil, 0)
  1331. }
  1332. func (portal *Portal) encrypt(content *event.Content, eventType event.Type) (event.Type, error) {
  1333. if portal.Encrypted && portal.bridge.Crypto != nil {
  1334. // TODO maybe the locking should be inside mautrix-go?
  1335. portal.encryptLock.Lock()
  1336. encrypted, err := portal.bridge.Crypto.Encrypt(portal.MXID, eventType, *content)
  1337. portal.encryptLock.Unlock()
  1338. if err != nil {
  1339. return eventType, fmt.Errorf("failed to encrypt event: %w", err)
  1340. }
  1341. eventType = event.EventEncrypted
  1342. content.Parsed = encrypted
  1343. }
  1344. return eventType, nil
  1345. }
  1346. func (portal *Portal) sendMessage(intent *appservice.IntentAPI, eventType event.Type, content *event.MessageEventContent, extraContent map[string]interface{}, timestamp int64) (*mautrix.RespSendEvent, error) {
  1347. wrappedContent := event.Content{Parsed: content, Raw: extraContent}
  1348. if timestamp != 0 && intent.IsCustomPuppet {
  1349. if wrappedContent.Raw == nil {
  1350. wrappedContent.Raw = map[string]interface{}{}
  1351. }
  1352. wrappedContent.Raw[doublePuppetField] = intent.IsCustomPuppet
  1353. }
  1354. var err error
  1355. eventType, err = portal.encrypt(&wrappedContent, eventType)
  1356. if err != nil {
  1357. return nil, err
  1358. }
  1359. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1360. if timestamp == 0 {
  1361. return intent.SendMessageEvent(portal.MXID, eventType, &wrappedContent)
  1362. } else {
  1363. return intent.SendMassagedMessageEvent(portal.MXID, eventType, &wrappedContent, timestamp)
  1364. }
  1365. }
  1366. type ConvertedMessage struct {
  1367. Intent *appservice.IntentAPI
  1368. Type event.Type
  1369. Content *event.MessageEventContent
  1370. Extra map[string]interface{}
  1371. Caption *event.MessageEventContent
  1372. }
  1373. func (portal *Portal) convertTextMessage(intent *appservice.IntentAPI, msg *waProto.Message) *ConvertedMessage {
  1374. content := &event.MessageEventContent{
  1375. Body: msg.GetConversation(),
  1376. MsgType: event.MsgText,
  1377. }
  1378. if msg.GetExtendedTextMessage() != nil {
  1379. content.Body = msg.GetExtendedTextMessage().GetText()
  1380. contextInfo := msg.GetExtendedTextMessage().GetContextInfo()
  1381. if contextInfo != nil {
  1382. portal.bridge.Formatter.ParseWhatsApp(content, contextInfo.GetMentionedJid())
  1383. portal.SetReply(content, contextInfo.GetStanzaId())
  1384. }
  1385. }
  1386. return &ConvertedMessage{Intent: intent, Type: event.EventMessage, Content: content}
  1387. }
  1388. func (portal *Portal) convertLocationMessage(intent *appservice.IntentAPI, msg *waProto.LocationMessage) *ConvertedMessage {
  1389. url := msg.GetUrl()
  1390. if len(url) == 0 {
  1391. url = fmt.Sprintf("https://maps.google.com/?q=%.5f,%.5f", msg.GetDegreesLatitude(), msg.GetDegreesLongitude())
  1392. }
  1393. name := msg.GetName()
  1394. if len(name) == 0 {
  1395. latChar := 'N'
  1396. if msg.GetDegreesLatitude() < 0 {
  1397. latChar = 'S'
  1398. }
  1399. longChar := 'E'
  1400. if msg.GetDegreesLongitude() < 0 {
  1401. longChar = 'W'
  1402. }
  1403. name = fmt.Sprintf("%.4f° %c %.4f° %c", math.Abs(msg.GetDegreesLatitude()), latChar, math.Abs(msg.GetDegreesLongitude()), longChar)
  1404. }
  1405. content := &event.MessageEventContent{
  1406. MsgType: event.MsgLocation,
  1407. Body: fmt.Sprintf("Location: %s\n%s\n%s", name, msg.GetAddress(), url),
  1408. Format: event.FormatHTML,
  1409. FormattedBody: fmt.Sprintf("Location: <a href='%s'>%s</a><br>%s", url, name, msg.GetAddress()),
  1410. GeoURI: fmt.Sprintf("geo:%.5f,%.5f", msg.GetDegreesLatitude(), msg.GetDegreesLongitude()),
  1411. }
  1412. if len(msg.GetJpegThumbnail()) > 0 {
  1413. thumbnailMime := http.DetectContentType(msg.GetJpegThumbnail())
  1414. uploadedThumbnail, _ := intent.UploadBytes(msg.GetJpegThumbnail(), thumbnailMime)
  1415. if uploadedThumbnail != nil {
  1416. cfg, _, _ := image.DecodeConfig(bytes.NewReader(msg.GetJpegThumbnail()))
  1417. content.Info = &event.FileInfo{
  1418. ThumbnailInfo: &event.FileInfo{
  1419. Size: len(msg.GetJpegThumbnail()),
  1420. Width: cfg.Width,
  1421. Height: cfg.Height,
  1422. MimeType: thumbnailMime,
  1423. },
  1424. ThumbnailURL: uploadedThumbnail.ContentURI.CUString(),
  1425. }
  1426. }
  1427. }
  1428. portal.SetReply(content, msg.GetContextInfo().GetStanzaId())
  1429. return &ConvertedMessage{Intent: intent, Type: event.EventMessage, Content: content}
  1430. }
  1431. const inviteMsg = `<a href="https://matrix.to/#/%s">%s</a> has invited you to join %s:
  1432. <blockquote>%s</blockquote>
  1433. The invite expires at %s. Reply to this message with <code>!wa accept</code> to accept the invite.`
  1434. const inviteMetaField = "fi.mau.whatsapp.invite"
  1435. func (portal *Portal) convertGroupInviteMessage(intent *appservice.IntentAPI, info *types.MessageInfo, msg *waProto.GroupInviteMessage) *ConvertedMessage {
  1436. puppet := portal.bridge.GetPuppetByJID(info.Sender)
  1437. expiry := time.Unix(msg.GetInviteExpiration(), 0)
  1438. htmlMessage := fmt.Sprintf(inviteMsg, intent.UserID, html.EscapeString(puppet.Displayname), msg.GetGroupName(), html.EscapeString(msg.GetCaption()), expiry)
  1439. content := &event.MessageEventContent{
  1440. MsgType: event.MsgText,
  1441. Body: format.HTMLToText(htmlMessage),
  1442. Format: event.FormatHTML,
  1443. FormattedBody: htmlMessage,
  1444. }
  1445. extraAttrs := map[string]interface{}{
  1446. inviteMetaField: map[string]interface{}{
  1447. "jid": msg.GetGroupJid(),
  1448. "code": msg.GetInviteCode(),
  1449. "expiration": strconv.FormatInt(msg.GetInviteExpiration(), 10),
  1450. "inviter": info.Sender.ToNonAD().String(),
  1451. },
  1452. }
  1453. portal.SetReply(content, msg.GetContextInfo().GetStanzaId())
  1454. return &ConvertedMessage{Intent: intent, Type: event.EventMessage, Content: content, Extra: extraAttrs}
  1455. }
  1456. func (portal *Portal) convertContactMessage(intent *appservice.IntentAPI, msg *waProto.ContactMessage) *ConvertedMessage {
  1457. fileName := fmt.Sprintf("%s.vcf", msg.GetDisplayName())
  1458. data := []byte(msg.GetVcard())
  1459. mimeType := "text/vcard"
  1460. data, uploadMimeType, file := portal.encryptFile(data, mimeType)
  1461. uploadResp, err := intent.UploadBytesWithName(data, uploadMimeType, fileName)
  1462. if err != nil {
  1463. portal.log.Errorfln("Failed to upload vcard of %s: %v", msg.GetDisplayName(), err)
  1464. return nil
  1465. }
  1466. content := &event.MessageEventContent{
  1467. Body: fileName,
  1468. MsgType: event.MsgFile,
  1469. File: file,
  1470. Info: &event.FileInfo{
  1471. MimeType: mimeType,
  1472. Size: len(msg.GetVcard()),
  1473. },
  1474. }
  1475. if content.File != nil {
  1476. content.File.URL = uploadResp.ContentURI.CUString()
  1477. } else {
  1478. content.URL = uploadResp.ContentURI.CUString()
  1479. }
  1480. portal.SetReply(content, msg.GetContextInfo().GetStanzaId())
  1481. return &ConvertedMessage{Intent: intent, Type: event.EventMessage, Content: content}
  1482. }
  1483. func (portal *Portal) tryKickUser(userID id.UserID, intent *appservice.IntentAPI) error {
  1484. _, err := intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: userID})
  1485. if err != nil {
  1486. httpErr, ok := err.(mautrix.HTTPError)
  1487. if ok && httpErr.RespError != nil && httpErr.RespError.ErrCode == "M_FORBIDDEN" {
  1488. _, err = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: userID})
  1489. }
  1490. }
  1491. return err
  1492. }
  1493. func (portal *Portal) removeUser(isSameUser bool, kicker *appservice.IntentAPI, target id.UserID, targetIntent *appservice.IntentAPI) {
  1494. if !isSameUser || targetIntent == nil {
  1495. err := portal.tryKickUser(target, kicker)
  1496. if err != nil {
  1497. portal.log.Warnfln("Failed to kick %s from %s: %v", target, portal.MXID, err)
  1498. if targetIntent != nil {
  1499. _, _ = portal.leaveWithPuppetMeta(targetIntent)
  1500. }
  1501. }
  1502. } else {
  1503. _, err := portal.leaveWithPuppetMeta(targetIntent)
  1504. if err != nil {
  1505. portal.log.Warnfln("Failed to leave portal as %s: %v", target, err)
  1506. _, _ = portal.MainIntent().KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: target})
  1507. }
  1508. }
  1509. }
  1510. func (portal *Portal) HandleWhatsAppKick(source *User, senderJID types.JID, jids []types.JID) {
  1511. sender := portal.bridge.GetPuppetByJID(senderJID)
  1512. senderIntent := sender.IntentFor(portal)
  1513. for _, jid := range jids {
  1514. if source != nil && source.JID.User == jid.User {
  1515. portal.log.Debugln("Ignoring self-kick by", source.MXID)
  1516. continue
  1517. }
  1518. puppet := portal.bridge.GetPuppetByJID(jid)
  1519. portal.removeUser(puppet.JID == sender.JID, senderIntent, puppet.MXID, puppet.DefaultIntent())
  1520. if !portal.IsBroadcastList() {
  1521. user := portal.bridge.GetUserByJID(jid)
  1522. if user != nil {
  1523. var customIntent *appservice.IntentAPI
  1524. if puppet.CustomMXID == user.MXID {
  1525. customIntent = puppet.CustomIntent()
  1526. }
  1527. portal.removeUser(puppet.JID == sender.JID, senderIntent, user.MXID, customIntent)
  1528. }
  1529. }
  1530. }
  1531. }
  1532. func (portal *Portal) leaveWithPuppetMeta(intent *appservice.IntentAPI) (*mautrix.RespSendEvent, error) {
  1533. content := event.Content{
  1534. Parsed: event.MemberEventContent{
  1535. Membership: event.MembershipLeave,
  1536. },
  1537. Raw: map[string]interface{}{
  1538. doublePuppetField: true,
  1539. },
  1540. }
  1541. return intent.SendStateEvent(portal.MXID, event.StateMember, intent.UserID.String(), &content)
  1542. }
  1543. func (portal *Portal) HandleWhatsAppInvite(source *User, senderJID *types.JID, jids []types.JID) (evtID id.EventID) {
  1544. intent := portal.MainIntent()
  1545. if senderJID != nil && !senderJID.IsEmpty() {
  1546. sender := portal.bridge.GetPuppetByJID(*senderJID)
  1547. intent = sender.IntentFor(portal)
  1548. }
  1549. for _, jid := range jids {
  1550. puppet := portal.bridge.GetPuppetByJID(jid)
  1551. puppet.SyncContact(source, true)
  1552. content := event.Content{
  1553. Parsed: event.MemberEventContent{
  1554. Membership: "invite",
  1555. Displayname: puppet.Displayname,
  1556. AvatarURL: puppet.AvatarURL.CUString(),
  1557. },
  1558. Raw: map[string]interface{}{
  1559. doublePuppetField: true,
  1560. },
  1561. }
  1562. resp, err := intent.SendStateEvent(portal.MXID, event.StateMember, puppet.MXID.String(), &content)
  1563. if err != nil {
  1564. portal.log.Warnfln("Failed to invite %s as %s: %v", puppet.MXID, intent.UserID, err)
  1565. _ = portal.MainIntent().EnsureInvited(portal.MXID, puppet.MXID)
  1566. } else {
  1567. evtID = resp.EventID
  1568. }
  1569. err = puppet.DefaultIntent().EnsureJoined(portal.MXID)
  1570. if err != nil {
  1571. portal.log.Errorfln("Failed to ensure %s is joined: %v", puppet.MXID, err)
  1572. }
  1573. }
  1574. return
  1575. }
  1576. func (portal *Portal) makeMediaBridgeFailureMessage(intent *appservice.IntentAPI, info *types.MessageInfo, bridgeErr error, captionContent *event.MessageEventContent) *ConvertedMessage {
  1577. portal.log.Errorfln("Failed to bridge media for %s: %v", info.ID, bridgeErr)
  1578. return &ConvertedMessage{Intent: intent, Type: event.EventMessage, Content: &event.MessageEventContent{
  1579. MsgType: event.MsgNotice,
  1580. Body: "Failed to bridge media",
  1581. }, Caption: captionContent}
  1582. }
  1583. func (portal *Portal) encryptFile(data []byte, mimeType string) ([]byte, string, *event.EncryptedFileInfo) {
  1584. if !portal.Encrypted {
  1585. return data, mimeType, nil
  1586. }
  1587. file := &event.EncryptedFileInfo{
  1588. EncryptedFile: *attachment.NewEncryptedFile(),
  1589. URL: "",
  1590. }
  1591. return file.Encrypt(data), "application/octet-stream", file
  1592. }
  1593. type MediaMessage interface {
  1594. whatsmeow.DownloadableMessage
  1595. GetContextInfo() *waProto.ContextInfo
  1596. GetMimetype() string
  1597. }
  1598. type MediaMessageWithThumbnail interface {
  1599. MediaMessage
  1600. GetJpegThumbnail() []byte
  1601. GetCaption() string
  1602. }
  1603. type MediaMessageWithCaption interface {
  1604. MediaMessage
  1605. GetCaption() string
  1606. }
  1607. type MediaMessageWithFileName interface {
  1608. MediaMessage
  1609. GetFileName() string
  1610. }
  1611. type MediaMessageWithDuration interface {
  1612. MediaMessage
  1613. GetSeconds() uint32
  1614. }
  1615. func (portal *Portal) convertMediaMessage(intent *appservice.IntentAPI, source *User, info *types.MessageInfo, msg MediaMessage) *ConvertedMessage {
  1616. messageWithCaption, ok := msg.(MediaMessageWithCaption)
  1617. var captionContent *event.MessageEventContent
  1618. if ok && len(messageWithCaption.GetCaption()) > 0 {
  1619. captionContent = &event.MessageEventContent{
  1620. Body: messageWithCaption.GetCaption(),
  1621. MsgType: event.MsgNotice,
  1622. }
  1623. portal.bridge.Formatter.ParseWhatsApp(captionContent, msg.GetContextInfo().GetMentionedJid())
  1624. }
  1625. data, err := source.Client.Download(msg)
  1626. // TODO can these errors still be handled?
  1627. //if errors.Is(err, whatsapp.ErrMediaDownloadFailedWith404) || errors.Is(err, whatsapp.ErrMediaDownloadFailedWith410) {
  1628. // portal.log.Warnfln("Failed to download media for %s: %v. Calling LoadMediaInfo and retrying download...", msg.info.Id, err)
  1629. // _, err = source.Conn.LoadMediaInfo(msg.info.RemoteJid, msg.info.Id, msg.info.FromMe)
  1630. // if err != nil {
  1631. // portal.sendMediaBridgeFailure(source, intent, msg.info, fmt.Errorf("failed to load media info: %w", err))
  1632. // return true
  1633. // }
  1634. // data, err = msg.download()
  1635. //}
  1636. if errors.Is(err, whatsmeow.ErrNoURLPresent) {
  1637. portal.log.Debugfln("No URL present error for media message %s, ignoring...", info.ID)
  1638. return nil
  1639. } else if err != nil {
  1640. return portal.makeMediaBridgeFailureMessage(intent, info, err, captionContent)
  1641. }
  1642. var width, height int
  1643. if strings.HasPrefix(msg.GetMimetype(), "image/") {
  1644. cfg, _, _ := image.DecodeConfig(bytes.NewReader(data))
  1645. width, height = cfg.Width, cfg.Height
  1646. }
  1647. data, uploadMimeType, file := portal.encryptFile(data, msg.GetMimetype())
  1648. uploaded, err := intent.UploadBytes(data, uploadMimeType)
  1649. if err != nil {
  1650. if errors.Is(err, mautrix.MTooLarge) {
  1651. return portal.makeMediaBridgeFailureMessage(intent, info, errors.New("homeserver rejected too large file"), captionContent)
  1652. } else if httpErr, ok := err.(mautrix.HTTPError); ok && httpErr.IsStatus(413) {
  1653. return portal.makeMediaBridgeFailureMessage(intent, info, errors.New("proxy rejected too large file"), captionContent)
  1654. } else {
  1655. return portal.makeMediaBridgeFailureMessage(intent, info, fmt.Errorf("failed to upload media: %w", err), captionContent)
  1656. }
  1657. }
  1658. content := &event.MessageEventContent{
  1659. File: file,
  1660. Info: &event.FileInfo{
  1661. Size: len(data),
  1662. MimeType: msg.GetMimetype(),
  1663. Width: width,
  1664. Height: height,
  1665. },
  1666. }
  1667. msgWithName, ok := msg.(MediaMessageWithFileName)
  1668. if ok && len(msgWithName.GetFileName()) > 0 {
  1669. content.Body = msgWithName.GetFileName()
  1670. } else {
  1671. mimeClass := strings.Split(msg.GetMimetype(), "/")[0]
  1672. switch mimeClass {
  1673. case "application":
  1674. content.Body = "file"
  1675. default:
  1676. content.Body = mimeClass
  1677. }
  1678. exts, _ := mime.ExtensionsByType(msg.GetMimetype())
  1679. if exts != nil && len(exts) > 0 {
  1680. content.Body += exts[0]
  1681. }
  1682. }
  1683. msgWithDuration, ok := msg.(MediaMessageWithDuration)
  1684. if ok {
  1685. content.Info.Duration = int(msgWithDuration.GetSeconds()) * 1000
  1686. }
  1687. if content.File != nil {
  1688. content.File.URL = uploaded.ContentURI.CUString()
  1689. } else {
  1690. content.URL = uploaded.ContentURI.CUString()
  1691. }
  1692. portal.SetReply(content, msg.GetContextInfo().GetStanzaId())
  1693. messageWithThumbnail, ok := msg.(MediaMessageWithThumbnail)
  1694. if ok && messageWithThumbnail.GetJpegThumbnail() != nil && portal.bridge.Config.Bridge.WhatsappThumbnail {
  1695. thumbnailData := messageWithThumbnail.GetJpegThumbnail()
  1696. thumbnailMime := http.DetectContentType(thumbnailData)
  1697. thumbnailCfg, _, _ := image.DecodeConfig(bytes.NewReader(thumbnailData))
  1698. thumbnailSize := len(thumbnailData)
  1699. thumbnail, thumbnailUploadMime, thumbnailFile := portal.encryptFile(thumbnailData, thumbnailMime)
  1700. uploadedThumbnail, err := intent.UploadBytes(thumbnail, thumbnailUploadMime)
  1701. if err != nil {
  1702. portal.log.Warnfln("Failed to upload thumbnail for %s: %v", info.ID, err)
  1703. } else if uploadedThumbnail != nil {
  1704. if thumbnailFile != nil {
  1705. thumbnailFile.URL = uploadedThumbnail.ContentURI.CUString()
  1706. content.Info.ThumbnailFile = thumbnailFile
  1707. } else {
  1708. content.Info.ThumbnailURL = uploadedThumbnail.ContentURI.CUString()
  1709. }
  1710. content.Info.ThumbnailInfo = &event.FileInfo{
  1711. Size: thumbnailSize,
  1712. Width: thumbnailCfg.Width,
  1713. Height: thumbnailCfg.Height,
  1714. MimeType: thumbnailMime,
  1715. }
  1716. }
  1717. }
  1718. _, isSticker := msg.(*waProto.StickerMessage)
  1719. switch strings.ToLower(strings.Split(msg.GetMimetype(), "/")[0]) {
  1720. case "image":
  1721. if !isSticker {
  1722. content.MsgType = event.MsgImage
  1723. }
  1724. case "video":
  1725. content.MsgType = event.MsgVideo
  1726. case "audio":
  1727. content.MsgType = event.MsgAudio
  1728. default:
  1729. content.MsgType = event.MsgFile
  1730. }
  1731. eventType := event.EventMessage
  1732. if isSticker {
  1733. eventType = event.EventSticker
  1734. }
  1735. return &ConvertedMessage{
  1736. Intent: intent,
  1737. Type: eventType,
  1738. Content: content,
  1739. Caption: captionContent,
  1740. }
  1741. }
  1742. func (portal *Portal) downloadThumbnail(content *event.MessageEventContent, id id.EventID) []byte {
  1743. if len(content.GetInfo().ThumbnailURL) == 0 {
  1744. return nil
  1745. }
  1746. mxc, err := content.GetInfo().ThumbnailURL.Parse()
  1747. if err != nil {
  1748. portal.log.Errorln("Malformed thumbnail URL in %s: %v", id, err)
  1749. }
  1750. thumbnail, err := portal.MainIntent().DownloadBytes(mxc)
  1751. if err != nil {
  1752. portal.log.Errorln("Failed to download thumbnail in %s: %v", id, err)
  1753. return nil
  1754. }
  1755. thumbnailType := http.DetectContentType(thumbnail)
  1756. var img image.Image
  1757. switch thumbnailType {
  1758. case "image/png":
  1759. img, err = png.Decode(bytes.NewReader(thumbnail))
  1760. case "image/gif":
  1761. img, err = gif.Decode(bytes.NewReader(thumbnail))
  1762. case "image/jpeg":
  1763. return thumbnail
  1764. default:
  1765. return nil
  1766. }
  1767. var buf bytes.Buffer
  1768. err = jpeg.Encode(&buf, img, &jpeg.Options{
  1769. Quality: jpeg.DefaultQuality,
  1770. })
  1771. if err != nil {
  1772. portal.log.Errorln("Failed to re-encode thumbnail in %s: %v", id, err)
  1773. return nil
  1774. }
  1775. return buf.Bytes()
  1776. }
  1777. func (portal *Portal) convertWebPtoPNG(webpImage []byte) ([]byte, error) {
  1778. webpDecoded, err := webp.Decode(bytes.NewReader(webpImage))
  1779. if err != nil {
  1780. return nil, fmt.Errorf("failed to decode webp image: %w", err)
  1781. }
  1782. var pngBuffer bytes.Buffer
  1783. if err := png.Encode(&pngBuffer, webpDecoded); err != nil {
  1784. return nil, fmt.Errorf("failed to encode png image: %w", err)
  1785. }
  1786. return pngBuffer.Bytes(), nil
  1787. }
  1788. func (portal *Portal) convertGifToVideo(gif []byte) ([]byte, error) {
  1789. dir, err := os.MkdirTemp("", "gif-convert-*")
  1790. if err != nil {
  1791. return nil, fmt.Errorf("failed to make temp dir: %w", err)
  1792. }
  1793. defer os.RemoveAll(dir)
  1794. inputFile, err := os.OpenFile(filepath.Join(dir, "input.gif"), os.O_CREATE|os.O_EXCL|os.O_WRONLY, 0600)
  1795. if err != nil {
  1796. return nil, fmt.Errorf("failed open input file: %w", err)
  1797. }
  1798. _, err = inputFile.Write(gif)
  1799. if err != nil {
  1800. _ = inputFile.Close()
  1801. return nil, fmt.Errorf("failed to write gif to input file: %w", err)
  1802. }
  1803. _ = inputFile.Close()
  1804. outputFileName := filepath.Join(dir, "output.mp4")
  1805. cmd := exec.Command("ffmpeg", "-hide_banner", "-loglevel", "warning",
  1806. "-f", "gif", "-i", inputFile.Name(),
  1807. "-pix_fmt", "yuv420p", "-c:v", "libx264", "-movflags", "+faststart",
  1808. "-filter:v", "crop='floor(in_w/2)*2:floor(in_h/2)*2'",
  1809. outputFileName)
  1810. vcLog := portal.log.Sub("VideoConverter").Writer(log.LevelWarn)
  1811. cmd.Stdout = vcLog
  1812. cmd.Stderr = vcLog
  1813. err = cmd.Run()
  1814. if err != nil {
  1815. return nil, fmt.Errorf("failed to run ffmpeg: %w", err)
  1816. }
  1817. outputFile, err := os.OpenFile(filepath.Join(dir, "output.mp4"), os.O_RDONLY, 0)
  1818. if err != nil {
  1819. return nil, fmt.Errorf("failed to open output file: %w", err)
  1820. }
  1821. defer func() {
  1822. _ = outputFile.Close()
  1823. _ = os.Remove(outputFile.Name())
  1824. }()
  1825. mp4, err := io.ReadAll(outputFile)
  1826. if err != nil {
  1827. return nil, fmt.Errorf("failed to read mp4 from output file: %w", err)
  1828. }
  1829. return mp4, nil
  1830. }
  1831. func (portal *Portal) preprocessMatrixMedia(sender *User, relaybotFormatted bool, content *event.MessageEventContent, eventID id.EventID, mediaType whatsmeow.MediaType) *MediaUpload {
  1832. var caption string
  1833. var mentionedJIDs []string
  1834. if relaybotFormatted {
  1835. caption, mentionedJIDs = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  1836. }
  1837. var file *event.EncryptedFileInfo
  1838. rawMXC := content.URL
  1839. if content.File != nil {
  1840. file = content.File
  1841. rawMXC = file.URL
  1842. }
  1843. mxc, err := rawMXC.Parse()
  1844. if err != nil {
  1845. portal.log.Errorln("Malformed content URL in %s: %v", eventID, err)
  1846. return nil
  1847. }
  1848. data, err := portal.MainIntent().DownloadBytes(mxc)
  1849. if err != nil {
  1850. portal.log.Errorfln("Failed to download media in %s: %v", eventID, err)
  1851. return nil
  1852. }
  1853. if file != nil {
  1854. data, err = file.Decrypt(data)
  1855. if err != nil {
  1856. portal.log.Errorfln("Failed to decrypt media in %s: %v", eventID, err)
  1857. return nil
  1858. }
  1859. }
  1860. if mediaType == whatsmeow.MediaVideo && content.GetInfo().MimeType == "image/gif" {
  1861. data, err = portal.convertGifToVideo(data)
  1862. if err != nil {
  1863. portal.log.Errorfln("Failed to convert gif to mp4 in %s: %v", eventID, err)
  1864. return nil
  1865. }
  1866. content.Info.MimeType = "video/mp4"
  1867. }
  1868. if mediaType == whatsmeow.MediaImage && content.GetInfo().MimeType == "image/webp" {
  1869. data, err = portal.convertWebPtoPNG(data)
  1870. if err != nil {
  1871. portal.log.Errorfln("Failed to convert webp to png in %s: %v", eventID, err)
  1872. return nil
  1873. }
  1874. content.Info.MimeType = "image/png"
  1875. }
  1876. uploadResp, err := sender.Client.Upload(context.Background(), data, mediaType)
  1877. if err != nil {
  1878. portal.log.Errorfln("Failed to upload media in %s: %v", eventID, err)
  1879. return nil
  1880. }
  1881. return &MediaUpload{
  1882. UploadResponse: uploadResp,
  1883. Caption: caption,
  1884. MentionedJIDs: mentionedJIDs,
  1885. Thumbnail: portal.downloadThumbnail(content, eventID),
  1886. FileLength: len(data),
  1887. }
  1888. }
  1889. type MediaUpload struct {
  1890. whatsmeow.UploadResponse
  1891. Caption string
  1892. MentionedJIDs []string
  1893. Thumbnail []byte
  1894. FileLength int
  1895. }
  1896. func (portal *Portal) sendMatrixConnectionError(sender *User, eventID id.EventID) bool {
  1897. if !sender.HasSession() {
  1898. portal.log.Debugln("Ignoring event", eventID, "from", sender.MXID, "as user has no session")
  1899. return true
  1900. } /*else if !sender.IsConnected() {
  1901. inRoom := ""
  1902. if portal.IsPrivateChat() {
  1903. inRoom = " in your management room"
  1904. }
  1905. if sender.IsLoginInProgress() {
  1906. portal.log.Debugln("Waiting for connection before handling event", eventID, "from", sender.MXID)
  1907. sender.Conn.WaitForLogin()
  1908. if sender.IsConnected() {
  1909. return false
  1910. }
  1911. }
  1912. reconnect := fmt.Sprintf("Use `%s reconnect`%s to reconnect.", portal.bridge.Config.Bridge.CommandPrefix, inRoom)
  1913. portal.log.Debugln("Ignoring event", eventID, "from", sender.MXID, "as user is not connected")
  1914. msg := format.RenderMarkdown("\u26a0 You are not connected to WhatsApp, so your message was not bridged. "+reconnect, true, false)
  1915. msg.MsgType = event.MsgNotice
  1916. _, err := portal.sendMainIntentMessage(msg)
  1917. if err != nil {
  1918. portal.log.Errorln("Failed to send bridging failure message:", err)
  1919. }
  1920. return true
  1921. }*/
  1922. // FIXME implement
  1923. return false
  1924. }
  1925. func (portal *Portal) addRelaybotFormat(sender *User, content *event.MessageEventContent) bool {
  1926. member := portal.MainIntent().Member(portal.MXID, sender.MXID)
  1927. if len(member.Displayname) == 0 {
  1928. member.Displayname = string(sender.MXID)
  1929. }
  1930. if content.Format != event.FormatHTML {
  1931. content.FormattedBody = strings.Replace(html.EscapeString(content.Body), "\n", "<br/>", -1)
  1932. content.Format = event.FormatHTML
  1933. }
  1934. data, err := portal.bridge.Config.Bridge.Relay.FormatMessage(content, sender.MXID, member)
  1935. if err != nil {
  1936. portal.log.Errorln("Failed to apply relaybot format:", err)
  1937. }
  1938. content.FormattedBody = data
  1939. return true
  1940. }
  1941. func addCodecToMime(mimeType, codec string) string {
  1942. mediaType, params, err := mime.ParseMediaType(mimeType)
  1943. if err != nil {
  1944. return mimeType
  1945. }
  1946. if _, ok := params["codecs"]; !ok {
  1947. params["codecs"] = codec
  1948. }
  1949. return mime.FormatMediaType(mediaType, params)
  1950. }
  1951. func parseGeoURI(uri string) (lat, long float64, err error) {
  1952. if !strings.HasPrefix(uri, "geo:") {
  1953. err = fmt.Errorf("uri doesn't have geo: prefix")
  1954. return
  1955. }
  1956. // Remove geo: prefix and anything after ;
  1957. coordinates := strings.Split(strings.TrimPrefix(uri, "geo:"), ";")[0]
  1958. if splitCoordinates := strings.Split(coordinates, ","); len(splitCoordinates) != 2 {
  1959. err = fmt.Errorf("didn't find exactly two numbers separated by a comma")
  1960. } else if lat, err = strconv.ParseFloat(splitCoordinates[0], 64); err != nil {
  1961. err = fmt.Errorf("latitude is not a number: %w", err)
  1962. } else if long, err = strconv.ParseFloat(splitCoordinates[1], 64); err != nil {
  1963. err = fmt.Errorf("longitude is not a number: %w", err)
  1964. }
  1965. return
  1966. }
  1967. func fallbackQuoteContent() *waProto.Message {
  1968. blankString := ""
  1969. return &waProto.Message{
  1970. Conversation: &blankString,
  1971. }
  1972. }
  1973. func (portal *Portal) convertMatrixMessage(sender *User, evt *event.Event) (*waProto.Message, *User) {
  1974. content, ok := evt.Content.Parsed.(*event.MessageEventContent)
  1975. if !ok {
  1976. portal.log.Debugfln("Failed to handle event %s: unexpected parsed content type %T", evt.ID, evt.Content.Parsed)
  1977. return nil, sender
  1978. }
  1979. var msg waProto.Message
  1980. var ctxInfo waProto.ContextInfo
  1981. replyToID := content.GetReplyTo()
  1982. if len(replyToID) > 0 {
  1983. replyToMsg := portal.bridge.DB.Message.GetByMXID(replyToID)
  1984. if replyToMsg != nil {
  1985. ctxInfo.StanzaId = &replyToMsg.JID
  1986. ctxInfo.Participant = proto.String(replyToMsg.Sender.String())
  1987. // Using blank content here seems to work fine on all official WhatsApp apps.
  1988. // Getting the content from the phone would be possible, but it's complicated.
  1989. // https://github.com/mautrix/whatsapp/commit/b3312bc663772aa274cea90ffa773da2217bb5e0
  1990. ctxInfo.QuotedMessage = fallbackQuoteContent()
  1991. }
  1992. }
  1993. relaybotFormatted := false
  1994. if !sender.HasSession() {
  1995. if !portal.HasRelaybot() {
  1996. portal.log.Debugln("Ignoring message from", sender.MXID, "in chat with no relaybot")
  1997. return nil, sender
  1998. }
  1999. relaybotFormatted = portal.addRelaybotFormat(sender, content)
  2000. sender = portal.GetRelayUser()
  2001. }
  2002. if evt.Type == event.EventSticker {
  2003. content.MsgType = event.MsgImage
  2004. }
  2005. if content.MsgType == event.MsgImage && content.GetInfo().MimeType == "image/gif" {
  2006. content.MsgType = event.MsgVideo
  2007. }
  2008. switch content.MsgType {
  2009. case event.MsgText, event.MsgEmote, event.MsgNotice:
  2010. text := content.Body
  2011. if content.MsgType == event.MsgNotice && !portal.bridge.Config.Bridge.BridgeNotices {
  2012. return nil, sender
  2013. }
  2014. if content.Format == event.FormatHTML {
  2015. text, ctxInfo.MentionedJid = portal.bridge.Formatter.ParseMatrix(content.FormattedBody)
  2016. }
  2017. if content.MsgType == event.MsgEmote && !relaybotFormatted {
  2018. text = "/me " + text
  2019. }
  2020. if ctxInfo.StanzaId != nil || ctxInfo.MentionedJid != nil {
  2021. msg.ExtendedTextMessage = &waProto.ExtendedTextMessage{
  2022. Text: &text,
  2023. ContextInfo: &ctxInfo,
  2024. }
  2025. } else {
  2026. msg.Conversation = &text
  2027. }
  2028. case event.MsgImage:
  2029. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaImage)
  2030. if media == nil {
  2031. return nil, sender
  2032. }
  2033. ctxInfo.MentionedJid = media.MentionedJIDs
  2034. msg.ImageMessage = &waProto.ImageMessage{
  2035. ContextInfo: &ctxInfo,
  2036. Caption: &media.Caption,
  2037. JpegThumbnail: media.Thumbnail,
  2038. Url: &media.URL,
  2039. MediaKey: media.MediaKey,
  2040. Mimetype: &content.GetInfo().MimeType,
  2041. FileEncSha256: media.FileEncSHA256,
  2042. FileSha256: media.FileSHA256,
  2043. FileLength: proto.Uint64(uint64(media.FileLength)),
  2044. }
  2045. case event.MsgVideo:
  2046. gifPlayback := content.GetInfo().MimeType == "image/gif"
  2047. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaVideo)
  2048. if media == nil {
  2049. return nil, sender
  2050. }
  2051. duration := uint32(content.GetInfo().Duration / 1000)
  2052. ctxInfo.MentionedJid = media.MentionedJIDs
  2053. msg.VideoMessage = &waProto.VideoMessage{
  2054. ContextInfo: &ctxInfo,
  2055. Caption: &media.Caption,
  2056. JpegThumbnail: media.Thumbnail,
  2057. Url: &media.URL,
  2058. MediaKey: media.MediaKey,
  2059. Mimetype: &content.GetInfo().MimeType,
  2060. GifPlayback: &gifPlayback,
  2061. Seconds: &duration,
  2062. FileEncSha256: media.FileEncSHA256,
  2063. FileSha256: media.FileSHA256,
  2064. FileLength: proto.Uint64(uint64(media.FileLength)),
  2065. }
  2066. case event.MsgAudio:
  2067. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaAudio)
  2068. if media == nil {
  2069. return nil, sender
  2070. }
  2071. duration := uint32(content.GetInfo().Duration / 1000)
  2072. msg.AudioMessage = &waProto.AudioMessage{
  2073. ContextInfo: &ctxInfo,
  2074. Url: &media.URL,
  2075. MediaKey: media.MediaKey,
  2076. Mimetype: &content.GetInfo().MimeType,
  2077. Seconds: &duration,
  2078. FileEncSha256: media.FileEncSHA256,
  2079. FileSha256: media.FileSHA256,
  2080. FileLength: proto.Uint64(uint64(media.FileLength)),
  2081. }
  2082. _, isMSC3245Voice := evt.Content.Raw["org.matrix.msc3245.voice"]
  2083. _, isMSC2516Voice := evt.Content.Raw["org.matrix.msc2516.voice"]
  2084. if isMSC3245Voice || isMSC2516Voice {
  2085. msg.AudioMessage.Ptt = proto.Bool(true)
  2086. // hacky hack to add the codecs param that whatsapp seems to require
  2087. msg.AudioMessage.Mimetype = proto.String(addCodecToMime(content.GetInfo().MimeType, "opus"))
  2088. }
  2089. case event.MsgFile:
  2090. media := portal.preprocessMatrixMedia(sender, relaybotFormatted, content, evt.ID, whatsmeow.MediaDocument)
  2091. if media == nil {
  2092. return nil, sender
  2093. }
  2094. msg.DocumentMessage = &waProto.DocumentMessage{
  2095. ContextInfo: &ctxInfo,
  2096. Url: &media.URL,
  2097. Title: &content.Body,
  2098. FileName: &content.Body,
  2099. MediaKey: media.MediaKey,
  2100. Mimetype: &content.GetInfo().MimeType,
  2101. FileEncSha256: media.FileEncSHA256,
  2102. FileSha256: media.FileSHA256,
  2103. FileLength: proto.Uint64(uint64(media.FileLength)),
  2104. }
  2105. case event.MsgLocation:
  2106. lat, long, err := parseGeoURI(content.GeoURI)
  2107. if err != nil {
  2108. portal.log.Debugfln("Invalid geo URI on Matrix event %s: %v", evt.ID, err)
  2109. return nil, sender
  2110. }
  2111. msg.LocationMessage = &waProto.LocationMessage{
  2112. DegreesLatitude: &lat,
  2113. DegreesLongitude: &long,
  2114. Comment: &content.Body,
  2115. ContextInfo: &ctxInfo,
  2116. }
  2117. default:
  2118. portal.log.Debugfln("Unhandled Matrix event %s: unknown msgtype %s", evt.ID, content.MsgType)
  2119. return nil, sender
  2120. }
  2121. return &msg, sender
  2122. }
  2123. func (portal *Portal) sendErrorMessage(message string, confirmed bool) id.EventID {
  2124. certainty := "may not have been"
  2125. if confirmed {
  2126. certainty = "was not"
  2127. }
  2128. resp, err := portal.sendMainIntentMessage(&event.MessageEventContent{
  2129. MsgType: event.MsgNotice,
  2130. Body: fmt.Sprintf("\u26a0 Your message %s bridged: %v", certainty, message),
  2131. })
  2132. if err != nil {
  2133. portal.log.Warnfln("Failed to send bridging error message:", err)
  2134. return ""
  2135. }
  2136. return resp.EventID
  2137. }
  2138. func (portal *Portal) sendDeliveryReceipt(eventID id.EventID) {
  2139. if portal.bridge.Config.Bridge.DeliveryReceipts {
  2140. err := portal.bridge.Bot.MarkRead(portal.MXID, eventID)
  2141. if err != nil {
  2142. portal.log.Debugfln("Failed to send delivery receipt for %s: %v", eventID, err)
  2143. }
  2144. }
  2145. }
  2146. func (portal *Portal) generateMessageInfo(sender *User) *types.MessageInfo {
  2147. return &types.MessageInfo{
  2148. ID: whatsmeow.GenerateMessageID(),
  2149. Timestamp: time.Now(),
  2150. MessageSource: types.MessageSource{
  2151. Sender: sender.JID,
  2152. Chat: portal.Key.JID,
  2153. IsFromMe: true,
  2154. IsGroup: portal.Key.JID.Server == types.GroupServer || portal.Key.JID.Server == types.BroadcastServer,
  2155. },
  2156. }
  2157. }
  2158. func (portal *Portal) HandleMatrixMessage(sender *User, evt *event.Event) {
  2159. if !portal.HasRelaybot() &&
  2160. ((portal.IsPrivateChat() && sender.JID.User != portal.Key.Receiver.User) ||
  2161. portal.sendMatrixConnectionError(sender, evt.ID)) {
  2162. return
  2163. }
  2164. portal.log.Debugfln("Received event %s", evt.ID)
  2165. msg, sender := portal.convertMatrixMessage(sender, evt)
  2166. if msg == nil {
  2167. return
  2168. }
  2169. info := portal.generateMessageInfo(sender)
  2170. dbMsg := portal.markHandled(nil, info, evt.ID, false, true, false)
  2171. portal.log.Debugln("Sending event", evt.ID, "to WhatsApp", info.ID)
  2172. err := sender.Client.SendMessage(portal.Key.JID, info.ID, msg)
  2173. if err != nil {
  2174. portal.log.Errorln("Error sending message: %v", err)
  2175. portal.sendErrorMessage(err.Error(), true)
  2176. } else {
  2177. portal.log.Debugfln("Handled Matrix event %s", evt.ID)
  2178. portal.sendDeliveryReceipt(evt.ID)
  2179. dbMsg.MarkSent()
  2180. }
  2181. }
  2182. func (portal *Portal) HandleMatrixRedaction(sender *User, evt *event.Event) {
  2183. if portal.IsPrivateChat() && sender.JID.User != portal.Key.Receiver.User {
  2184. return
  2185. }
  2186. msg := portal.bridge.DB.Message.GetByMXID(evt.Redacts)
  2187. if msg == nil {
  2188. portal.log.Debugfln("Ignoring redaction %s of unknown event by %s", msg, sender.MXID)
  2189. return
  2190. } else if msg.Sender.User != sender.JID.User {
  2191. 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, sender.MXID, msg.Sender, sender.JID)
  2192. return
  2193. }
  2194. portal.log.Debugfln("Sending redaction %s of %s/%s to WhatsApp", evt.ID, msg.MXID, msg.JID)
  2195. err := sender.Client.RevokeMessage(portal.Key.JID, msg.JID)
  2196. if err != nil {
  2197. portal.log.Errorfln("Error handling Matrix redaction %s: %v", evt.ID, err)
  2198. } else {
  2199. portal.log.Debugfln("Handled Matrix redaction %s of %s", evt.ID, evt.Redacts)
  2200. portal.sendDeliveryReceipt(evt.ID)
  2201. }
  2202. }
  2203. func (portal *Portal) Delete() {
  2204. portal.Portal.Delete()
  2205. portal.bridge.portalsLock.Lock()
  2206. delete(portal.bridge.portalsByJID, portal.Key)
  2207. if len(portal.MXID) > 0 {
  2208. delete(portal.bridge.portalsByMXID, portal.MXID)
  2209. }
  2210. portal.bridge.portalsLock.Unlock()
  2211. }
  2212. func (portal *Portal) GetMatrixUsers() ([]id.UserID, error) {
  2213. members, err := portal.MainIntent().JoinedMembers(portal.MXID)
  2214. if err != nil {
  2215. return nil, fmt.Errorf("failed to get member list: %w", err)
  2216. }
  2217. var users []id.UserID
  2218. for userID := range members.Joined {
  2219. _, isPuppet := portal.bridge.ParsePuppetMXID(userID)
  2220. if !isPuppet && userID != portal.bridge.Bot.UserID {
  2221. users = append(users, userID)
  2222. }
  2223. }
  2224. return users, nil
  2225. }
  2226. func (portal *Portal) CleanupIfEmpty() {
  2227. users, err := portal.GetMatrixUsers()
  2228. if err != nil {
  2229. portal.log.Errorfln("Failed to get Matrix user list to determine if portal needs to be cleaned up: %v", err)
  2230. return
  2231. }
  2232. if len(users) == 0 {
  2233. portal.log.Infoln("Room seems to be empty, cleaning up...")
  2234. portal.Delete()
  2235. portal.Cleanup(false)
  2236. }
  2237. }
  2238. func (portal *Portal) Cleanup(puppetsOnly bool) {
  2239. if len(portal.MXID) == 0 {
  2240. return
  2241. }
  2242. if portal.IsPrivateChat() {
  2243. _, err := portal.MainIntent().LeaveRoom(portal.MXID)
  2244. if err != nil {
  2245. portal.log.Warnln("Failed to leave private chat portal with main intent:", err)
  2246. }
  2247. return
  2248. }
  2249. intent := portal.MainIntent()
  2250. members, err := intent.JoinedMembers(portal.MXID)
  2251. if err != nil {
  2252. portal.log.Errorln("Failed to get portal members for cleanup:", err)
  2253. return
  2254. }
  2255. for member := range members.Joined {
  2256. if member == intent.UserID {
  2257. continue
  2258. }
  2259. puppet := portal.bridge.GetPuppetByMXID(member)
  2260. if puppet != nil {
  2261. _, err = puppet.DefaultIntent().LeaveRoom(portal.MXID)
  2262. if err != nil {
  2263. portal.log.Errorln("Error leaving as puppet while cleaning up portal:", err)
  2264. }
  2265. } else if !puppetsOnly {
  2266. _, err = intent.KickUser(portal.MXID, &mautrix.ReqKickUser{UserID: member, Reason: "Deleting portal"})
  2267. if err != nil {
  2268. portal.log.Errorln("Error kicking user while cleaning up portal:", err)
  2269. }
  2270. }
  2271. }
  2272. _, err = intent.LeaveRoom(portal.MXID)
  2273. if err != nil {
  2274. portal.log.Errorln("Error leaving with main intent while cleaning up portal:", err)
  2275. }
  2276. }
  2277. func (portal *Portal) HandleMatrixLeave(sender *User) {
  2278. if portal.IsPrivateChat() {
  2279. portal.log.Debugln("User left private chat portal, cleaning up and deleting...")
  2280. portal.Delete()
  2281. portal.Cleanup(false)
  2282. return
  2283. } else if portal.bridge.Config.Bridge.BridgeMatrixLeave {
  2284. // TODO should we somehow deduplicate this call if this leave was sent by the bridge?
  2285. // FIXME reimplement
  2286. //resp, err := sender.Client.LeaveGroup(portal.Key.JID)
  2287. //if err != nil {
  2288. // portal.log.Errorfln("Failed to leave group as %s: %v", sender.MXID, err)
  2289. // return
  2290. //}
  2291. //portal.log.Infoln("Leave response:", <-resp)
  2292. }
  2293. portal.CleanupIfEmpty()
  2294. }
  2295. func (portal *Portal) HandleMatrixKick(sender *User, evt *event.Event) {
  2296. puppet := portal.bridge.GetPuppetByMXID(id.UserID(evt.GetStateKey()))
  2297. if puppet != nil {
  2298. // FIXME reimplement
  2299. //resp, err := sender.Conn.RemoveMember(portal.Key.JID, []string{puppet.JID})
  2300. //if err != nil {
  2301. // portal.log.Errorfln("Failed to kick %s from group as %s: %v", puppet.JID, sender.MXID, err)
  2302. // return
  2303. //}
  2304. //portal.log.Infoln("Kick %s response: %s", puppet.JID, <-resp)
  2305. }
  2306. }
  2307. func (portal *Portal) HandleMatrixInvite(sender *User, evt *event.Event) {
  2308. puppet := portal.bridge.GetPuppetByMXID(id.UserID(evt.GetStateKey()))
  2309. if puppet != nil {
  2310. // FIXME reimplement
  2311. //resp, err := sender.Conn.AddMember(portal.Key.JID, []string{puppet.JID})
  2312. //if err != nil {
  2313. // portal.log.Errorfln("Failed to add %s to group as %s: %v", puppet.JID, sender.MXID, err)
  2314. // return
  2315. //}
  2316. //portal.log.Infofln("Add %s response: %s", puppet.JID, <-resp)
  2317. }
  2318. }
  2319. func (portal *Portal) HandleMatrixMeta(sender *User, evt *event.Event) {
  2320. var err error
  2321. switch content := evt.Content.Parsed.(type) {
  2322. case *event.RoomNameEventContent:
  2323. if content.Name == portal.Name {
  2324. return
  2325. }
  2326. // FIXME reimplement
  2327. //portal.Name = content.Name
  2328. //resp, err = sender.Conn.UpdateGroupSubject(content.Name, portal.Key.JID)
  2329. case *event.TopicEventContent:
  2330. if content.Topic == portal.Topic {
  2331. return
  2332. }
  2333. // FIXME reimplement
  2334. //portal.Topic = content.Topic
  2335. //resp, err = sender.Conn.UpdateGroupDescription(sender.JID, portal.Key.JID, content.Topic)
  2336. case *event.RoomAvatarEventContent:
  2337. return
  2338. }
  2339. if err != nil {
  2340. portal.log.Errorln("Failed to update metadata:", err)
  2341. } else {
  2342. //out := <-resp
  2343. //portal.log.Debugln("Successfully updated metadata:", out)
  2344. }
  2345. }