117 lines
4.8 KiB
JavaScript
117 lines
4.8 KiB
JavaScript
"use strict";
|
|
var __importDefault = (this && this.__importDefault) || function (mod) {
|
|
return (mod && mod.__esModule) ? mod : { "default": mod };
|
|
};
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
const mqtt_1 = __importDefault(require("mqtt"));
|
|
const Device_1 = __importDefault(require("./Device"));
|
|
const events_1 = require("events");
|
|
class Alex2MQTT extends events_1.EventEmitter {
|
|
constructor(username, password, rootTopic, debugLogging) {
|
|
super(); // Initialize EventEmitter
|
|
this.username = username;
|
|
this.password = password;
|
|
this.rootTopic = rootTopic;
|
|
this.debugLogging = debugLogging;
|
|
this.client = null;
|
|
this.devices = [];
|
|
this.MqttHost = "mqtt://Alex2MQTT.stormysdream.club";
|
|
}
|
|
connect() {
|
|
const options = {
|
|
username: this.username,
|
|
password: this.password,
|
|
};
|
|
this.client = mqtt_1.default.connect(this.MqttHost, options);
|
|
this.client.on("connect", () => {
|
|
if (this.debugLogging) {
|
|
console.log("[Alex2Node.ts] Connected to MQTT broker");
|
|
}
|
|
this.client.subscribe(this.rootTopic + "/#", (err) => {
|
|
if (this.debugLogging && !err) {
|
|
console.log("[Alex2Node.ts] Subscribed to topics");
|
|
}
|
|
if (err) {
|
|
console.error("[Alex2Node.ts] MQTT connection error:", err);
|
|
this.emit("error", err);
|
|
}
|
|
});
|
|
});
|
|
this.client.on("message", (topic, message) => {
|
|
if (this.debugLogging) {
|
|
console.log(`[Alex2Node.ts] MQTT Message Received`);
|
|
console.log(` Topic: ${topic}`);
|
|
console.log(` Payload: ${message.toString()}`);
|
|
}
|
|
if (topic == `${this.rootTopic}/discover`) {
|
|
if (this.debugLogging) {
|
|
console.log("[Alex2Node.ts] Discovery request received, getting device json...");
|
|
}
|
|
const deviceArray = this.devices.map((device) => device.getJSON());
|
|
if (deviceArray.length > 0) {
|
|
this.client.publish(topic + "_r", JSON.stringify(deviceArray), (err) => {
|
|
if (err) {
|
|
console.error("[Alex2Node.ts] MQTT connection error:", err);
|
|
this.emit("error", err);
|
|
}
|
|
else if (this.debugLogging) {
|
|
console.log(`[Alex2Node.ts] Discovery payloads published to ${topic + "_r"}`);
|
|
console.log(deviceArray);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
else if (topic.split("/").length == 3) {
|
|
const [root, endpointId, directiveType] = topic.split("/");
|
|
if (directiveType != "alexaDirective") {
|
|
return;
|
|
}
|
|
const device = this.devices.find((d) => d.endpointId === endpointId);
|
|
if (!device) {
|
|
if (this.debugLogging) {
|
|
console.warn(`[Alex2Node.ts] No device found for endpointId: ${endpointId}`);
|
|
}
|
|
return;
|
|
}
|
|
let payload;
|
|
try {
|
|
payload = JSON.parse(message.toString());
|
|
}
|
|
catch (e) {
|
|
console.error(`[Alex2Node.ts] Failed to parse payload JSON`, e);
|
|
return;
|
|
}
|
|
if (payload.header &&
|
|
payload.header.namespace === "Alexa" &&
|
|
payload.header.name === "ReportState") {
|
|
if (this.debugLogging) {
|
|
console.log(`[Alex2Node.ts] ReportState directive for device ${endpointId}`);
|
|
}
|
|
device.emit("ReportState", payload);
|
|
}
|
|
else {
|
|
device.emit("Event", payload, payload.header.namespace);
|
|
}
|
|
}
|
|
});
|
|
this.client.on("error", (err) => {
|
|
if (this.debugLogging) {
|
|
console.error("[Alex2Node.ts] Connection failed:", err);
|
|
}
|
|
console.error("[Alex2Node.ts] MQTT connection error:", err);
|
|
this.emit("error", err);
|
|
});
|
|
}
|
|
registerDevice(name, endpointId) {
|
|
if (!this.client) {
|
|
throw new Error("Must call connect before creating devices");
|
|
}
|
|
if (this.debugLogging) {
|
|
console.log(`[Alex2Node.ts] Creating new device with endpoint: ${endpointId}`);
|
|
}
|
|
const device = new Device_1.default(this.client, this.rootTopic, name, endpointId);
|
|
this.devices.push(device);
|
|
return device;
|
|
}
|
|
}
|
|
exports.default = Alex2MQTT;
|