add time series tests

META-INF/MANIFEST.MF

@@ -0,0 +1,2 @@
+Manifest-Version: 1.0
+

src/main/java/com/crazzyghost/alphavantage/exchangerate/ExchangeRate.java

@@ -1,22 +1,23 @@
 package com.crazzyghost.alphavantage.exchangerate;
 
+import java.io.IOException;
+import java.lang.reflect.Type;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
 import com.crazzyghost.alphavantage.AlphaVantageException;
-import com.crazzyghost.alphavantage.Fetcher;
 import com.crazzyghost.alphavantage.Config;
+import com.crazzyghost.alphavantage.Fetcher;
 import com.crazzyghost.alphavantage.UrlExtractor;
 import com.squareup.moshi.JsonAdapter;
 import com.squareup.moshi.Moshi;
 import com.squareup.moshi.Types;
+
 import okhttp3.Call;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.Response;
 
-import java.io.IOException;
-import java.lang.reflect.Type;
-import java.util.Map;
-import java.util.concurrent.TimeUnit;
-
 public class ExchangeRate implements Fetcher {
 
     private Config config;

src/test/java/TestTimeSeries.java

@@ -0,0 +1,136 @@
+import com.crazzyghost.alphavantage.AlphaVantage;
+import com.crazzyghost.alphavantage.Config;
+import com.crazzyghost.alphavantage.Fetcher;
+import com.crazzyghost.alphavantage.parameters.OutputSize;
+import com.crazzyghost.alphavantage.timeseries.response.TimeSeriesResponse;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import static org.junit.Assert.*;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicReference;
+
+
+public class TestTimeSeries {
+
+    private CountDownLatch lock = new CountDownLatch(1);
+
+    @BeforeClass
+    public static void setUp(){
+
+        Config config = Config.builder()
+                .key("M77PQNYAVBG0MB5N")
+                .timeOut(10)
+                .build();
+
+        AlphaVantage.api().init(config);
+
+    }
+
+    @AfterClass
+    public static void tearDown(){
+
+    }
+
+    @Test
+    public void timeSeriesDaily() throws InterruptedException {
+
+        AtomicReference<TimeSeriesResponse> response = new AtomicReference<>();
+
+        Fetcher.FailureCallback failureCallback = (e) -> lock.countDown();
+
+        Fetcher.SuccessCallback<TimeSeriesResponse> successCallback = (e) -> {
+            lock.countDown();
+            response.set(e);
+        };
+
+        AlphaVantage.api()
+                .timeSeries()
+                .daily()
+                .forSymbol("GOOGL")
+                .outputSize(OutputSize.COMPACT)
+                .onFailure(failureCallback)
+                .onSuccess(successCallback)
+                .fetch();
+
+        lock.await(10, TimeUnit.SECONDS);
+        assertNotNull(response.get());
+    }
+
+    @Test
+    public void timeSeriesDailyAdjusted() throws InterruptedException {
+
+        AtomicReference<TimeSeriesResponse> response = new AtomicReference<>();
+
+        Fetcher.FailureCallback failureCallback = (e) -> lock.countDown();
+
+        Fetcher.SuccessCallback<TimeSeriesResponse> successCallback = (e) -> {
+            lock.countDown();
+            response.set(e);
+        };
+
+        AlphaVantage.api()
+                .timeSeries()
+                .daily()
+                .adjusted()
+                .forSymbol("GOOGL")
+                .outputSize(OutputSize.COMPACT)
+                .onFailure(failureCallback)
+                .onSuccess(successCallback)
+                .fetch();
+
+        lock.await(10, TimeUnit.SECONDS);
+        assertNotNull(response.get());
+    }
+
+    @Test
+    public void timeSeriesWeekly() throws InterruptedException {
+
+        AtomicReference<TimeSeriesResponse> response = new AtomicReference<>();
+
+        Fetcher.FailureCallback failureCallback = (e) -> lock.countDown();
+
+        Fetcher.SuccessCallback<TimeSeriesResponse> successCallback = (e) -> {
+            lock.countDown();
+            response.set(e);
+        };
+
+        AlphaVantage.api()
+                .timeSeries()
+                .weekly()
+                .forSymbol("GOOGL")
+                .onFailure(failureCallback)
+                .onSuccess(successCallback)
+                .fetch();
+
+        lock.await(10, TimeUnit.SECONDS);
+        assertNotNull(response.get());
+    }
+
+    @Test
+    public void timeSeriesWeeklyAdjusted() throws InterruptedException {
+
+        AtomicReference<TimeSeriesResponse> response = new AtomicReference<>();
+
+        Fetcher.FailureCallback failureCallback = (e) -> lock.countDown();
+
+        Fetcher.SuccessCallback<TimeSeriesResponse> successCallback = (e) -> {
+            lock.countDown();
+            response.set(e);
+        };
+
+        AlphaVantage.api()
+                .timeSeries()
+                .weekly()
+                .adjusted()
+                .forSymbol("GOOGL")
+                .onFailure(failureCallback)
+                .onSuccess(successCallback)
+                .fetch();
+
+        lock.await(10, TimeUnit.SECONDS);
+        assertNotNull(response.get());
+    }
+}