smartpager/dispatcher
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

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

Browse source
This commit is contained in:
cheetah 2025-03-23 22:39:33 +01:00
commit 4c6b96fabd
5 changed files with 106 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
config.json
View file

@ -54,7 +54,14 @@
"pnet": {
"enabled": true,
"duplexTimeout": 10
}
},
"tetracontrol": {
"enabled": true,
"endpoint": "10.13.123.123:80",
"username": "user",
"password": "password",
"duplexTimeout": 300
}
},
"pagers": {
"birdyslim": {
@ -75,4 +82,4 @@
},
"deliveryPresets": {
}
}
}

34
html_config/index.html
View file

@ -141,6 +141,32 @@
</v-list-item-action>
</v-list-item-content>
</v-list-item>
<v-list-item> <!-- TETRACONTROL-->
<v-list-item-content>
<v-list-item-title>TETRACONTROL</v-list-item-title>
<v-list-item-action>
<v-row cols="12">
<v-col cols="6" sm="6" md="6">
<v-switch v-model="configData.connectors.tetracontrol.enabled" label="Enabled"></v-switch>
</v-col>
<v-col cols="6" sm="6" md="6">
<v-text-field type="number" :rules="validNumberRules" label="Duplex Timeout in seconds" v-model="configData.connectors.tetracontrol.duplexTimeout"></v-text-field>
</v-col>
<v-col cols="6" sm="6" md="6">
<v-text-field label="Username" v-model="configData.connectors.tetracontrol.username"></v-text-field>
</v-col>
<v-col cols="6" sm="6" md="6">
<v-text-field label="Password" type="password" v-model="configData.connectors.tetracontrol.password"></v-text-field>
</v-col>
<v-col cols="6" sm="6" md="6">
<v-text-field label="Endpoint" v-model="configData.connectors.tetracontrol.endpoint"></v-text-field>
</v-col>
</v-row>
</v-list-item-action>
</v-list-item-content>
</v-list-item>
<v-list-item> <!-- LoRaWAN-->
<v-list-item-content>
<v-list-item-title>LoRaWAN</v-list-item-title>
@ -332,6 +358,7 @@
{ k: 'Dummy', v: 'dummy' },
{ k: 'POCSAG GW', v: 'pocsag' },
{ k: 'DAPNET', v: 'dapnet' },
{ k: 'TETRAControl', v: 'tetracontrol' },
{ k: 'e*Cityruf inetgw', v: 'ecityruf' },
{ k: 'e*Cityruf Puppeteer', v: 'em-p-cityruf' },
@ -370,6 +397,11 @@
dapnet: {
enabled: null, duplexTimeout: null,
},
tetracontrol: {
enabled: null, duplexTimeout: null,
},
ecityruf: {
enabled: null, duplexTimeout: null,
},
@ -456,4 +488,4 @@
</script>
</body>
</html>
</html>

3
index.js
View file

@ -39,6 +39,9 @@ if (!!config.connectors.ecityruf && config.connectors.pagernetzAT.enabled === tr
if (!!config.connectors.ecityruf && config.connectors.pnet.enabled === true) {
types.ConnectorRegistry.register(new types.Connectors.pNetConnector())
}
if (!!config.connectors.tetracontrol && config.connectors.tetracontrol.enabled === true) {
types.ConnectorRegistry.register(new types.Connectors.TetraControlConnector(connection))
}
types.ConnectorRegistry.register(new types.Connectors.DummyConnector())

58
types/connectors/TetraControlConnector.js Normal file
View file

@ -0,0 +1,58 @@
const Connector = require("./Connector")
const config = require('../../config.json')
const md5 = require('md5')
const axios = require('axios')
const WebSocket = require('ws')
class TetraControlConnector extends Connector {
constructor (amqpConnMngr) {
super(amqpConnMngr)
this.name = "tetracontrol"
this.duplexCapable = false
}
async transmitMessage(msg, params) {
const UUID = this.name+':'+md5(JSON.stringify([this.name,...params]))
if (params.length < 1) return false
const target = params[0]
//if (target.split('#').length !== 2) throw 'No valid DAPNET Parameter <transmitterGroup#callSign>'
//const transmitterGroup = target.split('#')[ 0 ], callsign = target.split('#')[ 1 ]
/*const dapnetRequest = {
text: msg.payload,
callSignNames: [ callsign ],
transmitterGroupNames: [ transmitterGroup ]
}*/
const token = Buffer.from(`${ config.connectors.tetracontrol.username }:${ config.connectors.tetracontrol.password }`, 'utf8').toString('base64');
const headers = {
Authorization: `Basic ${token}`,
}
const ws = new WebSocket(`ws://${ config.connectors.tetracontrol.endpoint }/live.json?MaxAlter=3600`, { headers });
return new Promise((res, rej) => {
ws.on('open', function open() {
console.log('WebSocket connected');
const jsonData = {
text: msg.payload,
destSSI: target + '',
ProtocolID: 9,
radioID: 1,
type: "sds"
}
ws.send(JSON.stringify(jsonData))
ws.close()
})
ws.on('close',res)
ws.on('error',rej)
})
.then(() => {
this.connectorRegistry.reportState(msg, UUID, 'routed')
return true
})
.catch((err) => {
console.error(err )
this.connectorRegistry.reportFail(msg, UUID)
return false
})
}
}
module.exports = TetraControlConnector

4
types/connectors/index.js
View file

@ -24,8 +24,10 @@ module.exports = {
PagernetzConnetorAT: require('./PagernetzConnetorAT'),
pNetConnector: require('./pNetConnector'),
TetraControlConnector: require("./TetraControlConnector"),
LoRaWANConnector: require("./LoRaWANConnector"),
POCSAGConnector: require("./POCSAGConnector"),
DummyConnector: require("./DummyConnector"),
Connector: require("./Connector"),
}
}