105 lines
3.6 KiB
Java
105 lines
3.6 KiB
Java
package org.oscim.tiling.source;
|
|
|
|
import org.junit.After;
|
|
import org.junit.Before;
|
|
import org.junit.Test;
|
|
import org.oscim.core.Tile;
|
|
import org.oscim.tiling.source.oscimap4.OSciMap4TileSource;
|
|
|
|
import java.io.BufferedReader;
|
|
import java.io.File;
|
|
import java.io.InputStream;
|
|
import java.io.InputStreamReader;
|
|
|
|
import okhttp3.Cache;
|
|
import okhttp3.OkHttpClient;
|
|
import okhttp3.mockwebserver.MockResponse;
|
|
import okhttp3.mockwebserver.MockWebServer;
|
|
import okhttp3.mockwebserver.RecordedRequest;
|
|
|
|
import static org.fest.assertions.api.Assertions.assertThat;
|
|
|
|
public class OkHttpEngineTest {
|
|
private OkHttpEngine engine;
|
|
private MockWebServer server;
|
|
|
|
@Before
|
|
public void setUp() throws Exception {
|
|
MockResponse mockResponse = new MockResponse();
|
|
mockResponse.setBody("TEST RESPONSE");
|
|
server = new MockWebServer();
|
|
server.enqueue(mockResponse);
|
|
server.start();
|
|
engine = (OkHttpEngine) new OkHttpEngine.OkHttpFactory()
|
|
.create(new OSciMap4TileSource(server.url("/tiles/vtm").toString()));
|
|
}
|
|
|
|
@After
|
|
public void tearDown() throws Exception {
|
|
server.shutdown();
|
|
}
|
|
|
|
@Test
|
|
public void shouldNotBeNull() throws Exception {
|
|
assertThat(engine).isNotNull();
|
|
}
|
|
|
|
@Test(expected = IllegalArgumentException.class)
|
|
public void sendRequest_shouldRejectNullTile() throws Exception {
|
|
engine.sendRequest(null);
|
|
}
|
|
|
|
@Test
|
|
public void sendRequest_shouldAppendXYZToPath() throws Exception {
|
|
engine.sendRequest(new Tile(1, 2, (byte) 3));
|
|
|
|
RecordedRequest request = server.takeRequest();
|
|
assertThat(request.getPath()).isEqualTo("/tiles/vtm/3/1/2.vtm");
|
|
}
|
|
|
|
@Test
|
|
public void read_shouldReturnResponseStream() throws Exception {
|
|
engine.sendRequest(new Tile(1, 2, (byte) 3));
|
|
|
|
InputStream responseStream = engine.read();
|
|
String response = new BufferedReader(new InputStreamReader(responseStream)).readLine();
|
|
assertThat(response).isEqualTo("TEST RESPONSE");
|
|
}
|
|
|
|
// @Test(expected = IOException.class)
|
|
// public void close_shouldCloseInputStream() throws Exception {
|
|
// engine.sendRequest(new Tile(1, 2, new Integer(3).byteValue()));
|
|
// engine.close();
|
|
// // Calling read after the stream is closed should throw an exception.
|
|
// InputStream responseStream = engine.read();
|
|
// responseStream.read();
|
|
// }
|
|
//
|
|
// @Test(expected = IOException.class)
|
|
// public void requestCompleted_shouldCloseInputStream() throws Exception {
|
|
// engine.sendRequest(new Tile(1, 2, new Integer(3).byteValue()));
|
|
// engine.requestCompleted(true);
|
|
// // Calling read after the stream is closed should throw an exception.
|
|
// InputStream responseStream = engine.read();
|
|
// responseStream.read();
|
|
// }
|
|
|
|
@Test
|
|
public void requestCompleted_shouldReturnValueGiven() throws Exception {
|
|
assertThat(engine.requestCompleted(true)).isTrue();
|
|
assertThat(engine.requestCompleted(false)).isFalse();
|
|
}
|
|
|
|
@Test
|
|
public void create_shouldUseTileSourceCache() throws Exception {
|
|
Cache cache = new Cache(new File("tmp"), 1024);
|
|
OSciMap4TileSource tileSource =
|
|
new OSciMap4TileSource(server.url("/tiles/vtm").toString());
|
|
OkHttpClient.Builder builder = new OkHttpClient.Builder().cache(cache);
|
|
engine = (OkHttpEngine) new OkHttpEngine.OkHttpFactory(builder).create(tileSource);
|
|
engine.sendRequest(new Tile(1, 2, (byte) 3));
|
|
engine.requestCompleted(true);
|
|
assertThat(cache.requestCount()).isEqualTo(1);
|
|
}
|
|
}
|