ycrpg/js/plugins/SF_AutoUpdateWorker.js

onmessage = function (e) {
    var request = e.data;

    var result_files = {};
    result_files.delete_list = [];
    result_files.update_list = [];

    switch (request.command) {
        case "compare":
            compare_file_info(request.local_file_info, request.remote_file_info, result_files);
            send_command("delete", result_files.delete_list);
            send_command("update", result_files.update_list);
            send_command("finish", []);
            break;
        case "finish":
            send_command("finish");
            break;
    }
};

function compare_file_info(local_file_info, remote_file_info, result_files) {
    if (!remote_file_info) {
        result_files.delete_list = result_files.delete_list.concat(generate_file_list(local_file_info));
    } else if (!local_file_info) {
        result_files.update_list = result_files.update_list.concat(generate_file_list(remote_file_info));
    } else if (local_file_info.is_dir !== remote_file_info.is_dir) {
        result_files.delete_list = result_files.delete_list.concat(generate_file_list(local_file_info));
        result_files.update_list = result_files.update_list.concat(generate_file_list(remote_file_info));
    } else if (local_file_info.sha_512 !== remote_file_info.sha_512) {
        if (local_file_info.is_dir) {
            var visited_children = new Set();
            for (var i in local_file_info.children) {
                compare_file_info(local_file_info.children[i], remote_file_info.children[i], result_files);
                visited_children.add(i);
            }
            for (var i in remote_file_info.children) {
                if (!visited_children.has(i)) {
                    result_files.update_list = result_files.update_list.concat(
                        generate_file_list(remote_file_info.children[i])
                    );
                }
            }
        } else {
            result_files.update_list = result_files.update_list.concat(generate_file_list(remote_file_info));
        }
    }
}

function generate_file_list(file_info) {
    if (!file_info) {
        return [];
    }

    var file_list = [];
    if (file_info.is_dir) {
        for (var i in file_info.children) {
            file_list = file_list.concat(generate_file_list(file_info.children[i]));
        }
    }
    file_list.push({
        file_name: file_info.file_name,
        is_dir: file_info.is_dir,
        is_file: file_info.is_file,
        sha_512: file_info.sha_512,
    });
    return file_list;
}

// command: delete, update, finish
function send_command(command, file_list) {
    var command_data = {
        command: command,
        file_list: file_list,
    };
    postMessage(command_data);
}