Added a bulk api call demo

Author: yassine

src/main/java/io/ipdata/client/service/ApiKeyRequestInterceptor.java

@@ -12,7 +12,7 @@ class ApiKeyRequestInterceptor implements RequestInterceptor {
   private static final String API_KEY_PARAM = "api-key";
   private static final String ACCEPT_HEADER = "Accept";
   private static final String JSON_CONTENT  = "application/json";
-  private static final String API_CLIENT_HEADER = "X-API-CLIENT";
+  private static final String API_CLIENT_HEADER = "x-client";
   private static String API_CLIENT_VALUE;
   static {
     try {
@@ -21,7 +21,7 @@ class ApiKeyRequestInterceptor implements RequestInterceptor {
       API_CLIENT_VALUE  = String.format("io.ipdata.client.java.%s", version);
     }catch (Exception e){
       e.printStackTrace();
-      API_CLIENT_VALUE  = "io.ipdata.client.java.0.1.0";
+      API_CLIENT_VALUE  = "io.ipdata.client.java.UNKNOWN";
     }
   }
   private final String key;
@@ -30,7 +30,7 @@ class ApiKeyRequestInterceptor implements RequestInterceptor {
   public void apply(RequestTemplate template) {
     template.query(API_KEY_PARAM, key);
     template.header(ACCEPT_HEADER, JSON_CONTENT);
-    template.header(API_CLIENT_HEADER, API_CLIENT_VALUE);
+    //template.header(API_CLIENT_HEADER, API_CLIENT_VALUE); TODO: the api doesn't seem to accept any header
   }
 
 }

src/test/java/io/ipdata/client/BulkIpdataTest.java

@@ -7,19 +7,39 @@
 import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.common.io.CharStreams;
 import io.ipdata.client.service.IpdataField;
 import io.ipdata.client.service.IpdataService;
+import java.io.InputStreamReader;
 import java.net.URL;
+import java.util.Arrays;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.log4j.Level;
 import org.apache.log4j.LogManager;
+import org.junit.Test;
 
 @Slf4j
 public class IpdataTest {
 
   private static final String KEY = System.getenv("IPDATACO_KEY");
 
+
+  @Test
+  @SneakyThrows
+  public void testBulk(){
+    System.out.println(CharStreams.toString(new InputStreamReader(getClass().getResourceAsStream("/VERSION"))));
+    URL url = new URL("https://api.ipdata.co");
+
+    IpdataService ipdataService = Ipdata.builder()
+      .url(url)
+      .withDefaultCache()
+      .key("")
+      .get();
+    //ipdataService.asn("8.8.8.8");
+    //System.out.println(ipdataService.bulkIpdata(Arrays.asList("8.8.8.8", "41.125.44.251")));
+  }
+
   @SneakyThrows
   public static void main(String[] args) {
 
@@ -35,27 +55,33 @@ public static void main(String[] args) {
       .withDefaultCache()
       .key(KEY)
       .get();
-
+    String[] addresses = args[0].split(",");
     LogManager.resetConfiguration();
     LogManager.getLogger("io").setLevel(Level.OFF);
     System.out.println("##################### Asking for a full response #############################");
     long duration = System.currentTimeMillis();
-    String result = mapper.writeValueAsString(ipdataService.ipdata(args[0]));
+    String result = mapper.writeValueAsString(ipdataService.ipdata(addresses[0]));
     duration = System.currentTimeMillis() - duration;
     System.out.println(String.format("Got response : %s \nLatency: %s milliseconds", result, duration));
     System.out.println("################### Asking for ASN field ########################");
     duration = System.currentTimeMillis();
-    result = mapper.writeValueAsString(ipdataService.asn(args[0]));
+    result = mapper.writeValueAsString(ipdataService.asn(addresses[0]));
     duration = System.currentTimeMillis() - duration;
     System.out.println(String.format("Got response : %s \nLatency: %s milliseconds", result, duration));
     System.out.println("################## Asking for ip, city, and currency field ##########################");
     duration = System.currentTimeMillis();
-    result = mapper.writeValueAsString(ipdataService.getFields(args[0], IpdataField.IP, IpdataField.CITY, IpdataField.CURRENCY));
+    result = mapper.writeValueAsString(ipdataService.getFields(addresses[0], IpdataField.IP, IpdataField.CITY, IpdataField.CURRENCY));
     duration = System.currentTimeMillis() - duration;
     System.out.println(String.format("Got response : %s \nLatency: %s milliseconds", result, duration));
     System.out.println("################## Asking for full response that should hit the cache ##########################");
     duration = System.currentTimeMillis();
-    result = mapper.writeValueAsString(ipdataService.ipdata(args[0]));
+    result = mapper.writeValueAsString(ipdataService.ipdata(addresses[0]));
+    duration = System.currentTimeMillis() - duration;
+    System.out.println(String.format("Got response : %s \nLatency: %s milliseconds", result, duration));
+
+    System.out.println("##################### Asking for a bulk response #############################");
+    duration = System.currentTimeMillis();
+    result   = mapper.writeValueAsString(ipdataService.bulkIpdata(Arrays.asList(addresses)));
     duration = System.currentTimeMillis() - duration;
     System.out.println(String.format("Got response : %s \nLatency: %s milliseconds", result, duration));