| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497 |
- extends Control
- var mainmenu_visible : bool = false #used to test if mainmenu is open
- var effect_position = Vector2(40,40) #tracks mouse position for node placement offset
- @onready var graph_edit = $GraphEdit
- var selected_nodes = {} #used to track which nodes in the GraphEdit are selected
- var cdpprogs_location #stores the cdp programs location from user prefs for easy access
- var delete_intermediate_outputs # tracks state of delete intermediate outputs toggle
- @onready var console_output: RichTextLabel = $Console/ConsoleOutput
- var final_output_dir
- var copied_nodes_data = [] #stores node data on ctrl+c
- var copied_connections = [] #stores all connections on ctrl+c
- var undo_redo := UndoRedo.new()
- var output_audio_player #tracks the node that is the current output player for linking
- var input_audio_player #tracks node that is the current input player for linking
- var outfile = "no file" #tracks dir of output file from cdp process
- var currentfile = "none" #tracks dir of currently loaded file for saving
- var changesmade = false #tracks if user has made changes to the currently loaded save file
- var savestate # tracks what the user is trying to do when savechangespopup is called
- var helpfile #tracks which help file the user was trying to load when savechangespopup is called
- var outfilename #links to the user name for outputfile field
- var foldertoggle #links to the reuse folder button
- var lastoutputfolder = "none" #tracks last output folder, this can in future be used to replace global.outfile but i cba right now
- var process_successful #tracks if the last run process was successful
- # Called when the node enters the scene tree for the first time.
- func _ready() -> void:
- Nodes.hide()
- $mainmenu.hide()
- $"mainmenu/select_effect/Time Domain".show()
- $"mainmenu/select_effect/Time Domain/Distort".show()
- $"mainmenu/select_effect/Frequency Domain/Convert".show()
- $NoLocationPopup.hide()
- $Console.hide()
- $NoInputPopup.hide()
- $MultipleConnectionsPopup.hide()
-
- $SaveDialog.access = FileDialog.ACCESS_FILESYSTEM
- $SaveDialog.file_mode = FileDialog.FILE_MODE_SAVE_FILE
- $SaveDialog.filters = ["*.thd"]
-
- $LoadDialog.access = FileDialog.ACCESS_FILESYSTEM
- $LoadDialog.file_mode = FileDialog.FILE_MODE_OPEN_FILE
- $LoadDialog.filters = ["*.thd"]
-
- #Goes through all nodes in scene and checks for buttons in the make_node_buttons group
- #Associates all buttons with the _on_button_pressed fuction and passes the button as an argument
- for child in get_tree().get_nodes_in_group("make_node_buttons"):
- if child is Button:
- child.pressed.connect(_on_button_pressed.bind(child))
-
- check_cdp_location_set()
- check_user_preferences()
- new_patch()
- get_tree().set_auto_accept_quit(false)
-
- #Check export config for version number and set about menu to current version
- #Assumes version of mac + linux builds is the same as windows
- #Requires manual update for alpha and beta builds but once the -beta is removed will be fully automatic so long as version is updated on export
- var export_config = ConfigFile.new()
- export_config.load("res://export_presets.cfg")
- $MenuBar/About.set_item_text(0, "SoundThread v" + export_config.get_value("preset.0.options", "application/product_version", "version unknown") + "-alpha")
-
- #checks if display is hidpi and scales ui accordingly
- if DisplayServer.screen_get_dpi(0) >= 144:
- get_window().content_scale_factor = 2.0
- #goes through popup_windows group and scales all popups and resizes them
- for window in get_tree().get_nodes_in_group("popup_windows"):
- window.size = window.size * 2
- window.content_scale_factor = 2
-
-
-
-
- func new_patch():
- #clear old patch
- graph_edit.clear_connections()
- for node in graph_edit.get_children():
- if node is GraphNode:
- node.queue_free()
-
- #Generate input and output nodes
- var effect: GraphNode = Nodes.get_node(NodePath("inputfile")).duplicate()
- get_node("GraphEdit").add_child(effect, true)
- effect.position_offset = Vector2(20,80)
-
- effect = Nodes.get_node(NodePath("outputfile")).duplicate()
- get_node("GraphEdit").add_child(effect, true)
- effect.position_offset = Vector2((DisplayServer.screen_get_size().x - 480) ,80)
- _register_node_movement() #link nodes for tracking position changes for changes tracking
-
- changesmade = false #so it stops trying to save unchanged empty files
- Global.infile = "no_file" #resets input to stop processes running with old files
- get_window().title = "SoundThread"
- link_output()
-
-
- func link_output():
- #links various buttons and function in the input nodes - this is called after they are created so that it still works on new and loading files
- for control in get_tree().get_nodes_in_group("outputnode"): #check all items in outputnode group
- if control.get_meta("outputfunction") == "deleteintermediate": #link delete intermediate files toggle to script
- control.toggled.connect(_toggle_delete)
- control.button_pressed = true
- elif control.get_meta("outputfunction") == "runprocess": #link runprocess button
- control.button_down.connect(_run_process)
- elif control.get_meta("outputfunction") == "recycle": #link recycle button
- control.button_down.connect(_recycle_outfile)
- elif control.get_meta("outputfunction") == "audioplayer": #link output audio player
- output_audio_player = control
- elif control.get_meta("outputfunction") == "filename":
- control.text = "outfile"
- outfilename = control
- elif control.get_meta("outputfunction") == "reusefolder":
- foldertoggle = control
- foldertoggle.button_pressed = true
- elif control.get_meta("outputfunction") == "openfolder":
- control.button_down.connect(_open_output_folder)
- for control in get_tree().get_nodes_in_group("inputnode"):
- if control.get_meta("inputfunction") == "audioplayer": #link input for recycle function
- print("input player found")
- input_audio_player = control
- func check_user_preferences():
- var interface_settings = ConfigHandler.load_interface_settings()
- $MenuBar/SettingsButton.set_item_checked(1, interface_settings.disable_pvoc_warning)
- $MenuBar/SettingsButton.set_item_checked(2, interface_settings.auto_close_console)
-
- func check_cdp_location_set():
- #checks if the location has been set and prompts user to set it
- var cdpprogs_settings = ConfigHandler.load_cdpprogs_settings()
- if cdpprogs_settings.location == "no_location":
- $NoLocationPopup.show()
- else:
- #if location is set, stores it in a variable
- cdpprogs_location = str(cdpprogs_settings.location)
- print(cdpprogs_location)
- func _on_ok_button_button_down() -> void:
- #after user has read dialog on where to find cdp progs this loads the file browser
- $NoLocationPopup.hide()
- if OS.get_name() == "Windows":
- $CdpLocationDialog.current_dir = "C:/"
- else:
- $CdpLocationDialog.current_dir = "~/"
- $CdpLocationDialog.show()
- func _on_cdp_location_dialog_dir_selected(dir: String) -> void:
- #saves default location for cdp programs in config file
- ConfigHandler.save_cdpprogs_settings(dir)
- func _on_cdp_location_dialog_canceled() -> void:
- #cycles around the set location prompt if user cancels the file dialog
- check_cdp_location_set()
-
- # Called every frame. 'delta' is the elapsed time since the previous frame.
- func _process(delta: float) -> void:
- showmenu()
-
- func _input(event):
- if event.is_action_pressed("copy_node"):
- copy_selected_nodes()
- get_viewport().set_input_as_handled()
- elif event.is_action_pressed("paste_node"):
- paste_copied_nodes()
- get_viewport().set_input_as_handled()
- elif event.is_action_pressed("undo"):
- undo_redo.undo()
- elif event.is_action_pressed("redo"):
- undo_redo.redo()
- elif event.is_action_pressed("save"):
- if currentfile == "none":
- savestate = "saveas"
- $SaveDialog.popup_centered()
- else:
- save_graph_edit(currentfile)
- #logic for making, connecting, disconnecting, copy pasting and deleteing nodes and connections in GraphEdit
- #mostly taken from https://gdscript.com/solutions/godot-graphnode-and-graphedit-tutorial/
- func showmenu():
- #check for mouse input and if menu is already open and then open or close the menu
- #stores mouse position at time of right click to later place a node in that location
- if Input.is_action_just_pressed("open_menu"):
- if mainmenu_visible == false:
- effect_position = get_viewport().get_mouse_position()
- $mainmenu.show()
- mainmenu_visible = true
- else:
- $mainmenu.hide()
- mainmenu_visible = false
- # creates nodes from menu
- func _on_button_pressed(button: Button):
- #close menu
- $mainmenu.hide()
- mainmenu_visible = false
-
- #Find node with matching name to button and create a version of it in the graph edit
- #and position it close to the origin right click to open the menu
- var effect: GraphNode = Nodes.get_node(NodePath(button.name)).duplicate()
- get_node("GraphEdit").add_child(effect, true)
- effect.position_offset = effect_position
- _register_inputs_in_node(effect) #link sliders for changes tracking
- _register_node_movement() #link nodes for tracking position changes for changes tracking
- changesmade = true
- # Remove node with UndoRedo
- undo_redo.create_action("Add Node")
- undo_redo.add_undo_method(Callable(graph_edit, "remove_child").bind(effect))
- undo_redo.add_undo_method(Callable(effect, "queue_free"))
- undo_redo.add_undo_method(Callable(self, "_track_changes"))
- undo_redo.commit_action()
- func _on_graph_edit_connection_request(from_node: StringName, from_port: int, to_node: StringName, to_port: int) -> void:
- #get_node("GraphEdit").connect_node(from_node, from_port, to_node, to_port)
- var graph_edit = get_node("GraphEdit")
- var to_graph_node = graph_edit.get_node(NodePath(to_node))
- # Get the type of the input port using GraphNode's built-in method
- var port_type = to_graph_node.get_input_port_type(to_port)
- # If port type is 1 and already has a connection, reject the request
- if port_type == 1:
- var connections = graph_edit.get_connection_list()
- var existing_connections = 0
- for conn in connections:
- if conn.to_node == to_node and conn.to_port == to_port:
- existing_connections += 1
- if existing_connections >= 1:
- var interface_settings = ConfigHandler.load_interface_settings()
- if interface_settings.disable_pvoc_warning == false:
- $MultipleConnectionsPopup.show()
- return
- # If no conflict, allow the connection
- graph_edit.connect_node(from_node, from_port, to_node, to_port)
- changesmade = true
- func _on_graph_edit_disconnection_request(from_node: StringName, from_port: int, to_node: StringName, to_port: int) -> void:
- get_node("GraphEdit").disconnect_node(from_node, from_port, to_node, to_port)
- changesmade = true
- func _on_graph_edit_node_selected(node: Node) -> void:
- selected_nodes[node] = true
- func _on_graph_edit_node_deselected(node: Node) -> void:
- selected_nodes[node] = false
- func _unhandled_key_input(event: InputEvent) -> void:
- if event is InputEventKey and event.pressed and not event.echo:
- if event.keycode == KEY_BACKSPACE:
- _on_graph_edit_delete_nodes_request(PackedStringArray(selected_nodes.keys().filter(func(k): return selected_nodes[k])))
- pass
- func _on_graph_edit_delete_nodes_request(nodes: Array[StringName]) -> void:
- var graph_edit = get_node("GraphEdit")
- undo_redo.create_action("Delete Nodes (Undo only)")
- for node in selected_nodes.keys():
- if selected_nodes[node]:
- if node.name in ["inputfile", "outputfile"]:
- print("can't delete input or output")
- else:
- # Store duplicate and state for undo
- var node_data = node.duplicate()
- var position = node.position_offset
- # Store all connections for undo
- var conns = []
- for con in graph_edit.get_connection_list():
- if con["to_node"] == node.name or con["from_node"] == node.name:
- conns.append(con)
- # Delete
- remove_connections_to_node(node)
- node.queue_free()
- changesmade = true
- # Register undo restore
- undo_redo.add_undo_method(Callable(graph_edit, "add_child").bind(node_data, true))
- undo_redo.add_undo_method(Callable(node_data, "set_position_offset").bind(position))
- for con in conns:
- undo_redo.add_undo_method(Callable(graph_edit, "connect_node").bind(
- con["from_node"], con["from_port"],
- con["to_node"], con["to_port"]
- ))
- undo_redo.add_undo_method(Callable(self, "set_node_selected").bind(node_data, true))
- undo_redo.add_undo_method(Callable(self, "_track_changes"))
- undo_redo.add_undo_method(Callable(self, "_register_inputs_in_node").bind(node_data)) #link sliders for changes tracking
- undo_redo.add_undo_method(Callable(self, "_register_node_movement")) # link nodes for changes tracking
- # Clear selection
- selected_nodes = {}
- undo_redo.commit_action()
- func set_node_selected(node: Node, selected: bool) -> void:
- selected_nodes[node] = selected
- #
- func remove_connections_to_node(node):
- for con in get_node("GraphEdit").get_connection_list():
- if con["to_node"] == node.name or con["from_node"] == node.name:
- get_node("GraphEdit").disconnect_node(con["from_node"], con["from_port"], con["to_node"], con["to_port"])
- changesmade = true
-
- #copy and paste nodes with vertical offset on paste
- func copy_selected_nodes():
- copied_nodes_data.clear()
- copied_connections.clear()
- var graph_edit = get_node("GraphEdit")
- # Store selected nodes and their slider values
- for node in graph_edit.get_children():
- # Check if the node is selected and not an 'inputfile' or 'outputfile'
- if node is GraphNode and selected_nodes.get(node, false):
- if node.name == "inputfile" or node.name == "outputfile":
- continue # Skip these nodes
- var node_data = {
- "name": node.name,
- "type": node.get_class(),
- "offset": node.position_offset,
- "slider_values": {}
- }
- for child in node.get_children():
- if child is HSlider or child is VSlider:
- node_data["slider_values"][child.name] = child.value
- copied_nodes_data.append(node_data)
- # Store connections between selected nodes
- for conn in graph_edit.get_connection_list():
- var from_ref = graph_edit.get_node_or_null(NodePath(conn["from_node"]))
- var to_ref = graph_edit.get_node_or_null(NodePath(conn["to_node"]))
- var is_from_selected = from_ref != null and selected_nodes.get(from_ref, false)
- var is_to_selected = to_ref != null and selected_nodes.get(to_ref, false)
- # Skip if any of the connected nodes are 'inputfile' or 'outputfile'
- if (from_ref != null and (from_ref.name == "inputfile" or from_ref.name == "outputfile")) or (to_ref != null and (to_ref.name == "inputfile" or to_ref.name == "outputfile")):
- continue
- if is_from_selected and is_to_selected:
- # Store connection as dictionary
- var conn_data = {
- "from_node": conn["from_node"],
- "from_port": conn["from_port"],
- "to_node": conn["to_node"],
- "to_port": conn["to_port"]
- }
- copied_connections.append(conn_data)
- func paste_copied_nodes():
- if copied_nodes_data.is_empty():
- return
- var graph_edit = get_node("GraphEdit")
- var name_map = {}
- var pasted_nodes = []
- # Step 1: Find topmost and bottommost Y of copied nodes
- var min_y = INF
- var max_y = -INF
- for node_data in copied_nodes_data:
- var y = node_data["offset"].y
- min_y = min(min_y, y)
- max_y = max(max_y, y)
- # Step 2: Decide where to paste the group
- var base_y_offset = max_y + 350 # Pasting below the lowest node
- # Step 3: Paste nodes, preserving vertical layout
- for node_data in copied_nodes_data:
- var original_node = graph_edit.get_node_or_null(NodePath(node_data["name"]))
- if not original_node:
- continue
- var new_node = original_node.duplicate()
- new_node.name = node_data["name"] + "_copy_" + str(randi() % 10000)
- var relative_y = node_data["offset"].y - min_y
- new_node.position_offset = Vector2(
- node_data["offset"].x,
- base_y_offset + relative_y
- )
-
- # Restore sliders
- for child in new_node.get_children():
- if child.name in node_data["slider_values"]:
- child.value = node_data["slider_values"][child.name]
- graph_edit.add_child(new_node, true)
- _register_inputs_in_node(new_node) #link sliders for changes tracking
- _register_node_movement() # link nodes for changes tracking
- name_map[node_data["name"]] = new_node.name
- pasted_nodes.append(new_node)
- # Step 4: Reconnect new nodes
- for conn_data in copied_connections:
- var new_from = name_map.get(conn_data["from_node"], null)
- var new_to = name_map.get(conn_data["to_node"], null)
- if new_from and new_to:
- graph_edit.connect_node(new_from, conn_data["from_port"], new_to, conn_data["to_port"])
- # Step 5: Select pasted nodes
- for pasted_node in pasted_nodes:
- graph_edit.set_selected(pasted_node)
- selected_nodes[pasted_node] = true
-
- changesmade = true
-
- # Remove node with UndoRedo
- undo_redo.create_action("Paste Nodes")
- for pasted_node in pasted_nodes:
- undo_redo.add_undo_method(Callable(graph_edit, "remove_child").bind(pasted_node))
- undo_redo.add_undo_method(Callable(pasted_node, "queue_free"))
- undo_redo.add_undo_method(Callable(self, "remove_connections_to_node").bind(pasted_node))
- undo_redo.add_undo_method(Callable(self, "_track_changes"))
- undo_redo.commit_action()
-
- #functions for tracking changes for save state detection
- func _register_inputs_in_node(node: Node):
- #tracks input to nodes sliders and codeedit to track if patch is saved
- # Track Sliders
- for slider in node.find_children("*", "HSlider", true, false):
- # Create a Callable to the correct method
- var callable = Callable(self, "_on_any_slider_changed")
- # Check if it's already connected, and connect if not
- if not slider.is_connected("value_changed", callable):
- slider.connect("value_changed", callable)
-
- # Track CodeEdits (if necessary)
- for editor in node.find_children("*", "CodeEdit", true, false):
- var callable = Callable(self, "_on_any_input_changed")
- if not editor.is_connected("text_changed", callable):
- editor.connect("text_changed", callable)
-
- func _register_node_movement():
- for graphnode in graph_edit.get_children():
- if graphnode is GraphNode:
- var callable = Callable(self, "_on_graphnode_moved")
- if not graphnode.is_connected("position_offset_changed", callable):
- graphnode.connect("position_offset_changed", callable)
- func _on_graphnode_moved():
- changesmade = true
-
- func _on_any_slider_changed(value: float) -> void:
- changesmade = true
-
- func _on_any_input_changed():
- changesmade = true
- func _track_changes():
- changesmade = true
-
- func _run_process() -> void:
- if Global.infile == "no_file":
- $NoInputPopup.show()
- else:
- if foldertoggle.button_pressed == true and lastoutputfolder != "none":
- _on_file_dialog_dir_selected(lastoutputfolder)
- else:
- $FileDialog.show()
-
- func _on_file_dialog_dir_selected(dir: String) -> void:
- lastoutputfolder = dir
- console_output.clear()
- $Console.show()
- await get_tree().process_frame
- log_console("Generating processing queue", true)
- await get_tree().process_frame
- #get the current time in hh-mm-ss format as default : causes file name issues
- var time_dict = Time.get_time_dict_from_system()
- # Pad with zeros to ensure two digits for hour, minute, second
- var hour = str(time_dict.hour).pad_zeros(2)
- var minute = str(time_dict.minute).pad_zeros(2)
- var second = str(time_dict.second).pad_zeros(2)
- var time_str = hour + "-" + minute + "-" + second
- Global.outfile = dir + "/" + outfilename.text.get_basename() + "_" + Time.get_date_string_from_system() + "_" + time_str
- log_console("Output directory and file name(s):" + Global.outfile, true)
- await get_tree().process_frame
-
- run_thread_with_branches()
-
- func run_thread_with_branches():
- # Detect platform: Determine if the OS is Windows
- var is_windows := OS.get_name() == "Windows"
-
- # Choose appropriate commands based on OS
- var delete_cmd = "del" if is_windows else "rm"
- var rename_cmd = "ren" if is_windows else "mv"
- var path_sep := "/" # Always use forward slash for paths
- # Get all node connections in the GraphEdit
- var connections = graph_edit.get_connection_list()
- # Prepare data structures for graph traversal
- var graph = {} # forward adjacency list
- var reverse_graph = {} # reverse adjacency list (for input lookup)
- var indegree = {} # used for topological sort
- var all_nodes = {} # map of node name -> GraphNode reference
- log_console("Mapping thread.", true)
- await get_tree().process_frame # Let UI update
- #Step 0: check thread is valid
- var is_valid = path_exists_through_all_nodes()
- if is_valid == false:
- log_console("[color=#9c2828][b]Error: Valid Thread not found[/b][/color]", true)
- log_console("Threads must contain at least one processing node and a valid path from the Inputfile to the Outputfile.", true)
- await get_tree().process_frame # Let UI update
- return
- else:
- log_console("[color=#638382][b]Valid Thread found[/b][/color]", true)
- await get_tree().process_frame # Let UI update
-
- # Step 1: Gather nodes from the GraphEdit
- for child in graph_edit.get_children():
- if child is GraphNode:
- var name = str(child.name)
- all_nodes[name] = child
- if not child.has_meta("utility"):
- graph[name] = []
- reverse_graph[name] = []
- indegree[name] = 0 # Start with zero incoming edges
- # Step 2: Build graph relationships from connections
- for conn in connections:
- var from = str(conn["from_node"])
- var to = str(conn["to_node"])
- if graph.has(from) and graph.has(to):
- graph[from].append(to)
- reverse_graph[to].append(from)
- indegree[to] += 1 # Count incoming edges
- # Step 3: Topological sort to get execution order
- var sorted = [] # Sorted list of node names
- var queue = [] # Queue of nodes with 0 indegree
- for node in graph.keys():
- if indegree[node] == 0:
- queue.append(node)
- while not queue.is_empty():
- var current = queue.pop_front()
- sorted.append(current)
- for neighbor in graph[current]:
- indegree[neighbor] -= 1
- if indegree[neighbor] == 0:
- queue.append(neighbor)
- # If not all nodes were processed, there's a cycle
- if sorted.size() != graph.size():
- log_console("[color=#9c2828][b]Error: Thread not valid[/b][/color]", true)
- log_console("Threads cannot contain loops.", true)
- return
- # Step 4: Start processing audio
- var batch_lines = [] # Holds all batch file commands
- var intermediate_files = [] # Files to delete later
- # Dictionary to keep track of each node's output file
- var output_files = {}
- var process_count = 0
- # Start with the original input file
- var current_infile = Global.infile
- # Iterate over the processing nodes in topological order
- for node_name in sorted:
- var node = all_nodes[node_name]
-
- # Find upstream nodes connected to the current node
- var inputs = reverse_graph[node_name]
- var input_files = []
- for input_node in inputs:
- input_files.append(output_files[input_node])
- # Merge inputs if this node has more than one input
- if input_files.size() > 1:
- # Prepare final merge output file name
- var runmerge = merge_many_files(process_count, input_files)
- var merge_output = runmerge[0]
- var converted_files = runmerge[1]
- # Track the output and intermediate files
- current_infile = merge_output
-
- if delete_intermediate_outputs:
- intermediate_files.append(merge_output)
- for f in converted_files:
- intermediate_files.append(f)
- # If only one input, use that
- elif input_files.size() == 1:
- current_infile = input_files[0]
- ## If no input, use the original input file
- #else:
- #current_infile = Global.infile
- # Build the command for the current node's audio processing
- var slider_data = _get_slider_values_ordered(node)
-
- if node.get_slot_type_right(0) == 1: #detect if process outputs pvoc data
- if typeof(current_infile) == TYPE_ARRAY:
- #check if infile is an array meaning that the last pvoc process was run in dual mono mode
- # Process left and right seperately
- var pvoc_stereo_files = []
-
- for infile in current_infile:
- var makeprocess = make_process(node, process_count, infile, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- pvoc_stereo_files.append(output_file)
-
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- process_count += 1
-
- output_files[node_name] = pvoc_stereo_files
- else:
- var input_stereo = is_stereo(current_infile)
- if input_stereo == true:
- #audio file is stereo and needs to be split for pvoc processing
- var pvoc_stereo_files = []
- ##Split stereo to c1/c2
- run_command(cdpprogs_location + "/housekeep chans 2 " + "\"%s\"" % current_infile)
-
- # Process left and right seperately
- for channel in ["c1", "c2"]:
- var dual_mono_file = current_infile.get_basename() + "_%s.wav" % channel
-
- var makeprocess = make_process(node, process_count, dual_mono_file, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- pvoc_stereo_files.append(output_file)
-
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
-
- #Delete c1 and c2 because they can be in the wrong folder and if the same infile is used more than once
- #with this stereo process CDP will throw errors in the console even though its fine
- if is_windows:
- dual_mono_file = dual_mono_file.replace("/", "\\")
- run_command("%s \"%s\"" % [delete_cmd, dual_mono_file])
- process_count += 1
-
- # Store output file path for this node
- output_files[node_name] = pvoc_stereo_files
- else:
- #input file is mono run through process
- var makeprocess = make_process(node, process_count, current_infile, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- # Store output file path for this node
- output_files[node_name] = output_file
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- # Increase the process step count
- process_count += 1
-
- else:
- #Process outputs audio
- #check if this is the last pvoc process in a stereo processing chain
- if node.get_meta("command") == "pvoc_synth" and typeof(current_infile) == TYPE_ARRAY:
-
- #check if infile is an array meaning that the last pvoc process was run in dual mono mode
- # Process left and right seperately
- var pvoc_stereo_files = []
-
- for infile in current_infile:
- var makeprocess = make_process(node, process_count, infile, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- pvoc_stereo_files.append(output_file)
-
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- process_count += 1
-
-
- #interleave left and right
- var output_file = Global.outfile.get_basename() + str(process_count) + "_interleaved.wav"
- run_command(cdpprogs_location + "/submix interleave" + " \"%s\"" % pvoc_stereo_files[0] + " \"%s\"" % pvoc_stereo_files[1] + " \"%s\"" % output_file)
-
- # Store output file path for this node
- output_files[node_name] = output_file
- else:
- #Detect if input file is mono or stereo
- var input_stereo = is_stereo(current_infile)
- if input_stereo == true:
- if node.get_meta("stereo_input") == true: #audio file is stereo and process is stereo, run file through process
- var makeprocess = make_process(node, process_count, current_infile, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
-
- # Store output file path for this node
- output_files[node_name] = output_file
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- else: #audio file is stereo and process is mono, split stereo, process and recombine
- ##Split stereo to c1/c2
- run_command(cdpprogs_location + "/housekeep chans 2 " + "\"%s\"" % current_infile)
-
- # Process left and right seperately
- var dual_mono_output = []
- for channel in ["c1", "c2"]:
- var dual_mono_file = current_infile.get_basename() + "_%s.wav" % channel
-
- var makeprocess = make_process(node, process_count, dual_mono_file, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- dual_mono_output.append(output_file)
-
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
-
- #Delete c1 and c2 because they can be in the wrong folder and if the same infile is used more than once
- #with this stereo process CDP will throw errors in the console even though its fine
- if is_windows:
- dual_mono_file = dual_mono_file.replace("/", "\\")
- run_command("%s \"%s\"" % [delete_cmd, dual_mono_file])
- process_count += 1
-
-
- var output_file = Global.outfile.get_basename() + str(process_count) + "_interleaved.wav"
- run_command(cdpprogs_location + "/submix interleave" + " \"%s\"" % dual_mono_output[0] + " \"%s\"" % dual_mono_output[1] + " \"%s\"" % output_file)
-
- # Store output file path for this node
- output_files[node_name] = output_file
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- else: #audio file is mono, run through the process
- var makeprocess = make_process(node, process_count, current_infile, slider_data)
- # run the command
- run_command(makeprocess[0])
- await get_tree().process_frame
- var output_file = makeprocess[1]
- # Store output file path for this node
- output_files[node_name] = output_file
- # Mark file for cleanup if needed
- if delete_intermediate_outputs:
- intermediate_files.append(output_file)
- # Increase the process step count
- process_count += 1
- # FINAL OUTPUT STAGE
- # Collect all nodes that are connected to the outputfile node
- var output_inputs := []
- for conn in connections:
- if conn["to_node"] == "outputfile":
- output_inputs.append(str(conn["from_node"]))
- # List to hold the final output files to be merged (if needed)
- var final_outputs := []
- for node_name in output_inputs:
- if output_files.has(node_name):
- final_outputs.append(output_files[node_name])
- # If multiple outputs go to the outputfile node, merge them
- if final_outputs.size() > 1:
- var runmerge = merge_many_files(process_count, final_outputs)
- final_output_dir = runmerge[0]
- var converted_files = runmerge[1]
-
- if delete_intermediate_outputs:
- for f in converted_files:
- intermediate_files.append(f)
- # Only one output, no merge needed
- elif final_outputs.size() == 1:
- var single_output = final_outputs[0]
- final_output_dir = single_output
- intermediate_files.erase(single_output)
- # CLEANUP: Delete intermediate files after processing and rename final output
- log_console("Cleaning up intermediate files.", true)
- for file_path in intermediate_files:
- # Adjust file path format for Windows if needed
- var fixed_path = file_path
- if is_windows:
- fixed_path = fixed_path.replace("/", "\\")
- run_command("%s \"%s\"" % [delete_cmd, fixed_path])
- await get_tree().process_frame
-
- var final_filename = "\"%s.wav\"" % Global.outfile
- var final_output_dir_fixed_path = final_output_dir
- if is_windows:
- final_output_dir_fixed_path = final_output_dir_fixed_path.replace("/", "\\")
- run_command(rename_cmd + " \"%s\"" % final_output_dir_fixed_path + " " + final_filename.get_file())
- else:
- run_command(rename_cmd + " \"%s\"" % final_output_dir_fixed_path + " \"%s.wav\"" % Global.outfile)
- final_output_dir = Global.outfile + ".wav"
-
- output_audio_player.play_outfile(final_output_dir)
- outfile = final_output_dir
-
- var interface_settings = ConfigHandler.load_interface_settings() #checks if close console is enabled and closes console on a success
- if interface_settings.auto_close_console and process_successful == true:
- $Console.hide()
- func is_stereo(file: String) -> bool:
- var output = run_command(cdpprogs_location + "/sfprops -c " + "\"%s\"" % file)
- output = int(output[0].strip_edges()) #convert output from cmd to clean int
- if output == 1:
- return false
- elif output == 2:
- return true
- elif output == 1026: #ignore pvoc .ana files
- return false
- else:
- log_console("[color=#9c2828]Error: Only mono and stereo files are supported[/color]", true)
- return false
- func merge_many_files(process_count: int, input_files: Array) -> Array:
- var merge_output = "%s_merge_%d.wav" % [Global.outfile.get_basename(), process_count]
- var converted_files := [] # Track any mono->stereo converted files
- var inputs_to_merge := [] # Files to be used in the final merge
- var mono_files := []
- var stereo_files := []
- # STEP 1: Check each file's channel count
- for f in input_files:
- var output = run_command(cdpprogs_location + "/sfprops -c " + "\"%s\"" % f)
- if process_successful == true and output.size() > 0:
- var channels = int(output[0].strip_edges())
- if channels == 1:
- mono_files.append(f)
- elif channels == 2:
- stereo_files.append(f)
- else:
- push_error("Unexpected channel count in file: %s" % f)
- else:
- push_error("Failed to get channel count for file: %s" % f)
- # STEP 2: Convert mono to stereo if there is a mix
- if mono_files.size() > 0 and stereo_files.size() > 0:
- for mono_file in mono_files:
- var stereo_file = "%s_stereo.wav" % mono_file.get_basename()
- run_command(cdpprogs_location + "/submix interleave" + " \"%s\"" % mono_file + " \"%s\"" % mono_file + " \"%s\"" % stereo_file)
- if process_successful == false:
- log_console("Failed to interleave mono file: %s" % mono_file, true)
- else:
- converted_files.append(stereo_file)
- inputs_to_merge.append(stereo_file)
- # Add existing stereo files
- inputs_to_merge += stereo_files
- else:
- # All mono or all stereo — use input_files directly
- inputs_to_merge = input_files.duplicate()
- # STEP 3: Merge all input files (converted or original)
- var quoted_inputs := []
- for f in inputs_to_merge:
- quoted_inputs.append("\"%s\"" % f)
- run_command(cdpprogs_location + "/submix mergemany " + " ".join(quoted_inputs) + " \"%s\"" % merge_output)
- if process_successful == false:
- log_console("Failed to to merge files to" + merge_output, true)
-
- return [merge_output, converted_files]
- func _get_slider_values_ordered(node: Node) -> Array:
- var results := []
- for child in node.get_children():
- if child is Range:
- var flag = child.get_meta("flag") if child.has_meta("flag") else ""
- results.append([flag, child.value])
- elif child.get_child_count() > 0:
- var nested := _get_slider_values_ordered(child)
- results.append_array(nested)
- return results
- #func build_graph_from_connections(graph_edit: GraphEdit) -> Dictionary:
- #var connections = graph_edit.get_connection_list()
- #var graph := {}
- #var reverse_graph := {}
- #var all_nodes := {}
- #
- ## Collect all GraphNode names
- #for child in graph_edit.get_children():
- #if child is GraphNode:
- #var name = str(child.name)
- #all_nodes[name] = true
- #graph[name] = []
- #reverse_graph[name] = []
- #
- ## Build forward and reverse graphs
- #for conn in connections:
- #var from = str(conn["from_node"])
- #var to = str(conn["to_node"])
- #if graph.has(from) and graph.has(to):
- #graph[from].append(to)
- #reverse_graph[to].append(from)
- #
- ## Perform BFS from "inputfile"
- #var reachable := {}
- #var queue := ["inputfile"]
- #while not queue.is_empty():
- #var current = queue.pop_front()
- #if reachable.has(current):
- #continue
- #reachable[current] = true
- #for neighbor in graph.get(current, []):
- #queue.append(neighbor)
- #
- ## Reverse BFS from "outputfile"
- #var required := {}
- #queue = ["outputfile"]
- #while not queue.is_empty():
- #var current = queue.pop_front()
- #if required.has(current):
- #continue
- #required[current] = true
- #for parent in reverse_graph.get(current, []):
- #queue.append(parent)
- #
- ## Keep only nodes that are reachable both ways
- #var used_nodes := []
- #for node in reachable.keys():
- #if required.has(node):
- #used_nodes.append(node)
- #
- #var pruned_graph := {}
- #for node in used_nodes:
- #var filtered_neighbors := []
- #for neighbor in graph.get(node, []):
- #if used_nodes.has(neighbor):
- #filtered_neighbors.append(neighbor)
- #pruned_graph[node] = filtered_neighbors
- #
- #return {
- #"graph": pruned_graph,
- #"nodes": used_nodes
- #}
- #func topological_sort(graph: Dictionary, nodes: Array) -> Array:
- #var indegree := {}
- #for node in nodes:
- #indegree[node] = 0
- #for node in nodes:
- #for neighbor in graph[node]:
- #indegree[neighbor] += 1
- #
- #var queue := []
- #for node in nodes:
- #if indegree[node] == 0:
- #queue.append(node)
- #
- #var sorted := []
- #while not queue.is_empty():
- #var current = queue.pop_front()
- #sorted.append(current)
- #for neighbor in graph[current]:
- #indegree[neighbor] -= 1
- #if indegree[neighbor] == 0:
- #queue.append(neighbor)
- #
- #if sorted.size() != nodes.size():
- #push_error("Cycle detected or disconnected graph.")
- #return []
- #
- #return sorted
- func make_process(node: Node, process_count: int, current_infile: String, slider_data: Array) -> Array:
- # Determine output extension: .wav or .ana based on the node's slot type
- var extension = ".wav" if node.get_slot_type_right(0) == 0 else ".ana"
- # Construct output filename for this step
- var output_file = "%s_%d%s" % [Global.outfile.get_basename(), process_count, extension]
- # Get the command name from metadata or default to node name
- var command_name = str(node.get_meta("command"))
- command_name = command_name.replace("_", " ")
- # Start building the command line
- var line = "%s/%s \"%s\" \"%s\" " % [cdpprogs_location, command_name, current_infile, output_file]
- # Append parameter values from the sliders, include flags if present
- for entry in slider_data:
- var flag = entry[0]
- var value = entry[1]
- line += ("%s%.2f " % [flag, value]) if flag.begins_with("-") else ("%.2f " % value)
-
- return [line.strip_edges(), output_file]
- func run_command(command: String) -> Array:
- var is_windows = OS.get_name() == "Windows"
- var output: Array = []
- var error: Array = []
- var exit_code := 0
- if is_windows:
- exit_code = OS.execute("cmd.exe", ["/C", command], output, true, false)
- else:
- exit_code = OS.execute("sh", [command], output, true, false)
- var output_str := ""
- for item in output:
- output_str += item + "\n"
- var error_str := ""
- for item in error:
- error_str += item + "\n"
-
- console_output.append_text(command + "\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
-
- if exit_code == 0:
- if output_str.contains("ERROR:"): #checks if CDP reported an error but passed exit code 0 anyway
- console_output.append_text("[color=#9c2828][b]Processes failed[/b][/color]\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(output_str + "\n")
- process_successful = false
- else:
- console_output.append_text("[color=#638382]Processes ran successfully[/color]\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(output_str + "\n")
- process_successful = true
-
- else:
- console_output.append_text("[color=#9c2828][b]Processes failed with exit code: %d[/b][/color]\n" % exit_code)
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(error_str + "\n")
- process_successful = false
-
- return output
- func run_batch_file():
- var is_windows = OS.get_name() == "Windows"
- var script_ext = ".bat" if is_windows else ".sh"
- var script_name = "ordered_script" + script_ext
- var script_path = ProjectSettings.globalize_path("user://%s" % script_name)
- var output: Array = []
- var error: Array = []
- var exit_code := 0
- if is_windows:
- exit_code = OS.execute("cmd.exe", ["/c", script_path], output, true, true)
- else:
- exit_code = OS.execute("sh", [script_path], output, true, true)
- var output_str := ""
- for item in output:
- output_str += item + "\n"
- var error_str := ""
- for item in error:
- error_str += item + "\n"
- if exit_code == 0:
- if output_str.contains("ERROR:"): #checks if CDP reported an error but passed exit code 0 anyway
- console_output.append_text("[color=red][b]Processes failed[/b][/color]\n\n")
- console_output.append_text("[b]Error:[/b]\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(output_str + "\n")
- else:
- console_output.append_text("[color=green]Processes ran successfully[/color]\n\n")
- console_output.append_text("[b]Output:[/b]\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(output_str + "\n")
-
- if final_output_dir.ends_with(".wav"):
- output_audio_player.play_outfile(final_output_dir)
- outfile = final_output_dir
-
- var interface_settings = ConfigHandler.load_interface_settings() #checks if close console is enabled and closes console on a success
- if interface_settings.auto_close_console:
- $Console.hide()
- else:
- console_output.append_text("[color=red][b]Processes failed with exit code: %d[/b][/color]\n\n" % exit_code)
- console_output.append_text("[b]Error:[/b]\n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- console_output.append_text(error_str + "\n")
-
- func path_exists_through_all_nodes() -> bool:
- var all_nodes = {}
- var graph = {}
- # Gather all relevant nodes
- for child in graph_edit.get_children():
- if child is GraphNode:
- var name = str(child.name)
- all_nodes[name] = child
- if name in ["inputfile", "outputfile"] or not child.has_meta("utility"):
- graph[name] = []
- # Add edges to graph from the connection list
- var connection_list = graph_edit.get_connection_list()
- for conn in connection_list:
- var from = str(conn["from_node"])
- var to = str(conn["to_node"])
- if graph.has(from):
- graph[from].append(to)
- # BFS traversal to check path and depth
- var visited = {}
- var queue = [ { "node": "inputfile", "depth": 0 } ]
- var has_intermediate = false
- while queue.size() > 0:
- var current = queue.pop_front()
- var current_node = current["node"]
- var depth = current["depth"]
- if current_node in visited:
- continue
- visited[current_node] = true
- if current_node == "outputfile" and depth >= 2:
- has_intermediate = true
- if graph.has(current_node):
- for neighbor in graph[current_node]:
- queue.append({ "node": neighbor, "depth": depth + 1 })
- return has_intermediate
- func _toggle_delete(toggled_on: bool):
- delete_intermediate_outputs = toggled_on
- print(toggled_on)
- func _on_console_close_requested() -> void:
- $Console.hide()
- func log_console(text: String, update: bool) -> void:
- console_output.append_text(text + "\n \n")
- console_output.scroll_to_line(console_output.get_line_count() - 1)
- if update == true:
- await get_tree().process_frame # Optional: ensure UI updates
- func _on_console_open_folder_button_down() -> void:
- $Console.hide()
- OS.shell_open(Global.outfile.get_base_dir())
- func _on_ok_button_2_button_down() -> void:
- $NoInputPopup.hide()
- func _on_ok_button_3_button_down() -> void:
- $MultipleConnectionsPopup.hide()
- func _on_settings_button_index_pressed(index: int) -> void:
- var interface_settings = ConfigHandler.load_interface_settings()
-
- match index:
- 0:
- $CdpLocationDialog.show()
- 1:
- if interface_settings.disable_pvoc_warning == false:
- $MenuBar/SettingsButton.set_item_checked(index, true)
- ConfigHandler.save_interface_settings("disable_pvoc_warning", true)
- else:
- $MenuBar/SettingsButton.set_item_checked(index, false)
- ConfigHandler.save_interface_settings("disable_pvoc_warning", false)
- 2:
- if interface_settings.auto_close_console == false:
- $MenuBar/SettingsButton.set_item_checked(index, true)
- ConfigHandler.save_interface_settings("auto_close_console", true)
- else:
- $MenuBar/SettingsButton.set_item_checked(index, false)
- ConfigHandler.save_interface_settings("auto_close_console", false)
- 3:
- $Console.show()
- func _on_file_button_index_pressed(index: int) -> void:
- match index:
- 0:
- if changesmade == true:
- savestate = "newfile"
- $SaveChangesPopup.show()
- else:
- new_patch()
- currentfile = "none" #reset current file to none for save tracking
- 1:
- if currentfile == "none":
- savestate = "saveas"
- $SaveDialog.popup_centered()
- else:
- save_graph_edit(currentfile)
- 2:
- savestate = "saveas"
- $SaveDialog.popup_centered()
- 3:
- if changesmade == true:
- savestate = "load"
- $SaveChangesPopup.show()
- else:
- $LoadDialog.popup_centered()
- func save_graph_edit(path: String):
- var file = FileAccess.open(path, FileAccess.WRITE)
- if file == null:
- print("Failed to open file for saving")
- return
- var node_data_list = []
- var connection_data_list = []
- for node in graph_edit.get_children():
- if node is GraphNode:
- var offset = node.position_offset
- var node_data = {
- "name": node.name,
- "command": node.get_meta("command"),
- "offset": { "x": offset.x, "y": offset.y },
- "slider_values": {},
- "notes":{}
- }
- for child in node.find_children("*", "Slider", true, false):
- var relative_path = node.get_path_to(child)
- node_data["slider_values"][str(relative_path)] = child.value
-
- for child in node.find_children("*", "CodeEdit", true, false):
- node_data["notes"][child.name] = child.text
- node_data_list.append(node_data)
- for conn in graph_edit.get_connection_list():
- connection_data_list.append({
- "from_node": conn["from_node"],
- "from_port": conn["from_port"],
- "to_node": conn["to_node"],
- "to_port": conn["to_port"]
- })
- var graph_data = {
- "nodes": node_data_list,
- "connections": connection_data_list
- }
- var json = JSON.new()
- var json_string = json.stringify(graph_data, "\t")
- file.store_string(json_string)
- file.close()
- print("Graph saved.")
- changesmade = false
- get_window().title = "SoundThread - " + path.get_file().trim_suffix(".thd")
- func load_graph_edit(path: String):
- var file = FileAccess.open(path, FileAccess.READ)
- if file == null:
- print("Failed to open file for loading")
- return
- var json_text = file.get_as_text()
- file.close()
- var json = JSON.new()
- if json.parse(json_text) != OK:
- print("Error parsing JSON")
- return
- var graph_data = json.get_data()
- graph_edit.clear_connections()
- for node in graph_edit.get_children():
- if node is GraphNode:
- node.queue_free()
- await get_tree().process_frame # Ensure nodes are cleared
- for node_data in graph_data["nodes"]:
- var command_name = node_data.get("command", "")
- var template = Nodes.get_node_or_null(command_name)
- if not template:
- print("Template not found for command:", command_name)
- continue
- var new_node: GraphNode = template.duplicate()
- new_node.name = node_data["name"]
- new_node.position_offset = Vector2(node_data["offset"]["x"], node_data["offset"]["y"])
- new_node.set_meta("command", command_name)
- graph_edit.add_child(new_node)
- _register_node_movement() #link nodes for tracking position changes for changes tracking
- # Restore sliders
- for slider_path_str in node_data["slider_values"]:
- var slider = new_node.get_node_or_null(slider_path_str)
- if slider and (slider is HSlider or slider is VSlider):
- slider.value = node_data["slider_values"][slider_path_str]
-
-
-
- # Restore notes
- for codeedit_name in node_data["notes"]:
- var codeedit = new_node.find_child(codeedit_name, true, false)
- if codeedit and (codeedit is CodeEdit):
- codeedit.text = node_data["notes"][codeedit_name]
- _register_inputs_in_node(new_node) #link sliders for changes tracking
- # Restore connections
- for conn in graph_data["connections"]:
- graph_edit.connect_node(
- conn["from_node"], conn["from_port"],
- conn["to_node"], conn["to_port"]
- )
- link_output()
- print("Graph loaded.")
- get_window().title = "SoundThread - " + path.get_file().trim_suffix(".thd")
- func _on_save_dialog_file_selected(path: String) -> void:
- save_graph_edit(path) #save file
- #check what the user was trying to do before save and do that action
- if savestate == "newfile":
- new_patch()
- currentfile = "none" #reset current file to none for save tracking
- elif savestate == "load":
- $LoadDialog.popup_centered()
- elif savestate == "helpfile":
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit(helpfile)
- elif savestate == "quit":
- await get_tree().create_timer(0.25).timeout #little pause so that it feels like it actually saved even though it did
- get_tree().quit()
-
- savestate = "none" #reset save state, not really needed but feels good
- func _on_load_dialog_file_selected(path: String) -> void:
- currentfile = path #tracking path here only means "save" only saves patches the user has loaded rather than overwriting help files
- load_graph_edit(path)
- func _on_help_button_index_pressed(index: int) -> void:
- match index:
- 0:
- pass
- 1:
- if changesmade == true:
- savestate = "helpfile"
- helpfile = "res://examples/getting_started.thd"
- $SaveChangesPopup.show()
- else:
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit("res://examples/getting_started.thd")
- 2:
- if changesmade == true:
- savestate = "helpfile"
- helpfile = "res://examples/navigating.thd"
- $SaveChangesPopup.show()
- else:
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit("res://examples/navigating.thd")
- 3:
- if changesmade == true:
- savestate = "helpfile"
- helpfile = "res://examples/building_a_thread.thd"
- $SaveChangesPopup.show()
- else:
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit("res://examples/building_a_thread.thd")
- 4:
- if changesmade == true:
- savestate = "helpfile"
- helpfile = "res://examples/frequency_domain.thd"
- $SaveChangesPopup.show()
- else:
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit("res://examples/frequency_domain.thd")
- 5:
- if changesmade == true:
- savestate = "helpfile"
- helpfile = "res://examples/quirks.thd"
- $SaveChangesPopup.show()
- else:
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit("res://examples/quirks.thd")
- 6:
- pass
- 7:
- OS.shell_open("https://www.composersdesktop.com/docs/html/cdphome.htm")
- func _recycle_outfile():
- if outfile != "no file":
- input_audio_player.recycle_outfile(outfile)
- func _on_save_changes_button_down() -> void:
- $SaveChangesPopup.hide()
- if currentfile == "none":
- $SaveDialog.show()
- else:
- save_graph_edit(currentfile)
- if savestate == "newfile":
- new_patch()
- currentfile = "none" #reset current file to none for save tracking
- elif savestate == "load":
- $LoadDialog.popup_centered()
- elif savestate == "helpfile":
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit(helpfile)
- elif savestate == "quit":
- await get_tree().create_timer(0.25).timeout #little pause so that it feels like it actually saved even though it did
- get_tree().quit()
-
- savestate = "none"
- func _on_dont_save_changes_button_down() -> void:
- $SaveChangesPopup.hide()
- if savestate == "newfile":
- new_patch()
- currentfile = "none" #reset current file to none for save tracking
- elif savestate == "load":
- $LoadDialog.popup_centered()
- elif savestate == "helpfile":
- currentfile = "none" #reset current file to none for save tracking so user cant save over help file
- load_graph_edit(helpfile)
- elif savestate == "quit":
- get_tree().quit()
-
- savestate = "none"
-
- func _notification(what):
- if what == NOTIFICATION_WM_CLOSE_REQUEST:
- if changesmade == true:
- savestate = "quit"
- $SaveChangesPopup.show()
- else:
- get_tree().quit() # default behavior
-
- func _open_output_folder():
- if lastoutputfolder != "none":
- OS.shell_open(lastoutputfolder)
-
- func _on_rich_text_label_meta_clicked(meta: Variant) -> void:
- print(str(meta))
- OS.shell_open(str(meta))
|