votebot.js

var voteQueue = [];
var progress = 0;
let progress_bar = document.getElementById("progress");

function showProgress() {
    var dots = "";
    for(let i = 0; i < progress; i++) {
        dots = dots + ".";
    }
    progress_bar.innerHTML = "Работаем" + dots;
    progress = progress + 1;
    if(progress > 3) {
        progress = 0;
    } 
}

function showStop() {
    progress_bar.innerHTML = "Остановлено";
}

function toggleKey() {
    let key = document.getElementById("k");
    if(key.type == "text") {
        key.type = "password";
    } else {
        key.type = "text";
    }
}

function recoverData() {
    let raw_users = document.getElementById("voteaccounts");
    let key = document.getElementById("k");
    let username = document.getElementById("username");
    
    raw_users.value = localStorage.getItem("raw_users");
    key.value = localStorage.getItem("key");
    username.value = localStorage.getItem("username");
}

function parseAccounts(inp) {
    let accs = inp.split(",");
    for(let i = 0; i < accs.length; i++) {
        accs[i] = accs[i].trim();
    }
    return accs;
}

function showAccounts(ta) {
    var accs = parseAccounts(ta.value);
    var view = document.getElementById("accounts_view");
    var html = "";
    for(var i = 0; i < accs.length; i++) {
        html = html + "<br><a href='" + golosbase +"/@" + accs[i] + "'>@"+accs[i]+ "</a>";
    }
    view.innerHTML = html;
}

var votepower = 0;
var workerTimer;

function startVoting() {
    console.log("startBot");
    showAccounts(document.getElementById("voteaccounts"));
    
    steem.api.setWebSocket(golos_ws);
    var users = parseAccounts(document.getElementById("voteaccounts").value),
        k = document.getElementById("k").value,
        username = document.getElementById("username").value,
        votepower = document.getElementById("votepower").value,
        delay = document.getElementById("delay").value,
        debug = document.getElementById("debug").value,
        time, starttime, acttime, t = 1000,
        period = 10 * 60,
        utime, start, history,
        raw_users = document.getElementById("voteaccounts").value;
    
    function isDebug() {
        return debug == "debug";
    }

    localStorage.setItem("raw_users", raw_users);
    localStorage.setItem("key", k);
    localStorage.setItem("username", username);

    if(typeof users == "undefined" ||users.length == 0 || users.length == 1 && users[0] == "") {
        alert("Введите имена пользователей за которыми следить!");
        return;
    }

    if(typeof k != "undefined" && !k.startsWith("5")) {
        alert("Возможно вы ввели открытый ключ, тебуется однако приватный (начинается с '5'");
    }

    //Инициализация кэша
    var accounts = {};
    for(let i = 0; i < users.length; i++) {
        accounts[users[i]] = {lastId:-1, queue: []}; //-1 неизвестно, ждем новых постов
    }
    console.log(accounts);

    var checkDelay = 10000;
    var votingDelay = 3000;
    
    steem.api.getDynamicGlobalProperties(function(err, result) {
        starttime = Date.parse(result.time) / t;
    });
    //console.log("время запуска = " + starttime);
    progressTimer = setInterval(function() {
        showProgress();
    }, 1000);
    workerTimer = setInterval(function() {
        steem.api.getDynamicGlobalProperties(function(err, result) {
            acttime = Date.parse(result.time) / t;
        });
        for(let i = 0; i < users.length; i++) {
            let u = users[i];
            console.log("получение истории пользователя " +u);
            steem.api.getAccountHistory(u, -1, 20, function(err, result) {

                if(err != null) {
                    console.error("Ошибка получения истории ", err);
                    return;
                }
                
                //получили 10 последних записей из истории 
                //console.log(result);
                for(var ai = 0; ai < result.length; ai++) {
                    let heId = result[ai][0];
                    //проверить id, больше ли, чем уже прочитанный ранее?
                    if(isDebug()) {
                        console.log("сохраненный id = " + accounts[u].lastId + "  " + heId );
                    }
                    if(accounts[u].lastId < heId) {
                        let he = result[ai][1].op;
                        let time = result[ai][1].timestamp;
                        let utime = Date.parse(time) / t;
                        let tx = result[ai][1].trx_id;
                        //console.log(utime);
                        if(typeof he !== "undefined") {//Отсеять ошибки
                            let op = he[0];
                            let entry = he[1];
                            let nice_name = u + " / " + entry.permlink;
                            let earliesttime = acttime - (delay*60); //проверить, не созрел ли пост для голосования
                            if(op == "comment" && entry.author == u && entry.parent_author == "" && !entry.body.match("^@@ .* @@")) {
                                if(isDebug()) {
                                    console.log("найден пост " + nice_name);
                                    console.log("время запуска = " + starttime);
                                    console.log("время опроса = " + acttime);
                                    console.log("время время созревания = " + earliesttime);
                                    console.log("время создания поста = " + utime);
                                }
                                if(utime < earliesttime) {
                                    //console.log(entry);
                                    console.log(heId + ":" + accounts[u].lastId  + " добавить в очередь : " + u + " / " + entry.permlink);
                                    //добавляем в очередь для голосования
                                    accounts[u].queue.push({
                                        author : u,
                                        permlink : entry.permlink,
                                        title : entry.title,
                                        tx : tx,
                                        id : heId
                                    });
                                    votehtml = '<div><a href="https://golos.io/@' + u + '/' + entry.permlink + '"><strong>' + u + ": "  + entry.title + '</strong></a> <img id="' + tx + '" src="ic_check_box_outline_blank_white_24dp.png"/></div>';
                                    document.getElementById('nicedata').insertAdjacentHTML('afterbegin', votehtml);

                                    checkDelay = checkDelay + votingDelay;
                                }
                            }
                        }
                    }
                }
                //недавние голосования
                var actualVotes = [];
                var goVote = setInterval(function() {
                    let vote = accounts[u].queue.shift();
                    
                    if(typeof vote !== "undefined") {

                        //На всякий случай исключить двойное голосование
                        let voteKey = vote.author + "/" + vote.permlink;
                        if(!actualVotes.includes(voteKey)) {
                            actualVotes.push(voteKey);
                            
                            //убедиться, может быть раньше голосовали
                            steem.api.getActiveVotes(vote.author, vote.permlink, function(err, result) {
                                     
                                //console.log(result);
                                var alreadyVoted = false;
                                for(let i = 0; i < result.length; i++) {
                                    if(result[i].voter == username) {
                                        alreadyVoted = true;
                                        break;
                                    }
                                }
                                if(!alreadyVoted) {
                                    steem.broadcast.vote(k, username, vote.author, vote.permlink, votepower * 100, function(err, result) {
                                        console.log(err,result);
                                        let itemVote = document.getElementById(vote.tx);
                                        if(typeof err == "undefined") {
                                            alreadyVoted = true;
                                        } else {
                                            itemVote.src = "ic_error_white_24dp.png";
                                        }                                                                                    
                                    });
                                    if(checkDelay > 10000) {
                                        checkDelay = checkDelay - votingDelay;
                                    }
                                }
                                if(alreadyVoted) {
                                    let itemVote = document.getElementById(vote.tx);
                                    itemVote.src = "ic_check_box_white_24dp.png";
                                    accounts[u].lastId = vote.id;
                                    
                                }                                    
                            });
                        }
                    } else {
                        clearInterval(goVote);
                    }

                }, votingDelay);
            });
        }
    }, checkDelay);
}
    
function stopVoting() {
    clearInterval(workerTimer);
    clearInterval(progressTimer);
    showStop();
}