state.go 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217
  1. package chat
  2. import (
  3. "log/slog"
  4. "slices"
  5. "github.com/ayn2op/discordo/internal/notifications"
  6. "github.com/ayn2op/discordo/internal/ui"
  7. "github.com/ayn2op/tview"
  8. "github.com/diamondburned/arikawa/v3/discord"
  9. "github.com/diamondburned/arikawa/v3/gateway"
  10. "github.com/diamondburned/arikawa/v3/utils/httputil/httpdriver"
  11. "github.com/diamondburned/arikawa/v3/utils/ws"
  12. "github.com/diamondburned/ningen/v3/states/read"
  13. )
  14. func (m *Model) onRequest(r httpdriver.Request) error {
  15. if req, ok := r.(*httpdriver.DefaultRequest); ok {
  16. slog.Debug("new HTTP request", "method", req.Method, "url", req.URL)
  17. }
  18. return nil
  19. }
  20. func (m *Model) onRaw(event *ws.RawEvent) {
  21. slog.Debug(
  22. "new raw event",
  23. "code", event.OriginalCode,
  24. "type", event.OriginalType,
  25. // "data", event.Raw,
  26. )
  27. }
  28. func (m *Model) onReady(event *gateway.ReadyEvent) {
  29. // Rebuild indexes from scratch so reconnects and account switches do not
  30. // retain pointers to detached tree nodes.
  31. m.guildsTree.resetNodeIndex()
  32. dmNode := tview.NewTreeNode("Direct Messages").SetReference(dmNode{}).SetExpandable(true).SetExpanded(false)
  33. m.guildsTree.dmRootNode = dmNode
  34. root := m.guildsTree.
  35. GetRoot().
  36. ClearChildren().
  37. AddChild(dmNode)
  38. // Track guilds already in folders to find orphans.
  39. // Newly joined guilds may not be synced to GuildFolders yet but always appear in guild positions.
  40. guildsInFolders := make(map[discord.GuildID]bool)
  41. for _, folder := range event.UserSettings.GuildFolders {
  42. for _, guildID := range folder.GuildIDs {
  43. guildsInFolders[guildID] = true
  44. }
  45. }
  46. // Build index of all available guilds.
  47. guildsByID := make(map[discord.GuildID]*gateway.GuildCreateEvent, len(event.Guilds))
  48. for index := range event.Guilds {
  49. guildsByID[event.Guilds[index].ID] = &event.Guilds[index]
  50. }
  51. // Use GuildPositions for ordering (it's the canonical order).
  52. // Guilds not in any folder are "orphans" - add them directly to root.
  53. positions := event.UserSettings.GuildPositions
  54. // Fallback: GuildPositions shouldn't be nil but handle gracefully
  55. if len(positions) == 0 {
  56. positions = make([]discord.GuildID, 0, len(event.Guilds))
  57. for _, guildEvent := range event.Guilds {
  58. positions = append(positions, guildEvent.ID)
  59. }
  60. }
  61. for _, guildID := range positions {
  62. // Already handled in folder processing below
  63. if guildsInFolders[guildID] {
  64. continue
  65. }
  66. // Orphan guild - add directly to root in order
  67. if guildEvent, ok := guildsByID[guildID]; ok {
  68. m.guildsTree.createGuildNode(root, guildEvent.Guild)
  69. }
  70. }
  71. // Process folders (real folders and single-guild "folders")
  72. for _, folder := range event.UserSettings.GuildFolders {
  73. if folder.ID == 0 && len(folder.GuildIDs) == 1 {
  74. if guild, ok := guildsByID[folder.GuildIDs[0]]; ok {
  75. m.guildsTree.createGuildNode(root, guild.Guild)
  76. }
  77. } else {
  78. m.guildsTree.createFolderNode(folder, guildsByID)
  79. }
  80. }
  81. // Restore channels for guilds that were previously expanded.
  82. for guildID, guildNode := range m.guildsTree.guildNodeByID {
  83. if m.guildsTree.guildState.isExpanded(guildID) && len(guildNode.GetChildren()) == 0 {
  84. channels, err := m.state.Cabinet.Channels(guildID)
  85. if err != nil {
  86. slog.Error("failed to restore guild channels", "err", err, "guild_id", guildID)
  87. continue
  88. }
  89. ui.SortGuildChannels(channels)
  90. m.guildsTree.createChannelNodes(guildNode, channels)
  91. }
  92. }
  93. m.guildsTree.SetCurrentNode(root)
  94. m.app.SetFocus(m.guildsTree)
  95. }
  96. func (m *Model) onMessageCreate(message *gateway.MessageCreateEvent) {
  97. selectedChannel := m.SelectedChannel()
  98. if selectedChannel != nil && selectedChannel.ID == message.ChannelID {
  99. m.removeTyper(message.Author.ID)
  100. m.messagesList.addMessage(message.Message)
  101. } else {
  102. if err := notifications.Notify(m.state, message, m.cfg); err != nil {
  103. slog.Error("failed to notify", "err", err, "channel_id", message.ChannelID, "message_id", message.ID)
  104. }
  105. }
  106. }
  107. func (m *Model) onMessageUpdate(message *gateway.MessageUpdateEvent) {
  108. if selected := m.SelectedChannel(); selected != nil && selected.ID == message.ChannelID {
  109. index := slices.IndexFunc(m.messagesList.messages, func(m discord.Message) bool {
  110. return m.ID == message.ID
  111. })
  112. if index < 0 {
  113. return
  114. }
  115. m.messagesList.setMessage(index, message.Message)
  116. }
  117. }
  118. func (m *Model) onMessageDelete(message *gateway.MessageDeleteEvent) {
  119. selectedChannel := m.SelectedChannel()
  120. if selectedChannel == nil {
  121. return
  122. }
  123. if selectedChannel.ID == message.ChannelID {
  124. prevCursor := m.messagesList.Cursor()
  125. deletedIndex := slices.IndexFunc(m.messagesList.messages, func(m discord.Message) bool {
  126. return m.ID == message.ID
  127. })
  128. if deletedIndex < 0 {
  129. return
  130. }
  131. m.messagesList.deleteMessage(deletedIndex)
  132. // Keep cursor stable when possible after removal.
  133. newCursor := prevCursor
  134. if prevCursor == deletedIndex {
  135. // Prefer previous item; fall forward if we deleted the first.
  136. newCursor = deletedIndex - 1
  137. if newCursor < 0 {
  138. if deletedIndex < len(m.messagesList.messages) {
  139. newCursor = deletedIndex
  140. } else {
  141. newCursor = -1
  142. }
  143. }
  144. } else if prevCursor > deletedIndex {
  145. // Shift back since the list shrank before the cursor.
  146. newCursor = prevCursor - 1
  147. }
  148. if newCursor != prevCursor {
  149. // Avoid redundant cursor updates if nothing changed.
  150. m.messagesList.SetCursor(newCursor)
  151. }
  152. }
  153. }
  154. func (m *Model) onGuildMembersChunk(event *gateway.GuildMembersChunkEvent) {
  155. m.messagesList.setFetchingChunk(false, uint(len(event.Members)))
  156. }
  157. func (m *Model) onGuildMemberRemove(event *gateway.GuildMemberRemoveEvent) {
  158. m.messageInput.cache.Invalidate(event.GuildID.String()+" "+event.User.Username, m.state.MemberState.SearchLimit)
  159. }
  160. func (m *Model) onTypingStart(event *gateway.TypingStartEvent) {
  161. selectedChannel := m.SelectedChannel()
  162. if selectedChannel == nil {
  163. return
  164. }
  165. if selectedChannel.ID != event.ChannelID {
  166. return
  167. }
  168. me, _ := m.state.Cabinet.Me()
  169. if event.UserID == me.ID {
  170. return
  171. }
  172. m.addTyper(event.UserID)
  173. }
  174. func (m *Model) onReadUpdate(event *read.UpdateEvent) {
  175. // Use indexed node lookup to avoid walking the whole tree on every read
  176. // event. This runs frequently while reading/typing across channels.
  177. if event.GuildID.IsValid() {
  178. if guildNode := m.guildsTree.findNodeByReference(event.GuildID); guildNode != nil {
  179. m.guildsTree.setNodeLineStyle(guildNode, m.guildsTree.getGuildNodeStyle(event.GuildID))
  180. }
  181. }
  182. // Channel style is always updated for the target channel regardless of
  183. // whether it's in a guild or DM.
  184. if channelNode := m.guildsTree.findNodeByReference(event.ChannelID); channelNode != nil {
  185. m.guildsTree.setNodeLineStyle(channelNode, m.guildsTree.getChannelNodeStyle(event.ChannelID))
  186. }
  187. }