| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661 | 
							- from .utilities import prRed, prGreen, prPurple, prWhite, prOrange, \
 
-                         wrapRed, wrapGreen, wrapPurple, wrapWhite, wrapOrange
 
- from .utilities import get_node_prototype, class_for_mantis_prototype_node, \
 
-                         gen_nc_input_for_data
 
-     
 
- # BAD NAMES ahead, as these have nothing to do with NodeReroute nodes.
 
- def reroute_common(nc, nc_to, all_nc):
 
-     # we need to do this: go  to the to-node
 
-     # then reroute the link in the to_node all the way to the beginning
 
-     # so that the number of links in "real" nodes is unchanged
 
-     # then the links in the dummy nodes need to be deleted
 
-     # watch=False
 
-     # if nc.signature[-1] == 'NodeGroupOutput': watch=True
 
-     for inp_name, inp in nc.inputs.items():
 
-         # assume each input socket only has one input for now
 
-         if inp.is_connected:
 
-             while (inp.links):
 
-                 in_link = inp.links.pop()
 
-                 from_nc = in_link.from_node
 
-                 from_socket = in_link.from_socket
 
-                 links = []
 
-                 from_links = from_nc.outputs[from_socket].links.copy()
 
-                 while(from_links): # This is a weird way to do this HACK
 
-                     from_link = from_links.pop()
 
-                     if from_link == in_link:
 
-                         from_link.die()
 
-                         continue # DELETE the dummy node link 
 
-                     links.append(from_link)
 
-                 from_nc.outputs[from_socket].links = links
 
-                 down = nc_to.outputs[inp_name]
 
-                 for downlink in down.links:
 
-                     downlink.from_node = from_nc
 
-                     downlink.from_socket = from_socket
 
-                     from_nc.outputs[from_socket].links.append(downlink)
 
-                     if hasattr(downlink.to_node, "reroute_links"):
 
-                         # Recurse!
 
-                         downlink.to_node.reroute_links(downlink.to_node, all_nc)
 
-                 in_link.die()
 
- def reroute_links_grp(nc, all_nc):
 
-     if (nc_to := all_nc.get( ( *nc.signature, "NodeGroupInput") )):
 
-         reroute_common(nc, nc_to, all_nc)
 
-     else:
 
-         raise RuntimeError("Cannot read graph for some goshblamed son of a reason")
 
- def reroute_links_grpout(nc, all_nc):
 
-     if (nc_to := all_nc.get( ( *nc.signature[:-1],) )):
 
-         reroute_common(nc, nc_to, all_nc)
 
-     else:
 
-         raise RuntimeError("error leaving a node group (maybe you are running the tree from inside a node group?)... TODO: this should still work")
 
- def reroute_links_grpin(nc, all_nc):
 
-     pass
 
- # FIXME I don't think these signatures are unique.
 
- def insert_lazy_parents(nc):
 
-     from .link_containers import LinkInherit
 
-     from .xForm_containers import xFormArmature
 
-     from .node_container_common import NodeLink
 
-     inherit_nc = None
 
-     if nc.inputs["Relationship"].is_connected:
 
-         link = nc.inputs["Relationship"].links[0]
 
-         # print(nc)
 
-         from_nc = link.from_node
 
-         if from_nc.node_type in ["XFORM"] and link.from_socket in ["xForm Out"]:
 
-             inherit_nc = LinkInherit(("MANTIS_AUTOGENERATED", *nc.signature[1:], "LAZY_INHERIT"), nc.base_tree)
 
-             for from_link in from_nc.outputs["xForm Out"].links:
 
-                 if from_link.to_node == nc and from_link.to_socket == "Relationship":
 
-                     break # this is it
 
-             from_link.to_node = inherit_nc; from_link.to_socket="Parent"
 
-             
 
-             links=[]
 
-             while (nc.inputs["Relationship"].links):
 
-                 to_link = nc.inputs["Relationship"].links.pop()
 
-                 if to_link.from_node == from_nc and to_link.from_socket == "xForm Out":
 
-                     continue # don't keep this one
 
-                 links.append(to_link)
 
-             
 
-             nc.inputs["Relationship"].links=links
 
-             link=NodeLink(from_node=inherit_nc, from_socket="Inheritance", to_node=nc, to_socket="Relationship")
 
-             inherit_nc.inputs["Parent"].links.append(from_link)
 
-             
 
-             inherit_nc.parameters = {
 
-                                      "Parent":None,
 
-                                      "Inherit Rotation":True,
 
-                                      "Inherit Scale":'FULL',
 
-                                      "Connected":False,
 
-                                     }
 
-             # because the from node may have already been done.
 
-             init_connections(from_nc)
 
-             init_dependencies(from_nc)
 
-             init_connections(inherit_nc)
 
-             init_dependencies(inherit_nc)
 
-     return inherit_nc
 
- from_name_filter = ["Driver", ]
 
- to_name_filter = [
 
-                    "Custom Object xForm Override",
 
-                    "Custom Object",
 
-                    "Deform Bones"
 
-                  ]
 
- # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** #
 
- #                                  DATA FROM NODES                                  #
 
- # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** #
 
- from .base_definitions import replace_types
 
- # TODO: investigate whether I can set the properties in the downstream nodes directly.
 
- #       I am doing this in Schema Solver and it seems to work quite efficiently.
 
- def make_connections_to_ng_dummy(base_tree, tree_path_names, local_nc, all_nc, np):
 
-     from .node_container_common import NodeSocket
 
-     nc_to = local_nc[(None, *tree_path_names, np.name)]
 
-     for inp in np.inputs:
 
-         nc_from = None
 
-         if inp.bl_idname in  ['WildcardSocket']:
 
-             continue # it isn't a real input so I don't think it is good to check it.
 
-         to_s = inp.identifier
 
-         if not inp.is_linked: # make an autogenerated NC for the inputs of the group node
 
-             from .node_container_common import get_socket_value
 
-             nc_cls = gen_nc_input_for_data(inp)
 
-             if (nc_cls):
 
-                 sig = ("MANTIS_AUTOGENERATED", *tree_path_names, np.name, inp.name, inp.identifier)
 
-                 nc_from = nc_cls(sig, base_tree)
 
-                 # ugly! maybe even a HACK!
 
-                 nc_from.inputs = {}
 
-                 nc_from.outputs = {inp.name:NodeSocket(name = inp.name, node=nc_from)}
 
-                 nc_from.parameters = {inp.name:get_socket_value(inp)}
 
-                 # 
 
-                 local_nc[sig] = nc_from; all_nc[sig] = nc_from
 
-                 from_s = inp.name
 
-             else: # should this be an error instead?
 
-                 prRed("No available auto-generated class for input", *tree_path_names, np.name, inp.name)
 
-             nc_from.outputs[from_s].connect(node=nc_to, socket=to_s, sort_id=0)
 
- def gen_node_containers(base_tree, current_tree, tree_path_names, all_nc, local_nc, dummy_nodes, group_nodes, schema_nodes ):
 
-     from .internal_containers import DummyNode
 
-     from .base_definitions import SchemaNode
 
-     for np in current_tree.nodes:
 
-         # TODO: find out why I had to add this in. these should be taken care of already? BUG
 
-         if np.bl_idname in ["NodeFrame", "NodeReroute"]:
 
-             continue # not a Mantis Node
 
-         if (nc_cls := class_for_mantis_prototype_node(np)):
 
-             sig = (None, *tree_path_names, np.name)
 
-             # but I will probably choose to handle this elsewhere
 
-             # if isinstance(np, SchemaNode):
 
-             #     continue # we won't do this one here.
 
-             if np.bl_idname in replace_types:
 
-                 # prPurple(np.bl_idname)
 
-                 sig = (None, *tree_path_names, np.bl_idname)
 
-                 if local_nc.get(sig):
 
-                     continue # already made
 
-             nc = nc_cls( sig , base_tree)
 
-             local_nc[sig] = nc; all_nc[sig] = nc
 
-             # if np.bl_idname in ['UtilityMatricesFromCurve', 'UtilityBreakArray']:
 
-             #     schema_nodes[sig]=nc
 
-         elif np.bl_idname in ["NodeGroupInput", "NodeGroupOutput"]: # make a Dummy Node
 
-             # we only want ONE dummy in/out per tree_path, so use the bl_idname
 
-             sig = (None, *tree_path_names, np.bl_idname)
 
-             if not local_nc.get(sig):
 
-                 nc = DummyNode( signature=sig , base_tree=base_tree, prototype=np )
 
-                 local_nc[sig] = nc; all_nc[sig] = nc; dummy_nodes[sig] = nc
 
-                 if np.bl_idname in ["NodeGroupOutput"]:
 
-                     nc.reroute_links = reroute_links_grpout
 
-                 if np.bl_idname in ["NodeGroupInput"]:
 
-                     nc.reroute_links = reroute_links_grpin
 
-             # else:
 
-             #     nc = local_nc.get(sig)
 
-         elif np.bl_idname in  ["MantisNodeGroup", "MantisSchemaGroup"]:
 
-             nc = DummyNode( signature= (sig := (None, *tree_path_names, np.name) ), base_tree=base_tree, prototype=np )
 
-             local_nc[sig] = nc; all_nc[sig] = nc; dummy_nodes[sig] = nc
 
-             make_connections_to_ng_dummy(base_tree, tree_path_names, local_nc, all_nc, np)
 
-             if np.bl_idname == "MantisNodeGroup":
 
-                 group_nodes.append(nc)
 
-                 nc.reroute_links = reroute_links_grp
 
-             else:
 
-                 group_nodes.append(nc)
 
-                 schema_nodes[sig] = nc
 
-         else:
 
-             nc = None
 
-             prRed(f"Can't make nc for.. {np.bl_idname}")
 
-         # this should be done at init
 
-         if nc.signature[0] not in ['MANTIS_AUTOGENERATED'] and nc.node_type not in ['SCHEMA', 'DUMMY', 'DUMMY_SCHEMA']:
 
-             nc.fill_parameters()
 
- def data_from_tree(base_tree, tree_path, dummy_nodes, all_nc, all_schema):
 
-     # TODO: it should be realtively easy to make this use a while loop instead of recursion.
 
-     local_nc, group_nodes = {}, []
 
-     tree_path_names = [tree.name for tree in tree_path if hasattr(tree, "name")]
 
-     if tree_path[-1]:
 
-         current_tree = tree_path[-1].node_tree
 
-     else:
 
-         current_tree = base_tree
 
-     #
 
-     from .utilities import clear_reroutes
 
-     links = clear_reroutes(list(current_tree.links))
 
-     gen_node_containers(base_tree, current_tree, tree_path_names, all_nc, local_nc, dummy_nodes, group_nodes, all_schema)
 
-     
 
-     from .utilities import link_node_containers
 
-     for link in links:
 
-         link_node_containers((None, *tree_path_names), link, local_nc)
 
-     # Now, descend into the Node Groups and recurse
 
-     for nc in group_nodes:
 
-         # ng = get_node_prototype(nc.signature, base_tree)
 
-         data_from_tree(base_tree, tree_path+[nc.prototype], dummy_nodes, all_nc, all_schema)
 
-     return dummy_nodes, all_nc, all_schema
 
- from .utilities import check_and_add_root, init_connections, init_dependencies, init_schema_dependencies
 
- def delete_nc(nc):
 
-     return
 
-     # this doesn't seem to work actually
 
-     for socket in nc.inputs.values():
 
-         for l in socket.links:
 
-             if l is not None:
 
-                 l.__del__()
 
-     for socket in nc.outputs.values():
 
-         for l in socket.links:
 
-             if l is not None:
 
-                 l.__del__()
 
- def is_signature_in_other_signature(sig_a, sig_b):
 
-     # this is the easiest but not the best way to do this:
 
-     # this function is hideous but it does not seem to have any significant effect on timing
 
-     #    tested it with profiling on a full character rig.
 
-     # OK. Had another test in a more extreme situation and this one came out on top for time spent and calls
 
-     # gotta optimize this one.
 
-     sig_a = list(sig_a)
 
-     sig_a = ['MANTIS_NONE' if val is None else val for val in sig_a]
 
-     sig_b = list(sig_b)
 
-     sig_b = ['MANTIS_NONE' if val is None else val for val in sig_b]
 
-     string_a = "".join(sig_a)
 
-     string_b = "".join(sig_b)
 
-     return string_a in string_b
 
- def solve_schema_to_tree(nc, all_nc, roots=[]):
 
-     from .utilities import get_node_prototype
 
-     np = get_node_prototype(nc.signature, nc.base_tree)
 
-     # if not hasattr(np, 'node_tree'):
 
-     #     nc.bPrepare()
 
-     #     nc.prepared=True
 
-     #     return {}
 
-     from .schema_solve import SchemaSolver
 
-     length = nc.evaluate_input("Schema Length")
 
-     tree = np.node_tree
 
-     prOrange(f"Expanding schema {tree.name} in node {nc} with length {length}.")
 
-     for inp in nc.inputs.values():
 
-         inp.links.sort(key=lambda a : -a.multi_input_sort_id)
 
-     solver = SchemaSolver(nc, all_nc, np)
 
-     solved_nodes = solver.solve(length)
 
-     # prGreen(f"Finished solving schema {tree.name} in node {nc}.")
 
-     prWhite(f"Schema declared {len(solved_nodes)} nodes.")
 
-     nc.prepared = True
 
-     # TODO this should be handled by the schema's finalize() function
 
-     del_me = []
 
-     for k, v in all_nc.items():
 
-         # delete all the schema's internal nodes. The links have already been deleted by the solver.
 
-         if v.signature[0] not in ['MANTIS_AUTOGENERATED'] and is_signature_in_other_signature(nc.signature, k):
 
-             # print (wrapOrange("Culling: ")+wrapRed(v))
 
-             delete_nc(v)
 
-             del_me.append(k)
 
-     for k in del_me:
 
-         del all_nc[k]
 
-     
 
-     for k,v in solved_nodes.items():
 
-         all_nc[k]=v
 
-         init_connections(v)
 
-         check_and_add_root(v, roots, include_non_hierarchy=True)
 
-     # end TODO
 
-     return solved_nodes
 
- # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** #
 
- #                                  PARSE NODE TREE                                  #
 
- # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** # *** #
 
- from .utilities import get_all_dependencies
 
- def get_schema_length_dependencies(node):
 
-     """ Find all of the nodes that the Schema Length input depends on. """
 
-     # the deps recursively from the from_nodes connected to Schema Length
 
-     deps = []
 
-     # return get_all_dependencies(node)
 
-     inp = node.inputs.get("Schema Length")
 
-     if not inp:
 
-         inp = node.inputs.get("Array")
 
-     # this way we can handle Schema and Array Get nodes with one function
 
-     # ... since I may add more in the future this is not a robust solution HACK
 
-     for l in inp.links:
 
-         deps.extend(get_all_dependencies(l.from_node))
 
-     if inp := node.inputs.get("Index"):
 
-         for l in inp.links:
 
-             deps.extend(get_all_dependencies(l.from_node))
 
-     # now get the auto-generated simple inputs. These should not really be there but I haven't figured out how to set things directly yet lol
 
-     for inp in node.inputs.values():
 
-         for l in inp.links:
 
-             if "MANTIS_AUTOGENERATED" in l.from_node.signature:
 
-                 # l.from_node.bPrepare() # try this...
 
-                 # l.from_node.prepared = True; l.from_node.executed = True
 
-                 deps.extend([l.from_node]) # why we need this lol
 
-     return deps
 
-         
 
- def parse_tree(base_tree):
 
-     from uuid import uuid4 # do this here?
 
-     base_tree.execution_id = uuid4().__str__() # set this, it may be used by nodes during execution
 
-     # annoyingly I have to pass in values for all of the dicts because if I initialize them in the function call
 
-     #  then they stick around because the function definition inits them once and keeps a reference
 
-     # so instead I have to supply them to avoid ugly code or bugs elsewhere
 
-     # it's REALLY confusing when you run into this sort of problem. So it warrants four entire lines of comments!         
 
-     import time
 
-     data_start_time = time.time()
 
-     dummy_nodes, all_nc, all_schema =  data_from_tree(base_tree, tree_path = [None], dummy_nodes = {}, all_nc = {}, all_schema={})
 
-     # return
 
-     prGreen(f"Pulling data from tree took {time.time() - data_start_time} seconds")
 
-     for sig, dummy in dummy_nodes.items():
 
-         if (hasattr(dummy, "reroute_links")):
 
-             dummy.reroute_links(dummy, all_nc)
 
-     
 
-     # TODO
 
-     # MODIFY BELOW to use hierarchy_dependencies instead
 
-     # SCHEMA DUMMY nodes will need to gather the hierarchy and non-hierarchy dependencies
 
-     # so SCHEMA DUMMY will not make their dependencies all hierarchy
 
-     # since they will need to be able to send drivers and such   
 
-     start_time = time.time()
 
-     sig_check = (None, 'Node Group.001', 'switch_thigh')
 
-     roots = []
 
-     arrays = []
 
-     from .misc_containers import UtilityArrayGet
 
-     for nc in all_nc.values():
 
-         # clean up the groups
 
-         if nc.node_type in ["DUMMY"]:
 
-             if nc.prototype.bl_idname in ("MantisNodeGroup", "NodeGroupOutput"):
 
-                 continue
 
-         
 
-         from .base_definitions import from_name_filter, to_name_filter
 
-         init_dependencies(nc)
 
-         init_connections(nc)
 
-         check_and_add_root(nc, roots, include_non_hierarchy=True)
 
-         if isinstance(nc, UtilityArrayGet):
 
-             arrays.append(nc)
 
-     from collections import deque
 
-     unsolved_schema = deque()
 
-     solve_only_these = []; solve_only_these.extend(list(all_schema.values()))
 
-     for schema in all_schema.values():
 
-         # so basically we need to check every parent node if it is a schema
 
-         # this is a fairly slapdash solution but it works and I won't change it
 
-         for i in range(len(schema.signature)-1): # -1, we don't want to check this node, obviously
 
-             if parent := all_schema.get(schema.signature[:i+1]):
 
-                 solve_only_these.remove(schema)
 
-                 break
 
-         else:
 
-             init_schema_dependencies(schema, all_nc)
 
-             solve_only_these.extend(get_schema_length_dependencies(schema))
 
-             unsolved_schema.append(schema)
 
-     for array in arrays:
 
-         solve_only_these.extend(get_schema_length_dependencies(array))
 
-     solve_only_these.extend(arrays)
 
-     schema_solve_done = set()
 
-     solve_only_these = set(solve_only_these)
 
-     solve_layer = unsolved_schema.copy(); solve_layer.extend(roots)
 
-     
 
-     while(solve_layer):
 
-         n = solve_layer.pop()
 
-         if n not in solve_only_these: # removes the unneeded node from the solve-layer
 
-             continue
 
-         if n.signature in all_schema.keys():
 
-             for dep in n.hierarchy_dependencies:
 
-                 if dep not in schema_solve_done and (dep in solve_only_these):
 
-                     solve_layer.appendleft(n)
 
-                     break
 
-             else:
 
-                 solved_nodes = solve_schema_to_tree(n, all_nc, roots)
 
-                 unsolved_schema.remove(n)
 
-                 schema_solve_done.add(n)
 
-                 for node in solved_nodes.values():
 
-                     #
 
-                     init_dependencies(node)
 
-                     init_connections(node)
 
-                     #
 
-                     solve_layer.appendleft(node)
 
-                 for conn in n.hierarchy_connections:
 
-                     if conn not in schema_solve_done and conn not in solve_layer:
 
-                         solve_layer.appendleft(conn)
 
-         else:
 
-             for dep in n.hierarchy_dependencies:
 
-                 if dep not in schema_solve_done:
 
-                     break
 
-             else:
 
-                 n.bPrepare()
 
-                 schema_solve_done.add(n)
 
-                 for conn in n.hierarchy_connections:
 
-                     if conn not in schema_solve_done and conn not in solve_layer:
 
-                         solve_layer.appendleft(conn)
 
-     if unsolved_schema:
 
-         raise RuntimeError("Failed to resolve all schema declarations")
 
-     # I had a problem with this looping forever. I think it is resolved... but I don't know lol
 
-     all_nc = list(all_nc.values()).copy()
 
-     kept_nc = {}
 
-     while (all_nc):
 
-         nc = all_nc.pop()
 
-         if nc in arrays:
 
-             continue
 
-         if nc.node_type in ["DUMMY"]:
 
-             if nc.prototype.bl_idname in ["MantisNodeGroup", "NodeGroupOutput"]:
 
-                 continue
 
-             # continue
 
-         # cleanup autogen nodes
 
-         if nc.signature[0] == "MANTIS_AUTOGENERATED" and len(nc.inputs) == 0 and len(nc.outputs) == 1:
 
-             output=list(nc.outputs.values())[0]
 
-             value=list(nc.parameters.values())[0]   # TODO modify the dependecy get function to exclude these nodes completely
 
-             for l in output.links:
 
-                 to_node = l.to_node; to_socket = l.to_socket
 
-                 l.die()
 
-                 to_node.parameters[to_socket] = value
 
-                 del to_node.inputs[to_socket]
 
-                 init_dependencies(to_node)
 
-                 # init_connections(from_node)
 
-                 # it seems safe, and more importantly, fast, not to update the dependencies of these nodes.
 
-             continue # in my test case this reduced the time cost by 33% by removing a large number of root nodes.
 
-             # it went from 18.9 seconds to 9-10 seconds
 
-         if (nc.node_type in ['XFORM']) and ("Relationship" in nc.inputs.keys()):
 
-             if (new_nc := insert_lazy_parents(nc)):
 
-                 kept_nc[new_nc.signature]=new_nc
 
-         kept_nc[nc.signature]=nc
 
-     prWhite(f"Parsing tree took {time.time()-start_time} seconds.")
 
-     prWhite("Number of Nodes: %s" % (len(kept_nc)))
 
-     return kept_nc
 
- def sort_tree_into_layers(nodes, context):
 
-     from time import time
 
-     from .node_container_common import (get_depth_lines,
 
-       node_depth)
 
-     # All this function needs to do is sort out the hierarchy and
 
-     #  get things working in order of their dependencies.
 
-     
 
-     roots, drivers = [], []
 
-     start = time()
 
-     
 
-     for n in nodes.values():
 
-         if n.node_type == 'DRIVER': drivers.append(n)
 
-         # ugly but necesary to ensure that drivers are always connected.
 
-         check_and_add_root(n, roots)
 
-         
 
-     
 
-     layers, nodes_heights = {}, {}
 
-     #Possible improvement: unify roots if they represent the same data
 
-     all_sorted_nodes = []
 
-     for root in roots:
 
-         nodes_heights[root.signature] = 0
 
-         depth_lines = get_depth_lines(root)[0]
 
-         
 
-         for n in nodes.values():
 
-             if n.signature not in (depth_lines.keys()):
 
-                 continue #belongs to a different root
 
-             d = nodes_heights.get(n.signature, 0)
 
-             if (new_d := node_depth(depth_lines[n.signature])) > d:
 
-                 d = new_d
 
-             nodes_heights[n.signature] = d
 
-     
 
-     for k, v in nodes_heights.items():
 
-         if (layer := layers.get(v, None)):
 
-             layer.append(nodes[k]) # add it to the existing layer
 
-         else: layers[v] = [nodes[k]] # or make a new layer with the node
 
-         all_sorted_nodes.append(nodes[k]) # add it to the sorted list
 
-     
 
-     # TODO: investigate whether I can treat driver conenctions as an inverted hierarchy connection
 
-     #     as in, a hieraarchy connection from the to_node to the from_node in the link instead of the other way around.
 
-     #     because it looks like I am just putting the driver node one layer higher than the other one
 
-     for drv in drivers:
 
-         for out in drv.outputs.values():
 
-             for l in out.links:
 
-                 n = l.to_node
 
-                 if n in all_sorted_nodes: continue
 
-                 depth = nodes_heights[drv.signature] + 1
 
-                 nodes_heights[n.signature] = depth
 
-                 if (layer := layers.get(depth, None)):
 
-                     layer.append(n)
 
-                 else: layers[v] = [n]
 
-     #
 
-         #
 
-     prGreen("Sorting depth for %d nodes finished in %s seconds" %
 
-                (len(nodes), time() - start))
 
-     
 
-     keys = list(layers.keys())
 
-     keys.sort()
 
-     
 
-     num_nodes=0
 
-     print_missed=nodes.copy()
 
-     for i in keys:
 
-         print_layer = [l_item for l_item in layers[i]]
 
-         for k  in print_layer:
 
-             if k.node_type == "DUMMY":
 
-                 print (k, k.prototype.bl_idname, i)
 
-     if (False): # True to print the layers
 
-         for i in keys:
 
-             # print_layer = [l_item for l_item in layers[i] if l_item.node_type in ["XFORM",]]# "LINK", "DRIVER"]]
 
-             print_layer = [l_item for l_item in layers[i]]
 
-             for k  in print_layer:
 
-                 num_nodes+=1
 
-                 del print_missed[k.signature]
 
-             print(wrapGreen("%d: " % i), wrapWhite("%s" % print_layer))
 
-         prWhite(f"Final node count: {num_nodes}")
 
-         prOrange("The following nodes have been culled:")
 
-         for p in print_missed.values():
 
-             prWhite (p, p.dependencies)
 
-     return layers
 
- def error_popup_draw(self, context):
 
-     self.layout.label(text="Error executing tree. There is an illegal cycle somewhere in the tree.")
 
- #execute tree is really slow overall, but still completes 1000s of nodes in only 
 
- def execute_tree(nodes, base_tree, context):
 
-     # return
 
-     import bpy
 
-     from time import time
 
-     from .node_container_common import GraphError
 
-     from uuid import uuid4
 
-     original_active = context.view_layer.objects.active
 
-     start_execution_time = time()
 
-     from collections import deque
 
-     xForm_pass = deque()
 
-     for nc in nodes.values():
 
-         nc.prepared = False
 
-         nc.executed = False
 
-         check_and_add_root(nc, xForm_pass)
 
-     execute_pass = xForm_pass.copy()
 
-     # exe_order = {}; i=0
 
-     executed = []
 
-     # check for cycles here by keeping track of the number of times a node has been visited.
 
-     visited={}
 
-     check_max_len=len(nodes)**2 # seems too high but safe. In a well-ordered graph, I guess this number should be less than the number of nodes.
 
-     max_iterations = len(nodes)**2
 
-     i = 0
 
-     while(xForm_pass):
 
-         if i >= max_iterations:
 
-             raise GraphError("There is a cycle somewhere in the graph.")
 
-             bpy.context.window_manager.popup_menu(error_popup_draw, title="Error", icon='ERROR')
 
-             break
 
-         i+=1    
 
-         n = xForm_pass.pop()
 
-         if visited.get(n.signature):
 
-             visited[n.signature]+=1
 
-         else:
 
-             visited[n.signature]=0
 
-         if visited[n.signature] > check_max_len:
 
-             raise GraphError("There is a cycle in the graph somewhere. Fix it!")
 
-             bpy.context.window_manager.popup_menu(error_popup_draw, title="Error", icon='ERROR')
 
-             break
 
-             # we're trying to solve the halting problem at this point.. don't do that.
 
-             # TODO find a better way! there are algo's for this but they will require using a different solving algo, too
 
-         if n.prepared:
 
-             continue
 
-         if n.node_type not in ['XFORM', 'UTILITY']:
 
-             for dep in n.hierarchy_dependencies:
 
-                 if not dep.prepared:
 
-                     xForm_pass.appendleft(n) # hold it
 
-                     break
 
-             else:
 
-                 n.prepared=True
 
-                 executed.append(n)
 
-                 for conn in n.hierarchy_connections:
 
-                     if  not conn.prepared:
 
-                         xForm_pass.appendleft(conn)
 
-         else:
 
-             for dep in n.hierarchy_dependencies:
 
-                 if not dep.prepared:
 
-                     break
 
-             else:
 
-                 n.bPrepare(context)
 
-                 if not n.executed:
 
-                     n.bExecute(context)
 
-                 n.prepared=True
 
-                 executed.append(n)
 
-                 for conn in n.hierarchy_connections:
 
-                     if  not conn.prepared:
 
-                         xForm_pass.appendleft(conn)
 
-     
 
-     active = None
 
-     switch_me = []
 
-     for n in nodes.values():
 
-         # if it is a armature, switch modes
 
-         # total hack                   #kinda dumb
 
-         if ((hasattr(n, "bGetObject")) and (n.__class__.__name__ == "xFormArmature" )):
 
-             try:
 
-                 ob = n.bGetObject()
 
-             except KeyError: # for bones
 
-                 ob = None
 
-             # TODO this will be a problem if and when I add mesh/curve stuff
 
-             if (hasattr(ob, 'mode') and ob.mode == 'EDIT'):
 
-                 switch_me.append(ob)
 
-                 active = ob
 
-                 context.view_layer.objects.active = ob# need to have an active ob, not None, to switch modes.
 
-             # we override selected_objects to prevent anyone else from mode-switching
 
-     # TODO it's possible but unlikely that the user will try to run a 
 
-     #    graph with no armature nodes in it.
 
-     if (active):
 
-         with context.temp_override(**{'active_object':active, 'selected_objects':switch_me}):
 
-             bpy.ops.object.mode_set(mode='POSE')
 
-     for n in executed:
 
-         n.bPrepare(context)
 
-         if not n.executed:
 
-             n.bExecute(context)
 
-     for n in executed:
 
-         n.bFinalize(context)
 
-     
 
-     for n in nodes.values(): # if it is a armature, switch modes
 
-         if ((hasattr(n, "bGetObject")) and (n.__class__.__name__ == "xFormArmature" )):
 
-             if (hasattr(ob, 'mode') and ob.mode == 'POSE'):
 
-                 switch_me.append(ob)
 
-                 active = ob
 
-     if (active):
 
-         with context.temp_override(**{'active_object':active, 'selected_objects':switch_me}):
 
-             bpy.ops.object.mode_set(mode='OBJECT')
 
-     for ob in switch_me:
 
-         ob.data.pose_position = 'POSE'
 
-     tot_time = (time() - start_execution_time)
 
-     prGreen(f"Executed tree of {len(executed)} nodes in {tot_time} seconds")
 
-     if (original_active):
 
-         context.view_layer.objects.active = original_active
 
-         original_active.select_set(True)
 
 
  |