portal.go 58 KB

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