WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom1.5/script/plugin/module.js


 
Require("plugin/storage.js");
 
function Module_CreateAliasAutoComplete(args)
{
    // args[0] == command name
    var arg_index = args.length - 2;
   
    if (arg_index == 0)
    {
        return Module_GetAliasNames();
    }
    else if (arg_index == 1)
    {
        return Module_GetNames();
    }
    else if (arg_index == 2)
    {
        return Module_GetAvailableIds([ args[2] ])
    }
   
    return [];
}
 
function Module_CreateAlias(alias_name, module_name, module_id, specific)
{
    // TODO Check arguments
   
    var specific_list = {};
   
    if (specific)
    {
        var specific_parts = split(",", specific);
       
        // TODO: Check length
       
        for (var index in specific_parts)
        {
            var parts = split("=", specific_parts[index]);
           
            // TODO: Check length
           
            specific_list[parts[0]] = parts[1];
        }
    }
   
    var alias_data = {
        "group"       : false,
        "name"        : alias_name,
        "module_name" : module_name,
        "module_id"   : module_id,
        "specific"    : specific_list
    };
   
    return Storage_SetParameter("alias", alias_name, JSON.stringify(alias_data));
}
Console_RegisterCommand(Module_CreateAlias, Module_CreateAliasAutoComplete);
 
function Module_CreateAliasGroupAutoComplete(args)
{
    // args[0] == command name
    var arg_index = args.length - 2;
   
    if (arg_index == 0)
    {
        return Module_GetAliasNames();
    }
    else if (arg_index == 1)
    {
        return Module_GetNames();
    }
    else if (arg_index >= 2)
    {
        return Module_GetAliasNames([ args[2] ])
    }
   
    return [];
}
 
function Module_CreateAliasGroup(alias_group_name, module_type, alias_name1, alias_name2)
{
    if (arguments.length < 3)
    {
        throw("Not enought parameters given");
    }
   
    alias_group_name = arguments[0];
    module_type = arguments[1];
    var aliases = [];
   
    for (var n = 2; n < arguments.length; n++)
    {
        if (arguments[n].length > 0)
        {
            var aliases_data = Module_ResolveAlias(arguments[n]);
            aliases.push(arguments[n]);
        }
    }
   
    if (aliases.length == 0)
    {
        throw("No valid aliases were found, aborting creation of group alias");
    }
   
    var alias_data = {
        "group"       : true,
        "name"        : alias_group_name,
        "module_name" : module_type,
        "aliases"     : aliases
    };
   
    return Storage_SetParameter("alias", alias_group_name, JSON.stringify(alias_data));
}
Console_RegisterCommand(Module_CreateAliasGroup, Module_CreateAliasGroupAutoComplete);
 
function Module_ResolveAlias(alias_name, filter_module_names)
{
    var aliases_data = {};
    var alias_data_string = Storage_GetParameter("alias", alias_name);
   
    if (alias_data_string)
    {
        var alias_data = eval("(" + alias_data_string + ")");
       
        if (alias_data["group"])
        {
            for (var n in alias_data["aliases"])
            {
                var aliases_data_sub = Module_ResolveAlias(alias_data["aliases"][n], filter_module_names);
               
                for (var name in aliases_data_sub)
                {
                    aliases_data[name] = aliases_data_sub[name];
                }
            }
        }
        else
        {
            if (in_array(filter_module_names, alias_data["module_name"]))
            {
                aliases_data[alias_name] = alias_data;
            }
        }
    }
   
    return aliases_data;
}
 
function Module_LookupAliases(match_filter)
{
    var aliases_data_filtered = {};
    var aliases_data = Storage_GetParameters("alias");
   
    for (var name in aliases_data)
    {
        var alias_data = eval("(" + aliases_data[name] + ")");
       
        var valid = true;
       
        for (var key in match_filter)
        {
            if (alias_data[key] != match_filter[key])
            {
                valid = false;
                break;
            }
        }
       
        if (valid)
        {
            aliases_data_filtered[name] = alias_data;
        }
    }
   
    return aliases_data_filtered;
}
 
function Module_GetAliasNames(filter_module_names)
{
    var aliases_name_filtered = [];
    var aliases_data = Storage_GetParameters("alias");
   
    for (var name in aliases_data)
    {
        var alias_data = eval("(" + aliases_data[name] + ")");
       
        if (!filter_module_names || in_array(filter_module_names, alias_data["module_name"]))
        {
            aliases_name_filtered.push(name)
        }
    }
   
    return aliases_name_filtered;
}
 
function Module_GetAvailableIds(filter_module_names)
{
    var result_list = [];
    var available_modules = ModuleExport_GetAvailableModules();
   
    for (var n in available_modules)
    {
        var id_parts = available_modules[n].split(":", 2);
       
        if (in_array(filter_module_names, id_parts[0]))
        {
            result_list.push(id_parts[1]);
        }
    }
   
    return result_list;
}
 
function Module_GetNames()
{
    return [ "Dimmer230", "irTransmit", "irReceive", "SimpleDTMF", "BusVoltage" ];
}
 
function Module_SendMessage(module_name, module_id, command, variables)
{
    var args = [];
   
    args.push(module_name + ":" + module_id);
    args.push(command);
   
    var length = 0;
    for (var key in variables)
    {
        length++;
    }
   
    args.push(length);
   
    for (var key in variables)
    {
        args.push(key);
        args.push(variables[key]);
    }
   
    return ModuleExport_SendMessage.apply(null, Array.prototype.slice.call(args, 0));
}
 
var Module_OnChangeFunctions = {};
var Module_OnMessageFunctions = {};
 
function Module_RegisterToOnChange(alias_name, callback)
{
    if (!Module_OnChangeFunctions[alias_name])
    {
        Module_OnChangeFunctions[alias_name] = [];
    }
   
    Module_OnChangeFunctions[alias_name].push(callback);
}
 
function Module_RegisterToOnMessage(alias_name, callback)
{
    if (!Module_OnMessageFunctions[alias_name])
    {
        Module_OnMessageFunctions[alias_name] = [];
    }
   
    Module_OnMessageFunctions[alias_name].push(callback);
}
 
function Module_OnMessage(full_id, command, variables)
{
    var id_parts = full_id.split(":", 2);
    var aliases_data = {};
 
    var aliases_data = Module_LookupAliases({
        "module_name" : id_parts[0],
        "module_id"   : id_parts[1],
        "group"       : false
    });
   
    for (var alias_name in aliases_data)
    {
        var ok = true;
 
        if (aliases_data[alias_name]["specific"])
        {
            var ok = true;
           
            for (var name in variables)
            {
                if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])
                {
                    ok = false;
                    break;
                }
            }
        }
       
        if (Module_OnMessageFunctions[alias_name] && ok)
        {
            for (var n in Module_OnMessageFunctions[alias_name])
            {
                Module_OnMessageFunctions[alias_name][n](alias_name, command, variables);
            }
        }
    }
}
 
function Module_OnChange(full_id, available)
{
    var id_parts = full_id.split(":", 2);
    var aliases_data = {};
   
    var aliases_data_all = Module_LookupAliases({
        "module_name" : id_parts[0],
        "module_id"   : id_parts[1],
        "group"       : false
    });
   
    for (var alias_name in aliases_data)
    {
        var ok = true;
       
        if (aliases_data[alias_name]["specific"])
        {
            var ok = true;
           
            for (var name in variables)
            {
                if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])
                {
                    ok = false;
                    break;
                }
            }
        }
       
        if (Module_OnChangeFunctions[alias_name] && ok)
        {
            for (var n in Module_OnChangeFunctions[alias_name])
            {
                Module_OnChangeFunctions[alias_name][n](alias_name, available);
            }
        }
    }
}
 

Rev 1647	Rev 1648
1		1
2	Require("plugin/storage.js");	2	Require("plugin/storage.js");
3		3
4	function Module_CreateAliasAutoComplete(args)	4	function Module_CreateAliasAutoComplete(args)
5	{	5	{
6	// args[0] == command name	6	// args[0] == command name
7	var arg_index = args.length - 2;	7	var arg_index = args.length - 2;
8		8
9	if (arg_index == 0)	9	if (arg_index == 0)
10	{	10	{
11	return Module_GetAliasNames();	11	return Module_GetAliasNames();
12	}	12	}
13	else if (arg_index == 1)	13	else if (arg_index == 1)
14	{	14	{
15	return Module_GetNames();	15	return Module_GetNames();
16	}	16	}
17	else if (arg_index == 2)	17	else if (arg_index == 2)
18	{	18	{
19	return Module_GetAvailableIds([ args[2] ])	19	return Module_GetAvailableIds([ args[2] ])
20	}	20	}
21		21
22	return [];	22	return [];
23	}	23	}
24		24
25	function Module_CreateAlias(alias_name, module_name, module_id, specific)	25	function Module_CreateAlias(alias_name, module_name, module_id, specific)
26	{	26	{
27	// TODO Check arguments	27	// TODO Check arguments
28		28
29	var specific_list = {};	29	var specific_list = {};
30		30
31	if (specific)	31	if (specific)
32	{	32	{
33	var specific_parts = split(",", specific);	33	var specific_parts = split(",", specific);
34		34
35	// TODO: Check length	35	// TODO: Check length
36		36
37	for (var index in specific_parts)	37	for (var index in specific_parts)
38	{	38	{
39	var parts = split("=", specific_parts[index]);	39	var parts = split("=", specific_parts[index]);
40		40
41	// TODO: Check length	41	// TODO: Check length
42		42
43	specific_list[parts[0]] = parts[1];	43	specific_list[parts[0]] = parts[1];
44	}	44	}
45	}	45	}
46		46
47	var alias_data = {	47	var alias_data = {
48	"group" : false,	48	"group" : false,
49	"name" : alias_name,	49	"name" : alias_name,
50	"module_name" : module_name,	50	"module_name" : module_name,
51	"module_id" : module_id,	51	"module_id" : module_id,
52	"specific" : specific_list	52	"specific" : specific_list
53	};	53	};
54		54
55	return Storage_SetParameter("alias", alias_name, JSON.stringify(alias_data));	55	return Storage_SetParameter("alias", alias_name, JSON.stringify(alias_data));
56	}	56	}
57	Console_RegisterCommand(Module_CreateAlias, Module_CreateAliasAutoComplete);	57	Console_RegisterCommand(Module_CreateAlias, Module_CreateAliasAutoComplete);
58		58
59	function Module_CreateAliasGroupAutoComplete(args)	59	function Module_CreateAliasGroupAutoComplete(args)
60	{	60	{
61	// args[0] == command name	61	// args[0] == command name
62	var arg_index = args.length - 2;	62	var arg_index = args.length - 2;
63		63
64	if (arg_index == 0)	64	if (arg_index == 0)
65	{	65	{
66	return Module_GetAliasNames();	66	return Module_GetAliasNames();
67	}	67	}
68	else if (arg_index == 1)	68	else if (arg_index == 1)
69	{	69	{
70	return Module_GetNames();	70	return Module_GetNames();
71	}	71	}
72	else if (arg_index >= 2)	72	else if (arg_index >= 2)
73	{	73	{
74	return Module_GetAliasNames([ args[2] ])	74	return Module_GetAliasNames([ args[2] ])
75	}	75	}
76		76
77	return [];	77	return [];
78	}	78	}
79		79
80	function Module_CreateAliasGroup(alias_group_name, module_type, alias_name1, alias_name2)	80	function Module_CreateAliasGroup(alias_group_name, module_type, alias_name1, alias_name2)
81	{	81	{
82	if (arguments.length < 3)	82	if (arguments.length < 3)
83	{	83	{
84	throw("Not enought parameters given");	84	throw("Not enought parameters given");
85	}	85	}
86		86
87	alias_group_name = arguments[0];	87	alias_group_name = arguments[0];
88	module_type = arguments[1];	88	module_type = arguments[1];
89	var aliases = [];	89	var aliases = [];
90		90
91	for (var n = 2; n < arguments.length; n++)	91	for (var n = 2; n < arguments.length; n++)
92	{	92	{
93	if (arguments[n].length > 0)	93	if (arguments[n].length > 0)
94	{	94	{
95	var aliases_data = Module_ResolveAlias(arguments[n]);	95	var aliases_data = Module_ResolveAlias(arguments[n]);
96	aliases.push(arguments[n]);	96	aliases.push(arguments[n]);
97	}	97	}
98	}	98	}
99		99
100	if (aliases.length == 0)	100	if (aliases.length == 0)
101	{	101	{
102	throw("No valid aliases were found, aborting creation of group alias");	102	throw("No valid aliases were found, aborting creation of group alias");
103	}	103	}
104		104
105	var alias_data = {	105	var alias_data = {
106	"group" : true,	106	"group" : true,
107	"name" : alias_group_name,	107	"name" : alias_group_name,
108	"module_name" : module_type,	108	"module_name" : module_type,
109	"aliases" : aliases	109	"aliases" : aliases
110	};	110	};
111		111
112	return Storage_SetParameter("alias", alias_group_name, JSON.stringify(alias_data));	112	return Storage_SetParameter("alias", alias_group_name, JSON.stringify(alias_data));
113	}	113	}
114	Console_RegisterCommand(Module_CreateAliasGroup, Module_CreateAliasGroupAutoComplete);	114	Console_RegisterCommand(Module_CreateAliasGroup, Module_CreateAliasGroupAutoComplete);
115		115
116	function Module_ResolveAlias(alias_name, filter_module_names)	116	function Module_ResolveAlias(alias_name, filter_module_names)
117	{	117	{
118	var aliases_data = {};	118	var aliases_data = {};
119	var alias_data_string = Storage_GetParameter("alias", alias_name);	119	var alias_data_string = Storage_GetParameter("alias", alias_name);
120		120
121	if (alias_data_string)	121	if (alias_data_string)
122	{	122	{
123	var alias_data = eval("(" + alias_data_string + ")");	123	var alias_data = eval("(" + alias_data_string + ")");
124		124
125	if (alias_data["group"])	125	if (alias_data["group"])
126	{	126	{
127	for (var n in alias_data["aliases"])	127	for (var n in alias_data["aliases"])
128	{	128	{
129	var aliases_data_sub = Module_ResolveAlias(alias_data["aliases"][n], filter_module_names);	129	var aliases_data_sub = Module_ResolveAlias(alias_data["aliases"][n], filter_module_names);
130		130
131	for (var name in aliases_data_sub)	131	for (var name in aliases_data_sub)
132	{	132	{
133	aliases_data[name] = aliases_data_sub[name];	133	aliases_data[name] = aliases_data_sub[name];
134	}	134	}
135	}	135	}
136	}	136	}
137	else	137	else
138	{	138	{
139	if (in_array(filter_module_names, alias_data["module_name"]))	139	if (in_array(filter_module_names, alias_data["module_name"]))
140	{	140	{
141	aliases_data[alias_name] = alias_data;	141	aliases_data[alias_name] = alias_data;
142	}	142	}
143	}	143	}
144	}	144	}
145		145
146	return aliases_data;	146	return aliases_data;
147	}	147	}
148		148
149	function Module_LookupAliases(match_filter)	149	function Module_LookupAliases(match_filter)
150	{	150	{
151	var aliases_data_filtered = {};	151	var aliases_data_filtered = {};
152	var aliases_data = Storage_GetParameters("alias");	152	var aliases_data = Storage_GetParameters("alias");
153		153
154	for (var name in aliases_data)	154	for (var name in aliases_data)
155	{	155	{
156	var alias_data = eval("(" + aliases_data[name] + ")");	156	var alias_data = eval("(" + aliases_data[name] + ")");
157		157
158	var valid = true;	158	var valid = true;
159		159
160	for (var key in match_filter)	160	for (var key in match_filter)
161	{	161	{
162	if (alias_data[key] != match_filter[key])	162	if (alias_data[key] != match_filter[key])
163	{	163	{
164	valid = false;	164	valid = false;
165	break;	165	break;
166	}	166	}
167	}	167	}
168		168
169	if (valid)	169	if (valid)
170	{	170	{
171	aliases_data_filtered[name] = alias_data;	171	aliases_data_filtered[name] = alias_data;
172	}	172	}
173	}	173	}
174		174
175	return aliases_data_filtered;	175	return aliases_data_filtered;
176	}	176	}
177		177
178	function Module_GetAliasNames(filter_module_names)	178	function Module_GetAliasNames(filter_module_names)
179	{	179	{
180	var aliases_name_filtered = [];	180	var aliases_name_filtered = [];
181	var aliases_data = Storage_GetParameters("alias");	181	var aliases_data = Storage_GetParameters("alias");
182		182
183	for (var name in aliases_data)	183	for (var name in aliases_data)
184	{	184	{
185	var alias_data = eval("(" + aliases_data[name] + ")");	185	var alias_data = eval("(" + aliases_data[name] + ")");
186		186
187	if (!filter_module_names \|\| in_array(filter_module_names, alias_data["module_name"]))	187	if (!filter_module_names \|\| in_array(filter_module_names, alias_data["module_name"]))
188	{	188	{
189	aliases_name_filtered.push(name)	189	aliases_name_filtered.push(name)
190	}	190	}
191	}	191	}
192		192
193	return aliases_name_filtered;	193	return aliases_name_filtered;
194	}	194	}
195		195
196	function Module_GetAvailableIds(filter_module_names)	196	function Module_GetAvailableIds(filter_module_names)
197	{	197	{
198	var result_list = [];	198	var result_list = [];
199	var available_modules = ModuleExport_GetAvailableModules();	199	var available_modules = ModuleExport_GetAvailableModules();
200		200
201	for (var n in available_modules)	201	for (var n in available_modules)
202	{	202	{
203	var id_parts = available_modules[n].split(":", 2);	203	var id_parts = available_modules[n].split(":", 2);
204		204
205	if (in_array(filter_module_names, id_parts[0]))	205	if (in_array(filter_module_names, id_parts[0]))
206	{	206	{
207	result_list.push(id_parts[1]);	207	result_list.push(id_parts[1]);
208	}	208	}
209	}	209	}
210		210
211	return result_list;	211	return result_list;
212	}	212	}
213		213
214	function Module_GetNames()	214	function Module_GetNames()
215	{	215	{
216	return [ "Dimmer230", "irTransmit" ];	216	return [ "Dimmer230", "irTransmit", "irReceive", "SimpleDTMF", "BusVoltage" ];
217	}	217	}
218		218
219	function Module_SendMessage(module_name, module_id, command, variables)	219	function Module_SendMessage(module_name, module_id, command, variables)
220	{	220	{
221	var args = [];	221	var args = [];
222		222
223	args.push(module_name + ":" + module_id);	223	args.push(module_name + ":" + module_id);
224	args.push(command);	224	args.push(command);
225		225
226	var length = 0;	226	var length = 0;
227	for (var key in variables)	227	for (var key in variables)
228	{	228	{
229	length++;	229	length++;
230	}	230	}
231		231
232	args.push(length);	232	args.push(length);
233		233
234	for (var key in variables)	234	for (var key in variables)
235	{	235	{
236	args.push(key);	236	args.push(key);
237	args.push(variables[key]);	237	args.push(variables[key]);
238	}	238	}
239		239
240	return ModuleExport_SendMessage.apply(null, Array.prototype.slice.call(args, 0));	240	return ModuleExport_SendMessage.apply(null, Array.prototype.slice.call(args, 0));
241	}	241	}
242		242
243	var Module_OnChangeFunctions = {};	243	var Module_OnChangeFunctions = {};
244	var Module_OnMessageFunctions = {};	244	var Module_OnMessageFunctions = {};
245		245
246	function Module_RegisterToOnChange(alias_name, callback)	246	function Module_RegisterToOnChange(alias_name, callback)
247	{	247	{
248	if (!Module_OnChangeFunctions[alias_name])	248	if (!Module_OnChangeFunctions[alias_name])
249	{	249	{
250	Module_OnChangeFunctions[alias_name] = [];	250	Module_OnChangeFunctions[alias_name] = [];
251	}	251	}
252		252
253	Module_OnChangeFunctions[alias_name].push(callback);	253	Module_OnChangeFunctions[alias_name].push(callback);
254	}	254	}
255		255
256	function Module_RegisterToOnMessage(alias_name, callback)	256	function Module_RegisterToOnMessage(alias_name, callback)
257	{	257	{
258	if (!Module_OnMessageFunctions[alias_name])	258	if (!Module_OnMessageFunctions[alias_name])
259	{	259	{
260	Module_OnMessageFunctions[alias_name] = [];	260	Module_OnMessageFunctions[alias_name] = [];
261	}	261	}
262		262
263	Module_OnMessageFunctions[alias_name].push(callback);	263	Module_OnMessageFunctions[alias_name].push(callback);
264	}	264	}
265		265
266	function Module_OnMessage(full_id, command, variables)	266	function Module_OnMessage(full_id, command, variables)
267	{	267	{
268	var id_parts = full_id.split(":", 2);	268	var id_parts = full_id.split(":", 2);
269	var aliases_data = {};	269	var aliases_data = {};
270		270
271	var aliases_data = Module_LookupAliases({	271	var aliases_data = Module_LookupAliases({
272	"module_name" : id_parts[0],	272	"module_name" : id_parts[0],
273	"module_id" : id_parts[1],	273	"module_id" : id_parts[1],
274	"group" : false	274	"group" : false
275	});	275	});
276		276
277	for (var alias_name in aliases_data)	277	for (var alias_name in aliases_data)
278	{	278	{
279	var ok = true;	279	var ok = true;
280		280
281	if (aliases_data[alias_name]["specific"])	281	if (aliases_data[alias_name]["specific"])
282	{	282	{
283	var ok = true;	283	var ok = true;
284		284
285	for (var name in variables)	285	for (var name in variables)
286	{	286	{
287	if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])	287	if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])
288	{	288	{
289	ok = false;	289	ok = false;
290	break;	290	break;
291	}	291	}
292	}	292	}
293	}	293	}
294		294
295	if (Module_OnMessageFunctions[alias_name] && ok)	295	if (Module_OnMessageFunctions[alias_name] && ok)
296	{	296	{
297	for (var n in Module_OnMessageFunctions[alias_name])	297	for (var n in Module_OnMessageFunctions[alias_name])
298	{	298	{
299	Module_OnMessageFunctions[alias_name][n](alias_name, command, variables);	299	Module_OnMessageFunctions[alias_name][n](alias_name, command, variables);
300	}	300	}
301	}	301	}
302	}	302	}
303	}	303	}
304		304
305	function Module_OnChange(full_id, available)	305	function Module_OnChange(full_id, available)
306	{	306	{
307	var id_parts = full_id.split(":", 2);	307	var id_parts = full_id.split(":", 2);
308	var aliases_data = {};	308	var aliases_data = {};
309		309
310	var aliases_data_all = Module_LookupAliases({	310	var aliases_data_all = Module_LookupAliases({
311	"module_name" : id_parts[0],	311	"module_name" : id_parts[0],
312	"module_id" : id_parts[1],	312	"module_id" : id_parts[1],
313	"group" : false	313	"group" : false
314	});	314	});
315		315
316	for (var alias_name in aliases_data)	316	for (var alias_name in aliases_data)
317	{	317	{
318	var ok = true;	318	var ok = true;
319		319
320	if (aliases_data[alias_name]["specific"])	320	if (aliases_data[alias_name]["specific"])
321	{	321	{
322	var ok = true;	322	var ok = true;
323		323
324	for (var name in variables)	324	for (var name in variables)
325	{	325	{
326	if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])	326	if (aliases_data[alias_name]["specific"][name] && aliases_data[alias_name]["specific"][name] != variables[name])
327	{	327	{
328	ok = false;	328	ok = false;
329	break;	329	break;
330	}	330	}
331	}	331	}
332	}	332	}
333		333
334	if (Module_OnChangeFunctions[alias_name] && ok)	334	if (Module_OnChangeFunctions[alias_name] && ok)
335	{	335	{
336	for (var n in Module_OnChangeFunctions[alias_name])	336	for (var n in Module_OnChangeFunctions[alias_name])
337	{	337	{
338	Module_OnChangeFunctions[alias_name][n](alias_name, available);	338	Module_OnChangeFunctions[alias_name][n](alias_name, available);
339	}	339	}
340	}	340	}
341	}	341	}
342	}	342	}
343		343

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom1.5/script/plugin/module.js – Rev 1647 → 1648