adapters. fix state on branch.

Author: RapidCodeLab

cmd/app/main.go

@@ -47,7 +47,10 @@ func main() {
 		os.Exit(1)
 	}
 
-	l.Infof("application started. %s\n", time.Now().Format("2006-01-02 15:04:05"))
+	l.Infof(
+		"application started. %s\n",
+		time.Now().Format("2006-01-02 15:04:05"),
+	)
 
 	ctx := context.Background()
 	ctx, cancel := context.WithCancel(ctx)
@@ -72,13 +75,18 @@ func main() {
 		os.Exit(1)
 	}
 
-	deviceDetector, err := browscap_devicedetector.New(config.DeviceDBPath)
+	deviceDetector, err := browscap_devicedetector.New(
+		config.DeviceDBPath,
+	)
 	if err != nil {
 		l.Errorf("deviceDB open: %s\n", err.Error())
 		os.Exit(1)
 	}
 
-	geoDetector, err := geoip2_detector.New(config.GeoDBPath, "ru")
+	geoDetector, err := geoip2_detector.New(
+		config.GeoDBPath,
+		"ru",
+	)
 	if err != nil {
 		l.Errorf("geoDB open: %s\n", err.Error())
 		os.Exit(1)
@@ -87,7 +95,10 @@ func main() {
 	app := core.New(s, l)
 
 	enabledDSPAdapters := []interfaces.DSPName{}
-	dspConfigProvider, err := default_config_provider.New(config.DSPAdaptersConfigFilePath)
+	dspConfigProvider, err := default_config_provider.New(
+		config.DSPAdaptersConfigFilePath,
+		l,
+	)
 	if err != nil {
 		l.Errorf("dsp config provider: %s\n", err.Error())
 		os.Exit(1)
@@ -105,5 +116,8 @@ func main() {
 		os.Exit(1)
 	}
 
-	l.Infof("application successfully stopped. %s", time.Now().Format("2006-01-02 15:04:05"))
+	l.Infof(
+		"application successfully stopped. %s",
+		time.Now().Format("2006-01-02 15:04:05"),
+	)
 }

dsp-adapters/config-providers/default/main.go

@@ -1,16 +1,57 @@
 package default_config_provider
 
-import "github.com/RapidCodeLab/rapid-prebid-server/internal/application/interfaces"
+import (
+	"encoding/json"
+	"errors"
+	"io/fs"
+	"os"
+	"path/filepath"
 
-type provider struct{}
+	"github.com/RapidCodeLab/rapid-prebid-server/internal/application/interfaces"
+)
+
+var NoConfigFilesErr = errors.New("no config files found in path")
+
+type provider struct {
+	data map[interfaces.DSPName]interfaces.DSPAdapterConfig
+}
 
 func New(
 	path string,
+	l interfaces.Logger,
 ) (
 	interfaces.DSPConfigProvider,
 	error,
 ) {
-	return &provider{}, nil
+	configFiles, err := findFiles(path, ".json")
+	if err != nil {
+		return nil, err
+	}
+	if len(configFiles) < 1 {
+		return nil, NoConfigFilesErr
+	}
+
+	provider := &provider{}
+	provider.data = make(map[interfaces.DSPName]interfaces.DSPAdapterConfig)
+
+	for _, filePath := range configFiles {
+		f, err := os.Open(filePath)
+		if err != nil {
+			l.Errorf("read dsp config file: %s", err.Error())
+			continue
+		}
+
+		decoder := json.NewDecoder(f)
+		config := interfaces.DSPAdapterConfig{}
+		err = decoder.Decode(&config)
+		if err != nil {
+			l.Errorf("decode config:%s", err.Error())
+			continue
+		}
+		provider.data[config.Name] = config
+	}
+
+	return provider, nil
 }
 
 func (i *provider) Read(
@@ -21,3 +62,19 @@ func (i *provider) Read(
 ) {
 	return interfaces.DSPAdapterConfig{}, nil
 }
+
+func findFiles(root, ext string) ([]string, error) {
+	var a []string
+	err := filepath.WalkDir(
+		root,
+		func(s string, d fs.DirEntry, e error) error {
+			if e != nil {
+				return e
+			}
+			if filepath.Ext(d.Name()) == ext {
+				a = append(a, s)
+			}
+			return nil
+		})
+	return a, err
+}