model_management.alc 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362
  1. include "primitives.alh"
  2. include "io.alh"
  3. include "object_operations.alh"
  4. include "constructors.alh"
  5. include "metamodels.alh"
  6. include "library.alh"
  7. include "modelling.alh"
  8. include "utils.alh"
  9. Element function model_fuse(models : Element):
  10. Element new_model
  11. Element tagged_model
  12. String model_name
  13. Element model
  14. Element keys
  15. Element second_keys
  16. String key
  17. Element selected_MM
  18. String type
  19. Element reverse
  20. Integer prev_length
  21. // Read out some data first
  22. if (set_len(models) == 0):
  23. log("Cannot fuse empty set of models!")
  24. return read_root()!
  25. tagged_model = set_read(models)
  26. new_model = instantiate_model(tagged_model[1]["metamodel"])
  27. // Do the iteration
  28. while (set_len(models) > 0):
  29. tagged_model = set_pop(models)
  30. model_name = string_join(list_read(tagged_model, 0), "/")
  31. model = list_read(tagged_model, 1)
  32. reverse = make_reverse_dictionary(model["model"])
  33. // Add all elements from 'model', but prepend it with the 'model_name'
  34. keys = dict_keys(model["model"])
  35. second_keys = set_create()
  36. prev_length = -1
  37. while (set_len(keys) > 0):
  38. key = set_pop(keys)
  39. type = read_type(model, key)
  40. if (is_edge(model["model"][key])):
  41. String src
  42. String dst
  43. src = string_join(model_name, reverse[cast_id(read_edge_src(model["model"][key]))])
  44. dst = string_join(model_name, reverse[cast_id(read_edge_dst(model["model"][key]))])
  45. if (bool_and(dict_in(new_model["model"], src), dict_in(new_model["model"], dst))):
  46. instantiate_link(new_model, type, model_name + key, src, dst)
  47. else:
  48. set_add(second_keys, key)
  49. elif (has_value(model["model"][key])):
  50. instantiate_value(new_model, type, model_name + key, model["model"][key])
  51. else:
  52. instantiate_node(new_model, type, model_name + key)
  53. if (set_len(keys) == 0):
  54. if (set_len(second_keys) == prev_length):
  55. log("Cannot terminate model_fuse due to infinite recursion!")
  56. return read_root()!
  57. keys = second_keys
  58. second_keys = set_create()
  59. prev_length = set_len(keys)
  60. return new_model!
  61. Element function model_copy(src_model : Element):
  62. Element dst_model
  63. Element name
  64. Element keys
  65. Element second_keys
  66. String type
  67. Integer prev_length
  68. Element reverse
  69. reverse = make_reverse_dictionary(src_model["model"])
  70. dst_model = instantiate_model(src_model["metamodel"])
  71. keys = dict_keys(src_model["model"])
  72. second_keys = set_create()
  73. prev_length = -1
  74. while (set_len(keys) > 0):
  75. name = set_pop(keys)
  76. if (is_edge(src_model["model"][name])):
  77. // Is an edge, so potentially queue it
  78. String src
  79. String dst
  80. src = reverse[cast_id(read_edge_src(src_model["model"][name]))]
  81. dst = reverse[cast_id(read_edge_dst(src_model["model"][name]))]
  82. type = read_type(src_model, name)
  83. if (bool_and(dict_in(dst_model["model"], src), dict_in(dst_model["model"], dst))):
  84. // All present, so create the link between them
  85. instantiate_link(dst_model, type, name, src, dst)
  86. else:
  87. set_add(second_keys, name)
  88. elif (has_value(src_model["model"][name])):
  89. // Has a value, so copy that as well
  90. type = read_type(src_model, name)
  91. instantiate_value(dst_model, type, name, src_model["model"][name])
  92. else:
  93. // Is a node
  94. type = read_type(src_model, name)
  95. instantiate_node(dst_model, type, name)
  96. if (set_len(keys) == 0):
  97. if (set_len(second_keys) == prev_length):
  98. log("Cannot terminate model_copy due to infinite recursion!")
  99. return read_root()!
  100. keys = second_keys
  101. second_keys = set_create()
  102. prev_length = set_len(keys)
  103. return dst_model!
  104. Element function model_join(models : Element, metamodel : Element, tracability_model : Element):
  105. Element new_model
  106. Element tagged_model
  107. String retyping_key
  108. Element elem_map
  109. Element model
  110. Element keys
  111. String new_name
  112. Element second_keys
  113. String src
  114. String dst
  115. String key
  116. String type
  117. Integer prev_length
  118. new_model = instantiate_model(metamodel)
  119. elem_map = dict_create()
  120. Element retyping_keys
  121. retyping_keys = set_create()
  122. // Do the iteration
  123. while (set_len(models) > 0):
  124. tagged_model = set_pop(models)
  125. retyping_key = string_join(list_read(tagged_model, 0), "/")
  126. model = list_read(tagged_model, 1)
  127. set_add(retyping_keys, retyping_key)
  128. // Add all elements from 'model'
  129. keys = dict_keys(model["model"])
  130. second_keys = set_create()
  131. prev_length = -1
  132. while (set_len(keys) > 0):
  133. // Copy the new element
  134. key = set_pop(keys)
  135. type = read_type(model, key)
  136. new_name = retyping_key + key
  137. if (is_edge(model["model"][key])):
  138. src = cast_id(read_edge_src(model["model"][key]))
  139. dst = cast_id(read_edge_dst(model["model"][key]))
  140. if (bool_and(dict_in(elem_map, src), dict_in(elem_map, dst))):
  141. new_name = instantiate_link(new_model, retyping_key + type, new_name, elem_map[src], elem_map[dst])
  142. else:
  143. set_add(second_keys, key)
  144. new_name = ""
  145. elif (has_value(model["model"][key])):
  146. new_name = instantiate_value(new_model, retyping_key + type, new_name, model["model"][key])
  147. else:
  148. new_name = instantiate_node(new_model, retyping_key + type, new_name)
  149. if (new_name != ""):
  150. // Add the new name to a map which registers the mapping to the new name
  151. dict_add_fast(elem_map, cast_id(model["model"][key]), new_name)
  152. if (set_len(keys) == 0):
  153. if (set_len(second_keys) == prev_length):
  154. log("Cannot terminate model_join due to infinite recursion!")
  155. return read_root()!
  156. keys = second_keys
  157. second_keys = set_create()
  158. prev_length = set_len(keys)
  159. // Now link in the tracability model
  160. // Go over all TracabilityLink elements and connect them in the merged model as well
  161. if (element_neq(tracability_model, read_root())):
  162. Element tracability_links
  163. String tracability_link
  164. String new_name_src
  165. String new_name_dst
  166. String src_name
  167. String dst_name
  168. Element src_models
  169. String src_model
  170. Element dst_models
  171. String dst_model
  172. tracability_links = allInstances(tracability_model, "TracabilityLink")
  173. while (set_len(tracability_links) > 0):
  174. tracability_link = set_pop(tracability_links)
  175. src_name = read_attribute(tracability_model, readAssociationSource(tracability_model, tracability_link), "name")
  176. dst_name = read_attribute(tracability_model, readAssociationDestination(tracability_model, tracability_link), "name")
  177. type = read_attribute(tracability_model, tracability_link, "type")
  178. // Now try to find all possible combinations
  179. // that is, find all models for which src_name exists, and all models for which dst_name exists, and connect them
  180. src_models = set_copy(retyping_keys)
  181. while (set_len(src_models) > 0):
  182. src_model = set_pop(src_models)
  183. if (dict_in(new_model["model"], src_model + src_name)):
  184. // This element exists for this source model
  185. dst_models = set_copy(retyping_keys)
  186. while (set_len(dst_models) > 0):
  187. dst_model = set_pop(dst_models)
  188. if (dict_in(new_model["model"], dst_model + dst_name)):
  189. // Found a match for source and target, so create a link
  190. new_name = instantiate_link(new_model, type, "", src_model + src_name, dst_model + dst_name)
  191. if (new_name == ""):
  192. log("ERROR: could not create a tracability link; ignoring")
  193. return new_model!
  194. Element function model_split(merged_model : Element, models : Element, tracability : Boolean):
  195. if (set_len(models) == 0):
  196. // No results needed, so stop immediately unless tracability is True
  197. if (bool_not(tracability)):
  198. return dict_create()!
  199. Element result
  200. Element metamodel
  201. Element model_tuple
  202. Element tracability_model
  203. Element keys
  204. String key
  205. String src
  206. String dst
  207. Element reverse
  208. Element mapping
  209. String retyping_key
  210. String original_type
  211. Element elem
  212. Element second_keys
  213. String type
  214. Element splitted
  215. String source
  216. String target
  217. String link
  218. String src_name
  219. String dst_name
  220. String new_name
  221. Integer prev_length
  222. result = dict_create()
  223. tracability_model = instantiate_model(import_node("models/Tracability"))
  224. reverse = make_reverse_dictionary(merged_model["model"])
  225. mapping = dict_create()
  226. second_keys = set_create()
  227. prev_length = -1
  228. while (set_len(models) > 0):
  229. model_tuple = set_pop(models)
  230. retyping_key = model_tuple[0]
  231. metamodel = model_tuple[1]
  232. dict_add_fast(result, retyping_key, instantiate_model(metamodel))
  233. keys = dict_keys(merged_model["model"])
  234. while (set_len(keys) > 0):
  235. key = set_pop(keys)
  236. elem = merged_model["model"][key]
  237. type = read_type(merged_model, key)
  238. splitted = string_split_nr(type, "/", 1)
  239. if (list_len(splitted) == 1):
  240. // Only one, so no split possible
  241. // Indicates a tracability element!
  242. if (bool_and(tracability, is_edge(elem))):
  243. // Got a tracability link!
  244. // Is always an edge (for now?)
  245. // Find out source and target and hope that they are already present
  246. src = reverse[cast_id(read_edge_src(elem))]
  247. dst = reverse[cast_id(read_edge_dst(elem))]
  248. // All present, so create the link between them
  249. src_name = list_pop_final(string_split_nr(src, "/", 1))
  250. dst_name = list_pop_final(string_split_nr(dst, "/", 1))
  251. source = instantiate_node(tracability_model, "Reference", "")
  252. target = instantiate_node(tracability_model, "Reference", "")
  253. instantiate_attribute(tracability_model, source, "name", src_name)
  254. instantiate_attribute(tracability_model, target, "name", dst_name)
  255. link = instantiate_link(tracability_model, "TracabilityLink", "", source, target)
  256. instantiate_attribute(tracability_model, link, "type", type)
  257. else:
  258. retyping_key = splitted[0]
  259. if (list_len(string_split(key, "/")) > 1):
  260. new_name = list_read(string_split_nr(key, "/", 1), 1)
  261. else:
  262. new_name = key
  263. if (dict_in(result, retyping_key)):
  264. original_type = splitted[1]
  265. if (is_edge(elem)):
  266. // Is an edge, so potentially queue it
  267. src = reverse[cast_id(read_edge_src(elem))]
  268. dst = reverse[cast_id(read_edge_dst(elem))]
  269. if (bool_and(dict_in(mapping, src), dict_in(mapping, dst))):
  270. // All present, so create the link between them
  271. // Though we first check the model to which it was mapped, as this should be the same as we have now
  272. if (bool_and(dict_in(result[retyping_key]["model"], mapping[src]), dict_in(result[retyping_key]["model"], mapping[dst]))):
  273. // The matching worked fine
  274. dict_add_fast(mapping, key, instantiate_link(result[retyping_key], original_type, new_name, mapping[src], mapping[dst]))
  275. else:
  276. log("ERROR mapping: source/target mapped to model, but not found in expected model; ignoring")
  277. else:
  278. // Still source or destination in the queue, so we wait for that
  279. set_add(second_keys, key)
  280. elif (has_value(elem)):
  281. // Has a value, so copy that as well
  282. dict_add_fast(mapping, key, instantiate_value(result[retyping_key], original_type, new_name, elem))
  283. else:
  284. // Is a node
  285. dict_add_fast(mapping, key, instantiate_node(result[retyping_key], original_type, new_name))
  286. if (set_len(keys) == 0):
  287. if (set_len(second_keys) == prev_length):
  288. log("Cannot terminate model_split due to infinite recursion!")
  289. return read_root()!
  290. keys = second_keys
  291. second_keys = set_create()
  292. prev_length = set_len(keys)
  293. // Finally, we also add tracability information as a separate model
  294. if (tracability):
  295. dict_add_fast(result, "__tracability", tracability_model)
  296. log("Tracability model created with # links = " + cast_value(dict_len(tracability_model["model"])))
  297. return result!