| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172 |
- package chat
- import (
- "context"
- "errors"
- "io"
- "log/slog"
- "net/http"
- "os"
- "path/filepath"
- "slices"
- "strings"
- "sync"
- "time"
- "unicode/utf8"
- "github.com/ayn2op/tview/layers"
- "github.com/ayn2op/discordo/internal/clipboard"
- "github.com/ayn2op/discordo/internal/config"
- "github.com/ayn2op/discordo/internal/consts"
- "github.com/ayn2op/discordo/internal/markdown"
- "github.com/ayn2op/discordo/internal/ui"
- "github.com/ayn2op/tview"
- "github.com/ayn2op/tview/help"
- "github.com/ayn2op/tview/keybind"
- "github.com/diamondburned/arikawa/v3/api"
- "github.com/diamondburned/arikawa/v3/discord"
- "github.com/diamondburned/arikawa/v3/gateway"
- "github.com/diamondburned/arikawa/v3/state"
- "github.com/diamondburned/arikawa/v3/utils/json/option"
- "github.com/diamondburned/ningen/v3/discordmd"
- "github.com/gdamore/tcell/v3"
- "github.com/gdamore/tcell/v3/color"
- "github.com/skratchdot/open-golang/open"
- "github.com/yuin/goldmark/ast"
- "github.com/yuin/goldmark/parser"
- "github.com/yuin/goldmark/text"
- )
- type messagesList struct {
- *tview.List
- cfg *config.Config
- chatView *View
- messages []discord.Message
- // rows is the virtual list model rendered by tview (message rows +
- // date-separator rows). It is rebuilt lazily when rowsDirty is true.
- rows []messagesListRow
- rowsDirty bool
- renderer *markdown.Renderer
- // itemByID caches unselected message TextViews.
- itemByID map[discord.MessageID]*tview.TextView
- fetchingMembers struct {
- mu sync.Mutex
- value bool
- count uint
- done chan struct{}
- }
- }
- var _ help.KeyMap = (*messagesList)(nil)
- type messagesListRowKind uint8
- const (
- messagesListRowMessage messagesListRowKind = iota
- messagesListRowSeparator
- )
- type messagesListRow struct {
- kind messagesListRowKind
- messageIndex int
- timestamp discord.Timestamp
- }
- func newMessagesList(cfg *config.Config, chatView *View) *messagesList {
- ml := &messagesList{
- List: tview.NewList(),
- cfg: cfg,
- chatView: chatView,
- renderer: markdown.NewRenderer(cfg),
- itemByID: make(map[discord.MessageID]*tview.TextView),
- }
- ml.Box = ui.ConfigureBox(ml.Box, &cfg.Theme)
- ml.SetTitle("Messages")
- ml.SetBuilder(ml.buildItem)
- ml.SetChangedFunc(ml.onRowCursorChanged)
- ml.SetTrackEnd(true)
- ml.SetScrollBarVisibility(cfg.Theme.ScrollBar.Visibility.ScrollBarVisibility)
- ml.SetScrollBar(tview.NewScrollBar().
- SetTrackStyle(cfg.Theme.ScrollBar.TrackStyle.Style).
- SetThumbStyle(cfg.Theme.ScrollBar.ThumbStyle.Style).
- SetGlyphSet(cfg.Theme.ScrollBar.GlyphSet.GlyphSet))
- ml.SetInputCapture(ml.onInputCapture)
- return ml
- }
- func (ml *messagesList) reset() {
- ml.messages = nil
- ml.rows = nil
- ml.rowsDirty = false
- clear(ml.itemByID)
- ml.
- Clear().
- SetBuilder(ml.buildItem).
- SetTitle("")
- }
- func (ml *messagesList) setTitle(channel discord.Channel) {
- title := ui.ChannelToString(channel, ml.cfg.Icons)
- if topic := channel.Topic; topic != "" {
- title += " - " + topic
- }
- ml.SetTitle(title)
- }
- func (ml *messagesList) setMessages(messages []discord.Message) {
- ml.messages = slices.Clone(messages)
- slices.Reverse(ml.messages)
- ml.invalidateRows()
- // New channel payload / refetch: replace the cache wholesale to keep it in
- // lockstep with the current message slice.
- clear(ml.itemByID)
- ml.MarkDirty()
- }
- func (ml *messagesList) addMessage(message discord.Message) {
- ml.messages = append(ml.messages, message)
- ml.invalidateRows()
- // Defensive invalidation for ID reuse/edits delivered out-of-order.
- delete(ml.itemByID, message.ID)
- ml.MarkDirty()
- }
- func (ml *messagesList) setMessage(index int, message discord.Message) {
- if index < 0 || index >= len(ml.messages) {
- return
- }
- ml.messages[index] = message
- delete(ml.itemByID, message.ID)
- ml.invalidateRows()
- ml.MarkDirty()
- }
- func (ml *messagesList) deleteMessage(index int) {
- if index < 0 || index >= len(ml.messages) {
- return
- }
- delete(ml.itemByID, ml.messages[index].ID)
- ml.messages = append(ml.messages[:index], ml.messages[index+1:]...)
- ml.invalidateRows()
- ml.MarkDirty()
- }
- func (ml *messagesList) clearSelection() {
- ml.SetCursor(-1)
- }
- func (ml *messagesList) buildItem(index int, cursor int) tview.ListItem {
- ml.ensureRows()
- if index < 0 || index >= len(ml.rows) {
- return nil
- }
- row := ml.rows[index]
- if row.kind == messagesListRowSeparator {
- return ml.buildSeparatorItem(row.timestamp)
- }
- message := ml.messages[row.messageIndex]
- if index == cursor {
- return tview.NewTextView().
- SetWrap(true).
- SetWordWrap(true).
- SetLines(ml.renderMessage(message, ml.cfg.Theme.MessagesList.SelectedMessageStyle.Style))
- }
- item, ok := ml.itemByID[message.ID]
- if !ok {
- item = tview.NewTextView().
- SetWrap(true).
- SetWordWrap(true).
- SetLines(ml.renderMessage(message, ml.cfg.Theme.MessagesList.MessageStyle.Style))
- ml.itemByID[message.ID] = item
- }
- return item
- }
- func (ml *messagesList) renderMessage(message discord.Message, baseStyle tcell.Style) []tview.Line {
- builder := tview.NewLineBuilder()
- ml.writeMessage(builder, message, baseStyle)
- return builder.Finish()
- }
- func (ml *messagesList) buildSeparatorItem(ts discord.Timestamp) *tview.TextView {
- builder := tview.NewLineBuilder()
- ml.drawDateSeparator(builder, ts, ml.cfg.Theme.MessagesList.MessageStyle.Style)
- return tview.NewTextView().
- SetScrollable(false).
- SetWrap(false).
- SetWordWrap(false).
- SetLines(builder.Finish())
- }
- func (ml *messagesList) drawDateSeparator(builder *tview.LineBuilder, ts discord.Timestamp, baseStyle tcell.Style) {
- date := ts.Time().In(time.Local).Format(ml.cfg.DateSeparator.Format)
- label := " " + date + " "
- fillChar := ml.cfg.DateSeparator.Character
- dimStyle := baseStyle.Dim(true)
- _, _, width, _ := ml.GetInnerRect()
- if width <= 0 {
- builder.Write(strings.Repeat(fillChar, 8)+label+strings.Repeat(fillChar, 8), dimStyle)
- return
- }
- labelWidth := utf8.RuneCountInString(label)
- if width <= labelWidth {
- builder.Write(date, dimStyle)
- return
- }
- fillWidth := width - labelWidth
- left := fillWidth / 2
- right := fillWidth - left
- builder.Write(strings.Repeat(fillChar, left)+label+strings.Repeat(fillChar, right), dimStyle)
- }
- func (ml *messagesList) rebuildRows() {
- rows := make([]messagesListRow, 0, len(ml.messages)*2)
- for i := range ml.messages {
- if ml.cfg.DateSeparator.Enabled && i > 0 && !sameLocalDate(ml.messages[i-1].Timestamp, ml.messages[i].Timestamp) {
- rows = append(rows, messagesListRow{
- kind: messagesListRowSeparator,
- timestamp: ml.messages[i].Timestamp,
- })
- }
- rows = append(rows, messagesListRow{
- kind: messagesListRowMessage,
- messageIndex: i,
- })
- }
- ml.rows = rows
- ml.rowsDirty = false
- }
- func (ml *messagesList) invalidateRows() {
- ml.rowsDirty = true
- }
- // ensureRows lazily rebuilds list rows. This avoids repeated O(n) row rebuild
- // work when multiple message mutations happen close together.
- func (ml *messagesList) ensureRows() {
- if !ml.rowsDirty {
- return
- }
- ml.rebuildRows()
- }
- func sameLocalDate(a discord.Timestamp, b discord.Timestamp) bool {
- ta := a.Time().In(time.Local)
- tb := b.Time().In(time.Local)
- return ta.Year() == tb.Year() && ta.YearDay() == tb.YearDay()
- }
- // Cursor returns the selected message index, skipping separator rows.
- func (ml *messagesList) Cursor() int {
- ml.ensureRows()
- rowIndex := ml.List.Cursor()
- if rowIndex < 0 || rowIndex >= len(ml.rows) {
- return -1
- }
- row := ml.rows[rowIndex]
- if row.kind != messagesListRowMessage {
- return -1
- }
- return row.messageIndex
- }
- // SetCursor selects a message index and maps it to the corresponding row.
- func (ml *messagesList) SetCursor(index int) {
- ml.List.SetCursor(ml.messageToRowIndex(index))
- }
- func (ml *messagesList) messageToRowIndex(messageIndex int) int {
- ml.ensureRows()
- if messageIndex < 0 || messageIndex >= len(ml.messages) {
- return -1
- }
- for i, row := range ml.rows {
- if row.kind == messagesListRowMessage && row.messageIndex == messageIndex {
- return i
- }
- }
- return -1
- }
- func (ml *messagesList) onRowCursorChanged(rowIndex int) {
- ml.ensureRows()
- if rowIndex < 0 || rowIndex >= len(ml.rows) || ml.rows[rowIndex].kind == messagesListRowMessage {
- return
- }
- target := ml.nearestMessageRowIndex(rowIndex)
- ml.List.SetCursor(target)
- }
- // nearestMessageRowIndex expects rowIndex to be within bounds.
- func (ml *messagesList) nearestMessageRowIndex(rowIndex int) int {
- for i := rowIndex - 1; i >= 0; i-- {
- if ml.rows[i].kind == messagesListRowMessage {
- return i
- }
- }
- for i := rowIndex + 1; i < len(ml.rows); i++ {
- if ml.rows[i].kind == messagesListRowMessage {
- return i
- }
- }
- return -1
- }
- func (ml *messagesList) writeMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- if ml.cfg.HideBlockedUsers {
- isBlocked := ml.chatView.state.UserIsBlocked(message.Author.ID)
- if isBlocked {
- builder.Write("Blocked message", baseStyle.Foreground(color.Red).Bold(true))
- return
- }
- }
- switch message.Type {
- case discord.DefaultMessage:
- if message.Reference != nil && message.Reference.Type == discord.MessageReferenceTypeForward {
- ml.drawForwardedMessage(builder, message, baseStyle)
- } else {
- ml.drawDefaultMessage(builder, message, baseStyle)
- }
- case discord.GuildMemberJoinMessage:
- ml.drawTimestamps(builder, message.Timestamp, baseStyle)
- ml.drawAuthor(builder, message, baseStyle)
- builder.Write("joined the server.", baseStyle)
- case discord.InlinedReplyMessage:
- ml.drawReplyMessage(builder, message, baseStyle)
- case discord.ChannelPinnedMessage:
- ml.drawPinnedMessage(builder, message, baseStyle)
- default:
- ml.drawTimestamps(builder, message.Timestamp, baseStyle)
- ml.drawAuthor(builder, message, baseStyle)
- }
- }
- func (ml *messagesList) formatTimestamp(ts discord.Timestamp) string {
- return ts.Time().In(time.Local).Format(ml.cfg.Timestamps.Format)
- }
- func (ml *messagesList) drawTimestamps(builder *tview.LineBuilder, ts discord.Timestamp, baseStyle tcell.Style) {
- dimStyle := baseStyle.Dim(true)
- builder.Write(ml.formatTimestamp(ts)+" ", dimStyle)
- }
- func (ml *messagesList) drawAuthor(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- name := message.Author.DisplayOrUsername()
- foreground := tcell.ColorDefault
- if member := ml.memberForMessage(message); member != nil {
- if member.Nick != "" {
- name = member.Nick
- }
- color, ok := state.MemberColor(member, func(id discord.RoleID) *discord.Role {
- r, _ := ml.chatView.state.Cabinet.Role(message.GuildID, id)
- return r
- })
- if ok {
- foreground = tcell.NewHexColor(int32(color))
- }
- }
- style := baseStyle.Foreground(foreground).Bold(true)
- builder.Write(name+" ", style)
- }
- func (ml *messagesList) memberForMessage(message discord.Message) *discord.Member {
- // Webhooks do not have nicknames or roles.
- if !message.GuildID.IsValid() || message.WebhookID.IsValid() {
- return nil
- }
- member, err := ml.chatView.state.Cabinet.Member(message.GuildID, message.Author.ID)
- if err != nil {
- slog.Error("failed to get member from state", "guild_id", message.GuildID, "member_id", message.Author.ID, "err", err)
- return nil
- }
- return member
- }
- func (ml *messagesList) drawContent(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- c := []byte(message.Content)
- if ml.chatView.cfg.Markdown.Enabled {
- root := discordmd.ParseWithMessage(c, *ml.chatView.state.Cabinet, &message, false)
- lines := ml.renderer.RenderLines(c, root, baseStyle)
- if builder.HasCurrentLine() {
- startsWithCodeBlock := false
- if first := root.FirstChild(); first != nil {
- _, startsWithCodeBlock = first.(*ast.FencedCodeBlock)
- }
- if startsWithCodeBlock {
- // Keep code blocks visually separate from "timestamp + author".
- builder.NewLine()
- for len(lines) > 0 && len(lines[0]) == 0 {
- lines = lines[1:]
- }
- } else {
- for len(lines) > 1 && len(lines[0]) == 0 {
- lines = lines[1:]
- }
- }
- }
- builder.AppendLines(lines)
- } else {
- builder.Write(message.Content, baseStyle)
- }
- }
- func (ml *messagesList) drawSnapshotContent(builder *tview.LineBuilder, parent discord.Message, snapshot discord.MessageSnapshotMessage, baseStyle tcell.Style) {
- // Convert discord.MessageSnapshotMessage to discord.Message with common fields.
- message := discord.Message{
- Type: snapshot.Type,
- Content: snapshot.Content,
- Embeds: snapshot.Embeds,
- Attachments: snapshot.Attachments,
- Timestamp: snapshot.Timestamp,
- EditedTimestamp: snapshot.EditedTimestamp,
- Flags: snapshot.Flags,
- Mentions: snapshot.Mentions,
- MentionRoleIDs: snapshot.MentionRoleIDs,
- Stickers: snapshot.Stickers,
- Components: snapshot.Components,
- ChannelID: parent.ChannelID,
- GuildID: parent.GuildID,
- }
- ml.drawContent(builder, message, baseStyle)
- }
- func (ml *messagesList) drawDefaultMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- if ml.cfg.Timestamps.Enabled {
- ml.drawTimestamps(builder, message.Timestamp, baseStyle)
- }
- ml.drawAuthor(builder, message, baseStyle)
- ml.drawContent(builder, message, baseStyle)
- if message.EditedTimestamp.IsValid() {
- dimStyle := baseStyle.Dim(true)
- builder.Write(" (edited)", dimStyle)
- }
- attachmentStyle := ui.MergeStyle(baseStyle, ml.cfg.Theme.MessagesList.AttachmentStyle.Style)
- for _, a := range message.Attachments {
- builder.NewLine()
- if ml.cfg.ShowAttachmentLinks {
- builder.Write(a.Filename+":\n"+a.URL, attachmentStyle)
- } else {
- builder.Write(a.Filename, attachmentStyle)
- }
- }
- }
- func (ml *messagesList) drawForwardedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- dimStyle := baseStyle.Dim(true)
- ml.drawTimestamps(builder, message.Timestamp, baseStyle)
- ml.drawAuthor(builder, message, baseStyle)
- builder.Write(ml.cfg.Theme.MessagesList.ForwardedIndicator+" ", dimStyle)
- ml.drawSnapshotContent(builder, message, message.MessageSnapshots[0].Message, baseStyle)
- builder.Write(" ("+ml.formatTimestamp(message.MessageSnapshots[0].Message.Timestamp)+") ", dimStyle)
- }
- func (ml *messagesList) drawReplyMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- dimStyle := baseStyle.Dim(true)
- // indicator
- builder.Write(ml.cfg.Theme.MessagesList.ReplyIndicator+" ", dimStyle)
- if m := message.ReferencedMessage; m != nil {
- m.GuildID = message.GuildID
- ml.drawAuthor(builder, *m, dimStyle)
- ml.drawContent(builder, *m, dimStyle)
- } else {
- builder.Write("Original message was deleted", dimStyle)
- }
- builder.NewLine()
- // main
- ml.drawDefaultMessage(builder, message, baseStyle)
- }
- func (ml *messagesList) drawPinnedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
- builder.Write(message.Author.DisplayOrUsername(), baseStyle)
- builder.Write(" pinned a message.", baseStyle)
- }
- func (ml *messagesList) selectedMessage() (*discord.Message, error) {
- if len(ml.messages) == 0 {
- return nil, errors.New("no messages available")
- }
- cursor := ml.Cursor()
- if cursor == -1 || cursor >= len(ml.messages) {
- return nil, errors.New("no message is currently selected")
- }
- return &ml.messages[cursor], nil
- }
- func (ml *messagesList) onInputCapture(event *tcell.EventKey) *tcell.EventKey {
- switch {
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollUp.Keybind):
- ml.ScrollUp()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollDown.Keybind):
- ml.ScrollDown()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollTop.Keybind):
- ml.ScrollToStart()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollBottom.Keybind):
- ml.ScrollToEnd()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Cancel.Keybind):
- ml.clearSelection()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectUp.Keybind):
- ml.selectUp()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectDown.Keybind):
- ml.selectDown()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectTop.Keybind):
- ml.selectTop()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectBottom.Keybind):
- ml.selectBottom()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectReply.Keybind):
- ml.selectReply()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankID.Keybind):
- ml.yankID()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankContent.Keybind):
- ml.yankContent()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankURL.Keybind):
- ml.yankURL()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Open.Keybind):
- ml.open()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Reply.Keybind):
- ml.reply(false)
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ReplyMention.Keybind):
- ml.reply(true)
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Edit.Keybind):
- ml.edit()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Delete.Keybind):
- ml.delete()
- return nil
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.DeleteConfirm.Keybind):
- ml.confirmDelete()
- return nil
- }
- return event
- }
- func (ml *messagesList) selectUp() {
- messages := ml.messages
- if len(messages) == 0 {
- return
- }
- cursor := ml.Cursor()
- switch {
- case cursor == -1:
- cursor = len(messages) - 1
- case cursor > 0:
- cursor--
- case cursor == 0:
- added := ml.prependOlderMessages()
- if added == 0 {
- return
- }
- cursor = added - 1
- }
- ml.SetCursor(cursor)
- }
- func (ml *messagesList) selectDown() {
- messages := ml.messages
- if len(messages) == 0 {
- return
- }
- cursor := ml.Cursor()
- switch {
- case cursor == -1:
- cursor = len(messages) - 1
- case cursor < len(messages)-1:
- cursor++
- }
- ml.SetCursor(cursor)
- }
- func (ml *messagesList) selectTop() {
- if len(ml.messages) == 0 {
- return
- }
- ml.SetCursor(0)
- }
- func (ml *messagesList) selectBottom() {
- if len(ml.messages) == 0 {
- return
- }
- ml.SetCursor(len(ml.messages) - 1)
- }
- func (ml *messagesList) selectReply() {
- messages := ml.messages
- if len(messages) == 0 {
- return
- }
- cursor := ml.Cursor()
- if cursor == -1 || cursor >= len(messages) {
- return
- }
- if ref := messages[cursor].ReferencedMessage; ref != nil {
- refIdx := slices.IndexFunc(messages, func(m discord.Message) bool {
- return m.ID == ref.ID
- })
- if refIdx != -1 {
- ml.SetCursor(refIdx)
- }
- }
- }
- func (ml *messagesList) prependOlderMessages() int {
- selectedChannel := ml.chatView.SelectedChannel()
- if selectedChannel == nil {
- return 0
- }
- channelID := selectedChannel.ID
- before := ml.messages[0].ID
- limit := uint(ml.cfg.MessagesLimit)
- messages, err := ml.chatView.state.MessagesBefore(channelID, before, limit)
- if err != nil {
- slog.Error("failed to fetch older messages", "err", err)
- return 0
- }
- if len(messages) == 0 {
- return 0
- }
- if guildID := selectedChannel.GuildID; guildID.IsValid() {
- ml.requestGuildMembers(guildID, messages)
- }
- older := slices.Clone(messages)
- slices.Reverse(older)
- // Defensive invalidation if Discord returns overlapping windows.
- for _, message := range older {
- delete(ml.itemByID, message.ID)
- }
- ml.messages = slices.Concat(older, ml.messages)
- ml.invalidateRows()
- ml.MarkDirty()
- return len(messages)
- }
- func (ml *messagesList) yankID() {
- msg, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- go clipboard.Write(clipboard.FmtText, []byte(msg.ID.String()))
- }
- func (ml *messagesList) yankContent() {
- msg, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- go clipboard.Write(clipboard.FmtText, []byte(msg.Content))
- }
- func (ml *messagesList) yankURL() {
- msg, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- go clipboard.Write(clipboard.FmtText, []byte(msg.URL()))
- }
- func (ml *messagesList) open() {
- msg, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- var urls []string
- if msg.Content != "" {
- urls = extractURLs(msg.Content)
- }
- if len(urls) == 0 && len(msg.Attachments) == 0 {
- return
- }
- if len(urls)+len(msg.Attachments) == 1 {
- if len(urls) == 1 {
- go ml.openURL(urls[0])
- } else {
- attachment := msg.Attachments[0]
- if strings.HasPrefix(attachment.ContentType, "image/") {
- go ml.openAttachment(msg.Attachments[0])
- } else {
- go ml.openURL(attachment.URL)
- }
- }
- } else {
- ml.showAttachmentsList(urls, msg.Attachments)
- }
- }
- func extractURLs(content string) []string {
- src := []byte(content)
- node := parser.NewParser(
- parser.WithBlockParsers(discordmd.BlockParsers()...),
- parser.WithInlineParsers(discordmd.InlineParserWithLink()...),
- ).Parse(text.NewReader(src))
- var urls []string
- ast.Walk(node, func(n ast.Node, entering bool) (ast.WalkStatus, error) {
- if entering {
- switch n := n.(type) {
- case *ast.AutoLink:
- urls = append(urls, string(n.URL(src)))
- case *ast.Link:
- urls = append(urls, string(n.Destination))
- }
- }
- return ast.WalkContinue, nil
- })
- return urls
- }
- func (ml *messagesList) showAttachmentsList(urls []string, attachments []discord.Attachment) {
- type attachmentAction struct {
- label string
- shortcut rune
- open func()
- }
- closeList := func() {
- ml.chatView.RemoveLayer(attachmentsListLayerName)
- ml.chatView.app.SetFocus(ml)
- }
- var actions []attachmentAction
- for i, a := range attachments {
- attachment := a
- action := func() {
- if strings.HasPrefix(attachment.ContentType, "image/") {
- go ml.openAttachment(attachment)
- } else {
- go ml.openURL(attachment.URL)
- }
- }
- actions = append(actions, attachmentAction{
- label: attachment.Filename,
- shortcut: rune('a' + i),
- open: action,
- })
- }
- for i, u := range urls {
- url := u
- actions = append(actions, attachmentAction{
- label: url,
- shortcut: rune('1' + i),
- open: func() { go ml.openURL(url) },
- })
- }
- normalItems := make([]*tview.TextView, len(actions))
- selectedItems := make([]*tview.TextView, len(actions))
- for i, action := range actions {
- normalItems[i] = tview.NewTextView().
- SetScrollable(false).
- SetWrap(false).
- SetWordWrap(false).
- SetLines([]tview.Line{{{Text: action.label, Style: tcell.StyleDefault}}})
- selectedItems[i] = tview.NewTextView().
- SetScrollable(false).
- SetWrap(false).
- SetWordWrap(false).
- SetLines([]tview.Line{{{Text: action.label, Style: tcell.StyleDefault.Reverse(true)}}})
- }
- list := tview.NewList().
- SetSnapToItems(true).
- SetBuilder(func(index int, cursor int) tview.ListItem {
- if index < 0 || index >= len(actions) {
- return nil
- }
- if index == cursor {
- return selectedItems[index]
- }
- return normalItems[index]
- })
- list.Box = ui.ConfigureBox(list.Box, &ml.cfg.Theme)
- if len(actions) > 0 {
- list.SetCursor(0)
- }
- list.SetInputCapture(func(event *tcell.EventKey) *tcell.EventKey {
- switch {
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectUp.Keybind):
- return tcell.NewEventKey(tcell.KeyUp, "", tcell.ModNone)
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectDown.Keybind):
- return tcell.NewEventKey(tcell.KeyDown, "", tcell.ModNone)
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectTop.Keybind):
- return tcell.NewEventKey(tcell.KeyHome, "", tcell.ModNone)
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectBottom.Keybind):
- return tcell.NewEventKey(tcell.KeyEnd, "", tcell.ModNone)
- case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Cancel.Keybind):
- closeList()
- return nil
- }
- if event.Key() == tcell.KeyEnter || event.Key() == tcell.KeyRune && event.Str() == " " {
- index := list.Cursor()
- if index >= 0 && index < len(actions) {
- actions[index].open()
- closeList()
- }
- return nil
- }
- if event.Key() == tcell.KeyRune {
- key := event.Str()
- if key == "" {
- return event
- }
- ch := []rune(key)[0]
- for index, action := range actions {
- if action.shortcut == ch {
- list.SetCursor(index)
- actions[index].open()
- closeList()
- return nil
- }
- }
- }
- return event
- })
- ml.chatView.
- AddLayer(
- ui.Centered(list, 0, 0),
- layers.WithName(attachmentsListLayerName),
- layers.WithResize(true),
- layers.WithVisible(true),
- layers.WithOverlay(),
- ).
- SendToFront(attachmentsListLayerName)
- }
- func (ml *messagesList) openAttachment(attachment discord.Attachment) {
- resp, err := http.Get(attachment.URL)
- if err != nil {
- slog.Error("failed to fetch the attachment", "err", err, "url", attachment.URL)
- return
- }
- defer resp.Body.Close()
- path := filepath.Join(consts.CacheDir(), "attachments")
- if err := os.MkdirAll(path, os.ModePerm); err != nil {
- slog.Error("failed to create attachments dir", "err", err, "path", path)
- return
- }
- path = filepath.Join(path, attachment.Filename)
- file, err := os.Create(path)
- if err != nil {
- slog.Error("failed to create attachment file", "err", err, "path", path)
- return
- }
- defer file.Close()
- if _, err := io.Copy(file, resp.Body); err != nil {
- slog.Error("failed to copy attachment to file", "err", err)
- return
- }
- if err := open.Start(path); err != nil {
- slog.Error("failed to open attachment file", "err", err, "path", path)
- return
- }
- }
- func (ml *messagesList) openURL(url string) {
- if err := open.Start(url); err != nil {
- slog.Error("failed to open URL", "err", err, "url", url)
- }
- }
- func (ml *messagesList) reply(mention bool) {
- message, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- name := message.Author.DisplayOrUsername()
- if member := ml.memberForMessage(*message); member != nil && member.Nick != "" {
- name = member.Nick
- }
- data := ml.chatView.messageInput.sendMessageData
- data.Reference = &discord.MessageReference{MessageID: message.ID}
- data.AllowedMentions = &api.AllowedMentions{RepliedUser: option.False}
- title := "Replying to "
- if mention {
- data.AllowedMentions.RepliedUser = option.True
- title = "[@] " + title
- }
- ml.chatView.messageInput.sendMessageData = data
- ml.chatView.messageInput.SetTitle(title + name)
- ml.chatView.app.SetFocus(ml.chatView.messageInput)
- }
- func (ml *messagesList) edit() {
- message, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- me, _ := ml.chatView.state.Cabinet.Me()
- if message.Author.ID != me.ID {
- slog.Error("failed to edit message; not the author", "channel_id", message.ChannelID, "message_id", message.ID)
- return
- }
- ml.chatView.messageInput.SetTitle("Editing")
- ml.chatView.messageInput.edit = true
- ml.chatView.messageInput.SetText(message.Content, true)
- ml.chatView.app.SetFocus(ml.chatView.messageInput)
- }
- func (ml *messagesList) confirmDelete() {
- onChoice := func(choice string) {
- if choice == "Yes" {
- ml.delete()
- }
- }
- ml.chatView.showConfirmModal(
- "Are you sure you want to delete this message?",
- []string{"Yes", "No"},
- onChoice,
- )
- }
- func (ml *messagesList) delete() {
- msg, err := ml.selectedMessage()
- if err != nil {
- slog.Error("failed to get selected message", "err", err)
- return
- }
- if msg.GuildID.IsValid() {
- me, _ := ml.chatView.state.Cabinet.Me()
- if msg.Author.ID != me.ID && !ml.chatView.state.HasPermissions(msg.ChannelID, discord.PermissionManageMessages) {
- slog.Error("failed to delete message; missing relevant permissions", "channel_id", msg.ChannelID, "message_id", msg.ID)
- return
- }
- }
- selected := ml.chatView.SelectedChannel()
- if selected == nil {
- return
- }
- if err := ml.chatView.state.DeleteMessage(selected.ID, msg.ID, ""); err != nil {
- slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
- return
- }
- if err := ml.chatView.state.MessageRemove(selected.ID, msg.ID); err != nil {
- slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
- return
- }
- }
- func (ml *messagesList) requestGuildMembers(guildID discord.GuildID, messages []discord.Message) {
- usersToFetch := make([]discord.UserID, 0, len(messages))
- seen := make(map[discord.UserID]struct{}, len(messages))
- for _, message := range messages {
- // Do not fetch member for a webhook message.
- if message.WebhookID.IsValid() {
- continue
- }
- if member, _ := ml.chatView.state.Cabinet.Member(guildID, message.Author.ID); member == nil {
- userID := message.Author.ID
- if _, ok := seen[userID]; !ok {
- seen[userID] = struct{}{}
- usersToFetch = append(usersToFetch, userID)
- }
- }
- }
- if len(usersToFetch) > 0 {
- err := ml.chatView.state.SendGateway(context.TODO(), &gateway.RequestGuildMembersCommand{
- GuildIDs: []discord.GuildID{guildID},
- UserIDs: usersToFetch,
- })
- if err != nil {
- slog.Error("failed to request guild members", "guild_id", guildID, "err", err)
- return
- }
- ml.setFetchingChunk(true, 0)
- ml.waitForChunkEvent()
- }
- }
- func (ml *messagesList) setFetchingChunk(value bool, count uint) {
- ml.fetchingMembers.mu.Lock()
- defer ml.fetchingMembers.mu.Unlock()
- if ml.fetchingMembers.value == value {
- return
- }
- ml.fetchingMembers.value = value
- if value {
- ml.fetchingMembers.done = make(chan struct{})
- } else {
- ml.fetchingMembers.count = count
- close(ml.fetchingMembers.done)
- }
- }
- func (ml *messagesList) waitForChunkEvent() uint {
- ml.fetchingMembers.mu.Lock()
- if !ml.fetchingMembers.value {
- ml.fetchingMembers.mu.Unlock()
- return 0
- }
- ml.fetchingMembers.mu.Unlock()
- <-ml.fetchingMembers.done
- return ml.fetchingMembers.count
- }
- func (ml *messagesList) ShortHelp() []keybind.Keybind {
- cfg := ml.cfg.Keybinds.MessagesList
- help := []keybind.Keybind{
- cfg.SelectUp.Keybind,
- cfg.SelectDown.Keybind,
- cfg.Cancel.Keybind,
- }
- if msg, err := ml.selectedMessage(); err == nil {
- me, _ := ml.chatView.state.Cabinet.Me()
- if msg.Author.ID != me.ID {
- help = append(help, cfg.Reply.Keybind)
- }
- }
- return help
- }
- func (ml *messagesList) FullHelp() [][]keybind.Keybind {
- cfg := ml.cfg.Keybinds.MessagesList
- canSelectReply := false
- canReply := false
- canEdit := false
- canDelete := false
- canOpen := false
- if msg, err := ml.selectedMessage(); err == nil {
- canSelectReply = msg.ReferencedMessage != nil
- canOpen = len(extractURLs(msg.Content)) != 0 || len(msg.Attachments) != 0
- me, _ := ml.chatView.state.Cabinet.Me()
- canReply = msg.Author.ID != me.ID
- canEdit = msg.Author.ID == me.ID
- canDelete = canEdit
- if !canDelete {
- selected := ml.chatView.SelectedChannel()
- canDelete = selected != nil && ml.chatView.state.HasPermissions(selected.ID, discord.PermissionManageMessages)
- }
- }
- actions := make([]keybind.Keybind, 0, 4)
- if canReply {
- actions = append(actions, cfg.Reply.Keybind, cfg.ReplyMention.Keybind)
- }
- if canSelectReply {
- actions = append(actions, cfg.SelectReply.Keybind)
- }
- actions = append(actions, cfg.Cancel.Keybind)
- manage := make([]keybind.Keybind, 0, 4)
- if canEdit {
- manage = append(manage, cfg.Edit.Keybind)
- }
- if canDelete {
- manage = append(manage, cfg.DeleteConfirm.Keybind, cfg.Delete.Keybind)
- }
- if canOpen {
- manage = append(manage, cfg.Open.Keybind)
- }
- return [][]keybind.Keybind{
- {cfg.SelectUp.Keybind, cfg.SelectDown.Keybind, cfg.SelectTop.Keybind, cfg.SelectBottom.Keybind},
- {cfg.ScrollUp.Keybind, cfg.ScrollDown.Keybind, cfg.ScrollTop.Keybind, cfg.ScrollBottom.Keybind},
- actions,
- manage,
- {cfg.YankContent.Keybind, cfg.YankURL.Keybind, cfg.YankID.Keybind},
- }
- }
|