harcon-amqp - npm Package Compare versions

Comparing version 8.3.2 to 8.3.3

lib/AmqpBarrel.js

@@ -95,3 +95,3 @@ const { promisify } = require('util')
 
-			self.presences[ status.domain ][ status.entity ][ status.nodeID ] = Date.now()
+			self.presences[ status.domain ][ status.entity ][ status.nodeID ] = { timestamp: Date.now(), warper: status.warper }
 		} catch (err) { self.logger.harconlog( err ) }
@@ -143,3 +143,6 @@ }, true )
 	self.reporter = setInterval( () => { self.reportStatus() }, self.reporterInterval )
+
 	self.presences = {}
+	self.warper.referenceMatrix( self.presences )
+
 	self.keeperInterval = config.keeperInterval || 3000
@@ -278,3 +281,3 @@ self.keeper = setInterval( () => { self.checkPresence() }, self.keeperInterval )
 			Object.keys(self.presences[domain][entity]).forEach( function (nodeID) {
-				if ( self.presences[domain][entity][nodeID] <= timestamp - self.keeperInterval )
+				if ( self.presences[domain][entity][nodeID].timestamp <= timestamp - self.keeperInterval )
 					delete self.presences[domain][entity][nodeID]
@@ -294,3 +297,3 @@ } )
 					self.outs[ domain ].publish( DIVISION_REPORTS, JSON.stringify( {
-						domain: domain, entity: entity, nodeID: self.nodeID, pubKey: self.warper.pubKey
+						domain: domain, entity: entity, nodeID: self.nodeID, warper: self.warper.expose()
 					} ), 'utf8')
@@ -297,0 +300,0 @@ } )

package.json

 {
   "name": "harcon-amqp",
-  "version": "8.3.2",
+  "version": "8.3.3",
   "description": "AMQP plugin for the harcon messaging/service bus of node-based enterprise entities.",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

20110

increased by0.49%

Lines of code

461

increased by0.22%

No dependency changes