diff --git a/pkg/mining/repository.go b/pkg/mining/repository.go index 333bd39..6514d41 100644 --- a/pkg/mining/repository.go +++ b/pkg/mining/repository.go @@ -24,7 +24,7 @@ type Repository[T any] interface { // repo := NewFileRepository[MinersConfig](path, WithDefaults(defaultMinersConfig)) // data, err := repo.Load() type FileRepository[T any] struct { - mu sync.RWMutex + mutex sync.RWMutex path string defaults func() T } @@ -53,8 +53,8 @@ func NewFileRepository[T any](path string, options ...FileRepositoryOption[T]) * // data, err := repo.Load() // if err != nil { return defaults, err } func (r *FileRepository[T]) Load() (T, error) { - r.mu.RLock() - defer r.mu.RUnlock() + r.mutex.RLock() + defer r.mutex.RUnlock() var result T @@ -78,8 +78,8 @@ func (r *FileRepository[T]) Load() (T, error) { // if err := repo.Save(updated); err != nil { return fmt.Errorf("save: %w", err) } func (r *FileRepository[T]) Save(data T) error { - r.mu.Lock() - defer r.mu.Unlock() + r.mutex.Lock() + defer r.mutex.Unlock() return r.saveUnlocked(data) } @@ -104,8 +104,8 @@ func (r *FileRepository[T]) saveUnlocked(data T) error { // return nil // }) func (r *FileRepository[T]) Update(fn func(*T) error) error { - r.mu.Lock() - defer r.mu.Unlock() + r.mutex.Lock() + defer r.mutex.Unlock() // Load current data var data T @@ -140,8 +140,8 @@ func (r *FileRepository[T]) Path() string { // if !repo.Exists() { return defaults, nil } func (r *FileRepository[T]) Exists() bool { - r.mu.RLock() - defer r.mu.RUnlock() + r.mutex.RLock() + defer r.mutex.RUnlock() _, err := os.Stat(r.path) return err == nil @@ -149,8 +149,8 @@ func (r *FileRepository[T]) Exists() bool { // if err := repo.Delete(); err != nil { return err } func (r *FileRepository[T]) Delete() error { - r.mu.Lock() - defer r.mu.Unlock() + r.mutex.Lock() + defer r.mutex.Unlock() err := os.Remove(r.path) if os.IsNotExist(err) {