Log CC power data & send house totals

This applet is used 1) to log CurrentCost data to file on usb stick and 2) calculate house total load and generate xAP events for it (send respective message), latter again is configured to be posted on Pachube. 

I have small Linux box as home server (for samba, mythtv, dlna/ps3ms) that is up occasionally; when up it will periodically copy files from livebox and bulk load to mysql.  This data then can then be further analysed and visualized.  I have used Google Vis tools and mc-goog-visualization for this.

Enjoy,
Aivo

CcPowerApplet.lua

require("xap")
module (...,package.seeall)
 
info = {version="1.0", description="Log CurrentCost power data & xAP send house totals"}

load = { }      -- array of CurrentCost latest phase 1..3 values
temp = 0        -- Currentcost temperature
logtime = os.time()    -- using this we decide if current second event is already being sent
logpath = "/mnt/usb/livebox/currentcost"    -- folder on usb stick
oktolog = false         -- set to true when load and temp values all get initialised

function init()
    fp = xap.Filter()
    fp:add("xap-header", "source", "dbzoo.livebox.CurrentCost:ch.*")
    fp:callback(saveload)
    ft = xap.Filter()
    ft:add("xap-header", "source", "dbzoo.livebox.CurrentCost:temp")
--  ft:add("xap-header", "class", "xAPBSC.info")
    ft:callback(savetemp)
    xap.Timer(delaylogstart, 2):start()
end

-- Wait until all values initialized
function delaylogstart(self)
    if table.getn(load) < 3 or temp == 0 then return end
    oktolog = true
    self:delete()
end

function saveload()
    local source = xap.getValue("xap-header","source")
    local ch = tonumber(source:sub(-1))
    if ch == nil then
        print('Type mismatch, cc chnum.')
        return
    end
    load[ch] = xap.getValue("input.state","text")
--  print(string.format("%s,%s,%s,%s", os.date("%Y-%m-%d %X"), ch, xap.getValue("input.state","text"), temp))
    if oktolog and os.time() ~= logtime then   -- one log line/sum event for same second
        logtime = os.time()                           -- delaying send for 1 second,
        xap.Timer(logandsend, 1):start()        -- other possible events from same second are saved until then
    end
end

function savetemp()
    temp = xap.getValue("input.state","text")
end

function logandsend(self)
    local sumload = load[1] + load[2] + load[3]
    local cmd = string.format("echo %s,%s,%s,%s,%s,%s>>%s/%s", os.date("%Y-%m-%d %X"), sumload, load[1], load[2], load[3], temp, logpath, os.date("%Y%m%d"))
    os.execute(cmd)
--  print(cmd)
    local msg = string.format([[xap-header
{
target=dbzoo.livebox.CurrentCost:script
class=xAPBSC.ccel
}
input.state
{
state=on
text=%s
displaytext=%s watts
}]], sumload, sumload)
    xap.sendShort(msg)
--  print(msg)
    self:delete()
end