git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2023 Contributors to the openHAB project
   3  *
   4  * See the NOTICE file(s) distributed with this work for additional
   5  * information.
   6  *
   7  * This program and the accompanying materials are made available under the
   8  * terms of the Eclipse Public License 2.0 which is available at
   9  * http://www.eclipse.org/legal/epl-2.0
  10  *
  11  * SPDX-License-Identifier: EPL-2.0
  12  */
  13 package org.openhab.binding.kostalinverter.internal.secondgeneration;
  14
  15 import java.nio.charset.StandardCharsets;
  16 import java.security.MessageDigest;
  17 import java.security.NoSuchAlgorithmException;
  18 import java.util.Base64;
  19 import java.util.concurrent.ExecutionException;
  20 import java.util.concurrent.TimeoutException;
  21
  22 import org.eclipse.jdt.annotation.NonNullByDefault;
  23 import org.eclipse.jetty.client.HttpClient;
  24 import org.eclipse.jetty.client.api.ContentResponse;
  25 import org.eclipse.jetty.client.api.Request;
  26 import org.eclipse.jetty.client.util.StringContentProvider;
  27 import org.eclipse.jetty.http.HttpHeader;
  28 import org.slf4j.Logger;
  29 import org.slf4j.LoggerFactory;
  30
  31 import com.google.gson.JsonArray;
  32 import com.google.gson.JsonIOException;
  33 import com.google.gson.JsonObject;
  34 import com.google.gson.JsonParser;
  35
  36 /**
  37  * The {@link SecondGenerationConfigurationHandler} is responsible for configuration changes,
  38  * regarded to second generation part of the binding.
  39  *
  40  * @author Örjan Backsell - Initial contribution Piko1020, Piko New Generation
  41  */
  42 @NonNullByDefault
  43 public class SecondGenerationConfigurationHandler {
  44
  45     public static void executeConfigurationChanges(HttpClient httpClient, String url, String username, String password,
  46             String dxsId, String value)
  47             throws InterruptedException, ExecutionException, TimeoutException, NoSuchAlgorithmException {
  48         String urlLogin = url + "/api/login.json?";
  49         String salt = "";
  50         String sessionId = "";
  51
  52         Logger logger = LoggerFactory.getLogger(SecondGenerationConfigurationHandler.class);
  53
  54         String getAuthenticateResponse = httpClient.GET(urlLogin).getContentAsString();
  55
  56         try {
  57             JsonObject getAuthenticateResponseJsonObject = (JsonObject) JsonParser
  58                     .parseString(transformJsonResponse(getAuthenticateResponse));
  59
  60             sessionId = extractSessionId(getAuthenticateResponseJsonObject);
  61
  62             JsonObject authenticateJsonObject = JsonParser.parseString(getAuthenticateResponse).getAsJsonObject();
  63             salt = authenticateJsonObject.get("salt").getAsString();
  64
  65             String saltedPassword = new StringBuilder(password).append(salt).toString();
  66             MessageDigest mDigest = MessageDigest.getInstance("SHA1");
  67
  68             byte[] mDigestedPassword = mDigest.digest(saltedPassword.getBytes(StandardCharsets.UTF_8));
  69             StringBuilder loginPostStringBuilder = new StringBuilder();
  70             for (int i = 0; i < mDigestedPassword.length; i++) {
  71                 loginPostStringBuilder.append(Integer.toString((mDigestedPassword[i] & 0xff) + 0x100, 16).substring(1));
  72             }
  73             String saltedmDigestedPwd = Base64.getEncoder().encodeToString(mDigest.digest(saltedPassword.getBytes()));
  74
  75             String loginPostJsonData = "{\"mode\":1,\"userId\":\"" + username + "\",\"pwh\":\"" + saltedmDigestedPwd
  76                     + "\"}";
  77
  78             Request loginPostJsonResponse = httpClient.POST(urlLogin + "?sessionId=" + sessionId);
  79             loginPostJsonResponse.header(HttpHeader.CONTENT_TYPE, "application/json");
  80             loginPostJsonResponse.content(new StringContentProvider(loginPostJsonData));
  81             ContentResponse loginPostJsonDataContentResponse = loginPostJsonResponse.send();
  82
  83             String loginPostResponse = new String(loginPostJsonDataContentResponse.getContent(),
  84                     StandardCharsets.UTF_8);
  85
  86             JsonObject loginPostJsonObject = (JsonObject) JsonParser
  87                     .parseString(transformJsonResponse(loginPostResponse));
  88
  89             sessionId = extractSessionId(loginPostJsonObject);
  90
  91             // Part for sending data to Inverter
  92             String postJsonData = "{\"dxsEntries\":[{\"dxsId\":" + dxsId + ",\"value\":" + value + "}]}";
  93
  94             Request postJsonDataRequest = httpClient.POST(url + "/api/dxs.json?sessionId=" + sessionId);
  95             postJsonDataRequest.header(HttpHeader.CONTENT_TYPE, "application/json");
  96             postJsonDataRequest.content(new StringContentProvider(postJsonData));
  97             postJsonDataRequest.send();
  98         } catch (JsonIOException getAuthenticateResponseException) {
  99             logger.debug("Could not read the response: {}", getAuthenticateResponseException.getMessage());
 100         }
 101     }
 102
 103     static String transformJsonResponse(String jsonResponse) {
 104         // Method transformJsonResponse converts response,due to missing [] in ContentResponse
 105         // postJsonDataContentResponse.
 106
 107         int sessionStartPosition = jsonResponse.indexOf("session");
 108         int statusStartPosition = jsonResponse.indexOf("status");
 109
 110         StringBuilder transformStringBuilder = new StringBuilder();
 111
 112         transformStringBuilder.append(jsonResponse);
 113
 114         transformStringBuilder.insert(sessionStartPosition + 9, '[');
 115         int roleIdStartPosition = jsonResponse.indexOf("roleId");
 116         transformStringBuilder.insert(roleIdStartPosition + 11, ']');
 117
 118         transformStringBuilder.insert(statusStartPosition + 10, '[');
 119         int codeStartPosition = jsonResponse.indexOf("code");
 120         transformStringBuilder.insert(codeStartPosition + 11, ']');
 121
 122         return transformStringBuilder.toString();
 123     }
 124
 125     // Method extractSessionId extracts sessionId from JsonObject
 126     static String extractSessionId(JsonObject extractJsonObjectSessionId) {
 127         Logger sessionIdLogger = LoggerFactory.getLogger(SecondGenerationConfigurationHandler.class);
 128         String extractSessionId = "";
 129         JsonArray extractJsonArraySessionId = extractJsonObjectSessionId.getAsJsonArray("session");
 130
 131         int size = extractJsonArraySessionId.size();
 132         if (size > 0) {
 133             extractSessionId = extractJsonArraySessionId.get(size - 1).getAsJsonObject().get("sessionId").getAsString();
 134         }
 135         if ("0".equals(extractSessionId)) {
 136             sessionIdLogger.debug(" Login Post Json Reponse not OK! , inverter answered with sessionId like: {}",
 137                     extractSessionId);
 138         }
 139         return extractSessionId;
 140     }
 141
 142     // Method extractCode extracts code from JsonObject
 143     static String extractCode(JsonObject extractJsonObjectCode) {
 144         Logger codeLogger = LoggerFactory.getLogger(SecondGenerationConfigurationHandler.class);
 145         String extractCode = "";
 146         JsonArray extractJsonArrayCode = extractJsonObjectCode.getAsJsonArray("status");
 147
 148         int size = extractJsonArrayCode.size();
 149         if (size > 0) {
 150             extractCode = extractJsonArrayCode.get(size - 1).getAsJsonObject().get("code").getAsString();
 151         }
 152         if (!"0".equals(extractCode)) {
 153             codeLogger.debug(" Login Post Json Reponse not OK! , inverter answered with status code like: {}",
 154                     extractCode);
 155         }
 156         return extractCode;
 157     }
 158 }