Джим и я проделали небольшую работу на прошлой неделе, которая включала вызов URI статуса HA neo4j, чтобы проверить, был ли экземпляр master / slave, и мы использовали jersey-client .
Код выглядел примерно так:
class Neo4jInstance {
private Client httpClient;
private URI hostname;
public Neo4jInstance(Client httpClient, URI hostname) {
this.httpClient = httpClient;
this.hostname = hostname;
}
public Boolean isSlave() {
String slaveURI = hostname.toString() + ":7474/db/manage/server/ha/slave";
ClientResponse response = httpClient.resource(slaveURI).accept(TEXT_PLAIN).get(ClientResponse.class);
return Boolean.parseBoolean(response.getEntity(String.class));
}
}
При написании некоторых тестов для этого кода мы хотели оцепить фактические вызовы URI подчиненного HA, чтобы мы могли смоделировать оба условия, и краткий поиск показал, что mockito был подходящим вариантом .
В итоге мы получили тест, который выглядел так:
@Test
public void shouldIndicateInstanceIsSlave() {
Client client = mock( Client.class );
WebResource webResource = mock( WebResource.class );
WebResource.Builder builder = mock( WebResource.Builder.class );
ClientResponse clientResponse = mock( ClientResponse.class );
when( builder.get( ClientResponse.class ) ).thenReturn( clientResponse );
when( clientResponse.getEntity( String.class ) ).thenReturn( "true" );
when( webResource.accept( anyString() ) ).thenReturn( builder );
when( client.resource( anyString() ) ).thenReturn( webResource );
Boolean isSlave = new Neo4jInstance(client, URI.create("http://localhost")).isSlave();
assertTrue(isSlave);
}
что довольно грубо, но делает работу.
Я подумал, что должен быть лучший способ, поэтому я продолжил поиск и в конце концов наткнулся на это сообщение в списке рассылки, в котором предлагалось создать собственный ClientHandler и заглушить там запросы / ответы.
Я попытался сделать это и обернул его небольшим DSL, который охватывает только наш очень специфический вариант использования:
private static ClientBuilder client() {
return new ClientBuilder();
}
static class ClientBuilder {
private String uri;
private int statusCode;
private String content;
public ClientBuilder requestFor(String uri) {
this.uri = uri;
return this;
}
public ClientBuilder returns(int statusCode) {
this.statusCode = statusCode;
return this;
}
public Client create() {
return new Client() {
public ClientResponse handle(ClientRequest request) throws ClientHandlerException {
if (request.getURI().toString().equals(uri)) {
InBoundHeaders headers = new InBoundHeaders();
headers.put("Content-Type", asList("text/plain"));
return createDummyResponse(headers);
}
throw new RuntimeException("No stub defined for " + request.getURI());
}
};
}
private ClientResponse createDummyResponse(InBoundHeaders headers) {
return new ClientResponse(statusCode, headers, new ByteArrayInputStream(content.getBytes()), messageBodyWorkers());
}
private MessageBodyWorkers messageBodyWorkers() {
return new MessageBodyWorkers() {
public Map<MediaType, List<MessageBodyReader>> getReaders(MediaType mediaType) {
return null;
}
public Map<MediaType, List<MessageBodyWriter>> getWriters(MediaType mediaType) {
return null;
}
public String readersToString(Map<MediaType, List<MessageBodyReader>> mediaTypeListMap) {
return null;
}
public String writersToString(Map<MediaType, List<MessageBodyWriter>> mediaTypeListMap) {
return null;
}
public <T> MessageBodyReader<T> getMessageBodyReader(Class<T> tClass, Type type, Annotation[] annotations, MediaType mediaType) {
return (MessageBodyReader<T>) new StringProvider();
}
public <T> MessageBodyWriter<T> getMessageBodyWriter(Class<T> tClass, Type type, Annotation[] annotations, MediaType mediaType) {
return null;
}
public <T> List<MediaType> getMessageBodyWriterMediaTypes(Class<T> tClass, Type type, Annotation[] annotations) {
return null;
}
public <T> MediaType getMessageBodyWriterMediaType(Class<T> tClass, Type type, Annotation[] annotations, List<MediaType> mediaTypes) {
return null;
}
};
}
public ClientBuilder content(String content) {
this.content = content;
return this;
}
}
Если мы изменим наш тест, чтобы использовать этот код, он теперь выглядит так:
@Test
public void shouldIndicateInstanceIsSlave() {
Client client = client().requestFor("http://localhost:7474/db/manage/server/ha/slave").
returns(200).
content("true").
create();
Boolean isSlave = new Neo4jInstance(client, URI.create("http://localhost")).isSlave();
assertTrue(isSlave);
}
Есть ли способ лучше?
В Ruby я использовал WebMock для достижения этой цели, и Ашок указал мне на WebStub, который выглядит неплохо, за исключением того, что мне нужно было бы передать имя хоста + порт, а не создавать его в коде.