A File can now also be used to specify the working dir

This commit is contained in:
Erik C. Thauvin 2024-04-05 12:55:44 -07:00
parent e7d3060649
commit 2a2c81994a
Signed by: erik
GPG key ID: 776702A6A2DA330E
2 changed files with 39 additions and 18 deletions

View file

@ -24,6 +24,7 @@ import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Objects;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.logging.Level; import java.util.logging.Level;
import java.util.logging.Logger; import java.util.logging.Logger;
@ -39,8 +40,8 @@ public class ExecOperation extends AbstractOperation<ExecOperation> {
private final List<String> args_ = new ArrayList<>(); private final List<String> args_ = new ArrayList<>();
private boolean failOnExit_ = true; private boolean failOnExit_ = true;
private BaseProject project_; private BaseProject project_;
private int timeout = 30; private int timeout_ = 30;
private String workDir_; private File workDir_;
/** /**
* Configures the command and arguments to be executed. * Configures the command and arguments to be executed.
@ -81,11 +82,11 @@ public class ExecOperation extends AbstractOperation<ExecOperation> {
LOGGER.severe("A project must be specified."); LOGGER.severe("A project must be specified.");
} }
final File workDir; final File workDir = Objects.requireNonNullElseGet(workDir_,
if (workDir_ == null || workDir_.isBlank()) { () -> new File(project_.workDirectory().getAbsolutePath()));
workDir = new File(project_.workDirectory().getAbsolutePath());
} else { if (LOGGER.isLoggable(Level.INFO)) {
workDir = new File(workDir_); LOGGER.info("Working directory: " + workDir.getAbsolutePath());
} }
if (workDir.isDirectory()) { if (workDir.isDirectory()) {
@ -99,21 +100,21 @@ public class ExecOperation extends AbstractOperation<ExecOperation> {
} }
var proc = pb.start(); var proc = pb.start();
var err = proc.waitFor(timeout, TimeUnit.SECONDS); var err = proc.waitFor(timeout_, TimeUnit.SECONDS);
if (!err) { if (!err) {
proc.destroy(); proc.destroy();
throw new IOException("The command timed out."); throw new IOException("The command timed out.");
} else if (proc.exitValue() != 0 && failOnExit_) { } else if (proc.exitValue() != 0 && failOnExit_) {
throw new IOException("The command exit status is: " + proc.exitValue()); throw new IOException("The command exit value/status is: " + proc.exitValue());
} }
} else { } else {
throw new IOException("Invalid work directory: " + workDir); throw new IOException("Invalid working directory: " + workDir);
} }
} }
/** /**
* Configures whether the operation should fail if the command exit status is not 0. * Configures whether the operation should fail if the command exit value/status is not 0.
* <p> * <p>
* Default is {@code TRUE} * Default is {@code TRUE}
* *
@ -143,18 +144,28 @@ public class ExecOperation extends AbstractOperation<ExecOperation> {
* @return this operation instance * @return this operation instance
*/ */
public ExecOperation timeout(int timeout) { public ExecOperation timeout(int timeout) {
this.timeout = timeout; timeout_ = timeout;
return this; return this;
} }
/** /**
* Configures the work directory. * Configures the working directory.
*
* @param dir the directory
* @return this operation instance
*/
public ExecOperation workDir(File dir) {
workDir_ = dir;
return this;
}
/**
* Configures the working directory.
* *
* @param dir the directory path * @param dir the directory path
* @return this operation instance * @return this operation instance
*/ */
public ExecOperation workDir(String dir) { public ExecOperation workDir(String dir) {
workDir_ = dir; return workDir(new File(dir));
return this;
} }
} }

View file

@ -53,12 +53,12 @@ class ExecOperationTest {
} }
@Test @Test
void testExitStatus() { void testExitValue() {
assertThatCode(() -> assertThatCode(() ->
new ExecOperation() new ExecOperation()
.fromProject(new BaseProject()) .fromProject(new BaseProject())
.command(List.of("cat", FOO)) .command(List.of("cat", FOO))
.execute()).message().contains("exit status"); .execute()).message().contains("exit value/status");
} }
@Test @Test
@ -83,11 +83,21 @@ class ExecOperationTest {
@Test @Test
void testWorkDir() { void testWorkDir() {
assertThatCode(() ->
new ExecOperation()
.fromProject(new BaseProject())
.command("echo", FOO)
.workDir(new File(System.getProperty("java.io.tmpdir")))
.execute()).doesNotThrowAnyException();
}
@Test
void testWorkDirInvalid() {
assertThatCode(() -> assertThatCode(() ->
new ExecOperation() new ExecOperation()
.fromProject(new BaseProject()) .fromProject(new BaseProject())
.command("echo") .command("echo")
.workDir(FOO) .workDir(FOO)
.execute()).message().startsWith("Invalid work directory: ").endsWith(FOO); .execute()).message().startsWith("Invalid working directory: ").endsWith(FOO);
} }
} }