state.go 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. package cmd
  2. import (
  3. "context"
  4. "log"
  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/state"
  12. "github.com/diamondburned/arikawa/v3/utils/httputil/httpdriver"
  13. "github.com/rivo/tview"
  14. )
  15. func init() {
  16. api.UserAgent = constants.UserAgent
  17. gateway.DefaultIdentity = gateway.IdentifyProperties{
  18. OS: runtime.GOOS,
  19. Browser: constants.Name,
  20. Device: "",
  21. }
  22. }
  23. type State struct {
  24. *state.State
  25. }
  26. func openState(token string) error {
  27. discordState = &State{
  28. State: state.New(token),
  29. }
  30. // Handlers
  31. discordState.AddHandler(discordState.onReady)
  32. discordState.AddHandler(discordState.onMessageCreate)
  33. discordState.AddHandler(discordState.onMessageDelete)
  34. discordState.OnRequest = append(discordState.Client.OnRequest, discordState.onRequest)
  35. return discordState.Open(context.TODO())
  36. }
  37. func (s *State) onRequest(r httpdriver.Request) error {
  38. req, ok := r.(*httpdriver.DefaultRequest)
  39. if ok {
  40. log.Printf("method = %s; url = %s\n", req.Method, req.URL)
  41. }
  42. return nil
  43. }
  44. func (s *State) onReady(r *gateway.ReadyEvent) {
  45. root := mainFlex.guildsTree.GetRoot()
  46. dmNode := tview.NewTreeNode("Direct Messages")
  47. root.AddChild(dmNode)
  48. // Track guilds that have a parent (folder) to add orphan channels later
  49. var folderGuildIds []discord.GuildID
  50. for _, folder := range r.UserSettings.GuildFolders {
  51. folderGuildIds = append(folderGuildIds, folder.GuildIDs...)
  52. mainFlex.guildsTree.createFolderNode(folder)
  53. }
  54. // Orphan channels are added here
  55. for _, guild := range r.Guilds {
  56. if !slices.Contains(folderGuildIds, guild.ID) {
  57. mainFlex.guildsTree.createGuildNode(root, guild.Guild)
  58. }
  59. }
  60. mainFlex.guildsTree.SetCurrentNode(root)
  61. app.SetFocus(mainFlex.guildsTree)
  62. }
  63. func (s *State) onMessageCreate(m *gateway.MessageCreateEvent) {
  64. if mainFlex.guildsTree.selectedChannelID.IsValid() && mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  65. mainFlex.messagesText.createMessage(m.Message)
  66. }
  67. }
  68. func (s *State) onMessageDelete(m *gateway.MessageDeleteEvent) {
  69. if mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  70. mainFlex.messagesText.selectedMessage = -1
  71. mainFlex.messagesText.Highlight()
  72. mainFlex.messagesText.Clear()
  73. mainFlex.messagesText.drawMsgs(m.ChannelID)
  74. }
  75. }