demus/openhab-addons
1
0
Fork 0
mirror of https://github.com/openhab/openhab-addons.git synced 2025-01-26 15:21:41 +01:00
Code Issues Packages Projects Releases Wiki Activity

Enhancement: Query for subscription url every reconnect attempt (#14573)

Browse Source 
Signed-off-by: kjoglum <stiankj@online.no>
This commit is contained in:
Stian Kjoglum 2023-03-11 17:55:42 +01:00 committed by GitHub
parent d70e2c6294
commit ac7993d329
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 33 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
bundles/org.openhab.binding.tibber/src/main/java/org/openhab/binding/tibber/internal/handler/TibberHandler.java
View File

@ -146,28 +146,14 @@ public class TibberHandler extends BaseThingHandler {
if ("true".equals(rtEnabled)) { if ("true".equals(rtEnabled)) {
logger.debug("Pulse associated with HomeId: Live stream will be started"); logger.debug("Pulse associated with HomeId: Live stream will be started");
getSubscriptionUrl();
InputStream wsURL = tibberQuery.getWebsocketUrl(); if (subscriptionURL == null || subscriptionURL.isBlank()) {
String wsResponse = HttpUtil.executeUrl("POST", BASE_URL, httpHeader, wsURL, null, REQUEST_TIMEOUT); logger.debug("Unexpected subscription result from the server");
JsonObject wsobject = (JsonObject) JsonParser.parseString(wsResponse);
JsonObject dataObject = wsobject.getAsJsonObject("data");
if (dataObject != null) {
JsonObject viewerObject = dataObject.getAsJsonObject("viewer");
if (viewerObject != null) {
JsonElement subscriptionElement = viewerObject.get("websocketSubscriptionUrl");
if (subscriptionElement != null) {
subscriptionURL = subscriptionElement.toString().replaceAll("^\"|\"$", "");
}
}
}
String url = subscriptionURL;
if (url == null || url.isBlank()) {
logger.trace("Unexpected result from the server: {}", jsonResponse);
updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.COMMUNICATION_ERROR, updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.COMMUNICATION_ERROR,
"Unexpected result from the server"); "Unexpected subscription result from the server");
} else { } else {
logger.debug("Subscribing to: {}", subscriptionURL); logger.debug("Reconnecting Subscription to: {}", subscriptionURL);
open(); open();
} }
} else { } else {
@ -297,7 +283,34 @@ public class TibberHandler extends BaseThingHandler {
getURLInput(BASE_URL); getURLInput(BASE_URL);
if ("true".equals(rtEnabled) && !isConnected()) { if ("true".equals(rtEnabled) && !isConnected()) {
logger.debug("Attempting to reopen Websocket connection"); logger.debug("Attempting to reopen Websocket connection");
open(); getSubscriptionUrl();
if (subscriptionURL == null || subscriptionURL.isBlank()) {
logger.debug("Unexpected subscription result from the server");
updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.COMMUNICATION_ERROR,
"Unexpected subscription result from the server");
} else {
logger.debug("Reconnecting Subscription to: {}", subscriptionURL);
open();
}
}
}
private void getSubscriptionUrl() throws IOException {
TibberPriceConsumptionHandler tibberQuery = new TibberPriceConsumptionHandler();
InputStream wsURL = tibberQuery.getWebsocketUrl();
String wsResponse = HttpUtil.executeUrl("POST", BASE_URL, httpHeader, wsURL, null, REQUEST_TIMEOUT);
JsonObject wsobject = (JsonObject) JsonParser.parseString(wsResponse);
JsonObject dataObject = wsobject.getAsJsonObject("data");
if (dataObject != null) {
JsonObject viewerObject = dataObject.getAsJsonObject("viewer");
if (viewerObject != null) {
JsonElement subscriptionElement = viewerObject.get("websocketSubscriptionUrl");
if (subscriptionElement != null) {
subscriptionURL = subscriptionElement.toString().replaceAll("^\"|\"$", "");
}
}
} }
} }