disappear.go 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  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. "fmt"
  19. "time"
  20. "maunium.net/go/mautrix"
  21. "maunium.net/go/mautrix/id"
  22. "maunium.net/go/mautrix-whatsapp/database"
  23. )
  24. func (portal *Portal) MarkDisappearing(eventID id.EventID, expiresIn uint32, startNow bool) {
  25. if expiresIn == 0 || (!portal.bridge.Config.Bridge.DisappearingMessagesInGroups && portal.IsGroupChat()) {
  26. return
  27. }
  28. msg := portal.bridge.DB.DisappearingMessage.NewWithValues(portal.MXID, eventID, time.Duration(expiresIn)*time.Second, startNow)
  29. msg.Insert()
  30. if startNow {
  31. go portal.sleepAndDelete(msg)
  32. }
  33. }
  34. func (portal *Portal) ScheduleDisappearing() {
  35. if !portal.bridge.Config.Bridge.DisappearingMessagesInGroups && portal.IsGroupChat() {
  36. return
  37. }
  38. nowPlusHour := time.Now().Add(1 * time.Hour)
  39. for _, msg := range portal.bridge.DB.DisappearingMessage.StartAllUnscheduledInRoom(portal.MXID) {
  40. if msg.ExpireAt.Before(nowPlusHour) {
  41. go portal.sleepAndDelete(msg)
  42. }
  43. }
  44. }
  45. func (bridge *Bridge) DisappearingLoop() {
  46. for {
  47. for _, msg := range bridge.DB.DisappearingMessage.GetUpcomingScheduled(1 * time.Hour) {
  48. portal := bridge.GetPortalByMXID(msg.RoomID)
  49. go portal.sleepAndDelete(msg)
  50. }
  51. time.Sleep(1 * time.Hour)
  52. }
  53. }
  54. func (portal *Portal) sleepAndDelete(msg *database.DisappearingMessage) {
  55. sleepTime := msg.ExpireAt.Sub(time.Now())
  56. portal.log.Debugfln("Sleeping for %s to make %s disappear", sleepTime, msg.EventID)
  57. time.Sleep(sleepTime)
  58. _, err := portal.MainIntent().RedactEvent(msg.RoomID, msg.EventID, mautrix.ReqRedact{
  59. Reason: "Message expired",
  60. TxnID: fmt.Sprintf("mxwa_disappear_%s", msg.EventID),
  61. })
  62. if err != nil {
  63. portal.log.Warnfln("Failed to make %s disappear: %v", msg.EventID, err)
  64. } else {
  65. portal.log.Debugfln("Disappeared %s", msg.EventID)
  66. }
  67. msg.Delete()
  68. }