Merge branch 'master' of https://git.cheetah.cat/smartpager/dispatcher

config.json

@@ -12,6 +12,10 @@
             "enabled": true,
             "duplexTimeout": 300
         },
+        "pagernetzAT": {
+            "enabled": true,
+            "duplexTimeout": 300
+        },
         "pocsag": {
             "enabled": true,
             "duplexTimeout": 300

index.js

@@ -32,6 +32,9 @@ if (!!config.connectors.emPuppettering && config.connectors.emPuppettering.enabl
     types.ConnectorRegistry.register(new types.Connectors.eMessagePuppeteerConnectorTwoWays(connection))
 }
 
+if (!!config.connectors.ecityruf && config.connectors.pagernetzAT.enabled === true) {
+    types.ConnectorRegistry.register(new types.Connectors.PagernetzConnetorAT(connection))
+}
 
 types.ConnectorRegistry.register(new types.Connectors.DummyConnector())
 

types/connectors/PagernetzConnetorAT.js

@@ -0,0 +1,17 @@
+const Connector = require("./Connector")
+const md5 = require('md5')
+
+const config = require('../../config.json')
+class PagernetzConnetorAT extends Connector {
+  constructor (amqpConnMngr) {
+    super(amqpConnMngr)
+    this.name = "pagernetz-at"
+    this.duplexCapable = true
+  }
+  async transmitMessage(msg, params) {
+    const UUID = this.name+':'+md5(JSON.stringify([ this.name, ...params ])) // uuid=name+hash of name+args
+    await new Promise((res)=>setTimeout(res,3e3))
+    this.connectorRegistry.reportFail(msg, UUID)
+  }
+}
+module.exports = PagernetzConnetorAT

types/connectors/index.js

@@ -21,6 +21,8 @@ module.exports = {
     eMessagePuppeteerConnectorCityruf,
     eMessagePuppeteerConnectorTwoWays,
 
+    PagernetzConnetorAT: require('./PagernetzConnetorAT'),
+
     LoRaWANConnector: require("./LoRaWANConnector"),
     POCSAGConnector: require("./POCSAGConnector"),
     DummyConnector: require("./DummyConnector"),