144 lines
3.9 KiB
JavaScript
144 lines
3.9 KiB
JavaScript
const mqtt = require('mqtt');
|
|
const { MatrixClient, SimpleFsStorageProvider, AutojoinRoomsMixin } = require('matrix-bot-sdk');
|
|
const config = require('./config.json');
|
|
|
|
// Matrix client
|
|
const storage = new SimpleFsStorageProvider("matrix-storage.json");
|
|
const matrix = new MatrixClient(config.matrix.homeserverUrl, config.matrix.accessToken, storage);
|
|
AutojoinRoomsMixin.setupOnClient(matrix);
|
|
matrix.start().then(() => console.log("Matrix bot started"));
|
|
|
|
function formatMessageCQ(data) {
|
|
const {
|
|
callsign,
|
|
msg,
|
|
ccode,
|
|
country,
|
|
mode,
|
|
freq,
|
|
db,
|
|
dt,
|
|
locator
|
|
} = data;
|
|
|
|
// Country flag emoji
|
|
const emojiFlag = countryCodeToFlagEmoji(ccode);
|
|
|
|
// Convert frequency Hz to MHz with 3 decimal digits
|
|
const freqMHz = (freq / 1_000_000).toFixed(3);
|
|
|
|
// RSSI visual bars
|
|
const rssiBars = snrToBars(db);
|
|
|
|
// Google Maps locator search
|
|
const mapLink = `https://k7fry.com/grid/?qth=${locator}`;
|
|
|
|
return `📡 ${callsign} ${emojiFlag} 📍<a href="${mapLink}">${locator}</a>
|
|
📶 ${db} dB | ${dt} s | ${rssiBars}
|
|
🔊 ${freqMHz}MHz ${mode} `;
|
|
}
|
|
|
|
function formatMessageWX(data) {
|
|
const {
|
|
temperature_F,
|
|
humidity,
|
|
rain_mm,
|
|
wind_dir_deg,
|
|
wind_avg_m_s,
|
|
wind_max_m_s,
|
|
light_lux,
|
|
uv,
|
|
mic,
|
|
mode,
|
|
timestamp
|
|
} = data;
|
|
|
|
const emoji = {
|
|
temp: "🌡️",
|
|
humidity: "💧",
|
|
rain: "🌧️",
|
|
wind: "🍃",
|
|
light: "💡",
|
|
uv: "☀️",
|
|
mic: "🎙️",
|
|
time: "🕒",
|
|
mode: "⚙️"
|
|
};
|
|
|
|
const dirEmoji = getWindDirectionEmoji(wind_dir_deg);
|
|
const readableTime = new Date(timestamp).toLocaleString();
|
|
|
|
return `
|
|
${emoji.temp} Temperature: ${temperature_F.toFixed(1)} °C
|
|
${emoji.humidity} Humidity: ${humidity}% (may be out of range!)
|
|
${emoji.rain} Rainfall: ${rain_mm} mm
|
|
${emoji.wind} Wind: ${wind_avg_m_s} m/s avg, ${wind_max_m_s} m/s max ${dirEmoji} (${wind_dir_deg}°)
|
|
${emoji.light} Light: ${light_lux} lux
|
|
${emoji.uv} UV Index: ${uv}
|
|
${emoji.time} Time: ${readableTime}
|
|
`.trim();
|
|
}
|
|
|
|
|
|
// Helper: SNR (dB) to emoji "bar chart"
|
|
function snrToBars(db) {
|
|
const snr = Math.max(Math.min(db, 0), -30); // clamp -30 to 0
|
|
const levels = 5;
|
|
const filled = Math.round(((snr + 30) / 30) * levels);
|
|
return '▓'.repeat(filled) + '░'.repeat(levels - filled);
|
|
}
|
|
|
|
// Helper: ISO country code (e.g. "CA") → 🇨🇦 emoji
|
|
function countryCodeToFlagEmoji(cc) {
|
|
if (!cc) return '';
|
|
return cc.toUpperCase().replace(/./g, c =>
|
|
String.fromCodePoint(0x1f1e6 - 65 + c.charCodeAt(0))
|
|
);
|
|
}
|
|
// MQTT client
|
|
const mqttClient = mqtt.connect(config.mqtt.url, {
|
|
username: config.mqtt.username,
|
|
password: config.mqtt.password,
|
|
clientId: 'mqtt-matrix-' + Math.random().toString(16).slice(2, 10),
|
|
clean: true,
|
|
connectTimeout: 4000,
|
|
reconnectPeriod: 2000,
|
|
});
|
|
|
|
mqttClient.on('connect', () => {
|
|
console.log('MQTT connected');
|
|
mqttClient.subscribe(config.mqtt.topic, { qos: 0 }, err => {
|
|
if (err) console.error('Subscribe error', err);
|
|
});
|
|
});
|
|
|
|
mqttClient.on('message', async (topic, payload) => {
|
|
const data = JSON.parse(payload.toString());
|
|
console.log(`MQTT message on ${topic}: ${data?.msg}`);
|
|
// Simple filter—customize as needed
|
|
if (data?.model?.includes('CQ')) {
|
|
await matrix.sendMessage(config.matrix.roomId, {
|
|
msgtype: "m.text",
|
|
format: "org.matrix.custom.html",
|
|
formatted_body: formatMessageCQ(data),
|
|
body: formatMessageCQ(data),
|
|
});
|
|
} else if (data?.msg?.includes('Sharp-SPC775')) {
|
|
const msg = `🌡️${data.temperature_C} | 💧${data.humidity}`;
|
|
await matrix.sendMessage(config.matrix.roomId, {
|
|
msgtype: "m.text",
|
|
format: "org.matrix.custom.html",
|
|
formatted_body: msg,
|
|
body: msg,
|
|
});
|
|
}
|
|
else if (data?.msg?.includes('Cotech-367959')) {
|
|
await matrix.sendMessage(config.matrix.roomId, {
|
|
msgtype: "m.text",
|
|
format: "org.matrix.custom.html",
|
|
formatted_body: formatMessageWX(data),
|
|
body: formatMessageWX(data),
|
|
});
|
|
}
|
|
});
|