deployment added

src/udi/config/config.go

@@ -4,6 +4,10 @@ import "encoding/json"
 import "log"
 import "os"
 
+type HandlerConfigT struct {
+  DatabaseConnStr string `json:"databaseConnStr"`
+  Attributes map[string]string `json:"attributes"`
+}
 
 type ConfigT struct {
   Mqtt struct {
@@ -16,11 +20,7 @@ type ConfigT struct {
     Topics []string `json:"topics"`
     Handler string `json:"handler"`
   } `json:"topicMappings"`
-  Handlers []struct {
-    Name string `json:"name"`
-    DatabaseConnStr string `json:"databaseConnStr"`
-    Attributes map[string]string `json:"attributes"`
-  } `json:"handlers"`
+  Handlers map[string]HandlerConfigT `json:"handlers"`
   Archiver struct {
     Dir string `json:"dir"`
   }

src/udi/dispatcher/dispatcher.go

@@ -22,8 +22,8 @@ func InitDispatcher() {
   go archiver()
   handlerMap["TTN"] = ttn.NewTTNHandler()
   handlerMap["IoT"] = iot.NewIoTHandler()
-  handlerMap["PV"] = pv.NewPvHandler()
-  handlerMap["MBGW3"] = mbgw3.NewMbgw3Handler()
+  handlerMap["PV"] = pv.NewPvHandler(config.Config.Handlers["PV"])
+  handlerMap["MBGW3"] = mbgw3.NewMbgw3Handler(config.Config.Handlers["MBGW3"])
 }
 
 func storeMessage(filename string, item handler.MessageT) {

src/udi/handlers/mbgw3/mbgw3.go

@@ -6,6 +6,7 @@ import (
   "time"
   "strconv"
   "encoding/json"
+  "udi/config"
   "udi/handlers/handler"
   "udi/database"
 )
@@ -29,12 +30,12 @@ type Observation struct {
 }
 
 
-func NewMbgw3Handler() *Mbgw3Handler {
+func NewMbgw3Handler(config config.HandlerConfigT) *Mbgw3Handler {
   t := &Mbgw3Handler {
     id: idSeq,
   }
   idSeq += 1
-  t.dbh = database.NewDatabaseHandle("")
+  t.dbh = database.NewDatabaseHandle(config.DatabaseConnStr)
   return t
 }
 

src/udi/handlers/pv/pv.go

@@ -5,6 +5,7 @@ import (
   "reflect"
   "time"
   "encoding/json"
+  "udi/config"
   "udi/handlers/handler"
   "udi/database"
 )
@@ -38,12 +39,12 @@ type PvValue struct {
 }
 
 
-func NewPvHandler() *PvHandler {
+func NewPvHandler(config config.HandlerConfigT) *PvHandler {
   t := &PvHandler {
     id: idSeq,
   }
   idSeq += 1
-  t.dbh = database.NewDatabaseHandle("")
+  t.dbh = database.NewDatabaseHandle(config.DatabaseConnStr)
   return t
 }