Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a1a9388d88 | |||
| 4caac3a6c7 |
+1
-1
@@ -1,6 +1,6 @@
|
||||
[project]
|
||||
name = "mcp-synology-container"
|
||||
version = "0.2.7"
|
||||
version = "0.2.8"
|
||||
description = "MCP server for Synology Container Manager"
|
||||
requires-python = ">=3.12"
|
||||
dependencies = [
|
||||
|
||||
@@ -27,6 +27,10 @@ logger = logging.getLogger(__name__)
|
||||
# Session error codes that trigger transparent re-auth
|
||||
_SESSION_ERROR_CODES = frozenset({106, 107, 119})
|
||||
|
||||
# Cooldown after a failed init so repeated tool calls don't hammer DSM
|
||||
# (and don't escalate 407 "IP blocked" lockouts).
|
||||
INIT_ERROR_COOLDOWN = 60.0
|
||||
|
||||
# Parameters to mask in debug logging
|
||||
_SENSITIVE_PARAMS = frozenset({"passwd", "_sid", "device_id", "otp_code", "device_token"})
|
||||
|
||||
@@ -111,6 +115,8 @@ class DsmClient:
|
||||
self._init_lock = asyncio.Lock()
|
||||
self._initialized = False
|
||||
self._initializing = False # True while inside _ensure_initialized
|
||||
self._init_error: Exception | None = None
|
||||
self._init_error_until: float = 0.0
|
||||
logger.debug(
|
||||
"DsmClient: base_url=%s verify_ssl=%s timeout=%d",
|
||||
self._base_url,
|
||||
@@ -141,6 +147,10 @@ class DsmClient:
|
||||
async with self._init_lock:
|
||||
if self._initialized: # re-check inside lock
|
||||
return
|
||||
# Negative cache: re-raise cached error during cooldown window.
|
||||
now = asyncio.get_event_loop().time()
|
||||
if self._init_error is not None and now < self._init_error_until:
|
||||
raise self._init_error
|
||||
self._initializing = True
|
||||
try:
|
||||
sys.stderr.write(f"[dsm] Connecting to {self._base_url}...\n")
|
||||
@@ -157,7 +167,18 @@ class DsmClient:
|
||||
sys.stderr.write("[dsm] Auth OK\n")
|
||||
sys.stderr.flush()
|
||||
self._initialized = True
|
||||
self._init_error = None
|
||||
self._init_error_until = 0.0
|
||||
logger.debug("Lazy init complete")
|
||||
except Exception as e:
|
||||
self._init_error = e
|
||||
self._init_error_until = now + INIT_ERROR_COOLDOWN
|
||||
logger.warning(
|
||||
"Lazy init failed (%s); will retry after %.0fs cooldown",
|
||||
type(e).__name__,
|
||||
INIT_ERROR_COOLDOWN,
|
||||
)
|
||||
raise
|
||||
finally:
|
||||
self._initializing = False
|
||||
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user