state.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. package cmd
  2. import (
  3. "context"
  4. "log/slog"
  5. "runtime"
  6. "slices"
  7. "github.com/ayn2op/discordo/internal/config"
  8. "github.com/diamondburned/arikawa/v3/api"
  9. "github.com/diamondburned/arikawa/v3/discord"
  10. "github.com/diamondburned/arikawa/v3/gateway"
  11. "github.com/diamondburned/arikawa/v3/utils/httputil/httpdriver"
  12. "github.com/diamondburned/ningen/v3"
  13. "github.com/gdamore/tcell/v2"
  14. "github.com/rivo/tview"
  15. )
  16. const userAgent = config.Name + "/0.1 (https://github.com/diamondburned/arikawa, v3)"
  17. func init() {
  18. api.UserAgent = userAgent
  19. gateway.DefaultIdentity = gateway.IdentifyProperties{
  20. OS: runtime.GOOS,
  21. Device: "",
  22. Browser: config.Name,
  23. BrowserUserAgent: userAgent,
  24. }
  25. }
  26. type State struct {
  27. *ningen.State
  28. cfg *config.Config
  29. app *tview.Application
  30. }
  31. func openState(token string, app *tview.Application, cfg *config.Config) error {
  32. discordState = &State{
  33. State: ningen.New(token),
  34. cfg: cfg,
  35. app: app,
  36. }
  37. // Handlers
  38. discordState.AddHandler(discordState.onReady)
  39. discordState.AddHandler(discordState.onMessageCreate)
  40. discordState.AddHandler(discordState.onMessageDelete)
  41. discordState.OnRequest = append(discordState.Client.OnRequest, discordState.onRequest)
  42. return discordState.Open(context.TODO())
  43. }
  44. func (s *State) onRequest(r httpdriver.Request) error {
  45. req, ok := r.(*httpdriver.DefaultRequest)
  46. if ok {
  47. slog.Info("new HTTP request", "method", req.Method, "path", req.URL.Path)
  48. }
  49. return nil
  50. }
  51. func (s *State) onReady(r *gateway.ReadyEvent) {
  52. root := mainFlex.guildsTree.GetRoot()
  53. dmNode := tview.NewTreeNode("Direct Messages")
  54. dmNode.SetColor(tcell.GetColor(s.cfg.Theme.GuildsTree.PrivateChannelColor))
  55. root.AddChild(dmNode)
  56. // Track guilds that have a parent (folder) to add orphan channels later
  57. var folderGuildIds []discord.GuildID
  58. for _, folder := range r.UserSettings.GuildFolders {
  59. // Hide unnamed, single-server folders
  60. if folder.Name == "" && len(folder.GuildIDs) < 2 {
  61. continue
  62. }
  63. folderGuildIds = append(folderGuildIds, folder.GuildIDs...)
  64. mainFlex.guildsTree.createFolderNode(folder)
  65. }
  66. // add orphan (without folder) guilds to guilds tree
  67. for _, guild := range r.Guilds {
  68. if !slices.Contains(folderGuildIds, guild.ID) {
  69. mainFlex.guildsTree.createGuildNode(root, guild.Guild)
  70. }
  71. }
  72. mainFlex.guildsTree.SetCurrentNode(root)
  73. s.app.SetFocus(mainFlex.guildsTree)
  74. }
  75. func (s *State) onMessageCreate(m *gateway.MessageCreateEvent) {
  76. if mainFlex.guildsTree.selectedChannelID.IsValid() && mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  77. mainFlex.messagesText.createMessage(m.Message)
  78. }
  79. }
  80. func (s *State) onMessageDelete(m *gateway.MessageDeleteEvent) {
  81. if mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  82. mainFlex.messagesText.selectedMessageID = 0
  83. mainFlex.messagesText.Highlight()
  84. mainFlex.messagesText.Clear()
  85. mainFlex.messagesText.drawMsgs(m.ChannelID)
  86. }
  87. }