-
-
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 6346d1b
Showing
5 changed files
with
189 additions
and
85 deletions.
There are no files selected for viewing
155 changes: 155 additions & 0 deletions
155
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,155 @@ | ||
| /** | ||
| * Copyright (c) 2010-2024 Contributors to the openHAB project | ||
| * | ||
| * See the NOTICE file(s) distributed with this work for additional | ||
| * information. | ||
| * | ||
| * This program and the accompanying materials are made available under the | ||
| * terms of the Eclipse Public License 2.0 which is available at | ||
| * http://www.eclipse.org/legal/epl-2.0 | ||
| * | ||
| * SPDX-License-Identifier: EPL-2.0 | ||
| */ | ||
| 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; | ||
|
|
||
| /** | ||
| * The {@link AwattarApi} class is responsible for encapsulating the aWATTar API and providing the data to the bridge. | ||
| * | ||
| * @author Thomas Leber - Initial contribution | ||
| */ | ||
| 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