spacecruft/farmbot_os
spacecruft/farmbot_os
1
0
Fork 0
Code Issues Pull requests Releases Activity

ack rpc ok messages to from_device after auto sync commands are applied

Browse source
This commit is contained in:
connor rigby 2017-11-14 11:08:51 -08:00
parent 7b4517e320
commit e6def9bfcd
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/farmbot/bot_state/transport/gen_mqtt/client.ex
View file

@ -91,11 +91,13 @@ defmodule Farmbot.BotState.Transport.GenMQTT.Client do
spawn fn() ->
mod = Module.concat(["Farmbot", "Repo", kind])
if Code.ensure_loaded?(mod) do
%{"body" => body} = Poison.decode!(payload, as: %{"body" => struct(mod)})
%{"body" => body, "args" => %{"label" => uuid}} = Poison.decode!(payload, as: %{"body" => struct(mod)})
Farmbot.Repo.register_sync_cmd(String.to_integer(remote_id), kind, body)
if Farmbot.System.ConfigStorage.get_config_value(:bool, "settings", "auto_sync") do
# Farmbot.Repo.flip()
Farmbot.Repo.flip()
end
Farmbot.CeleryScript.AST.Node.RpcOk.execute(%{label: uuid}, [], struct(Macro.Env))
else
Logger.warn 2, "Unknown syncable: #{mod}: #{inspect Poison.decode!(payload)}"
end