messages_list.go 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098
  1. package chat
  2. import (
  3. "context"
  4. "errors"
  5. "io"
  6. "log/slog"
  7. "net/http"
  8. "os"
  9. "path/filepath"
  10. "slices"
  11. "strings"
  12. "sync"
  13. "time"
  14. "unicode/utf8"
  15. "github.com/ayn2op/tview/layers"
  16. "github.com/ayn2op/discordo/internal/clipboard"
  17. "github.com/ayn2op/discordo/internal/config"
  18. "github.com/ayn2op/discordo/internal/consts"
  19. "github.com/ayn2op/discordo/internal/markdown"
  20. "github.com/ayn2op/discordo/internal/ui"
  21. "github.com/ayn2op/tview"
  22. "github.com/ayn2op/tview/help"
  23. "github.com/ayn2op/tview/keybind"
  24. "github.com/diamondburned/arikawa/v3/api"
  25. "github.com/diamondburned/arikawa/v3/discord"
  26. "github.com/diamondburned/arikawa/v3/gateway"
  27. "github.com/diamondburned/arikawa/v3/state"
  28. "github.com/diamondburned/arikawa/v3/utils/json/option"
  29. "github.com/diamondburned/ningen/v3/discordmd"
  30. "github.com/gdamore/tcell/v3"
  31. "github.com/gdamore/tcell/v3/color"
  32. "github.com/skratchdot/open-golang/open"
  33. "github.com/yuin/goldmark/ast"
  34. "github.com/yuin/goldmark/parser"
  35. "github.com/yuin/goldmark/text"
  36. )
  37. type messagesList struct {
  38. *tview.List
  39. cfg *config.Config
  40. chatView *View
  41. messages []discord.Message
  42. // rows is the virtual list model rendered by tview (message rows +
  43. // date-separator rows). It is rebuilt lazily when rowsDirty is true.
  44. rows []messagesListRow
  45. rowsDirty bool
  46. renderer *markdown.Renderer
  47. // itemByID caches unselected message TextViews.
  48. itemByID map[discord.MessageID]*tview.TextView
  49. attachmentsPicker *attachmentsPicker
  50. fetchingMembers struct {
  51. mu sync.Mutex
  52. value bool
  53. count uint
  54. done chan struct{}
  55. }
  56. }
  57. var _ help.KeyMap = (*messagesList)(nil)
  58. type messagesListRowKind uint8
  59. const (
  60. messagesListRowMessage messagesListRowKind = iota
  61. messagesListRowSeparator
  62. )
  63. type messagesListRow struct {
  64. kind messagesListRowKind
  65. messageIndex int
  66. timestamp discord.Timestamp
  67. }
  68. func newMessagesList(cfg *config.Config, chatView *View) *messagesList {
  69. ml := &messagesList{
  70. List: tview.NewList(),
  71. cfg: cfg,
  72. chatView: chatView,
  73. renderer: markdown.NewRenderer(cfg),
  74. itemByID: make(map[discord.MessageID]*tview.TextView),
  75. }
  76. ml.attachmentsPicker = newAttachmentsPicker(cfg, chatView)
  77. ml.Box = ui.ConfigureBox(ml.Box, &cfg.Theme)
  78. ml.SetTitle("Messages")
  79. ml.SetBuilder(ml.buildItem)
  80. ml.SetChangedFunc(ml.onRowCursorChanged)
  81. ml.SetTrackEnd(true)
  82. ml.SetScrollBarVisibility(cfg.Theme.ScrollBar.Visibility.ScrollBarVisibility)
  83. ml.SetScrollBar(tview.NewScrollBar().
  84. SetTrackStyle(cfg.Theme.ScrollBar.TrackStyle.Style).
  85. SetThumbStyle(cfg.Theme.ScrollBar.ThumbStyle.Style).
  86. SetGlyphSet(cfg.Theme.ScrollBar.GlyphSet.GlyphSet))
  87. return ml
  88. }
  89. func (ml *messagesList) reset() {
  90. ml.messages = nil
  91. ml.rows = nil
  92. ml.rowsDirty = false
  93. clear(ml.itemByID)
  94. ml.
  95. Clear().
  96. SetBuilder(ml.buildItem).
  97. SetTitle("")
  98. }
  99. func (ml *messagesList) setTitle(channel discord.Channel) {
  100. title := ui.ChannelToString(channel, ml.cfg.Icons)
  101. if topic := channel.Topic; topic != "" {
  102. title += " - " + topic
  103. }
  104. ml.SetTitle(title)
  105. }
  106. func (ml *messagesList) setMessages(messages []discord.Message) {
  107. ml.messages = slices.Clone(messages)
  108. slices.Reverse(ml.messages)
  109. ml.invalidateRows()
  110. // New channel payload / refetch: replace the cache wholesale to keep it in
  111. // lockstep with the current message slice.
  112. clear(ml.itemByID)
  113. ml.MarkDirty()
  114. }
  115. func (ml *messagesList) addMessage(message discord.Message) {
  116. ml.messages = append(ml.messages, message)
  117. ml.invalidateRows()
  118. // Defensive invalidation for ID reuse/edits delivered out-of-order.
  119. delete(ml.itemByID, message.ID)
  120. ml.MarkDirty()
  121. }
  122. func (ml *messagesList) setMessage(index int, message discord.Message) {
  123. if index < 0 || index >= len(ml.messages) {
  124. return
  125. }
  126. ml.messages[index] = message
  127. delete(ml.itemByID, message.ID)
  128. ml.invalidateRows()
  129. ml.MarkDirty()
  130. }
  131. func (ml *messagesList) deleteMessage(index int) {
  132. if index < 0 || index >= len(ml.messages) {
  133. return
  134. }
  135. delete(ml.itemByID, ml.messages[index].ID)
  136. ml.messages = append(ml.messages[:index], ml.messages[index+1:]...)
  137. ml.invalidateRows()
  138. ml.MarkDirty()
  139. }
  140. func (ml *messagesList) clearSelection() {
  141. ml.SetCursor(-1)
  142. }
  143. func (ml *messagesList) buildItem(index int, cursor int) tview.ListItem {
  144. ml.ensureRows()
  145. if index < 0 || index >= len(ml.rows) {
  146. return nil
  147. }
  148. row := ml.rows[index]
  149. if row.kind == messagesListRowSeparator {
  150. return ml.buildSeparatorItem(row.timestamp)
  151. }
  152. message := ml.messages[row.messageIndex]
  153. if index == cursor {
  154. return tview.NewTextView().
  155. SetWrap(true).
  156. SetWordWrap(true).
  157. SetLines(ml.renderMessage(message, ml.cfg.Theme.MessagesList.SelectedMessageStyle.Style))
  158. }
  159. item, ok := ml.itemByID[message.ID]
  160. if !ok {
  161. item = tview.NewTextView().
  162. SetWrap(true).
  163. SetWordWrap(true).
  164. SetLines(ml.renderMessage(message, ml.cfg.Theme.MessagesList.MessageStyle.Style))
  165. ml.itemByID[message.ID] = item
  166. }
  167. return item
  168. }
  169. func (ml *messagesList) renderMessage(message discord.Message, baseStyle tcell.Style) []tview.Line {
  170. builder := tview.NewLineBuilder()
  171. ml.writeMessage(builder, message, baseStyle)
  172. return builder.Finish()
  173. }
  174. func (ml *messagesList) buildSeparatorItem(ts discord.Timestamp) *tview.TextView {
  175. builder := tview.NewLineBuilder()
  176. ml.drawDateSeparator(builder, ts, ml.cfg.Theme.MessagesList.MessageStyle.Style)
  177. return tview.NewTextView().
  178. SetScrollable(false).
  179. SetWrap(false).
  180. SetWordWrap(false).
  181. SetLines(builder.Finish())
  182. }
  183. func (ml *messagesList) drawDateSeparator(builder *tview.LineBuilder, ts discord.Timestamp, baseStyle tcell.Style) {
  184. date := ts.Time().In(time.Local).Format(ml.cfg.DateSeparator.Format)
  185. label := " " + date + " "
  186. fillChar := ml.cfg.DateSeparator.Character
  187. dimStyle := baseStyle.Dim(true)
  188. _, _, width, _ := ml.GetInnerRect()
  189. if width <= 0 {
  190. builder.Write(strings.Repeat(fillChar, 8)+label+strings.Repeat(fillChar, 8), dimStyle)
  191. return
  192. }
  193. labelWidth := utf8.RuneCountInString(label)
  194. if width <= labelWidth {
  195. builder.Write(date, dimStyle)
  196. return
  197. }
  198. fillWidth := width - labelWidth
  199. left := fillWidth / 2
  200. right := fillWidth - left
  201. builder.Write(strings.Repeat(fillChar, left)+label+strings.Repeat(fillChar, right), dimStyle)
  202. }
  203. func (ml *messagesList) rebuildRows() {
  204. rows := make([]messagesListRow, 0, len(ml.messages)*2)
  205. for i := range ml.messages {
  206. if ml.cfg.DateSeparator.Enabled && i > 0 && !sameLocalDate(ml.messages[i-1].Timestamp, ml.messages[i].Timestamp) {
  207. rows = append(rows, messagesListRow{
  208. kind: messagesListRowSeparator,
  209. timestamp: ml.messages[i].Timestamp,
  210. })
  211. }
  212. rows = append(rows, messagesListRow{
  213. kind: messagesListRowMessage,
  214. messageIndex: i,
  215. })
  216. }
  217. ml.rows = rows
  218. ml.rowsDirty = false
  219. }
  220. func (ml *messagesList) invalidateRows() {
  221. ml.rowsDirty = true
  222. }
  223. // ensureRows lazily rebuilds list rows. This avoids repeated O(n) row rebuild
  224. // work when multiple message mutations happen close together.
  225. func (ml *messagesList) ensureRows() {
  226. if !ml.rowsDirty {
  227. return
  228. }
  229. ml.rebuildRows()
  230. }
  231. func sameLocalDate(a discord.Timestamp, b discord.Timestamp) bool {
  232. ta := a.Time().In(time.Local)
  233. tb := b.Time().In(time.Local)
  234. return ta.Year() == tb.Year() && ta.YearDay() == tb.YearDay()
  235. }
  236. // Cursor returns the selected message index, skipping separator rows.
  237. func (ml *messagesList) Cursor() int {
  238. ml.ensureRows()
  239. rowIndex := ml.List.Cursor()
  240. if rowIndex < 0 || rowIndex >= len(ml.rows) {
  241. return -1
  242. }
  243. row := ml.rows[rowIndex]
  244. if row.kind != messagesListRowMessage {
  245. return -1
  246. }
  247. return row.messageIndex
  248. }
  249. // SetCursor selects a message index and maps it to the corresponding row.
  250. func (ml *messagesList) SetCursor(index int) {
  251. ml.List.SetCursor(ml.messageToRowIndex(index))
  252. }
  253. func (ml *messagesList) messageToRowIndex(messageIndex int) int {
  254. ml.ensureRows()
  255. if messageIndex < 0 || messageIndex >= len(ml.messages) {
  256. return -1
  257. }
  258. for i, row := range ml.rows {
  259. if row.kind == messagesListRowMessage && row.messageIndex == messageIndex {
  260. return i
  261. }
  262. }
  263. return -1
  264. }
  265. func (ml *messagesList) onRowCursorChanged(rowIndex int) {
  266. ml.ensureRows()
  267. if rowIndex < 0 || rowIndex >= len(ml.rows) || ml.rows[rowIndex].kind == messagesListRowMessage {
  268. return
  269. }
  270. target := ml.nearestMessageRowIndex(rowIndex)
  271. ml.List.SetCursor(target)
  272. }
  273. // nearestMessageRowIndex expects rowIndex to be within bounds.
  274. func (ml *messagesList) nearestMessageRowIndex(rowIndex int) int {
  275. for i := rowIndex - 1; i >= 0; i-- {
  276. if ml.rows[i].kind == messagesListRowMessage {
  277. return i
  278. }
  279. }
  280. for i := rowIndex + 1; i < len(ml.rows); i++ {
  281. if ml.rows[i].kind == messagesListRowMessage {
  282. return i
  283. }
  284. }
  285. return -1
  286. }
  287. func (ml *messagesList) writeMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  288. if ml.cfg.HideBlockedUsers {
  289. isBlocked := ml.chatView.state.UserIsBlocked(message.Author.ID)
  290. if isBlocked {
  291. builder.Write("Blocked message", baseStyle.Foreground(color.Red).Bold(true))
  292. return
  293. }
  294. }
  295. switch message.Type {
  296. case discord.DefaultMessage:
  297. if message.Reference != nil && message.Reference.Type == discord.MessageReferenceTypeForward {
  298. ml.drawForwardedMessage(builder, message, baseStyle)
  299. } else {
  300. ml.drawDefaultMessage(builder, message, baseStyle)
  301. }
  302. case discord.GuildMemberJoinMessage:
  303. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  304. ml.drawAuthor(builder, message, baseStyle)
  305. builder.Write("joined the server.", baseStyle)
  306. case discord.InlinedReplyMessage:
  307. ml.drawReplyMessage(builder, message, baseStyle)
  308. case discord.ChannelPinnedMessage:
  309. ml.drawPinnedMessage(builder, message, baseStyle)
  310. default:
  311. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  312. ml.drawAuthor(builder, message, baseStyle)
  313. }
  314. }
  315. func (ml *messagesList) formatTimestamp(ts discord.Timestamp) string {
  316. return ts.Time().In(time.Local).Format(ml.cfg.Timestamps.Format)
  317. }
  318. func (ml *messagesList) drawTimestamps(builder *tview.LineBuilder, ts discord.Timestamp, baseStyle tcell.Style) {
  319. dimStyle := baseStyle.Dim(true)
  320. builder.Write(ml.formatTimestamp(ts)+" ", dimStyle)
  321. }
  322. func (ml *messagesList) drawAuthor(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  323. name := message.Author.DisplayOrUsername()
  324. foreground := tcell.ColorDefault
  325. if member := ml.memberForMessage(message); member != nil {
  326. if member.Nick != "" {
  327. name = member.Nick
  328. }
  329. color, ok := state.MemberColor(member, func(id discord.RoleID) *discord.Role {
  330. r, _ := ml.chatView.state.Cabinet.Role(message.GuildID, id)
  331. return r
  332. })
  333. if ok {
  334. foreground = tcell.NewHexColor(int32(color))
  335. }
  336. }
  337. style := baseStyle.Foreground(foreground).Bold(true)
  338. builder.Write(name+" ", style)
  339. }
  340. func (ml *messagesList) memberForMessage(message discord.Message) *discord.Member {
  341. // Webhooks do not have nicknames or roles.
  342. if !message.GuildID.IsValid() || message.WebhookID.IsValid() {
  343. return nil
  344. }
  345. member, err := ml.chatView.state.Cabinet.Member(message.GuildID, message.Author.ID)
  346. if err != nil {
  347. slog.Error("failed to get member from state", "guild_id", message.GuildID, "member_id", message.Author.ID, "err", err)
  348. return nil
  349. }
  350. return member
  351. }
  352. func (ml *messagesList) drawContent(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  353. c := []byte(message.Content)
  354. if ml.chatView.cfg.Markdown.Enabled {
  355. root := discordmd.ParseWithMessage(c, *ml.chatView.state.Cabinet, &message, false)
  356. lines := ml.renderer.RenderLines(c, root, baseStyle)
  357. if builder.HasCurrentLine() {
  358. startsWithCodeBlock := false
  359. if first := root.FirstChild(); first != nil {
  360. _, startsWithCodeBlock = first.(*ast.FencedCodeBlock)
  361. }
  362. if startsWithCodeBlock {
  363. // Keep code blocks visually separate from "timestamp + author".
  364. builder.NewLine()
  365. for len(lines) > 0 && len(lines[0]) == 0 {
  366. lines = lines[1:]
  367. }
  368. } else {
  369. for len(lines) > 1 && len(lines[0]) == 0 {
  370. lines = lines[1:]
  371. }
  372. }
  373. }
  374. builder.AppendLines(lines)
  375. } else {
  376. builder.Write(message.Content, baseStyle)
  377. }
  378. }
  379. func (ml *messagesList) drawSnapshotContent(builder *tview.LineBuilder, parent discord.Message, snapshot discord.MessageSnapshotMessage, baseStyle tcell.Style) {
  380. // Convert discord.MessageSnapshotMessage to discord.Message with common fields.
  381. message := discord.Message{
  382. Type: snapshot.Type,
  383. Content: snapshot.Content,
  384. Embeds: snapshot.Embeds,
  385. Attachments: snapshot.Attachments,
  386. Timestamp: snapshot.Timestamp,
  387. EditedTimestamp: snapshot.EditedTimestamp,
  388. Flags: snapshot.Flags,
  389. Mentions: snapshot.Mentions,
  390. MentionRoleIDs: snapshot.MentionRoleIDs,
  391. Stickers: snapshot.Stickers,
  392. Components: snapshot.Components,
  393. ChannelID: parent.ChannelID,
  394. GuildID: parent.GuildID,
  395. }
  396. ml.drawContent(builder, message, baseStyle)
  397. }
  398. func (ml *messagesList) drawDefaultMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  399. if ml.cfg.Timestamps.Enabled {
  400. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  401. }
  402. ml.drawAuthor(builder, message, baseStyle)
  403. ml.drawContent(builder, message, baseStyle)
  404. if message.EditedTimestamp.IsValid() {
  405. dimStyle := baseStyle.Dim(true)
  406. builder.Write(" (edited)", dimStyle)
  407. }
  408. attachmentStyle := ui.MergeStyle(baseStyle, ml.cfg.Theme.MessagesList.AttachmentStyle.Style)
  409. for _, a := range message.Attachments {
  410. builder.NewLine()
  411. if ml.cfg.ShowAttachmentLinks {
  412. builder.Write(a.Filename+":\n"+a.URL, attachmentStyle)
  413. } else {
  414. builder.Write(a.Filename, attachmentStyle)
  415. }
  416. }
  417. }
  418. func (ml *messagesList) drawForwardedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  419. dimStyle := baseStyle.Dim(true)
  420. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  421. ml.drawAuthor(builder, message, baseStyle)
  422. builder.Write(ml.cfg.Theme.MessagesList.ForwardedIndicator+" ", dimStyle)
  423. ml.drawSnapshotContent(builder, message, message.MessageSnapshots[0].Message, baseStyle)
  424. builder.Write(" ("+ml.formatTimestamp(message.MessageSnapshots[0].Message.Timestamp)+") ", dimStyle)
  425. }
  426. func (ml *messagesList) drawReplyMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  427. dimStyle := baseStyle.Dim(true)
  428. // indicator
  429. builder.Write(ml.cfg.Theme.MessagesList.ReplyIndicator+" ", dimStyle)
  430. if m := message.ReferencedMessage; m != nil {
  431. m.GuildID = message.GuildID
  432. ml.drawAuthor(builder, *m, dimStyle)
  433. ml.drawContent(builder, *m, dimStyle)
  434. } else {
  435. builder.Write("Original message was deleted", dimStyle)
  436. }
  437. builder.NewLine()
  438. // main
  439. ml.drawDefaultMessage(builder, message, baseStyle)
  440. }
  441. func (ml *messagesList) drawPinnedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  442. builder.Write(message.Author.DisplayOrUsername(), baseStyle)
  443. builder.Write(" pinned a message.", baseStyle)
  444. }
  445. func (ml *messagesList) selectedMessage() (*discord.Message, error) {
  446. if len(ml.messages) == 0 {
  447. return nil, errors.New("no messages available")
  448. }
  449. cursor := ml.Cursor()
  450. if cursor == -1 || cursor >= len(ml.messages) {
  451. return nil, errors.New("no message is currently selected")
  452. }
  453. return &ml.messages[cursor], nil
  454. }
  455. func (ml *messagesList) handleInput(event *tcell.EventKey) *tcell.EventKey {
  456. switch {
  457. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollUp.Keybind):
  458. ml.ScrollUp()
  459. return nil
  460. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollDown.Keybind):
  461. ml.ScrollDown()
  462. return nil
  463. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollTop.Keybind):
  464. ml.ScrollToStart()
  465. return nil
  466. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollBottom.Keybind):
  467. ml.ScrollToEnd()
  468. return nil
  469. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Cancel.Keybind):
  470. ml.clearSelection()
  471. return nil
  472. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectUp.Keybind):
  473. ml.selectUp()
  474. return nil
  475. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectDown.Keybind):
  476. ml.selectDown()
  477. return nil
  478. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectTop.Keybind):
  479. ml.selectTop()
  480. return nil
  481. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectBottom.Keybind):
  482. ml.selectBottom()
  483. return nil
  484. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectReply.Keybind):
  485. ml.selectReply()
  486. return nil
  487. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankID.Keybind):
  488. ml.yankID()
  489. return nil
  490. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankContent.Keybind):
  491. ml.yankContent()
  492. return nil
  493. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankURL.Keybind):
  494. ml.yankURL()
  495. return nil
  496. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Open.Keybind):
  497. ml.open()
  498. return nil
  499. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Reply.Keybind):
  500. ml.reply(false)
  501. return nil
  502. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ReplyMention.Keybind):
  503. ml.reply(true)
  504. return nil
  505. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Edit.Keybind):
  506. ml.edit()
  507. return nil
  508. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Delete.Keybind):
  509. ml.delete()
  510. return nil
  511. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.DeleteConfirm.Keybind):
  512. ml.confirmDelete()
  513. return nil
  514. }
  515. return event
  516. }
  517. func (ml *messagesList) InputHandler(event *tcell.EventKey, setFocus func(p tview.Primitive)) {
  518. event = ml.handleInput(event)
  519. if event == nil {
  520. return
  521. }
  522. ml.List.InputHandler(event, setFocus)
  523. }
  524. func (ml *messagesList) selectUp() {
  525. messages := ml.messages
  526. if len(messages) == 0 {
  527. return
  528. }
  529. cursor := ml.Cursor()
  530. switch {
  531. case cursor == -1:
  532. cursor = len(messages) - 1
  533. case cursor > 0:
  534. cursor--
  535. case cursor == 0:
  536. added := ml.prependOlderMessages()
  537. if added == 0 {
  538. return
  539. }
  540. cursor = added - 1
  541. }
  542. ml.SetCursor(cursor)
  543. }
  544. func (ml *messagesList) selectDown() {
  545. messages := ml.messages
  546. if len(messages) == 0 {
  547. return
  548. }
  549. cursor := ml.Cursor()
  550. switch {
  551. case cursor == -1:
  552. cursor = len(messages) - 1
  553. case cursor < len(messages)-1:
  554. cursor++
  555. }
  556. ml.SetCursor(cursor)
  557. }
  558. func (ml *messagesList) selectTop() {
  559. if len(ml.messages) == 0 {
  560. return
  561. }
  562. ml.SetCursor(0)
  563. }
  564. func (ml *messagesList) selectBottom() {
  565. if len(ml.messages) == 0 {
  566. return
  567. }
  568. ml.SetCursor(len(ml.messages) - 1)
  569. }
  570. func (ml *messagesList) selectReply() {
  571. messages := ml.messages
  572. if len(messages) == 0 {
  573. return
  574. }
  575. cursor := ml.Cursor()
  576. if cursor == -1 || cursor >= len(messages) {
  577. return
  578. }
  579. if ref := messages[cursor].ReferencedMessage; ref != nil {
  580. refIdx := slices.IndexFunc(messages, func(m discord.Message) bool {
  581. return m.ID == ref.ID
  582. })
  583. if refIdx != -1 {
  584. ml.SetCursor(refIdx)
  585. }
  586. }
  587. }
  588. func (ml *messagesList) prependOlderMessages() int {
  589. selectedChannel := ml.chatView.SelectedChannel()
  590. if selectedChannel == nil {
  591. return 0
  592. }
  593. channelID := selectedChannel.ID
  594. before := ml.messages[0].ID
  595. limit := uint(ml.cfg.MessagesLimit)
  596. messages, err := ml.chatView.state.MessagesBefore(channelID, before, limit)
  597. if err != nil {
  598. slog.Error("failed to fetch older messages", "err", err)
  599. return 0
  600. }
  601. if len(messages) == 0 {
  602. return 0
  603. }
  604. if guildID := selectedChannel.GuildID; guildID.IsValid() {
  605. ml.requestGuildMembers(guildID, messages)
  606. }
  607. older := slices.Clone(messages)
  608. slices.Reverse(older)
  609. // Defensive invalidation if Discord returns overlapping windows.
  610. for _, message := range older {
  611. delete(ml.itemByID, message.ID)
  612. }
  613. ml.messages = slices.Concat(older, ml.messages)
  614. ml.invalidateRows()
  615. ml.MarkDirty()
  616. return len(messages)
  617. }
  618. func (ml *messagesList) yankID() {
  619. msg, err := ml.selectedMessage()
  620. if err != nil {
  621. slog.Error("failed to get selected message", "err", err)
  622. return
  623. }
  624. go clipboard.Write(clipboard.FmtText, []byte(msg.ID.String()))
  625. }
  626. func (ml *messagesList) yankContent() {
  627. msg, err := ml.selectedMessage()
  628. if err != nil {
  629. slog.Error("failed to get selected message", "err", err)
  630. return
  631. }
  632. go clipboard.Write(clipboard.FmtText, []byte(msg.Content))
  633. }
  634. func (ml *messagesList) yankURL() {
  635. msg, err := ml.selectedMessage()
  636. if err != nil {
  637. slog.Error("failed to get selected message", "err", err)
  638. return
  639. }
  640. go clipboard.Write(clipboard.FmtText, []byte(msg.URL()))
  641. }
  642. func (ml *messagesList) open() {
  643. msg, err := ml.selectedMessage()
  644. if err != nil {
  645. slog.Error("failed to get selected message", "err", err)
  646. return
  647. }
  648. var urls []string
  649. if msg.Content != "" {
  650. urls = extractURLs(msg.Content)
  651. }
  652. if len(urls) == 0 && len(msg.Attachments) == 0 {
  653. return
  654. }
  655. if len(urls)+len(msg.Attachments) == 1 {
  656. if len(urls) == 1 {
  657. go ml.openURL(urls[0])
  658. } else {
  659. attachment := msg.Attachments[0]
  660. if strings.HasPrefix(attachment.ContentType, "image/") {
  661. go ml.openAttachment(msg.Attachments[0])
  662. } else {
  663. go ml.openURL(attachment.URL)
  664. }
  665. }
  666. } else {
  667. ml.showAttachmentsList(urls, msg.Attachments)
  668. }
  669. }
  670. func extractURLs(content string) []string {
  671. src := []byte(content)
  672. node := parser.NewParser(
  673. parser.WithBlockParsers(discordmd.BlockParsers()...),
  674. parser.WithInlineParsers(discordmd.InlineParserWithLink()...),
  675. ).Parse(text.NewReader(src))
  676. var urls []string
  677. ast.Walk(node, func(n ast.Node, entering bool) (ast.WalkStatus, error) {
  678. if entering {
  679. switch n := n.(type) {
  680. case *ast.AutoLink:
  681. urls = append(urls, string(n.URL(src)))
  682. case *ast.Link:
  683. urls = append(urls, string(n.Destination))
  684. }
  685. }
  686. return ast.WalkContinue, nil
  687. })
  688. return urls
  689. }
  690. func (ml *messagesList) showAttachmentsList(urls []string, attachments []discord.Attachment) {
  691. var items []attachmentItem
  692. for _, a := range attachments {
  693. attachment := a
  694. action := func() {
  695. if strings.HasPrefix(attachment.ContentType, "image/") {
  696. go ml.openAttachment(attachment)
  697. } else {
  698. go ml.openURL(attachment.URL)
  699. }
  700. }
  701. items = append(items, attachmentItem{
  702. label: attachment.Filename,
  703. open: action,
  704. })
  705. }
  706. for _, u := range urls {
  707. url := u
  708. items = append(items, attachmentItem{
  709. label: url,
  710. open: func() { go ml.openURL(url) },
  711. })
  712. }
  713. ml.attachmentsPicker.SetItems(items)
  714. ml.chatView.
  715. AddLayer(
  716. ui.Centered(ml.attachmentsPicker, 0, 0),
  717. layers.WithName(attachmentsListLayerName),
  718. layers.WithResize(true),
  719. layers.WithVisible(true),
  720. layers.WithOverlay(),
  721. ).
  722. SendToFront(attachmentsListLayerName)
  723. ml.chatView.app.SetFocus(ml.attachmentsPicker)
  724. }
  725. func (ml *messagesList) openAttachment(attachment discord.Attachment) {
  726. resp, err := http.Get(attachment.URL)
  727. if err != nil {
  728. slog.Error("failed to fetch the attachment", "err", err, "url", attachment.URL)
  729. return
  730. }
  731. defer resp.Body.Close()
  732. path := filepath.Join(consts.CacheDir(), "attachments")
  733. if err := os.MkdirAll(path, os.ModePerm); err != nil {
  734. slog.Error("failed to create attachments dir", "err", err, "path", path)
  735. return
  736. }
  737. path = filepath.Join(path, attachment.Filename)
  738. file, err := os.Create(path)
  739. if err != nil {
  740. slog.Error("failed to create attachment file", "err", err, "path", path)
  741. return
  742. }
  743. defer file.Close()
  744. if _, err := io.Copy(file, resp.Body); err != nil {
  745. slog.Error("failed to copy attachment to file", "err", err)
  746. return
  747. }
  748. if err := open.Start(path); err != nil {
  749. slog.Error("failed to open attachment file", "err", err, "path", path)
  750. return
  751. }
  752. }
  753. func (ml *messagesList) openURL(url string) {
  754. if err := open.Start(url); err != nil {
  755. slog.Error("failed to open URL", "err", err, "url", url)
  756. }
  757. }
  758. func (ml *messagesList) reply(mention bool) {
  759. message, err := ml.selectedMessage()
  760. if err != nil {
  761. slog.Error("failed to get selected message", "err", err)
  762. return
  763. }
  764. name := message.Author.DisplayOrUsername()
  765. if member := ml.memberForMessage(*message); member != nil && member.Nick != "" {
  766. name = member.Nick
  767. }
  768. data := ml.chatView.messageInput.sendMessageData
  769. data.Reference = &discord.MessageReference{MessageID: message.ID}
  770. data.AllowedMentions = &api.AllowedMentions{RepliedUser: option.False}
  771. title := "Replying to "
  772. if mention {
  773. data.AllowedMentions.RepliedUser = option.True
  774. title = "[@] " + title
  775. }
  776. ml.chatView.messageInput.sendMessageData = data
  777. ml.chatView.messageInput.SetTitle(title + name)
  778. ml.chatView.app.SetFocus(ml.chatView.messageInput)
  779. }
  780. func (ml *messagesList) edit() {
  781. message, err := ml.selectedMessage()
  782. if err != nil {
  783. slog.Error("failed to get selected message", "err", err)
  784. return
  785. }
  786. me, _ := ml.chatView.state.Cabinet.Me()
  787. if message.Author.ID != me.ID {
  788. slog.Error("failed to edit message; not the author", "channel_id", message.ChannelID, "message_id", message.ID)
  789. return
  790. }
  791. ml.chatView.messageInput.SetTitle("Editing")
  792. ml.chatView.messageInput.edit = true
  793. ml.chatView.messageInput.SetText(message.Content, true)
  794. ml.chatView.app.SetFocus(ml.chatView.messageInput)
  795. }
  796. func (ml *messagesList) confirmDelete() {
  797. onChoice := func(choice string) {
  798. if choice == "Yes" {
  799. ml.delete()
  800. }
  801. }
  802. ml.chatView.showConfirmModal(
  803. "Are you sure you want to delete this message?",
  804. []string{"Yes", "No"},
  805. onChoice,
  806. )
  807. }
  808. func (ml *messagesList) delete() {
  809. msg, err := ml.selectedMessage()
  810. if err != nil {
  811. slog.Error("failed to get selected message", "err", err)
  812. return
  813. }
  814. if msg.GuildID.IsValid() {
  815. me, _ := ml.chatView.state.Cabinet.Me()
  816. if msg.Author.ID != me.ID && !ml.chatView.state.HasPermissions(msg.ChannelID, discord.PermissionManageMessages) {
  817. slog.Error("failed to delete message; missing relevant permissions", "channel_id", msg.ChannelID, "message_id", msg.ID)
  818. return
  819. }
  820. }
  821. selected := ml.chatView.SelectedChannel()
  822. if selected == nil {
  823. return
  824. }
  825. if err := ml.chatView.state.DeleteMessage(selected.ID, msg.ID, ""); err != nil {
  826. slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
  827. return
  828. }
  829. if err := ml.chatView.state.MessageRemove(selected.ID, msg.ID); err != nil {
  830. slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
  831. return
  832. }
  833. }
  834. func (ml *messagesList) requestGuildMembers(guildID discord.GuildID, messages []discord.Message) {
  835. usersToFetch := make([]discord.UserID, 0, len(messages))
  836. seen := make(map[discord.UserID]struct{}, len(messages))
  837. for _, message := range messages {
  838. // Do not fetch member for a webhook message.
  839. if message.WebhookID.IsValid() {
  840. continue
  841. }
  842. if member, _ := ml.chatView.state.Cabinet.Member(guildID, message.Author.ID); member == nil {
  843. userID := message.Author.ID
  844. if _, ok := seen[userID]; !ok {
  845. seen[userID] = struct{}{}
  846. usersToFetch = append(usersToFetch, userID)
  847. }
  848. }
  849. }
  850. if len(usersToFetch) > 0 {
  851. err := ml.chatView.state.SendGateway(context.TODO(), &gateway.RequestGuildMembersCommand{
  852. GuildIDs: []discord.GuildID{guildID},
  853. UserIDs: usersToFetch,
  854. })
  855. if err != nil {
  856. slog.Error("failed to request guild members", "guild_id", guildID, "err", err)
  857. return
  858. }
  859. ml.setFetchingChunk(true, 0)
  860. ml.waitForChunkEvent()
  861. }
  862. }
  863. func (ml *messagesList) setFetchingChunk(value bool, count uint) {
  864. ml.fetchingMembers.mu.Lock()
  865. defer ml.fetchingMembers.mu.Unlock()
  866. if ml.fetchingMembers.value == value {
  867. return
  868. }
  869. ml.fetchingMembers.value = value
  870. if value {
  871. ml.fetchingMembers.done = make(chan struct{})
  872. } else {
  873. ml.fetchingMembers.count = count
  874. close(ml.fetchingMembers.done)
  875. }
  876. }
  877. func (ml *messagesList) waitForChunkEvent() uint {
  878. ml.fetchingMembers.mu.Lock()
  879. if !ml.fetchingMembers.value {
  880. ml.fetchingMembers.mu.Unlock()
  881. return 0
  882. }
  883. ml.fetchingMembers.mu.Unlock()
  884. <-ml.fetchingMembers.done
  885. return ml.fetchingMembers.count
  886. }
  887. func (ml *messagesList) ShortHelp() []keybind.Keybind {
  888. cfg := ml.cfg.Keybinds.MessagesList
  889. help := []keybind.Keybind{
  890. cfg.SelectUp.Keybind,
  891. cfg.SelectDown.Keybind,
  892. cfg.Cancel.Keybind,
  893. }
  894. if msg, err := ml.selectedMessage(); err == nil {
  895. me, _ := ml.chatView.state.Cabinet.Me()
  896. if msg.Author.ID != me.ID {
  897. help = append(help, cfg.Reply.Keybind)
  898. }
  899. }
  900. return help
  901. }
  902. func (ml *messagesList) FullHelp() [][]keybind.Keybind {
  903. cfg := ml.cfg.Keybinds.MessagesList
  904. canSelectReply := false
  905. canReply := false
  906. canEdit := false
  907. canDelete := false
  908. canOpen := false
  909. if msg, err := ml.selectedMessage(); err == nil {
  910. canSelectReply = msg.ReferencedMessage != nil
  911. canOpen = len(extractURLs(msg.Content)) != 0 || len(msg.Attachments) != 0
  912. me, _ := ml.chatView.state.Cabinet.Me()
  913. canReply = msg.Author.ID != me.ID
  914. canEdit = msg.Author.ID == me.ID
  915. canDelete = canEdit
  916. if !canDelete {
  917. selected := ml.chatView.SelectedChannel()
  918. canDelete = selected != nil && ml.chatView.state.HasPermissions(selected.ID, discord.PermissionManageMessages)
  919. }
  920. }
  921. actions := make([]keybind.Keybind, 0, 4)
  922. if canReply {
  923. actions = append(actions, cfg.Reply.Keybind, cfg.ReplyMention.Keybind)
  924. }
  925. if canSelectReply {
  926. actions = append(actions, cfg.SelectReply.Keybind)
  927. }
  928. actions = append(actions, cfg.Cancel.Keybind)
  929. manage := make([]keybind.Keybind, 0, 4)
  930. if canEdit {
  931. manage = append(manage, cfg.Edit.Keybind)
  932. }
  933. if canDelete {
  934. manage = append(manage, cfg.DeleteConfirm.Keybind, cfg.Delete.Keybind)
  935. }
  936. if canOpen {
  937. manage = append(manage, cfg.Open.Keybind)
  938. }
  939. return [][]keybind.Keybind{
  940. {cfg.SelectUp.Keybind, cfg.SelectDown.Keybind, cfg.SelectTop.Keybind, cfg.SelectBottom.Keybind},
  941. {cfg.ScrollUp.Keybind, cfg.ScrollDown.Keybind, cfg.ScrollTop.Keybind, cfg.ScrollBottom.Keybind},
  942. actions,
  943. manage,
  944. {cfg.YankContent.Keybind, cfg.YankURL.Keybind, cfg.YankID.Keybind},
  945. }
  946. }