Any guidence on how I can get the Elite 200 to work

[nano2dev]

Elite 200 V22444000203846

https://www.bluettipower.com/products/elite-200-v2-portable-power-station

Does not show up in --scan

Using https://github.com/nhurman/bluetti_mqtt was able to list it in --scan

Found Elite 200 V22444000203846: address CC:__:A2:D3:__:F6 (bluetti, encrypted)

[nano2dev]

@nhurman - I'm currently using your fork.

Any suggestions?

root@raspberrypi:~/bluetti_mqtt3# python3 -m bluetti_mqtt.logger_cli CC:__:A2:D3:__:F6 --log /tmp/log --encrypted
Connecting to CC:__:A2:D3:__:F6
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
ERROR:asyncio:Task exception was never retrieved
future: <Task finished name='Task-16' coro=<EncryptedConnection.on_packet() done, defined at /root/bluetti_mqtt3/bluetti_mqtt/bluetooth/encryption.py:386> exception=ValueError('Data not aligned on aes block size')>
Traceback (most recent call last):
  File "/root/bluetti_mqtt3/bluetti_mqtt/bluetooth/encryption.py", line 405, in on_packet
    decrypted = Message(aes_decrypt(message.buffer, key, iv))
                        ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/root/bluetti_mqtt3/bluetti_mqtt/bluetooth/encryption.py", line 117, in aes_decrypt
    raise ValueError("Data not aligned on aes block size")
ValueError: Data not aligned on aes block size
Got an error running command ReadHoldingRegisters(starting_address=0, quantity=70): MODBUS Exception ReadHoldingRegisters(starting_address=0, quantity=70): 2
Got an error running command ReadHoldingRegisters(starting_address=70, quantity=21): MODBUS Exception ReadHoldingRegisters(starting_address=70, quantity=21): 2
Got an error running command ReadHoldingRegisters(starting_address=3001, quantity=61): MODBUS Exception ReadHoldingRegisters(starting_address=3001, quantity=61): 2
^C^CTraceback (most recent call last):
  File "/usr/lib/python3.11/asyncio/runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/lib/python3.11/asyncio/base_events.py", line 653, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "/root/bluetti_mqtt3/bluetti_mqtt/logger_cli.py", line 83, in log
    await asyncio.sleep(10)  # We need to wait after switching packs for the data to be available
    ^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/lib/python3.11/asyncio/tasks.py", line 639, in sleep
    return await future

[nano2dev]

Vibe coded this to check MODBUS codes

nano test.py

import asyncio
import struct
from bluetti_mqtt.bluetooth.client import BluetoothClient
from bluetti_mqtt.core.commands import ReadHoldingRegisters

def is_interesting(val: int) -> bool:
    return (
        val in (0, 1)
        or 1 <= val <= 100
        or 100 <= val <= 300
        or 300 <= val <= 5000
        or 32000 <= val <= 40000
    )

def decode_registers(raw: bytes, addr: int) -> str | None:
    if len(raw) < 3:
        return None

    data = raw[2:]
    if len(data) % 2 != 0:
        data = data[:-1]  # trim last byte if odd

    try:
        regs = struct.unpack(f'>{len(data)//2}H', data)
    except Exception:
        return None

    lines = []
    for i, val in enumerate(regs):
        if not is_interesting(val):
            continue

        abs_addr = addr + i
        ascii_char = chr(val) if 32 <= val <= 126 else '.'
        dec1 = val / 10
        dec2 = val / 100
        lines.append(
            f"{abs_addr:04}: {val:<5} | ASCII: '{ascii_char}' | ÷10: {dec1:.1f} | ÷100: {dec2:.2f}"
        )

    return "\n".join(lines) if lines else None

async def probe_registers(address: str):
    client = BluetoothClient(address, is_encrypted=True)
    asyncio.create_task(client.run())
    await asyncio.sleep(2)

    try:
        for addr in range(0, 4000, 10):
            command = ReadHoldingRegisters(addr, 10)
            try:
                response_future = await client.perform(command)
                raw = await response_future
                decoded = decode_registers(raw, addr)
                if decoded:
                    print(f"\n--- Register Block {addr}-{addr+9} ---")
                    print(decoded)
            except Exception:
                continue
    finally:
        await client.client.disconnect()

if __name__ == "__main__":
    asyncio.run(probe_registers("CC:__:A2:D3:__:F6"))

python test.py

--- Register Block 0-9 ---
0001: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0002: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0003: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0004: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0005: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0006: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0007: 2304  | ASCII: '.' | ÷10: 230.4 | ÷100: 23.04
0008: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0009: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0010: 58    | ASCII: ':' | ÷10: 5.8 | ÷100: 0.58

--- Register Block 10-19 ---
0011: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0012: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0013: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0014: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0015: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0016: 7     | ASCII: '.' | ÷10: 0.7 | ÷100: 0.07
0018: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0019: 0     | ASCII: '.' | ÷10: 0.0 | ÷100: 0.00
0020: 170   | ASCII: '.' | ÷10: 17.0 | ÷100: 1.70

...

root@raspberrypi:~/bluetti_mqtt3# python3 -m bluetti_mqtt.logger_cli CC:__:A2:D3:__:F6 --log /tmp/log --encrypted
Connecting to CC:8D:A2:D3:B4:F6
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Waiting for connection...
Got an error running command ReadHoldingRegisters(starting_address=0, quantity=70): MODBUS Exception ReadHoldingRegisters(starting_address=0, quantity=70): 2
Got an error running command ReadHoldingRegisters(starting_address=70, quantity=21): MODBUS Exception ReadHoldingRegisters(starting_address=70, quantity=21): 2
Got an error running command ReadHoldingRegisters(starting_address=3001, quantity=61): MODBUS Exception ReadHoldingRegisters(starting_address=3001, quantity=61): 2
{'ac_output_power_alt': Decimal('0.2'), 'battery_percent_alt': 1, 'ac_output_current_alt': Decimal('40.4'), 'ac_output_flag_alt': False, 'mystery_power_reading': Decimal('40.4'), 'input_voltage_alt': Decimal('0')}

Almost there...

[nano2dev]

bluetti_mqtt/bluetti_mqtt/core/devices/elite200.py

from enum import Enum, unique
from typing import List
from ..commands import ReadHoldingRegisters
from .bluetti_device import BluettiDevice
from .struct import DeviceStruct


@unique
class OutputMode(Enum):
    STOP = 0
    INVERTER_OUTPUT = 1
    BYPASS_OUTPUT_C = 2
    BYPASS_OUTPUT_D = 3
    LOAD_MATCHING = 4


@unique
class AutoSleepMode(Enum):
    THIRTY_SECONDS = 2
    ONE_MINUTE = 3
    FIVE_MINUTES = 4
    NEVER = 5


class Elite200(BluettiDevice):
    def __init__(self, address: str, sn: str):
        self.struct = DeviceStruct()

        # Verified: block 160–169
        self.struct.add_uint_field("dc_input_power", 160)
        self.struct.add_uint_field("ac_input_power", 161)
        self.struct.add_uint_field("ac_output_power", 162)
        self.struct.add_uint_field("dc_output_power", 163)
        self.struct.add_uint_field("total_battery_percent", 164)
        self.struct.add_bool_field("ac_output_on", 165)
        self.struct.add_bool_field("dc_output_on", 166)
        self.struct.add_decimal_field("ac_input_voltage", 167, 1)
        self.struct.add_decimal_field("dc_input_voltage1", 168, 1)
        self.struct.add_bool_field("power_off", 169)

        super().__init__(address, "Elite 200", sn)

    @property
    def pack_num_max(self):
        return 1

    @property
    def polling_commands(self) -> List[ReadHoldingRegisters]:
        return [ReadHoldingRegisters(160, 10)]

    @property
    def pack_polling_commands(self) -> List[ReadHoldingRegisters]:
        return []

    @property
    def logging_commands(self) -> List[ReadHoldingRegisters]:
        return [ReadHoldingRegisters(160, 10)]

    @property
    def pack_logging_commands(self) -> List[ReadHoldingRegisters]:
        return []

    @property
    def writable_ranges(self) -> List[range]:
        return []

ELITE200 = Elite200

[nhurman]

I don't have one of those to check, but you could try running it again the V2Device class in the fork, from looking at the apk at the start of the year most of the devices using encryption were supposed to use this family of registers. At least for the standard stuff like battery percentage?

[nano2dev]

@nhurman - Thank you. That worked for data.

Any idea how i can enable ac_enable, dc_enable to be able to turn these on/off programmatically

[nano2dev]

@nhurman - Apologies for the double ping.

Any guidence on sending ac_enable, dc_enable commands for the new encrypted protocols.

I'm willing to pay in crypto.

[nhurman]

I don't have time to go look at the code again right now, maybe this week-end. The encryption is just an extra layer, underneath that it's the same as it ever was.

When the devices were updated to support encryption, along with the encryption was a "ProtocolV2" that is being used across the board which is why you very likely can re-use that class. I was only interested by the read-only stuff but it's all available in the android apk if you run it through a java decompiler.

[nano2dev]

@nhurman - I'm involved in the Nano Currency crypto.

I often pay out bounties for software development work in Nano.

If you or anyone reading is interested, I will pay 20 NANO (~$20) to anyone who offers some successfull assitance in getting me to send MQTT commands to my Elite 200 model for enable_ac && enable_dc

[nhurman]

See the last two commits in https://github.com/nhurman/bluetti_mqtt/ . I can't try AC right now, but I can toggle DC with it.

[nano2dev]

@nhurman You absolute wizard! You did what CoPilot+ could not.

I can confirm to be able to read json, and send dc_enable & ac_enable commands.

For anyone wanting my fork: https://github.com/nano2dev/bluetti_mqtt

For Elite 200, the mqtt_cleint.py regex has to be updated to support Spaces in Device Names

COMMAND_TOPIC_RE = re.compile(r'^bluetti/command/(.+?)-(\d+)/([a-z_]+)$')

@warhammerkid This is worthy of upstream merge so that everyone can benefit from support of encrypted models.

@nhurman - If you'd like some feeless & instant crypto, please download https://natrium.io - And chat or DM me your address.

[toeachbyeach]

I have spent some time packaging your updates @nano2dev into an addon for Home Assistant so its easier to install for that method. I'm a bit scared to offer it to the world by merging with the other branch as this is my first project and I don't know how good the code is (a lot of copilot) and whatever else I may have broken.

[dappergentleman]

I got this working with my Elite 200 as a local add-on in my VM of HAOS by editing some files in this fork: https://github.com/jesherman/bluetti2mqtt and putting it into the HA addons folder.

config.yaml - commented out the "image:" line; changed version and deleted irrelevant archs for good measure.

arch:
  - amd64
#image: ghcr.io/jesherman/{arch}-addon-bluetti2mqtt
host_dbus: true

build.yaml - bumped version of base python, deleted irrelevant archs.

---
build_from:
  amd64: ghcr.io/hassio-addons/base-python/amd64:17.0.0

Dockerfile - reconciled pip packages, used nano2dev's fork.

# Install bluetti_mqtt and other pip packages
RUN pip install asyncio-mqtt==0.12.1 bleak==0.22.3 crcmod==1.7 cryptography==44.0.0 dbus-next==0.2.3 paho-mqtt==1.6.1 pyasn1==0.6.1
RUN pip install git+https://github.com/nano2dev/bluetti_mqtt

Thanks to the devs for getting this functioning.

[toeachbyeach]

I got this working with my Elite 200 as a local add-on in my VM of HAOS by editing some files in this fork: https://github.com/jesherman/bluetti2mqtt and putting it into the HA addons folder.

config.yaml - commented out the "image:" line; changed version and deleted irrelevant archs for good measure.

arch:
  - amd64
#image: ghcr.io/jesherman/{arch}-addon-bluetti2mqtt
host_dbus: true

build.yaml - bumped version of base python, deleted irrelevant archs.

---
build_from:
  amd64: ghcr.io/hassio-addons/base-python/amd64:17.0.0

Dockerfile - reconciled pip packages, used nano2dev's fork.

# Install bluetti_mqtt and other pip packages
RUN pip install asyncio-mqtt==0.12.1 bleak==0.22.3 crcmod==1.7 cryptography==44.0.0 dbus-next==0.2.3 paho-mqtt==1.6.1 pyasn1==0.6.1
RUN pip install git+https://github.com/nano2dev/bluetti_mqtt

Thanks to the devs for getting this functioning.

Amazing job! I can't believe I spent a week messing around and thats all it took. Damn.

[Laho812]

Hello everyone,
I got an Elite 200 V2 and want to integrate it into Home Assistant. Can someone tell me the easiest way to install it as an HAOS Add-on and the available features?
I'm interested in battery percentage, AC/DC input power, enable/disable AC/DC output, change maximum AC input current.

Thanks in advance!