ztimson/weather-station
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

WIP: MQTT

Browse Source
This commit is contained in:
Zakary Timson
2026-09-11 11:28:34 -04:00
parent b86e4613bf
commit 396a1f4cab
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/config.mjs
View File

@@ -13,8 +13,8 @@ export function cfg() {
TINYGS_URL: process.env.TINYGS_URL || '', TINYGS_URL: process.env.TINYGS_URL || '',
TINYGS_AUTH: process.env.TINYGS_AUTH || '', TINYGS_AUTH: process.env.TINYGS_AUTH || '',
TINYGS_MQTT_PORT: process.env.TINYGS_MQTT_PORT || 1883, TINYGS_MQTT_PORT: process.env.TINYGS_MQTT_PORT || 1883,
TINYGS_MQTT_USER: process.env.TINYGS_MQTT_USER || 'admin', TINYGS_MQTT_USER: process.env.TINYGS_MQTT_USER || '',
TINYGS_MQTT_PASS: process.env.TINYGS_MQTT_PASS || 'admin', TINYGS_MQTT_PASS: process.env.TINYGS_MQTT_PASS || '',
DB_HOST: process.env.DB_HOST || 'http://localhost:8428', DB_HOST: process.env.DB_HOST || 'http://localhost:8428',
EMAIL: process.env.EMAIL, EMAIL: process.env.EMAIL,
LATITUDE: parseFloat(process.env.LATITUDE || '0'), LATITUDE: parseFloat(process.env.LATITUDE || '0'),

4
server/src/sats.mjs
View File

@@ -59,7 +59,7 @@ export async function startTinyGSServer() {
const broker = await Aedes.createBroker(); const broker = await Aedes.createBroker();
const server = createServer(broker.handle); const server = createServer(broker.handle);
if (TINYGS_MQTT_USER) { if(TINYGS_MQTT_USER) {
broker.authenticate = (client, username, password, cb) => { broker.authenticate = (client, username, password, cb) => {
const ok = username === TINYGS_MQTT_USER && password?.toString() === TINYGS_MQTT_PASS; const ok = username === TINYGS_MQTT_USER && password?.toString() === TINYGS_MQTT_PASS;
if (!ok) console.warn(`[tinygs] rejected auth from ${client.id}`); if (!ok) console.warn(`[tinygs] rejected auth from ${client.id}`);
@@ -75,7 +75,7 @@ export async function startTinyGSServer() {
broker.on('client', client => console.info(`[tinygs] connected: ${client.id}`)); broker.on('client', client => console.info(`[tinygs] connected: ${client.id}`));
broker.on('clientDisconnect', client => console.info(`[tinygs] disconnected: ${client.id}`)); broker.on('clientDisconnect', client => console.info(`[tinygs] disconnected: ${client.id}`));
server.listen(TINYGS_MQTT_PORT, () => console.info(`🛜 MQTT broker - localhost:${TINYGS_MQTT_PORT}`)); server.listen(TINYGS_MQTT_PORT, '0.0.0.0', () => console.info(`🛜 MQTT broker - localhost:${TINYGS_MQTT_PORT}`));
} }
export const getTinyGSData = () => { export const getTinyGSData = () => {