added better error handling for the sonnen http client

Author: atimgraves

IoTSonnenUploader/src/main/java/com/oracle/demo/timg/iot/iotsonnenuploader/sonnencontroller/SonnenBatteryClient.java

@@ -46,6 +46,7 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 import io.micronaut.http.annotation.Get;
 import io.micronaut.http.annotation.Header;
 import io.micronaut.http.client.annotation.Client;
+import io.micronaut.http.client.exceptions.HttpClientException;
 
 @Client(id = "sonnenbattery", path = "/api/v2")
 @Header(name = USER_AGENT, value = "Micronaut HTTP Client")
@@ -54,9 +55,11 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 public interface SonnenBatteryClient {
 
 	@Get("/configurations")
-	public SonnenConfiguration fetchConfiguration();
+	// @Error(exception = ReadTimeoutException.class)
+	public SonnenConfiguration fetchConfiguration() throws HttpClientException;
 
 	@Get("/status")
-	public SonnenStatus fetchStatus();
+	// @Error(exception = ReadTimeoutException.class)
+	public SonnenStatus fetchStatus() throws HttpClientException;
 
 }

IoTSonnenUploader/src/main/java/com/oracle/demo/timg/iot/iotsonnenuploader/uploader/Uploader.java

@@ -44,6 +44,7 @@ Software and the Larger Work(s), and to sublicense the foregoing rights on
 import com.oracle.demo.timg.iot.iotsonnenuploader.sonnencontroller.SonnenBatteryClient;
 
 import io.micronaut.context.event.StartupEvent;
+import io.micronaut.http.client.exceptions.HttpClientException;
 import io.micronaut.runtime.event.annotation.EventListener;
 import io.micronaut.scheduling.TaskExecutors;
 import io.micronaut.scheduling.annotation.ExecuteOn;
@@ -63,7 +64,14 @@ public class Uploader {
 	@Scheduled(fixedRate = "120s", initialDelay = "5s")
 	@ExecuteOn(TaskExecutors.IO)
 	public SonnenConfiguration processConfiguration() {
-		SonnenConfiguration conf = client.fetchConfiguration();
+		SonnenConfiguration conf;
+		try {
+			conf = client.fetchConfiguration();
+		} catch (HttpClientException e) {
+			log.warning("HttpClientException getting configuration from sonnen, no data to upload for service "
+					+ e.getServiceId());
+			return null;
+		}
 		log.info("Retrieved configuration from battery : " + conf);
 		CompletableFuture<Void> publishResp = mqttSonnenBatteryPublisher.publishSonnenConfiguration(conf);
 		publishResp.thenRun(() -> log.info("Published configuration as object"));
@@ -73,7 +81,14 @@ public SonnenConfiguration processConfiguration() {
 	@Scheduled(fixedRate = "10s", initialDelay = "10s")
 	@ExecuteOn(TaskExecutors.IO)
 	public SonnenStatus processStatus() {
-		SonnenStatus status = client.fetchStatus();
+		SonnenStatus status;
+		try {
+			status = client.fetchStatus();
+		} catch (HttpClientException e) {
+			log.warning("HttpClientExcepton getting configuration from sonnen, no data to upload, for service "
+					+ e.getServiceId());
+			return null;
+		}
 		log.info("Retrieved status from battery : " + status);
 		CompletableFuture<Void> publishResp = mqttSonnenBatteryPublisher.publishSonnenStatus(status);
 		publishResp.thenRun(() -> log.info("Published status as object"));