// see https://github.com/siyuan-note/siyuan/blob/1710194122495d282a51650441d9fc80804561bb/app/src/layout/Model.ts
(() => {
    // 创建socket客户端
    createSocketClient(siyuan.ws.ws.url);

    // 当收到消息时被调用
    function onReceivedMessage(event) {
        const message = parseJson(event.data);
        if(message.cmd === 'transactions') {
            // 这里获取更新后的数据
            console.log(message);
        }
    }

    // 创建socket客户端
    function createSocketClient(url) {
        // 连接 WebSocket 服务器
        const socket = new WebSocket(url);
    
        socket.onopen = function(event) {
            console.log('WebSocket opened');
        };
    
        socket.onmessage = onReceivedMessage;
    
        socket.onclose = function(event) {
            console.log('WebSocket closed!');
        };
    
        socket.onerror = function(error) {
            console.error('WebSocket Error:', error);
        };

        return socket;
    }

    // 客户端向服务器发送消息
    function sendMessage(socket, message) {
        if (socket.readyState === WebSocket.OPEN) {
            socket.send(message);
        } else {
            console.error('WebSocket connection is not open');
        }
    }

    // 解析json
    function parseJson(jsonString) {
        let json = {};
        try {
            json = JSON.parse(jsonString || '{}');
        } catch(e) {
            json = {};
            console.error('parseJson error', e);
        }
        return json;
    }
})()

siyuan.ws.ws.addEventListener('message', (e) => {
    const msg = JSON.parse(e.data);
    if(msg.cmd === "transactions") {
        // 这里获取更新后的数据
        console.log(msg);
    }
});

// 当块被保存时执行回调（仅执行一次）
function whenBlockSaved(filter) {
    return new Promise((resolve, reject) => {
        const ws = siyuan.ws.ws;
        const clearEvent = () => ws.removeEventListener('message', handler);
        const handler = (event) => {
            try {
                const msg = JSON.parse(event.data);
                if(msg.cmd === "transactions") {
                    if(typeof filter === 'function') {
                        if(filter(msg)) resolve(msg);
                    } else {
                        resolve(msg);
                    }
                    clearEvent();
                }
            } catch(e) {
                reject(e);
                clearEvent();
            }
        }
        clearEvent();
        ws.addEventListener('message', handler);
    });
}

// 调用示例

// 链式调用
// whenBlockSaved().then((msg) => {
//     console.log(msg);
// });

// 异步调用
// const msg = await whenBlockSaved();
// console.log(msg);

// 过滤条件
// whenBlockSaved(msg => {
//     return msg.data.find(item => item.doOperations.find(item2 => item2.action === 'update' && item2.id === '20241204115642-hmpp8kh'));
// }).then((msg) => {
//     console.log(msg);
// });

// const filter = msg => msg.data.find(item => item.doOperations.find(item2 => item2.action === 'update' && item2.id === '20241204115642-hmpp8kh'));
// const msg = await whenBlockSaved(filter);
// console.log(msg);