From af8f82f95a2c44365365b636bfb9e2b671bade31 Mon Sep 17 00:00:00 2001 From: Claude Date: Thu, 2 Apr 2026 13:40:56 +0100 Subject: [PATCH] ax(mining): rename mu to mutex in FileRepository (AX Principle 1) Co-Authored-By: Charon --- pkg/mining/repository.go | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) 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) {