application.lua

-- file : application.lua
local module = {}  
m = nil

-- Sends a simple ping to the broker
local function send_dht22(temp, humi)  
    m:publish(config.ENDPOINT .. "temp", temp,0,0)
    m:publish(config.ENDPOINT .. "humidity", humi,0,0)
    --print(config.ENDPOINT .. "temp" .. temp, "id=" .. config.ID,0,0)
    print("Sending temp")
end

local function get_dht22()
    pin = 5
    status, temp, humi, temp_dec, humi_dec = dht.read(pin)
    if status == dht.OK then
        send_dht22(temp, humi)
        -- Float firmware using this example
        --print("DHT Temperature:"..temp..";".."Humidity:"..humi)

    elseif status == dht.ERROR_CHECKSUM then
        print( "DHT Checksum error." )
    elseif status == dht.ERROR_TIMEOUT then
        print( "DHT timed out." )
    end
end 

-- Sends my id to the broker for registration
local function register_myself()  
    m:subscribe(config.ENDPOINT .. config.ID,0,function(conn)
        print("Successfully subscribed to data endpoint")
    end)
end

local function mqtt_start()  
    m = mqtt.Client(config.ID, 120)
    -- register message callback beforehand
    m:on("message", function(conn, topic, data) 
      if data ~= nil then
        print(topic .. ": " .. data)
        -- do something, we have received a message
      end
    end)
    -- Connect to broker
    m:connect(config.HOST, config.PORT, 0, 1, function(con) 
        register_myself()
        -- And then pings each 1000 milliseconds
        tmr.stop(6)
        tmr.alarm(6, 60000, 1, get_dht22)
    end) 

end

function module.start()  
  mqtt_start()
  print(temp)
end

return module