99 lines
2.6 KiB
JavaScript
99 lines
2.6 KiB
JavaScript
const express = require("express");
|
|
const AWS = require("aws-sdk");
|
|
require("aws-sdk/lib/maintenance_mode_message").suppress = true;
|
|
const fs = require("fs");
|
|
const path = require("path");
|
|
const { DateTime } = require("luxon");
|
|
|
|
const app = express();
|
|
const config = JSON.parse(fs.readFileSync("./config.json", "utf8"));
|
|
|
|
// 配置S3
|
|
AWS.config.update({
|
|
accessKeyId: config.s3.accessKeyId,
|
|
secretAccessKey: config.s3.secretAccessKey,
|
|
region: config.s3.region,
|
|
});
|
|
|
|
const s3 = new AWS.S3({ endpoint: config.s3.endpoint });
|
|
|
|
// 确保日志文件目录存在
|
|
if (!fs.existsSync("logs")) {
|
|
fs.mkdirSync("logs");
|
|
}
|
|
|
|
// 添加控制台和文件日志记录
|
|
function log(message) {
|
|
// 定义日志文件路径
|
|
const logFile = path.join(
|
|
"logs",
|
|
`${DateTime.now().toFormat("yyyy-MM-dd")}.log`
|
|
);
|
|
console.log(
|
|
`${DateTime.now().toFormat("yyyy-MM-dd HH:mm:ss")} - ${message}`
|
|
);
|
|
fs.appendFileSync(
|
|
logFile,
|
|
`${DateTime.now().toFormat("yyyy-MM-dd HH:mm:ss")} - ${message}\n`
|
|
);
|
|
}
|
|
|
|
// 处理下载文件请求
|
|
app.get("*", (req, res) => {
|
|
const config = JSON.parse(fs.readFileSync("./config.json", "utf8"));
|
|
const filePath = req.url.replace("/", "");
|
|
const downloadPath = config.routing[filePath];
|
|
|
|
if (!downloadPath) {
|
|
const statusCode = 404;
|
|
log(
|
|
"Status Code: " +
|
|
statusCode +
|
|
", Request URL: " +
|
|
req.url +
|
|
", Target URL: " +
|
|
"Request URL Not Found"
|
|
);
|
|
return res.status(statusCode).send("File not found");
|
|
}
|
|
|
|
const s3Params = {
|
|
Bucket: config.s3.bucket,
|
|
Key: downloadPath,
|
|
};
|
|
|
|
s3.getObject(s3Params, (err, data) => {
|
|
if (err) {
|
|
console.error("Failed to download file:", err);
|
|
const statusCode = 500;
|
|
log(
|
|
"Status Code: " +
|
|
statusCode +
|
|
", Request URL: " +
|
|
req.url +
|
|
", Target URL: " +
|
|
downloadPath
|
|
);
|
|
return res.status(statusCode).send("Failed to download file");
|
|
}
|
|
|
|
const statusCode = 200;
|
|
log(
|
|
"Status Code: " +
|
|
statusCode +
|
|
", Request URL: " +
|
|
req.url +
|
|
", Target URL: " +
|
|
downloadPath
|
|
);
|
|
|
|
res.attachment(downloadPath);
|
|
res.send(data.Body);
|
|
});
|
|
});
|
|
|
|
// 启动服务器
|
|
app.listen(config.port, () => {
|
|
console.log(`Server listening on port ${config.port}`);
|
|
});
|