fix(agent): resolve Node SDK version via the runtime, gate Node separately

The local-run version gate ran main's file-based CheckSDKVersion for Node
too, which (a) couldn't find @livekit/agents in monorepo/workspace layouts
where the dep is a `workspace:*` symlink rather than a versioned entry, and
(b) gated on the Python thin-CLI baseline (1.6.0), the wrong floor for the
Node SDK.

Resolve the installed @livekit/agents via Node's own module resolution
(embedded node_resolve_version.js), starting from the entrypoint's directory
so pnpm/workspace symlinks and hoisting resolve exactly as they will at
runtime, and gate Node on its own nodeAgentMinVersion. Python keeps the
existing CheckSDKVersion path. Export IsVersionSatisfied for the reused
comparison.

Author: u9g

cmd/lk/agent_run_test.go

@@ -36,9 +36,12 @@ func TestAgentProcessFailSignal(t *testing.T) {
 	dir := t.TempDir()
 	script := `console.log('shutting down job task {"reason": "job crashed"}'); setTimeout(() => {}, 30000);`
 	require.NoError(t, os.WriteFile(filepath.Join(dir, "agent.js"), []byte(script), 0o644))
-	// startAgent gates on the SDK version, so declare a satisfying dependency.
-	pkgJSON := `{"dependencies": {"@livekit/agents": "1.6.0"}}`
-	require.NoError(t, os.WriteFile(filepath.Join(dir, "package.json"), []byte(pkgJSON), 0o644))
+	// startAgent gates on the SDK version, which Node resolves from node_modules,
+	// so install a satisfying @livekit/agents stub.
+	agentsDir := filepath.Join(dir, "node_modules", "@livekit", "agents")
+	require.NoError(t, os.MkdirAll(agentsDir, 0o755))
+	require.NoError(t, os.WriteFile(filepath.Join(agentsDir, "package.json"),
+		[]byte(`{"name": "@livekit/agents", "version": "1.6.0"}`), 0o644))
 
 	ap, err := startAgent(AgentStartConfig{
 		Dir:         dir,

cmd/lk/node_resolve_version.js

@@ -0,0 +1,20 @@
+// Reports the installed @livekit/agents version using Node's own module
+// resolution paths, so pnpm/workspace symlinks and hoisting resolve exactly as
+// they will at runtime. Reads package.json directly, so it works even before
+// the package is built. Prints the version to stdout, or exits non-zero if the
+// package can't be found.
+const { createRequire } = require('module');
+const path = require('path');
+const fs = require('fs');
+
+try {
+  const req = createRequire(path.join(process.cwd(), 'noop.js'));
+  for (const base of req.resolve.paths('@livekit/agents') || []) {
+    const pkgPath = path.join(base, '@livekit/agents', 'package.json');
+    if (fs.existsSync(pkgPath)) {
+      process.stdout.write(JSON.parse(fs.readFileSync(pkgPath, 'utf8')).version || '');
+      process.exit(0);
+    }
+  }
+} catch (e) {}
+process.exit(1);

cmd/lk/simulate_subprocess.go

@@ -17,6 +17,7 @@ package main
 import (
 	"bufio"
 	"context"
+	_ "embed"
 	"encoding/json"
 	"fmt"
 	"io"
@@ -129,6 +130,56 @@ func checkTypeStrippingSupport(dir, nodeBin string) error {
 	return nil
 }
 
+// nodeAgentMinVersion is the minimum @livekit/agents (agents-js) release the
+// CLI supports. Unlike the Python thin CLI (gated on thinCLIMinVersion), the
+// Node entrypoint exposes the start/console/simulate subcommands directly, so
+// the baseline differs. Local placeholder — the deploy path sources the
+// equivalent floor from server client settings.
+const nodeAgentMinVersion = "1.0.0"
+
+// nodeResolveVersionScript asks Node to report the installed @livekit/agents
+// version using its own module resolution paths (so pnpm/workspace symlinks
+// and hoisting resolve exactly as they will at runtime). See the source file
+// for details.
+//
+//go:embed node_resolve_version.js
+var nodeResolveVersionScript string
+
+// resolveNodeAgentVersion returns the installed @livekit/agents version as Node
+// resolves it from fromDir, or "" if it can't be determined.
+func resolveNodeAgentVersion(nodeBin, fromDir string) string {
+	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+	cmd := exec.CommandContext(ctx, nodeBin, "-e", nodeResolveVersionScript)
+	cmd.Dir = fromDir
+	out, err := cmd.Output()
+	if err != nil {
+		return ""
+	}
+	return strings.TrimSpace(string(out))
+}
+
+// checkNodeSDKVersion gates a Node agent on nodeAgentMinVersion, resolving the
+// installed @livekit/agents from the entrypoint's directory so monorepo and
+// workspace layouts (where the dep is a workspace:* symlink, not a versioned
+// entry in the root package.json) report the version that will actually run.
+func checkNodeSDKVersion(cfg AgentStartConfig) error {
+	nodeBin, err := findNodeBinary()
+	if err != nil {
+		return err
+	}
+	fromDir := filepath.Dir(filepath.Join(cfg.Dir, cfg.Entrypoint))
+	version := resolveNodeAgentVersion(nodeBin, fromDir)
+	if version == "" {
+		return fmt.Errorf("@livekit/agents not found; install dependencies and make sure this is a LiveKit agent project")
+	}
+	// An unparseable version (e.g. a local "0.0.0-dev" tag) shouldn't block a run.
+	if ok, err := agentfs.IsVersionSatisfied(version, nodeAgentMinVersion); err == nil && !ok {
+		return fmt.Errorf("@livekit/agents version %s is too old, please upgrade to %s or newer", version, nodeAgentMinVersion)
+	}
+	return nil
+}
+
 // defaultEntrypoints returns candidate entrypoint paths (relative to the
 // project root or working directory) probed for a project type, in priority
 // order. Forward slashes are valid on all platforms.
@@ -270,8 +321,14 @@ func buildAgentCommand(cfg AgentStartConfig) (string, []string, error) {
 
 // startAgent launches a Python or Node agent subprocess and monitors its output.
 func startAgent(cfg AgentStartConfig) (*AgentProcess, error) {
-	// fail fast when livekit-agents is older than the thin-CLI baseline
-	if err := agentfs.CheckSDKVersion(cfg.Dir, cfg.ProjectType, map[string]string{
+	// fail fast when the agent SDK is older than the baseline the CLI supports.
+	// Node resolves the installed package via the runtime so workspace/monorepo
+	// layouts work; Python parses project files against the thin-CLI baseline.
+	if cfg.ProjectType.IsNode() {
+		if err := checkNodeSDKVersion(cfg); err != nil {
+			return nil, err
+		}
+	} else if err := agentfs.CheckSDKVersion(cfg.Dir, cfg.ProjectType, map[string]string{
 		"python-min-sdk-version": thinCLIMinVersion,
 		"node-min-sdk-version":   thinCLIMinVersion,
 	}); err != nil {

pkg/agentfs/sdk_version_check.go

@@ -205,7 +205,7 @@ func checkRequirementsFile(filePath, minVersion string) VersionCheckResult {
 
 		version, found := parsePythonPackageVersion(line)
 		if found {
-			satisfied, err := isVersionSatisfied(version, minVersion)
+			satisfied, err := IsVersionSatisfied(version, minVersion)
 			return VersionCheckResult{
 				PackageInfo: PackageInfo{
 					Name:        "livekit-agents",
@@ -243,7 +243,7 @@ func checkPyprojectToml(filePath, minVersion string) VersionCheckResult {
 				if line, ok := dep.(string); ok {
 					version, found := parsePythonPackageVersion(line)
 					if found {
-						satisfied, err := isVersionSatisfied(version, minVersion)
+						satisfied, err := IsVersionSatisfied(version, minVersion)
 						return VersionCheckResult{
 							PackageInfo: PackageInfo{
 								Name:        "livekit-agents",
@@ -281,7 +281,7 @@ func checkPipfile(filePath, minVersion string) VersionCheckResult {
 			version = "latest"
 		}
 
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "livekit-agents",
@@ -326,7 +326,7 @@ func checkSetupPy(filePath, minVersion string) VersionCheckResult {
 				}
 				version, found := parsePythonPackageVersion(packageLine)
 				if found {
-					satisfied, err := isVersionSatisfied(version, minVersion)
+					satisfied, err := IsVersionSatisfied(version, minVersion)
 					return VersionCheckResult{
 						PackageInfo: PackageInfo{
 							Name:        "livekit-agents",
@@ -360,7 +360,7 @@ func checkSetupCfg(filePath, minVersion string) VersionCheckResult {
 	if matches != nil {
 		version := strings.TrimSpace(matches[2])
 
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "livekit-agents",
@@ -407,7 +407,7 @@ func checkPackageJSON(filePath, minVersion string) VersionCheckResult {
 
 	for _, deps := range dependencyMaps {
 		if version, ok := deps["@livekit/agents"]; ok {
-			satisfied, err := isVersionSatisfied(version, minVersion)
+			satisfied, err := IsVersionSatisfied(version, minVersion)
 			return VersionCheckResult{
 				PackageInfo: PackageInfo{
 					Name:        "@livekit/agents",
@@ -467,7 +467,7 @@ func checkPackageLockJSON(filePath, minVersion string) VersionCheckResult {
 	}
 
 	if dep, ok := lockJSON.Dependencies["@livekit/agents"]; ok {
-		satisfied, err := isVersionSatisfied(dep.Version, minVersion)
+		satisfied, err := IsVersionSatisfied(dep.Version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "@livekit/agents",
@@ -497,7 +497,7 @@ func checkYarnLock(filePath, minVersion string) VersionCheckResult {
 	matches := pattern.FindStringSubmatch(string(content))
 	if matches != nil {
 		version := matches[1]
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "@livekit/agents",
@@ -527,7 +527,7 @@ func checkPnpmLock(filePath, minVersion string) VersionCheckResult {
 	matches := pattern.FindStringSubmatch(string(content))
 	if matches != nil {
 		version := strings.TrimSpace(matches[1])
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "@livekit/agents",
@@ -557,7 +557,7 @@ func checkPoetryLock(filePath, minVersion string) VersionCheckResult {
 	matches := pattern.FindStringSubmatch(string(content))
 	if matches != nil {
 		version := matches[1]
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "livekit-agents",
@@ -587,7 +587,7 @@ func checkUvLock(filePath, minVersion string) VersionCheckResult {
 	matches := pattern.FindStringSubmatch(string(content))
 	if matches != nil {
 		version := matches[1]
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "livekit-agents",
@@ -617,7 +617,7 @@ func checkPipfileLock(filePath, minVersion string) VersionCheckResult {
 	matches := pattern.FindStringSubmatch(string(content))
 	if matches != nil {
 		version := matches[1]
-		satisfied, err := isVersionSatisfied(version, minVersion)
+		satisfied, err := IsVersionSatisfied(version, minVersion)
 		return VersionCheckResult{
 			PackageInfo: PackageInfo{
 				Name:        "livekit-agents",
@@ -635,8 +635,8 @@ func checkPipfileLock(filePath, minVersion string) VersionCheckResult {
 	return VersionCheckResult{}
 }
 
-// isVersionSatisfied checks if a version satisfies the minimum requirement
-func isVersionSatisfied(version, minVersion string) (bool, error) {
+// IsVersionSatisfied checks if a version satisfies the minimum requirement
+func IsVersionSatisfied(version, minVersion string) (bool, error) {
 	// Handle special cases
 	if version == "latest" || version == "*" || version == "" || version == "next" {
 		return true, nil // Latest version always satisfies

pkg/agentfs/sdk_version_check_test.go

@@ -230,7 +230,7 @@ func TestIsVersionSatisfied(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.version+"_vs_"+tt.minVersion, func(t *testing.T) {
-			result, err := isVersionSatisfied(tt.version, tt.minVersion)
+			result, err := IsVersionSatisfied(tt.version, tt.minVersion)
 
 			if tt.expectErr {
 				if err == nil {