10.01.2023, 10:52
Use updated user.websocket library attached to this post.
Change token / homeId as needed. Add object updates at line 78. Use grp.checkupdate or grp.checkwrite so that LM is not overloaded with unnecessary duplicate values.
Change token / homeId as needed. Add object updates at line 78. Use grp.checkupdate or grp.checkwrite so that LM is not overloaded with unnecessary duplicate values.
Code:
ws = require('user.websocket')
json = require('json')
http = require('socket.http')
ltn12 = require('ltn12')
token = '12345'
payload = json.encode({ query = '{viewer { websocketSubscriptionUrl } }' })
res = http.request({
url = 'https://api.tibber.com/v1-beta/gql',
method = 'POST',
headers = {
['Authorization'] = 'Bearer ' .. token,
['Content-Type'] = 'application/json',
['Content-Length'] = #payload,
},
source = ltn12.source.string(payload),
})
res = json.pdecode(res)
if type(res) == 'table' and res.data then
url = res.data.viewer.websocketSubscriptionUrl
client, err = ws.client('sync', 30)
client.protocol = 'graphql-transport-ws'
res, err = client:connect(url)
query = [[
subscription {
liveMeasurement(homeId: "a-b-c-d") {
timestamp
power
accumulatedConsumption
accumulatedCost
currency
minPower
averagePower
maxPower
}
}
]]
else
res = nil
end
if res then
res, err = client:send(json.encode({
type = 'connection_init',
payload = {
token = token
}
}))
client:receive()
ts, tu = os.microtime()
res, err = client:send(json.encode({
id = ts .. '-' .. tu,
type = 'subscribe',
payload = {
query = query
}
}))
while true do
data, opcode, _, _, err = client:receive()
if data then
if opcode == ws.PING then
client:send(data, ws.PONG)
elseif opcode == ws.TEXT then
data = json.pdecode(data)
if type(data) == 'table' then
-- update objects here
end
end
else
log('receive failed: ' .. tostring(err))
break
end
end
else
log('connection failed: ' .. tostring(err))
end
if client then
client:close()
client = nil
end