guildstate.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. package chat
  2. import (
  3. "encoding/json"
  4. "log/slog"
  5. "os"
  6. "path/filepath"
  7. "sync"
  8. "github.com/ayn2op/discordo/internal/consts"
  9. "github.com/diamondburned/arikawa/v3/discord"
  10. )
  11. type guildState struct {
  12. ExpandedGuilds map[discord.GuildID]bool `json:"expanded_guilds"`
  13. ExpandedChannels map[discord.ChannelID]bool `json:"expanded_channels,omitempty"`
  14. mu sync.RWMutex
  15. }
  16. var stateFilePath = filepath.Join(consts.CacheDir(), "state.json")
  17. func loadGuildState() *guildState {
  18. gs := &guildState{
  19. ExpandedGuilds: make(map[discord.GuildID]bool),
  20. ExpandedChannels: make(map[discord.ChannelID]bool),
  21. }
  22. data, err := os.ReadFile(stateFilePath)
  23. if err != nil {
  24. return gs
  25. }
  26. if err := json.Unmarshal(data, gs); err != nil {
  27. slog.Warn("failed to parse guild state", "err", err)
  28. return &guildState{
  29. ExpandedGuilds: make(map[discord.GuildID]bool),
  30. ExpandedChannels: make(map[discord.ChannelID]bool),
  31. }
  32. }
  33. if gs.ExpandedGuilds == nil {
  34. gs.ExpandedGuilds = make(map[discord.GuildID]bool)
  35. }
  36. if gs.ExpandedChannels == nil {
  37. gs.ExpandedChannels = make(map[discord.ChannelID]bool)
  38. }
  39. return gs
  40. }
  41. func (gs *guildState) save() {
  42. gs.mu.Lock()
  43. defer gs.mu.Unlock()
  44. atomicSaveJSON(stateFilePath, gs)
  45. }
  46. func (gs *guildState) setExpanded(id discord.GuildID, expanded bool) {
  47. gs.mu.Lock()
  48. if expanded {
  49. gs.ExpandedGuilds[id] = true
  50. } else {
  51. delete(gs.ExpandedGuilds, id)
  52. }
  53. gs.mu.Unlock()
  54. gs.save()
  55. }
  56. func (gs *guildState) isExpanded(id discord.GuildID) bool {
  57. gs.mu.RLock()
  58. defer gs.mu.RUnlock()
  59. return gs.ExpandedGuilds[id]
  60. }
  61. func (gs *guildState) setChannelExpanded(id discord.ChannelID, expanded bool) {
  62. gs.mu.Lock()
  63. if expanded {
  64. gs.ExpandedChannels[id] = true
  65. } else {
  66. delete(gs.ExpandedChannels, id)
  67. }
  68. gs.mu.Unlock()
  69. gs.save()
  70. }
  71. func (gs *guildState) isChannelExpanded(id discord.ChannelID, defaultExpanded bool) bool {
  72. gs.mu.RLock()
  73. defer gs.mu.RUnlock()
  74. if v, ok := gs.ExpandedChannels[id]; ok {
  75. return v
  76. }
  77. return defaultExpanded
  78. }