package fitnesse.responders.run;
import static util.RegexTestCase.*;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
import fitnesse.testrunner.Stoppable;
import org.junit.Before;
import org.junit.Test;
import fitnesse.FitNesseContext;
import fitnesse.http.MockRequest;
import fitnesse.http.MockResponseSender;
import fitnesse.http.Request;
import fitnesse.http.Response;
import fitnesse.testutil.FitNesseUtil;
import fitnesse.wiki.fs.InMemoryPage;
public class StopTestResponderTest {
private Request request = null;
private FitNesseContext context = null;
private StoppedRecorder stoppableA = new StoppedRecorder();
private StoppedRecorder stoppableB = new StoppedRecorder();
@Before
public void setUp() throws Exception {
request = new MockRequest();
context = FitNesseUtil.makeTestContext(InMemoryPage.makeRoot("RooT"));
}
@Test
public void testStopAll() throws Exception {
SuiteResponder.runningTestingTracker.addStartedProcess("1", stoppableA);
SuiteResponder.runningTestingTracker.addStartedProcess("2", stoppableB);
StopTestResponder stopResponder = new StopTestResponder();
String response = runResponder(stopResponder);
assertTrue(stoppableA.wasStopped());
assertTrue(stoppableB.wasStopped());
assertSubString("all", response);
assertSubString("2", response);
}
@Test
public void testStopB() throws Exception {
SuiteResponder.runningTestingTracker.addStartedProcess("1", stoppableA);
final String bId = SuiteResponder.runningTestingTracker.addStartedProcess("2", stoppableB);
request = new MockRequest() {
@Override
public boolean hasInput(String key) {
return ("id".equalsIgnoreCase(key));
}
@Override
public Object getInput(String key) {
return bId;
}
};
StopTestResponder stopResponder = new StopTestResponder();
String response = runResponder(stopResponder);
assertFalse(stoppableA.wasStopped());
assertTrue(stoppableB.wasStopped());
assertSubString("Stopped 1 test", response);
}
private String runResponder(StopTestResponder responder) throws Exception {
Response response = responder.makeResponse(context, request);
MockResponseSender sender = new MockResponseSender();
sender.doSending(response);
String results = sender.sentData();
return results;
}
class StoppedRecorder implements Stoppable {
private boolean wasStopped = false;
public synchronized void stop() {
wasStopped = true;
}
public synchronized boolean wasStopped() {
return wasStopped;
}
}
}