History

renames / reorgs

Rhys Sullivan committed 7 months ago

Commit fd9bbfe1 parent 0baa98683 files · +215 −215Browse files

Unified · Split

83 files
  1. packages/drivers/google-discovery/src/document.ts +1 −1
  2. packages/drivers/google-discovery/src/index.ts +3 −3
  3. packages/drivers/google-discovery/src/tools.test.ts +0 −0
  4. packages/drivers/google-discovery/src/tools.ts +2 −2
  5. packages/drivers/google-discovery/src/types.ts +0 −0
  6. packages/drivers/mcp/src/connection.ts +1 −1
  7. packages/drivers/mcp/src/elicitation-bridge.ts +0 −0
  8. packages/drivers/mcp/src/elicitation-form.test.ts +1 −1
  9. packages/drivers/mcp/src/elicitation.url.test.ts +2 −2
  10. packages/drivers/mcp/src/index.ts +3 −3
  11. packages/drivers/mcp/src/manifest.ts +0 −0
  12. packages/drivers/mcp/src/tools.test.ts +2 −2
  13. packages/drivers/mcp/src/tools.ts +2 −2
  14. packages/drivers/openapi/src/definitions.ts +1 −1
  15. packages/drivers/openapi/src/document.test.ts +1 −1
  16. packages/drivers/openapi/src/document.ts +1 −1
  17. packages/drivers/openapi/src/extraction.real-specs.test.ts +3 −3
  18. packages/drivers/openapi/src/extraction.ts +3 −3
  19. packages/drivers/openapi/src/extractor-wasm.ts +0 −0
  20. packages/drivers/openapi/src/http-serialization.ts +0 −0
  21. packages/drivers/openapi/src/index.ts +9 −9
  22. packages/drivers/openapi/src/real-spec-coverage.test.ts +5 −5
  23. packages/drivers/openapi/src/schema-refs.ts +0 −0
  24. packages/drivers/openapi/src/tool-presentation.test.ts +4 −4
  25. packages/drivers/openapi/src/tool-presentation.ts +3 −3
  26. packages/drivers/openapi/src/tools.test.ts +2 −2
  27. packages/drivers/openapi/src/tools.ts +6 −6
  28. packages/drivers/openapi/src/types.ts +0 −0
  29. packages/platform/control-plane/src/api/executions/http.ts +1 −1
  30. packages/platform/control-plane/src/api/local-context.ts +2 −2
  31. packages/platform/control-plane/src/api/local/http.ts +2 −2
  32. packages/platform/control-plane/src/api/sources/http.ts +1 −1
  33. packages/platform/control-plane/src/runtime/catalog/source/runtime.test.ts +2 −2
  34. packages/platform/control-plane/src/runtime/catalog/source/runtime.ts +7 −7
  35. packages/platform/control-plane/src/runtime/catalog/source/snapshot.test.ts +1 −1
  36. packages/platform/control-plane/src/runtime/catalog/source/sync.ts +9 −9
  37. packages/platform/control-plane/src/runtime/catalog/source/type-declarations.test.ts +1 −1
  38. packages/platform/control-plane/src/runtime/catalog/source/type-declarations.ts +3 −3
  39. packages/platform/control-plane/src/runtime/execution/http.test.ts +0 −0
  40. packages/platform/control-plane/src/runtime/execution/ir-execution.ts +1 −1
  41. packages/platform/control-plane/src/runtime/execution/live.test.ts +1 −1
  42. packages/platform/control-plane/src/runtime/execution/live.ts +0 −0
  43. packages/platform/control-plane/src/runtime/execution/mcp-resume.test.ts +0 −0
  44. packages/platform/control-plane/src/runtime/execution/runtime-config.test.ts +0 −0
  45. packages/platform/control-plane/src/runtime/execution/runtime.ts +0 −0
  46. packages/platform/control-plane/src/runtime/execution/service.ts +4 −4
  47. packages/platform/control-plane/src/runtime/execution/state.ts +0 −0
  48. packages/platform/control-plane/src/runtime/execution/workspace/authorization.ts +6 −6
  49. packages/platform/control-plane/src/runtime/execution/workspace/environment.ts +10 −10
  50. packages/platform/control-plane/src/runtime/execution/workspace/local.ts +1 −1
  51. packages/platform/control-plane/src/runtime/execution/workspace/source-catalog.ts +4 −4
  52. packages/platform/control-plane/src/runtime/execution/workspace/tool-invoker.ts +11 −11
  53. packages/platform/control-plane/src/runtime/index.ts +20 −20
  54. packages/platform/control-plane/src/runtime/local/config-secrets.ts +0 −0
  55. packages/platform/control-plane/src/runtime/local/config.test.ts +1 −1
  56. packages/platform/control-plane/src/runtime/local/config.ts +1 −1
  57. packages/platform/control-plane/src/runtime/local/control-plane-store.test.ts +2 −2
  58. packages/platform/control-plane/src/runtime/local/control-plane-store.ts +3 −3
  59. packages/platform/control-plane/src/runtime/local/errors.ts +0 −0
  60. packages/platform/control-plane/src/runtime/local/installation.test.ts +2 −2
  61. packages/platform/control-plane/src/runtime/local/installation.ts +1 −1
  62. packages/platform/control-plane/src/runtime/local/operations.ts +5 −5
  63. packages/platform/control-plane/src/runtime/local/runtime-context.ts +2 −2
  64. packages/platform/control-plane/src/runtime/local/secret-material-providers.ts +3 −3
  65. packages/platform/control-plane/src/runtime/local/source-artifacts.test.ts +2 −2
  66. packages/platform/control-plane/src/runtime/local/source-artifacts.ts +2 −2
  67. packages/platform/control-plane/src/runtime/local/storage.ts +7 −7
  68. packages/platform/control-plane/src/runtime/local/tools.ts +2 −2
  69. packages/platform/control-plane/src/runtime/local/workspace-state.ts +2 −2
  70. packages/platform/control-plane/src/runtime/local/workspace-sync.ts +2 −2
  71. packages/platform/control-plane/src/runtime/policy/policies-operations.ts +6 −6
  72. packages/platform/control-plane/src/runtime/sources/executor-tools.ts +3 −3
  73. packages/platform/control-plane/src/runtime/sources/source-adapter-fixture-matrix.test.ts +1 −1
  74. packages/platform/control-plane/src/runtime/sources/source-adapters/mcp.test.ts +1 −1
  75. packages/platform/control-plane/src/runtime/sources/source-auth-service.ts +4 −4
  76. packages/platform/control-plane/src/runtime/sources/source-inspection.ts +2 −2
  77. packages/platform/control-plane/src/runtime/sources/source-store.test.ts +2 −2
  78. packages/platform/control-plane/src/runtime/sources/source-store.ts +2 −2
  79. packages/platform/control-plane/src/runtime/sources/source-store/config.ts +3 −3
  80. packages/platform/control-plane/src/runtime/sources/source-store/deps.ts +6 −6
  81. packages/platform/control-plane/src/runtime/sources/source-store/lifecycle.ts +1 −1
  82. packages/platform/control-plane/src/runtime/sources/source-store/records.ts +4 −4
  83. packages/platform/control-plane/src/runtime/sources/sources-operations.ts +1 −1
packages/drivers/google-discovery/src/document.tsrenamed from packages/drivers/google-discovery/src/google-discovery-document.ts+1−1
@@ -7,7 +7,7 @@ import type { · 6 unmodified lines
7 GoogleDiscoveryMethodParameter,7 GoogleDiscoveryMethodParameter,
8 GoogleDiscoverySchemaRefTable,8 GoogleDiscoverySchemaRefTable,
9 GoogleDiscoveryToolManifest,9 GoogleDiscoveryToolManifest,
10} from "./google-discovery-types";10} from "./types";
11 11
12type JsonObject = Record<string, unknown>;12type JsonObject = Record<string, unknown>;
13 13
packages/drivers/google-discovery/src/index.ts+3−3
@@ -1,14 +1,14 @@
1export {1export {
2 extractGoogleDiscoveryManifest,2 extractGoogleDiscoveryManifest,
3 compileGoogleDiscoveryToolDefinitions,3 compileGoogleDiscoveryToolDefinitions,
4} from "./google-discovery-document";4} from "./document";
5export {5export {
6 buildGoogleDiscoveryToolPresentation,6 buildGoogleDiscoveryToolPresentation,
7 createGoogleDiscoveryToolFromDefinition,7 createGoogleDiscoveryToolFromDefinition,
8 decodeGoogleDiscoverySchemaRefTableJson,8 decodeGoogleDiscoverySchemaRefTableJson,
9 googleDiscoveryProviderDataFromDefinition,9 googleDiscoveryProviderDataFromDefinition,
10 type CreateGoogleDiscoveryToolFromDefinitionInput,10 type CreateGoogleDiscoveryToolFromDefinitionInput,
11} from "./google-discovery-tools";11} from "./tools";
12export {12export {
13 GoogleDiscoveryHttpMethodSchema,13 GoogleDiscoveryHttpMethodSchema,
14 GoogleDiscoveryParameterLocationSchema,14 GoogleDiscoveryParameterLocationSchema,
@@ -27,4 +27,4 @@ export { · 12 unmodified lines
27 type GoogleDiscoveryToolDefinition,27 type GoogleDiscoveryToolDefinition,
28 type GoogleDiscoverySchemaRefTable,28 type GoogleDiscoverySchemaRefTable,
29 type GoogleDiscoveryToolManifest,29 type GoogleDiscoveryToolManifest,
30} from "./google-discovery-types";30} from "./types";
packages/drivers/google-discovery/src/tools.test.tsrenamed from packages/drivers/google-discovery/src/google-discovery-tools.test.ts+0−0

File renamed without changes.

packages/drivers/google-discovery/src/tools.tsrenamed from packages/drivers/google-discovery/src/google-discovery-tools.ts+2−2
@@ -22,10 +22,10 @@ import type { · 21 unmodified lines
22 GoogleDiscoveryManifestMethod,22 GoogleDiscoveryManifestMethod,
23 GoogleDiscoverySchemaRefTable,23 GoogleDiscoverySchemaRefTable,
24 GoogleDiscoveryToolDefinition,24 GoogleDiscoveryToolDefinition,
25} from "./google-discovery-types";25} from "./types";
26import {26import {
27 GoogleDiscoveryToolProviderDataSchema,27 GoogleDiscoveryToolProviderDataSchema,
28} from "./google-discovery-types";28} from "./types";
29 29
30const decodeGoogleDiscoveryToolProviderDataJson = Schema.decodeUnknownEither(30const decodeGoogleDiscoveryToolProviderDataJson = Schema.decodeUnknownEither(
31 GoogleDiscoveryToolProviderDataSchema,31 GoogleDiscoveryToolProviderDataSchema,
packages/drivers/google-discovery/src/types.tsrenamed from packages/drivers/google-discovery/src/google-discovery-types.ts+0−0

File renamed without changes.

packages/drivers/mcp/src/connection.tsrenamed from packages/drivers/mcp/src/mcp-connection.ts+1−1
@@ -3,7 +3,7 @@ import { Client } from "@modelcontextprotocol/sdk/client/index.js"; · 2 unmodified lines
3import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";3import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
4import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";4import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
5 5
6import type { McpConnection, McpConnector } from "./mcp-tools";6import type { McpConnection, McpConnector } from "./tools";
7 7
8export type McpTransportPreference = "auto" | "streamable-http" | "sse";8export type McpTransportPreference = "auto" | "streamable-http" | "sse";
9 9
packages/drivers/mcp/src/elicitation-bridge.tsrenamed from packages/drivers/mcp/src/mcp-elicitation-bridge.ts+0−0

File renamed without changes.

packages/drivers/mcp/src/elicitation-form.test.tsrenamed from packages/drivers/mcp/src/mcp-elicitation-form.test.ts+1−1
@@ -11,7 +11,7 @@ import { makeSesExecutor } from "@executor/runtime-ses"; · 10 unmodified lines
11import {11import {
12 createMcpConnectorFromClient,12 createMcpConnectorFromClient,
13 discoverMcpToolsFromConnector,13 discoverMcpToolsFromConnector,
14} from "./mcp-tools";14} from "./tools";
15 15
16type McpTestPair = {16type McpTestPair = {
17 server: McpServer;17 server: McpServer;
packages/drivers/mcp/src/elicitation.url.test.tsrenamed from packages/drivers/mcp/src/mcp-elicitation.url.test.ts+2−2
@@ -11,8 +11,8 @@ import { z } from "zod/v4"; · 10 unmodified lines
11import { makeToolInvokerFromTools } from "@executor/codemode-core";11import { makeToolInvokerFromTools } from "@executor/codemode-core";
12import { makeSesExecutor } from "@executor/runtime-ses";12import { makeSesExecutor } from "@executor/runtime-ses";
13 13
14import { createSdkMcpConnector } from "./mcp-connection";14import { createSdkMcpConnector } from "./connection";
15import { discoverMcpToolsFromConnector } from "./mcp-tools";15import { discoverMcpToolsFromConnector } from "./tools";
16 16
17type UrlMcpServer = {17type UrlMcpServer = {
18 endpoint: string;18 endpoint: string;
packages/drivers/mcp/src/index.ts+3−3
@@ -2,7 +2,7 @@ export { · 1 unmodified line
2 createSdkMcpConnector,2 createSdkMcpConnector,
3 type CreateSdkMcpConnectorInput,3 type CreateSdkMcpConnectorInput,
4 type McpTransportPreference,4 type McpTransportPreference,
5} from "./mcp-connection";5} from "./connection";
6export {6export {
7 McpToolsError,7 McpToolsError,
8 createMcpConnectorFromClient,8 createMcpConnectorFromClient,
@@ -16,7 +16,7 @@ export { · 7 unmodified lines
16 type McpDiscoveryElicitationContext,16 type McpDiscoveryElicitationContext,
17 type McpToolManifest,17 type McpToolManifest,
18 type McpToolManifestEntry,18 type McpToolManifestEntry,
19} from "./mcp-tools";19} from "./tools";
20export type {20export type {
21 McpListToolsMetadata,21 McpListToolsMetadata,
22 McpServerCapabilities,22 McpServerCapabilities,
@@ -24,4 +24,4 @@ export type { · 1 unmodified line
24 McpServerMetadata,24 McpServerMetadata,
25 McpToolAnnotations,25 McpToolAnnotations,
26 McpToolExecution,26 McpToolExecution,
27} from "./mcp-manifest";27} from "./manifest";
packages/drivers/mcp/src/manifest.tsrenamed from packages/drivers/mcp/src/mcp-manifest.ts+0−0

File renamed without changes.

packages/drivers/mcp/src/tools.test.tsrenamed from packages/drivers/mcp/src/mcp-tools.test.ts+2−2
@@ -15,12 +15,12 @@ import type { · 14 unmodified lines
15 ToolPath,15 ToolPath,
16} from "@executor/codemode-core";16} from "@executor/codemode-core";
17 17
18import { createSdkMcpConnector } from "./mcp-connection";18import { createSdkMcpConnector } from "./connection";
19import {19import {
20 McpToolsError,20 McpToolsError,
21 discoverMcpToolsFromConnector,21 discoverMcpToolsFromConnector,
22 extractMcpToolManifestFromListToolsResult,22 extractMcpToolManifestFromListToolsResult,
23} from "./mcp-tools";23} from "./tools";
24 24
25const resolveToolDefinition = (value: ToolInput): ToolDefinition =>25const resolveToolDefinition = (value: ToolInput): ToolDefinition =>
26 typeof value === "object" && value !== null && "tool" in value26 typeof value === "object" && value !== null && "tool" in value
packages/drivers/mcp/src/tools.tsrenamed from packages/drivers/mcp/src/mcp-tools.ts+2−2
@@ -26,13 +26,13 @@ import { · 25 unmodified lines
26 readMcpElicitationRequest,26 readMcpElicitationRequest,
27 readUnknownRecord,27 readUnknownRecord,
28 toMcpElicitationResponse,28 toMcpElicitationResponse,
29} from "./mcp-elicitation-bridge";29} from "./elicitation-bridge";
30import {30import {
31 extractMcpToolManifestFromListToolsResult,31 extractMcpToolManifestFromListToolsResult,
32 joinToolPath,32 joinToolPath,
33 type McpToolManifest,33 type McpToolManifest,
34 type McpToolManifestEntry,34 type McpToolManifestEntry,
35} from "./mcp-manifest";35} from "./manifest";
36 36
37export type { McpToolManifest, McpToolManifestEntry };37export type { McpToolManifest, McpToolManifestEntry };
38export { extractMcpToolManifestFromListToolsResult };38export { extractMcpToolManifestFromListToolsResult };
packages/drivers/openapi/src/definitions.tsrenamed from packages/drivers/openapi/src/openapi-definitions.ts+1−1
@@ -12,7 +12,7 @@ import { · 11 unmodified lines
12 OpenApiToolProviderDataSchema,12 OpenApiToolProviderDataSchema,
13 type OpenApiExtractedTool,13 type OpenApiExtractedTool,
14 type OpenApiToolManifest,14 type OpenApiToolManifest,
15} from "./openapi-types";15} from "./types";
16 16
17const VERSION_SEGMENT_REGEX = /^v\d+(?:[._-]\d+)?$/i;17const VERSION_SEGMENT_REGEX = /^v\d+(?:[._-]\d+)?$/i;
18const IGNORED_PATH_SEGMENTS = new Set(["api"]);18const IGNORED_PATH_SEGMENTS = new Set(["api"]);
packages/drivers/openapi/src/document.test.tsrenamed from packages/drivers/openapi/src/openapi-document.test.ts+1−1
@@ -2,7 +2,7 @@ import { describe, expect, it } from "@effect/vitest"; · 1 unmodified line
2import { assertInclude, assertTrue } from "@effect/vitest/utils";2import { assertInclude, assertTrue } from "@effect/vitest/utils";
3import * as Effect from "effect/Effect";3import * as Effect from "effect/Effect";
4 4
5import { parseOpenApiDocument } from "./openapi-document";5import { parseOpenApiDocument } from "./document";
6 6
7describe("openapi-document", () => {7describe("openapi-document", () => {
8 it.effect("parses JSON OpenAPI document text", () =>8 it.effect("parses JSON OpenAPI document text", () =>
packages/drivers/openapi/src/document.tsrenamed from packages/drivers/openapi/src/openapi-document.ts+1−1
@@ -1,6 +1,6 @@
1import { parse as parseYaml } from "yaml";1import { parse as parseYaml } from "yaml";
2 2
3import type { OpenApiJsonObject } from "./openapi-types";3import type { OpenApiJsonObject } from "./types";
4 4
5const isOpenApiJsonObject = (value: unknown): value is OpenApiJsonObject =>5const isOpenApiJsonObject = (value: unknown): value is OpenApiJsonObject =>
6 typeof value === "object" && value !== null && !Array.isArray(value);6 typeof value === "object" && value !== null && !Array.isArray(value);
packages/drivers/openapi/src/extraction.real-specs.test.tsrenamed from packages/drivers/openapi/src/openapi-extraction.real-specs.test.ts+3−3
@@ -2,9 +2,9 @@ import { describe, expect, it } from "@effect/vitest"; · 1 unmodified line
2import * as Effect from "effect/Effect";2import * as Effect from "effect/Effect";
3import type { ToolDefinition, ToolInput } from "@executor/codemode-core";3import type { ToolDefinition, ToolInput } from "@executor/codemode-core";
4 4
5import { extractOpenApiManifest } from "./openapi-extraction";5import { extractOpenApiManifest } from "./extraction";
6import { createOpenApiToolsFromManifest } from "./openapi-tools";6import { createOpenApiToolsFromManifest } from "./tools";
7import type { OpenApiJsonObject } from "./openapi-types";7import type { OpenApiJsonObject } from "./types";
8 8
9const VERCEL_OPENAPI_SPEC_URL = "https://openapi.vercel.sh/";9const VERCEL_OPENAPI_SPEC_URL = "https://openapi.vercel.sh/";
10 10
packages/drivers/openapi/src/extraction.tsrenamed from packages/drivers/openapi/src/openapi-extraction.ts+3−3
@@ -4,8 +4,8 @@ import { pipe } from "effect/Function"; · 3 unmodified lines
4import * as ParseResult from "effect/ParseResult";4import * as ParseResult from "effect/ParseResult";
5import * as Schema from "effect/Schema";5import * as Schema from "effect/Schema";
6 6
7import { parseOpenApiDocument } from "./openapi-document";7import { parseOpenApiDocument } from "./document";
8import { extractOpenApiManifestJsonWithWasm } from "./openapi-extractor-wasm";8import { extractOpenApiManifestJsonWithWasm } from "./extractor-wasm";
9import {9import {
10 OpenApiToolManifestSchema,10 OpenApiToolManifestSchema,
11 type OpenApiExtractedTool,11 type OpenApiExtractedTool,
@@ -15,7 +15,7 @@ import { · 3 unmodified lines
15 type OpenApiJsonObject,15 type OpenApiJsonObject,
16 type OpenApiSpecInput,16 type OpenApiSpecInput,
17 type OpenApiToolManifest,17 type OpenApiToolManifest,
18} from "./openapi-types";18} from "./types";
19 19
20type OpenApiExtractionStage = "validate" | "extract";20type OpenApiExtractionStage = "validate" | "extract";
21 21
packages/drivers/openapi/src/extractor-wasm.tsrenamed from packages/drivers/openapi/src/openapi-extractor-wasm.ts+0−0

File renamed without changes.

packages/drivers/openapi/src/http-serialization.tsrenamed from packages/drivers/openapi/src/openapi-http-serialization.ts+0−0

File renamed without changes.

packages/drivers/openapi/src/index.ts+9−9
@@ -1,22 +1,22 @@
1export {1export {
2 fetchOpenApiDocument,2 fetchOpenApiDocument,
3 parseOpenApiDocument,3 parseOpenApiDocument,
4} from "./openapi-document";4} from "./document";
5export {5export {
6 OpenApiExtractionError,6 OpenApiExtractionError,
7 extractOpenApiManifest,7 extractOpenApiManifest,
8} from "./openapi-extraction";8} from "./extraction";
9export {9export {
10 compileOpenApiToolDefinitions,10 compileOpenApiToolDefinitions,
11 openApiProviderDataFromDefinition,11 openApiProviderDataFromDefinition,
12 OpenApiToolDefinitionSchema,12 OpenApiToolDefinitionSchema,
13 type OpenApiToolDefinition,13 type OpenApiToolDefinition,
14} from "./openapi-definitions";14} from "./definitions";
15export {15export {
16 buildOpenApiToolPresentation,16 buildOpenApiToolPresentation,
17 openApiOutputTypeSignatureFromSchema,17 openApiOutputTypeSignatureFromSchema,
18 type OpenApiToolPresentation,18 type OpenApiToolPresentation,
19} from "./openapi-tool-presentation";19} from "./tool-presentation";
20export {20export {
21 httpBodyModeFromContentType,21 httpBodyModeFromContentType,
22 isJsonMediaType,22 isJsonMediaType,
@@ -31,14 +31,14 @@ export { · 8 unmodified lines
31 type SerializedOpenApiRequestBody,31 type SerializedOpenApiRequestBody,
32 type SerializedOpenApiParameterValue,32 type SerializedOpenApiParameterValue,
33 type SerializedOpenApiQueryEntry,33 type SerializedOpenApiQueryEntry,
34} from "./openapi-http-serialization";34} from "./http-serialization";
35export {35export {
36 OpenApiToolInvocationError,36 OpenApiToolInvocationError,
37 createOpenApiToolFromDefinition,37 createOpenApiToolFromDefinition,
38 createOpenApiToolsFromManifest,38 createOpenApiToolsFromManifest,
39 createOpenApiToolsFromSpec,39 createOpenApiToolsFromSpec,
40} from "./openapi-tools";40} from "./tools";
41export { resolveSchemaWithRefHints, resolveTypingSchemasWithRefHints } from "./openapi-schema-refs";41export { resolveSchemaWithRefHints, resolveTypingSchemasWithRefHints } from "./schema-refs";
42export {42export {
43 OPEN_API_HTTP_METHODS,43 OPEN_API_HTTP_METHODS,
44 OPEN_API_PARAMETER_LOCATIONS,44 OPEN_API_PARAMETER_LOCATIONS,
@@ -89,11 +89,11 @@ export { · 44 unmodified lines
89 type OpenApiSecuritySchemeType,89 type OpenApiSecuritySchemeType,
90 type OpenApiOAuthFlow,90 type OpenApiOAuthFlow,
91 type OpenApiSecurityScheme,91 type OpenApiSecurityScheme,
92} from "./openapi-types";92} from "./types";
93export type {93export type {
94 OpenApiExample,94 OpenApiExample,
95 OpenApiParameterDocumentation,95 OpenApiParameterDocumentation,
96 OpenApiRequestBodyDocumentation,96 OpenApiRequestBodyDocumentation,
97 OpenApiResponseDocumentation,97 OpenApiResponseDocumentation,
98 OpenApiToolDocumentation,98 OpenApiToolDocumentation,
99} from "./openapi-types";99} from "./types";
packages/drivers/openapi/src/real-spec-coverage.test.tsrenamed from packages/drivers/openapi/src/openapi-real-spec-coverage.test.ts+5−5
@@ -3,15 +3,15 @@ import { readFileSync } from "node:fs"; · 2 unmodified lines
3import { describe, expect, it } from "@effect/vitest";3import { describe, expect, it } from "@effect/vitest";
4import * as Effect from "effect/Effect";4import * as Effect from "effect/Effect";
5 5
6import { compileOpenApiToolDefinitions } from "./openapi-definitions";6import { compileOpenApiToolDefinitions } from "./definitions";
7import { parseOpenApiDocument } from "./openapi-document";7import { parseOpenApiDocument } from "./document";
8import { extractOpenApiManifest } from "./openapi-extraction";8import { extractOpenApiManifest } from "./extraction";
9import { buildOpenApiToolPresentation } from "./openapi-tool-presentation";9import { buildOpenApiToolPresentation } from "./tool-presentation";
10import type {10import type {
11 OpenApiExtractedTool,11 OpenApiExtractedTool,
12 OpenApiJsonObject,12 OpenApiJsonObject,
13 OpenApiToolManifest,13 OpenApiToolManifest,
14} from "./openapi-types";14} from "./types";
15 15
16const readFixture = (name: string): string =>16const readFixture = (name: string): string =>
17 readFileSync(17 readFileSync(
packages/drivers/openapi/src/schema-refs.tsrenamed from packages/drivers/openapi/src/openapi-schema-refs.ts+0−0

File renamed without changes.

packages/drivers/openapi/src/tool-presentation.test.tsrenamed from packages/drivers/openapi/src/openapi-tool-presentation.test.ts+4−4
@@ -3,10 +3,10 @@ import { readFileSync } from "node:fs"; · 2 unmodified lines
3import { describe, expect, it } from "@effect/vitest";3import { describe, expect, it } from "@effect/vitest";
4import * as Effect from "effect/Effect";4import * as Effect from "effect/Effect";
5 5
6import type { OpenApiToolDefinition } from "./openapi-definitions";6import type { OpenApiToolDefinition } from "./definitions";
7import { compileOpenApiToolDefinitions } from "./openapi-definitions";7import { compileOpenApiToolDefinitions } from "./definitions";
8import { extractOpenApiManifest } from "./openapi-extraction";8import { extractOpenApiManifest } from "./extraction";
9import { buildOpenApiToolPresentation } from "./openapi-tool-presentation";9import { buildOpenApiToolPresentation } from "./tool-presentation";
10 10
11const readFixture = (name: string): string =>11const readFixture = (name: string): string =>
12 readFileSync(12 readFileSync(
packages/drivers/openapi/src/tool-presentation.tsrenamed from packages/drivers/openapi/src/openapi-tool-presentation.ts+3−3
@@ -9,15 +9,15 @@ import type { · 8 unmodified lines
9 OpenApiResponseVariant,9 OpenApiResponseVariant,
10 OpenApiToolDocumentation,10 OpenApiToolDocumentation,
11 OpenApiToolProviderData,11 OpenApiToolProviderData,
12} from "./openapi-types";12} from "./types";
13import {13import {
14 openApiProviderDataFromDefinition,14 openApiProviderDataFromDefinition,
15 type OpenApiToolDefinition,15 type OpenApiToolDefinition,
16} from "./openapi-definitions";16} from "./definitions";
17import {17import {
18 resolveSchemaWithRefHints,18 resolveSchemaWithRefHints,
19 resolveTypingSchemasWithRefHints,19 resolveTypingSchemasWithRefHints,
20} from "./openapi-schema-refs";20} from "./schema-refs";
21 21
22const asRecord = (value: unknown): Record<string, unknown> =>22const asRecord = (value: unknown): Record<string, unknown> =>
23 typeof value === "object" && value !== null && !Array.isArray(value)23 typeof value === "object" && value !== null && !Array.isArray(value)
packages/drivers/openapi/src/tools.test.tsrenamed from packages/drivers/openapi/src/openapi-tools.test.ts+2−2
@@ -20,8 +20,8 @@ import { Schema } from "effect"; · 19 unmodified lines
20 20
21import type { ToolDefinition, ToolInput, ToolMap } from "@executor/codemode-core";21import type { ToolDefinition, ToolInput, ToolMap } from "@executor/codemode-core";
22 22
23import { extractOpenApiManifest } from "./openapi-extraction";23import { extractOpenApiManifest } from "./extraction";
24import { createOpenApiToolsFromManifest, createOpenApiToolsFromSpec } from "./openapi-tools";24import { createOpenApiToolsFromManifest, createOpenApiToolsFromSpec } from "./tools";
25 25
26type TestServer = {26type TestServer = {
27 baseUrl: string;27 baseUrl: string;
packages/drivers/openapi/src/tools.tsrenamed from packages/drivers/openapi/src/openapi-tools.ts+6−6
@@ -21,26 +21,26 @@ import { · 20 unmodified lines
21import {21import {
22 compileOpenApiToolDefinitions,22 compileOpenApiToolDefinitions,
23 type OpenApiToolDefinition,23 type OpenApiToolDefinition,
24} from "./openapi-definitions";24} from "./definitions";
25import {25import {
26 httpBodyModeFromContentType,26 httpBodyModeFromContentType,
27 serializeOpenApiParameterValue,27 serializeOpenApiParameterValue,
28 serializeOpenApiRequestBody,28 serializeOpenApiRequestBody,
29 withSerializedQueryEntries,29 withSerializedQueryEntries,
30 type SerializedOpenApiQueryEntry,30 type SerializedOpenApiQueryEntry,
31} from "./openapi-http-serialization";31} from "./http-serialization";
32import { buildOpenApiToolPresentation } from "./openapi-tool-presentation";32import { buildOpenApiToolPresentation } from "./tool-presentation";
33import { resolveSchemaWithRefHints } from "./openapi-schema-refs";33import { resolveSchemaWithRefHints } from "./schema-refs";
34import {34import {
35 extractOpenApiManifest,35 extractOpenApiManifest,
36 type OpenApiExtractionError,36 type OpenApiExtractionError,
37} from "./openapi-extraction";37} from "./extraction";
38import {38import {
39 type OpenApiRefHintTable,39 type OpenApiRefHintTable,
40 type OpenApiInvocationPayload,40 type OpenApiInvocationPayload,
41 type OpenApiSpecInput,41 type OpenApiSpecInput,
42 type OpenApiToolManifest,42 type OpenApiToolManifest,
43} from "./openapi-types";43} from "./types";
44 44
45type OpenApiToolArgs = Record<string, unknown>;45type OpenApiToolArgs = Record<string, unknown>;
46type OpenApiToolParameter = OpenApiInvocationPayload["parameters"][number];46type OpenApiToolParameter = OpenApiInvocationPayload["parameters"][number];
packages/drivers/openapi/src/types.tsrenamed from packages/drivers/openapi/src/openapi-types.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/api/executions/http.ts+1−1
@@ -4,7 +4,7 @@ import { · 3 unmodified lines
4 createExecution,4 createExecution,
5 getExecution,5 getExecution,
6 resumeExecution,6 resumeExecution,
7} from "../../runtime/execution/execution-service";7} from "../../runtime/execution/service";
8 8
9import { ControlPlaneApi } from "../api";9import { ControlPlaneApi } from "../api";
10import { resolveRequestedLocalWorkspace } from "../local-context";10import { resolveRequestedLocalWorkspace } from "../local-context";
packages/platform/control-plane/src/api/local-context.ts+2−2
@@ -3,8 +3,8 @@ import * as Effect from "effect/Effect"; · 2 unmodified lines
3 3
4import {4import {
5 RuntimeLocalWorkspaceMismatchError,5 RuntimeLocalWorkspaceMismatchError,
6} from "../runtime/local/local-errors";6} from "../runtime/local/errors";
7import { requireRuntimeLocalWorkspace } from "../runtime/local/local-runtime-context";7import { requireRuntimeLocalWorkspace } from "../runtime/local/runtime-context";
8import { ControlPlaneForbiddenError } from "./errors";8import { ControlPlaneForbiddenError } from "./errors";
9 9
10export const resolveRequestedLocalWorkspace = (10export const resolveRequestedLocalWorkspace = (
packages/platform/control-plane/src/api/local/http.ts+2−2
@@ -7,8 +7,8 @@ import * as Option from "effect/Option"; · 6 unmodified lines
7import { SecretMaterialIdSchema } from "#schema";7import { SecretMaterialIdSchema } from "#schema";
8import {8import {
9 getLocalInstallation,9 getLocalInstallation,
10} from "../../runtime/local/local-operations";10} from "../../runtime/local/operations";
11import { requireRuntimeLocalWorkspace } from "../../runtime/local/local-runtime-context";11import { requireRuntimeLocalWorkspace } from "../../runtime/local/runtime-context";
12import {12import {
13 createDefaultSecretMaterialDeleter,13 createDefaultSecretMaterialDeleter,
14 createDefaultSecretMaterialStorer,14 createDefaultSecretMaterialStorer,
packages/platform/control-plane/src/api/sources/http.ts+1−1
@@ -22,7 +22,7 @@ import { · 21 unmodified lines
22 completeSourceCredentialSetup,22 completeSourceCredentialSetup,
23 getSourceCredentialInteraction,23 getSourceCredentialInteraction,
24 submitSourceCredentialInteraction,24 submitSourceCredentialInteraction,
25} from "../../runtime/local/local-operations";25} from "../../runtime/local/operations";
26import { discoverSource } from "../../runtime/sources/source-discovery";26import { discoverSource } from "../../runtime/sources/source-discovery";
27import { hasSourceAdapterFamily } from "../../runtime/sources/source-adapters";27import { hasSourceAdapterFamily } from "../../runtime/sources/source-adapters";
28import { RuntimeSourceAuthServiceTag } from "../../runtime/sources/source-auth-service";28import { RuntimeSourceAuthServiceTag } from "../../runtime/sources/source-auth-service";
packages/platform/control-plane/src/runtime/catalog/source/runtime.test.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-catalog-runtime.test.ts+2−2
@@ -33,12 +33,12 @@ import { · 32 unmodified lines
33 formatTypeNameSegment,33 formatTypeNameSegment,
34 joinTypeNameSegments,34 joinTypeNameSegments,
35 projectedCatalogTypeRoots,35 projectedCatalogTypeRoots,
36} from "./catalog-typescript";36} from "../catalog-typescript";
37import {37import {
38 expandCatalogToolByPath,38 expandCatalogToolByPath,
39 expandCatalogTools,39 expandCatalogTools,
40 type LoadedSourceCatalog,40 type LoadedSourceCatalog,
41} from "./source-catalog-runtime";41} from "./runtime";
42 42
43const put = <K extends string, V>(record: Record<K, V>, key: K, value: V) => {43const put = <K extends string, V>(record: Record<K, V>, key: K, value: V) => {
44 record[key] = value;44 record[key] = value;
packages/platform/control-plane/src/runtime/catalog/source/runtime.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-catalog-runtime.ts+7−7
@@ -30,27 +30,27 @@ import type { · 29 unmodified lines
30 ShapeSymbol,30 ShapeSymbol,
31 Symbol as IrSymbol,31 Symbol as IrSymbol,
32} from "@executor/ir/model";32} from "@executor/ir/model";
33import { LocalSourceArtifactMissingError } from "../local/local-errors";33import { LocalSourceArtifactMissingError } from "../../local/errors";
34import {34import {
35 createCatalogTypeProjector,35 createCatalogTypeProjector,
36 joinTypeNameSegments,36 joinTypeNameSegments,
37 projectedCatalogTypeRoots,37 projectedCatalogTypeRoots,
38 type CatalogTypeProjector,38 type CatalogTypeProjector,
39} from "./catalog-typescript";39} from "../catalog-typescript";
40import {40import {
41 RuntimeLocalWorkspaceService,41 RuntimeLocalWorkspaceService,
42 type RuntimeLocalWorkspaceState,42 type RuntimeLocalWorkspaceState,
43} from "../local/local-runtime-context";43} from "../../local/runtime-context";
44import type { LocalSourceArtifact } from "../local/local-source-artifacts";44import type { LocalSourceArtifact } from "../../local/source-artifacts";
45import {45import {
46 SourceArtifactStore,46 SourceArtifactStore,
47 type SourceArtifactStoreShape,47 type SourceArtifactStoreShape,
48} from "../local/local-storage";48} from "../../local/storage";
49import { namespaceFromSourceName } from "../sources/source-names";49import { namespaceFromSourceName } from "../../sources/source-names";
50import {50import {
51 RuntimeSourceStoreService,51 RuntimeSourceStoreService,
52 type RuntimeSourceStore,52 type RuntimeSourceStore,
53} from "../sources/source-store";53} from "../../sources/source-store";
54 54
55type CatalogImportMetadata = CatalogSnapshotV1["import"];55type CatalogImportMetadata = CatalogSnapshotV1["import"];
56 56
packages/platform/control-plane/src/runtime/catalog/source/snapshot.test.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-catalog-snapshot.test.ts+1−1
@@ -6,7 +6,7 @@ import { · 5 unmodified lines
6 buildGraphqlToolPresentation,6 buildGraphqlToolPresentation,
7 compileGraphqlToolDefinitions,7 compileGraphqlToolDefinitions,
8 type GraphqlToolManifest,8 type GraphqlToolManifest,
9} from "../sources/graphql-tools";9} from "../../sources/graphql-tools";
10import {10import {
11 createGoogleDiscoveryCatalogSnapshot,11 createGoogleDiscoveryCatalogSnapshot,
12 createGraphqlCatalogSnapshot,12 createGraphqlCatalogSnapshot,
packages/platform/control-plane/src/runtime/catalog/source/sync.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-catalog-sync.ts+9−9
@@ -11,30 +11,30 @@ import * as Layer from "effect/Layer"; · 10 unmodified lines
11import {11import {
12 RuntimeLocalWorkspaceService,12 RuntimeLocalWorkspaceService,
13 type RuntimeLocalWorkspaceState,13 type RuntimeLocalWorkspaceState,
14} from "../local/local-runtime-context";14} from "../../local/runtime-context";
15import {15import {
16 SourceArtifactStore,16 SourceArtifactStore,
17 type SourceArtifactStoreShape,17 type SourceArtifactStoreShape,
18 WorkspaceStateStore,18 WorkspaceStateStore,
19 type WorkspaceStateStoreShape,19 type WorkspaceStateStoreShape,
20} from "../local/local-storage";20} from "../../local/storage";
21import {21import {
22 type LocalWorkspaceState,22 type LocalWorkspaceState,
23} from "../local/local-workspace-state";23} from "../../local/workspace-state";
24import {24import {
25 RuntimeSourceAuthMaterialService,25 RuntimeSourceAuthMaterialService,
26} from "../auth/source-auth-material";26} from "../../auth/source-auth-material";
27import {27import {
28 getSourceAdapterForSource,28 getSourceAdapterForSource,
29} from "../sources/source-adapters";29} from "../../sources/source-adapters";
30import {30import {
31 catalogSyncResultFromMcpManifest,31 catalogSyncResultFromMcpManifest,
32} from "../sources/source-adapters/mcp";32} from "../../sources/source-adapters/mcp";
33import { SecretMaterialResolverService } from "../local/secret-material-providers";33import { SecretMaterialResolverService } from "../../local/secret-material-providers";
34import { snapshotFromSourceCatalogSyncResult } from "../sources/catalog-sync-result";34import { snapshotFromSourceCatalogSyncResult } from "../../sources/catalog-sync-result";
35import {35import {
36 refreshSourceTypeDeclarationInBackground,36 refreshSourceTypeDeclarationInBackground,
37} from "./source-type-declarations";37} from "./type-declarations";
38 38
39const shouldIndexSource = (source: Source): boolean =>39const shouldIndexSource = (source: Source): boolean =>
40 source.enabled40 source.enabled
packages/platform/control-plane/src/runtime/catalog/source/type-declarations.test.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-type-declarations.test.ts+1−1
@@ -24,7 +24,7 @@ import { · 23 unmodified lines
24 ShapeSymbolIdSchema,24 ShapeSymbolIdSchema,
25} from "@executor/ir/ids";25} from "@executor/ir/ids";
26import type { CatalogV1, GraphQLExecutable, ProvenanceRef } from "@executor/ir/model";26import type { CatalogV1, GraphQLExecutable, ProvenanceRef } from "@executor/ir/model";
27import { syncWorkspaceSourceTypeDeclarationsNode } from "./source-type-declarations";27import { syncWorkspaceSourceTypeDeclarationsNode } from "./type-declarations";
28 28
29const put = <K extends string, V>(record: Record<K, V>, key: K, value: V) => {29const put = <K extends string, V>(record: Record<K, V>, key: K, value: V) => {
30 record[key] = value;30 record[key] = value;
packages/platform/control-plane/src/runtime/catalog/source/type-declarations.tsrenamed from packages/platform/control-plane/src/runtime/catalog/source-type-declarations.ts+3−3
@@ -14,12 +14,12 @@ import { · 13 unmodified lines
14 joinTypeNameSegments,14 joinTypeNameSegments,
15 projectedCatalogTypeRoots,15 projectedCatalogTypeRoots,
16 shapeAllowsOmittedArgs,16 shapeAllowsOmittedArgs,
17} from "./catalog-typescript";17} from "../catalog-typescript";
18import type { ResolvedLocalWorkspaceContext } from "../local/local-config";18import type { ResolvedLocalWorkspaceContext } from "../../local/config";
19import {19import {
20 LocalFileSystemError,20 LocalFileSystemError,
21 unknownLocalErrorDetails,21 unknownLocalErrorDetails,
22} from "../local/local-errors";22} from "../../local/errors";
23 23
24type SourceDeclarationEntry = {24type SourceDeclarationEntry = {
25 source: Source;25 source: Source;
packages/platform/control-plane/src/runtime/execution/http.test.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-http.test.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/ir-execution.ts+1−1
@@ -33,7 +33,7 @@ import type { · 32 unmodified lines
33 ParameterSymbol,33 ParameterSymbol,
34 Scope,34 Scope,
35} from "@executor/ir/model";35} from "@executor/ir/model";
36import type { LoadedSourceCatalogToolIndexEntry } from "../catalog/source-catalog-runtime";36import type { LoadedSourceCatalogToolIndexEntry } from "../catalog/source/runtime";
37import type { ResolvedSourceAuthMaterial } from "../auth/source-auth-material";37import type { ResolvedSourceAuthMaterial } from "../auth/source-auth-material";
38 38
39const asObject = (value: unknown): Record<string, unknown> =>39const asObject = (value: unknown): Record<string, unknown> =>
packages/platform/control-plane/src/runtime/execution/live.test.tsrenamed from packages/platform/control-plane/src/runtime/execution/live-execution.test.ts+1−1
@@ -1,6 +1,6 @@
1import { describe, expect, it } from "@effect/vitest";1import { describe, expect, it } from "@effect/vitest";
2 2
3import { sanitizePersistedElicitationResponse } from "./live-execution";3import { sanitizePersistedElicitationResponse } from "./live";
4 4
5describe("live-execution", () => {5describe("live-execution", () => {
6 it("redacts secret refs from persisted interaction responses", () => {6 it("redacts secret refs from persisted interaction responses", () => {
packages/platform/control-plane/src/runtime/execution/live.tsrenamed from packages/platform/control-plane/src/runtime/execution/live-execution.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/mcp-resume.test.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-mcp-resume.test.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/runtime-config.test.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-runtime-config.test.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/runtime.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-runtime.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/service.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-service.ts+4−4
@@ -29,16 +29,16 @@ import * as Effect from "effect/Effect"; · 28 unmodified lines
29import * as Option from "effect/Option";29import * as Option from "effect/Option";
30import * as Schema from "effect/Schema";30import * as Schema from "effect/Schema";
31 31
32import { type ResolveExecutionEnvironment } from "./execution-state";32import { type ResolveExecutionEnvironment } from "./state";
33import {33import {
34 LiveExecutionManagerService,34 LiveExecutionManagerService,
35 sanitizePersistedElicitationResponse,35 sanitizePersistedElicitationResponse,
36 type LiveExecutionManager,36 type LiveExecutionManager,
37} from "./live-execution";37} from "./live";
38import {38import {
39 getRuntimeLocalWorkspaceOption,39 getRuntimeLocalWorkspaceOption,
40 provideOptionalRuntimeLocalWorkspace,40 provideOptionalRuntimeLocalWorkspace,
41} from "../local/local-runtime-context";41} from "../local/runtime-context";
42import {42import {
43 asOperationErrors,43 asOperationErrors,
44 operationErrors,44 operationErrors,
@@ -48,7 +48,7 @@ import { · 3 unmodified lines
48 ControlPlaneStore,48 ControlPlaneStore,
49 type ControlPlaneStoreShape,49 type ControlPlaneStoreShape,
50} from "../store";50} from "../store";
51import { RuntimeExecutionResolverService } from "./workspace-execution-environment";51import { RuntimeExecutionResolverService } from "./workspace/environment";
52 52
53const executionOps = {53const executionOps = {
54 create: operationErrors("executions.create"),54 create: operationErrors("executions.create"),
packages/platform/control-plane/src/runtime/execution/state.tsrenamed from packages/platform/control-plane/src/runtime/execution/execution-state.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/execution/workspace/authorization.tsrenamed from packages/platform/control-plane/src/runtime/execution/workspace-persisted-tool-authorization.ts+6−6
@@ -4,12 +4,12 @@ import * as Either from "effect/Either"; · 3 unmodified lines
4import * as Effect from "effect/Effect";4import * as Effect from "effect/Effect";
5import * as Schema from "effect/Schema";5import * as Schema from "effect/Schema";
6 6
7import type { LoadedSourceCatalogToolIndexEntry } from "../catalog/source-catalog-runtime";7import type { LoadedSourceCatalogToolIndexEntry } from "../../catalog/source/runtime";
8import type { SecretMaterialResolveContext } from "../local/secret-material-providers";8import type { SecretMaterialResolveContext } from "../../local/secret-material-providers";
9import type { WorkspaceStorageServices } from "../local/local-storage";9import type { WorkspaceStorageServices } from "../../local/storage";
10import { invocationDescriptorFromTool } from "./ir-execution";10import { invocationDescriptorFromTool } from "../ir-execution";
11import { evaluateInvocationPolicy } from "../policy/invocation-policy-engine";11import { evaluateInvocationPolicy } from "../../policy/invocation-policy-engine";
12import { loadRuntimeLocalWorkspacePolicies } from "../policy/policies-operations";12import { loadRuntimeLocalWorkspacePolicies } from "../../policy/policies-operations";
13 13
14const asToolPath = (value: string): ToolPath => value as ToolPath;14const asToolPath = (value: string): ToolPath => value as ToolPath;
15 15
packages/platform/control-plane/src/runtime/execution/workspace/environment.tsrenamed from packages/platform/control-plane/src/runtime/execution/workspace-execution-environment.ts+10−10
@@ -13,27 +13,27 @@ import * as Layer from "effect/Layer"; · 12 unmodified lines
13import type {13import type {
14 ExecutionEnvironment,14 ExecutionEnvironment,
15 ResolveExecutionEnvironment,15 ResolveExecutionEnvironment,
16} from "./execution-state";16} from "../state";
17import {17import {
18 createCodeExecutorForRuntime,18 createCodeExecutorForRuntime,
19 resolveConfiguredExecutionRuntime,19 resolveConfiguredExecutionRuntime,
20} from "./execution-runtime";20} from "../runtime";
21import { createWorkspaceToolInvoker } from "./workspace-tool-invoker";21import { createWorkspaceToolInvoker } from "./tool-invoker";
22import {22import {
23 RuntimeSourceAuthServiceTag,23 RuntimeSourceAuthServiceTag,
24} from "../sources/source-auth-service";24} from "../../sources/source-auth-service";
25import {25import {
26 RuntimeSourceCatalogStoreService,26 RuntimeSourceCatalogStoreService,
27} from "../catalog/source-catalog-runtime";27} from "../../catalog/source/runtime";
28import { RuntimeSourceAuthMaterialService } from "../auth/source-auth-material";28import { RuntimeSourceAuthMaterialService } from "../../auth/source-auth-material";
29import {29import {
30 getRuntimeLocalWorkspaceOption,30 getRuntimeLocalWorkspaceOption,
31} from "../local/local-runtime-context";31} from "../../local/runtime-context";
32import {32import {
33 LocalToolRuntimeLoaderService,33 LocalToolRuntimeLoaderService,
34 type LocalToolRuntimeLoaderShape,34 type LocalToolRuntimeLoaderShape,
35 type LocalToolRuntime,35 type LocalToolRuntime,
36} from "../local/local-tools";36} from "../../local/tools";
37import {37import {
38 SourceArtifactStore,38 SourceArtifactStore,
39 type SourceArtifactStoreShape,39 type SourceArtifactStoreShape,
@@ -41,11 +41,11 @@ import { · 1 unmodified line
41 type WorkspaceConfigStoreShape,41 type WorkspaceConfigStoreShape,
42 WorkspaceStateStore,42 WorkspaceStateStore,
43 type WorkspaceStateStoreShape,43 type WorkspaceStateStoreShape,
44} from "../local/local-storage";44} from "../../local/storage";
45export {45export {
46 createCodeExecutorForRuntime,46 createCodeExecutorForRuntime,
47 resolveConfiguredExecutionRuntime,47 resolveConfiguredExecutionRuntime,
48} from "./execution-runtime";48} from "../runtime";
49 49
50const createEmptyLocalToolRuntime = (): LocalToolRuntime => ({50const createEmptyLocalToolRuntime = (): LocalToolRuntime => ({
51 tools: {},51 tools: {},
packages/platform/control-plane/src/runtime/execution/workspace/local.tsrenamed from packages/platform/control-plane/src/runtime/execution/workspace-runtime-local.ts+1−1
@@ -3,7 +3,7 @@ import * as Effect from "effect/Effect"; · 2 unmodified lines
3import {3import {
4 provideOptionalRuntimeLocalWorkspace,4 provideOptionalRuntimeLocalWorkspace,
5 type RuntimeLocalWorkspaceState,5 type RuntimeLocalWorkspaceState,
6} from "../local/local-runtime-context";6} from "../../local/runtime-context";
7 7
8export const provideRuntimeLocalWorkspace = <A, E, R>(8export const provideRuntimeLocalWorkspace = <A, E, R>(
9 effect: Effect.Effect<A, E, R>,9 effect: Effect.Effect<A, E, R>,
packages/platform/control-plane/src/runtime/execution/workspace/source-catalog.tsrenamed from packages/platform/control-plane/src/runtime/execution/workspace-source-catalog.ts+4−4
@@ -9,16 +9,16 @@ import { · 8 unmodified lines
9 RuntimeSourceCatalogStoreService,9 RuntimeSourceCatalogStoreService,
10 type LoadedSourceCatalogToolIndexEntry,10 type LoadedSourceCatalogToolIndexEntry,
11 catalogToolCatalogEntry,11 catalogToolCatalogEntry,
12} from "../catalog/source-catalog-runtime";12} from "../../catalog/source/runtime";
13import type { RuntimeLocalWorkspaceState } from "../local/local-runtime-context";13import type { RuntimeLocalWorkspaceState } from "../../local/runtime-context";
14import {14import {
15 makeWorkspaceStorageLayer,15 makeWorkspaceStorageLayer,
16 type SourceArtifactStoreShape,16 type SourceArtifactStoreShape,
17 type WorkspaceConfigStoreShape,17 type WorkspaceConfigStoreShape,
18 type WorkspaceStateStoreShape,18 type WorkspaceStateStoreShape,
19 type WorkspaceStorageServices,19 type WorkspaceStorageServices,
20} from "../local/local-storage";20} from "../../local/storage";
21import { provideRuntimeLocalWorkspace } from "./workspace-runtime-local";21import { provideRuntimeLocalWorkspace } from "./local";
22 22
23const tokenize = (value: string): string[] =>23const tokenize = (value: string): string[] =>
24 value24 value
packages/platform/control-plane/src/runtime/execution/workspace/tool-invoker.tsrenamed from packages/platform/control-plane/src/runtime/execution/workspace-tool-invoker.ts+11−11
@@ -10,32 +10,32 @@ import { · 9 unmodified lines
10import type { AccountId, Source } from "#schema";10import type { AccountId, Source } from "#schema";
11import * as Effect from "effect/Effect";11import * as Effect from "effect/Effect";
12 12
13import { RuntimeSourceAuthMaterialService } from "../auth/source-auth-material";13import { RuntimeSourceAuthMaterialService } from "../../auth/source-auth-material";
14import { RuntimeSourceCatalogStoreService } from "../catalog/source-catalog-runtime";14import { RuntimeSourceCatalogStoreService } from "../../catalog/source/runtime";
15import type { RuntimeLocalWorkspaceState } from "../local/local-runtime-context";15import type { RuntimeLocalWorkspaceState } from "../../local/runtime-context";
16import {16import {
17 type LocalToolRuntime,17 type LocalToolRuntime,
18} from "../local/local-tools";18} from "../../local/tools";
19import {19import {
20 makeWorkspaceStorageLayer,20 makeWorkspaceStorageLayer,
21 type SourceArtifactStoreShape,21 type SourceArtifactStoreShape,
22 type WorkspaceConfigStoreShape,22 type WorkspaceConfigStoreShape,
23 type WorkspaceStateStoreShape,23 type WorkspaceStateStoreShape,
24} from "../local/local-storage";24} from "../../local/storage";
25import {25import {
26 RuntimeSourceAuthService,26 RuntimeSourceAuthService,
27} from "../sources/source-auth-service";27} from "../../sources/source-auth-service";
28import { createExecutorToolMap } from "../sources/executor-tools";28import { createExecutorToolMap } from "../../sources/executor-tools";
29import { invokeIrTool } from "./ir-execution";29import { invokeIrTool } from "../ir-execution";
30import {30import {
31 authorizePersistedToolInvocation,31 authorizePersistedToolInvocation,
32 toSecretResolutionContext,32 toSecretResolutionContext,
33} from "./workspace-persisted-tool-authorization";33} from "./authorization";
34import { provideRuntimeLocalWorkspace } from "./workspace-runtime-local";34import { provideRuntimeLocalWorkspace } from "./local";
35import {35import {
36 createWorkspaceSourceCatalog,36 createWorkspaceSourceCatalog,
37 loadWorkspaceCatalogToolByPath,37 loadWorkspaceCatalogToolByPath,
38} from "./workspace-source-catalog";38} from "./source-catalog";
39 39
40export const createWorkspaceToolInvoker = (input: {40export const createWorkspaceToolInvoker = (input: {
41 workspaceId: Source["workspaceId"];41 workspaceId: Source["workspaceId"];
packages/platform/control-plane/src/runtime/index.ts+20−20
@@ -8,35 +8,35 @@ import { NodeFileSystem } from "@effect/platform-node"; · 7 unmodified lines
8import { type ControlPlaneApiRuntimeContext } from "#api";8import { type ControlPlaneApiRuntimeContext } from "#api";
9import type { LocalInstallation } from "#schema";9import type { LocalInstallation } from "#schema";
10 10
11import { type ResolveExecutionEnvironment } from "./execution/execution-state";11import { type ResolveExecutionEnvironment } from "./execution/state";
12import {12import {
13 createLiveExecutionManager,13 createLiveExecutionManager,
14 LiveExecutionManagerService,14 LiveExecutionManagerService,
15} from "./execution/live-execution";15} from "./execution/live";
16import {16import {
17 createLocalControlPlanePersistence,17 createLocalControlPlanePersistence,
18 type LocalControlPlanePersistence,18 type LocalControlPlanePersistence,
19} from "./local/local-control-plane-store";19} from "./local/control-plane-store";
20 20
21import {21import {
22 resolveLocalWorkspaceContext,22 resolveLocalWorkspaceContext,
23} from "./local/local-config";23} from "./local/config";
24import {24import {
25 LocalStorageLive,25 LocalStorageLive,
26 LocalInstallationStore,26 LocalInstallationStore,
27 LocalWorkspaceConfigStore,27 LocalWorkspaceConfigStore,
28} from "./local/local-storage";28} from "./local/storage";
29import {29import {
30 type RuntimeLocalWorkspaceState,30 type RuntimeLocalWorkspaceState,
31 RuntimeLocalWorkspaceLive,31 RuntimeLocalWorkspaceLive,
32} from "./local/local-runtime-context";32} from "./local/runtime-context";
33import { LocalToolRuntimeLoaderLive } from "./local/local-tools";33import { LocalToolRuntimeLoaderLive } from "./local/tools";
34import { synchronizeLocalWorkspaceState } from "./local/local-workspace-sync";34import { synchronizeLocalWorkspaceState } from "./local/workspace-sync";
35import { ControlPlaneStore, type ControlPlaneStoreShape } from "./store";35import { ControlPlaneStore, type ControlPlaneStoreShape } from "./store";
36import { RuntimeSourceStoreLive } from "./sources/source-store";36import { RuntimeSourceStoreLive } from "./sources/source-store";
37import { RuntimeSourceCatalogStoreLive } from "./catalog/source-catalog-runtime";37import { RuntimeSourceCatalogStoreLive } from "./catalog/source/runtime";
38import { RuntimeSourceAuthMaterialLive } from "./auth/source-auth-material";38import { RuntimeSourceAuthMaterialLive } from "./auth/source-auth-material";
39import { RuntimeSourceCatalogSyncLive } from "./catalog/source-catalog-sync";39import { RuntimeSourceCatalogSyncLive } from "./catalog/source/sync";
40import {40import {
41 RuntimeSourceAuthServiceLive,41 RuntimeSourceAuthServiceLive,
42} from "./sources/source-auth-service";42} from "./sources/source-auth-service";
@@ -44,26 +44,26 @@ import type { ResolveSecretMaterial } from "./local/secret-material-providers"; · 1 unmodified line
44import { SecretMaterialLive } from "./local/secret-material-providers";44import { SecretMaterialLive } from "./local/secret-material-providers";
45import {45import {
46 RuntimeExecutionResolverLive,46 RuntimeExecutionResolverLive,
47} from "./execution/workspace-execution-environment";47} from "./execution/workspace/environment";
48 48
49export * from "./execution/execution-state";49export * from "./execution/state";
50export * from "./sources/executor-tools";50export * from "./sources/executor-tools";
51export * from "./execution/live-execution";51export * from "./execution/live";
52export * from "./local/local-config";52export * from "./local/config";
53export * from "./local/local-installation";53export * from "./local/installation";
54export * from "./local/local-storage";54export * from "./local/storage";
55export * from "./local/local-source-artifacts";55export * from "./local/source-artifacts";
56export * from "./local/local-tools";56export * from "./local/tools";
57export * from "./catalog/schema-type-signature";57export * from "./catalog/schema-type-signature";
58export * from "./sources/source-auth-service";58export * from "./sources/source-auth-service";
59export * from "./local/secret-material-providers";59export * from "./local/secret-material-providers";
60export * from "./sources/source-credential-interactions";60export * from "./sources/source-credential-interactions";
61export * from "./sources/source-adapters/mcp";61export * from "./sources/source-adapters/mcp";
62export * from "./store";62export * from "./store";
63export * from "./execution/workspace-execution-environment";63export * from "./execution/workspace/environment";
64export * from "./sources/source-inspection";64export * from "./sources/source-inspection";
65export * from "./sources/source-discovery";65export * from "./sources/source-discovery";
66export * from "./execution/execution-service";66export * from "./execution/service";
67 67
68export type RuntimeControlPlaneOptions = {68export type RuntimeControlPlaneOptions = {
69 executionResolver?: ResolveExecutionEnvironment;69 executionResolver?: ResolveExecutionEnvironment;
packages/platform/control-plane/src/runtime/local/config-secrets.tsrenamed from packages/platform/control-plane/src/runtime/local/local-config-secrets.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/local/config.test.tsrenamed from packages/platform/control-plane/src/runtime/local/local-config.test.ts+1−1
@@ -13,7 +13,7 @@ import { · 12 unmodified lines
13 resolveDefaultHomeStateDirectory,13 resolveDefaultHomeStateDirectory,
14 resolveHomeConfigPath,14 resolveHomeConfigPath,
15 resolveLocalWorkspaceContext,15 resolveLocalWorkspaceContext,
16} from "./local-config";16} from "./config";
17 17
18const makeWorkspaceRoot = () =>18const makeWorkspaceRoot = () =>
19 mkdtempSync(join(tmpdir(), "executor-local-config-"));19 mkdtempSync(join(tmpdir(), "executor-local-config-"));
packages/platform/control-plane/src/runtime/local/config.tsrenamed from packages/platform/control-plane/src/runtime/local/local-config.ts+1−1
@@ -20,7 +20,7 @@ import { · 19 unmodified lines
20 LocalExecutorConfigDecodeError,20 LocalExecutorConfigDecodeError,
21 LocalFileSystemError,21 LocalFileSystemError,
22 unknownLocalErrorDetails,22 unknownLocalErrorDetails,
23} from "./local-errors";23} from "./errors";
24 24
25const decodeLocalExecutorConfig = Schema.decodeUnknownSync(LocalExecutorConfigSchema);25const decodeLocalExecutorConfig = Schema.decodeUnknownSync(LocalExecutorConfigSchema);
26 26
packages/platform/control-plane/src/runtime/local/control-plane-store.test.tsrenamed from packages/platform/control-plane/src/runtime/local/local-control-plane-store.test.ts+2−2
@@ -4,12 +4,12 @@ import { dirname, join } from "node:path"; · 3 unmodified lines
4import { describe, expect, it } from "@effect/vitest";4import { describe, expect, it } from "@effect/vitest";
5import * as Effect from "effect/Effect";5import * as Effect from "effect/Effect";
6 6
7import type { ResolvedLocalWorkspaceContext } from "./local-config";7import type { ResolvedLocalWorkspaceContext } from "./config";
8import {8import {
9 loadLocalControlPlaneState,9 loadLocalControlPlaneState,
10 localControlPlaneStatePath,10 localControlPlaneStatePath,
11 writeLocalControlPlaneState,11 writeLocalControlPlaneState,
12} from "./local-control-plane-store";12} from "./control-plane-store";
13 13
14const makeContext = (): ResolvedLocalWorkspaceContext => {14const makeContext = (): ResolvedLocalWorkspaceContext => {
15 const workspaceRoot = mkdtempSync(join(tmpdir(), "executor-control-plane-store-"));15 const workspaceRoot = mkdtempSync(join(tmpdir(), "executor-control-plane-store-"));
packages/platform/control-plane/src/runtime/local/control-plane-store.tsrenamed from packages/platform/control-plane/src/runtime/local/local-control-plane-store.ts+3−3
@@ -29,12 +29,12 @@ import * as Effect from "effect/Effect"; · 28 unmodified lines
29import * as Option from "effect/Option";29import * as Option from "effect/Option";
30import * as Schema from "effect/Schema";30import * as Schema from "effect/Schema";
31 31
32import type { ResolvedLocalWorkspaceContext } from "./local-config";32import type { ResolvedLocalWorkspaceContext } from "./config";
33import { deriveLocalInstallation } from "./local-installation";33import { deriveLocalInstallation } from "./installation";
34import {34import {
35 LocalFileSystemError,35 LocalFileSystemError,
36 unknownLocalErrorDetails,36 unknownLocalErrorDetails,
37} from "./local-errors";37} from "./errors";
38 38
39const LOCAL_CONTROL_PLANE_STATE_VERSION = 1 as const;39const LOCAL_CONTROL_PLANE_STATE_VERSION = 1 as const;
40const LOCAL_CONTROL_PLANE_STATE_BASENAME = "control-plane-state.json";40const LOCAL_CONTROL_PLANE_STATE_BASENAME = "control-plane-state.json";
packages/platform/control-plane/src/runtime/local/errors.tsrenamed from packages/platform/control-plane/src/runtime/local/local-errors.ts+0−0

File renamed without changes.

packages/platform/control-plane/src/runtime/local/installation.test.tsrenamed from packages/platform/control-plane/src/runtime/local/local-installation.test.ts+2−2
@@ -6,8 +6,8 @@ import { describe, expect, it } from "@effect/vitest"; · 5 unmodified lines
6import * as Effect from "effect/Effect";6import * as Effect from "effect/Effect";
7 7
8import { createControlPlaneRuntime } from "../index";8import { createControlPlaneRuntime } from "../index";
9import { getOrProvisionLocalInstallation } from "./local-installation";9import { getOrProvisionLocalInstallation } from "./installation";
10import { resolveLocalWorkspaceContext } from "./local-config";10import { resolveLocalWorkspaceContext } from "./config";
11 11
12const TEST_WORKSPACE_ROOT = mkdtempSync(join(tmpdir(), "executor-local-installation-"));12const TEST_WORKSPACE_ROOT = mkdtempSync(join(tmpdir(), "executor-local-installation-"));
13const TEST_HOME_CONFIG_PATH = join(TEST_WORKSPACE_ROOT, ".executor-home.jsonc");13const TEST_HOME_CONFIG_PATH = join(TEST_WORKSPACE_ROOT, ".executor-home.jsonc");
packages/platform/control-plane/src/runtime/local/installation.tsrenamed from packages/platform/control-plane/src/runtime/local/local-installation.ts+1−1
@@ -7,7 +7,7 @@ import { · 6 unmodified lines
7} from "#schema";7} from "#schema";
8import * as Effect from "effect/Effect";8import * as Effect from "effect/Effect";
9 9
10import type { ResolvedLocalWorkspaceContext } from "./local-config";10import type { ResolvedLocalWorkspaceContext } from "./config";
11 11
12const LOCAL_ACCOUNT_ID = AccountIdSchema.make("acc_local_default");12const LOCAL_ACCOUNT_ID = AccountIdSchema.make("acc_local_default");
13 13
packages/platform/control-plane/src/runtime/local/operations.tsrenamed from packages/platform/control-plane/src/runtime/local/local-operations.ts+5−5
@@ -11,14 +11,14 @@ import { · 10 unmodified lines
11import * as Effect from "effect/Effect";11import * as Effect from "effect/Effect";
12import * as Option from "effect/Option";12import * as Option from "effect/Option";
13 13
14import { submitExecutionInteractionResponse } from "../execution/execution-service";14import { submitExecutionInteractionResponse } from "../execution/service";
15import { LiveExecutionManagerService } from "../execution/live-execution";15import { LiveExecutionManagerService } from "../execution/live";
16import {16import {
17 operationErrors,17 operationErrors,
18} from "../policy/operation-errors";18} from "../policy/operation-errors";
19import { resolveLocalWorkspaceContext } from "./local-config";19import { resolveLocalWorkspaceContext } from "./config";
20import { InstallationStore, LocalInstallationStore } from "./local-storage";20import { InstallationStore, LocalInstallationStore } from "./storage";
21import { getRuntimeLocalWorkspaceOption } from "./local-runtime-context";21import { getRuntimeLocalWorkspaceOption } from "./runtime-context";
22import { RuntimeSourceAuthServiceTag } from "../sources/source-auth-service";22import { RuntimeSourceAuthServiceTag } from "../sources/source-auth-service";
23import {23import {
24 createSourceCredentialSelectionBearerContent,24 createSourceCredentialSelectionBearerContent,
packages/platform/control-plane/src/runtime/local/runtime-context.tsrenamed from packages/platform/control-plane/src/runtime/local/local-runtime-context.ts+2−2
@@ -7,11 +7,11 @@ import type { AccountId, WorkspaceId } from "#schema"; · 6 unmodified lines
7import type {7import type {
8 LoadedLocalExecutorConfig,8 LoadedLocalExecutorConfig,
9 ResolvedLocalWorkspaceContext,9 ResolvedLocalWorkspaceContext,
10} from "./local-config";10} from "./config";
11import {11import {
12 RuntimeLocalWorkspaceMismatchError,12 RuntimeLocalWorkspaceMismatchError,
13 RuntimeLocalWorkspaceUnavailableError,13 RuntimeLocalWorkspaceUnavailableError,
14} from "./local-errors";14} from "./errors";
15 15
16export type RuntimeLocalWorkspaceState = {16export type RuntimeLocalWorkspaceState = {
17 context: ResolvedLocalWorkspaceContext;17 context: ResolvedLocalWorkspaceContext;
packages/platform/control-plane/src/runtime/local/secret-material-providers.ts+3−3
@@ -17,9 +17,9 @@ import * as Effect from "effect/Effect"; · 16 unmodified lines
17import * as Layer from "effect/Layer";17import * as Layer from "effect/Layer";
18import * as Option from "effect/Option";18import * as Option from "effect/Option";
19 19
20import { resolveConfigRelativePath } from "./local-config";20import { resolveConfigRelativePath } from "./config";
21import { fromConfigSecretProviderId } from "./local-config-secrets";21import { fromConfigSecretProviderId } from "./config-secrets";
22import { getRuntimeLocalWorkspaceOption } from "./local-runtime-context";22import { getRuntimeLocalWorkspaceOption } from "./runtime-context";
23import { ControlPlaneStore } from "../store";23import { ControlPlaneStore } from "../store";
24import type { ControlPlaneStoreShape } from "../store";24import type { ControlPlaneStoreShape } from "../store";
25 25
packages/platform/control-plane/src/runtime/local/source-artifacts.test.tsrenamed from packages/platform/control-plane/src/runtime/local/local-source-artifacts.test.ts+2−2
@@ -17,8 +17,8 @@ import { · 16 unmodified lines
17 readLocalSourceArtifact,17 readLocalSourceArtifact,
18 removeLocalSourceArtifact,18 removeLocalSourceArtifact,
19 writeLocalSourceArtifact,19 writeLocalSourceArtifact,
20} from "./local-source-artifacts";20} from "./source-artifacts";
21import type { ResolvedLocalWorkspaceContext } from "./local-config";21import type { ResolvedLocalWorkspaceContext } from "./config";
22import {22import {
23 createCatalogImportMetadata,23 createCatalogImportMetadata,
24 createGraphqlCatalogFragment,24 createGraphqlCatalogFragment,
packages/platform/control-plane/src/runtime/local/source-artifacts.tsrenamed from packages/platform/control-plane/src/runtime/local/local-source-artifacts.ts+2−2
@@ -25,12 +25,12 @@ import { · 24 unmodified lines
25 snapshotFromSourceCatalogSyncResult,25 snapshotFromSourceCatalogSyncResult,
26 type SourceCatalogSyncResult,26 type SourceCatalogSyncResult,
27} from "../sources/catalog-sync-result";27} from "../sources/catalog-sync-result";
28import type { ResolvedLocalWorkspaceContext } from "./local-config";28import type { ResolvedLocalWorkspaceContext } from "./config";
29import {29import {
30 LocalFileSystemError,30 LocalFileSystemError,
31 LocalSourceArtifactDecodeError,31 LocalSourceArtifactDecodeError,
32 unknownLocalErrorDetails,32 unknownLocalErrorDetails,
33} from "./local-errors";33} from "./errors";
34import {34import {
35 createSourceCatalogRevisionRecord,35 createSourceCatalogRevisionRecord,
36 stableSourceCatalogId,36 stableSourceCatalogId,
packages/platform/control-plane/src/runtime/local/storage.tsrenamed from packages/platform/control-plane/src/runtime/local/local-storage.ts+7−7
@@ -8,30 +8,30 @@ import * as Layer from "effect/Layer"; · 7 unmodified lines
8import type {8import type {
9 LoadedLocalExecutorConfig,9 LoadedLocalExecutorConfig,
10 ResolvedLocalWorkspaceContext,10 ResolvedLocalWorkspaceContext,
11} from "./local-config";11} from "./config";
12import {12import {
13 loadLocalExecutorConfig,13 loadLocalExecutorConfig,
14 resolveConfigRelativePath,14 resolveConfigRelativePath,
15 writeProjectLocalExecutorConfig,15 writeProjectLocalExecutorConfig,
16} from "./local-config";16} from "./config";
17import {17import {
18 getOrProvisionLocalInstallation,18 getOrProvisionLocalInstallation,
19 loadLocalInstallation,19 loadLocalInstallation,
20} from "./local-installation";20} from "./installation";
21import type {21import type {
22 LocalSourceArtifact,22 LocalSourceArtifact,
23} from "./local-source-artifacts";23} from "./source-artifacts";
24import {24import {
25 buildLocalSourceArtifact,25 buildLocalSourceArtifact,
26 readLocalSourceArtifact,26 readLocalSourceArtifact,
27 removeLocalSourceArtifact,27 removeLocalSourceArtifact,
28 writeLocalSourceArtifact,28 writeLocalSourceArtifact,
29} from "./local-source-artifacts";29} from "./source-artifacts";
30import type { LocalWorkspaceState } from "./local-workspace-state";30import type { LocalWorkspaceState } from "./workspace-state";
31import {31import {
32 loadLocalWorkspaceState,32 loadLocalWorkspaceState,
33 writeLocalWorkspaceState,33 writeLocalWorkspaceState,
34} from "./local-workspace-state";34} from "./workspace-state";
35import type { SourceCatalogSyncResult } from "../sources/catalog-sync-result";35import type { SourceCatalogSyncResult } from "../sources/catalog-sync-result";
36import type { Source } from "#schema";36import type { Source } from "#schema";
37 37
packages/platform/control-plane/src/runtime/local/tools.tsrenamed from packages/platform/control-plane/src/runtime/local/local-tools.ts+2−2
@@ -21,7 +21,7 @@ import * as Effect from "effect/Effect"; · 20 unmodified lines
21import * as Layer from "effect/Layer";21import * as Layer from "effect/Layer";
22import * as ts from "typescript";22import * as ts from "typescript";
23 23
24import type { ResolvedLocalWorkspaceContext } from "./local-config";24import type { ResolvedLocalWorkspaceContext } from "./config";
25import {25import {
26 LocalFileSystemError,26 LocalFileSystemError,
27 LocalToolDefinitionError,27 LocalToolDefinitionError,
@@ -29,7 +29,7 @@ import { · 1 unmodified line
29 LocalToolPathConflictError,29 LocalToolPathConflictError,
30 LocalToolTranspileError,30 LocalToolTranspileError,
31 unknownLocalErrorDetails,31 unknownLocalErrorDetails,
32} from "./local-errors";32} from "./errors";
33 33
34const SUPPORTED_LOCAL_TOOL_EXTENSIONS = new Set([".ts", ".js", ".mjs"]);34const SUPPORTED_LOCAL_TOOL_EXTENSIONS = new Set([".ts", ".js", ".mjs"]);
35const LOCAL_TOOLS_DIRECTORY = "tools";35const LOCAL_TOOLS_DIRECTORY = "tools";
packages/platform/control-plane/src/runtime/local/workspace-state.tsrenamed from packages/platform/control-plane/src/runtime/local/local-workspace-state.ts+2−2
@@ -9,12 +9,12 @@ import { · 8 unmodified lines
9import * as Effect from "effect/Effect";9import * as Effect from "effect/Effect";
10import * as Schema from "effect/Schema";10import * as Schema from "effect/Schema";
11 11
12import type { ResolvedLocalWorkspaceContext } from "./local-config";12import type { ResolvedLocalWorkspaceContext } from "./config";
13import {13import {
14 LocalFileSystemError,14 LocalFileSystemError,
15 LocalWorkspaceStateDecodeError,15 LocalWorkspaceStateDecodeError,
16 unknownLocalErrorDetails,16 unknownLocalErrorDetails,
17} from "./local-errors";17} from "./errors";
18 18
19const WORKSPACE_STATE_BASENAME = "workspace-state.json";19const WORKSPACE_STATE_BASENAME = "workspace-state.json";
20 20
packages/platform/control-plane/src/runtime/local/workspace-sync.tsrenamed from packages/platform/control-plane/src/runtime/local/local-workspace-sync.ts+2−2
@@ -4,12 +4,12 @@ import * as Effect from "effect/Effect"; · 3 unmodified lines
4import {4import {
5 type LoadedLocalExecutorConfig,5 type LoadedLocalExecutorConfig,
6 type ResolvedLocalWorkspaceContext,6 type ResolvedLocalWorkspaceContext,
7} from "./local-config";7} from "./config";
8import {8import {
9 loadLocalWorkspaceState,9 loadLocalWorkspaceState,
10 writeLocalWorkspaceState,10 writeLocalWorkspaceState,
11 type LocalWorkspaceState,11 type LocalWorkspaceState,
12} from "./local-workspace-state";12} from "./workspace-state";
13 13
14const trimOrNull = (value: string | null | undefined): string | null => {14const trimOrNull = (value: string | null | undefined): string | null => {
15 if (value == null) {15 if (value == null) {
packages/platform/control-plane/src/runtime/policy/policies-operations.ts+6−6
@@ -15,23 +15,23 @@ import * as Effect from "effect/Effect"; · 14 unmodified lines
15 15
16import {16import {
17 requireRuntimeLocalWorkspace,17 requireRuntimeLocalWorkspace,
18} from "../local/local-runtime-context";18} from "../local/runtime-context";
19import type {19import type {
20 WorkspaceStorageServices,20 WorkspaceStorageServices,
21 WorkspaceConfigStoreShape,21 WorkspaceConfigStoreShape,
22 WorkspaceStateStoreShape,22 WorkspaceStateStoreShape,
23} from "../local/local-storage";23} from "../local/storage";
24import {24import {
25 WorkspaceConfigStore,25 WorkspaceConfigStore,
26 WorkspaceStateStore,26 WorkspaceStateStore,
27} from "../local/local-storage";27} from "../local/storage";
28import type { ResolvedLocalWorkspaceContext } from "../local/local-config";28import type { ResolvedLocalWorkspaceContext } from "../local/config";
29import {29import {
30 type LocalWorkspaceState,30 type LocalWorkspaceState,
31} from "../local/local-workspace-state";31} from "../local/workspace-state";
32import {32import {
33 derivePolicyConfigKey,33 derivePolicyConfigKey,
34} from "../local/local-workspace-sync";34} from "../local/workspace-sync";
35import {35import {
36 type OperationErrors,36 type OperationErrors,
37 operationErrors,37 operationErrors,
packages/platform/control-plane/src/runtime/sources/executor-tools.ts+3−3
@@ -19,7 +19,7 @@ import * as Effect from "effect/Effect"; · 18 unmodified lines
19import * as Cause from "effect/Cause";19import * as Cause from "effect/Cause";
20import * as Exit from "effect/Exit";20import * as Exit from "effect/Exit";
21import * as Schema from "effect/Schema";21import * as Schema from "effect/Schema";
22import type { RuntimeLocalWorkspaceState } from "../local/local-runtime-context";22import type { RuntimeLocalWorkspaceState } from "../local/runtime-context";
23import {23import {
24 type LocalStorageServices,24 type LocalStorageServices,
25 LocalInstallationStore,25 LocalInstallationStore,
@@ -27,8 +27,8 @@ import { · 1 unmodified line
27 LocalWorkspaceConfigStore,27 LocalWorkspaceConfigStore,
28 LocalWorkspaceStateStore,28 LocalWorkspaceStateStore,
29 makeLocalStorageLayer,29 makeLocalStorageLayer,
30} from "../local/local-storage";30} from "../local/storage";
31import { provideOptionalRuntimeLocalWorkspace } from "../local/local-runtime-context";31import { provideOptionalRuntimeLocalWorkspace } from "../local/runtime-context";
32 32
33/** Run an Effect as a Promise, preserving the original error (not FiberFailure). */33/** Run an Effect as a Promise, preserving the original error (not FiberFailure). */
34const runEffect = async <A>(34const runEffect = async <A>(
packages/platform/control-plane/src/runtime/sources/source-adapter-fixture-matrix.test.ts+1−1
@@ -46,7 +46,7 @@ import { · 45 unmodified lines
46import {46import {
47 expandCatalogToolByPath,47 expandCatalogToolByPath,
48 type LoadedSourceCatalog,48 type LoadedSourceCatalog,
49} from "../catalog/source-catalog-runtime";49} from "../catalog/source/runtime";
50import { invokeIrTool } from "../execution/ir-execution";50import { invokeIrTool } from "../execution/ir-execution";
51import {51import {
52 createGoogleDiscoveryCatalogSnapshot,52 createGoogleDiscoveryCatalogSnapshot,
packages/platform/control-plane/src/runtime/sources/source-adapters/mcp.test.ts+1−1
@@ -26,7 +26,7 @@ import { invokeIrTool } from "../../execution/ir-execution"; · 25 unmodified lines
26import {26import {
27 expandCatalogToolByPath,27 expandCatalogToolByPath,
28 type LoadedSourceCatalog,28 type LoadedSourceCatalog,
29} from "../../catalog/source-catalog-runtime";29} from "../../catalog/source/runtime";
30import { snapshotFromSourceCatalogSyncResult } from "../catalog-sync-result";30import { snapshotFromSourceCatalogSyncResult } from "../catalog-sync-result";
31import { createSourceFromPayload } from "../source-definitions";31import { createSourceFromPayload } from "../source-definitions";
32import { mcpSourceAdapter } from "./mcp";32import { mcpSourceAdapter } from "./mcp";
packages/platform/control-plane/src/runtime/sources/source-auth-service.ts+4−4
@@ -45,12 +45,12 @@ import { · 44 unmodified lines
45 LiveExecutionManagerService,45 LiveExecutionManagerService,
46 sanitizePersistedElicitationResponse,46 sanitizePersistedElicitationResponse,
47 type LiveExecutionManager,47 type LiveExecutionManager,
48} from "../execution/live-execution";48} from "../execution/live";
49import {49import {
50 getRuntimeLocalWorkspaceOption,50 getRuntimeLocalWorkspaceOption,
51 provideOptionalRuntimeLocalWorkspace,51 provideOptionalRuntimeLocalWorkspace,
52 type RuntimeLocalWorkspaceState,52 type RuntimeLocalWorkspaceState,
53} from "../local/local-runtime-context";53} from "../local/runtime-context";
54import {54import {
55 exchangeMcpOAuthAuthorizationCode,55 exchangeMcpOAuthAuthorizationCode,
56 startMcpOAuthAuthorization,56 startMcpOAuthAuthorization,
@@ -86,7 +86,7 @@ import { · 29 unmodified lines
86import {86import {
87 RuntimeSourceCatalogSyncService,87 RuntimeSourceCatalogSyncService,
88 type RuntimeSourceCatalogSyncShape,88 type RuntimeSourceCatalogSyncShape,
89} from "../catalog/source-catalog-sync";89} from "../catalog/source/sync";
90import {90import {
91 buildOAuth2AuthorizationUrl,91 buildOAuth2AuthorizationUrl,
92 createPkceCodeVerifier,92 createPkceCodeVerifier,
@@ -100,7 +100,7 @@ import { · 7 unmodified lines
100 type RuntimeSourceStore,100 type RuntimeSourceStore,
101 RuntimeSourceStoreService,101 RuntimeSourceStoreService,
102} from "./source-store";102} from "./source-store";
103import type { WorkspaceStorageServices } from "../local/local-storage";103import type { WorkspaceStorageServices } from "../local/storage";
104import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";104import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";
105 105
106const trimOrNull = (value: string | null | undefined): string | null => {106const trimOrNull = (value: string | null | undefined): string | null => {
packages/platform/control-plane/src/runtime/sources/source-inspection.ts+2−2
@@ -17,7 +17,7 @@ import { · 16 unmodified lines
17import * as Effect from "effect/Effect";17import * as Effect from "effect/Effect";
18 18
19import { joinTypeNameSegments } from "../catalog/catalog-typescript";19import { joinTypeNameSegments } from "../catalog/catalog-typescript";
20import { LocalSourceArtifactMissingError } from "../local/local-errors";20import { LocalSourceArtifactMissingError } from "../local/errors";
21import { operationErrors } from "../policy/operation-errors";21import { operationErrors } from "../policy/operation-errors";
22import { formatWithPrettier } from "../catalog/prettier-format";22import { formatWithPrettier } from "../catalog/prettier-format";
23import {23import {
@@ -25,7 +25,7 @@ import { · 1 unmodified line
25 expandCatalogTools,25 expandCatalogTools,
26 loadSourceWithCatalog,26 loadSourceWithCatalog,
27 type LoadedSourceCatalogTool,27 type LoadedSourceCatalogTool,
28} from "../catalog/source-catalog-runtime";28} from "../catalog/source/runtime";
29import { RuntimeSourceStoreService } from "./source-store";29import { RuntimeSourceStoreService } from "./source-store";
30 30
31const sourceInspectOps = {31const sourceInspectOps = {
packages/platform/control-plane/src/runtime/sources/source-store.test.ts+2−2
@@ -7,9 +7,9 @@ import { · 6 unmodified lines
7 type Source,7 type Source,
8} from "#schema";8} from "#schema";
9 9
10import type { LoadedLocalExecutorConfig } from "../local/local-config";10import type { LoadedLocalExecutorConfig } from "../local/config";
11import { buildLocalSourceRecord } from "./source-store";11import { buildLocalSourceRecord } from "./source-store";
12import type { LocalWorkspaceState } from "../local/local-workspace-state";12import type { LocalWorkspaceState } from "../local/workspace-state";
13 13
14const workspaceId = WorkspaceIdSchema.make("ws_source_store");14const workspaceId = WorkspaceIdSchema.make("ws_source_store");
15const sourceId = SourceIdSchema.make("linear");15const sourceId = SourceIdSchema.make("linear");
packages/platform/control-plane/src/runtime/sources/source-store.ts+2−2
@@ -12,8 +12,8 @@ import { · 11 unmodified lines
12 type WorkspaceStorageServices,12 type WorkspaceStorageServices,
13 WorkspaceConfigStore,13 WorkspaceConfigStore,
14 WorkspaceStateStore,14 WorkspaceStateStore,
15} from "../local/local-storage";15} from "../local/storage";
16import { RuntimeLocalWorkspaceService } from "../local/local-runtime-context";16import { RuntimeLocalWorkspaceService } from "../local/runtime-context";
17import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";17import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";
18import {18import {
19 loadRuntimeSourceStoreDeps,19 loadRuntimeSourceStoreDeps,
packages/platform/control-plane/src/runtime/sources/source-store/config.ts+3−3
@@ -6,12 +6,12 @@ import type { · 5 unmodified lines
6} from "#schema";6} from "#schema";
7import { SourceIdSchema } from "#schema";7import { SourceIdSchema } from "#schema";
8 8
9import type { LoadedLocalExecutorConfig } from "../../local/local-config";9import type { LoadedLocalExecutorConfig } from "../../local/config";
10import { LocalUnsupportedSourceKindError } from "../../local/local-errors";10import { LocalUnsupportedSourceKindError } from "../../local/errors";
11import {11import {
12 fromConfigSecretProviderId,12 fromConfigSecretProviderId,
13 toConfigSecretProviderId,13 toConfigSecretProviderId,
14} from "../../local/local-config-secrets";14} from "../../local/config-secrets";
15import { slugify } from "../slug";15import { slugify } from "../slug";
16 16
17export const trimOrNull = (value: string | null | undefined): string | null => {17export const trimOrNull = (value: string | null | undefined): string | null => {
packages/platform/control-plane/src/runtime/sources/source-store/deps.ts+6−6
@@ -4,30 +4,30 @@ import * as Effect from "effect/Effect"; · 3 unmodified lines
4import type {4import type {
5 LoadedLocalExecutorConfig,5 LoadedLocalExecutorConfig,
6 ResolvedLocalWorkspaceContext,6 ResolvedLocalWorkspaceContext,
7} from "../../local/local-config";7} from "../../local/config";
8import {8import {
9 LocalExecutorConfigDecodeError,9 LocalExecutorConfigDecodeError,
10 LocalFileSystemError,10 LocalFileSystemError,
11 LocalWorkspaceStateDecodeError,11 LocalWorkspaceStateDecodeError,
12 RuntimeLocalWorkspaceMismatchError,12 RuntimeLocalWorkspaceMismatchError,
13 RuntimeLocalWorkspaceUnavailableError,13 RuntimeLocalWorkspaceUnavailableError,
14} from "../../local/local-errors";14} from "../../local/errors";
15import {15import {
16 requireRuntimeLocalWorkspace,16 requireRuntimeLocalWorkspace,
17 type RuntimeLocalWorkspaceState,17 type RuntimeLocalWorkspaceState,
18} from "../../local/local-runtime-context";18} from "../../local/runtime-context";
19import type {19import type {
20 SourceArtifactStoreShape,20 SourceArtifactStoreShape,
21 WorkspaceStorageServices,21 WorkspaceStorageServices,
22 WorkspaceConfigStoreShape,22 WorkspaceConfigStoreShape,
23 WorkspaceStateStoreShape,23 WorkspaceStateStoreShape,
24} from "../../local/local-storage";24} from "../../local/storage";
25import {25import {
26 SourceArtifactStore,26 SourceArtifactStore,
27 WorkspaceConfigStore,27 WorkspaceConfigStore,
28 WorkspaceStateStore,28 WorkspaceStateStore,
29} from "../../local/local-storage";29} from "../../local/storage";
30import type { LocalWorkspaceState } from "../../local/local-workspace-state";30import type { LocalWorkspaceState } from "../../local/workspace-state";
31import type { ControlPlaneStoreShape } from "../../store";31import type { ControlPlaneStoreShape } from "../../store";
32 32
33export type RuntimeSourceStoreDeps = {33export type RuntimeSourceStoreDeps = {
packages/platform/control-plane/src/runtime/sources/source-store/lifecycle.ts+1−1
@@ -6,7 +6,7 @@ import { · 5 unmodified lines
6 clearProviderGrantOrphanedAt,6 clearProviderGrantOrphanedAt,
7 markProviderGrantOrphanedIfUnused,7 markProviderGrantOrphanedIfUnused,
8} from "../../auth/provider-grant-lifecycle";8} from "../../auth/provider-grant-lifecycle";
9import type { LocalWorkspaceState } from "../../local/local-workspace-state";9import type { LocalWorkspaceState } from "../../local/workspace-state";
10import {10import {
11 stableSourceCatalogId,11 stableSourceCatalogId,
12 stableSourceCatalogRevisionId,12 stableSourceCatalogRevisionId,
packages/platform/control-plane/src/runtime/sources/source-store/records.ts+4−4
@@ -10,8 +10,8 @@ import * as Effect from "effect/Effect"; · 9 unmodified lines
10 10
11import { sourceAuthFromAuthArtifact } from "../../auth/auth-artifacts";11import { sourceAuthFromAuthArtifact } from "../../auth/auth-artifacts";
12import { authArtifactSecretMaterialRefs } from "../../auth/auth-artifacts";12import { authArtifactSecretMaterialRefs } from "../../auth/auth-artifacts";
13import { refreshWorkspaceSourceTypeDeclarationsInBackground } from "../../catalog/source-type-declarations";13import { refreshWorkspaceSourceTypeDeclarationsInBackground } from "../../catalog/source/type-declarations";
14import type { LoadedLocalExecutorConfig } from "../../local/local-config";14import type { LoadedLocalExecutorConfig } from "../../local/config";
15import {15import {
16 LocalConfiguredSourceNotFoundError,16 LocalConfiguredSourceNotFoundError,
17 LocalExecutorConfigDecodeError,17 LocalExecutorConfigDecodeError,
@@ -19,8 +19,8 @@ import { · 1 unmodified line
19 LocalWorkspaceStateDecodeError,19 LocalWorkspaceStateDecodeError,
20 RuntimeLocalWorkspaceMismatchError,20 RuntimeLocalWorkspaceMismatchError,
21 RuntimeLocalWorkspaceUnavailableError,21 RuntimeLocalWorkspaceUnavailableError,
22} from "../../local/local-errors";22} from "../../local/errors";
23import type { LocalWorkspaceState } from "../../local/local-workspace-state";23import type { LocalWorkspaceState } from "../../local/workspace-state";
24import { getSourceAdapter } from "../source-adapters";24import { getSourceAdapter } from "../source-adapters";
25import {25import {
26 resolveRuntimeLocalWorkspaceFromDeps,26 resolveRuntimeLocalWorkspaceFromDeps,
packages/platform/control-plane/src/runtime/sources/sources-operations.ts+1−1
@@ -25,7 +25,7 @@ import { · 24 unmodified lines
25 operationErrors,25 operationErrors,
26} from "../policy/operation-errors";26} from "../policy/operation-errors";
27import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";27import { ControlPlaneStore, type ControlPlaneStoreShape } from "../store";
28import { RuntimeSourceCatalogSyncService } from "../catalog/source-catalog-sync";28import { RuntimeSourceCatalogSyncService } from "../catalog/source/sync";
29import {29import {
30 RuntimeSourceStoreService,30 RuntimeSourceStoreService,
31} from "./source-store";31} from "./source-store";