utilities.py 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963
  1. #fool: should be wrColor like prColor... dumb
  2. def wrapRed(skk): return "\033[91m{}\033[00m".format(skk)
  3. def wrapGreen(skk): return "\033[92m{}\033[00m".format(skk)
  4. def wrapPurple(skk): return "\033[95m{}\033[00m".format(skk)
  5. def wrapWhite(skk): return "\033[97m{}\033[00m".format(skk)
  6. def wrapOrange(skk): return "\033[0;33m{}\033[00m".format(skk)
  7. # these should reimplement the print interface..
  8. def prRed(*args): print (*[wrapRed(arg) for arg in args])
  9. def prGreen(*args): print (*[wrapGreen(arg) for arg in args])
  10. def prPurple(*args): print (*[wrapPurple(arg) for arg in args])
  11. def prWhite(*args): print (*[wrapWhite(arg) for arg in args])
  12. def prOrange(*args): print (*[wrapOrange(arg) for arg in args])
  13. # add THIS to the top of a file for easy access:
  14. # from mantis.utilities import (prRed, prGreen, prPurple, prWhite,
  15. # prOrange,
  16. # wrapRed, wrapGreen, wrapPurple, wrapWhite,
  17. # wrapOrange,)
  18. # A fuction for getting to the end of a Reroute.
  19. # TODO: this seems really inefficient!
  20. def socket_seek(start_link, links):
  21. link = start_link
  22. while(link.from_socket):
  23. for newlink in links:
  24. if link.from_socket.node.inputs:
  25. if newlink.to_socket == link.from_socket.node.inputs[0]:
  26. link=newlink; break
  27. else:
  28. break
  29. return link.from_socket
  30. # this creates fake links that have the same interface as Blender's
  31. # so that I can bypass Reroutes
  32. def clear_reroutes(links):
  33. from .base_definitions import DummyLink
  34. kept_links, rerouted_starts = [], []
  35. rerouted = []
  36. all_links = links.copy()
  37. while(all_links):
  38. link = all_links.pop()
  39. to_cls = link.to_socket.node.bl_idname
  40. from_cls = link.from_socket.node.bl_idname
  41. reroute_classes = ["NodeReroute"]
  42. if (to_cls in reroute_classes and
  43. from_cls in reroute_classes):
  44. rerouted.append(link)
  45. elif (to_cls in reroute_classes and not
  46. from_cls in reroute_classes):
  47. rerouted.append(link)
  48. elif (from_cls in reroute_classes and not
  49. to_cls in reroute_classes):
  50. rerouted_starts.append(link)
  51. else:
  52. kept_links.append(link)
  53. for start in rerouted_starts:
  54. from_socket = socket_seek(start, rerouted)
  55. new_link = DummyLink(from_socket=from_socket, to_socket=start.to_socket, nc_from=None, nc_to=None, multi_input_sort_id=start.multi_input_sort_id )
  56. kept_links.append(new_link)
  57. return kept_links
  58. def tree_from_nc(sig, base_tree):
  59. if (sig[0] == 'MANTIS_AUTOGENERATED'):
  60. sig = sig[:-2] # cut off the end part of the signature (because it uses socket.name and socket.identifier)
  61. # this will lead to totally untraceble bugs in the event of a change in how signatures are assigned
  62. tree = base_tree
  63. for i, path_item in enumerate(sig):
  64. if (i == 0) or (i == len(sig) - 1):
  65. continue
  66. tree = tree.nodes.get(path_item).node_tree
  67. return tree
  68. def get_node_prototype(sig, base_tree):
  69. return tree_from_nc(sig, base_tree).nodes.get( sig[-1] )
  70. ##################################################################################################
  71. # groups and changing sockets -- this is used extensively by Schema.
  72. ##################################################################################################
  73. # this one returns None if there is an error.
  74. def get_socket_maps(node, force=False):
  75. maps = [{}, {}]
  76. node_collection = ["inputs", "outputs"]
  77. links = ["from_socket", "to_socket"]
  78. for collection, map, linked_socket in zip(node_collection, maps, links):
  79. for sock in getattr(node, collection):
  80. if sock.is_linked:
  81. other_sockets = []
  82. # Sort the links first (in case they are mult-input), because Blender doesn't
  83. links = sorted(list(sock.links), key = lambda l : l.multi_input_sort_id)
  84. # HACK here because Blender will crash if the socket values in the NodeReroute
  85. # are mutated. Because this seems to happen in a deffered way, I can't account
  86. # for it except by checking the node later...
  87. # TODO: The fact that I need this hack means I can probably solve this problem
  88. # for all node types in a safer way, since they may also be dynamic somehow
  89. for l in links:
  90. if "from" in linked_socket and l.from_node.bl_idname == "NodeReroute":
  91. other_sockets.append(l.from_node)
  92. elif "to" in linked_socket and l.to_node.bl_idname == "NodeReroute":
  93. other_sockets.append(l.to_node)
  94. else:
  95. other_sockets.append(getattr(l, linked_socket))
  96. map[sock.identifier]= other_sockets
  97. elif hasattr(sock, "default_value"):
  98. if sock.get("default_value") is not None:
  99. val = sock['default_value']
  100. elif sock.bl_idname == "EnumCurveSocket" and sock.get("default_value") is None:
  101. # HACK I need to add this special case because during file-load,
  102. # this value is None and should not be altered until it is set once.
  103. continue
  104. elif (val := sock.default_value) is not None:
  105. pass
  106. elif not force:
  107. continue
  108. map[sock.identifier]=val
  109. else:
  110. from .socket_definitions import no_default_value
  111. if sock.bl_idname in no_default_value:
  112. map[sock.identifier]=None
  113. else:
  114. raise RuntimeError(f"ERROR: Could not get socket data for socket of type: {sock.bl_idname}")
  115. return maps
  116. # this function is completely overloaded with different purposes and code paths
  117. # TODO refactor everything that funnels into this function
  118. # make this stuff simpler.
  119. def do_relink(node, s, map, in_out='INPUT', parent_name = ''):
  120. if not node.__class__.is_registered_node_type(): return
  121. tree = node.id_data; interface_in_out = 'OUTPUT' if in_out == 'INPUT' else 'INPUT'
  122. if hasattr(node, "node_tree"):
  123. tree = node.node_tree
  124. interface_in_out=in_out
  125. from bpy.types import NodeSocket, Node
  126. get_string = '__extend__'
  127. if s: get_string = s.identifier
  128. from .base_definitions import SchemaUINode
  129. if (hasattr(node, "node_tree") or isinstance(node, SchemaUINode)) and get_string not in map.keys():
  130. # this happens when we are creating a new node group and need to update it from nothing.
  131. return
  132. val = map[get_string] # this will throw an error if the socket isn't there. Good!
  133. if isinstance(val, list):
  134. for sub_val in val:
  135. # this will only happen once because it assigns s, so it is safe to do in the for loop.
  136. if s is None:
  137. name = unique_socket_name(node, sub_val, tree)
  138. sock_type = sub_val.bl_idname
  139. if parent_name:
  140. interface_socket = update_interface(tree.interface, name, interface_in_out, sock_type, parent_name)
  141. if in_out =='INPUT':
  142. s = node.inputs.new(sock_type, name, identifier=interface_socket.identifier)
  143. else:
  144. s = node.outputs.new(sock_type, name, identifier=interface_socket.identifier)
  145. if parent_name == 'Array': s.display_shape='SQUARE_DOT'
  146. # then move it up and delete the other link.
  147. # this also needs to modify the interface of the node tree.
  148. if isinstance(sub_val, NodeSocket):
  149. l = None
  150. if in_out =='INPUT':
  151. l = node.id_data.links.new(input=sub_val, output=s)
  152. else:
  153. l = node.id_data.links.new(input=s, output=sub_val)
  154. if l is None:
  155. raise RuntimeError("Could not create link")
  156. elif isinstance(sub_val, Node):
  157. l = None
  158. # this happens when it is a NodeReroute
  159. if not s.is_output:
  160. l = node.id_data.links.new(input=sub_val.outputs[0], output=s)
  161. else:
  162. l = node.id_data.links.new(input=s, output=sub_val.inputs[0])
  163. if l is None:
  164. raise RuntimeError("Could not create link")
  165. else:
  166. raise RuntimeError("Unhandled case in do_relink()")
  167. elif get_string != "__extend__":
  168. if not s.is_output:
  169. try:
  170. s.default_value = val
  171. except (AttributeError, ValueError): # must be readonly or maybe it doesn't have a d.v.
  172. pass
  173. def update_interface(interface, name, in_out, sock_type, parent_name):
  174. if parent_name:
  175. if not (interface_parent := interface.items_tree.get(parent_name)):
  176. interface_parent = interface.new_panel(name=parent_name)
  177. socket = interface.new_socket(name=name,in_out=in_out, socket_type=sock_type, parent=interface_parent)
  178. if parent_name == 'Connection':
  179. in_out = 'OUTPUT' if in_out == 'INPUT' else 'INPUT' # flip this make sure connections always do both
  180. interface.new_socket(name=name,in_out=in_out, socket_type=sock_type, parent=interface_parent)
  181. return socket
  182. else:
  183. raise RuntimeError(wrapRed("Cannot add interface item to tree without specifying type."))
  184. #UGLY BAD REFACTOR
  185. def relink_socket_map_add_socket(node, socket_collection, item, in_out=None,):
  186. if not in_out: in_out=item.in_out
  187. if node.bl_idname in ['MantisSchemaGroup'] and item.parent and item.parent.name == 'Array':
  188. multi = True if in_out == 'INPUT' else False
  189. s = socket_collection.new(type=item.socket_type, name=item.name, identifier=item.identifier, use_multi_input=multi)
  190. else:
  191. s = socket_collection.new(type=item.socket_type, name=item.name, identifier=item.identifier)
  192. if item.parent.name == 'Array': s.display_shape = 'SQUARE_DOT'
  193. return s
  194. # TODO REFACTOR THIS
  195. # I did this awful thing because I needed the above code
  196. # but I have provided this interface to Mantis
  197. # I did not follow the Single Responsibility Principle
  198. # I am now suffering for it, as I rightly deserve.
  199. def relink_socket_map(node, socket_collection, map, item, in_out=None,):
  200. s = relink_socket_map_add_socket(node, socket_collection, item, in_out=None,)
  201. do_relink(node, s, map)
  202. def unique_socket_name(node, other_socket, tree):
  203. name_stem = other_socket.bl_label; num=0
  204. # if hasattr(other_socket, "default_value"):
  205. # name_stem = type(other_socket.default_value).__name__
  206. for item in tree.interface.items_tree:
  207. if item.item_type == 'PANEL': continue
  208. if other_socket.is_output and item.in_out == 'INPUT': continue
  209. if not other_socket.is_output and item.in_out == 'OUTPUT': continue
  210. if name_stem in item.name: num+=1
  211. name = name_stem + '.' + str(num).zfill(3)
  212. return name
  213. ##############################
  214. # READ TREE and also Schema Solve!
  215. ##############################
  216. # TODO: refactor the following two functions, they should be one function with arguments.
  217. def init_connections(nc):
  218. c, hc = [], []
  219. for i in nc.outputs.values():
  220. for l in i.links:
  221. # if l.from_node != nc:
  222. # continue
  223. if l.is_hierarchy:
  224. hc.append(l.to_node)
  225. c.append(l.to_node)
  226. nc.hierarchy_connections = hc
  227. nc.connections = c
  228. def init_dependencies(nc):
  229. c, hc = [], []
  230. for i in nc.inputs.values():
  231. for l in i.links:
  232. # if l.to_node != nc:
  233. # continue
  234. if l.is_hierarchy:
  235. hc.append(l.from_node)
  236. c.append(l.from_node)
  237. nc.hierarchy_dependencies = hc
  238. nc.dependencies = c
  239. def schema_dependency_handle_item(schema, all_nc, item,):
  240. hierarchy = True
  241. from .base_definitions import from_name_filter, to_name_filter
  242. if item.in_out == 'INPUT':
  243. dependencies = schema.dependencies
  244. hierarchy_dependencies = schema.hierarchy_dependencies
  245. if item.parent and item.parent.name == 'Array':
  246. for schema_idname in ['SchemaArrayInput', 'SchemaArrayInputGet', 'SchemaArrayInputAll']:
  247. if (nc := all_nc.get( (*schema.signature, schema_idname) )):
  248. for from_link in schema.inputs[item.identifier].links:
  249. if from_link.from_socket in from_name_filter:
  250. hierarchy = False
  251. # hierarchy_reason='b'
  252. if from_link.from_node not in dependencies:
  253. if hierarchy:
  254. hierarchy_dependencies.append(from_link.from_node)
  255. dependencies.append(from_link.from_node)
  256. if item.parent and item.parent.name == 'Constant':
  257. if nc := all_nc.get((*schema.signature, 'SchemaConstInput')):
  258. for from_link in schema.inputs[item.identifier].links:
  259. if from_link.from_socket in from_name_filter:
  260. # hierarchy_reason='d'
  261. hierarchy = False
  262. if from_link.from_node not in dependencies:
  263. if hierarchy:
  264. hierarchy_dependencies.append(from_link.from_node)
  265. dependencies.append(from_link.from_node)
  266. if item.parent and item.parent.name == 'Connection':
  267. if nc := all_nc.get((*schema.signature, 'SchemaIncomingConnection')):
  268. for from_link in schema.inputs[item.identifier].links:
  269. if from_link.from_socket in from_name_filter:
  270. # hierarchy_reason='f'
  271. hierarchy = False
  272. if from_link.from_node not in dependencies:
  273. if hierarchy:
  274. hierarchy_dependencies.append(from_link.from_node)
  275. dependencies.append(from_link.from_node)
  276. def init_schema_dependencies(schema, all_nc):
  277. """ Initialize the dependencies for Schema, and mark them as hierarchy or non-hierarchy dependencies
  278. Non-hierarchy dependencies are e.g. drivers and custom transforms.
  279. """
  280. tree = schema.prototype.node_tree
  281. if tree is None:
  282. raise RuntimeError(f"Cannot get dependencies for schema {schema}")
  283. schema.dependencies = []
  284. schema.hierarchy_dependencies = []
  285. for l in schema.inputs["Schema Length"].links:
  286. schema.hierarchy_dependencies.append(l.from_node)
  287. if tree.interface:
  288. for item in tree.interface.items_tree:
  289. if item.item_type == 'PANEL':
  290. continue
  291. schema_dependency_handle_item(schema, all_nc, item,)
  292. def check_and_add_root(n, roots, include_non_hierarchy=False):
  293. if (include_non_hierarchy * len(n.dependencies)) > 0:
  294. return
  295. elif len(n.hierarchy_dependencies) > 0:
  296. return
  297. roots.append(n)
  298. def get_link_in_out(link):
  299. from .base_definitions import replace_types
  300. from_name, to_name = link.from_socket.node.name, link.to_socket.node.name
  301. # catch special bl_idnames and bunch the connections up
  302. if link.from_socket.node.bl_idname in replace_types:
  303. from_name = link.from_socket.node.bl_idname
  304. if link.to_socket.node.bl_idname in replace_types:
  305. to_name = link.to_socket.node.bl_idname
  306. return from_name, to_name
  307. def link_node_containers(tree_path_names, link, local_nc, from_suffix='', to_suffix=''):
  308. dummy_types = ["DUMMY", "DUMMY_SCHEMA"]
  309. from_name, to_name = get_link_in_out(link)
  310. nc_from = local_nc.get( (*tree_path_names, from_name+from_suffix) )
  311. nc_to = local_nc.get( (*tree_path_names, to_name+to_suffix))
  312. if (nc_from and nc_to):
  313. from_s, to_s = link.from_socket.name, link.to_socket.name
  314. if nc_to.node_type in dummy_types: to_s = link.to_socket.identifier
  315. if nc_from.node_type in dummy_types: from_s = link.from_socket.identifier
  316. try:
  317. connection = nc_from.outputs[from_s].connect(node=nc_to, socket=to_s, sort_id=link.multi_input_sort_id)
  318. if connection is None:
  319. prWhite(f"Already connected: {from_name}:{from_s}->{to_name}:{to_s}")
  320. return connection
  321. except KeyError as e:
  322. prRed(f"{nc_from}:{from_s} or {nc_to}:{to_s} missing; review the connections printed below:")
  323. print (nc_from.outputs.keys())
  324. print (nc_to.inputs.keys())
  325. raise e
  326. else:
  327. prRed(nc_from, nc_to, (*tree_path_names, from_name+from_suffix), (*tree_path_names, to_name+to_suffix))
  328. raise RuntimeError(wrapRed("Link not connected: %s -> %s in tree %s" % (from_name, to_name, tree_path_names[-1])))
  329. def get_all_dependencies(nc):
  330. from .base_definitions import GraphError
  331. """ find all dependencies for a mantis node"""
  332. nodes = []
  333. check_nodes = [nc]
  334. nodes_checked = set()
  335. while (len(check_nodes) > 0):
  336. node = check_nodes.pop()
  337. nodes_checked.add (node)
  338. connected_nodes = node.hierarchy_dependencies
  339. for new_node in connected_nodes:
  340. if new_node in nodes:
  341. continue
  342. nodes.append(new_node)
  343. if new_node not in nodes_checked:
  344. check_nodes.append(new_node)
  345. return nodes
  346. def get_all_nodes_of_type(base_tree, bl_idname):
  347. nodes = []
  348. check_nodes = list(base_tree.nodes)
  349. while (len(check_nodes) > 0):
  350. node = check_nodes.pop()
  351. if node.bl_idname in bl_idname:
  352. nodes.append(node)
  353. if hasattr(node, "node_tree"):
  354. check_nodes.extend(list(node.node_tree.nodes))
  355. return nodes
  356. ##################################################################################################
  357. # misc
  358. ##################################################################################################
  359. # TODO: get the matrix to return a mathutils.Matrix so I don't need a function call here
  360. def to_mathutils_value(socket):
  361. if hasattr(socket, "default_value"):
  362. val = socket.default_value
  363. if socket.bl_idname in ['MatrixSocket']:
  364. return socket.TellValue()
  365. else:
  366. return val
  367. else:
  368. return None
  369. def all_trees_in_tree(base_tree, selected=False):
  370. """ Recursively finds all trees referenced in a given base-tree."""
  371. # note that this is recursive but not by tail-end recursion
  372. # a while-loop is a better way to do recursion in Python.
  373. trees = [base_tree]
  374. can_descend = True
  375. check_trees = [base_tree]
  376. while (len(check_trees) > 0): # this seems innefficient, why 2 loops?
  377. new_trees = []
  378. while (len(check_trees) > 0):
  379. tree = check_trees.pop()
  380. for node in tree.nodes:
  381. if selected == True and node.select == False:
  382. continue
  383. if new_tree := getattr(node, "node_tree", None):
  384. if new_tree in trees: continue
  385. new_trees.append(new_tree)
  386. trees.append(new_tree)
  387. check_trees = new_trees
  388. return trees
  389. # this is a destructive operation, not a pure function or whatever. That isn't good but I don't care.
  390. def SugiyamaGraph(tree, iterations):
  391. from grandalf.graphs import Vertex, Edge, Graph, graph_core
  392. class defaultview(object):
  393. w,h = 1,1
  394. xz = (0,0)
  395. no_links = set()
  396. verts = {}
  397. for n in tree.nodes:
  398. has_links=False
  399. for inp in n.inputs:
  400. if inp.is_linked:
  401. has_links=True
  402. break
  403. else:
  404. no_links.add(n.name)
  405. for out in n.outputs:
  406. if out.is_linked:
  407. has_links=True
  408. break
  409. else:
  410. try:
  411. no_links.remove(n.name)
  412. except KeyError:
  413. pass
  414. if not has_links:
  415. continue
  416. v = Vertex(n.name)
  417. v.view = defaultview()
  418. v.view.xy = n.location
  419. v.view.h = n.height*2.5
  420. v.view.w = n.width*2.2
  421. verts[n.name] = v
  422. edges = []
  423. for link in tree.links:
  424. weight = 1 # maybe this is useful
  425. edges.append(Edge(verts[link.from_node.name], verts[link.to_node.name], weight) )
  426. graph = Graph(verts.values(), edges)
  427. from grandalf.layouts import SugiyamaLayout
  428. sug = SugiyamaLayout(graph.C[0]) # no idea what .C[0] is
  429. roots=[]
  430. for node in tree.nodes:
  431. has_links=False
  432. for inp in node.inputs:
  433. if inp.is_linked:
  434. has_links=True
  435. break
  436. for out in node.outputs:
  437. if out.is_linked:
  438. has_links=True
  439. break
  440. if not has_links:
  441. continue
  442. if len(node.inputs)==0:
  443. roots.append(verts[node.name])
  444. else:
  445. for inp in node.inputs:
  446. if inp.is_linked==True:
  447. break
  448. else:
  449. roots.append(verts[node.name])
  450. sug.init_all(roots=roots,)
  451. sug.draw(iterations)
  452. for v in graph.C[0].sV:
  453. for n in tree.nodes:
  454. if n.name == v.data:
  455. n.location.x = v.view.xy[1]
  456. n.location.y = v.view.xy[0]
  457. # now we can take all the input nodes and try to put them in a sensible place
  458. for n_name in no_links:
  459. n = tree.nodes.get(n_name)
  460. next_n = None
  461. next_node = None
  462. for output in n.outputs:
  463. if output.is_linked == True:
  464. next_node = output.links[0].to_node
  465. break
  466. # let's see if the next node
  467. if next_node:
  468. # need to find the other node in the same layer...
  469. other_node = None
  470. for s_input in next_node.inputs:
  471. if s_input.is_linked:
  472. other_node = s_input.links[0].from_node
  473. if other_node is n:
  474. continue
  475. else:
  476. break
  477. if other_node:
  478. n.location = other_node.location
  479. n.location.y -= other_node.height*2
  480. else: # we'll just position it next to the next node
  481. n.location = next_node.location
  482. n.location.x -= next_node.width*1.5
  483. def project_point_to_plane(point, origin, normal):
  484. return point - normal.dot(point- origin)*normal
  485. ##################################################################################################
  486. # stuff I should probably refactor!!
  487. ##################################################################################################
  488. # This is really, really stupid way to do this
  489. def gen_nc_input_for_data(socket):
  490. # Class List #TODO deduplicate
  491. from . import xForm_containers, link_containers, misc_nodes, primitives_containers, deformer_containers, math_containers, schema_containers
  492. from .internal_containers import NoOpNode
  493. classes = {}
  494. for module in [xForm_containers, link_containers, misc_nodes, primitives_containers, deformer_containers, math_containers, schema_containers]:
  495. for cls in module.TellClasses():
  496. classes[cls.__name__] = cls
  497. #
  498. socket_class_map = {
  499. "MatrixSocket" : classes["InputMatrix"],
  500. "xFormSocket" : None,
  501. "RelationshipSocket" : NoOpNode,
  502. "DeformerSocket" : NoOpNode,
  503. "GeometrySocket" : classes["InputExistingGeometryData"],
  504. "EnableSocket" : classes["InputBoolean"],
  505. "HideSocket" : classes["InputBoolean"],
  506. #
  507. "DriverSocket" : None,
  508. "DriverVariableSocket" : None,
  509. "FCurveSocket" : None,
  510. "KeyframeSocket" : None,
  511. "BoneCollectionSocket" : classes["InputString"],
  512. #
  513. "xFormParameterSocket" : None,
  514. "ParameterBoolSocket" : classes["InputBoolean"],
  515. "ParameterIntSocket" : classes["InputFloat"], #TODO: make an Int node for this
  516. "ParameterFloatSocket" : classes["InputFloat"],
  517. "ParameterVectorSocket" : classes["InputVector"],
  518. "ParameterStringSocket" : classes["InputString"],
  519. #
  520. "TransformSpaceSocket" : classes["InputTransformSpace"],
  521. "BooleanSocket" : classes["InputBoolean"],
  522. "BooleanThreeTupleSocket" : classes["InputBooleanThreeTuple"],
  523. "RotationOrderSocket" : classes["InputRotationOrder"],
  524. "QuaternionSocket" : None,
  525. "QuaternionSocketAA" : None,
  526. "UnsignedIntSocket" : classes["InputFloat"],
  527. "IntSocket" : classes["InputFloat"],
  528. "StringSocket" : classes["InputString"],
  529. #
  530. "BoolUpdateParentNode" : classes["InputBoolean"],
  531. "IKChainLengthSocket" : classes["InputFloat"],
  532. "EnumInheritScale" : classes["InputString"],
  533. "EnumRotationMix" : classes["InputString"],
  534. "EnumRotationMixCopyTransforms" : classes["InputString"],
  535. "EnumMaintainVolumeStretchTo" : classes["InputString"],
  536. "EnumRotationStretchTo" : classes["InputString"],
  537. "EnumTrackAxis" : classes["InputString"],
  538. "EnumUpAxis" : classes["InputString"],
  539. "EnumLockAxis" : classes["InputString"],
  540. "EnumLimitMode" : classes["InputString"],
  541. "EnumYScaleMode" : classes["InputString"],
  542. "EnumXZScaleMode" : classes["InputString"],
  543. "EnumCurveSocket" : classes["InputString"],
  544. "EnumMetaRigSocket" : classes["InputString"],
  545. # Deformers
  546. "EnumSkinning" : classes["InputString"],
  547. #
  548. "FloatSocket" : classes["InputFloat"],
  549. "FloatFactorSocket" : classes["InputFloat"],
  550. "FloatPositiveSocket" : classes["InputFloat"],
  551. "FloatAngleSocket" : classes["InputFloat"],
  552. "VectorSocket" : classes["InputVector"],
  553. "VectorEulerSocket" : classes["InputVector"],
  554. "VectorTranslationSocket" : classes["InputVector"],
  555. "VectorScaleSocket" : classes["InputVector"],
  556. # Drivers
  557. "EnumDriverVariableType" : classes["InputString"],
  558. "EnumDriverVariableEvaluationSpace" : classes["InputString"],
  559. "EnumDriverRotationMode" : classes["InputString"],
  560. "EnumDriverType" : classes["InputString"],
  561. "EnumKeyframeInterpTypeSocket" : classes["InputString"],
  562. "EnumKeyframeBezierHandleTypeSocket" : classes["InputString"],
  563. # Math
  564. "MathFloatOperation" : classes["InputString"],
  565. "MathVectorOperation" : classes["InputString"],
  566. "MatrixTransformOperation" : classes["InputString"],
  567. # Schema
  568. "WildcardSocket" : None,
  569. }
  570. return socket_class_map.get(socket.bl_idname, None)
  571. ####################################
  572. # CURVE STUFF
  573. ####################################
  574. def make_perpendicular(v1, v2):
  575. projected = (v2.dot(v1) / v1.dot(v1)) * v1
  576. perpendicular = v2 - projected
  577. return perpendicular
  578. # this stuff could be branchless but I don't use it much TODO
  579. def cap(val, maxValue):
  580. if (val > maxValue):
  581. return maxValue
  582. return val
  583. def capMin(val, minValue):
  584. if (val < minValue):
  585. return minValue
  586. return val
  587. def wrap(min : float, max : float, value: float) -> float:
  588. range = max-min; remainder = value % range
  589. if remainder > max: return min + remainder-max
  590. else: return remainder
  591. def lerpVal(a, b, fac = 0.5):
  592. return a + ( (b-a) * fac)
  593. #wtf this doesn't do anything even remotely similar to wrap
  594. # HACK BAD FIXME UNBREAK ME BAD
  595. # I don't understand what this function does but I am using it in multiple places?
  596. def old_bad_wrap_that_should_be_refactored(val, maxValue, minValue = None):
  597. if (val > maxValue):
  598. return (-1 * ((maxValue - val) + 1))
  599. if ((minValue) and (val < minValue)):
  600. return (val + maxValue)
  601. return val
  602. #TODO clean this up
  603. def RibbonMeshEdgeLengths(m, ribbon):
  604. tE = ribbon[0]; bE = ribbon[1]; c = ribbon[2]
  605. lengths = []
  606. for i in range( len( tE ) ): #tE and bE are same length
  607. if (c == True):
  608. v1NextInd = tE[old_bad_wrap_that_should_be_refactored((i+1), len(tE) - 1)]
  609. else:
  610. v1NextInd = tE[cap((i+1) , len(tE) - 1 )]
  611. v1 = m.vertices[tE[i]]; v1Next = m.vertices[v1NextInd]
  612. if (c == True):
  613. v2NextInd = bE[old_bad_wrap_that_should_be_refactored((i+1), len(bE) - 1)]
  614. else:
  615. v2NextInd = bE[cap((i+1) , len(bE) - 1 )]
  616. v2 = m.vertices[bE[i]]; v2Next = m.vertices[v2NextInd]
  617. v = v1.co.lerp(v2.co, 0.5); vNext = v1Next.co.lerp(v2Next.co, 0.5)
  618. # get the center, edges may not be straight so total length
  619. # of one edge may be more than the ribbon center's length
  620. lengths.append(( v - vNext ).length)
  621. return lengths
  622. def EnsureCurveIsRibbon(crv, defaultRadius = 0.1):
  623. crvRadius = 0
  624. crv.data.offset = 0
  625. if (crv.data.bevel_depth == 0):
  626. crvRadius = crv.data.extrude
  627. else: #Set ribbon from bevel depth
  628. crvRadius = crv.data.bevel_depth
  629. crv.data.bevel_depth = 0
  630. crv.data.extrude = crvRadius
  631. if (crvRadius == 0):
  632. crv.data.extrude = defaultRadius
  633. def SetRibbonData(m, ribbon):
  634. #maybe this could be incorporated into the DetectWireEdges function?
  635. #maybe I can check for closed poly curves here? under what other circumstance
  636. # will I find the ends of the wire have identical coordinates?
  637. ribbonData = []
  638. tE = ribbon[0].copy(); bE = ribbon[1].copy()# circle = ribbon[2]
  639. #
  640. lengths = RibbonMeshEdgeLengths(m, ribbon)
  641. lengths.append(0)
  642. totalLength = sum(lengths)
  643. # m.calc_normals() #calculate normals
  644. # it appears this has been removed.
  645. for i, (t, b) in enumerate(zip(tE, bE)):
  646. ind = old_bad_wrap_that_should_be_refactored( (i + 1), len(tE) - 1 )
  647. tNext = tE[ind]; bNext = bE[ind]
  648. ribbonData.append( ( (t,b), (tNext, bNext), lengths[i] ) )
  649. #if this is a circle, the last v in vertData has a length, otherwise 0
  650. return ribbonData, totalLength
  651. def mesh_from_curve(crv, context,):
  652. """Utility function for converting a mesh to a curve
  653. which will return the correct mesh even with modifiers"""
  654. import bpy
  655. bevel = crv.data.bevel_depth
  656. extrude = crv.data.extrude
  657. offset = crv.data.offset
  658. if (len(crv.modifiers) > 0):
  659. do_unlink = False
  660. if (not context.scene.collection.all_objects.get(crv.name)):
  661. context.collection.objects.link(crv) # i guess this forces the dg to update it?
  662. do_unlink = True
  663. dg = context.view_layer.depsgraph
  664. # just gonna modify it for now lol
  665. EnsureCurveIsRibbon(crv)
  666. # try:
  667. dg.update()
  668. mOb = crv.evaluated_get(dg)
  669. m = bpy.data.meshes.new_from_object(mOb)
  670. m.name=crv.data.name+'_mesh'
  671. if (do_unlink):
  672. context.collection.objects.unlink(crv)
  673. else: # (ಥ﹏ಥ) why can't I just use this !
  674. # for now I will just do it like this
  675. EnsureCurveIsRibbon(crv)
  676. m = bpy.data.meshes.new_from_object(crv)
  677. crv.data.bevel_depth = bevel
  678. crv.data.extrude = extrude
  679. crv.data.offset = offset
  680. return m
  681. def DetectRibbon(f, bm, skipMe):
  682. fFirst = f.index
  683. cont = True
  684. circle = False
  685. tEdge, bEdge = [],[]
  686. while (cont == True):
  687. skipMe.add(f.index)
  688. tEdge.append (f.loops[0].vert.index) # top-left
  689. bEdge.append (f.loops[3].vert.index) # bottom-left
  690. nEdge = bm.edges.get([f.loops[1].vert, f.loops[2].vert])
  691. nFaces = nEdge.link_faces
  692. if (len(nFaces) == 1):
  693. cont = False
  694. else:
  695. for nFace in nFaces:
  696. if (nFace != f):
  697. f = nFace
  698. break
  699. if (f.index == fFirst):
  700. cont = False
  701. circle = True
  702. if (cont == False): # we've reached the end, get the last two:
  703. tEdge.append (f.loops[1].vert.index) # top-right
  704. bEdge.append (f.loops[2].vert.index) # bottom-right
  705. # this will create a loop for rings --
  706. # "the first shall be the last and the last shall be first"
  707. return (tEdge,bEdge,circle)
  708. def DetectRibbons(m, fReport = None):
  709. # Returns list of vertex indices belonging to ribbon mesh edges
  710. # NOTE: this assumes a mesh object with only ribbon meshes
  711. # ---DO NOT call this script with a mesh that isn't a ribbon!--- #
  712. import bmesh
  713. bm = bmesh.new()
  714. bm.from_mesh(m)
  715. mIslands, mIsland = [], []
  716. skipMe = set()
  717. bm.faces.ensure_lookup_table()
  718. #first, get a list of mesh islands
  719. for f in bm.faces:
  720. if (f.index in skipMe):
  721. continue #already done here
  722. checkMe = [f]
  723. while (len(checkMe) > 0):
  724. facesFound = 0
  725. for f in checkMe:
  726. if (f.index in skipMe):
  727. continue #already done here
  728. mIsland.append(f)
  729. skipMe.add(f.index)
  730. for e in f.edges:
  731. checkMe += e.link_faces
  732. if (facesFound == 0):
  733. #this is the last iteration
  734. mIslands.append(mIsland)
  735. checkMe, mIsland = [], []
  736. ribbons = []
  737. skipMe = set() # to store ends already checked
  738. for mIsl in mIslands:
  739. ribbon = None
  740. first = float('inf')
  741. for f in mIsl:
  742. if (f.index in skipMe):
  743. continue #already done here
  744. if (f.index < first):
  745. first = f.index
  746. adjF = 0
  747. for e in f.edges:
  748. adjF+= (len(e.link_faces) - 1)
  749. # every face other than this one is added to the list
  750. if (adjF == 1):
  751. ribbon = (DetectRibbon(f, bm, skipMe) )
  752. break
  753. if (ribbon == None):
  754. ribbon = (DetectRibbon(bm.faces[first], bm, skipMe) )
  755. ribbons.append(ribbon)
  756. # print (ribbons)
  757. return ribbons
  758. def data_from_ribbon_mesh(m, factorsList, mat, ribbons = None, fReport = None):
  759. #Note, factors list should be equal in length the the number of wires
  760. #Now working for multiple wires, ugly tho
  761. if (ribbons == None):
  762. ribbons = DetectRibbons(m, fReport=fReport)
  763. if (ribbons is None):
  764. if (fReport):
  765. fReport(type = {'ERROR'}, message="No ribbon to get data from.")
  766. else:
  767. print ("No ribbon to get data from.")
  768. return None
  769. ret = []
  770. for factors, ribbon in zip(factorsList, ribbons):
  771. points = []
  772. widths = []
  773. normals = []
  774. ribbonData, totalLength = SetRibbonData(m, ribbon)
  775. for fac in factors:
  776. if (fac == 0):
  777. data = ribbonData[0]
  778. curFac = 0
  779. elif (fac == 1):
  780. data = ribbonData[-1]
  781. curFac = 0
  782. else:
  783. targetLength = totalLength * fac
  784. data = ribbonData[0]
  785. curLength = 0
  786. for ( (t, b), (tNext, bNext), length,) in ribbonData:
  787. if (curLength >= targetLength):
  788. break
  789. curLength += length
  790. data = ( (t, b), (tNext, bNext), length,)
  791. targetLengthAtEdge = (curLength - targetLength)
  792. if (targetLength == 0):
  793. curFac = 0
  794. elif (targetLength == totalLength):
  795. curFac = 1
  796. else:
  797. # NOTE: This can be Zero. That should throw an error.
  798. curFac = 1 - (targetLengthAtEdge/ data[2]) #length
  799. t1 = m.vertices[data[0][0]]; b1 = m.vertices[data[0][1]]
  800. t2 = m.vertices[data[1][0]]; b2 = m.vertices[data[1][1]]
  801. #location
  802. loc1 = (t1.co).lerp(b1.co, 0.5)
  803. loc2 = (t2.co).lerp(b2.co, 0.5)
  804. #width
  805. w1 = (t1.co - b1.co).length/2
  806. w2 = (t2.co - b2.co).length/2 #radius, not diameter
  807. #normal
  808. n1 = (t1.normal).slerp(b1.normal, 0.5)
  809. n2 = (t1.normal).slerp(b2.normal, 0.5)
  810. if ((data[0][0] > data[1][0]) and (ribbon[2] == False)):
  811. curFac = 0
  812. #don't interpolate if at the end of a ribbon that isn't circular
  813. if ( 0 < curFac < 1):
  814. outPoint = loc1.lerp(loc2, curFac)
  815. outNorm = n1.lerp(n2, curFac)
  816. outWidth = w1 + ( (w2-w1) * curFac)
  817. elif (curFac <= 0):
  818. outPoint = loc1.copy()
  819. outNorm = n1
  820. outWidth = w1
  821. elif (curFac >= 1):
  822. outPoint = loc2.copy()
  823. outNorm = n2
  824. outWidth = w2
  825. outPoint = mat @ outPoint
  826. outNorm.normalize()
  827. points.append ( outPoint.copy() ) #copy because this is an actual vertex location
  828. widths.append ( outWidth )
  829. normals.append( outNorm )
  830. ret.append( (points, widths, normals) )
  831. return ret # this is a list of tuples containing three lists
  832. #This bisection search is generic, and it searches based on the
  833. # magnitude of the error, rather than the sign.
  834. # If the sign of the error is meaningful, a simpler function
  835. # can be used.
  836. def do_bisect_search_by_magnitude(
  837. owner,
  838. attribute,
  839. index = None,
  840. test_function = None,
  841. modify = None,
  842. max_iterations = 10000,
  843. threshold = 0.0001,
  844. thresh2 = 0.0005,
  845. context = None,
  846. update_dg = None,
  847. ):
  848. from math import floor
  849. i = 0; best_so_far = 0; best = float('inf')
  850. min = 0; center = max_iterations//2; max = max_iterations
  851. # enforce getting the absolute value, in case the function has sign information
  852. # The sign may be useful in a sign-aware bisect search, but this one is more robust!
  853. test = lambda : abs(test_function(owner, attribute, index, context = context,))
  854. while (i <= max_iterations):
  855. upper = (max - ((max-center))//2)
  856. modify(owner, attribute, index, upper, context = context); error1 = test()
  857. lower = (center - ((center-min))//2)
  858. modify(owner, attribute, index, lower, context = context); error2 = test()
  859. if (error1 < error2):
  860. min = center
  861. center, check = upper, upper
  862. error = error1
  863. else:
  864. max = center
  865. center, check = lower, lower
  866. error = error2
  867. if (error <= threshold) or (min == max-1):
  868. break
  869. if (error < thresh2):
  870. j = min
  871. while (j < max):
  872. modify(owner, attribute, index, j * 1/max_iterations, context = context)
  873. error = test()
  874. if (error < best):
  875. best_so_far = j; best = error
  876. if (error <= threshold):
  877. break
  878. j+=1
  879. else: # loop has completed without finding a solution
  880. i = best_so_far; error = test()
  881. modify(owner, attribute, index, best_so_far, context = context)
  882. break
  883. if (error < best):
  884. best_so_far = check; best = error
  885. i+=1
  886. if update_dg:
  887. update_dg.update()
  888. else: # Loop has completed without finding a solution
  889. i = best_so_far
  890. modify(owner, attribute, best_so_far, context = context); i+=1