// shutter-device.js - Final attempt based on the official example.
// This script tries to build a standalone Window Covering device
// by manually composing the endpoint with the required behaviors.

import { ServerNode, Endpoint, DeviceTypeId, VendorId } from "@matter/main";
import { WindowCoveringDevice } from "@matter/main/devices/window-covering";

// Importing the required server behaviors as per the official examples.
import {
    OnOffServer, // Not used but included for testing import patterns
    LevelControlServer, // Not used but included for testing import patterns
    WindowCoveringServer
} from "@matter/main/behaviors";

import mqtt from "mqtt";

// --- Config ---
const MQTT_URL = process.env.MQTT_URL ?? "mqtt://localhost";
const MQTT_COMMAND_TOPIC = process.env.MQTT_CMD ?? "scs/cover/set/69";
const MQTT_STATE_TOPIC   = process.env.MQTT_STATE ?? "scs/cover/state/69";
const MATTER_PORT = Number(process.env.MATTER_PORT ?? 5541);
const MATTER_PASSCODE = Number(process.env.MATTER_PASSCODE ?? 20202021);
const MATTER_DISCRIMINATOR = Number(process.env.MATTER_DISCRIMINATOR ?? 3841);

const normalizeTopic = (t) => (t || "").replace(/\/+$/, "");

function parseCoverState(payload) {
    const stateStr = (payload?.toString() ?? "").trim().toLowerCase();
    if (stateStr === "open") return 0;   // Matter: 0% = Open
    if (stateStr === "closed") return 100; // Matter: 100% = Closed
    return null; 
}

async function run() {
    const device = await ServerNode.create({
        id: "node-shutter-cam",
        network: { port: MATTER_PORT },
        commissioning: { passcode: MATTER_PASSCODE, discriminator: MATTER_DISCRIMINATOR },
        productDescription: {
            name: "Bedroom Shutter",
            deviceType: DeviceTypeId(WindowCoveringDevice.deviceType),
        },
        basicInformation: {
            vendorName: "matter-bridge",
            vendorId: VendorId(0xFFF1),
            nodeLabel: "Bedroom Shutter",
            productName: "Shutter",
            productLabel: "Bedroom Shutter",
            productId: 0x8009,
            serialNumber: "shutter-real-sn-01",
            uniqueId: "shutter-real-uid-01",
        },
    });

    // Manual composition of the endpoint, following the official example's pattern.
    const endpoint = new Endpoint({
        type: WindowCoveringDevice.deviceType,
        behaviors: [ WindowCoveringServer ], // This line causes the crash
        id: "shutter"
    });
    await device.add(endpoint);

    const mqttClient = mqtt.connect(MQTT_URL, { reconnectPeriod: 3000 });
    
    // --- MQTT -> Matter Logic ---
    mqttClient.on("connect", () => {
        console.log(`[MQTT] Connected to ${MQTT_URL}`);
        mqttClient.subscribe({ [MQTT_STATE_TOPIC]: { qos: 1 } });
    });

    mqttClient.on("message", async (topic, payload) => {
        const newPosition = parseCoverState(payload);
        if (newPosition === null) return;
        
        console.log(`[MQTT] State received, updating Matter position to: ${newPosition}%`);
        await endpoint.set({
            windowCovering: {
                targetPositionLiftPercentage: newPosition,
                currentPositionLiftPercentage: newPosition,
            }
        });
    });

    // --- Matter -> MQTT Logic ---
    endpoint.events.windowCovering.upOrOpen$Invoked.on(() => {
        console.log("[MATTER] 'Open' command received -> sending OPEN");
        mqttClient.publish(MQTT_COMMAND_TOPIC, "OPEN");
    });

    endpoint.events.windowCovering.downOrClose$Invoked.on(() => {
        console.log("[MATTER] 'Close' command received -> sending CLOSE");
        mqttClient.publish(MQTT_COMMAND_TOPIC, "CLOSE");
    });
    
    endpoint.events.windowCovering.stopMotion$Invoked.on(() => {
        console.log("[MATTER] 'Stop' command received -> sending STOP");
        mqttClient.publish(MQTT_COMMAND_TOPIC, "STOP");
    });

    await device.run();

    process.on("SIGINT", async () => { await device.close(); process.exit(0); });
}

run().catch(console.error);

node tapparella-camera.js
2025-07-28 18:28:03.093 INFO   ServerNodeStore      Opened node-tapparella-cam storage at /root/.matter/node-tapparella-cam
2025-07-28 18:28:03.142 INFO   SessionManager       restoring resumption record for node 12684493823293599705 and peer node 12684493823293599705 for fabric index 1
2025-07-28 18:28:03.145 DEBUG  Crypto               Using Node.js crypto implementation for node-tapparella-cam
2025-07-28 18:28:03.195 WARN   BasicInfor~ionServer Using development values for some BasicInformation attributes: hardwareVersion: 0 softwareVersion: 0
2025-07-28 18:28:03.516 INFO   BaseEventStore       Loaded volatile event store with next number 1001
2025-07-28 18:28:03.624 INFO   Endpoint             node-tapparella-cam ready endpoint#: 0 type: RootNode (0x16) behaviors: 💤parts ✓index ✓basicInformation ✓accessControl ✓groupKeyManagement ✓generalCommissioning ✓administratorCommissioning ✓operationalCredentials ✓generalDiagnostics ✓commissioning ✓network 💤productDescription 💤subscription 💤sessions ✓events 💤controller ✓descriptor
[implementation] EndpointType "behaviors" must be an array of Behavior.Type instances
      at new Behaviors (file:///opt/matter-bridge/node_modules/@matter/node/dist/esm/endpoint/properties/Behaviors.js:121:13)
      at new Endpoint (file:///opt/matter-bridge/node_modules/@matter/node/dist/esm/endpoint/Endpoint.js:253:23)
      at run (file:///opt/matter-bridge/devices/tapparella-camera.js:55:22)