Files
router-lists-ui/backend/server.js
T
denozord d2e6aa1d38
Publish Docker image / build-and-push (push) Failing after 2m17s
Init commit
2025-07-07 13:07:26 +07:00

83 lines
2.2 KiB
JavaScript

require('dotenv').config();
const express = require('express');
const AWS = require('aws-sdk');
const cors = require('cors');
const path = require('path');
const app = express();
const port = 3001;
app.use(cors());
app.use(express.json());
// Serve static files from the React app
app.use(express.static(path.join(__dirname, 'public')));
// Configure AWS S3
const s3 = new AWS.S3({
endpoint: 'https://storage.yandexcloud.net',
region: process.env.AWS_REGION,
credentials: {
accessKeyId: process.env.AWS_ACCESS_KEY_ID,
secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY,
}
});
const BUCKET_NAME = process.env.S3_BUCKET_NAME;
const FILE_KEY = 'domains.txt';
// Get domains from S3
app.get('/api/domains', async (req, res) => {
const params = {
Bucket: BUCKET_NAME,
Key: FILE_KEY,
};
try {
const data = await s3.getObject(params).promise();
const fileContent = data.Body.toString('utf-8');
const domains = fileContent.split('\n').filter(line => line).map(line => {
const [domain, type] = line.split(' ');
return { domain, type };
});
res.json(domains);
} catch (error) {
if (error.code === 'NoSuchKey') {
res.json([]); // Return empty array if file does not exist
} else {
console.error(error);
res.status(500).send('Error reading from S3');
}
}
});
// Update domains in S3
app.post('/api/domains', async (req, res) => {
const { domains } = req.body;
const fileContent = domains.map(d => `${d.domain} ${d.type}`).join('\n');
const params = {
Bucket: BUCKET_NAME,
Key: FILE_KEY,
Body: fileContent,
ContentType: 'text/plain',
};
try {
await s3.putObject(params).promise();
res.send('File updated successfully');
} catch (error) {
console.error(error);
res.status(500).send('Error writing to S3');
}
});
// The "catchall" handler: for any request that doesn't
// match one above, send back React's index.html file.
app.get('*', (req, res) => {
res.sendFile(path.join(__dirname, 'public', 'index.html'));
});
app.listen(port, () => {
console.log(`Server is running on http://localhost:${port}`);
});