-
-
Notifications
You must be signed in to change notification settings - Fork 3.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Signed-off-by: Thomas Leber <thomas@tl-photography.at>
- Loading branch information
1 parent
7e73ed8
commit 4f57c66
Showing
5 changed files
with
171 additions
and
84 deletions.
There are no files selected for viewing
137 changes: 137 additions & 0 deletions
137
bundles/org.openhab.binding.awattar/src/main/java/org/openhab/binding/api/AwattarApi.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| package org.openhab.binding.api; | ||
|
|
||
| import static org.eclipse.jetty.http.HttpMethod.GET; | ||
| import static org.eclipse.jetty.http.HttpStatus.OK_200; | ||
|
|
||
| import java.time.LocalDate; | ||
| import java.time.ZoneId; | ||
| import java.time.ZonedDateTime; | ||
| import java.util.Comparator; | ||
| import java.util.SortedSet; | ||
| import java.util.TreeSet; | ||
| import java.util.concurrent.ExecutionException; | ||
| import java.util.concurrent.TimeUnit; | ||
| import java.util.concurrent.TimeoutException; | ||
|
|
||
| import javax.validation.constraints.NotBlank; | ||
|
|
||
| import org.eclipse.jdt.annotation.NonNull; | ||
| import org.eclipse.jetty.client.HttpClient; | ||
| import org.eclipse.jetty.client.api.ContentResponse; | ||
| import org.openhab.binding.awattar.internal.AwattarBridgeConfiguration; | ||
| import org.openhab.binding.awattar.internal.AwattarPrice; | ||
| import org.openhab.binding.awattar.internal.dto.AwattarApiData; | ||
| import org.openhab.binding.awattar.internal.dto.Datum; | ||
| import org.openhab.binding.awattar.internal.handler.TimeRange; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
|
|
||
| import com.google.gson.Gson; | ||
|
|
||
| public class AwattarApi { | ||
| private final Logger logger = LoggerFactory.getLogger(AwattarApi.class); | ||
|
|
||
| private static final String URL_DE = "https://api.awattar.de/v1/marketdata"; | ||
| private static final String URL_AT = "https://api.awattar.at/v1/marketdata"; | ||
| private String url = URL_DE; | ||
|
|
||
| private final @NonNull HttpClient httpClient; | ||
|
|
||
| private @NotBlank double vatFactor; | ||
| private @NotBlank double basePrice; | ||
|
|
||
| private @NonNull ZoneId zone; | ||
|
|
||
| /** | ||
| * Exception thrown when the response from the aWATTar API is empty. | ||
| */ | ||
| public class EmptyDataResponseException extends Exception { | ||
| private static final long serialVersionUID = 1L; | ||
|
|
||
| public EmptyDataResponseException(String message) { | ||
| super(message); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Constructor for the aWATTar API. | ||
| * | ||
| * @param httpClient the HTTP client to use | ||
| * @param zone the time zone to use | ||
| */ | ||
| public AwattarApi(@NonNull HttpClient httpClient, @NonNull ZoneId zone) { | ||
| this.zone = zone; | ||
| this.httpClient = httpClient; | ||
| } | ||
|
|
||
| /** | ||
| * Initialize the aWATTar API. | ||
| * | ||
| * @param config the configuration to use | ||
| */ | ||
| public void initialize(AwattarBridgeConfiguration config) { | ||
| vatFactor = 1 + (config.vatPercent / 100); | ||
| basePrice = config.basePrice; | ||
|
|
||
| if (config.country.equals("DE")) { | ||
| this.url = URL_DE; | ||
| } else if (config.country.equals("AT")) { | ||
| this.url = URL_AT; | ||
| } else { | ||
| throw new IllegalArgumentException("Country code must be 'DE' or 'AT'"); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Get the data from the aWATTar API. | ||
| * The data is returned as a sorted set of {@link AwattarPrice} objects. | ||
| * The data is requested from now minus one day to now plus three days. | ||
| * | ||
| * @return the data as a sorted set of {@link AwattarPrice} objects | ||
| * @throws InterruptedException if the thread is interrupted | ||
| * @throws TimeoutException if the request times out | ||
| * @throws ExecutionException if the request fails | ||
| * @throws EmptyDataResponseException if the response is empty | ||
| */ | ||
| public SortedSet<AwattarPrice> getData() throws InterruptedException, TimeoutException, ExecutionException, EmptyDataResponseException { | ||
| // we start one day in the past to cover ranges that already started yesterday | ||
| ZonedDateTime zdt = LocalDate.now(zone).atStartOfDay(zone).minusDays(1); | ||
| long start = zdt.toInstant().toEpochMilli(); | ||
| // Starting from midnight yesterday we add three days so that the range covers | ||
| // the whole next day. | ||
| zdt = zdt.plusDays(3); | ||
| long end = zdt.toInstant().toEpochMilli(); | ||
| StringBuilder request = new StringBuilder(url); | ||
| request.append("?start=").append(start).append("&end=").append(end); | ||
|
|
||
| logger.trace("aWATTar API request: = '{}'", request); | ||
| ContentResponse contentResponse = httpClient.newRequest(request.toString()).method(GET) | ||
| .timeout(10, TimeUnit.SECONDS).send(); | ||
| int httpStatus = contentResponse.getStatus(); | ||
| String content = contentResponse.getContentAsString(); | ||
| logger.trace("aWATTar API response: status = {}, content = '{}'", httpStatus, content); | ||
|
|
||
| if (content == null) { | ||
| logger.error("The response from the aWATTar API is empty"); | ||
| throw new EmptyDataResponseException("The response from the aWATTar API is empty"); | ||
| } else if (httpStatus == OK_200) { | ||
| Gson gson = new Gson(); | ||
| SortedSet<AwattarPrice> result = new TreeSet<>(Comparator.comparing(AwattarPrice::timerange)); | ||
|
|
||
| AwattarApiData apiData = gson.fromJson(content, AwattarApiData.class); | ||
| for (Datum d : apiData.data) { | ||
| double netPrice = d.marketprice / 10.0; | ||
| TimeRange timeRange = new TimeRange(d.startTimestamp, d.endTimestamp); | ||
|
|
||
| logger.trace("Adding price: netPrice = {}, timeRange = '{}'", netPrice, timeRange); | ||
| result.add(new AwattarPrice(netPrice, netPrice * vatFactor, netPrice + basePrice, | ||
| (netPrice + basePrice) * vatFactor, timeRange)); | ||
|
|
||
| } | ||
| return result; | ||
| } else { | ||
| logger.error("The aWATTar API returned code : {}", httpStatus); | ||
| throw new ExecutionException("The aWATTar API returned code : " + httpStatus, null); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters