Comparar commits
7 Commits
v1.17.0
...
pestanas-c
| Autor | SHA1 | Fecha | |
|---|---|---|---|
|
|
6539f6939c | ||
|
|
d3216c10ef | ||
|
|
d7bf8c6740 | ||
|
|
9c7bdf552c | ||
|
|
5797c478bc | ||
|
|
4d066157cf | ||
|
|
5a6f6c918f |
51
README.md
51
README.md
@@ -20,6 +20,16 @@ NAS. Esto le da al equipo un cliente nativo de verdad en Windows y Mac:
|
|||||||
- **Colores de pestaña** (v1.6.0): clic derecho sobre una pestaña ▸ **Color**, con
|
- **Colores de pestaña** (v1.6.0): clic derecho sobre una pestaña ▸ **Color**, con
|
||||||
la misma paleta de nueve tonos que usa Chrome para sus grupos. Sirve para agrupar
|
la misma paleta de nueve tonos que usa Chrome para sus grupos. Sirve para agrupar
|
||||||
de un vistazo (todo lo de un cliente en verde) y **se guarda con la sesión**.
|
de un vistazo (todo lo de un cliente en verde) y **se guarda con la sesión**.
|
||||||
|
- **Pestaña del color de su página** (v1.21.0): una página puede pedir el color de
|
||||||
|
su pestaña con `<html data-ls-pestana="#rrggbb">` (solo ese formato). El modo
|
||||||
|
edición de un set la pinta del gris del editor: activa se funde con su barra de
|
||||||
|
arriba y detrás se reconoce entre las demás. Esa página no cambia el tema de la
|
||||||
|
barra (su fondo oscuro no es el de la app).
|
||||||
|
- **Pestañas con nombre** (v1.21.0): `window.open(url, "ls-…")` o un enlace con
|
||||||
|
`target="ls-…"` abre la pestaña la primera vez y las siguientes **vuelven a
|
||||||
|
ella** en vez de abrir otra. La página recibe la URL nueva por
|
||||||
|
`window.__lsAbrir(url)` (el modo edición cambia de foto sin recargar); si no lo
|
||||||
|
tiene, navega. Nombre y color se guardan con la sesión.
|
||||||
- **Zoom de interfaz**: ⌘/Ctrl `+` / `−` / `0` y Ctrl+rueda, con indicador en la
|
- **Zoom de interfaz**: ⌘/Ctrl `+` / `−` / `0` y Ctrl+rueda, con indicador en la
|
||||||
barra y **persistencia** entre sesiones (50%–250%).
|
barra y **persistencia** entre sesiones (50%–250%).
|
||||||
- **Documentos dentro de la app**: los visores/editores del propio servidor
|
- **Documentos dentro de la app**: los visores/editores del propio servidor
|
||||||
@@ -39,6 +49,47 @@ NAS. Esto le da al equipo un cliente nativo de verdad en Windows y Mac:
|
|||||||
resultado. Es un popup nativo del sistema, igual en Windows y macOS, y vive
|
resultado. Es un popup nativo del sistema, igual en Windows y macOS, y vive
|
||||||
solo en el shell (la web app no se toca).
|
solo en el shell (la web app no se toca).
|
||||||
|
|
||||||
|
- **Pestañas en reposo** (v1.19.0, solo Windows): cada pestaña es la web app entera, con su
|
||||||
|
conexión del chat y sus sondeos. Una que lleva 5 minutos oculta se **suspende** (WebView2
|
||||||
|
`TrySuspend`: deja de gastar CPU y el sistema puede recuperar su memoria) y despierta sola,
|
||||||
|
donde estaba, al volver a ella. No se duerme la activa, ni una con una subida, una descarga o
|
||||||
|
audio en curso, ni un editor de documentos (`/docs/`).
|
||||||
|
|
||||||
|
- **Salud de la app** (v1.20.0, `src-tauri/src/salud.rs`): cuánto gasta de verdad, qué falla
|
||||||
|
y cómo se repone sola. Nada sale del equipo; todo queda en la carpeta de logs de la app
|
||||||
|
(⋮ ▸ *Abrir diagnóstico*, o desde la bandeja).
|
||||||
|
- **Recursos reales**: el exe es pequeño; el gasto está en la docena de procesos de WebView2
|
||||||
|
que cuelgan de él (uno por pestaña, GPU, utilidad), que el Administrador de tareas reparte.
|
||||||
|
Cada minuto se mide el árbol entero —memoria privada, CPU como la columna del Administrador
|
||||||
|
de tareas, número de procesos— y se ve en la bandeja y en ⋮ («Recursos: 2,1 GB · CPU 3 % ·
|
||||||
|
13 procesos»). Cada muestra va a `recursos.csv` (fecha, procesos, MB, CPU, pestañas,
|
||||||
|
dormidas): la curva de un día de trabajo real.
|
||||||
|
- **Diario de errores** (`salud.log`, rota a 2 MB): pánicos de Rust, procesos de WebView2
|
||||||
|
caídos o colgados, errores de JavaScript de las páginas (mensaje y archivo:línea, máx. 20
|
||||||
|
por carga y sin repetidos en un minuto), el hilo principal sin responder (ventana
|
||||||
|
congelada: cuándo y cuánto), fallos del actualizador y **cierres de golpe** (si al arrancar
|
||||||
|
sigue el testigo `en-marcha`, la sesión anterior no terminó bien).
|
||||||
|
- **Se repone sola**: pestaña cuyo proceso muere o se cuelga → se recarga (freno: 3 veces en
|
||||||
|
10 min; después avisa y la deja quieta). Si muere el proceso principal de WebView2 (caen
|
||||||
|
todas) → la app se reinicia sola. Windows la reabre si se cuelga o se cierra de golpe
|
||||||
|
(`RegisterApplicationRestart`). Con el árbol por encima de 3 GB se duermen **ya** las
|
||||||
|
pestañas ocultas (con las mismas reglas del reposo: nunca una con subida, descarga o audio).
|
||||||
|
|
||||||
|
- **Ahorro de memoria** (v1.20.0, `src-tauri/src/memoria.rs`). Medido en el equipo de edición:
|
||||||
|
2,2 GB con 5 pestañas tras un día abierta, **1,3 GB de ellos en el proceso gráfico** de WebView2,
|
||||||
|
que crece con las horas y no devuelve nada (reiniciarlo a mano bajó la app a 1,1 GB sin perder
|
||||||
|
nada). Sin quitar funciones:
|
||||||
|
- **Al abrir solo se carga la pestaña activa**; las demás esperan en la barra con su título y
|
||||||
|
se cargan al hacer clic (como Chrome/Edge). Antes arrancaban todas a la vez.
|
||||||
|
- **Pestañas descartadas**: una que lleva 30 min dormida se cierra de verdad y vuelve a su URL
|
||||||
|
al activarla (1-2 s de carga). Nunca un editor de documentos ni una con subida, descarga o audio.
|
||||||
|
- **Nivel de memoria bajo** para lo que no se ve (pestañas ocultas; todo con la ventana en la
|
||||||
|
bandeja o minimizada): WebView2 suelta cachés que puede regenerar.
|
||||||
|
- **El proceso gráfico se recicla** al pasar de 600 MB, solo si nadie mira (ventana oculta o
|
||||||
|
minimizada, o 10 min sin tocar el equipo y sin sonido saliendo), como mucho cada 30 min.
|
||||||
|
- Lo que ya se guardaba en disco sigue igual: la caché HTTP (los archivos de la app vienen con
|
||||||
|
`immutable`, 1 año), el service worker de la web y el cajón de miniaturas (`cache.rs`).
|
||||||
|
|
||||||
- **Rastreador de trabajo efectivo** (v1.10.0, `src-tauri/src/tracker.rs`): mide
|
- **Rastreador de trabajo efectivo** (v1.10.0, `src-tauri/src/tracker.rs`): mide
|
||||||
cuánto tiempo se trabaja de verdad y en qué aplicación, y lo publica en el
|
cuánto tiempo se trabaja de verdad y en qué aplicación, y lo publica en el
|
||||||
panel **/rastreo** del servidor. Cada 5 s mira la ventana al frente y si
|
panel **/rastreo** del servidor. Cada 5 s mira la ventana al frente y si
|
||||||
|
|||||||
27
dist/index.html
vendido
27
dist/index.html
vendido
@@ -7,7 +7,7 @@
|
|||||||
<!--
|
<!--
|
||||||
Barra de pestañas del shell de escritorio (webview "chrome", local).
|
Barra de pestañas del shell de escritorio (webview "chrome", local).
|
||||||
Habla con Rust por eventos (__TAURI__.event):
|
Habla con Rust por eventos (__TAURI__.event):
|
||||||
recibe ls-tabs {tabs:[{label,title,url,loading,active,color}], zoom, version,
|
recibe ls-tabs {tabs:[{label,title,url,loading,active,color,pagina}], zoom, version,
|
||||||
mac, win, maximized, dark}
|
mac, win, maximized, dark}
|
||||||
emite ls-ready, ls-new-tab, ls-activate, ls-close-tab, ls-reload, ls-zoom, ls-cycle,
|
emite ls-ready, ls-new-tab, ls-activate, ls-close-tab, ls-reload, ls-zoom, ls-cycle,
|
||||||
ls-activate-n, ls-nav, ls-menu, ls-check-update, ls-tab-menu, ls-reorder
|
ls-activate-n, ls-nav, ls-menu, ls-check-update, ls-tab-menu, ls-reorder
|
||||||
@@ -208,6 +208,17 @@
|
|||||||
}
|
}
|
||||||
:root.oscuro .tab[data-color]:not(.active) { background: rgba(var(--tc), 0.36); }
|
:root.oscuro .tab[data-color]:not(.active) { background: rgba(var(--tc), 0.36); }
|
||||||
:root.oscuro .tab[data-color]:not(.active):hover { background: rgba(var(--tc), 0.5); }
|
:root.oscuro .tab[data-color]:not(.active):hover { background: rgba(var(--tc), 0.5); }
|
||||||
|
/* ── La pestaña del COLOR DE SU PÁGINA (1.21) ──
|
||||||
|
La página lo pide (`<html data-ls-pestana="#262626">`): el modo edición de un set pinta la
|
||||||
|
suya del gris del editor. Activa, es de ese color y se funde con la barra de arriba de la
|
||||||
|
página, como la de siempre se funde con el blanco de la app. Detrás, el mismo color: entre
|
||||||
|
las demás se reconoce de un vistazo. Con color del menú encima, ese va de franja arriba.
|
||||||
|
(#tabs delante: gana a las reglas de tema y de color del menú sin !important.) */
|
||||||
|
#tabs .tab.pagina { --muted: color-mix(in srgb, var(--tp-fg) 60%, transparent); background: var(--tp); color: var(--tp-fg); }
|
||||||
|
#tabs .tab.pagina:not(.active) { box-shadow: none; }
|
||||||
|
#tabs .tab.pagina:not(.active):hover { background: color-mix(in srgb, var(--tp) 86%, var(--tp-fg)); color: var(--tp-fg); }
|
||||||
|
#tabs .tab.pagina .cerrar:hover { background: color-mix(in srgb, var(--tp-fg) 18%, transparent); color: var(--tp-fg); }
|
||||||
|
#tabs .tab.pagina[data-color] { box-shadow: inset 0 3px 0 rgb(var(--tc)); }
|
||||||
/* Reordenar arrastrando: NO se usa drag&drop de HTML5 (en el webview de la barra en
|
/* Reordenar arrastrando: NO se usa drag&drop de HTML5 (en el webview de la barra en
|
||||||
macOS los eventos no llegan), sino eventos de puntero. Se apaga el arrastre nativo de
|
macOS los eventos no llegan), sino eventos de puntero. Se apaga el arrastre nativo de
|
||||||
WebKit para que no salga la imagen fantasma al mover una pestaña. */
|
WebKit para que no salga la imagen fantasma al mover una pestaña. */
|
||||||
@@ -500,6 +511,14 @@
|
|||||||
$tabs.classList.toggle("compactas", ancho < 112);
|
$tabs.classList.toggle("compactas", ancho < 112);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ¿Un #rrggbb claro? (luminancia relativa): decide si la letra encima va oscura o clara.
|
||||||
|
function esClaro(hex) {
|
||||||
|
const n = parseInt(hex.slice(1), 16);
|
||||||
|
const lin = (c) => { c /= 255; return c <= 0.04045 ? c / 12.92 : ((c + 0.055) / 1.055) ** 2.4; };
|
||||||
|
const l = 0.2126 * lin((n >> 16) & 255) + 0.7152 * lin((n >> 8) & 255) + 0.0722 * lin(n & 255);
|
||||||
|
return l > 0.35;
|
||||||
|
}
|
||||||
|
|
||||||
function render() {
|
function render() {
|
||||||
$tabs.textContent = "";
|
$tabs.textContent = "";
|
||||||
for (const t of estado.tabs) {
|
for (const t of estado.tabs) {
|
||||||
@@ -508,6 +527,12 @@
|
|||||||
el.className = "tab" + (t.active ? " active" : "");
|
el.className = "tab" + (t.active ? " active" : "");
|
||||||
el.dataset.label = t.label;
|
el.dataset.label = t.label;
|
||||||
if (t.color) el.dataset.color = t.color; // teñido desde el menú de la pestaña
|
if (t.color) el.dataset.color = t.color; // teñido desde el menú de la pestaña
|
||||||
|
// El color que pide la página (ya validado #rrggbb en el shell), con letra que se lea encima.
|
||||||
|
if (t.pagina) {
|
||||||
|
el.classList.add("pagina");
|
||||||
|
el.style.setProperty("--tp", t.pagina);
|
||||||
|
el.style.setProperty("--tp-fg", esClaro(t.pagina) ? "#202124" : "#ececec");
|
||||||
|
}
|
||||||
el.title = texto;
|
el.title = texto;
|
||||||
|
|
||||||
const fav = document.createElement("span");
|
const fav = document.createElement("span");
|
||||||
|
|||||||
4
package-lock.json
generado
4
package-lock.json
generado
@@ -1,12 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "labstream-desktop",
|
"name": "labstream-desktop",
|
||||||
"version": "1.14.1",
|
"version": "1.19.0",
|
||||||
"lockfileVersion": 3,
|
"lockfileVersion": 3,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "labstream-desktop",
|
"name": "labstream-desktop",
|
||||||
"version": "1.14.1",
|
"version": "1.19.0",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@tauri-apps/cli": "^2"
|
"@tauri-apps/cli": "^2"
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "labstream-desktop",
|
"name": "labstream-desktop",
|
||||||
"version": "1.17.0",
|
"version": "1.21.0",
|
||||||
"private": true,
|
"private": true,
|
||||||
"description": "App de escritorio (Windows) que envuelve Labstream OS — cliente del servidor del NAS.",
|
"description": "App de escritorio (Windows) que envuelve Labstream OS — cliente del servidor del NAS.",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
28
src-tauri/Cargo.lock
generado
28
src-tauri/Cargo.lock
generado
@@ -2366,11 +2366,13 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "labstream-desktop"
|
name = "labstream-desktop"
|
||||||
version = "1.17.0"
|
version = "1.21.0"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"active-win-pos-rs",
|
"active-win-pos-rs",
|
||||||
"device_query",
|
"device_query",
|
||||||
"gethostname 0.5.0",
|
"gethostname 0.5.0",
|
||||||
|
"percent-encoding",
|
||||||
|
"rfd",
|
||||||
"serde",
|
"serde",
|
||||||
"serde_json",
|
"serde_json",
|
||||||
"tauri",
|
"tauri",
|
||||||
@@ -2382,6 +2384,7 @@ dependencies = [
|
|||||||
"tauri-plugin-single-instance",
|
"tauri-plugin-single-instance",
|
||||||
"tauri-plugin-updater",
|
"tauri-plugin-updater",
|
||||||
"ureq",
|
"ureq",
|
||||||
|
"webview2-com",
|
||||||
"windows 0.61.3",
|
"windows 0.61.3",
|
||||||
]
|
]
|
||||||
|
|
||||||
@@ -3603,6 +3606,29 @@ dependencies = [
|
|||||||
"web-sys",
|
"web-sys",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "rfd"
|
||||||
|
version = "0.17.2"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "20dafead71c16a34e1ff357ddefc8afc11e7d51d6d2b9fbd07eaa48e3e540220"
|
||||||
|
dependencies = [
|
||||||
|
"block2",
|
||||||
|
"dispatch2",
|
||||||
|
"js-sys",
|
||||||
|
"libc",
|
||||||
|
"log",
|
||||||
|
"objc2",
|
||||||
|
"objc2-app-kit",
|
||||||
|
"objc2-core-foundation",
|
||||||
|
"objc2-foundation",
|
||||||
|
"percent-encoding",
|
||||||
|
"raw-window-handle",
|
||||||
|
"wasm-bindgen",
|
||||||
|
"wasm-bindgen-futures",
|
||||||
|
"web-sys",
|
||||||
|
"windows-sys 0.61.2",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "ring"
|
name = "ring"
|
||||||
version = "0.17.14"
|
version = "0.17.14"
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "labstream-desktop"
|
name = "labstream-desktop"
|
||||||
version = "1.17.0"
|
version = "1.21.0"
|
||||||
description = "Cliente de escritorio de Labstream OS"
|
description = "Cliente de escritorio de Labstream OS"
|
||||||
authors = ["Labstream SAS"]
|
authors = ["Labstream SAS"]
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
@@ -64,6 +64,8 @@ device_query = "4"
|
|||||||
# Solo Windows: en macOS no hay API pública sencilla de nivel de audio por app (el equipo de
|
# Solo Windows: en macOS no hay API pública sencilla de nivel de audio por app (el equipo de
|
||||||
# edición es Windows). El `windows` crate ya está en la caché por Tauri.
|
# edición es Windows). El `windows` crate ya está en la caché por Tauri.
|
||||||
[target.'cfg(windows)'.dependencies]
|
[target.'cfg(windows)'.dependencies]
|
||||||
|
# Pestañas en reposo (1.19): ICoreWebView2_3::TrySuspend. Es la misma versión que ya trae Tauri.
|
||||||
|
webview2-com = "0.38"
|
||||||
windows = { version = "0.61", features = [
|
windows = { version = "0.61", features = [
|
||||||
"Win32_Foundation",
|
"Win32_Foundation",
|
||||||
"Win32_System_Com",
|
"Win32_System_Com",
|
||||||
@@ -73,4 +75,12 @@ windows = { version = "0.61", features = [
|
|||||||
"Win32_System_Variant",
|
"Win32_System_Variant",
|
||||||
"Win32_Media_Audio",
|
"Win32_Media_Audio",
|
||||||
"Win32_Media_Audio_Endpoints",
|
"Win32_Media_Audio_Endpoints",
|
||||||
|
# Salud (1.20): medir el árbol de procesos (exe + WebView2) y el reinicio automático de Windows.
|
||||||
|
"Win32_System_Diagnostics_ToolHelp",
|
||||||
|
"Win32_System_ProcessStatus",
|
||||||
|
"Win32_System_Threading",
|
||||||
|
"Win32_System_Recovery",
|
||||||
|
# Memoria (1.20): ¿cuánto lleva el equipo sin tocar? (para reciclar el proceso gráfico sin que se note)
|
||||||
|
"Win32_UI_Input_KeyboardAndMouse",
|
||||||
|
"Win32_System_SystemInformation",
|
||||||
] }
|
] }
|
||||||
|
|||||||
@@ -36,11 +36,14 @@
|
|||||||
|
|
||||||
mod cache;
|
mod cache;
|
||||||
mod tracker;
|
mod tracker;
|
||||||
|
mod salud;
|
||||||
|
mod memoria;
|
||||||
|
|
||||||
use std::{
|
use std::{
|
||||||
collections::HashMap,
|
collections::HashMap,
|
||||||
path::{Path, PathBuf},
|
path::{Path, PathBuf},
|
||||||
sync::Mutex,
|
sync::Mutex,
|
||||||
|
time::{Duration, Instant},
|
||||||
};
|
};
|
||||||
|
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
@@ -78,6 +81,19 @@ fn es_pestana_interna(target: &Url, server: &Url) -> bool {
|
|||||||
target.origin() == server.origin()
|
target.origin() == server.origin()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// El color que pide una página para su pestaña: solo `#rrggbb` (va a un estilo de la barra; nada
|
||||||
|
// que no sea un color llega allí).
|
||||||
|
fn color_de_pagina(c: &str) -> Option<String> {
|
||||||
|
let hex = c.strip_prefix('#')?;
|
||||||
|
(hex.len() == 6 && hex.chars().all(|ch| ch.is_ascii_hexdigit())).then(|| c.to_ascii_lowercase())
|
||||||
|
}
|
||||||
|
|
||||||
|
// Un nombre de ventana que identifica pestaña: los de la app (`ls-…`, p. ej. `ls-edicion-<set>`).
|
||||||
|
// Los reservados del navegador (_blank, _self…) y cualquier otro abren pestaña nueva como siempre.
|
||||||
|
fn nombre_de_ventana(n: &str) -> Option<String> {
|
||||||
|
(n.starts_with("ls-") && n.len() <= 80 && n.chars().all(|c| c.is_ascii_alphanumeric() || c == '-' || c == '_')).then(|| n.to_string())
|
||||||
|
}
|
||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
mod navigation_tests {
|
mod navigation_tests {
|
||||||
use super::*;
|
use super::*;
|
||||||
@@ -92,6 +108,20 @@ mod navigation_tests {
|
|||||||
assert!(is_google_host("docs.google.com"));
|
assert!(is_google_host("docs.google.com"));
|
||||||
assert!(!is_google_host("docs.google.com.evil.example"));
|
assert!(!is_google_host("docs.google.com.evil.example"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn la_pagina_solo_pide_colores_y_nombres_de_la_app() {
|
||||||
|
assert_eq!(color_de_pagina("#262626").as_deref(), Some("#262626"));
|
||||||
|
assert_eq!(color_de_pagina("#A0b1C2").as_deref(), Some("#a0b1c2"));
|
||||||
|
for malo in ["", "262626", "#26262", "#2626266", "red", "#26262g", "#262626;background:url(x)"] {
|
||||||
|
assert_eq!(color_de_pagina(malo), None, "{malo}");
|
||||||
|
}
|
||||||
|
assert_eq!(nombre_de_ventana("ls-edicion-cmg123").as_deref(), Some("ls-edicion-cmg123"));
|
||||||
|
for malo in ["", "_blank", "_self", "edicion", "ls-a b", "ls-\"<x>"] {
|
||||||
|
assert_eq!(nombre_de_ventana(malo), None, "{malo}");
|
||||||
|
}
|
||||||
|
assert_eq!(nombre_de_ventana(&format!("ls-{}", "a".repeat(80))), None);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
const TAB_BAR_H: f64 = 40.0; // alto lógico de la barra de pestañas (chrome)
|
const TAB_BAR_H: f64 = 40.0; // alto lógico de la barra de pestañas (chrome)
|
||||||
const CHROME: &str = "chrome";
|
const CHROME: &str = "chrome";
|
||||||
@@ -112,6 +142,19 @@ struct TabRec {
|
|||||||
// Color elegido a mano desde el menú de la pestaña (None = sin teñir). Aquí solo vive el
|
// Color elegido a mano desde el menú de la pestaña (None = sin teñir). Aquí solo vive el
|
||||||
// NOMBRE; el tono exacto y cómo se pinta son cosa del CSS de la barra.
|
// NOMBRE; el tono exacto y cómo se pinta son cosa del CSS de la barra.
|
||||||
color: Option<String>,
|
color: Option<String>,
|
||||||
|
// Reposo (ver «Pestañas en reposo»): desde cuándo está oculta (None = es la activa) y si ya
|
||||||
|
// se suspendió.
|
||||||
|
oculta_desde: Option<Instant>,
|
||||||
|
dormida: bool,
|
||||||
|
// Ahorro de memoria (memoria.rs): su webview se cerró tras DESCARTE_TRAS dormida. Sigue en la
|
||||||
|
// barra con título, URL y color, y se crea otra vez al volver a ella.
|
||||||
|
descartada: bool,
|
||||||
|
// El color que PIDE la página (`<html data-ls-pestana="#262626">`, ver `color_de_pagina`): el
|
||||||
|
// modo edición de un set pinta su pestaña del gris del editor. Lo manda la página, no el menú.
|
||||||
|
pagina: Option<String>,
|
||||||
|
// El nombre de ventana con que se abrió (`window.open(url, nombre)`): abrir otra vez con el
|
||||||
|
// mismo nombre lleva a esta pestaña en vez de abrir otra (ver `reusar_pestana`).
|
||||||
|
nombre: Option<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
// Paleta de colores de pestaña, la misma idea que los grupos de Chrome: sirve para agrupar de
|
// Paleta de colores de pestaña, la misma idea que los grupos de Chrome: sirve para agrupar de
|
||||||
@@ -184,6 +227,16 @@ struct Persisted {
|
|||||||
// que un estado.json viejo (sin colores) siga cargando tal cual.
|
// que un estado.json viejo (sin colores) siga cargando tal cual.
|
||||||
#[serde(default)]
|
#[serde(default)]
|
||||||
colors: Vec<String>,
|
colors: Vec<String>,
|
||||||
|
// Título de cada pestaña (mismo orden): al abrir, las que no son la activa se quedan sin
|
||||||
|
// cargar (ver `registrar_diferida`) y la barra necesita algo que enseñar mientras tanto.
|
||||||
|
#[serde(default)]
|
||||||
|
titles: Vec<String>,
|
||||||
|
// El color que pidió la página y el nombre de ventana de cada una (mismo orden; "" = ninguno):
|
||||||
|
// la pestaña del modo edición vuelve del gris del editor y se sigue reutilizando.
|
||||||
|
#[serde(default)]
|
||||||
|
paginas: Vec<String>,
|
||||||
|
#[serde(default)]
|
||||||
|
nombres: Vec<String>,
|
||||||
#[serde(default)]
|
#[serde(default)]
|
||||||
active: usize,
|
active: usize,
|
||||||
#[serde(default)]
|
#[serde(default)]
|
||||||
@@ -215,6 +268,9 @@ fn save_persisted<R: Runtime>(app: &AppHandle<R>) {
|
|||||||
win: s.win,
|
win: s.win,
|
||||||
tabs: s.tabs.iter().map(|t| t.url.clone()).collect(),
|
tabs: s.tabs.iter().map(|t| t.url.clone()).collect(),
|
||||||
colors: s.tabs.iter().map(|t| t.color.clone().unwrap_or_default()).collect(),
|
colors: s.tabs.iter().map(|t| t.color.clone().unwrap_or_default()).collect(),
|
||||||
|
titles: s.tabs.iter().map(|t| t.title.clone()).collect(),
|
||||||
|
paginas: s.tabs.iter().map(|t| t.pagina.clone().unwrap_or_default()).collect(),
|
||||||
|
nombres: s.tabs.iter().map(|t| t.nombre.clone().unwrap_or_default()).collect(),
|
||||||
active: s.active,
|
active: s.active,
|
||||||
autostart: s.autostart,
|
autostart: s.autostart,
|
||||||
dark: s.dark,
|
dark: s.dark,
|
||||||
@@ -272,7 +328,63 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
try { T.core.invoke('plugin:opener|open_url', { url: url, with: null }); }
|
try { T.core.invoke('plugin:opener|open_url', { url: url, with: null }); }
|
||||||
catch (e) { try { T.opener.openUrl(url); } catch (_) {} }
|
catch (e) { try { T.opener.openUrl(url); } catch (_) {} }
|
||||||
}
|
}
|
||||||
function newTab(url) { emit('ls-new-tab', { url: url }); }
|
function newTab(url, nombre) { emit('ls-new-tab', nombre ? { url: url, name: nombre } : { url: url }); }
|
||||||
|
// Una ventana con nombre de la app (`ls-…`): reabrirla lleva a la pestaña que ya la tiene.
|
||||||
|
function nombreVentana(n) { return typeof n === 'string' && /^ls-[A-Za-z0-9_-]{1,77}$/.test(n) ? n : null; }
|
||||||
|
|
||||||
|
// ── Errores de la página → diario de salud del shell (salud.log) ──
|
||||||
|
// Solo el mensaje, el archivo:línea y la ruta (sin datos del formulario ni de la sesión). Como
|
||||||
|
// mucho 20 por carga de página; el shell además descarta repetidos durante un minuto.
|
||||||
|
var errores = 0;
|
||||||
|
function reportarError(tipo, msg, src) {
|
||||||
|
if (++errores > 20) return;
|
||||||
|
emit('ls-error', { label: LABEL, tipo: tipo, msg: String(msg || '').slice(0, 300), src: String(src || '').slice(0, 200), url: location.pathname });
|
||||||
|
}
|
||||||
|
addEventListener('error', function (e) {
|
||||||
|
// Con captura llegan también las imágenes o scripts que no cargan: esos no traen mensaje.
|
||||||
|
if (e && e.message) reportarError('error', e.message, (e.filename || '') + ':' + (e.lineno || 0));
|
||||||
|
}, true);
|
||||||
|
addEventListener('unhandledrejection', function (e) {
|
||||||
|
var r = e && e.reason;
|
||||||
|
reportarError('promesa', (r && (r.stack || r.message)) || r, '');
|
||||||
|
});
|
||||||
|
|
||||||
|
// ── Reposo ──
|
||||||
|
// El shell suspende las pestañas que llevan un rato ocultas (dejan de gastar CPU y sueltan
|
||||||
|
// memoria). Antes PREGUNTA: una pestaña con una subida o una descarga en curso, o con algo
|
||||||
|
// sonando, no se duerme. Se cuentan las peticiones vivas (fetch y XHR; el stream del chat es
|
||||||
|
// EventSource y no cuenta) y, ante cualquier duda, la cuenta se queda arriba: no dormir es
|
||||||
|
// siempre el lado seguro.
|
||||||
|
var enCurso = 0;
|
||||||
|
try {
|
||||||
|
var _send = XMLHttpRequest.prototype.send;
|
||||||
|
XMLHttpRequest.prototype.send = function () {
|
||||||
|
var hecho = false;
|
||||||
|
enCurso++;
|
||||||
|
this.addEventListener('loadend', function () { if (!hecho) { hecho = true; enCurso--; } });
|
||||||
|
try { return _send.apply(this, arguments); }
|
||||||
|
catch (e) { if (!hecho) { hecho = true; enCurso--; } throw e; }
|
||||||
|
};
|
||||||
|
var _fetch = window.fetch;
|
||||||
|
if (_fetch) {
|
||||||
|
window.fetch = function () {
|
||||||
|
enCurso++;
|
||||||
|
var baja = function () { enCurso--; };
|
||||||
|
var p;
|
||||||
|
try { p = _fetch.apply(this, arguments); } catch (e) { baja(); throw e; }
|
||||||
|
p.then(baja, baja);
|
||||||
|
return p;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
} catch (e) {}
|
||||||
|
window.__lsReposo = function () {
|
||||||
|
var suena = false;
|
||||||
|
try {
|
||||||
|
var medios = document.querySelectorAll('video,audio');
|
||||||
|
for (var i = 0; i < medios.length; i++) { if (!medios[i].paused && !medios[i].ended) suena = true; }
|
||||||
|
} catch (e) { suena = true; }
|
||||||
|
emit('ls-reposo', { label: LABEL, libre: enCurso <= 0 && !suena });
|
||||||
|
};
|
||||||
|
|
||||||
// Las imagenes conservan su URL HTTPS y la sesion del webview. El descargador
|
// Las imagenes conservan su URL HTTPS y la sesion del webview. El descargador
|
||||||
// lsthumb no comparte cookies: falla con miniaturas sin token y omite la
|
// lsthumb no comparte cookies: falla con miniaturas sin token y omite la
|
||||||
@@ -304,13 +416,25 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
} catch (e) { return null; }
|
} catch (e) { return null; }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ── El color que la página pide para SU pestaña ── `<html data-ls-pestana='#262626'>` (el modo
|
||||||
|
// edición de un set, del gris del editor). "" = ninguno.
|
||||||
|
function colorPestana() {
|
||||||
|
try {
|
||||||
|
var c = document.documentElement && document.documentElement.getAttribute('data-ls-pestana');
|
||||||
|
return c && /^#[0-9a-fA-F]{6}$/.test(c) ? c : '';
|
||||||
|
} catch (e) { return ''; }
|
||||||
|
}
|
||||||
|
|
||||||
// Título, URL y TEMA → barra de pestañas (y para restaurar la sesión al reabrir).
|
// Título, URL y TEMA → barra de pestañas (y para restaurar la sesión al reabrir).
|
||||||
// El tema viaja aquí porque la web decide su modo con su propio botón y NO sigue al
|
// El tema viaja aquí porque la web decide su modo con su propio botón y NO sigue al
|
||||||
// sistema: la barra tiene que copiarle a ELLA.
|
// sistema: la barra tiene que copiarle a ELLA. Una página con color propio no lo dice: su
|
||||||
|
// fondo oscuro es el de su pestaña, no el tema de la app.
|
||||||
function report() {
|
function report() {
|
||||||
var carga = { label: LABEL, title: document.title || 'Labstream OS', url: location.href };
|
var carga = { label: LABEL, title: document.title || 'Labstream OS', url: location.href, pestana: colorPestana() };
|
||||||
|
if (!carga.pestana) {
|
||||||
var oscuro = temaOscuro();
|
var oscuro = temaOscuro();
|
||||||
if (oscuro !== null) carga.dark = oscuro;
|
if (oscuro !== null) carga.dark = oscuro;
|
||||||
|
}
|
||||||
emit('ls-title', carga);
|
emit('ls-title', carga);
|
||||||
}
|
}
|
||||||
function watchTitle() {
|
function watchTitle() {
|
||||||
@@ -335,7 +459,7 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
// por si el tema aterriza tarde con la hidratación.
|
// por si el tema aterriza tarde con la hidratación.
|
||||||
function vigilarTema() {
|
function vigilarTema() {
|
||||||
if (!window.MutationObserver) return;
|
if (!window.MutationObserver) return;
|
||||||
var conf = { attributes: true, attributeFilter: ['class', 'style', 'data-theme'] };
|
var conf = { attributes: true, attributeFilter: ['class', 'style', 'data-theme', 'data-ls-pestana'] };
|
||||||
if (document.documentElement) new MutationObserver(report).observe(document.documentElement, conf);
|
if (document.documentElement) new MutationObserver(report).observe(document.documentElement, conf);
|
||||||
if (document.body) new MutationObserver(report).observe(document.body, conf);
|
if (document.body) new MutationObserver(report).observe(document.body, conf);
|
||||||
}
|
}
|
||||||
@@ -352,7 +476,8 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
if (!u) return;
|
if (!u) return;
|
||||||
if (isExt(u)) { e.preventDefault(); openExternal(u.href); return; }
|
if (isExt(u)) { e.preventDefault(); openExternal(u.href); return; }
|
||||||
var mod = e.metaKey || e.ctrlKey;
|
var mod = e.metaKey || e.ctrlKey;
|
||||||
if (isApp(u) && (mod || a.target === '_blank')) { e.preventDefault(); newTab(u.href); }
|
var nombre = mod ? null : nombreVentana(a.target);
|
||||||
|
if (isApp(u) && (mod || a.target === '_blank' || nombre)) { e.preventDefault(); newTab(u.href, nombre); }
|
||||||
}, true);
|
}, true);
|
||||||
|
|
||||||
// Clic con la rueda (botón central) en un enlace interno → pestaña nueva, como en el navegador.
|
// Clic con la rueda (botón central) en un enlace interno → pestaña nueva, como en el navegador.
|
||||||
@@ -369,7 +494,7 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
window.open = function (url, name, feats) {
|
window.open = function (url, name, feats) {
|
||||||
var u = url ? abs(url) : null;
|
var u = url ? abs(url) : null;
|
||||||
if (isExt(u)) { openExternal(u.href); return null; }
|
if (isExt(u)) { openExternal(u.href); return null; }
|
||||||
if (isInterno(u)) { newTab(u.href); return null; }
|
if (isInterno(u)) { newTab(u.href, nombreVentana(name)); return null; }
|
||||||
return _open ? _open.call(window, url, name, feats) : null;
|
return _open ? _open.call(window, url, name, feats) : null;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -381,6 +506,10 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
// nota y en cualquier campo de la app. En macOS no aplica (Option no toca ctrlKey).
|
// nota y en cualquier campo de la app. En macOS no aplica (Option no toca ctrlKey).
|
||||||
if (e.altKey) return;
|
if (e.altKey) return;
|
||||||
var mod = e.metaKey || e.ctrlKey;
|
var mod = e.metaKey || e.ctrlKey;
|
||||||
|
// F5 recarga, como en cualquier navegador de Windows (y Ctrl+F5 / Shift+F5 también). WebView2
|
||||||
|
// tiene apagados sus propios atajos, así que F5 no hacía NADA: el único que recargaba era
|
||||||
|
// Ctrl+R, y va antes del filtro de abajo porque F5 no lleva modificador.
|
||||||
|
if (e.key === 'F5') { e.preventDefault(); location.reload(); return; }
|
||||||
if (!mod) return;
|
if (!mod) return;
|
||||||
var k = e.key;
|
var k = e.key;
|
||||||
if (k === 't' || k === 'T') {
|
if (k === 't' || k === 'T') {
|
||||||
@@ -419,6 +548,110 @@ const INIT_JS_TPL: &str = r#"
|
|||||||
})();
|
})();
|
||||||
"#;
|
"#;
|
||||||
|
|
||||||
|
// ── Pestañas en reposo ──
|
||||||
|
//
|
||||||
|
// Cada pestaña es la web app ENTERA: su árbol de React, su conexión del chat, sus sondeos. Con
|
||||||
|
// seis abiertas corrían seis, aunque solo se mire una. Una pestaña que lleva REPOSO_TRAS oculta
|
||||||
|
// se SUSPENDE (WebView2 `TrySuspend`: se congelan sus temporizadores y el sistema puede recuperar
|
||||||
|
// su memoria) y despierta sola, donde estaba, al volver a ella. La activa nunca se duerme, así
|
||||||
|
// que los avisos y el globo de no leídos siguen llegando por ella.
|
||||||
|
//
|
||||||
|
// No se duerme: la que está cargando, la que dice estar ocupada (subida, descarga o audio en
|
||||||
|
// curso: ver `__lsReposo` en el script de la pestaña) ni un editor de documentos (`/docs/`:
|
||||||
|
// OnlyOffice mantiene su propia conexión de edición y no conviene cortarla).
|
||||||
|
// Solo Windows: WKWebView (macOS) no ofrece nada equivalente y ya frena lo oculto por su cuenta.
|
||||||
|
const REPOSO_TRAS: Duration = Duration::from_secs(5 * 60);
|
||||||
|
const REPOSO_RONDA: Duration = Duration::from_secs(60);
|
||||||
|
|
||||||
|
fn puede_reposar(t: &TabRec, activa: bool) -> bool {
|
||||||
|
!activa
|
||||||
|
&& !t.dormida
|
||||||
|
&& !t.loading
|
||||||
|
&& !t.url.contains("/docs/")
|
||||||
|
&& t.oculta_desde.map(|d| d.elapsed() >= REPOSO_TRAS).unwrap_or(false)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Cada minuto: a las candidatas se les PREGUNTA si están libres. La respuesta llega por el
|
||||||
|
// evento `ls-reposo` y es ahí donde se suspende.
|
||||||
|
fn ronda_de_reposo<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
let candidatas: Vec<String> = {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
s.tabs.iter().enumerate().filter(|(i, t)| puede_reposar(t, *i == s.active)).map(|(_, t)| t.label.clone()).collect()
|
||||||
|
};
|
||||||
|
for label in candidatas {
|
||||||
|
if let Some(wv) = get_webview(app, &label) {
|
||||||
|
let _ = wv.eval("window.__lsReposo && window.__lsReposo()");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// Ahorro de memoria: las que llevan DESCARTE_TRAS ocultas y ya están dormidas (pasaron el
|
||||||
|
// filtro de arriba: sin subida, descarga ni audio, y no son un editor) se descartan.
|
||||||
|
let a_descartar: Vec<String> = {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
s.tabs
|
||||||
|
.iter()
|
||||||
|
.enumerate()
|
||||||
|
.filter(|(i, t)| {
|
||||||
|
*i != s.active
|
||||||
|
&& t.dormida
|
||||||
|
&& !t.descartada
|
||||||
|
&& !t.url.contains("/docs/")
|
||||||
|
&& t.oculta_desde.map(|d| d.elapsed() >= memoria::DESCARTE_TRAS).unwrap_or(false)
|
||||||
|
})
|
||||||
|
.map(|(_, t)| t.label.clone())
|
||||||
|
.collect()
|
||||||
|
};
|
||||||
|
for label in a_descartar {
|
||||||
|
descartar_pestana(app, &label);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn dormir_pestana<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
||||||
|
{
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
let activa = s.active;
|
||||||
|
let Some((i, t)) = s.tabs.iter_mut().enumerate().find(|(_, t)| t.label == label) else { return };
|
||||||
|
// Pudo volverse la activa (o empezar a cargar) mientras contestaba.
|
||||||
|
if !puede_reposar(t, i == activa) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
t.dormida = true;
|
||||||
|
}
|
||||||
|
if let Some(wv) = get_webview(app, label) {
|
||||||
|
dormir_webview(&wv);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
fn dormir_webview<R: Runtime>(wv: &Webview<R>) {
|
||||||
|
let _ = wv.with_webview(|pw| unsafe {
|
||||||
|
use webview2_com::{Microsoft::Web::WebView2::Win32::ICoreWebView2_3, TrySuspendCompletedHandler};
|
||||||
|
use windows::core::Interface;
|
||||||
|
let Ok(core) = pw.controller().CoreWebView2() else { return };
|
||||||
|
let Ok(core3) = core.cast::<ICoreWebView2_3>() else { return };
|
||||||
|
// Si WebView2 no puede (la pestaña está visible, o usa algo que lo impide), no pasa nada.
|
||||||
|
let _ = core3.TrySuspend(&TrySuspendCompletedHandler::create(Box::new(|_, _| Ok(()))));
|
||||||
|
});
|
||||||
|
}
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
fn dormir_webview<R: Runtime>(_wv: &Webview<R>) {}
|
||||||
|
|
||||||
|
// WebView2 ya despierta sola una vista al hacerla visible; se pide igual, por si acaso.
|
||||||
|
#[cfg(windows)]
|
||||||
|
fn despertar_webview<R: Runtime>(wv: &Webview<R>) {
|
||||||
|
let _ = wv.with_webview(|pw| unsafe {
|
||||||
|
use webview2_com::Microsoft::Web::WebView2::Win32::ICoreWebView2_3;
|
||||||
|
use windows::core::Interface;
|
||||||
|
let Ok(core) = pw.controller().CoreWebView2() else { return };
|
||||||
|
let Ok(core3) = core.cast::<ICoreWebView2_3>() else { return };
|
||||||
|
let _ = core3.Resume();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
fn despertar_webview<R: Runtime>(_wv: &Webview<R>) {}
|
||||||
|
|
||||||
// ── Utilidades del shell ──
|
// ── Utilidades del shell ──
|
||||||
|
|
||||||
fn main_window<R: Runtime>(app: &AppHandle<R>) -> Option<Window<R>> {
|
fn main_window<R: Runtime>(app: &AppHandle<R>) -> Option<Window<R>> {
|
||||||
@@ -464,7 +697,7 @@ fn broadcast<R: Runtime>(app: &AppHandle<R>) {
|
|||||||
.tabs
|
.tabs
|
||||||
.iter()
|
.iter()
|
||||||
.enumerate()
|
.enumerate()
|
||||||
.map(|(i, t)| json!({ "label": t.label, "title": t.title, "url": t.url, "loading": t.loading, "active": i == s.active, "color": t.color }))
|
.map(|(i, t)| json!({ "label": t.label, "title": t.title, "url": t.url, "loading": t.loading, "active": i == s.active, "color": t.color, "pagina": t.pagina }))
|
||||||
.collect();
|
.collect();
|
||||||
json!({
|
json!({
|
||||||
"tabs": tabs,
|
"tabs": tabs,
|
||||||
@@ -508,17 +741,34 @@ fn activate_tab<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
|||||||
} else {
|
} else {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
// Reposo: la activa deja de contar; las demás empiezan a contar desde que se ocultan.
|
||||||
|
let ahora = Instant::now();
|
||||||
|
let activa = s.active;
|
||||||
|
for (i, t) in s.tabs.iter_mut().enumerate() {
|
||||||
|
if i == activa {
|
||||||
|
t.oculta_desde = None;
|
||||||
|
t.dormida = false;
|
||||||
|
} else if t.oculta_desde.is_none() {
|
||||||
|
t.oculta_desde = Some(ahora);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// Descartada por ahorro de memoria: se crea otra vez en su última URL antes de mostrarla.
|
||||||
|
revivir_pestana(app, label);
|
||||||
let Some(win) = main_window(app) else { return };
|
let Some(win) = main_window(app) else { return };
|
||||||
for wv in win.webviews() {
|
for wv in win.webviews() {
|
||||||
if wv.label() == CHROME {
|
if wv.label() == CHROME {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if wv.label() == label {
|
if wv.label() == label {
|
||||||
|
despertar_webview(&wv);
|
||||||
|
memoria::nivel_bajo(&wv, false);
|
||||||
let _ = wv.show();
|
let _ = wv.show();
|
||||||
let _ = wv.set_focus();
|
let _ = wv.set_focus();
|
||||||
} else {
|
} else {
|
||||||
let _ = wv.hide();
|
let _ = wv.hide();
|
||||||
|
// Oculta: que WebView2 suelte cachés y memoria que puede regenerar (memoria.rs).
|
||||||
|
memoria::nivel_bajo(&wv, true);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
broadcast(app);
|
broadcast(app);
|
||||||
@@ -620,12 +870,17 @@ fn avisar_descarga_terminada<R: Runtime>(webview: &Webview<R>, url: &Url, path:
|
|||||||
|
|
||||||
// Crea una pestaña nueva cargando `url` (o el servidor si viene vacío).
|
// Crea una pestaña nueva cargando `url` (o el servidor si viene vacío).
|
||||||
fn create_tab<R: Runtime>(app: &AppHandle<R>, url: Option<String>, activate: bool) {
|
fn create_tab<R: Runtime>(app: &AppHandle<R>, url: Option<String>, activate: bool) {
|
||||||
|
crear_pestana(app, url, activate, None);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Lo mismo, con su nombre de ventana (ver `reusar_pestana`). Devuelve la etiqueta de la nueva.
|
||||||
|
fn crear_pestana<R: Runtime>(app: &AppHandle<R>, url: Option<String>, activate: bool, nombre: Option<String>) -> Option<String> {
|
||||||
let target = url.unwrap_or_else(|| SERVER_URL.to_string());
|
let target = url.unwrap_or_else(|| SERVER_URL.to_string());
|
||||||
// Solo el origen de la app puede abrirse en pestaña; cualquier otra cosa va al navegador.
|
// Solo el origen de la app puede abrirse en pestaña; cualquier otra cosa va al navegador.
|
||||||
let Ok(parsed) = Url::parse(&target) else { return };
|
let parsed = Url::parse(&target).ok()?;
|
||||||
let Ok(server) = Url::parse(SERVER_URL) else { return };
|
let server = Url::parse(SERVER_URL).ok()?;
|
||||||
if !es_pestana_interna(&parsed, &server) {
|
if !es_pestana_interna(&parsed, &server) {
|
||||||
return;
|
return None;
|
||||||
}
|
}
|
||||||
|
|
||||||
let label = {
|
let label = {
|
||||||
@@ -633,18 +888,77 @@ fn create_tab<R: Runtime>(app: &AppHandle<R>, url: Option<String>, activate: boo
|
|||||||
let mut s = shell.lock().unwrap();
|
let mut s = shell.lock().unwrap();
|
||||||
let label = format!("tab-{}", s.next_id);
|
let label = format!("tab-{}", s.next_id);
|
||||||
s.next_id += 1;
|
s.next_id += 1;
|
||||||
s.tabs.push(TabRec { label: label.clone(), title: "Labstream OS".into(), url: target.clone(), loading: true, color: None });
|
s.tabs.push(TabRec { label: label.clone(), title: "Labstream OS".into(), url: target.clone(), loading: true, color: None, oculta_desde: if activate { None } else { Some(Instant::now()) }, dormida: false, descartada: false, pagina: None, nombre });
|
||||||
label
|
label
|
||||||
};
|
};
|
||||||
|
|
||||||
let Some(win) = main_window(app) else { return };
|
match montar_webview(app, &label, parsed) {
|
||||||
|
Ok(_) => {
|
||||||
|
if activate {
|
||||||
|
activate_tab(app, &label);
|
||||||
|
} else {
|
||||||
|
broadcast(app);
|
||||||
|
save_persisted(app);
|
||||||
|
}
|
||||||
|
Some(label)
|
||||||
|
}
|
||||||
|
Err(e) => {
|
||||||
|
salud::anotar("ERROR", "pestaña", &format!("no se pudo crear el webview: {e}"));
|
||||||
|
// Revertir el registro si el webview no se pudo crear.
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
s.tabs.retain(|t| t.label != label);
|
||||||
|
None
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── Pestañas con NOMBRE (1.21) ──
|
||||||
|
// `window.open(url, "ls-edicion-<set>")` (el modo edición de un set) abre la pestaña la primera
|
||||||
|
// vez; las siguientes llevan a ESA pestaña, como hace el navegador con una ventana con nombre, en
|
||||||
|
// vez de amontonar una por foto. A la página se le pasa la URL nueva por `__lsAbrir` (el modo
|
||||||
|
// edición cambia de foto sin recargar, guardando lo de la que tenía); si no lo conoce, navega.
|
||||||
|
// Devuelve false si no hay pestaña con ese nombre (entonces se crea).
|
||||||
|
fn reusar_pestana<R: Runtime>(app: &AppHandle<R>, nombre: &str, url: Option<&str>) -> bool {
|
||||||
|
let Ok(server) = Url::parse(SERVER_URL) else { return false };
|
||||||
|
let destino = match url.map(Url::parse) {
|
||||||
|
None => None,
|
||||||
|
Some(Ok(u)) if es_pestana_interna(&u, &server) => Some(u),
|
||||||
|
Some(_) => return false,
|
||||||
|
};
|
||||||
|
let (label, descartada) = {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
let Some(t) = s.tabs.iter_mut().find(|t| t.nombre.as_deref() == Some(nombre)) else { return false };
|
||||||
|
// Descartada (sin webview): se crea ya en la URL nueva al activarla.
|
||||||
|
if t.descartada {
|
||||||
|
if let Some(d) = &destino {
|
||||||
|
t.url = d.to_string();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
(t.label.clone(), t.descartada)
|
||||||
|
};
|
||||||
|
activate_tab(app, &label);
|
||||||
|
if let (Some(d), false) = (destino, descartada) {
|
||||||
|
if let Some(wv) = get_webview(app, &label) {
|
||||||
|
let u = serde_json::to_string(d.as_str()).unwrap_or_else(|_| "\"\"".into());
|
||||||
|
let _ = wv.eval(format!("(function(u){{try{{if(window.__lsAbrir&&window.__lsAbrir(u))return}}catch(e){{}}location.assign(u)}})({u})"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
true
|
||||||
|
}
|
||||||
|
|
||||||
|
// Crea el webview de una pestaña: una nueva (create_tab) o una descartada que vuelve
|
||||||
|
// (revivir_pestana, al activarla). Lo vigila salud.rs: si su proceso muere, se recarga sola.
|
||||||
|
fn montar_webview<R: Runtime>(app: &AppHandle<R>, label: &str, parsed: Url) -> tauri::Result<Webview<R>> {
|
||||||
|
let win = main_window(app).ok_or(tauri::Error::WindowNotFound)?;
|
||||||
let scale = win.scale_factor().unwrap_or(1.0);
|
let scale = win.scale_factor().unwrap_or(1.0);
|
||||||
let size = win.inner_size().map(|s| s.to_logical::<f64>(scale)).unwrap_or(LogicalSize::new(1400.0, 900.0));
|
let size = win.inner_size().map(|s| s.to_logical::<f64>(scale)).unwrap_or(LogicalSize::new(1400.0, 900.0));
|
||||||
|
|
||||||
let init = INIT_JS_TPL.replace("__LABEL__", &label).replace("__ORIGIN__", SERVER_URL);
|
let init = INIT_JS_TPL.replace("__LABEL__", label).replace("__ORIGIN__", SERVER_URL);
|
||||||
let app_zoom = app.clone();
|
let app_zoom = app.clone();
|
||||||
let app_navigation = app.clone();
|
let app_navigation = app.clone();
|
||||||
let builder = WebviewBuilder::new(&label, WebviewUrl::External(parsed))
|
let builder = WebviewBuilder::new(label, WebviewUrl::External(parsed))
|
||||||
.initialization_script(&init)
|
.initialization_script(&init)
|
||||||
.on_navigation(move |url| {
|
.on_navigation(move |url| {
|
||||||
if url.scheme() == "https" && url.host_str().map(is_google_host).unwrap_or(false) {
|
if url.scheme() == "https" && url.host_str().map(is_google_host).unwrap_or(false) {
|
||||||
@@ -681,30 +995,111 @@ fn create_tab<R: Runtime>(app: &AppHandle<R>, url: Option<String>, activate: boo
|
|||||||
set_loading(&app_zoom, wv.label(), cargando);
|
set_loading(&app_zoom, wv.label(), cargando);
|
||||||
});
|
});
|
||||||
|
|
||||||
let created = win.add_child(
|
let wv = win.add_child(
|
||||||
builder,
|
builder,
|
||||||
LogicalPosition::new(0.0, TAB_BAR_H),
|
LogicalPosition::new(0.0, TAB_BAR_H),
|
||||||
LogicalSize::new(size.width, (size.height - TAB_BAR_H).max(0.0)),
|
LogicalSize::new(size.width, (size.height - TAB_BAR_H).max(0.0)),
|
||||||
);
|
)?;
|
||||||
|
// Si su proceso de WebView2 muere o se cuelga, se anota y la pestaña se recarga sola.
|
||||||
|
salud::vigilar_pestana(app, &wv);
|
||||||
|
Ok(wv)
|
||||||
|
}
|
||||||
|
|
||||||
match created {
|
// Ahorro de memoria: una pestaña dormida desde hace DESCARTE_TRAS se cierra de verdad (su proceso
|
||||||
Ok(_) => {
|
// sale de la memoria) y queda en la barra con su título, URL y color. `activate_tab` la revive.
|
||||||
if activate {
|
fn descartar_pestana<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
||||||
activate_tab(app, &label);
|
{
|
||||||
} else {
|
|
||||||
broadcast(app);
|
|
||||||
save_persisted(app);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Err(_) => {
|
|
||||||
// Revertir el registro si el webview no se pudo crear.
|
|
||||||
let shell = app.state::<ShellState>();
|
let shell = app.state::<ShellState>();
|
||||||
let mut s = shell.lock().unwrap();
|
let mut s = shell.lock().unwrap();
|
||||||
s.tabs.retain(|t| t.label != label);
|
let activa = s.active;
|
||||||
|
let Some((i, t)) = s.tabs.iter_mut().enumerate().find(|(_, t)| t.label == label) else { return };
|
||||||
|
if i == activa || !t.dormida || t.descartada {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
t.descartada = true;
|
||||||
|
t.dormida = false;
|
||||||
|
}
|
||||||
|
if let Some(wv) = get_webview(app, label) {
|
||||||
|
let _ = wv.close();
|
||||||
|
}
|
||||||
|
salud::anotar("INFO", "memoria", &format!("pestaña {label} descartada (lleva {} min dormida)", memoria::DESCARTE_TRAS.as_secs() / 60));
|
||||||
|
}
|
||||||
|
|
||||||
|
// Una pestaña de la sesión anterior que no es la activa: entra en la barra SIN webview (como si se
|
||||||
|
// hubiera descartado) y se crea la primera vez que se activa.
|
||||||
|
fn registrar_diferida<R: Runtime>(app: &AppHandle<R>, url: &str, title: &str) {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
let label = format!("tab-{}", s.next_id);
|
||||||
|
s.next_id += 1;
|
||||||
|
let title = if title.is_empty() { "Labstream OS".to_string() } else { title.to_string() };
|
||||||
|
s.tabs.push(TabRec { label, title, url: url.to_string(), loading: false, color: None, oculta_desde: Some(Instant::now()), dormida: false, descartada: true, pagina: None, nombre: None });
|
||||||
|
}
|
||||||
|
|
||||||
|
// Vuelve a crear el webview de una pestaña descartada, en su última URL. Devuelve false si no se
|
||||||
|
// pudo (la pestaña se deja como estaba y se anota).
|
||||||
|
fn revivir_pestana<R: Runtime>(app: &AppHandle<R>, label: &str) -> bool {
|
||||||
|
let url = {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
match s.tabs.iter().find(|t| t.label == label) {
|
||||||
|
Some(t) if t.descartada => t.url.clone(),
|
||||||
|
_ => return true, // no estaba descartada: nada que hacer
|
||||||
|
}
|
||||||
|
};
|
||||||
|
let Ok(parsed) = Url::parse(&url) else { return false };
|
||||||
|
match montar_webview(app, label, parsed) {
|
||||||
|
Ok(_) => {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
if let Some(t) = s.tabs.iter_mut().find(|t| t.label == label) {
|
||||||
|
t.descartada = false;
|
||||||
|
t.loading = true;
|
||||||
|
}
|
||||||
|
true
|
||||||
|
}
|
||||||
|
Err(e) => {
|
||||||
|
salud::anotar("ERROR", "memoria", &format!("no se pudo revivir la pestaña {label}: {e}"));
|
||||||
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[cfg_attr(not(windows), allow(dead_code))]
|
||||||
|
// Una pestaña que se cayó varias veces seguidas ya no se recarga sola (salud.rs): se avisa para
|
||||||
|
// que la persona la recargue (F5) o la cierre, en vez de dejarla en blanco sin explicación.
|
||||||
|
pub(crate) fn aviso_pestana_rota<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
||||||
|
let titulo = {
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
s.tabs.iter().find(|t| t.label == label).map(|t| t.title.clone()).unwrap_or_else(|| "Una pestaña".into())
|
||||||
|
};
|
||||||
|
let _ = app
|
||||||
|
.notification()
|
||||||
|
.builder()
|
||||||
|
.title("Labstream OS")
|
||||||
|
.body(format!("«{titulo}» falló varias veces seguidas. Recárgala con F5 o ciérrala."))
|
||||||
|
.show();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Memoria alta (salud.rs): las pestañas ocultas se duermen YA, sin esperar sus 5 minutos. Se les
|
||||||
|
// adelanta el reloj de «oculta desde» y se pasa la ronda normal, que sigue preguntando a cada una
|
||||||
|
// si está libre (una subida, una descarga o algo sonando no se duermen nunca).
|
||||||
|
fn dormir_ocultas_ya<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
{
|
||||||
|
let shell = app.state::<ShellState>();
|
||||||
|
let mut s = shell.lock().unwrap();
|
||||||
|
let activa = s.active;
|
||||||
|
let antes = Instant::now().checked_sub(REPOSO_TRAS).unwrap_or_else(Instant::now);
|
||||||
|
for (i, t) in s.tabs.iter_mut().enumerate() {
|
||||||
|
if i != activa && t.oculta_desde.is_some() {
|
||||||
|
t.oculta_desde = Some(antes);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
ronda_de_reposo(app);
|
||||||
|
}
|
||||||
|
|
||||||
// Cierra una pestaña; si era la activa, activa la vecina. Nunca deja cero pestañas.
|
// Cierra una pestaña; si era la activa, activa la vecina. Nunca deja cero pestañas.
|
||||||
fn close_tab<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
fn close_tab<R: Runtime>(app: &AppHandle<R>, label: &str) {
|
||||||
let next_active: Option<String> = {
|
let next_active: Option<String> = {
|
||||||
@@ -918,6 +1313,9 @@ fn show_app_menu<R: Runtime>(app: &AppHandle<R>) {
|
|||||||
&CheckMenuItem::with_id(app, "autostart-toggle", "Iniciar con el sistema", true, autostart_on, None::<&str>)?,
|
&CheckMenuItem::with_id(app, "autostart-toggle", "Iniciar con el sistema", true, autostart_on, None::<&str>)?,
|
||||||
&MenuItem::with_id(app, "check-update", "Buscar actualización…", true, None::<&str>)?,
|
&MenuItem::with_id(app, "check-update", "Buscar actualización…", true, None::<&str>)?,
|
||||||
&PredefinedMenuItem::separator(app)?,
|
&PredefinedMenuItem::separator(app)?,
|
||||||
|
&MenuItem::with_id(app, "salud-resumen", salud::resumen(), false, None::<&str>)?,
|
||||||
|
&MenuItem::with_id(app, "diagnostico", "Abrir diagnóstico", true, None::<&str>)?,
|
||||||
|
&PredefinedMenuItem::separator(app)?,
|
||||||
&MenuItem::with_id(app, "version", &version, false, None::<&str>)?,
|
&MenuItem::with_id(app, "version", &version, false, None::<&str>)?,
|
||||||
&MenuItem::with_id(app, "quit-app", "Salir de Labstream OS", true, None::<&str>)?,
|
&MenuItem::with_id(app, "quit-app", "Salir de Labstream OS", true, None::<&str>)?,
|
||||||
],
|
],
|
||||||
@@ -1112,21 +1510,47 @@ async fn check_update_manual(handle: tauri::AppHandle) {
|
|||||||
match updater.check().await {
|
match updater.check().await {
|
||||||
Ok(Some(update)) => {
|
Ok(Some(update)) => {
|
||||||
notify(format!("Instalando la versión {}…", update.version));
|
notify(format!("Instalando la versión {}…", update.version));
|
||||||
if update.download_and_install(|_, _| {}, || {}).await.is_ok() {
|
let version = update.version.clone();
|
||||||
handle.restart();
|
match update.download_and_install(|_, _| {}, move || salud::antes_de_actualizar(&version)).await {
|
||||||
} else {
|
Ok(()) => handle.restart(),
|
||||||
|
Err(e) => {
|
||||||
|
salud::anotar("ERROR", "actualizacion", &format!("no se pudo instalar: {e}"));
|
||||||
notify("No se pudo instalar la actualización. Intenta de nuevo más tarde.".into());
|
notify("No se pudo instalar la actualización. Intenta de nuevo más tarde.".into());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
Ok(None) => notify(format!("Estás en la última versión ({}).", handle.package_info().version)),
|
Ok(None) => notify(format!("Estás en la última versión ({}).", handle.package_info().version)),
|
||||||
Err(_) => notify("No se pudo comprobar la actualización (revisa la red).".into()),
|
Err(e) => {
|
||||||
|
salud::anotar("AVISO", "actualizacion", &format!("no se pudo comprobar: {e}"));
|
||||||
|
notify("No se pudo comprobar la actualización (revisa la red).".into());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ⋮ ▸ Abrir diagnóstico (y la bandeja): la carpeta con salud.log y recursos.csv, para mirarla o
|
||||||
|
// mandarla cuando algo falle.
|
||||||
|
fn abrir_diagnostico<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
if let Some(dir) = salud::carpeta() {
|
||||||
|
let _ = app.opener().open_path(dir.to_string_lossy().to_string(), None::<&str>);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Muestra y enfoca la ventana principal (tray, dock, segunda instancia).
|
// Muestra y enfoca la ventana principal (tray, dock, segunda instancia).
|
||||||
fn show_main<R: Runtime>(app: &AppHandle<R>) {
|
fn show_main<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
memoria::a_la_vista(app);
|
||||||
if let Some(w) = main_window(app) {
|
if let Some(w) = main_window(app) {
|
||||||
let _ = w.show();
|
let _ = w.show();
|
||||||
|
// tao guarda su propia nota de «visible» y `show()` solo llama a ShowWindow si esa nota
|
||||||
|
// cambia (WindowFlags::apply_diff). Visto en el equipo de edición (2026-10-14, 1.19.0): la
|
||||||
|
// ventana estaba OCULTA en Windows con la nota en «visible», así que ni la bandeja, ni el
|
||||||
|
// icono, ni la tecla del MasterHUB la sacaban (set_focus sí corría: tomaba el foco sin
|
||||||
|
// verse). `is_visible()` lee el estado REAL (IsWindowVisible); si no cuadra, se baja y
|
||||||
|
// se sube la nota para que ShowWindow corra de verdad, y se anota para medir cada cuánto pasa.
|
||||||
|
if !w.is_visible().unwrap_or(true) {
|
||||||
|
salud::anotar("AVISO", "ventana", "show() no la mostró (estado de tao desincronizado): se rehace ocultar + mostrar");
|
||||||
|
let _ = w.hide();
|
||||||
|
let _ = w.show();
|
||||||
|
}
|
||||||
let _ = w.unminimize();
|
let _ = w.unminimize();
|
||||||
let _ = w.set_focus();
|
let _ = w.set_focus();
|
||||||
}
|
}
|
||||||
@@ -1140,8 +1564,21 @@ async fn check_update(handle: tauri::AppHandle) {
|
|||||||
Ok(u) => u,
|
Ok(u) => u,
|
||||||
Err(_) => return,
|
Err(_) => return,
|
||||||
};
|
};
|
||||||
if let Ok(Some(update)) = updater.check().await {
|
let update = match updater.check().await {
|
||||||
if update.download_and_install(|_, _| {}, || {}).await.is_ok() {
|
Ok(Some(u)) => u,
|
||||||
|
Ok(None) => return,
|
||||||
|
Err(e) => {
|
||||||
|
salud::anotar("AVISO", "actualizacion", &format!("no se pudo comprobar: {e}"));
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
{
|
||||||
|
let version = update.version.clone();
|
||||||
|
let r = update.download_and_install(|_, _| {}, move || salud::antes_de_actualizar(&version)).await;
|
||||||
|
if let Err(e) = &r {
|
||||||
|
salud::anotar("ERROR", "actualizacion", &format!("no se pudo instalar: {e}"));
|
||||||
|
}
|
||||||
|
if r.is_ok() {
|
||||||
let _ = handle
|
let _ = handle
|
||||||
.notification()
|
.notification()
|
||||||
.builder()
|
.builder()
|
||||||
@@ -1264,6 +1701,8 @@ pub fn run() {
|
|||||||
.manage(Descargas::default())
|
.manage(Descargas::default())
|
||||||
.setup(|app| {
|
.setup(|app| {
|
||||||
let handle = app.handle().clone();
|
let handle = app.handle().clone();
|
||||||
|
// Lo primero: el diario de salud (pánicos, cierres de golpe, reinicio automático).
|
||||||
|
salud::preparar(&handle);
|
||||||
let saved = load_persisted(&handle);
|
let saved = load_persisted(&handle);
|
||||||
|
|
||||||
// Arranque automático al iniciar sesión: por defecto activado, pero se respeta
|
// Arranque automático al iniciar sesión: por defecto activado, pero se respeta
|
||||||
@@ -1430,6 +1869,7 @@ pub fn run() {
|
|||||||
}
|
}
|
||||||
id if id.starts_with("tab-color-") => tab_menu_action(app, id),
|
id if id.starts_with("tab-color-") => tab_menu_action(app, id),
|
||||||
"autostart-toggle" => toggle_autostart(app),
|
"autostart-toggle" => toggle_autostart(app),
|
||||||
|
"diagnostico" => abrir_diagnostico(app),
|
||||||
"clear-cache" => {
|
"clear-cache" => {
|
||||||
let antes = cache::tamano(app);
|
let antes = cache::tamano(app);
|
||||||
cache::vaciar(app);
|
cache::vaciar(app);
|
||||||
@@ -1469,7 +1909,11 @@ pub fn run() {
|
|||||||
// Pestañas de la sesión anterior (o una nueva si no hay), cada una con su color.
|
// Pestañas de la sesión anterior (o una nueva si no hay), cada una con su color.
|
||||||
// El color se empareja con su URL ANTES de filtrar: el filtro por origen puede
|
// El color se empareja con su URL ANTES de filtrar: el filtro por origen puede
|
||||||
// descartar entradas y entonces los índices de las dos listas dejarían de casar.
|
// descartar entradas y entonces los índices de las dos listas dejarían de casar.
|
||||||
let restore: Vec<(String, String)> = {
|
// Ahorro de memoria al abrir: solo se CARGA la pestaña que estaba activa; las demás se
|
||||||
|
// registran descartadas (título, URL y color en la barra) y se crean al hacer clic en
|
||||||
|
// ellas, como hacen Chrome y Edge. Antes se cargaban todas a la vez: con 5 pestañas, 5
|
||||||
|
// copias enteras de la web app arrancando juntas.
|
||||||
|
let restore: Vec<(String, String, String, String, String)> = {
|
||||||
let server = Url::parse(SERVER_URL).expect("URL del servidor válida");
|
let server = Url::parse(SERVER_URL).expect("URL del servidor válida");
|
||||||
saved
|
saved
|
||||||
.tabs
|
.tabs
|
||||||
@@ -1477,26 +1921,33 @@ pub fn run() {
|
|||||||
.enumerate()
|
.enumerate()
|
||||||
.filter(|(_, u)| Url::parse(u).map(|p| es_pestana_interna(&p, &server)).unwrap_or(false))
|
.filter(|(_, u)| Url::parse(u).map(|p| es_pestana_interna(&p, &server)).unwrap_or(false))
|
||||||
.take(12)
|
.take(12)
|
||||||
.map(|(i, u)| (u.clone(), saved.colors.get(i).cloned().unwrap_or_default()))
|
.map(|(i, u)| {
|
||||||
|
let de = |v: &Vec<String>| v.get(i).cloned().unwrap_or_default();
|
||||||
|
(u.clone(), de(&saved.colors), de(&saved.titles), de(&saved.paginas), de(&saved.nombres))
|
||||||
|
})
|
||||||
.collect()
|
.collect()
|
||||||
};
|
};
|
||||||
if restore.is_empty() {
|
if restore.is_empty() {
|
||||||
create_tab(&handle, None, true);
|
create_tab(&handle, None, true);
|
||||||
} else {
|
} else {
|
||||||
for (url, color) in &restore {
|
let idx = saved.active.min(restore.len() - 1);
|
||||||
|
for (i, (url, color, title, pagina, nombre)) in restore.iter().enumerate() {
|
||||||
|
if i == idx {
|
||||||
create_tab(&handle, Some(url.clone()), false);
|
create_tab(&handle, Some(url.clone()), false);
|
||||||
if !color.is_empty() {
|
} else {
|
||||||
// create_tab acaba de empujar su pestaña al final de la lista.
|
registrar_diferida(&handle, url, title);
|
||||||
|
}
|
||||||
|
// La pestaña se acaba de empujar al final de la lista.
|
||||||
let shell = handle.state::<ShellState>();
|
let shell = handle.state::<ShellState>();
|
||||||
let mut s = shell.lock().unwrap();
|
let mut s = shell.lock().unwrap();
|
||||||
if let Some(t) = s.tabs.last_mut() {
|
if let Some(t) = s.tabs.last_mut().filter(|t| t.url == *url) {
|
||||||
if t.url == *url {
|
if !color.is_empty() {
|
||||||
t.color = Some(color.clone());
|
t.color = Some(color.clone());
|
||||||
}
|
}
|
||||||
|
t.pagina = color_de_pagina(pagina);
|
||||||
|
t.nombre = nombre_de_ventana(nombre);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
let idx = saved.active.min(restore.len() - 1);
|
|
||||||
let label = {
|
let label = {
|
||||||
let shell = handle.state::<ShellState>();
|
let shell = handle.state::<ShellState>();
|
||||||
let s = shell.lock().unwrap();
|
let s = shell.lock().unwrap();
|
||||||
@@ -1514,9 +1965,28 @@ pub fn run() {
|
|||||||
broadcast(&h);
|
broadcast(&h);
|
||||||
});
|
});
|
||||||
let h = handle.clone();
|
let h = handle.clone();
|
||||||
|
handle.listen_any("ls-reposo", move |e| {
|
||||||
|
if field_bool(e.payload(), "libre") == Some(true) {
|
||||||
|
if let Some(l) = field(e.payload(), "label") {
|
||||||
|
dormir_pestana(&h, &l);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
let h = handle.clone();
|
||||||
|
std::thread::spawn(move || loop {
|
||||||
|
std::thread::sleep(REPOSO_RONDA);
|
||||||
|
ronda_de_reposo(&h);
|
||||||
|
});
|
||||||
|
let h = handle.clone();
|
||||||
handle.listen_any("ls-new-tab", move |e| {
|
handle.listen_any("ls-new-tab", move |e| {
|
||||||
let url = field(e.payload(), "url");
|
let url = field(e.payload(), "url");
|
||||||
create_tab(&h, url, true);
|
let nombre = field(e.payload(), "name").and_then(|n| nombre_de_ventana(&n));
|
||||||
|
if let Some(n) = &nombre {
|
||||||
|
if reusar_pestana(&h, n, url.as_deref()) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
crear_pestana(&h, url, true, nombre);
|
||||||
});
|
});
|
||||||
let h = handle.clone();
|
let h = handle.clone();
|
||||||
handle.listen_any("ls-activate", move |e| {
|
handle.listen_any("ls-activate", move |e| {
|
||||||
@@ -1617,11 +2087,12 @@ pub fn run() {
|
|||||||
});
|
});
|
||||||
let h = handle.clone();
|
let h = handle.clone();
|
||||||
handle.listen_any("ls-title", move |e| {
|
handle.listen_any("ls-title", move |e| {
|
||||||
let (label, title, url, dark) = (
|
let (label, title, url, dark, pestana) = (
|
||||||
field(e.payload(), "label"),
|
field(e.payload(), "label"),
|
||||||
field(e.payload(), "title"),
|
field(e.payload(), "title"),
|
||||||
field(e.payload(), "url"),
|
field(e.payload(), "url"),
|
||||||
field_bool(e.payload(), "dark"),
|
field_bool(e.payload(), "dark"),
|
||||||
|
field(e.payload(), "pestana"),
|
||||||
);
|
);
|
||||||
if let Some(label) = label {
|
if let Some(label) = label {
|
||||||
let shell = h.state::<ShellState>();
|
let shell = h.state::<ShellState>();
|
||||||
@@ -1633,6 +2104,10 @@ pub fn run() {
|
|||||||
if let Some(url) = url {
|
if let Some(url) = url {
|
||||||
t.url = url;
|
t.url = url;
|
||||||
}
|
}
|
||||||
|
// (una página de antes de la 1.21 no lo manda: se deja como estaba)
|
||||||
|
if let Some(p) = pestana {
|
||||||
|
t.pagina = color_de_pagina(&p);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
// El tema es global (todas las pestañas del origen comparten modo): el
|
// El tema es global (todas las pestañas del origen comparten modo): el
|
||||||
// último reporte manda, venga de la pestaña que venga.
|
// último reporte manda, venga de la pestaña que venga.
|
||||||
@@ -1649,9 +2124,16 @@ pub fn run() {
|
|||||||
let abrir = MenuItem::with_id(app, "abrir", "Abrir Labstream", true, None::<&str>)?;
|
let abrir = MenuItem::with_id(app, "abrir", "Abrir Labstream", true, None::<&str>)?;
|
||||||
let salir = MenuItem::with_id(app, "salir", "Salir", true, None::<&str>)?;
|
let salir = MenuItem::with_id(app, "salir", "Salir", true, None::<&str>)?;
|
||||||
let (trk_estado, trk_toggle) = tracker::armar_menu(app.handle())?;
|
let (trk_estado, trk_toggle) = tracker::armar_menu(app.handle())?;
|
||||||
|
// Lo que gasta la app entera (exe + todos sus procesos de WebView2), cada minuto.
|
||||||
|
let recursos = MenuItem::with_id(app, "salud-recursos", salud::resumen(), false, None::<&str>)?;
|
||||||
|
let diagnostico = MenuItem::with_id(app, "diagnostico", "Abrir diagnóstico", true, None::<&str>)?;
|
||||||
let sep1 = PredefinedMenuItem::separator(app)?;
|
let sep1 = PredefinedMenuItem::separator(app)?;
|
||||||
let sep2 = PredefinedMenuItem::separator(app)?;
|
let sep2 = PredefinedMenuItem::separator(app)?;
|
||||||
let menu = Menu::with_items(app, &[&abrir, &sep1, &trk_estado, &trk_toggle, &sep2, &salir])?;
|
let sep3 = PredefinedMenuItem::separator(app)?;
|
||||||
|
let menu = Menu::with_items(
|
||||||
|
app,
|
||||||
|
&[&abrir, &sep1, &trk_estado, &trk_toggle, &sep2, &recursos, &diagnostico, &sep3, &salir],
|
||||||
|
)?;
|
||||||
|
|
||||||
TrayIconBuilder::with_id("main-tray")
|
TrayIconBuilder::with_id("main-tray")
|
||||||
.icon(app.default_window_icon().unwrap().clone())
|
.icon(app.default_window_icon().unwrap().clone())
|
||||||
@@ -1660,6 +2142,7 @@ pub fn run() {
|
|||||||
.show_menu_on_left_click(false)
|
.show_menu_on_left_click(false)
|
||||||
.on_menu_event(|app, event| match event.id.as_ref() {
|
.on_menu_event(|app, event| match event.id.as_ref() {
|
||||||
"abrir" => show_main(app),
|
"abrir" => show_main(app),
|
||||||
|
"diagnostico" => abrir_diagnostico(app),
|
||||||
"salir" => {
|
"salir" => {
|
||||||
save_persisted(app);
|
save_persisted(app);
|
||||||
app.exit(0);
|
app.exit(0);
|
||||||
@@ -1683,6 +2166,20 @@ pub fn run() {
|
|||||||
// El sensor del rastreador: listener de vinculación + hilo de medición.
|
// El sensor del rastreador: listener de vinculación + hilo de medición.
|
||||||
tracker::iniciar(app.handle());
|
tracker::iniciar(app.handle());
|
||||||
|
|
||||||
|
// Salud: medición de recursos cada minuto y vigilante del hilo principal.
|
||||||
|
salud::iniciar(app.handle(), recursos, dormir_ocultas_ya);
|
||||||
|
// Errores de JavaScript de las pestañas (los manda el script de cada página).
|
||||||
|
handle.listen_any("ls-error", |e| {
|
||||||
|
let p = e.payload();
|
||||||
|
salud::error_js(
|
||||||
|
&field(p, "label").unwrap_or_default(),
|
||||||
|
&field(p, "tipo").unwrap_or_default(),
|
||||||
|
&field(p, "msg").unwrap_or_default(),
|
||||||
|
&field(p, "src").unwrap_or_default(),
|
||||||
|
&field(p, "url").unwrap_or_default(),
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
})
|
})
|
||||||
.on_window_event(|window, event| {
|
.on_window_event(|window, event| {
|
||||||
@@ -1693,6 +2190,8 @@ pub fn run() {
|
|||||||
let _ = window.hide();
|
let _ = window.hide();
|
||||||
api.prevent_close();
|
api.prevent_close();
|
||||||
}
|
}
|
||||||
|
// Vuelve a primer plano (p. ej. tras minimizar): memoria normal para lo que se ve.
|
||||||
|
WindowEvent::Focused(true) => memoria::a_la_vista(window.app_handle()),
|
||||||
// La barra y las pestañas siguen el tamaño de la ventana.
|
// La barra y las pestañas siguen el tamaño de la ventana.
|
||||||
WindowEvent::Resized(_) | WindowEvent::ScaleFactorChanged { .. } => {
|
WindowEvent::Resized(_) | WindowEvent::ScaleFactorChanged { .. } => {
|
||||||
let app = window.app_handle();
|
let app = window.app_handle();
|
||||||
@@ -1755,6 +2254,10 @@ pub fn run() {
|
|||||||
if let tauri::RunEvent::ExitRequested { .. } = event {
|
if let tauri::RunEvent::ExitRequested { .. } = event {
|
||||||
save_persisted(app);
|
save_persisted(app);
|
||||||
}
|
}
|
||||||
|
// Salida limpia: sin esto, el próximo arranque anotaría un «cierre de golpe».
|
||||||
|
if let tauri::RunEvent::Exit = event {
|
||||||
|
salud::salida_limpia();
|
||||||
|
}
|
||||||
let _ = app;
|
let _ = app;
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
212
src-tauri/src/memoria.rs
Archivo normal
212
src-tauri/src/memoria.rs
Archivo normal
@@ -0,0 +1,212 @@
|
|||||||
|
// ── Memoria (v1.20.0): que la app gaste lo que necesita y devuelva lo que no ──
|
||||||
|
//
|
||||||
|
// MEDIDO en el equipo de edición (2026-10-14, app abierta desde el día anterior, 5 pestañas):
|
||||||
|
// 2.221 MB de memoria privada en 13 procesos. De eso, 1.329 MB eran del PROCESO GRÁFICO de
|
||||||
|
// WebView2 (gpu-process), que crece con las horas (fotos, miniaturas, el reproductor de revisión,
|
||||||
|
// dos monitores 4K) y no devuelve nada; cada pestaña viva pesaba 110-180 MB más. Se reinició a
|
||||||
|
// mano solo el proceso gráfico: WebView2 lo levantó de nuevo, nada se perdió, y la app bajó a
|
||||||
|
// 1.140 MB. De ahí salen las tres medidas de este módulo:
|
||||||
|
//
|
||||||
|
// 1. RECICLAR EL PROCESO GRÁFICO: si pasa de GPU_RECICLAR_MB y nadie está mirando (ventana
|
||||||
|
// oculta o minimizada, o sin tocar ratón ni teclado RECICLAR_INACTIVO), se cierra y WebView2
|
||||||
|
// crea otro al momento (es un caso previsto: ProcessFailed GPU_PROCESS_EXITED, que salud.rs
|
||||||
|
// anota). Como mucho cada RECICLAR_CADA: Chromium pasa a dibujar sin GPU si el proceso gráfico
|
||||||
|
// cae varias veces en poco tiempo, y eso sería peor que la memoria.
|
||||||
|
// 2. NIVEL DE MEMORIA BAJO (ICoreWebView2_19::MemoryUsageTargetLevel): a las pestañas ocultas
|
||||||
|
// —y a todas con la ventana oculta o minimizada— se les pide a WebView2 que suelte cachés y
|
||||||
|
// memoria que puede regenerar. La pestaña a la vista vuelve a «normal» al instante.
|
||||||
|
// 3. DESCARTAR PESTAÑAS (lib.rs, `ronda_de_reposo`): una pestaña que lleva DESCARTE_TRAS dormida
|
||||||
|
// se cierra de verdad —su proceso sale de la memoria— y se queda en la barra con su título,
|
||||||
|
// URL y color; al volver a ella se crea otra vez en la misma URL (1-2 s de carga). Es lo que
|
||||||
|
// hace el «Ahorro de memoria» de Chrome. Solo llegan aquí pestañas que ya pasaron el filtro
|
||||||
|
// del reposo (sin subidas, descargas ni audio, y nunca un editor de documentos).
|
||||||
|
|
||||||
|
// En macOS solo existen los niveles y el descarte; la medición y el reciclaje son de Windows.
|
||||||
|
#![cfg_attr(not(windows), allow(dead_code, unused_imports))]
|
||||||
|
|
||||||
|
use std::{
|
||||||
|
sync::{mpsc, Mutex},
|
||||||
|
time::{Duration, Instant},
|
||||||
|
};
|
||||||
|
|
||||||
|
use tauri::{AppHandle, Manager, Runtime, Webview};
|
||||||
|
|
||||||
|
use crate::salud;
|
||||||
|
|
||||||
|
pub const GPU_RECICLAR_MB: u64 = 600;
|
||||||
|
const RECICLAR_CADA: Duration = Duration::from_secs(30 * 60);
|
||||||
|
const RECICLAR_INACTIVO: Duration = Duration::from_secs(10 * 60);
|
||||||
|
pub const DESCARTE_TRAS: Duration = Duration::from_secs(30 * 60);
|
||||||
|
|
||||||
|
static ULTIMO_RECICLAJE: Mutex<Option<Instant>> = Mutex::new(None);
|
||||||
|
|
||||||
|
/// Memoria de los procesos de WebView2 por tipo, para el diario: (gpu_mb, renderers_mb).
|
||||||
|
#[derive(Clone, Copy, Default)]
|
||||||
|
pub struct Reparto {
|
||||||
|
pub gpu_mb: u64,
|
||||||
|
pub pestanas_mb: u64,
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── Nivel de memoria de una pestaña ──
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
pub fn nivel_bajo<R: Runtime>(wv: &Webview<R>, bajo: bool) {
|
||||||
|
let _ = wv.with_webview(move |pw| unsafe {
|
||||||
|
use webview2_com::Microsoft::Web::WebView2::Win32::{
|
||||||
|
ICoreWebView2_19, COREWEBVIEW2_MEMORY_USAGE_TARGET_LEVEL_LOW, COREWEBVIEW2_MEMORY_USAGE_TARGET_LEVEL_NORMAL,
|
||||||
|
};
|
||||||
|
use windows::core::Interface;
|
||||||
|
let Ok(core) = pw.controller().CoreWebView2() else { return };
|
||||||
|
// ICoreWebView2_19 existe desde el runtime 1.0.2210 (2023): si no está, no pasa nada.
|
||||||
|
let Ok(c19) = core.cast::<ICoreWebView2_19>() else { return };
|
||||||
|
let _ = c19.SetMemoryUsageTargetLevel(if bajo { COREWEBVIEW2_MEMORY_USAGE_TARGET_LEVEL_LOW } else { COREWEBVIEW2_MEMORY_USAGE_TARGET_LEVEL_NORMAL });
|
||||||
|
});
|
||||||
|
}
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
pub fn nivel_bajo<R: Runtime>(_wv: &Webview<R>, _bajo: bool) {}
|
||||||
|
|
||||||
|
/// Con la ventana oculta o minimizada, todas las vistas a nivel bajo; si no, solo las ocultas.
|
||||||
|
/// La llama la ronda de salud cada minuto (desde su hilo: las consultas a la ventana esperan al
|
||||||
|
/// hilo principal y aquí eso es seguro).
|
||||||
|
pub fn ajustar_niveles<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
let Some(win) = app.get_window("main") else { return };
|
||||||
|
let nadie_mira = !win.is_visible().unwrap_or(true) || win.is_minimized().unwrap_or(false);
|
||||||
|
let activa = {
|
||||||
|
let shell = app.state::<crate::ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
s.tabs.get(s.active).map(|t| t.label.clone())
|
||||||
|
};
|
||||||
|
for wv in win.webviews() {
|
||||||
|
let visible = wv.label() == crate::CHROME || Some(wv.label()) == activa.as_deref();
|
||||||
|
nivel_bajo(&wv, nadie_mira || !visible);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// La ventana vuelve a verse (bandeja, minimizar, foco): la barra y la pestaña activa recuperan el
|
||||||
|
/// nivel normal YA, sin esperar a la ronda del minuto. No consulta la ventana: vale en cualquier hilo.
|
||||||
|
pub fn a_la_vista<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
let activa = {
|
||||||
|
let shell = app.state::<crate::ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
s.tabs.get(s.active).map(|t| t.label.clone())
|
||||||
|
};
|
||||||
|
for label in std::iter::once(crate::CHROME.to_string()).chain(activa) {
|
||||||
|
if let Some(wv) = app.get_webview(&label) {
|
||||||
|
nivel_bajo(&wv, false);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── Procesos de WebView2 y reciclaje del proceso gráfico ──
|
||||||
|
|
||||||
|
/// (pid, tipo) de todos los procesos del entorno WebView2 de la app. Tipo: el valor de
|
||||||
|
/// COREWEBVIEW2_PROCESS_KIND (0 navegador, 1 pestaña, 2 utilidad, 3 sandbox, 4 GPU…).
|
||||||
|
/// No llamar desde el hilo principal: espera su respuesta.
|
||||||
|
#[cfg(windows)]
|
||||||
|
fn procesos<R: Runtime>(app: &AppHandle<R>) -> Vec<(u32, i32)> {
|
||||||
|
let Some(wv) = app.get_webview(crate::CHROME) else { return Vec::new() };
|
||||||
|
let (tx, rx) = mpsc::channel();
|
||||||
|
let pedido = wv.with_webview(move |pw| unsafe {
|
||||||
|
use webview2_com::Microsoft::Web::WebView2::Win32::{ICoreWebView2Environment8, ICoreWebView2_2, COREWEBVIEW2_PROCESS_KIND};
|
||||||
|
use windows::core::Interface;
|
||||||
|
let mut v = Vec::new();
|
||||||
|
let lista = pw
|
||||||
|
.controller()
|
||||||
|
.CoreWebView2()
|
||||||
|
.and_then(|c| c.cast::<ICoreWebView2_2>())
|
||||||
|
.and_then(|c| c.Environment())
|
||||||
|
.and_then(|e| e.cast::<ICoreWebView2Environment8>())
|
||||||
|
.and_then(|e| e.GetProcessInfos());
|
||||||
|
if let Ok(lista) = lista {
|
||||||
|
let mut n = 0u32;
|
||||||
|
let _ = lista.Count(&mut n);
|
||||||
|
for i in 0..n {
|
||||||
|
let Ok(info) = lista.GetValueAtIndex(i) else { continue };
|
||||||
|
let (mut pid, mut kind) = (0i32, COREWEBVIEW2_PROCESS_KIND::default());
|
||||||
|
if info.ProcessId(&mut pid).is_ok() && info.Kind(&mut kind).is_ok() {
|
||||||
|
v.push((pid as u32, kind.0));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
let _ = tx.send(v);
|
||||||
|
});
|
||||||
|
if pedido.is_err() {
|
||||||
|
return Vec::new();
|
||||||
|
}
|
||||||
|
rx.recv_timeout(Duration::from_secs(5)).unwrap_or_default()
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Segundos sin tocar ratón ni teclado en todo el equipo.
|
||||||
|
#[cfg(windows)]
|
||||||
|
fn inactivo() -> Duration {
|
||||||
|
use windows::Win32::{System::SystemInformation::GetTickCount, UI::Input::KeyboardAndMouse::{GetLastInputInfo, LASTINPUTINFO}};
|
||||||
|
unsafe {
|
||||||
|
let mut li = LASTINPUTINFO { cbSize: std::mem::size_of::<LASTINPUTINFO>() as u32, dwTime: 0 };
|
||||||
|
if !GetLastInputInfo(&mut li).as_bool() {
|
||||||
|
return Duration::ZERO;
|
||||||
|
}
|
||||||
|
Duration::from_millis(GetTickCount().wrapping_sub(li.dwTime) as u64)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Ronda de memoria (cada minuto, hilo de salud): reparte la memoria por tipo y, si toca,
|
||||||
|
/// recicla el proceso gráfico.
|
||||||
|
#[cfg(windows)]
|
||||||
|
pub fn ronda<R: Runtime>(app: &AppHandle<R>) -> Reparto {
|
||||||
|
const GPU: i32 = 4; // COREWEBVIEW2_PROCESS_KIND_GPU
|
||||||
|
const PESTANA: i32 = 1; // COREWEBVIEW2_PROCESS_KIND_RENDERER
|
||||||
|
let procs = procesos(app);
|
||||||
|
let mut r = Reparto::default();
|
||||||
|
let mut gpu = None;
|
||||||
|
for &(pid, kind) in &procs {
|
||||||
|
let mb = salud::memoria_privada_mb(pid);
|
||||||
|
match kind {
|
||||||
|
GPU => {
|
||||||
|
r.gpu_mb += mb;
|
||||||
|
gpu = Some((pid, mb));
|
||||||
|
}
|
||||||
|
PESTANA => r.pestanas_mb += mb,
|
||||||
|
_ => {}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if let Some((pid, mb)) = gpu {
|
||||||
|
if mb >= GPU_RECICLAR_MB {
|
||||||
|
let nadie_mira = app
|
||||||
|
.get_window("main")
|
||||||
|
.map(|w| !w.is_visible().unwrap_or(true) || w.is_minimized().unwrap_or(false))
|
||||||
|
.unwrap_or(false);
|
||||||
|
let toca = ULTIMO_RECICLAJE.lock().unwrap().map(|t| t.elapsed() >= RECICLAR_CADA).unwrap_or(true);
|
||||||
|
// Con la ventana a la vista solo si nadie toca el equipo Y no sale sonido: alguien
|
||||||
|
// viendo un video de revisión sin tocar nada está «inactivo» pero sí está mirando, y
|
||||||
|
// cortarle el proceso gráfico le daría un parpadeo en pleno video.
|
||||||
|
let quieto = inactivo() >= RECICLAR_INACTIVO && !crate::tracker::hay_audio_sonando();
|
||||||
|
if toca && (nadie_mira || quieto) {
|
||||||
|
*ULTIMO_RECICLAJE.lock().unwrap() = Some(Instant::now());
|
||||||
|
if terminar(pid) {
|
||||||
|
salud::anotar("INFO", "memoria", &format!("proceso gráfico reciclado: tenía {mb} MB (WebView2 crea otro limpio)"));
|
||||||
|
} else {
|
||||||
|
salud::anotar("AVISO", "memoria", &format!("no se pudo reciclar el proceso gráfico ({mb} MB)"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
r
|
||||||
|
}
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
pub fn ronda<R: Runtime>(_app: &AppHandle<R>) -> Reparto {
|
||||||
|
Reparto::default()
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
fn terminar(pid: u32) -> bool {
|
||||||
|
use windows::Win32::{
|
||||||
|
Foundation::CloseHandle,
|
||||||
|
System::Threading::{OpenProcess, TerminateProcess, PROCESS_TERMINATE},
|
||||||
|
};
|
||||||
|
unsafe {
|
||||||
|
let Ok(h) = OpenProcess(PROCESS_TERMINATE, false, pid) else { return false };
|
||||||
|
let ok = TerminateProcess(h, 0).is_ok();
|
||||||
|
let _ = CloseHandle(h);
|
||||||
|
ok
|
||||||
|
}
|
||||||
|
}
|
||||||
519
src-tauri/src/salud.rs
Archivo normal
519
src-tauri/src/salud.rs
Archivo normal
@@ -0,0 +1,519 @@
|
|||||||
|
// ── Salud de la app (v1.20.0): cuánto gasta de verdad, qué falla y cómo se repone sola ──
|
||||||
|
//
|
||||||
|
// POR QUÉ: la app es un exe pequeño (~60 MB) que cuelga de él una docena de procesos de WebView2
|
||||||
|
// (uno por pestaña, más el GPU y los de utilidad). En el Administrador de tareas el gasto real
|
||||||
|
// queda repartido entre «Microsoft Edge WebView2» y no se ve cuánto pesa Labstream OS entero; y
|
||||||
|
// cuando algo fallaba (una pestaña en blanco, un cuelgue) no quedaba rastro. Este módulo:
|
||||||
|
//
|
||||||
|
// 1. MIDE cada minuto el ÁRBOL de procesos de la app (el exe + todos sus WebView2): memoria
|
||||||
|
// privada, CPU y número de procesos. Lo enseña en la bandeja («Recursos: 2,1 GB · CPU 3 %»)
|
||||||
|
// y lo anota en `recursos.csv`, para tener la curva de un día de trabajo real.
|
||||||
|
// Columnas del CSV: fecha, procesos, memoria_mb, cpu, pestañas, dormidas, descartadas,
|
||||||
|
// gpu_mb (proceso gráfico) y pestanas_mb (suma de los procesos de pestaña).
|
||||||
|
// 2. ANOTA en `salud.log` lo que falla: pánicos de Rust, procesos de WebView2 caídos o colgados,
|
||||||
|
// errores de JavaScript de las páginas, el hilo principal sin responder y los cierres de golpe
|
||||||
|
// (si al arrancar sigue el testigo `en-marcha`, la sesión anterior no se cerró bien).
|
||||||
|
// 3. SE REPONE: una pestaña cuyo proceso murió o se colgó se recarga sola (con freno: más de 3 en
|
||||||
|
// 10 min y se deja quieta para no entrar en bucle); si muere el proceso principal de WebView2
|
||||||
|
// —se caen TODAS las pestañas— la app se reinicia; Windows la vuelve a abrir si se cuelga o
|
||||||
|
// se cierra de golpe (RegisterApplicationRestart); y con la memoria por encima del umbral se
|
||||||
|
// duermen ya las pestañas ocultas, sin esperar sus 5 minutos.
|
||||||
|
//
|
||||||
|
// Todo queda en la carpeta de logs de la app (%LOCALAPPDATA%\co.labstream.os\logs) y se abre
|
||||||
|
// desde ⋮ ▸ Diagnóstico. No se envía nada a ningún sitio.
|
||||||
|
|
||||||
|
use std::{
|
||||||
|
collections::HashMap,
|
||||||
|
fs,
|
||||||
|
io::Write,
|
||||||
|
path::PathBuf,
|
||||||
|
sync::{
|
||||||
|
atomic::{AtomicBool, AtomicU32, Ordering},
|
||||||
|
Mutex, OnceLock,
|
||||||
|
},
|
||||||
|
time::{Duration, Instant, SystemTime, UNIX_EPOCH},
|
||||||
|
};
|
||||||
|
|
||||||
|
use tauri::{menu::MenuItem, AppHandle, Manager, Runtime};
|
||||||
|
|
||||||
|
const LOG_MAX: u64 = 2 * 1024 * 1024; // salud.log rota a salud.1.log al pasar de 2 MB
|
||||||
|
const CSV_MAX: u64 = 4 * 1024 * 1024;
|
||||||
|
const MUESTRA_CADA: Duration = Duration::from_secs(60);
|
||||||
|
/// Memoria privada del árbol a partir de la cual se duermen ya las pestañas ocultas.
|
||||||
|
pub const MEMORIA_ALTA_MB: u64 = 3 * 1024;
|
||||||
|
const RECARGAS_MAX: usize = 3; // por pestaña…
|
||||||
|
const RECARGAS_VENTANA: Duration = Duration::from_secs(10 * 60); // …en esta ventana
|
||||||
|
|
||||||
|
static DIR: OnceLock<PathBuf> = OnceLock::new();
|
||||||
|
static ESCRITURA: Mutex<()> = Mutex::new(());
|
||||||
|
static ERRORES: AtomicU32 = AtomicU32::new(0);
|
||||||
|
static RECUPERACIONES: AtomicU32 = AtomicU32::new(0);
|
||||||
|
static REINICIANDO: AtomicBool = AtomicBool::new(false);
|
||||||
|
static ULTIMA: Mutex<Option<Muestra>> = Mutex::new(None);
|
||||||
|
static RECARGAS: OnceLock<Mutex<HashMap<String, Vec<Instant>>>> = OnceLock::new();
|
||||||
|
static VISTOS_JS: OnceLock<Mutex<HashMap<String, Instant>>> = OnceLock::new();
|
||||||
|
|
||||||
|
#[derive(Clone, Copy, Default)]
|
||||||
|
pub struct Muestra {
|
||||||
|
pub procesos: u32,
|
||||||
|
pub memoria_mb: u64,
|
||||||
|
pub cpu: f64,
|
||||||
|
}
|
||||||
|
|
||||||
|
pub struct SaludUi<R: Runtime>(pub MenuItem<R>);
|
||||||
|
|
||||||
|
// ── Diario ──
|
||||||
|
|
||||||
|
/// Fecha y hora UTC en ISO 8601, sin dependencias (días civiles de Howard Hinnant).
|
||||||
|
fn ahora_iso() -> String {
|
||||||
|
let s = SystemTime::now().duration_since(UNIX_EPOCH).map(|d| d.as_secs()).unwrap_or(0) as i64;
|
||||||
|
let (dias, resto) = (s.div_euclid(86_400), s.rem_euclid(86_400));
|
||||||
|
let z = dias + 719_468;
|
||||||
|
let era = z.div_euclid(146_097);
|
||||||
|
let doe = z - era * 146_097;
|
||||||
|
let yoe = (doe - doe / 1460 + doe / 36_524 - doe / 146_096) / 365;
|
||||||
|
let doy = doe - (365 * yoe + yoe / 4 - yoe / 100);
|
||||||
|
let mp = (5 * doy + 2) / 153;
|
||||||
|
let d = doy - (153 * mp + 2) / 5 + 1;
|
||||||
|
let m = if mp < 10 { mp + 3 } else { mp - 9 };
|
||||||
|
let y = yoe + era * 400 + if m <= 2 { 1 } else { 0 };
|
||||||
|
format!("{y:04}-{m:02}-{d:02}T{:02}:{:02}:{:02}Z", resto / 3600, resto % 3600 / 60, resto % 60)
|
||||||
|
}
|
||||||
|
|
||||||
|
fn anexar(nombre: &str, max: u64, linea: &str) {
|
||||||
|
let Some(dir) = DIR.get() else { return };
|
||||||
|
let _g = ESCRITURA.lock();
|
||||||
|
let ruta = dir.join(nombre);
|
||||||
|
if fs::metadata(&ruta).map(|m| m.len() > max).unwrap_or(false) {
|
||||||
|
let viejo = dir.join(nombre.replacen('.', ".1.", 1));
|
||||||
|
let _ = fs::remove_file(&viejo);
|
||||||
|
let _ = fs::rename(&ruta, &viejo);
|
||||||
|
}
|
||||||
|
if let Ok(mut f) = fs::OpenOptions::new().create(true).append(true).open(&ruta) {
|
||||||
|
let _ = writeln!(f, "{linea}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Anota una línea en salud.log. `nivel`: INFO, AVISO o ERROR.
|
||||||
|
pub fn anotar(nivel: &str, origen: &str, msg: &str) {
|
||||||
|
if nivel == "ERROR" {
|
||||||
|
ERRORES.fetch_add(1, Ordering::Relaxed);
|
||||||
|
}
|
||||||
|
let msg = msg.replace(['\r', '\n'], " ");
|
||||||
|
anexar("salud.log", LOG_MAX, &format!("{} {nivel:<5} {origen}: {msg}", ahora_iso()));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Error de JavaScript de una pestaña. El mismo mensaje no se repite más de una vez por minuto.
|
||||||
|
pub fn error_js(label: &str, tipo: &str, msg: &str, src: &str, ruta: &str) {
|
||||||
|
let clave = format!("{tipo}|{msg}|{src}");
|
||||||
|
{
|
||||||
|
let mut v = VISTOS_JS.get_or_init(Default::default).lock().unwrap();
|
||||||
|
if v.get(&clave).map(|t| t.elapsed() < Duration::from_secs(60)).unwrap_or(false) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if v.len() > 500 {
|
||||||
|
v.clear();
|
||||||
|
}
|
||||||
|
v.insert(clave, Instant::now());
|
||||||
|
}
|
||||||
|
anotar("ERROR", &format!("js {label}"), &format!("{tipo} en {ruta}: {msg} [{src}]"));
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn carpeta() -> Option<PathBuf> {
|
||||||
|
DIR.get().cloned()
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Texto para la bandeja y el menú ⋮.
|
||||||
|
pub fn resumen() -> String {
|
||||||
|
if cfg!(not(windows)) {
|
||||||
|
return "Recursos: la medición es solo de Windows".into();
|
||||||
|
}
|
||||||
|
let Some(m) = *ULTIMA.lock().unwrap() else { return "Recursos: midiendo…".into() };
|
||||||
|
let mem = if m.memoria_mb >= 1024 { format!("{:.1} GB", m.memoria_mb as f64 / 1024.0).replace('.', ",") } else { format!("{} MB", m.memoria_mb) };
|
||||||
|
let mut s = format!("Recursos: {mem} · CPU {:.0} % · {} procesos", m.cpu, m.procesos);
|
||||||
|
let (e, r) = (ERRORES.load(Ordering::Relaxed), RECUPERACIONES.load(Ordering::Relaxed));
|
||||||
|
if e > 0 || r > 0 {
|
||||||
|
s.push_str(&format!(" · {e} errores, {r} recuperadas"));
|
||||||
|
}
|
||||||
|
s
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── Arranque y salida ──
|
||||||
|
|
||||||
|
/// Prepara la carpeta, el registro de pánicos, el testigo de cierre limpio y el reinicio automático.
|
||||||
|
/// Va lo PRIMERO en setup: así un fallo del propio arranque ya queda anotado.
|
||||||
|
pub fn preparar<R: Runtime>(app: &AppHandle<R>) {
|
||||||
|
let dir = app
|
||||||
|
.path()
|
||||||
|
.app_log_dir()
|
||||||
|
.or_else(|_| app.path().app_local_data_dir().map(|d| d.join("logs")))
|
||||||
|
.unwrap_or_else(|_| std::env::temp_dir().join("labstream-os-logs"));
|
||||||
|
let _ = fs::create_dir_all(&dir);
|
||||||
|
let _ = DIR.set(dir.clone());
|
||||||
|
|
||||||
|
let anterior = std::panic::take_hook();
|
||||||
|
std::panic::set_hook(Box::new(move |info| {
|
||||||
|
let donde = info.location().map(|l| format!("{}:{}", l.file(), l.line())).unwrap_or_default();
|
||||||
|
let que = info
|
||||||
|
.payload()
|
||||||
|
.downcast_ref::<&str>()
|
||||||
|
.map(|s| s.to_string())
|
||||||
|
.or_else(|| info.payload().downcast_ref::<String>().cloned())
|
||||||
|
.unwrap_or_default();
|
||||||
|
anotar("ERROR", "panico", &format!("{que} ({donde}) hilo={}", std::thread::current().name().unwrap_or("?")));
|
||||||
|
anterior(info);
|
||||||
|
}));
|
||||||
|
|
||||||
|
let testigo = dir.join("en-marcha");
|
||||||
|
if testigo.exists() {
|
||||||
|
anotar("ERROR", "app", "la sesión anterior terminó de golpe (cierre forzado, cuelgue, apagón o fallo)");
|
||||||
|
}
|
||||||
|
let _ = fs::write(&testigo, std::process::id().to_string());
|
||||||
|
anotar("INFO", "app", &format!("inicio v{} pid {}", app.package_info().version, std::process::id()));
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
unsafe {
|
||||||
|
// Si la app se cuelga o se cae, Windows la vuelve a abrir (solo si llevaba ≥60 s en marcha,
|
||||||
|
// así que un fallo en el arranque no entra en bucle). Al reiniciar el equipo no: de eso ya
|
||||||
|
// se encarga el arranque automático.
|
||||||
|
use windows::Win32::System::Recovery::{RegisterApplicationRestart, RESTART_NO_REBOOT};
|
||||||
|
if RegisterApplicationRestart(windows::core::PCWSTR::null(), RESTART_NO_REBOOT).is_err() {
|
||||||
|
anotar("AVISO", "app", "no se pudo registrar el reinicio automático de Windows");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Salida limpia: borra el testigo (si no se borra, el próximo arranque anota un cierre de golpe).
|
||||||
|
pub fn salida_limpia() {
|
||||||
|
if REINICIANDO.load(Ordering::Relaxed) {
|
||||||
|
anotar("INFO", "app", "reinicio para recuperarse");
|
||||||
|
} else {
|
||||||
|
anotar("INFO", "app", "salida");
|
||||||
|
}
|
||||||
|
if let Some(d) = DIR.get() {
|
||||||
|
let _ = fs::remove_file(d.join("en-marcha"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Justo antes de que el instalador de una actualización cierre la app (en Windows lo hace él, sin
|
||||||
|
/// pasar por la salida normal): se anota y se quita el testigo, para no contarlo como cierre de golpe.
|
||||||
|
pub fn antes_de_actualizar(version: &str) {
|
||||||
|
anotar("INFO", "actualizacion", &format!("se instala la versión {version}"));
|
||||||
|
if let Some(d) = DIR.get() {
|
||||||
|
let _ = fs::remove_file(d.join("en-marcha"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Hilo de medición y vigilante del hilo principal. `memoria_alta` se llama (como mucho cada 10
|
||||||
|
/// min) cuando el árbol pasa de MEMORIA_ALTA_MB: lib.rs duerme ahí las pestañas ocultas.
|
||||||
|
pub fn iniciar<R: Runtime>(app: &AppHandle<R>, item: MenuItem<R>, memoria_alta: impl Fn(&AppHandle<R>) + Send + 'static) {
|
||||||
|
app.manage(SaludUi(item));
|
||||||
|
let h = app.clone();
|
||||||
|
std::thread::Builder::new()
|
||||||
|
.name("salud-recursos".into())
|
||||||
|
.spawn(move || {
|
||||||
|
// El medidor de audio (memoria.rs → tracker::hay_audio_sonando) usa COM en este hilo.
|
||||||
|
#[cfg(windows)]
|
||||||
|
unsafe {
|
||||||
|
use windows::Win32::System::Com::{CoInitializeEx, COINIT_MULTITHREADED};
|
||||||
|
let _ = CoInitializeEx(None, COINIT_MULTITHREADED);
|
||||||
|
}
|
||||||
|
let mut medidor = Medidor::default();
|
||||||
|
let mut ultimo_aviso: Option<Instant> = None;
|
||||||
|
let mut pico = 0u64;
|
||||||
|
loop {
|
||||||
|
std::thread::sleep(MUESTRA_CADA);
|
||||||
|
// Primero la memoria (memoria.rs): niveles de las vistas y, si toca, reciclar el
|
||||||
|
// proceso gráfico. Luego se mide, para que la muestra ya refleje lo liberado.
|
||||||
|
crate::memoria::ajustar_niveles(&h);
|
||||||
|
let reparto = crate::memoria::ronda(&h);
|
||||||
|
let Some(m) = medidor.medir() else { continue };
|
||||||
|
*ULTIMA.lock().unwrap() = Some(m);
|
||||||
|
let (pestanas, dormidas, descartadas) = conteo_pestanas(&h);
|
||||||
|
anexar(
|
||||||
|
"recursos.csv",
|
||||||
|
CSV_MAX,
|
||||||
|
&format!(
|
||||||
|
"{},{},{},{:.1},{},{},{},{},{}",
|
||||||
|
ahora_iso(), m.procesos, m.memoria_mb, m.cpu, pestanas, dormidas, descartadas, reparto.gpu_mb, reparto.pestanas_mb
|
||||||
|
),
|
||||||
|
);
|
||||||
|
if m.memoria_mb > pico + 256 && m.memoria_mb > 1024 {
|
||||||
|
pico = m.memoria_mb;
|
||||||
|
anotar("INFO", "recursos", &format!("nuevo pico de memoria: {} MB en {} procesos ({pestanas} pestañas)", m.memoria_mb, m.procesos));
|
||||||
|
}
|
||||||
|
if m.memoria_mb >= MEMORIA_ALTA_MB && ultimo_aviso.map(|t| t.elapsed() > Duration::from_secs(600)).unwrap_or(true) {
|
||||||
|
ultimo_aviso = Some(Instant::now());
|
||||||
|
anotar("AVISO", "recursos", &format!("memoria alta ({} MB): se duermen ya las pestañas ocultas", m.memoria_mb));
|
||||||
|
memoria_alta(&h);
|
||||||
|
}
|
||||||
|
// set_text despacha al hilo principal y espera: aquí, en un hilo propio, es seguro.
|
||||||
|
let _ = h.state::<SaludUi<R>>().0.set_text(resumen());
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.ok();
|
||||||
|
|
||||||
|
// ¿Responde el hilo principal? Un cuelgue de la interfaz (la ventana «No responde») no deja
|
||||||
|
// ningún otro rastro. Se le manda una tarea vacía cada 20 s; si tarda más de 15 s, se anota
|
||||||
|
// cuándo empezó y cuánto duró.
|
||||||
|
let h = app.clone();
|
||||||
|
std::thread::Builder::new()
|
||||||
|
.name("salud-vigilante".into())
|
||||||
|
.spawn(move || loop {
|
||||||
|
std::thread::sleep(Duration::from_secs(20));
|
||||||
|
let (tx, rx) = std::sync::mpsc::channel();
|
||||||
|
let t0 = Instant::now();
|
||||||
|
if h.run_on_main_thread(move || {
|
||||||
|
let _ = tx.send(());
|
||||||
|
})
|
||||||
|
.is_err()
|
||||||
|
{
|
||||||
|
return; // la app está cerrándose
|
||||||
|
}
|
||||||
|
if rx.recv_timeout(Duration::from_secs(15)).is_err() {
|
||||||
|
anotar("ERROR", "app", "el hilo principal no responde (la ventana se congeló)");
|
||||||
|
let _ = rx.recv();
|
||||||
|
anotar("AVISO", "app", &format!("el hilo principal volvió a responder tras {} s", t0.elapsed().as_secs()));
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.ok();
|
||||||
|
}
|
||||||
|
|
||||||
|
fn conteo_pestanas<R: Runtime>(app: &AppHandle<R>) -> (usize, usize, usize) {
|
||||||
|
let shell = app.state::<crate::ShellState>();
|
||||||
|
let s = shell.lock().unwrap();
|
||||||
|
(s.tabs.len(), s.tabs.iter().filter(|t| t.dormida).count(), s.tabs.iter().filter(|t| t.descartada).count())
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Memoria privada de un proceso, en MB (0 si no se puede abrir).
|
||||||
|
#[cfg(windows)]
|
||||||
|
pub fn memoria_privada_mb(pid: u32) -> u64 {
|
||||||
|
use windows::Win32::{
|
||||||
|
Foundation::CloseHandle,
|
||||||
|
System::{
|
||||||
|
ProcessStatus::{GetProcessMemoryInfo, PROCESS_MEMORY_COUNTERS, PROCESS_MEMORY_COUNTERS_EX},
|
||||||
|
Threading::{OpenProcess, PROCESS_QUERY_LIMITED_INFORMATION},
|
||||||
|
},
|
||||||
|
};
|
||||||
|
unsafe {
|
||||||
|
let Ok(hp) = OpenProcess(PROCESS_QUERY_LIMITED_INFORMATION, false, pid) else { return 0 };
|
||||||
|
let mut mc = PROCESS_MEMORY_COUNTERS_EX { cb: std::mem::size_of::<PROCESS_MEMORY_COUNTERS_EX>() as u32, ..Default::default() };
|
||||||
|
let ok = GetProcessMemoryInfo(hp, &mut mc as *mut _ as *mut PROCESS_MEMORY_COUNTERS, mc.cb).is_ok();
|
||||||
|
let _ = CloseHandle(hp);
|
||||||
|
if ok {
|
||||||
|
mc.PrivateUsage as u64 / (1024 * 1024)
|
||||||
|
} else {
|
||||||
|
0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// ── Recuperación de pestañas (WebView2) ──
|
||||||
|
|
||||||
|
#[cfg_attr(not(windows), allow(dead_code))] // en macOS no hay ProcessFailed: solo lo usa Windows
|
||||||
|
/// ¿Se puede recargar otra vez esta pestaña? Freno contra bucles: RECARGAS_MAX en RECARGAS_VENTANA.
|
||||||
|
fn permitir_recarga(label: &str) -> bool {
|
||||||
|
let mut m = RECARGAS.get_or_init(Default::default).lock().unwrap();
|
||||||
|
let v = m.entry(label.to_string()).or_default();
|
||||||
|
v.retain(|t| t.elapsed() < RECARGAS_VENTANA);
|
||||||
|
if v.len() >= RECARGAS_MAX {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
v.push(Instant::now());
|
||||||
|
true
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Se engancha al aviso `ProcessFailed` de WebView2 de una pestaña recién creada.
|
||||||
|
#[cfg(windows)]
|
||||||
|
pub fn vigilar_pestana<R: Runtime>(app: &AppHandle<R>, wv: &tauri::Webview<R>) {
|
||||||
|
let label = wv.label().to_string();
|
||||||
|
let h = app.clone();
|
||||||
|
let _ = wv.with_webview(move |pw| unsafe {
|
||||||
|
use webview2_com::{Microsoft::Web::WebView2::Win32::*, ProcessFailedEventHandler};
|
||||||
|
let Ok(core) = pw.controller().CoreWebView2() else { return };
|
||||||
|
let mut token = 0i64;
|
||||||
|
let handler = ProcessFailedEventHandler::create(Box::new(move |sender, args| {
|
||||||
|
let mut kind = COREWEBVIEW2_PROCESS_FAILED_KIND::default();
|
||||||
|
if let Some(a) = args {
|
||||||
|
let _ = a.ProcessFailedKind(&mut kind);
|
||||||
|
}
|
||||||
|
let recargar = |por: &str| {
|
||||||
|
if !permitir_recarga(&label) {
|
||||||
|
anotar("ERROR", &format!("pestaña {label}"), &format!("{por} otra vez: ya se recargó {RECARGAS_MAX} veces en 10 min, se deja quieta"));
|
||||||
|
crate::aviso_pestana_rota(&h, &label);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if let Some(c) = &sender {
|
||||||
|
if c.Reload().is_ok() {
|
||||||
|
RECUPERACIONES.fetch_add(1, Ordering::Relaxed);
|
||||||
|
anotar("AVISO", &format!("pestaña {label}"), &format!("{por}: recargada sola"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
match kind {
|
||||||
|
COREWEBVIEW2_PROCESS_FAILED_KIND_RENDER_PROCESS_EXITED => {
|
||||||
|
anotar("ERROR", &format!("pestaña {label}"), "su proceso se cerró (pestaña en blanco)");
|
||||||
|
recargar("proceso cerrado");
|
||||||
|
}
|
||||||
|
COREWEBVIEW2_PROCESS_FAILED_KIND_RENDER_PROCESS_UNRESPONSIVE => {
|
||||||
|
anotar("ERROR", &format!("pestaña {label}"), "su proceso dejó de responder");
|
||||||
|
recargar("proceso colgado");
|
||||||
|
}
|
||||||
|
COREWEBVIEW2_PROCESS_FAILED_KIND_BROWSER_PROCESS_EXITED => {
|
||||||
|
// Lo avisan TODAS las pestañas a la vez: solo la primera reinicia.
|
||||||
|
if !REINICIANDO.swap(true, Ordering::SeqCst) {
|
||||||
|
anotar("ERROR", "webview2", "se cerró el proceso principal de WebView2: se reinicia la app");
|
||||||
|
RECUPERACIONES.fetch_add(1, Ordering::Relaxed);
|
||||||
|
crate::save_persisted(&h);
|
||||||
|
let hh = h.clone();
|
||||||
|
// Desde un hilo aparte, restart() pide la salida al bucle de eventos: pasa por
|
||||||
|
// RunEvent::Exit (salida_limpia anota el reinicio y quita el testigo) y el
|
||||||
|
// plugin de instancia única suelta su mutex ANTES de lanzar la copia nueva.
|
||||||
|
std::thread::spawn(move || {
|
||||||
|
std::thread::sleep(Duration::from_millis(500));
|
||||||
|
hh.restart();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
COREWEBVIEW2_PROCESS_FAILED_KIND_FRAME_RENDER_PROCESS_EXITED => {
|
||||||
|
anotar("AVISO", &format!("pestaña {label}"), "se cerró el proceso de un marco interno (p. ej. un editor incrustado)");
|
||||||
|
}
|
||||||
|
COREWEBVIEW2_PROCESS_FAILED_KIND_GPU_PROCESS_EXITED => {
|
||||||
|
anotar("AVISO", "webview2", "se reinició el proceso de gráficos (WebView2 lo levanta solo)");
|
||||||
|
}
|
||||||
|
otro => anotar("AVISO", "webview2", &format!("se cerró un proceso auxiliar (tipo {})", otro.0)),
|
||||||
|
}
|
||||||
|
Ok(())
|
||||||
|
}));
|
||||||
|
if core.add_ProcessFailed(&handler, &mut token).is_err() {
|
||||||
|
anotar("AVISO", "webview2", "no se pudo vigilar una pestaña");
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
pub fn vigilar_pestana<R: Runtime>(_app: &AppHandle<R>, _wv: &tauri::Webview<R>) {}
|
||||||
|
|
||||||
|
// ── Medición del árbol de procesos ──
|
||||||
|
|
||||||
|
#[derive(Default)]
|
||||||
|
struct Medidor {
|
||||||
|
cpu_previa: HashMap<u32, u64>, // pid → tiempo de CPU acumulado (100 ns)
|
||||||
|
cuando: Option<Instant>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
impl Medidor {
|
||||||
|
fn medir(&mut self) -> Option<Muestra> {
|
||||||
|
use windows::Win32::{
|
||||||
|
Foundation::{CloseHandle, FILETIME},
|
||||||
|
System::{
|
||||||
|
Diagnostics::ToolHelp::{CreateToolhelp32Snapshot, Process32FirstW, Process32NextW, PROCESSENTRY32W, TH32CS_SNAPPROCESS},
|
||||||
|
ProcessStatus::{GetProcessMemoryInfo, PROCESS_MEMORY_COUNTERS, PROCESS_MEMORY_COUNTERS_EX},
|
||||||
|
Threading::{GetProcessTimes, OpenProcess, PROCESS_QUERY_LIMITED_INFORMATION},
|
||||||
|
},
|
||||||
|
};
|
||||||
|
unsafe {
|
||||||
|
// 1. Todos los procesos con su padre; 2. el árbol que cuelga de este exe.
|
||||||
|
let snap = CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0).ok()?;
|
||||||
|
let mut padres: Vec<(u32, u32)> = Vec::with_capacity(512);
|
||||||
|
let mut e = PROCESSENTRY32W { dwSize: std::mem::size_of::<PROCESSENTRY32W>() as u32, ..Default::default() };
|
||||||
|
if Process32FirstW(snap, &mut e).is_ok() {
|
||||||
|
loop {
|
||||||
|
padres.push((e.th32ProcessID, e.th32ParentProcessID));
|
||||||
|
if Process32NextW(snap, &mut e).is_err() {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
let _ = CloseHandle(snap);
|
||||||
|
let mut arbol = vec![std::process::id()];
|
||||||
|
let mut i = 0;
|
||||||
|
while i < arbol.len() {
|
||||||
|
let p = arbol[i];
|
||||||
|
for &(hijo, padre) in &padres {
|
||||||
|
if padre == p && hijo != p && !arbol.contains(&hijo) {
|
||||||
|
arbol.push(hijo);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
i += 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
let mut memoria = 0u64;
|
||||||
|
let mut cpu_ahora: HashMap<u32, u64> = HashMap::new();
|
||||||
|
for &pid in &arbol {
|
||||||
|
let Ok(hp) = OpenProcess(PROCESS_QUERY_LIMITED_INFORMATION, false, pid) else { continue };
|
||||||
|
let mut mc = PROCESS_MEMORY_COUNTERS_EX { cb: std::mem::size_of::<PROCESS_MEMORY_COUNTERS_EX>() as u32, ..Default::default() };
|
||||||
|
if GetProcessMemoryInfo(hp, &mut mc as *mut _ as *mut PROCESS_MEMORY_COUNTERS, mc.cb).is_ok() {
|
||||||
|
memoria += mc.PrivateUsage as u64;
|
||||||
|
}
|
||||||
|
let (mut c, mut x, mut k, mut u) = (FILETIME::default(), FILETIME::default(), FILETIME::default(), FILETIME::default());
|
||||||
|
if GetProcessTimes(hp, &mut c, &mut x, &mut k, &mut u).is_ok() {
|
||||||
|
let t = |f: FILETIME| ((f.dwHighDateTime as u64) << 32) | f.dwLowDateTime as u64;
|
||||||
|
cpu_ahora.insert(pid, t(k) + t(u));
|
||||||
|
}
|
||||||
|
let _ = CloseHandle(hp);
|
||||||
|
}
|
||||||
|
|
||||||
|
// CPU: lo gastado desde la muestra anterior, sobre el tiempo de reloj × núcleos (como
|
||||||
|
// la columna CPU del Administrador de tareas). Un proceso que no estaba en la muestra
|
||||||
|
// anterior empieza a contar en la siguiente (si no, sumaría toda su vida de golpe).
|
||||||
|
let ahora = Instant::now();
|
||||||
|
let cpu = match self.cuando {
|
||||||
|
Some(antes) => {
|
||||||
|
let pared = ahora.duration_since(antes).as_secs_f64() * 1e7; // en 100 ns
|
||||||
|
let nucleos = std::thread::available_parallelism().map(|n| n.get()).unwrap_or(1) as f64;
|
||||||
|
let gastado: u64 = cpu_ahora.iter().filter_map(|(p, t)| self.cpu_previa.get(p).map(|antes| t.saturating_sub(*antes))).sum();
|
||||||
|
(gastado as f64 / (pared * nucleos) * 100.0).clamp(0.0, 100.0)
|
||||||
|
}
|
||||||
|
None => 0.0,
|
||||||
|
};
|
||||||
|
self.cpu_previa = cpu_ahora;
|
||||||
|
self.cuando = Some(ahora);
|
||||||
|
Some(Muestra { procesos: arbol.len() as u32, memoria_mb: memoria / (1024 * 1024), cpu })
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(not(windows))]
|
||||||
|
impl Medidor {
|
||||||
|
fn medir(&mut self) -> Option<Muestra> {
|
||||||
|
None // macOS: pendiente (proc_pidinfo); el equipo de edición es Windows
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(test)]
|
||||||
|
mod tests {
|
||||||
|
use super::*;
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn fecha_iso_con_formato_fijo() {
|
||||||
|
let f = ahora_iso();
|
||||||
|
assert_eq!(f.len(), 20, "{f}");
|
||||||
|
assert!(f.starts_with("20") && f.ends_with('Z') && &f[10..11] == "T", "{f}");
|
||||||
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn el_freno_corta_la_cuarta_recarga() {
|
||||||
|
let l = "tab-prueba-freno";
|
||||||
|
assert!(permitir_recarga(l));
|
||||||
|
assert!(permitir_recarga(l));
|
||||||
|
assert!(permitir_recarga(l));
|
||||||
|
assert!(!permitir_recarga(l), "la cuarta en 10 minutos no se permite");
|
||||||
|
assert!(permitir_recarga("otra-pestana"), "el freno es por pestaña");
|
||||||
|
}
|
||||||
|
|
||||||
|
#[cfg(windows)]
|
||||||
|
#[test]
|
||||||
|
fn mide_al_menos_este_proceso() {
|
||||||
|
// un binario de prueba casi no reserva memoria: se le da 32 MB tocados para que se note
|
||||||
|
let lastre = vec![1u8; 32 * 1024 * 1024];
|
||||||
|
let mut m = Medidor::default();
|
||||||
|
let a = m.medir().expect("primera muestra");
|
||||||
|
assert!(a.procesos >= 1 && a.memoria_mb > 0, "procesos={} memoria={}", a.procesos, a.memoria_mb);
|
||||||
|
assert_eq!(a.cpu, 0.0, "sin muestra previa no hay CPU");
|
||||||
|
std::thread::sleep(Duration::from_millis(200));
|
||||||
|
let b = m.medir().expect("segunda muestra");
|
||||||
|
assert!((0.0..=100.0).contains(&b.cpu));
|
||||||
|
assert!(lastre.iter().all(|&x| x == 1));
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -279,7 +279,7 @@ fn es_navegador(app: &str) -> bool {
|
|||||||
// si hay sonido saliendo AHORA. Un video mudo no se detecta (no suena); es el límite honesto de
|
// si hay sonido saliendo AHORA. Un video mudo no se detecta (no suena); es el límite honesto de
|
||||||
// medirlo desde fuera del navegador.
|
// medirlo desde fuera del navegador.
|
||||||
#[cfg(windows)]
|
#[cfg(windows)]
|
||||||
fn hay_audio_sonando() -> bool {
|
pub(crate) fn hay_audio_sonando() -> bool {
|
||||||
use windows::Win32::Media::Audio::Endpoints::IAudioMeterInformation;
|
use windows::Win32::Media::Audio::Endpoints::IAudioMeterInformation;
|
||||||
use windows::Win32::Media::Audio::{eMultimedia, eRender, IMMDeviceEnumerator, MMDeviceEnumerator};
|
use windows::Win32::Media::Audio::{eMultimedia, eRender, IMMDeviceEnumerator, MMDeviceEnumerator};
|
||||||
use windows::Win32::System::Com::{CoCreateInstance, CLSCTX_ALL};
|
use windows::Win32::System::Com::{CoCreateInstance, CLSCTX_ALL};
|
||||||
@@ -300,7 +300,7 @@ fn hay_audio_sonando() -> bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[cfg(not(windows))]
|
#[cfg(not(windows))]
|
||||||
fn hay_audio_sonando() -> bool {
|
pub(crate) fn hay_audio_sonando() -> bool {
|
||||||
// macOS: no hay API pública sencilla de nivel de audio; la excepción del video no aplica aquí
|
// macOS: no hay API pública sencilla de nivel de audio; la excepción del video no aplica aquí
|
||||||
// (el equipo de edición es Windows). Follow-up posible con CoreAudio. false = como siempre.
|
// (el equipo de edición es Windows). Follow-up posible con CoreAudio. false = como siempre.
|
||||||
false
|
false
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
{
|
{
|
||||||
"$schema": "https://schema.tauri.app/config/2",
|
"$schema": "https://schema.tauri.app/config/2",
|
||||||
"productName": "Labstream OS",
|
"productName": "Labstream OS",
|
||||||
"version": "1.17.0",
|
"version": "1.21.0",
|
||||||
"identifier": "co.labstream.os",
|
"identifier": "co.labstream.os",
|
||||||
"build": {
|
"build": {
|
||||||
"frontendDist": "../dist"
|
"frontendDist": "../dist"
|
||||||
|
|||||||
Referencia en una nueva incidencia
Block a user