49 lines
1.3 KiB
JavaScript
49 lines
1.3 KiB
JavaScript
// ---- Home Assistant API Client ----
|
|
require('dotenv').config();
|
|
|
|
const https = require('https');
|
|
|
|
const HA_URL = process.env.HA_URL; // z.B. "https://haos.vogt.de.com"
|
|
const HA_TOKEN = process.env.HA_TOKEN; // Long-Lived Access Token aus HA
|
|
|
|
/**
|
|
* Fragt den aktuellen Zustand einer Home-Assistant-Entity ab.
|
|
* @param {string} entityId - z.B. "sensor.wohnzimmer_temperatur"
|
|
* @returns {Promise<{state: string, attributes: object}>}
|
|
*/
|
|
function getHaState(entityId) {
|
|
return new Promise((resolve, reject) => {
|
|
const url = new URL(`${HA_URL}/api/states/${entityId}`);
|
|
const options = {
|
|
hostname: url.hostname,
|
|
path: url.pathname,
|
|
method: 'GET',
|
|
headers: {
|
|
Authorization: `Bearer ${HA_TOKEN}`,
|
|
'Content-Type': 'application/json',
|
|
},
|
|
};
|
|
|
|
const req = https.request(options, (res) => {
|
|
let data = '';
|
|
res.on('data', (chunk) => (data += chunk));
|
|
res.on('end', () => {
|
|
if (res.statusCode !== 200) {
|
|
reject(new Error(`HA API Fehler: ${res.statusCode} - ${data}`));
|
|
return;
|
|
}
|
|
try {
|
|
resolve(JSON.parse(data));
|
|
} catch (e) {
|
|
reject(e);
|
|
}
|
|
});
|
|
});
|
|
|
|
req.on('error', reject);
|
|
req.end();
|
|
});
|
|
}
|
|
|
|
module.exports = { getHaState };
|