Subversion Repositories HomeAutomation

function RRD_Tool() {Log("\033[31mCall to RRD_Tool() can be removed from autostart.js!\033[0m\n");}

/* Declaration of static variables */

RRD_Tool_myInterval = null;

RRD_Tool_StoredData = null;

RRD_Tool_Timers = null;

/* Constant config name */

RRD_Tool_Config = "RRD_Tool_config";

function RRD_Tool_Init()

{

    //Log("\033[33mRRD Tool updater starting...\033[0m");

    var last_value_string = Storage_GetParameters(RRD_Tool_Config);

    RRD_Tool_StoredData = new Array();

    RRD_Tool_Timers = new Array();

    for (var name in last_value_string)

    {

        RRD_Tool_StoredData[name] = eval("(" + last_value_string[name] + ")");

        Log("\033[33mFound: "+name+" with update rate of "+RRD_Tool_StoredData[name]["rrd"]["Period_s"]+"s.\033[0m");

        RRD_Tool_Timers[name] = Timer_SetTimer(function(timer) {RRD_Tool_timerUpdate(timer)}, RRD_Tool_StoredData[name]["rrd"]["Period_s"]*1000, true);

    }

    //Log("\033[33mRRD Tool updater created.\033[0m");

}

RRD_Tool_Init();

RRD_Tool_timerUpdate = function(timer)

{

    var alias_string = Storage_GetParameters("LastValues");

    for (var name in RRD_Tool_Timers)

    {  

        if (RRD_Tool_Timers[name] == timer) {

            //Log("Timer: "+timer+", named: "+name+" with data: "+RRD_Tool_StoredData[name]["rrd"]["file"]+"\n");

            /* Create command to execute...*/

            var names = "";

            var values = "N";

            var cmd = "/usr/bin/rrdtool update --template ";

            var first = 1;

            for (var label in RRD_Tool_StoredData[name]["rrdNames"])

            {

                //Log("Found label: "+label+"\n");

                var data = eval("(" + alias_string[RRD_Tool_StoredData[name]["rrdNames"][label]["Module"]] + ")");

                var datatype=RRD_Tool_StoredData[name]["rrdNames"][label]["data"];

                if (typeof data[datatype] == 'undefined')

                {

                    //Log("\033[31mCould not find datatype: "+RRD_Tool_StoredData[name]["rrdNames"][label]["data"]+".\033[0m");

                    continue;

                }

                if (typeof data[datatype]["value"][RRD_Tool_StoredData[name]["rrdNames"][label]["value"]] == 'undefined')

                {

                    //Log("\033[33mwifipid: result was: " + JSON.stringify(data[datatype]) + "\033[0m\n");

                    //Log("\033[31mCould not find value: "+RRD_Tool_StoredData[name]["rrdNames"][label]["value"]+".\033[0m");

                    continue;

                }

                var periodicity=RRD_Tool_StoredData[name]["rrd"]["Period_s"];

                //Log("\033[31mTimeout: "+RRD_Tool_StoredData[name]["rrdNames"][label]["noTimeOut"]+"  "+datatype+".\033[0m");

                if (typeof RRD_Tool_StoredData[name]["rrdNames"][label]["noTimeOut"] == 'undefined')

                {

//                Log("\033[31mUndef.\033[0m");

                    if (((get_time() - periodicity*2) > data[datatype]["timestamp"]))

                    {

//                      Log("\033[31mError1: RRD-store "+name+" could not store data, too old. Current time="+get_time()+", periodicity="+periodicity+", data timestamp="+data[datatype]["timestamp"]+" data: "+RRD_Tool_StoredData[name]["rrdNames"][label]["data"]+" value: "+RRD_Tool_StoredData[name]["rrdNames"][label]["value"]+".\033[0m");

                        continue;

                    }

                } else {

//                Log("\033[31mDef.\033[0m");

                    if (((get_time() - periodicity*2) > data[datatype]["timestamp"])&& RRD_Tool_StoredData[name]["rrdNames"][label]["noTimeOut"] != '1')

                    {

//                      Log("\033[31mError2: RRD-store "+name+" could not store data, too old. Current time="+get_time()+", periodicity="+periodicity+", data timestamp="+data[datatype]["timestamp"]+" data: "+RRD_Tool_StoredData[name]["rrdNames"][label]["data"]+" value: "+RRD_Tool_StoredData[name]["rrdNames"][label]["value"]+".\033[0m");

                        continue;

                    }

                }

                if (first == 1) {

                    names += label;

                    first = 0;

                } else {

                    names += ":"+label;  

                }

                if (typeof data[RRD_Tool_StoredData[name]["rrdNames"][label]["data"]]["value"] == "string")

                {

                    values += ":"+data[RRD_Tool_StoredData[name]["rrdNames"][label]["data"]]["value"];

                }

                else

                {

                    values += ":"+data[RRD_Tool_StoredData[name]["rrdNames"][label]["data"]]["value"][RRD_Tool_StoredData[name]["rrdNames"][label]["value"]];

                }  

            }

            if (first != 1) {

                cmd += names + " "+RRD_Tool_StoredData[name]["rrd"]["file"]+" "+values;

//              Log("Command: "+cmd);

                Execute(cmd);

            }

            break;

        }

    }

}

/* Tab complete stuff */

RRD_Tool_Aliases        = function() { return Module_GetAliasNames(); };

RRD_Tool_Intervals      = function() { return [ 5, 10, 30, 60, 120, 150, 300 ]; };

RRD_Tool_MinValues      = function() { return [ -40, 0 ]; };

RRD_Tool_MaxValues      = function() { return [ 50, 100, 10000, 20000 ]; };

/* Function returns an array with all CAN variables existing in LastValues storage */

RRD_Tool_Variables      = function()

{

    var last_value_string = Storage_GetParameters("LastValues");

    var last_values = new Array();

    var last_values_variables = [];

    for (var name in last_value_string)

    {

        last_values[name] = eval("(" + last_value_string[name] + ")");

        for (var name2 in last_values[name])

        {

            /* Only get unique variables */

            if (last_values_variables.indexOf(name2) == -1)

            {

                last_values_variables.push(name2);

            }

        }

    }

    return last_values_variables;

};

/*

electricPower={"rrd":{"file":"/var/www/appdata/rrd-data-new/electricPower.rrd","Period_s":"60"}, "rrdNames":{"power":{"Module":"powerMeter","data":"Power32","value":"value"}}}

<store_name>={"rrd":{"file":"<rrd_filename>","Period_s":"<push_interval>"}, "rrdNames":{"<rrd_data_source_name>":{"Module":"<alias_name>","data":"<variable_name>","value":"value"}}}

*/

/*

TODO:

handle more than one rrd data source (not possible with different alias/variables)

function RRDTool_AddConfig(alias_name, variable_name, push_interval, store_name, rrd_filename, rrd_data_source_name_array)

*/

/* Function to add new rrd config on atomic command line interface */

function RRDTool_AddConfig(alias_name, variable_name, push_interval, store_name, rrd_filename, rrd_data_source_name)

{

    if (arguments.length < 6)

    {

        Log("\033[31mNot enough parameters given.\033[0m\n");

        return false;

    }

    if (RRD_Tool_Config == null || RRD_Tool_StoredData == null || RRD_Tool_Timers == null)

    {

        RRD_Tool_Config = "RRD_Tool_config";

        RRD_Tool_StoredData = new Array();

        RRD_Tool_Timers = new Array();

    }

    //Log("rrd data source array length: "+rrd_data_source_name_array.length);

    //if (rrd_data_source_name_array.length > 0)

    //{

        var newString = "{\"rrd\":{\"file\":\"" + rrd_filename + "\",\"Period_s\":\"" + push_interval + "\"},\"rrdNames\":{\"" + rrd_data_source_name + "\":{\"Module\":\""+alias_name+"\",\"data\":\""+variable_name+"\",\"value\":\"value\"}}";

        //for (var rrd_data_source in rrd_data_source_name_array)

        //{

        //  newString += "";

        //}

        newString += "}";

        /* Push new config line to storage */

        Storage_SetParameter(RRD_Tool_Config, store_name, newString);

        //Log("New config: "+newString + " configname " + RRD_Tool_Config +"\n");

    //}

    /* Start this new config now */

    RRD_Tool_StoredData[store_name] = eval("(" + newString + ")");

    RRD_Tool_Timers[store_name] = Timer_SetTimer(function(timer) {RRD_Tool_timerUpdate(timer)}, RRD_Tool_StoredData[store_name]["rrd"]["Period_s"]*1000, true);

    Log("\033[33mCreated: "+store_name+" with update rate of "+RRD_Tool_StoredData[store_name]["rrd"]["Period_s"]+"s.\033[0m\n");

}

Console_RegisterCommand(RRDTool_AddConfig, function(arg_index, args) { return Console_StandardAutocomplete(arg_index, args, RRD_Tool_Aliases(), RRD_Tool_Variables(), RRD_Tool_Intervals() ); });

/* Function to add new rrd config and create rrd file on atomic command line interface */

function RRDTool_AddConfigCreateRrd(alias_name, variable_name, push_interval, data_max, data_min, store_name, rrd_filename, rrd_data_source_name)

{

    /* Create new rrd file */

    /* Two avarages, one with 1 value avarage and one with 12 values avarage */

    /* Make sure 1 value avarage last 14 days and 12 value avarage last 10 years, independant of push interval */

    /* set data timeout to double push interval */

    /* set step to push interval */

}

//Console_RegisterCommand(RRDTool_AddConfigCreateRrd, function(arg_index, args) { return Console_StandardAutocomplete(arg_index, args, RRD_Tool_Aliases(), RRD_Tool_Variables(), RRD_Tool_Intervals(), RRD_Tool_MaxValues(), RRD_Tool_MinValues() ); });