/**
 * @license
 * Copyright 2025-2026 Open Home Foundation
 * SPDX-License-Identifier: Apache-2.0
 */

import { NodeId } from "@matter/main";
import { EndpointNumber } from "@matter/main/types";
import { NodeStates, PairedNode } from "@project-chip/matter.js/device";
import { ServerError } from "../types/WebSocketMessageTypes.js";
import { AttributeDataCache } from "./AttributeDataCache.js";

/**
 * Manages node storage and tracks per-node availability.
 *
 * This class handles:
 * - Storage of PairedNode instances
 * - Node retrieval and existence checking
 * - Attribute data caching
 * - Connection state tracking for availability debouncing
 */
export class Nodes {
    #nodes = new Map<NodeId, PairedNode>();
    #attributeCache = new AttributeDataCache();
    /** Cached so serialization and event paths always agree on availability. */
    #lastAvailability = new Map<NodeId, boolean>();
    /**
     * Buffered endpoint_added events. python-matter-server wire contract requires
     * node_updated (carrying the new endpoint) to arrive before endpoint_added,
     * so HA can resolve node.endpoints[endpoint_id] in its callback.
     */
    #pendingEndpointAdds = new Map<NodeId, EndpointNumber[]>();

    get attributeCache(): AttributeDataCache {
        return this.#attributeCache;
    }

    getIds(): NodeId[] {
        return Array.from(this.#nodes.keys());
    }

    /** @throws ServerError if node not found */
    get(nodeId: NodeId): PairedNode {
        const node = this.#nodes.get(nodeId);
        if (node === undefined) {
            throw ServerError.nodeNotExists(nodeId);
        }
        return node;
    }

    has(nodeId: NodeId): boolean {
        return this.#nodes.has(nodeId);
    }

    set(nodeId: NodeId, node: PairedNode): void {
        this.#nodes.set(nodeId, node);
    }

    delete(nodeId: NodeId): void {
        this.#nodes.delete(nodeId);
        this.#attributeCache.delete(nodeId);
        this.#lastAvailability.delete(nodeId);
        this.#pendingEndpointAdds.delete(nodeId);
    }

    queueEndpointAdded(nodeId: NodeId, endpointId: EndpointNumber): void {
        let queue = this.#pendingEndpointAdds.get(nodeId);
        if (queue === undefined) {
            queue = [];
            this.#pendingEndpointAdds.set(nodeId, queue);
        }
        queue.push(endpointId);
    }

    /** Returns insertion-ordered queue; empty if nothing pending. */
    drainPendingEndpointAdds(nodeId: NodeId): EndpointNumber[] {
        const queue = this.#pendingEndpointAdds.get(nodeId);
        if (queue === undefined || queue.length === 0) {
            return [];
        }
        this.#pendingEndpointAdds.delete(nodeId);
        return queue;
    }

    seedState(nodeId: NodeId, initialState: NodeStates): void {
        this.#lastAvailability.set(nodeId, initialState === NodeStates.Connected);
    }

    /** `debouncePending` = reconnect timer armed by caller; keeps non-Connected states available. */
    processStateChange(
        nodeId: NodeId,
        newState: NodeStates,
        debouncePending: boolean,
    ): { availabilityChanged: true; available: boolean } | { availabilityChanged: false } {
        const wasAvailable = this.#lastAvailability.get(nodeId) ?? false;
        const available = this.isNodeAvailable(newState, debouncePending);

        this.#lastAvailability.set(nodeId, available);

        if (wasAvailable !== available) {
            return { availabilityChanged: true, available };
        }
        return { availabilityChanged: false };
    }

    /** Returns true if the node was previously considered available. */
    forceUnavailable(nodeId: NodeId): boolean {
        const wasAvailable = this.#lastAvailability.get(nodeId) ?? false;
        this.#lastAvailability.set(nodeId, false);
        return wasAvailable;
    }

    isNodeAvailable(currentState: NodeStates, debouncePending = false): boolean {
        if (currentState === NodeStates.Connected) {
            return true;
        }
        return debouncePending;
    }

    /** Returns the cached value, not a recomputation — avoids disagreement with the event path. */
    isAvailable(nodeId: NodeId): boolean {
        return this.#lastAvailability.get(nodeId) ?? false;
    }
}