state.go 2.6 KB

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