NetAtmo Cameras into LM - Printable Version

Code:

<?



require('apps')

-- read POST data

body = ngx.req.get_body_data()



if body then

  -- decode data as JSON

  data = json.pdecode(body)



  -- check that data is a table

  if type(data) == 'table' then

    log(data)



    -- movement detected, you can check data.camera_id if you have multiple cameras

    if data.event_type == 'movement' then

      -- do something when movement happens

    end

  end

end

Code:

require 'ltn12'

require 'socket.http'

json = require("json")

https = require 'ssl.https'





  local client_id = "xxxxxxxxxxxxxxxxxxxxx"     

  local client_secret = "xxxxxxxxxxxxxxxxxxxxxxxxxxxx"

  local scope = "read_presence read_camera"  --Welcome camera use read_camera, Presence camera use read_presence 

  local username = "xxxxxxxxxxxxx"

  local password = "xxxxxxxxxxxxxxxxxxx"



--Client credentials grant type

  grant_acess_data = "grant_type=password&client_id=" .. client_id .."&client_secret=" .. client_secret .. "&username=" .. username .. "&password=" .. password .. "&scope=" .. scope

  request_oauth_url = "https://api.netatmo.net/oauth2/token"



  



function Netatmo_Post(url, body, headers) --headers = {}

   res_body ={}

  

  local body, code, hdrs, stat = https.request

 

  {

    url = url;

    method = "POST",

    headers = headers,

    source = ltn12.source.string(body);

    sink = ltn12.sink.table(res_body);

  }



  if (code ~= 200) then

    log("netatmo post error : "..tostring(code)..","..tostring(body))

    return

  end

  

   return json.pdecode(res_body[1])

  end









function Get_Token()

  

  res = Netatmo_Post(request_oauth_url, grant_acess_data, {["Content-Type"] = "application/x-www-form-urlencoded",  ["Content-Length"] = #grant_acess_data, })

--log(res)



  if res then 

  grp.write('32/1/1', res.refresh_token)

  grp.write('32/1/2', res.access_token)  

  grp.write('32/1/3', res.expires_in)

    else 

    log('Netatmo token request failed')

 end

  

end





function Refresh_token()

 

  refresh_acess_data = "grant_type=refresh_token&refresh_token="..grp.getvalue('32/1/1').."&client_id=" .. client_id .."&client_secret=" .. client_secret

  res = Netatmo_Post(request_oauth_url, refresh_acess_data , {["Content-Type"] = "application/x-www-form-urlencoded",  ["Content-Length"] = #refresh_acess_data, })

  log(res)



  if res then 

  grp.write('32/1/1', res.refresh_token)

  grp.write('32/1/2', res.access_token)

  grp.write('32/1/3', res.expires_in)

    else 

    log('Netatmo token refresh failed')

 end

  

end