|
1 | 1 | package mill.testng;
|
2 | 2 |
|
3 |
| -import org.scalatools.testing.Fingerprint; |
4 |
| -import org.scalatools.testing.Logger; |
5 |
| -import org.scalatools.testing.Runner2; |
6 |
| -import org.scalatools.testing.EventHandler; |
| 3 | +import sbt.testing.*; |
7 | 4 |
|
8 |
| -public class TestNGRunner extends Runner2 { |
9 |
| - ClassLoader testClassLoader; |
10 |
| - Logger[] loggers; |
11 |
| - TestRunState state; |
12 |
| - public TestNGRunner(ClassLoader testClassLoader, Logger[] loggers, TestRunState state) { |
13 |
| - this.testClassLoader = testClassLoader; |
14 |
| - this.loggers = loggers; |
15 |
| - this.state = state; |
| 5 | +class TestNGTask implements Task { |
| 6 | + |
| 7 | + TaskDef taskDef; |
| 8 | + TestNGRunner runner; |
| 9 | + public TestNGTask(TaskDef taskDef, TestNGRunner runner){ |
| 10 | + this.taskDef = taskDef; |
| 11 | + this.runner = runner; |
16 | 12 | }
|
17 |
| - public void run(String testClassname, Fingerprint fingerprint, EventHandler eventHandler, String[] testOptions) { |
| 13 | + |
| 14 | + @Override |
| 15 | + public String[] tags() { |
| 16 | + return new String[0]; |
| 17 | + } |
| 18 | + |
| 19 | + @Override |
| 20 | + public Task[] execute(EventHandler eventHandler, Logger[] loggers) { |
18 | 21 | if (TestRunState.permissionToExecute.tryAcquire()) {
|
19 | 22 | TestNGInstance.start(
|
20 | 23 | TestNGInstance.loggingTo(loggers)
|
21 |
| - .loadingClassesFrom(testClassLoader) |
22 |
| - .using(testOptions) |
23 |
| - .storingEventsIn(state.recorder) |
| 24 | + .loadingClassesFrom(runner.testClassLoader) |
| 25 | + .using(runner.args()) |
| 26 | + .storingEventsIn(runner.state.recorder) |
24 | 27 | );
|
25 | 28 |
|
26 |
| - state.testCompletion.countDown(); |
| 29 | + runner.state.testCompletion.countDown(); |
27 | 30 | }
|
28 | 31 |
|
29 | 32 | try{
|
30 |
| - state.testCompletion.await(); |
| 33 | + runner.state.testCompletion.await(); |
31 | 34 | }catch(InterruptedException e){
|
32 | 35 | throw new RuntimeException(e);
|
33 | 36 | }
|
34 | 37 |
|
35 |
| - state.recorder.replayTo(eventHandler, testClassname, loggers); |
| 38 | + runner.state.recorder.replayTo(eventHandler, taskDef.fullyQualifiedName(), loggers); |
| 39 | + return new Task[0]; |
| 40 | + } |
| 41 | + |
| 42 | + @Override |
| 43 | + public TaskDef taskDef() { |
| 44 | + return taskDef; |
| 45 | + } |
| 46 | +} |
| 47 | +public class TestNGRunner implements Runner { |
| 48 | + ClassLoader testClassLoader; |
| 49 | + TestRunState state; |
| 50 | + String[] args; |
| 51 | + String[] remoteArgs; |
| 52 | + public TestNGRunner(String[] args, String[] remoteArgs, ClassLoader testClassLoader, TestRunState state) { |
| 53 | + this.testClassLoader = testClassLoader; |
| 54 | + this.state = state; |
| 55 | + this.args = args; |
| 56 | + this.remoteArgs = remoteArgs; |
| 57 | + } |
| 58 | + |
| 59 | + public Task[] tasks(TaskDef[] taskDefs) { |
| 60 | + Task[] out = new Task[taskDefs.length]; |
| 61 | + for (int i = 0; i < taskDefs.length; i += 1) { |
| 62 | + out[i] = new TestNGTask(taskDefs[i], this); |
| 63 | + } |
| 64 | + return out; |
36 | 65 | }
|
| 66 | + |
| 67 | + public String done() { return null; } |
| 68 | + |
| 69 | + public String[] remoteArgs() { return remoteArgs; } |
| 70 | + |
| 71 | + public String[] args() { return args; } |
37 | 72 | }
|
0 commit comments