26 lines
789 B
TypeScript
26 lines
789 B
TypeScript
|
import { Request, Response } from "express";
|
||
|
|
import { getWebScraperQueue } from "../../src/services/queue-service";
|
||
|
|
|
||
|
|
export async function crawlJobStatusPreviewController(req: Request, res: Response) {
|
||
|
|
try {
|
||
|
|
const job = await getWebScraperQueue().getJob(req.params.jobId);
|
||
|
|
if (!job) {
|
||
|
|
return res.status(404).json({ error: "Job not found" });
|
||
|
|
}
|
||
|
|
|
||
|
|
const { current, current_url, total, current_step } = await job.progress();
|
||
|
|
res.json({
|
||
|
|
status: await job.getState(),
|
||
|
|
// progress: job.progress(),
|
||
|
|
current: current,
|
||
|
|
current_url: current_url,
|
||
|
|
current_step: current_step,
|
||
|
|
total: total,
|
||
|
|
data: job.returnvalue,
|
||
|
|
});
|
||
|
|
} catch (error) {
|
||
|
|
console.error(error);
|
||
|
|
return res.status(500).json({ error: error.message });
|
||
|
|
}
|
||
|
|
}
|