Snider/Mining
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ax(mining): rename mu to mutex in FileRepository (AX Principle 1)

Browse source 
Co-Authored-By: Charon <charon@lethean.io>
This commit is contained in:
Claude 2026-04-02 13:40:56 +01:00
parent f005921de9
commit af8f82f95a
No known key found for this signature in database
GPG key ID: AF404715446AEB41
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
pkg/mining/repository.go
View file

@ -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) {