diff --git a/.env.example b/.env.example
index 56378a1..f62805c 100644
--- a/.env.example
+++ b/.env.example
@@ -12,6 +12,7 @@ DATA_DIR=/app/data
# ─── رفتار ───
ROLLBACK_MINUTES=15
+TEST_ROLLBACK_MINUTES=2
AUTO_TEST_INTERVAL_MINUTES=30
FLASK_ENV=production
diff --git a/README.md b/README.md
index 5a6ae54..2c275fe 100644
--- a/README.md
+++ b/README.md
@@ -99,14 +99,21 @@ echo 'export PYTHONPATH=/opt/mirror-manager' | sudo tee /etc/profile.d/mirror-ma
1. به **https://mirror.itistan.ir** بروید
2. با `ADMIN_USERNAME` / `ADMIN_PASSWORD` وارد شوید
3. در **اولین ورود** backup اولیه خودکار گرفته میشود
-4. یک **پروفایل** انتخاب و **اعمال** کنید
-5. در پنجره rollback تست کنید → **تأیید** یا **rollback**
+4. یک **پروفایل** انتخاب کنید → **تست موقت (۲ دقیقه)** بزنید
+5. Dokploy و deploy را تست کنید → **اعمال نهایی** (نگهداشتن تغییرات)
+6. اگر مشکل پیش آمد: `mirror-manager emergency-restore` از SSH
---
## CLI (از SSH)
```bash
+# بازگردانی فوری — آخرین backup قبل از apply (توصیه در emergency)
+mirror-manager emergency-restore
+
+# یا معادل:
+mirror-manager restore --last
+
# بازگردانی تنظیمات اولیه (قبل از نصب Mirror Manager)
mirror-manager restore --initial
diff --git a/app/__init__.py b/app/__init__.py
index 2bba85c..d50a9fe 100644
--- a/app/__init__.py
+++ b/app/__init__.py
@@ -13,8 +13,12 @@ from app.routes.main import main_bp
from app.routes.mirrors import mirrors_bp
from app.routes.profiles import profiles_bp
from app.seed import seed_all
-from app.services.applier import ensure_initial_backup, restore_initial
-from app.services.backup import restore_backup
+from app.services.applier import (
+ ensure_initial_backup,
+ emergency_restore_last_apply,
+ restore_initial,
+)
+from app.services.backup import get_latest_apply_backup, restore_backup
from app.services.scheduler import init_scheduler
@@ -87,17 +91,29 @@ def cli():
@cli.command()
@click.option("--initial", is_flag=True, help="بازگردانی تنظیمات اولیه")
+@click.option("--last", is_flag=True, help="آخرین backup قبل از apply")
@click.option("--backup", default=None, help="مسیر backup مشخص")
-def restore(initial, backup):
+def restore(initial, backup, last):
os.environ["DISABLE_SCHEDULER"] = "1"
+ if not os.environ.get("HOST_ROOT"):
+ os.environ.setdefault("HOST_ROOT", "/")
+ if not os.environ.get("DATA_DIR"):
+ os.environ.setdefault("DATA_DIR", "/var/lib/mirror-manager/data")
app = create_app()
with app.app_context():
if initial:
result = restore_initial()
+ elif last:
+ path = get_latest_apply_backup()
+ if not path:
+ click.echo("backup قبل از apply یافت نشد.")
+ return
+ click.echo(f"بازگردانی از: {path}")
+ result = restore_backup(path)
elif backup:
result = restore_backup(backup)
else:
- click.echo("یکی از --initial یا --backup را مشخص کنید.")
+ click.echo("یکی از --initial، --last یا --backup را مشخص کنید.")
return
if result.get("success"):
click.echo("بازگردانی موفق:")
@@ -107,6 +123,25 @@ def restore(initial, backup):
click.echo(f"خطا: {result.get('error')}")
+@cli.command("emergency-restore")
+def emergency_restore_cmd():
+ """بازگردانی فوری آخرین backup قبل از apply — یک دستور"""
+ os.environ["DISABLE_SCHEDULER"] = "1"
+ if not os.environ.get("HOST_ROOT"):
+ os.environ.setdefault("HOST_ROOT", "/")
+ if not os.environ.get("DATA_DIR"):
+ os.environ.setdefault("DATA_DIR", "/var/lib/mirror-manager/data")
+ app = create_app()
+ with app.app_context():
+ result = emergency_restore_last_apply()
+ if result.get("success"):
+ click.echo(f"بازگردانی فوری موفق از: {result.get('backup_path', '')}")
+ for item in result.get("restored", []):
+ click.echo(f" - {item}")
+ else:
+ click.echo(f"خطا: {result.get('error')}")
+
+
@cli.command()
def disable():
container = os.environ.get("MIRROR_CONTAINER_NAME", "mirror-manager")
diff --git a/app/config.py b/app/config.py
index 9846f44..32ab008 100644
--- a/app/config.py
+++ b/app/config.py
@@ -18,6 +18,7 @@ class Config:
HOST_ROOT = os.environ.get("HOST_ROOT", "")
ROLLBACK_MINUTES = int(os.environ.get("ROLLBACK_MINUTES", "15"))
+ TEST_ROLLBACK_MINUTES = int(os.environ.get("TEST_ROLLBACK_MINUTES", "2"))
AUTO_TEST_INTERVAL_MINUTES = int(os.environ.get("AUTO_TEST_INTERVAL_MINUTES", "30"))
RESOLVED_DROPIN = "mirror-manager.conf"
diff --git a/app/guides.py b/app/guides.py
index 4f0bd85..e0f6ccc 100644
--- a/app/guides.py
+++ b/app/guides.py
@@ -71,7 +71,8 @@ GUIDES = {
هشدار
-با restart Docker، containerها (از جمله Dokploy) چند ثانیه قطع میشوند. بهتر است در ساعات کمترافیک apply کنید.
+با restart Docker، containerها (از جمله Dokploy) چند ثانیه قطع میشوند. همیشه ابتدا «تست موقت» را بزنید.
+فقط کلیدهای رسمی Docker در daemon.json نوشته میشوند — کلیدهای نامعتبر باعث crash شدن Docker نمیشوند.
میرور پیشفرض
@@ -131,6 +132,16 @@ GUIDES = {
پروفایل چیست؟
مجموعهای از میرورها برای DNS، APT، Docker، GitHub و... که با یک کلیک apply میشوند.
+اعمال امن (توصیهشده)
+
+تست موقت (۲ دقیقه): پروفایل اعمال میشود. اگر تأیید نکنید، خودکار rollback.سرویسها (Dokploy، mirror، deploy) را تست کنید.
+اعمال نهایی: از صفحه وضعیت تست، دکمه «نگهداشتن تغییرات» را بزنید.
+
+بازگردانی فوری
+اگر دسترسی قطع شد: mirror-manager emergency-restore از SSH — یا دکمه «بازگردانی فوری» در بخش Restore.
+
پروفایلهای پیشفرض
آروان کامل: Shecan + Arvan APT/Docker + GitClone
Rollback
-بعد از apply، پنجره زمانی (پیشفرض ۱۵ دقیقه) برای تست دارید. اگر تأیید نکنید، تنظیمات قبلی بازگردانده میشود.
+تست موقت پیشفرض ۲ دقیقه است. اعمال نهایی بدون پنجره rollback — فقط بعد از تست موفق.
""",
},
"settings": {
@@ -163,15 +174,20 @@ GUIDES = {
Backup اولیه
در اولین اجرا، snapshot از تنظیمات فعلی سیستم گرفته میشود.
+بازگردانی فوری (Emergency)
+یک دستور / یک دکمه — برگشت به آخرین backup قبل از apply (DNS، APT، Docker، ...).
+
بازگردانی
+emergency-restore: آخرین backup قبل از apply — سریعترین راهتنظیمات اولیه: برگشت به وضعیت قبل از نصب Mirror Managerbackup apply: برگشت به وضعیت قبل از آخرین applybackup apply: برگشت به backup مشخص
از SSH
- mirror-manager restore --initial
-mirror-manager restore --backup /path/to/backup
+mirror-manager emergency-restore
+mirror-manager restore --initial
+mirror-manager restore --last
mirror-manager disable
mirror-manager enable
""",
diff --git a/app/routes/__init__.py b/app/routes/__init__.py
index e69de29..8b13789 100644
--- a/app/routes/__init__.py
+++ b/app/routes/__init__.py
@@ -0,0 +1 @@
+
diff --git a/app/routes/apply.py b/app/routes/apply.py
index 22b7d6f..93b91ac 100644
--- a/app/routes/apply.py
+++ b/app/routes/apply.py
@@ -1,12 +1,19 @@
from flask import Blueprint, flash, jsonify, redirect, render_template, request, url_for
from flask_login import login_required
-from app.extensions import db
from app.guides import GUIDES
from app.models import ApplyLog, Profile, Setting, SystemState
from app.models import utcnow
-from app.services.applier import apply_profile, confirm_apply, get_system_status, restore_initial, rollback_apply
-from app.services.backup import list_backups, restore_backup
+from app.services.applier import (
+ APPLY_MODE_FINAL,
+ APPLY_MODE_TEST,
+ apply_profile,
+ confirm_apply,
+ emergency_restore_last_apply,
+ restore_initial,
+ rollback_apply,
+)
+from app.services.backup import get_latest_apply_backup, list_backups, restore_backup
apply_bp = Blueprint("apply", __name__, url_prefix="/apply")
@@ -20,33 +27,52 @@ def index():
if state and state.pending_apply_log_id:
pending = ApplyLog.query.get(state.pending_apply_log_id)
+ test_minutes = int(Setting.get("test_rollback_minutes", "2") or "2")
recent_logs = ApplyLog.query.order_by(ApplyLog.started_at.desc()).limit(10).all()
return render_template(
"apply/index.html",
profiles=profiles,
pending=pending,
recent_logs=recent_logs,
+ test_minutes=test_minutes,
guide=GUIDES.get("profiles", {}),
)
-@apply_bp.route("/profile/", methods=["POST"])
-@login_required
-def apply(profile_id):
+def _handle_apply(profile_id: int, mode: str):
profile = Profile.query.get_or_404(profile_id)
- rollback_minutes = int(request.form.get("rollback_minutes", Setting.get("rollback_minutes", "15") or "15"))
+ state = SystemState.query.first()
+ if state and state.pending_apply_log_id:
+ flash("یک تست در انتظار تأیید است. ابتدا آن را تأیید یا rollback کنید.", "warning")
+ return redirect(url_for("apply.status", log_id=state.pending_apply_log_id))
- log = apply_profile(profile, rollback_minutes=rollback_minutes)
+ log = apply_profile(profile, mode=mode)
if log.status == "failed":
- flash("اعمال پروفایل با خطا مواجه شد. جزئیات را بررسی کنید.", "danger")
+ flash("اعمال پروفایل با خطا مواجه شد. تنظیمات قبلی خودکار بازگردانده شد.", "danger")
+ elif mode == APPLY_MODE_FINAL:
+ flash("پروفایل بهصورت نهایی اعمال و ثبت شد.", "success")
+ return redirect(url_for("main.dashboard"))
else:
+ test_minutes = log.get_details().get("rollback_minutes", 2)
flash(
- f"پروفایل اعمال شد. {rollback_minutes} دقیقه برای تست دارید — سپس rollback خودکار انجام میشود.",
+ f"تست موقت اعمال شد. {test_minutes} دقیقه برای بررسی دارید — در صورت عدم تأیید، rollback خودکار انجام میشود.",
"warning",
)
return redirect(url_for("apply.status", log_id=log.id))
+@apply_bp.route("/profile//test", methods=["POST"])
+@login_required
+def apply_test(profile_id):
+ return _handle_apply(profile_id, APPLY_MODE_TEST)
+
+
+@apply_bp.route("/profile//final", methods=["POST"])
+@login_required
+def apply_final(profile_id):
+ return _handle_apply(profile_id, APPLY_MODE_FINAL)
+
+
@apply_bp.route("/status/")
@login_required
def status(log_id):
@@ -60,6 +86,7 @@ def status(log_id):
log=log,
details=details,
remaining_seconds=remaining_seconds,
+ apply_mode=details.get("mode", APPLY_MODE_TEST),
)
@@ -67,7 +94,7 @@ def status(log_id):
@login_required
def confirm(log_id):
confirm_apply(log_id)
- flash("تغییرات تأیید و ثبت شد.", "success")
+ flash("تست موفق بود — تغییرات بهصورت نهایی ثبت شد.", "success")
return redirect(url_for("main.dashboard"))
@@ -106,14 +133,27 @@ restore_bp = Blueprint("restore", __name__, url_prefix="/restore")
def index():
backups = list_backups()
state = SystemState.query.first()
+ latest_apply = get_latest_apply_backup()
return render_template(
"restore/index.html",
backups=backups,
state=state,
+ latest_apply_backup=str(latest_apply) if latest_apply else None,
guide=GUIDES.get("restore", {}),
)
+@restore_bp.route("/emergency", methods=["POST"])
+@login_required
+def emergency_restore_view():
+ result = emergency_restore_last_apply()
+ if result.get("success"):
+ flash(f"بازگردانی فوری انجام شد از: {result.get('backup_path', '')}", "success")
+ else:
+ flash(result.get("error", "خطا در بازگردانی"), "danger")
+ return redirect(url_for("restore.index"))
+
+
@restore_bp.route("/initial", methods=["POST"])
@login_required
def restore_initial_view():
@@ -158,6 +198,7 @@ def index():
Setting.set(key, "true" if request.form.get(key) == "on" else "false")
Setting.set("rollback_minutes", request.form.get("rollback_minutes", "15"))
+ Setting.set("test_rollback_minutes", request.form.get("test_rollback_minutes", "2"))
Setting.set("auto_test_interval_minutes", request.form.get("auto_test_interval_minutes", "30"))
Setting.set("max_switches_per_day", request.form.get("max_switches_per_day", "3"))
Setting.set(
@@ -170,7 +211,7 @@ def index():
settings = {key: Setting.get(key) for key in (
"auto_switch_dns", "auto_switch_apt", "auto_switch_docker",
"auto_switch_github", "auto_switch_pip", "auto_switch_npm",
- "rollback_minutes", "auto_test_interval_minutes",
+ "rollback_minutes", "test_rollback_minutes", "auto_test_interval_minutes",
"max_switches_per_day", "rollback_on_all_fail",
)}
return render_template("settings/index.html", settings=settings, guide=GUIDES.get("settings", {}))
diff --git a/app/seed.py b/app/seed.py
index 875e6f4..757f5de 100644
--- a/app/seed.py
+++ b/app/seed.py
@@ -203,6 +203,7 @@ def seed_settings() -> None:
"auto_test_interval_minutes": "30",
"max_switches_per_day": "3",
"rollback_minutes": "15",
+ "test_rollback_minutes": "2",
"rollback_on_all_fail": "true",
}
from app.models import Setting
diff --git a/app/services/__init__.py b/app/services/__init__.py
index e69de29..8b13789 100644
--- a/app/services/__init__.py
+++ b/app/services/__init__.py
@@ -0,0 +1 @@
+
diff --git a/app/services/applier.py b/app/services/applier.py
index aa142f8..ba3db81 100644
--- a/app/services/applier.py
+++ b/app/services/applier.py
@@ -2,11 +2,10 @@ from __future__ import annotations
import logging
from datetime import timedelta
-from pathlib import Path
from app.config import Config
from app.extensions import db
-from app.models import ApplyLog, Profile, SystemState
+from app.models import ApplyLog, Profile, Setting, SystemState
from app.models import utcnow
from app.services import apt, backup, dns, docker_svc, github, pip_npm
from app.services.host import run_on_host
@@ -22,6 +21,9 @@ APPLIERS = {
"npm": pip_npm.apply_npm,
}
+APPLY_MODE_TEST = "test"
+APPLY_MODE_FINAL = "final"
+
def ensure_initial_backup() -> SystemState:
state = SystemState.query.first()
@@ -40,9 +42,22 @@ def ensure_initial_backup() -> SystemState:
return state
-def apply_profile(profile: Profile, rollback_minutes: int | None = None) -> ApplyLog:
+def _rollback_minutes_for_mode(mode: str, rollback_minutes: int | None) -> int | None:
+ if mode == APPLY_MODE_FINAL:
+ return None
+ if rollback_minutes is not None:
+ return rollback_minutes
+ default = Setting.get("test_rollback_minutes", str(Config.TEST_ROLLBACK_MINUTES))
+ return int(default or Config.TEST_ROLLBACK_MINUTES)
+
+
+def apply_profile(
+ profile: Profile,
+ mode: str = APPLY_MODE_TEST,
+ rollback_minutes: int | None = None,
+) -> ApplyLog:
state = ensure_initial_backup()
- rollback_minutes = rollback_minutes or int(Config.ROLLBACK_MINUTES)
+ rollback_minutes = _rollback_minutes_for_mode(mode, rollback_minutes)
previous_backup = backup.create_backup(f"before_apply_{profile.id}")
apply_log = ApplyLog(
@@ -50,12 +65,17 @@ def apply_profile(profile: Profile, rollback_minutes: int | None = None) -> Appl
status="running",
backup_path=str(previous_backup),
previous_backup_path=state.initial_backup_path,
- rollback_at=utcnow() + timedelta(minutes=rollback_minutes),
+ rollback_at=utcnow() + timedelta(minutes=rollback_minutes) if rollback_minutes else None,
)
db.session.add(apply_log)
db.session.flush()
- details: dict = {"steps": [], "profile": profile.name}
+ details: dict = {
+ "steps": [],
+ "profile": profile.name,
+ "mode": mode,
+ "rollback_minutes": rollback_minutes,
+ }
mirrors = profile.mirrors_by_category()
order = ["dns", "apt", "docker", "github", "pip", "npm"]
@@ -69,11 +89,14 @@ def apply_profile(profile: Profile, rollback_minutes: int | None = None) -> Appl
try:
result = applier(mirror)
details["steps"].append({"category": category, "mirror": mirror.name, **result})
+ if not result.get("success", True):
+ break
except Exception as exc:
logger.exception("Apply failed for %s", category)
details["steps"].append(
{"category": category, "mirror": mirror.name, "success": False, "error": str(exc)}
)
+ break
failed = [s for s in details["steps"] if not s.get("success", True)]
if failed and apply_log.backup_path:
@@ -81,11 +104,22 @@ def apply_profile(profile: Profile, rollback_minutes: int | None = None) -> Appl
details["auto_rollback"] = rollback_result
apply_log.set_details(details)
- apply_log.status = "failed" if failed else "pending_confirm"
apply_log.finished_at = utcnow()
- state.current_profile_id = profile.id if not failed else state.current_profile_id
- state.pending_apply_log_id = apply_log.id if not failed else None
+ if failed:
+ apply_log.status = "failed"
+ apply_log.rollback_at = None
+ elif mode == APPLY_MODE_FINAL:
+ apply_log.confirmed = True
+ apply_log.status = "confirmed"
+ apply_log.rollback_at = None
+ state.current_profile_id = profile.id
+ state.pending_apply_log_id = None
+ else:
+ apply_log.status = "pending_confirm"
+ state.current_profile_id = profile.id
+ state.pending_apply_log_id = apply_log.id
+
db.session.commit()
return apply_log
@@ -97,9 +131,15 @@ def confirm_apply(apply_log_id: int) -> ApplyLog:
apply_log.status = "confirmed"
apply_log.rollback_at = None
+ details = apply_log.get_details()
+ details["confirmed_from"] = APPLY_MODE_TEST
+ apply_log.set_details(details)
+
state = SystemState.query.first()
if state:
state.pending_apply_log_id = None
+ if apply_log.profile_id:
+ state.current_profile_id = apply_log.profile_id
db.session.commit()
return apply_log
@@ -112,6 +152,7 @@ def rollback_apply(apply_log_id: int) -> dict:
result = backup.restore_backup(apply_log.backup_path)
apply_log.status = "rolled_back"
apply_log.finished_at = utcnow()
+ apply_log.rollback_at = None
state = SystemState.query.first()
if state:
@@ -120,6 +161,28 @@ def rollback_apply(apply_log_id: int) -> dict:
return result
+def emergency_restore_last_apply() -> dict:
+ """One-shot restore of the most recent pre-apply backup."""
+ path = backup.get_latest_apply_backup()
+ if not path:
+ return {"success": False, "error": "backup قبل از apply یافت نشد"}
+ result = backup.restore_backup(path)
+ if result.get("success"):
+ result["backup_path"] = str(path)
+
+ state = SystemState.query.first()
+ pending_id = state.pending_apply_log_id if state else None
+ if pending_id:
+ log = ApplyLog.query.get(pending_id)
+ if log and log.status == "pending_confirm":
+ log.status = "rolled_back"
+ log.finished_at = utcnow()
+ log.rollback_at = None
+ state.pending_apply_log_id = None
+ db.session.commit()
+ return result
+
+
def restore_initial() -> dict:
state = SystemState.query.first()
if not state or not state.initial_backup_path:
diff --git a/app/services/backup.py b/app/services/backup.py
index b2cfa82..644db6e 100644
--- a/app/services/backup.py
+++ b/app/services/backup.py
@@ -7,6 +7,7 @@ from datetime import datetime
from pathlib import Path
from app.config import Config
+from app.services.docker_svc import sanitize_daemon_json_file
from app.services.host import host_path, run_on_host
logger = logging.getLogger(__name__)
@@ -147,12 +148,37 @@ def restore_backup(backup_root: Path | str) -> dict:
elif dropin.exists():
dropin.unlink()
+ daemon_path = host_path("etc/docker/daemon.json")
+ if sanitize_daemon_json_file(daemon_path):
+ results.append("پاکسازی کلیدهای نامعتبر daemon.json")
+
run_on_host(["systemctl", "restart", "systemd-resolved"])
- run_on_host(["systemctl", "restart", "docker"])
+ docker_result = run_on_host(["systemctl", "restart", "docker"], timeout=120)
+ if docker_result.returncode != 0:
+ return {
+ "success": False,
+ "error": (docker_result.stderr or "خطا در restart docker")[:500],
+ "restored": results,
+ }
return {"success": True, "restored": results}
+def get_latest_apply_backup() -> Path | None:
+ """Return the most recent before_apply backup directory, if any."""
+ if not Config.BACKUP_DIR.exists():
+ return None
+ candidates = sorted(
+ (
+ p
+ for p in Config.BACKUP_DIR.iterdir()
+ if p.is_dir() and "before_apply" in p.name
+ ),
+ reverse=True,
+ )
+ return candidates[0] if candidates else None
+
+
def create_initial_backup() -> Path:
return create_backup("initial")
diff --git a/app/services/docker_svc.py b/app/services/docker_svc.py
index c11e645..7ec62ba 100644
--- a/app/services/docker_svc.py
+++ b/app/services/docker_svc.py
@@ -1,57 +1,107 @@
-from __future__ import annotations
-
-import json
-import logging
-from pathlib import Path
-
-from app.models import Mirror
-from app.services.host import host_path, run_on_host
-
-logger = logging.getLogger(__name__)
-
-DAEMON_JSON = "etc/docker/daemon.json"
-MIRROR_MANAGER_KEY = "mirror-manager"
-
-
-def read_current_docker() -> dict:
- path = host_path(DAEMON_JSON)
- if not path.exists():
- return {"exists": False, "config": {}}
- try:
- return {"exists": True, "config": json.loads(path.read_text(encoding="utf-8"))}
- except json.JSONDecodeError:
- return {"exists": True, "config": {}, "parse_error": True}
-
-
-def apply_docker(mirror: Mirror) -> dict:
- if not mirror.url:
- return {"success": False, "error": "URL رجیstry داکر تعریف نشده"}
-
- path = host_path(DAEMON_JSON)
- path.parent.mkdir(parents=True, exist_ok=True)
-
- config: dict = {}
- if path.exists():
- try:
- config = json.loads(path.read_text(encoding="utf-8"))
- except json.JSONDecodeError:
- config = {}
-
- config["registry-mirrors"] = [mirror.url.rstrip("/")]
- config["_mirror_manager"] = MIRROR_MANAGER_KEY
-
- path.write_text(json.dumps(config, indent=2, ensure_ascii=False), encoding="utf-8")
-
- result = run_on_host(["systemctl", "restart", "docker"], timeout=120)
- if result.returncode != 0:
- return {
- "success": False,
- "error": (result.stderr or "خطا در restart docker")[:500],
- }
-
- return {
- "success": True,
- "message": f"Docker registry mirror اعمال شد: {mirror.name}",
- "url": mirror.url,
- "warning": "سرویس Docker restart شد — containerها موقتاً قطع میشوند",
- }
+from __future__ import annotations
+
+import json
+import logging
+from pathlib import Path
+
+from app.models import Mirror
+from app.services.host import host_path, run_on_host
+
+logger = logging.getLogger(__name__)
+
+DAEMON_JSON = "etc/docker/daemon.json"
+INVALID_DAEMON_KEYS = ("_mirror_manager",)
+
+
+def sanitize_daemon_config(config: dict) -> dict:
+ """Remove keys that Docker daemon does not accept."""
+ for key in INVALID_DAEMON_KEYS:
+ config.pop(key, None)
+ return config
+
+
+def sanitize_daemon_json_file(path: Path | None = None) -> bool:
+ """Strip invalid keys from daemon.json on disk. Returns True if file was modified."""
+ path = path or host_path(DAEMON_JSON)
+ if not path.exists():
+ return False
+ try:
+ config = json.loads(path.read_text(encoding="utf-8"))
+ except json.JSONDecodeError:
+ return False
+ cleaned = sanitize_daemon_config(dict(config))
+ if cleaned == config:
+ return False
+ path.write_text(json.dumps(cleaned, indent=2, ensure_ascii=False), encoding="utf-8")
+ return True
+
+
+def verify_docker_running() -> dict:
+ active = run_on_host(["systemctl", "is-active", "docker"], timeout=30)
+ if active.returncode != 0:
+ return {
+ "success": False,
+ "error": "Docker بعد از restart بالا نیامد — تنظیمات daemon.json را بررسی کنید",
+ }
+ info = run_on_host(["docker", "info"], timeout=30)
+ if info.returncode != 0:
+ return {
+ "success": False,
+ "error": (info.stderr or info.stdout or "docker info ناموفق")[:500],
+ }
+ return {"success": True}
+
+
+def read_current_docker() -> dict:
+ path = host_path(DAEMON_JSON)
+ if not path.exists():
+ return {"exists": False, "config": {}}
+ try:
+ config = json.loads(path.read_text(encoding="utf-8"))
+ has_invalid = any(key in config for key in INVALID_DAEMON_KEYS)
+ return {
+ "exists": True,
+ "config": config,
+ "has_invalid_keys": has_invalid,
+ }
+ except json.JSONDecodeError:
+ return {"exists": True, "config": {}, "parse_error": True}
+
+
+def apply_docker(mirror: Mirror) -> dict:
+ if not mirror.url:
+ return {"success": False, "error": "URL رجیstry داکر تعریف نشده"}
+
+ path = host_path(DAEMON_JSON)
+ path.parent.mkdir(parents=True, exist_ok=True)
+
+ config: dict = {}
+ if path.exists():
+ try:
+ config = json.loads(path.read_text(encoding="utf-8"))
+ except json.JSONDecodeError:
+ config = {}
+
+ config = sanitize_daemon_config(config)
+ config["registry-mirrors"] = [mirror.url.rstrip("/")]
+
+ path.write_text(json.dumps(config, indent=2, ensure_ascii=False), encoding="utf-8")
+
+ result = run_on_host(["systemctl", "restart", "docker"], timeout=120)
+ if result.returncode != 0:
+ return {
+ "success": False,
+ "error": (result.stderr or result.stdout or "خطا در restart docker")[:500],
+ }
+
+ health = verify_docker_running()
+ if not health.get("success"):
+ return health
+
+ return {
+ "success": True,
+ "message": f"Docker registry mirror اعمال شد: {mirror.name}",
+ "url": mirror.url,
+ "warning": "سرویس Docker restart شد — containerها موقتاً قطع میشوند",
+ }
+
\ No newline at end of file
diff --git a/app/services/scheduler.py b/app/services/scheduler.py
index 13f28f0..cffa537 100644
--- a/app/services/scheduler.py
+++ b/app/services/scheduler.py
@@ -6,7 +6,7 @@ from datetime import datetime, timezone
from app.extensions import db
from app.models import ApplyLog, Mirror, Profile, ProfileItem, Setting, SystemState
from app.models import utcnow
-from app.services.applier import apply_profile, rollback_apply
+from app.services.applier import APPLY_MODE_FINAL, apply_profile, rollback_apply
from app.services.tester import get_best_mirror, test_mirror
logger = logging.getLogger(__name__)
@@ -78,7 +78,7 @@ def run_auto_switch(app) -> None:
item.mirror_id = best.id
db.session.commit()
- apply_profile(profile)
+ apply_profile(profile, mode=APPLY_MODE_FINAL)
_increment_switch_count()
logger.info("Auto-switched %s to %s", category, best.name)
break
diff --git a/app/templates/apply/index.html b/app/templates/apply/index.html
index eb6b6b0..56d1d21 100644
--- a/app/templates/apply/index.html
+++ b/app/templates/apply/index.html
@@ -1,53 +1,75 @@
-{% extends "base.html" %}
-{% from "macros.html" import guide_box %}
-{% block title %}اعمال تنظیمات{% endblock %}
-{% block content %}
-اعمال پروفایل
-{{ guide_box(guide, 'profiles') }}
-
-{% if pending and not pending.confirmed %}
-
- یک apply در انتظار تأیید است.
-
ادامه
-
- {% for p in profiles %}
-
-
-
-
{{ p.name }}
-
{{ p.description }}
-
-
-
-
- {% endfor %}
-
تاریخچه apply
-
-
- پروفایل وضعیت شروع
- {% for log in recent_logs %}
-
- {{ log.profile.name if log.profile else '-' }}
- {{ log.status }} {{ log.started_at.strftime('%Y-%m-%d %H:%M') }}
- جزئیات
- {% endfor %}
-
-
-
اعمال پروفایل
+{{ guide_box(guide, 'profiles') }}
+
+{% if pending and not pending.confirmed %}
+
+{% endif %}
+
+
+ توصیه: همیشه ابتدا «تست موقت» را بزنید.
+ اگر {{ test_minutes }} دقیقه تأیید نکنید، تنظیمات قبلی خودکار برمیگردد.
+ Docker ممکن است چند ثانیه restart شود.
+
+
+
+ {% for p in profiles %}
+
+
+
+
{{ p.name }}
+
{{ p.description }}
+
+ {% for item in p.items %}
+ {{ item.category }}: {{ item.mirror.name if item.mirror else '-' }}
+ {% endfor %}
+
+
+
+
+
+
+
+
+ {% endfor %}
+
تاریخچه apply
+
+
+ پروفایل نوع وضعیت شروع
+ {% for log in recent_logs %}
+
+ {{ log.profile.name if log.profile else '-' }}
+
+ {% if log.get_details().get('mode') == 'final' %}
+ نهایی
+ {% else %}
+ تست
+ {% endif %}
+
+ {{ log.status }} {{ log.started_at.strftime('%Y-%m-%d %H:%M') }}
+ جزئیات
+ {% endfor %}
+
+
+
وضعیت اعمال پروفایل
-پروفایل: {{ log.profile.name if log.profile else '-' }}
-وضعیت: {{ log.status }}
-
-{% if not log.confirmed and log.status == 'pending_confirm' %}
-
- پنجره تست:
- {{ remaining_seconds }} ثانیه تا rollback خودکار
-
-
-
-
-
-{% endif %}
-
-جزئیات مراحل
-{% for step in details.get('steps', []) %}
-
-
-
- {{ step.category }} — {{ step.get('mirror', '') }}موفق
- {% else %}
- ناموفق
- {% endif %}
-
- {% if step.get('message') %}
{{ step.message }} {% endif %}
- {% if step.get('error') %}
{{ step.error }} {% endif %}
- {% if step.get('warning') %}
{{ step.warning }} {% endif %}
-
-
داشبورد
-{% endblock %}
-
-{% block scripts %}
-{% if not log.confirmed and log.status == 'pending_confirm' %}
-
-{% endif %}
-{% endblock %}
+{% extends "base.html" %}
+{% block title %}وضعیت Apply{% endblock %}
+{% block content %}
+وضعیت اعمال پروفایل
+پروفایل: {{ log.profile.name if log.profile else '-' }}
+
+ نوع:
+ {% if apply_mode == 'final' %}
+ اعمال نهایی
+ {% else %}
+ تست موقت
+ {% endif %}
+
+وضعیت: {{ log.status }}
+
+{% if log.status == 'failed' and details.get('auto_rollback') %}
+
+ بهخاطر خطا در یکی از مراحل، backup قبلی خودکار بازگردانده شد.
+
+{% endif %}
+
+{% if not log.confirmed and log.status == 'pending_confirm' %}
+
+
پنجره تست:
+
{{ remaining_seconds }} ثانیه تا rollback خودکار
+
اگر دسترسی به پنل قطع شد، از SSH: mirror-manager emergency-restore
+
+
+
+
+{% endif %}
+
+جزئیات مراحل
+{% for step in details.get('steps', []) %}
+
+
+
+ {{ step.category }} — {{ step.get('mirror', '') }}موفق
+ {% else %}
+ ناموفق
+ {% endif %}
+
+ {% if step.get('message') %}
{{ step.message }} {% endif %}
+ {% if step.get('error') %}
{{ step.error }} {% endif %}
+ {% if step.get('warning') %}
{{ step.warning }} {% endif %}
+
+
داشبورد
+بازگردانی
+{% endblock %}
+
+{% block scripts %}
+{% if not log.confirmed and log.status == 'pending_confirm' %}
+
+{% endif %}
+{% endblock %}
+
\ No newline at end of file
diff --git a/app/templates/profiles/list.html b/app/templates/profiles/list.html
index 694edc9..32e3e18 100644
--- a/app/templates/profiles/list.html
+++ b/app/templates/profiles/list.html
@@ -1,39 +1,37 @@
-{% extends "base.html" %}
-{% from "macros.html" import guide_box %}
-{% block title %}پروفایلها{% endblock %}
-{% block content %}
-
-
پروفایلها
-
+ پروفایل جدید
-
- {% for p in profiles %}
-
-
-
-
{{ p.name }}{% if p.is_default %} پیشفرض {% endif %}
-
{{ p.description or '' }}
-
- {% for item in p.items %}
- {{ item.category }}: {{ item.mirror.name if item.mirror else '-' }}
- {% endfor %}
-
-
-
-
-
- {% else %}
-
- {% endfor %}
-
+
پروفایلها
+
+ پروفایل جدید
+
+ {% for p in profiles %}
+
+
+
+
{{ p.name }}{% if p.is_default %} پیشفرض {% endif %}
+
{{ p.description or '' }}
+
+ {% for item in p.items %}
+ {{ item.category }}: {{ item.mirror.name if item.mirror else '-' }}
+ {% endfor %}
+
+
+
+
+
+ {% else %}
+
+ {% endfor %}
+
بازگردانی تنظیمات
-{{ guide_box(guide, 'restore') }}
-
-
-
-
-
-
بازگردانی به تنظیمات اولیه
-
وضعیت سیستم قبل از اولین اجرای Mirror Manager
- {% if state and state.initial_backup_path %}
-
{{ state.initial_backup_path }}
-
- {% else %}
-
Backup اولیه یافت نشد
- {% endif %}
-
-
-
-
Backupهای موجود
-
-
- نام برچسب عملیات
- {% for b in backups %}
-
- {{ b.name }}{{ b.label }}
-
-
-
-
- {% else %}
- backupی وجود ندارد
-
-
-
-
دستورات SSH
-
python3 mirror-manager restore --initial
-python3 mirror-manager restore --backup /path/to/backup
-python3 mirror-manager disable
-python3 mirror-manager enable
-
-
بازگردانی تنظیمات
+{{ guide_box(guide, 'restore') }}
+
+
+
+
+
+
بازگردانی فوری (Emergency)
+
برگشت به آخرین backup قبل از apply — یک کلیک، بدون انتخاب مسیر
+ {% if latest_apply_backup %}
+
{{ latest_apply_backup }}
+
+ {% else %}
+
backup قبل از apply یافت نشد
+ {% endif %}
+
+
+
+
+
+
+
بازگردانی به تنظیمات اولیه
+
وضعیت سیستم قبل از اولین اجرای Mirror Manager
+ {% if state and state.initial_backup_path %}
+
{{ state.initial_backup_path }}
+
+ {% else %}
+
Backup اولیه یافت نشد
+ {% endif %}
+
+
+
+
Backupهای موجود
+
+
+ نام برچسب عملیات
+ {% for b in backups %}
+
+ {{ b.name }}{{ b.label }}
+
+
+
+
+ {% else %}
+ backupی وجود ندارد
+
+
+
+
دستورات SSH (یک خط)
+
mirror-manager emergency-restore
+mirror-manager restore --initial
+mirror-manager restore --last
+mirror-manager disable
+mirror-manager enable
+
+
Rollback و تست
-
پنجره rollback پیشفرض (دقیقه)
+
پنجره تست موقت (دقیقه)
+
+
پس از «تست موقت» — rollback خودکار اگر تأیید نشود
+
+
+ پنجره rollback قدیمی (دقیقه)
diff --git a/deploy/install-cli.sh b/deploy/install-cli.sh
index 85f131e..ea78fba 100644
--- a/deploy/install-cli.sh
+++ b/deploy/install-cli.sh
@@ -1,18 +1,25 @@
-#!/bin/bash
-set -euo pipefail
-
-INSTALL_DIR="${1:-/opt/mirror-manager}"
-BIN="/usr/local/bin/mirror-manager"
-
-echo "نصب Mirror Manager CLI..."
-sudo mkdir -p /var/lib/mirror-manager/data
-sudo cp "$INSTALL_DIR/mirror-manager" "$BIN"
-sudo chmod +x "$BIN"
-
-PROFILE_D="/etc/profile.d/mirror-manager.sh"
-echo "export PYTHONPATH=$INSTALL_DIR" | sudo tee "$PROFILE_D" > /dev/null
-echo "export MIRROR_CONTAINER_NAME=mirror-manager" | sudo tee -a "$PROFILE_D" > /dev/null
-
-echo "CLI نصب شد: mirror-manager"
-echo " mirror-manager status"
-echo " mirror-manager restore --initial"
+#!/bin/bash
+set -euo pipefail
+
+INSTALL_DIR="${1:-/opt/mirror-manager}"
+BIN="/usr/local/bin/mirror-manager"
+
+echo "نصب Mirror Manager CLI..."
+sudo mkdir -p /var/lib/mirror-manager/data
+sudo cp "$INSTALL_DIR/mirror-manager" "$BIN"
+sudo chmod +x "$BIN"
+
+PROFILE_D="/etc/profile.d/mirror-manager.sh"
+{
+ echo "export PYTHONPATH=$INSTALL_DIR"
+ echo "export MIRROR_CONTAINER_NAME=mirror-manager"
+ echo "export DATA_DIR=/var/lib/mirror-manager/data"
+ echo "export HOST_ROOT=/"
+} | sudo tee "$PROFILE_D" > /dev/null
+
+echo "CLI نصب شد: mirror-manager"
+echo " mirror-manager emergency-restore # بازگردانی فوری"
+echo " mirror-manager restore --last"
+echo " mirror-manager restore --initial"
+echo " mirror-manager status"
+
\ No newline at end of file
diff --git a/docker-compose.yml b/docker-compose.yml
index bbdb939..93e792b 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -19,6 +19,7 @@ services:
- HOST_ROOT=/host
- DATA_DIR=/app/data
- ROLLBACK_MINUTES=${ROLLBACK_MINUTES:-15}
+ - TEST_ROLLBACK_MINUTES=${TEST_ROLLBACK_MINUTES:-2}
- AUTO_TEST_INTERVAL_MINUTES=${AUTO_TEST_INTERVAL_MINUTES:-30}
volumes:
- /etc:/host/etc