You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
224 lines
8.5 KiB
JavaScript
224 lines
8.5 KiB
JavaScript
const amqp = require('amqp-connection-manager')
|
|
const fs = require('fs')
|
|
const config = require('./config.json')
|
|
|
|
|
|
// Create a connetion manager
|
|
const connection = amqp.connect(config.general.amqp)
|
|
connection.on('connect', () => console.log('Connected to AMQP.'))
|
|
connection.on('disconnect', err => console.log('Disconnected from AMQP.', err.stack))
|
|
|
|
const types = require('./types') // also initializes the registries, if they havent been loaded
|
|
|
|
if (!!config.connectors.pocsag && config.connectors.pocsag.enabled === true) {
|
|
types.ConnectorRegistry.register(new types.Connectors.POCSAGConnector(connection))
|
|
}
|
|
if (!!config.connectors.lorawan && config.connectors.lorawan.enabled === true) {
|
|
types.ConnectorRegistry.register(new types.Connectors.LoRaWANConnector(connection))
|
|
}
|
|
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))
|
|
}
|
|
if (!!config.connectors.emessage && config.connectors.emessage.enabled === true) {
|
|
types.ConnectorRegistry.register(new types.Connectors.eMessageAlertManagerConnectorBase(connection))
|
|
types.ConnectorRegistry.register(new types.Connectors.eMessageAlertManagerConnectorCityruf(connection))
|
|
types.ConnectorRegistry.register(new types.Connectors.eMessageAlertManagerConnectorTwoWays(connection))
|
|
}
|
|
if (!!config.connectors.emPuppettering && config.connectors.emPuppettering.enabled === true) {
|
|
types.ConnectorRegistry.register(new types.Connectors.eMessagePuppeteerConnectorBase(connection))
|
|
types.ConnectorRegistry.register(new types.Connectors.eMessagePuppeteerConnectorCityruf(connection))
|
|
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))
|
|
}
|
|
if (!!config.connectors.tetracontrol && config.connectors.tetracontrol.enabled === true) {
|
|
types.ConnectorRegistry.register(new types.Connectors.TetraControlConnector(connection))
|
|
}
|
|
|
|
types.ConnectorRegistry.register(new types.Connectors.DummyConnector())
|
|
|
|
types.DeviceRegistry.register(new types.devices.GenericPager())
|
|
types.DeviceRegistry.register(new types.devices.BirdySlim())
|
|
types.DeviceRegistry.register(new types.devices.EMessage2Ways())
|
|
types.DeviceRegistry.register(new types.devices.Skyper())
|
|
|
|
const express = require('express')
|
|
const { MessageManager } = require('./types')
|
|
const app = express(), appConfig = express()
|
|
const appServer = require('http').createServer(app)
|
|
app.use(express.json({ limit: '1mb' }))
|
|
app.use(express.static('html_main'))
|
|
app.use(express.static(__dirname + '/node_modules/@mdi/font'))
|
|
|
|
appConfig.use(express.json({ limit: '1mb' }))
|
|
appConfig.use(express.static('html_config'))
|
|
appConfig.use(express.static(__dirname + '/node_modules/@mdi/font'))
|
|
|
|
app.post('/api/message/preset', async (req, res) => {
|
|
if (!req.body.preset) return res.status(500).json("ERROR: no msg preset")
|
|
if (!req.body.payload) return res.status(500).json("ERROR: no msg payload")
|
|
|
|
if (!config.deliveryPresets[ req.body.preset ]) return res.status(500).json("ERROR: delivery Preset does not exist")
|
|
|
|
let id = await types.MessageManager.New(
|
|
config.deliveryPresets[ req.body.preset ].params.type,
|
|
config.deliveryPresets[ req.body.preset ].params.routing,
|
|
req.body.payload
|
|
)
|
|
await types.MessageManager.Deliver(id)
|
|
return res.json(id)
|
|
})
|
|
app.post('/api/message/advanced', async (req, res) => {
|
|
if (!req.body.type) return res.status(500).json("ERROR: no msg type(simple,duplex)")
|
|
if (!req.body.payload) return res.status(500).json("ERROR: no msg payload")
|
|
if (!req.body.routing) return res.status(500).json("ERROR: no msg routing")
|
|
|
|
let id = await types.MessageManager.New(req.body.type, req.body.routing, req.body.payload)
|
|
await types.MessageManager.Deliver(id)
|
|
return res.json(id)
|
|
})
|
|
app.post('/api/message/advanced/menu', async (req, res) => {
|
|
if (!req.body.payload) return res.status(500).json("ERROR: no msg payload")
|
|
if (!req.body.options) return res.status(500).json("ERROR: no msg options")
|
|
if (!req.body.routing) return res.status(500).json("ERROR: no msg routing")
|
|
|
|
let id = await types.MessageManager.New('duplex', req.body.routing,
|
|
req.body.payload + '\n\n' + Object.keys(req.body.options).map((key, index) => {
|
|
return `[${ index + 1 }]${ req.body.options[key].sep || ' ' }${ req.body.options[key].txt }`
|
|
}).join('\n')
|
|
)
|
|
types.MessageManager.attachMenudata(id, {
|
|
options: req.body.options,
|
|
})
|
|
await types.MessageManager.Deliver(id)
|
|
return res.json(id)
|
|
})
|
|
|
|
|
|
app.get('/api/message/status/:id/menu', async (req, res) => { //TODO: make this fancy
|
|
return res.json(types.MessageManager.messages[ req.params.id ])
|
|
})
|
|
|
|
app.get('/api/message/status/:id', async (req, res) => { //TODO: make this fancy
|
|
return res.json(types.MessageManager.messages[ req.params.id ])
|
|
})
|
|
|
|
app.get('/api/message/recent', async (req, res) => {
|
|
let msgs = Object.values(types.MessageManager.messages)
|
|
.sort((a,b) => b.date-a.date)
|
|
return res.json(msgs)
|
|
})
|
|
|
|
app.get('/api/message/ack/recv/:id', async (req, res) => {
|
|
types.ConnectorRegistry.reportDelivered({ id: req.params.id }, 'http')
|
|
types.MessageManager.attachMetadata(req.params.id, {
|
|
ack: 'recv',
|
|
rssi: 0x00,
|
|
date: new Date(),
|
|
metadata: { http: true },
|
|
})
|
|
return res.json(true)
|
|
})
|
|
app.get('/api/message/ack/read/:id', async (req, res) => {
|
|
types.MessageManager.markMessageRead(req.params.id)
|
|
types.MessageManager.attachMetadata(req.params.id, {
|
|
ack: 'read',
|
|
date: new Date(),
|
|
metadata: { http: true },
|
|
})
|
|
return res.json(true)
|
|
})
|
|
|
|
app.get('/api/device/:id', async (req, res) => {
|
|
return res.json(
|
|
req.params.id.length == 1
|
|
? Object.keys(types.DeviceRegistry.DeviceStates)
|
|
: types.DeviceRegistry.DeviceStates[ req.params.id ]
|
|
)
|
|
})
|
|
|
|
app.get('/api/devices', async (req, res) => {
|
|
return res.json(types.DeviceRegistry.DeviceStates)
|
|
})
|
|
app.get('/api/deliveryPresets', async (req, res) => {
|
|
return res.json(
|
|
Object.keys(config.deliveryPresets)
|
|
.map(key => {
|
|
return {
|
|
key,
|
|
name: config.deliveryPresets[ key ].name
|
|
}
|
|
})
|
|
)
|
|
})
|
|
|
|
|
|
const io = require('socket.io')(appServer)
|
|
io.on("connection", socket => {
|
|
console.log('new socket.io connection')
|
|
})
|
|
|
|
types.MessageManager.events.on('event', (eventType, eventData) => {
|
|
console.log(eventType, eventData)
|
|
io.sockets.emit('msgmgr:event', eventType, eventData)
|
|
})
|
|
|
|
types.DeviceRegistry.events.on('event', (deviceType, deviceId, eventData) => {
|
|
console.log(deviceType, deviceId, eventData)
|
|
io.sockets.emit('device:event', deviceType, deviceId, eventData)
|
|
})
|
|
/** CONFIG Routes */
|
|
|
|
appConfig.get('/config', async (req, res) => {
|
|
const parsedConfig = JSON.parse(fs.readFileSync('config.json'))
|
|
parsedConfig.deliveryPresets = parsedConfig.deliveryPresets || {
|
|
'example': {
|
|
"name": "Normal",
|
|
"params": {
|
|
"type": "duplex",
|
|
"routing": {
|
|
"device": "generic",
|
|
"connectors": [
|
|
[
|
|
"dummy",
|
|
"1234"
|
|
]
|
|
]
|
|
}
|
|
},
|
|
}
|
|
}
|
|
return res.json(parsedConfig)
|
|
})
|
|
appConfig.post('/config', async (req, res) => {
|
|
if (!(!!req.body.general)) return res.status(403).json(false)
|
|
if (!(!!req.body.connectors)) return res.status(403).json(false)
|
|
if (!(!!req.body.pagers)) return res.status(403).json(false)
|
|
console.log(req.body)
|
|
fs.writeFileSync('config.json', JSON.stringify(req.body, null, "\t"))
|
|
return res.json(true)
|
|
})
|
|
appConfig.post('/restart', (req, res) => {
|
|
process.exit(1)
|
|
})
|
|
|
|
/*const memstats = () => {
|
|
const used = process.memoryUsage()
|
|
for (let key in used) {
|
|
console.log(`${key} ${Math.round(used[key] / 1024 / 1024 * 100) / 100} MB`)
|
|
}
|
|
}
|
|
memstats()
|
|
setInterval(memstats, 10e3)*/
|
|
|
|
|
|
appServer.listen(config.general.port)
|
|
if (config.general.configWebInterfaceEnabled === true) {
|
|
appConfig.listen(config.general.configPort)
|
|
}
|