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

Use auth

Browse source
This commit is contained in:
connor rigby 2017-11-13 10:27:25 -08:00
parent 40d33368e7
commit 60b6da11e3
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/farmbot/bot_state/transport/amqp/amqp.ex
View file

@ -23,8 +23,7 @@ defmodule Farmbot.BotState.Transport.AMQP do
def init([]) do
token = ConfigStorage.get_config_value(:string, "authorization", "token")
with {:ok, %{bot: device, mqtt: mqtt_server}} <- Farmbot.Jwt.decode(token),
{:ok, conn} <- AMQP.Connection.open([host: mqtt_server]),
# {:ok, conn} <- AMQP.Connection.open([host: mqtt_server, username: device, password: token]),
{:ok, conn} <- AMQP.Connection.open([host: mqtt_server, username: device, password: token]),
{:ok, chan} <- AMQP.Channel.open(conn),
queue_name <- Enum.join([device, UUID.uuid1()], "-"),
{:ok, _} <- AMQP.Queue.declare(chan, queue_name, [auto_delete: true]),
@ -98,7 +97,6 @@ defmodule Farmbot.BotState.Transport.AMQP do
end
def handle_info({:basic_deliver, payload, %{routing_key: key}}, state) do
IO.puts "#{key}"
device = state.bot
route = String.split(key, ".")
case route do