guildstate.go 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  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. mu sync.RWMutex
  14. }
  15. var stateFilePath = filepath.Join(consts.CacheDir(), "state.json")
  16. func loadGuildState() *guildState {
  17. gs := &guildState{ExpandedGuilds: make(map[discord.GuildID]bool)}
  18. data, err := os.ReadFile(stateFilePath)
  19. if err != nil {
  20. return gs
  21. }
  22. if err := json.Unmarshal(data, gs); err != nil {
  23. slog.Warn("failed to parse guild state", "err", err)
  24. return &guildState{ExpandedGuilds: make(map[discord.GuildID]bool)}
  25. }
  26. if gs.ExpandedGuilds == nil {
  27. gs.ExpandedGuilds = make(map[discord.GuildID]bool)
  28. }
  29. return gs
  30. }
  31. func (gs *guildState) save() {
  32. gs.mu.Lock()
  33. defer gs.mu.Unlock()
  34. data, err := json.Marshal(gs)
  35. if err != nil {
  36. slog.Error("failed to marshal guild state", "err", err)
  37. return
  38. }
  39. tmpPath := stateFilePath + ".tmp"
  40. if err := os.WriteFile(tmpPath, data, 0600); err != nil {
  41. slog.Error("failed to write guild state", "err", err)
  42. return
  43. }
  44. if err := os.Rename(tmpPath, stateFilePath); err != nil {
  45. slog.Error("failed to rename guild state file", "err", err)
  46. }
  47. }
  48. func (gs *guildState) setExpanded(id discord.GuildID, expanded bool) {
  49. gs.mu.Lock()
  50. if expanded {
  51. gs.ExpandedGuilds[id] = true
  52. } else {
  53. delete(gs.ExpandedGuilds, id)
  54. }
  55. gs.mu.Unlock()
  56. gs.save()
  57. }
  58. func (gs *guildState) isExpanded(id discord.GuildID) bool {
  59. gs.mu.RLock()
  60. defer gs.mu.RUnlock()
  61. return gs.ExpandedGuilds[id]
  62. }