modelverse.py 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444
  1. from sccd.runtime.statecharts_core import Event
  2. import sccd.runtime.socket2event as socket2event
  3. import modelverse_SCCD
  4. import time
  5. controller = modelverse_SCCD.Controller()
  6. socket2event.boot_translation_service(controller)
  7. ID = 0
  8. # Exceptions
  9. class ModelverseException(Exception):
  10. pass
  11. class UnknownError(ModelverseException):
  12. pass
  13. class UnknownIdentifier(ModelverseException):
  14. pass
  15. class CompilationError(ModelverseException):
  16. pass
  17. class NoSuchAttribute(ModelverseException):
  18. pass
  19. class UnknownModel(ModelverseException):
  20. pass
  21. class ConnectionError(ModelverseException):
  22. pass
  23. class ModelExists(ModelverseException):
  24. pass
  25. class PermissionDenied(ModelverseException):
  26. pass
  27. class InvalidMode(ModelverseException):
  28. pass
  29. class InterfaceMismatch(ModelverseException):
  30. pass
  31. class UnknownMetamodellingHierarchy(ModelverseException):
  32. pass
  33. def run_controller():
  34. try:
  35. controller.start()
  36. finally:
  37. controller.stop()
  38. def _next_ID():
  39. global ID
  40. ID += 1
  41. return ID
  42. def INPUT(action, context, parameters):
  43. print("Executing " + str(action))
  44. print("Parameters: " + str(parameters))
  45. print("In context: " + str(context))
  46. controller.addInput(Event("action", "action_in", [action, _next_ID(), context, parameters]))
  47. def OUTPUT():
  48. while 1:
  49. response = responses.fetch(-1)
  50. print("Got response with name: " + str(response.name))
  51. if response.name == "result":
  52. print("Value: " + str(response.parameters[1]))
  53. return response.parameters[1]
  54. elif response.name == "exception":
  55. print("Exception: " + str(response.parameters))
  56. if response.parameters[1] == "UnknownIdentifier":
  57. raise UnknownIdentifier()
  58. elif response.parameters[1] == "UnknownMetamodellingHierarchy":
  59. raise UnknownMetamodellingHierarchy()
  60. def init(address_param="127.0.0.1:8001", timeout=20.0):
  61. INPUT("init", None, [address_param, timeout])
  62. return OUTPUT()
  63. def login(username, password):
  64. INPUT("login", None, [username, password])
  65. return OUTPUT()
  66. def model_list(location):
  67. INPUT("model_list", None, [location])
  68. return OUTPUT()
  69. def model_add(model_name, metamodel_name, model_code=""):
  70. INPUT("model_add", None, [model_name, metamodel_name, model_code])
  71. return OUTPUT()
  72. def model_delete(model_name):
  73. INPUT("model_delete", None, [model_name])
  74. return OUTPUT()
  75. def model_list_full(location):
  76. INPUT("model_list_full", None, [location])
  77. return OUTPUT()
  78. def verify(model_name, metamodel_name):
  79. INPUT("verify", None, [model_name, metamodel_name])
  80. return OUTPUT()
  81. def model_overwrite(model_name, new_model):
  82. INPUT("model_overwrite", None, [model_name, new_model])
  83. return OUTPUT()
  84. def disconnect():
  85. INPUT("disconnect", None, [])
  86. return OUTPUT()
  87. def user_logout():
  88. INPUT("user_logout", None, [])
  89. return OUTPUT()
  90. def user_delete():
  91. INPUT("user_delete", None, [])
  92. return OUTPUT()
  93. def model_render(model_name, mapper_name):
  94. INPUT("model_render", None, [model_name, mapper_name])
  95. return OUTPUT()
  96. def transformation_between(source, target):
  97. INPUT("transformation_between", None, [source, target])
  98. return OUTPUT()
  99. def transformation_add_MT(source_metamodels, target_metamodels, operation_name, code, callback=None):
  100. INPUT("transformation_add_MT", None, [source_metamodels, target_metamodels, operation_name, code])
  101. context = OUTPUT()
  102. if callback is not None:
  103. callback(context)
  104. print("Callback finished; sending exit")
  105. INPUT("exit", context, [])
  106. return OUTPUT()
  107. def transformation_add_AL(source_metamodels, target_metamodels, operation_name, code, callback=None):
  108. INPUT("transformation_add_AL", None, [source_metamodels, target_metamodels, operation_name, code])
  109. context = OUTPUT()
  110. if callback is not None:
  111. callback(context)
  112. INPUT("exit", context, [])
  113. return OUTPUT()
  114. def transformation_add_MANUAL(source_metamodels, target_metamodels, operation_name, callback=None):
  115. INPUT("transformation_add_MANUAL", None, [source_metamodels, target_metamodels, operation_name])
  116. context = OUTPUT()
  117. if callback is not None:
  118. print("DOING CALLBACK FOR MANUAL")
  119. callback(context)
  120. print("CALLBACK FINISHED")
  121. INPUT("exit", context, [])
  122. return OUTPUT()
  123. def transformation_execute_MT(operation_name, input_models_dict, output_models_dict, statechart=None):
  124. if statechart is not None:
  125. port_sc = statechart[0].addOutputListener(statechart[2])
  126. INPUT("transformation_execute_MT", None, [operation_name, input_models_dict, output_models_dict])
  127. context = OUTPUT()
  128. if statechart is not None:
  129. while 1:
  130. empty = True
  131. # Fetch output from the MV
  132. response = responses.fetch(0)
  133. if response is not None:
  134. print("Got response from MV: " + str(response))
  135. if response.name == "data_output":
  136. # Got output of MV, so forward to SCCD
  137. statechart[0].addInput(Event("input", statechart[1], response.parameters))
  138. elif response.name == "result":
  139. # Finished execution, so continue and return result
  140. statechart[0].addInput(Event("terminate", statechart[1], []))
  141. return response.parameters[1]
  142. empty = False
  143. # Fetch output from the SC
  144. response = port_sc.fetch(0)
  145. if response is not None:
  146. print("Got response from SC: " + str(response))
  147. if response.name == "output":
  148. controller.addInput(Event("data_input", "action_in", [response.parameters, context]))
  149. empty = False
  150. if empty:
  151. time.sleep(0.01)
  152. else:
  153. return OUTPUT()
  154. def transformation_execute_AL(operation_name, input_models_dict, output_models_dict, statechart=None):
  155. if statechart is not None:
  156. port_sc = statechart[0].addOutputListener(statechart[2])
  157. INPUT("transformation_execute_AL", None, [operation_name, input_models_dict, output_models_dict])
  158. context = OUTPUT()
  159. if statechart is not None:
  160. while 1:
  161. empty = True
  162. # Fetch output from the MV
  163. response = responses.fetch(0)
  164. if response is not None:
  165. print("Got response from MV: " + str(response))
  166. if response.name == "data_output":
  167. # Got output of MV, so forward to SCCD
  168. statechart[0].addInput(Event("input", statechart[1], response.parameters))
  169. elif response.name == "result":
  170. # Finished execution, so continue and return result
  171. statechart[0].addInput(Event("terminate", statechart[1], []))
  172. return response.parameters[1]
  173. empty = False
  174. # Fetch output from the SC
  175. response = port_sc.fetch(0)
  176. if response is not None:
  177. print("Got response from SC: " + str(response))
  178. if response.name == "output":
  179. controller.addInput(Event("data_input", "action_in", [response.parameters, context]))
  180. empty = False
  181. if empty:
  182. time.sleep(0.01)
  183. else:
  184. return OUTPUT()
  185. def transformation_execute_MANUAL(operation_name, input_models_dict, output_models_dict, callback=None):
  186. INPUT("transformation_execute_MANUAL", None, [operation_name, input_models_dict, output_models_dict])
  187. context = OUTPUT()
  188. if callback is not None:
  189. callback(context)
  190. INPUT("exit", context, [])
  191. return OUTPUT()
  192. def permission_modify(model_name, permissions):
  193. INPUT("permission_modify", None, [model_name, permissions])
  194. return OUTPUT()
  195. def permission_owner(model_name, permission):
  196. INPUT("permission_owner", None, [model_name, permission])
  197. return OUTPUT()
  198. def permission_group(model_name, group):
  199. INPUT("permission_group", None, [model_name, group])
  200. return OUTPUT()
  201. def group_create(group_name):
  202. INPUT("group_create", None, [group_name])
  203. return OUTPUT()
  204. def group_delete(group_name):
  205. INPUT("group_delete", None, [group_name])
  206. return OUTPUT()
  207. def group_owner_add(group_name, user_name):
  208. INPUT("group_owner_add", None, [group_name, user_name])
  209. return OUTPUT()
  210. def group_owner_delete(group_name, user_name):
  211. INPUT("group_owner_delete", None, [group_name, user_name])
  212. return OUTPUT()
  213. def group_join(group_name, user_name):
  214. INPUT("group_join", None, [group_name, user_name])
  215. return OUTPUT()
  216. def group_kick(group_name, user_name):
  217. INPUT("group_kick", None, [group_name, user_name])
  218. return OUTPUT()
  219. def group_list():
  220. INPUT("group_list", None, [])
  221. return OUTPUT()
  222. def admin_promote(user_name):
  223. INPUT("admin_promote", None, [user_name])
  224. return OUTPUT()
  225. def admin_demote(user_name):
  226. INPUT("admin_demote", None, [user_name])
  227. return OUTPUT()
  228. def conformance_delete(model_name, metamodel_name):
  229. INPUT("conformance_delete", None, [model_name, metamodel_name])
  230. return OUTPUT()
  231. def conformance_add(model_name, metamodel_name):
  232. INPUT("conformance_add", None, [model_name, metamodel_name])
  233. return OUTPUT()
  234. def folder_create(folder_name):
  235. INPUT("folder_create", None, [folder_name])
  236. return OUTPUT()
  237. def model_types(model_name):
  238. INPUT("model_types", None, [model_name])
  239. return OUTPUT()
  240. def alter_context(model_name, metamodel_name):
  241. INPUT("alter_context", None, [model_name, metamodel_name])
  242. return OUTPUT()
  243. def element_list(model_name, context=None):
  244. INPUT("element_list", context, [model_name])
  245. return OUTPUT()
  246. def element_list_nice(model_name, context=None):
  247. INPUT("element_list_nice", context, [model_name])
  248. return OUTPUT()
  249. def types(model_name, context=None):
  250. INPUT("types", context, [model_name])
  251. return OUTPUT()
  252. def types_full(model_name, context=None):
  253. INPUT("types_full", context, [model_name])
  254. return OUTPUT()
  255. def read_info(model_name, ID, context=None):
  256. INPUT("read_info", context, [model_name, ID])
  257. return OUTPUT()
  258. def read_attrs(model_name, ID, context=None):
  259. INPUT("read_attrs", context, [model_name, ID])
  260. return OUTPUT()
  261. def instantiate(model_name, typename, edge=None, ID="", context=None):
  262. INPUT("instantiate", context, [model_name, typename, edge, ID])
  263. return OUTPUT()
  264. def delete_element(model_name, ID, context=None):
  265. INPUT("delete_element", context, [model_name, ID])
  266. return OUTPUT()
  267. def attr_assign(model_name, ID, attr, value, context=None):
  268. INPUT("attr_assign", context, [model_name, ID, attr, value])
  269. return OUTPUT()
  270. def attr_assign_code(model_name, ID, attr, code, context=None):
  271. INPUT("attr_assign_code", context, [model_name, ID, attr, code])
  272. return OUTPUT()
  273. def attr_delete(model_name, ID, attr, context=None):
  274. INPUT("attr_delete", context, [model_name, ID, attr])
  275. return OUTPUT()
  276. def read_outgoing(model_name, ID, typename, context=None):
  277. INPUT("read_outgoing", context, [model_name, ID, typename])
  278. return OUTPUT()
  279. def read_incoming(model_name, ID, typename, context=None):
  280. INPUT("read_incoming", context, [model_name, ID, typename])
  281. return OUTPUT()
  282. def read_association_source(model_name, ID, context=None):
  283. INPUT("read_association_source", context, [model_name, ID])
  284. return OUTPUT()
  285. def read_association_destination(model_name, ID, context=None):
  286. INPUT("read_association_destination", context, [model_name, ID])
  287. return OUTPUT()
  288. def connections_between(model_name, source, target, context=None):
  289. INPUT("connections_between", context, [model_name, source, target])
  290. return OUTPUT()
  291. def define_attribute(model_name, node, attr_name, attr_type, context=None):
  292. INPUT("define_attribute", context, [model_name, node, attr_name, attr_type])
  293. return OUTPUT()
  294. def all_instances(model_name, type_name, context=None):
  295. INPUT("all_instances", context, [model_name, type_name])
  296. return OUTPUT()
  297. def process_execute(process_name, prefix, callbacks=None):
  298. # for all callbacks to SCs, start up the output port already
  299. sc_ports = {}
  300. for k, v in callbacks.items():
  301. if isinstance(v, (tuple, list)):
  302. # Is a statechart, so register already
  303. sc_ports[k] = v[0].addOutputListener(v[2])
  304. INPUT("process_execute", None, [process_name, prefix])
  305. #TODO this is all pseudo-code
  306. while 1:
  307. operation = OUTPUT()
  308. print("Operation: " + str(operation))
  309. if isinstance(operation, (list, tuple)):
  310. t, name, context = operation
  311. print("Executing operation of type %s with name %s in context %s" % (t, name, context))
  312. if t == "OP":
  313. if name in callbacks:
  314. callbacks[name](context)
  315. INPUT("exit", context, [])
  316. elif t == "SC":
  317. if name in callbacks:
  318. statechart = callbacks[name]
  319. while 1:
  320. empty = True
  321. # Fetch output from the MV
  322. response = responses.fetch(0)
  323. if response is not None:
  324. print("Got response from MV: " + str(response))
  325. if response.name == "data_output":
  326. # Got output of MV, so forward to SCCD
  327. statechart[0].addInput(Event("input", statechart[1], response.parameters))
  328. elif response.name == "result":
  329. # Finished execution, so continue and return result
  330. statechart[0].addInput(Event("terminate", statechart[1], []))
  331. return response.parameters[1]
  332. empty = False
  333. # Fetch output from the SC
  334. response = sc_ports[name].fetch(0)
  335. if response is not None:
  336. print("Got response from SC: " + str(response))
  337. if response.name == "output":
  338. controller.addInput(Event("data_input", "action_in", [response.parameters, context]))
  339. empty = False
  340. if empty:
  341. time.sleep(0.01)
  342. else:
  343. if operation == "Finished":
  344. # Finished execution of the process, so exit
  345. return None
  346. # TODO monitor the new function and execute the correct callback
  347. import threading
  348. thrd = threading.Thread(target=run_controller)
  349. thrd.daemon = True
  350. thrd.start()
  351. responses = controller.addOutputListener("action_out")
  352. controller.addOutputListener("ready").fetch(-1)