-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
78 lines (64 loc) · 2.09 KB
/
Copy pathserver.js
File metadata and controls
78 lines (64 loc) · 2.09 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
const express = require('express');
const cors = require('cors');
const config = require('./src/config/config');
const logger = require('./src/utils/logger');
const { errorHandler } = require('./src/middleware/validation');
const scrapeRoutes = require('./src/routes/scrape');
const authRoutes = require('./src/routes/auth');
const pooledScrapingService = require('./src/services/pooledScraper');
const app = express();
// Middleware
app.use(cors());
app.use(express.json({ limit: '1mb' }));
app.use(express.urlencoded({ extended: true }));
// Health check endpoint
app.get('/health', (req, res) => {
res.json({
status: 'OK',
timestamp: new Date().toISOString(),
version: '1.0.0'
});
});
// API routes
app.use('/api', scrapeRoutes);
app.use('/api/auth', authRoutes);
// Error handling middleware
app.use(errorHandler);
// 404 handler
app.use('*', (req, res) => {
res.status(404).json({
success: false,
error: 'Endpoint not found'
});
});
// Initialize browser pool and start server
async function startServer() {
try {
logger.info('Initializing browser pool...');
await pooledScrapingService.initialize();
const server = app.listen(config.port, () => {
logger.info(`Server running on port ${config.port}`);
logger.info(`Environment: ${config.nodeEnv}`);
logger.info(`Health check: http://localhost:${config.port}/health`);
logger.info(`Browser pool: ${config.browserPool.maxBrowsers} browsers, ${config.browserPool.maxPagesPerBrowser} pages each`);
});
return server;
} catch (error) {
logger.error('Failed to start server:', error.message);
process.exit(1);
}
}
const serverPromise = startServer();
// Graceful shutdown
async function gracefulShutdown(signal) {
logger.info(`${signal} received, shutting down gracefully`);
const server = await serverPromise;
server.close(async () => {
logger.info('Server closed');
await pooledScrapingService.shutdown();
process.exit(0);
});
}
process.on('SIGTERM', () => gracefulShutdown('SIGTERM'));
process.on('SIGINT', () => gracefulShutdown('SIGINT'));
module.exports = app;