feat: refactor plugin capability handling and improve host config service integration

Author: gqcn

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

@@ -76,14 +76,13 @@ jobs:
           backend_port=18080
           frontend_port=15666
 
-          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core/pkg/plugin/capability" "$smoke_root/apps/lina-core/manifest/config" "$smoke_root/apps/lina-core/manifest/sql" "$smoke_root/apps/lina-core/manifest/i18n/en-US" "$smoke_root/apps/lina-core/internal/packed/manifest" "$smoke_root/apps/lina-vben/node_modules/.bin" "$smoke_root/apps/lina-vben/apps/web-antd"
+          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core" "$smoke_root/apps/lina-core/manifest/config" "$smoke_root/apps/lina-core/manifest/sql" "$smoke_root/apps/lina-core/manifest/i18n/en-US" "$smoke_root/apps/lina-core/internal/packed/manifest" "$smoke_root/apps/lina-vben/node_modules/.bin" "$smoke_root/apps/lina-vben/apps/web-antd"
           cp Makefile "$smoke_root/Makefile"
           cp -R hack/makefiles "$smoke_root/hack/makefiles"
           cp -R hack/tools/linactl "$smoke_root/hack/tools/linactl"
           cp apps/lina-core/go.mod "$smoke_root/apps/lina-core/go.mod"
           cp apps/lina-core/go.sum "$smoke_root/apps/lina-core/go.sum"
-          cp -R apps/lina-core/pkg/plugin/pluginbridge "$smoke_root/apps/lina-core/pkg/plugin/pluginbridge"
-          cp -R apps/lina-core/pkg/plugin/capability/data "$smoke_root/apps/lina-core/pkg/plugin/capability/data"
+          cp -R apps/lina-core/pkg "$smoke_root/apps/lina-core/pkg"
           cat > "$smoke_root/go.work" <<'WORK'
           go 1.25.0
 
@@ -161,14 +160,13 @@ jobs:
 
           smoke_root="$RUNNER_TEMP/wasm-command-root"
 
-          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core/pkg/plugin/capability" "$smoke_root/apps/lina-plugins/demo-dynamic"
+          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core" "$smoke_root/apps/lina-plugins/demo-dynamic"
           cp Makefile "$smoke_root/Makefile"
           cp -R hack/makefiles "$smoke_root/hack/makefiles"
           cp -R hack/tools/linactl "$smoke_root/hack/tools/linactl"
           cp apps/lina-core/go.mod "$smoke_root/apps/lina-core/go.mod"
           cp apps/lina-core/go.sum "$smoke_root/apps/lina-core/go.sum"
-          cp -R apps/lina-core/pkg/plugin/pluginbridge "$smoke_root/apps/lina-core/pkg/plugin/pluginbridge"
-          cp -R apps/lina-core/pkg/plugin/capability/data "$smoke_root/apps/lina-core/pkg/plugin/capability/data"
+          cp -R apps/lina-core/pkg "$smoke_root/apps/lina-core/pkg"
           cat > "$smoke_root/go.work" <<'WORK'
           go 1.25.0
 

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

@@ -71,14 +71,13 @@ jobs:
           git -C "$source_dir" add .
           git -C "$source_dir" commit -q -m "initial plugin"
 
-          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core/pkg/plugin/capability"
+          mkdir -p "$smoke_root/hack/tools" "$smoke_root/apps/lina-core"
           cp Makefile "$smoke_root/Makefile"
           cp -R hack/makefiles "$smoke_root/hack/makefiles"
           cp -R hack/tools/linactl "$smoke_root/hack/tools/linactl"
           cp apps/lina-core/go.mod "$smoke_root/apps/lina-core/go.mod"
           cp apps/lina-core/go.sum "$smoke_root/apps/lina-core/go.sum"
-          cp -R apps/lina-core/pkg/plugin/pluginbridge "$smoke_root/apps/lina-core/pkg/plugin/pluginbridge"
-          cp -R apps/lina-core/pkg/plugin/capability/data "$smoke_root/apps/lina-core/pkg/plugin/capability/data"
+          cp -R apps/lina-core/pkg "$smoke_root/apps/lina-core/pkg"
           cat > "$smoke_root/go.work" <<'WORK'
           go 1.25.0
 

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

@@ -238,10 +238,15 @@ func newHTTPRuntime(ctx context.Context, configSvc config.Service) (*httpRuntime
 		closeHTTPCoordinationAfterInitError(ctx, coordinationSvc)
 		return nil, err
 	}
+	hostConfigReader, ok := configSvc.(pluginservicehostconfig.RawConfigReader)
+	if !ok {
+		closeHTTPCoordinationAfterInitError(ctx, coordinationSvc)
+		return nil, gerror.New("host config service does not support raw reads")
+	}
 	var (
 		jobMgmtSvc            = jobmgmtsvc.New(bizCtxSvc, configSvc, i18nSvc, jobRegistry, jobScheduler, scopeSvc)
 		middlewareSvc         = middleware.New(authSvc, bizCtxSvc, configSvc, i18nSvc, pluginSvc, roleSvc, tenantSvc)
-		hostConfigSvc         = pluginservicehostconfig.New(configSvc)
+		hostConfigSvc         = pluginservicehostconfig.New(hostConfigReader)
 		pluginConfigFactory   = pluginserviceconfig.NewConfigFactory("", "")
 		pluginManifestFactory = pluginservicemanifest.NewFactory("")
 	)

apps/lina-core/internal/service/plugin/internal/testutil/testutil_services.go

@@ -150,7 +150,7 @@ func NewServices() *Services {
 		configProvider,
 		capabilitySvc,
 		capabilityconfig.NewConfigFactory("", ""),
-		capabilityhostconfig.New(configProvider),
+		capabilityhostconfig.New(mustHostConfigRawReader(configProvider)),
 		capabilitymanifest.NewFactory(""),
 	)
 
@@ -164,6 +164,16 @@ func NewServices() *Services {
 	}
 }
 
+// mustHostConfigRawReader returns the raw host-config reader implemented by
+// the shared test config service and panics if fixture wiring regresses.
+func mustHostConfigRawReader(configProvider configsvc.Service) capabilityhostconfig.RawConfigReader {
+	reader, ok := configProvider.(capabilityhostconfig.RawConfigReader)
+	if !ok {
+		panic("test config service does not support raw host config reads")
+	}
+	return reader
+}
+
 // runtimeCacheChangeNotifier is a no-op cache revision publisher for isolated
 // plugin runtime tests.
 type runtimeCacheChangeNotifier struct{}

apps/lina-core/internal/service/plugin/plugin_host_services_test.go

@@ -143,11 +143,23 @@ func newWasmHostServiceTestDeps(t *testing.T) *wasmHostServiceTestDeps {
 		configSvc:       configSvc,
 		hostServices:    newRootTestCapabilities(bizCtxSvc, nil),
 		configFactory:   capabilityconfig.NewConfigFactory("", ""),
-		hostConfigSvc:   capabilityhostconfig.New(configSvc),
+		hostConfigSvc:   capabilityhostconfig.New(mustHostConfigRawReaderForTest(t, configSvc)),
 		manifestFactory: capabilitymanifest.NewFactory(""),
 	}
 }
 
+// mustHostConfigRawReaderForTest returns the raw host-config reader implemented
+// by the test config service or fails the current test during fixture wiring.
+func mustHostConfigRawReaderForTest(t *testing.T, configSvc configsvc.Service) capabilityhostconfig.RawConfigReader {
+	t.Helper()
+
+	reader, ok := configSvc.(capabilityhostconfig.RawConfigReader)
+	if !ok {
+		t.Fatal("test config service does not support raw host config reads")
+	}
+	return reader
+}
+
 // configureWasmHostServicesForTest calls the production root configuration
 // entry with one explicit dependency set.
 func configureWasmHostServicesForTest(deps *wasmHostServiceTestDeps) error {

apps/lina-core/internal/service/plugin/plugin_test.go

@@ -124,13 +124,23 @@ func configureRootWasmHostServicesForTest(
 		configProvider,
 		capabilities,
 		capabilityconfig.NewConfigFactory("", ""),
-		capabilityhostconfig.New(configProvider),
+		capabilityhostconfig.New(mustHostConfigRawReader(configProvider)),
 		capabilitymanifest.NewFactory(""),
 	); err != nil {
 		panic(err)
 	}
 }
 
+// mustHostConfigRawReader returns the raw host-config reader implemented by
+// the root test config service and panics if the fixture wiring regresses.
+func mustHostConfigRawReader(configProvider configsvc.Service) capabilityhostconfig.RawConfigReader {
+	reader, ok := configProvider.(capabilityhostconfig.RawConfigReader)
+	if !ok {
+		panic("test config service does not support raw host config reads")
+	}
+	return reader
+}
+
 // rootTestCapabilities publishes the minimal host service directory required
 // by root-package plugin facade tests. It mirrors the production capability
 // wiring only for services used by provider construction and leaves unrelated

apps/lina-core/internal/service/user/user_test_dependencies_test.go

@@ -50,7 +50,11 @@ func newUserTestService(tenantRuntimes ...tenantcapsvc.ProviderRuntime) Service
 	authSvc := auth.New(configSvc, pluginSvc, orgCapSvc, roleSvc, tenantSvc, sessionStore, kvCacheSvc)
 	notifySvc := notify.New(tenantSvc)
 	apiDocSvc := apidoc.New(configSvc, bizCtxSvc, i18nSvc, pluginSvc)
-	hostConfigSvc := capabilityhostconfig.New(configSvc)
+	hostConfigReader, ok := configSvc.(capabilityhostconfig.RawConfigReader)
+	if !ok {
+		panic("test config service does not support raw host config reads")
+	}
+	hostConfigSvc := capabilityhostconfig.New(hostConfigReader)
 	capabilities, err := pluginsvc.NewHostServices(
 		apiDocSvc,
 		authSvc,

apps/lina-core/pkg/plugin/capability/hostconfigcap/hostconfig.go

@@ -7,23 +7,22 @@ import (
 	"context"
 
 	"github.com/gogf/gf/v2/container/gvar"
-
-	hostconfigsvc "lina-core/internal/service/config"
 )
 
-// rawConfigReader is implemented by the host-owned config service. It keeps
-// this adapter dependent on the startup-injected config instance instead of
-// reaching around the service graph for global configuration.
-type rawConfigReader interface {
+// RawConfigReader is implemented by the host-owned config service. It keeps
+// this adapter dependent on the startup-injected config instance without
+// coupling this public capability package to host internal service packages.
+type RawConfigReader interface {
+	// GetRaw returns one raw host configuration value or root snapshot.
 	GetRaw(ctx context.Context, key string) (*gvar.Var, error)
 }
 
 // serviceAdapter reads individual host config keys from the host config service.
 type serviceAdapter struct {
-	configSvc hostconfigsvc.Service
+	configSvc RawConfigReader
 }
 
 // New creates a host config reader backed by the host config service.
-func New(configSvc hostconfigsvc.Service) Service {
+func New(configSvc RawConfigReader) Service {
 	return &serviceAdapter{configSvc: configSvc}
 }

apps/lina-core/pkg/plugin/capability/hostconfigcap/hostconfig_access.go

@@ -103,9 +103,5 @@ func (s *serviceAdapter) valueForKey(ctx context.Context, key string) (*gvar.Var
 	if s == nil || s.configSvc == nil {
 		return nil, gerror.New("host config service is not configured")
 	}
-	reader, ok := s.configSvc.(rawConfigReader)
-	if !ok {
-		return nil, gerror.New("host config service does not support raw reads")
-	}
-	return reader.GetRaw(ctx, key)
+	return s.configSvc.GetRaw(ctx, key)
 }

apps/lina-core/pkg/plugin/capability/hostconfigcap/hostconfig_access_test.go

@@ -8,10 +8,9 @@ import (
 	"strings"
 	"testing"
 
+	"github.com/gogf/gf/v2/container/gvar"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gcfg"
-
-	hostconfigsvc "lina-core/internal/service/config"
 )
 
 // TestHostConfigReadsAnyNonRootHostConfigKey verifies source plugins can read
@@ -26,7 +25,7 @@ plugin:
     storagePath: "temp/dynamic"
 `)
 
-	svc := New(hostconfigsvc.New())
+	svc := New(testRawHostConfigReader{})
 	ctx := context.Background()
 
 	link, err := svc.String(ctx, "database.default.link", "")
@@ -54,7 +53,7 @@ workspace:
   basePath: "/admin"
 `)
 
-	svc := New(hostconfigsvc.New())
+	svc := New(testRawHostConfigReader{})
 	found, err := svc.Exists(context.Background(), "database.default.link")
 	if err != nil {
 		t.Fatalf("check missing host config key: %v", err)
@@ -72,7 +71,7 @@ workspace:
   basePath: "/admin"
 `)
 
-	svc := New(hostconfigsvc.New())
+	svc := New(testRawHostConfigReader{})
 	value, err := svc.Get(context.Background(), ".")
 	if err != nil {
 		t.Fatalf("read host config root: %v", err)
@@ -102,17 +101,6 @@ func TestHostConfigRequiresInjectedRawReader(t *testing.T) {
 	}
 }
 
-// TestHostConfigRejectsServiceWithoutRawReads verifies accidental stand-ins
-// cannot bypass the injected host config service contract.
-func TestHostConfigRejectsServiceWithoutRawReads(t *testing.T) {
-	svc := New(hostConfigServiceWithoutRawReads{})
-
-	if _, err := svc.Get(context.Background(), "workspace.basePath"); err == nil ||
-		!strings.Contains(err.Error(), "does not support raw reads") {
-		t.Fatalf("expected service without raw reads to fail explicitly, got %v", err)
-	}
-}
-
 // setTestHostConfigAdapter swaps the process config adapter for one test case
 // and restores the original adapter afterward.
 func setTestHostConfigAdapter(t *testing.T, content string) {
@@ -130,13 +118,10 @@ func setTestHostConfigAdapter(t *testing.T, content string) {
 	})
 }
 
-// hostConfigServiceWithoutRawReads satisfies the broad host config service
-// contract but intentionally omits GetRaw for dependency-boundary tests.
-type hostConfigServiceWithoutRawReads struct {
-	hostconfigsvc.Service
-}
+// testRawHostConfigReader reads from the test-scoped GoFrame config adapter.
+type testRawHostConfigReader struct{}
 
-// GetWorkspaceBasePath returns a deterministic workspace base path.
-func (hostConfigServiceWithoutRawReads) GetWorkspaceBasePath(context.Context) string {
-	return "/admin"
+// GetRaw returns one raw test config value through the active GoFrame adapter.
+func (testRawHostConfigReader) GetRaw(ctx context.Context, key string) (*gvar.Var, error) {
+	return g.Cfg().Get(ctx, key)
 }