mirror of
https://github.com/ChuckBuilds/LEDMatrix.git
synced 2026-06-22 04:18:38 +00:00
Compare commits
7 Commits
fix/post-i
...
dbb53da31d
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dbb53da31d | ||
|
|
452afacd12 | ||
|
|
3b45a75f75 | ||
|
|
1a0f1c8015 | ||
|
|
b361866679 | ||
|
|
ceb4c4105f | ||
|
|
e9af18cdf1 |
@@ -1,4 +1,5 @@
|
|||||||
# LEDMatrix
|
# LEDMatrix
|
||||||
|
[](https://app.codacy.com/gh/ChuckBuilds/LEDMatrix/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_grade)
|
||||||
## Welcome to LEDMatrix!
|
## Welcome to LEDMatrix!
|
||||||
Welcome to the LEDMatrix Project! This open-source project enables you to run an information-rich display on a Raspberry Pi connected to an LED RGB Matrix panel. Whether you want to see your calendar, weather forecasts, sports scores, stock prices, or any other information at a glance, LEDMatrix brings it all together.
|
Welcome to the LEDMatrix Project! This open-source project enables you to run an information-rich display on a Raspberry Pi connected to an LED RGB Matrix panel. Whether you want to see your calendar, weather forecasts, sports scores, stock prices, or any other information at a glance, LEDMatrix brings it all together.
|
||||||
|
|
||||||
|
|||||||
@@ -1110,6 +1110,7 @@ $ACTUAL_USER ALL=(ALL) NOPASSWD: $SYSTEMCTL_PATH restart ledmatrix-web.service
|
|||||||
$ACTUAL_USER ALL=(ALL) NOPASSWD: $PYTHON_PATH $PROJECT_ROOT_DIR/display_controller.py
|
$ACTUAL_USER ALL=(ALL) NOPASSWD: $PYTHON_PATH $PROJECT_ROOT_DIR/display_controller.py
|
||||||
$ACTUAL_USER ALL=(ALL) NOPASSWD: $BASH_PATH $PROJECT_ROOT_DIR/start_display.sh
|
$ACTUAL_USER ALL=(ALL) NOPASSWD: $BASH_PATH $PROJECT_ROOT_DIR/start_display.sh
|
||||||
$ACTUAL_USER ALL=(ALL) NOPASSWD: $BASH_PATH $PROJECT_ROOT_DIR/stop_display.sh
|
$ACTUAL_USER ALL=(ALL) NOPASSWD: $BASH_PATH $PROJECT_ROOT_DIR/stop_display.sh
|
||||||
|
$ACTUAL_USER ALL=(ALL) NOPASSWD: $BASH_PATH $PROJECT_ROOT_DIR/scripts/fix_perms/safe_plugin_rm.sh *
|
||||||
EOF
|
EOF
|
||||||
if [ -n "$JOURNALCTL_PATH" ]; then
|
if [ -n "$JOURNALCTL_PATH" ]; then
|
||||||
cat >> /tmp/ledmatrix_web_sudoers << EOF
|
cat >> /tmp/ledmatrix_web_sudoers << EOF
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
requests>=2.28.0
|
requests>=2.28.0
|
||||||
Pillow>=10.3.0
|
Pillow>=12.2.0
|
||||||
pytz>=2022.1
|
pytz>=2022.1
|
||||||
numpy>=1.24.0
|
numpy>=1.24.0
|
||||||
|
|||||||
@@ -118,7 +118,7 @@ total_count=${#ARCHITECTURES[@]}
|
|||||||
|
|
||||||
for arch in "${!ARCHITECTURES[@]}"; do
|
for arch in "${!ARCHITECTURES[@]}"; do
|
||||||
if download_binary "$arch" "${ARCHITECTURES[$arch]}"; then
|
if download_binary "$arch" "${ARCHITECTURES[$arch]}"; then
|
||||||
((success_count++))
|
success_count=$((success_count + 1))
|
||||||
fi
|
fi
|
||||||
done
|
done
|
||||||
|
|
||||||
|
|||||||
@@ -155,7 +155,7 @@ class WiFiMonitorDaemon:
|
|||||||
logger.error(f"NetworkManager restart failed (rc={e.returncode}); "
|
logger.error(f"NetworkManager restart failed (rc={e.returncode}); "
|
||||||
"resetting failure counter to avoid tight retry loop")
|
"resetting failure counter to avoid tight retry loop")
|
||||||
self._consecutive_internet_failures = 0
|
self._consecutive_internet_failures = 0
|
||||||
except Exception as e:
|
except (subprocess.SubprocessError, OSError) as e:
|
||||||
logger.error(f"NetworkManager restart error: {e}; "
|
logger.error(f"NetworkManager restart error: {e}; "
|
||||||
"resetting failure counter to avoid tight retry loop")
|
"resetting failure counter to avoid tight retry loop")
|
||||||
self._consecutive_internet_failures = 0
|
self._consecutive_internet_failures = 0
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ if os.getenv("EMULATOR", "false") == "true":
|
|||||||
from RGBMatrixEmulator import RGBMatrix, RGBMatrixOptions
|
from RGBMatrixEmulator import RGBMatrix, RGBMatrixOptions
|
||||||
else:
|
else:
|
||||||
from rgbmatrix import RGBMatrix, RGBMatrixOptions
|
from rgbmatrix import RGBMatrix, RGBMatrixOptions
|
||||||
|
from contextlib import contextmanager
|
||||||
from PIL import Image, ImageDraw, ImageFont
|
from PIL import Image, ImageDraw, ImageFont
|
||||||
import time
|
import time
|
||||||
from typing import Dict, Any, List, Tuple
|
from typing import Dict, Any, List, Tuple
|
||||||
@@ -28,6 +29,8 @@ class DisplayManager:
|
|||||||
self.config = config or {}
|
self.config = config or {}
|
||||||
self._force_fallback = force_fallback
|
self._force_fallback = force_fallback
|
||||||
self._suppress_test_pattern = suppress_test_pattern
|
self._suppress_test_pattern = suppress_test_pattern
|
||||||
|
# When True, update_display() and clear() skip hardware writes (used during off-screen content capture)
|
||||||
|
self._capture_mode_active = False
|
||||||
# Snapshot settings for web preview integration (service writes, web reads)
|
# Snapshot settings for web preview integration (service writes, web reads)
|
||||||
self._snapshot_path = "/tmp/led_matrix_preview.png"
|
self._snapshot_path = "/tmp/led_matrix_preview.png"
|
||||||
self._snapshot_min_interval_sec = 0.2 # max ~5 fps
|
self._snapshot_min_interval_sec = 0.2 # max ~5 fps
|
||||||
@@ -255,6 +258,22 @@ class DisplayManager:
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"Error drawing test pattern: {e}", exc_info=True)
|
logger.error(f"Error drawing test pattern: {e}", exc_info=True)
|
||||||
|
|
||||||
|
@contextmanager
|
||||||
|
def capture_mode(self):
|
||||||
|
"""Suppress hardware output during off-screen content capture.
|
||||||
|
|
||||||
|
Plugins call update_display() as part of their normal display() flow.
|
||||||
|
When fetching content for Vegas mode the render loop is still running,
|
||||||
|
so any incidental hardware write causes a visible flash on the matrix.
|
||||||
|
Entering this context prevents those writes without affecting the PIL
|
||||||
|
image buffer, which the adapter reads to extract content.
|
||||||
|
"""
|
||||||
|
self._capture_mode_active = True
|
||||||
|
try:
|
||||||
|
yield
|
||||||
|
finally:
|
||||||
|
self._capture_mode_active = False
|
||||||
|
|
||||||
def update_display(self):
|
def update_display(self):
|
||||||
"""Update the display using double buffering with proper sync."""
|
"""Update the display using double buffering with proper sync."""
|
||||||
try:
|
try:
|
||||||
@@ -265,6 +284,9 @@ class DisplayManager:
|
|||||||
self._write_snapshot_if_due()
|
self._write_snapshot_if_due()
|
||||||
return
|
return
|
||||||
|
|
||||||
|
if self._capture_mode_active:
|
||||||
|
return # Skip hardware write — content is being captured off-screen
|
||||||
|
|
||||||
# Copy the current image to the offscreen canvas
|
# Copy the current image to the offscreen canvas
|
||||||
self.offscreen_canvas.SetImage(self.image)
|
self.offscreen_canvas.SetImage(self.image)
|
||||||
|
|
||||||
@@ -305,20 +327,22 @@ class DisplayManager:
|
|||||||
self.image = Image.new('RGB', (self.matrix.width, self.matrix.height))
|
self.image = Image.new('RGB', (self.matrix.width, self.matrix.height))
|
||||||
self.draw = ImageDraw.Draw(self.image)
|
self.draw = ImageDraw.Draw(self.image)
|
||||||
|
|
||||||
# Clear both canvases and the underlying matrix to ensure no artifacts
|
if not self._capture_mode_active:
|
||||||
|
# Clear both canvases and the underlying matrix to ensure no artifacts.
|
||||||
|
# Failures are non-fatal — the image buffer is already black above, so
|
||||||
|
# the next update_display() call will push clean content regardless.
|
||||||
try:
|
try:
|
||||||
self.offscreen_canvas.Clear()
|
self.offscreen_canvas.Clear()
|
||||||
except Exception:
|
except (RuntimeError, OSError) as e:
|
||||||
pass
|
logger.error("Failed to clear offscreen canvas: %s", e)
|
||||||
try:
|
try:
|
||||||
self.current_canvas.Clear()
|
self.current_canvas.Clear()
|
||||||
except Exception:
|
except (RuntimeError, OSError) as e:
|
||||||
pass
|
logger.error("Failed to clear current canvas: %s", e)
|
||||||
try:
|
try:
|
||||||
# Extra safety: clear the matrix front buffer as well
|
|
||||||
self.matrix.Clear()
|
self.matrix.Clear()
|
||||||
except Exception:
|
except (RuntimeError, OSError) as e:
|
||||||
pass
|
logger.error("Failed to clear matrix front buffer: %s", e)
|
||||||
|
|
||||||
# Note: We do NOT call update_display() here to avoid black flashes.
|
# Note: We do NOT call update_display() here to avoid black flashes.
|
||||||
# The caller should call update_display() after drawing new content.
|
# The caller should call update_display() after drawing new content.
|
||||||
|
|||||||
@@ -329,6 +329,7 @@ class PluginAdapter:
|
|||||||
# Save display state to restore after
|
# Save display state to restore after
|
||||||
original_image = self.display_manager.image.copy()
|
original_image = self.display_manager.image.copy()
|
||||||
|
|
||||||
|
with self.display_manager.capture_mode():
|
||||||
# Method 1: Try _create_scrolling_display (stocks pattern)
|
# Method 1: Try _create_scrolling_display (stocks pattern)
|
||||||
if hasattr(plugin, '_create_scrolling_display'):
|
if hasattr(plugin, '_create_scrolling_display'):
|
||||||
logger.info(
|
logger.info(
|
||||||
@@ -408,10 +409,7 @@ class PluginAdapter:
|
|||||||
original_image = self.display_manager.image.copy()
|
original_image = self.display_manager.image.copy()
|
||||||
logger.info("[%s] Fallback: saved original display state", plugin_id)
|
logger.info("[%s] Fallback: saved original display state", plugin_id)
|
||||||
|
|
||||||
# Lightweight in-memory data refresh before capturing.
|
# Ensure plugin has fresh data before capturing
|
||||||
# Full update() is intentionally skipped here — the background
|
|
||||||
# update tick in the Vegas coordinator handles periodic API
|
|
||||||
# refreshes so we don't block the content-fetch thread.
|
|
||||||
has_update_data = hasattr(plugin, 'update_data')
|
has_update_data = hasattr(plugin, 'update_data')
|
||||||
logger.info("[%s] Fallback: has update_data=%s", plugin_id, has_update_data)
|
logger.info("[%s] Fallback: has update_data=%s", plugin_id, has_update_data)
|
||||||
if has_update_data:
|
if has_update_data:
|
||||||
@@ -421,7 +419,9 @@ class PluginAdapter:
|
|||||||
except (AttributeError, RuntimeError, OSError):
|
except (AttributeError, RuntimeError, OSError):
|
||||||
logger.exception("[%s] Fallback: update_data() failed", plugin_id)
|
logger.exception("[%s] Fallback: update_data() failed", plugin_id)
|
||||||
|
|
||||||
# Clear and call plugin display
|
# Clear and call plugin display — use capture_mode to suppress hardware writes
|
||||||
|
# that plugins may trigger internally via update_display().
|
||||||
|
with self.display_manager.capture_mode():
|
||||||
self.display_manager.clear()
|
self.display_manager.clear()
|
||||||
logger.info("[%s] Fallback: display cleared, calling display()", plugin_id)
|
logger.info("[%s] Fallback: display cleared, calling display()", plugin_id)
|
||||||
|
|
||||||
@@ -436,6 +436,7 @@ class PluginAdapter:
|
|||||||
|
|
||||||
# Capture the result
|
# Capture the result
|
||||||
captured = self.display_manager.image.copy()
|
captured = self.display_manager.image.copy()
|
||||||
|
|
||||||
logger.info(
|
logger.info(
|
||||||
"[%s] Fallback: captured frame %dx%d, mode=%s",
|
"[%s] Fallback: captured frame %dx%d, mode=%s",
|
||||||
plugin_id, captured.width, captured.height, captured.mode
|
plugin_id, captured.width, captured.height, captured.mode
|
||||||
@@ -454,6 +455,7 @@ class PluginAdapter:
|
|||||||
plugin_id
|
plugin_id
|
||||||
)
|
)
|
||||||
# Try once more with force_clear=True
|
# Try once more with force_clear=True
|
||||||
|
with self.display_manager.capture_mode():
|
||||||
self.display_manager.clear()
|
self.display_manager.clear()
|
||||||
plugin.display(force_clear=True)
|
plugin.display(force_clear=True)
|
||||||
captured = self.display_manager.image.copy()
|
captured = self.display_manager.image.copy()
|
||||||
@@ -585,28 +587,6 @@ class PluginAdapter:
|
|||||||
else:
|
else:
|
||||||
self._content_cache.clear()
|
self._content_cache.clear()
|
||||||
|
|
||||||
def invalidate_plugin_scroll_cache(self, plugin: 'BasePlugin', plugin_id: str) -> None:
|
|
||||||
"""
|
|
||||||
Clear a plugin's scroll_helper cache so Vegas re-fetches fresh visuals.
|
|
||||||
|
|
||||||
Uses scroll_helper.clear_cache() to reset all cached state (cached_image,
|
|
||||||
cached_array, total_scroll_width, scroll_position, etc.) — not just the
|
|
||||||
image. Without this, plugins that use scroll_helper (stocks, news,
|
|
||||||
odds-ticker, etc.) would keep serving stale scroll images even after
|
|
||||||
their data refreshes.
|
|
||||||
|
|
||||||
Args:
|
|
||||||
plugin: Plugin instance
|
|
||||||
plugin_id: Plugin identifier
|
|
||||||
"""
|
|
||||||
scroll_helper = getattr(plugin, 'scroll_helper', None)
|
|
||||||
if scroll_helper is None:
|
|
||||||
return
|
|
||||||
|
|
||||||
if getattr(scroll_helper, 'cached_image', None) is not None:
|
|
||||||
scroll_helper.clear_cache()
|
|
||||||
logger.debug("[%s] Cleared scroll_helper cache", plugin_id)
|
|
||||||
|
|
||||||
def get_content_type(self, plugin: 'BasePlugin', plugin_id: str) -> str:
|
def get_content_type(self, plugin: 'BasePlugin', plugin_id: str) -> str:
|
||||||
"""
|
"""
|
||||||
Get the type of content a plugin provides.
|
Get the type of content a plugin provides.
|
||||||
|
|||||||
@@ -202,8 +202,25 @@ class RenderPipeline:
|
|||||||
# Update scroll position
|
# Update scroll position
|
||||||
self.scroll_helper.update_scroll_position()
|
self.scroll_helper.update_scroll_position()
|
||||||
|
|
||||||
# Check if cycle is complete
|
# Determine if the cycle is done.
|
||||||
if self.scroll_helper.is_scroll_complete():
|
#
|
||||||
|
# scroll_helper considers a cycle complete only after
|
||||||
|
# total_distance_scrolled >= total_scroll_width + display_width.
|
||||||
|
# That extra display_width of travel causes a "wrap-around" phase
|
||||||
|
# where scroll_position resets to ~0 and the first plugin's content
|
||||||
|
# re-enters from the right — the user sees this 2-3 s window as
|
||||||
|
# "a plugin partially displaying before the next one starts."
|
||||||
|
#
|
||||||
|
# We end the cycle as soon as total_distance_scrolled reaches
|
||||||
|
# total_scroll_width (the wrap-around point), before any second-pass
|
||||||
|
# content becomes visible. scroll_helper.is_scroll_complete() is
|
||||||
|
# kept as a fallback for edge-cases where that threshold is skipped.
|
||||||
|
at_wrap_point = (
|
||||||
|
not self._cycle_complete and
|
||||||
|
self.scroll_helper.total_distance_scrolled >= self.scroll_helper.total_scroll_width
|
||||||
|
)
|
||||||
|
|
||||||
|
if at_wrap_point or self.scroll_helper.is_scroll_complete():
|
||||||
if not self._cycle_complete:
|
if not self._cycle_complete:
|
||||||
self._cycle_complete = True
|
self._cycle_complete = True
|
||||||
self.stats['scroll_cycles'] += 1
|
self.stats['scroll_cycles'] += 1
|
||||||
@@ -211,6 +228,20 @@ class RenderPipeline:
|
|||||||
"Scroll cycle complete after %.1fs",
|
"Scroll cycle complete after %.1fs",
|
||||||
time.time() - self._cycle_start_time
|
time.time() - self._cycle_start_time
|
||||||
)
|
)
|
||||||
|
# Push blank immediately so the hardware never shows
|
||||||
|
# post-wrap content while the coordinator recomposes.
|
||||||
|
try:
|
||||||
|
from PIL import Image as _Image
|
||||||
|
blank = _Image.new('RGB', (self.display_width, self.display_height))
|
||||||
|
self.display_manager.image = blank
|
||||||
|
self.display_manager.update_display()
|
||||||
|
except (ImportError, OSError, RuntimeError, ValueError, TypeError, MemoryError) as exc:
|
||||||
|
logger.error(
|
||||||
|
"Failed to push blank frame at cycle end "
|
||||||
|
"(display=%dx%d): %s",
|
||||||
|
self.display_width, self.display_height, exc
|
||||||
|
)
|
||||||
|
return True # Cycle done; coordinator starts new cycle next frame
|
||||||
|
|
||||||
# Get visible portion
|
# Get visible portion
|
||||||
visible_frame = self.scroll_helper.get_visible_portion()
|
visible_frame = self.scroll_helper.get_visible_portion()
|
||||||
|
|||||||
@@ -226,13 +226,24 @@ def serve_plugin_asset(plugin_id, filename):
|
|||||||
'message': 'Internal server error'
|
'message': 'Internal server error'
|
||||||
}), 500
|
}), 500
|
||||||
|
|
||||||
|
# Prime psutil CPU measurement once at startup so interval=None returns a real value
|
||||||
|
try:
|
||||||
|
import psutil as _psutil_prime
|
||||||
|
_psutil_prime.cpu_percent(interval=None)
|
||||||
|
except ImportError:
|
||||||
|
pass
|
||||||
|
|
||||||
# Cached AP mode check — avoids creating a WiFiManager per request
|
# Cached AP mode check — avoids creating a WiFiManager per request
|
||||||
_ap_mode_cache = {'value': False, 'timestamp': 0}
|
_ap_mode_cache = {'value': False, 'timestamp': 0}
|
||||||
_AP_MODE_CACHE_TTL = 5 # seconds
|
_AP_MODE_CACHE_TTL = 30 # seconds — AP mode is user-initiated; 30s is fine
|
||||||
|
|
||||||
|
# Cached ledmatrix service status for SSE stats stream
|
||||||
|
_ledmatrix_service_cache = {'active': False, 'timestamp': 0}
|
||||||
|
_LEDMATRIX_SERVICE_CACHE_TTL = 15 # seconds
|
||||||
|
|
||||||
def is_ap_mode_active():
|
def is_ap_mode_active():
|
||||||
"""
|
"""
|
||||||
Check if access point mode is currently active (cached, 5s TTL).
|
Check if access point mode is currently active (cached, 30s TTL).
|
||||||
Uses a direct systemctl check instead of instantiating WiFiManager.
|
Uses a direct systemctl check instead of instantiating WiFiManager.
|
||||||
"""
|
"""
|
||||||
now = time.time()
|
now = time.time()
|
||||||
@@ -444,7 +455,8 @@ def system_status_generator():
|
|||||||
# Try to import psutil for system stats
|
# Try to import psutil for system stats
|
||||||
try:
|
try:
|
||||||
import psutil
|
import psutil
|
||||||
cpu_percent = round(psutil.cpu_percent(interval=1), 1)
|
# interval=None is non-blocking; primed at module startup above
|
||||||
|
cpu_percent = round(psutil.cpu_percent(interval=None), 1)
|
||||||
memory = psutil.virtual_memory()
|
memory = psutil.virtual_memory()
|
||||||
memory_used_percent = round(memory.percent, 1)
|
memory_used_percent = round(memory.percent, 1)
|
||||||
|
|
||||||
@@ -461,14 +473,17 @@ def system_status_generator():
|
|||||||
memory_used_percent = 0
|
memory_used_percent = 0
|
||||||
cpu_temp = 0
|
cpu_temp = 0
|
||||||
|
|
||||||
# Check if display service is running
|
# Check if display service is running (cached to avoid per-client subprocess forks)
|
||||||
service_active = False
|
now = time.time()
|
||||||
|
if (now - _ledmatrix_service_cache['timestamp']) >= _LEDMATRIX_SERVICE_CACHE_TTL:
|
||||||
try:
|
try:
|
||||||
result = subprocess.run(['systemctl', 'is-active', 'ledmatrix'],
|
result = subprocess.run(['systemctl', 'is-active', 'ledmatrix'],
|
||||||
capture_output=True, text=True, timeout=2)
|
capture_output=True, text=True, timeout=2)
|
||||||
service_active = result.stdout.strip() == 'active'
|
_ledmatrix_service_cache['active'] = result.stdout.strip() == 'active'
|
||||||
except (subprocess.SubprocessError, OSError):
|
except (subprocess.SubprocessError, OSError):
|
||||||
pass
|
pass
|
||||||
|
_ledmatrix_service_cache['timestamp'] = now
|
||||||
|
service_active = _ledmatrix_service_cache['active']
|
||||||
|
|
||||||
status = {
|
status = {
|
||||||
'timestamp': time.time(),
|
'timestamp': time.time(),
|
||||||
@@ -546,7 +561,7 @@ def display_preview_generator():
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
yield {'error': str(e)}
|
yield {'error': str(e)}
|
||||||
|
|
||||||
time.sleep(0.5) # Check 2 times per second (reduced frequency for better performance)
|
time.sleep(1.0) # Check once per second — halves PIL encode overhead vs 0.5s
|
||||||
|
|
||||||
# Logs generator for SSE
|
# Logs generator for SSE
|
||||||
def logs_generator():
|
def logs_generator():
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ from flask import Blueprint, request, jsonify, Response, send_from_directory
|
|||||||
import json
|
import json
|
||||||
import os
|
import os
|
||||||
import re
|
import re
|
||||||
|
import shutil
|
||||||
import socket
|
import socket
|
||||||
import sys
|
import sys
|
||||||
import subprocess
|
import subprocess
|
||||||
@@ -16,6 +17,11 @@ from typing import Optional, Tuple, Dict, Any, Type
|
|||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
SUDO_BIN = shutil.which("sudo") or "/usr/bin/sudo"
|
||||||
|
SYSTEMCTL_BIN = shutil.which("systemctl") or "/usr/bin/systemctl"
|
||||||
|
REBOOT_BIN = shutil.which("reboot") or "/usr/sbin/reboot"
|
||||||
|
POWEROFF_BIN = shutil.which("poweroff") or "/usr/sbin/poweroff"
|
||||||
|
|
||||||
# Import new infrastructure
|
# Import new infrastructure
|
||||||
from src.web_interface.api_helpers import success_response, error_response, validate_request_json
|
from src.web_interface.api_helpers import success_response, error_response, validate_request_json
|
||||||
from src.web_interface.errors import ErrorCode
|
from src.web_interface.errors import ErrorCode
|
||||||
@@ -218,7 +224,7 @@ def _ensure_display_service_running():
|
|||||||
if status.get('active'):
|
if status.get('active'):
|
||||||
status['started'] = False
|
status['started'] = False
|
||||||
return status
|
return status
|
||||||
result = _run_systemctl_command(['sudo', 'systemctl', 'start', 'ledmatrix.service'])
|
result = _run_systemctl_command([SUDO_BIN, SYSTEMCTL_BIN, 'start', 'ledmatrix.service'])
|
||||||
service_status = _get_display_service_status()
|
service_status = _get_display_service_status()
|
||||||
result['started'] = result.get('returncode') == 0
|
result['started'] = result.get('returncode') == 0
|
||||||
result['active'] = service_status.get('active')
|
result['active'] = service_status.get('active')
|
||||||
@@ -227,7 +233,7 @@ def _ensure_display_service_running():
|
|||||||
|
|
||||||
def _stop_display_service():
|
def _stop_display_service():
|
||||||
"""Stop the ledmatrix display service."""
|
"""Stop the ledmatrix display service."""
|
||||||
result = _run_systemctl_command(['sudo', 'systemctl', 'stop', 'ledmatrix.service'])
|
result = _run_systemctl_command([SUDO_BIN, SYSTEMCTL_BIN, 'stop', 'ledmatrix.service'])
|
||||||
status = _get_display_service_status()
|
status = _get_display_service_status()
|
||||||
result['active'] = status.get('active')
|
result['active'] = status.get('active')
|
||||||
result['status'] = status
|
result['status'] = status
|
||||||
@@ -1716,7 +1722,7 @@ def execute_system_action():
|
|||||||
if mode:
|
if mode:
|
||||||
# For on-demand modes, we would need to integrate with the display controller
|
# For on-demand modes, we would need to integrate with the display controller
|
||||||
# For now, just start the display service
|
# For now, just start the display service
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'start', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'start', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
return jsonify({
|
return jsonify({
|
||||||
'status': 'success' if result.returncode == 0 else 'error',
|
'status': 'success' if result.returncode == 0 else 'error',
|
||||||
@@ -1727,22 +1733,22 @@ def execute_system_action():
|
|||||||
'stderr': result.stderr
|
'stderr': result.stderr
|
||||||
})
|
})
|
||||||
else:
|
else:
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'start', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'start', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
elif action == 'stop_display':
|
elif action == 'stop_display':
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'stop', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'stop', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
elif action == 'enable_autostart':
|
elif action == 'enable_autostart':
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'enable', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'enable', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
elif action == 'disable_autostart':
|
elif action == 'disable_autostart':
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'disable', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'disable', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
elif action == 'reboot_system':
|
elif action == 'reboot_system':
|
||||||
result = subprocess.run(['sudo', 'reboot'],
|
result = subprocess.run([SUDO_BIN, REBOOT_BIN],
|
||||||
capture_output=True, text=True, timeout=10)
|
capture_output=True, text=True, timeout=10)
|
||||||
elif action == 'shutdown_system':
|
elif action == 'shutdown_system':
|
||||||
result = subprocess.run(['sudo', 'poweroff'],
|
result = subprocess.run([SUDO_BIN, POWEROFF_BIN],
|
||||||
capture_output=True, text=True, timeout=10)
|
capture_output=True, text=True, timeout=10)
|
||||||
elif action == 'git_pull':
|
elif action == 'git_pull':
|
||||||
# Use PROJECT_ROOT instead of hardcoded path
|
# Use PROJECT_ROOT instead of hardcoded path
|
||||||
@@ -1824,10 +1830,10 @@ def execute_system_action():
|
|||||||
'stderr': result.stderr
|
'stderr': result.stderr
|
||||||
})
|
})
|
||||||
elif action == 'restart_display_service':
|
elif action == 'restart_display_service':
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'restart', 'ledmatrix.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'restart', 'ledmatrix.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
elif action == 'restart_web_service':
|
elif action == 'restart_web_service':
|
||||||
result = subprocess.run(['sudo', 'systemctl', 'restart', 'ledmatrix-web.service'],
|
result = subprocess.run([SUDO_BIN, SYSTEMCTL_BIN, 'restart', 'ledmatrix-web.service'],
|
||||||
capture_output=True, text=True, timeout=15)
|
capture_output=True, text=True, timeout=15)
|
||||||
else:
|
else:
|
||||||
return jsonify({'status': 'error', 'message': f'Unknown action: {action}'}), 400
|
return jsonify({'status': 'error', 'message': f'Unknown action: {action}'}), 400
|
||||||
@@ -1840,6 +1846,13 @@ def execute_system_action():
|
|||||||
'stderr': result.stderr
|
'stderr': result.stderr
|
||||||
})
|
})
|
||||||
|
|
||||||
|
except subprocess.TimeoutExpired:
|
||||||
|
if action == 'start_display' and mode:
|
||||||
|
msg = f'Failed to start display in {mode} mode: timed out'
|
||||||
|
else:
|
||||||
|
msg = f'Action {action} timed out'
|
||||||
|
logger.warning("[System] execute_system_action timed out: action=%s", action)
|
||||||
|
return jsonify({'status': 'error', 'message': msg, 'returncode': -1, 'stdout': '', 'stderr': 'timeout'}), 500
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.exception("[System] execute_system_action failed")
|
logger.exception("[System] execute_system_action failed")
|
||||||
return jsonify({'status': 'error', 'message': 'Failed to execute system action'}), 500
|
return jsonify({'status': 'error', 'message': 'Failed to execute system action'}), 500
|
||||||
@@ -4264,8 +4277,13 @@ def _set_missing_booleans_to_false(config, schema_props, form_keys, prefix='', c
|
|||||||
elif prop_type == 'object' and 'properties' in prop_schema:
|
elif prop_type == 'object' and 'properties' in prop_schema:
|
||||||
# Recurse into nested objects
|
# Recurse into nested objects
|
||||||
if config_node is not None:
|
if config_node is not None:
|
||||||
# Inside an array item — ensure nested dict exists in item
|
# Inside an array item — only recurse if the sub-object already exists.
|
||||||
if prop_name not in node or not isinstance(node[prop_name], dict):
|
# Never create optional sub-objects that weren't submitted; doing so
|
||||||
|
# produces e.g. logo:{} on feed items with no logo, which then fails
|
||||||
|
# schema validation when the object has required fields (id, path).
|
||||||
|
if prop_name not in node:
|
||||||
|
continue
|
||||||
|
if not isinstance(node[prop_name], dict):
|
||||||
node[prop_name] = {}
|
node[prop_name] = {}
|
||||||
_set_missing_booleans_to_false(
|
_set_missing_booleans_to_false(
|
||||||
config, prop_schema['properties'], form_keys, full_path,
|
config, prop_schema['properties'], form_keys, full_path,
|
||||||
@@ -4405,10 +4423,22 @@ def _filter_config_by_schema(config, schema, prefix=''):
|
|||||||
prop_schema = schema_props[key]
|
prop_schema = schema_props[key]
|
||||||
|
|
||||||
# Handle nested objects recursively
|
# Handle nested objects recursively
|
||||||
|
item_prefix = f"{prefix}.{key}" if prefix else key
|
||||||
if isinstance(value, dict) and prop_schema.get('type') == 'object' and 'properties' in prop_schema:
|
if isinstance(value, dict) and prop_schema.get('type') == 'object' and 'properties' in prop_schema:
|
||||||
filtered[key] = _filter_config_by_schema(value, prop_schema, f"{prefix}.{key}" if prefix else key)
|
filtered[key] = _filter_config_by_schema(value, prop_schema, item_prefix)
|
||||||
|
elif isinstance(value, list) and prop_schema.get('type') == 'array':
|
||||||
|
items_schema = prop_schema.get('items', {})
|
||||||
|
if isinstance(items_schema, dict) and items_schema.get('type') == 'object' and 'properties' in items_schema:
|
||||||
|
# Filter each item in the array so extra fields are stripped before
|
||||||
|
# schema validation (important when items has additionalProperties: false)
|
||||||
|
filtered[key] = [
|
||||||
|
_filter_config_by_schema(item, items_schema, item_prefix) if isinstance(item, dict) else item
|
||||||
|
for item in value
|
||||||
|
]
|
||||||
else:
|
else:
|
||||||
# Keep the value as-is for non-object types
|
filtered[key] = value
|
||||||
|
else:
|
||||||
|
# Keep the value as-is for non-object/non-array types
|
||||||
filtered[key] = value
|
filtered[key] = value
|
||||||
|
|
||||||
return filtered
|
return filtered
|
||||||
@@ -7564,6 +7594,126 @@ _STARLARK_APPS_DIR = PROJECT_ROOT / 'starlark-apps'
|
|||||||
_STARLARK_MANIFEST_FILE = _STARLARK_APPS_DIR / 'manifest.json'
|
_STARLARK_MANIFEST_FILE = _STARLARK_APPS_DIR / 'manifest.json'
|
||||||
|
|
||||||
|
|
||||||
|
def _find_pixlet_binary(explicit_path: Optional[str] = None) -> Optional[str]:
|
||||||
|
"""Find pixlet binary: explicit path → bundled binary → system PATH."""
|
||||||
|
import platform
|
||||||
|
if explicit_path and os.path.isfile(explicit_path) and os.access(explicit_path, os.X_OK):
|
||||||
|
return explicit_path
|
||||||
|
bin_dir = PROJECT_ROOT / "bin" / "pixlet"
|
||||||
|
system = platform.system().lower()
|
||||||
|
machine = platform.machine().lower()
|
||||||
|
if system == "linux":
|
||||||
|
if "aarch64" in machine or "arm64" in machine:
|
||||||
|
name = "pixlet-linux-arm64"
|
||||||
|
elif "x86_64" in machine or "amd64" in machine:
|
||||||
|
name = "pixlet-linux-amd64"
|
||||||
|
else:
|
||||||
|
name = None
|
||||||
|
elif system == "darwin":
|
||||||
|
name = "pixlet-darwin-arm64" if "arm64" in machine else "pixlet-darwin-amd64"
|
||||||
|
else:
|
||||||
|
name = None
|
||||||
|
if name:
|
||||||
|
bundled = bin_dir / name
|
||||||
|
if bundled.is_file():
|
||||||
|
if os.access(str(bundled), os.X_OK):
|
||||||
|
return str(bundled)
|
||||||
|
try:
|
||||||
|
bundled.chmod(0o755)
|
||||||
|
except OSError:
|
||||||
|
logger.warning("Could not make pixlet bundled binary executable (%s); falling back to PATH", bundled)
|
||||||
|
else:
|
||||||
|
if os.access(str(bundled), os.X_OK):
|
||||||
|
return str(bundled)
|
||||||
|
logger.warning("Pixlet bundled binary still not executable after chmod (%s); falling back to PATH", bundled)
|
||||||
|
return shutil.which("pixlet")
|
||||||
|
|
||||||
|
|
||||||
|
def _standalone_render_starlark_app(app_id: str) -> Tuple[bool, int, Optional[str]]:
|
||||||
|
"""Render a Starlark app via pixlet directly (no plugin required).
|
||||||
|
|
||||||
|
Reads the .star file and config from starlark-apps/{app_id}/, runs pixlet,
|
||||||
|
and saves the output to cached_render.webp in the same directory.
|
||||||
|
This is the web-service fallback when starlark-apps plugin is not loaded.
|
||||||
|
|
||||||
|
Returns (success, http_status_code, error_message).
|
||||||
|
"""
|
||||||
|
manifest = _read_starlark_manifest()
|
||||||
|
if not isinstance(manifest, dict):
|
||||||
|
return False, 400, "Invalid manifest shape: expected object with 'apps' mapping"
|
||||||
|
apps = manifest.get('apps', {})
|
||||||
|
if not isinstance(apps, dict):
|
||||||
|
return False, 400, "Invalid manifest shape: expected object with 'apps' mapping"
|
||||||
|
app_data = apps.get(app_id)
|
||||||
|
if not app_data:
|
||||||
|
return False, 404, f"App not found: {app_id}"
|
||||||
|
|
||||||
|
app_dir = _STARLARK_APPS_DIR / app_id
|
||||||
|
star_file = app_dir / app_data.get('star_file', f'{app_id}.star')
|
||||||
|
if not star_file.exists():
|
||||||
|
return False, 404, f"Star file not found: {star_file}"
|
||||||
|
|
||||||
|
full_config = api_v3.config_manager.load_config() if api_v3.config_manager else {}
|
||||||
|
plugin_config = full_config.get('starlark-apps', {})
|
||||||
|
|
||||||
|
pixlet_path = _find_pixlet_binary(plugin_config.get('pixlet_path'))
|
||||||
|
if not pixlet_path:
|
||||||
|
return False, 503, "Pixlet binary not found — install pixlet first"
|
||||||
|
|
||||||
|
magnify = plugin_config.get('magnify')
|
||||||
|
if magnify is None:
|
||||||
|
hw = full_config.get('display', {}).get('hardware', {})
|
||||||
|
cols = hw.get('cols', 64)
|
||||||
|
chain = hw.get('chain_length', 1)
|
||||||
|
rows = hw.get('rows', 32)
|
||||||
|
magnify = max(1, min(8, int(min((cols * chain) / 64, rows / 32))))
|
||||||
|
else:
|
||||||
|
try:
|
||||||
|
magnify = max(1, min(8, int(magnify)))
|
||||||
|
except (ValueError, TypeError):
|
||||||
|
magnify = 1
|
||||||
|
|
||||||
|
config_file = app_dir / 'config.json'
|
||||||
|
app_config: Dict[str, Any] = {}
|
||||||
|
if config_file.exists():
|
||||||
|
try:
|
||||||
|
with open(config_file) as f:
|
||||||
|
app_config = json.load(f)
|
||||||
|
except json.JSONDecodeError as e:
|
||||||
|
return False, 400, f"Invalid config.json for {app_id} ({config_file}): {e}"
|
||||||
|
except OSError as e:
|
||||||
|
return False, 400, f"Cannot read config.json for {app_id} ({config_file}): {e}"
|
||||||
|
if not isinstance(app_config, dict):
|
||||||
|
return False, 400, (
|
||||||
|
f"config.json for {app_id} must be a JSON object, "
|
||||||
|
f"got {type(app_config).__name__}"
|
||||||
|
)
|
||||||
|
|
||||||
|
INTERNAL_KEYS = {'render_interval', 'display_duration'}
|
||||||
|
pixlet_config = {k: v for k, v in app_config.items() if k not in INTERNAL_KEYS}
|
||||||
|
|
||||||
|
output_path = str(app_dir / 'cached_render.webp')
|
||||||
|
cmd = [pixlet_path, 'render', str(star_file)]
|
||||||
|
for key, value in pixlet_config.items():
|
||||||
|
if not re.match(r'^[a-zA-Z_][a-zA-Z0-9_]*$', key):
|
||||||
|
continue
|
||||||
|
value_str = 'true' if value is True else 'false' if value is False else str(value)
|
||||||
|
if re.search(r'[`$|<>&;\x00]|\$\(', value_str):
|
||||||
|
continue
|
||||||
|
cmd.append(f'{key}={value_str}')
|
||||||
|
cmd.extend(['-o', output_path, '-m', str(magnify)])
|
||||||
|
|
||||||
|
try:
|
||||||
|
result = subprocess.run(cmd, capture_output=True, text=True, timeout=30, cwd=str(app_dir))
|
||||||
|
if result.returncode == 0 and os.path.isfile(output_path):
|
||||||
|
return True, 200, None
|
||||||
|
return False, 502, f"Pixlet failed (exit {result.returncode}): {result.stderr.strip()}"
|
||||||
|
except subprocess.TimeoutExpired:
|
||||||
|
return False, 504, "Render timed out after 30s"
|
||||||
|
except Exception as e:
|
||||||
|
return False, 500, f"Render error: {e}"
|
||||||
|
|
||||||
|
|
||||||
def _read_starlark_manifest() -> Dict[str, Any]:
|
def _read_starlark_manifest() -> Dict[str, Any]:
|
||||||
"""Read the starlark-apps manifest.json directly from disk."""
|
"""Read the starlark-apps manifest.json directly from disk."""
|
||||||
try:
|
try:
|
||||||
@@ -7683,24 +7833,11 @@ def get_starlark_status():
|
|||||||
'display_info': magnify_info
|
'display_info': magnify_info
|
||||||
})
|
})
|
||||||
|
|
||||||
# Plugin not loaded - check Pixlet availability directly
|
# Plugin not loaded - check Pixlet availability via shared resolver
|
||||||
import shutil
|
# (respects user-configured pixlet_path, bundled binary, and system PATH)
|
||||||
import platform
|
full_config = api_v3.config_manager.load_config() if api_v3.config_manager else {}
|
||||||
|
pixlet_path = _find_pixlet_binary(full_config.get('starlark-apps', {}).get('pixlet_path'))
|
||||||
system = platform.system().lower()
|
pixlet_available = pixlet_path is not None
|
||||||
machine = platform.machine().lower()
|
|
||||||
bin_dir = PROJECT_ROOT / 'bin' / 'pixlet'
|
|
||||||
|
|
||||||
pixlet_binary = None
|
|
||||||
if system == "linux":
|
|
||||||
if "aarch64" in machine or "arm64" in machine:
|
|
||||||
pixlet_binary = bin_dir / "pixlet-linux-arm64"
|
|
||||||
elif "x86_64" in machine or "amd64" in machine:
|
|
||||||
pixlet_binary = bin_dir / "pixlet-linux-amd64"
|
|
||||||
elif system == "darwin":
|
|
||||||
pixlet_binary = bin_dir / ("pixlet-darwin-arm64" if "arm64" in machine else "pixlet-darwin-amd64")
|
|
||||||
|
|
||||||
pixlet_available = (pixlet_binary and pixlet_binary.exists()) or shutil.which('pixlet') is not None
|
|
||||||
|
|
||||||
# Read app counts from manifest
|
# Read app counts from manifest
|
||||||
manifest = _read_starlark_manifest()
|
manifest = _read_starlark_manifest()
|
||||||
@@ -8153,20 +8290,27 @@ def toggle_starlark_app(app_id):
|
|||||||
def render_starlark_app(app_id):
|
def render_starlark_app(app_id):
|
||||||
"""Force render a Starlark app."""
|
"""Force render a Starlark app."""
|
||||||
try:
|
try:
|
||||||
starlark_plugin = _get_starlark_plugin()
|
is_valid, err = _validate_starlark_app_path(app_id)
|
||||||
if not starlark_plugin:
|
if not is_valid:
|
||||||
return jsonify({'status': 'error', 'message': 'Rendering requires the main LEDMatrix service (plugin not loaded in web service)'}), 503
|
return jsonify({'status': 'error', 'message': err}), 400
|
||||||
|
|
||||||
|
starlark_plugin = _get_starlark_plugin()
|
||||||
|
if starlark_plugin:
|
||||||
app = starlark_plugin.apps.get(app_id)
|
app = starlark_plugin.apps.get(app_id)
|
||||||
if not app:
|
if not app:
|
||||||
return jsonify({'status': 'error', 'message': f'App not found: {app_id}'}), 404
|
return jsonify({'status': 'error', 'message': f'App not found: {app_id}'}), 404
|
||||||
|
|
||||||
success = starlark_plugin._render_app(app, force=True)
|
success = starlark_plugin._render_app(app, force=True)
|
||||||
if success:
|
if success:
|
||||||
return jsonify({'status': 'success', 'message': 'App rendered', 'frame_count': len(app.frames) if app.frames else 0})
|
return jsonify({'status': 'success', 'message': 'App rendered',
|
||||||
else:
|
'frame_count': len(app.frames) if app.frames else 0})
|
||||||
return jsonify({'status': 'error', 'message': 'Failed to render app'}), 500
|
return jsonify({'status': 'error', 'message': 'Failed to render app'}), 500
|
||||||
|
|
||||||
|
# Web-service context: plugin not loaded, call pixlet directly
|
||||||
|
success, status_code, error = _standalone_render_starlark_app(app_id)
|
||||||
|
if success:
|
||||||
|
return jsonify({'status': 'success', 'message': 'App rendered successfully', 'frame_count': 0}), status_code
|
||||||
|
return jsonify({'status': 'error', 'message': error or 'Render failed', 'frame_count': 0}), status_code
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.exception("[Starlark] render_starlark_app failed")
|
logger.exception("[Starlark] render_starlark_app failed")
|
||||||
return jsonify({'status': 'error', 'message': 'Failed to render Starlark app'}), 500
|
return jsonify({'status': 'error', 'message': 'Failed to render Starlark app'}), 500
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
from flask import Blueprint, render_template, request, redirect, url_for, flash, jsonify
|
from flask import Blueprint, render_template, request, redirect, url_for, flash, jsonify
|
||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
from html import escape as html_escape
|
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from src.web_interface.secret_helpers import mask_secret_fields
|
from src.web_interface.secret_helpers import mask_secret_fields
|
||||||
|
|
||||||
@@ -355,7 +354,7 @@ def _load_plugin_config_partial(plugin_id):
|
|||||||
plugin_info = pages_v3.plugin_manager.get_plugin_info(plugin_id)
|
plugin_info = pages_v3.plugin_manager.get_plugin_info(plugin_id)
|
||||||
|
|
||||||
if not plugin_info:
|
if not plugin_info:
|
||||||
return f'<div class="text-red-500 p-4">Plugin "{html_escape(plugin_id)}" not found</div>', 404
|
return f'<div class="text-red-500 p-4">Plugin "{plugin_id}" not found</div>', 404
|
||||||
|
|
||||||
# Get plugin instance (may be None if not loaded)
|
# Get plugin instance (may be None if not loaded)
|
||||||
plugin_instance = pages_v3.plugin_manager.get_plugin(plugin_id)
|
plugin_instance = pages_v3.plugin_manager.get_plugin(plugin_id)
|
||||||
|
|||||||
@@ -91,7 +91,7 @@
|
|||||||
const xOptions = config['x-options'] || config['x_options'] || {};
|
const xOptions = config['x-options'] || config['x_options'] || {};
|
||||||
const requestedFormat = xOptions.format || 'long';
|
const requestedFormat = xOptions.format || 'long';
|
||||||
// Validate format exists in DAY_LABELS, default to 'long' if not
|
// Validate format exists in DAY_LABELS, default to 'long' if not
|
||||||
const format = Object.prototype.hasOwnProperty.call(DAY_LABELS, requestedFormat) ? requestedFormat : 'long';
|
const format = DAY_LABELS.hasOwnProperty(requestedFormat) ? requestedFormat : 'long';
|
||||||
const layout = xOptions.layout || 'horizontal';
|
const layout = xOptions.layout || 'horizontal';
|
||||||
const showSelectAll = xOptions.selectAll !== false;
|
const showSelectAll = xOptions.selectAll !== false;
|
||||||
|
|
||||||
|
|||||||
@@ -1225,10 +1225,10 @@ function initializePlugins() {
|
|||||||
window.pluginManager._reswap = false;
|
window.pluginManager._reswap = false;
|
||||||
// Await the installed-plugins fetch so window.installedPlugins is populated before
|
// Await the installed-plugins fetch so window.installedPlugins is populated before
|
||||||
// searchPluginStore renders Installed/Reinstall badges against it.
|
// searchPluginStore renders Installed/Reinstall badges against it.
|
||||||
loadInstalledPlugins().then(() => {
|
loadInstalledPlugins().catch(err => {
|
||||||
searchPluginStore(!isReswapWarm);
|
|
||||||
}).catch(err => {
|
|
||||||
console.error('[PluginStore] loadInstalledPlugins failed:', err);
|
console.error('[PluginStore] loadInstalledPlugins failed:', err);
|
||||||
|
}).finally(() => {
|
||||||
|
searchPluginStore(!isReswapWarm);
|
||||||
});
|
});
|
||||||
|
|
||||||
// Setup search functionality (with guard against duplicate listeners)
|
// Setup search functionality (with guard against duplicate listeners)
|
||||||
@@ -4853,9 +4853,9 @@ window.executePluginAction = function(actionId, actionIndex, pluginIdParam = nul
|
|||||||
showNotification(data.message || 'Action completed successfully!', 'success');
|
showNotification(data.message || 'Action completed successfully!', 'success');
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
statusDiv.innerHTML = `<div class="text-red-600"><i class="fas fa-exclamation-circle mr-2"></i>${data.message}</div>`;
|
statusDiv.innerHTML = `<div class="text-red-600"><i class="fas fa-exclamation-circle mr-2"></i>${escapeHtml(data.message || 'Error')}</div>`;
|
||||||
if (data.output) {
|
if (data.output) {
|
||||||
statusDiv.innerHTML += `<pre class="mt-2 text-xs bg-red-50 p-2 rounded overflow-auto max-h-32">${data.output}</pre>`;
|
statusDiv.innerHTML += `<pre class="mt-2 text-xs bg-red-50 p-2 rounded overflow-auto max-h-32">${escapeHtml(data.output)}</pre>`;
|
||||||
}
|
}
|
||||||
btn.innerHTML = originalText;
|
btn.innerHTML = originalText;
|
||||||
btn.disabled = false;
|
btn.disabled = false;
|
||||||
@@ -4899,8 +4899,8 @@ window.executePluginAction = function(actionId, actionIndex, pluginIdParam = nul
|
|||||||
</div>
|
</div>
|
||||||
<div class="mb-3">
|
<div class="mb-3">
|
||||||
<p class="text-sm text-blue-700 mb-2">1. Click the link below to authorize:</p>
|
<p class="text-sm text-blue-700 mb-2">1. Click the link below to authorize:</p>
|
||||||
<a href="${data.auth_url}" target="_blank" class="text-blue-600 hover:text-blue-800 underline break-all">
|
<a href="${data.auth_url && data.auth_url.startsWith('http') ? escapeHtml(data.auth_url) : '#'}" target="_blank" class="text-blue-600 hover:text-blue-800 underline break-all">
|
||||||
${data.auth_url}
|
${escapeHtml(data.auth_url || '')}
|
||||||
</a>
|
</a>
|
||||||
</div>
|
</div>
|
||||||
<div class="mb-2">
|
<div class="mb-2">
|
||||||
@@ -4922,7 +4922,7 @@ window.executePluginAction = function(actionId, actionIndex, pluginIdParam = nul
|
|||||||
<div class="text-green-900 font-medium mb-2">
|
<div class="text-green-900 font-medium mb-2">
|
||||||
<i class="fas fa-check-circle mr-2"></i>${data.message || 'Action completed successfully'}
|
<i class="fas fa-check-circle mr-2"></i>${data.message || 'Action completed successfully'}
|
||||||
</div>
|
</div>
|
||||||
${data.output ? `<pre class="mt-2 text-xs bg-green-50 p-2 rounded overflow-auto max-h-32">${data.output}</pre>` : ''}
|
${data.output ? `<pre class="mt-2 text-xs bg-green-50 p-2 rounded overflow-auto max-h-32">${escapeHtml(data.output)}</pre>` : ''}
|
||||||
</div>
|
</div>
|
||||||
`;
|
`;
|
||||||
btn.innerHTML = originalText;
|
btn.innerHTML = originalText;
|
||||||
@@ -4935,9 +4935,9 @@ window.executePluginAction = function(actionId, actionIndex, pluginIdParam = nul
|
|||||||
statusDiv.innerHTML = `
|
statusDiv.innerHTML = `
|
||||||
<div class="bg-red-50 border border-red-200 rounded p-3">
|
<div class="bg-red-50 border border-red-200 rounded p-3">
|
||||||
<div class="text-red-900 font-medium mb-2">
|
<div class="text-red-900 font-medium mb-2">
|
||||||
<i class="fas fa-exclamation-circle mr-2"></i>${data.message || 'Action failed'}
|
<i class="fas fa-exclamation-circle mr-2"></i>${escapeHtml(data.message || 'Action failed')}
|
||||||
</div>
|
</div>
|
||||||
${data.output ? `<pre class="mt-2 text-xs bg-red-50 p-2 rounded overflow-auto max-h-32">${data.output}</pre>` : ''}
|
${data.output ? `<pre class="mt-2 text-xs bg-red-50 p-2 rounded overflow-auto max-h-32">${escapeHtml(data.output)}</pre>` : ''}
|
||||||
</div>
|
</div>
|
||||||
`;
|
`;
|
||||||
btn.innerHTML = originalText;
|
btn.innerHTML = originalText;
|
||||||
@@ -8067,4 +8067,3 @@ setTimeout(function() {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
})();
|
})();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user