Strolch
/
strolch
mirror of https://github.com/strolch-li/strolch.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[New] Allow to pass Action to Controller for actions

This commit is contained in:
Robert von Burg 2021-08-25 16:10:01 +02:00
parent 7005452a8c
commit a876509eb1
1 changed files with 71 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

94
li.strolch.service/src/main/java/li/strolch/execution/Controller.java
View File

@ -185,11 +185,7 @@ public class Controller {
Action action = this.activity.getElementByLocator(actionLoc);
// set this action to executed
SetActionToExecutedCommand command = new SetActionToExecutedCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
toExecuted(tx, action);
updateObservers();
@ -207,6 +203,22 @@ public class Controller {
this.executionHandler.triggerExecution(this.realm);
}
/**
* Completes the execution of the given {@link Action}
*
* @param tx
* the TX
* @param action
* the {@link Action} to set to executed
*/
public void toExecuted(StrolchTransaction tx, Action action) throws Exception {
SetActionToExecutedCommand command = new SetActionToExecutedCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
}
/**
* Sets the state of the {@link Action} with the given {@link Locator} to {@link State#STOPPED}
*
@ -224,11 +236,7 @@ public class Controller {
Action action = this.activity.getElementByLocator(actionLoc);
// set this action to executed
SetActionToStoppedCommand command = new SetActionToStoppedCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
toStopped(tx, action);
tx.commitOnClose();
}
@ -237,6 +245,22 @@ public class Controller {
updateObservers();
}
/**
* Sets the state of the {@link Action} to {@link State#STOPPED}
*
* @param tx
* the TX
* @param action
* the {@link Action} to set to stopped
*/
public void toStopped(StrolchTransaction tx, Action action) throws Exception {
SetActionToStoppedCommand command = new SetActionToStoppedCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
}
/**
* Sets the state of the {@link Action} with the given {@link Locator} to {@link State#ERROR}
*
@ -253,12 +277,8 @@ public class Controller {
Action action = this.activity.getElementByLocator(actionLoc);
// set this action to executed
SetActionToErrorCommand command = new SetActionToErrorCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
// set this action to error
toError(tx, action);
tx.commitOnClose();
}
@ -267,6 +287,22 @@ public class Controller {
updateObservers();
}
/**
* Sets the state of the {@link Action} to {@link State#ERROR}
*
* @param tx
* the TX
* @param action
* the {@link Action} to set to error
*/
public void toError(StrolchTransaction tx, Action action) throws Exception {
SetActionToErrorCommand command = new SetActionToErrorCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
}
/**
* Sets the state of the {@link Action} with the given {@link Locator} to {@link State#WARNING}
*
@ -283,12 +319,8 @@ public class Controller {
Action action = this.activity.getElementByLocator(actionLoc);
// set this action to executed
SetActionToWarningCommand command = new SetActionToWarningCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
// set this action to warning
toWarning(tx, action);
tx.commitOnClose();
}
@ -297,6 +329,22 @@ public class Controller {
updateObservers();
}
/**
* Sets the state of the {@link Action} with the given {@link Locator} to {@link State#WARNING}
*
* @param tx
* the TX
* @param action
* the {@link Action} to set to error
*/
public void toWarning(StrolchTransaction tx, Action action) throws Exception {
SetActionToWarningCommand command = new SetActionToWarningCommand(tx);
command.setExecutionPolicy(refreshExecutionPolicy(tx, action));
command.setAction(action);
command.validate();
command.doCommand();
}
/**
* Sets the state of the {@link Action} with the given {@link Locator} to {@link State#ERROR}
*
@ -366,7 +414,7 @@ public class Controller {
}
}
private void updateObservers() {
public void updateObservers() {
StrolchRealm realm = this.executionHandler.getContainer().getRealm(this.realm);
if (!realm.isUpdateObservers())
return;