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

"use strict";

import { decode_payload } from './DecodePayload.mjs';
import { get_id_number } from '../Helpers/IdGenerator.mjs';

class MessageHandler {
	get debug() {
		return this.settings.logging.debug;
	}
	constructor({ settings, ReadingRepo, GatewayRepo }) {
		this.settings = settings;
		this.repo_reading = ReadingRepo;
		this.repo_gateway = GatewayRepo;
	}
	
	async handle(message) {
		if(this.debug) console.log(message);
		
		let decoded_payload = decode_payload(message.payload_raw);
		if(this.debug) console.log(decoded_payload);
		
		let rssis = [];
		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({
				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;