|
|
@@ -1,5 +1,6 @@
|
|
|
package cz.senslog.connector.fetch.azure;
|
|
|
|
|
|
+import com.google.gson.reflect.TypeToken;
|
|
|
import cz.senslog.connector.config.model.HostConfig;
|
|
|
import cz.senslog.connector.exception.SyntaxException;
|
|
|
import cz.senslog.connector.fetch.api.ConnectorFetcher;
|
|
|
@@ -15,9 +16,11 @@ import cz.senslog.connector.model.azure.SensorInfo;
|
|
|
import org.apache.logging.log4j.LogManager;
|
|
|
import org.apache.logging.log4j.Logger;
|
|
|
|
|
|
+import java.lang.reflect.Type;
|
|
|
import java.time.LocalDateTime;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Arrays;
|
|
|
+import java.util.Collection;
|
|
|
import java.util.List;
|
|
|
|
|
|
import static cz.senslog.connector.http.HttpHeader.AUTHORIZATION;
|
|
|
@@ -112,7 +115,6 @@ public class AzureFetcher implements ConnectorFetcher<AzureModel> {
|
|
|
.header(AUTHORIZATION, accessToken)
|
|
|
.build();
|
|
|
|
|
|
- /*
|
|
|
logger.info("Sending the http request to get information about sensors.");
|
|
|
HttpResponse response = httpClient.send(request);
|
|
|
logger.info("Received a response with a status: {}.", response.getStatus());
|
|
|
@@ -136,11 +138,6 @@ public class AzureFetcher implements ConnectorFetcher<AzureModel> {
|
|
|
logger.debug("Parsing body of the response from JSON format.");
|
|
|
Type sensorInfoListType = new TypeToken<Collection<SensorInfo>>() {}.getType();
|
|
|
List<SensorInfo> sensors = jsonToObject(response.getBody(), sensorInfoListType);
|
|
|
- */
|
|
|
- List<SensorInfo> sensors = new ArrayList<SensorInfo>(2){{
|
|
|
- add(new SensorInfo(){{setEui("8CF9574000000948"); setStatus(1);}});
|
|
|
- add(new SensorInfo(){{setEui("8CF95740000008AE"); setStatus(1);}});
|
|
|
- }};
|
|
|
|
|
|
if (sensors.isEmpty()) {
|
|
|
throw logger.throwing(new Exception("Received empty list of sensors."));
|