vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: use pgBossClient

Browse Source
This commit is contained in:
amhsirak
2025-11-28 15:45:30 +05:30
parent 6efd92ace9
commit 87346cba1a
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
server/src/routes/record.ts
View File

@@ -17,7 +17,7 @@ import { chromium } from 'playwright-extra';
import stealthPlugin from 'puppeteer-extra-plugin-stealth'; import stealthPlugin from 'puppeteer-extra-plugin-stealth';
import logger from "../logger"; import logger from "../logger";
import { requireSignIn } from '../middlewares/auth'; import { requireSignIn } from '../middlewares/auth';
import { pgBoss } from '../pgboss-worker'; import { pgBossClient } from '../storage/pgboss';
export const router = Router(); export const router = Router();
chromium.use(stealthPlugin()); chromium.use(stealthPlugin());
@@ -36,7 +36,7 @@ async function waitForJobCompletion(jobId: string, queueName: string, timeout =
} }
try { try {
const job = await pgBoss.getJobById(queueName, jobId); const job = await pgBossClient.getJobById(queueName, jobId);
if (!job) { if (!job) {
return reject(new Error(`Job ${jobId} not found`)); return reject(new Error(`Job ${jobId} not found`));
@@ -79,9 +79,9 @@ router.get('/start', requireSignIn, async (req: AuthenticatedRequest, res: Respo
} }
try { try {
await pgBoss.createQueue('initialize-browser-recording'); await pgBossClient.createQueue('initialize-browser-recording');
const jobId = await pgBoss.send('initialize-browser-recording', { const jobId = await pgBossClient.send('initialize-browser-recording', {
userId: req.user.id, userId: req.user.id,
timestamp: new Date().toISOString() timestamp: new Date().toISOString()
}); });
@@ -139,9 +139,9 @@ router.get('/stop/:browserId', requireSignIn, async (req: AuthenticatedRequest,
} }
try { try {
await pgBoss.createQueue('destroy-browser'); await pgBossClient.createQueue('destroy-browser');
const jobId = await pgBoss.send('destroy-browser', { const jobId = await pgBossClient.send('destroy-browser', {
browserId: req.params.browserId, browserId: req.params.browserId,
userId: req.user.id, userId: req.user.id,
timestamp: new Date().toISOString() timestamp: new Date().toISOString()
@@ -233,9 +233,9 @@ router.get('/interpret', requireSignIn, async (req: AuthenticatedRequest, res) =
} }
try { try {
await pgBoss.createQueue('interpret-workflow'); await pgBossClient.createQueue('interpret-workflow');
const jobId = await pgBoss.send('interpret-workflow', { const jobId = await pgBossClient.send('interpret-workflow', {
userId: req.user.id, userId: req.user.id,
timestamp: new Date().toISOString() timestamp: new Date().toISOString()
}); });
@@ -270,9 +270,9 @@ router.get('/interpret/stop', requireSignIn, async (req: AuthenticatedRequest, r
} }
try { try {
await pgBoss.createQueue('stop-interpretation'); await pgBossClient.createQueue('stop-interpretation');
const jobId = await pgBoss.send('stop-interpretation', { const jobId = await pgBossClient.send('stop-interpretation', {
userId: req.user.id, userId: req.user.id,
timestamp: new Date().toISOString() timestamp: new Date().toISOString()
}); });