portal.go 71 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230
  1. package main
  2. import (
  3. "bytes"
  4. "errors"
  5. "fmt"
  6. "html"
  7. "reflect"
  8. "strconv"
  9. "strings"
  10. "sync"
  11. "time"
  12. "maunium.net/go/mautrix/bridge/status"
  13. "maunium.net/go/mautrix/crypto/attachment"
  14. "maunium.net/go/mautrix/format"
  15. "maunium.net/go/mautrix/util"
  16. "maunium.net/go/mautrix/util/variationselector"
  17. "github.com/bwmarrin/discordgo"
  18. log "maunium.net/go/maulogger/v2"
  19. "maunium.net/go/mautrix"
  20. "maunium.net/go/mautrix/appservice"
  21. "maunium.net/go/mautrix/bridge"
  22. "maunium.net/go/mautrix/bridge/bridgeconfig"
  23. "maunium.net/go/mautrix/event"
  24. "maunium.net/go/mautrix/id"
  25. "go.mau.fi/mautrix-discord/config"
  26. "go.mau.fi/mautrix-discord/database"
  27. )
  28. type portalDiscordMessage struct {
  29. msg interface{}
  30. user *User
  31. thread *Thread
  32. }
  33. type portalMatrixMessage struct {
  34. evt *event.Event
  35. user *User
  36. }
  37. type Portal struct {
  38. *database.Portal
  39. Parent *Portal
  40. Guild *Guild
  41. bridge *DiscordBridge
  42. log log.Logger
  43. roomCreateLock sync.Mutex
  44. encryptLock sync.Mutex
  45. discordMessages chan portalDiscordMessage
  46. matrixMessages chan portalMatrixMessage
  47. recentMessages *util.RingBuffer[string, *discordgo.Message]
  48. currentlyTyping []id.UserID
  49. currentlyTypingLock sync.Mutex
  50. }
  51. const recentMessageBufferSize = 32
  52. var _ bridge.Portal = (*Portal)(nil)
  53. var _ bridge.ReadReceiptHandlingPortal = (*Portal)(nil)
  54. var _ bridge.MembershipHandlingPortal = (*Portal)(nil)
  55. var _ bridge.TypingPortal = (*Portal)(nil)
  56. //var _ bridge.MetaHandlingPortal = (*Portal)(nil)
  57. //var _ bridge.DisappearingPortal = (*Portal)(nil)
  58. func (portal *Portal) IsEncrypted() bool {
  59. return portal.Encrypted
  60. }
  61. func (portal *Portal) MarkEncrypted() {
  62. portal.Encrypted = true
  63. portal.Update()
  64. }
  65. func (portal *Portal) ReceiveMatrixEvent(user bridge.User, evt *event.Event) {
  66. if user.GetPermissionLevel() >= bridgeconfig.PermissionLevelUser /*|| portal.HasRelaybot()*/ {
  67. portal.matrixMessages <- portalMatrixMessage{user: user.(*User), evt: evt}
  68. }
  69. }
  70. var (
  71. portalCreationDummyEvent = event.Type{Type: "fi.mau.dummy.portal_created", Class: event.MessageEventType}
  72. )
  73. func (br *DiscordBridge) loadPortal(dbPortal *database.Portal, key *database.PortalKey, chanType discordgo.ChannelType) *Portal {
  74. if dbPortal == nil {
  75. if key == nil || chanType < 0 {
  76. return nil
  77. }
  78. dbPortal = br.DB.Portal.New()
  79. dbPortal.Key = *key
  80. dbPortal.Type = chanType
  81. dbPortal.Insert()
  82. }
  83. portal := br.NewPortal(dbPortal)
  84. br.portalsByID[portal.Key] = portal
  85. if portal.MXID != "" {
  86. br.portalsByMXID[portal.MXID] = portal
  87. }
  88. if portal.GuildID != "" {
  89. portal.Guild = portal.bridge.GetGuildByID(portal.GuildID, true)
  90. }
  91. if portal.ParentID != "" {
  92. parentKey := database.NewPortalKey(portal.ParentID, "")
  93. var ok bool
  94. portal.Parent, ok = br.portalsByID[parentKey]
  95. if !ok {
  96. portal.Parent = br.loadPortal(br.DB.Portal.GetByID(parentKey), nil, -1)
  97. }
  98. }
  99. return portal
  100. }
  101. func (br *DiscordBridge) GetPortalByMXID(mxid id.RoomID) *Portal {
  102. br.portalsLock.Lock()
  103. defer br.portalsLock.Unlock()
  104. portal, ok := br.portalsByMXID[mxid]
  105. if !ok {
  106. return br.loadPortal(br.DB.Portal.GetByMXID(mxid), nil, -1)
  107. }
  108. return portal
  109. }
  110. func (user *User) GetPortalByMeta(meta *discordgo.Channel) *Portal {
  111. return user.GetPortalByID(meta.ID, meta.Type)
  112. }
  113. func (user *User) GetExistingPortalByID(id string) *Portal {
  114. return user.bridge.GetExistingPortalByID(database.NewPortalKey(id, user.DiscordID))
  115. }
  116. func (user *User) GetPortalByID(id string, chanType discordgo.ChannelType) *Portal {
  117. return user.bridge.GetPortalByID(database.NewPortalKey(id, user.DiscordID), chanType)
  118. }
  119. func (br *DiscordBridge) GetExistingPortalByID(key database.PortalKey) *Portal {
  120. br.portalsLock.Lock()
  121. defer br.portalsLock.Unlock()
  122. portal, ok := br.portalsByID[key]
  123. if !ok {
  124. portal, ok = br.portalsByID[database.NewPortalKey(key.ChannelID, "")]
  125. if !ok {
  126. return br.loadPortal(br.DB.Portal.GetByID(key), nil, -1)
  127. }
  128. }
  129. return portal
  130. }
  131. func (br *DiscordBridge) GetPortalByID(key database.PortalKey, chanType discordgo.ChannelType) *Portal {
  132. br.portalsLock.Lock()
  133. defer br.portalsLock.Unlock()
  134. if chanType != discordgo.ChannelTypeDM {
  135. key.Receiver = ""
  136. }
  137. portal, ok := br.portalsByID[key]
  138. if !ok {
  139. return br.loadPortal(br.DB.Portal.GetByID(key), &key, chanType)
  140. }
  141. return portal
  142. }
  143. func (br *DiscordBridge) GetAllPortals() []*Portal {
  144. return br.dbPortalsToPortals(br.DB.Portal.GetAll())
  145. }
  146. func (br *DiscordBridge) GetAllPortalsInGuild(guildID string) []*Portal {
  147. return br.dbPortalsToPortals(br.DB.Portal.GetAllInGuild(guildID))
  148. }
  149. func (br *DiscordBridge) GetAllIPortals() (iportals []bridge.Portal) {
  150. portals := br.GetAllPortals()
  151. iportals = make([]bridge.Portal, len(portals))
  152. for i, portal := range portals {
  153. iportals[i] = portal
  154. }
  155. return iportals
  156. }
  157. func (br *DiscordBridge) GetDMPortalsWith(otherUserID string) []*Portal {
  158. return br.dbPortalsToPortals(br.DB.Portal.FindPrivateChatsWith(otherUserID))
  159. }
  160. func (br *DiscordBridge) dbPortalsToPortals(dbPortals []*database.Portal) []*Portal {
  161. br.portalsLock.Lock()
  162. defer br.portalsLock.Unlock()
  163. output := make([]*Portal, len(dbPortals))
  164. for index, dbPortal := range dbPortals {
  165. if dbPortal == nil {
  166. continue
  167. }
  168. portal, ok := br.portalsByID[dbPortal.Key]
  169. if !ok {
  170. portal = br.loadPortal(dbPortal, nil, -1)
  171. }
  172. output[index] = portal
  173. }
  174. return output
  175. }
  176. func (br *DiscordBridge) NewPortal(dbPortal *database.Portal) *Portal {
  177. portal := &Portal{
  178. Portal: dbPortal,
  179. bridge: br,
  180. log: br.Log.Sub(fmt.Sprintf("Portal/%s", dbPortal.Key)),
  181. discordMessages: make(chan portalDiscordMessage, br.Config.Bridge.PortalMessageBuffer),
  182. matrixMessages: make(chan portalMatrixMessage, br.Config.Bridge.PortalMessageBuffer),
  183. recentMessages: util.NewRingBuffer[string, *discordgo.Message](recentMessageBufferSize),
  184. }
  185. go portal.messageLoop()
  186. return portal
  187. }
  188. func (portal *Portal) messageLoop() {
  189. for {
  190. select {
  191. case msg := <-portal.matrixMessages:
  192. portal.handleMatrixMessages(msg)
  193. case msg := <-portal.discordMessages:
  194. portal.handleDiscordMessages(msg)
  195. }
  196. }
  197. }
  198. func (portal *Portal) IsPrivateChat() bool {
  199. return portal.Type == discordgo.ChannelTypeDM
  200. }
  201. func (portal *Portal) MainIntent() *appservice.IntentAPI {
  202. if portal.IsPrivateChat() && portal.OtherUserID != "" {
  203. return portal.bridge.GetPuppetByID(portal.OtherUserID).DefaultIntent()
  204. }
  205. return portal.bridge.Bot
  206. }
  207. type CustomBridgeInfoContent struct {
  208. event.BridgeEventContent
  209. RoomType string `json:"com.beeper.room_type,omitempty"`
  210. }
  211. func init() {
  212. event.TypeMap[event.StateBridge] = reflect.TypeOf(CustomBridgeInfoContent{})
  213. event.TypeMap[event.StateHalfShotBridge] = reflect.TypeOf(CustomBridgeInfoContent{})
  214. }
  215. func (portal *Portal) getBridgeInfo() (string, CustomBridgeInfoContent) {
  216. bridgeInfo := event.BridgeEventContent{
  217. BridgeBot: portal.bridge.Bot.UserID,
  218. Creator: portal.MainIntent().UserID,
  219. Protocol: event.BridgeInfoSection{
  220. ID: "discordgo",
  221. DisplayName: "Discord",
  222. AvatarURL: portal.bridge.Config.AppService.Bot.ParsedAvatar.CUString(),
  223. ExternalURL: "https://discord.com/",
  224. },
  225. Channel: event.BridgeInfoSection{
  226. ID: portal.Key.ChannelID,
  227. DisplayName: portal.Name,
  228. },
  229. }
  230. var bridgeInfoStateKey string
  231. if portal.GuildID == "" {
  232. bridgeInfoStateKey = fmt.Sprintf("fi.mau.discord://discord/dm/%s", portal.Key.ChannelID)
  233. bridgeInfo.Channel.ExternalURL = fmt.Sprintf("https://discord.com/channels/@me/%s", portal.Key.ChannelID)
  234. } else {
  235. bridgeInfo.Network = &event.BridgeInfoSection{
  236. ID: portal.GuildID,
  237. }
  238. if portal.Guild != nil {
  239. bridgeInfo.Network.DisplayName = portal.Guild.Name
  240. bridgeInfo.Network.AvatarURL = portal.Guild.AvatarURL.CUString()
  241. // TODO is it possible to find the URL?
  242. }
  243. bridgeInfoStateKey = fmt.Sprintf("fi.mau.discord://discord/%s/%s", portal.GuildID, portal.Key.ChannelID)
  244. bridgeInfo.Channel.ExternalURL = fmt.Sprintf("https://discord.com/channels/%s/%s", portal.GuildID, portal.Key.ChannelID)
  245. }
  246. var roomType string
  247. if portal.Type == discordgo.ChannelTypeDM || portal.Type == discordgo.ChannelTypeGroupDM {
  248. roomType = "dm"
  249. }
  250. return bridgeInfoStateKey, CustomBridgeInfoContent{bridgeInfo, roomType}
  251. }
  252. func (portal *Portal) UpdateBridgeInfo() {
  253. if len(portal.MXID) == 0 {
  254. portal.log.Debugln("Not updating bridge info: no Matrix room created")
  255. return
  256. }
  257. portal.log.Debugln("Updating bridge info...")
  258. stateKey, content := portal.getBridgeInfo()
  259. _, err := portal.MainIntent().SendStateEvent(portal.MXID, event.StateBridge, stateKey, content)
  260. if err != nil {
  261. portal.log.Warnln("Failed to update m.bridge:", err)
  262. }
  263. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  264. _, err = portal.MainIntent().SendStateEvent(portal.MXID, event.StateHalfShotBridge, stateKey, content)
  265. if err != nil {
  266. portal.log.Warnln("Failed to update uk.half-shot.bridge:", err)
  267. }
  268. }
  269. func (portal *Portal) GetEncryptionEventContent() (evt *event.EncryptionEventContent) {
  270. evt = &event.EncryptionEventContent{Algorithm: id.AlgorithmMegolmV1}
  271. if rot := portal.bridge.Config.Bridge.Encryption.Rotation; rot.EnableCustom {
  272. evt.RotationPeriodMillis = rot.Milliseconds
  273. evt.RotationPeriodMessages = rot.Messages
  274. }
  275. return
  276. }
  277. func (portal *Portal) CreateMatrixRoom(user *User, channel *discordgo.Channel) error {
  278. portal.roomCreateLock.Lock()
  279. defer portal.roomCreateLock.Unlock()
  280. if portal.MXID != "" {
  281. return nil
  282. }
  283. portal.log.Infoln("Creating Matrix room for channel")
  284. channel = portal.UpdateInfo(user, channel)
  285. if channel == nil {
  286. return fmt.Errorf("didn't find channel metadata")
  287. }
  288. intent := portal.MainIntent()
  289. if err := intent.EnsureRegistered(); err != nil {
  290. return err
  291. }
  292. bridgeInfoStateKey, bridgeInfo := portal.getBridgeInfo()
  293. initialState := []*event.Event{{
  294. Type: event.StateBridge,
  295. Content: event.Content{Parsed: bridgeInfo},
  296. StateKey: &bridgeInfoStateKey,
  297. }, {
  298. // TODO remove this once https://github.com/matrix-org/matrix-doc/pull/2346 is in spec
  299. Type: event.StateHalfShotBridge,
  300. Content: event.Content{Parsed: bridgeInfo},
  301. StateKey: &bridgeInfoStateKey,
  302. }}
  303. if !portal.AvatarURL.IsEmpty() {
  304. initialState = append(initialState, &event.Event{
  305. Type: event.StateRoomAvatar,
  306. Content: event.Content{Parsed: &event.RoomAvatarEventContent{
  307. URL: portal.AvatarURL,
  308. }},
  309. })
  310. }
  311. creationContent := make(map[string]interface{})
  312. if portal.Type == discordgo.ChannelTypeGuildCategory {
  313. creationContent["type"] = event.RoomTypeSpace
  314. }
  315. if !portal.bridge.Config.Bridge.FederateRooms {
  316. creationContent["m.federate"] = false
  317. }
  318. spaceID := portal.ExpectedSpaceID()
  319. if spaceID != "" {
  320. spaceIDStr := spaceID.String()
  321. initialState = append(initialState, &event.Event{
  322. Type: event.StateSpaceParent,
  323. StateKey: &spaceIDStr,
  324. Content: event.Content{Parsed: &event.SpaceParentEventContent{
  325. Via: []string{portal.bridge.AS.HomeserverDomain},
  326. Canonical: true,
  327. }},
  328. })
  329. }
  330. if portal.bridge.Config.Bridge.RestrictedRooms && portal.Guild != nil && portal.Guild.MXID != "" {
  331. // TODO don't do this for private channels in guilds
  332. initialState = append(initialState, &event.Event{
  333. Type: event.StateJoinRules,
  334. Content: event.Content{Parsed: &event.JoinRulesEventContent{
  335. JoinRule: event.JoinRuleRestricted,
  336. Allow: []event.JoinRuleAllow{{
  337. RoomID: spaceID,
  338. Type: event.JoinRuleAllowRoomMembership,
  339. }},
  340. }},
  341. })
  342. }
  343. var invite []id.UserID
  344. if portal.bridge.Config.Bridge.Encryption.Default {
  345. initialState = append(initialState, &event.Event{
  346. Type: event.StateEncryption,
  347. Content: event.Content{
  348. Parsed: portal.GetEncryptionEventContent(),
  349. },
  350. })
  351. portal.Encrypted = true
  352. if portal.IsPrivateChat() {
  353. invite = append(invite, portal.bridge.Bot.UserID)
  354. }
  355. }
  356. resp, err := intent.CreateRoom(&mautrix.ReqCreateRoom{
  357. Visibility: "private",
  358. Name: portal.Name,
  359. Topic: portal.Topic,
  360. Invite: invite,
  361. Preset: "private_chat",
  362. IsDirect: portal.IsPrivateChat(),
  363. InitialState: initialState,
  364. CreationContent: creationContent,
  365. })
  366. if err != nil {
  367. portal.log.Warnln("Failed to create room:", err)
  368. return err
  369. }
  370. portal.NameSet = true
  371. portal.TopicSet = true
  372. portal.AvatarSet = !portal.AvatarURL.IsEmpty()
  373. portal.MXID = resp.RoomID
  374. portal.bridge.portalsLock.Lock()
  375. portal.bridge.portalsByMXID[portal.MXID] = portal
  376. portal.bridge.portalsLock.Unlock()
  377. portal.Update()
  378. portal.log.Infoln("Matrix room created:", portal.MXID)
  379. if portal.Encrypted && portal.IsPrivateChat() {
  380. err = portal.bridge.Bot.EnsureJoined(portal.MXID, appservice.EnsureJoinedParams{BotOverride: portal.MainIntent().Client})
  381. if err != nil {
  382. portal.log.Errorfln("Failed to ensure bridge bot is joined to private chat portal: %v", err)
  383. }
  384. }
  385. if portal.GuildID == "" {
  386. user.addPrivateChannelToSpace(portal)
  387. } else {
  388. portal.updateSpace()
  389. }
  390. portal.ensureUserInvited(user)
  391. user.syncChatDoublePuppetDetails(portal, true)
  392. portal.syncParticipants(user, channel.Recipients)
  393. if portal.IsPrivateChat() {
  394. puppet := user.bridge.GetPuppetByID(portal.Key.Receiver)
  395. chats := map[id.UserID][]id.RoomID{puppet.MXID: {portal.MXID}}
  396. user.updateDirectChats(chats)
  397. }
  398. firstEventResp, err := portal.MainIntent().SendMessageEvent(portal.MXID, portalCreationDummyEvent, struct{}{})
  399. if err != nil {
  400. portal.log.Errorln("Failed to send dummy event to mark portal creation:", err)
  401. } else {
  402. portal.FirstEventID = firstEventResp.EventID
  403. portal.Update()
  404. }
  405. return nil
  406. }
  407. func (portal *Portal) handleDiscordMessages(msg portalDiscordMessage) {
  408. if portal.MXID == "" {
  409. _, ok := msg.msg.(*discordgo.MessageCreate)
  410. if !ok {
  411. portal.log.Warnln("Can't create Matrix room from non new message event")
  412. return
  413. }
  414. portal.log.Debugln("Creating Matrix room from incoming message")
  415. if err := portal.CreateMatrixRoom(msg.user, nil); err != nil {
  416. portal.log.Errorln("Failed to create portal room:", err)
  417. return
  418. }
  419. }
  420. switch convertedMsg := msg.msg.(type) {
  421. case *discordgo.MessageCreate:
  422. portal.handleDiscordMessageCreate(msg.user, convertedMsg.Message, msg.thread)
  423. case *discordgo.MessageUpdate:
  424. portal.handleDiscordMessageUpdate(msg.user, convertedMsg.Message)
  425. case *discordgo.MessageDelete:
  426. portal.handleDiscordMessageDelete(msg.user, convertedMsg.Message)
  427. case *discordgo.MessageReactionAdd:
  428. portal.handleDiscordReaction(msg.user, convertedMsg.MessageReaction, true, msg.thread)
  429. case *discordgo.MessageReactionRemove:
  430. portal.handleDiscordReaction(msg.user, convertedMsg.MessageReaction, false, msg.thread)
  431. default:
  432. portal.log.Warnln("unknown message type")
  433. }
  434. }
  435. func (portal *Portal) ensureUserInvited(user *User) bool {
  436. return user.ensureInvited(portal.MainIntent(), portal.MXID, portal.IsPrivateChat())
  437. }
  438. func (portal *Portal) markMessageHandled(discordID string, editIndex int, authorID string, timestamp time.Time, threadID string, parts []database.MessagePart) {
  439. msg := portal.bridge.DB.Message.New()
  440. msg.Channel = portal.Key
  441. msg.DiscordID = discordID
  442. msg.EditIndex = editIndex
  443. msg.SenderID = authorID
  444. msg.Timestamp = timestamp
  445. msg.ThreadID = threadID
  446. msg.MassInsert(parts)
  447. }
  448. func (portal *Portal) createMediaFailedMessage(bridgeErr error) *event.MessageEventContent {
  449. return &event.MessageEventContent{
  450. Body: fmt.Sprintf("Failed to bridge media: %v", bridgeErr),
  451. MsgType: event.MsgNotice,
  452. }
  453. }
  454. func (portal *Portal) sendMediaFailedMessage(intent *appservice.IntentAPI, bridgeErr error) id.EventID {
  455. resp, err := portal.sendMatrixMessage(intent, event.EventMessage, portal.createMediaFailedMessage(bridgeErr), nil, 0)
  456. if err != nil {
  457. portal.log.Warnfln("Failed to send media error message to matrix: %v", err)
  458. return ""
  459. }
  460. return resp.EventID
  461. }
  462. const DiscordStickerSize = 160
  463. func (portal *Portal) handleDiscordFile(typeName string, intent *appservice.IntentAPI, id, url string, content *event.MessageEventContent, ts time.Time, threadRelation *event.RelatesTo) *database.MessagePart {
  464. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, url, portal.Encrypted, id, content.Info.MimeType)
  465. if err != nil {
  466. errorEventID := portal.sendMediaFailedMessage(intent, err)
  467. if errorEventID != "" {
  468. return &database.MessagePart{
  469. AttachmentID: id,
  470. MXID: errorEventID,
  471. }
  472. }
  473. return nil
  474. }
  475. content.Info.Size = dbFile.Size
  476. if content.Info.Width == 0 && content.Info.Height == 0 {
  477. content.Info.Width = dbFile.Width
  478. content.Info.Height = dbFile.Height
  479. }
  480. if dbFile.DecryptionInfo != nil {
  481. content.File = &event.EncryptedFileInfo{
  482. EncryptedFile: *dbFile.DecryptionInfo,
  483. URL: dbFile.MXC.CUString(),
  484. }
  485. } else {
  486. content.URL = dbFile.MXC.CUString()
  487. }
  488. evtType := event.EventMessage
  489. if typeName == "sticker" && (content.Info.Width > DiscordStickerSize || content.Info.Height > DiscordStickerSize) {
  490. if content.Info.Width > content.Info.Height {
  491. content.Info.Height /= content.Info.Width / DiscordStickerSize
  492. content.Info.Width = DiscordStickerSize
  493. } else if content.Info.Width < content.Info.Height {
  494. content.Info.Width /= content.Info.Height / DiscordStickerSize
  495. content.Info.Height = DiscordStickerSize
  496. } else {
  497. content.Info.Width = DiscordStickerSize
  498. content.Info.Height = DiscordStickerSize
  499. }
  500. evtType = event.EventSticker
  501. } else if typeName == "sticker" {
  502. evtType = event.EventSticker
  503. }
  504. resp, err := portal.sendMatrixMessage(intent, evtType, content, nil, ts.UnixMilli())
  505. if err != nil {
  506. portal.log.Warnfln("Failed to send %s to Matrix: %v", typeName, err)
  507. return nil
  508. }
  509. // Update the fallback reply event for the next attachment
  510. if threadRelation != nil {
  511. threadRelation.InReplyTo.EventID = resp.EventID
  512. }
  513. return &database.MessagePart{
  514. AttachmentID: id,
  515. MXID: resp.EventID,
  516. }
  517. }
  518. func (portal *Portal) handleDiscordSticker(intent *appservice.IntentAPI, sticker *discordgo.Sticker, ts time.Time, threadRelation *event.RelatesTo) *database.MessagePart {
  519. var mime string
  520. switch sticker.FormatType {
  521. case discordgo.StickerFormatTypePNG:
  522. mime = "image/png"
  523. case discordgo.StickerFormatTypeAPNG:
  524. mime = "image/apng"
  525. case discordgo.StickerFormatTypeLottie:
  526. mime = "application/json"
  527. }
  528. content := &event.MessageEventContent{
  529. Body: sticker.Name, // TODO find description from somewhere?
  530. Info: &event.FileInfo{
  531. MimeType: mime,
  532. },
  533. RelatesTo: threadRelation,
  534. }
  535. return portal.handleDiscordFile("sticker", intent, sticker.ID, sticker.URL(), content, ts, threadRelation)
  536. }
  537. func (portal *Portal) handleDiscordAttachment(intent *appservice.IntentAPI, att *discordgo.MessageAttachment, ts time.Time, threadRelation *event.RelatesTo) *database.MessagePart {
  538. // var captionContent *event.MessageEventContent
  539. // if att.Description != "" {
  540. // captionContent = &event.MessageEventContent{
  541. // Body: att.Description,
  542. // MsgType: event.MsgNotice,
  543. // }
  544. // }
  545. // portal.Log.Debugfln("captionContent: %#v", captionContent)
  546. content := &event.MessageEventContent{
  547. Body: att.Filename,
  548. Info: &event.FileInfo{
  549. Height: att.Height,
  550. MimeType: att.ContentType,
  551. Width: att.Width,
  552. // This gets overwritten later after the file is uploaded to the homeserver
  553. Size: att.Size,
  554. },
  555. RelatesTo: threadRelation,
  556. }
  557. switch strings.ToLower(strings.Split(att.ContentType, "/")[0]) {
  558. case "audio":
  559. content.MsgType = event.MsgAudio
  560. case "image":
  561. content.MsgType = event.MsgImage
  562. case "video":
  563. content.MsgType = event.MsgVideo
  564. default:
  565. content.MsgType = event.MsgFile
  566. }
  567. return portal.handleDiscordFile("attachment", intent, att.ID, att.URL, content, ts, threadRelation)
  568. }
  569. type BeeperLinkPreview struct {
  570. mautrix.RespPreviewURL
  571. MatchedURL string `json:"matched_url"`
  572. ImageEncryption *event.EncryptedFileInfo `json:"beeper:image:encryption,omitempty"`
  573. }
  574. func (portal *Portal) convertDiscordLinkEmbedImage(intent *appservice.IntentAPI, url string, width, height int, preview *BeeperLinkPreview) {
  575. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, url, portal.Encrypted, "", "")
  576. if err != nil {
  577. portal.log.Warnfln("Failed to copy image in URL preview: %v", err)
  578. } else {
  579. if width != 0 || height != 0 {
  580. preview.ImageWidth = width
  581. preview.ImageHeight = height
  582. } else {
  583. preview.ImageWidth = dbFile.Width
  584. preview.ImageHeight = dbFile.Height
  585. }
  586. preview.ImageSize = dbFile.Size
  587. preview.ImageType = dbFile.MimeType
  588. if dbFile.Encrypted {
  589. preview.ImageEncryption = &event.EncryptedFileInfo{
  590. EncryptedFile: *dbFile.DecryptionInfo,
  591. URL: dbFile.MXC.CUString(),
  592. }
  593. } else {
  594. preview.ImageURL = dbFile.MXC.CUString()
  595. }
  596. }
  597. }
  598. func (portal *Portal) convertDiscordLinkEmbedsToBeeper(intent *appservice.IntentAPI, embeds []*discordgo.MessageEmbed) (previews []BeeperLinkPreview) {
  599. previews = []BeeperLinkPreview{}
  600. for _, embed := range embeds {
  601. if embed.Type != discordgo.EmbedTypeLink && embed.Type != discordgo.EmbedTypeArticle {
  602. continue
  603. }
  604. var preview BeeperLinkPreview
  605. preview.MatchedURL = embed.URL
  606. preview.Title = embed.Title
  607. preview.Description = embed.Description
  608. if embed.Image != nil {
  609. portal.convertDiscordLinkEmbedImage(intent, embed.Image.URL, embed.Image.Width, embed.Image.Height, &preview)
  610. } else if embed.Thumbnail != nil {
  611. portal.convertDiscordLinkEmbedImage(intent, embed.Thumbnail.URL, embed.Thumbnail.Width, embed.Thumbnail.Height, &preview)
  612. }
  613. previews = append(previews, preview)
  614. }
  615. return
  616. }
  617. type ConvertedMessage struct {
  618. Content *event.MessageEventContent
  619. Extra map[string]any
  620. }
  621. func (portal *Portal) convertDiscordVideoEmbed(intent *appservice.IntentAPI, embed *discordgo.MessageEmbed) ConvertedMessage {
  622. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, embed.Video.URL, portal.Encrypted, "", "")
  623. if err != nil {
  624. return ConvertedMessage{Content: portal.createMediaFailedMessage(err)}
  625. }
  626. content := &event.MessageEventContent{
  627. MsgType: event.MsgVideo,
  628. Body: embed.URL,
  629. Info: &event.FileInfo{
  630. Width: embed.Video.Width,
  631. Height: embed.Video.Height,
  632. MimeType: dbFile.MimeType,
  633. Size: dbFile.Size,
  634. },
  635. }
  636. if content.Info.Width == 0 && content.Info.Height == 0 {
  637. content.Info.Width = dbFile.Width
  638. content.Info.Height = dbFile.Height
  639. }
  640. if dbFile.DecryptionInfo != nil {
  641. content.File = &event.EncryptedFileInfo{
  642. EncryptedFile: *dbFile.DecryptionInfo,
  643. URL: dbFile.MXC.CUString(),
  644. }
  645. } else {
  646. content.URL = dbFile.MXC.CUString()
  647. }
  648. extra := map[string]any{}
  649. if embed.Type == discordgo.EmbedTypeGifv {
  650. extra["info"] = map[string]any{
  651. "fi.mau.discord.gifv": true,
  652. "fi.mau.loop": true,
  653. "fi.mau.autoplay": true,
  654. "fi.mau.hide_controls": true,
  655. "fi.mau.no_audio": true,
  656. }
  657. }
  658. return ConvertedMessage{Content: content, Extra: extra}
  659. }
  660. func (portal *Portal) handleDiscordVideoEmbed(intent *appservice.IntentAPI, embed *discordgo.MessageEmbed, msgID string, index int, ts time.Time, threadRelation *event.RelatesTo) *database.MessagePart {
  661. content := portal.convertDiscordVideoEmbed(intent, embed)
  662. content.Content.RelatesTo = threadRelation
  663. resp, err := portal.sendMatrixMessage(intent, event.EventMessage, content.Content, content.Extra, ts.UnixMilli())
  664. if err != nil {
  665. portal.log.Warnfln("Failed to send embed #%d of message %s to Matrix: %v", index+1, msgID, err)
  666. return nil
  667. }
  668. // Update the fallback reply event for the next attachment
  669. if threadRelation != nil {
  670. threadRelation.InReplyTo.EventID = resp.EventID
  671. }
  672. return &database.MessagePart{
  673. AttachmentID: fmt.Sprintf("%s-e%d", msgID, index+1),
  674. MXID: resp.EventID,
  675. }
  676. }
  677. const (
  678. embedHTMLWrapper = `<blockquote class="discord-embed">%s</blockquote>`
  679. embedHTMLWrapperColor = `<blockquote class="discord-embed" background-color="#%06X">%s</blockquote>`
  680. embedHTMLAuthorWithImage = `<p class="discord-embed-author"><img data-mx-emoticon width="24" height="24" src="%s" title="Author icon" alt="Author icon">&nbsp;<span>%s</span></p>`
  681. embedHTMLAuthorPlain = `<p class="discord-embed-author"><span>%s</span></p>`
  682. embedHTMLAuthorLink = `<a href="%s">%s</a>`
  683. embedHTMLTitleWithLink = `<p class="discord-embed-title"><a href="%s"><strong>%s</strong></a></p>`
  684. embedHTMLTitlePlain = `<p class="discord-embed-title"><strong>%s</strong></p>`
  685. embedHTMLDescription = `<p class="discord-embed-description">%s</p>`
  686. embedHTMLFieldName = `<th>%s</th>`
  687. embedHTMLFieldValue = `<td>%s</td>`
  688. embedHTMLFields = `<table class="discord-embed-fields"><tr>%s</tr><tr>%s</tr></table>`
  689. embedHTMLLinearField = `<p class="discord-embed-field" x-inline="%s"><strong>%s</strong><br><span>%s</span></p>`
  690. embedHTMLImage = `<p class="discord-embed-image"><img src="%s" alt="Embed image" title="Embed image"></p>`
  691. embedHTMLFooterWithImage = `<p class="discord-embed-footer"><sub><img data-mx-emoticon width="20" height="20" src="%s" title="Footer icon" alt="Footer icon">&nbsp;<span>%s</span>%s</sub></p>`
  692. embedHTMLFooterPlain = `<p class="discord-embed-footer"><sub><span>%s</span>%s</sub></p>`
  693. embedHTMLFooterOnlyDate = `<p class="discord-embed-footer"><sub>%s</sub></p>`
  694. embedHTMLDate = `<time datetime="%s">%s</time>`
  695. embedFooterDateSeparator = ` • `
  696. )
  697. func (portal *Portal) handleDiscordRichEmbed(intent *appservice.IntentAPI, embed *discordgo.MessageEmbed, msgID string, index int, ts time.Time, threadRelation *event.RelatesTo) *database.MessagePart {
  698. var htmlParts []string
  699. if embed.Author != nil {
  700. var authorHTML string
  701. authorNameHTML := html.EscapeString(embed.Author.Name)
  702. if embed.Author.URL != "" {
  703. authorNameHTML = fmt.Sprintf(embedHTMLAuthorLink, embed.Author.URL, authorNameHTML)
  704. }
  705. authorHTML = fmt.Sprintf(embedHTMLAuthorPlain, authorNameHTML)
  706. if embed.Author.ProxyIconURL != "" {
  707. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, embed.Author.ProxyIconURL, false, "", "")
  708. if err != nil {
  709. portal.log.Warnfln("Failed to reupload author icon in embed #%d of message %s: %v", index+1, msgID, err)
  710. } else {
  711. authorHTML = fmt.Sprintf(embedHTMLAuthorWithImage, dbFile.MXC, authorNameHTML)
  712. }
  713. }
  714. htmlParts = append(htmlParts, authorHTML)
  715. }
  716. if embed.Title != "" {
  717. var titleHTML string
  718. baseTitleHTML := portal.renderDiscordMarkdownOnlyHTML(embed.Title)
  719. if embed.URL != "" {
  720. titleHTML = fmt.Sprintf(embedHTMLTitleWithLink, html.EscapeString(embed.URL), baseTitleHTML)
  721. } else {
  722. titleHTML = fmt.Sprintf(embedHTMLTitlePlain, baseTitleHTML)
  723. }
  724. htmlParts = append(htmlParts, titleHTML)
  725. }
  726. if embed.Description != "" {
  727. htmlParts = append(htmlParts, fmt.Sprintf(embedHTMLDescription, portal.renderDiscordMarkdownOnlyHTML(embed.Description)))
  728. }
  729. for i := 0; i < len(embed.Fields); i++ {
  730. item := embed.Fields[i]
  731. if portal.bridge.Config.Bridge.EmbedFieldsAsTables {
  732. splitItems := []*discordgo.MessageEmbedField{item}
  733. if item.Inline && len(embed.Fields) > i+1 && embed.Fields[i+1].Inline {
  734. splitItems = append(splitItems, embed.Fields[i+1])
  735. i++
  736. if len(embed.Fields) > i+1 && embed.Fields[i+1].Inline {
  737. splitItems = append(splitItems, embed.Fields[i+1])
  738. i++
  739. }
  740. }
  741. headerParts := make([]string, len(splitItems))
  742. contentParts := make([]string, len(splitItems))
  743. for j, splitItem := range splitItems {
  744. headerParts[j] = fmt.Sprintf(embedHTMLFieldName, portal.renderDiscordMarkdownOnlyHTML(splitItem.Name))
  745. contentParts[j] = fmt.Sprintf(embedHTMLFieldValue, portal.renderDiscordMarkdownOnlyHTML(splitItem.Value))
  746. }
  747. htmlParts = append(htmlParts, fmt.Sprintf(embedHTMLFields, strings.Join(headerParts, ""), strings.Join(contentParts, "")))
  748. } else {
  749. htmlParts = append(htmlParts, fmt.Sprintf(embedHTMLLinearField,
  750. strconv.FormatBool(item.Inline),
  751. portal.renderDiscordMarkdownOnlyHTML(item.Name),
  752. portal.renderDiscordMarkdownOnlyHTML(item.Value),
  753. ))
  754. }
  755. }
  756. if embed.Image != nil {
  757. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, embed.Image.ProxyURL, false, "", "")
  758. if err != nil {
  759. portal.log.Warnfln("Failed to reupload image in embed #%d of message %s: %v", index+1, msgID, err)
  760. } else {
  761. htmlParts = append(htmlParts, fmt.Sprintf(embedHTMLImage, dbFile.MXC))
  762. }
  763. }
  764. var embedDateHTML string
  765. if embed.Timestamp != "" {
  766. formattedTime := embed.Timestamp
  767. parsedTS, err := time.Parse(time.RFC3339, embed.Timestamp)
  768. if err != nil {
  769. portal.log.Warnfln("Failed to parse timestamp in embed #%d of message %s: %v", index+1, msgID, err)
  770. } else {
  771. formattedTime = parsedTS.Format(discordTimestampStyle('F').Format())
  772. }
  773. embedDateHTML = fmt.Sprintf(embedHTMLDate, embed.Timestamp, formattedTime)
  774. }
  775. if embed.Footer != nil {
  776. var footerHTML string
  777. var datePart string
  778. if embedDateHTML != "" {
  779. datePart = embedFooterDateSeparator + embedDateHTML
  780. }
  781. footerHTML = fmt.Sprintf(embedHTMLFooterPlain, html.EscapeString(embed.Footer.Text), datePart)
  782. if embed.Footer.ProxyIconURL != "" {
  783. dbFile, err := portal.bridge.copyAttachmentToMatrix(intent, embed.Footer.ProxyIconURL, false, "", "")
  784. if err != nil {
  785. portal.log.Warnfln("Failed to reupload footer icon in embed #%d of message %s: %v", index+1, msgID, err)
  786. } else {
  787. footerHTML = fmt.Sprintf(embedHTMLFooterWithImage, dbFile.MXC, html.EscapeString(embed.Footer.Text), datePart)
  788. }
  789. }
  790. htmlParts = append(htmlParts, footerHTML)
  791. } else if embed.Timestamp != "" {
  792. htmlParts = append(htmlParts, fmt.Sprintf(embedHTMLFooterOnlyDate, embedDateHTML))
  793. }
  794. if len(htmlParts) == 0 {
  795. return nil
  796. }
  797. compiledHTML := strings.Join(htmlParts, "")
  798. if embed.Color != 0 {
  799. compiledHTML = fmt.Sprintf(embedHTMLWrapperColor, embed.Color, compiledHTML)
  800. } else {
  801. compiledHTML = fmt.Sprintf(embedHTMLWrapper, compiledHTML)
  802. }
  803. content := format.HTMLToContent(compiledHTML)
  804. content.RelatesTo = threadRelation.Copy()
  805. resp, err := portal.sendMatrixMessage(intent, event.EventMessage, &content, nil, ts.UnixMilli())
  806. if err != nil {
  807. portal.log.Warnfln("Failed to send embed #%d of message %s to Matrix: %v", index+1, msgID, err)
  808. return nil
  809. }
  810. // Update the fallback reply event for the next attachment
  811. if threadRelation != nil {
  812. threadRelation.InReplyTo.EventID = resp.EventID
  813. }
  814. return &database.MessagePart{
  815. AttachmentID: fmt.Sprintf("%s-e%d", msgID, index+1),
  816. MXID: resp.EventID,
  817. }
  818. }
  819. func isPlainGifMessage(msg *discordgo.Message) bool {
  820. return len(msg.Embeds) == 1 && msg.Embeds[0].Video != nil && msg.Embeds[0].URL == msg.Content
  821. }
  822. func (portal *Portal) handleDiscordMessageCreate(user *User, msg *discordgo.Message, thread *Thread) {
  823. if portal.MXID == "" {
  824. portal.log.Warnln("handle message called without a valid portal")
  825. return
  826. }
  827. switch msg.Type {
  828. case discordgo.MessageTypeChannelNameChange, discordgo.MessageTypeChannelIconChange, discordgo.MessageTypeChannelPinnedMessage:
  829. // These are handled via channel updates
  830. return
  831. }
  832. portal.recentMessages.Push(msg.ID, msg)
  833. // Handle normal message
  834. existing := portal.bridge.DB.Message.GetByDiscordID(portal.Key, msg.ID)
  835. if existing != nil {
  836. portal.log.Debugln("Dropping duplicate message", msg.ID)
  837. return
  838. }
  839. portal.log.Debugfln("Starting handling of %s by %s", msg.ID, msg.Author.ID)
  840. puppet := portal.bridge.GetPuppetByID(msg.Author.ID)
  841. puppet.UpdateInfo(user, msg.Author)
  842. intent := puppet.IntentFor(portal)
  843. var threadRelation *event.RelatesTo
  844. var threadID string
  845. if thread != nil {
  846. threadID = thread.ID
  847. lastEventID := thread.RootMXID
  848. lastInThread := portal.bridge.DB.Message.GetLastInThread(portal.Key, thread.ID)
  849. if lastInThread != nil {
  850. lastEventID = lastInThread.MXID
  851. }
  852. threadRelation = (&event.RelatesTo{}).SetThread(thread.RootMXID, lastEventID)
  853. }
  854. var parts []database.MessagePart
  855. ts, _ := discordgo.SnowflakeTimestamp(msg.ID)
  856. if msg.Content != "" && !isPlainGifMessage(msg) {
  857. content := portal.renderDiscordMarkdown(msg.Content)
  858. content.RelatesTo = threadRelation.Copy()
  859. extraContent := map[string]any{
  860. "com.beeper.linkpreviews": portal.convertDiscordLinkEmbedsToBeeper(intent, msg.Embeds),
  861. }
  862. if msg.MessageReference != nil {
  863. //key := database.PortalKey{msg.MessageReference.ChannelID, user.ID}
  864. replyTo := portal.bridge.DB.Message.GetByDiscordID(portal.Key, msg.MessageReference.MessageID)
  865. if len(replyTo) > 0 {
  866. if content.RelatesTo == nil {
  867. content.RelatesTo = &event.RelatesTo{}
  868. }
  869. content.RelatesTo.SetReplyTo(replyTo[0].MXID)
  870. }
  871. }
  872. resp, err := portal.sendMatrixMessage(intent, event.EventMessage, &content, extraContent, ts.UnixMilli())
  873. if err != nil {
  874. portal.log.Warnfln("Failed to send message %s to matrix: %v", msg.ID, err)
  875. return
  876. }
  877. parts = append(parts, database.MessagePart{MXID: resp.EventID})
  878. // Update the fallback reply event for attachments
  879. if threadRelation != nil {
  880. threadRelation.InReplyTo.EventID = resp.EventID
  881. }
  882. go portal.sendDeliveryReceipt(resp.EventID)
  883. }
  884. for _, att := range msg.Attachments {
  885. part := portal.handleDiscordAttachment(intent, att, ts, threadRelation)
  886. if part != nil {
  887. parts = append(parts, *part)
  888. }
  889. }
  890. for _, sticker := range msg.StickerItems {
  891. part := portal.handleDiscordSticker(intent, sticker, ts, threadRelation)
  892. if part != nil {
  893. parts = append(parts, *part)
  894. }
  895. }
  896. for i, embed := range msg.Embeds {
  897. var part *database.MessagePart
  898. switch {
  899. case embed.Video != nil: // gif/video embeds (hopefully no rich content)
  900. part = portal.handleDiscordVideoEmbed(intent, embed, msg.ID, i, ts, threadRelation)
  901. case embed.Type == discordgo.EmbedTypeLink, embed.Type == discordgo.EmbedTypeArticle:
  902. // skip link previews, these are handled earlier
  903. default: // rich embeds
  904. part = portal.handleDiscordRichEmbed(intent, embed, msg.ID, i, ts, threadRelation)
  905. }
  906. if part != nil {
  907. parts = append(parts, *part)
  908. }
  909. }
  910. if len(parts) == 0 {
  911. portal.log.Warnfln("Unhandled message %s (type %d)", msg.ID, msg.Type)
  912. } else {
  913. portal.markMessageHandled(msg.ID, 0, msg.Author.ID, ts, threadID, parts)
  914. }
  915. }
  916. const JoinThreadReaction = "join thread"
  917. func (portal *Portal) sendThreadCreationNotice(thread *Thread) {
  918. thread.creationNoticeLock.Lock()
  919. defer thread.creationNoticeLock.Unlock()
  920. if thread.CreationNoticeMXID != "" {
  921. return
  922. }
  923. creationNotice := "Thread created. React to this message with \"join thread\" to join the thread on Discord."
  924. if portal.bridge.Config.Bridge.AutojoinThreadOnOpen {
  925. creationNotice = "Thread created. Opening this thread will auto-join you to it on Discord."
  926. }
  927. resp, err := portal.sendMatrixMessage(portal.MainIntent(), event.EventMessage, &event.MessageEventContent{
  928. Body: creationNotice,
  929. MsgType: event.MsgNotice,
  930. RelatesTo: (&event.RelatesTo{}).SetThread(thread.RootMXID, thread.RootMXID),
  931. }, nil, time.Now().UnixMilli())
  932. if err != nil {
  933. portal.log.Errorfln("Failed to send thread creation notice: %v", err)
  934. return
  935. }
  936. portal.bridge.threadsLock.Lock()
  937. thread.CreationNoticeMXID = resp.EventID
  938. portal.bridge.threadsByCreationNoticeMXID[resp.EventID] = thread
  939. portal.bridge.threadsLock.Unlock()
  940. thread.Update()
  941. portal.log.Debugfln("Sent notice %s about thread for %s being created", thread.CreationNoticeMXID, thread.ID)
  942. resp, err = portal.MainIntent().SendMessageEvent(portal.MXID, event.EventReaction, &event.ReactionEventContent{
  943. RelatesTo: event.RelatesTo{
  944. Type: event.RelAnnotation,
  945. EventID: thread.CreationNoticeMXID,
  946. Key: JoinThreadReaction,
  947. },
  948. })
  949. if err != nil {
  950. portal.log.Errorfln("Failed to send prefilled reaction to thread creation notice: %v", err)
  951. } else {
  952. portal.log.Debugfln("Sent prefilled reaction %s to thread creation notice %s", resp.EventID, thread.CreationNoticeMXID)
  953. }
  954. }
  955. func (portal *Portal) handleDiscordMessageUpdate(user *User, msg *discordgo.Message) {
  956. if portal.MXID == "" {
  957. portal.log.Warnln("handle message called without a valid portal")
  958. return
  959. }
  960. existing := portal.bridge.DB.Message.GetByDiscordID(portal.Key, msg.ID)
  961. if existing == nil {
  962. portal.log.Warnfln("Dropping update of unknown message %s", msg.ID)
  963. return
  964. }
  965. if msg.Flags == discordgo.MessageFlagsHasThread {
  966. thread := portal.bridge.GetThreadByID(msg.ID, existing[0])
  967. portal.log.Debugfln("Marked %s as a thread root", msg.ID)
  968. if thread.CreationNoticeMXID == "" {
  969. portal.sendThreadCreationNotice(thread)
  970. }
  971. }
  972. if msg.Author == nil {
  973. creationMessage, ok := portal.recentMessages.Get(msg.ID)
  974. if !ok {
  975. portal.log.Debugfln("Dropping edit with no author of non-recent message %s", msg.ID)
  976. return
  977. }
  978. portal.log.Debugfln("Found original message %s in cache for edit without author", msg.ID)
  979. if len(msg.Embeds) > 0 {
  980. creationMessage.Embeds = msg.Embeds
  981. }
  982. if len(msg.Attachments) > 0 {
  983. creationMessage.Attachments = msg.Attachments
  984. }
  985. if len(msg.Components) > 0 {
  986. creationMessage.Components = msg.Components
  987. }
  988. // TODO are there other fields that need copying?
  989. msg = creationMessage
  990. } else {
  991. portal.recentMessages.Replace(msg.ID, msg)
  992. }
  993. intent := portal.bridge.GetPuppetByID(msg.Author.ID).IntentFor(portal)
  994. attachmentMap := map[string]*database.Message{}
  995. for _, existingPart := range existing {
  996. if existingPart.AttachmentID != "" {
  997. attachmentMap[existingPart.AttachmentID] = existingPart
  998. }
  999. }
  1000. for _, remainingAttachment := range msg.Attachments {
  1001. if _, found := attachmentMap[remainingAttachment.ID]; found {
  1002. delete(attachmentMap, remainingAttachment.ID)
  1003. }
  1004. }
  1005. for _, remainingSticker := range msg.StickerItems {
  1006. if _, found := attachmentMap[remainingSticker.ID]; found {
  1007. delete(attachmentMap, remainingSticker.ID)
  1008. }
  1009. }
  1010. for _, deletedAttachment := range attachmentMap {
  1011. _, err := intent.RedactEvent(portal.MXID, deletedAttachment.MXID)
  1012. if err != nil {
  1013. portal.log.Warnfln("Failed to remove attachment %s: %v", deletedAttachment.MXID, err)
  1014. }
  1015. deletedAttachment.Delete()
  1016. }
  1017. if msg.Content == "" || existing[0].AttachmentID != "" {
  1018. portal.log.Debugfln("Dropping non-text edit to %s (message on matrix: %t, text on discord: %t)", msg.ID, existing[0].AttachmentID == "", len(msg.Content) > 0)
  1019. return
  1020. }
  1021. var content event.MessageEventContent
  1022. var extraContent map[string]any
  1023. if isPlainGifMessage(msg) {
  1024. converted := portal.convertDiscordVideoEmbed(intent, msg.Embeds[0])
  1025. content = *converted.Content
  1026. extraContent = converted.Extra
  1027. } else {
  1028. content = portal.renderDiscordMarkdown(msg.Content)
  1029. extraContent = map[string]any{
  1030. "com.beeper.linkpreviews": portal.convertDiscordLinkEmbedsToBeeper(intent, msg.Embeds),
  1031. }
  1032. }
  1033. content.SetEdit(existing[0].MXID)
  1034. var editTS int64
  1035. if msg.EditedTimestamp != nil {
  1036. editTS = msg.EditedTimestamp.UnixMilli()
  1037. }
  1038. // TODO figure out some way to deduplicate outgoing edits
  1039. resp, err := portal.sendMatrixMessage(intent, event.EventMessage, &content, extraContent, editTS)
  1040. if err != nil {
  1041. portal.log.Warnfln("Failed to send message %s to matrix: %v", msg.ID, err)
  1042. return
  1043. }
  1044. portal.sendDeliveryReceipt(resp.EventID)
  1045. //ts, _ := msg.Timestamp.Parse()
  1046. //portal.markMessageHandled(existing, msg.ID, resp.EventID, msg.Author.ID, ts)
  1047. }
  1048. func (portal *Portal) handleDiscordMessageDelete(user *User, msg *discordgo.Message) {
  1049. existing := portal.bridge.DB.Message.GetByDiscordID(portal.Key, msg.ID)
  1050. intent := portal.MainIntent()
  1051. var lastResp id.EventID
  1052. for _, dbMsg := range existing {
  1053. resp, err := intent.RedactEvent(portal.MXID, dbMsg.MXID)
  1054. if err != nil {
  1055. portal.log.Warnfln("Failed to redact message %s: %v", dbMsg.MXID, err)
  1056. } else if resp != nil && resp.EventID != "" {
  1057. lastResp = resp.EventID
  1058. }
  1059. dbMsg.Delete()
  1060. }
  1061. if lastResp != "" {
  1062. portal.sendDeliveryReceipt(lastResp)
  1063. }
  1064. }
  1065. func (portal *Portal) syncParticipants(source *User, participants []*discordgo.User) {
  1066. for _, participant := range participants {
  1067. puppet := portal.bridge.GetPuppetByID(participant.ID)
  1068. puppet.UpdateInfo(source, participant)
  1069. user := portal.bridge.GetUserByID(participant.ID)
  1070. if user != nil {
  1071. portal.ensureUserInvited(user)
  1072. }
  1073. if user == nil || !puppet.IntentFor(portal).IsCustomPuppet {
  1074. if err := puppet.IntentFor(portal).EnsureJoined(portal.MXID); err != nil {
  1075. portal.log.Warnfln("Failed to make puppet of %s join %s: %v", participant.ID, portal.MXID, err)
  1076. }
  1077. }
  1078. }
  1079. }
  1080. func (portal *Portal) encrypt(intent *appservice.IntentAPI, content *event.Content, eventType event.Type) (event.Type, error) {
  1081. if !portal.Encrypted || portal.bridge.Crypto == nil {
  1082. return eventType, nil
  1083. }
  1084. intent.AddDoublePuppetValue(content)
  1085. // TODO maybe the locking should be inside mautrix-go?
  1086. portal.encryptLock.Lock()
  1087. err := portal.bridge.Crypto.Encrypt(portal.MXID, eventType, content)
  1088. portal.encryptLock.Unlock()
  1089. if err != nil {
  1090. return eventType, fmt.Errorf("failed to encrypt event: %w", err)
  1091. }
  1092. return event.EventEncrypted, nil
  1093. }
  1094. func (portal *Portal) sendMatrixMessage(intent *appservice.IntentAPI, eventType event.Type, content *event.MessageEventContent, extraContent map[string]interface{}, timestamp int64) (*mautrix.RespSendEvent, error) {
  1095. wrappedContent := event.Content{Parsed: content, Raw: extraContent}
  1096. var err error
  1097. eventType, err = portal.encrypt(intent, &wrappedContent, eventType)
  1098. if err != nil {
  1099. return nil, err
  1100. }
  1101. _, _ = intent.UserTyping(portal.MXID, false, 0)
  1102. if timestamp == 0 {
  1103. return intent.SendMessageEvent(portal.MXID, eventType, &wrappedContent)
  1104. } else {
  1105. return intent.SendMassagedMessageEvent(portal.MXID, eventType, &wrappedContent, timestamp)
  1106. }
  1107. }
  1108. func (portal *Portal) handleMatrixMessages(msg portalMatrixMessage) {
  1109. switch msg.evt.Type {
  1110. case event.EventMessage:
  1111. portal.handleMatrixMessage(msg.user, msg.evt)
  1112. case event.EventRedaction:
  1113. portal.handleMatrixRedaction(msg.user, msg.evt)
  1114. case event.EventReaction:
  1115. portal.handleMatrixReaction(msg.user, msg.evt)
  1116. default:
  1117. portal.log.Debugln("unknown event type", msg.evt.Type)
  1118. }
  1119. }
  1120. const discordEpoch = 1420070400000
  1121. func generateNonce() string {
  1122. snowflake := (time.Now().UnixMilli() - discordEpoch) << 22
  1123. // Nonce snowflakes don't have internal IDs or increments
  1124. return strconv.FormatInt(snowflake, 10)
  1125. }
  1126. func (portal *Portal) getEvent(mxid id.EventID) (*event.Event, error) {
  1127. evt, err := portal.MainIntent().GetEvent(portal.MXID, mxid)
  1128. if err != nil {
  1129. return nil, err
  1130. }
  1131. _ = evt.Content.ParseRaw(evt.Type)
  1132. if evt.Type == event.EventEncrypted {
  1133. decryptedEvt, err := portal.bridge.Crypto.Decrypt(evt)
  1134. if err != nil {
  1135. return nil, err
  1136. } else {
  1137. evt = decryptedEvt
  1138. }
  1139. }
  1140. return evt, nil
  1141. }
  1142. func genThreadName(evt *event.Event) string {
  1143. body := evt.Content.AsMessage().Body
  1144. if len(body) == 0 {
  1145. return "thread"
  1146. }
  1147. fields := strings.Fields(body)
  1148. var title string
  1149. for _, field := range fields {
  1150. if len(title)+len(field) < 40 {
  1151. title += field
  1152. title += " "
  1153. continue
  1154. }
  1155. if len(title) == 0 {
  1156. title = field[:40]
  1157. }
  1158. break
  1159. }
  1160. return title
  1161. }
  1162. func (portal *Portal) startThreadFromMatrix(sender *User, threadRoot id.EventID) (string, error) {
  1163. rootEvt, err := portal.getEvent(threadRoot)
  1164. if err != nil {
  1165. return "", fmt.Errorf("failed to get root event: %w", err)
  1166. }
  1167. threadName := genThreadName(rootEvt)
  1168. existingMsg := portal.bridge.DB.Message.GetByMXID(portal.Key, threadRoot)
  1169. if existingMsg == nil {
  1170. return "", fmt.Errorf("unknown root event")
  1171. } else if existingMsg.ThreadID != "" {
  1172. return "", fmt.Errorf("root event is already in a thread")
  1173. } else {
  1174. var ch *discordgo.Channel
  1175. ch, err = sender.Session.MessageThreadStartComplex(portal.Key.ChannelID, existingMsg.DiscordID, &discordgo.ThreadStart{
  1176. Name: threadName,
  1177. AutoArchiveDuration: 24 * 60,
  1178. Type: discordgo.ChannelTypeGuildPublicThread,
  1179. Location: "Message",
  1180. })
  1181. if err != nil {
  1182. return "", fmt.Errorf("error starting thread: %v", err)
  1183. }
  1184. portal.log.Debugfln("Created Discord thread from %s/%s", threadRoot, ch.ID)
  1185. portal.bridge.GetThreadByID(existingMsg.DiscordID, existingMsg)
  1186. return ch.ID, nil
  1187. }
  1188. }
  1189. func (portal *Portal) sendErrorMessage(msgType, message string, confirmed bool) id.EventID {
  1190. if !portal.bridge.Config.Bridge.MessageErrorNotices {
  1191. return ""
  1192. }
  1193. certainty := "may not have been"
  1194. if confirmed {
  1195. certainty = "was not"
  1196. }
  1197. resp, err := portal.sendMatrixMessage(portal.MainIntent(), event.EventMessage, &event.MessageEventContent{
  1198. MsgType: event.MsgNotice,
  1199. Body: fmt.Sprintf("\u26a0 Your %s %s bridged: %v", msgType, certainty, message),
  1200. }, nil, 0)
  1201. if err != nil {
  1202. portal.log.Warnfln("Failed to send bridging error message:", err)
  1203. return ""
  1204. }
  1205. return resp.EventID
  1206. }
  1207. var (
  1208. errUnknownMsgType = errors.New("unknown msgtype")
  1209. errUnexpectedParsedContentType = errors.New("unexpected parsed content type")
  1210. errUserNotReceiver = errors.New("user is not portal receiver")
  1211. errUnknownEditTarget = errors.New("unknown edit target")
  1212. errUnknownRelationType = errors.New("unknown relation type")
  1213. errTargetNotFound = errors.New("target event not found")
  1214. errUnknownEmoji = errors.New("unknown emoji")
  1215. )
  1216. func errorToStatusReason(err error) (reason event.MessageStatusReason, status event.MessageStatus, isCertain, sendNotice bool, humanMessage string) {
  1217. switch {
  1218. case errors.Is(err, errUnknownMsgType),
  1219. errors.Is(err, errUnknownRelationType),
  1220. errors.Is(err, errUnexpectedParsedContentType),
  1221. errors.Is(err, errUnknownEmoji),
  1222. errors.Is(err, id.InvalidContentURI),
  1223. errors.Is(err, attachment.UnsupportedVersion),
  1224. errors.Is(err, attachment.UnsupportedAlgorithm):
  1225. return event.MessageStatusUnsupported, event.MessageStatusFail, true, true, ""
  1226. case errors.Is(err, attachment.HashMismatch),
  1227. errors.Is(err, attachment.InvalidKey),
  1228. errors.Is(err, attachment.InvalidInitVector):
  1229. return event.MessageStatusUndecryptable, event.MessageStatusFail, true, true, ""
  1230. case errors.Is(err, errUserNotReceiver):
  1231. return event.MessageStatusNoPermission, event.MessageStatusFail, true, false, ""
  1232. case errors.Is(err, errUnknownEditTarget):
  1233. return event.MessageStatusGenericError, event.MessageStatusFail, true, false, ""
  1234. case errors.Is(err, errTargetNotFound):
  1235. return event.MessageStatusGenericError, event.MessageStatusFail, true, false, ""
  1236. default:
  1237. return event.MessageStatusGenericError, event.MessageStatusRetriable, false, true, ""
  1238. }
  1239. }
  1240. func (portal *Portal) sendStatusEvent(evtID id.EventID, err error) {
  1241. if !portal.bridge.Config.Bridge.MessageStatusEvents {
  1242. return
  1243. }
  1244. intent := portal.bridge.Bot
  1245. if !portal.Encrypted {
  1246. // Bridge bot isn't present in unencrypted DMs
  1247. intent = portal.MainIntent()
  1248. }
  1249. stateKey, _ := portal.getBridgeInfo()
  1250. content := event.BeeperMessageStatusEventContent{
  1251. Network: stateKey,
  1252. RelatesTo: event.RelatesTo{
  1253. Type: event.RelReference,
  1254. EventID: evtID,
  1255. },
  1256. Status: event.MessageStatusSuccess,
  1257. }
  1258. if err == nil {
  1259. content.Status = event.MessageStatusSuccess
  1260. } else {
  1261. content.Reason, content.Status, _, _, content.Message = errorToStatusReason(err)
  1262. content.Error = err.Error()
  1263. }
  1264. _, err = intent.SendMessageEvent(portal.MXID, event.BeeperMessageStatus, &content)
  1265. if err != nil {
  1266. portal.log.Warnln("Failed to send message status event:", err)
  1267. }
  1268. }
  1269. func (portal *Portal) sendMessageMetrics(evt *event.Event, err error, part string) {
  1270. var msgType string
  1271. switch evt.Type {
  1272. case event.EventMessage:
  1273. msgType = "message"
  1274. case event.EventReaction:
  1275. msgType = "reaction"
  1276. case event.EventRedaction:
  1277. msgType = "redaction"
  1278. default:
  1279. msgType = "unknown event"
  1280. }
  1281. evtDescription := evt.ID.String()
  1282. if evt.Type == event.EventRedaction {
  1283. evtDescription += fmt.Sprintf(" of %s", evt.Redacts)
  1284. }
  1285. if err != nil {
  1286. level := log.LevelError
  1287. if part == "Ignoring" {
  1288. level = log.LevelDebug
  1289. }
  1290. portal.log.Logfln(level, "%s %s %s from %s: %v", part, msgType, evtDescription, evt.Sender, err)
  1291. reason, statusCode, isCertain, sendNotice, _ := errorToStatusReason(err)
  1292. checkpointStatus := status.ReasonToCheckpointStatus(reason, statusCode)
  1293. portal.bridge.SendMessageCheckpoint(evt, status.MsgStepRemote, err, checkpointStatus, 0)
  1294. if sendNotice {
  1295. portal.sendErrorMessage(msgType, err.Error(), isCertain)
  1296. }
  1297. portal.sendStatusEvent(evt.ID, err)
  1298. } else {
  1299. portal.log.Debugfln("Handled Matrix %s %s", msgType, evtDescription)
  1300. portal.sendDeliveryReceipt(evt.ID)
  1301. portal.bridge.SendMessageSuccessCheckpoint(evt, status.MsgStepRemote, 0)
  1302. portal.sendStatusEvent(evt.ID, nil)
  1303. }
  1304. }
  1305. func (portal *Portal) handleMatrixMessage(sender *User, evt *event.Event) {
  1306. if portal.IsPrivateChat() && sender.DiscordID != portal.Key.Receiver {
  1307. go portal.sendMessageMetrics(evt, errUserNotReceiver, "Ignoring")
  1308. return
  1309. }
  1310. content, ok := evt.Content.Parsed.(*event.MessageEventContent)
  1311. if !ok {
  1312. go portal.sendMessageMetrics(evt, fmt.Errorf("%w %T", errUnexpectedParsedContentType, evt.Content.Parsed), "Ignoring")
  1313. return
  1314. }
  1315. channelID := portal.Key.ChannelID
  1316. var threadID string
  1317. if editMXID := content.GetRelatesTo().GetReplaceID(); editMXID != "" && content.NewContent != nil {
  1318. edits := portal.bridge.DB.Message.GetByMXID(portal.Key, editMXID)
  1319. if edits != nil {
  1320. discordContent := portal.parseMatrixHTML(sender, content.NewContent)
  1321. // TODO save edit in message table
  1322. _, err := sender.Session.ChannelMessageEdit(edits.DiscordProtoChannelID(), edits.DiscordID, discordContent)
  1323. go portal.sendMessageMetrics(evt, err, "Failed to edit")
  1324. } else {
  1325. go portal.sendMessageMetrics(evt, fmt.Errorf("%w %s", errUnknownEditTarget, editMXID), "Ignoring")
  1326. }
  1327. return
  1328. } else if threadRoot := content.GetRelatesTo().GetThreadParent(); threadRoot != "" {
  1329. existingThread := portal.bridge.DB.Thread.GetByMatrixRootMsg(threadRoot)
  1330. if existingThread != nil {
  1331. threadID = existingThread.ID
  1332. } else {
  1333. var err error
  1334. threadID, err = portal.startThreadFromMatrix(sender, threadRoot)
  1335. if err != nil {
  1336. portal.log.Warnfln("Failed to start thread from %s: %v", threadRoot, err)
  1337. }
  1338. }
  1339. }
  1340. if threadID != "" {
  1341. channelID = threadID
  1342. }
  1343. var sendReq discordgo.MessageSend
  1344. switch content.MsgType {
  1345. case event.MsgText, event.MsgEmote, event.MsgNotice:
  1346. if replyToMXID := content.RelatesTo.GetNonFallbackReplyTo(); replyToMXID != "" {
  1347. replyTo := portal.bridge.DB.Message.GetByMXID(portal.Key, replyToMXID)
  1348. if replyTo != nil && replyTo.ThreadID == threadID {
  1349. sendReq.Reference = &discordgo.MessageReference{
  1350. ChannelID: channelID,
  1351. MessageID: replyTo.DiscordID,
  1352. }
  1353. }
  1354. }
  1355. sendReq.Content = portal.parseMatrixHTML(sender, content)
  1356. case event.MsgAudio, event.MsgFile, event.MsgImage, event.MsgVideo:
  1357. data, err := portal.downloadMatrixAttachment(content)
  1358. if err != nil {
  1359. go portal.sendMessageMetrics(evt, err, "Error downloading media in")
  1360. return
  1361. }
  1362. sendReq.Files = []*discordgo.File{{
  1363. Name: content.Body,
  1364. ContentType: content.Info.MimeType,
  1365. Reader: bytes.NewReader(data),
  1366. }}
  1367. if content.FileName != "" && content.FileName != content.Body {
  1368. sendReq.Files[0].Name = content.FileName
  1369. sendReq.Content = portal.parseMatrixHTML(sender, content)
  1370. }
  1371. default:
  1372. go portal.sendMessageMetrics(evt, fmt.Errorf("%w %q", errUnknownMsgType, content.MsgType), "Ignoring")
  1373. return
  1374. }
  1375. sendReq.Nonce = generateNonce()
  1376. msg, err := sender.Session.ChannelMessageSendComplex(channelID, &sendReq)
  1377. go portal.sendMessageMetrics(evt, err, "Error sending")
  1378. if msg != nil {
  1379. dbMsg := portal.bridge.DB.Message.New()
  1380. dbMsg.Channel = portal.Key
  1381. dbMsg.DiscordID = msg.ID
  1382. if len(msg.Attachments) > 0 {
  1383. dbMsg.AttachmentID = msg.Attachments[0].ID
  1384. }
  1385. dbMsg.MXID = evt.ID
  1386. dbMsg.SenderID = sender.DiscordID
  1387. dbMsg.Timestamp, _ = discordgo.SnowflakeTimestamp(msg.ID)
  1388. dbMsg.ThreadID = threadID
  1389. dbMsg.Insert()
  1390. }
  1391. }
  1392. func (portal *Portal) sendDeliveryReceipt(eventID id.EventID) {
  1393. if portal.bridge.Config.Bridge.DeliveryReceipts {
  1394. err := portal.bridge.Bot.MarkRead(portal.MXID, eventID)
  1395. if err != nil {
  1396. portal.log.Debugfln("Failed to send delivery receipt for %s: %v", eventID, err)
  1397. }
  1398. }
  1399. }
  1400. func (portal *Portal) HandleMatrixLeave(brSender bridge.User) {
  1401. sender := brSender.(*User)
  1402. if portal.IsPrivateChat() && sender.DiscordID == portal.Key.Receiver {
  1403. portal.log.Debugln("User left private chat portal, cleaning up and deleting...")
  1404. portal.cleanup(false)
  1405. portal.RemoveMXID()
  1406. } else {
  1407. portal.cleanupIfEmpty()
  1408. }
  1409. }
  1410. func (portal *Portal) HandleMatrixKick(brSender bridge.User, brTarget bridge.Ghost) {}
  1411. func (portal *Portal) HandleMatrixInvite(brSender bridge.User, brTarget bridge.Ghost) {}
  1412. func (portal *Portal) leave(sender *User) {
  1413. if portal.MXID == "" {
  1414. return
  1415. }
  1416. intent := portal.bridge.GetPuppetByID(sender.DiscordID).IntentFor(portal)
  1417. intent.LeaveRoom(portal.MXID)
  1418. }
  1419. func (portal *Portal) Delete() {
  1420. portal.Portal.Delete()
  1421. portal.bridge.portalsLock.Lock()
  1422. delete(portal.bridge.portalsByID, portal.Key)
  1423. if portal.MXID != "" {
  1424. delete(portal.bridge.portalsByMXID, portal.MXID)
  1425. }
  1426. portal.bridge.portalsLock.Unlock()
  1427. }
  1428. func (portal *Portal) cleanupIfEmpty() {
  1429. if portal.MXID == "" {
  1430. return
  1431. }
  1432. users, err := portal.getMatrixUsers()
  1433. if err != nil {
  1434. portal.log.Errorfln("Failed to get Matrix user list to determine if portal needs to be cleaned up: %v", err)
  1435. return
  1436. }
  1437. if len(users) == 0 {
  1438. portal.log.Infoln("Room seems to be empty, cleaning up...")
  1439. portal.cleanup(false)
  1440. portal.RemoveMXID()
  1441. }
  1442. }
  1443. func (portal *Portal) RemoveMXID() {
  1444. portal.bridge.portalsLock.Lock()
  1445. defer portal.bridge.portalsLock.Unlock()
  1446. if portal.MXID == "" {
  1447. return
  1448. }
  1449. delete(portal.bridge.portalsByMXID, portal.MXID)
  1450. portal.MXID = ""
  1451. portal.AvatarSet = false
  1452. portal.NameSet = false
  1453. portal.TopicSet = false
  1454. portal.Encrypted = false
  1455. portal.InSpace = ""
  1456. portal.FirstEventID = ""
  1457. portal.Update()
  1458. portal.bridge.DB.Message.DeleteAll(portal.Key)
  1459. }
  1460. func (portal *Portal) cleanup(puppetsOnly bool) {
  1461. if portal.MXID == "" {
  1462. return
  1463. }
  1464. intent := portal.MainIntent()
  1465. if portal.bridge.SpecVersions.UnstableFeatures["com.beeper.room_yeeting"] {
  1466. err := intent.BeeperDeleteRoom(portal.MXID)
  1467. if err == nil || errors.Is(err, mautrix.MNotFound) {
  1468. return
  1469. }
  1470. portal.log.Warnfln("Failed to delete %s using hungryserv yeet endpoint, falling back to normal behavior: %v", portal.MXID, err)
  1471. }
  1472. if portal.IsPrivateChat() {
  1473. _, err := portal.MainIntent().LeaveRoom(portal.MXID)
  1474. if err != nil {
  1475. portal.log.Warnln("Failed to leave private chat portal with main intent:", err)
  1476. }
  1477. return
  1478. }
  1479. portal.bridge.cleanupRoom(intent, portal.MXID, puppetsOnly, portal.log)
  1480. }
  1481. func (br *DiscordBridge) cleanupRoom(intent *appservice.IntentAPI, mxid id.RoomID, puppetsOnly bool, log log.Logger) {
  1482. members, err := intent.JoinedMembers(mxid)
  1483. if err != nil {
  1484. log.Errorln("Failed to get portal members for cleanup:", err)
  1485. return
  1486. }
  1487. for member := range members.Joined {
  1488. if member == intent.UserID {
  1489. continue
  1490. }
  1491. puppet := br.GetPuppetByMXID(member)
  1492. if puppet != nil {
  1493. _, err = puppet.DefaultIntent().LeaveRoom(mxid)
  1494. if err != nil {
  1495. log.Errorln("Error leaving as puppet while cleaning up portal:", err)
  1496. }
  1497. } else if !puppetsOnly {
  1498. _, err = intent.KickUser(mxid, &mautrix.ReqKickUser{UserID: member, Reason: "Deleting portal"})
  1499. if err != nil {
  1500. log.Errorln("Error kicking user while cleaning up portal:", err)
  1501. }
  1502. }
  1503. }
  1504. _, err = intent.LeaveRoom(mxid)
  1505. if err != nil {
  1506. log.Errorln("Error leaving with main intent while cleaning up portal:", err)
  1507. }
  1508. }
  1509. func (portal *Portal) getMatrixUsers() ([]id.UserID, error) {
  1510. members, err := portal.MainIntent().JoinedMembers(portal.MXID)
  1511. if err != nil {
  1512. return nil, fmt.Errorf("failed to get member list: %w", err)
  1513. }
  1514. var users []id.UserID
  1515. for userID := range members.Joined {
  1516. _, isPuppet := portal.bridge.ParsePuppetMXID(userID)
  1517. if !isPuppet && userID != portal.bridge.Bot.UserID {
  1518. users = append(users, userID)
  1519. }
  1520. }
  1521. return users, nil
  1522. }
  1523. func (portal *Portal) handleMatrixReaction(sender *User, evt *event.Event) {
  1524. if portal.IsPrivateChat() && sender.DiscordID != portal.Key.Receiver {
  1525. go portal.sendMessageMetrics(evt, errUserNotReceiver, "Ignoring")
  1526. return
  1527. }
  1528. reaction := evt.Content.AsReaction()
  1529. if reaction.RelatesTo.Type != event.RelAnnotation {
  1530. go portal.sendMessageMetrics(evt, fmt.Errorf("%w %s", errUnknownRelationType, reaction.RelatesTo.Type), "Ignoring")
  1531. return
  1532. }
  1533. if reaction.RelatesTo.Key == JoinThreadReaction {
  1534. thread := portal.bridge.GetThreadByRootOrCreationNoticeMXID(reaction.RelatesTo.EventID)
  1535. if thread == nil {
  1536. go portal.sendMessageMetrics(evt, errTargetNotFound, "Ignoring thread join")
  1537. return
  1538. }
  1539. thread.Join(sender)
  1540. return
  1541. }
  1542. msg := portal.bridge.DB.Message.GetByMXID(portal.Key, reaction.RelatesTo.EventID)
  1543. if msg == nil {
  1544. go portal.sendMessageMetrics(evt, errTargetNotFound, "Ignoring")
  1545. return
  1546. }
  1547. firstMsg := msg
  1548. if msg.AttachmentID != "" {
  1549. firstMsg = portal.bridge.DB.Message.GetFirstByDiscordID(portal.Key, msg.DiscordID)
  1550. // TODO should the emoji be rerouted to the first message if it's different?
  1551. }
  1552. // Figure out if this is a custom emoji or not.
  1553. emojiID := reaction.RelatesTo.Key
  1554. if strings.HasPrefix(emojiID, "mxc://") {
  1555. uri, _ := id.ParseContentURI(emojiID)
  1556. emoji := portal.bridge.DB.Emoji.GetByMatrixURL(uri)
  1557. if emoji == nil {
  1558. go portal.sendMessageMetrics(evt, fmt.Errorf("%w %s", errUnknownEmoji, emojiID), "Ignoring")
  1559. return
  1560. }
  1561. emojiID = emoji.APIName()
  1562. } else {
  1563. emojiID = variationselector.Remove(emojiID)
  1564. }
  1565. existing := portal.bridge.DB.Reaction.GetByDiscordID(portal.Key, msg.DiscordID, sender.DiscordID, emojiID)
  1566. if existing != nil {
  1567. portal.log.Debugfln("Dropping duplicate Matrix reaction %s (already sent as %s)", evt.ID, existing.MXID)
  1568. go portal.sendMessageMetrics(evt, nil, "")
  1569. return
  1570. }
  1571. err := sender.Session.MessageReactionAdd(msg.DiscordProtoChannelID(), msg.DiscordID, emojiID)
  1572. go portal.sendMessageMetrics(evt, err, "Error sending")
  1573. if err == nil {
  1574. dbReaction := portal.bridge.DB.Reaction.New()
  1575. dbReaction.Channel = portal.Key
  1576. dbReaction.MessageID = msg.DiscordID
  1577. dbReaction.FirstAttachmentID = firstMsg.AttachmentID
  1578. dbReaction.Sender = sender.DiscordID
  1579. dbReaction.EmojiName = emojiID
  1580. dbReaction.ThreadID = msg.ThreadID
  1581. dbReaction.MXID = evt.ID
  1582. dbReaction.Insert()
  1583. }
  1584. }
  1585. func (portal *Portal) handleDiscordReaction(user *User, reaction *discordgo.MessageReaction, add bool, thread *Thread) {
  1586. intent := portal.bridge.GetPuppetByID(reaction.UserID).IntentFor(portal)
  1587. var discordID string
  1588. var matrixReaction string
  1589. if reaction.Emoji.ID != "" {
  1590. reactionMXC := portal.getEmojiMXCByDiscordID(reaction.Emoji.ID, reaction.Emoji.Name, reaction.Emoji.Animated)
  1591. if reactionMXC.IsEmpty() {
  1592. return
  1593. }
  1594. matrixReaction = reactionMXC.String()
  1595. discordID = reaction.Emoji.ID
  1596. } else {
  1597. discordID = reaction.Emoji.Name
  1598. matrixReaction = variationselector.Add(reaction.Emoji.Name)
  1599. }
  1600. // Find the message that we're working with.
  1601. message := portal.bridge.DB.Message.GetByDiscordID(portal.Key, reaction.MessageID)
  1602. if message == nil {
  1603. portal.log.Debugfln("failed to add reaction to message %s: message not found", reaction.MessageID)
  1604. return
  1605. }
  1606. // Lookup an existing reaction
  1607. existing := portal.bridge.DB.Reaction.GetByDiscordID(portal.Key, message[0].DiscordID, reaction.UserID, discordID)
  1608. if !add {
  1609. if existing == nil {
  1610. portal.log.Debugln("Failed to remove reaction for unknown message", reaction.MessageID)
  1611. return
  1612. }
  1613. resp, err := intent.RedactEvent(portal.MXID, existing.MXID)
  1614. if err != nil {
  1615. portal.log.Warnfln("Failed to remove reaction from %s: %v", portal.MXID, err)
  1616. }
  1617. existing.Delete()
  1618. go portal.sendDeliveryReceipt(resp.EventID)
  1619. return
  1620. } else if existing != nil {
  1621. portal.log.Debugfln("Ignoring duplicate reaction %s from %s to %s", discordID, reaction.UserID, message[0].DiscordID)
  1622. return
  1623. }
  1624. content := event.ReactionEventContent{
  1625. RelatesTo: event.RelatesTo{
  1626. EventID: message[0].MXID,
  1627. Type: event.RelAnnotation,
  1628. Key: matrixReaction,
  1629. },
  1630. }
  1631. extraContent := map[string]any{}
  1632. if reaction.Emoji.ID != "" {
  1633. extraContent["fi.mau.discord.reaction"] = map[string]any{
  1634. "id": reaction.Emoji.ID,
  1635. "name": reaction.Emoji.Name,
  1636. "mxc": matrixReaction,
  1637. }
  1638. if !portal.bridge.Config.Bridge.CustomEmojiReactions {
  1639. content.RelatesTo.Key = fmt.Sprintf(":%s:", reaction.Emoji.Name)
  1640. }
  1641. }
  1642. resp, err := intent.SendMessageEvent(portal.MXID, event.EventReaction, &event.Content{
  1643. Parsed: &content,
  1644. Raw: extraContent,
  1645. })
  1646. if err != nil {
  1647. portal.log.Errorfln("failed to send reaction from %s: %v", reaction.MessageID, err)
  1648. return
  1649. }
  1650. if existing == nil {
  1651. dbReaction := portal.bridge.DB.Reaction.New()
  1652. dbReaction.Channel = portal.Key
  1653. dbReaction.MessageID = message[0].DiscordID
  1654. dbReaction.FirstAttachmentID = message[0].AttachmentID
  1655. dbReaction.Sender = reaction.UserID
  1656. dbReaction.EmojiName = discordID
  1657. dbReaction.MXID = resp.EventID
  1658. if thread != nil {
  1659. dbReaction.ThreadID = thread.ID
  1660. }
  1661. dbReaction.Insert()
  1662. portal.sendDeliveryReceipt(dbReaction.MXID)
  1663. }
  1664. }
  1665. func (portal *Portal) handleMatrixRedaction(sender *User, evt *event.Event) {
  1666. if portal.IsPrivateChat() && sender.DiscordID != portal.Key.Receiver {
  1667. go portal.sendMessageMetrics(evt, errUserNotReceiver, "Ignoring")
  1668. return
  1669. }
  1670. // First look if we're redacting a message
  1671. message := portal.bridge.DB.Message.GetByMXID(portal.Key, evt.Redacts)
  1672. if message != nil {
  1673. // TODO add support for deleting individual attachments from messages
  1674. err := sender.Session.ChannelMessageDelete(message.DiscordProtoChannelID(), message.DiscordID)
  1675. go portal.sendMessageMetrics(evt, err, "Error sending")
  1676. if err == nil {
  1677. message.Delete()
  1678. }
  1679. return
  1680. }
  1681. // Now check if it's a reaction.
  1682. reaction := portal.bridge.DB.Reaction.GetByMXID(evt.Redacts)
  1683. if reaction != nil && reaction.Channel == portal.Key {
  1684. err := sender.Session.MessageReactionRemove(reaction.DiscordProtoChannelID(), reaction.MessageID, reaction.EmojiName, reaction.Sender)
  1685. go portal.sendMessageMetrics(evt, err, "Error sending")
  1686. if err == nil {
  1687. reaction.Delete()
  1688. }
  1689. return
  1690. }
  1691. go portal.sendMessageMetrics(evt, errTargetNotFound, "Ignoring")
  1692. }
  1693. func (portal *Portal) HandleMatrixReadReceipt(brUser bridge.User, eventID id.EventID, receipt event.ReadReceipt) {
  1694. sender := brUser.(*User)
  1695. if sender.Session == nil {
  1696. return
  1697. }
  1698. var thread *Thread
  1699. discordThreadID := ""
  1700. if receipt.ThreadID != "" && receipt.ThreadID != event.ReadReceiptThreadMain {
  1701. thread = portal.bridge.GetThreadByRootMXID(receipt.ThreadID)
  1702. if thread != nil {
  1703. discordThreadID = thread.ID
  1704. }
  1705. }
  1706. if thread != nil {
  1707. if portal.bridge.Config.Bridge.AutojoinThreadOnOpen {
  1708. thread.Join(sender)
  1709. }
  1710. if eventID == thread.CreationNoticeMXID {
  1711. portal.log.Debugfln("Dropping Matrix read receipt from %s for thread creation notice %s of %s", sender.MXID, thread.CreationNoticeMXID, thread.ID)
  1712. return
  1713. }
  1714. }
  1715. msg := portal.bridge.DB.Message.GetByMXID(portal.Key, eventID)
  1716. if msg == nil {
  1717. msg = portal.bridge.DB.Message.GetClosestBefore(portal.Key, discordThreadID, receipt.Timestamp)
  1718. if msg == nil {
  1719. portal.log.Debugfln("Dropping Matrix read receipt from %s for %s: no messages found", sender.MXID, eventID)
  1720. return
  1721. } else {
  1722. portal.log.Debugfln("Matrix read receipt target %s from %s not found, using closest message %s", eventID, sender.MXID, msg.MXID)
  1723. }
  1724. }
  1725. if receipt.ThreadID != "" && msg.ThreadID != discordThreadID {
  1726. portal.log.Debugfln("Dropping Matrix read receipt from %s for %s in unexpected thread (receipt: %s, message: %s)", receipt.ThreadID, msg.ThreadID)
  1727. return
  1728. }
  1729. resp, err := sender.Session.ChannelMessageAckNoToken(msg.DiscordProtoChannelID(), msg.DiscordID)
  1730. if err != nil {
  1731. portal.log.Warnfln("Failed to handle read receipt for %s/%s from %s: %v", msg.MXID, msg.DiscordID, sender.MXID, err)
  1732. } else if resp.Token != nil {
  1733. portal.log.Debugfln("Marked %s/%s as read by %s (and got unexpected non-nil token %s)", msg.MXID, msg.DiscordID, sender.MXID, *resp.Token)
  1734. } else {
  1735. portal.log.Debugfln("Marked %s/%s in %s as read by %s", msg.MXID, msg.DiscordID, msg.DiscordProtoChannelID(), sender.MXID)
  1736. }
  1737. }
  1738. func typingDiff(prev, new []id.UserID) (started []id.UserID) {
  1739. OuterNew:
  1740. for _, userID := range new {
  1741. for _, previousUserID := range prev {
  1742. if userID == previousUserID {
  1743. continue OuterNew
  1744. }
  1745. }
  1746. started = append(started, userID)
  1747. }
  1748. return
  1749. }
  1750. func (portal *Portal) HandleMatrixTyping(newTyping []id.UserID) {
  1751. portal.currentlyTypingLock.Lock()
  1752. defer portal.currentlyTypingLock.Unlock()
  1753. startedTyping := typingDiff(portal.currentlyTyping, newTyping)
  1754. portal.currentlyTyping = newTyping
  1755. for _, userID := range startedTyping {
  1756. user := portal.bridge.GetUserByMXID(userID)
  1757. if user != nil && user.Session != nil {
  1758. user.ViewingChannel(portal)
  1759. err := user.Session.ChannelTyping(portal.Key.ChannelID)
  1760. if err != nil {
  1761. portal.log.Warnfln("Failed to mark %s as typing: %v", user.MXID, err)
  1762. } else {
  1763. portal.log.Debugfln("Marked %s as typing", user.MXID)
  1764. }
  1765. }
  1766. }
  1767. }
  1768. func (portal *Portal) UpdateName(meta *discordgo.Channel) bool {
  1769. var parentName, guildName string
  1770. if portal.Parent != nil {
  1771. parentName = portal.Parent.PlainName
  1772. }
  1773. if portal.Guild != nil {
  1774. guildName = portal.Guild.PlainName
  1775. }
  1776. plainNameChanged := portal.PlainName != meta.Name
  1777. portal.PlainName = meta.Name
  1778. return portal.UpdateNameDirect(portal.bridge.Config.Bridge.FormatChannelName(config.ChannelNameParams{
  1779. Name: meta.Name,
  1780. ParentName: parentName,
  1781. GuildName: guildName,
  1782. NSFW: meta.NSFW,
  1783. Type: meta.Type,
  1784. })) || plainNameChanged
  1785. }
  1786. func (portal *Portal) UpdateNameDirect(name string) bool {
  1787. if portal.Name == name && (portal.NameSet || portal.MXID == "") {
  1788. return false
  1789. } else if !portal.Encrypted && !portal.bridge.Config.Bridge.PrivateChatPortalMeta && portal.IsPrivateChat() {
  1790. return false
  1791. }
  1792. portal.log.Debugfln("Updating name %q -> %q", portal.Name, name)
  1793. portal.Name = name
  1794. portal.NameSet = false
  1795. if portal.MXID != "" {
  1796. _, err := portal.MainIntent().SetRoomName(portal.MXID, portal.Name)
  1797. if err != nil {
  1798. portal.log.Warnln("Failed to update room name:", err)
  1799. } else {
  1800. portal.NameSet = true
  1801. }
  1802. }
  1803. return true
  1804. }
  1805. func (portal *Portal) UpdateAvatarFromPuppet(puppet *Puppet) bool {
  1806. if portal.Avatar == puppet.Avatar && portal.AvatarURL == puppet.AvatarURL && (portal.AvatarSet || portal.MXID == "") {
  1807. return false
  1808. }
  1809. portal.log.Debugfln("Updating avatar from puppet %q -> %q", portal.Avatar, puppet.Avatar)
  1810. portal.Avatar = puppet.Avatar
  1811. portal.AvatarURL = puppet.AvatarURL
  1812. portal.AvatarSet = false
  1813. portal.updateRoomAvatar()
  1814. return true
  1815. }
  1816. func (portal *Portal) UpdateGroupDMAvatar(iconID string) bool {
  1817. if portal.Avatar == iconID && (iconID == "") == portal.AvatarURL.IsEmpty() && (portal.AvatarSet || portal.MXID == "") {
  1818. return false
  1819. }
  1820. portal.log.Debugfln("Updating group DM avatar %q -> %q", portal.Avatar, iconID)
  1821. portal.Avatar = iconID
  1822. portal.AvatarSet = false
  1823. portal.AvatarURL = id.ContentURI{}
  1824. if portal.Avatar != "" {
  1825. uri, err := uploadAvatar(portal.MainIntent(), discordgo.EndpointGroupIcon(portal.Key.ChannelID, portal.Avatar))
  1826. if err != nil {
  1827. portal.log.Warnfln("Failed to reupload channel avatar %s: %v", portal.Avatar, err)
  1828. return true
  1829. } else {
  1830. portal.AvatarURL = uri
  1831. }
  1832. }
  1833. portal.updateRoomAvatar()
  1834. return true
  1835. }
  1836. func (portal *Portal) updateRoomAvatar() {
  1837. if portal.MXID == "" {
  1838. return
  1839. }
  1840. _, err := portal.MainIntent().SetRoomAvatar(portal.MXID, portal.AvatarURL)
  1841. if err != nil {
  1842. portal.log.Warnln("Failed to update room avatar:", err)
  1843. } else {
  1844. portal.AvatarSet = true
  1845. }
  1846. }
  1847. func (portal *Portal) UpdateTopic(topic string) bool {
  1848. if portal.Topic == topic && (portal.TopicSet || portal.MXID == "") {
  1849. return false
  1850. }
  1851. portal.log.Debugfln("Updating topic %q -> %q", portal.Topic, topic)
  1852. portal.Topic = topic
  1853. portal.TopicSet = false
  1854. if portal.MXID != "" {
  1855. _, err := portal.MainIntent().SetRoomTopic(portal.MXID, portal.Topic)
  1856. if err != nil {
  1857. portal.log.Warnln("Failed to update room topic:", err)
  1858. } else {
  1859. portal.TopicSet = true
  1860. }
  1861. }
  1862. return true
  1863. }
  1864. func (portal *Portal) removeFromSpace() {
  1865. if portal.InSpace == "" {
  1866. return
  1867. }
  1868. portal.log.Debugfln("Removing room from space %s", portal.InSpace)
  1869. _, err := portal.MainIntent().SendStateEvent(portal.MXID, event.StateSpaceParent, portal.InSpace.String(), struct{}{})
  1870. if err != nil {
  1871. portal.log.Warnfln("Failed to unset canonical space %s: %v", portal.InSpace, err)
  1872. }
  1873. _, err = portal.bridge.Bot.SendStateEvent(portal.InSpace, event.StateSpaceChild, portal.MXID.String(), struct{}{})
  1874. if err != nil {
  1875. portal.log.Warnfln("Failed to add room to space %s: %v", portal.InSpace, err)
  1876. }
  1877. portal.InSpace = ""
  1878. }
  1879. func (portal *Portal) addToSpace(mxid id.RoomID) bool {
  1880. if portal.InSpace == mxid {
  1881. return false
  1882. }
  1883. portal.removeFromSpace()
  1884. if mxid == "" {
  1885. return true
  1886. }
  1887. portal.log.Debugfln("Adding room to space %s", mxid)
  1888. _, err := portal.MainIntent().SendStateEvent(portal.MXID, event.StateSpaceParent, mxid.String(), &event.SpaceParentEventContent{
  1889. Via: []string{portal.bridge.AS.HomeserverDomain},
  1890. Canonical: true,
  1891. })
  1892. if err != nil {
  1893. portal.log.Warnfln("Failed to set canonical space %s: %v", mxid, err)
  1894. }
  1895. _, err = portal.bridge.Bot.SendStateEvent(mxid, event.StateSpaceChild, portal.MXID.String(), &event.SpaceChildEventContent{
  1896. Via: []string{portal.bridge.AS.HomeserverDomain},
  1897. // TODO order
  1898. })
  1899. if err != nil {
  1900. portal.log.Warnfln("Failed to add room to space %s: %v", mxid, err)
  1901. } else {
  1902. portal.InSpace = mxid
  1903. }
  1904. return true
  1905. }
  1906. func (portal *Portal) UpdateParent(parentID string) bool {
  1907. if portal.ParentID == parentID {
  1908. return false
  1909. }
  1910. portal.log.Debugfln("Updating parent ID %q -> %q", portal.ParentID, parentID)
  1911. portal.ParentID = parentID
  1912. if portal.ParentID != "" {
  1913. portal.Parent = portal.bridge.GetPortalByID(database.NewPortalKey(parentID, ""), discordgo.ChannelTypeGuildCategory)
  1914. } else {
  1915. portal.Parent = nil
  1916. }
  1917. return true
  1918. }
  1919. func (portal *Portal) ExpectedSpaceID() id.RoomID {
  1920. if portal.Parent != nil {
  1921. return portal.Parent.MXID
  1922. } else if portal.Guild != nil {
  1923. return portal.Guild.MXID
  1924. }
  1925. return ""
  1926. }
  1927. func (portal *Portal) updateSpace() bool {
  1928. if portal.MXID == "" {
  1929. return false
  1930. }
  1931. if portal.Parent != nil {
  1932. return portal.addToSpace(portal.Parent.MXID)
  1933. } else if portal.Guild != nil {
  1934. return portal.addToSpace(portal.Guild.MXID)
  1935. }
  1936. return false
  1937. }
  1938. func (portal *Portal) UpdateInfo(source *User, meta *discordgo.Channel) *discordgo.Channel {
  1939. changed := false
  1940. if meta == nil {
  1941. portal.log.Debugfln("UpdateInfo called without metadata, fetching from %s's state cache", source.DiscordID)
  1942. meta, _ = source.Session.State.Channel(portal.Key.ChannelID)
  1943. if meta == nil {
  1944. portal.log.Warnfln("No metadata found in state cache, fetching from server via %s", source.DiscordID)
  1945. var err error
  1946. meta, err = source.Session.Channel(portal.Key.ChannelID)
  1947. if err != nil {
  1948. portal.log.Errorfln("Failed to fetch meta via %s: %v", source.DiscordID, err)
  1949. return nil
  1950. }
  1951. }
  1952. }
  1953. if portal.Type != meta.Type {
  1954. portal.log.Warnfln("Portal type changed from %d to %d", portal.Type, meta.Type)
  1955. portal.Type = meta.Type
  1956. changed = true
  1957. }
  1958. if portal.OtherUserID == "" && portal.IsPrivateChat() {
  1959. if len(meta.Recipients) == 0 {
  1960. var err error
  1961. meta, err = source.Session.Channel(meta.ID)
  1962. if err != nil {
  1963. portal.log.Errorfln("Failed to get DM channel info:", err)
  1964. }
  1965. }
  1966. portal.OtherUserID = meta.Recipients[0].ID
  1967. portal.log.Infoln("Found other user ID:", portal.OtherUserID)
  1968. changed = true
  1969. }
  1970. if meta.GuildID != "" && portal.GuildID == "" {
  1971. portal.GuildID = meta.GuildID
  1972. portal.Guild = portal.bridge.GetGuildByID(portal.GuildID, true)
  1973. changed = true
  1974. }
  1975. switch portal.Type {
  1976. case discordgo.ChannelTypeDM:
  1977. if portal.OtherUserID != "" {
  1978. puppet := portal.bridge.GetPuppetByID(portal.OtherUserID)
  1979. changed = portal.UpdateAvatarFromPuppet(puppet) || changed
  1980. changed = portal.UpdateNameDirect(puppet.Name) || changed
  1981. }
  1982. case discordgo.ChannelTypeGroupDM:
  1983. changed = portal.UpdateGroupDMAvatar(meta.Icon) || changed
  1984. fallthrough
  1985. default:
  1986. changed = portal.UpdateName(meta) || changed
  1987. }
  1988. changed = portal.UpdateTopic(meta.Topic) || changed
  1989. changed = portal.UpdateParent(meta.ParentID) || changed
  1990. // Private channels are added to the space in User.handlePrivateChannel
  1991. if portal.GuildID != "" && portal.MXID != "" && portal.ExpectedSpaceID() != portal.InSpace {
  1992. changed = portal.updateSpace() || changed
  1993. }
  1994. if changed {
  1995. portal.UpdateBridgeInfo()
  1996. portal.Update()
  1997. }
  1998. return meta
  1999. }