VisualSapfor/src/Visual_DVM_2021/Passes/SSH/TaskConnectionPass.java

package Visual_DVM_2021.Passes.SSH;
import Common.Current;
import Common.Global;
import Common.Utils.Utils;
import GlobalData.RemoteFile.RemoteFile;
import GlobalData.Tasks.Supervisor.Remote.RemoteTaskSupervisor;
public abstract class TaskConnectionPass<S extends RemoteTaskSupervisor> extends ConnectionPass {
    public S supervisor; //инициализация идет в конструкторе потомка.
    public TaskConnectionPass(Class<S> s_class) {
        try {
            supervisor = s_class.newInstance();
        } catch (Exception e) {
            Global.Log.PrintException(e);
        }
    }
    @Override
    protected boolean needsAnimation() {
        return true;
    }
    @Override
    public void Connect() throws Exception {
        machine = supervisor.task.getMachine();
        user = supervisor.task.getUser();
        super.Connect();
        RemoteFile userWorkspace = new RemoteFile(user.workspace, true);
        if (!user.connection.Exists(userWorkspace))
            throw new WorkspaceNotFoundException(
                    "Рабочее пространство пользователя " + Utils.Brackets(user.login)
                            + " на машине " + Utils.Brackets(machine.getURL())
                            + "\n" + Utils.Brackets(user.workspace) + "\nне найдено.\n" +
                            "Требуется выполнить повторную инициализацию пользователя."
            );
    }
    @Override
    protected void ServerAction() throws Exception {
        supervisor.PerformTask();
    }
    @Override
    protected void performFinish() throws Exception {
        supervisor.UpdateTask();
        super.performFinish(); //disconnect
    }
    @Override
    public void Interrupt() throws Exception {
        Current.getProject().CreateInterruptFile();
    }
}