fix(Full Session): loading menu fixes, launch fixes

Author: ShadowApex

core/global/launch_manager.gd

@@ -64,6 +64,8 @@ var logger := Log.get_logger("LaunchManager", Log.LEVEL.DEBUG)
 
 # Connect to Gamescope signals
 func _init() -> void:
+	_load_persist_data()
+
 	# Get the window ID of OpenGamepadUI
 	if _xwayland_ogui:
 		var ogui_windows := _xwayland_ogui.get_windows_for_pid(PID)
@@ -77,6 +79,7 @@ func _init() -> void:
 			if from == to:
 				return
 			logger.info("Window focus changed from " + str(from) + " to: " + str(to))
+			self.check_running.call_deferred()
 		_xwayland_primary.focused_window_updated.connect(on_focus_changed)
 
 		# When focused app changes, update the current app and gamepad profile
@@ -115,6 +118,7 @@ func _init() -> void:
 			if from == to:
 				return
 			logger.debug("Focusable apps changed from", from, "to", to)
+			self.check_running.call_deferred()
 			# If focusable apps has changed and the currently focused app no longer exists,
 			# remove the manual focus
 			var baselayer_app := _xwayland_primary.baselayer_app
@@ -123,6 +127,14 @@ func _init() -> void:
 				_xwayland_primary.remove_baselayer_app()
 		_xwayland_primary.focusable_apps_updated.connect(on_focusable_apps_changed)
 
+	# Listen for signals from the secondary Gamescope XWayland
+	if _xwayland_game:
+		# Listen for window created/destroyed events
+		var on_window_created := func(window_id: int):
+			logger.debug("Window created:", window_id)
+			self.check_running.call_deferred()
+		_xwayland_ogui.window_created.connect(on_window_created)
+
 	# Whenever the in-game state is entered, set the gamepad profile
 	var on_game_state_entered := func(_from: State):
 		if _current_app:
@@ -152,6 +164,7 @@ func _init() -> void:
 	in_game_state.state_exited.connect(on_game_state_exited)
 	set_gamepad_profile("")
 
+
 # Loads persistent data like recent games launched, etc.
 func _load_persist_data():
 	# Create the data directory if it doesn't exist
@@ -189,20 +202,20 @@ func launch(app: LibraryLaunchItem) -> RunningApp:
 	# Override any parameters that may be in the user's config for this game
 	var section := ".".join(["game", app.name.to_lower()])
 	var cmd_key := ".".join(["command", app._provider_id])
-	var user_cmd = settings_manager.get_value(section, cmd_key)
-	if user_cmd and user_cmd is String:
+	var user_cmd = settings_manager.get_value(section, cmd_key, "")
+	if user_cmd and user_cmd is String and not (user_cmd as String).is_empty():
 		cmd = user_cmd
 	var args_key := ".".join(["args", app._provider_id])
-	var user_args = settings_manager.get_value(section, args_key)
-	if user_args and user_args is PackedStringArray:
+	var user_args = settings_manager.get_value(section, args_key, PackedStringArray())
+	if user_args and user_args is PackedStringArray and not (user_args as PackedStringArray).is_empty():
 		args = user_args
 	var cwd_key := ".".join(["cwd", app._provider_id])
-	var user_cwd = settings_manager.get_value(section, cwd_key)
-	if user_cwd and user_cwd is String:
+	var user_cwd = settings_manager.get_value(section, cwd_key, "")
+	if user_cwd and user_cwd is String and not (user_cwd as String).is_empty():
 		cwd = user_cwd
 	var env_key := ".".join(["env", app._provider_id])
-	var user_env = settings_manager.get_value(section, env_key)
-	if user_env and user_env is Dictionary:
+	var user_env = settings_manager.get_value(section, env_key, {})
+	if user_env and user_env is Dictionary and not (user_env as Dictionary).is_empty():
 		env = user_env
 	var sandboxing_key := ".".join(["use_sandboxing", app._provider_id])
 	var use_sandboxing := settings_manager.get_value(section, sandboxing_key, true) as bool
@@ -376,8 +389,8 @@ func set_gamepad_profile(path: String, target_gamepad: String = "") -> void:
 			logger.info("Setting target devices to: ", target_devices)
 			gamepad.set_target_devices(target_devices)
 
-	var notify := Notification.new("Using gamepad profile: " + profile.name)
-	notification_manager.show(notify)
+	#var notify := Notification.new("Using gamepad profile: " + profile.name)
+	#notification_manager.show(notify)
 
 
 ## Sets the given running app as the current app

core/global/platform.gd

@@ -44,14 +44,15 @@ enum PLATFORM {
 	STEAMOS,
 	MANJARO,
 	ARCH_LIKE,
+	NIXOS,
 }
 
 var hardware_manager := load("res://core/systems/hardware/hardware_manager.tres") as HardwareManager
 
 ## Detected Operating System information
 var os_info := _detect_os()
 ## The OS platform provider detected
-var os: PlatformProvider
+var os: OSPlatform
 ## The hardware platform provider detected
 var platform: PlatformProvider
 var logger := Log.get_logger("Platform", Log.LEVEL.INFO)
@@ -127,6 +128,8 @@ func _init() -> void:
 		os = load("res://core/platform/os/chimeraos.tres")
 	if PLATFORM.MANJARO in flags:
 		os = load("res://core/platform/os/manjaro.tres")
+	if PLATFORM.NIXOS in flags:
+		os = load("res://core/platform/os/nixos.tres")
 
 	if os:
 		for action in os.startup_actions:
@@ -286,6 +289,8 @@ func _read_os() -> Array[PLATFORM]:
 		flags.append(PLATFORM.MANJARO)
 	if os_info.id_like == "arch":
 		flags.append(PLATFORM.ARCH_LIKE)
+	if os_info.id == "nixos":
+		flags.append(PLATFORM.NIXOS)
 
 	return flags
 

core/platform/os/nixos.gd

@@ -0,0 +1,23 @@
+extends OSPlatform
+class_name PlatformNixOS
+
+
+func _init() -> void:
+	logger.set_name("PlatformNixOS")
+	logger.set_level(Log.LEVEL.INFO)
+	logger.info("Detected NixOS platform")
+
+
+## NixOS typically cannot execute regular binaries, so downloaded binaries will
+## be run with 'steam-run'. 
+func get_binary_compatibility_cmd(cmd: String, args: PackedStringArray) -> Array[String]:
+	# Hack for steam plugin running steamcmd on NixOS
+	var command: Array[String] = []
+	if not cmd.ends_with("steamcmd.sh"):
+		return command
+
+	command.push_back("steam-run")
+	command.push_back(cmd)
+	command.append_array(args)
+
+	return command

core/platform/os/nixos.tres

@@ -0,0 +1,10 @@
+[gd_resource type="Resource" script_class="PlatformNixOS" load_steps=3 format=3 uid="uid://byxeetkb11b3e"]
+
+[ext_resource type="Script" path="res://core/platform/os/nixos.gd" id="1_h88kc"]
+[ext_resource type="Script" path="res://core/platform/actions/platform_action.gd" id="2_tc12v"]
+
+[resource]
+script = ExtResource("1_h88kc")
+name = ""
+startup_actions = Array[ExtResource("2_tc12v")]([])
+shutdown_actions = Array[ExtResource("2_tc12v")]([])

core/platform/os/os_platform.gd

@@ -4,3 +4,11 @@ class_name OSPlatform
 
 @export_category("Images")
 @export var logo: Texture2D ## Logo of the OS
+
+
+## If the OS requires running regular binaries through a compatibility tool,
+## this method should return the given command/args prepended with the compatibility
+## tool to use.
+func get_binary_compatibility_cmd(cmd: String, args: PackedStringArray) -> Array[String]:
+	var result: Array[String] = []
+	return result

core/systems/debug/log_manager.gd

@@ -88,4 +88,3 @@ func get_available_loggers() -> PackedStringArray:
 	var logger_names := loggers_by_name.keys()
 	mutex.unlock()
 	return logger_names
-

core/systems/input/input_plumber.gd

@@ -23,6 +23,9 @@ func _init() -> void:
 		var file := FileAccess.open(DEFAULT_PROFILE, FileAccess.READ)
 		var content := file.get_as_text()
 		file.close()
+		if DirAccess.make_dir_recursive_absolute(PROFILES_DIR) != OK:
+			var logger := Log.get_logger("InputPlumber", Log.LEVEL.DEBUG)
+			logger.error("Failed to create gamepad profiles directory")
 		var new_file := FileAccess.open(DEFAULT_GLOBAL_PROFILE, FileAccess.WRITE)
 		new_file.store_string(content)
 		new_file.close()

core/systems/launcher/interactive_process.gd

@@ -11,19 +11,23 @@ var pty: Pty
 var cmd: String
 var args: PackedStringArray = []
 var pid: int
+var platform := load("res://core/global/platform.tres") as Platform
 var registry := load("res://core/systems/resource/resource_registry.tres") as ResourceRegistry
 var lines_mutex := Mutex.new()
 var lines_buffer := PackedStringArray()
 var logger := Log.get_logger("InteractiveProcess", Log.LEVEL.INFO)
 
 
 func _init(command: String, cmd_args: PackedStringArray = []) -> void:
-	# Hack for steam plugin running steamcmd on NixOS
-	#if command.ends_with("steamcmd.sh"):
-		#cmd = "steam-run"
-		#args = PackedStringArray([command])
-		#args.append_array(cmd_args)
-		#return
+	# Check to see if this OS requires running the command through a binary
+	# compatibility tool.
+	if platform and platform.os:
+		var compatibility_cmd := platform.os.get_binary_compatibility_cmd(command, cmd_args)
+		if not compatibility_cmd.is_empty():
+			logger.debug("Using binary compatibility tool")
+			self.cmd = compatibility_cmd.pop_front()
+			self.args = PackedStringArray(compatibility_cmd)
+			return
 
 	self.cmd = command
 	self.args = cmd_args

core/systems/launcher/launcher.gd

@@ -11,6 +11,10 @@ func _init() -> void:
 	launch_manager._load_persist_data()
 
 
-# TODO: Replace this with dbus signaling. This is super shitty.
-func _process(delta) -> void:
-	launch_manager.check_running()
+func _ready() -> void:
+	var timer := Timer.new()
+	timer.autostart = true
+	timer.one_shot = false
+	timer.wait_time = 1
+	timer.timeout.connect(launch_manager.check_running)
+	add_child(timer)

core/systems/launcher/reaper.gd

@@ -147,7 +147,7 @@ static func get_pid_status(pid: int) -> Dictionary:
 	var status_file: FileAccess = FileAccess.open(status_path, FileAccess.READ)
 	if not status_file:
 		var logger := Log.get_logger("Reaper")
-		logger.error("Unable to check status for pid: {0}".format([pid]))
+		logger.debug("Unable to check status for pid: {0}".format([pid]))
 		return {}
 
 	# Parse the status output
@@ -215,7 +215,7 @@ static func is_gamescope_pid(pid: int) -> bool:
 	var status: Dictionary = get_pid_status(pid)
 	if not "Name" in status:
 		var logger := Log.get_logger("Reaper")
-		logger.error("No name was found in pid status!")
+		logger.debug("No name was found in pid status!")
 		return false
 	if status["Name"] == "gamescope-wl":
 		return true