Merge pull request #9 from RADAR-base/webservice-integration

tweak parameters

Author: blootsvoets

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/FitbitSourceConnector.java

@@ -62,7 +62,7 @@ public void start(Map<String, String> props) {
         e.printStackTrace();
       }
 
-    },0, 1, TimeUnit.HOURS);
+    },0, 5, TimeUnit.MINUTES);
   }
 
   @Override

kafka-connect-fitbit-source/src/main/java/org/radarbase/connect/rest/fitbit/user/ServiceUserRepository.java

@@ -63,7 +63,7 @@ public class ServiceUserRepository implements UserRepository {
   private HashSet<String> containedUsers;
   private Set< ? extends User> timedCachedUsers = new HashSet<>();
   private final AtomicReference<Instant> nextFetch = new AtomicReference<>(Instant.MIN);
-  private static final Duration FETCH_THRESHOLD = Duration.ofMinutes(30L);
+  private static final Duration FETCH_THRESHOLD = Duration.ofMinutes(1L);
 
   public ServiceUserRepository() {
     this.client = new OkHttpClient();
@@ -95,7 +95,7 @@ public Stream<? extends User> stream() throws IOException {
     }
 
     logger.info("Requesting user information from webservice");
-    Request request = requestFor("users" + "?device-type=FitBit").build();
+    Request request = requestFor("users" + "?source-type=FitBit").build();
     this.timedCachedUsers = this.<Users>makeRequest(request, USER_LIST_READER)
         .getUsers().stream()
         .filter(u -> containedUsers.isEmpty() || containedUsers.contains(u.getId()))