subscribeFeedbacks on connect

crosspoint feedback remove parsing of variable which is not accepted.

companion/HELP.md

@@ -31,7 +31,7 @@ The alarms should match the number of configured alarm indexs in your system. Re
 ## Version History
 
 ### Version 1.0.2
-- Minor TCP improvements
+- Minor TCP improvements & fixes
 
 ### Version 1.0.1
 - Update dependencies

src/feedbacks.js

@@ -30,17 +30,11 @@ module.exports = async function (self) {
 			callback: ({ options }) => {
 				return self.connections[options.dst] == options.src
 			},
-			subscribe: async ({ options }) => {
-				let cmd = SOM + control.reqInterrogate + appTag.crosspoint + options.dst + paramSep + nullParam
-				self.addCmdtoQueue(cmd)
+			subscribe: ({ options }) => {
+				self.addCmdtoQueue(SOM + control.reqInterrogate + appTag.crosspoint + options.dst + paramSep + nullParam)
 			},
-			learn: async (feedback) => {
-				let dst = parseInt(await self.parseVariablesInString(feedback.options.dst))
-				if (isNaN(dst) || dst < 1 || dst > self.config.dst) {
-					self.log('warn', `an invalid varible has been passed: ${dst}`)
-					return undefined
-				}
-				const source = self.connections[dst]
+			learn: (feedback) => {
+				const source = self.connections[feedback.options.dst]
 				return {
 					...feedback.options,
 					src: source,

src/main.js

@@ -35,10 +35,10 @@ class NTP_DOT_PROTOCOL extends InstanceBase {
 		this.log('debug', `destroy. ID: ${this.id}`)
 		clearTimeout(this.keepAliveTimer)
 		clearTimeout(this.cmdTimer)
-		this.keepAliveTimer = null
-		this.cmdTimer = null
+		delete this.keepAliveTimer
+		delete this.cmdTimer
 		if (this.socket) {
-			await this.sendCommand(EndSession)
+			this.sendCommand(EndSession)
 			this.socket.destroy()
 		} else {
 			this.updateStatus(InstanceStatus.Disconnected)

src/tcp.js

@@ -51,6 +51,8 @@ module.exports = {
 		this.addCmdtoQueue(SOM + control.reqNotification + appTag.alive + 1 + paramSep + 0)
 		//request alarm notifications
 		this.addCmdtoQueue(SOM + control.reqNotification + appTag.alarm + 1 + paramSep + 1)
+		//make sure all feedbacks are accurate
+		this.subscribeFeedbacks()
 		return true
 	},