xixu-me
5281b33bcc
Introduced Dockerfile, .dockerignore, and GitHub Actions workflow for building and publishing Docker images. Added server.js as the Express entrypoint for standalone deployment. Updated README with Docker, Docker Compose, and Kubernetes deployment instructions.
79 lines
2.3 KiB
JavaScript
79 lines
2.3 KiB
JavaScript
import express from 'express';
|
|
import handler from './api/[...path].js';
|
|
import healthHandler from './api/health.js';
|
|
|
|
const app = express();
|
|
const PORT = process.env.PORT || 3000;
|
|
|
|
// Middleware to parse JSON bodies
|
|
app.use(express.json());
|
|
app.use(express.raw({ type: 'application/octet-stream', limit: '50mb' }));
|
|
|
|
// Health endpoint
|
|
app.get('/api/health', async (req, res) => {
|
|
try {
|
|
const request = new Request(`http://localhost:${PORT}${req.url}`, {
|
|
method: req.method,
|
|
headers: req.headers
|
|
});
|
|
const response = await healthHandler(request);
|
|
|
|
res.status(response.status);
|
|
response.headers.forEach((value, key) => {
|
|
res.set(key, value);
|
|
});
|
|
|
|
const contentType = response.headers.get('content-type');
|
|
if (contentType && contentType.includes('application/json')) {
|
|
res.json(await response.json());
|
|
} else {
|
|
res.send(await response.text());
|
|
}
|
|
} catch (error) {
|
|
console.error('Health check error:', error);
|
|
res.status(500).json({ error: 'Health check failed' });
|
|
}
|
|
});
|
|
|
|
// Main handler for all other routes
|
|
app.use('*', async (req, res) => {
|
|
try {
|
|
const request = new Request(`http://localhost:${PORT}${req.originalUrl}`, {
|
|
method: req.method,
|
|
headers: req.headers,
|
|
body: req.method !== 'GET' && req.method !== 'HEAD' ? req.body : undefined
|
|
});
|
|
|
|
const response = await handler(request);
|
|
|
|
res.status(response.status);
|
|
response.headers.forEach((value, key) => {
|
|
res.set(key, value);
|
|
});
|
|
|
|
const contentType = response.headers.get('content-type');
|
|
if (contentType && contentType.includes('application/json')) {
|
|
res.json(await response.json());
|
|
} else if (response.body) {
|
|
// Handle binary data
|
|
const arrayBuffer = await response.arrayBuffer();
|
|
const buffer = Buffer.from(arrayBuffer);
|
|
res.send(buffer);
|
|
} else {
|
|
res.send(await response.text());
|
|
}
|
|
} catch (error) {
|
|
console.error('Request handler error:', error);
|
|
res.status(500).json({
|
|
error: 'Internal server error',
|
|
message: error.message,
|
|
timestamp: new Date().toISOString()
|
|
});
|
|
}
|
|
});
|
|
|
|
app.listen(PORT, '0.0.0.0', () => {
|
|
console.log(`🚀 Xget server running on port ${PORT}`);
|
|
console.log(`📡 Health check: http://localhost:${PORT}/api/health`);
|
|
});
|