From 261c0b916bbd0e652506918e9fd2f624cc0b541f Mon Sep 17 00:00:00 2001
From: cheetah <git@cheetah.cat>
Date: Fri, 2 Apr 2021 16:16:24 +0000
Subject: [PATCH] added eCityruf Connector

---
 config.json                           |  4 +++
 html/index.html                       | 18 ++++++++--
 index.js                              |  3 ++
 package.json                          |  3 +-
 types/connectors/eCityrufConnector.js | 52 +++++++++++++++++++++++++++
 types/connectors/index.js             |  1 +
 6 files changed, 78 insertions(+), 3 deletions(-)
 create mode 100644 types/connectors/eCityrufConnector.js

diff --git a/config.json b/config.json
index 8779aa6..62730fd 100644
--- a/config.json
+++ b/config.json
@@ -16,6 +16,10 @@
             "enabled": true,
             "duplexTimeout": 300
         },
+		"ecityruf": {
+			"enabled": false,
+			"duplexTimeout": 180
+		},
         "lorawan": {
             "enabled": true,
             "mqttserver": "mqtt://eu.thethings.network:1883",
diff --git a/html/index.html b/html/index.html
index ab65eab..101b349 100644
--- a/html/index.html
+++ b/html/index.html
@@ -67,7 +67,15 @@
                 <label for="pocsag_duplex_timeout">Duplex Timeout(in seconds): [recommended 90s]</label>
                 <input type="number" min="10" max="1200" id="pocsag_duplex_timeout"/>
             </fieldset>
-
+            <fieldset>
+                <legend>eCityruf Connector</legend>
+                <label for="ecityruf_enabled">Enabled:</label>
+                <input type="checkbox" id="ecityruf_enabled"/>
+                </br>
+                <label for="ecityruf_duplex_timeout">Duplex Timeout(in seconds): [recommended 180s]</label>
+                <input type="number" min="10" max="1200" id="ecityruf_duplex_timeout"/>
+            </fieldset>
+            
             <hr>
             <!--
                 <button>Check Settings</button>
@@ -102,6 +110,9 @@
 
             $('#pocsag_enabled').attr('checked', config.connectors.pocsag.enabled)
             $('#pocsag_duplex_timeout').val(config.connectors.pocsag.duplexTimeout)
+
+            $('#ecityruf_enabled').attr('checked', config.connectors.ecityruf.enabled)
+            $('#ecityruf_duplex_timeout').val(config.connectors.ecityruf.duplexTimeout)
         }
         async function saveConfigFromForm() {
             let newConfig = await $.getJSON('/config') // make a copy from the current dispatcher config
@@ -120,7 +131,10 @@
             // connectors.pocsag
             newConfig.connectors.pocsag.enabled = $('#pocsag_enabled').prop('checked')
             newConfig.connectors.pocsag.duplexTimeout = parseInt($('#pocsag_duplex_timeout').val())
-
+            // connectors.ecityruf
+            newConfig.connectors.ecityruf.enabled = $('#ecityruf_enabled').prop('checked')
+            newConfig.connectors.ecityruf.duplexTimeout = parseInt($('#ecityruf_duplex_timeout').val())
+            
             console.log(newConfig)
             await $.ajax({
                 type: 'POST',
diff --git a/index.js b/index.js
index 96c3f19..681bf63 100644
--- a/index.js
+++ b/index.js
@@ -18,6 +18,9 @@ if (!!config.connectors.lorawan && config.connectors.lorawan.enabled === true) {
 if (!!config.connectors.dapnet && config.connectors.dapnet.enabled === true) {
     types.ConnectorRegistry.register(new types.Connectors.DAPNETConnector(connection))
 }
+if (!!config.connectors.ecityruf && config.connectors.ecityruf.enabled === true) {
+    types.ConnectorRegistry.register(new types.Connectors.eCityrufConnector(connection))
+}
 types.ConnectorRegistry.register(new types.Connectors.DummyConnector())
 
 types.DeviceRegistry.register(new types.devices.GenericPager())
diff --git a/package.json b/package.json
index bafe5df..8e4a5d4 100644
--- a/package.json
+++ b/package.json
@@ -24,6 +24,7 @@
     "axios": "^0.21.1",
     "express": "^4.17.1",
     "md5": "^2.3.0",
-    "mqtt": "^4.2.6"
+    "mqtt": "^4.2.6",
+    "querystring": "^0.2.1"
   }
 }
diff --git a/types/connectors/eCityrufConnector.js b/types/connectors/eCityrufConnector.js
new file mode 100644
index 0000000..10b1896
--- /dev/null
+++ b/types/connectors/eCityrufConnector.js
@@ -0,0 +1,52 @@
+const Connector = require("./Connector")
+const config = require('../../config.json')
+const md5 = require('md5')
+const axios = require('axios')
+// [ "ecityruf", "123456789" ]
+class eCityrufConnector extends Connector {
+  constructor (amqpConnMngr) {
+    super(amqpConnMngr)
+    this.name = "ecityruf"
+    this.duplexCapable = false
+  }
+  async transmitMessage(msg, params) {
+      const UUID = this.name+':'+md5(JSON.stringify([this.name,...params]))
+      if (params.length !== 1) return false
+      const cityrufRequest = require('querystring').stringify({
+        service: 1,
+        class: 7,
+        language: 'en',
+        action: 'SendMessage',
+        number: params[ 0 ],
+        message: msg.payload,
+        lengthAlert: '',
+      })
+      console.log(cityrufRequest)
+      return axios.post('https://inetgateway.emessage.de/cgi-bin/funkruf2.cgi', cityrufRequest, {
+        headers: {
+          'Content-Type': 'application/x-www-form-urlencoded',
+          'Sec-Fetch-Site': 'same-origin',
+          'Sec-Fetch-Mode': 'navigate',
+          'Sec-Fetch-User': '?1',
+          'Sec-Fetch-Dest': 'document',
+          'Referer': 'https://inetgateway.emessage.de/cgi-bin/funkruf2.cgi'
+        }
+      })
+      .then((res) => {
+        if (res.status === 200) {
+          if (res.data.indexOf('OK. Your message has been sent') > -1) {
+            this.connectorRegistry.reportState(msg, UUID, 'routed')
+            return true
+          }
+        }
+        this.connectorRegistry.reportFail(msg, UUID)
+        return false
+      })
+      .catch((err) => {
+        console.error(err.response.data)
+        this.connectorRegistry.reportFail(msg, UUID)
+        return false
+      })
+  }
+}
+module.exports = eCityrufConnector
\ No newline at end of file
diff --git a/types/connectors/index.js b/types/connectors/index.js
index eb943f3..7f01939 100644
--- a/types/connectors/index.js
+++ b/types/connectors/index.js
@@ -1,5 +1,6 @@
 module.exports = {
     DAPNETConnector: require("./DAPNETConnector"),
+    eCityrufConnector: require('./eCityrufConnector'),
     LoRaWANConnector: require("./LoRaWANConnector"),
     POCSAGConnector: require("./POCSAGConnector"),
     DummyConnector: require("./DummyConnector"),