kern/v4/lev1/safe_bool_react/safe_bool_react.go

// package safe_bool_react -- потокобезопасный булевый признак с реакцией на своё изменение.
package safe_bool_react

import (
	"fmt"
	"os"
	"strings"
	"sync"

	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
)

// safeBoolReact -- потокобезопасный булевый признак с реакцией на своё изменение.
type safeBoolReact struct {
	sync.RWMutex
	dict map[string]func(kspec.EBoolMut) // Словарь обратных вызовов
	val  bool
}

// NewSafeBoolReact -- возвращает новый потокобезопасный булевый признак с реакцией на своё изменение.
func NewSafeBoolReact() mKs.ISafeBoolReact {
	sf := &safeBoolReact{
		dict: map[string]func(kspec.EBoolMut){},
	}
	return sf
}

// NewSafeBoolReactFromStr -- возвращает новое потокобезопасное булево с реакцией из строки.
func NewSafeBoolReactFromStr(strVal string) mL0.IResult[mKs.ISafeBoolReact] {
	sf := NewSafeBoolReact()
	res := sf.FromStr(strVal)
	if res.IsErr() {
		err := fmt.Errorf("NewSafeBoolReactFromStr(): in parse str(%v), err=\n\t%w", strVal, res.Err())
		return mL0.NewErr[mKs.ISafeBoolReact](err)
	}
	return mL0.NewOk(sf)
}

// NewSafeBoolGetenv -- возвращает новое потокобезопасное целое с реакцией из окружения.
func NewSafeBoolGetenv(env string) mL0.IResult[mKs.ISafeBoolReact] {
	sf := NewSafeBoolReact()
	res := sf.Getenv(env)
	if res.IsErr() {
		err := fmt.Errorf("NewSafeBoolGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
		return mL0.NewErr[mKs.ISafeBoolReact](err)
	}
	return mL0.NewOk(sf)
}

// Delete -- удаляет функцию обратного вызова из наблюдения.
func (sf *safeBoolReact) Delete(key string) {
	sf.Lock()
	defer sf.Unlock()
	delete(sf.dict, key)
}

// Add -- добавляет функцию обратного вызова.
func (sf *safeBoolReact) Add(key string, fn func(kspec.EBoolMut)) mL0.IResult[kspec.EBool] {
	sf.Lock()
	defer sf.Unlock()
	if key == "" {
		return mL0.NewErr[kspec.EBool](fmt.Errorf("safeBoolReact.Add(): key is empty"))
	}
	_, isOk := sf.dict[key]
	if isOk {
		return mL0.NewErr[kspec.EBool](fmt.Errorf("safeBoolReact.Add(): key(%v) already exists", key))
	}
	sf.dict[key] = fn
	return mL0.NewOk(ebool.NewEBool(true))
}

// Get -- возвращает хранимый булевый признак.
func (sf *safeBoolReact) Get() bool {
	sf.RLock()
	defer sf.RUnlock()
	return sf.val
}

// Set -- устанавливает булевый признак.
func (sf *safeBoolReact) Set() {
	sf.Lock()
	defer sf.Unlock()
	sf.val = true
	for _, fn := range sf.dict {
		fn(ebool.NewEBoolMut(true))
	}
}

// Reset -- сбрасывает булевый признак.
func (sf *safeBoolReact) Reset() {
	sf.Lock()
	defer sf.Unlock()
	sf.val = false
	for _, fn := range sf.dict {
		fn(ebool.NewEBoolMut(false))
	}
}

// FromStr -- получает число из строки.
func (sf *safeBoolReact) FromStr(strVal string) mL0.IResult[kspec.EBool] {
	strVal = strings.ToLower(strVal)
	sf.Lock()
	defer sf.Unlock()
	switch strVal {
	case "true":
		sf.val = true
	case "false":
		sf.val = false
	default:
		return mL0.NewErr[kspec.EBool](fmt.Errorf("safeBoolReact.FromStr(): val(%v) bad", strVal))
	}
	return mL0.NewOk(ebool.NewEBool(sf.val))
}

// Getenv -- получает значение из окружения.
func (sf *safeBoolReact) Getenv(env string) mL0.IResult[kspec.EBool] {
	strVal := os.Getenv(env)
	res := sf.FromStr(strVal)
	if res.IsErr() {
		err := fmt.Errorf("safeBoolReact.Getenv(): from env %v, err=\n\t%w", env, res.Err())
		return mL0.NewErr[kspec.EBool](err)
	}
	return res
}