messages_list.go 31 KB

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