Packages
grizzly
0.15.3
9.1.4
9.1.2
9.1.1
9.1.0
9.0.0
8.15.3
8.15.2
8.15.1
8.15.0
8.14.0
8.13.0
8.12.0
8.11.3
8.11.2
8.11.1
8.11.0
8.10.0
8.9.0
8.8.1
8.8.0
8.7.1
8.7.0
8.6.12
8.6.11
8.6.10
8.6.9
8.6.8
8.6.7
retired
8.6.6
8.6.5
8.6.4
8.6.3
8.6.2
8.6.1
8.6.0
8.5.3
8.5.2
8.5.1
8.5.0
8.4.0
8.3.0
8.2.3
8.2.2
8.2.1
8.2.0
8.1.0
8.0.1
8.0.0
7.4.3
7.4.2
7.4.1
7.4.0
7.3.0
7.2.0
7.1.4
7.1.3
7.1.2
7.1.1
7.1.0
7.0.4
7.0.3
7.0.2
7.0.1
7.0.0
6.8.8
6.8.7
6.8.6
6.8.5
6.8.4
6.8.3
6.8.2
6.8.1
6.8.0
6.7.1
6.7.0
6.6.1
6.6.0
6.5.1
6.5.0
6.4.0
6.3.0
6.2.0
6.1.1
6.1.0
6.0.1
6.0.0
5.4.1
5.4.0
5.3.0
5.2.8
5.2.7
5.2.6
5.2.5
5.2.4
5.2.3
5.2.2
5.2.1
5.2.0
5.1.2
5.1.1
5.1.0
5.0.2
5.0.1
5.0.0
4.0.1
4.0.0
3.0.0
2.1.0
2.0.0
1.0.1
1.0.0
0.22.7
0.22.6
0.22.5
0.22.4
0.22.3
0.22.2
0.22.1
0.22.0
0.21.1
0.21.0
0.20.2
0.20.1
0.20.0
0.19.1
0.19.0
0.18.3
0.18.2
0.18.1
0.18.0
0.17.7
0.17.6
0.17.5
0.17.4
0.17.3
0.17.2
0.17.1
0.17.0
0.16.2
0.16.1
0.16.0
0.15.11
0.15.10
0.15.9
0.15.8
0.15.7
0.15.6
0.15.5
0.15.4
0.15.3
0.15.2
0.15.1
0.15.0
0.14.8
0.14.7
0.14.6
0.14.5
0.14.4
0.14.3
0.14.2
0.14.1
0.14.0
0.13.0
0.12.3
0.12.2
0.12.1
0.12.0
0.11.0
0.10.3
0.10.2
0.10.1
0.10.0
0.9.0
0.9.0-rc.4
0.9.0-rc.3
0.9.0-rc.2
0.9.0-rc.1
0.9.0-rc.0
0.8.8
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.0
0.6.6
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.0
0.4.3
0.4.2
Elixir Z-Wave library
Current section
Files
Jump to
Current section
Files
lib/grizzly/unsolicited_server/response_handler.ex
defmodule Grizzly.UnsolicitedServer.ResponseHandler do
@moduledoc false
# module helper for handling various different responses from the Z-Wave PAN
# network
require Logger
alias Grizzly.SeqNumber
alias Grizzly.Transport
alias Grizzly.{Associations, SeqNumber, Transport, ZWave}
alias Grizzly.UnsolicitedServer.Messages
alias Grizzly.ZWave.Command
alias Grizzly.ZWave.Commands.{
AssociationReport,
AssociationGroupingsReport,
AssociationSpecificGroupReport,
ZIPPacket
}
@doc """
When a transport receives a response from the Z-Wave network handle it
and send any other commands back over the Z-Wave PAN if needed
"""
@spec handle_response(Transport.t(), Transport.Response.t()) :: :ok
def handle_response(transport, response) do
internal_command = Command.param!(response.command, :command)
case handle_command(internal_command) do
{:ok, zip_packet} ->
binary = ZWave.to_binary(zip_packet)
Transport.send(transport, binary, to: {response.ip_address, response.port})
:notification ->
:ok = Messages.broadcast(response.ip_address, response.command)
{:notification, command} ->
:ok = Messages.broadcast(response.ip_address, command)
:ok ->
:ok
end
end
defp handle_command(%Command{name: :supervision_get} = command) do
encapsulated_command = Command.param!(command, :encapsulated_command)
case ZWave.from_binary(encapsulated_command) do
{:ok, report} ->
{:notification, report}
{:error, reason} ->
Logger.warn(
"Failed to parse: #{inspect(encapsulated_command)} notification for reason: #{
inspect(reason)
}"
)
:ok
end
end
defp handle_command(%Command{name: :association_specific_group_get}) do
seq_number = SeqNumber.get_and_inc()
{:ok, report} = AssociationSpecificGroupReport.new(group: 0)
ZIPPacket.with_zwave_command(report, seq_number)
end
defp handle_command(%Command{name: :association_get}) do
seq_number = SeqNumber.get_and_inc()
# According the the Z-Wave specification if a get request contains an
# unsupported grouping identifier then we should report back the grouping
# information for group number 1. Since right now we only support that
# group we don't need to check because we will always just send back the
# grouping information for group id 1.
association = Associations.get(1)
{:ok, association_report} =
AssociationReport.new(
grouping_identifier: association.grouping_identifier,
max_nodes_supported: 1,
nodes: association.nodes
)
ZIPPacket.with_zwave_command(association_report, seq_number, flag: nil)
end
defp handle_command(%Command{name: :association_set} = command) do
grouping_identifier = Command.param!(command, :grouping_identifier)
# According the Z-Wave specification we should just ignore grouping ids that
# we don't support. As of right now we are only supporting grouping id 1, so
# if the command contains something other than one we will just move along.
if grouping_identifier == 1 do
nodes = Command.param!(command, :nodes)
Associations.save(grouping_identifier, nodes)
else
:ok
end
end
defp handle_command(%Command{name: :association_groupings_get}) do
seq_number = SeqNumber.get_and_inc()
{:ok, groupings_report} = AssociationGroupingsReport.new(supported_groupings: 1)
ZIPPacket.with_zwave_command(groupings_report, seq_number, flag: nil)
end
defp handle_command(%Command{name: :association_remove} = command) do
grouping_id = Command.param!(command, :grouping_identifier)
nodes = Command.param!(command, :nodes)
# This case matching is based off a table from the Z-Wave specification
# Right now we only have one association grouping, so the first and third
# match are the same right now. I want to keep the matching explicit right
# now as I hope it will enable quicker understand to any future work that
# will be as it maps nicely to the documentation found in the Z-Wave
# specification.
case {grouping_id, nodes} do
{1, []} ->
Associations.delete_all_nodes_from_grouping(grouping_id)
{1, nodes} ->
Associations.delete_nodes_from_grouping(grouping_id, nodes)
{0, []} ->
Associations.delete_all()
{0, nodes} ->
Associations.delete_nodes_from_all_groupings(nodes)
_ ->
:ok
end
end
defp handle_command(_command), do: :notification
end