merge: pull latest master into dev

Resolved conflicts:
- openai_source.py: keep dev version with abort_signal filtering
- customizer.ts: keep dev version with viewMode functionality
- useSessions.ts: keep dev version with pendingSessionId handling
- platformUtils.js: keep dev version with correct tutorial links
- AddNewPlatform.vue: keep dev version with correct docs link
- FullLayout.vue: keep dev version with viewMode-based logic
- VerticalHeader.vue: keep dev version with viewMode-based logic

Author: LIghtJUNction

astrbot/_internal/abc/abp/base_astrbot_abp_client.py

@@ -0,0 +1,57 @@
+"""
+ABP (AstrBot Protocol) client - in-process star communication.
+"""
+
+from __future__ import annotations
+
+from abc import ABC, abstractmethod
+from typing import Any
+
+
+class BaseAstrbotAbpClient(ABC):
+    """
+    ABP client: in-process star (plugin) communication.
+
+    Stars register themselves; client delegates calls to registered instances.
+
+    Subclass must implement:
+    - connect() -> None
+    - register_star(name, instance) -> None
+    - unregister_star(name) -> None
+    - call_star_tool(star, tool, args) -> Any
+    - shutdown() -> None
+    """
+
+    @property
+    @abstractmethod
+    def connected(self) -> bool: ...
+
+    @abstractmethod
+    async def connect(self) -> None:
+        """Lightweight: just sets connected=True."""
+        ...
+
+    @abstractmethod
+    def register_star(self, star_name: str, star_instance: Any) -> None:
+        """Add star to internal registry."""
+        ...
+
+    @abstractmethod
+    def unregister_star(self, star_name: str) -> None:
+        """Remove star from registry (idempotent)."""
+        ...
+
+    @abstractmethod
+    async def call_star_tool(
+        self,
+        star_name: str,
+        tool_name: str,
+        arguments: dict[str, Any],
+    ) -> Any:
+        """Delegate to star_instance.call_tool(tool_name, arguments)."""
+        ...
+
+    @abstractmethod
+    async def shutdown(self) -> None:
+        """Set connected=False, cancel pending requests."""
+        ...

astrbot/_internal/abc/acp/base_astrbot_acp_client.py

@@ -0,0 +1,66 @@
+"""
+ACP (AstrBot Communication Protocol) client.
+
+Transport: TCP | Unix Socket
+Messages:  JSON with Content-Length header
+"""
+
+from __future__ import annotations
+
+from abc import ABC, abstractmethod
+from typing import Any
+
+
+class BaseAstrbotAcpClient(ABC):
+    """
+    ACP client: connects to ACP servers via TCP or Unix socket.
+
+    Subclass must implement:
+    - connect() -> None
+    - connect_to_server(host, port) -> None
+    - connect_to_unix_socket(path) -> None
+    - call_tool(server, tool, args) -> Any
+    - send_notification(method, params) -> None
+    - shutdown() -> None
+    """
+
+    @property
+    @abstractmethod
+    def connected(self) -> bool: ...
+
+    @abstractmethod
+    async def connect(self) -> None: ...
+
+    @abstractmethod
+    async def connect_to_server(self, host: str, port: int) -> None:
+        """Connect via TCP."""
+        ...
+
+    @abstractmethod
+    async def connect_to_unix_socket(self, socket_path: str) -> None:
+        """Connect via Unix domain socket."""
+        ...
+
+    @abstractmethod
+    async def call_tool(
+        self,
+        server_name: str,
+        tool_name: str,
+        arguments: dict[str, Any],
+    ) -> Any:
+        """Call tool on server, return result."""
+        ...
+
+    @abstractmethod
+    async def send_notification(
+        self,
+        method: str,
+        params: dict[str, Any],
+    ) -> None:
+        """Send one-way notification."""
+        ...
+
+    @abstractmethod
+    async def shutdown(self) -> None:
+        """Close connection, cancel pending requests."""
+        ...

astrbot/_internal/abc/acp/base_astrbot_acp_server.py

@@ -0,0 +1,68 @@
+"""
+ACP (AstrBot Communication Protocol) server.
+
+Transport: TCP listening socket
+Messages:  JSON with Content-Length header
+"""
+
+from __future__ import annotations
+
+from abc import ABC, abstractmethod
+from collections.abc import Callable
+from typing import Any
+
+
+class BaseAstrbotAcpServer(ABC):
+    """
+    ACP server: listens for client connections, exposes tools.
+
+    Subclass must implement:
+    - start(host, port) -> None
+    - register_tool(name, handler) -> None
+    - register_notification_handler(name, handler) -> None
+    - broadcast_notification(method, params) -> None
+    - shutdown() -> None
+    """
+
+    @property
+    @abstractmethod
+    def running(self) -> bool:
+        """True if server is accepting connections."""
+        ...
+
+    @abstractmethod
+    async def start(self, host: str = "127.0.0.1", port: int = 8765) -> None:
+        """Bind and listen. Block until shutdown."""
+        ...
+
+    @abstractmethod
+    def register_tool(
+        self,
+        name: str,
+        handler: Callable[..., Any],
+    ) -> None:
+        """Register async tool handler (receives params dict, returns result)."""
+        ...
+
+    @abstractmethod
+    def register_notification_handler(
+        self,
+        name: str,
+        handler: Callable[..., Any],
+    ) -> None:
+        """Register async notification handler (receives params dict)."""
+        ...
+
+    @abstractmethod
+    async def broadcast_notification(
+        self,
+        method: str,
+        params: dict[str, Any],
+    ) -> None:
+        """Send notification to all connected clients."""
+        ...
+
+    @abstractmethod
+    async def shutdown(self) -> None:
+        """Stop accepting, close all client connections."""
+        ...

astrbot/_internal/abc/base_astrbot_gateway.py

@@ -0,0 +1,73 @@
+"""
+AstrBot Gateway - HTTP/WebSocket API server.
+
+Built on FastAPI, provides:
+- HTTP REST API (stats, inspector, config)
+- WebSocket for real-time events
+- Static file serving (dashboard)
+- Authentication (JWT/API key)
+"""
+
+from __future__ import annotations
+
+from abc import ABC, abstractmethod
+
+
+class BaseAstrbotGateway(ABC):
+    """
+    Gateway: HTTP/WebSocket server built on FastAPI.
+
+    ┌─────────────────────────────────────────────────────────┐
+    │                      FastAPI App                        │
+    ├─────────────────────────────────────────────────────────┤
+    │  REST Endpoints              WebSocket                  │
+    │  ├─ GET /api/stats          ├─ /ws (connection manager)│
+    │  ├─ GET /api/inspector/*   │                          │
+    │  ├─ GET /api/memory/*      │                          │
+    │  └─ ...                    │                          │
+    │                                                         │
+    │  Middleware: CORS, Auth, Logging                        │
+    └─────────────────────────────────────────────────────────┘
+                          │
+                          ▼
+              ┌─────────────────────────┐
+              │     Orchestrator        │
+              │  (owns protocol clients)│
+              └─────────────────────────┘
+
+    Routes (typical):
+        GET  /              → Dashboard static files
+        GET  /api/stats     → System statistics
+        GET  /api/inspector/stars → List registered stars
+        WS   /ws            → WebSocket for real-time events
+
+    serve() Lifecycle:
+        1. Create FastAPI app
+        2. Register routes
+        3. Start WebSocket manager
+        4. Bind to host:port
+        5. Run ASGI server (uvicorn/hypercorn)
+        6. Block until shutdown
+        7. Close all connections
+
+    Subclass must implement:
+    - serve(): start server, block until shutdown
+    """
+
+    @abstractmethod
+    async def serve(self) -> None:
+        """
+        Start gateway server - blocks until shutdown.
+
+        Should:
+        1. Create FastAPI app with routes
+        2. Configure CORS, auth middleware
+        3. Start WebSocket connection manager
+        4. Bind to ASTRBOT_PORT (default 6185)
+        5. Run ASGI server
+        6. Handle graceful shutdown on SIGTERM/SIGINT
+
+        Raises:
+            OSError: address already in use
+        """
+        ...