Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 37 additions & 0 deletions bellows/ezsp/v14/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,43 @@ async def get_tc_link_key(self) -> zigpy.state.Key:

return zigpy.state.Key(key=tc_link_key_data)

async def send_unicast(
self,
nwk: t.NWK,
aps_frame: t.EmberApsFrame,
message_tag: t.uint8_t,
data: bytes,
) -> tuple[t.sl_Status, t.uint8_t]:
status, sequence = await self.sendUnicast(
message_type=t.EmberOutgoingMessageType.OUTGOING_DIRECT,
nwk=nwk,
aps_frame=aps_frame,
message_tag=message_tag,
message=data,
)

return status, sequence

async def send_multicast(
self,
aps_frame: t.EmberApsFrame,
radius: t.uint8_t,
non_member_radius: t.uint8_t,
message_tag: t.uint8_t,
data: bytes,
) -> tuple[t.sl_Status, t.uint8_t]:
status, sequence = await self.sendMulticast(
aps_frame=aps_frame,
hops=radius,
broadcast_addr=t.BroadcastAddress.RX_ON_WHEN_IDLE,
alias=0x0000,
sequence=aps_frame.sequence,
message_tag=message_tag,
message=data,
)

return status, sequence

async def send_broadcast(
self,
address: t.BroadcastAddress,
Expand Down
18 changes: 17 additions & 1 deletion bellows/ezsp/v14/commands.py
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ class GetTokenDataRsp(Struct):
},
),
"sendBroadcast": (
0x0034,
0x0036,
{
"alias": t.uint16_t,
"destination": BroadcastAddress,
Expand All @@ -128,6 +128,22 @@ class GetTokenDataRsp(Struct):
"sequence": t.uint8_t,
},
),
"sendMulticast": (
0x0038,
{
"aps_frame": t.EmberApsFrame,
"hops": t.uint8_t,
"broadcast_addr": t.BroadcastAddress,
"alias": t.uint16_t,
"sequence": t.uint8_t,
"message_tag": t.uint16_t,
"message": t.LVBytes,
},
{
"status": t.sl_Status,
"sequence": t.uint8_t,
},
),
"launchStandaloneBootloader": (
0x008F,
{
Expand Down
49 changes: 48 additions & 1 deletion tests/test_ezsp_v14.py
Original file line number Diff line number Diff line change
Expand Up @@ -155,8 +155,55 @@ async def test_get_network_key_without_network(ezsp_f):
await ezsp_f.get_network_key()


async def test_send_unicast(ezsp_f) -> None:
ezsp_f.sendUnicast.return_value = (t.sl_Status.OK, 0x0042)
status, message_tag = await ezsp_f.send_unicast(
nwk=0x1234,
aps_frame=t.EmberApsFrame(),
message_tag=0x42,
data=b"hello",
)

assert status == t.sl_Status.OK
assert message_tag == 0x42
assert ezsp_f.sendUnicast.mock_calls == [
call(
message_type=t.EmberOutgoingMessageType.OUTGOING_DIRECT,
nwk=0x1234,
aps_frame=t.EmberApsFrame(),
message_tag=0x42,
message=b"hello",
)
]


async def test_send_multicast(ezsp_f) -> None:
ezsp_f.sendMulticast.return_value = (t.sl_Status.OK, 0x0042)
status, message_tag = await ezsp_f.send_multicast(
aps_frame=t.EmberApsFrame(sequence=0x34),
radius=12,
non_member_radius=34,
message_tag=0x42,
data=b"hello",
)

assert status == t.sl_Status.OK
assert message_tag == 0x42
assert ezsp_f.sendMulticast.mock_calls == [
call(
aps_frame=t.EmberApsFrame(sequence=0x34),
hops=12,
broadcast_addr=t.BroadcastAddress.RX_ON_WHEN_IDLE,
alias=0x0000,
sequence=0x34,
message_tag=0x0042,
message=b"hello",
)
]


async def test_send_broadcast(ezsp_f) -> None:
ezsp_f.sendBroadcast.return_value = (t.sl_Status.OK, 0x42)
ezsp_f.sendBroadcast.return_value = (t.sl_Status.OK, 0x0042)
status, message_tag = await ezsp_f.send_broadcast(
address=t.BroadcastAddress.ALL_ROUTERS_AND_COORDINATOR,
aps_frame=t.EmberApsFrame(),
Expand Down