messages_list.go 29 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099
  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, ml.chatView.state)
  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. // Always show a date separator before the first message, and between messages on different days.
  207. if ml.cfg.DateSeparator.Enabled && (i == 0 || !sameLocalDate(ml.messages[i-1].Timestamp, ml.messages[i].Timestamp)) {
  208. rows = append(rows, messagesListRow{
  209. kind: messagesListRowSeparator,
  210. timestamp: ml.messages[i].Timestamp,
  211. })
  212. }
  213. rows = append(rows, messagesListRow{
  214. kind: messagesListRowMessage,
  215. messageIndex: i,
  216. })
  217. }
  218. ml.rows = rows
  219. ml.rowsDirty = false
  220. }
  221. func (ml *messagesList) invalidateRows() {
  222. ml.rowsDirty = true
  223. }
  224. // ensureRows lazily rebuilds list rows. This avoids repeated O(n) row rebuild
  225. // work when multiple message mutations happen close together.
  226. func (ml *messagesList) ensureRows() {
  227. if !ml.rowsDirty {
  228. return
  229. }
  230. ml.rebuildRows()
  231. }
  232. func sameLocalDate(a discord.Timestamp, b discord.Timestamp) bool {
  233. ta := a.Time().In(time.Local)
  234. tb := b.Time().In(time.Local)
  235. return ta.Year() == tb.Year() && ta.YearDay() == tb.YearDay()
  236. }
  237. // Cursor returns the selected message index, skipping separator rows.
  238. func (ml *messagesList) Cursor() int {
  239. ml.ensureRows()
  240. rowIndex := ml.List.Cursor()
  241. if rowIndex < 0 || rowIndex >= len(ml.rows) {
  242. return -1
  243. }
  244. row := ml.rows[rowIndex]
  245. if row.kind != messagesListRowMessage {
  246. return -1
  247. }
  248. return row.messageIndex
  249. }
  250. // SetCursor selects a message index and maps it to the corresponding row.
  251. func (ml *messagesList) SetCursor(index int) {
  252. ml.List.SetCursor(ml.messageToRowIndex(index))
  253. }
  254. func (ml *messagesList) messageToRowIndex(messageIndex int) int {
  255. ml.ensureRows()
  256. if messageIndex < 0 || messageIndex >= len(ml.messages) {
  257. return -1
  258. }
  259. for i, row := range ml.rows {
  260. if row.kind == messagesListRowMessage && row.messageIndex == messageIndex {
  261. return i
  262. }
  263. }
  264. return -1
  265. }
  266. func (ml *messagesList) onRowCursorChanged(rowIndex int) {
  267. ml.ensureRows()
  268. if rowIndex < 0 || rowIndex >= len(ml.rows) || ml.rows[rowIndex].kind == messagesListRowMessage {
  269. return
  270. }
  271. target := ml.nearestMessageRowIndex(rowIndex)
  272. ml.List.SetCursor(target)
  273. }
  274. // nearestMessageRowIndex expects rowIndex to be within bounds.
  275. func (ml *messagesList) nearestMessageRowIndex(rowIndex int) int {
  276. for i := rowIndex - 1; i >= 0; i-- {
  277. if ml.rows[i].kind == messagesListRowMessage {
  278. return i
  279. }
  280. }
  281. for i := rowIndex + 1; i < len(ml.rows); i++ {
  282. if ml.rows[i].kind == messagesListRowMessage {
  283. return i
  284. }
  285. }
  286. return -1
  287. }
  288. func (ml *messagesList) writeMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  289. if ml.cfg.HideBlockedUsers {
  290. isBlocked := ml.chatView.state.UserIsBlocked(message.Author.ID)
  291. if isBlocked {
  292. builder.Write("Blocked message", baseStyle.Foreground(color.Red).Bold(true))
  293. return
  294. }
  295. }
  296. switch message.Type {
  297. case discord.DefaultMessage:
  298. if message.Reference != nil && message.Reference.Type == discord.MessageReferenceTypeForward {
  299. ml.drawForwardedMessage(builder, message, baseStyle)
  300. } else {
  301. ml.drawDefaultMessage(builder, message, baseStyle)
  302. }
  303. case discord.GuildMemberJoinMessage:
  304. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  305. ml.drawAuthor(builder, message, baseStyle)
  306. builder.Write("joined the server.", baseStyle)
  307. case discord.InlinedReplyMessage:
  308. ml.drawReplyMessage(builder, message, baseStyle)
  309. case discord.ChannelPinnedMessage:
  310. ml.drawPinnedMessage(builder, message, baseStyle)
  311. default:
  312. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  313. ml.drawAuthor(builder, message, baseStyle)
  314. }
  315. }
  316. func (ml *messagesList) formatTimestamp(ts discord.Timestamp) string {
  317. return ts.Time().In(time.Local).Format(ml.cfg.Timestamps.Format)
  318. }
  319. func (ml *messagesList) drawTimestamps(builder *tview.LineBuilder, ts discord.Timestamp, baseStyle tcell.Style) {
  320. dimStyle := baseStyle.Dim(true)
  321. builder.Write(ml.formatTimestamp(ts)+" ", dimStyle)
  322. }
  323. func (ml *messagesList) drawAuthor(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  324. name := message.Author.DisplayOrUsername()
  325. foreground := tcell.ColorDefault
  326. if member := ml.memberForMessage(message); member != nil {
  327. if member.Nick != "" {
  328. name = member.Nick
  329. }
  330. color, ok := state.MemberColor(member, func(id discord.RoleID) *discord.Role {
  331. r, _ := ml.chatView.state.Cabinet.Role(message.GuildID, id)
  332. return r
  333. })
  334. if ok {
  335. foreground = tcell.NewHexColor(int32(color))
  336. }
  337. }
  338. style := baseStyle.Foreground(foreground).Bold(true)
  339. builder.Write(name+" ", style)
  340. }
  341. func (ml *messagesList) memberForMessage(message discord.Message) *discord.Member {
  342. // Webhooks do not have nicknames or roles.
  343. if !message.GuildID.IsValid() || message.WebhookID.IsValid() {
  344. return nil
  345. }
  346. member, err := ml.chatView.state.Cabinet.Member(message.GuildID, message.Author.ID)
  347. if err != nil {
  348. slog.Error("failed to get member from state", "guild_id", message.GuildID, "member_id", message.Author.ID, "err", err)
  349. return nil
  350. }
  351. return member
  352. }
  353. func (ml *messagesList) drawContent(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  354. c := []byte(message.Content)
  355. if ml.chatView.cfg.Markdown.Enabled {
  356. root := discordmd.ParseWithMessage(c, *ml.chatView.state.Cabinet, &message, false)
  357. lines := ml.renderer.RenderLines(c, root, baseStyle)
  358. if builder.HasCurrentLine() {
  359. startsWithCodeBlock := false
  360. if first := root.FirstChild(); first != nil {
  361. _, startsWithCodeBlock = first.(*ast.FencedCodeBlock)
  362. }
  363. if startsWithCodeBlock {
  364. // Keep code blocks visually separate from "timestamp + author".
  365. builder.NewLine()
  366. for len(lines) > 0 && len(lines[0]) == 0 {
  367. lines = lines[1:]
  368. }
  369. } else {
  370. for len(lines) > 1 && len(lines[0]) == 0 {
  371. lines = lines[1:]
  372. }
  373. }
  374. }
  375. builder.AppendLines(lines)
  376. } else {
  377. builder.Write(message.Content, baseStyle)
  378. }
  379. }
  380. func (ml *messagesList) drawSnapshotContent(builder *tview.LineBuilder, parent discord.Message, snapshot discord.MessageSnapshotMessage, baseStyle tcell.Style) {
  381. // Convert discord.MessageSnapshotMessage to discord.Message with common fields.
  382. message := discord.Message{
  383. Type: snapshot.Type,
  384. Content: snapshot.Content,
  385. Embeds: snapshot.Embeds,
  386. Attachments: snapshot.Attachments,
  387. Timestamp: snapshot.Timestamp,
  388. EditedTimestamp: snapshot.EditedTimestamp,
  389. Flags: snapshot.Flags,
  390. Mentions: snapshot.Mentions,
  391. MentionRoleIDs: snapshot.MentionRoleIDs,
  392. Stickers: snapshot.Stickers,
  393. Components: snapshot.Components,
  394. ChannelID: parent.ChannelID,
  395. GuildID: parent.GuildID,
  396. }
  397. ml.drawContent(builder, message, baseStyle)
  398. }
  399. func (ml *messagesList) drawDefaultMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  400. if ml.cfg.Timestamps.Enabled {
  401. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  402. }
  403. ml.drawAuthor(builder, message, baseStyle)
  404. ml.drawContent(builder, message, baseStyle)
  405. if message.EditedTimestamp.IsValid() {
  406. dimStyle := baseStyle.Dim(true)
  407. builder.Write(" (edited)", dimStyle)
  408. }
  409. attachmentStyle := ui.MergeStyle(baseStyle, ml.cfg.Theme.MessagesList.AttachmentStyle.Style)
  410. for _, a := range message.Attachments {
  411. builder.NewLine()
  412. if ml.cfg.ShowAttachmentLinks {
  413. builder.Write(a.Filename+":\n"+a.URL, attachmentStyle)
  414. } else {
  415. builder.Write(a.Filename, attachmentStyle)
  416. }
  417. }
  418. }
  419. func (ml *messagesList) drawForwardedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  420. dimStyle := baseStyle.Dim(true)
  421. ml.drawTimestamps(builder, message.Timestamp, baseStyle)
  422. ml.drawAuthor(builder, message, baseStyle)
  423. builder.Write(ml.cfg.Theme.MessagesList.ForwardedIndicator+" ", dimStyle)
  424. ml.drawSnapshotContent(builder, message, message.MessageSnapshots[0].Message, baseStyle)
  425. builder.Write(" ("+ml.formatTimestamp(message.MessageSnapshots[0].Message.Timestamp)+") ", dimStyle)
  426. }
  427. func (ml *messagesList) drawReplyMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  428. dimStyle := baseStyle.Dim(true)
  429. // indicator
  430. builder.Write(ml.cfg.Theme.MessagesList.ReplyIndicator+" ", dimStyle)
  431. if m := message.ReferencedMessage; m != nil {
  432. m.GuildID = message.GuildID
  433. ml.drawAuthor(builder, *m, dimStyle)
  434. ml.drawContent(builder, *m, dimStyle)
  435. } else {
  436. builder.Write("Original message was deleted", dimStyle)
  437. }
  438. builder.NewLine()
  439. // main
  440. ml.drawDefaultMessage(builder, message, baseStyle)
  441. }
  442. func (ml *messagesList) drawPinnedMessage(builder *tview.LineBuilder, message discord.Message, baseStyle tcell.Style) {
  443. builder.Write(message.Author.DisplayOrUsername(), baseStyle)
  444. builder.Write(" pinned a message.", baseStyle)
  445. }
  446. func (ml *messagesList) selectedMessage() (*discord.Message, error) {
  447. if len(ml.messages) == 0 {
  448. return nil, errors.New("no messages available")
  449. }
  450. cursor := ml.Cursor()
  451. if cursor == -1 || cursor >= len(ml.messages) {
  452. return nil, errors.New("no message is currently selected")
  453. }
  454. return &ml.messages[cursor], nil
  455. }
  456. func (ml *messagesList) handleInput(event *tcell.EventKey) *tcell.EventKey {
  457. switch {
  458. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollUp.Keybind):
  459. ml.ScrollUp()
  460. return nil
  461. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollDown.Keybind):
  462. ml.ScrollDown()
  463. return nil
  464. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollTop.Keybind):
  465. ml.ScrollToStart()
  466. return nil
  467. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ScrollBottom.Keybind):
  468. ml.ScrollToEnd()
  469. return nil
  470. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Cancel.Keybind):
  471. ml.clearSelection()
  472. return nil
  473. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectUp.Keybind):
  474. ml.selectUp()
  475. return nil
  476. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectDown.Keybind):
  477. ml.selectDown()
  478. return nil
  479. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectTop.Keybind):
  480. ml.selectTop()
  481. return nil
  482. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectBottom.Keybind):
  483. ml.selectBottom()
  484. return nil
  485. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.SelectReply.Keybind):
  486. ml.selectReply()
  487. return nil
  488. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankID.Keybind):
  489. ml.yankID()
  490. return nil
  491. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankContent.Keybind):
  492. ml.yankContent()
  493. return nil
  494. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.YankURL.Keybind):
  495. ml.yankURL()
  496. return nil
  497. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Open.Keybind):
  498. ml.open()
  499. return nil
  500. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Reply.Keybind):
  501. ml.reply(false)
  502. return nil
  503. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.ReplyMention.Keybind):
  504. ml.reply(true)
  505. return nil
  506. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Edit.Keybind):
  507. ml.edit()
  508. return nil
  509. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.Delete.Keybind):
  510. ml.delete()
  511. return nil
  512. case keybind.Matches(event, ml.cfg.Keybinds.MessagesList.DeleteConfirm.Keybind):
  513. ml.confirmDelete()
  514. return nil
  515. }
  516. return event
  517. }
  518. func (ml *messagesList) InputHandler(event *tcell.EventKey, setFocus func(p tview.Primitive)) {
  519. event = ml.handleInput(event)
  520. if event == nil {
  521. return
  522. }
  523. ml.List.InputHandler(event, setFocus)
  524. }
  525. func (ml *messagesList) selectUp() {
  526. messages := ml.messages
  527. if len(messages) == 0 {
  528. return
  529. }
  530. cursor := ml.Cursor()
  531. switch {
  532. case cursor == -1:
  533. cursor = len(messages) - 1
  534. case cursor > 0:
  535. cursor--
  536. case cursor == 0:
  537. added := ml.prependOlderMessages()
  538. if added == 0 {
  539. return
  540. }
  541. cursor = added - 1
  542. }
  543. ml.SetCursor(cursor)
  544. }
  545. func (ml *messagesList) selectDown() {
  546. messages := ml.messages
  547. if len(messages) == 0 {
  548. return
  549. }
  550. cursor := ml.Cursor()
  551. switch {
  552. case cursor == -1:
  553. cursor = len(messages) - 1
  554. case cursor < len(messages)-1:
  555. cursor++
  556. }
  557. ml.SetCursor(cursor)
  558. }
  559. func (ml *messagesList) selectTop() {
  560. if len(ml.messages) == 0 {
  561. return
  562. }
  563. ml.SetCursor(0)
  564. }
  565. func (ml *messagesList) selectBottom() {
  566. if len(ml.messages) == 0 {
  567. return
  568. }
  569. ml.SetCursor(len(ml.messages) - 1)
  570. }
  571. func (ml *messagesList) selectReply() {
  572. messages := ml.messages
  573. if len(messages) == 0 {
  574. return
  575. }
  576. cursor := ml.Cursor()
  577. if cursor == -1 || cursor >= len(messages) {
  578. return
  579. }
  580. if ref := messages[cursor].ReferencedMessage; ref != nil {
  581. refIdx := slices.IndexFunc(messages, func(m discord.Message) bool {
  582. return m.ID == ref.ID
  583. })
  584. if refIdx != -1 {
  585. ml.SetCursor(refIdx)
  586. }
  587. }
  588. }
  589. func (ml *messagesList) prependOlderMessages() int {
  590. selectedChannel := ml.chatView.SelectedChannel()
  591. if selectedChannel == nil {
  592. return 0
  593. }
  594. channelID := selectedChannel.ID
  595. before := ml.messages[0].ID
  596. limit := uint(ml.cfg.MessagesLimit)
  597. messages, err := ml.chatView.state.MessagesBefore(channelID, before, limit)
  598. if err != nil {
  599. slog.Error("failed to fetch older messages", "err", err)
  600. return 0
  601. }
  602. if len(messages) == 0 {
  603. return 0
  604. }
  605. if guildID := selectedChannel.GuildID; guildID.IsValid() {
  606. ml.requestGuildMembers(guildID, messages)
  607. }
  608. older := slices.Clone(messages)
  609. slices.Reverse(older)
  610. // Defensive invalidation if Discord returns overlapping windows.
  611. for _, message := range older {
  612. delete(ml.itemByID, message.ID)
  613. }
  614. ml.messages = slices.Concat(older, ml.messages)
  615. ml.invalidateRows()
  616. ml.MarkDirty()
  617. return len(messages)
  618. }
  619. func (ml *messagesList) yankID() {
  620. msg, err := ml.selectedMessage()
  621. if err != nil {
  622. slog.Error("failed to get selected message", "err", err)
  623. return
  624. }
  625. go clipboard.Write(clipboard.FmtText, []byte(msg.ID.String()))
  626. }
  627. func (ml *messagesList) yankContent() {
  628. msg, err := ml.selectedMessage()
  629. if err != nil {
  630. slog.Error("failed to get selected message", "err", err)
  631. return
  632. }
  633. go clipboard.Write(clipboard.FmtText, []byte(msg.Content))
  634. }
  635. func (ml *messagesList) yankURL() {
  636. msg, err := ml.selectedMessage()
  637. if err != nil {
  638. slog.Error("failed to get selected message", "err", err)
  639. return
  640. }
  641. go clipboard.Write(clipboard.FmtText, []byte(msg.URL()))
  642. }
  643. func (ml *messagesList) open() {
  644. msg, err := ml.selectedMessage()
  645. if err != nil {
  646. slog.Error("failed to get selected message", "err", err)
  647. return
  648. }
  649. var urls []string
  650. if msg.Content != "" {
  651. urls = extractURLs(msg.Content)
  652. }
  653. if len(urls) == 0 && len(msg.Attachments) == 0 {
  654. return
  655. }
  656. if len(urls)+len(msg.Attachments) == 1 {
  657. if len(urls) == 1 {
  658. go ml.openURL(urls[0])
  659. } else {
  660. attachment := msg.Attachments[0]
  661. if strings.HasPrefix(attachment.ContentType, "image/") {
  662. go ml.openAttachment(msg.Attachments[0])
  663. } else {
  664. go ml.openURL(attachment.URL)
  665. }
  666. }
  667. } else {
  668. ml.showAttachmentsList(urls, msg.Attachments)
  669. }
  670. }
  671. func extractURLs(content string) []string {
  672. src := []byte(content)
  673. node := parser.NewParser(
  674. parser.WithBlockParsers(discordmd.BlockParsers()...),
  675. parser.WithInlineParsers(discordmd.InlineParserWithLink()...),
  676. ).Parse(text.NewReader(src))
  677. var urls []string
  678. ast.Walk(node, func(n ast.Node, entering bool) (ast.WalkStatus, error) {
  679. if entering {
  680. switch n := n.(type) {
  681. case *ast.AutoLink:
  682. urls = append(urls, string(n.URL(src)))
  683. case *ast.Link:
  684. urls = append(urls, string(n.Destination))
  685. }
  686. }
  687. return ast.WalkContinue, nil
  688. })
  689. return urls
  690. }
  691. func (ml *messagesList) showAttachmentsList(urls []string, attachments []discord.Attachment) {
  692. var items []attachmentItem
  693. for _, a := range attachments {
  694. attachment := a
  695. action := func() {
  696. if strings.HasPrefix(attachment.ContentType, "image/") {
  697. go ml.openAttachment(attachment)
  698. } else {
  699. go ml.openURL(attachment.URL)
  700. }
  701. }
  702. items = append(items, attachmentItem{
  703. label: attachment.Filename,
  704. open: action,
  705. })
  706. }
  707. for _, u := range urls {
  708. url := u
  709. items = append(items, attachmentItem{
  710. label: url,
  711. open: func() { go ml.openURL(url) },
  712. })
  713. }
  714. ml.attachmentsPicker.SetItems(items)
  715. ml.chatView.
  716. AddLayer(
  717. ui.Centered(ml.attachmentsPicker, 0, 0),
  718. layers.WithName(attachmentsListLayerName),
  719. layers.WithResize(true),
  720. layers.WithVisible(true),
  721. layers.WithOverlay(),
  722. ).
  723. SendToFront(attachmentsListLayerName)
  724. ml.chatView.app.SetFocus(ml.attachmentsPicker)
  725. }
  726. func (ml *messagesList) openAttachment(attachment discord.Attachment) {
  727. resp, err := http.Get(attachment.URL)
  728. if err != nil {
  729. slog.Error("failed to fetch the attachment", "err", err, "url", attachment.URL)
  730. return
  731. }
  732. defer resp.Body.Close()
  733. path := filepath.Join(consts.CacheDir(), "attachments")
  734. if err := os.MkdirAll(path, os.ModePerm); err != nil {
  735. slog.Error("failed to create attachments dir", "err", err, "path", path)
  736. return
  737. }
  738. path = filepath.Join(path, attachment.Filename)
  739. file, err := os.Create(path)
  740. if err != nil {
  741. slog.Error("failed to create attachment file", "err", err, "path", path)
  742. return
  743. }
  744. defer file.Close()
  745. if _, err := io.Copy(file, resp.Body); err != nil {
  746. slog.Error("failed to copy attachment to file", "err", err)
  747. return
  748. }
  749. if err := open.Start(path); err != nil {
  750. slog.Error("failed to open attachment file", "err", err, "path", path)
  751. return
  752. }
  753. }
  754. func (ml *messagesList) openURL(url string) {
  755. if err := open.Start(url); err != nil {
  756. slog.Error("failed to open URL", "err", err, "url", url)
  757. }
  758. }
  759. func (ml *messagesList) reply(mention bool) {
  760. message, err := ml.selectedMessage()
  761. if err != nil {
  762. slog.Error("failed to get selected message", "err", err)
  763. return
  764. }
  765. name := message.Author.DisplayOrUsername()
  766. if member := ml.memberForMessage(*message); member != nil && member.Nick != "" {
  767. name = member.Nick
  768. }
  769. data := ml.chatView.messageInput.sendMessageData
  770. data.Reference = &discord.MessageReference{MessageID: message.ID}
  771. data.AllowedMentions = &api.AllowedMentions{RepliedUser: option.False}
  772. title := "Replying to "
  773. if mention {
  774. data.AllowedMentions.RepliedUser = option.True
  775. title = "[@] " + title
  776. }
  777. ml.chatView.messageInput.sendMessageData = data
  778. ml.chatView.messageInput.SetTitle(title + name)
  779. ml.chatView.app.SetFocus(ml.chatView.messageInput)
  780. }
  781. func (ml *messagesList) edit() {
  782. message, err := ml.selectedMessage()
  783. if err != nil {
  784. slog.Error("failed to get selected message", "err", err)
  785. return
  786. }
  787. me, _ := ml.chatView.state.Cabinet.Me()
  788. if message.Author.ID != me.ID {
  789. slog.Error("failed to edit message; not the author", "channel_id", message.ChannelID, "message_id", message.ID)
  790. return
  791. }
  792. ml.chatView.messageInput.SetTitle("Editing")
  793. ml.chatView.messageInput.edit = true
  794. ml.chatView.messageInput.SetText(message.Content, true)
  795. ml.chatView.app.SetFocus(ml.chatView.messageInput)
  796. }
  797. func (ml *messagesList) confirmDelete() {
  798. onChoice := func(choice string) {
  799. if choice == "Yes" {
  800. ml.delete()
  801. }
  802. }
  803. ml.chatView.showConfirmModal(
  804. "Are you sure you want to delete this message?",
  805. []string{"Yes", "No"},
  806. onChoice,
  807. )
  808. }
  809. func (ml *messagesList) delete() {
  810. msg, err := ml.selectedMessage()
  811. if err != nil {
  812. slog.Error("failed to get selected message", "err", err)
  813. return
  814. }
  815. if msg.GuildID.IsValid() {
  816. me, _ := ml.chatView.state.Cabinet.Me()
  817. if msg.Author.ID != me.ID && !ml.chatView.state.HasPermissions(msg.ChannelID, discord.PermissionManageMessages) {
  818. slog.Error("failed to delete message; missing relevant permissions", "channel_id", msg.ChannelID, "message_id", msg.ID)
  819. return
  820. }
  821. }
  822. selected := ml.chatView.SelectedChannel()
  823. if selected == nil {
  824. return
  825. }
  826. if err := ml.chatView.state.DeleteMessage(selected.ID, msg.ID, ""); err != nil {
  827. slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
  828. return
  829. }
  830. if err := ml.chatView.state.MessageRemove(selected.ID, msg.ID); err != nil {
  831. slog.Error("failed to delete message", "channel_id", selected.ID, "message_id", msg.ID, "err", err)
  832. return
  833. }
  834. }
  835. func (ml *messagesList) requestGuildMembers(guildID discord.GuildID, messages []discord.Message) {
  836. usersToFetch := make([]discord.UserID, 0, len(messages))
  837. seen := make(map[discord.UserID]struct{}, len(messages))
  838. for _, message := range messages {
  839. // Do not fetch member for a webhook message.
  840. if message.WebhookID.IsValid() {
  841. continue
  842. }
  843. if member, _ := ml.chatView.state.Cabinet.Member(guildID, message.Author.ID); member == nil {
  844. userID := message.Author.ID
  845. if _, ok := seen[userID]; !ok {
  846. seen[userID] = struct{}{}
  847. usersToFetch = append(usersToFetch, userID)
  848. }
  849. }
  850. }
  851. if len(usersToFetch) > 0 {
  852. err := ml.chatView.state.SendGateway(context.TODO(), &gateway.RequestGuildMembersCommand{
  853. GuildIDs: []discord.GuildID{guildID},
  854. UserIDs: usersToFetch,
  855. })
  856. if err != nil {
  857. slog.Error("failed to request guild members", "guild_id", guildID, "err", err)
  858. return
  859. }
  860. ml.setFetchingChunk(true, 0)
  861. ml.waitForChunkEvent()
  862. }
  863. }
  864. func (ml *messagesList) setFetchingChunk(value bool, count uint) {
  865. ml.fetchingMembers.mu.Lock()
  866. defer ml.fetchingMembers.mu.Unlock()
  867. if ml.fetchingMembers.value == value {
  868. return
  869. }
  870. ml.fetchingMembers.value = value
  871. if value {
  872. ml.fetchingMembers.done = make(chan struct{})
  873. } else {
  874. ml.fetchingMembers.count = count
  875. close(ml.fetchingMembers.done)
  876. }
  877. }
  878. func (ml *messagesList) waitForChunkEvent() uint {
  879. ml.fetchingMembers.mu.Lock()
  880. if !ml.fetchingMembers.value {
  881. ml.fetchingMembers.mu.Unlock()
  882. return 0
  883. }
  884. ml.fetchingMembers.mu.Unlock()
  885. <-ml.fetchingMembers.done
  886. return ml.fetchingMembers.count
  887. }
  888. func (ml *messagesList) ShortHelp() []keybind.Keybind {
  889. cfg := ml.cfg.Keybinds.MessagesList
  890. help := []keybind.Keybind{
  891. cfg.SelectUp.Keybind,
  892. cfg.SelectDown.Keybind,
  893. cfg.Cancel.Keybind,
  894. }
  895. if msg, err := ml.selectedMessage(); err == nil {
  896. me, _ := ml.chatView.state.Cabinet.Me()
  897. if msg.Author.ID != me.ID {
  898. help = append(help, cfg.Reply.Keybind)
  899. }
  900. }
  901. return help
  902. }
  903. func (ml *messagesList) FullHelp() [][]keybind.Keybind {
  904. cfg := ml.cfg.Keybinds.MessagesList
  905. canSelectReply := false
  906. canReply := false
  907. canEdit := false
  908. canDelete := false
  909. canOpen := false
  910. if msg, err := ml.selectedMessage(); err == nil {
  911. canSelectReply = msg.ReferencedMessage != nil
  912. canOpen = len(extractURLs(msg.Content)) != 0 || len(msg.Attachments) != 0
  913. me, _ := ml.chatView.state.Cabinet.Me()
  914. canReply = msg.Author.ID != me.ID
  915. canEdit = msg.Author.ID == me.ID
  916. canDelete = canEdit
  917. if !canDelete {
  918. selected := ml.chatView.SelectedChannel()
  919. canDelete = selected != nil && ml.chatView.state.HasPermissions(selected.ID, discord.PermissionManageMessages)
  920. }
  921. }
  922. actions := make([]keybind.Keybind, 0, 4)
  923. if canReply {
  924. actions = append(actions, cfg.Reply.Keybind, cfg.ReplyMention.Keybind)
  925. }
  926. if canSelectReply {
  927. actions = append(actions, cfg.SelectReply.Keybind)
  928. }
  929. actions = append(actions, cfg.Cancel.Keybind)
  930. manage := make([]keybind.Keybind, 0, 4)
  931. if canEdit {
  932. manage = append(manage, cfg.Edit.Keybind)
  933. }
  934. if canDelete {
  935. manage = append(manage, cfg.DeleteConfirm.Keybind, cfg.Delete.Keybind)
  936. }
  937. if canOpen {
  938. manage = append(manage, cfg.Open.Keybind)
  939. }
  940. return [][]keybind.Keybind{
  941. {cfg.SelectUp.Keybind, cfg.SelectDown.Keybind, cfg.SelectTop.Keybind, cfg.SelectBottom.Keybind},
  942. {cfg.ScrollUp.Keybind, cfg.ScrollDown.Keybind, cfg.ScrollTop.Keybind, cfg.ScrollBottom.Keybind},
  943. actions,
  944. manage,
  945. {cfg.YankContent.Keybind, cfg.YankURL.Keybind, cfg.YankID.Keybind},
  946. }
  947. }