package chat import ( "fmt" "log/slog" "sync" "time" "github.com/ayn2op/discordo/internal/config" "github.com/ayn2op/discordo/internal/ui" "github.com/ayn2op/tview" "github.com/ayn2op/tview/flex" "github.com/ayn2op/tview/keybind" "github.com/ayn2op/tview/layers" "github.com/diamondburned/arikawa/v3/discord" "github.com/diamondburned/ningen/v3" "github.com/diamondburned/ningen/v3/states/read" "github.com/gdamore/tcell/v3" ) const typingDuration = 10 * time.Second const ( flexLayerName = "flex" mentionsListLayerName = "mentionsList" attachmentsListLayerName = "attachmentsList" confirmModalLayerName = "confirmModal" channelsPickerLayerName = "channelsPicker" ) type Model struct { *layers.Layers // guildsTree (sidebar) + rightFlex mainFlex *flex.Model // messagesList + messageInput rightFlex *flex.Model guildsTree *guildsTree messagesList *messagesList messageInput *messageInput channelsPicker *channelsPicker selectedChannel *discord.Channel selectedChannelMu sync.RWMutex typersMu sync.RWMutex typers map[discord.UserID]*time.Timer confirmModalDone func(label string) confirmModalPreviousFocus tview.Primitive app *tview.Application cfg *config.Config state *ningen.State token string } func NewModel(app *tview.Application, cfg *config.Config, token string) *Model { m := &Model{ Layers: layers.New(), mainFlex: flex.NewModel(), rightFlex: flex.NewModel(), typers: make(map[discord.UserID]*time.Timer), app: app, cfg: cfg, token: token, } m.guildsTree = newGuildsTree(cfg, m) m.messagesList = newMessagesList(cfg, m) m.messageInput = newMessageInput(cfg, m) m.channelsPicker = newChannelsPicker(cfg, m) m.SetBackgroundLayerStyle(m.cfg.Theme.Dialog.BackgroundStyle.Style) m.buildLayout() return m } func (m *Model) SelectedChannel() *discord.Channel { m.selectedChannelMu.RLock() defer m.selectedChannelMu.RUnlock() return m.selectedChannel } func (m *Model) SetSelectedChannel(channel *discord.Channel) { m.selectedChannelMu.Lock() m.selectedChannel = channel m.selectedChannelMu.Unlock() } func (m *Model) buildLayout() { m.Clear() m.rightFlex.Clear() m.mainFlex.Clear() m.rightFlex. SetDirection(flex.DirectionRow). AddItem(m.messagesList, 0, 1, false). AddItem(m.messageInput, 3, 1, false) // The guilds tree is always focused first at start-up. m.mainFlex. AddItem(m.guildsTree, 0, 1, true). AddItem(m.rightFlex, 0, 4, false) m.AddLayer(m.mainFlex, layers.WithName(flexLayerName), layers.WithResize(true), layers.WithVisible(true)) m.AddLayer( m.messageInput.mentionsList, layers.WithName(mentionsListLayerName), layers.WithResize(false), layers.WithVisible(false), layers.WithEnabled(false), ) } func (m *Model) togglePicker() { if m.HasLayer(channelsPickerLayerName) { m.closePicker() } else { m.openPicker() } } func (m *Model) openPicker() { m.AddLayer( ui.Centered(m.channelsPicker, m.cfg.Picker.Width, m.cfg.Picker.Height), layers.WithName(channelsPickerLayerName), layers.WithResize(true), layers.WithVisible(true), layers.WithOverlay(), ).SendToFront(channelsPickerLayerName) m.channelsPicker.update() } func (m *Model) closePicker() { m.RemoveLayer(channelsPickerLayerName) m.channelsPicker.Update() } func (m *Model) toggleGuildsTree() tview.Command { // The guilds tree is visible if the number of items is two. if m.mainFlex.GetItemCount() == 2 { m.mainFlex.RemoveItem(m.guildsTree) if m.guildsTree.HasFocus() { return tview.SetFocus(m.mainFlex) } } else { m.buildLayout() return tview.SetFocus(m.guildsTree) } return nil } func (m *Model) focusGuildsTree() tview.Command { // The guilds tree is not hidden if the number of items is two. if m.mainFlex.GetItemCount() == 2 { return tview.SetFocus(m.guildsTree) } return nil } func (m *Model) focusMessageInput() tview.Command { if !m.messageInput.GetDisabled() { return tview.SetFocus(m.messageInput) } return nil } func (m *Model) focusMessagesList() tview.Command { return tview.SetFocus(m.messagesList) } func (m *Model) focusPrevious() tview.Command { switch m.app.Focused() { case m.guildsTree: if cmd := m.focusMessageInput(); cmd != nil { return cmd } return m.focusMessagesList() case m.messagesList: // Fallback when guilds/input are unavailable. if cmd := m.focusGuildsTree(); cmd != nil { return cmd } if cmd := m.focusMessageInput(); cmd != nil { return cmd } return m.focusMessagesList() case m.messageInput: return m.focusMessagesList() } return nil } func (m *Model) focusNext() tview.Command { switch m.app.Focused() { case m.guildsTree: return m.focusMessagesList() case m.messagesList: // Fallback when input/guilds are unavailable. if cmd := m.focusMessageInput(); cmd != nil { return cmd } if cmd := m.focusGuildsTree(); cmd != nil { return cmd } case m.messageInput: if cmd := m.focusGuildsTree(); cmd != nil { return cmd } return m.focusMessagesList() } return nil } func (m *Model) HandleEvent(event tcell.Event) tview.Command { switch event := event.(type) { case *tview.InitEvent: return func() tcell.Event { if err := m.OpenState(m.token); err != nil { slog.Error("failed to open chat state", "err", err) return tcell.NewEventError(err) } return nil } case *QuitEvent: return tview.Batch( m.closeState(), tview.Quit(), ) case *tview.ModalDoneEvent: if m.HasLayer(confirmModalLayerName) { m.RemoveLayer(confirmModalLayerName) var focusCmd tview.Command if m.confirmModalPreviousFocus != nil { focusCmd = tview.SetFocus(m.confirmModalPreviousFocus) } onDone := m.confirmModalDone m.confirmModalDone = nil m.confirmModalPreviousFocus = nil if onDone != nil { onDone(event.ButtonLabel) } return focusCmd } case *tview.KeyEvent: switch { case keybind.Matches(event, m.cfg.Keybinds.FocusGuildsTree.Keybind): m.messageInput.removeMentionsList() return m.focusGuildsTree() case keybind.Matches(event, m.cfg.Keybinds.FocusMessagesList.Keybind): m.messageInput.removeMentionsList() return m.focusMessagesList() case keybind.Matches(event, m.cfg.Keybinds.FocusMessageInput.Keybind): return m.focusMessageInput() case keybind.Matches(event, m.cfg.Keybinds.FocusPrevious.Keybind): return m.focusPrevious() case keybind.Matches(event, m.cfg.Keybinds.FocusNext.Keybind): return m.focusNext() case keybind.Matches(event, m.cfg.Keybinds.ToggleGuildsTree.Keybind): return m.toggleGuildsTree() case keybind.Matches(event, m.cfg.Keybinds.ToggleChannelsPicker.Keybind): m.togglePicker() return nil case keybind.Matches(event, m.cfg.Keybinds.Logout.Keybind): return tview.Batch(m.closeState(), m.logout()) } case *closeLayerEvent: if m.HasLayer(event.name) { m.HideLayer(event.name) } return nil } return m.Layers.HandleEvent(event) } func (m *Model) showConfirmModal(prompt string, buttons []string, onDone func(label string)) { m.confirmModalPreviousFocus = m.app.Focused() m.confirmModalDone = onDone modal := tview.NewModal(). SetText(prompt). AddButtons(buttons) m. AddLayer( ui.Centered(modal, 0, 0), layers.WithName(confirmModalLayerName), layers.WithResize(true), layers.WithVisible(true), layers.WithOverlay(), ). SendToFront(confirmModalLayerName) } func (m *Model) onReadUpdate(event *read.UpdateEvent) { m.app.QueueUpdateDraw(func() { // 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)) } }) } func (m *Model) clearTypers() { m.typersMu.Lock() for _, timer := range m.typers { timer.Stop() } clear(m.typers) m.typersMu.Unlock() m.updateFooter() } func (m *Model) addTyper(userID discord.UserID) { m.typersMu.Lock() typer, ok := m.typers[userID] if ok { typer.Reset(typingDuration) } else { m.typers[userID] = time.AfterFunc(typingDuration, func() { m.removeTyper(userID) }) } m.typersMu.Unlock() m.updateFooter() } func (m *Model) removeTyper(userID discord.UserID) { m.typersMu.Lock() if typer, ok := m.typers[userID]; ok { typer.Stop() delete(m.typers, userID) } m.typersMu.Unlock() m.updateFooter() } func (m *Model) updateFooter() { selectedChannel := m.SelectedChannel() if selectedChannel == nil { return } guildID := selectedChannel.GuildID m.typersMu.RLock() defer m.typersMu.RUnlock() var footer string if len(m.typers) > 0 { var names []string for userID := range m.typers { var name string if guildID.IsValid() { member, err := m.state.Cabinet.Member(guildID, userID) if err != nil { slog.Error("failed to get member from state", "err", err, "guild_id", guildID, "user_id", userID) continue } if member.Nick != "" { name = member.Nick } else { name = member.User.DisplayOrUsername() } } else { for _, recipient := range selectedChannel.DMRecipients { if recipient.ID == userID { name = recipient.DisplayOrUsername() break } } } if name != "" { names = append(names, name) } } switch len(names) { case 1: footer = names[0] + " is typing..." case 2: footer = fmt.Sprintf("%s and %s are typing...", names[0], names[1]) case 3: footer = fmt.Sprintf("%s, %s, and %s are typing...", names[0], names[1], names[2]) default: footer = "Several people are typing..." } } go m.app.QueueUpdateDraw(func() { m.messagesList.SetFooter(footer) }) }