state.go 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. package cmd
  2. import (
  3. "context"
  4. "log"
  5. "runtime"
  6. "github.com/ayn2op/discordo/internal/constants"
  7. "github.com/diamondburned/arikawa/v3/api"
  8. "github.com/diamondburned/arikawa/v3/gateway"
  9. "github.com/diamondburned/arikawa/v3/state"
  10. "github.com/diamondburned/arikawa/v3/utils/httputil/httpdriver"
  11. "github.com/rivo/tview"
  12. )
  13. func init() {
  14. api.UserAgent = constants.UserAgent
  15. gateway.DefaultIdentity = gateway.IdentifyProperties{
  16. OS: runtime.GOOS,
  17. Browser: constants.Name,
  18. Device: "",
  19. }
  20. }
  21. type State struct {
  22. *state.State
  23. }
  24. func openState(token string) error {
  25. discordState = &State{
  26. State: state.New(token),
  27. }
  28. // Handlers
  29. discordState.AddHandler(discordState.onReady)
  30. discordState.AddHandler(discordState.onMessageCreate)
  31. discordState.AddHandler(discordState.onMessageDelete)
  32. discordState.StateLog = discordState.onLog
  33. discordState.OnRequest = append(discordState.Client.OnRequest, discordState.onRequest)
  34. return discordState.Open(context.TODO())
  35. }
  36. func (s *State) onLog(err error) {
  37. log.Println(err.Error())
  38. }
  39. func (s *State) onRequest(r httpdriver.Request) error {
  40. req, ok := r.(*httpdriver.DefaultRequest)
  41. if ok {
  42. log.Printf("method = %s; url = %s\n", req.Method, req.URL)
  43. }
  44. return nil
  45. }
  46. func (s *State) onReady(r *gateway.ReadyEvent) {
  47. dmNode := tview.NewTreeNode("Direct Messages")
  48. mainFlex.guildsTree.root.AddChild(dmNode)
  49. folders := r.UserSettings.GuildFolders
  50. if len(folders) == 0 {
  51. for _, g := range r.Guilds {
  52. mainFlex.guildsTree.createGuildNode(mainFlex.guildsTree.root, g.Guild)
  53. }
  54. } else {
  55. for _, gf := range folders {
  56. // If the ID of the guild folder is zero, the guild folder only contains single guild.
  57. if gf.ID == 0 {
  58. g, err := s.Cabinet.Guild(gf.GuildIDs[0])
  59. if err != nil {
  60. log.Println(err)
  61. continue
  62. }
  63. mainFlex.guildsTree.createGuildNode(mainFlex.guildsTree.root, *g)
  64. } else {
  65. mainFlex.guildsTree.createGuildFolderNode(mainFlex.guildsTree.root, gf)
  66. }
  67. }
  68. }
  69. mainFlex.guildsTree.SetCurrentNode(mainFlex.guildsTree.root)
  70. app.SetFocus(mainFlex.guildsTree)
  71. }
  72. func (s *State) onMessageCreate(m *gateway.MessageCreateEvent) {
  73. if mainFlex.guildsTree.selectedChannelID.IsValid() && mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  74. mainFlex.messagesText.createMessage(m.Message)
  75. }
  76. }
  77. func (s *State) onMessageDelete(m *gateway.MessageDeleteEvent) {
  78. if mainFlex.guildsTree.selectedChannelID == m.ChannelID {
  79. mainFlex.messagesText.selectedMessage = -1
  80. mainFlex.messagesText.Highlight()
  81. mainFlex.messagesText.Clear()
  82. mainFlex.messagesText.drawMsgs(m.ChannelID)
  83. }
  84. }