diff --git a/handler/real_time_data_subscription.go b/handler/real_time_data_subscription.go index 7faa3cd..f0f435b 100644 --- a/handler/real_time_data_subscription.go +++ b/handler/real_time_data_subscription.go @@ -383,6 +383,9 @@ func mergeMeasurementsForStart(config *RealTimeSubConfig, newMeasurements map[st config.measurements[interval] = existingMeas maps.Copy(config.targetContext, newMeasurementsContextMap) } + } else { + config.measurements[interval] = newMeas + maps.Copy(config.targetContext, newMeasurementsContextMap) } } return allDuplicates diff --git a/router/component.go b/router/component.go new file mode 100644 index 0000000..76bad8a --- /dev/null +++ b/router/component.go @@ -0,0 +1,14 @@ +// Package router provides router config +package router + +import ( + "modelRT/handler" + + "github.com/gin-gonic/gin" +) + +// registerComponentRoutes define func of register component routes +func registerComponentRoutes(rg *gin.RouterGroup) { + g := rg.Group("/component/") + g.POST("attribute/update", handler.ComponentAttributeUpdateHandler) +} diff --git a/router/router.go b/router/router.go index d91f7a2..f785202 100644 --- a/router/router.go +++ b/router/router.go @@ -26,4 +26,5 @@ func RegisterRoutes(engine *gin.Engine, clientToken string) { registerMeasurementRoutes(routeGroup, middleware.SetTokenMiddleware(clientToken), measurementLimiter.Middleware) registerDataRoutes(routeGroup) registerMonitorRoutes(routeGroup) + registerComponentRoutes(routeGroup) }