Floke
a347620d02
Behebt den 'require is not defined' Fehler durch Umbenennung von server.js zu server.cjs und Anpassung des Start-Skripts in package.json.
91 lines
3.5 KiB
JavaScript
91 lines
3.5 KiB
JavaScript
|
|
const express = require('express');
|
|
const { spawn } = require('child_process');
|
|
const bodyParser = require('body-parser');
|
|
const cors = require('cors');
|
|
const fs = require('fs');
|
|
const path = require('path');
|
|
|
|
const app = express();
|
|
const PORT = 3001; // Node.js Server läuft auf einem anderen Port als React (3000)
|
|
|
|
// Middleware
|
|
app.use(cors()); // Ermöglicht Cross-Origin-Requests von der React-App
|
|
app.use(bodyParser.json()); // Parst JSON-Anfragen
|
|
|
|
// API-Endpunkt für generateSearchStrategy
|
|
app.post('/api/generate-search-strategy', async (req, res) => {
|
|
const { referenceUrl, contextContent } = req.body;
|
|
|
|
if (!referenceUrl || !contextContent) {
|
|
return res.status(400).json({ error: 'Missing referenceUrl or contextContent' });
|
|
}
|
|
|
|
// Temporäre Datei für contextContent erstellen
|
|
const tempContextFilePath = path.join(__dirname, 'tmp', `context_${Date.now()}.md`);
|
|
// Sicherstellen, dass das tmp-Verzeichnis existiert
|
|
const tmpDir = path.join(__dirname, 'tmp');
|
|
if (!fs.existsSync(tmpDir)) {
|
|
fs.mkdirSync(tmpDir);
|
|
}
|
|
|
|
try {
|
|
fs.writeFileSync(tempContextFilePath, contextContent);
|
|
|
|
// Python-Skript aufrufen
|
|
// Achtung: Hier muss der korrekte Pfad zur venv und zum Python-Skript angegeben werden.
|
|
// Für den Container oder lokalen Betrieb muss dies entsprechend angepasst werden.
|
|
// Aktuell gehen wir davon aus, dass das Python-Skript im Hauptverzeichnis liegt.
|
|
const pythonProcess = spawn(
|
|
path.join(__dirname, '..', '.venv', 'bin', 'python3'), // Pfad zur venv python3
|
|
[path.join(__dirname, '..', 'market_intel_orchestrator.py'), '--mode', 'generate_strategy', '--reference_url', referenceUrl, '--context_file', tempContextFilePath]
|
|
);
|
|
|
|
let pythonOutput = '';
|
|
let pythonError = '';
|
|
|
|
pythonProcess.stdout.on('data', (data) => {
|
|
pythonOutput += data.toString();
|
|
});
|
|
|
|
pythonProcess.stderr.on('data', (data) => {
|
|
pythonError += data.toString();
|
|
});
|
|
|
|
pythonProcess.on('close', (code) => {
|
|
// Temporäre Datei löschen
|
|
fs.unlinkSync(tempContextFilePath);
|
|
|
|
if (code !== 0) {
|
|
console.error(`Python script exited with code ${code}: ${pythonError}`);
|
|
return res.status(500).json({ error: 'Python script failed', details: pythonError });
|
|
}
|
|
try {
|
|
const result = JSON.parse(pythonOutput);
|
|
res.json(result);
|
|
} catch (parseError) {
|
|
console.error('Failed to parse Python output as JSON:', parseError);
|
|
res.status(500).json({ error: 'Invalid JSON from Python script', rawOutput: pythonOutput, details: pythonError });
|
|
}
|
|
});
|
|
|
|
pythonProcess.on('error', (err) => {
|
|
console.error('Failed to start python process:', err);
|
|
// Temporäre Datei löschen, falls sie existiert
|
|
if (fs.existsSync(tempContextFilePath)) {
|
|
fs.unlinkSync(tempContextFilePath);
|
|
}
|
|
res.status(500).json({ error: 'Failed to start Python process', details: err.message });
|
|
});
|
|
|
|
} catch (writeError) {
|
|
console.error('Failed to write temporary context file:', writeError);
|
|
res.status(500).json({ error: 'Failed to write temporary file', details: writeError.message });
|
|
}
|
|
});
|
|
|
|
// Start des Servers
|
|
app.listen(PORT, () => {
|
|
console.log(`Node.js API Bridge running on http://localhost:${PORT}`);
|
|
});
|