OpenCV Abhängigkeiten für Agent besser verpacken

agents/fedeo-device-agent/src/config.ts

@@ -1,8 +1,13 @@
 import path from "node:path"
 import os from "node:os"
+import { existsSync } from "node:fs"
+import { fileURLToPath } from "node:url"
 import { AgentConfig } from "./types.js"
 import { loadDotEnv } from "./env.js"
 
+const currentFile = fileURLToPath(import.meta.url)
+const agentRoot = path.resolve(path.dirname(currentFile), "..")
+
 const optional = (value: string | undefined) => {
     const trimmed = value?.trim()
     return trimmed ? trimmed : undefined
@@ -30,6 +35,11 @@ const postprocessProfileFromEnv = (value: string | undefined): AgentConfig["post
     return "document"
 }
 
+const defaultPostprocessPython = () => {
+    const localVenvPython = path.join(agentRoot, ".venv-opencv", "bin", "python")
+    return existsSync(localVenvPython) ? localVenvPython : "python3"
+}
+
 export const loadConfig = (): AgentConfig => {
     loadDotEnv(process.env.FEDEO_AGENT_ENV || ".env")
 
@@ -52,6 +62,7 @@ export const loadConfig = (): AgentConfig => {
         scanSource: optional(process.env.FEDEO_SCAN_SOURCE),
         scanPostprocess: booleanFromEnv(process.env.FEDEO_SCAN_POSTPROCESS, false),
         postprocessProfile: postprocessProfileFromEnv(process.env.FEDEO_SCAN_POSTPROCESS_PROFILE),
-        postprocessPython: optional(process.env.FEDEO_SCAN_POSTPROCESS_PYTHON) || "python3",
+        postprocessPython: optional(process.env.FEDEO_SCAN_POSTPROCESS_PYTHON) || defaultPostprocessPython(),
+        postprocessStrict: booleanFromEnv(process.env.FEDEO_SCAN_POSTPROCESS_STRICT, false),
     }
 }

agents/fedeo-device-agent/src/scan/sane.ts

@@ -3,6 +3,7 @@ import path from "node:path"
 import { AgentConfig, ScanJob, ScanResult } from "../types.js"
 import { commandExists, runCommand } from "../commands.js"
 import { hasOpenCvPostprocessRuntime, postprocessScan } from "./postprocess.js"
+import { log } from "../logger.js"
 
 const mimeTypes = {
     pdf: "application/pdf",
@@ -51,6 +52,12 @@ const ensureFilenameExtension = (filename: string, format: AgentConfig["scanForm
     return `${filename.slice(0, -ext.length)}${expectedExt}`
 }
 
+const fallbackRawResult = (scanOutputPath: string, jobId: string): ScanResult => ({
+    path: scanOutputPath,
+    filename: `${jobId}.raw.png`,
+    mimeType: "image/png",
+})
+
 export const hasSane = () => commandExists("scanimage")
 
 export const listScanners = async () => {
@@ -111,10 +118,27 @@ export const runScan = async (config: AgentConfig, job: ScanJob): Promise<ScanRe
 
     if (shouldPostprocess) {
         if (!await hasOpenCvPostprocessRuntime(config)) {
-            throw new Error("OpenCV-Nachbearbeitung ist aktiviert, aber python3 mit cv2, Pillow und numpy ist nicht verfügbar")
+            const message = "OpenCV-Nachbearbeitung ist aktiviert, aber python3 mit cv2, Pillow und numpy ist nicht verfügbar"
+            if (config.postprocessStrict) throw new Error(message)
+
+            log.warn(`${message}. Rohscan wird ohne Korrektur hochgeladen.`, {
+                jobId: job.id,
+                python: config.postprocessPython,
+            })
+            return fallbackRawResult(scanOutputPath, job.id)
         }
 
-        return await postprocessScan(config, scanOutputPath, filename, format, postprocessProfile)
+        try {
+            return await postprocessScan(config, scanOutputPath, filename, format, postprocessProfile)
+        } catch (error) {
+            if (config.postprocessStrict) throw error
+
+            log.warn("OpenCV-Nachbearbeitung fehlgeschlagen. Rohscan wird ohne Korrektur hochgeladen.", {
+                jobId: job.id,
+                error: error instanceof Error ? error.message : String(error),
+            })
+            return fallbackRawResult(scanOutputPath, job.id)
+        }
     }
 
     return {

agents/fedeo-device-agent/src/types.ts

@@ -12,6 +12,7 @@ export type AgentConfig = {
     scanPostprocess: boolean
     postprocessProfile: "document" | "receipt" | "raw"
     postprocessPython: string
+    postprocessStrict: boolean
 }
 
 export type AgentHeartbeat = {