Loading go-apps/meep-sss/sbi/sss-sbi.go +22 −0 Changes for go-apps/meep-sss/sbi/sss-sbi.go: 22 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -394,6 +394,9 @@ func GetSensorData(sensorIdentifier string) (data SensorData, err error) { return data, err } log.Info("sbi.GetSensorData: s: ", s) log.Info("sbi.GetSensorData: s.SensorPropertyList: ", s.SensorPropertyList) log.Info("sbi.GetSensorData: s.SensorCharacteristicList: ", s.SensorCharacteristicList) log.Info("sbi.GetSensorData: s.Flex: ", s.Flex) sensor := convertSensorDiscoveryInfoFromSssMgr(s) log.Info("sbi.GetSensorData: sensors: ", sensor) Loading @@ -407,6 +410,7 @@ func GetSensorData(sensorIdentifier string) (data SensorData, err error) { } j, err := json.Marshal(sensor.SensorCharacteristicList) if err != nil { log.Warn("sbi.GetSensorData: j: ", j) return data, err } data.Data = string(j) Loading @@ -424,14 +428,18 @@ func convertSensorDiscoveryInfoListFromSssMgr(s []tm.SensorDiscoveryInfo) (senso } func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor SensorDiscoveryInfo) { log.Info(">>> sbi.convertSensorDiscoveryInfoFromSssMgr: ", s) sensor = SensorDiscoveryInfo{ SensorIdentifier: s.SensorIdentifier, SensorType: s.SensorType, } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.SensorPropertyList): ", len(s.SensorPropertyList)) if len(s.SensorPropertyList) != 0 { sensor.SensorPropertyList = make([]string, len(s.SensorPropertyList)) copy(sensor.SensorPropertyList, s.SensorPropertyList) } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.SensorCharacteristicList): ", len(s.SensorCharacteristicList)) if len(s.SensorCharacteristicList) != 0 { sensor.SensorCharacteristicList = make([]SensorCharacteristic, len(s.SensorCharacteristicList)) for i, val := range s.SensorCharacteristicList { Loading @@ -442,6 +450,19 @@ func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor Sens } } // End of 'for' statement } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.Flex): ", len(s.Flex)) if len(s.Flex) != 0 { sensor.SensorCharacteristicList = make([]SensorCharacteristic, len(s.Flex)) i := 0 for key, val := range s.Flex { sensor.SensorCharacteristicList[i] = SensorCharacteristic{ CharacteristicName: key, CharacteristicValue: val.(string), CharacteristicUnitOfMeasure: nil, } i += 1 } // End of 'for' statement } if s.SensorPosition != nil { sensor.SensorPosition = &Point{ Latitude: s.SensorPosition.Latitude, Loading @@ -449,5 +470,6 @@ func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor Sens } } log.Info("<<< sbi.convertSensorDiscoveryInfoFromSssMgr: ", sensor) return sensor } go-apps/meep-sss/server/meep-sss.go +8 −0 Changes for go-apps/meep-sss/server/meep-sss.go: 8 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -755,7 +755,11 @@ func sensorStatusLookupGET(w http.ResponseWriter, r *http.Request) { s, err := sbi.GetSensorStatus(q["sensorIdentifier"][0]) if err != nil { if err.Error() == "Wrong Device identifier" { errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest) } else { errHandlerProblemDetails(w, err.Error(), http.StatusInternalServerError) } return } log.Debug("sensorStatusLookupGET: s: ", s) Loading Loading @@ -794,7 +798,11 @@ func sensorDataLookupGET(w http.ResponseWriter, r *http.Request) { s, err := sbi.GetSensorData(q["sensorIdentifier"][0]) if err != nil { if err.Error() == "Wrong Device identifier" { errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest) } else { errHandlerProblemDetails(w, err.Error(), http.StatusInternalServerError) } return } log.Debug("sensorDataLookupGET: s: ", s) Loading Loading
go-apps/meep-sss/sbi/sss-sbi.go +22 −0 Changes for go-apps/meep-sss/sbi/sss-sbi.go: 22 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -394,6 +394,9 @@ func GetSensorData(sensorIdentifier string) (data SensorData, err error) { return data, err } log.Info("sbi.GetSensorData: s: ", s) log.Info("sbi.GetSensorData: s.SensorPropertyList: ", s.SensorPropertyList) log.Info("sbi.GetSensorData: s.SensorCharacteristicList: ", s.SensorCharacteristicList) log.Info("sbi.GetSensorData: s.Flex: ", s.Flex) sensor := convertSensorDiscoveryInfoFromSssMgr(s) log.Info("sbi.GetSensorData: sensors: ", sensor) Loading @@ -407,6 +410,7 @@ func GetSensorData(sensorIdentifier string) (data SensorData, err error) { } j, err := json.Marshal(sensor.SensorCharacteristicList) if err != nil { log.Warn("sbi.GetSensorData: j: ", j) return data, err } data.Data = string(j) Loading @@ -424,14 +428,18 @@ func convertSensorDiscoveryInfoListFromSssMgr(s []tm.SensorDiscoveryInfo) (senso } func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor SensorDiscoveryInfo) { log.Info(">>> sbi.convertSensorDiscoveryInfoFromSssMgr: ", s) sensor = SensorDiscoveryInfo{ SensorIdentifier: s.SensorIdentifier, SensorType: s.SensorType, } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.SensorPropertyList): ", len(s.SensorPropertyList)) if len(s.SensorPropertyList) != 0 { sensor.SensorPropertyList = make([]string, len(s.SensorPropertyList)) copy(sensor.SensorPropertyList, s.SensorPropertyList) } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.SensorCharacteristicList): ", len(s.SensorCharacteristicList)) if len(s.SensorCharacteristicList) != 0 { sensor.SensorCharacteristicList = make([]SensorCharacteristic, len(s.SensorCharacteristicList)) for i, val := range s.SensorCharacteristicList { Loading @@ -442,6 +450,19 @@ func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor Sens } } // End of 'for' statement } log.Info("sbi.convertSensorDiscoveryInfoFromSssMgr: len(s.Flex): ", len(s.Flex)) if len(s.Flex) != 0 { sensor.SensorCharacteristicList = make([]SensorCharacteristic, len(s.Flex)) i := 0 for key, val := range s.Flex { sensor.SensorCharacteristicList[i] = SensorCharacteristic{ CharacteristicName: key, CharacteristicValue: val.(string), CharacteristicUnitOfMeasure: nil, } i += 1 } // End of 'for' statement } if s.SensorPosition != nil { sensor.SensorPosition = &Point{ Latitude: s.SensorPosition.Latitude, Loading @@ -449,5 +470,6 @@ func convertSensorDiscoveryInfoFromSssMgr(s tm.SensorDiscoveryInfo) (sensor Sens } } log.Info("<<< sbi.convertSensorDiscoveryInfoFromSssMgr: ", sensor) return sensor }
go-apps/meep-sss/server/meep-sss.go +8 −0 Changes for go-apps/meep-sss/server/meep-sss.go: 8 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -755,7 +755,11 @@ func sensorStatusLookupGET(w http.ResponseWriter, r *http.Request) { s, err := sbi.GetSensorStatus(q["sensorIdentifier"][0]) if err != nil { if err.Error() == "Wrong Device identifier" { errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest) } else { errHandlerProblemDetails(w, err.Error(), http.StatusInternalServerError) } return } log.Debug("sensorStatusLookupGET: s: ", s) Loading Loading @@ -794,7 +798,11 @@ func sensorDataLookupGET(w http.ResponseWriter, r *http.Request) { s, err := sbi.GetSensorData(q["sensorIdentifier"][0]) if err != nil { if err.Error() == "Wrong Device identifier" { errHandlerProblemDetails(w, err.Error(), http.StatusBadRequest) } else { errHandlerProblemDetails(w, err.Error(), http.StatusInternalServerError) } return } log.Debug("sensorDataLookupGET: s: ", s) Loading