safe_bool.go 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. // package safe_bool -- потокобезопасный булевый признак.
  2. package safe_bool
  3. import (
  4. "fmt"
  5. "os"
  6. "strings"
  7. "sync"
  8. mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
  9. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
  10. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
  11. mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
  12. )
  13. // safeBool -- потокобезопасный булевый признак.
  14. type safeBool struct {
  15. sync.RWMutex
  16. val bool
  17. }
  18. // NewSafeBool -- возвращает новый потокобезопасный булевый признак.
  19. func NewSafeBool(val bool) mKs.ISafeBool {
  20. sf := &safeBool{
  21. val: val,
  22. }
  23. return sf
  24. }
  25. // NewSafeBoolFromStr -- возвращает новое потокобезопасное булево из строки.
  26. func NewSafeBoolFromStr(strVal string) mL0.IResult[mKs.ISafeBool] {
  27. sf := NewSafeBool(false)
  28. res := sf.FromStr(strVal)
  29. if res.IsErr() {
  30. err := fmt.Errorf("NewSafeBoolFromStr(): in parse str(%v), err=\n\t%w", strVal, res.Err())
  31. return mL0.NewErr[mKs.ISafeBool](err)
  32. }
  33. return mL0.NewOk(sf)
  34. }
  35. // NewSafeBoolGetenv -- возвращает новое потокобезопасное целое из окружения.
  36. func NewSafeBoolGetenv(env string) mL0.IResult[mKs.ISafeBool] {
  37. sf := NewSafeBool(false)
  38. res := sf.Getenv(env)
  39. if res.IsErr() {
  40. err := fmt.Errorf("NewSafeBoolGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
  41. return mL0.NewErr[mKs.ISafeBool](err)
  42. }
  43. return mL0.NewOk(sf)
  44. }
  45. // Get -- возвращает хранимый булевый признак.
  46. func (sf *safeBool) Get() bool {
  47. sf.RLock()
  48. defer sf.RUnlock()
  49. return sf.val
  50. }
  51. // Set -- устанавливает булевый признак.
  52. func (sf *safeBool) Set() {
  53. sf.Lock()
  54. defer sf.Unlock()
  55. sf.val = true
  56. }
  57. // Reset -- сбрасывает булевый признак.
  58. func (sf *safeBool) Reset() {
  59. sf.Lock()
  60. defer sf.Unlock()
  61. sf.val = false
  62. }
  63. // FromStr -- получает число из строки.
  64. func (sf *safeBool) FromStr(strVal string) mL0.IResult[kspec.EBool] {
  65. strVal = strings.ToLower(strVal)
  66. sf.Lock()
  67. defer sf.Unlock()
  68. switch strVal {
  69. case "true":
  70. sf.val = true
  71. case "false":
  72. sf.val = false
  73. default:
  74. return mL0.NewErr[kspec.EBool](fmt.Errorf("safeBool.FromStr(): val(%v) bad", strVal))
  75. }
  76. return mL0.NewOk(ebool.NewEBool(sf.val))
  77. }
  78. // Getenv -- получает значение из окружения.
  79. func (sf *safeBool) Getenv(env string) mL0.IResult[kspec.EBool] {
  80. strVal := os.Getenv(env)
  81. res := sf.FromStr(strVal)
  82. if res.IsErr() {
  83. err := fmt.Errorf("safeBool.Getenv(): from env %v, err=\n\t%w", env, res.Err())
  84. return mL0.NewErr[kspec.EBool](err)
  85. }
  86. return res
  87. }