Files
windmill/cli/test/resource_folders_unit.test.ts
Pyra 9643006f1e feat(cli): better stale scripts detection #3 (#8480)
* fix

Signed-off-by: pyranota <pyra@duck.com>

* reduce tests

Signed-off-by: pyranota <pyra@duck.com>

* update

Signed-off-by: pyranota <pyra@duck.com>

* fix

Signed-off-by: pyranota <pyra@duck.com>

* update

Signed-off-by: pyranota <pyra@duck.com>

* WIP: stash changes after merge with origin/main

* Delete backend/parsers/windmill-parser-wasm/Cargo.lock

* reset cargo.toml

* feat(cli): integrate dependency tree into generate-metadata command

- Add isDirectlyStale field to DependencyNode for staleness tracking
- Update addScript to accept itemType, folder, isRawApp, isDirectlyStale
- Update propagateStaleness to use isDirectlyStale field instead of parameter
- Handlers now determine staleness and pass it to tree.addScript
- generate-metadata calls propagateStaleness() and populates staleItems from tree
- Pass legacyBehaviour=false and tree to handlers during generation phase

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* fix(cli): store originalPath in tree for correct handler invocation

Scripts need the path with extension to be passed to the handler.
Added originalPath field to DependencyNode to track this.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

* fix parsers

Signed-off-by: pyranota <pyra@duck.com>

* rever sqlx removal

* update sqlx

* feat: make py-imports parser WASM-compatible and add as separate WASM package

Gate heavy deps (sqlx, windmill-common, async-recursion, toml, pep440_rs,
tracing) behind cfg(not(wasm32)). Make parse_code_for_imports,
parse_relative_imports, NImport, and ImportPin public. Remove duplicate
import_parser from parser-py (reset to origin/main). Add py-imports-parser
feature to windmill-parser-wasm and py-imports target to build.nu.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* safer return

* update

* fix: CLI metadata fixes - folder filter, staleness detection, WASM py-imports setup

- Fix lazy_static cfg gating for WASM compatibility (split into separate blocks)
- Fix folder argument filter to match specific file paths (not just directories)
- Fix staleness detection to use checkHash with conf (includes module hashes)
- Convert relative_imports_skip tests from Deno to bun APIs
- Add windmill-parser-wasm-py-imports to CLI and build-npm dependencies
- Relax module stale test to not require per-module change detail in output

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: restore temp_script_refs parameter in parse_python_imports

Re-adds the temp_script_refs parameter that was lost when resetting
py-imports crate to origin/main. This enables resolving relative imports
from not-yet-deployed scripts during CLI lock generation.

* fixes

* extend testsuit

* update ee repo ref

* fix: diff endpoint bytea cast, upload only mismatched scripts

- Add POST /scripts/raw_temp/diff endpoint to batch-compare local content
  hashes against deployed versions using Postgres sha256()
- Use convert_to(content, 'UTF8') instead of content::bytea to avoid
  failure on scripts containing backslash sequences (e.g. \n)
- CLI now diffs all scripts against deployed, uploads only mismatched ones
- propagateStaleness no longer deletes non-stale nodes (needed for diff)
- Suppress verbose log.info messages during metadata generation
- Add E2E tests for locally modified and unpushed helper scripts

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* rework

* sqlx

* fixes

* add index

* expand tests

* fix flows

* archive script before executing

* disable tests for ci

* skip Python-dependent E2E tests on CI

Tests requiring the python backend feature are skipped when
CI_MINIMAL_FEATURES=true since CI builds with zip-only features.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: make flow fixture lock optional and reset nonDottedPaths after tests

Flow fixtures no longer emit an empty lock file by default. The lockContent
parameter controls whether a lock: "!inline ..." line appears in flow.yaml.
This prevents flows from appearing "up-to-date" when they should be processed
by generate-metadata.

Also adds afterAll to reset setNonDottedPaths(false) so global state doesn't
leak between test files when run together.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: add error logging in withTestBackend to diagnose CI failures

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: add --bail 1 to CI test runner to show full error on first failure

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: include CLI stdout/stderr in assertion message for workspace deps test

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: set WMDEBUG_FORCE_V0_WORKSPACE_DEPENDENCIES in test backend

The workspace deps feature requires workers to report their version, but
in test/CI there are no separate workers (standalone mode). The version
check fails because workers haven't had time to ping yet. Setting this
env var bypasses the version check.

Also reverts --bail 1 from CI workflow now that the root cause is fixed.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: add --bail 1 to Windows CI and assertion messages for Windows failure diagnosis

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: replace TEMP_SCRIPT_REFS_PLACEHOLDER in bun builder tests

The loader.bun.js now includes a TEMP_SCRIPT_REFS_PLACEHOLDER that must
be replaced before execution. The builder tests were missing this
replacement, causing all 6 bun_builder_tests to fail.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: use cdirFwd in Windows loader filterLoad regex

Raw cdir (with backslashes) interpolated into RegExp causes \r to
become carriage return and \w to become word-char, so filterLoad
never matches main.ts. This prevents replaceRelativeImports from
running, leaving bare relative imports like "./script_b" in the
bundled output, which scanImports then misparses as package ".".

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: Windows filterLoad regex + graceful fallback for old backends

- Fix filterLoad in loader.bun.windows.js to match both native backslash
  and forward-slash paths from Bun's resolver by escaping cdir for regex
- Wrap uploadScripts in try/catch so generate-metadata degrades gracefully
  when the backend lacks /raw_temp endpoints (locks use deployed versions)
- Add TODO for missing TEMP_SCRIPT_REFS support in Windows loader

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: add loader/builder debug logging for Windows CI diagnosis

Temporary console.log statements to understand:
- What path Bun passes to onLoad for main.ts
- Whether filterLoad regex matches
- Whether replaceRelativeImports fires
- What the bundled output contains
- What imports scanImports extracts

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* chore: trigger CI for cli path

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* chore: trigger CI via workflow file change

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* Add TEMP_SCRIPT_REFS to Windows loader, use .ts extensions in test imports

- Add TEMP_SCRIPT_REFS_PLACEHOLDER support to loader.bun.windows.js
  (mirrors loader.bun.js) so CLI lock generation can resolve imports
  from locally-modified scripts on Windows
- Use .ts extensions in all test relative imports to work around the
  Windows filterLoad regex bug (replaceRelativeImports doesn't fire
  on Windows, so extensionless imports fail)
- Remove unused uploadSucceeded variable

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* Remove debug logging from loader_builder.bun.js

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* Remove windmill-parser-wasm-py-imports from frontend package.json

This dependency is only needed by the CLI, not the frontend.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* debug: add temp_script_refs logging for Windows CI investigation

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* ci: remove --bail 1 from Windows CLI tests

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: normalize backslashes in folder filter treePath lookup (Windows)

On Windows, item.path (originalPath) uses backslashes but tree keys
use forward slashes. The isRelevant filter's touchesFolder call
passed the unnormalized path to traverseTransitive, which couldn't
find the node. This caused cross-folder importers to be excluded
from generate-metadata when a folder argument was specified.

Also removes debug logging from previous commit.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* Update cli-tests.yml

* fix: normalize backslashes in strict-folder-boundaries warning message (Windows)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* chore: update ee-repo-ref to fe8f0d1d7448464c98474d994e6492c0a45e8e38

This commit updates the EE repository reference after PR #467 was merged in windmill-ee-private.

Previous ee-repo-ref: 03e6eaf950776c96b9581848a583af9ad735be60

New ee-repo-ref: fe8f0d1d7448464c98474d994e6492c0a45e8e38

Automated by sync-ee-ref workflow.

* revert cli-tests.yml

---------

Signed-off-by: pyranota <pyra@duck.com>
Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>
Co-authored-by: windmill-internal-app[bot] <windmill-internal-app[bot]@users.noreply.github.com>
2026-03-23 18:20:19 +00:00

626 lines
23 KiB
TypeScript

/**
* Unit tests for resource_folders.ts path detection and manipulation functions.
* Tests both dotted (.flow, .app, .raw_app) and non-dotted (__flow, __app, __raw_app) modes.
*/
import { expect, test, describe, beforeEach } from "bun:test";
import {
setNonDottedPaths,
getNonDottedPaths,
getFolderSuffixes,
getFolderSuffix,
getMetadataFileName,
getMetadataPathSuffix,
isFlowPath,
isAppPath,
isRawAppPath,
isFolderResourcePath,
isFolderResourcePathAnyFormat,
detectFolderResourceType,
isRawAppBackendPath,
isAppInlineScriptPath,
isFlowInlineScriptPath,
extractResourceName,
extractFolderPath,
buildFolderPath,
buildMetadataPath,
hasFolderSuffix,
validateFolderName,
extractNameFromFolder,
isFlowMetadataFile,
isAppMetadataFile,
isRawAppMetadataFile,
isRawAppFolderMetadataFile,
getDeleteSuffix,
transformJsonPathToDir,
isModuleEntryPoint,
getScriptBasePathFromModulePath,
} from "../src/utils/resource_folders.ts";
import { removeWorkerPrefix } from "../src/commands/worker-groups/worker-groups.ts";
// =============================================================================
// Helper: reset to dotted mode before each test
// =============================================================================
beforeEach(() => {
setNonDottedPaths(false);
});
// =============================================================================
// Configuration Functions
// =============================================================================
describe("setNonDottedPaths / getNonDottedPaths", () => {
test("defaults to false (dotted)", () => {
expect(getNonDottedPaths()).toBe(false);
});
test("can be set to true", () => {
setNonDottedPaths(true);
expect(getNonDottedPaths()).toBe(true);
});
test("can be toggled back to false", () => {
setNonDottedPaths(true);
setNonDottedPaths(false);
expect(getNonDottedPaths()).toBe(false);
});
});
describe("getFolderSuffixes", () => {
test("returns dotted suffixes by default", () => {
const suffixes = getFolderSuffixes();
expect(suffixes.flow).toBe(".flow");
expect(suffixes.app).toBe(".app");
expect(suffixes.raw_app).toBe(".raw_app");
});
test("returns non-dotted suffixes when configured", () => {
setNonDottedPaths(true);
const suffixes = getFolderSuffixes();
expect(suffixes.flow).toBe("__flow");
expect(suffixes.app).toBe("__app");
expect(suffixes.raw_app).toBe("__raw_app");
});
});
describe("getFolderSuffix", () => {
test("returns correct suffix for each type (dotted)", () => {
expect(getFolderSuffix("flow")).toBe(".flow");
expect(getFolderSuffix("app")).toBe(".app");
expect(getFolderSuffix("raw_app")).toBe(".raw_app");
});
test("returns correct suffix for each type (non-dotted)", () => {
setNonDottedPaths(true);
expect(getFolderSuffix("flow")).toBe("__flow");
expect(getFolderSuffix("app")).toBe("__app");
expect(getFolderSuffix("raw_app")).toBe("__raw_app");
});
});
// =============================================================================
// Metadata File Names
// =============================================================================
describe("getMetadataFileName", () => {
test("returns correct metadata file names", () => {
expect(getMetadataFileName("flow", "yaml")).toBe("flow.yaml");
expect(getMetadataFileName("flow", "json")).toBe("flow.json");
expect(getMetadataFileName("app", "yaml")).toBe("app.yaml");
expect(getMetadataFileName("app", "json")).toBe("app.json");
expect(getMetadataFileName("raw_app", "yaml")).toBe("raw_app.yaml");
expect(getMetadataFileName("raw_app", "json")).toBe("raw_app.json");
});
});
describe("getMetadataPathSuffix", () => {
test("returns correct path suffix (dotted)", () => {
expect(getMetadataPathSuffix("flow", "yaml")).toBe(".flow/flow.yaml");
expect(getMetadataPathSuffix("app", "json")).toBe(".app/app.json");
expect(getMetadataPathSuffix("raw_app", "yaml")).toBe(".raw_app/raw_app.yaml");
});
test("returns correct path suffix (non-dotted)", () => {
setNonDottedPaths(true);
expect(getMetadataPathSuffix("flow", "yaml")).toBe("__flow/flow.yaml");
expect(getMetadataPathSuffix("app", "json")).toBe("__app/app.json");
expect(getMetadataPathSuffix("raw_app", "yaml")).toBe("__raw_app/raw_app.yaml");
});
});
// =============================================================================
// Path Detection Functions (dotted mode)
// =============================================================================
describe("isFlowPath (dotted)", () => {
test("detects flow paths", () => {
expect(isFlowPath("f/my_flow.flow/flow.yaml")).toBe(true);
expect(isFlowPath("u/admin/test.flow/step.ts")).toBe(true);
});
test("rejects non-flow paths", () => {
expect(isFlowPath("f/my_script.ts")).toBe(false);
expect(isFlowPath("f/my_app.app/app.yaml")).toBe(false);
});
});
describe("isAppPath (dotted)", () => {
test("detects app paths", () => {
expect(isAppPath("f/my_app.app/app.yaml")).toBe(true);
expect(isAppPath("u/admin/dashboard.app/inline.ts")).toBe(true);
});
test("rejects non-app paths", () => {
expect(isAppPath("f/my_script.ts")).toBe(false);
expect(isAppPath("f/my_flow.flow/flow.yaml")).toBe(false);
});
});
describe("isRawAppPath (dotted)", () => {
test("detects raw_app paths", () => {
expect(isRawAppPath("f/my_raw.raw_app/raw_app.yaml")).toBe(true);
});
test("rejects non-raw_app paths", () => {
expect(isRawAppPath("f/my_app.app/app.yaml")).toBe(false);
expect(isRawAppPath("f/my_script.ts")).toBe(false);
});
});
// =============================================================================
// Path Detection Functions (non-dotted mode)
// =============================================================================
describe("isFlowPath (non-dotted)", () => {
test("detects non-dotted flow paths", () => {
setNonDottedPaths(true);
expect(isFlowPath("f/my_flow__flow/flow.yaml")).toBe(true);
});
test("rejects dotted flow paths in non-dotted mode", () => {
setNonDottedPaths(true);
expect(isFlowPath("f/my_flow.flow/flow.yaml")).toBe(false);
});
});
describe("isAppPath (non-dotted)", () => {
test("detects non-dotted app paths", () => {
setNonDottedPaths(true);
expect(isAppPath("f/my_app__app/app.yaml")).toBe(true);
});
});
describe("isRawAppPath (non-dotted)", () => {
test("detects non-dotted raw_app paths", () => {
setNonDottedPaths(true);
expect(isRawAppPath("f/my_raw__raw_app/raw_app.yaml")).toBe(true);
});
});
// =============================================================================
// Composite Path Detection
// =============================================================================
describe("isFolderResourcePath", () => {
test("returns true for any folder resource path", () => {
expect(isFolderResourcePath("f/x.flow/flow.yaml")).toBe(true);
expect(isFolderResourcePath("f/x.app/app.yaml")).toBe(true);
expect(isFolderResourcePath("f/x.raw_app/raw_app.yaml")).toBe(true);
});
test("returns false for non-folder paths", () => {
expect(isFolderResourcePath("f/script.ts")).toBe(false);
expect(isFolderResourcePath("f/var.variable.yaml")).toBe(false);
});
});
// This is the bug that isFolderResourcePathAnyFormat fixes:
// when nonDottedPaths is false (default), isFolderResourcePath misses non-dotted paths
// like "f/my_raw__raw_app/backend/a.ts", causing raw app backend scripts to leak
// into the standalone script list during generate-metadata.
describe("isFolderResourcePathAnyFormat", () => {
test("detects non-dotted paths even when global setting is dotted", () => {
setNonDottedPaths(false);
expect(isFolderResourcePathAnyFormat("f/my_raw__raw_app/backend/a.ts")).toBe(true);
expect(isFolderResourcePathAnyFormat("f/my_flow__flow/step.ts")).toBe(true);
expect(isFolderResourcePathAnyFormat("f/dashboard__app/inline.ts")).toBe(true);
});
test("detects dotted paths even when global setting is non-dotted", () => {
setNonDottedPaths(true);
expect(isFolderResourcePathAnyFormat("f/my_raw.raw_app/backend/a.ts")).toBe(true);
expect(isFolderResourcePathAnyFormat("f/my_flow.flow/step.ts")).toBe(true);
expect(isFolderResourcePathAnyFormat("f/dashboard.app/inline.ts")).toBe(true);
});
test("rejects non-folder-resource paths", () => {
expect(isFolderResourcePathAnyFormat("f/my_script.ts")).toBe(false);
expect(isFolderResourcePathAnyFormat("f/var.variable.yaml")).toBe(false);
});
test("confirms isFolderResourcePath fails for mismatched format (the bug)", () => {
setNonDottedPaths(false);
// isFolderResourcePath misses non-dotted paths when setting is dotted
expect(isFolderResourcePath("f/my_raw__raw_app/backend/a.ts")).toBe(false);
// isFolderResourcePathAnyFormat catches it
expect(isFolderResourcePathAnyFormat("f/my_raw__raw_app/backend/a.ts")).toBe(true);
});
});
describe("detectFolderResourceType", () => {
test("detects flow type", () => {
expect(detectFolderResourceType("f/x.flow/flow.yaml")).toBe("flow");
});
test("detects app type", () => {
expect(detectFolderResourceType("f/x.app/app.yaml")).toBe("app");
});
test("detects raw_app type", () => {
expect(detectFolderResourceType("f/x.raw_app/raw_app.yaml")).toBe("raw_app");
});
test("returns null for non-folder paths", () => {
expect(detectFolderResourceType("f/script.ts")).toBeNull();
});
});
// =============================================================================
// Inline Script / Backend Path Detection
// =============================================================================
describe("isRawAppBackendPath", () => {
test("detects raw app backend paths (dotted)", () => {
expect(isRawAppBackendPath("f/my_app.raw_app/backend/handler.ts")).toBe(true);
});
test("rejects non-backend raw app paths", () => {
expect(isRawAppBackendPath("f/my_app.raw_app/raw_app.yaml")).toBe(false);
});
test("detects raw app backend paths (non-dotted)", () => {
setNonDottedPaths(true);
expect(isRawAppBackendPath("f/my_app__raw_app/backend/handler.ts")).toBe(true);
});
});
describe("isAppInlineScriptPath", () => {
test("detects inline script paths in apps", () => {
expect(isAppInlineScriptPath("f/dashboard.app/inline_0.ts")).toBe(true);
});
test("rejects non-app paths", () => {
expect(isAppInlineScriptPath("f/script.ts")).toBe(false);
});
});
describe("isFlowInlineScriptPath", () => {
test("detects inline script paths in flows", () => {
expect(isFlowInlineScriptPath("f/pipeline.flow/step_0.ts")).toBe(true);
});
test("rejects non-flow paths", () => {
expect(isFlowInlineScriptPath("f/script.ts")).toBe(false);
});
});
// =============================================================================
// Path Manipulation Functions
// =============================================================================
describe("extractResourceName", () => {
test("extracts name from flow path", () => {
expect(extractResourceName("f/my_flow.flow/flow.yaml", "flow")).toBe("f/my_flow");
});
test("extracts name from app path", () => {
expect(extractResourceName("f/dashboard.app/app.yaml", "app")).toBe("f/dashboard");
});
test("extracts name from raw_app path", () => {
expect(extractResourceName("f/my_raw.raw_app/raw_app.yaml", "raw_app")).toBe("f/my_raw");
});
test("returns null when type doesn't match", () => {
expect(extractResourceName("f/script.ts", "flow")).toBeNull();
});
test("works in non-dotted mode", () => {
setNonDottedPaths(true);
expect(extractResourceName("f/my_flow__flow/flow.yaml", "flow")).toBe("f/my_flow");
});
});
describe("extractFolderPath", () => {
test("extracts folder path from flow", () => {
expect(extractFolderPath("f/my_flow.flow/flow.yaml", "flow")).toBe("f/my_flow.flow/");
});
test("returns null when type doesn't match", () => {
expect(extractFolderPath("f/script.ts", "flow")).toBeNull();
});
});
describe("buildFolderPath", () => {
test("builds folder path (dotted)", () => {
expect(buildFolderPath("f/my_flow", "flow")).toBe("f/my_flow.flow");
expect(buildFolderPath("f/dashboard", "app")).toBe("f/dashboard.app");
expect(buildFolderPath("f/my_raw", "raw_app")).toBe("f/my_raw.raw_app");
});
test("builds folder path (non-dotted)", () => {
setNonDottedPaths(true);
expect(buildFolderPath("f/my_flow", "flow")).toBe("f/my_flow__flow");
expect(buildFolderPath("f/dashboard", "app")).toBe("f/dashboard__app");
expect(buildFolderPath("f/my_raw", "raw_app")).toBe("f/my_raw__raw_app");
});
});
describe("buildMetadataPath", () => {
test("builds metadata path (dotted, yaml)", () => {
expect(buildMetadataPath("f/my_flow", "flow", "yaml")).toBe("f/my_flow.flow/flow.yaml");
});
test("builds metadata path (dotted, json)", () => {
expect(buildMetadataPath("f/dashboard", "app", "json")).toBe("f/dashboard.app/app.json");
});
test("builds metadata path (non-dotted)", () => {
setNonDottedPaths(true);
expect(buildMetadataPath("f/my_flow", "flow", "yaml")).toBe("f/my_flow__flow/flow.yaml");
});
});
// =============================================================================
// Folder Validation Functions
// =============================================================================
describe("hasFolderSuffix", () => {
test("returns true for matching suffix", () => {
expect(hasFolderSuffix("my_flow.flow", "flow")).toBe(true);
expect(hasFolderSuffix("dashboard.app", "app")).toBe(true);
expect(hasFolderSuffix("my_raw.raw_app", "raw_app")).toBe(true);
});
test("returns false for non-matching suffix", () => {
expect(hasFolderSuffix("my_flow.app", "flow")).toBe(false);
expect(hasFolderSuffix("script.ts", "flow")).toBe(false);
});
test("works in non-dotted mode", () => {
setNonDottedPaths(true);
expect(hasFolderSuffix("my_flow__flow", "flow")).toBe(true);
expect(hasFolderSuffix("my_flow.flow", "flow")).toBe(false);
});
});
describe("validateFolderName", () => {
test("returns null for valid folder name", () => {
expect(validateFolderName("my_flow.flow", "flow")).toBeNull();
});
test("returns error message for invalid folder name", () => {
const result = validateFolderName("my_flow.app", "flow");
expect(result).not.toBeNull();
expect(result).toContain("my_flow.app");
expect(result).toContain(".flow");
});
});
describe("extractNameFromFolder", () => {
test("extracts name by removing suffix (dotted)", () => {
expect(extractNameFromFolder("my_flow.flow", "flow")).toBe("my_flow");
expect(extractNameFromFolder("dashboard.app", "app")).toBe("dashboard");
expect(extractNameFromFolder("my_raw.raw_app", "raw_app")).toBe("my_raw");
});
test("returns original name if suffix doesn't match", () => {
expect(extractNameFromFolder("my_script", "flow")).toBe("my_script");
});
test("extracts name (non-dotted)", () => {
setNonDottedPaths(true);
expect(extractNameFromFolder("my_flow__flow", "flow")).toBe("my_flow");
});
});
// =============================================================================
// Metadata File Detection Functions
// =============================================================================
describe("isFlowMetadataFile", () => {
test("detects dotted flow metadata files", () => {
expect(isFlowMetadataFile("f/my_flow.flow.json")).toBe(true);
expect(isFlowMetadataFile("f/my_flow.flow.yaml")).toBe(true);
});
test("rejects non-flow metadata files", () => {
expect(isFlowMetadataFile("f/my_app.app.json")).toBe(false);
expect(isFlowMetadataFile("f/script.ts")).toBe(false);
});
test("detects non-dotted flow metadata files when configured", () => {
setNonDottedPaths(true);
expect(isFlowMetadataFile("f/my_flow__flow.json")).toBe(true);
expect(isFlowMetadataFile("f/my_flow__flow.yaml")).toBe(true);
// API format (dotted) is always detected
expect(isFlowMetadataFile("f/my_flow.flow.json")).toBe(true);
});
});
describe("isAppMetadataFile", () => {
test("detects dotted app metadata files", () => {
expect(isAppMetadataFile("f/dashboard.app.json")).toBe(true);
expect(isAppMetadataFile("f/dashboard.app.yaml")).toBe(true);
});
test("rejects non-app metadata files", () => {
expect(isAppMetadataFile("f/my_flow.flow.json")).toBe(false);
});
test("detects non-dotted app metadata files when configured", () => {
setNonDottedPaths(true);
expect(isAppMetadataFile("f/dashboard__app.json")).toBe(true);
// API format always detected
expect(isAppMetadataFile("f/dashboard.app.json")).toBe(true);
});
});
describe("isRawAppMetadataFile", () => {
test("detects dotted raw_app metadata files", () => {
expect(isRawAppMetadataFile("f/my_raw.raw_app.json")).toBe(true);
expect(isRawAppMetadataFile("f/my_raw.raw_app.yaml")).toBe(true);
});
test("rejects non-raw_app metadata files", () => {
expect(isRawAppMetadataFile("f/my_app.app.json")).toBe(false);
});
test("detects non-dotted raw_app metadata files when configured", () => {
setNonDottedPaths(true);
expect(isRawAppMetadataFile("f/my_raw__raw_app.json")).toBe(true);
expect(isRawAppMetadataFile("f/my_raw.raw_app.json")).toBe(true);
});
});
describe("isRawAppFolderMetadataFile", () => {
test("detects raw_app folder metadata file (dotted)", () => {
expect(isRawAppFolderMetadataFile("f/my_raw.raw_app/raw_app.yaml")).toBe(true);
expect(isRawAppFolderMetadataFile("f/my_raw.raw_app/raw_app.json")).toBe(true);
});
test("rejects non-metadata files", () => {
expect(isRawAppFolderMetadataFile("f/my_raw.raw_app/backend/handler.ts")).toBe(false);
});
});
// =============================================================================
// Sync-related Path Functions
// =============================================================================
describe("getDeleteSuffix", () => {
test("returns correct delete suffix", () => {
expect(getDeleteSuffix("flow", "yaml")).toBe(".flow/flow.yaml");
expect(getDeleteSuffix("app", "json")).toBe(".app/app.json");
expect(getDeleteSuffix("raw_app", "yaml")).toBe(".raw_app/raw_app.yaml");
});
test("returns correct delete suffix (non-dotted)", () => {
setNonDottedPaths(true);
expect(getDeleteSuffix("flow", "yaml")).toBe("__flow/flow.yaml");
});
});
describe("transformJsonPathToDir", () => {
test("transforms API dotted .flow.json to dotted dir", () => {
expect(transformJsonPathToDir("f/my_flow.flow.json", "flow")).toBe("f/my_flow.flow");
});
test("transforms API dotted .app.json to dotted dir", () => {
expect(transformJsonPathToDir("f/dashboard.app.json", "app")).toBe("f/dashboard.app");
});
test("transforms API dotted to non-dotted dir when configured", () => {
setNonDottedPaths(true);
expect(transformJsonPathToDir("f/my_flow.flow.json", "flow")).toBe("f/my_flow__flow");
});
test("handles already-configured format", () => {
setNonDottedPaths(true);
expect(transformJsonPathToDir("f/my_flow__flow.json", "flow")).toBe("f/my_flow__flow");
});
test("returns unchanged path when suffix doesn't match", () => {
expect(transformJsonPathToDir("f/script.ts", "flow")).toBe("f/script.ts");
});
});
// =============================================================================
// removeWorkerPrefix (from worker-groups.ts)
// =============================================================================
// =============================================================================
// Module Path Functions
// =============================================================================
describe("isModuleEntryPoint", () => {
test("detects entry point files in __mod folders", () => {
expect(isModuleEntryPoint("f/my_script__mod/script.ts")).toBe(true);
expect(isModuleEntryPoint("u/admin/tool__mod/script.py")).toBe(true);
expect(isModuleEntryPoint("f/nested/path/script__mod/script.go")).toBe(true);
});
test("rejects non-entry-point files in __mod folders", () => {
expect(isModuleEntryPoint("f/my_script__mod/helper.ts")).toBe(false);
expect(isModuleEntryPoint("f/my_script__mod/utils/math.py")).toBe(false);
expect(isModuleEntryPoint("f/my_script__mod/helper.lock")).toBe(false);
});
test("rejects entry point files in subdirectories of __mod", () => {
expect(isModuleEntryPoint("f/my_script__mod/sub/script.ts")).toBe(false);
});
test("rejects paths without __mod", () => {
expect(isModuleEntryPoint("f/my_script.ts")).toBe(false);
expect(isModuleEntryPoint("f/script.ts")).toBe(false);
});
test("handles windows-style separators", () => {
expect(isModuleEntryPoint("f\\my_script__mod\\script.ts")).toBe(true);
expect(isModuleEntryPoint("f\\my_script__mod\\helper.ts")).toBe(false);
});
test("matches any extension for script.*", () => {
expect(isModuleEntryPoint("f/x__mod/script.yaml")).toBe(true);
expect(isModuleEntryPoint("f/x__mod/script.json")).toBe(true);
expect(isModuleEntryPoint("f/x__mod/script.lock")).toBe(true);
expect(isModuleEntryPoint("f/x__mod/script.sh")).toBe(true);
});
});
describe("getScriptBasePathFromModulePath", () => {
test("extracts base path from module entry point", () => {
expect(getScriptBasePathFromModulePath("f/my_script__mod/script.ts")).toBe("f/my_script");
expect(getScriptBasePathFromModulePath("u/admin/tool__mod/script.py")).toBe("u/admin/tool");
});
test("extracts base path from module helper files", () => {
expect(getScriptBasePathFromModulePath("f/my_script__mod/helper.ts")).toBe("f/my_script");
expect(getScriptBasePathFromModulePath("f/my_script__mod/utils/math.py")).toBe("f/my_script");
});
test("extracts base path from nested script paths", () => {
expect(getScriptBasePathFromModulePath("f/deeply/nested/script__mod/helper.ts")).toBe("f/deeply/nested/script");
});
test("returns undefined for non-module paths", () => {
expect(getScriptBasePathFromModulePath("f/my_script.ts")).toBeUndefined();
expect(getScriptBasePathFromModulePath("f/my_flow.flow/flow.yaml")).toBeUndefined();
});
test("handles windows-style separators", () => {
expect(getScriptBasePathFromModulePath("f\\my_script__mod\\helper.ts")).toBe("f/my_script");
});
});
describe("removeWorkerPrefix", () => {
test("removes worker__ prefix", () => {
expect(removeWorkerPrefix("worker__default")).toBe("default");
expect(removeWorkerPrefix("worker__gpu")).toBe("gpu");
});
test("returns name unchanged if no prefix", () => {
expect(removeWorkerPrefix("default")).toBe("default");
expect(removeWorkerPrefix("gpu")).toBe("gpu");
});
test("handles empty string", () => {
expect(removeWorkerPrefix("")).toBe("");
});
test("handles worker__ as the entire name", () => {
expect(removeWorkerPrefix("worker__")).toBe("");
});
});