Merge pull request 'add toml provider' (#7) from toml into master

Reviewed-on: #7

.drone.yml

@@ -1,3 +1,4 @@
+---
 kind: pipeline
 name: default
 
@@ -11,10 +12,82 @@ steps:
   image: golang
   commands:
   # - go test -parallel 10 -race ./... 
-  # - go test -race ./... 
   - go test ./... 
 
 - name: golangci-lint
   image: golangci/golangci-lint:v1.55
   commands:
   - golangci-lint run
+
+---
+kind: pipeline
+name: json
+
+steps:
+- name: test 
+  image: golang
+  commands:
+  - cd provider/json
+  - go test ./... 
+
+- name: golangci-lint
+  image: golangci/golangci-lint:v1.55
+  commands:
+  - cd provider/json
+  - golangci-lint run
+
+---
+kind: pipeline
+name: yaml
+
+steps:
+- name: test 
+  image: golang
+  commands:
+  - cd provider/yaml
+  - go test ./... 
+
+- name: golangci-lint
+  image: golangci/golangci-lint:v1.55
+  commands:
+  - cd provider/yaml
+  - golangci-lint run
+
+---
+kind: pipeline
+type: docker
+name: ini
+
+steps:
+- name: test 
+  image: golang
+  failure: ignore # runtime/cgo: pthread_create failed: Operation not permitted
+  commands:
+  - cd provider/ini
+  - go test ./... 
+
+- name: golangci-lint
+  image: golangci/golangci-lint:v1.55
+  commands:
+  - cd provider/ini
+  - golangci-lint run
+
+
+---
+kind: pipeline
+type: docker
+name: toml
+
+steps:
+- name: test 
+  image: golang
+  commands:
+  - cd provider/toml
+  - go test ./... 
+
+- name: golangci-lint
+  image: golangci/golangci-lint:v1.55
+  commands:
+  - cd provider/toml
+  - golangci-lint run
+

provider/ini/go.mod

@@ -0,0 +1,15 @@
+module gitoa.ru/go-4devs/config/provider/ini
+
+go 1.21
+
+require (
+	github.com/stretchr/testify v1.8.4
+	gitoa.ru/go-4devs/config v0.0.1
+	gopkg.in/ini.v1 v1.67.0
+)
+
+require (
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)

provider/ini/go.sum

@@ -0,0 +1,14 @@
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
+github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
+gitoa.ru/go-4devs/config v0.0.1 h1:9KrOO09YbIMO8qL8aVn/G74DurGdOIW5y3O02bays4I=
+gitoa.ru/go-4devs/config v0.0.1/go.mod h1:xfEC2Al9xnMLJUuekYs3KhJ5BIzWAseNwkMwbN6/xss=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA=
+gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

provider/ini/provider.go

@@ -0,0 +1,58 @@
+package ini
+
+import (
+	"context"
+	"fmt"
+	"strings"
+
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/value"
+	"gopkg.in/ini.v1"
+)
+
+const (
+	Name      = "ini"
+	Separator = "."
+)
+
+var _ config.Provider = (*Provider)(nil)
+
+func New(data *ini.File) *Provider {
+	return &Provider{
+		data: data,
+		resolve: func(path []string) (string, string) {
+			if len(path) == 1 {
+				return "", path[0]
+			}
+
+			return strings.Join(path[:len(path)-1], Separator), strings.ToUpper(path[len(path)-1])
+		},
+		name: Name,
+	}
+}
+
+type Provider struct {
+	data    *ini.File
+	resolve func(path []string) (string, string)
+	name    string
+}
+
+func (p *Provider) Name() string {
+	return p.name
+}
+
+func (p *Provider) Value(_ context.Context, path ...string) (config.Value, error) {
+	section, name := p.resolve(path)
+
+	iniSection, err := p.data.GetSection(section)
+	if err != nil {
+		return nil, fmt.Errorf("%w: %s: %w", config.ErrValueNotFound, p.Name(), err)
+	}
+
+	iniKey, err := iniSection.GetKey(name)
+	if err != nil {
+		return nil, fmt.Errorf("%w: %s: %w", config.ErrValueNotFound, p.Name(), err)
+	}
+
+	return value.JString(iniKey.String()), nil
+}

provider/ini/provider_test.go

@@ -0,0 +1,38 @@
+package ini_test
+
+import (
+	"embed"
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/require"
+	"gitoa.ru/go-4devs/config/provider/ini"
+	"gitoa.ru/go-4devs/config/test"
+	lib "gopkg.in/ini.v1"
+)
+
+//go:embed fixture/*
+var fixtures embed.FS
+
+func TestProvider(t *testing.T) {
+	t.Parallel()
+
+	data, derr := fixtures.ReadFile("fixture/config.ini")
+	require.NoError(t, derr)
+
+	file, err := lib.Load(data)
+	require.NoError(t, err)
+
+	read := []test.Read{
+		test.NewRead("To Do, In Progress, Done", "project", "PROJECT_BOARD_BASIC_KANBAN_TYPE"),
+		test.NewRead("markdown", "repository.editor", "PREVIEWABLE_FILE_MODES"),
+		test.NewRead("http://0.0.0.0:3000/", "server", "LOCAL_ROOT_URL"),
+		test.NewRead(20*time.Minute, "server", "LFS_HTTP_AUTH_EXPIRY"),
+		test.NewRead(5120, "repository.pull-request", "DEFAULT_MERGE_MESSAGE_SIZE"),
+		test.NewRead(true, "ui", "SHOW_USER_EMAIL"),
+		test.NewRead(false, "cors", "enabled"),
+	}
+
+	prov := ini.New(file)
+	test.Run(t, prov, read)
+}

provider/json/fixture/config.json

@@ -0,0 +1,17 @@
+{
+    "app": {
+        "name": {
+            "var": [
+                "name"
+            ],
+            "title": "config title",
+            "timeout": "1m",
+            "success": true
+        }
+    },
+    "cfg": {
+        "duration": 1260000000000,
+        "enabled": true,
+        "type":"json"
+    }
+}

provider/json/go.mod

@@ -0,0 +1,13 @@
+module gitoa.ru/go-4devs/config/provider/json
+
+go 1.21
+
+require (
+	github.com/tidwall/gjson v1.17.0
+	gitoa.ru/go-4devs/config v0.0.1
+)
+
+require (
+	github.com/tidwall/match v1.1.1 // indirect
+	github.com/tidwall/pretty v1.2.0 // indirect
+)

provider/json/go.sum

@@ -0,0 +1,10 @@
+github.com/tidwall/gjson v1.17.0 h1:/Jocvlh98kcTfpN2+JzGQWQcqrPQwDrVEMApx/M5ZwM=
+github.com/tidwall/gjson v1.17.0/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
+github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA=
+github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
+github.com/tidwall/pretty v1.2.0 h1:RWIZEg2iJ8/g6fDDYzMpobmaoGh5OLl4AXtGUGPcqCs=
+github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
+gitoa.ru/go-4devs/config v0.0.0-20240125174937-085589a9383a h1:61iwpn1Ec4yIkBSvSz8knNENJuhj6v2rp6bfw1wkG0E=
+gitoa.ru/go-4devs/config v0.0.0-20240125174937-085589a9383a/go.mod h1:3g2bwE2OTDyYwm33KN/Cqc8pEdGlWXnB8Ju3PsYNQr0=
+gitoa.ru/go-4devs/config v0.0.1 h1:9KrOO09YbIMO8qL8aVn/G74DurGdOIW5y3O02bays4I=
+gitoa.ru/go-4devs/config v0.0.1/go.mod h1:xfEC2Al9xnMLJUuekYs3KhJ5BIzWAseNwkMwbN6/xss=

provider/json/provider.go

@@ -0,0 +1,65 @@
+package json
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/tidwall/gjson"
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/value"
+)
+
+const (
+	Name      = "json"
+	Separator = "."
+)
+
+var _ config.Provider = (*Provider)(nil)
+
+func New(json []byte, opts ...Option) *Provider {
+	provider := Provider{
+		key: func(s ...string) string {
+			return strings.Join(s, Separator)
+		},
+		data: json,
+	}
+
+	for _, opt := range opts {
+		opt(&provider)
+	}
+
+	return &provider
+}
+
+func NewFile(path string, opts ...Option) (*Provider, error) {
+	file, err := os.ReadFile(filepath.Clean(path))
+	if err != nil {
+		return nil, fmt.Errorf("%w: unable to read config file %#q: file not found or unreadable", err, path)
+	}
+
+	return New(file, opts...), nil
+}
+
+type Option func(*Provider)
+
+type Provider struct {
+	data []byte
+	key  func(...string) string
+	name string
+}
+
+func (p *Provider) Name() string {
+	return p.name
+}
+
+func (p *Provider) Value(_ context.Context, path ...string) (config.Value, error) {
+	key := p.key(path...)
+	if val := gjson.GetBytes(p.data, key); val.Exists() {
+		return value.JString(val.String()), nil
+	}
+
+	return nil, fmt.Errorf("%v:%w", p.Name(), config.ErrValueNotFound)
+}

provider/json/provider_example_test.go

@@ -0,0 +1,55 @@
+package json_test
+
+import (
+	"context"
+	"fmt"
+	"log"
+
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/provider/json"
+	"gitoa.ru/go-4devs/config/test"
+)
+
+func ExampleClient_Value() {
+	ctx := context.Background()
+
+	// read json config
+	jsonConfig, jerr := fixture.ReadFile("fixture/config.json")
+	if jerr != nil {
+		log.Printf("failed load file:%v", jerr)
+
+		return
+	}
+
+	config, err := config.New(
+		json.New(jsonConfig),
+	)
+	if err != nil {
+		log.Print(err)
+
+		return
+	}
+
+	title, err := config.Value(ctx, "app.name.title")
+	if err != nil {
+		log.Print("app.name.title", err)
+
+		return
+	}
+
+	cfgValue, err := config.Value(ctx, "cfg")
+	if err != nil {
+		log.Print("cfg ", err)
+
+		return
+	}
+
+	cfg := test.Config{}
+	_ = cfgValue.Unmarshal(&cfg)
+
+	fmt.Printf("title from json: %v\n", title.String())
+	fmt.Printf("struct from json: %+v\n", cfg)
+	// Output:
+	// title from json: config title
+	// struct from json: {Duration:21m0s Enabled:true}
+}

provider/json/provider_test.go

@@ -0,0 +1,33 @@
+package json_test
+
+import (
+	"embed"
+	"testing"
+	"time"
+
+	"gitoa.ru/go-4devs/config/provider/json"
+	"gitoa.ru/go-4devs/config/test"
+	"gitoa.ru/go-4devs/config/test/require"
+)
+
+//go:embed fixture/*
+var fixture embed.FS
+
+func TestProvider(t *testing.T) {
+	t.Parallel()
+
+	js, err := fixture.ReadFile("fixture/config.json")
+	require.NoError(t, err)
+
+	prov := json.New(js)
+	sl := []string{}
+	read := []test.Read{
+		test.NewRead("config title", "app.name.title"),
+		test.NewRead(time.Minute, "app.name.timeout"),
+		test.NewReadUnmarshal(&[]string{"name"}, &sl, "app.name.var"),
+		test.NewReadConfig("cfg"),
+		test.NewRead(true, "app", "name", "success"),
+	}
+
+	test.Run(t, prov, read)
+}

provider/toml/fixture/config.toml

@@ -0,0 +1,31 @@
+title = "TOML Example"
+
+[owner]
+name = "Tom Preston-Werner"
+dob = 1979-05-27T07:32:00-08:00 # First class dates
+
+[database]
+server = "192.168.1.1"
+ports = [ 8001, 8001, 8002 ]
+connection_max = 5000
+enabled = true
+
+[servers]
+
+  # Indentation (tabs and/or spaces) is allowed but not required
+  [servers.alpha]
+  ip = "10.0.0.1"
+  dc = "eqdc10"
+
+  [servers.beta]
+  ip = "10.0.0.2"
+  dc = "eqdc10"
+
+[clients]
+data = [ ["gamma", "delta"], [1, 2] ]
+
+# Line breaks are OK when inside arrays
+hosts = [
+  "alpha",
+  "omega"
+]

provider/toml/go.mod

@@ -0,0 +1,15 @@
+module gitoa.ru/go-4devs/config/provider/toml
+
+go 1.21
+
+require (
+	github.com/pelletier/go-toml v1.9.5
+	github.com/stretchr/testify v1.8.4
+	gitoa.ru/go-4devs/config v0.0.1
+)
+
+require (
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)

provider/toml/go.sum

@@ -0,0 +1,14 @@
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/pelletier/go-toml v1.9.5 h1:4yBQzkHv+7BHq2PQUZF3Mx0IYxG7LsP222s7Agd3ve8=
+github.com/pelletier/go-toml v1.9.5/go.mod h1:u1nR/EPcESfeI/szUZKdtJ0xRNbUoANCkoOuaOx1Y+c=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
+github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
+gitoa.ru/go-4devs/config v0.0.1 h1:9KrOO09YbIMO8qL8aVn/G74DurGdOIW5y3O02bays4I=
+gitoa.ru/go-4devs/config v0.0.1/go.mod h1:xfEC2Al9xnMLJUuekYs3KhJ5BIzWAseNwkMwbN6/xss=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

provider/toml/provider.go

@@ -0,0 +1,71 @@
+package toml
+
+import (
+	"context"
+	"fmt"
+	"strings"
+
+	"github.com/pelletier/go-toml"
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/value"
+)
+
+const (
+	Name      = "toml"
+	Separator = "."
+)
+
+var _ config.Provider = (*Provider)(nil)
+
+func NewFile(file string, opts ...Option) (*Provider, error) {
+	tree, err := toml.LoadFile(file)
+	if err != nil {
+		return nil, fmt.Errorf("toml: failed load file: %w", err)
+	}
+
+	return configure(tree, opts...), nil
+}
+
+type Option func(*Provider)
+
+func configure(tree *toml.Tree, opts ...Option) *Provider {
+	prov := &Provider{
+		tree: tree,
+		key: func(s []string) string {
+			return strings.Join(s, Separator)
+		},
+	}
+
+	for _, opt := range opts {
+		opt(prov)
+	}
+
+	return prov
+}
+
+func New(data []byte, opts ...Option) (*Provider, error) {
+	tree, err := toml.LoadBytes(data)
+	if err != nil {
+		return nil, fmt.Errorf("toml failed load data: %w", err)
+	}
+
+	return configure(tree, opts...), nil
+}
+
+type Provider struct {
+	tree *toml.Tree
+	key  func([]string) string
+	name string
+}
+
+func (p *Provider) Name() string {
+	return p.name
+}
+
+func (p *Provider) Value(_ context.Context, path ...string) (config.Value, error) {
+	if k := p.key(path); p.tree.Has(k) {
+		return Value{Value: value.Value{Val: p.tree.Get(k)}}, nil
+	}
+
+	return nil, config.ErrValueNotFound
+}

provider/toml/provider_test.go

@@ -0,0 +1,36 @@
+package toml_test
+
+import (
+	"embed"
+	"testing"
+
+	"gitoa.ru/go-4devs/config/provider/toml"
+	"gitoa.ru/go-4devs/config/test"
+	"gitoa.ru/go-4devs/config/test/require"
+)
+
+//go:embed fixture/*
+var fixtures embed.FS
+
+func TestProvider(t *testing.T) {
+	t.Parallel()
+
+	files, ferr := fixtures.ReadFile("fixture/config.toml")
+	require.NoError(t, ferr)
+
+	prov, err := toml.New(files)
+	require.NoError(t, err)
+
+	m := []int{}
+
+	read := []test.Read{
+		test.NewRead("192.168.1.1", "database.server"),
+		test.NewRead("TOML Example", "title"),
+		test.NewRead("10.0.0.1", "servers.alpha.ip"),
+		test.NewRead(true, "database.enabled"),
+		test.NewRead(5000, "database.connection_max"),
+		test.NewReadUnmarshal(&[]int{8001, 8001, 8002}, &m, "database", "ports"),
+	}
+
+	test.Run(t, prov, read)
+}

provider/toml/value.go

@@ -0,0 +1,41 @@
+package toml
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/value"
+)
+
+type Value struct {
+	value.Value
+}
+
+func (s Value) Int() int {
+	v, _ := s.ParseInt()
+
+	return v
+}
+
+func (s Value) ParseInt() (int, error) {
+	v, err := s.ParseInt64()
+	if err != nil {
+		return 0, fmt.Errorf("toml failed parce int: %w", err)
+	}
+
+	return int(v), nil
+}
+
+func (s Value) Unmarshal(target interface{}) error {
+	b, err := json.Marshal(s.Raw())
+	if err != nil {
+		return fmt.Errorf("%w: %w", config.ErrInvalidValue, err)
+	}
+
+	if err := json.Unmarshal(b, target); err != nil {
+		return fmt.Errorf("%w: %w", config.ErrInvalidValue, err)
+	}
+
+	return nil
+}

provider/yaml/fixture/config.yaml

@@ -0,0 +1,14 @@
+app:
+    title: yaml title
+    name:
+        var: 
+            - test
+        bool_var: true
+duration_var: 21m
+empty_var: 
+url_var: "http://google.com/"
+time_var: "2020-01-02T15:04:05Z"
+cfg:
+    duration: 21m
+    enabled: true
+    type: yaml

provider/yaml/go.mod

@@ -0,0 +1,8 @@
+module gitoa.ru/go-4devs/config/provider/yaml
+
+go 1.21
+
+require (
+	gitoa.ru/go-4devs/config v0.0.1
+	gopkg.in/yaml.v3 v3.0.1
+)

provider/yaml/go.sum

@@ -0,0 +1,6 @@
+gitoa.ru/go-4devs/config v0.0.1 h1:9KrOO09YbIMO8qL8aVn/G74DurGdOIW5y3O02bays4I=
+gitoa.ru/go-4devs/config v0.0.1/go.mod h1:xfEC2Al9xnMLJUuekYs3KhJ5BIzWAseNwkMwbN6/xss=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

provider/yaml/provider.go

@@ -0,0 +1,100 @@
+package yaml
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"os"
+
+	"gitoa.ru/go-4devs/config"
+	"gitoa.ru/go-4devs/config/value"
+	"gopkg.in/yaml.v3"
+)
+
+const (
+	Name = "yaml"
+)
+
+var _ config.Provider = (*Provider)(nil)
+
+func NewFile(name string, opts ...Option) (*Provider, error) {
+	in, err := os.ReadFile(name)
+	if err != nil {
+		return nil, fmt.Errorf("yaml_file: read error: %w", err)
+	}
+
+	return New(in, opts...)
+}
+
+func New(yml []byte, opts ...Option) (*Provider, error) {
+	var data yaml.Node
+	if err := yaml.Unmarshal(yml, &data); err != nil {
+		return nil, fmt.Errorf("yaml: unmarshal err: %w", err)
+	}
+
+	return create(opts...).With(&data), nil
+}
+
+func create(opts ...Option) *Provider {
+	prov := Provider{
+		name: Name,
+	}
+
+	for _, opt := range opts {
+		opt(&prov)
+	}
+
+	return &prov
+}
+
+type Option func(*Provider)
+
+type Provider struct {
+	data node
+	name string
+}
+
+func (p *Provider) Name() string {
+	return p.name
+}
+
+func (p *Provider) Value(_ context.Context, path ...string) (config.Value, error) {
+	return p.data.read(p.Name(), path)
+}
+
+func (p *Provider) With(data *yaml.Node) *Provider {
+	return &Provider{
+		data: node{Node: data},
+	}
+}
+
+type node struct {
+	*yaml.Node
+}
+
+func (n *node) read(name string, keys []string) (config.Value, error) {
+	val, err := getData(n.Node.Content[0].Content, keys)
+	if err != nil {
+		if errors.Is(err, config.ErrValueNotFound) {
+			return nil, fmt.Errorf("%w: %s", config.ErrValueNotFound, name)
+		}
+
+		return nil, fmt.Errorf("%w: %s", err, name)
+	}
+
+	return value.Decode(val), nil
+}
+
+func getData(node []*yaml.Node, keys []string) (func(interface{}) error, error) {
+	for idx := len(node) - 1; idx > 0; idx -= 2 {
+		if node[idx-1].Value == keys[0] {
+			if len(keys) > 1 {
+				return getData(node[idx].Content, keys[1:])
+			}
+
+			return node[idx].Decode, nil
+		}
+	}
+
+	return nil, config.ErrValueNotFound
+}

provider/yaml/provider_test.go

@@ -0,0 +1,32 @@
+package yaml_test
+
+import (
+	"embed"
+	"testing"
+	"time"
+
+	"gitoa.ru/go-4devs/config/provider/yaml"
+	"gitoa.ru/go-4devs/config/test"
+	"gitoa.ru/go-4devs/config/test/require"
+)
+
+//go:embed fixture/*
+var fixture embed.FS
+
+func TestProvider(t *testing.T) {
+	t.Parallel()
+
+	data, err := fixture.ReadFile("fixture/config.yaml")
+	require.NoError(t, err)
+	prov, err := yaml.New(data)
+	require.NoError(t, err)
+
+	read := []test.Read{
+		test.NewRead(21*time.Minute, "duration_var"),
+		test.NewRead(true, "app", "name", "bool_var"),
+		test.NewRead(test.Time("2020-01-02T15:04:05Z"), "time_var"),
+		test.NewReadConfig("cfg"),
+	}
+
+	test.Run(t, prov, read)
+}

provider/yaml/watch.go

@@ -0,0 +1,46 @@
+package yaml
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	"gitoa.ru/go-4devs/config"
+	"gopkg.in/yaml.v3"
+)
+
+const NameWatch = "yaml_watch"
+
+func NewWatch(name string, opts ...Option) *Watch {
+	wath := Watch{
+		file: name,
+		prov: create(opts...),
+		name: NameWatch,
+	}
+
+	return &wath
+}
+
+type Watch struct {
+	file string
+	prov *Provider
+	name string
+}
+
+func (p *Watch) Name() string {
+	return p.name
+}
+
+func (p *Watch) Value(ctx context.Context, path ...string) (config.Value, error) {
+	in, err := os.ReadFile(p.file)
+	if err != nil {
+		return nil, fmt.Errorf("yaml_file: read error: %w", err)
+	}
+
+	var yNode yaml.Node
+	if err = yaml.Unmarshal(in, &yNode); err != nil {
+		return nil, fmt.Errorf("yaml_file: unmarshal error: %w", err)
+	}
+
+	return p.prov.With(&yNode).Value(ctx, path...)
+}