+
+
+
+
+
+
+
+ Goodbye!
+ YTPTube has shut down.
+You may now close this window.
+ +{trace}",
- width=600,
- height=400,
- resizable=True,
- )
- webview.start(
- gui="edgechromium" if os.name == "nt" else "qt",
- debug=False,
- storage_path=str(Path(os.getenv("YTP_TEMP_PATH", os.getcwd())) / "webview"),
- private_mode=False,
- )
- sys.exit(1)
-
-
-def set_env():
- defaults = {
- "YTP_CONFIG_PATH": lambda: platformdirs.user_config_dir(APP_NAME.lower(), "arabcoders", ensure_exists=True),
- "YTP_TEMP_PATH": lambda: platformdirs.user_cache_dir(APP_NAME.lower(), "arabcoders", ensure_exists=True),
- "YTP_DOWNLOAD_PATH": lambda: platformdirs.user_downloads_dir(),
- "YTP_ACCESS_LOG": "false",
- "YTP_BROWSER_ENABLED": "true",
- "YTP_BROWSER_CONTROL_ENABLED": "true",
- }
-
- for key, value in defaults.items():
- if os.getenv(key) is not None:
- continue
-
- os.environ[key] = value() if callable(value) else value
-
-
-def run_backend(host: str, port: int, ready_event: threading.Event, error_queue: queue.Queue):
- try:
- try:
- loop = asyncio.get_running_loop()
- except RuntimeError:
- loop = asyncio.new_event_loop()
- asyncio.set_event_loop(loop)
-
- from app.main import Main
-
- Main(is_native=True).start(host, port, cb=lambda: ready_event.set())
- except Exception as e:
- logging.exception(e)
- error_queue.put(e)
- ready_event.set()
-
-
-def get_usable_port(host: str = "127.0.0.1") -> int:
- """
- Get a usable port on the specified host.
- If no port is available, it will raise an OSError.
- """
- with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
- s.bind((host, 0))
- port = s.getsockname()[1]
- s.close()
-
- return port
-
-
-def main():
- host = "127.0.0.1"
- set_env()
-
- cfg_path: Path = Path(os.getenv("YTP_CONFIG_PATH")) / "webview.json"
- win_conf: dict[str, int] = {}
-
- if cfg_path.exists():
- data = json.loads(cfg_path.read_text())
- for key in ("width", "height", "x", "y"):
- if key in data:
- win_conf[key] = data[key]
-
- port = get_usable_port(host)
-
- ready = threading.Event()
- errors: queue.Queue = queue.Queue()
- threading.Thread(target=run_backend, args=(host, port, ready, errors), daemon=False).start()
-
- ready.wait(timeout=5)
-
- if not errors.empty():
- error_window(errors.get())
- return
-
- from app.library.version import APP_VERSION
-
- gui = "edgechromium" if os.name == "nt" else "qt"
- create_kwargs = {**win_conf, "resizable": True}
- window = webview.create_window(f"{APP_NAME} - {APP_VERSION}", f"http://{host}:{port}", **create_kwargs)
-
- def save_geometry():
- cfg = {
- "port": port,
- "width": window.width,
- "height": window.height,
- "x": window.x,
- "y": window.y,
- }
- cfg_path.write_text(json.dumps(cfg))
-
- window.events.resized += lambda *_: save_geometry()
- window.events.moved += lambda *_: save_geometry()
- window.events.closing += lambda *_: os._exit(0)
-
- webview.settings["ALLOW_DOWNLOADS"] = True
- webview.settings["OPEN_DEVTOOLS_IN_DEBUG"] = False
- webview.start(
- gui=gui,
- debug=True,
- storage_path=str(Path(os.getenv("YTP_TEMP_PATH", os.getcwd())) / "webview"),
- private_mode=False,
- )
-
-
-if __name__ == "__main__":
- try:
- from multiprocessing import freeze_support
-
- freeze_support()
- main()
- except Exception as e:
- logging.exception(e)
- error_window(e)
- os._exit(1)
diff --git a/app/routes/api/system.py b/app/routes/api/system.py
new file mode 100644
index 00000000..5564ea40
--- /dev/null
+++ b/app/routes/api/system.py
@@ -0,0 +1,59 @@
+import asyncio
+import logging
+
+from aiohttp import web
+from aiohttp.web import Request, Response
+from aiohttp.web_runner import GracefulExit
+
+from app.library.config import Config
+from app.library.encoder import Encoder
+from app.library.Events import EventBus, Events
+from app.library.router import route
+
+LOG: logging.Logger = logging.getLogger(__name__)
+
+
+@route("POST", "api/system/shutdown", "system.shutdown")
+async def shutdown_system(request: Request, config: Config, encoder: Encoder, notify: EventBus) -> Response:
+ """
+ Get the presets.
+
+ Args:
+ request (Request): The request object.
+ config (Config): The config instance.
+ encoder (Encoder): The encoder instance.
+ notify (EventBus): The event bus instance.
+
+ Returns:
+ Response: The response object.
+
+ """
+ if config.is_native is not True:
+ return web.json_response(
+ {"error": "Shutdown is only available in the native mode."},
+ status=web.HTTPBadRequest.status_code,
+ )
+
+ app = request.app
+
+ async def do_shutdown():
+ await notify.emit(
+ Events.SHUTDOWN,
+ data={"app": app},
+ title="Application Shutdown",
+ message="Shutdown initiated by user request.",
+ )
+ await asyncio.sleep(0.5)
+ await app.shutdown()
+ await app.cleanup()
+ raise GracefulExit
+
+ # Schedule shutdown after response
+ asyncio.create_task(do_shutdown())
+ return web.json_response(
+ data={
+ "message": "The application shutting down.",
+ },
+ status=web.HTTPOk.status_code,
+ dumps=encoder.encode,
+ )
diff --git a/pyproject.toml b/pyproject.toml
index bbfd5975..cfe61218 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -78,12 +78,7 @@ indent-width = 4
target-version = "py311"
[project.optional-dependencies]
-webview = [
- #windows only
- "qtpy; sys_platform == 'win32'",
- "pyside6; sys_platform == 'win32'",
- # all
- "pywebview",
+installer = [
"pyinstaller",
]
diff --git a/ui/app/components/Dialog.vue b/ui/app/components/Dialog.vue
new file mode 100644
index 00000000..2c4809ae
--- /dev/null
+++ b/ui/app/components/Dialog.vue
@@ -0,0 +1,151 @@
+
+
+
+ {{ state.current?.opts.title ?? defaultTitle }}
+ ++ {{ state.current?.opts.message }} +
+ + ++ + + {{ state.errorMsg }} + +
+