portal.go 76 KB

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