feat: enhance plugin host service capabilities (#68)

Author: gqcn

.agents/rules/dev-tooling.md

@@ -23,9 +23,6 @@
 
 - `hack/tools/linactl/`下承载具体`make`或`linactl`命令实现的源码文件，必须按对应命令名称命名为`command_<command>.go`。
 - `<command>`保持命令的点分段语义。例如`make dev`对应`command_dev.go`，`make build`对应`command_build.go`，`make env.setup`对应`command_env.setup.go`。
-- 同一文件只应承载该命令的主实现及其紧密私有辅助逻辑。
-- 跨命令复用能力应提取到职责明确的非命令文件或内部组件。
-- 禁止继续把多个无直接归属的命令混放到`command_ops.go`这类兜底文件中。
 - 若命令名与 Go 工具链文件后缀规则冲突，必须使用明确的命令专属后缀并记录原因，例如`test`命令使用`command_testcmd.go`，`wasm`命令使用`command_wasmcmd.go`。
 
 ## linactl 子组件组织要求

.agents/rules/plugin.md

@@ -16,8 +16,6 @@ apps/lina-plugins/<plugin-id>/
 ├── Makefile                         # 插件make指令入口
 ├── backend/
 │   ├── api/                         # API DTO与路由契约
-│   ├── hack/
-│   │   └── config.yaml              # make dao等插件开发配置
 │   ├── internal/
 │   │   ├── controller/              # HTTP控制器
 │   │   ├── service/                 # 业务服务层
@@ -28,6 +26,7 @@ apps/lina-plugins/<plugin-id>/
 │   ├── pages/                       # 插件页面
 │   └── slots/                       # 插槽页面，可选
 ├── hack/                            # 插件自身脚本和工具
+│   ├── config.yaml                  # 插件开发期工具配置入口，包含代码生成、自定义构建等配置
 │   └── tests/                       # 插件测试内容
 │       └── e2e/                     # 插件 e2e 测试内容
 ├── manifest/
@@ -57,6 +56,8 @@ apps/lina-plugins/<plugin-id>/
 - 插件多语言资源放在`manifest/i18n/<locale>/`，API 文档翻译资源放在`manifest/i18n/<locale>/apidoc/`。
 - 插件 SQL 必须遵守`.agents/rules/database.md`。
 - 插件 i18n 资源必须遵守`.agents/rules/i18n.md`。
+- 插件开发期工具配置统一维护在插件根`hack/config.yaml`，包括代码生成、自定义构建等插件本地工具配置。
+- 插件自定义构建指令统一放在插件根`hack/config.yaml`的`build.commands`下，由仓库根`make build`或`linactl build`读取执行。
 
 ## 插件后端同构开发结构要求
 
@@ -69,7 +70,7 @@ apps/lina-plugins/<plugin-id>/
 
 ## 插件数据库访问要求
 
-- 插件的后端代码生成工具配置维护在`backend/hack/config.yaml`。
+- 涉及数据库访问的插件应在插件根`hack/config.yaml`中维护`gfcli.gen.dao`等代码生成工具配置，GoFrame 生成工作目录仍为插件`backend/`。
 - 禁止插件重新依赖宿主的`dao/do/entity`生成工件。
 - 动态插件涉及宿主数据访问时，必须通过`plugin.yaml`的`hostServices`资源边界和宿主授权的 host service 协议。
 

.agents/skills/lina-perf-audit/scripts/setup-audit-env.sh

@@ -307,7 +307,7 @@ BACKUP_FILE="$RUN_DIR/logger-backup.json"
 TOKEN_FILE="$RUN_DIR/token.txt"
 TRACE_CHECK_FILE="$RUN_DIR/trace-id-check.txt"
 BACKEND_BINARY="temp/bin/lina-perf-audit-backend"
-BACKEND_PID_FILE="temp/pids/backend.pid"
+BACKEND_PID_FILE="temp/pids/lina-core.pid"
 LOGGER_PATH="${RUN_DIR}/"
 LOGGER_FILE="server.log"
 HEALTH_URL="http://127.0.0.1:9120/api/v1/health"

.github/workflows/reusable-make-command-smoke.yml

@@ -146,11 +146,11 @@ jobs:
 
           make -C "$smoke_root" dev plugins=0 BACKEND_PORT="$backend_port" FRONTEND_PORT="$frontend_port"
           make -C "$smoke_root" status BACKEND_PORT="$backend_port" FRONTEND_PORT="$frontend_port" | tee "$RUNNER_TEMP/dev-status.txt"
-          grep -q "Backend" "$RUNNER_TEMP/dev-status.txt"
-          grep -q "Frontend" "$RUNNER_TEMP/dev-status.txt"
+          grep -q "Lina Core" "$RUNNER_TEMP/dev-status.txt"
+          grep -q "Lina Vben" "$RUNNER_TEMP/dev-status.txt"
           make -C "$smoke_root" stop BACKEND_PORT="$backend_port" FRONTEND_PORT="$frontend_port"
-          test ! -f "$smoke_root/temp/pids/backend.pid"
-          test ! -f "$smoke_root/temp/pids/frontend.pid"
+          test ! -f "$smoke_root/temp/pids/lina-core.pid"
+          test ! -f "$smoke_root/temp/pids/lina-vben.pid"
 
       # Verify wasm through a real isolated dynamic plugin build and artifact assertion.
       # 通过真实隔离动态插件构建和产物断言验证 wasm 指令。

Makefile

@@ -5,8 +5,8 @@ BACKEND_DIR   := apps/lina-core
 FRONTEND_DIR  := apps/lina-vben
 TEMP_DIR      := temp
 PID_DIR       := $(TEMP_DIR)/pids
-BACKEND_PID   := $(PID_DIR)/backend.pid
-FRONTEND_PID  := $(PID_DIR)/frontend.pid
+BACKEND_PID   := $(PID_DIR)/lina-core.pid
+FRONTEND_PID  := $(PID_DIR)/lina-vben.pid
 BACKEND_PORT  := 9120
 FRONTEND_PORT := 5666
 BACKEND_LOG   := $(TEMP_DIR)/lina-core.log

apps/lina-core/api/usermsg/v1/usermsg_get.go

@@ -20,7 +20,7 @@ type GetRes struct {
 	TypeLabel     string     `json:"typeLabel" dc:"Localized category label resolved by the host according to the request locale" eg:"Notice"`
 	TypeColor     string     `json:"typeColor" dc:"Localized category tag color resolved by the host so the inbox preview can render badges without hardcoding category-specific colors" eg:"blue"`
 	SourceType    SourceType `json:"sourceType" dc:"Source type: notice=notification announcement plugin=dynamic plugin system=system" eg:"notice"`
-	SourceId      int64      `json:"sourceId" dc:"Source ID" eg:"1001"`
+	SourceId      string     `json:"sourceId" dc:"Original sender-declared source record ID" eg:"notice-1001"`
 	Content       string     `json:"content" dc:"Can be used directly to preview rendered message content" eg:"<p>The system will be undergoing maintenance tonight</p>"`
 	CreatedByName string     `json:"createdByName" dc:"Sender username" eg:"admin"`
 	CreatedAt     *int64     `json:"createdAt" dc:"Message creation time as Unix timestamp in milliseconds" eg:"1776752400000"`

apps/lina-core/api/usermsg/v1/usermsg_list.go

@@ -44,7 +44,7 @@ type MessageItem struct {
 	TypeLabel    string               `json:"typeLabel" dc:"Localized category label resolved by the host according to the request locale" eg:"Notice"`
 	TypeColor    string               `json:"typeColor" dc:"Localized category tag color resolved by the host so the inbox UI can render badges without hardcoding category-specific colors" eg:"blue"`
 	SourceType   SourceType           `json:"sourceType" dc:"Source type: notice=notification announcement plugin=dynamic plugin system=system" eg:"notice"`
-	SourceId     int64                `json:"sourceId" dc:"Source ID, this field is used for the current notification announcement preview" eg:"1001"`
+	SourceId     string               `json:"sourceId" dc:"Original sender-declared source record ID" eg:"notice-1001"`
 	IsRead       statusflag.ReadState `json:"isRead" dc:"Whether it has been read: 0=unread 1=read" eg:"0"`
 	ReadAt       *int64               `json:"readAt" dc:"Read time as Unix timestamp in milliseconds, empty when unread" eg:"1776240000000"`
 	CreatedAt    *int64               `json:"createdAt" dc:"Message creation time as Unix timestamp in milliseconds" eg:"1776238200000"`

apps/lina-core/internal/cmd/internal/httpstartup/http.go

@@ -51,5 +51,5 @@ func Run(ctx context.Context) error {
 	dispatchSystemStartedHook(ctx, runtime.pluginSvc)
 
 	server.Run()
-	return shutdownHTTPRuntime(ctx, runtime, configSvc)
+	return shutdownHTTPRuntime(ctx, runtime, server)
 }

apps/lina-core/internal/cmd/internal/httpstartup/http_runtime.go

@@ -145,13 +145,6 @@ func configureHTTPServer(
 		return err
 	}
 
-	shutdownCfg := configSvc.GetShutdown(ctx)
-	if shutdownCfg != nil && shutdownCfg.Timeout > 0 {
-		timeoutSeconds := durationSeconds(shutdownCfg.Timeout)
-		server.SetGracefulTimeout(timeoutSeconds)
-		server.SetGracefulShutdownTimeout(timeoutSeconds)
-	}
-
 	// Request-size limits are enforced by host middleware so multipart uploads
 	// can follow the runtime-effective sys.upload.maxSize value per request
 	// instead of being clipped by GoFrame's static 8MB default at server entry.
@@ -262,13 +255,8 @@ func newHTTPRuntime(ctx context.Context, configSvc config.Service) (*httpRuntime
 		closeHTTPCoordinationAfterInitError(ctx, coordinationSvc)
 		return nil, err
 	}
-	pluginStorageCfg := configSvc.GetPluginStorage(ctx)
-	storageRuntime := pluginsvc.NewStorageProviderRuntime(configSvc, pluginRuntime)
-	localStorageProvider := pluginsvc.NewLocalStorageProvider(
-		configSvc.GetPluginDynamicStoragePath(ctx),
-		clusterSvc != nil && clusterSvc.IsEnabled(),
-		pluginStorageCfg.AllowLocalProviderInCluster,
-	)
+	storageRuntime := pluginsvc.NewStorageProviderRuntime(pluginRuntime)
+	localStorageProvider := pluginsvc.NewLocalStorageProvider(configSvc.GetPluginDynamicStoragePath(ctx))
 	capabilities, err := pluginsvc.NewHostServices(
 		apiDocSvc,
 		authSvc,
@@ -590,9 +578,9 @@ func logHTTPStartupSummary(ctx context.Context, collector *startupstats.Collecto
 
 // shutdownHTTPRuntime stops non-HTTP runtime components after GoFrame Server.Run
 // has handled signal listening and HTTP graceful shutdown.
-func shutdownHTTPRuntime(ctx context.Context, runtime *httpRuntime, configSvc config.Service) error {
+func shutdownHTTPRuntime(ctx context.Context, runtime *httpRuntime, server *ghttp.Server) error {
 	shutdownBaseCtx := context.WithoutCancel(ctx)
-	shutdownTimeout := resolveShutdownTimeout(shutdownBaseCtx, configSvc)
+	shutdownTimeout := resolveRuntimeShutdownTimeout(server)
 	logger.Infof(shutdownBaseCtx, "runtime shutdown requested, timeout=%s", shutdownTimeout)
 
 	shutdownCtx, cancel := context.WithTimeout(shutdownBaseCtx, shutdownTimeout)
@@ -661,24 +649,11 @@ func shutdownStep(ctx context.Context, name string, fn func(context.Context) err
 	}
 }
 
-// resolveShutdownTimeout returns the configured full runtime-shutdown budget.
-func resolveShutdownTimeout(ctx context.Context, configSvc config.Service) time.Duration {
-	if configSvc == nil {
-		return 30 * time.Second
-	}
-	cfg := configSvc.GetShutdown(ctx)
-	if cfg == nil || cfg.Timeout <= 0 {
-		return 30 * time.Second
-	}
-	return cfg.Timeout
-}
-
-// durationSeconds converts a validated duration into whole seconds for
-// GoFrame server configuration.
-func durationSeconds(value time.Duration) int {
-	seconds := int(value / time.Second)
-	if seconds < 1 {
-		return 1
+// resolveRuntimeShutdownTimeout returns the host-owned cleanup budget from the
+// GoFrame HTTP server graceful shutdown configuration already active at startup.
+func resolveRuntimeShutdownTimeout(server *ghttp.Server) time.Duration {
+	if server == nil {
+		return time.Duration(ghttp.NewConfig().GracefulShutdownTimeout) * time.Second
 	}
-	return seconds
+	return time.Duration(server.GetGracefulShutdownTimeout()) * time.Second
 }

apps/lina-core/internal/cmd/internal/httpstartup/http_test.go

@@ -1038,8 +1038,8 @@ func newRouteBindingTestRuntime(ctx context.Context) *httpRuntime {
 		notifySvc,
 		kvCacheSvc,
 		hostLockSvc,
-		pluginsvc.NewStorageProviderRuntime(configSvc, pluginRuntime),
-		pluginsvc.NewLocalStorageProvider(configSvc.GetPluginDynamicStoragePath(ctx), false, false),
+		pluginsvc.NewStorageProviderRuntime(pluginRuntime),
+		pluginsvc.NewLocalStorageProvider(configSvc.GetPluginDynamicStoragePath(ctx)),
 	)
 	if err != nil {
 		panic(err)