adminandClaude Opus 5
79843aa2ae
Erster Stand der Hintergrundprozesse, die auf der Synology unter /volume1/homes/wagner/SolarManager laufen: der Manager selbst, die Sammler je Geraet, die MQTT-Bruecke, der Wecker und - neu hinzugezogen - der AutoAction-Runner, der als Hintergrundprozess hierher gehoert und nicht ins Web-Verzeichnis. Zugangsdaten stehen nicht mehr im Quelltext, sondern in config.ini, die nicht mit eingecheckt wird. Vorlage ist config.ini.example, gelesen wird sie von konfig.py. Betroffen waren solarManager.py (Datenbank und Wattpilot), zeit.py, gatherWaterData.py, wecker.py und skoda_testdaten.py, das sich das Passwort bisher aus dem Quelltext eines anderen Moduls herausgesucht hat. Die Kia-Anbindung ist mit dem Fahrzeug entfallen: kiaTest.py, gatherCarData.py und hyundai_kia_connect_api sind nicht mehr dabei, ebenso gatherInverterData.py, auf das nur noch eine auskommentierte Zeile zeigte. Die mitgelieferten Bibliotheken bleiben im Repository - die NAS hat kein pip, sie muessen neben den Skripten liegen. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
91 lines
2.9 KiB
Python
91 lines
2.9 KiB
Python
# Test whether a client responds to max-inflight and reconnect when max-inflight is reached
|
|
|
|
# The client should connect with keepalive=60, clean session set,
|
|
# and client id publish-fill-inflight
|
|
# The test will send a CONNACK message to the client with rc=0. Upon receiving
|
|
# the CONNACK the client should verify that rc==0.
|
|
# Then client should send 10 PUBLISH with QoS == 1. On client side 12 message will be
|
|
# submitted, so 2 will be queued.
|
|
# The test will wait 0.5 seconds after received the 10 PUBLISH. After this wait, it will
|
|
# disconnect the client.
|
|
# The client should re-connect and re-sent the first 10 messages.
|
|
# The test will PUBACK one message, it should receive another PUBLISH.
|
|
# The test will wait 0.5 seconds and expect no PUBLISH.
|
|
# The test will then PUBACK all message.
|
|
# The client should disconnect once everything is acked.
|
|
|
|
import pytest
|
|
|
|
import tests.paho_test as paho_test
|
|
|
|
|
|
def expected_payload(i: int) -> bytes:
|
|
return f"message{i}"
|
|
|
|
connect_packet = paho_test.gen_connect("publish-qos1-test", keepalive=60)
|
|
connack_packet = paho_test.gen_connack(rc=0)
|
|
|
|
disconnect_packet = paho_test.gen_disconnect()
|
|
|
|
first_connection_publishs = [
|
|
paho_test.gen_publish(
|
|
"topic", qos=1, mid=i+1, payload=expected_payload(i),
|
|
)
|
|
for i in range(10)
|
|
]
|
|
second_connection_publishs = [
|
|
paho_test.gen_publish(
|
|
# I'm not sure we should have the mid+13.
|
|
# Currently on reconnection client will do two wrong thing:
|
|
# * it sent more than max_inflight packet
|
|
# * it re-send message both with mid = old_mid + 12 AND with mid = old_mid & dup=1
|
|
"topic", qos=1, mid=i+13, payload=expected_payload(i),
|
|
)
|
|
for i in range(12)
|
|
]
|
|
second_connection_pubacks = [
|
|
paho_test.gen_puback(i+13)
|
|
for i in range(12)
|
|
]
|
|
|
|
@pytest.mark.xfail
|
|
def test_03_publish_fill_inflight(server_socket, start_client):
|
|
start_client("03-publish-fill-inflight.py")
|
|
|
|
(conn, address) = server_socket.accept()
|
|
conn.settimeout(10)
|
|
|
|
paho_test.expect_packet(conn, "connect", connect_packet)
|
|
conn.send(connack_packet)
|
|
|
|
for packet in first_connection_publishs:
|
|
paho_test.expect_packet(conn, "publish", packet)
|
|
|
|
paho_test.expect_no_packet(conn, 0.5)
|
|
|
|
conn.close()
|
|
|
|
(conn, address) = server_socket.accept()
|
|
conn.settimeout(10)
|
|
|
|
paho_test.expect_packet(conn, "connect", connect_packet)
|
|
conn.send(connack_packet)
|
|
|
|
for packet in second_connection_publishs[:10]:
|
|
paho_test.expect_packet(conn, "publish", packet)
|
|
|
|
paho_test.expect_no_packet(conn, 0.2)
|
|
|
|
conn.send(second_connection_pubacks[0])
|
|
paho_test.expect_packet(conn, "publish", second_connection_publishs[10])
|
|
|
|
paho_test.expect_no_packet(conn, 0.5)
|
|
|
|
for packet in second_connection_pubacks[1:11]:
|
|
conn.send(packet)
|
|
|
|
paho_test.expect_packet(conn, "publish", second_connection_publishs[11])
|
|
|
|
paho_test.expect_no_packet(conn, 0.5)
|
|
|