Add saving to the application

Author: NetroScript

scripts/Application.gd

@@ -24,7 +24,7 @@ var currently_loaded_files: Array[ProcessedImage] = []
 var current_loading_index := 0
 var currently_active_item: ProcessedImage
 
-var output_path: String = ""
+var output_path: String = "./"
 var current_file_format : FILE_FORMATS = FILE_FORMATS.SAME_AS_INPUT
 
 # Possible entries {directory_tree}, {file},{extension}, {index}, {width}, {height}, {rotations}, {rect.x}, {rect.y}, {rect.width}, {rect.height}
@@ -45,6 +45,11 @@ var current_active_index := -1 :
 			currently_active_item = currently_loaded_files[current_active_index]
 			active_item_changed.emit(currently_active_item)
 			currently_active_item.is_active = true
+			return
+			
+		# If we are at the last item, emit it again so that it gets saved
+		if value == currently_loaded_files.size():
+			active_item_changed.emit(currently_active_item)
 
 var thread_polling_timer: Timer
 var thread_workers: Array[ImageThreadWorker] = []
@@ -130,6 +135,14 @@ func threaded_crop_image(image: Image, size: Rect2i, callback: Callable) -> void
 	})
 	var worker := select_worker()
 	worker.add_item_to_queue(worktask)
+	
+func threaded_save_image(image: Image, path: String, callback: Callable) -> void:
+	
+	var worktask := ImageThreadWorkerTask.new(callback, path, ImageThreadWorkerTask.WORKER_TASKS.STORE, {
+		"image": image,
+	})
+	var worker := select_worker()
+	worker.add_item_to_queue(worktask)
 
 func select_worker() -> ImageThreadWorker:
 	# Find a non working thread
@@ -218,6 +231,9 @@ class ImageThreadWorker extends Resource:
 					ImageThreadWorkerTask.WORKER_TASKS.CROP:
 						var image := thread.wait_to_finish() as Image
 						current_work_item.callback.call(image)
+					ImageThreadWorkerTask.WORKER_TASKS.STORE:
+						var status := thread.wait_to_finish() as int
+						current_work_item.callback.call(status)
 
 				current_work_item = null
 				check_for_work()
@@ -237,6 +253,12 @@ class ImageThreadWorker extends Resource:
 							current_work_item.data_playload["size"],
 							current_work_item.data_playload["crop_size"],
 						))
+					
+					ImageThreadWorkerTask.WORKER_TASKS.STORE:
+						thread.start(save_image.bind(
+							current_work_item.data_playload["image"],
+							current_work_item.path
+						))
 
 
 	func load_image_texture(path: String) -> ImageTexture:
@@ -261,3 +283,22 @@ class ImageThreadWorker extends Resource:
 		new_image.resize(size.x, size.y, Image.INTERPOLATE_LANCZOS)
 
 		return new_image
+
+	func save_image(image: Image, path: String) -> int:
+		
+		# Get the extension of our image
+		var extension := path.get_extension().to_lower()
+		
+		# Recursively ensure that the directory exists
+		DirAccess.make_dir_recursive_absolute(path.get_base_dir())
+		
+		# Based on the extension call the different saving routines
+		match extension:
+			"png":
+				return image.save_png(path)
+			"jpg", "jpeg":
+				return image.save_jpg(path, 0.8)
+			"webp":
+				return image.save_webp(path)
+		
+		return 0

scripts/ImageScrollManager.gd

@@ -28,13 +28,16 @@ func _ready() -> void:
 
 	resized.connect(func(): old_scroll_position = -1)
 
-	Application.active_item_changed.connect(func(item: ProcessedImage): scroll_horizontal = (item.index - (visible_items / 2)) * item_width)
+	Application.active_item_changed.connect(on_active_item_changed)
 
 	image_update_timer = Timer.new()
 	image_update_timer.wait_time = 0.25
 	add_child(image_update_timer)
 	image_update_timer.timeout.connect(load_and_unload_images)
 	image_update_timer.start()
+	
+func on_active_item_changed(item: ProcessedImage) -> void: 
+	scroll_horizontal = (item.index - (visible_items / 2)) * item_width
 
 func load_and_unload_images():
 

scripts/ProcessedImage.gd

@@ -8,7 +8,7 @@ signal was_unloaded
 signal active_changed
 
 var source_path: String
-var processed_path: String
+var processed_path: String = ""
 var is_currently_loaded := false 
 var was_already_exported := false
 var relative_path: String
@@ -19,7 +19,8 @@ var preview_texture : Texture2D = null
 var index: int = 0
 var total_rotations: int = 0
 
-var is_loading_image: bool = false
+var is_loading_images: int = 0
+var is_exporting_image: bool = false
 
 var exported_section: Rect2i = Rect2i()
 
@@ -38,18 +39,32 @@ func load_image() -> void:
 	if original_texture != null and preview_texture != null:
 		return
 
-	if is_loading_image:
+	if is_loading_images != 0:
 		return
 
-	is_loading_image = true
+	if processed_path != "":
+		is_loading_images = 2
+	else:
+		is_loading_images = 1
 
 	Application.threaded_load_image(
 		source_path,
 		func(image: ImageTexture): 
 			original_texture = image
-			was_loaded.emit()
-			is_loading_image = false
+			is_loading_images -= 1
+			if is_loading_images == 0:
+				was_loaded.emit()
 	)
+	
+	if processed_path != "":
+		Application.threaded_load_image(
+			processed_path,
+			func(image: ImageTexture): 
+				preview_texture = image
+				is_loading_images -= 1
+				if is_loading_images == 0:
+					was_loaded.emit()
+		)
 
 func rotate(direction: int) -> void:
 	if original_texture == null:
@@ -75,18 +90,58 @@ func unload_image() -> bool:
 
 func export_image(position: Rect2i) -> void:
 
-	exported_section = position
+	# If the crop region didn't change, we do not need to do anything
+	if position == exported_section:
+		return
+	
+	if is_exporting_image:
+		return
 
 	# We now have our image section, where we extract a new image
 	if original_texture != null:
 
+		is_exporting_image = true
+		
 		Application.threaded_crop_image(
 			original_texture.get_image(),
 			position,
 			func(image: Image):
 				preview_texture = ImageTexture.create_from_image(image)
-				was_already_exported = true
-				was_exported.emit()
+				
+				# Create a formatted file name for the image
+				var file_name : String = Application.output_template.format({
+					"directory_tree": relative_path.get_base_dir().path_join(""),
+					"file": relative_path.get_file().trim_suffix("." + relative_path.get_extension()),
+					"extension": relative_path.get_extension() if Application.current_file_format == 0 else ["png", "jpg", "webp"][Application.current_file_format - 1],
+					"index": index,
+					"width": Application.crop_to_size.x,
+					"height": Application.crop_to_size.x,
+					"rotations": total_rotations,
+					"rect.x": exported_section.position.x,
+					"rect.y": exported_section.position.y,
+					"rect.width": exported_section.size.x,
+					"rect.height": exported_section.size.y,
+				})
+
+				# Remove leading / from the filename and join the path with the output directory
+				var path := Application.output_path.path_join(file_name.trim_prefix("/"))
+
+				exported_section = position
+				
+				Application.threaded_save_image(
+					image, 
+					path, 
+					func(status: int):
+						
+						is_exporting_image = false
+						
+						if status == OK:
+							processed_path = path
+							was_already_exported = true
+							was_exported.emit()
+						else:
+							print("File - " + path + " - was exported unsuccessfully - status: " + error_string(status))
+				)
 		)