user.go 41 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239
  1. // mautrix-whatsapp - A Matrix-WhatsApp puppeting bridge.
  2. // Copyright (C) 2022 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. "context"
  19. "crypto/hmac"
  20. "crypto/sha256"
  21. "encoding/binary"
  22. "encoding/json"
  23. "errors"
  24. "fmt"
  25. "math"
  26. "net/http"
  27. "strconv"
  28. "strings"
  29. "sync"
  30. "time"
  31. log "maunium.net/go/maulogger/v2"
  32. "maunium.net/go/mautrix"
  33. "maunium.net/go/mautrix/appservice"
  34. "maunium.net/go/mautrix/bridge"
  35. "maunium.net/go/mautrix/bridge/bridgeconfig"
  36. "maunium.net/go/mautrix/event"
  37. "maunium.net/go/mautrix/format"
  38. "maunium.net/go/mautrix/id"
  39. "maunium.net/go/mautrix/pushrules"
  40. "go.mau.fi/whatsmeow"
  41. "go.mau.fi/whatsmeow/appstate"
  42. waProto "go.mau.fi/whatsmeow/binary/proto"
  43. "go.mau.fi/whatsmeow/store"
  44. "go.mau.fi/whatsmeow/types"
  45. "go.mau.fi/whatsmeow/types/events"
  46. waLog "go.mau.fi/whatsmeow/util/log"
  47. "maunium.net/go/mautrix-whatsapp/database"
  48. )
  49. type User struct {
  50. *database.User
  51. Client *whatsmeow.Client
  52. Session *store.Device
  53. bridge *WABridge
  54. log log.Logger
  55. Admin bool
  56. Whitelisted bool
  57. RelayWhitelisted bool
  58. PermissionLevel bridgeconfig.PermissionLevel
  59. mgmtCreateLock sync.Mutex
  60. spaceCreateLock sync.Mutex
  61. connLock sync.Mutex
  62. historySyncs chan *events.HistorySync
  63. lastPresence types.Presence
  64. historySyncLoopsStarted bool
  65. spaceMembershipChecked bool
  66. lastPhoneOfflineWarning time.Time
  67. groupListCache []*types.GroupInfo
  68. groupListCacheLock sync.Mutex
  69. groupListCacheTime time.Time
  70. BackfillQueue *BackfillQueue
  71. BridgeState *bridge.BridgeStateQueue
  72. }
  73. func (br *WABridge) getUserByMXID(userID id.UserID, onlyIfExists bool) *User {
  74. _, isPuppet := br.ParsePuppetMXID(userID)
  75. if isPuppet || userID == br.Bot.UserID {
  76. return nil
  77. }
  78. br.usersLock.Lock()
  79. defer br.usersLock.Unlock()
  80. user, ok := br.usersByMXID[userID]
  81. if !ok {
  82. userIDPtr := &userID
  83. if onlyIfExists {
  84. userIDPtr = nil
  85. }
  86. return br.loadDBUser(br.DB.User.GetByMXID(userID), userIDPtr)
  87. }
  88. return user
  89. }
  90. func (br *WABridge) GetUserByMXID(userID id.UserID) *User {
  91. return br.getUserByMXID(userID, false)
  92. }
  93. func (br *WABridge) GetIUser(userID id.UserID, create bool) bridge.User {
  94. u := br.getUserByMXID(userID, !create)
  95. if u == nil {
  96. return nil
  97. }
  98. return u
  99. }
  100. func (user *User) GetPermissionLevel() bridgeconfig.PermissionLevel {
  101. return user.PermissionLevel
  102. }
  103. func (user *User) GetManagementRoomID() id.RoomID {
  104. return user.ManagementRoom
  105. }
  106. func (user *User) GetMXID() id.UserID {
  107. return user.MXID
  108. }
  109. func (user *User) GetCommandState() map[string]interface{} {
  110. return nil
  111. }
  112. func (br *WABridge) GetUserByMXIDIfExists(userID id.UserID) *User {
  113. return br.getUserByMXID(userID, true)
  114. }
  115. func (br *WABridge) GetUserByJID(jid types.JID) *User {
  116. br.usersLock.Lock()
  117. defer br.usersLock.Unlock()
  118. user, ok := br.usersByUsername[jid.User]
  119. if !ok {
  120. return br.loadDBUser(br.DB.User.GetByUsername(jid.User), nil)
  121. }
  122. return user
  123. }
  124. func (user *User) addToJIDMap() {
  125. user.bridge.usersLock.Lock()
  126. user.bridge.usersByUsername[user.JID.User] = user
  127. user.bridge.usersLock.Unlock()
  128. }
  129. func (user *User) removeFromJIDMap(state bridge.State) {
  130. user.bridge.usersLock.Lock()
  131. jidUser, ok := user.bridge.usersByUsername[user.JID.User]
  132. if ok && user == jidUser {
  133. delete(user.bridge.usersByUsername, user.JID.User)
  134. }
  135. user.bridge.usersLock.Unlock()
  136. user.bridge.Metrics.TrackLoginState(user.JID, false)
  137. user.BridgeState.Send(state)
  138. }
  139. func (br *WABridge) GetAllUsers() []*User {
  140. br.usersLock.Lock()
  141. defer br.usersLock.Unlock()
  142. dbUsers := br.DB.User.GetAll()
  143. output := make([]*User, len(dbUsers))
  144. for index, dbUser := range dbUsers {
  145. user, ok := br.usersByMXID[dbUser.MXID]
  146. if !ok {
  147. user = br.loadDBUser(dbUser, nil)
  148. }
  149. output[index] = user
  150. }
  151. return output
  152. }
  153. func (br *WABridge) loadDBUser(dbUser *database.User, mxid *id.UserID) *User {
  154. if dbUser == nil {
  155. if mxid == nil {
  156. return nil
  157. }
  158. dbUser = br.DB.User.New()
  159. dbUser.MXID = *mxid
  160. dbUser.Insert()
  161. }
  162. user := br.NewUser(dbUser)
  163. br.usersByMXID[user.MXID] = user
  164. if !user.JID.IsEmpty() {
  165. var err error
  166. user.Session, err = br.WAContainer.GetDevice(user.JID)
  167. if err != nil {
  168. user.log.Errorfln("Failed to load user's whatsapp session: %v", err)
  169. } else if user.Session == nil {
  170. user.log.Warnfln("Didn't find session data for %s, treating user as logged out", user.JID)
  171. user.JID = types.EmptyJID
  172. user.Update()
  173. } else {
  174. user.Session.Log = &waLogger{user.log.Sub("Session")}
  175. br.usersByUsername[user.JID.User] = user
  176. }
  177. }
  178. if len(user.ManagementRoom) > 0 {
  179. br.managementRooms[user.ManagementRoom] = user
  180. }
  181. return user
  182. }
  183. func (br *WABridge) NewUser(dbUser *database.User) *User {
  184. user := &User{
  185. User: dbUser,
  186. bridge: br,
  187. log: br.Log.Sub("User").Sub(string(dbUser.MXID)),
  188. historySyncs: make(chan *events.HistorySync, 32),
  189. lastPresence: types.PresenceUnavailable,
  190. }
  191. user.PermissionLevel = user.bridge.Config.Bridge.Permissions.Get(user.MXID)
  192. user.RelayWhitelisted = user.PermissionLevel >= bridgeconfig.PermissionLevelRelay
  193. user.Whitelisted = user.PermissionLevel >= bridgeconfig.PermissionLevelUser
  194. user.Admin = user.PermissionLevel >= bridgeconfig.PermissionLevelAdmin
  195. user.BridgeState = br.NewBridgeStateQueue(user, user.log)
  196. return user
  197. }
  198. func (user *User) ensureInvited(intent *appservice.IntentAPI, roomID id.RoomID, isDirect bool) (ok bool) {
  199. inviteContent := event.Content{
  200. Parsed: &event.MemberEventContent{
  201. Membership: event.MembershipInvite,
  202. IsDirect: isDirect,
  203. },
  204. Raw: map[string]interface{}{},
  205. }
  206. customPuppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  207. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  208. inviteContent.Raw["fi.mau.will_auto_accept"] = true
  209. }
  210. _, err := intent.SendStateEvent(roomID, event.StateMember, user.MXID.String(), &inviteContent)
  211. var httpErr mautrix.HTTPError
  212. if err != nil && errors.As(err, &httpErr) && httpErr.RespError != nil && strings.Contains(httpErr.RespError.Err, "is already in the room") {
  213. user.bridge.StateStore.SetMembership(roomID, user.MXID, event.MembershipJoin)
  214. ok = true
  215. return
  216. } else if err != nil {
  217. user.log.Warnfln("Failed to invite user to %s: %v", roomID, err)
  218. } else {
  219. ok = true
  220. }
  221. if customPuppet != nil && customPuppet.CustomIntent() != nil {
  222. err = customPuppet.CustomIntent().EnsureJoined(roomID, appservice.EnsureJoinedParams{IgnoreCache: true})
  223. if err != nil {
  224. user.log.Warnfln("Failed to auto-join %s: %v", roomID, err)
  225. ok = false
  226. } else {
  227. ok = true
  228. }
  229. }
  230. return
  231. }
  232. func (user *User) GetSpaceRoom() id.RoomID {
  233. if !user.bridge.Config.Bridge.PersonalFilteringSpaces {
  234. return ""
  235. }
  236. if len(user.SpaceRoom) == 0 {
  237. user.spaceCreateLock.Lock()
  238. defer user.spaceCreateLock.Unlock()
  239. if len(user.SpaceRoom) > 0 {
  240. return user.SpaceRoom
  241. }
  242. resp, err := user.bridge.Bot.CreateRoom(&mautrix.ReqCreateRoom{
  243. Visibility: "private",
  244. Name: "WhatsApp",
  245. Topic: "Your WhatsApp bridged chats",
  246. InitialState: []*event.Event{{
  247. Type: event.StateRoomAvatar,
  248. Content: event.Content{
  249. Parsed: &event.RoomAvatarEventContent{
  250. URL: user.bridge.Config.AppService.Bot.ParsedAvatar,
  251. },
  252. },
  253. }},
  254. CreationContent: map[string]interface{}{
  255. "type": event.RoomTypeSpace,
  256. },
  257. PowerLevelOverride: &event.PowerLevelsEventContent{
  258. Users: map[id.UserID]int{
  259. user.bridge.Bot.UserID: 9001,
  260. user.MXID: 50,
  261. },
  262. },
  263. })
  264. if err != nil {
  265. user.log.Errorln("Failed to auto-create space room:", err)
  266. } else {
  267. user.SpaceRoom = resp.RoomID
  268. user.Update()
  269. user.ensureInvited(user.bridge.Bot, user.SpaceRoom, false)
  270. }
  271. } else if !user.spaceMembershipChecked && !user.bridge.StateStore.IsInRoom(user.SpaceRoom, user.MXID) {
  272. user.ensureInvited(user.bridge.Bot, user.SpaceRoom, false)
  273. }
  274. user.spaceMembershipChecked = true
  275. return user.SpaceRoom
  276. }
  277. func (user *User) GetManagementRoom() id.RoomID {
  278. if len(user.ManagementRoom) == 0 {
  279. user.mgmtCreateLock.Lock()
  280. defer user.mgmtCreateLock.Unlock()
  281. if len(user.ManagementRoom) > 0 {
  282. return user.ManagementRoom
  283. }
  284. creationContent := make(map[string]interface{})
  285. if !user.bridge.Config.Bridge.FederateRooms {
  286. creationContent["m.federate"] = false
  287. }
  288. resp, err := user.bridge.Bot.CreateRoom(&mautrix.ReqCreateRoom{
  289. Topic: "WhatsApp bridge notices",
  290. IsDirect: true,
  291. CreationContent: creationContent,
  292. })
  293. if err != nil {
  294. user.log.Errorln("Failed to auto-create management room:", err)
  295. } else {
  296. user.SetManagementRoom(resp.RoomID)
  297. }
  298. }
  299. return user.ManagementRoom
  300. }
  301. func (user *User) SetManagementRoom(roomID id.RoomID) {
  302. existingUser, ok := user.bridge.managementRooms[roomID]
  303. if ok {
  304. existingUser.ManagementRoom = ""
  305. existingUser.Update()
  306. }
  307. user.ManagementRoom = roomID
  308. user.bridge.managementRooms[user.ManagementRoom] = user
  309. user.Update()
  310. }
  311. type waLogger struct{ l log.Logger }
  312. func (w *waLogger) Debugf(msg string, args ...interface{}) { w.l.Debugfln(msg, args...) }
  313. func (w *waLogger) Infof(msg string, args ...interface{}) { w.l.Infofln(msg, args...) }
  314. func (w *waLogger) Warnf(msg string, args ...interface{}) { w.l.Warnfln(msg, args...) }
  315. func (w *waLogger) Errorf(msg string, args ...interface{}) { w.l.Errorfln(msg, args...) }
  316. func (w *waLogger) Sub(module string) waLog.Logger { return &waLogger{l: w.l.Sub(module)} }
  317. var ErrAlreadyLoggedIn = errors.New("already logged in")
  318. func (user *User) obfuscateJID(jid types.JID) string {
  319. // Turn the first 4 bytes of HMAC-SHA256(hs_token, phone) into a number and replace the middle of the actual phone with that deterministic random number.
  320. randomNumber := binary.BigEndian.Uint32(hmac.New(sha256.New, []byte(user.bridge.Config.AppService.HSToken)).Sum([]byte(jid.User))[:4])
  321. return fmt.Sprintf("+%s-%d-%s:%d", jid.User[:1], randomNumber, jid.User[len(jid.User)-2:], jid.Device)
  322. }
  323. func (user *User) createClient(sess *store.Device) {
  324. user.Client = whatsmeow.NewClient(sess, &waLogger{user.log.Sub("Client")})
  325. user.Client.AddEventHandler(user.HandleEvent)
  326. user.Client.SetForceActiveDeliveryReceipts(user.bridge.Config.Bridge.ForceActiveDeliveryReceipts)
  327. user.Client.GetMessageForRetry = func(requester, to types.JID, id types.MessageID) *waProto.Message {
  328. Segment.Track(user.MXID, "WhatsApp incoming retry (message not found)", map[string]interface{}{
  329. "requester": user.obfuscateJID(requester),
  330. "messageID": id,
  331. })
  332. user.bridge.Metrics.TrackRetryReceipt(0, false)
  333. return nil
  334. }
  335. user.Client.PreRetryCallback = func(receipt *events.Receipt, messageID types.MessageID, retryCount int, msg *waProto.Message) bool {
  336. Segment.Track(user.MXID, "WhatsApp incoming retry (accepted)", map[string]interface{}{
  337. "requester": user.obfuscateJID(receipt.Sender),
  338. "messageID": messageID,
  339. "retryCount": retryCount,
  340. })
  341. user.bridge.Metrics.TrackRetryReceipt(retryCount, true)
  342. return true
  343. }
  344. }
  345. func (user *User) Login(ctx context.Context) (<-chan whatsmeow.QRChannelItem, error) {
  346. user.connLock.Lock()
  347. defer user.connLock.Unlock()
  348. if user.Session != nil {
  349. return nil, ErrAlreadyLoggedIn
  350. } else if user.Client != nil {
  351. user.unlockedDeleteConnection()
  352. }
  353. newSession := user.bridge.WAContainer.NewDevice()
  354. newSession.Log = &waLogger{user.log.Sub("Session")}
  355. user.createClient(newSession)
  356. qrChan, err := user.Client.GetQRChannel(ctx)
  357. if err != nil {
  358. return nil, fmt.Errorf("failed to get QR channel: %w", err)
  359. }
  360. err = user.Client.Connect()
  361. if err != nil {
  362. return nil, fmt.Errorf("failed to connect to WhatsApp: %w", err)
  363. }
  364. return qrChan, nil
  365. }
  366. func (user *User) Connect() bool {
  367. user.connLock.Lock()
  368. defer user.connLock.Unlock()
  369. if user.Client != nil {
  370. return user.Client.IsConnected()
  371. } else if user.Session == nil {
  372. return false
  373. }
  374. user.log.Debugln("Connecting to WhatsApp")
  375. user.BridgeState.Send(bridge.State{StateEvent: bridge.StateConnecting, Error: WAConnecting})
  376. user.createClient(user.Session)
  377. err := user.Client.Connect()
  378. if err != nil {
  379. user.log.Warnln("Error connecting to WhatsApp:", err)
  380. user.BridgeState.Send(bridge.State{
  381. StateEvent: bridge.StateUnknownError,
  382. Error: WAConnectionFailed,
  383. Info: map[string]interface{}{
  384. "go_error": err.Error(),
  385. },
  386. })
  387. return false
  388. }
  389. return true
  390. }
  391. func (user *User) unlockedDeleteConnection() {
  392. if user.Client == nil {
  393. return
  394. }
  395. user.Client.Disconnect()
  396. user.Client.RemoveEventHandlers()
  397. user.Client = nil
  398. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  399. }
  400. func (user *User) DeleteConnection() {
  401. user.connLock.Lock()
  402. defer user.connLock.Unlock()
  403. user.unlockedDeleteConnection()
  404. }
  405. func (user *User) HasSession() bool {
  406. return user.Session != nil
  407. }
  408. func (user *User) DeleteSession() {
  409. if user.Session != nil {
  410. err := user.Session.Delete()
  411. if err != nil {
  412. user.log.Warnln("Failed to delete session:", err)
  413. }
  414. user.Session = nil
  415. }
  416. if !user.JID.IsEmpty() {
  417. user.JID = types.EmptyJID
  418. user.Update()
  419. }
  420. // Delete all of the backfill and history sync data.
  421. user.bridge.DB.Backfill.DeleteAll(user.MXID)
  422. user.bridge.DB.HistorySync.DeleteAllConversations(user.MXID)
  423. user.bridge.DB.HistorySync.DeleteAllMessages(user.MXID)
  424. user.bridge.DB.MediaBackfillRequest.DeleteAllMediaBackfillRequests(user.MXID)
  425. }
  426. func (user *User) IsConnected() bool {
  427. return user.Client != nil && user.Client.IsConnected()
  428. }
  429. func (user *User) IsLoggedIn() bool {
  430. return user.IsConnected() && user.Client.IsLoggedIn()
  431. }
  432. func (user *User) tryAutomaticDoublePuppeting() {
  433. if !user.bridge.Config.CanAutoDoublePuppet(user.MXID) {
  434. return
  435. }
  436. user.log.Debugln("Checking if double puppeting needs to be enabled")
  437. puppet := user.bridge.GetPuppetByJID(user.JID)
  438. if len(puppet.CustomMXID) > 0 {
  439. user.log.Debugln("User already has double-puppeting enabled")
  440. // Custom puppet already enabled
  441. return
  442. }
  443. accessToken, err := puppet.loginWithSharedSecret(user.MXID)
  444. if err != nil {
  445. user.log.Warnln("Failed to login with shared secret:", err)
  446. return
  447. }
  448. err = puppet.SwitchCustomMXID(accessToken, user.MXID)
  449. if err != nil {
  450. puppet.log.Warnln("Failed to switch to auto-logined custom puppet:", err)
  451. return
  452. }
  453. user.log.Infoln("Successfully automatically enabled custom puppet")
  454. }
  455. func (user *User) sendMarkdownBridgeAlert(formatString string, args ...interface{}) {
  456. if user.bridge.Config.Bridge.DisableBridgeAlerts {
  457. return
  458. }
  459. notice := fmt.Sprintf(formatString, args...)
  460. content := format.RenderMarkdown(notice, true, false)
  461. _, err := user.bridge.Bot.SendMessageEvent(user.GetManagementRoom(), event.EventMessage, content)
  462. if err != nil {
  463. user.log.Warnf("Failed to send bridge alert \"%s\": %v", notice, err)
  464. }
  465. }
  466. const callEventMaxAge = 15 * time.Minute
  467. func (user *User) handleCallStart(sender types.JID, id, callType string, ts time.Time) {
  468. if !user.bridge.Config.Bridge.CallStartNotices || ts.Add(callEventMaxAge).Before(time.Now()) {
  469. return
  470. }
  471. portal := user.GetPortalByJID(sender)
  472. text := "Incoming call"
  473. if callType != "" {
  474. text = fmt.Sprintf("Incoming %s call", callType)
  475. }
  476. portal.messages <- PortalMessage{
  477. fake: &fakeMessage{
  478. Sender: sender,
  479. Text: text,
  480. ID: id,
  481. Time: ts,
  482. Important: true,
  483. },
  484. source: user,
  485. }
  486. }
  487. const PhoneDisconnectWarningTime = 12 * 24 * time.Hour // 12 days
  488. const PhoneDisconnectPingTime = 10 * 24 * time.Hour
  489. const PhoneMinPingInterval = 24 * time.Hour
  490. func (user *User) sendHackyPhonePing() {
  491. user.PhoneLastPinged = time.Now()
  492. msgID := whatsmeow.GenerateMessageID()
  493. keyIDs := make([]*waProto.AppStateSyncKeyId, 0, 1)
  494. lastKeyID, err := user.GetLastAppStateKeyID()
  495. if lastKeyID != nil {
  496. keyIDs = append(keyIDs, &waProto.AppStateSyncKeyId{
  497. KeyId: lastKeyID,
  498. })
  499. } else {
  500. user.log.Warnfln("Failed to get last app state key ID to send hacky phone ping: %v - sending empty request", err)
  501. }
  502. ts, err := user.Client.SendMessage(user.JID.ToNonAD(), msgID, &waProto.Message{
  503. ProtocolMessage: &waProto.ProtocolMessage{
  504. Type: waProto.ProtocolMessage_APP_STATE_SYNC_KEY_REQUEST.Enum(),
  505. AppStateSyncKeyRequest: &waProto.AppStateSyncKeyRequest{
  506. KeyIds: keyIDs,
  507. },
  508. },
  509. })
  510. if err != nil {
  511. user.log.Warnfln("Failed to send hacky phone ping: %v", err)
  512. } else {
  513. user.log.Debugfln("Sent hacky phone ping %s/%s because phone has been offline for >10 days", msgID, ts.Unix())
  514. user.PhoneLastPinged = ts
  515. user.Update()
  516. }
  517. }
  518. func (user *User) PhoneRecentlySeen(doPing bool) bool {
  519. if doPing && !user.PhoneLastSeen.IsZero() && user.PhoneLastSeen.Add(PhoneDisconnectPingTime).Before(time.Now()) && user.PhoneLastPinged.Add(PhoneMinPingInterval).Before(time.Now()) {
  520. // Over 10 days since the phone was seen and over a day since the last somewhat hacky ping, send a new ping.
  521. go user.sendHackyPhonePing()
  522. }
  523. return user.PhoneLastSeen.IsZero() || user.PhoneLastSeen.Add(PhoneDisconnectWarningTime).After(time.Now())
  524. }
  525. // phoneSeen records a timestamp when the user's main device was seen online.
  526. // The stored timestamp can later be used to warn the user if the main device is offline for too long.
  527. func (user *User) phoneSeen(ts time.Time) {
  528. if user.PhoneLastSeen.Add(1 * time.Hour).After(ts) {
  529. // The last seen timestamp isn't going to be perfectly accurate in any case,
  530. // so don't spam the database with an update every time there's an event.
  531. return
  532. } else if !user.PhoneRecentlySeen(false) {
  533. if user.BridgeState.GetPrev().Error == WAPhoneOffline && user.IsConnected() {
  534. user.log.Debugfln("Saw phone after current bridge state said it has been offline, switching state back to connected")
  535. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateConnected})
  536. } else {
  537. user.log.Debugfln("Saw phone after current bridge state said it has been offline, not sending new bridge state (prev: %s, connected: %t)", user.BridgeState.GetPrev().Error, user.IsConnected())
  538. }
  539. }
  540. user.PhoneLastSeen = ts
  541. go user.Update()
  542. }
  543. func formatDisconnectTime(dur time.Duration) string {
  544. days := int(math.Floor(dur.Hours() / 24))
  545. hours := int(dur.Hours()) % 24
  546. if hours == 0 {
  547. return fmt.Sprintf("%d days", days)
  548. } else if hours == 1 {
  549. return fmt.Sprintf("%d days and 1 hour", days)
  550. } else {
  551. return fmt.Sprintf("%d days and %d hours", days, hours)
  552. }
  553. }
  554. func (user *User) sendPhoneOfflineWarning() {
  555. if user.lastPhoneOfflineWarning.Add(12 * time.Hour).After(time.Now()) {
  556. // Don't spam the warning too much
  557. return
  558. }
  559. user.lastPhoneOfflineWarning = time.Now()
  560. timeSinceSeen := time.Now().Sub(user.PhoneLastSeen)
  561. user.sendMarkdownBridgeAlert("Your phone hasn't been seen in %s. The server will force the bridge to log out if the phone is not active at least every 2 weeks.", formatDisconnectTime(timeSinceSeen))
  562. }
  563. func (user *User) HandleEvent(event interface{}) {
  564. switch v := event.(type) {
  565. case *events.LoggedOut:
  566. go user.handleLoggedOut(v.OnConnect, v.Reason)
  567. case *events.Connected:
  568. user.bridge.Metrics.TrackConnectionState(user.JID, true)
  569. user.bridge.Metrics.TrackLoginState(user.JID, true)
  570. if len(user.Client.Store.PushName) > 0 {
  571. go func() {
  572. err := user.Client.SendPresence(user.lastPresence)
  573. if err != nil {
  574. user.log.Warnln("Failed to send initial presence:", err)
  575. }
  576. }()
  577. }
  578. go user.tryAutomaticDoublePuppeting()
  579. if user.bridge.Config.Bridge.HistorySync.Backfill && !user.historySyncLoopsStarted {
  580. go user.handleHistorySyncsLoop()
  581. user.historySyncLoopsStarted = true
  582. }
  583. case *events.OfflineSyncPreview:
  584. user.log.Infofln("Server says it's going to send %d messages and %d receipts that were missed during downtime", v.Messages, v.Receipts)
  585. go user.BridgeState.Send(bridge.State{
  586. StateEvent: bridge.StateBackfilling,
  587. Message: fmt.Sprintf("backfilling %d messages and %d receipts", v.Messages, v.Receipts),
  588. })
  589. case *events.OfflineSyncCompleted:
  590. if !user.PhoneRecentlySeen(true) {
  591. user.log.Infofln("Offline sync completed, but phone last seen date is still %s - sending phone offline bridge status", user.PhoneLastSeen)
  592. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateTransientDisconnect, Error: WAPhoneOffline})
  593. } else {
  594. if user.BridgeState.GetPrev().StateEvent == bridge.StateBackfilling {
  595. user.log.Infoln("Offline sync completed")
  596. }
  597. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateConnected})
  598. }
  599. case *events.AppStateSyncComplete:
  600. if len(user.Client.Store.PushName) > 0 && v.Name == appstate.WAPatchCriticalBlock {
  601. err := user.Client.SendPresence(user.lastPresence)
  602. if err != nil {
  603. user.log.Warnln("Failed to send presence after app state sync:", err)
  604. }
  605. } else if v.Name == appstate.WAPatchCriticalUnblockLow {
  606. go func() {
  607. err := user.ResyncContacts()
  608. if err != nil {
  609. user.log.Errorln("Failed to resync puppets: %v", err)
  610. }
  611. }()
  612. }
  613. case *events.PushNameSetting:
  614. // Send presence available when connecting and when the pushname is changed.
  615. // This makes sure that outgoing messages always have the right pushname.
  616. err := user.Client.SendPresence(user.lastPresence)
  617. if err != nil {
  618. user.log.Warnln("Failed to send presence after push name update:", err)
  619. }
  620. case *events.PairSuccess:
  621. user.PhoneLastSeen = time.Now()
  622. user.Session = user.Client.Store
  623. user.JID = v.ID
  624. user.addToJIDMap()
  625. user.Update()
  626. case *events.StreamError:
  627. var message string
  628. if v.Code != "" {
  629. message = fmt.Sprintf("Unknown stream error with code %s", v.Code)
  630. } else if children := v.Raw.GetChildren(); len(children) > 0 {
  631. message = fmt.Sprintf("Unknown stream error (contains %s node)", children[0].Tag)
  632. } else {
  633. message = "Unknown stream error"
  634. }
  635. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateUnknownError, Message: message})
  636. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  637. case *events.ConnectFailure:
  638. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateUnknownError, Message: fmt.Sprintf("Unknown connection failure: %s", v.Reason)})
  639. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  640. case *events.ClientOutdated:
  641. user.log.Errorfln("Got a client outdated connect failure. The bridge is likely out of date, please update immediately.")
  642. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateUnknownError, Message: "Connect failure: 405 client outdated"})
  643. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  644. case *events.TemporaryBan:
  645. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateBadCredentials, Message: v.String()})
  646. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  647. case *events.Disconnected:
  648. // Don't send the normal transient disconnect state if we're already in a different transient disconnect state.
  649. // TODO remove this if/when the phone offline state is moved to a sub-state of CONNECTED
  650. if user.BridgeState.GetPrev().Error != WAPhoneOffline && user.PhoneRecentlySeen(false) {
  651. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateTransientDisconnect, Message: "Disconnected from WhatsApp. Trying to reconnect."})
  652. }
  653. user.bridge.Metrics.TrackConnectionState(user.JID, false)
  654. case *events.Contact:
  655. go user.syncPuppet(v.JID, "contact event")
  656. case *events.PushName:
  657. go user.syncPuppet(v.JID, "push name event")
  658. case *events.BusinessName:
  659. go user.syncPuppet(v.JID, "business name event")
  660. case *events.GroupInfo:
  661. user.groupListCache = nil
  662. go user.handleGroupUpdate(v)
  663. case *events.JoinedGroup:
  664. user.groupListCache = nil
  665. go user.handleGroupCreate(v)
  666. case *events.Picture:
  667. go user.handlePictureUpdate(v)
  668. case *events.Receipt:
  669. if v.IsFromMe && v.Sender.Device == 0 {
  670. user.phoneSeen(v.Timestamp)
  671. }
  672. go user.handleReceipt(v)
  673. case *events.ChatPresence:
  674. go user.handleChatPresence(v)
  675. case *events.Message:
  676. portal := user.GetPortalByMessageSource(v.Info.MessageSource)
  677. portal.messages <- PortalMessage{evt: v, source: user}
  678. case *events.MediaRetry:
  679. user.phoneSeen(v.Timestamp)
  680. portal := user.GetPortalByJID(v.ChatID)
  681. portal.mediaRetries <- PortalMediaRetry{evt: v, source: user}
  682. case *events.CallOffer:
  683. user.handleCallStart(v.CallCreator, v.CallID, "", v.Timestamp)
  684. case *events.CallOfferNotice:
  685. user.handleCallStart(v.CallCreator, v.CallID, v.Type, v.Timestamp)
  686. case *events.IdentityChange:
  687. puppet := user.bridge.GetPuppetByJID(v.JID)
  688. portal := user.GetPortalByJID(v.JID)
  689. if len(portal.MXID) > 0 && user.bridge.Config.Bridge.IdentityChangeNotices {
  690. text := fmt.Sprintf("Your security code with %s changed.", puppet.Displayname)
  691. if v.Implicit {
  692. text = fmt.Sprintf("Your security code with %s (device #%d) changed.", puppet.Displayname, v.JID.Device)
  693. }
  694. portal.messages <- PortalMessage{
  695. fake: &fakeMessage{
  696. Sender: v.JID,
  697. Text: text,
  698. ID: strconv.FormatInt(v.Timestamp.Unix(), 10),
  699. Time: v.Timestamp,
  700. Important: false,
  701. },
  702. source: user,
  703. }
  704. }
  705. case *events.CallTerminate, *events.CallRelayLatency, *events.CallAccept, *events.UnknownCallEvent:
  706. // ignore
  707. case *events.UndecryptableMessage:
  708. portal := user.GetPortalByMessageSource(v.Info.MessageSource)
  709. portal.messages <- PortalMessage{undecryptable: v, source: user}
  710. case *events.HistorySync:
  711. if user.bridge.Config.Bridge.HistorySync.Backfill {
  712. user.historySyncs <- v
  713. }
  714. case *events.Mute:
  715. portal := user.GetPortalByJID(v.JID)
  716. if portal != nil {
  717. var mutedUntil time.Time
  718. if v.Action.GetMuted() {
  719. mutedUntil = time.Unix(v.Action.GetMuteEndTimestamp(), 0)
  720. }
  721. go user.updateChatMute(nil, portal, mutedUntil)
  722. }
  723. case *events.Archive:
  724. portal := user.GetPortalByJID(v.JID)
  725. if portal != nil {
  726. go user.updateChatTag(nil, portal, user.bridge.Config.Bridge.ArchiveTag, v.Action.GetArchived())
  727. }
  728. case *events.Pin:
  729. portal := user.GetPortalByJID(v.JID)
  730. if portal != nil {
  731. go user.updateChatTag(nil, portal, user.bridge.Config.Bridge.PinnedTag, v.Action.GetPinned())
  732. }
  733. case *events.AppState:
  734. // Ignore
  735. case *events.KeepAliveTimeout:
  736. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateTransientDisconnect, Error: WAKeepaliveTimeout})
  737. case *events.KeepAliveRestored:
  738. user.log.Infof("Keepalive restored after timeouts, sending connected event")
  739. go user.BridgeState.Send(bridge.State{StateEvent: bridge.StateConnected})
  740. case *events.MarkChatAsRead:
  741. if user.bridge.Config.Bridge.SyncManualMarkedUnread {
  742. user.markUnread(user.GetPortalByJID(v.JID), !v.Action.GetRead())
  743. }
  744. default:
  745. user.log.Debugfln("Unknown type of event in HandleEvent: %T", v)
  746. }
  747. }
  748. func (user *User) updateChatMute(intent *appservice.IntentAPI, portal *Portal, mutedUntil time.Time) {
  749. if len(portal.MXID) == 0 || !user.bridge.Config.Bridge.MuteBridging {
  750. return
  751. } else if intent == nil {
  752. doublePuppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  753. if doublePuppet == nil || doublePuppet.CustomIntent() == nil {
  754. return
  755. }
  756. intent = doublePuppet.CustomIntent()
  757. }
  758. var err error
  759. if mutedUntil.IsZero() && mutedUntil.Before(time.Now()) {
  760. user.log.Debugfln("Portal %s is muted until %s, unmuting...", portal.MXID, mutedUntil)
  761. err = intent.DeletePushRule("global", pushrules.RoomRule, string(portal.MXID))
  762. } else {
  763. user.log.Debugfln("Portal %s is muted until %s, muting...", portal.MXID, mutedUntil)
  764. err = intent.PutPushRule("global", pushrules.RoomRule, string(portal.MXID), &mautrix.ReqPutPushRule{
  765. Actions: []pushrules.PushActionType{pushrules.ActionDontNotify},
  766. })
  767. }
  768. if err != nil && !errors.Is(err, mautrix.MNotFound) {
  769. user.log.Warnfln("Failed to update push rule for %s through double puppet: %v", portal.MXID, err)
  770. }
  771. }
  772. type CustomTagData struct {
  773. Order json.Number `json:"order"`
  774. DoublePuppet string `json:"fi.mau.double_puppet_source"`
  775. }
  776. type CustomTagEventContent struct {
  777. Tags map[string]CustomTagData `json:"tags"`
  778. }
  779. func (user *User) updateChatTag(intent *appservice.IntentAPI, portal *Portal, tag string, active bool) {
  780. if len(portal.MXID) == 0 || len(tag) == 0 {
  781. return
  782. } else if intent == nil {
  783. doublePuppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  784. if doublePuppet == nil || doublePuppet.CustomIntent() == nil {
  785. return
  786. }
  787. intent = doublePuppet.CustomIntent()
  788. }
  789. var existingTags CustomTagEventContent
  790. err := intent.GetTagsWithCustomData(portal.MXID, &existingTags)
  791. if err != nil && !errors.Is(err, mautrix.MNotFound) {
  792. user.log.Warnfln("Failed to get tags of %s: %v", portal.MXID, err)
  793. }
  794. currentTag, ok := existingTags.Tags[tag]
  795. if active && !ok {
  796. user.log.Debugln("Adding tag", tag, "to", portal.MXID)
  797. data := CustomTagData{"0.5", doublePuppetValue}
  798. err = intent.AddTagWithCustomData(portal.MXID, tag, &data)
  799. } else if !active && ok && currentTag.DoublePuppet == doublePuppetValue {
  800. user.log.Debugln("Removing tag", tag, "from", portal.MXID)
  801. err = intent.RemoveTag(portal.MXID, tag)
  802. } else {
  803. err = nil
  804. }
  805. if err != nil {
  806. user.log.Warnfln("Failed to update tag %s for %s through double puppet: %v", tag, portal.MXID, err)
  807. }
  808. }
  809. type CustomReadReceipt struct {
  810. Timestamp int64 `json:"ts,omitempty"`
  811. DoublePuppetSource string `json:"fi.mau.double_puppet_source,omitempty"`
  812. }
  813. type CustomReadMarkers struct {
  814. mautrix.ReqSetReadMarkers
  815. ReadExtra CustomReadReceipt `json:"com.beeper.read.extra"`
  816. FullyReadExtra CustomReadReceipt `json:"com.beeper.fully_read.extra"`
  817. }
  818. func (user *User) syncChatDoublePuppetDetails(portal *Portal, justCreated bool) {
  819. doublePuppet := portal.bridge.GetPuppetByCustomMXID(user.MXID)
  820. if doublePuppet == nil {
  821. return
  822. }
  823. if doublePuppet == nil || doublePuppet.CustomIntent() == nil || len(portal.MXID) == 0 {
  824. return
  825. }
  826. if justCreated || !user.bridge.Config.Bridge.TagOnlyOnCreate {
  827. chat, err := user.Client.Store.ChatSettings.GetChatSettings(portal.Key.JID)
  828. if err != nil {
  829. user.log.Warnfln("Failed to get settings of %s: %v", portal.Key.JID, err)
  830. return
  831. }
  832. intent := doublePuppet.CustomIntent()
  833. if portal.Key.JID == types.StatusBroadcastJID && justCreated {
  834. if user.bridge.Config.Bridge.MuteStatusBroadcast {
  835. user.updateChatMute(intent, portal, time.Now().Add(365*24*time.Hour))
  836. }
  837. if len(user.bridge.Config.Bridge.StatusBroadcastTag) > 0 {
  838. user.updateChatTag(intent, portal, user.bridge.Config.Bridge.StatusBroadcastTag, true)
  839. }
  840. return
  841. } else if !chat.Found {
  842. return
  843. }
  844. user.updateChatMute(intent, portal, chat.MutedUntil)
  845. user.updateChatTag(intent, portal, user.bridge.Config.Bridge.ArchiveTag, chat.Archived)
  846. user.updateChatTag(intent, portal, user.bridge.Config.Bridge.PinnedTag, chat.Pinned)
  847. }
  848. }
  849. func (user *User) getDirectChats() map[id.UserID][]id.RoomID {
  850. res := make(map[id.UserID][]id.RoomID)
  851. privateChats := user.bridge.DB.Portal.FindPrivateChats(user.JID.ToNonAD())
  852. for _, portal := range privateChats {
  853. if len(portal.MXID) > 0 {
  854. res[user.bridge.FormatPuppetMXID(portal.Key.JID)] = []id.RoomID{portal.MXID}
  855. }
  856. }
  857. return res
  858. }
  859. func (user *User) UpdateDirectChats(chats map[id.UserID][]id.RoomID) {
  860. if !user.bridge.Config.Bridge.SyncDirectChatList {
  861. return
  862. }
  863. puppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  864. if puppet == nil || puppet.CustomIntent() == nil {
  865. return
  866. }
  867. intent := puppet.CustomIntent()
  868. method := http.MethodPatch
  869. if chats == nil {
  870. chats = user.getDirectChats()
  871. method = http.MethodPut
  872. }
  873. user.log.Debugln("Updating m.direct list on homeserver")
  874. var err error
  875. if user.bridge.Config.Homeserver.Asmux {
  876. urlPath := intent.BuildClientURL("unstable", "com.beeper.asmux", "dms")
  877. _, err = intent.MakeFullRequest(mautrix.FullRequest{
  878. Method: method,
  879. URL: urlPath,
  880. Headers: http.Header{"X-Asmux-Auth": {user.bridge.AS.Registration.AppToken}},
  881. RequestJSON: chats,
  882. })
  883. } else {
  884. existingChats := make(map[id.UserID][]id.RoomID)
  885. err = intent.GetAccountData(event.AccountDataDirectChats.Type, &existingChats)
  886. if err != nil {
  887. user.log.Warnln("Failed to get m.direct list to update it:", err)
  888. return
  889. }
  890. for userID, rooms := range existingChats {
  891. if _, ok := user.bridge.ParsePuppetMXID(userID); !ok {
  892. // This is not a ghost user, include it in the new list
  893. chats[userID] = rooms
  894. } else if _, ok := chats[userID]; !ok && method == http.MethodPatch {
  895. // This is a ghost user, but we're not replacing the whole list, so include it too
  896. chats[userID] = rooms
  897. }
  898. }
  899. err = intent.SetAccountData(event.AccountDataDirectChats.Type, &chats)
  900. }
  901. if err != nil {
  902. user.log.Warnln("Failed to update m.direct list:", err)
  903. }
  904. }
  905. func (user *User) handleLoggedOut(onConnect bool, reason events.ConnectFailureReason) {
  906. errorCode := WAUnknownLogout
  907. if reason == events.ConnectFailureLoggedOut {
  908. errorCode = WALoggedOut
  909. } else if reason == events.ConnectFailureMainDeviceGone {
  910. errorCode = WAMainDeviceGone
  911. }
  912. user.removeFromJIDMap(bridge.State{StateEvent: bridge.StateBadCredentials, Error: errorCode})
  913. user.DeleteConnection()
  914. user.Session = nil
  915. user.JID = types.EmptyJID
  916. user.Update()
  917. if onConnect {
  918. user.sendMarkdownBridgeAlert("Connecting to WhatsApp failed as the device was unlinked (error %s). Please link the bridge to your phone again.", reason)
  919. } else {
  920. user.sendMarkdownBridgeAlert("You were logged out from another device. Please link the bridge to your phone again.")
  921. }
  922. }
  923. func (user *User) GetPortalByMessageSource(ms types.MessageSource) *Portal {
  924. jid := ms.Chat
  925. if ms.IsIncomingBroadcast() {
  926. if ms.IsFromMe {
  927. jid = ms.BroadcastListOwner.ToNonAD()
  928. } else {
  929. jid = ms.Sender.ToNonAD()
  930. }
  931. if jid.IsEmpty() {
  932. return nil
  933. }
  934. }
  935. return user.bridge.GetPortalByJID(database.NewPortalKey(jid, user.JID))
  936. }
  937. func (user *User) GetPortalByJID(jid types.JID) *Portal {
  938. return user.bridge.GetPortalByJID(database.NewPortalKey(jid, user.JID))
  939. }
  940. func (user *User) syncPuppet(jid types.JID, reason string) {
  941. user.bridge.GetPuppetByJID(jid).SyncContact(user, false, false, reason)
  942. }
  943. func (user *User) ResyncContacts() error {
  944. contacts, err := user.Client.Store.Contacts.GetAllContacts()
  945. if err != nil {
  946. return fmt.Errorf("failed to get cached contacts: %w", err)
  947. }
  948. user.log.Infofln("Resyncing displaynames with %d contacts", len(contacts))
  949. for jid, contact := range contacts {
  950. puppet := user.bridge.GetPuppetByJID(jid)
  951. if puppet != nil {
  952. puppet.Sync(user, contact)
  953. } else {
  954. user.log.Warnfln("Got a nil puppet for %s while syncing contacts", jid)
  955. }
  956. }
  957. return nil
  958. }
  959. func (user *User) ResyncGroups(createPortals bool) error {
  960. groups, err := user.Client.GetJoinedGroups()
  961. if err != nil {
  962. return fmt.Errorf("failed to get group list from server: %w", err)
  963. }
  964. for _, group := range groups {
  965. portal := user.GetPortalByJID(group.JID)
  966. if len(portal.MXID) == 0 {
  967. if createPortals {
  968. err = portal.CreateMatrixRoom(user, group, true, true)
  969. if err != nil {
  970. return fmt.Errorf("failed to create room for %s: %w", group.JID, err)
  971. }
  972. }
  973. } else {
  974. portal.UpdateMatrixRoom(user, group)
  975. }
  976. }
  977. return nil
  978. }
  979. const WATypingTimeout = 15 * time.Second
  980. func (user *User) handleChatPresence(presence *events.ChatPresence) {
  981. puppet := user.bridge.GetPuppetByJID(presence.Sender)
  982. portal := user.GetPortalByJID(presence.Chat)
  983. if puppet == nil || portal == nil || len(portal.MXID) == 0 {
  984. return
  985. }
  986. if presence.State == types.ChatPresenceComposing {
  987. if puppet.typingIn != "" && puppet.typingAt.Add(WATypingTimeout).Before(time.Now()) {
  988. if puppet.typingIn == portal.MXID {
  989. return
  990. }
  991. _, _ = puppet.IntentFor(portal).UserTyping(puppet.typingIn, false, 0)
  992. }
  993. _, _ = puppet.IntentFor(portal).UserTyping(portal.MXID, true, WATypingTimeout.Milliseconds())
  994. puppet.typingIn = portal.MXID
  995. puppet.typingAt = time.Now()
  996. } else {
  997. _, _ = puppet.IntentFor(portal).UserTyping(portal.MXID, false, 0)
  998. puppet.typingIn = ""
  999. }
  1000. }
  1001. func (user *User) handleReceipt(receipt *events.Receipt) {
  1002. if receipt.Type != events.ReceiptTypeRead && receipt.Type != events.ReceiptTypeReadSelf {
  1003. return
  1004. }
  1005. portal := user.GetPortalByMessageSource(receipt.MessageSource)
  1006. if portal == nil || len(portal.MXID) == 0 {
  1007. return
  1008. }
  1009. portal.messages <- PortalMessage{receipt: receipt, source: user}
  1010. }
  1011. func makeReadMarkerContent(eventID id.EventID, doublePuppet bool) CustomReadMarkers {
  1012. var extra CustomReadReceipt
  1013. if doublePuppet {
  1014. extra.DoublePuppetSource = doublePuppetValue
  1015. }
  1016. return CustomReadMarkers{
  1017. ReqSetReadMarkers: mautrix.ReqSetReadMarkers{
  1018. Read: eventID,
  1019. FullyRead: eventID,
  1020. },
  1021. ReadExtra: extra,
  1022. FullyReadExtra: extra,
  1023. }
  1024. }
  1025. func (user *User) markSelfReadFull(portal *Portal) {
  1026. puppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  1027. if puppet == nil || puppet.CustomIntent() == nil {
  1028. return
  1029. }
  1030. lastMessage := user.bridge.DB.Message.GetLastInChat(portal.Key)
  1031. if lastMessage == nil {
  1032. return
  1033. }
  1034. user.SetLastReadTS(portal.Key, lastMessage.Timestamp)
  1035. err := puppet.CustomIntent().SetReadMarkers(portal.MXID, makeReadMarkerContent(lastMessage.MXID, true))
  1036. if err != nil {
  1037. user.log.Warnfln("Failed to mark %s (last message) in %s as read: %v", lastMessage.MXID, portal.MXID, err)
  1038. } else {
  1039. user.log.Debugfln("Marked %s (last message) in %s as read", lastMessage.MXID, portal.MXID)
  1040. }
  1041. }
  1042. func (user *User) markUnread(portal *Portal, unread bool) {
  1043. puppet := user.bridge.GetPuppetByCustomMXID(user.MXID)
  1044. if puppet == nil || puppet.CustomIntent() == nil {
  1045. return
  1046. }
  1047. err := puppet.CustomIntent().SetRoomAccountData(portal.MXID, "m.marked_unread",
  1048. map[string]bool{"unread": unread})
  1049. if err != nil {
  1050. user.log.Warnfln("Failed to mark %s as unread via m.marked_unread: %v", portal.MXID, err)
  1051. } else {
  1052. user.log.Debugfln("Marked %s as unread via m.marked_unread: %v", portal.MXID, err)
  1053. }
  1054. err = puppet.CustomIntent().SetRoomAccountData(portal.MXID, "com.famedly.marked_unread",
  1055. map[string]bool{"unread": unread})
  1056. if err != nil {
  1057. user.log.Warnfln("Failed to mark %s as unread via com.famedly.marked_unread: %v", portal.MXID, err)
  1058. } else {
  1059. user.log.Debugfln("Marked %s as unread via com.famedly.marked_unread: %v", portal.MXID, err)
  1060. }
  1061. }
  1062. func (user *User) handleGroupCreate(evt *events.JoinedGroup) {
  1063. portal := user.GetPortalByJID(evt.JID)
  1064. if len(portal.MXID) == 0 {
  1065. err := portal.CreateMatrixRoom(user, &evt.GroupInfo, true, true)
  1066. if err != nil {
  1067. user.log.Errorln("Failed to create Matrix room after join notification: %v", err)
  1068. }
  1069. } else {
  1070. portal.UpdateMatrixRoom(user, &evt.GroupInfo)
  1071. }
  1072. }
  1073. func (user *User) handleGroupUpdate(evt *events.GroupInfo) {
  1074. portal := user.GetPortalByJID(evt.JID)
  1075. if portal == nil || len(portal.MXID) == 0 {
  1076. user.log.Debugfln("Ignoring group info update in chat with no portal: %+v", evt)
  1077. return
  1078. }
  1079. switch {
  1080. case evt.Announce != nil:
  1081. portal.RestrictMessageSending(evt.Announce.IsAnnounce)
  1082. case evt.Locked != nil:
  1083. portal.RestrictMetadataChanges(evt.Locked.IsLocked)
  1084. case evt.Name != nil:
  1085. portal.UpdateName(evt.Name.Name, evt.Name.NameSetBy, true)
  1086. case evt.Topic != nil:
  1087. portal.UpdateTopic(evt.Topic.Topic, evt.Topic.TopicSetBy, true)
  1088. case evt.Leave != nil:
  1089. if evt.Sender != nil && !evt.Sender.IsEmpty() {
  1090. portal.HandleWhatsAppKick(user, *evt.Sender, evt.Leave)
  1091. }
  1092. case evt.Join != nil:
  1093. portal.HandleWhatsAppInvite(user, evt.Sender, evt.Join)
  1094. case evt.Promote != nil:
  1095. portal.ChangeAdminStatus(evt.Promote, true)
  1096. case evt.Demote != nil:
  1097. portal.ChangeAdminStatus(evt.Demote, false)
  1098. case evt.Ephemeral != nil:
  1099. portal.UpdateGroupDisappearingMessages(evt.Sender, evt.Timestamp, evt.Ephemeral.DisappearingTimer)
  1100. }
  1101. }
  1102. func (user *User) handlePictureUpdate(evt *events.Picture) {
  1103. if evt.JID.Server == types.DefaultUserServer {
  1104. puppet := user.bridge.GetPuppetByJID(evt.JID)
  1105. user.log.Debugfln("Received picture update for puppet %s (current: %s, new: %s)", evt.JID, puppet.Avatar, evt.PictureID)
  1106. if puppet.Avatar != evt.PictureID {
  1107. puppet.UpdateAvatar(user)
  1108. }
  1109. } else if portal := user.GetPortalByJID(evt.JID); portal != nil {
  1110. user.log.Debugfln("Received picture update for portal %s (current: %s, new: %s)", evt.JID, portal.Avatar, evt.PictureID)
  1111. if portal.Avatar != evt.PictureID {
  1112. portal.UpdateAvatar(user, evt.Author, true)
  1113. }
  1114. }
  1115. }
  1116. func (user *User) StartPM(jid types.JID, reason string) (*Portal, *Puppet, bool, error) {
  1117. user.log.Debugln("Starting PM with", jid, "from", reason)
  1118. puppet := user.bridge.GetPuppetByJID(jid)
  1119. puppet.SyncContact(user, true, false, reason)
  1120. portal := user.GetPortalByJID(puppet.JID)
  1121. if len(portal.MXID) > 0 {
  1122. ok := portal.ensureUserInvited(user)
  1123. if !ok {
  1124. portal.log.Warnfln("ensureUserInvited(%s) returned false, creating new portal", user.MXID)
  1125. portal.MXID = ""
  1126. } else {
  1127. return portal, puppet, false, nil
  1128. }
  1129. }
  1130. err := portal.CreateMatrixRoom(user, nil, false, true)
  1131. return portal, puppet, true, err
  1132. }
  1133. const groupListCacheMaxAge = 24 * time.Hour
  1134. func (user *User) getCachedGroupList() ([]*types.GroupInfo, error) {
  1135. user.groupListCacheLock.Lock()
  1136. defer user.groupListCacheLock.Unlock()
  1137. if user.groupListCache != nil && user.groupListCacheTime.Add(groupListCacheMaxAge).After(time.Now()) {
  1138. return user.groupListCache, nil
  1139. }
  1140. var err error
  1141. user.groupListCache, err = user.Client.GetJoinedGroups()
  1142. user.groupListCacheTime = time.Now()
  1143. return user.groupListCache, err
  1144. }