jjminguez/biblioteca_conocimiento_laboratorio
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

03-sep: [comando] /descargar ver progreso de descargas + listar_descargas en nas_dl

Browse Source
This commit is contained in:
juanjo
2026-09-03 23:38:23 +02:00
parent 9e067f4e4d
commit 07f4f89a22
2 changed files with 109 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
vigilancia/nas_dl.py
View File

@@ -139,6 +139,70 @@ def add_torrent(uri, session=None):
return False
def human_size(n):
"""Formatea bytes a una unidad legible."""
n = float(n or 0)
for u in ("B", "KB", "MB", "GB", "TB"):
if n < 1024:
return f"{n:.1f}{u}"
n /= 1024
return f"{n:.1f}PB"
def listar_descargas(hablar_solo_activas=True, session=None):
"""Devuelve (lineas_texto, activas). Lista las tareas de Download Station
con estado, porcentaje de progreso, tamaño descargado y velocidad.
`progress` se calcula con downloaded_pieces/total_pieces (fiable en NAS)."""
if not session:
session = login()
if not session:
return ["❌ No se pudo autenticar con Download Station."], []
try:
r = _api("/webapi/DownloadStation/task.cgi", {
"api": "SYNO.DownloadStation.Task",
"version": "3",
"method": "list",
"additional": "detail,transfer",
}, session=session)
if not r.get("success"):
return [f"❌ Error al listar: {r.get('error')}"], []
except Exception as e:
return [f"❌ Error al consultar el NAS: {e}"], []
tareas = r.get("data", {}).get("tasks", []) or []
lineas, activas, resto = [], [], []
for t in tareas:
titulo = t.get("title") or ""
estado = t.get("status") or "?"
detail = (t.get("additional") or {}).get("detail") or {}
transfer = (t.get("additional") or {}).get("transfer") or {}
total_pieces = detail.get("total_pieces") or 0
done_pieces = transfer.get("downloaded_pieces") or 0
pct = (done_pieces * 100.0 / total_pieces) if total_pieces else 0
size = transfer.get("size_downloaded") or 0
speed = transfer.get("speed_download") or 0
if estado == "downloading":
activas.append(f"▶️ <b>{pct:.1f}%</b> {human_size(size)} ⬇️{speed // 1024} KB/s\n"
f" {titulo}")
else:
resto.append((estado, pct, size, titulo))
if activas:
lineas.append("📥 <b>DESCARGANDO</b>")
lineas.extend(activas)
lineas.append("")
if not hablar_solo_activas:
lineas.append("📁 Otras tareas:")
for estado, pct, size, titulo in resto:
icono = {"finished": "✅", "error": "❌", "paused": "⏸️",
"seeding": "🌱"}.get(estado, "•")
if estado == "finished":
lineas.append(f"{icono} {titulo}")
else:
lineas.append(f"{icono} {estado} ({pct:.0f}%) — {titulo}")
if not activas:
lineas.append("No hay torrents descargándose ahora mismo.")
return lineas, activas
if __name__ == "__main__":
import sys
if len(sys.argv) < 2:

33
vigilancia/pi_bot.py
View File

@@ -80,10 +80,13 @@ def estado():
def enviar(texto, chat_id):
# Trocea mensajes largos (Telegram limita a ~4096 chars) para no fallar en silencio
for i in range(0, len(texto), 4000):
bloque = texto[i:i + 4000]
try:
r = requests.post(
f"https://api.telegram.org/bot{TOKEN}/sendMessage",
data={"chat_id": chat_id, "text": texto, "parse_mode": "HTML"},
data={"chat_id": chat_id, "text": bloque, "parse_mode": "HTML"},
timeout=10,
)
d = r.json()
@@ -204,6 +207,10 @@ def procesar(texto, chat_id):
else:
ok = mandar_youtube(url)
enviar("🎬 YouTube lanzado en la TV ✅" if ok else "❌ No se pudo lanzar YouTube", chat_id)
elif t in ("descargar", "/descargar"):
import nas_dl
lineas, _act = nas_dl.listar_descargas(hablar_solo_activas=True)
enviar("\n".join(lineas), chat_id)
elif t.startswith("descargar ") or t.startswith("/descargar "):
uri = texto.split(" ", 1)[1].strip()
if not uri:
@@ -254,29 +261,31 @@ def procesar(texto, chat_id):
"<b>7.</b> <code>novedades</code> — últimas novedades del catálogo\n"
" ✏️ Ej: <code>/novedades</code>\n\n"
"━━━ 🖥️ NAS / DESCARGAS ━━━\n"
"<b>8.</b> <code>descargar &lt;enlace&gt;</code> — añade a Download Station\n"
"<b>8.</b> <code>descargar</code> — torrents descargándose y su progreso\n"
" ✏️ Ej: <code>/descargar</code>\n"
"<b>9.</b> <code>descargar &lt;enlace&gt;</code> — añade a Download Station\n"
" ✏️ Ej: <code>/descargar magnet:?xt=urn:btih:...</code>\n\n"
"━━━ 📺 TV ━━━\n"
"<b>9.</b> <code>tv &lt;mensaje&gt;</code> — mensaje rápido a la tele\n"
"<b>10.</b> <code>tv &lt;mensaje&gt;</code> — mensaje rápido a la tele\n"
" ✏️ Ej: <code>/tv la cena está lista</code>\n"
"<b>10.</b> <code>alarma &lt;mensaje&gt;</code> — secuencia completa (sirena x3)\n"
"<b>11.</b> <code>alarma &lt;mensaje&gt;</code> — secuencia completa (sirena x3)\n"
" ✏️ Ej: <code>/alarma vienen a por vosotros</code>\n"
"<b>11.</b> <code>youtube &lt;URL&gt;</code> — reproduce YouTube en la TV\n"
"<b>12.</b> <code>youtube &lt;URL&gt;</code> — reproduce YouTube en la TV\n"
" ✏️ Ej: <code>/youtube https://youtu.be/xxxx</code>\n\n"
"━━━ 🛠️ SISTEMA ━━━\n"
"<b>12.</b> <code>estado</code> — estado de la Pi\n"
"<b>13.</b> <code>estado</code> — estado de la Pi\n"
" ✏️ Ej: <code>/estado</code>\n"
"<b>13.</b> <code>temperatura</code> — temperatura de la Pi\n"
"<b>14.</b> <code>temperatura</code> — temperatura de la Pi\n"
" ✏️ Ej: <code>/temperatura</code>\n"
"<b>14.</b> <code>panorama</code> — fotos de las cámaras\n"
"<b>15.</b> <code>panorama</code> — fotos de las cámaras\n"
" ✏️ Ej: <code>/panorama</code>\n"
"<b>15.</b> <code>limpieza</code> — limpia procesos atascados\n"
"<b>16.</b> <code>limpieza</code> — limpia procesos atascados\n"
" ✏️ Ej: <code>/limpieza</code>\n"
"<b>16.</b> <code>servicios</code> — estado de los servicios\n"
"<b>17.</b> <code>servicios</code> — estado de los servicios\n"
" ✏️ Ej: <code>/servicios</code>\n"
"<b>17.</b> <code>reboot</code> — reinicia la Pi\n"
"<b>18.</b> <code>reboot</code> — reinicia la Pi\n"
" ✏️ Ej: <code>/reboot</code> → confirmar con <code>/confirmar-reboot</code>\n"
"<b>18.</b> <code>ayuda</code> — este índice\n"
"<b>19.</b> <code>ayuda</code> — este índice\n"
" ✏️ Ej: <code>/ayuda</code>",
chat_id)
elif t in ("servicios", "/servicios"):