Method execute_final_command

faugus/runner.py:230–310

(self)

            set_env("UMU_CONTAINER_NSENTER", "1")

    def execute_final_command(self):

        def start_and_watch(cmd, is_game=False):
            log_file = None
            if self.enable_logging:
                log_path = Path(logs_dir) / self.log_dir
                log_path.mkdir(parents=True, exist_ok=True)
                log_file = open(log_path / "umu.log", "a", encoding="utf-8")

            process = subprocess.Popen(
                cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                bufsize=8192, text=True
            )

            def watch_stream(stream, lf=None):
                for line in iter(stream.readline, ""):
                    clean_line = re.sub(r'\x1B(?:[@-Z\\-_]|\[[0-?]*[ -/]*[@-~])', '', line).strip()

                    if lf:
                        lf.write(f"{clean_line}\n")
                        lf.flush()

                    self.check_game_output(clean_line)

                    if os.environ.get("GAMEID") == "winetricks-gui":
                        GLib.idle_add(self.append_to_text_view, clean_line)
                    else:
                        print(line, end="")
                stream.close()

            threads = [
                Thread(target=watch_stream, args=(process.stdout, log_file), daemon=True),
                Thread(target=watch_stream, args=(process.stderr, log_file), daemon=True)
            ]
            for t in threads: t.start()

            if is_game:
                self.process = process
                GLib.child_watch_add(GLib.PRIORITY_DEFAULT, process.pid, self.on_process_exit)
                Thread(target=self._watch_game_process, daemon=True).start()
                if log_file:
                    def close_log_later():
                        for t in threads:
                            t.join(timeout=5)
                        log_file.flush()
                        log_file.close()
                    Thread(target=close_log_later, daemon=True).start()
            else:
                process.wait()
                for t in threads: t.join(timeout=1)
                if log_file:
                    log_file.close()

        popen_prefix = []
        if os.environ.get("PREVENT_SLEEP"):
            try:
                import dbus
                iface = dbus.Interface(dbus.SessionBus().get_object("org.freedesktop.portal.Desktop", "/org/freedesktop/portal/desktop"), "org.freedesktop.portal.Inhibit")