add ASIR1 (Programación) support: nginx, watchers, scripts
- New subdomain asir1.qu3v3d0.tech (nginx server block for napi2) - python-upload-watcher.sh v7: batching, re-uploads, Windows-safe, __pycache__ filtering, full student names in XMPP notifications - sshfs mount units for both napi-data and napi-data2 - nginx configs for DDAW2 and ASIR1 preserved as reference - Screenshot of XMPP notifications for debugging Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
parent
14949a3775
commit
aa3126cdb6
|
|
@ -1 +1,4 @@
|
||||||
data
|
data/
|
||||||
|
TASKS.org
|
||||||
|
BUGS.org
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1 @@
|
||||||
|
.
|
||||||
Binary file not shown.
|
After Width: | Height: | Size: 201 KiB |
|
|
@ -0,0 +1,51 @@
|
||||||
|
# 🌐 Configuraciones Nginx — napi
|
||||||
|
|
||||||
|
Copia de referencia de los server blocks desplegados en **zzz** (`qu3v3d0.tech`).
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 📋 Sites activos
|
||||||
|
|
||||||
|
| Fichero | server_name | Root | Grupo |
|
||||||
|
|:--------|:------------|:-----|:------|
|
||||||
|
| **`napi-ddaw2.conf`** | `notas.qu3v3d0.tech` | `/var/www/napi` | DDAW2 (19 alumnos) |
|
||||||
|
| **`napi2-asir1.conf`** | `asir1.qu3v3d0.tech` | `/var/www/napi2` | ASIR1 Programación (21 alumnos) |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🔑 Funcionamiento común
|
||||||
|
|
||||||
|
Ambos sites comparten la misma arquitectura:
|
||||||
|
|
||||||
|
1. **Auth PAM** (`libnginx-mod-http-auth-pam`) — credenciales SFTP del alumno
|
||||||
|
2. **`$remote_user`** — Nginx usa el usuario autenticado para servir su `notas.md`
|
||||||
|
3. **`viewer.html`** — App estática que hace `fetch('/notas.md')` y renderiza con `marked.js` + `twemoji`
|
||||||
|
4. **SSL wildcard** — `*.qu3v3d0.tech` (certificado en `/etc/ssl/certs/qu3v3d0.tech.crt`)
|
||||||
|
|
||||||
|
```
|
||||||
|
Alumno → https://asir1.qu3v3d0.tech → Auth PAM → viewer.html
|
||||||
|
→ fetch('/notas.md') → Nginx alias → /var/www/napi2/data/$remote_user/notas.md
|
||||||
|
→ marked.js renderiza → alumno ve su feedback
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🛠️ Gestión en zzz
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Ver configs activos
|
||||||
|
ls -la /etc/nginx/sites-enabled/
|
||||||
|
|
||||||
|
# Editar
|
||||||
|
sudo nano /etc/nginx/sites-available/napi2
|
||||||
|
|
||||||
|
# Test + reload
|
||||||
|
sudo nginx -t && sudo systemctl reload nginx
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 📅 DNS
|
||||||
|
|
||||||
|
DNS wildcard `*.qu3v3d0.tech` → `161.22.44.104` (zzz).
|
||||||
|
No hay que tocar DNS para añadir nuevos subdominios.
|
||||||
|
|
@ -0,0 +1,41 @@
|
||||||
|
# napi — Notas API (notas.qu3v3d0.tech)
|
||||||
|
# Auth: PAM (mismas credenciales que SFTP)
|
||||||
|
# Datos: /var/www/api/data/$remote_user/notas.md
|
||||||
|
|
||||||
|
server {
|
||||||
|
listen 80;
|
||||||
|
server_name notas.qu3v3d0.tech;
|
||||||
|
return 301 https://$server_name$request_uri;
|
||||||
|
}
|
||||||
|
|
||||||
|
server {
|
||||||
|
listen 443 ssl;
|
||||||
|
server_name notas.qu3v3d0.tech;
|
||||||
|
|
||||||
|
ssl_certificate /etc/ssl/certs/qu3v3d0.tech.crt;
|
||||||
|
ssl_certificate_key /etc/ssl/private/qu3v3d0.tech.key;
|
||||||
|
|
||||||
|
root /var/www/api;
|
||||||
|
|
||||||
|
auth_pam "Notas DDAW2";
|
||||||
|
auth_pam_service_name "common-auth";
|
||||||
|
|
||||||
|
location = / {
|
||||||
|
try_files /viewer.html =404;
|
||||||
|
}
|
||||||
|
|
||||||
|
location = /notas.md {
|
||||||
|
alias /var/www/api/data/$remote_user/notas.md;
|
||||||
|
default_type text/plain;
|
||||||
|
charset utf-8;
|
||||||
|
add_header Cache-Control "no-cache";
|
||||||
|
}
|
||||||
|
|
||||||
|
location ~* \.(js|css)$ {
|
||||||
|
expires 7d;
|
||||||
|
}
|
||||||
|
|
||||||
|
location / {
|
||||||
|
return 404;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,41 @@
|
||||||
|
# napi2 — Notas Programación ASIR1 (asir1.qu3v3d0.tech)
|
||||||
|
# Auth: PAM (mismas credenciales que SFTP)
|
||||||
|
# Datos: /var/www/napi2/data/$remote_user/notas.md
|
||||||
|
|
||||||
|
server {
|
||||||
|
listen 80;
|
||||||
|
server_name asir1.qu3v3d0.tech;
|
||||||
|
return 301 https://$server_name$request_uri;
|
||||||
|
}
|
||||||
|
|
||||||
|
server {
|
||||||
|
listen 443 ssl;
|
||||||
|
server_name asir1.qu3v3d0.tech;
|
||||||
|
|
||||||
|
ssl_certificate /etc/ssl/certs/qu3v3d0.tech.crt;
|
||||||
|
ssl_certificate_key /etc/ssl/private/qu3v3d0.tech.key;
|
||||||
|
|
||||||
|
root /var/www/napi2;
|
||||||
|
|
||||||
|
auth_pam "Notas Programacion ASIR1";
|
||||||
|
auth_pam_service_name "common-auth";
|
||||||
|
|
||||||
|
location = / {
|
||||||
|
try_files /viewer.html =404;
|
||||||
|
}
|
||||||
|
|
||||||
|
location = /notas.md {
|
||||||
|
alias /var/www/napi2/data/$remote_user/notas.md;
|
||||||
|
default_type text/plain;
|
||||||
|
charset utf-8;
|
||||||
|
add_header Cache-Control "no-cache";
|
||||||
|
}
|
||||||
|
|
||||||
|
location ~* \.(js|css)$ {
|
||||||
|
expires 7d;
|
||||||
|
}
|
||||||
|
|
||||||
|
location / {
|
||||||
|
return 404;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,165 @@
|
||||||
|
# 📜 Scripts y Servicios — napi
|
||||||
|
|
||||||
|
Copia de referencia de todos los scripts y unidades systemd desplegados en **zzz** (`qu3v3d0.tech`) y **aldebaran/anka4** para el sistema de retroalimentación a estudiantes.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🗂️ Inventario
|
||||||
|
|
||||||
|
| Fichero | Dónde vive | Descripción |
|
||||||
|
|:--------|:-----------|:------------|
|
||||||
|
| **`python-upload-watcher.sh`** | `zzz:/usr/local/bin/` | Watcher ASIR1 — detecta entregas SFTP en `/home/USER/python/`, agrupa por carpeta, notifica XMPP |
|
||||||
|
| **`nginx-user-config-watcher.sh`** | `zzz:/usr/local/bin/` | Watcher DDAW2 — valida y despliega `*.conf` de alumnos, analiza CSP, notifica XMPP |
|
||||||
|
| **`xmpp-notify.py`** | `zzz:/usr/local/bin/` | Bot XMPP one-shot (slixmpp) — envía mensaje a `jla@librebits.info` |
|
||||||
|
| **`python-upload-watcher.service`** | `zzz:/etc/systemd/system/` | Unit systemd para el watcher ASIR1 |
|
||||||
|
| **`nginx-user-config-watcher.service`** | `zzz:/etc/systemd/system/` | Unit systemd para el watcher DDAW2 |
|
||||||
|
| **`home-fenix-napi-data.mount`** | `aldebaran:~/.config/systemd/user/` | Mount sshfs `~/napi-data/` → `zzz:/var/www/napi/data/` (DDAW2) |
|
||||||
|
| **`home-fenix-napi-data2.mount`** | `aldebaran:~/.config/systemd/user/` | Mount sshfs `~/napi-data2/` → `zzz:/var/www/napi2/data/` (ASIR1) |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🐍 python-upload-watcher.sh (v5)
|
||||||
|
|
||||||
|
**Propósito:** Monitorizar las entregas de prácticas de Programación (ASIR1) subidas por SFTP.
|
||||||
|
|
||||||
|
### Características
|
||||||
|
|
||||||
|
- ✅ **Batching por carpeta** — Cuando un alumno sube `PRACTICA3.1/` con N ficheros, envía **un solo mensaje XMPP** con el listado completo (espera 10s de silencio)
|
||||||
|
- ♻️ **Re-entregas** — Si el alumno borra y re-sube la misma carpeta (<120s), etiqueta como "Re-entrega"
|
||||||
|
- 🪟 **Windows-safe** — Ignora `Thumbs.db`, `desktop.ini`, `.DS_Store`, `*.tmp`, `~$*`
|
||||||
|
- 📁 **Iconos por tipo** — 🐍 `.py` · 📦 `.zip/.rar` · 📝 `.md` · 📄 `.txt` · 📕 `.pdf` · 📘 `.docx`
|
||||||
|
|
||||||
|
### Ejemplo de notificación XMPP
|
||||||
|
|
||||||
|
```
|
||||||
|
📁 [barrios] Entrega ASIR1: PRACTICA3.1/ (4 ficheros)
|
||||||
|
🐍 main.py (2048 bytes)
|
||||||
|
🐍 utils.py (1024 bytes)
|
||||||
|
📝 README.md (512 bytes)
|
||||||
|
📄 requisitos.txt (128 bytes)
|
||||||
|
```
|
||||||
|
|
||||||
|
```
|
||||||
|
📁 [barrios] ♻️ Re-entrega ASIR1: PRACTICA3.1/ (3 ficheros)
|
||||||
|
🐍 main.py (2100 bytes)
|
||||||
|
📝 README.md (600 bytes)
|
||||||
|
📄 requisitos.txt (128 bytes)
|
||||||
|
```
|
||||||
|
|
||||||
|
### Eventos inotifywait monitorizados
|
||||||
|
|
||||||
|
| Evento | Acción |
|
||||||
|
|:-------|:-------|
|
||||||
|
| `CREATE` (directorio) | Abre batch, detecta re-entrega si fue borrado recientemente |
|
||||||
|
| `CREATE` (fichero) | Ignorado (esperamos `close_write`) |
|
||||||
|
| `CLOSE_WRITE` | Fichero completado → añade al batch o notifica individual |
|
||||||
|
| `MOVED_TO` | Fichero movido al directorio → igual que `close_write` |
|
||||||
|
| `DELETE` / `MOVED_FROM` | Registra borrado de carpeta (para detectar re-entregas) |
|
||||||
|
|
||||||
|
### Log
|
||||||
|
|
||||||
|
```bash
|
||||||
|
sudo tail -f /var/log/python-upload-watcher.log # en zzz
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🌐 nginx-user-config-watcher.sh (v3)
|
||||||
|
|
||||||
|
**Propósito:** Despliegue automático de configuraciones Nginx subidas por alumnos de DDAW2 via SFTP.
|
||||||
|
|
||||||
|
### Características
|
||||||
|
|
||||||
|
- ✅ **Validación de seguridad** — Verifica `server_name`, `root`, bloquea directivas peligrosas (`proxy_pass`, `include /`, etc.)
|
||||||
|
- 🔒 **Análisis CSP** — Revisa cabeceras `Content-Security-Policy`, detecta `unsafe-inline`, multiline, HTTPS
|
||||||
|
- 📛 **Nomenclatura** — Verifica patrón `mi-nginx[-SUFIJO].conf`
|
||||||
|
- 🌐 **Multi-sitio v3** — `mi-nginx-hextris.conf` → `USER-hextris.qu3v3d0.tech`
|
||||||
|
- 🗑️ **Undeploy** — Borrar el `.conf` via SFTP elimina el site de Nginx
|
||||||
|
- 💡 **Pistas humanizadas** — Traduce errores `nginx -t` a español comprensible
|
||||||
|
|
||||||
|
### Límites
|
||||||
|
|
||||||
|
- Máximo **4 sitios** por alumno
|
||||||
|
- Solo `.conf` dentro de `/home/USER/html/`
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 📨 xmpp-notify.py
|
||||||
|
|
||||||
|
Bot XMPP one-shot usando `slixmpp`. Envía un mensaje y desconecta.
|
||||||
|
|
||||||
|
```bash
|
||||||
|
/usr/local/bin/xmpp-notify.py "Mensaje de prueba"
|
||||||
|
```
|
||||||
|
|
||||||
|
- **JID:** `zzz@librebits.info`
|
||||||
|
- **Destinatario:** `jla@librebits.info`
|
||||||
|
- **Config:** `/etc/xmpp-notify.conf` (credenciales)
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## ⚙️ Units systemd
|
||||||
|
|
||||||
|
### En zzz (system-level)
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Estado de los watchers
|
||||||
|
sudo systemctl status python-upload-watcher.service # ASIR1
|
||||||
|
sudo systemctl status nginx-user-config-watcher.service # DDAW2
|
||||||
|
|
||||||
|
# Reiniciar
|
||||||
|
sudo systemctl restart python-upload-watcher.service
|
||||||
|
sudo systemctl restart nginx-user-config-watcher.service
|
||||||
|
```
|
||||||
|
|
||||||
|
### En aldebaran/anka4 (user-level)
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# Estado de los mounts sshfs
|
||||||
|
systemctl --user status home-fenix-napi\\x2ddata.mount # DDAW2
|
||||||
|
systemctl --user status home-fenix-napi\\x2ddata2.mount # ASIR1
|
||||||
|
|
||||||
|
# Montar/desmontar
|
||||||
|
systemctl --user start home-fenix-napi\\x2ddata2.mount
|
||||||
|
systemctl --user stop home-fenix-napi\\x2ddata2.mount
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 🏗️ Estructura de directorios en zzz
|
||||||
|
|
||||||
|
```
|
||||||
|
/var/www/napi/ ← DDAW2
|
||||||
|
├── viewer.html
|
||||||
|
├── marked.min.js
|
||||||
|
├── twemoji.min.js
|
||||||
|
└── data/
|
||||||
|
├── anas/notas.md
|
||||||
|
├── pablo/notas.md
|
||||||
|
└── ... (19 alumnos)
|
||||||
|
|
||||||
|
/var/www/napi2/ ← ASIR1 (Programación)
|
||||||
|
├── viewer.html
|
||||||
|
├── marked.min.js
|
||||||
|
├── twemoji.min.js
|
||||||
|
└── data/
|
||||||
|
├── barja/notas.md
|
||||||
|
├── barrios/notas.md
|
||||||
|
└── ... (21 alumnos)
|
||||||
|
|
||||||
|
/home/USER/python/ ← Entregas SFTP (ASIR1)
|
||||||
|
├── PRACTICA3.1/
|
||||||
|
│ ├── main.py
|
||||||
|
│ └── README.md
|
||||||
|
└── fichero_suelto.py
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 📅 Historial de versiones
|
||||||
|
|
||||||
|
| Script | Versión | Fecha | Cambios |
|
||||||
|
|:-------|:--------|:------|:--------|
|
||||||
|
| `python-upload-watcher.sh` | **v5** | 2026-02-25 | Batching + re-entregas + Windows-safe + fix `local` en subshell |
|
||||||
|
| `nginx-user-config-watcher.sh` | **v3** | 2026-02-19 | Multi-sitio + undeploy + CSP analysis |
|
||||||
|
| `xmpp-notify.py` | **v1** | 2026-01-27 | Bot one-shot slixmpp |
|
||||||
|
|
@ -0,0 +1,13 @@
|
||||||
|
[Unit]
|
||||||
|
Description=SSHFS mount napi-data from zzz (qu3v3d0.tech)
|
||||||
|
After=network-online.target
|
||||||
|
Wants=network-online.target
|
||||||
|
|
||||||
|
[Mount]
|
||||||
|
What=fenix@qu3v3d0.tech:/var/www/napi/data
|
||||||
|
Where=/home/fenix/napi-data
|
||||||
|
Type=fuse.sshfs
|
||||||
|
Options=reconnect,ServerAliveInterval=15,ServerAliveCountMax=3,IdentityFile=/home/fenix/.ssh/id_rsa,_netdev,allow_other
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=default.target
|
||||||
|
|
@ -0,0 +1,13 @@
|
||||||
|
[Unit]
|
||||||
|
Description=SSHFS mount napi-data2 from zzz (qu3v3d0.tech) — Programación ASIR1
|
||||||
|
After=network-online.target
|
||||||
|
Wants=network-online.target
|
||||||
|
|
||||||
|
[Mount]
|
||||||
|
What=fenix@qu3v3d0.tech:/var/www/napi2/data
|
||||||
|
Where=/home/fenix/napi-data2
|
||||||
|
Type=fuse.sshfs
|
||||||
|
Options=reconnect,ServerAliveInterval=15,ServerAliveCountMax=3,IdentityFile=/home/fenix/.ssh/id_rsa,_netdev,allow_other
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=default.target
|
||||||
|
|
@ -0,0 +1,12 @@
|
||||||
|
[Unit]
|
||||||
|
Description=Watch and deploy user Nginx configs
|
||||||
|
After=network.target nginx.service
|
||||||
|
|
||||||
|
[Service]
|
||||||
|
Type=simple
|
||||||
|
ExecStart=/usr/local/bin/nginx-user-config-watcher.sh
|
||||||
|
Restart=always
|
||||||
|
RestartSec=5
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=multi-user.target
|
||||||
|
|
@ -0,0 +1,508 @@
|
||||||
|
#!/bin/bash
|
||||||
|
# /usr/local/bin/nginx-user-config-watcher.sh
|
||||||
|
# Watcher para configs nginx de usuarios via SFTP
|
||||||
|
# Detecta cualquier archivo *.conf en /home/USER/html/
|
||||||
|
# Con notificaciones XMPP a jla@librebits.info
|
||||||
|
#
|
||||||
|
# v2 — Análisis CSP post-deploy + humanización de errores nginx (P2.5)
|
||||||
|
# v3 — Multi-sitio por alumno: mi-nginx-SUFIJO.conf → USER-SUFIJO.qu3v3d0.tech
|
||||||
|
# Retrocompatible: mi-nginx.conf (sin sufijo) funciona igual que v2
|
||||||
|
|
||||||
|
WATCH_DIR="/home"
|
||||||
|
LOG="/var/log/nginx-user-configs.log"
|
||||||
|
MAX_SITES=4
|
||||||
|
|
||||||
|
log() {
|
||||||
|
echo "$(date '+%Y-%m-%d %H:%M:%S') - $1" >> "$LOG"
|
||||||
|
}
|
||||||
|
|
||||||
|
# Notificación XMPP (fire and forget)
|
||||||
|
notify_xmpp() {
|
||||||
|
local msg="$1"
|
||||||
|
/usr/local/bin/xmpp-notify.py "$msg" >/dev/null 2>&1 &
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# analyze_csp() — Analiza un .conf desplegado buscando
|
||||||
|
# cabeceras CSP y de seguridad. Devuelve texto con pistas.
|
||||||
|
# -------------------------------------------------------
|
||||||
|
analyze_csp() {
|
||||||
|
local conf="$1"
|
||||||
|
local hints=""
|
||||||
|
local conf_content
|
||||||
|
conf_content=$(cat "$conf" 2>/dev/null) || return
|
||||||
|
|
||||||
|
# --- Check 1: ¿Tiene cabecera CSP? ---
|
||||||
|
if ! echo "$conf_content" | grep -q "Content-Security-Policy"; then
|
||||||
|
hints="${hints}💡 Tu .conf no tiene cabecera Content-Security-Policy (opcional según la práctica)
|
||||||
|
"
|
||||||
|
else
|
||||||
|
# --- Check 2: ¿CSP multiline? (add_header ... " sin cierre en misma línea) ---
|
||||||
|
# Buscamos líneas con add_header Content-Security-Policy que abren comillas
|
||||||
|
# pero no las cierran en la misma línea
|
||||||
|
if echo "$conf_content" | grep -E 'add_header\s+Content-Security-Policy' | grep -qE '"[^"]*$'; then
|
||||||
|
hints="${hints}⚠️ CSP con saltos de línea: ponlo todo en UNA sola línea entre comillas
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- Check 3: ¿CSP en bloque HTTPS (443) o solo en HTTP (80)? ---
|
||||||
|
# Estrategia: buscar si CSP aparece ANTES del primer listen 443
|
||||||
|
# o si no hay listen 443 en absoluto
|
||||||
|
local has_443
|
||||||
|
has_443=$(echo "$conf_content" | grep -c "listen.*443")
|
||||||
|
if [[ "$has_443" -eq 0 ]]; then
|
||||||
|
hints="${hints}⚠️ No hay bloque HTTPS (listen 443) — la CSP debería ir en el bloque HTTPS
|
||||||
|
"
|
||||||
|
else
|
||||||
|
# Comprobar si CSP está solo en bloque HTTP (antes de listen 443)
|
||||||
|
# Obtenemos la línea de CSP y la línea de listen 443
|
||||||
|
local csp_line
|
||||||
|
local ssl_line
|
||||||
|
csp_line=$(echo "$conf_content" | grep -n "Content-Security-Policy" | head -1 | cut -d: -f1)
|
||||||
|
ssl_line=$(echo "$conf_content" | grep -n "listen.*443" | head -1 | cut -d: -f1)
|
||||||
|
if [[ -n "$csp_line" && -n "$ssl_line" && "$csp_line" -lt "$ssl_line" ]]; then
|
||||||
|
# CSP aparece antes del bloque 443 — verificar si también está después
|
||||||
|
local csp_after_ssl
|
||||||
|
csp_after_ssl=$(echo "$conf_content" | tail -n +"$ssl_line" | grep -c "Content-Security-Policy")
|
||||||
|
if [[ "$csp_after_ssl" -eq 0 ]]; then
|
||||||
|
hints="${hints}⚠️ CSP solo en bloque HTTP (80), no en HTTPS (443) — ponla en el bloque donde se sirve tu web
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- Check 4: ¿unsafe-inline en script-src? ---
|
||||||
|
if echo "$conf_content" | grep -i "script-src" | grep -qi "unsafe-inline"; then
|
||||||
|
hints="${hints}⚠️ unsafe-inline en script-src debilita la protección CSP contra XSS
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- Check 5: ¿Falta 'always' en add_header CSP? ---
|
||||||
|
if echo "$conf_content" | grep "Content-Security-Policy" | grep -qv "always"; then
|
||||||
|
hints="${hints}💡 Consejo: añade 'always' para que CSP se envíe también en respuestas 4xx/5xx
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- Check 6: ¿Tiene las otras cabeceras de seguridad? ---
|
||||||
|
local missing_headers=""
|
||||||
|
if ! echo "$conf_content" | grep -q "X-Content-Type-Options"; then
|
||||||
|
missing_headers="${missing_headers} X-Content-Type-Options"
|
||||||
|
fi
|
||||||
|
if ! echo "$conf_content" | grep -q "X-Frame-Options"; then
|
||||||
|
missing_headers="${missing_headers} X-Frame-Options"
|
||||||
|
fi
|
||||||
|
if ! echo "$conf_content" | grep -q "X-XSS-Protection"; then
|
||||||
|
missing_headers="${missing_headers} X-XSS-Protection"
|
||||||
|
fi
|
||||||
|
if ! echo "$conf_content" | grep -q "Referrer-Policy"; then
|
||||||
|
missing_headers="${missing_headers} Referrer-Policy"
|
||||||
|
fi
|
||||||
|
if [[ -n "$missing_headers" ]]; then
|
||||||
|
hints="${hints}💡 Faltan cabeceras de seguridad:${missing_headers}
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Devolver resultado
|
||||||
|
if [[ -z "$hints" ]]; then
|
||||||
|
echo "🔒 CSP y cabeceras de seguridad: todo OK"
|
||||||
|
else
|
||||||
|
echo "$hints"
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# humanize_nginx_error() — Traduce errores nginx -t
|
||||||
|
# a pistas comprensibles para el alumno.
|
||||||
|
# -------------------------------------------------------
|
||||||
|
humanize_nginx_error() {
|
||||||
|
local error_output="$1"
|
||||||
|
local pistas=""
|
||||||
|
|
||||||
|
if echo "$error_output" | grep -q 'unexpected "}"'; then
|
||||||
|
pistas="${pistas}💡 ¿Te falta un ';' al final de alguna directiva?
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
if echo "$error_output" | grep -q "unexpected end of file"; then
|
||||||
|
pistas="${pistas}💡 ¿Cerraste todos los bloques server { } con '}'?
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
if echo "$error_output" | grep -q "directive is not allowed"; then
|
||||||
|
pistas="${pistas}💡 Revisa que cada directiva esté dentro del bloque server { } correcto
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
if echo "$error_output" | grep -q "unknown directive"; then
|
||||||
|
pistas="${pistas}💡 ¿Hay algún typo en el nombre de una directiva?
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
if echo "$error_output" | grep -q "invalid number of arguments"; then
|
||||||
|
pistas="${pistas}💡 Alguna directiva tiene argumentos de más o de menos — revisa comillas y punto y coma
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
if echo "$error_output" | grep -qE '(missing|unexpected) ";"'; then
|
||||||
|
pistas="${pistas}💡 Revisa los punto y coma (;) — puede que sobre o falte alguno
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
|
||||||
|
echo "$pistas"
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# check_https_redirect() — Verifica si la config tiene
|
||||||
|
# redirección HTTP → HTTPS (return 301 https://)
|
||||||
|
# -------------------------------------------------------
|
||||||
|
check_https_redirect() {
|
||||||
|
local conf="$1"
|
||||||
|
local expected_name="$2"
|
||||||
|
local conf_content
|
||||||
|
conf_content=$(cat "$conf" 2>/dev/null) || return
|
||||||
|
local hints=""
|
||||||
|
|
||||||
|
# ¿Tiene listen 443 ssl? (es decir, ¿sirve HTTPS?)
|
||||||
|
if echo "$conf_content" | grep -q "listen.*443.*ssl"; then
|
||||||
|
# Tiene HTTPS → ¿redirige HTTP a HTTPS?
|
||||||
|
if ! echo "$conf_content" | grep -qE "return\s+301\s+https://"; then
|
||||||
|
hints="${hints}⚠️ HTTPS activo pero NO hay redirección HTTP → HTTPS.
|
||||||
|
💡 Añade un bloque server { listen 80; return 301 https://\$server_name\$request_uri; }
|
||||||
|
"
|
||||||
|
else
|
||||||
|
hints="${hints}✅ Redirección HTTP → HTTPS configurada correctamente
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
# No tiene HTTPS
|
||||||
|
hints="${hints}⚠️ Tu config no tiene bloque HTTPS (listen 443 ssl) — el tráfico no va cifrado
|
||||||
|
💡 Recuerda: la práctica requiere forzar tráfico HTTP → HTTPS
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
|
||||||
|
echo "$hints"
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# check_naming_convention() — Avisa si el fichero .conf
|
||||||
|
# no sigue la nomenclatura mi-nginx[-SUFIJO].conf
|
||||||
|
# -------------------------------------------------------
|
||||||
|
check_naming_convention() {
|
||||||
|
local conffile="$1"
|
||||||
|
if [[ ! "$conffile" =~ ^mi-nginx(-[a-z0-9]+)?\.conf$ ]]; then
|
||||||
|
echo "📛 Tu fichero se llama '$conffile' — la nomenclatura recomendada es:
|
||||||
|
• mi-nginx.conf → sitio principal
|
||||||
|
• mi-nginx-hextris.conf → segundo sitio (Hextris)
|
||||||
|
• mi-nginx-app.conf → tercer sitio (App)
|
||||||
|
Usa el formato mi-nginx-NOMBRE.conf para que el sistema detecte automáticamente tu subdominio.
|
||||||
|
"
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# extract_app_suffix() — Extrae el sufijo de app del nombre del .conf
|
||||||
|
# mi-nginx.conf → "" (vacío = sitio principal)
|
||||||
|
# mi-nginx-portfolio.conf → "portfolio"
|
||||||
|
# otro-nombre.conf → "" (no sigue el patrón multi-sitio)
|
||||||
|
# -------------------------------------------------------
|
||||||
|
extract_app_suffix() {
|
||||||
|
local conffile="$1"
|
||||||
|
if [[ "$conffile" =~ ^mi-nginx-([a-z0-9]+)\.conf$ ]]; then
|
||||||
|
echo "${BASH_REMATCH[1]}"
|
||||||
|
else
|
||||||
|
echo ""
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
# -------------------------------------------------------
|
||||||
|
# undeploy_site() — Elimina un site de nginx cuando el
|
||||||
|
# alumno borra su mi-nginx[-SUFIJO].conf via SFTP
|
||||||
|
# -------------------------------------------------------
|
||||||
|
undeploy_site() {
|
||||||
|
local user="$1"
|
||||||
|
local conffile="$2"
|
||||||
|
|
||||||
|
local app_suffix
|
||||||
|
app_suffix=$(extract_app_suffix "$conffile")
|
||||||
|
|
||||||
|
local site_id
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
site_id="${user}-${app_suffix}"
|
||||||
|
else
|
||||||
|
site_id="${user}"
|
||||||
|
fi
|
||||||
|
|
||||||
|
local dest="/etc/nginx/sites-available/$site_id"
|
||||||
|
local enabled="/etc/nginx/sites-enabled/$site_id"
|
||||||
|
|
||||||
|
# Solo actuar si el site existe desplegado
|
||||||
|
if [[ -f "$dest" || -L "$enabled" ]]; then
|
||||||
|
rm -f "$enabled" "$dest"
|
||||||
|
|
||||||
|
# Validar que nginx sigue OK sin ese site
|
||||||
|
if nginx -t 2>&1 | grep -q "successful"; then
|
||||||
|
systemctl reload nginx
|
||||||
|
log "[$user] UNDEPLOY: Site $site_id eliminado (borrado $conffile) y nginx recargado"
|
||||||
|
notify_xmpp "🗑️ [$user] Site $site_id eliminado (borrado $conffile)"
|
||||||
|
else
|
||||||
|
log "[$user] UNDEPLOY: Site $site_id eliminado pero nginx -t falló (recargando de todas formas)"
|
||||||
|
systemctl reload nginx
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
|
validate_and_deploy() {
|
||||||
|
local user="$1"
|
||||||
|
local conffile="$2"
|
||||||
|
local src="/home/$user/html/$conffile"
|
||||||
|
|
||||||
|
# --- v3: Determinar sufijo de app y nombres esperados ---
|
||||||
|
local app_suffix
|
||||||
|
app_suffix=$(extract_app_suffix "$conffile")
|
||||||
|
|
||||||
|
local expected_name
|
||||||
|
local expected_root
|
||||||
|
local site_id
|
||||||
|
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
expected_name="${user}-${app_suffix}"
|
||||||
|
expected_root="/home/$user/html/$app_suffix"
|
||||||
|
site_id="${user}-${app_suffix}"
|
||||||
|
else
|
||||||
|
expected_name="${user}"
|
||||||
|
expected_root="/home/$user/html"
|
||||||
|
site_id="${user}"
|
||||||
|
fi
|
||||||
|
|
||||||
|
local dest="/etc/nginx/sites-available/$site_id"
|
||||||
|
local enabled="/etc/nginx/sites-enabled/$site_id"
|
||||||
|
local tmp="/tmp/nginx-test-${site_id}.conf"
|
||||||
|
local backup="/tmp/nginx-backup-${site_id}.conf"
|
||||||
|
local error_file="/home/$user/html/nginx-error.log"
|
||||||
|
local status_file="/home/$user/html/nginx-status.log"
|
||||||
|
local practica_file="/home/$user/html/practica-status.log"
|
||||||
|
|
||||||
|
# Verificar que el archivo existe
|
||||||
|
[[ ! -f "$src" ]] && return 1
|
||||||
|
|
||||||
|
# --- v3: Límite de sitios por alumno (solo para sitios NUEVOS) ---
|
||||||
|
if [[ -n "$app_suffix" && ! -f "$dest" ]]; then
|
||||||
|
local current_sites
|
||||||
|
current_sites=$(ls /etc/nginx/sites-enabled/${user} /etc/nginx/sites-enabled/${user}-* 2>/dev/null | wc -l)
|
||||||
|
if (( current_sites >= MAX_SITES )); then
|
||||||
|
log "[$user] RECHAZADO: límite de $MAX_SITES sitios alcanzado"
|
||||||
|
echo "ERROR: Ya tienes $MAX_SITES sitios desplegados (límite máximo $MAX_SITES)." > "$error_file"
|
||||||
|
echo "Elimina algún mi-nginx-*.conf si quieres crear uno nuevo." >> "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: límite de $MAX_SITES sitios alcanzado"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Copiar a temporal para validar
|
||||||
|
cp "$src" "$tmp"
|
||||||
|
|
||||||
|
# Comprobar nomenclatura del fichero (aviso temprano)
|
||||||
|
local naming_check
|
||||||
|
naming_check=$(check_naming_convention "$conffile")
|
||||||
|
|
||||||
|
# SEGURIDAD: Verificar que server_name coincide con el esperado
|
||||||
|
if ! grep -qE "^\s*server_name\s+${expected_name}\.(local|qu3v3d0\.tech)" "$tmp"; then
|
||||||
|
log "[$user] RECHAZADO: server_name no coincide (esperado: ${expected_name}.qu3v3d0.tech)"
|
||||||
|
{
|
||||||
|
echo "ERROR: server_name debe ser ${expected_name}.qu3v3d0.tech"
|
||||||
|
if [[ -n "$naming_check" ]]; then
|
||||||
|
echo ""
|
||||||
|
echo "$naming_check"
|
||||||
|
fi
|
||||||
|
} > "$error_file"
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
echo "(Para el fichero $conffile el subdominio esperado es ${expected_name}.qu3v3d0.tech)" >> "$error_file"
|
||||||
|
fi
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: server_name incorrecto ($conffile, esperado: ${expected_name})"
|
||||||
|
rm -f "$tmp"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# SEGURIDAD: Verificar que root apunta al directorio correcto
|
||||||
|
# - Sin sufijo: prefijo /home/USER/html (v2-compatible, permite subdirectorios)
|
||||||
|
# - Con sufijo: exacto /home/USER/html/SUFIJO (multi-sitio v3)
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
if ! grep -qE "^\s*root\s+${expected_root}\s*;" "$tmp"; then
|
||||||
|
log "[$user] RECHAZADO: root no apunta a $expected_root"
|
||||||
|
echo "ERROR: root debe ser ${expected_root}" > "$error_file"
|
||||||
|
echo "(Para el fichero $conffile la carpeta debe ser html/$app_suffix/)" >> "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: root incorrecto ($conffile, esperado: ${expected_root})"
|
||||||
|
rm -f "$tmp"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
else
|
||||||
|
# Retrocompatible con v2: acepta /home/USER/html y cualquier subdirectorio
|
||||||
|
if ! grep -qE "^\s*root\s+/home/$user/html" "$tmp"; then
|
||||||
|
log "[$user] RECHAZADO: root no apunta a /home/$user/html"
|
||||||
|
echo "ERROR: root debe ser /home/$user/html" > "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: root incorrecto ($conffile)"
|
||||||
|
rm -f "$tmp"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- v3: Verificar que el subdirectorio existe (solo multi-sitio) ---
|
||||||
|
if [[ -n "$app_suffix" && ! -d "$expected_root" ]]; then
|
||||||
|
log "[$user] RECHAZADO: directorio $expected_root no existe"
|
||||||
|
echo "ERROR: La carpeta '$app_suffix/' no existe dentro de html/." > "$error_file"
|
||||||
|
echo "Crea primero la carpeta via SFTP (FileZilla) y luego vuelve a subir $conffile." >> "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: carpeta html/$app_suffix/ no existe"
|
||||||
|
rm -f "$tmp"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# SEGURIDAD: Bloquear directivas peligrosas (ignorando comentarios)
|
||||||
|
if grep -v "^\s*#" "$tmp" | grep -qE "(proxy_pass|fastcgi_pass|uwsgi_pass|include\s+/|lua_|perl_|upstream)" ; then
|
||||||
|
log "[$user] RECHAZADO: directivas prohibidas detectadas ($conffile)"
|
||||||
|
echo "ERROR: Directivas proxy/include/lua no permitidas" > "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: directivas prohibidas ($conffile)"
|
||||||
|
rm -f "$tmp"
|
||||||
|
return 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Hacer backup del config actual si existe
|
||||||
|
[[ -f "$dest" ]] && cp "$dest" "$backup"
|
||||||
|
|
||||||
|
# Copiar nuevo config a sites-available
|
||||||
|
cp "$tmp" "$dest"
|
||||||
|
|
||||||
|
# Asegurar que el symlink existe
|
||||||
|
ln -sf "$dest" "$enabled"
|
||||||
|
|
||||||
|
# Validar sintaxis nginx con la nueva config
|
||||||
|
local nginx_output
|
||||||
|
nginx_output=$(nginx -t 2>&1)
|
||||||
|
|
||||||
|
if echo "$nginx_output" | grep -q "successful"; then
|
||||||
|
# Sintaxis OK - recargar nginx
|
||||||
|
systemctl reload nginx
|
||||||
|
log "[$user] OK: Config desplegada ($conffile → $site_id) y nginx recargado"
|
||||||
|
|
||||||
|
# Analizar CSP y cabeceras de seguridad
|
||||||
|
local csp_analysis
|
||||||
|
csp_analysis=$(analyze_csp "$dest")
|
||||||
|
|
||||||
|
# Analizar redirección HTTP → HTTPS
|
||||||
|
local https_check
|
||||||
|
https_check=$(check_https_redirect "$dest" "$expected_name")
|
||||||
|
|
||||||
|
# Mensaje de deploy según sea sitio principal o sub-sitio
|
||||||
|
local deploy_msg
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
deploy_msg="✅ [$user] Config desplegada OK ($conffile → ${expected_name}.qu3v3d0.tech)"
|
||||||
|
else
|
||||||
|
deploy_msg="✅ [$user] Config desplegada OK ($conffile)"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# XMPP al profesor (resumen + todos los análisis)
|
||||||
|
notify_xmpp "$deploy_msg
|
||||||
|
$https_check$csp_analysis${naming_check:+
|
||||||
|
$naming_check}"
|
||||||
|
|
||||||
|
# nginx-status.log (resumen para el alumno)
|
||||||
|
{
|
||||||
|
echo "OK: Config desplegada desde $conffile $(date)"
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
echo "🌐 Sitio: https://${expected_name}.qu3v3d0.tech"
|
||||||
|
fi
|
||||||
|
echo ""
|
||||||
|
echo "$https_check"
|
||||||
|
echo "$csp_analysis"
|
||||||
|
if [[ -n "$naming_check" ]]; then
|
||||||
|
echo "$naming_check"
|
||||||
|
fi
|
||||||
|
} > "$status_file"
|
||||||
|
chown $user:www-data "$status_file" 2>/dev/null
|
||||||
|
|
||||||
|
# practica-status.log (detalle completo)
|
||||||
|
{
|
||||||
|
echo "=== Análisis de $conffile — $(date) ==="
|
||||||
|
if [[ -n "$app_suffix" ]]; then
|
||||||
|
echo "🌐 Sitio: https://${expected_name}.qu3v3d0.tech"
|
||||||
|
echo "📁 Root: $expected_root"
|
||||||
|
fi
|
||||||
|
echo ""
|
||||||
|
echo "--- Redirección HTTPS ---"
|
||||||
|
echo "$https_check"
|
||||||
|
echo "--- Seguridad (CSP y cabeceras) ---"
|
||||||
|
echo "$csp_analysis"
|
||||||
|
if [[ -n "$naming_check" ]]; then
|
||||||
|
echo "--- Nomenclatura ---"
|
||||||
|
echo "$naming_check"
|
||||||
|
fi
|
||||||
|
echo "---"
|
||||||
|
echo "Revisa el enunciado de tu práctica para los entregables pendientes."
|
||||||
|
} > "$practica_file"
|
||||||
|
chown $user:www-data "$practica_file" 2>/dev/null
|
||||||
|
|
||||||
|
rm -f "$error_file"
|
||||||
|
rm -f "$backup"
|
||||||
|
else
|
||||||
|
# Error de sintaxis - revertir
|
||||||
|
log "[$user] RECHAZADO: Error de sintaxis nginx ($conffile → $site_id)"
|
||||||
|
|
||||||
|
# Humanizar el error
|
||||||
|
local pistas
|
||||||
|
pistas=$(humanize_nginx_error "$nginx_output")
|
||||||
|
|
||||||
|
# nginx-error.log con error original + pistas
|
||||||
|
{
|
||||||
|
echo "$nginx_output" | tail -5
|
||||||
|
echo "ERROR: Sintaxis nginx inválida."
|
||||||
|
if [[ -n "$pistas" ]]; then
|
||||||
|
echo ""
|
||||||
|
echo "--- Pistas ---"
|
||||||
|
echo "$pistas"
|
||||||
|
fi
|
||||||
|
} > "$error_file"
|
||||||
|
chown $user:www-data "$error_file" 2>/dev/null
|
||||||
|
|
||||||
|
# XMPP al profesor con pistas
|
||||||
|
if [[ -n "$pistas" ]]; then
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: sintaxis inválida ($conffile)
|
||||||
|
$pistas"
|
||||||
|
else
|
||||||
|
notify_xmpp "❌ [$user] Config RECHAZADA: sintaxis inválida ($conffile)"
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Restaurar backup si existe
|
||||||
|
if [[ -f "$backup" ]]; then
|
||||||
|
cp "$backup" "$dest"
|
||||||
|
log "[$user] Config anterior de $site_id restaurada"
|
||||||
|
else
|
||||||
|
rm -f "$dest" "$enabled"
|
||||||
|
log "[$user] Config $site_id eliminada (no había backup)"
|
||||||
|
fi
|
||||||
|
rm -f "$backup"
|
||||||
|
fi
|
||||||
|
|
||||||
|
rm -f "$tmp"
|
||||||
|
}
|
||||||
|
|
||||||
|
log "=== Nginx User Config Watcher v3 iniciado (*.conf, multi-sitio) ==="
|
||||||
|
notify_xmpp "🚀 [zzz] Nginx Config Watcher v3 iniciado (*.conf, multi-sitio)"
|
||||||
|
|
||||||
|
# Bucle principal con inotifywait - detecta cualquier *.conf
|
||||||
|
# v3.1: también detecta delete/moved_from para limpiar sites huérfanos
|
||||||
|
inotifywait -m -r -e close_write,moved_to,delete,moved_from --format "%e %w%f" "$WATCH_DIR" 2>/dev/null | while read event filepath; do
|
||||||
|
# Captura: /home/USER/html/ARCHIVO.conf
|
||||||
|
if [[ "$filepath" =~ ^/home/([^/]+)/html/([^/]+.conf)$ ]]; then
|
||||||
|
user="${BASH_REMATCH[1]}"
|
||||||
|
conffile="${BASH_REMATCH[2]}"
|
||||||
|
if [[ "$event" == *DELETE* || "$event" == *MOVED_FROM* ]]; then
|
||||||
|
log "[$user] Detectado borrado de $conffile"
|
||||||
|
undeploy_site "$user" "$conffile"
|
||||||
|
else
|
||||||
|
log "[$user] Detectado cambio en $conffile"
|
||||||
|
sleep 1 # Esperar a que el archivo esté completo
|
||||||
|
validate_and_deploy "$user" "$conffile"
|
||||||
|
fi
|
||||||
|
fi
|
||||||
|
done
|
||||||
|
|
@ -0,0 +1,12 @@
|
||||||
|
[Unit]
|
||||||
|
Description=Watch ASIR1 Python uploads via SFTP and notify XMPP
|
||||||
|
After=network.target
|
||||||
|
|
||||||
|
[Service]
|
||||||
|
Type=simple
|
||||||
|
ExecStart=/usr/local/bin/python-upload-watcher.sh
|
||||||
|
Restart=always
|
||||||
|
RestartSec=5
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=multi-user.target
|
||||||
|
|
@ -0,0 +1,213 @@
|
||||||
|
#!/bin/bash
|
||||||
|
# /usr/local/bin/python-upload-watcher.sh
|
||||||
|
# Watcher para entregas de Programación ASIR1 via SFTP
|
||||||
|
# v7 — Nombre completo en notificaciones ([María Jara] en vez de [jara])
|
||||||
|
#
|
||||||
|
# - Batching por carpeta: UN mensaje XMPP con listado completo
|
||||||
|
# - Re-entregas: detecta delete+recreate (<120s)
|
||||||
|
# - Windows-safe: ignora Thumbs.db, desktop.ini, .DS_Store, *.tmp, __pycache__, *.pyc
|
||||||
|
|
||||||
|
WATCH_DIR="/home"
|
||||||
|
|
||||||
|
# --- Mapa usuario → nombre completo ---
|
||||||
|
fullname() {
|
||||||
|
case "$1" in
|
||||||
|
barja) echo "Alex Barja" ;;
|
||||||
|
barrios) echo "Andrés Barrios" ;;
|
||||||
|
cayo) echo "Jared Cayo" ;;
|
||||||
|
contrera) echo "Luciano Contrera" ;;
|
||||||
|
duque) echo "Jorge Duque" ;;
|
||||||
|
florea) echo "Alejandro Florea" ;;
|
||||||
|
gomes) echo "Gabriel Gomes" ;;
|
||||||
|
izquierdo) echo "Daniel Izquierdo" ;;
|
||||||
|
jara) echo "María Jara" ;;
|
||||||
|
lillo) echo "Fernando Lillo" ;;
|
||||||
|
linares) echo "Christopher Linares" ;;
|
||||||
|
macedo) echo "Eduardo Macedo" ;;
|
||||||
|
martinez) echo "Daniel Martínez" ;;
|
||||||
|
munoz) echo "Jordy Muñoz" ;;
|
||||||
|
olcina) echo "Jorge Olcina" ;;
|
||||||
|
ponce) echo "Francisco Ponce" ;;
|
||||||
|
posada) echo "Santiago Posada" ;;
|
||||||
|
quiroz) echo "Alexander Quiroz" ;;
|
||||||
|
reynoso) echo "Jorge Reynoso" ;;
|
||||||
|
sierra) echo "Leonel Sierra" ;;
|
||||||
|
torrero) echo "Mario Torrero" ;;
|
||||||
|
*) echo "$1" ;; # fallback: username tal cual
|
||||||
|
esac
|
||||||
|
}
|
||||||
|
LOG="/var/log/python-upload-watcher.log"
|
||||||
|
BATCH_DIR="/tmp/python-watcher-batches"
|
||||||
|
DELETE_DIR="/tmp/python-watcher-deletes"
|
||||||
|
QUIET_SECONDS=10
|
||||||
|
|
||||||
|
mkdir -p "$BATCH_DIR" "$DELETE_DIR"
|
||||||
|
|
||||||
|
log() {
|
||||||
|
echo "$(date '+%Y-%m-%d %H:%M:%S') - $1" >> "$LOG"
|
||||||
|
}
|
||||||
|
|
||||||
|
notify_xmpp() {
|
||||||
|
/usr/local/bin/xmpp-notify.py "$1" >/dev/null 2>&1 &
|
||||||
|
}
|
||||||
|
|
||||||
|
is_junk() {
|
||||||
|
case "${1,,}" in
|
||||||
|
thumbs.db|desktop.ini|.ds_store|*.tmp|~\$*|~*.tmp) return 0 ;;
|
||||||
|
__pycache__|*.pyc|*.pyo) return 0 ;;
|
||||||
|
.git|.venv|.env|node_modules|.idea|.vscode) return 0 ;;
|
||||||
|
*) return 1 ;;
|
||||||
|
esac
|
||||||
|
}
|
||||||
|
|
||||||
|
# Filtrar paths que contengan directorios basura
|
||||||
|
is_junk_path() {
|
||||||
|
case "$1" in
|
||||||
|
*/__pycache__/*|*/.git/*|*/.venv/*|*/node_modules/*|*/.idea/*|*/.vscode/*) return 0 ;;
|
||||||
|
*) return 1 ;;
|
||||||
|
esac
|
||||||
|
}
|
||||||
|
|
||||||
|
file_icon() {
|
||||||
|
case "${1,,}" in
|
||||||
|
*.py) echo "🐍" ;;
|
||||||
|
*.zip|*.rar|*.tar*|*.gz|*.bz2|*.7z) echo "📦" ;;
|
||||||
|
*.md) echo "📝" ;;
|
||||||
|
*.txt) echo "📄" ;;
|
||||||
|
*.pdf) echo "📕" ;;
|
||||||
|
*.docx|*.doc) echo "📘" ;;
|
||||||
|
*.png|*.jpg|*.jpeg|*.gif) echo "🖼️" ;;
|
||||||
|
*) echo "📎" ;;
|
||||||
|
esac
|
||||||
|
}
|
||||||
|
|
||||||
|
batch_key() {
|
||||||
|
echo "${1}_${2}" | tr '/ ' '__'
|
||||||
|
}
|
||||||
|
|
||||||
|
flush_batch() {
|
||||||
|
local batchfile="$1"
|
||||||
|
[[ ! -f "$batchfile" ]] && return
|
||||||
|
|
||||||
|
local user dir tag file_count file_list label msg
|
||||||
|
user=$(sed -n '1p' "$batchfile")
|
||||||
|
dir=$(sed -n '2p' "$batchfile")
|
||||||
|
tag=$(sed -n '3p' "$batchfile")
|
||||||
|
file_count=$(tail -n +4 "$batchfile" | wc -l)
|
||||||
|
|
||||||
|
[[ "$file_count" -eq 0 ]] && { rm -f "$batchfile"; return; }
|
||||||
|
|
||||||
|
file_list=$(tail -n +4 "$batchfile")
|
||||||
|
label="Entrega"
|
||||||
|
[[ "$tag" == "re-entrega" ]] && label="♻️ Re-entrega"
|
||||||
|
|
||||||
|
local display_name
|
||||||
|
display_name=$(fullname "$user")
|
||||||
|
msg="📁 [$display_name] $label ASIR1: $dir/ ($file_count ficheros)
|
||||||
|
$file_list"
|
||||||
|
|
||||||
|
log "[$user] BATCH FLUSH ($tag): $dir/ → $file_count ficheros"
|
||||||
|
notify_xmpp "$msg"
|
||||||
|
rm -f "$batchfile"
|
||||||
|
}
|
||||||
|
|
||||||
|
flush_daemon() {
|
||||||
|
while true; do
|
||||||
|
sleep 3
|
||||||
|
for batchfile in "$BATCH_DIR"/*.batch; do
|
||||||
|
[[ ! -f "$batchfile" ]] && continue
|
||||||
|
local last_mod now age
|
||||||
|
last_mod=$(stat -c%Y "$batchfile" 2>/dev/null) || continue
|
||||||
|
now=$(date +%s)
|
||||||
|
age=$(( now - last_mod ))
|
||||||
|
(( age >= QUIET_SECONDS )) && flush_batch "$batchfile"
|
||||||
|
done
|
||||||
|
done
|
||||||
|
}
|
||||||
|
|
||||||
|
flush_daemon &
|
||||||
|
FLUSH_PID=$!
|
||||||
|
trap "kill $FLUSH_PID 2>/dev/null" EXIT
|
||||||
|
|
||||||
|
log "=== Python Upload Watcher v7 iniciado ==="
|
||||||
|
notify_xmpp "🚀 [zzz] Python Upload Watcher v7 iniciado (ASIR1)"
|
||||||
|
|
||||||
|
# ---------------------------------------------------------
|
||||||
|
# Bucle principal — sin 'local', todo variables globales
|
||||||
|
# ---------------------------------------------------------
|
||||||
|
inotifywait -m -r \
|
||||||
|
-e close_write -e moved_to -e create -e delete -e moved_from \
|
||||||
|
--format "%e %w%f" "$WATCH_DIR" 2>/dev/null | \
|
||||||
|
while IFS= read -r line; do
|
||||||
|
|
||||||
|
_event="${line%% /*}"
|
||||||
|
_filepath="/${line#* /}"
|
||||||
|
|
||||||
|
[[ ! "$_filepath" =~ ^/home/([^/]+)/python/(.+)$ ]] && continue
|
||||||
|
|
||||||
|
_user="${BASH_REMATCH[1]}"
|
||||||
|
_relpath="${BASH_REMATCH[2]}"
|
||||||
|
_filename=$(basename "$_relpath")
|
||||||
|
|
||||||
|
is_junk "$_filename" && continue
|
||||||
|
is_junk_path "$_relpath" && continue
|
||||||
|
|
||||||
|
# --- DELETE / MOVED_FROM ---
|
||||||
|
if [[ "$_event" == *DELETE* || "$_event" == *MOVED_FROM* ]]; then
|
||||||
|
if [[ "$_relpath" != */* ]]; then
|
||||||
|
_bk=$(batch_key "$_user" "$_relpath")
|
||||||
|
echo "$(date +%s)" > "$DELETE_DIR/$_bk"
|
||||||
|
rm -f "$BATCH_DIR/${_bk}.batch"
|
||||||
|
log "[$_user] BORRADA: $_relpath/"
|
||||||
|
fi
|
||||||
|
continue
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- CREATE directorio ---
|
||||||
|
if [[ "$_event" == *CREATE* && -d "$_filepath" ]]; then
|
||||||
|
# Solo carpetas de primer nivel bajo python/
|
||||||
|
if [[ "$_relpath" != */* ]]; then
|
||||||
|
_bk=$(batch_key "$_user" "$_relpath")
|
||||||
|
_tag="new"
|
||||||
|
|
||||||
|
if [[ -f "$DELETE_DIR/$_bk" ]]; then
|
||||||
|
_del_ts=$(cat "$DELETE_DIR/$_bk")
|
||||||
|
_now=$(date +%s)
|
||||||
|
(( _now - _del_ts < 120 )) && _tag="re-entrega"
|
||||||
|
rm -f "$DELETE_DIR/$_bk"
|
||||||
|
fi
|
||||||
|
|
||||||
|
printf '%s\n%s\n%s\n' "$(fullname "$_user")" "$_relpath" "$_tag" > "$BATCH_DIR/${_bk}.batch"
|
||||||
|
log "[$_user] CARPETA ($_tag): $_relpath/ — batch abierto en $BATCH_DIR/${_bk}.batch"
|
||||||
|
fi
|
||||||
|
continue
|
||||||
|
fi
|
||||||
|
|
||||||
|
# --- CREATE fichero → skip (close_write viene después) ---
|
||||||
|
[[ "$_event" == *CREATE* ]] && continue
|
||||||
|
|
||||||
|
# --- close_write / moved_to → fichero completado ---
|
||||||
|
_size=$(stat -c%s "$_filepath" 2>/dev/null || echo "?")
|
||||||
|
_icon=$(file_icon "$_filename")
|
||||||
|
|
||||||
|
if [[ "$_relpath" == */* ]]; then
|
||||||
|
_topdir="${_relpath%%/*}"
|
||||||
|
_bk=$(batch_key "$_user" "$_topdir")
|
||||||
|
_batchfile="$BATCH_DIR/${_bk}.batch"
|
||||||
|
|
||||||
|
if [[ -f "$_batchfile" ]]; then
|
||||||
|
_subpath="${_relpath#*/}"
|
||||||
|
echo " $_icon $_subpath ($_size bytes)" >> "$_batchfile"
|
||||||
|
log "[$_user] +BATCH: $_relpath ($_size bytes)"
|
||||||
|
continue
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Sin batch → individual
|
||||||
|
log "[$_user] Subido: $_relpath ($_size bytes)"
|
||||||
|
notify_xmpp "$_icon [$(fullname "$_user")] Entrega ASIR1: $_relpath ($_size bytes)"
|
||||||
|
else
|
||||||
|
log "[$_user] Subido: $_relpath ($_size bytes)"
|
||||||
|
notify_xmpp "$_icon [$(fullname "$_user")] Entrega ASIR1: $_relpath ($_size bytes)"
|
||||||
|
fi
|
||||||
|
|
||||||
|
done
|
||||||
|
|
@ -0,0 +1,33 @@
|
||||||
|
#!/usr/bin/env python3
|
||||||
|
"""
|
||||||
|
Notificador XMPP one-shot para zzz.qu3v3d0.tech
|
||||||
|
Uso: xmpp-notify.py "mensaje"
|
||||||
|
"""
|
||||||
|
import sys
|
||||||
|
import slixmpp
|
||||||
|
import asyncio
|
||||||
|
import logging
|
||||||
|
|
||||||
|
logging.basicConfig(level=logging.WARNING)
|
||||||
|
|
||||||
|
class NotifyBot(slixmpp.ClientXMPP):
|
||||||
|
def __init__(self, msg):
|
||||||
|
super().__init__("zzz@librebits.info", "zzz2025")
|
||||||
|
self.msg = msg
|
||||||
|
self.add_event_handler("session_start", self.start)
|
||||||
|
|
||||||
|
async def start(self, event):
|
||||||
|
self.send_message(mto="jla@librebits.info", mbody=self.msg, mtype="chat")
|
||||||
|
await asyncio.sleep(0.5)
|
||||||
|
self.disconnect()
|
||||||
|
|
||||||
|
async def main(msg):
|
||||||
|
bot = NotifyBot(msg)
|
||||||
|
bot.connect()
|
||||||
|
await asyncio.sleep(8)
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
if len(sys.argv) < 2:
|
||||||
|
print("Uso: xmpp-notify.py \"mensaje\"")
|
||||||
|
sys.exit(1)
|
||||||
|
asyncio.run(main(sys.argv[1]))
|
||||||
Loading…
Reference in New Issue