LoRaWAN-Signal-Mapping/server/ttn-app-server/MessageHandler.mjs

64 lines
1.7 KiB
JavaScript
Raw Permalink Normal View History

"use strict";
import { decode_payload } from './DecodePayload.mjs';
import { get_id_number } from '../Helpers/IdGenerator.mjs';
class MessageHandler {
2019-07-10 13:44:52 +00:00
get debug() {
return this.settings.logging.verbose;
2019-07-10 13:44:52 +00:00
}
constructor({ settings, ReadingRepo, GatewayRepo }) {
this.settings = settings;
this.repo_reading = ReadingRepo;
this.repo_gateway = GatewayRepo;
}
2019-07-09 12:14:25 +00:00
async handle(message) {
2019-07-10 13:44:52 +00:00
if(this.debug) console.log(message);
2019-07-09 12:14:25 +00:00
if(this.settings.ttn.encryption_key == "CHANGE_THIS") {
this.log.error(`Error: No encryption key specified. Try filling in the required values in settings.toml. If they don't exist yet, try using server/settings.default.toml as a reference.`);
return false;
}
let decoded_payload = decode_payload(message.payload_raw, this.settings.ttn.encryption_key);
2019-07-10 13:44:52 +00:00
if(this.debug) console.log(decoded_payload);
let rssis = [];
2019-07-10 13:44:52 +00:00
for(let gw of message.metadata.gateways) {
if(this.debug) console.log("gateway ", gw);
// Insert the gateway info into the database if it doesn't exist already
if(!this.repo_gateway.exists(gw.gtw_id)) {
this.repo_gateway.add({
id: gw.gtw_id,
latitude: gw.latitude, longitude: gw.longitude,
altitude: gw.altitude
});
}
// Generate an RSSI object
rssis.push({
2019-07-10 13:44:52 +00:00
id: await get_id_number(),
gateway_id: gw.gtw_id,
rssi: gw.rssi,
snr: gw.snr,
channel: gw.channel
});
}
// Add the reading and the associated RSSIs to the database
this.repo_reading.add({
id: decoded_payload.id,
latitude: decoded_payload.latitude,
longitude: decoded_payload.longitude,
data_rate: message.metadata.data_rate,
code_rate: message.metadata.coding_rate,
rssis
});
}
}
export default MessageHandler;