[argoclima] Initial contribution

CODEOWNERS

@@ -29,6 +29,7 @@
 /bundles/org.openhab.binding.androidtv/ @morph166955
 /bundles/org.openhab.binding.anel/ @paphko
 /bundles/org.openhab.binding.anthem/ @mhilbush
+/bundles/org.openhab.binding.argoclima/ @mbronk
 /bundles/org.openhab.binding.asuswrt/ @wildcs
 /bundles/org.openhab.binding.astro/ @gerrieg
 /bundles/org.openhab.binding.atlona/ @mlobstein

bom/openhab-addons/pom.xml

@@ -136,6 +136,11 @@
       <artifactId>org.openhab.binding.anthem</artifactId>
       <version>${project.version}</version>
     </dependency>
+    <dependency>
+      <groupId>org.openhab.addons.bundles</groupId>
+      <artifactId>org.openhab.binding.argoclima</artifactId>
+      <version>${project.version}</version>
+    </dependency>
     <dependency>
       <groupId>org.openhab.addons.bundles</groupId>
       <artifactId>org.openhab.binding.astro</artifactId>

bundles/org.openhab.binding.argoclima/NOTICE

@@ -0,0 +1,13 @@
+This content is produced and maintained by the openHAB project.
+
+* Project home: https://www.openhab.org
+
+== Declared Project Licenses
+
+This program and the accompanying materials are made available under the terms
+of the Eclipse Public License 2.0 which is available at
+https://www.eclipse.org/legal/epl-2.0/.
+
+== Source Code
+
+https://github.com/openhab/openhab-addons

bundles/org.openhab.binding.argoclima/pom.xml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.openhab.addons.bundles</groupId>
+    <artifactId>org.openhab.addons.reactor.bundles</artifactId>
+    <version>4.2.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>org.openhab.binding.argoclima</artifactId>
+
+  <name>openHAB Add-ons :: Bundles :: ArgoClima Binding</name>
+
+</project>

bundles/org.openhab.binding.argoclima/scripts/download_ota_fw_files.py

@@ -0,0 +1,104 @@
+#!/usr/bin/env python3
+"""
+Downloads current Argo Ulisse firmware binary files from manufacturer's servers
+"""
+
+__license__ = """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
+"""
+
+import hashlib
+import secrets
+import urllib.request
+from enum import Enum
+from itertools import cycle
+
+
+# Randomized values. Do not seem to impact the downloaded file
+USERNAME = secrets.token_hex(4)
+PASSWORD_MD5 = hashlib.md5(secrets.token_hex(4).encode('ASCII')).hexdigest()
+CPU_ID = secrets.token_hex(8)
+
+
+class FwType(str, Enum):
+    UNIT = 'OU_FW'
+    WIFI = 'UI_FW'
+
+
+def get_uri(fw_type: FwType, page: int):
+    return f'http://31.14.128.210/UI/UI.php?CM={fw_type}&PK={page}&USN={USERNAME}&PSW={PASSWORD_MD5}&CPU_ID={CPU_ID}'
+
+
+def get_api_response(fw_type: FwType, page: int):
+    with urllib.request.urlopen(get_uri(fw_type, page)) as response:
+        data: str = response.read().decode().rstrip()
+        if not data.endswith('|||'):
+            raise RuntimeError(f"Invalid upstream response {data}")
+        return {e.split('=')[0]: str.join("=", e.split('=')[1:]) for e in data[:-3].split('|')}
+
+
+def download_fw_from_remote_server(fw_type: FwType, split_into_multiple_files=False):
+    print(f'> {get_uri(fw_type, -1)}...')
+    ver_response = get_api_response(fw_type, -1)
+    try:
+        size = int(ver_response['SIZE'])
+        chunk_count = int(ver_response['NUM_PACK'])
+        checksum = int(ver_response['CKS'])  # CRC-16?
+        base_offset = int(ver_response['OFFSET'])
+        print(f'FW Version: {ver_response}\n\tRelease: {ver_response["RELEASE"]}\n\tSize: {size}'
+              f'\n\t#chunks: {chunk_count}\n\tchecksum: {checksum}')
+
+        total_received_size = 0
+        data = ""
+        current_offset = base_offset
+        for i in range(0, chunk_count):
+            chunk_response = get_api_response(fw_type, i)
+            current_chunk_size_bytes = int(chunk_response['SIZE'])
+            print(f'{fw_type} chunk [{i+1}/{chunk_count}] - Response: {chunk_response}')
+
+            response_offset = int(chunk_response['OFFSET'])
+            if response_offset != current_offset:
+                if not split_into_multiple_files:
+                    difference = response_offset - current_offset
+                    print(f"Current offset is {current_offset}, but the response wants to write to {response_offset}."
+                          f" Padding with 0xDEADBEEF")
+                    fillers = cycle(['DE', 'AD', 'BE', 'EF'])
+                    for x in range(0, difference):
+                        data += next(fillers)
+                    current_offset += difference
+                else:
+                    save_to_file(base_offset, data, fw_type, total_received_size, ver_response["RELEASE"])
+                    total_received_size = 0
+                    data = ""
+                    current_offset = response_offset
+                    base_offset = response_offset
+            total_received_size += current_chunk_size_bytes
+            current_offset += current_chunk_size_bytes
+            data += chunk_response['DATA'][:current_chunk_size_bytes*2]
+
+        save_to_file(base_offset, data, fw_type, total_received_size, ver_response["RELEASE"])
+
+    finally:
+        finish_response = get_api_response(fw_type, 256)
+        print(finish_response)
+
+
+def save_to_file(base_offset, data, fw_type, total_received_size, version):
+    print()
+    print('-' * 50)
+    print(f'Received {total_received_size} bytes. Total binary size: {len(data) / 2:.0f}[b]')
+    print(f'Data (base16):\n\t{data}\n')
+    fw_binary = bytes.fromhex(data)
+    filename = f'Argo_firmware_{fw_type}_v{version}__offset_0x{base_offset:X}.bin'
+    with open(filename, "wb") as output_file:
+        output_file.write(fw_binary)
+    print(f'Firmware written to {filename}')
+
+
+if __name__ == '__main__':
+    print(f'Username={USERNAME}, Password={PASSWORD_MD5}, CPU_ID={CPU_ID}')
+    download_fw_from_remote_server(fw_type=FwType.UNIT, split_into_multiple_files=False)
+    download_fw_from_remote_server(fw_type=FwType.WIFI, split_into_multiple_files=False)

bundles/org.openhab.binding.argoclima/src/main/feature/feature.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<features name="org.openhab.binding.argoclima-${project.version}" xmlns="http://karaf.apache.org/xmlns/features/v1.4.0">
+	<repository>mvn:org.openhab.core.features.karaf/org.openhab.core.features.karaf.openhab-core/${ohc.version}/xml/features</repository>
+
+	<feature name="openhab-binding-argoclima" description="ArgoClima Binding" version="${project.version}">
+		<feature>openhab-runtime-base</feature>
+		<bundle start-level="80">mvn:org.openhab.addons.bundles/org.openhab.binding.argoclima/${project.version}</bundle>
+	</feature>
+</features>

bundles/org.openhab.binding.argoclima/src/main/java/org/openhab/binding/argoclima/internal/ArgoClimaBindingConstants.java

@@ -0,0 +1,212 @@
+/**
+ * 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.argoclima.internal;
+
+import java.time.Duration;
+
+import org.eclipse.jdt.annotation.NonNullByDefault;
+import org.openhab.core.thing.ThingTypeUID;
+
+/**
+ * The {@link ArgoClimaBindingConstants} class defines common constants, which are
+ * used across the whole binding.
+ *
+ * @author Mateusz Bronk - Initial contribution
+ */
+@NonNullByDefault
+public class ArgoClimaBindingConstants {
+
+    public static final String BINDING_ID = "argoclima";
+
+    /////////////
+    // List of all Thing Type UIDs
+    /////////////
+    public static final ThingTypeUID THING_TYPE_ARGOCLIMA_LOCAL = new ThingTypeUID(BINDING_ID, "local");
+    public static final ThingTypeUID THING_TYPE_ARGOCLIMA_REMOTE = new ThingTypeUID(BINDING_ID, "remote");
+
+    /////////////
+    // Thing configuration parameters
+    /////////////
+    public static final String PARAMETER_HOSTNAME = "hostname";
+    public static final String PARAMETER_LOCAL_DEVICE_IP = "localDeviceIP";
+    public static final String PARAMETER_HVAC_LISTEN_PORT = "hvacListenPort";
+    public static final String PARAMETER_DEVICE_CPU_ID = "deviceCpuId";
+    public static final String PARAMETER_CONNECTION_MODE = "connectionMode"; // LOCAL_CONNECTION | REMOTE_API_STUB |
+                                                                             // REMOTE_API_PROXY
+    public static final String PARAMETER_USE_LOCAL_CONNECTION = "useLocalConnection";
+    public static final String PARAMETER_REFRESH_INTERNAL = "refreshInterval";
+    public static final String PARAMETER_STUB_SERVER_PORT = "stubServerPort";
+    public static final String PARAMETER_STUB_SERVER_LISTEN_ADDRESSES = "stubServerListenAddresses";
+    public static final String PARAMETER_OEM_SERVER_PORT = "oemServerPort";
+    public static final String PARAMETER_OEM_SERVER_ADDRESS = "oemServerAddress";
+    public static final String PARAMETER_INCLUDE_DEVICE_SIDE_PASSWORDS_IN_PROPERTIES = "includeDeviceSidePasswordsInProperties";
+    public static final String PARAMETER_MATCH_ANY_INCOMING_DEVICE_IP = "matchAnyIncomingDeviceIp";
+
+    public static final String PARAMETER_USERNAME = "username";
+    public static final String PARAMETER_PASSWORD = "password";
+
+    public static final String PARAMETER_SCHEDULE_GROUP_NAME = "schedule%d"; // 1..3
+    public static final String PARAMETER_SCHEDULE_X_DAYS = PARAMETER_SCHEDULE_GROUP_NAME + "DayOfWeek";
+    public static final String PARAMETER_SCHEDULE_X_ON_TIME = PARAMETER_SCHEDULE_GROUP_NAME + "OnTime";
+    public static final String PARAMETER_SCHEDULE_X_OFF_TIME = PARAMETER_SCHEDULE_GROUP_NAME + "OffTime";
+    public static final String PARAMETER_ACTIONS_GROUP_NAME = "actions";
+    public static final String PARAMETER_RESET_TO_FACTORY_DEFAULTS = "resetToFactoryDefaults";
+
+    /////////////
+    // Thing configuration properties
+    /////////////
+    public static final String PROPERTY_CPU_ID = "cpuId";
+    public static final String PROPERTY_LOCAL_IP_ADDRESS = "localIpAddress";
+    public static final String PROPERTY_UNIT_FW = "unitFirmwareVersion";
+    public static final String PROPERTY_WIFI_FW = "wifiFirmwareVersion";
+    public static final String PROPERTY_LAST_SEEN = "lastSeen";
+    public static final String PROPERTY_WEB_UI = "argoWebUI";
+    public static final String PROPERTY_WEB_UI_USERNAME = "argoWebUIUsername";
+    public static final String PROPERTY_WEB_UI_PASSWORD = "argoWebUIPassword";
+    public static final String PROPERTY_WIFI_SSID = "wifiSSID";
+    public static final String PROPERTY_WIFI_PASSWORD = "wifiPassword";
+    public static final String PROPERTY_LOCAL_TIME = "localTime";
+
+    /////////////
+    // List of all Channel IDs
+    /////////////
+    public static final String CHANNEL_POWER = "ac-controls#power";
+    public static final String CHANNEL_MODE = "ac-controls#mode";
+    public static final String CHANNEL_SET_TEMPERATURE = "ac-controls#set-temperature";
+    public static final String CHANNEL_CURRENT_TEMPERATURE = "ac-controls#current-temperature";
+    public static final String CHANNEL_FAN_SPEED = "ac-controls#fan-speed";
+    public static final String CHANNEL_ECO_MODE = "modes#eco-mode";
+    public static final String CHANNEL_TURBO_MODE = "modes#turbo-mode";
+    public static final String CHANNEL_NIGHT_MODE = "modes#night-mode";
+    public static final String CHANNEL_ACTIVE_TIMER = "timers#active-timer";
+    public static final String CHANNEL_DELAY_TIMER = "timers#delay-timer";
+    // Note: schedule timers day of week/time setting not currently supported as channels (YAGNI), and moved to config
+    public static final String CHANNEL_MODE_EX = "unsupported#mode-ex";
+    public static final String CHANNEL_SWING_MODE = "unsupported#swing-mode";
+    public static final String CHANNEL_FILTER_MODE = "unsupported#filter-mode";
+
+    public static final String CHANNEL_I_FEEL_ENABLED = "settings#ifeel-enabled";
+    public static final String CHANNEL_DEVICE_LIGHTS = "settings#device-lights";
+
+    public static final String CHANNEL_TEMPERATURE_DISPLAY_UNIT = "settings#temperature-display-unit";
+    public static final String CHANNEL_ECO_POWER_LIMIT = "settings#eco-power-limit";
+
+    /////////////
+    // Binding's hard-coded configuration (not parameterized)
+    /////////////
+    /** Maximum number of failed status polls after which the device will be considered offline */
+    public static final int MAX_API_RETRIES = 3;
+
+    /**
+     * Time to wait between command issue and communicating with the device. Allows to include multiple commands in one
+     * device communication session (preferred).
+     * Time window chosen so that it is not (too) perceptible by an user, while still enough for rules/groups to be able
+     * to fit
+     */
+    public static final Duration SEND_COMMAND_DEBOUNCE_TIME = Duration.ofMillis(100);
+
+    /**
+     * The minimum resolution during which the command sending background thread does any meaningful action. This is
+     * merely to avoid busy wait and doesn't mean the thread is doing anything of use on every cycle. There are separate
+     * configurable "update" and "(re)send" frequencies governing that. This parameter only controls the lowest possible
+     * resolution of those (a "tick")
+     */
+    public static final Duration SEND_COMMAND_DUTY_CYCLE = Duration.ofSeconds(1);
+
+    /**
+     * The frequency to poll the device with, waiting for the command confirmation
+     */
+    public static final Duration POLL_FREQUENCY_AFTER_COMMAND_SENT_LOCAL = Duration.ofSeconds(3);
+
+    /**
+     * The frequency to poll the Argo servers with, waiting for the command confirmation
+     */
+    public static final Duration POLL_FREQUENCY_AFTER_COMMAND_SENT_REMOTE = Duration.ofSeconds(5);
+
+    /**
+     * The frequency to re-send the pending command to the device at (if it hadn't been confirmed yet).
+     * Aka. the optimistic time when the device "should acknowledge. Should be greater than
+     * {@link #POLL_FREQUENCY_AFTER_COMMAND_SENT_LOCAL}
+     *
+     * @see #SEND_COMMAND_MAX_WAIT_TIME_LOCAL_DIRECT
+     * @see #SEND_COMMAND_MAX_WAIT_TIME_LOCAL_INDIRECT
+     */
+    public static final Duration SEND_COMMAND_RETRY_FREQUENCY_LOCAL = Duration.ofSeconds(10);
+
+    /**
+     * The frequency to re-send the pending command to the remote Argo server at (if it hadn't been confirmed yet).
+     * Aka. the optimistic time when the server "should acknowledge. Should be greater than
+     * {@link #POLL_FREQUENCY_AFTER_COMMAND_SENT_REMOTE}
+     *
+     * @see #SEND_COMMAND_MAX_WAIT_TIME_REMOTE
+     */
+    public static final Duration SEND_COMMAND_RETRY_FREQUENCY_REMOTE = Duration.ofSeconds(20);
+
+    /**
+     * Max time to wait for a pending command to be confirmed by the device in a local-direct mode (when we are issuing
+     * communications to a device in local LAN).
+     * <p>
+     * During this time, the commands may get {@link #SEND_COMMAND_RETRY_FREQUENCY_LOCAL retried} and the device status
+     * may be
+     * {@link #POLL_FREQUENCY_AFTER_COMMAND_SENT_LOCAL re-fetched}
+     */
+    public static final Duration SEND_COMMAND_MAX_WAIT_TIME_LOCAL_DIRECT = Duration.ofSeconds(20); // 60-remote
+
+    /**
+     * Max time to wait for a pending command to be confirmed in an *indirect* mode (where we're only
+     * sniffing/intercepting communications)
+     * <p>
+     * A healthy device seems to be polling Argo servers every minute (and if the server returns a pending command
+     * request, does a few more more frequent exchanges as well), so 2 minutes seem safe
+     */
+    public static final Duration SEND_COMMAND_MAX_WAIT_TIME_LOCAL_INDIRECT = Duration.ofSeconds(120);
+
+    /**
+     * Max time to wait for a pending command to be confirmed in an *remote* mode (where we're talking to a remote Argo
+     * server)
+     * <p>
+     * The server seems to confirm a bit faster than our intercepting proxy and we want to minimize traffic our binding
+     * issues against remote side, hence a more conservative value
+     */
+    public static final Duration SEND_COMMAND_MAX_WAIT_TIME_REMOTE = Duration.ofSeconds(60);
+
+    /**
+     * Time to wait for (confirmable) command to be reported back by the device (by changing its state to the requested
+     * value). If this period elapses w/o the device confirming, the command is considered not handled and REJECTED
+     * (would not be retried any more, and the reported device's state will be the actual one device sent, not the
+     * "in-flight" desired one)
+     *
+     * @implNote This is just a final "give up" time (not affecting any send logic). Should be no shorter than max try
+     *           time
+     */
+    public static final Duration PENDING_COMMAND_EXPIRE_TIME = SEND_COMMAND_MAX_WAIT_TIME_LOCAL_INDIRECT
+            .plus(Duration.ofSeconds(1));
+
+    /**
+     * Timeout for getting the HTTP response from Argo servers in pass-through(proxy) mode
+     */
+    public static final Duration UPSTREAM_PROXY_HTTP_REQUEST_TIMEOUT = Duration.ofSeconds(30);
+
+    /////////////
+    // R&D-only switches
+    /////////////
+    /**
+     * Whether the binding shall wait for the device confirming commands have been received (by flipping to the desired
+     * state) or work in a fire and forget mode and stop tracking upon first send.
+     * <p>
+     * This applies only to confirmable commands (read-write) and is a default behavior of Argo's own web implementation
+     *
+     * @implNote This is a debug-only switch (makes little to no sense to disable it in real-world usage)
+     */
+    public static final boolean AWAIT_DEVICE_CONFIRMATIONS_AFTER_COMMANDS = true;
+}