fix: enrich-batch Endpoint in words-Router verschieben (war nach 404-Handler in index.js)
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
16
src/index.js
16
src/index.js
@@ -67,7 +67,7 @@ migrate()
|
|||||||
// Automatische Wort-Kategorisierung (Message Batches API): kurz nach Boot + stündlich.
|
// Automatische Wort-Kategorisierung (Message Batches API): kurz nach Boot + stündlich.
|
||||||
// Submit/Collect-Ticks, entkoppelt von generate-words und Publish.
|
// Submit/Collect-Ticks, entkoppelt von generate-words und Publish.
|
||||||
const { runCategorizationTick } = require('./lib/classifyWords');
|
const { runCategorizationTick } = require('./lib/classifyWords');
|
||||||
const { runEnrichTick, enrichWordsSync } = require('./lib/enrichWords');
|
const { runEnrichTick } = require('./lib/enrichWords');
|
||||||
const HOUR = 60 * 60 * 1000;
|
const HOUR = 60 * 60 * 1000;
|
||||||
const tick = () => runCategorizationTick().catch(err => console.error('Auto-Kategorisierung:', err.message));
|
const tick = () => runCategorizationTick().catch(err => console.error('Auto-Kategorisierung:', err.message));
|
||||||
const enrichTick = () => runEnrichTick().catch(err => console.error('Auto-Anreicherung:', err.message));
|
const enrichTick = () => runEnrichTick().catch(err => console.error('Auto-Anreicherung:', err.message));
|
||||||
@@ -75,19 +75,5 @@ migrate()
|
|||||||
setTimeout(enrichTick, 60_000);
|
setTimeout(enrichTick, 60_000);
|
||||||
setInterval(tick, HOUR);
|
setInterval(tick, HOUR);
|
||||||
setInterval(enrichTick, HOUR);
|
setInterval(enrichTick, HOUR);
|
||||||
|
|
||||||
// Manueller Trigger: POST /api/words/enrich-batch
|
|
||||||
app.post('/api/words/enrich-batch', auth, async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
const sync = req.query.sync === 'true';
|
|
||||||
if (sync) {
|
|
||||||
const max = parseInt(req.query.max) || 500;
|
|
||||||
const result = await enrichWordsSync({ max });
|
|
||||||
return res.json(result);
|
|
||||||
}
|
|
||||||
const result = await runEnrichTick();
|
|
||||||
res.json(result);
|
|
||||||
} catch (err) { next(err); }
|
|
||||||
});
|
|
||||||
})
|
})
|
||||||
.catch(err => { console.error('Migration failed:', err); process.exit(1); });
|
.catch(err => { console.error('Migration failed:', err); process.exit(1); });
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
const router = require('express').Router();
|
const router = require('express').Router();
|
||||||
const { query } = require('../db');
|
const { query } = require('../db');
|
||||||
|
const { runEnrichTick, enrichWordsSync } = require('../lib/enrichWords');
|
||||||
|
|
||||||
const STATUSES = ['requested', 'translated', 'generated', 'blocked', 'published'];
|
const STATUSES = ['requested', 'translated', 'generated', 'blocked', 'published'];
|
||||||
|
|
||||||
@@ -9,6 +10,18 @@ const STATUS_TIMESTAMP = {
|
|||||||
blocked: 'blocked_at',
|
blocked: 'blocked_at',
|
||||||
};
|
};
|
||||||
|
|
||||||
|
// POST /api/words/enrich-batch — manueller Trigger für Wort-Anreicherung
|
||||||
|
router.post('/enrich-batch', async (req, res, next) => {
|
||||||
|
try {
|
||||||
|
const sync = req.query.sync === 'true';
|
||||||
|
if (sync) {
|
||||||
|
const max = parseInt(req.query.max) || 500;
|
||||||
|
return res.json(await enrichWordsSync({ max }));
|
||||||
|
}
|
||||||
|
res.json(await runEnrichTick());
|
||||||
|
} catch (err) { next(err); }
|
||||||
|
});
|
||||||
|
|
||||||
// GET /api/words
|
// GET /api/words
|
||||||
router.get('/', async (req, res, next) => {
|
router.get('/', async (req, res, next) => {
|
||||||
try {
|
try {
|
||||||
|
|||||||
Reference in New Issue
Block a user