123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303 |
- {
-
- 'interfaces': [{'method':'POST', 'url=':'/exportmtoppdevs'}],
- 'csworker':
- function(resp, method, uri, reqData, wcontext) {
- var actions = [__wHttpReq('GET', '/current.model?wid=' + wcontext.__aswid)];
- _do.chain(actions) (
- function(asdata) {
- var writeActions = [_fspp.mkdirs('./exported_to_pypdevs/')];
- _do.chain(writeActions) (
- function() {
- var file_contents = '',
- as = _utils.jsonp(asdata['data']),
- type_map = {},
- type_map_keys = {},
- incoming = {},
- outgoing = {};
-
- file_contents += 'import sys\n'
- file_contents += 'sys.path.append("../../pypdevs/src/")\n\n'
- file_contents += 'from DEVS import *\n'
- file_contents += 'from infinity import INFINITY\n'
- file_contents += 'from util import *\n\n'
-
- for (var key in as.nodes) {
- var node = as.nodes[key];
- if (!(node['$type'] in type_map)) {
- type_map[node['$type']] = [];
- type_map_keys[node['$type']] = [];
- }
- type_map[node['$type']].push(node);
- type_map_keys[node['$type']].push(key);
- node['$key'] = key;
- }
-
- function safe_add(l, el) {
- if (l.indexOf(el) == -1) {
- l.push(el);
- }
- }
-
- function calc_in_out_rel(rel_type) {
- for (var idx in type_map_keys[rel_type]) {
- key = type_map_keys[rel_type][idx];
- incoming[key] = [];
- outgoing[key] = [];
- for (var e_key in as.edges) {
- var e = as.edges[e_key];
- if (e['dest'] == key) {
- safe_add(incoming[key], e['src'])
- if (!(e['src'] in outgoing)) {
- outgoing[e['src']] = [];
- }
- safe_add(outgoing[e['src']], key);
- }
- if (e['src'] == key) {
- safe_add(outgoing[key], e['dest'])
- if (!(e['dest'] in incoming)) {
- incoming[e['dest']] = [];
- }
- safe_add(incoming[e['dest']], key);
- }
- }
- }
- }
-
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/states');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/ports');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/channel');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/statedef');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/submodels');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/ExternalTransition');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/InternalTransition');
- calc_in_out_rel('/Formalisms/ParallelDEVS/ParallelDEVS/ConfluentTransition');
-
- for (var key in type_map['/Formalisms/ParallelDEVS/ParallelDEVS/StateDefinition']) {
- var node = type_map['/Formalisms/ParallelDEVS/ParallelDEVS/StateDefinition'][key],
- list_of_params = ['name=""'].concat(node['parameters']['value'].map(function(el) {return el['name'] + '=None'})),
- list_of_param_names = ['name'].concat(node['parameters']['value'].map(function(el) {return el['name']})),
- list_of_attrs = [['name', '']].concat(node['attributes']['value'].map(function(el) {return [el['name'], el['default']]}));
- file_contents += 'class ' + node['name']['value'] + ':\n';
- file_contents += '\tdef __init__(self, ' + list_of_params.join(', ') + '):\n';
- file_contents += list_of_attrs.map(function(el) {return '\t\tself.' + el[0] + ' = ' + (list_of_param_names.indexOf(el[0]) != -1 ? el[0] : el[1])}).join('\n') + "\n";
- file_contents += node['__init__']['value'].split('\n').map(function(line) {return '\t\t' + line}).join('\n');
- file_contents += '\n\n';
- }
-
- for (var key in type_map['/Formalisms/ParallelDEVS/ParallelDEVS/Event']) {
- var node = type_map['/Formalisms/ParallelDEVS/ParallelDEVS/Event'][key],
- list_of_params = (node['parameters']['value'].map(function(el) {return el['name'] + '=None'})),
- list_of_param_names = (node['parameters']['value'].map(function(el) {return el['name']})),
- list_of_attrs = (node['attributes']['value'].map(function(el) {return [el['name'], el['default']]}));
- file_contents += 'class ' + node['name']['value'] + ':\n';
- file_contents += '\tdef __init__(self, ' + list_of_params.join(', ') + '):\n';
- file_contents += list_of_attrs.map(function(el) {return '\t\tself.' + el[0] + ' = ' + (list_of_param_names.indexOf(el[0]) != -1 ? el[0] : el[1])}).join('\n') + "\n";
- file_contents += node['__init__']['value'].split('\n').map(function(line) {return '\t\t' + line}).join('\n');
- file_contents += '\n\n';
- file_contents += '\tdef __str__(self):\n';
- file_contents += '\t\treturn "' + node['name']['value'] + '(" + ' + list_of_attrs.map(function(el) {return 'str(self.' + el[0] + ')'}).join(' + ", " + ') + ' + ")"';
- file_contents += '\n\n';
- }
-
- for (var idx in type_map['/Formalisms/ParallelDEVS/ParallelDEVS/AtomicDEVS']) {
- var node = type_map['/Formalisms/ParallelDEVS/ParallelDEVS/AtomicDEVS'][idx],
- list_of_params = (node['parameters']['value'].map(function(el) {return el['name'] + '=None'})),
- list_of_param_names = (node['parameters']['value'].map(function(el) {return el['name']})),
- list_of_attrs = (node['attributes']['value'].map(function(el) {return [el['name'], el['default']]}));
- file_contents += 'class ' + node['name']['value'] + '(AtomicDEVS):\n';
- file_contents += '\tdef __init__(' + (['self', 'name="' + node['name']['value'] + '"'].concat(list_of_params).join(', ')) + '):\n';
- file_contents += '\t\tAtomicDEVS.__init__(self, name)\n';
- file_contents += list_of_attrs.map(function(el) {return '\t\tself.' + el[0] + ' = ' + (list_of_param_names.indexOf(el[0]) != -1 ? el[0] + ' if ' + el[0] + ' is not None else ' + el[1] : el[1])}).join('\n');
- file_contents += '\n';
- key = type_map_keys['/Formalisms/ParallelDEVS/ParallelDEVS/AtomicDEVS'][idx];
- statedef = as.nodes[outgoing[outgoing[key].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/statedef'})[0]][0]];
- states = outgoing[key].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/states'}).map(function(statesid) {return outgoing[statesid][0]}).map(function(sid) {return as.nodes[sid]});
- defstate = states.filter(function(el) {return el['initial']['value']})[0]
- list_of_assigns = ['name="' + defstate['name']['value'] + '"'].concat(statedef['initial_binding']['value'].map(function(el) {return el['name'] + '=' + el['val']}))
- file_contents += '\t\tself.state = ' + statedef['name']['value'] + '(' + list_of_assigns.join(', ') + ')\n';
- file_contents += node['__init__']['value'].split('\n').map(function(line) {return '\t\t' + line}).join('\n') + "\n";
- ports = outgoing[key].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/ports'}).map(function(portsid) {return outgoing[portsid][0]}).map(function(pid) {return as.nodes[pid]});
- file_contents += '\t\tself.my_ports = {' + ports.map(function(el) {return '"' + el['name']['value'] + '": ' + (el['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/OutputPort' ? 'self.addOutPort("' : 'self.addInPort("') + el['name']['value'] + '")'}).join(', ') + '}\n\n'
- file_contents += '\tdef timeAdvance(self):\n'
- file_contents += states.map(function(s) {return '\t\tif self.state.name == "' + s['name']['value'] + '":\n' + s['time_advance']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n')}).join('\n')
- file_contents += '\n\n';
- file_contents += '\tdef outputFnc(self):\n'
- file_contents += '\t\tdef subfunc(self):\n'
- file_contents += states.map(function(s) {return '\t\t\tif self.state.name == "' + s['name']['value'] + '":\n' + (s['output']['value'] == '' ? ['\t\t\t\treturn {}'] : s['output']['value'].split('\n').map(function(line) {return '\t\t\t\t' + line}).join('\n'))}).join('\n') + "\n";
- file_contents += '\t\treturn {self.my_ports[k]: v for k, v in subfunc(self).iteritems()}\n';
- file_contents += '\n\n';
- file_contents += '\tdef intTransition(self):\n'
- var content = false;
- for (var sidx in states) {
- s = states[sidx];
- if (outgoing[s['$key']]) {
- internals = outgoing[s['$key']].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/InternalTransition'}).map(function(tid) {return as.nodes[tid]});
- for (var iidx in internals) {
- content = true;
- internal = internals[iidx];
- var target = as.nodes[outgoing[internal['$key']][0]],
- cond_name = 'cond_int_' + s['name']['value'] + '_to_' + target['name']['value'],
- action_name = 'action_int_' + s['name']['value'] + '_to_' + target['name']['value'];
- file_contents += '\t\t\def ' + cond_name + '():\n';
- file_contents += internal['condition']['value'] == '' ? '\t\t\treturn True' : internal['condition']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\t\def ' + action_name + '():\n';
- file_contents += internal['action']['value'] == '' ? '\t\t\treturn {}' : internal['action']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\tif self.state.name == "' + s['name']['value'] + '" and ' + cond_name + '():\n';
- file_contents += '\t\t\treturn ' + statedef['name']['value'] + '(name="' + target['name']['value'] + '", **' + action_name + '())\n\n';
- }
- }
- }
- if (!content) {
- file_contents += '\t\treturn AtomicDEVS.intTransition(self)\n';
- } else {
- file_contents += '\t\telse:\n';
- file_contents += '\t\t\treturn AtomicDEVS.intTransition(self)\n';
- }
- file_contents += '\n';
- file_contents += '\tdef extTransition(self, my_inputs):\n'
- file_contents += '\t\tinputs = {k.getPortName(): v for k, v in my_inputs.iteritems()}\n'
- content = false;
- for (var sidx in states) {
- s = states[sidx];
- if (outgoing[s['$key']]) {
- externals = outgoing[s['$key']].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/ExternalTransition'}).map(function(tid) {return as.nodes[tid]});
- for (var iidx in externals) {
- content = true;
- external = externals[iidx];
- var target = as.nodes[outgoing[external['$key']][0]],
- cond_name = 'cond_ext_' + s['name']['value'] + '_to_' + target['name']['value'],
- action_name = 'action_ext_' + s['name']['value'] + '_to_' + target['name']['value'];
- file_contents += '\t\t\def ' + cond_name + '():\n';
- file_contents += external['condition']['value'] == '' ? '\t\t\treturn True' : external['condition']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\t\def ' + action_name + '():\n';
- file_contents += external['action']['value'] == '' ? '\t\t\treturn {}' : external['action']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\tif self.state.name == "' + s['name']['value'] + '" and ' + cond_name + '():\n';
- file_contents += '\t\t\treturn ' + statedef['name']['value'] + '(name="' + target['name']['value'] + '", **' + action_name + '())\n\n';
- }
- }
- }
- if (!content) {
- file_contents += '\t\treturn AtomicDEVS.extTransition(self, my_inputs)\n';
- } else {
- file_contents += '\t\telse:\n';
- file_contents += '\t\t\treturn AtomicDEVS.extTransition(self, my_inputs)\n';
- }
- file_contents += '\n'
- file_contents += '\tdef confTransition(self, my_inputs):\n'
- file_contents += '\t\tinputs = {k.getPortName(): v for k, v in my_inputs.iteritems()}\n'
- content = false;
- for (var sidx in states) {
- s = states[sidx];
- confluents = outgoing[s['$key']].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/ConfluentTransition'}).map(function(tid) {return as.nodes[tid]});
- for (var iidx in confluents) {
- content = true;
- confluent = confluents[iidx];
- var target = as.nodes[outgoing[confluent['$key']][0]],
- cond_name = 'cond_conf_' + s['name']['value'] + '_to_' + target['name']['value'],
- action_name = 'action_conf_' + s['name']['value'] + '_to_' + target['name']['value'];
- file_contents += '\t\t\def ' + cond_name + '():\n';
- file_contents += confluent['condition']['value'] == '' ? '\t\t\treturn True' : confluent['condition']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\t\def ' + action_name + '():\n';
- file_contents += confluent['action']['value'] == '' ? '\t\t\treturn {}' : confluent['action']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\t\tif self.state.name == "' + s['name']['value'] + '" and ' + cond_name + '():\n';
- file_contents += '\t\t\treturn ' + statedef['name']['value'] + '(name="' + target['name']['value'] + '", **' + action_name + '())\n\n';
- }
- }
- if (!content) {
- file_contents += '\t\treturn AtomicDEVS.confTransition(self, my_inputs)\n';
- } else {
- file_contents += '\t\telse:\n';
- file_contents += '\t\t\treturn AtomicDEVS.confTransition(self, my_inputs)\n';
- }
- file_contents += '\n'
- }
-
- for (var idx in type_map['/Formalisms/ParallelDEVS/ParallelDEVS/CoupledDEVS']) {
- var node = type_map['/Formalisms/ParallelDEVS/ParallelDEVS/CoupledDEVS'][idx],
- list_of_params = (node['parameters']['value'].map(function(el) {return el['name'] + '=None'})),
- list_of_param_names = (node['parameters']['value'].map(function(el) {return el['name']})),
- list_of_attrs = (node['attributes']['value'].map(function(el) {return [el['name'], el['default']]}));
- file_contents += 'class ' + node['name']['value'] + '(CoupledDEVS):\n';
- file_contents += '\tdef __init__(' + (['self', 'name="' + node['name']['value'] + '"'].concat(list_of_params).join(', ')) + '):\n';
- file_contents += '\t\tCoupledDEVS.__init__(self, name)\n';
- file_contents += list_of_attrs.map(function(el) {return '\t\tself.' + el[0] + ' = ' + (list_of_param_names.indexOf(el[0]) != -1 ? el[0] : el[1])}).join('\n') + "\n";
- file_contents += node['__init__']['value'].split('\n').map(function(line) {return '\t\t' + line}).join('\n') + "\n";
- key = type_map_keys['/Formalisms/ParallelDEVS/ParallelDEVS/CoupledDEVS'][idx];
- ports = outgoing[key].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/ports'}).map(function(portsid) {return outgoing[portsid][0]}).map(function(pid) {return as.nodes[pid]});
- file_contents += '\t\tself.my_ports = {' + ports.map(function(el) {return '"' + el['name']['value'] + '": ' + (el['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/OutputPort' ? 'self.addOutPort("' : 'self.addInPort("') + el['name']['value'] + '")'}).join(', ') + '}\n'
- file_contents += '\t\tself.submodels = {}\n';
- submodels = outgoing[key].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/submodels'}).map(function(submodelsid) {return outgoing[submodelsid][0]}).map(function(mid) {return as.nodes[mid]});
- file_contents += submodels.map(function(m) {return '\t\tself.submodels["' + m['name']['value'] + '"] = self.addSubModel(' + m['devs_type']['value'] + '(' + ['name="' + m['name']['value'] + '"'].concat(m['parameter_binding']['value'].map(function(pb) {return pb['name'] + '=' + pb['val']})).join(', ') + '))'}).join('\n');
- file_contents += '\n\n';
- myportkeys = ports.map(function(port) {return port['$key']});
- port_to_m = {};
- m_to_ports = {};
- m_to_ports[key] = ports;
- ports.forEach(function(p) {port_to_m[p['$key']] = node});
- for (var skey in submodels) {
- var m = submodels[skey];
- m_to_ports[m['$key']] = [];
- ports = outgoing[m['$key']].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/ports'}).map(function(portsid) {return outgoing[portsid][0]}).map(function(pid) {return as.nodes[pid]});
- ports.forEach(function(p) {port_to_m[p['$key']] = m; m_to_ports[m['$key']].push(p);});
- }
- for (var mkey in m_to_ports) {
- for (var pidx in m_to_ports[mkey]) {
- var p = m_to_ports[mkey][pidx],
- pkey = p['$key'];
- if (pkey in outgoing) {
- var conns = outgoing[pkey].filter(function(el) {return as.nodes[el]['$type'] == '/Formalisms/ParallelDEVS/ParallelDEVS/channel'}).map(function(channelid) {return as.nodes[channelid]})
- for (var cidx in conns) {
- var conn = conns[cidx],
- target = as.nodes[outgoing[conn['$key']][0]],
- transfname = 'transfer_' + as.nodes[mkey]['name']['value'] + '_' + as.nodes[pkey]['name']['value'] + '_to_' + target['name']['value'],
- fromportstr = (mkey == key ? 'self' : 'self.submodels["' + as.nodes[mkey]['name']['value'] + '"]') + '.my_ports["' + as.nodes[pkey]['name']['value'] + '"]',
- toportstr = (port_to_m[target['$key']]['$key'] == key ? 'self' : 'self.submodels["' + port_to_m[target['$key']]['name']['value'] + '"]') + '.my_ports["' + target['name']['value'] + '"]';
- if (conn['transfer_function']['value'] != '') {
- file_contents += '\t\tdef ' + transfname + '(event):\n';
- file_contents += conn['transfer_function']['value'].split('\n').map(function(line) {return '\t\t\t' + line}).join('\n');
- file_contents += '\n\n';
- file_contents += '\t\tself.connectPorts(' + fromportstr + ', ' + toportstr + ', ' + transfname + ')\n\n';
- } else {
- file_contents += '\t\tself.connectPorts(' + fromportstr + ', ' + toportstr + ')\n';
- }
- }
- }
- }
- }
- file_contents += '\n';
- }
-
- _fs.writeFileSync('./exported_to_pypdevs/model.py', file_contents);
-
- file_contents = 'import sys\n';
- file_contents += 'sys.path.append("../../pypdevs/src/")\n\n';
- file_contents += 'from DEVS import *\n';
- file_contents += 'from model import *\n';
- file_contents += 'from python_runtime.statecharts_core import Event\n';
- file_contents += 'from sccd import Controller\n\n';
- file_contents += 'def termination_condition(time, model, transitioned):\n';
- file_contents += '\ttime = time[0]\n';
- file_contents += type_map['/Formalisms/ParallelDEVS/ParallelDEVS/Simulation'][0]['end_condition']['value'].split('\n').map(function(line) {return '\t' + line}).join('\n') + '\n';
-
- _fs.writeFileSync('./exported_to_pypdevs/experiment.py', file_contents);
-
- __postMessage({'statusCode': 200,
- 'respIndex': resp});
- },
- function(writeErr) {__postInternalErrorMsg(resp, writeErr);}
- );
- },
- function(err) {__postInternalErrorMsg(resp, err);}
- )
- },
- 'asworker':
- function(resp, method, uri, reqData, wcontext)
- {
- __postMessage(
- {'statusCode': 200,
- 'respIndex': resp});
- }
- }
|