/**
 * shutter-as-dimmer.js - STABLE WORKAROUND
 * -----------------------------------------------------------------
 * Simulates the shutter as a DimmableLightDevice to ensure stability.
 * 0% = Closed, 100% = Open.
 * -----------------------------------------------------------------
 */

import { ServerNode, Endpoint, DeviceTypeId, VendorId } from "@matter/main";
import { DimmableLightDevice } from "@matter/main/devices/dimmable-light";
import mqtt from "mqtt";

// --- CONFIG ---
const MQTT_URL = process.env.MQTT_URL ?? "mqtt://localhost";
const MQTT_CMD_TOPIC = process.env.MQTT_CMD_TOPIC ?? "scs/cover/set/69";
const MQTT_STATE_TOPIC = process.env.MQTT_STATE_TOPIC ?? "scs/cover/state/69";
const MATTER_PORT = Number(process.env.MATTER_PORT ?? 5541);

const log = (...a) => console.log("[SHUTTER-DIMMER]", ...a);

async function run() {
    log("Starting Shutter bridge (as Dimmer)...");

    const device = await ServerNode.create({
        id: "node-shutter-dimmer",
        network: { port: MATTER_PORT },
        commissioning: { passcode: 20202021, discriminator: 3841 },
        productDescription: {
            name: "Bedroom Shutter",
            deviceType: DeviceTypeId(DimmableLightDevice.deviceType),
        },
        // ... other basic information
    });

    const endpoint = new Endpoint(DimmableLightDevice, { id: "dimmer" });
    await device.add(endpoint);

    await endpoint.set({
        onOff: { onOff: false },
        levelControl: { currentLevel: 0 }
    });

    const mqttClient = mqtt.connect(MQTT_URL, { reconnectPeriod: 3000 });

    mqttClient.on("connect", () => {
        log(`MQTT connected to ${MQTT_URL}`);
        mqttClient.subscribe({ [MQTT_STATE_TOPIC]: { qos: 1 } });
    });

    mqttClient.on("message", (topic, payload) => {
        if (topic !== MQTT_STATE_TOPIC) return;
        const state = payload.toString().toLowerCase();
        log(`State received from MQTT: '${state}'`);

        const dataToSet = {};
        switch (state) {
            case "open":
                dataToSet.onOff = { onOff: true };
                dataToSet.levelControl = { currentLevel: 254 }; // Max level
                break;
            case "closed":
                dataToSet.onOff = { onOff: false };
                dataToSet.levelControl = { currentLevel: 0 };
                break;
            case "stop":
                return;
        }
        endpoint.set(dataToSet).catch(e => log("Error setting state:", e));
    });

    endpoint.events.onOff.onOff$Changed.on(isOn => {
        mqttClient.publish(MQTT_CMD_TOPIC, isOn ? "OPEN" : "CLOSE");
    });

    endpoint.events.levelControl.currentLevel$Changed.on(level => {
        mqttClient.publish(MQTT_CMD_TOPIC, level > 0 ? "OPEN" : "CLOSE");
    });

    await device.run();
    log("Shutter (as Dimmer) ready for commissioning! ✅");
}

run().catch((err) => console.error("[FATAL]", err));

/**
 * shutter-correct-class-fails.js - NON-WORKING ATTEMPT
 * -----------------------------------------------------------------
 * This code attempts to use the correct WindowCoveringDevice class
 * but fails during initialization.
 * -----------------------------------------------------------------
 */

import { ServerNode, Endpoint, DeviceTypeId, VendorId } from "@matter/main";
import { ClusterServer } from "@matter/main/cluster-server";
import { WindowCoveringDevice } from "@matter/main/devices/window-covering";
import { WindowCoveringCluster } from "@matter/main/clusters/window-covering";
import mqtt from "mqtt";

// --- CONFIG ---
const MQTT_URL = process.env.MQTT_URL ?? "mqtt://localhost";
const MQTT_CMD_TOPIC = process.env.MQTT_CMD_TOPIC ?? "scs/cover/set/69";
const MQTT_STATE_TOPIC = process.env.MQTT_STATE_TOPIC ?? "scs/cover/state/69";
const MATTER_PORT = Number(process.env.MATTER_PORT ?? 5542);

const log = (...a) => console.log("[SHUTTER-CORRECT]", ...a);

async function run() {
    log("Attempting bridge with WindowCoveringDevice (explicit method)...");

    const device = await ServerNode.create({
        id: "node-shutter-correct",
        network: { port: MATTER_PORT },
        commissioning: { passcode: 20202021, discriminator: 3842 },
        productDescription: {
            name: "Correct Shutter",
            deviceType: DeviceTypeId(WindowCoveringDevice.deviceType),
        },
        // ... other basic information
    });

    const endpoint = new Endpoint(WindowCoveringDevice, { id: "window-covering" });

    // ATTEMPT TO MANUALLY ADD THE CLUSTER (FAILS)
    // This was one of several attempts to force the cluster to be added.
    // It failed with a "Cannot find module" error for "cluster-server".
    /*
    endpoint.addClusterServer(
        ClusterServer(
            WindowCoveringCluster.with("Lift"),
            { currentPositionLiftPercent: 0, targetPositionLiftPercent: 0 }
        )
    );
    */
    await device.add(endpoint);

    const mqttClient = mqtt.connect(MQTT_URL, { reconnectPeriod: 3000 });
    // ... MQTT logic follows ...

    // This code fails because endpoint.events.windowCovering is undefined
    endpoint.events.windowCovering.upOrOpen.on(() => {
        log("Matter command: UpOrOpen -> Publishing 'OPEN' to MQTT");
        mqttClient.publish(MQTT_CMD_TOPIC, "OPEN");
    });
    // ... other command handlers also fail ...

    await device.run();
    log("This log is never reached.");
}

run().catch((err) => console.error("[FATAL]", err));

[SHUTTER-CORRECT] Starting bridge with WindowCoveringDevice...
2025-08-01 10:28:27.628 INFO    ServerNodeStore         Opened node-shutter-correct storage at /root/.matter/node-shutter-correct
...
2025-08-01 10:28:28.231 INFO    Endpoint                node-shutter-correct.window-covering ready endpoint#: 1 type: WindowCovering (0x202) behaviors: ✓identify ✓descriptor
[FATALE] TypeError: Cannot read properties of undefined (reading 'upOrOpen')
    at run (file:///opt/smartthings-mqtt-bridge/shutter-correct-class-fails.js:99:36)
...
2025-08-01 10:27:10.631 FATAL   Logger                  Unhandled error detected: Cannot read properties of undefined (reading 'currentPositionLiftPercent')
    at MqttClient.<anonymous> (file:///opt/smartthings-mqtt-bridge/shutter-correct-class-fails.js:94:61)
...
TypeError: Cannot read properties of undefined (reading 'currentPositionLiftPercent')
    at MqttClient.<anonymous> (file:///opt/smartthings-mqtt-bridge/shutter-correct-class-fails.js:94:61)