openclaw / src /daemon /gateway-entrypoint.ts

Add files using upload-large-folder tool

d197cf3 verified about 2 months ago

2.11 kB

/** Resolves gateway dist entrypoints used by installed daemon command lines. */
import path from "node:path";
import { pathExists } from "../utils.js";

const GATEWAY_DIST_ENTRYPOINT_BASENAMES = [
  "index.js",
  "index.mjs",
  "entry.js",
  "entry.mjs",
] as const;

/** Detects built gateway dist entrypoints from service command arguments. */
export function isGatewayDistEntrypointPath(inputPath: string): boolean {
  return /[/\\]dist[/\\].+\.(cjs|js|mjs)$/.test(inputPath);
}

function buildGatewayInstallEntrypointCandidates(root?: string): string[] {
  if (!root) {
    return [];
  }
  return GATEWAY_DIST_ENTRYPOINT_BASENAMES.map((basename) => path.join(root, "dist", basename));
}

export function buildGatewayDistEntrypointCandidates(...inputs: string[]): string[] {
  const distDirs: string[] = [];
  const seenDirs = new Set<string>();

  for (const inputPath of inputs) {
    if (!isGatewayDistEntrypointPath(inputPath)) {
      continue;
    }
    const distDir = path.dirname(inputPath);
    if (seenDirs.has(distDir)) {
      continue;
    }
    seenDirs.add(distDir);
    distDirs.push(distDir);
  }

  // Prefer canonical basenames across every observed dist dir before falling
  // through, so repaired services converge on the same entrypoint order.
  const candidates: string[] = [];
  for (const basename of GATEWAY_DIST_ENTRYPOINT_BASENAMES) {
    for (const distDir of distDirs) {
      candidates.push(path.join(distDir, basename));
    }
  }
  return candidates;
}

export async function findFirstAccessibleGatewayEntrypoint(
  candidates: string[],
  exists: (candidate: string) => Promise<boolean> = pathExists,
): Promise<string | undefined> {
  for (const candidate of candidates) {
    if (await exists(candidate)) {
      return candidate;
    }
  }
  return undefined;
}

export async function resolveGatewayInstallEntrypoint(
  root: string | undefined,
  exists: (candidate: string) => Promise<boolean> = pathExists,
): Promise<string | undefined> {
  return findFirstAccessibleGatewayEntrypoint(
    buildGatewayInstallEntrypointCandidates(root),
    exists,
  );
}

	/** Resolves gateway dist entrypoints used by installed daemon command lines. */
	import path from "node:path";
	import { pathExists } from "../utils.js";

	const GATEWAY_DIST_ENTRYPOINT_BASENAMES = [
	"index.js",
	"index.mjs",
	"entry.js",
	"entry.mjs",
	] as const;

	/** Detects built gateway dist entrypoints from service command arguments. */
	export function isGatewayDistEntrypointPath(inputPath: string): boolean {
	return /[/\\]dist[/\\].+\.(cjs\|js\|mjs)$/.test(inputPath);
	}

	function buildGatewayInstallEntrypointCandidates(root?: string): string[] {
	if (!root) {
	return [];
	}
	return GATEWAY_DIST_ENTRYPOINT_BASENAMES.map((basename) => path.join(root, "dist", basename));
	}

	export function buildGatewayDistEntrypointCandidates(...inputs: string[]): string[] {
	const distDirs: string[] = [];
	const seenDirs = new Set<string>();

	for (const inputPath of inputs) {
	if (!isGatewayDistEntrypointPath(inputPath)) {
	continue;
	}
	const distDir = path.dirname(inputPath);
	if (seenDirs.has(distDir)) {
	continue;
	}
	seenDirs.add(distDir);
	distDirs.push(distDir);
	}

	// Prefer canonical basenames across every observed dist dir before falling
	// through, so repaired services converge on the same entrypoint order.
	const candidates: string[] = [];
	for (const basename of GATEWAY_DIST_ENTRYPOINT_BASENAMES) {
	for (const distDir of distDirs) {
	candidates.push(path.join(distDir, basename));
	}
	}
	return candidates;
	}

	export async function findFirstAccessibleGatewayEntrypoint(
	candidates: string[],
	exists: (candidate: string) => Promise<boolean> = pathExists,
	): Promise<string \| undefined> {
	for (const candidate of candidates) {
	if (await exists(candidate)) {
	return candidate;
	}
	}
	return undefined;
	}

	export async function resolveGatewayInstallEntrypoint(
	root: string \| undefined,
	exists: (candidate: string) => Promise<boolean> = pathExists,
	): Promise<string \| undefined> {
	return findFirstAccessibleGatewayEntrypoint(
	buildGatewayInstallEntrypointCandidates(root),
	exists,
	);
	}