foo

config.go

@@ -1,5 +1,5 @@
 /*
- * Johan Stenstam, [email protected]
+ * Johan Stenstam, [email protected]
  */
 
 package main
@@ -10,6 +10,8 @@ import (
 
 	"github.com/go-playground/validator/v10"
 	"github.com/spf13/viper"
+
+	"github.com/dnstapir/tapir"
 )
 
 type Config struct {
@@ -156,3 +158,7 @@ func ValidateBySection(config *Config, configsections map[string]interface{}, cf
 	}
 	return nil
 }
+
+func (td *TemData) ProcessTapirGlobalConfig(tpkg tapir.TapirMsg) {
+	log.Printf("TapirProcessGlobalConfig: %+v", tpkg)
+}

refreshengine.go

@@ -88,10 +88,20 @@ func (td *TemData) RefreshEngine(conf *Config, stopch chan struct{}) {
 	for {
 		select {
 		case tpkg = <-TapirIntelCh:
-			log.Printf("RefreshEngine: Tapir IntelUpdate: (src: %s) %d additions and %d removals\n",
-				tpkg.Data.SrcName, len(tpkg.Data.Added), len(tpkg.Data.Removed))
-			td.ProcessTapirUpdate(tpkg)
-			log.Printf("RefreshEngine: Tapir IntelUpdate evaluated.")
+			switch tpkg.Data.MsgType {
+			case "intelupdate":
+				log.Printf("RefreshEngine: Tapir IntelUpdate: (src: %s) %d additions and %d removals\n",
+					tpkg.Data.SrcName, len(tpkg.Data.Added), len(tpkg.Data.Removed))
+				td.ProcessTapirUpdate(tpkg)
+				log.Printf("RefreshEngine: Tapir IntelUpdate evaluated.")
+
+			case "global-config":
+				td.ProcessTapirGlobalConfig(tpkg.Data)
+				log.Printf("RefreshEngine: Tapir Global Config evaluated.")
+
+			default:
+				log.Printf("RefreshEngine: Tapir IntelUpdate: unknown msg type: %s", tpkg.Data.MsgType)
+			}
 
 		case zr = <-zonerefch:
 			zone = zr.Name

sources.go

@@ -628,6 +628,7 @@ func (td *TemData) ParseLocalFile(sourceid string, s *tapir.WBGlist, rpt chan st
 func (td *TemData) BootstrapMqttSource(s *tapir.WBGlist, src SourceConf) (*tapir.WBGlist, error) {
 	// Initialize the API client
 	api := &tapir.ApiClient{
+		BaseUrl:    fmt.Sprintf(src.BootstrapUrl, src.Bootstrap[0]), // Must specify a valid BaseUrl
 		ApiKey:     src.BootstrapKey,
 		AuthMethod: "X-API-Key",
 	}