// إنشاء قناة بيانات WebRTC للمزامنة اللامركزية بين المتصفحات
class EdgeSyncMesh {
    constructor(identifier) {
        this.peerConnection = new RTCPeerConnection({
            iceServers: [{ urls: 'stun:stun.l.google.com:19302' }]
        });
        this.dataChannel = null;
        this.isInitiator = identifier;
    }

    async init() {
        if (this.isInitiator) {
            this.dataChannel = this.peerConnection.createDataChannel("edge-sync-channel");
            this.setupDataChannelEvents();
            const offer = await this.peerConnection.createOffer();
            await this.peerConnection.setLocalDescription(offer);
            // إرسال العرض عبر خادم الإشارة (Signaling Server)
            return offer;
        } else {
            this.peerConnection.ondatachannel = (event) => {
                this.dataChannel = event.channel;
                this.setupDataChannelEvents();
            };
        }
    }

    setupDataChannelEvents() {
        this.dataChannel.onmessage = (event) => {
            const incomingData = JSON.parse(event.data);
            this.mergeDistributedState(incomingData);
        };
        this.dataChannel.onopen = () => console.log("تمت بنجاح متصل الحافة الموزعة");
    }

    broadcastStateChange(localState) {
        if (this.dataChannel && this.dataChannel.readyState === "open") {
            this.dataChannel.send(JSON.stringify(localState));
        }
    }

    async mergeDistributedState(data) {
        // خوارزمية دمج البيانات لضمان الاتساق النهائي (Eventual Consistency)
        const db = await indexedDB.open("EdgeStore", 1);
        console.log("تحديث البيانات القادمة من الحافة:", data);
    }
}

// تطبيق هيكل بيانات LWW-Map بسيط للمزامنة اللامركزية
class DistributedLWWMap {
    constructor() {
        this.store = new Map(); // مفتاح -> { value, timestamp, nodeId }
        this.nodeId = crypto.randomUUID();
    }

    set(key, value) {
        const timestamp = Date.now();
        this.store.set(key, { value, timestamp, nodeId: this.nodeId });
    }

    get(key) {
        return this.store.get(key)?.value;
    }

    merge(remoteMapData) {
        for (const [key, remoteEntry] of Object.entries(remoteMapData)) {
            const localEntry = this.store.get(key);

            if (!localEntry) {
                this.store.set(key, remoteEntry);
            } else {
                // حل التعارض بناءً على الطابع الزمني الأعلى، وفي حال التساوي نلجأ لمعرف العقدة
                if (remoteEntry.timestamp > localEntry.timestamp || 
                   (remoteEntry.timestamp === localEntry.timestamp && remoteEntry.nodeId > localEntry.nodeId)) {
                    this.store.set(key, remoteEntry);
                }
            }
        }
    }
}