Merge branch 'ai-node'

Author: ElecTwix

.gitignore

@@ -1,5 +1,6 @@
 .claude
 .ai
+conductor
 .direnv
 .env.*.local
 .env.keys
@@ -35,7 +36,3 @@ coverage.out
 packages/server/server
 tools/collect_go_failures.py
 /server
-# Conductor
-
-# Conductor
-conductor/

.nx/version-plans/version-plan-1770054685952.md

@@ -0,0 +1,6 @@
+---
+desktop: minor
+cli: minor
+---
+
+Add AI node support with multi-provider LLM integration (OpenAI, Anthropic, Gemini), credential vault encryption, and variable introspection system

.prettierignore

@@ -3,6 +3,7 @@
 *.har
 AGENTS.md
 CHANGELOG.md
+conductor/
 dist
 flake.lock
 GEMINI.md

GEMINI.md

@@ -55,6 +55,34 @@ DevTools is a local-first, open-source API testing platform (Postman alternative
 - **Fix:** `task fix` (runs Prettier and Syncpack).
 - **Go Benchmarks:** Use `task benchmark:run` to run, `task benchmark:baseline` to save baseline, and `task benchmark:compare` to compare.
 
+### Nx Version Plans
+Version plans are file-based versioning for independent releases. They allow contributors to declare version bumps alongside their changes without modifying `package.json` directly.
+
+**How it works:**
+1. When making a change that warrants a release, create a version plan file
+2. The file is stored in `.nx/version-plans/` as a markdown file
+3. During release, Nx reads all pending version plans and applies the bumps
+
+**Creating a version plan:**
+```bash
+task version-plan project=desktop   # Interactive prompt for bump type + message
+```
+
+**Version plan file format:**
+```markdown
+---
+desktop: patch    # or minor, major
+---
+
+Description of the change (used in changelog)
+```
+
+**Available projects:** `desktop`, `cli`, `api-recorder-extension`
+
+**Configuration:** Defined in `nx.json` under `release.versionPlans`. Projects use independent versioning (`projectsRelationship: independent`).
+
+**Reference:** [Nx Version Plans Documentation](https://nx.dev/recipes/nx-release/file-based-versioning-version-plans)
+
 ## Implementation Guidelines
 
 ### CLI (Go)
@@ -78,6 +106,24 @@ DevTools is a local-first, open-source API testing platform (Postman alternative
 - **Seeding:** Use `BaseTestServices.CreateTempCollection` to quickly seed workspace/user/collection state.
 - **Parallelism:** Safe to use `t.Parallel()` *only* if each subtest creates its own independent DB.
 
+### Go Integration Testing Pattern
+Use this pattern for tests that require external services (APIs, Cloud), cost money, or are too slow for standard CI.
+
+- **Naming Convention:** Start files with `integration_` (e.g., `integration_providers_test.go`).
+- **Build Tags:** Use specific tags to exclude from default `go test`.
+  - Example: `//go:build ai_integration`
+- **Safety Guard:** Always check an explicit environment variable at the start of the test to prevent accidental execution.
+  - Example: `if os.Getenv("RUN_XX_INTEGRATION") != "true" { t.Skip() }`
+- **Example Implementation (AI Node):**
+  - **Location:** `packages/server/pkg/flow/node/nai/integration_*.go`
+  - **Tag:** `ai_integration`
+  - **Guard:** `RUN_AI_INTEGRATION_TESTS=true`
+  - **Env Vars:**
+    - `OPENAI_API_KEY`, `OPENAI_BASE_URL`, `OPENAI_MODEL`
+    - `ANTHROPIC_API_KEY`, `ANTHROPIC_BASE_URL`, `ANTHROPIC_MODEL`
+    - `GEMINI_API_KEY`
+  - **Command:** `RUN_AI_INTEGRATION_TESTS=true OPENAI_API_KEY=sk-... go test -tags ai_integration -v ./packages/server/pkg/flow/node/nai`
+
 ### TypeScript/React (Client/Desktop)
 - **State/Effects:** Effect-TS and TanStack Query.
 - **Styling:** Tailwind CSS v4. Co-located with components.

apps/cli/cmd/flow.go

@@ -16,6 +16,7 @@ import (
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/idwrap"
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/ioworkspace"
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/model/mflow"
+	"github.com/the-dev-tools/dev-tools/packages/server/pkg/service/scredential"
 	yamlflowsimplev2 "github.com/the-dev-tools/dev-tools/packages/server/pkg/translate/yamlflowsimplev2"
 	"github.com/the-dev-tools/dev-tools/packages/spec/dist/buf/go/api/node_js_executor/v1/node_js_executorv1connect"
 
@@ -144,18 +145,25 @@ var yamlflowRunCmd = &cobra.Command{
 			services.HTTPAssert,
 		)
 
+		// Create LLM provider factory for AI nodes
+		llmFactory := scredential.NewLLMProviderFactory(&services.Credential)
+
 		builder := flowbuilder.New(
 			&services.Node,
 			&services.NodeRequest,
 			&services.NodeFor,
 			&services.NodeForEach,
 			&services.NodeIf,
 			&services.NodeJS,
+			&services.NodeAI,
+			&services.NodeAiProvider,
+			&services.NodeMemory,
 			&services.Workspace,
 			&services.Variable,
 			&services.FlowVariable,
 			resolver,
 			services.Logger,
+			llmFactory,
 		)
 
 		if !quietMode {

apps/cli/go.sum

@@ -5,8 +5,8 @@ connectrpc.com/connect v1.19.1/go.mod h1:tN20fjdGlewnSFeZxLKb0xwIZ6ozc3OQs2hTXy4
 github.com/andybalholm/brotli v1.2.0 h1:ukwgCxwYrmACq68yiUqwIWnGY0cTPox/M94sVwToPjQ=
 github.com/andybalholm/brotli v1.2.0/go.mod h1:rzTDkvFWvIrjDXZHkuS16NPggd91W3kUSvPlQ1pLaKY=
 github.com/cpuguy83/go-md2man/v2 v2.0.6/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
+github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
 github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/expr-lang/expr v1.17.7 h1:Q0xY/e/2aCIp8g9s/LGvMDCC5PxYlvHgDZRQ4y16JX8=
@@ -18,6 +18,7 @@ github.com/fsnotify/fsnotify v1.9.0/go.mod h1:8jBTzvmWwFyi3Pb8djgCCO5IBqzKJ/Jwo8
 github.com/go-viper/mapstructure/v2 v2.4.0 h1:EBsztssimR/CONLSZZ04E8qAkxNYq4Qp9LvH92wZUgs=
 github.com/go-viper/mapstructure/v2 v2.4.0/go.mod h1:oJDH3BJKyqBA2TXFhDsKDGDTlndYOZ6rGS0BRZIxGhM=
 github.com/golang-jwt/jwt/v5 v5.3.0 h1:pv4AsKCKKZuqlgs5sUmn4x8UlGa0kEVt/puTpKx9vvo=
+github.com/golang-jwt/jwt/v5 v5.3.0/go.mod h1:fxCRLWMO43lRc8nhHWY6LGqRcf+1gQWArsqaEUEa5bE=
 github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
 github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
 github.com/google/pprof v0.0.0-20250607225305-033d6d78b36a h1://KbezygeMJZCSHH+HgUZiTeSoiuFspbMg1ge+eFj18=
@@ -45,8 +46,8 @@ github.com/oklog/ulid/v2 v2.1.1/go.mod h1:rcEKHmBBKfef9DhnvX7y1HZBYxjXb0cP5ExxNs
 github.com/pborman/getopt v0.0.0-20170112200414-7148bc3a4c30/go.mod h1:85jBQOZwpVEaDAr341tbn15RS4fCAsIst0qp7i8ex1o=
 github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0t5Ec4=
 github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ=
@@ -90,9 +91,8 @@ golang.org/x/tools v0.40.0 h1:yLkxfA+Qnul4cs9QA3KnlFu0lVmd8JJfoq+E41uSutA=
 golang.org/x/tools v0.40.0/go.mod h1:Ik/tzLRlbscWpqqMRjyWYDisX8bG13FrdXp3o4Sr9lc=
 google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
 google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
-gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 modernc.org/cc/v4 v4.27.1 h1:9W30zRlYrefrDV2JE2O8VDtJ1yPGownxciz5rrbQZis=

apps/cli/internal/common/services.go

@@ -7,6 +7,7 @@ import (
 	"log/slog"
 
 	"github.com/the-dev-tools/dev-tools/packages/db/pkg/sqlc/gen"
+	"github.com/the-dev-tools/dev-tools/packages/server/pkg/service/scredential"
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/service/senv"
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/service/sflow"
 	"github.com/the-dev-tools/dev-tools/packages/server/pkg/service/shttp"
@@ -36,6 +37,12 @@ type Services struct {
 	NodeForEach sflow.NodeForEachService
 	NodeIf      sflow.NodeIfService
 	NodeJS      sflow.NodeJsService
+	NodeAI         sflow.NodeAIService
+	NodeAiProvider sflow.NodeAiProviderService
+	NodeMemory     sflow.NodeMemoryService
+
+	// Credentials
+	Credential scredential.CredentialService
 
 	// HTTP (V2)
 	HTTP               shttp.HTTPService
@@ -77,6 +84,12 @@ func CreateServices(ctx context.Context, db *sql.DB, logger *slog.Logger) (*Serv
 		NodeForEach: sflow.NewNodeForEachService(queries),
 		NodeIf:      *sflow.NewNodeIfService(queries),
 		NodeJS:      sflow.NewNodeJsService(queries),
+		NodeAI:         sflow.NewNodeAIService(queries),
+		NodeAiProvider: sflow.NewNodeAiProviderService(queries),
+		NodeMemory:     sflow.NewNodeMemoryService(queries),
+
+		// Credentials
+		Credential: scredential.NewCredentialService(queries),
 
 		// HTTP (V2)
 		HTTP:               shttp.New(queries, logger),

apps/cli/internal/runner/runner_test.go

@@ -110,11 +110,15 @@ func newFlowTestFixture(t *testing.T) *flowTestFixture {
 		&nodeForEachService,
 		nodeIfService,
 		&nodeJSService,
+		nil, // NodeAIService - not needed for CLI tests
+		nil, // NodeAiProviderService - not needed for CLI tests
+		nil, // NodeMemoryService - not needed for CLI tests
 		&workspaceService,
 		&varService,
 		&flowVariableService,
 		res,
 		logger,
+		nil, // LLMProviderFactory - not needed for CLI tests
 	)
 
 	_ = logconsole.NewLogChanMap() // unused but kept for parity if needed