rhl-lieferscheine/lib/search/index.js

import { ApiError } from "@/lib/api/errors";
import { createQsirchProvider } from "@/lib/search/providers/qsirch";
import { createFsProvider } from "@/lib/search/providers/fs";

/**
 * Provider selection.
 *
 * We keep provider selection in one place:
 * - SEARCH_PROVIDER=qsirch | fs
 *
 * This allows:
 * - local dev: fs fallback
 * - production: qsirch (fast, indexed)
 */

let cachedProvider = null;

function normalizeProviderName(value) {
	return String(value || "")
		.trim()
		.toLowerCase();
}

export function getSearchProvider() {
	if (cachedProvider) return cachedProvider;

	const providerName = normalizeProviderName(
		process.env.SEARCH_PROVIDER || "fs"
	);

	if (providerName === "fs") {
		cachedProvider = createFsProvider();
		return cachedProvider;
	}

	if (providerName === "qsirch") {
		cachedProvider = createQsirchProvider({
			baseUrl: process.env.QSIRCH_BASE_URL,
			account: process.env.QSIRCH_ACCOUNT,
			password: process.env.QSIRCH_PASSWORD,
			pathPrefix: process.env.QSIRCH_PATH_PREFIX || "/Niederlassungen",
			dateField: (process.env.QSIRCH_DATE_FIELD || "modified").trim(),
			mode: (process.env.QSIRCH_MODE || "sync").trim(),
		});

		return cachedProvider;
	}

	throw new ApiError({
		status: 500,
		code: "SEARCH_BACKEND_UNAVAILABLE",
		message: "Internal server error",
	});
}

/**
 * Unified search entrypoint used by route handlers.
 *
 * @param {{
 *   mode: "branch"|"multi"|"all",
 *   branches: string[]|null,
 *   q: string|null,
 *   from: string|null,
 *   to: string|null,
 *   limit: number,
 *   cursor: string|null
 * }} input
 */
export async function search(input) {
	const provider = getSearchProvider();
	return provider.search(input);
}