no message

This commit is contained in:
2025-02-04 20:51:23 +03:00
parent b05e7ffaec
commit d4c2875ed5
6 changed files with 24 additions and 63 deletions

View File

@@ -1,22 +1,23 @@
package _VisualDVM.Passes.All;
import _VisualDVM.Global;
import _VisualDVM.Passes.Server.ComponentsRepositoryPass_OLD;
import _VisualDVM.Passes.Server.ComponentsServerPass;
import _VisualDVM.Repository.Server.ServerCode;
import _VisualDVM.Repository.Server.ServerExchangeUnit_2021;
import java.io.File;
import java.util.Vector;
public class GetComponentsBackupsFromServer extends ComponentsRepositoryPass_OLD<Vector<File>> {
public class GetComponentsBackupsFromServer extends ComponentsServerPass<Vector<File>> {
@Override
protected boolean canStart(Object... args) throws Exception {
target = new Vector<>();
return Global.components.getUI().CheckCurrent(Log);
return Global.components.getUI().CheckCurrent(Log)&&
SendRequest(ServerCode.GetComponentsBackups,
Global.components.getUI().getCurrent().getComponentType().toString());
}
@Override
protected void ServerAction() throws Exception {
Command(new ServerExchangeUnit_2021(ServerCode.GetComponentsBackups,
Global.components.getUI().getCurrent().getComponentType().toString()));
target = (Vector<File>) server_response.object;
protected void body() throws Exception {
target = (Vector<File>) request.server_response.object;
}
@Override
protected boolean validate() {

View File

@@ -1,36 +1,16 @@
package _VisualDVM.Passes.All;
import _VisualDVM.Passes.Server.ComponentsRepositoryPass_OLD;
import _VisualDVM.Passes.Server.ComponentsServerPass;
import _VisualDVM.Repository.Server.ServerCode;
import _VisualDVM.Repository.Server.ServerExchangeUnit_2021;
import java.net.ConnectException;
public class PingComponentsServer extends ComponentsRepositoryPass_OLD {
boolean flag;
public class PingComponentsServer extends ComponentsServerPass {
//todo ПИНГ РЕАЛИЗОВАТЬ ЧЕРЕЗ SSH
boolean silent;
@Override
protected boolean canStart(Object... args) throws Exception {
flag = false;
silent = args.length > 0 ? (boolean) args[0] : false;
return super.canStart(args);
}
@Override
protected void ServerAction() throws Exception {
Command(new ServerExchangeUnit_2021(ServerCode.Ping));
flag = true;
}
@Override
protected boolean validate() {
return flag;
}
@Override
protected void CheckException(Exception ex) {
if (silent) {
Throwable cause = getCauseRec(ex);
if ((cause instanceof ConnectException) && cause.getMessage().contains("Connection refused: connect")) {
//так как это пинг, игнорируем.
return;
}
}
super.CheckException(ex);
return super.canStart(args)&&SendRequest(ServerCode.Ping);
}
}

View File

@@ -1,36 +1,16 @@
package _VisualDVM.Passes.All;
import _VisualDVM.Passes.Server.TestingServerPass;
import _VisualDVM.Passes.Server.TestingSystemPass_OLD;
import _VisualDVM.Repository.Server.ServerCode;
import _VisualDVM.Repository.Server.ServerExchangeUnit_2021;
import java.net.ConnectException;
public class PingTestingServer extends TestingSystemPass_OLD {
boolean flag;
public class PingTestingServer extends TestingServerPass {
//todo ПИНГ РЕАЛИЗОВАТЬ ЧЕРЕЗ SSH
boolean silent;
@Override
protected boolean canStart(Object... args) throws Exception {
flag = false;
silent = args.length > 0 ? (boolean) args[0] : false;
return super.canStart(args);
}
@Override
protected void ServerAction() throws Exception {
Command(new ServerExchangeUnit_2021(ServerCode.Ping));
flag = true;
}
@Override
protected boolean validate() {
return flag;
}
@Override
protected void CheckException(Exception ex) {
if (silent) {
Throwable cause = getCauseRec(ex);
if ((cause instanceof ConnectException) && cause.getMessage().contains("Connection refused: connect")) {
//так как это пинг, игнорируем.
return;
}
}
super.CheckException(ex);
return super.canStart(args)&&(SendRequest(ServerCode.Ping));
}
}

View File

@@ -1,16 +1,13 @@
package _VisualDVM.Passes.All;
import _VisualDVM.Passes.Server.ComponentsRepositoryPass_OLD;
import _VisualDVM.Passes.Server.ComponentsServerPass;
import _VisualDVM.Repository.Server.ServerCode;
import _VisualDVM.Repository.Server.ServerExchangeUnit_2021;
import _VisualDVM.Repository.SubscriberWorkspace.SubscriberWorkspace;
public class PublishRemoteWorkspace extends ComponentsRepositoryPass_OLD<SubscriberWorkspace> {
public class PublishRemoteWorkspace extends ComponentsServerPass<SubscriberWorkspace> {
@Override
protected boolean canStart(Object... args) throws Exception {
target = (SubscriberWorkspace) args[0];
return true;
}
@Override
protected void ServerAction() throws Exception {
Command(new ServerExchangeUnit_2021(ServerCode.PublishObject, "", target));
return SendRequest(ServerCode.PublishObject, "", target);
}
}

View File

@@ -118,6 +118,8 @@ public enum ServerCode {
return "Публикация объектов на сервере";
case ReplaceTestCode:
return "Замена кода теста на сервере";
case GetComponentsBackups:
return "Получение резервных копий компонента с сервера";
default:
return this.toString();
}