| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217 |
- package chat
- import (
- "log/slog"
- "slices"
- "github.com/ayn2op/discordo/internal/notifications"
- "github.com/ayn2op/discordo/internal/ui"
- "github.com/ayn2op/tview"
- "github.com/diamondburned/arikawa/v3/discord"
- "github.com/diamondburned/arikawa/v3/gateway"
- "github.com/diamondburned/arikawa/v3/utils/httputil/httpdriver"
- "github.com/diamondburned/arikawa/v3/utils/ws"
- "github.com/diamondburned/ningen/v3/states/read"
- )
- func (m *Model) onRequest(r httpdriver.Request) error {
- if req, ok := r.(*httpdriver.DefaultRequest); ok {
- slog.Debug("new HTTP request", "method", req.Method, "url", req.URL)
- }
- return nil
- }
- func (m *Model) onRaw(event *ws.RawEvent) {
- slog.Debug(
- "new raw event",
- "code", event.OriginalCode,
- "type", event.OriginalType,
- // "data", event.Raw,
- )
- }
- func (m *Model) onReady(event *gateway.ReadyEvent) {
- // Rebuild indexes from scratch so reconnects and account switches do not
- // retain pointers to detached tree nodes.
- m.guildsTree.resetNodeIndex()
- dmNode := tview.NewTreeNode("Direct Messages").SetReference(dmNode{}).SetExpandable(true).SetExpanded(false)
- m.guildsTree.dmRootNode = dmNode
- root := m.guildsTree.
- GetRoot().
- ClearChildren().
- AddChild(dmNode)
- // Track guilds already in folders to find orphans.
- // Newly joined guilds may not be synced to GuildFolders yet but always appear in guild positions.
- guildsInFolders := make(map[discord.GuildID]bool)
- for _, folder := range event.UserSettings.GuildFolders {
- for _, guildID := range folder.GuildIDs {
- guildsInFolders[guildID] = true
- }
- }
- // Build index of all available guilds.
- guildsByID := make(map[discord.GuildID]*gateway.GuildCreateEvent, len(event.Guilds))
- for index := range event.Guilds {
- guildsByID[event.Guilds[index].ID] = &event.Guilds[index]
- }
- // Use GuildPositions for ordering (it's the canonical order).
- // Guilds not in any folder are "orphans" - add them directly to root.
- positions := event.UserSettings.GuildPositions
- // Fallback: GuildPositions shouldn't be nil but handle gracefully
- if len(positions) == 0 {
- positions = make([]discord.GuildID, 0, len(event.Guilds))
- for _, guildEvent := range event.Guilds {
- positions = append(positions, guildEvent.ID)
- }
- }
- for _, guildID := range positions {
- // Already handled in folder processing below
- if guildsInFolders[guildID] {
- continue
- }
- // Orphan guild - add directly to root in order
- if guildEvent, ok := guildsByID[guildID]; ok {
- m.guildsTree.createGuildNode(root, guildEvent.Guild)
- }
- }
- // Process folders (real folders and single-guild "folders")
- for _, folder := range event.UserSettings.GuildFolders {
- if folder.ID == 0 && len(folder.GuildIDs) == 1 {
- if guild, ok := guildsByID[folder.GuildIDs[0]]; ok {
- m.guildsTree.createGuildNode(root, guild.Guild)
- }
- } else {
- m.guildsTree.createFolderNode(folder, guildsByID)
- }
- }
- // Restore channels for guilds that were previously expanded.
- for guildID, guildNode := range m.guildsTree.guildNodeByID {
- if m.guildsTree.guildState.isExpanded(guildID) && len(guildNode.GetChildren()) == 0 {
- channels, err := m.state.Cabinet.Channels(guildID)
- if err != nil {
- slog.Error("failed to restore guild channels", "err", err, "guild_id", guildID)
- continue
- }
- ui.SortGuildChannels(channels)
- m.guildsTree.createChannelNodes(guildNode, channels)
- }
- }
- m.guildsTree.SetCurrentNode(root)
- m.app.SetFocus(m.guildsTree)
- }
- func (m *Model) onMessageCreate(message *gateway.MessageCreateEvent) {
- selectedChannel := m.SelectedChannel()
- if selectedChannel != nil && selectedChannel.ID == message.ChannelID {
- m.removeTyper(message.Author.ID)
- m.messagesList.addMessage(message.Message)
- } else {
- if err := notifications.Notify(m.state, message, m.cfg); err != nil {
- slog.Error("failed to notify", "err", err, "channel_id", message.ChannelID, "message_id", message.ID)
- }
- }
- }
- func (m *Model) onMessageUpdate(message *gateway.MessageUpdateEvent) {
- if selected := m.SelectedChannel(); selected != nil && selected.ID == message.ChannelID {
- index := slices.IndexFunc(m.messagesList.messages, func(m discord.Message) bool {
- return m.ID == message.ID
- })
- if index < 0 {
- return
- }
- m.messagesList.setMessage(index, message.Message)
- }
- }
- func (m *Model) onMessageDelete(message *gateway.MessageDeleteEvent) {
- selectedChannel := m.SelectedChannel()
- if selectedChannel == nil {
- return
- }
- if selectedChannel.ID == message.ChannelID {
- prevCursor := m.messagesList.Cursor()
- deletedIndex := slices.IndexFunc(m.messagesList.messages, func(m discord.Message) bool {
- return m.ID == message.ID
- })
- if deletedIndex < 0 {
- return
- }
- m.messagesList.deleteMessage(deletedIndex)
- // Keep cursor stable when possible after removal.
- newCursor := prevCursor
- if prevCursor == deletedIndex {
- // Prefer previous item; fall forward if we deleted the first.
- newCursor = deletedIndex - 1
- if newCursor < 0 {
- if deletedIndex < len(m.messagesList.messages) {
- newCursor = deletedIndex
- } else {
- newCursor = -1
- }
- }
- } else if prevCursor > deletedIndex {
- // Shift back since the list shrank before the cursor.
- newCursor = prevCursor - 1
- }
- if newCursor != prevCursor {
- // Avoid redundant cursor updates if nothing changed.
- m.messagesList.SetCursor(newCursor)
- }
- }
- }
- func (m *Model) onGuildMembersChunk(event *gateway.GuildMembersChunkEvent) {
- m.messagesList.setFetchingChunk(false, uint(len(event.Members)))
- }
- func (m *Model) onGuildMemberRemove(event *gateway.GuildMemberRemoveEvent) {
- m.messageInput.cache.Invalidate(event.GuildID.String()+" "+event.User.Username, m.state.MemberState.SearchLimit)
- }
- func (m *Model) onTypingStart(event *gateway.TypingStartEvent) {
- selectedChannel := m.SelectedChannel()
- if selectedChannel == nil {
- return
- }
- if selectedChannel.ID != event.ChannelID {
- return
- }
- me, _ := m.state.Cabinet.Me()
- if event.UserID == me.ID {
- return
- }
- m.addTyper(event.UserID)
- }
- func (m *Model) onReadUpdate(event *read.UpdateEvent) {
- // Use indexed node lookup to avoid walking the whole tree on every read
- // event. This runs frequently while reading/typing across channels.
- if event.GuildID.IsValid() {
- if guildNode := m.guildsTree.findNodeByReference(event.GuildID); guildNode != nil {
- m.guildsTree.setNodeLineStyle(guildNode, m.guildsTree.getGuildNodeStyle(event.GuildID))
- }
- }
- // Channel style is always updated for the target channel regardless of
- // whether it's in a guild or DM.
- if channelNode := m.guildsTree.findNodeByReference(event.ChannelID); channelNode != nil {
- m.guildsTree.setNodeLineStyle(channelNode, m.guildsTree.getChannelNodeStyle(event.ChannelID))
- }
- }
|