RH-Lieferscheine/lib/fetchSearchedFilesInBranch.js

// lib/fetchSearchedFilesInBranch.js
import smbClient from "@/lib/smbClient";
import PDFParser from "pdf2json";

function decodePDFText(texts) {
	return texts
		.map((text) => text.R.map((item) => decodeURIComponent(item.T)).join(""))
		.join(" ");
}

async function searchPDFsInDirectory(directoryPath, searchTerm) {
	return new Promise((resolve) => {
		smbClient.readdir(directoryPath, async (err, files) => {
			if (err) {
				console.error("Fehler beim Lesen des Verzeichnisses:", err);
				resolve([]);
				return;
			}

			let foundInFiles = [];
			console.log(`Durchsuche Verzeichnis: ${directoryPath}`);
			console.log(`Gefundene Dateien und Ordner:`, files);

			for (const file of files) {
				if (typeof file === "string") {
					const filePath = `${directoryPath}\\${file}`;

					if (file.toLowerCase().endsWith(".pdf")) {
						console.log(`Überprüfe PDF-Datei: ${filePath}`);
						const found = await searchInPDF(filePath, searchTerm);
						if (found) {
							console.log(`Begriff "${searchTerm}" gefunden in: ${filePath}`);
							foundInFiles.push(filePath);
						} else {
							console.log(
								`Begriff "${searchTerm}" NICHT gefunden in: ${filePath}`
							);
						}
					} else {
						// Wenn es sich nicht um eine PDF handelt, rekursiv durchsuchen (als Ordner annehmen)
						console.log(`Durchsuche Unterverzeichnis: ${filePath}`);
						const nestedResults = await searchPDFsInDirectory(
							filePath,
							searchTerm
						);
						foundInFiles = foundInFiles.concat(nestedResults);
					}
				}
			}
			resolve(foundInFiles);
		});
	});
}

async function searchInPDF(filePath, searchTerm) {
	return new Promise((resolve) => {
		smbClient.readFile(filePath, (err, data) => {
			if (err) {
				console.error("Fehler beim Lesen der Datei:", err);
				resolve(false);
				return;
			}

			const pdfParser = new PDFParser();
			pdfParser.on("pdfParser_dataReady", (pdfData) => {
				const textContent = pdfData.Pages.map((page) =>
					decodePDFText(page.Texts)
				).join(" ");
				const containsTerm = textContent
					.toLowerCase()
					.includes(searchTerm.toLowerCase());
				resolve(containsTerm);
			});
			pdfParser.on("pdfParser_dataError", (parseErr) => {
				console.error("Fehler beim Verarbeiten der PDF:", parseErr);
				resolve(false);
			});
			pdfParser.parseBuffer(data);
		});
	});
}

export async function fetchSearchedFilesInBranch(niederlassungId, searchTerm) {
	const directoryPath = `${niederlassungId}`;
	try {
		console.log(`Starte Suche in Niederlassung: ${niederlassungId}`);
		const resultFiles = await searchPDFsInDirectory(directoryPath, searchTerm);
		return resultFiles;
	} catch (error) {
		console.error("Fehler bei der Suche nach Dateien:", error);
		return [];
	}
}