Resolve "Implement management component with automatic subscriptions to NEs"

See merge request !358

.gitignore

@@ -23,12 +23,13 @@ cli/gosdnc
 csbi/resources/csbi
 
 # controller
+controller/config/*_test.toml
 controller/configs/testing-gosdn.toml
 controller/configs/gosdn.toml
 controller/configs/development-gosdn.toml
 controller/configs/containerlab-gosdn.toml
-controller/config/*_test.toml
 controller/configs/ci-testing-gosdn.toml
+controller/configs/gNMISubscriptions.txt
 controller/stores_testing
 controller/stores/**
 controller/cmd/gosdn/stores/

controller/config/gnmiSubscriptionConfig.go

+package config
+
+import (
+	"bufio"
+	"fmt"
+	"os"
+	"path/filepath"
+	"strings"
+)
+
+const (
+	defaultGnmiSubscriptionFilePath = "controller/configs/gNMISubscriptions.txt"
+)
+
+var gnmiSubscriptionPaths [][]string
+
+// ReadGnmiSubscriptionPaths reads the paths the watcher should subscribe to provided in a file.
+func ReadGnmiSubscriptionPaths() error {
+	currentDir, err := os.Getwd()
+	if err != nil {
+		return err
+	}
+
+	filePath := filepath.Join(currentDir, defaultGnmiSubscriptionFilePath)
+
+	f, err := os.Open(filePath)
+	if err != nil {
+		return err
+	}
+
+	defer f.Close()
+
+	scanner := bufio.NewScanner(f)
+
+	for scanner.Scan() {
+		path := strings.Split(scanner.Text(), "/")
+		gnmiSubscriptionPaths = append(gnmiSubscriptionPaths, path)
+	}
+
+	fmt.Println(gnmiSubscriptionPaths)
+
+	return nil
+}
+
+// GetGnmiSubscriptionPaths returns the paths the watcher should subscribe to.
+func GetGnmiSubscriptionPaths() [][]string {
+	return gnmiSubscriptionPaths
+}

controller/configs/gNMISubscriptions.txt.example

+system/config/hostname
+system/config/domain-name

controller/controller.go

@@ -74,6 +74,11 @@ func initialize() error {
 		return err
 	}
 
+	err = config.ReadGnmiSubscriptionPaths()
+	if err != nil {
+		log.Error("Error reading in gNMI subscription paths, can not watch devices automatically: ", err)
+	}
+
 	eventService, err := eventservice.NewEventService()
 	if err != nil {
 		return err
@@ -107,8 +112,9 @@ func initialize() error {
 	}
 
 	c.deviceWatcher = nucleus.NewDeviceWatcher(c.pndStore)
-	// TODO: udpate with actual paths to subscribe to using template/config
-	c.deviceWatcher.SubToDevices([][]string{{"system", "config", "hostname"}}, nil)
+	// TODO: udpate with actual paths to subscribe when using template/config
+	fmt.Println(config.GetGnmiSubscriptionPaths())
+	c.deviceWatcher.SubToDevices(config.GetGnmiSubscriptionPaths(), nil)
 
 	err = ensureDefaultRoleExists()
 	if err != nil {