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

chore: modify server config

Browse Source
This commit is contained in:
amhsirak
2025-11-28 16:03:53 +05:30
parent 915c8f1271
commit ac1c728e96
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server/src/server.ts
View File

@@ -22,6 +22,7 @@ import session from 'express-session';
import Run from './models/Run'; import Run from './models/Run';
import { processQueuedRuns, recoverOrphanedRuns } from './routes/storage'; import { processQueuedRuns, recoverOrphanedRuns } from './routes/storage';
import { startWorkers } from './pgboss-worker'; import { startWorkers } from './pgboss-worker';
import { stopPgBossClient, startPgBossClient } from './storage/pgboss'
const app = express(); const app = express();
app.use(cors({ app.use(cors({
@@ -37,8 +38,8 @@ const pool = new Pool({
database: process.env.DB_NAME, database: process.env.DB_NAME,
password: process.env.DB_PASSWORD, password: process.env.DB_PASSWORD,
port: process.env.DB_PORT ? parseInt(process.env.DB_PORT, 10) : undefined, port: process.env.DB_PORT ? parseInt(process.env.DB_PORT, 10) : undefined,
max: 50, max: 10,
min: 5, min: 0,
idleTimeoutMillis: 30000, idleTimeoutMillis: 30000,
connectionTimeoutMillis: 10000, connectionTimeoutMillis: 10000,
maxUses: 7500, maxUses: 7500,
@@ -152,8 +153,13 @@ if (require.main === module) {
logger.log('info', 'Cleaning up stale browser slots...'); logger.log('info', 'Cleaning up stale browser slots...');
browserPool.cleanupStaleBrowserSlots(); browserPool.cleanupStaleBrowserSlots();
// Recover orphaned runs from potential crashes
await recoverOrphanedRuns(); await recoverOrphanedRuns();
// Start pgBoss client for job submission
await startPgBossClient();
// Start pgBoss workers AFTER recovery is complete
await startWorkers(); await startWorkers();
io = new Server(server); io = new Server(server);