mirror of
https://github.com/meshtastic/python.git
synced 2026-09-25 13:15:56 -04:00
protobufs v2.8.0
This commit is contained in:
1 parent
0539a9600f
commit
efb6d1c0e9
30 files changed
+2548
-472
No files matched your search
@@ -21,6 +21,7 @@ from meshtastic.protobuf import (
|
||||
atak_pb2,
|
||||
config_pb2,
|
||||
mesh_pb2,
|
||||
mqtt_pb2,
|
||||
nanopb_pb2,
|
||||
telemetry_pb2,
|
||||
)
|
||||
@@ -640,7 +641,15 @@ def test_descriptor_multilevel_nested_route_link_uid():
|
||||
|
||||
@pytest.mark.unit
|
||||
def test_descriptor_telemetry_environment_one_wire_temperature():
|
||||
"""EnvironmentMetrics.one_wire_temperature has max_count = 8 from telemetry.options."""
|
||||
"""EnvironmentMetrics.one_wire_temperature has type = FT_IGNORE from telemetry.options."""
|
||||
env = telemetry_pb2.DESCRIPTOR.message_types_by_name["EnvironmentMetrics"]
|
||||
opts = _field_opts(env, "one_wire_temperature")
|
||||
assert opts.max_count == 8
|
||||
assert opts.type == nanopb_pb2.FT_IGNORE
|
||||
|
||||
|
||||
@pytest.mark.unit
|
||||
def test_descriptor_mqtt_service_envelope_pointer_fields():
|
||||
"""ServiceEnvelope fields carry type = FT_POINTER from mqtt.options."""
|
||||
envelope = mqtt_pb2.DESCRIPTOR.message_types_by_name["ServiceEnvelope"]
|
||||
for name in ("packet", "channel_id", "gateway_id"):
|
||||
assert _field_opts(envelope, name).type == nanopb_pb2.FT_POINTER
|
||||
@@ -12,11 +12,11 @@ def test_handleFromRadio_with_traffic_management_module_config():
|
||||
"""Test _handleFromRadio with moduleConfig.traffic_management."""
|
||||
iface = MeshInterface(noProto=True)
|
||||
from_radio = mesh_pb2.FromRadio()
|
||||
from_radio.moduleConfig.traffic_management.enabled = True
|
||||
from_radio.moduleConfig.traffic_management.rate_limit_enabled = True
|
||||
from_radio.moduleConfig.traffic_management.position_min_interval_secs = 30
|
||||
from_radio.moduleConfig.traffic_management.rate_limit_window_secs = 60
|
||||
|
||||
iface._handleFromRadio(from_radio.SerializeToString())
|
||||
|
||||
assert iface.localNode.moduleConfig.traffic_management.enabled is True
|
||||
assert iface.localNode.moduleConfig.traffic_management.rate_limit_enabled is True
|
||||
assert iface.localNode.moduleConfig.traffic_management.position_min_interval_secs == 30
|
||||
assert iface.localNode.moduleConfig.traffic_management.rate_limit_window_secs == 60
|
||||
iface.close()
|
||||
@@ -1153,8 +1153,8 @@ def test_writeConfig_traffic_management():
|
||||
"""Test writeConfig with traffic_management module config."""
|
||||
iface = MagicMock(autospec=SerialInterface)
|
||||
anode = Node(iface, 123, noProto=True)
|
||||
anode.moduleConfig.traffic_management.enabled = True
|
||||
anode.moduleConfig.traffic_management.rate_limit_enabled = True
|
||||
anode.moduleConfig.traffic_management.position_min_interval_secs = 30
|
||||
anode.moduleConfig.traffic_management.rate_limit_window_secs = 60
|
||||
|
||||
sent_admin = []
|
||||
|
||||
@@ -1167,8 +1167,8 @@ def test_writeConfig_traffic_management():
|
||||
assert len(sent_admin) == 1
|
||||
assert sent_admin[0].HasField("set_module_config")
|
||||
assert sent_admin[0].set_module_config.HasField("traffic_management")
|
||||
assert sent_admin[0].set_module_config.traffic_management.enabled is True
|
||||
assert sent_admin[0].set_module_config.traffic_management.rate_limit_enabled is True
|
||||
assert sent_admin[0].set_module_config.traffic_management.position_min_interval_secs == 30
|
||||
assert sent_admin[0].set_module_config.traffic_management.rate_limit_window_secs == 60
|
||||
|
||||
|
||||
# TODO
|
||||
|
||||
Reference in new issue
Block a user