Subscribe to remote DeviceDiag server in UCLPC

DerAndereAndi · DerAndereAndi · commit 0f7f85e016ec · 2024-04-09T13:00:15.000+02:00
diff --git a/uclpc/events.go b/uclpc/events.go
@@ -35,7 +35,7 @@ func (e *UCLPC) HandleEvent(payload spineapi.EventPayload) {
 	}
 }
 
-// the remote device was connected
+// the remote entity was connected
 func (e *UCLPC) connected(entity spineapi.EntityRemoteInterface) {
 	// initialise features, e.g. subscriptions, descriptions
 	if loadControl, err := util.LoadControl(e.service, entity); err == nil {
@@ -48,6 +48,12 @@ func (e *UCLPC) connected(entity spineapi.EntityRemoteInterface) {
 			logging.Log().Debug(err)
 		}
 	}
+
+	if localDeviceDiag, err := util.DeviceDiagnosis(e.service, entity); err == nil {
+		if _, err := localDeviceDiag.Subscribe(); err != nil {
+			logging.Log().Debug(err)
+		}
+	}
 }
 
 // the load control limit description data was updated

Original file line number	Diff line number	Diff line change
`@@ -35,7 +35,7 @@ func (e *UCLPC) HandleEvent(payload spineapi.EventPayload) {`
`35`	`35`	`}`
`36`	`36`	`}`
`37`	`37`
`38`		`-// the remote device was connected`
	`38`	`+// the remote entity was connected`
`39`	`39`	`func (e *UCLPC) connected(entity spineapi.EntityRemoteInterface) {`
`40`	`40`	`// initialise features, e.g. subscriptions, descriptions`
`41`	`41`	`if loadControl, err := util.LoadControl(e.service, entity); err == nil {`
`@@ -48,6 +48,12 @@ func (e *UCLPC) connected(entity spineapi.EntityRemoteInterface) {`
`48`	`48`	`logging.Log().Debug(err)`
`49`	`49`	`}`
`50`	`50`	`}`
	`51`	`+`
	`52`	`+ if localDeviceDiag, err := util.DeviceDiagnosis(e.service, entity); err == nil {`
	`53`	`+ if _, err := localDeviceDiag.Subscribe(); err != nil {`
	`54`	`+ logging.Log().Debug(err)`
	`55`	`+ }`
	`56`	`+ }`
`51`	`57`	`}`
`52`	`58`
`53`	`59`	`// the load control limit description data was updated`