Skip to content

Commit

Permalink
Add force restart and toggle live reload options to DevUI
Browse files Browse the repository at this point in the history 
Resolves: quarkusio#19011
  • Loading branch information
@geoand
geoand committed Jul 27, 2021
1 parent f4755fc commit 761be23
Show file tree
Hide file tree
Showing 13 changed files with 196 additions and 33 deletions.
10 changes: 8 additions & 2 deletions core/deployment/src/main/java/io/quarkus/deployment/console/ConsoleStateManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -106,8 +106,14 @@ void installBuiltins(DevModeType devModeType) {
}
}));
commands.add(new ConsoleCommand('l', "Toggle live reload",
new ConsoleCommand.HelpState(() -> RuntimeUpdatesProcessor.INSTANCE.isLiveReloadEnabled()),
() -> RuntimeUpdatesProcessor.INSTANCE.toggleLiveReloadEnabled()));
new ConsoleCommand.HelpState(() -> RuntimeUpdatesProcessor.INSTANCE.isLiveReloadEnabled()), () -> {
// TODO: same hack as above
if (TestSupport.instance().isPresent()) {
TestSupport.instance().get().toggleLiveReloadEnabled();
} else {
RuntimeUpdatesProcessor.INSTANCE.toggleLiveReloadEnabled();
}
}));
}

ConsoleContext context = createContext("System");
Expand Down
9 changes: 7 additions & 2 deletions core/deployment/src/main/java/io/quarkus/deployment/dev/RuntimeUpdatesProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -479,8 +479,13 @@ public boolean doScan(boolean userInitiated, boolean forceRestart) {
|| (IsolatedDevModeMain.deploymentProblem != null && userInitiated) || configFileRestartNeeded);
if (restartNeeded) {
String changeString = changedFilesForRestart.stream().map(Path::getFileName).map(Object::toString)
.collect(Collectors.joining(", ")) + ".";
log.infof("Restarting quarkus due to changes in " + changeString);
.collect(Collectors.joining(", "));
if (!changeString.isEmpty()) {
log.infof("Restarting quarkus due to changes in %s.", changeString);
} else if (forceRestart && userInitiated) {
log.info("Restarting as requested by the user.");
}

restartCallback.accept(filesChanged, changedClassResults);
long timeNanoSeconds = System.nanoTime() - startNanoseconds;
log.infof("Live reload total time: %ss ", Timing.convertToBigDecimalSeconds(timeNanoSeconds));
Expand Down
7 changes: 7 additions & 0 deletions core/deployment/src/main/java/io/quarkus/deployment/dev/testing/TestController.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,13 @@ public interface TestController {
*/
boolean toggleInstrumentation();

/**
* Toggles instrumentation based reload.
*
* @return <code>true</code> if this change to do instrumentation based reload
*/
boolean toggleLiveReloadEnabled();

/**
* Print the current results and failures
*/
Expand Down
4 changes: 4 additions & 0 deletions core/deployment/src/main/java/io/quarkus/deployment/dev/testing/TestListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,10 @@ default void setInstrumentationBasedReload(boolean ibr) {

}

default void setLiveReloadEnabled(boolean lre) {

}

default void testCompileFailed(String message) {

}
Expand Down
12 changes: 12 additions & 0 deletions core/deployment/src/main/java/io/quarkus/deployment/dev/testing/TestSupport.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -308,6 +308,18 @@ public boolean toggleInstrumentation() {
return ibr;
}

@Override
public boolean toggleLiveReloadEnabled() {

boolean lr = RuntimeUpdatesProcessor.INSTANCE.toggleLiveReloadEnabled();

for (TestListener i : testListeners) {
i.setLiveReloadEnabled(lr);
}

return lr;
}

@Override
public void printFullResults() {
if (currentState().getFailingClasses().isEmpty()) {
Expand Down
24 changes: 17 additions & 7 deletions .../devmode-spi/src/main/java/io/quarkus/dev/testing/ContinuousTestingWebsocketListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
public class ContinuousTestingWebsocketListener {

private static Consumer<State> stateListener;
private static volatile State lastState = new State(false, false, 0, 0, 0, 0, false, false, false);
private static volatile State lastState = new State(false, false, 0, 0, 0, 0, false, false, false, true);

public static Consumer<State> getStateListener() {
return stateListener;
Expand Down Expand Up @@ -35,39 +35,47 @@ public static void setInProgress(boolean inProgress) {
State state = lastState;
if (state != null) {
setLastState(new State(state.running, inProgress, state.run, state.passed, state.failed, state.skipped,
state.isBrokenOnly, state.isTestOutput, state.isInstrumentationBasedReload));
state.isBrokenOnly, state.isTestOutput, state.isInstrumentationBasedReload, state.isLiveReload));
}
}

public static void setRunning(boolean running) {
State state = lastState;
if (state != null) {
setLastState(new State(running, running && state.inProgress, state.run, state.passed, state.failed, state.skipped,
state.isBrokenOnly, state.isTestOutput, state.isInstrumentationBasedReload));
state.isBrokenOnly, state.isTestOutput, state.isInstrumentationBasedReload, state.isLiveReload));
}
}

public static void setBrokenOnly(boolean brokenOnly) {
State state = lastState;
if (state != null) {
setLastState(new State(state.running, state.inProgress, state.run, state.passed, state.failed, state.skipped,
brokenOnly, state.isTestOutput, state.isInstrumentationBasedReload));
brokenOnly, state.isTestOutput, state.isInstrumentationBasedReload, state.isLiveReload));
}
}

public static void setTestOutput(boolean testOutput) {
State state = lastState;
if (state != null) {
setLastState(new State(state.running, state.inProgress, state.run, state.passed, state.failed, state.skipped,
state.isBrokenOnly, testOutput, state.isInstrumentationBasedReload));
state.isBrokenOnly, testOutput, state.isInstrumentationBasedReload, state.isLiveReload));
}
}

public static void setInstrumentationBasedReload(boolean instrumentationBasedReload) {
State state = lastState;
if (state != null) {
setLastState(new State(state.running, state.inProgress, state.run, state.passed, state.failed, state.skipped,
state.isBrokenOnly, state.isTestOutput, instrumentationBasedReload));
state.isBrokenOnly, state.isTestOutput, instrumentationBasedReload, state.isLiveReload));
}
}

public static void setLiveReloadEnabled(boolean liveReload) {
State state = lastState;
if (state != null) {
setLastState(new State(state.running, state.inProgress, state.run, state.passed, state.failed, state.skipped,
state.isBrokenOnly, state.isTestOutput, state.isInstrumentationBasedReload, liveReload));
}
}

Expand All @@ -81,9 +89,10 @@ public static class State {
public final boolean isBrokenOnly;
public final boolean isTestOutput;
public final boolean isInstrumentationBasedReload;
public final boolean isLiveReload;

public State(boolean running, boolean inProgress, long run, long passed, long failed, long skipped,
boolean isBrokenOnly, boolean isTestOutput, boolean isInstrumentationBasedReload) {
boolean isBrokenOnly, boolean isTestOutput, boolean isInstrumentationBasedReload, boolean isLiveReload) {
this.running = running;
this.inProgress = inProgress;
this.run = run;
Expand All @@ -93,6 +102,7 @@ public State(boolean running, boolean inProgress, long run, long passed, long fa
this.isBrokenOnly = isBrokenOnly;
this.isTestOutput = isTestOutput;
this.isInstrumentationBasedReload = isInstrumentationBasedReload;
this.isLiveReload = isLiveReload;
}
}
}
10 changes: 8 additions & 2 deletions .../io/quarkus/vertx/http/deployment/devmode/console/ContinuousTestingWebSocketListener.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ public void listenerRegistered(TestController testController) {
public void testsEnabled() {
ContinuousTestingWebsocketListener
.setLastState(
new ContinuousTestingWebsocketListener.State(true, true, 0L, 0L, 0L, 0L, false, false, false));
new ContinuousTestingWebsocketListener.State(true, true, 0L, 0L, 0L, 0L, false, false, false, true));
}

@Override
Expand Down Expand Up @@ -55,7 +55,8 @@ public void runComplete(TestRunResults testRunResults) {
testRunResults.getFailedCount(), testRunResults.getSkippedCount(),
ContinuousTestingWebsocketListener.getLastState().isBrokenOnly,
ContinuousTestingWebsocketListener.getLastState().isTestOutput,
ContinuousTestingWebsocketListener.getLastState().isInstrumentationBasedReload));
ContinuousTestingWebsocketListener.getLastState().isInstrumentationBasedReload,
ContinuousTestingWebsocketListener.getLastState().isLiveReload));
}

@Override
Expand Down Expand Up @@ -86,4 +87,9 @@ public void setInstrumentationBasedReload(boolean ibr) {
ContinuousTestingWebsocketListener.setInstrumentationBasedReload(ibr);
}

@Override
public void setLiveReloadEnabled(boolean lre) {
ContinuousTestingWebsocketListener.setLiveReloadEnabled(lre);
}

}
55 changes: 43 additions & 12 deletions ...ployment/src/main/java/io/quarkus/vertx/http/deployment/devmode/tests/TestsProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
import io.quarkus.deployment.annotations.ExecutionTime;
import io.quarkus.deployment.annotations.Record;
import io.quarkus.deployment.builditem.LaunchModeBuildItem;
import io.quarkus.deployment.dev.RuntimeUpdatesProcessor;
import io.quarkus.deployment.dev.testing.TestClassResult;
import io.quarkus.deployment.dev.testing.TestListenerBuildItem;
import io.quarkus.deployment.dev.testing.TestRunResults;
Expand Down Expand Up @@ -73,7 +74,7 @@ DevConsoleRouteBuildItem handleTestStatus(LaunchModeBuildItem launchModeBuildIte
//DISABLED, RUNNING (run id), RUN (run id, start time, nextRunQueued)
//GET tests/results

return new DevConsoleRouteBuildItem("tests/status", "GET", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/status", "GET", new Handler<>() {
@Override
public void handle(RoutingContext event) {
jsonResponse(event);
Expand Down Expand Up @@ -106,7 +107,7 @@ void toggleTestRunner(LaunchModeBuildItem launchModeBuildItem, BuildProducer<Dev
if (testsDisabled(launchModeBuildItem, ts)) {
return;
}
routeProducer.produce(new DevConsoleRouteBuildItem("tests/toggle", "POST", new Handler<RoutingContext>() {
routeProducer.produce(new DevConsoleRouteBuildItem("tests/toggle", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
if (ts.get().isStarted()) {
Expand All @@ -120,7 +121,7 @@ public void handle(RoutingContext event) {
event.response().putHeader("Content-Type", "application/json; charset=utf-8").end(object.build());
}
}));
routeProducer.produce(new DevConsoleRouteBuildItem("tests/toggle-broken-only", "POST", new Handler<RoutingContext>() {
routeProducer.produce(new DevConsoleRouteBuildItem("tests/toggle-broken-only", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
boolean brokenOnlyMode = ts.get().toggleBrokenOnlyMode();
Expand All @@ -132,7 +133,7 @@ public void handle(RoutingContext event) {
}

private boolean testsDisabled(LaunchModeBuildItem launchModeBuildItem, Optional<TestSupport> ts) {
return !ts.isPresent() || launchModeBuildItem.getDevModeType().orElse(null) != DevModeType.LOCAL;
return ts.isEmpty() || launchModeBuildItem.getDevModeType().orElse(null) != DevModeType.LOCAL;
}

@BuildStep(onlyIf = IsDevelopment.class)
Expand All @@ -141,7 +142,7 @@ DevConsoleRouteBuildItem runAllTests(LaunchModeBuildItem launchModeBuildItem) {
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/runall", "POST", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/runall", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
ts.get().runAllTests();
Expand All @@ -150,12 +151,12 @@ public void handle(RoutingContext event) {
}

@BuildStep(onlyIf = IsDevelopment.class)
DevConsoleRouteBuildItem runFailedTests(LaunchModeBuildItem launchModeBuildItem) {
DevConsoleRouteBuildItem toggleTestOutput(LaunchModeBuildItem launchModeBuildItem) {
Optional<TestSupport> ts = TestSupport.instance();
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/toggle-test-output", "POST", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/toggle-test-output", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {

Expand All @@ -168,12 +169,12 @@ public void handle(RoutingContext event) {
}

@BuildStep(onlyIf = IsDevelopment.class)
DevConsoleRouteBuildItem toggleTestOutput(LaunchModeBuildItem launchModeBuildItem) {
DevConsoleRouteBuildItem runFailedTests(LaunchModeBuildItem launchModeBuildItem) {
Optional<TestSupport> ts = TestSupport.instance();
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/runfailed", "POST", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/runfailed", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
ts.get().runFailedTests();
Expand All @@ -187,7 +188,7 @@ DevConsoleRouteBuildItem printfailures(LaunchModeBuildItem launchModeBuildItem)
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/printfailures", "POST", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/printfailures", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
ts.get().printFullResults();
Expand All @@ -201,7 +202,7 @@ DevConsoleRouteBuildItem toggleInstrumentation(LaunchModeBuildItem launchModeBui
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/toggle-instrumentation", "POST", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/toggle-instrumentation", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
boolean instrumentationEnabled = ts.get().toggleInstrumentation();
Expand All @@ -212,14 +213,44 @@ public void handle(RoutingContext event) {
});
}

@BuildStep(onlyIf = IsDevelopment.class)
DevConsoleRouteBuildItem toggleLiveReloadEnabled(LaunchModeBuildItem launchModeBuildItem) {
Optional<TestSupport> ts = TestSupport.instance();
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}
return new DevConsoleRouteBuildItem("tests/toggle-live-reload", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
boolean liveReloadEnabled = ts.get().toggleLiveReloadEnabled();
Json.JsonObjectBuilder object = Json.object();
object.put("liveReloadEnabled", liveReloadEnabled);
event.response().putHeader("Content-Type", "application/json; charset=utf-8").end(object.build());
}
});
}

@BuildStep(onlyIf = IsDevelopment.class)
DevConsoleRouteBuildItem forceRestart(LaunchModeBuildItem launchModeBuildItem) {
if (testsDisabled(launchModeBuildItem, TestSupport.instance())) {
return null;
}
return new DevConsoleRouteBuildItem("tests/force-restart", "POST", new Handler<>() {
@Override
public void handle(RoutingContext event) {
RuntimeUpdatesProcessor.INSTANCE.doScan(true, true);
}
});
}

@BuildStep(onlyIf = IsDevelopment.class)
DevConsoleRouteBuildItem handleTestResult(LaunchModeBuildItem launchModeBuildItem) {
Optional<TestSupport> ts = TestSupport.instance();
if (testsDisabled(launchModeBuildItem, ts)) {
return null;
}

return new DevConsoleRouteBuildItem("tests/result", "GET", new Handler<RoutingContext>() {
return new DevConsoleRouteBuildItem("tests/result", "GET", new Handler<>() {
@Override
public void handle(RoutingContext event) {
TestRunResults testRunResults = ts.get().getResults();
Expand Down
Loading

0 comments on commit 761be23

Please sign in to comment.