Add files using upload-large-folder tool

5cb63c1 verified about 1 month ago

2.68 kB

/**
 * Bundled channel runtime artifact resolver.
 *
 * Resolves generated contract artifacts through runtime records with local workspace fallback.
 */
import { createRequire } from "node:module";
import { fileURLToPath, pathToFileURL } from "node:url";
import { vi } from "vitest";
import { listBundledChannelPluginMetadata } from "../../../../plugins/bundled-channel-runtime.js";
import { resolvePluginRootPublicSurfacePath } from "../../../../plugins/public-surface-runtime.js";
import { resolveRelativeBundledPluginPublicModuleId } from "../../../../test-utils/bundled-plugin-public-surface.js";

const REPO_ROOT = fileURLToPath(new URL("../../../../../", import.meta.url));

/** Installs plugin-owned transport mocks before loading a public source artifact. */
export async function importBundledChannelContractSourceArtifact<T extends object>(
  pluginId: string,
  artifactBasename: string,
  mockFactories: Record<string, () => Record<string, unknown>>,
): Promise<T> {
  const moduleId = resolveRelativeBundledPluginPublicModuleId({
    fromModuleUrl: import.meta.url,
    pluginId,
    artifactBasename,
  });
  const requirePlugin = createRequire(new URL(moduleId, import.meta.url));
  // Lazy transport imports still need these mocks after this loader returns;
  // the test runner clears the mock registry between files.
  for (const [dependency, factory] of Object.entries(mockFactories)) {
    vi.doMock(requirePlugin.resolve(dependency), factory);
  }
  return (await import(moduleId)) as T;
}

function resolveBundledChannelContractArtifactUrl(pluginId: string, entryBaseName: string): string {
  const normalizedEntryBaseName = entryBaseName.replace(/\.(?:[cm]?js|ts)$/u, "");
  const metadata = listBundledChannelPluginMetadata({
    rootDir: REPO_ROOT,
    includeChannelConfigs: false,
    includeSyntheticChannelConfigs: false,
  }).find((entry) => entry.manifest.id === pluginId);
  if (!metadata) {
    throw new Error(`missing bundled channel plugin '${pluginId}'`);
  }
  const modulePath = resolvePluginRootPublicSurfacePath({
    pluginRoot: metadata.rootDir,
    pluginId,
    entrySource: metadata.source.built,
    artifactBasename: `${normalizedEntryBaseName}.js`,
  });
  if (!modulePath) {
    throw new Error(`missing ${entryBaseName} for bundled channel plugin '${pluginId}'`);
  }
  return pathToFileURL(modulePath).href;
}

/** Imports a generated bundled channel artifact through the contract boundary. */
export async function importBundledChannelContractArtifact<T extends object>(
  pluginId: string,
  entryBaseName: string,
): Promise<T> {
  return (await import(resolveBundledChannelContractArtifactUrl(pluginId, entryBaseName))) as T;
}

	/**
	* Bundled channel runtime artifact resolver.
	*
	* Resolves generated contract artifacts through runtime records with local workspace fallback.
	*/
	import { createRequire } from "node:module";
	import { fileURLToPath, pathToFileURL } from "node:url";
	import { vi } from "vitest";
	import { listBundledChannelPluginMetadata } from "../../../../plugins/bundled-channel-runtime.js";
	import { resolvePluginRootPublicSurfacePath } from "../../../../plugins/public-surface-runtime.js";
	import { resolveRelativeBundledPluginPublicModuleId } from "../../../../test-utils/bundled-plugin-public-surface.js";

	const REPO_ROOT = fileURLToPath(new URL("../../../../../", import.meta.url));

	/** Installs plugin-owned transport mocks before loading a public source artifact. */
	export async function importBundledChannelContractSourceArtifact<T extends object>(
	pluginId: string,
	artifactBasename: string,
	mockFactories: Record<string, () => Record<string, unknown>>,
	): Promise<T> {
	const moduleId = resolveRelativeBundledPluginPublicModuleId({
	fromModuleUrl: import.meta.url,
	pluginId,
	artifactBasename,
	});
	const requirePlugin = createRequire(new URL(moduleId, import.meta.url));
	// Lazy transport imports still need these mocks after this loader returns;
	// the test runner clears the mock registry between files.
	for (const [dependency, factory] of Object.entries(mockFactories)) {
	vi.doMock(requirePlugin.resolve(dependency), factory);
	}
	return (await import(moduleId)) as T;
	}

	function resolveBundledChannelContractArtifactUrl(pluginId: string, entryBaseName: string): string {
	const normalizedEntryBaseName = entryBaseName.replace(/\.(?:[cm]?js\|ts)$/u, "");
	const metadata = listBundledChannelPluginMetadata({
	rootDir: REPO_ROOT,
	includeChannelConfigs: false,
	includeSyntheticChannelConfigs: false,
	}).find((entry) => entry.manifest.id === pluginId);
	if (!metadata) {
	throw new Error(`missing bundled channel plugin '${pluginId}'`);
	}
	const modulePath = resolvePluginRootPublicSurfacePath({
	pluginRoot: metadata.rootDir,
	pluginId,
	entrySource: metadata.source.built,
	artifactBasename: `${normalizedEntryBaseName}.js`,
	});
	if (!modulePath) {
	throw new Error(`missing ${entryBaseName} for bundled channel plugin '${pluginId}'`);
	}
	return pathToFileURL(modulePath).href;
	}

	/** Imports a generated bundled channel artifact through the contract boundary. */
	export async function importBundledChannelContractArtifact<T extends object>(
	pluginId: string,
	entryBaseName: string,
	): Promise<T> {
	return (await import(resolveBundledChannelContractArtifactUrl(pluginId, entryBaseName))) as T;
	}