package Visual_DVM_2021.Passes.All;
import Common.Current;
import Common.Global;
import Common.UI.UI;
import Repository.Server.ServerCode;
import Repository.Server.ServerExchangeUnit_2021;
import TestingSystem.DVM.DVMPackage.DVMPackage;
import TestingSystem.DVM.Tasks.TestRunTask;
import TestingSystem.DVM.TasksPackage.TasksPackage;
import TestingSystem.DVM.TasksPackage.TasksPackageState;
import Visual_DVM_2021.Passes.Server.TestingSystemPass;
import javafx.util.Pair;

import java.util.Vector;
public class ActualizeDVMPackages extends TestingSystemPass<Vector<Pair<Integer, TasksPackageState>>> {
    @Override
    protected boolean needsAnimation() {
        return false;
    }
    @Override
    protected boolean canStart(Object... args) throws Exception {
        target = new Vector<>();
        for (DVMPackage dvmPackage : Global.testingServer.db.dvmPackages.Data.values()) {
            if (dvmPackage.state.isActive())
                target.add(new Pair(dvmPackage.id, dvmPackage.state));
        }
        return !target.isEmpty();
    }
    @Override
    protected void ServerAction() throws Exception {
        Command(new ServerExchangeUnit_2021(ServerCode.UpdateActiveDVMPackages, "", target));
    }
    @Override
    protected void performDone() throws Exception {
        Vector<DVMPackage> res = (Vector<DVMPackage>) response.object;
        Global.testingServer.db.BeginTransaction();
        for (DVMPackage dvmPackage : res)
            Global.testingServer.db.UpdateWithCheck(dvmPackage);
        Global.testingServer.db.Commit();
    }
    @Override
    protected void showDone() throws Exception {
        Global.testingServer.db.dvmPackages.RefreshUI();
    }
}