VisualSapfor/src/Visual_DVM_2021/Passes/All/CloneDVMPackage.java

package Visual_DVM_2021.Passes.All;
import Common.Constants;
import Common.Current;
import Common.Database.Database;
import Common.Global;
import Common.Utils.Utils;
import GlobalData.Compiler.CompilerType;
import GlobalData.Machine.MachineType;
import GlobalData.Tasks.TaskState;
import GlobalData.User.UserState;
import TestingSystem.Common.Group.Group;
import TestingSystem.Common.TasksPackageState;
import TestingSystem.Common.Test.Test;
import TestingSystem.Common.Test.TestType;
import TestingSystem.DVM.DVMPackage.DVMPackage;
import TestingSystem.DVM.DVMPackage.DVMPackage_json;
import TestingSystem.DVM.DVMTasks.DVMCompilationTask;
import TestingSystem.DVM.DVMTasks.DVMRunTask;
import Visual_DVM_2021.Passes.AddObjectPass;
import Visual_DVM_2021.Passes.PassCode_2021;
public class CloneDVMPackage extends AddObjectPass<DVMPackage> {
    DVMPackage src;
    public CloneDVMPackage() {
        super(DVMPackage.class);
    }
    @Override
    public String getIconPath() {
        return "/icons/MultiFiles.png";
    }
    @Override
    protected Database getDb() {
        return Global.testingServer.db;
    }
    @Override
    protected boolean canStart(Object... args) throws Exception {
        src = null;
        if (!Current.getAccount().CheckRegistered(Log)) {
            return false;
        }
        if (Current.Check(Log, Current.Machine, Current.User, Current.Compiler, Current.DVMPackage)) {
            if (!Current.getMachine().type.equals(MachineType.Server)) {
                Log.Writeln_("Тестирование поддерживается только на одиночном удалённом сервере.");
                return false;
            }
            if (!Current.getUser().state.equals(UserState.ready_to_work)) {
                Log.Writeln_("Пользователь не готов к работе. Выполните инициализацию пользователя!");
                return false;
            }
            if (!Current.getCompiler().type.equals(CompilerType.dvm)) {
                Log.Writeln_("Тестирование поддерживается только для DVM компиляторов.");
                return false;
            }
            if (!Current.getCompiler().versionLoaded)
                passes.get(PassCode_2021.ShowCompilerVersion).Do(Current.getCompiler(), false);
            //-
            for (DVMPackage dvmPackage : Global.testingServer.db.dvmPackages.Data.values()) {
                if (dvmPackage.state.equals(TasksPackageState.Draft)) {
                    Log.Writeln_("Может существовать только один пакет, готовящийся к публикации.");
                    return false;
                }
            }
            //--
            src = Current.getDVMPackage();
            if (!src.state.equals(TasksPackageState.Done)) {
                Log.Writeln_("Возможно повторить только завершенный пакет!");
                return false;
            }
            if (!src.isLoaded())
                passes.get(PassCode_2021.DownloadDVMPackage).Do();
            if (!src.isLoaded())
                return false;
            //---->>
            target = new DVMPackage();
            target.id = Constants.Nan;
            //-
            target.sender_name = Current.getAccount().name;
            target.sender_address = Current.getAccount().email;
            //-
            target.machine_name = Current.getMachine().name;
            target.machine_address = Current.getMachine().address;
            target.machine_port = Current.getMachine().port;
            //-
            target.user_name = Current.getUser().login;
            target.user_password = Current.getUser().password;
            target.user_workspace = Current.getUser().workspace;
            //--
            target.drv = Current.getCompiler().call_command;
            target.version = Current.getCompiler().getVersionInfo();
            //--
            target.kernels = Global.properties.TestingKernels;
            target.needsEmail = Global.properties.EmailOnTestingProgress ? 1 : 0;
            //--
            target.tasksCount = 0;
            //--
            return true;
        }
        return false;
    }
    @Override
    protected void body() throws Exception {
        // надо скопировать все задачи.
        src.readJson();
        target.package_json = new DVMPackage_json();
        //--
        for (DVMCompilationTask src_compilationTask : src.package_json.compilationTasks) {
            if (Global.testingServer.db.groups.containsKey(src_compilationTask.group_id) &&
                    Global.testingServer.db.tests.containsKey(src_compilationTask.test_id)
            ) {
                Group group = Global.testingServer.db.groups.get(src_compilationTask.group_id);
                Test test = Global.testingServer.db.tests.get(src_compilationTask.test_id);
                //--
                DVMCompilationTask compilationTask = new DVMCompilationTask();
                //--
                compilationTask.group_id = group.id;
                compilationTask.group_description = group.description;
                compilationTask.language = src_compilationTask.language;
                //--
                compilationTask.test_id = test.id;
                compilationTask.test_description = test.description;
                compilationTask.test_type = group.type;
                //--
                compilationTask.maxtime = src_compilationTask.maxtime;
                //--
                compilationTask.flags = src_compilationTask.flags;
                compilationTask.kernels = 1;
                //---
                for (DVMRunTask src_runTask : src_compilationTask.runTasks) {
                    DVMRunTask runTask = new DVMRunTask();
                    //--
                    runTask.group_id = group.id;
                    runTask.group_description = group.description;
                    runTask.language = src_runTask.language;
                    //--
                    runTask.test_id = test.id;
                    runTask.test_description = test.description;
                    runTask.test_type = group.type;
                    //--
                    runTask.compilation_maxtime = src_runTask.compilation_maxtime;
                    runTask.compilation_state = TaskState.Waiting;
                    runTask.maxtime = src_runTask.maxtime;
                    //--
                    runTask.cube = src_runTask.cube;
                    runTask.min_dim = src_runTask.min_dim;
                    runTask.max_dim = src_runTask.max_dim;
                    runTask.matrix = src_runTask.matrix;
                    runTask.environments = src_runTask.environments;
                    runTask.usr_par = src_runTask.usr_par;
                    runTask.args = test.args;
                    //--
                    runTask.flags = src_runTask.flags;
                    runTask.kernels = (group.type == TestType.Performance) ? target.kernels :
                            Math.min(Utils.getMatrixProcessors(src_runTask.matrix), target.kernels);
                    compilationTask.runTasks.add(runTask);
                }
                //--
                target.package_json.compilationTasks.add(compilationTask);
                //-
            }
        }
        ///-
        //инициализируем идентификаторы задач.
        for (DVMCompilationTask compilationTask : target.package_json.compilationTasks) {
            //--
            compilationTask.id = target.package_json.getMaxTaskId();
            //-
            for (DVMRunTask runTask : compilationTask.runTasks) {
                runTask.id = target.package_json.getMaxTaskId();
                runTask.dvmcompilationtask_id = compilationTask.id;
                target.tasksCount++;
            }
        }
        //черновик не вставляется в бд. идет только как элемент списка.
        Global.testingServer.db.dvmPackages.Data.put(target.id, target);
    }
    @Override
    protected void showDone() throws Exception {
        super.showDone();
        Global.testingServer.db.dvmRunTasks.ShowDVMPackage(target);
    }
}