Compare commits
No commits in common. "main" and "v-0.9b" have entirely different histories.
142
api/v1/index.js
142
api/v1/index.js
@ -1,114 +1,58 @@
|
|||||||
const express = require("express");
|
const router = require("express").Router();
|
||||||
const router = express.Router();
|
const response = require("./response-wrapper");
|
||||||
const fs = require("fs");
|
// const config = require('../../config-handler');
|
||||||
const config = require('../../config-handler');
|
|
||||||
const database = require('../../database');
|
|
||||||
const bodyParser = require('body-parser');
|
|
||||||
|
|
||||||
// Парсинг куки
|
// Парсинг куки
|
||||||
//router.use(require('cookie-parser')());
|
//router.use(require('cookie-parser')());
|
||||||
|
|
||||||
// Парсим JSON
|
|
||||||
router.use(bodyParser.json({ type: 'application/*+json' }));
|
|
||||||
router.use(bodyParser.json({ type: 'application/json' }));
|
|
||||||
|
|
||||||
const unknownError = (err) => {
|
|
||||||
const stackId = new Date().getTime();
|
|
||||||
let errorLoggingFolder = config().error_logs_folder;
|
|
||||||
errorLoggingFolder = !["/", "\\"].includes(errorLoggingFolder.at(-1))
|
|
||||||
? errorLoggingFolder + "/"
|
|
||||||
: errorLoggingFolder;
|
|
||||||
fs.writeFileSync(
|
|
||||||
`${errorLoggingFolder}error_${stackId}.log`,
|
|
||||||
`ERROR:
|
|
||||||
Date: ${new Date()}
|
|
||||||
Name: ${err.name}
|
|
||||||
Message: ${err.message}
|
|
||||||
Stack:
|
|
||||||
${err.stack}`,
|
|
||||||
);
|
|
||||||
|
|
||||||
return {
|
|
||||||
error: "UNKNOWN_ERROR",
|
|
||||||
details: {
|
|
||||||
trace_id: stackId,
|
|
||||||
},
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
// Загрузка музыки при помощи спец. метода
|
// Загрузка музыки при помощи спец. метода
|
||||||
router.get('/music', async (req, res) => {
|
function muzicLoad(req, res) {
|
||||||
res.setHeader("Content-Type", "audio/mpeg");
|
res.setHeader("Content-Type", "audio/mpeg");
|
||||||
database.music.findAll({
|
global.database.muzic.get(
|
||||||
where: { id: !Number.isInteger(+req.query.id) ? 0 : +req.query.id }, raw: true
|
(err, data) => {
|
||||||
}).then((data) => {
|
|
||||||
data = data[0]?.data;
|
data = data[0]?.data;
|
||||||
res.send(!data ? Buffer.from([]) : data);
|
|
||||||
}).catch((err) => {
|
|
||||||
res.send(Buffer.from([]));
|
|
||||||
});
|
|
||||||
});
|
|
||||||
// middleware (Обработка ошибок типа ответа)
|
|
||||||
router.use((req, res, next) => {
|
|
||||||
const unknownResponseFormat = "UNKNOWN_RESPONSE_FORMAT";
|
|
||||||
if (!res.result) {
|
|
||||||
return res.status(400).send(unknownResponseFormat);
|
|
||||||
}
|
|
||||||
next();
|
|
||||||
|
|
||||||
/*if (!req.query.response_format) {
|
|
||||||
res.send(unknownResponseFormat);
|
|
||||||
}
|
|
||||||
else if (req.query.response_format === 'json') {
|
|
||||||
res.result = function (data, isErr = false, code = 200) {
|
|
||||||
this.status(code).json(!isErr ? {
|
|
||||||
response : data
|
|
||||||
} : {
|
|
||||||
error : data
|
|
||||||
});
|
|
||||||
};
|
|
||||||
next();
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
res.send(unknownResponseFormat);
|
|
||||||
}*/
|
|
||||||
});
|
|
||||||
|
|
||||||
// Методы
|
|
||||||
router.use(
|
|
||||||
require('./methods')
|
|
||||||
);
|
|
||||||
|
|
||||||
// Обработка ошибок
|
|
||||||
router.use(
|
|
||||||
async function (err, req, res, next) {
|
|
||||||
if (err) {
|
if (err) {
|
||||||
if (err.name === "ApiError") {
|
res.send(Buffer.from([]));
|
||||||
req.logger.log(
|
} else {
|
||||||
new Date(),
|
res.send(!data ? Buffer.from([]) : data);
|
||||||
req.ip,
|
}
|
||||||
`Ошибка API.\n${err.stack}`,
|
},
|
||||||
true
|
{ where: { id: !Number.isInteger(+req.query.id) ? 0 : +req.query.id } },
|
||||||
);
|
);
|
||||||
return res.result({
|
}
|
||||||
error : err.message,
|
|
||||||
details : err.details
|
// Подгрузка с файла
|
||||||
}, true, 400);
|
router.use("/:method_name", async (req, res, next, ...etc) => {
|
||||||
|
if (req.params.method_name === "muzic") {
|
||||||
|
muzicLoad(req, res);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
else {
|
|
||||||
req.logger.log(
|
try {
|
||||||
new Date(),
|
const methodFunct = require(`./methods/${req.params.method_name}`);
|
||||||
req.ip,
|
response(methodFunct, req, res);
|
||||||
`Критическая ошибка API\n${err.stack}`,
|
} catch (e) {
|
||||||
true
|
if (e.message.includes("Cannot find module")) {
|
||||||
|
const ApiError = require("./errorClass");
|
||||||
|
res.status(400).sendModed(
|
||||||
|
await response(
|
||||||
|
(req, res) => {
|
||||||
|
throw new ApiError("METHOD_NOT_FOUNDED");
|
||||||
|
},
|
||||||
|
req,
|
||||||
|
res,
|
||||||
|
),
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
response(
|
||||||
|
async () => {
|
||||||
|
throw e;
|
||||||
|
},
|
||||||
|
req,
|
||||||
|
res,
|
||||||
);
|
);
|
||||||
return res.result({
|
|
||||||
error : unknownError(err)
|
|
||||||
}, true, 500);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else next();
|
});
|
||||||
}
|
|
||||||
);
|
|
||||||
|
|
||||||
module.exports = router;
|
module.exports = router;
|
||||||
@ -1,75 +1,87 @@
|
|||||||
const ApiError = require("../errorClass");
|
const ApiError = require("../errorClass");
|
||||||
const config = require("../../../config-handler");
|
const config = require("../../../config-handler");
|
||||||
const database = require("../../../database");
|
|
||||||
const apiTypes = require("../typeChecker");
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
async function isAuthorExists(authorId) {
|
||||||
|
if (!authorId) return false;
|
||||||
async function checkSyntaxArgs(req, res) {
|
return (
|
||||||
if (req.body === undefined || !req.headers['content-type'].includes('json')) {
|
(
|
||||||
throw new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'create-item', no_post : false });
|
await global.database.authors
|
||||||
}
|
.promiseMode()
|
||||||
const checker = new apiTypes.TypeChecker();
|
.get({ where: { id: authorId } })
|
||||||
|
).length !== 0
|
||||||
await checker.checkRequired(req.body.type, apiTypes.ItemType, 'type');
|
);
|
||||||
await checker.checkRequired(req.body.name, apiTypes.NameType, 'name');
|
|
||||||
|
|
||||||
if (req.body.type === 'music') {
|
|
||||||
await checker.checkRequired(req.body.author_id, apiTypes.AuthorType, 'author_id');
|
|
||||||
await checker.checkAdditional(req.body.data, apiTypes.Base64FileType, 'data');
|
|
||||||
}
|
|
||||||
|
|
||||||
const result = await checker.calculate();
|
|
||||||
if (!result.success) {
|
|
||||||
throw new ApiError("UNSYNTAX_PARAMS_OR_MISSED_REQUIRED_PARAMS", result);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
router.post('/create-item', async (req, res, next) => {
|
async function checkSyntaxArgs(req, res) {
|
||||||
try {
|
return !!(
|
||||||
await checkSyntaxArgs(req, res);
|
// Проверка поля type.
|
||||||
|
["author", "muzic"].indexOf(req.json?.type) !== -1 && // Проверка поля name.
|
||||||
if (req.body.type === "author") {
|
typeof req.json.name === "string" &&
|
||||||
if (
|
req.json.name.length >= 2 &&
|
||||||
config().authors_blacklist.filter((blacklisted) => {
|
(req.json.type === "muzic"
|
||||||
return req.body.name
|
? true
|
||||||
|
: config().authors_blacklist.filter((blacklisted) => {
|
||||||
|
return req.json.name
|
||||||
.toLowerCase()
|
.toLowerCase()
|
||||||
.includes(blacklisted.toLowerCase());
|
.includes(blacklisted.toLowerCase());
|
||||||
}).length !== 0
|
}).length === 0) && // Дополнительные поля для muzic
|
||||||
) {
|
(req.json.type === "muzic"
|
||||||
throw new ApiError("AUTHOR_BLACKLISTED");
|
? !!(
|
||||||
}
|
// Для `muzic`
|
||||||
|
(
|
||||||
|
// Проверка поля author_id.
|
||||||
|
(await isAuthorExists(req.json.author_id)) && // Проверка поля data. (Передаётся либо ничего, либо строка с base64)
|
||||||
|
(req.json.data === undefined
|
||||||
|
? true
|
||||||
|
: typeof req.json.data === "string")
|
||||||
|
)
|
||||||
|
)
|
||||||
|
: true)
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
const result = await database.authors.create({
|
module.exports = async (req, res) => {
|
||||||
name: req.body.name,
|
if (req.json === undefined) {
|
||||||
|
// console.log(req.headers);
|
||||||
|
throw new ApiError("METHOD_MUST_BE_POST_JSON", {
|
||||||
|
request_method: req.method,
|
||||||
|
"content-type": !req.headers["content-type"]
|
||||||
|
? null
|
||||||
|
: req.headers["content-type"],
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (!(await checkSyntaxArgs(req, res))) {
|
||||||
|
throw new ApiError("INVALID_OR_UNSYNTAX_PARAMS", {
|
||||||
|
request_method: req.method,
|
||||||
|
params: {
|
||||||
|
type: req.json?.type === undefined ? null : req.json.type,
|
||||||
|
name: req.json?.name === undefined ? null : req.json.name,
|
||||||
|
...(req.json?.type === "muzic"
|
||||||
|
? {
|
||||||
|
author_id:
|
||||||
|
req.json?.author_id === undefined ? null : req.json?.author_id,
|
||||||
|
data: req.json?.data === undefined ? null : req.json.data,
|
||||||
|
}
|
||||||
|
: {}),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (req.json.type === "author") {
|
||||||
|
let result = await global.database.authors.promiseMode().add({
|
||||||
|
name: req.json.name,
|
||||||
time: Math.round(new Date().getTime() / 1000),
|
time: Math.round(new Date().getTime() / 1000),
|
||||||
});
|
});
|
||||||
res.result(result.dataValues.id);
|
return result.dataValues.id;
|
||||||
} else {
|
} else {
|
||||||
const result = await database.music.create({
|
let result = await global.database.muzic.promiseMode().add({
|
||||||
name: req.body.name,
|
name: req.json.name,
|
||||||
author_id: req.body.author_id,
|
author_id: req.json.author_id,
|
||||||
data:
|
data:
|
||||||
(req.body.data === undefined || req.body.data === null)
|
req.json.data === undefined
|
||||||
? undefined
|
? undefined
|
||||||
: Buffer.from(req.body.data, "base64"),
|
: Buffer.from(req.json.data, "base64"),
|
||||||
time: Math.round(new Date().getTime() / 1000),
|
time: Math.round(new Date().getTime() / 1000),
|
||||||
});
|
});
|
||||||
res.result(result.dataValues.id);
|
return result.dataValues.id;
|
||||||
}
|
}
|
||||||
}
|
};
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/create-item', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
return next(new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'create-item', no_post : true }));
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,88 +1,90 @@
|
|||||||
const ApiError = require("../errorClass");
|
const ApiError = require("../errorClass");
|
||||||
const database = require("../../../database");
|
|
||||||
const config = require("../../../config-handler");
|
|
||||||
const apiTypes = require("../typeChecker");
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
async function isAuthorExists(id) {
|
||||||
|
if (!id || !Number.isInteger(id)) return false;
|
||||||
async function checkSyntaxArgs(req, res) {
|
return (
|
||||||
if (req.body === undefined || !req.headers['content-type'].includes('json')) {
|
(await global.database.authors.promiseMode().get({ where: { id } }))
|
||||||
throw new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'edit-item', no_post : false });
|
.length !== 0
|
||||||
}
|
);
|
||||||
const checker = new apiTypes.TypeChecker();
|
|
||||||
|
|
||||||
await checker.checkRequired(req.body.type, apiTypes.ItemType, 'type');
|
|
||||||
await checker.checkAdditional(req.body.name, apiTypes.NameType, 'name');
|
|
||||||
|
|
||||||
if (req.body.type === 'music') {
|
|
||||||
await checker.checkRequired(req.body.id, apiTypes.MusicType, 'id');
|
|
||||||
|
|
||||||
await checker.checkAdditional(req.body.author_id, apiTypes.AuthorType, 'author_id');
|
|
||||||
await checker.checkAdditional(req.body.data, apiTypes.Base64FileType, 'data');
|
|
||||||
}
|
|
||||||
else if (req.body.type === 'author') {
|
|
||||||
await checker.checkRequired(req.body.id, apiTypes.AuthorType, 'id');
|
|
||||||
}
|
|
||||||
|
|
||||||
const result = await checker.calculate();
|
|
||||||
if (!result.success) {
|
|
||||||
throw new ApiError("UNSYNTAX_PARAMS_OR_MISSED_REQUIRED_PARAMS", result);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
router.post('/edit-item', async (req, res, next) => {
|
async function isMuzicExists(id) {
|
||||||
try {
|
if (!id || !Number.isInteger(id)) return false;
|
||||||
await checkSyntaxArgs(req, res);
|
let result =
|
||||||
|
(await global.database.muzic.promiseMode().get({ where: { id } }))
|
||||||
|
.length !== 0;
|
||||||
|
console.log("isMuzicExists", result);
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
if (req.body.type === "author") {
|
async function checkSyntaxArgs(req, res) {
|
||||||
if (
|
return !!(
|
||||||
config().authors_blacklist.filter((blacklisted) => {
|
// Проверка поля type
|
||||||
return req.body.name
|
["author", "muzic"].includes(req.json.type) && // Проверка поля name
|
||||||
.toLowerCase()
|
(req.json.name === undefined
|
||||||
.includes(blacklisted.toLowerCase());
|
? true
|
||||||
}).length !== 0
|
: typeof req.json.name === "string" && req.json.name.length >= 2) && // Проверка id
|
||||||
) {
|
(req.json.type === "author"
|
||||||
throw new ApiError("AUTHOR_BLACKLISTED");
|
? await isAuthorExists(req.json.id)
|
||||||
|
: await isMuzicExists(req.json.id)) && // Проверка при type=muzic
|
||||||
|
(req.json.type === "muzic"
|
||||||
|
? // Проверка поля author_id
|
||||||
|
(req.json.author_id === undefined
|
||||||
|
? true
|
||||||
|
: await isAuthorExists(req.json.author_id)) && // Проверка поля data. (Передаётся либо ничего, либо строка с base64)
|
||||||
|
((req.json.data === undefined || req.json.data === null) ? true : typeof req.json.data === "string")
|
||||||
|
: true)
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = async (req, res) => {
|
||||||
|
if (req.method !== "POST") {
|
||||||
|
throw new ApiError("METHOD_MUST_BE_POST_JSON", {
|
||||||
|
request_method: req.method,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
console.log(await checkSyntaxArgs(req, res));
|
||||||
|
if (!(await checkSyntaxArgs(req, res))) {
|
||||||
|
throw new ApiError("INVALID_OR_UNSYNTAX_PARAMS", {
|
||||||
|
request_method: req.method,
|
||||||
|
params: {
|
||||||
|
id: req.json.id === undefined ? null : req.json.id,
|
||||||
|
type: req.json.type === undefined ? null : req.json.type,
|
||||||
|
name: req.json.name === undefined ? null : req.json.name,
|
||||||
|
...(req.json.type === "muzic"
|
||||||
|
? {
|
||||||
|
author_id: req.json.author_id,
|
||||||
|
data: req.json.data,
|
||||||
|
}
|
||||||
|
: {}),
|
||||||
|
},
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
await database.authors.update(
|
if (req.json.type === "author") {
|
||||||
|
await global.database.authors.promiseMode().edit(
|
||||||
{
|
{
|
||||||
name: req.body.name,
|
name: req.json.name,
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
where: {
|
where: {
|
||||||
id: req.body.id,
|
id: req.json.id,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
} else {
|
} else {
|
||||||
await database.music.update(
|
await global.database.muzic.promiseMode().edit(
|
||||||
{
|
{
|
||||||
name: req.body.name,
|
name: req.json.name,
|
||||||
author_id: req.body.author_id,
|
author_id: req.json.author_id,
|
||||||
data: !req.body.data ? (req.body.data === null ? null : undefined) : Buffer.from(req.body.data, "base64"),
|
data: !req.json.data ? (req.json.data === null ? null : undefined) : Buffer.from(req.json.data, "base64"),
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
where: {
|
where: {
|
||||||
id: req.body.id,
|
id: req.json.id,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
res.result("ok");
|
return "ok";
|
||||||
}
|
};
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/edit-item', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
return next(new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'edit-item', no_post : true }));
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,76 +1,55 @@
|
|||||||
const { Op } = require("sequelize");
|
|
||||||
const ApiError = require("../errorClass");
|
const ApiError = require("../errorClass");
|
||||||
const database = require("../../../database");
|
|
||||||
const apiTypes = require("../typeChecker");
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
|
||||||
|
|
||||||
async function checkSyntaxArgs(req, res) {
|
async function checkSyntaxArgs(req, res) {
|
||||||
const checker = new apiTypes.TypeChecker(false);
|
return !!(
|
||||||
|
// Проверка поля offset
|
||||||
await checker.checkAdditional(req.query.id, apiTypes.AuthorType, 'id');
|
(req.query.id === undefined ? true : Number.isInteger(+req.query.offset)) && // Проверка поля offset
|
||||||
await checker.checkAdditional(req.query.offset, apiTypes.IntType, 'offset');
|
(req.query.offset === undefined
|
||||||
await checker.checkAdditional(req.query.count, apiTypes.IntType, 'count');
|
? true
|
||||||
await checker.checkAdditional(req.query.min_date, apiTypes.IntType, 'min_date');
|
: Number.isInteger(+req.query.offset)) && // Проверка поля count
|
||||||
await checker.checkAdditional(req.query.max_date, apiTypes.IntType, 'max_date');
|
(req.query.count === undefined
|
||||||
await checker.checkAdditional(req.query.q, apiTypes.StrType, 'q');
|
? true
|
||||||
|
: Number.isInteger(+req.query.count)) && // Проверка поля min_date
|
||||||
const result = await checker.calculate();
|
(req.query.min_date === undefined
|
||||||
if (!result.success) {
|
? true
|
||||||
throw new ApiError("UNSYNTAX_PARAMS_OR_MISSED_REQUIRED_PARAMS", result);
|
: Number.isInteger(+req.query.min_date)) && // Проверка поля max_date
|
||||||
}
|
(req.query.max_date === undefined
|
||||||
|
? true
|
||||||
|
: Number.isInteger(+req.query.max_date)) && // Проверка поля q. (Ключевые слова для поиска)
|
||||||
|
true // (Проверки нет, query всегда строка, необязательный параметр)
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
router.get('/get-authors', async (req, res, next) => {
|
module.exports = async (req, res) => {
|
||||||
try {
|
if (req.method !== "GET") {
|
||||||
await checkSyntaxArgs(req, res);
|
throw new ApiError("METHOD_MUST_BE_GET", {
|
||||||
|
request_method: req.method,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (!(await checkSyntaxArgs(req, res))) {
|
||||||
|
throw new ApiError("INVALID_OR_UNSYNTAX_PARAMS", {
|
||||||
|
request_method: req.method,
|
||||||
|
params: {
|
||||||
|
id: req.query?.id === undefined ? null : req.query.id,
|
||||||
|
q: req.query?.q === undefined ? null : req.query.q,
|
||||||
|
offset: req.query?.offset === undefined ? null : req.query.offset,
|
||||||
|
count: req.query?.count === undefined ? null : req.query.count,
|
||||||
|
min_date: req.query?.min_date === undefined ? null : req.query.min_date,
|
||||||
|
max_date: req.query?.max_date === undefined ? null : req.query.max_date,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
const offset = req.query.offset === undefined ? 0 : +req.query.offset;
|
const offset = req.query.offset === undefined ? 0 : +req.query.offset;
|
||||||
const countFromNull =
|
const countFromNull =
|
||||||
req.query.count === undefined ? undefined : offset + +req.query.count;
|
req.query.count === undefined ? undefined : offset + +req.query.count;
|
||||||
|
|
||||||
// Выборка по времени
|
|
||||||
const requiredTimeSearch = req.query.min_date || req.query.max_date;
|
|
||||||
const minDate = req.query.min_date === undefined ? 0 : +req.query.min_date;
|
|
||||||
const maxDate = req.query.max_date === undefined ? 9999999999 : +req.query.max_date;
|
|
||||||
|
|
||||||
let result = (
|
let result = (
|
||||||
await database.authors.findAll(
|
await global.database.authors.promiseMode().get(
|
||||||
req.query.id === undefined
|
req.query.id === undefined
|
||||||
? {
|
? {}
|
||||||
order: [
|
|
||||||
['id', 'ASC'],
|
|
||||||
['name', 'ASC'],
|
|
||||||
],
|
|
||||||
attributes: ['id', 'name', 'time'],
|
|
||||||
...(requiredTimeSearch ? ({
|
|
||||||
// Запрос на выборку по времени
|
|
||||||
where : {
|
|
||||||
time : {
|
|
||||||
[Op.gte] : minDate,
|
|
||||||
[Op.lte] : maxDate
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}) : {}),
|
|
||||||
raw : true
|
|
||||||
}
|
|
||||||
: {
|
: {
|
||||||
order: [
|
|
||||||
['id', 'ASC'],
|
|
||||||
['name', 'ASC'],
|
|
||||||
],
|
|
||||||
attributes: ['id', 'name', 'time'],
|
|
||||||
where : {
|
|
||||||
id: +req.query.id,
|
id: +req.query.id,
|
||||||
...(requiredTimeSearch ? ({
|
|
||||||
// Запрос на выборку по времени
|
|
||||||
time : {
|
|
||||||
[Op.gte] : minDate,
|
|
||||||
[Op.lte] : maxDate
|
|
||||||
}
|
|
||||||
}) : {})
|
|
||||||
},
|
|
||||||
raw : true
|
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
).map((i) => ({
|
).map((i) => ({
|
||||||
@ -78,6 +57,14 @@ router.get('/get-authors', async (req, res, next) => {
|
|||||||
name: i.name,
|
name: i.name,
|
||||||
date: i.time,
|
date: i.time,
|
||||||
}));
|
}));
|
||||||
|
// Если просят выборку по времени
|
||||||
|
if (req.query.min_date || req.query.max_date) {
|
||||||
|
const minDate = req.query.min_date === undefined ? 0 : +req.query.min_date;
|
||||||
|
const maxDate =
|
||||||
|
req.query.max_date === undefined ? 1e32 : +req.query.max_date;
|
||||||
|
|
||||||
|
result = result.filter((res) => minDate <= res.date && res.date <= maxDate);
|
||||||
|
}
|
||||||
|
|
||||||
if (req.query?.q !== undefined) {
|
if (req.query?.q !== undefined) {
|
||||||
result = result.filter((i) => {
|
result = result.filter((i) => {
|
||||||
@ -87,23 +74,8 @@ router.get('/get-authors', async (req, res, next) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
result = result.slice(offset, countFromNull);
|
result = result.slice(offset, countFromNull);
|
||||||
res.result({
|
return {
|
||||||
count: result.length,
|
count: result.length,
|
||||||
items: result,
|
items: result,
|
||||||
});
|
};
|
||||||
}
|
};
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/get-authors', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
return next(new ApiError("METHOD_MUST_BE_GET", { method : 'get-authors' }));
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,127 +0,0 @@
|
|||||||
const { Op } = require("sequelize");
|
|
||||||
const ApiError = require("../errorClass");
|
|
||||||
const database = require("../../../database");
|
|
||||||
const apiTypes = require("../typeChecker");
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
|
||||||
|
|
||||||
async function checkSyntaxArgs(req, res) {
|
|
||||||
const checker = new apiTypes.TypeChecker(false);
|
|
||||||
|
|
||||||
await checker.checkAdditional(req.query.id, apiTypes.MusicType, 'id');
|
|
||||||
await checker.checkAdditional(req.query.author, apiTypes.AuthorType, 'author');
|
|
||||||
await checker.checkAdditional(req.query.authors, apiTypes.AuthorsType, 'authors');
|
|
||||||
await checker.checkAdditional(req.query.offset, apiTypes.IntType, 'offset');
|
|
||||||
await checker.checkAdditional(req.query.count, apiTypes.IntType, 'count');
|
|
||||||
await checker.checkAdditional(req.query.min_date, apiTypes.IntType, 'min_date');
|
|
||||||
await checker.checkAdditional(req.query.max_date, apiTypes.IntType, 'max_date');
|
|
||||||
await checker.checkAdditional(req.query.q, apiTypes.StrType, 'q');
|
|
||||||
await checker.checkAdditional(req.query.searchByAuthor, apiTypes.StrType, 'searchByAuthor');
|
|
||||||
await checker.checkAdditional(req.query.searchByName, apiTypes.StrType, 'searchByName');
|
|
||||||
|
|
||||||
const result = await checker.calculate();
|
|
||||||
if (!result.success) {
|
|
||||||
throw new ApiError("UNSYNTAX_PARAMS_OR_MISSED_REQUIRED_PARAMS", result);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
router.get('/get-music', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
await checkSyntaxArgs(req, res);
|
|
||||||
|
|
||||||
// Оптимизация: флаг searchByAuthor выставится на 0, если была запрошена выборка по музыке определённого автора
|
|
||||||
// Тем самым, мы ускоряем время ответа, поскольку мы не перебираем массив searchedAuthors с целью поиска совпадений
|
|
||||||
let searchByAuthor =
|
|
||||||
req.query.author === undefined ? req.query.searchByAuthor : "0";
|
|
||||||
|
|
||||||
const offset = req.query.offset === undefined ? 0 : +req.query.offset;
|
|
||||||
const countFromNull =
|
|
||||||
req.query.count === undefined ? undefined : offset + +req.query.count;
|
|
||||||
|
|
||||||
const searchAuthors = !req.query.authors ? [] : [...req.query.authors.split(',').map(i => +i)];
|
|
||||||
if (req.query.author) searchAuthors.push(+req.query.author);
|
|
||||||
|
|
||||||
const minDate = req.query.min_date === undefined ? 0 : +req.query.min_date;
|
|
||||||
const maxDate = req.query.max_date === undefined ? 9999999999 : +req.query.max_date;
|
|
||||||
|
|
||||||
let searchedParams = [];
|
|
||||||
if (searchAuthors > 0) {
|
|
||||||
searchAuthors.forEach(author_id => {
|
|
||||||
console.log(author_id);
|
|
||||||
searchedParams.push({ [Op.and] : [
|
|
||||||
req.query.id !== undefined ? {id : +req.query.id} : undefined,
|
|
||||||
{ author_id },
|
|
||||||
{time : {
|
|
||||||
[Op.gte]: minDate,
|
|
||||||
[Op.lte]: maxDate,
|
|
||||||
}},
|
|
||||||
] });
|
|
||||||
});
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
searchedParams.push({ [Op.and] : [
|
|
||||||
req.query.id !== undefined ? {id : +req.query.id} : undefined,
|
|
||||||
{time : {
|
|
||||||
[Op.gte]: minDate,
|
|
||||||
[Op.lte]: maxDate,
|
|
||||||
}},
|
|
||||||
] });
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log('searchedParams', searchedParams);
|
|
||||||
|
|
||||||
let result = (
|
|
||||||
await database.music.findAll({
|
|
||||||
where : { [Op.or]: searchedParams },
|
|
||||||
raws : true
|
|
||||||
})
|
|
||||||
).map((i) => ({
|
|
||||||
id: i.id,
|
|
||||||
name: i.name,
|
|
||||||
author_id: i.author_id,
|
|
||||||
is_data_exists: i.data !== null && i.data.length > 0,
|
|
||||||
date: i.time,
|
|
||||||
}));
|
|
||||||
|
|
||||||
if (req.query?.q !== undefined) {
|
|
||||||
let authors = await database.authors.findAll({raws : true});
|
|
||||||
let searchedAuthors = result.map((i) => {
|
|
||||||
let author_id = i.author_id;
|
|
||||||
return authors.filter((a) => a.id === author_id)[0];
|
|
||||||
});
|
|
||||||
result = result.filter((i) => {
|
|
||||||
const search = req.query.q.toLowerCase();
|
|
||||||
return (
|
|
||||||
(req.query.searchByName !== "0" &&
|
|
||||||
i.name.toLowerCase().includes(search)) ||
|
|
||||||
!!(
|
|
||||||
searchByAuthor !== "0" &&
|
|
||||||
searchedAuthors
|
|
||||||
.filter((a) => a.id === i.author_id)[0]
|
|
||||||
?.name.toLowerCase()
|
|
||||||
.includes(search)
|
|
||||||
)
|
|
||||||
);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
result = result.slice(offset, countFromNull);
|
|
||||||
res.result({
|
|
||||||
count: result.length,
|
|
||||||
items: result,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/get-music', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
return next(new ApiError("METHOD_MUST_BE_GET", { method : 'get-music' }));
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
142
api/v1/methods/get-muzic.js
Normal file
142
api/v1/methods/get-muzic.js
Normal file
@ -0,0 +1,142 @@
|
|||||||
|
const ApiError = require("../errorClass");
|
||||||
|
|
||||||
|
async function isAuthorExists(authorId) {
|
||||||
|
if (!authorId) return false;
|
||||||
|
return (
|
||||||
|
(
|
||||||
|
await global.database.authors
|
||||||
|
.promiseMode()
|
||||||
|
.get({ where: { id: authorId } })
|
||||||
|
).length !== 0
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
async function isAuthorsExists(authorsId) {
|
||||||
|
if (!Array.isArray(authorsId)) return false;
|
||||||
|
const authors = (await global.database.authors.promiseMode().get()).map(
|
||||||
|
(i) => i.id,
|
||||||
|
);
|
||||||
|
return authorsId.map((authorId) => authors.includes(authorId));
|
||||||
|
}
|
||||||
|
|
||||||
|
async function checkSyntaxArgs(req, res) {
|
||||||
|
return !!(
|
||||||
|
// Проверка поля author.
|
||||||
|
(req.query.author === undefined
|
||||||
|
? true
|
||||||
|
: await isAuthorExists(+req.query.author)) && // Проверка поля authors.
|
||||||
|
(req.query.authors === undefined
|
||||||
|
? true
|
||||||
|
: await isAuthorsExists(req.query.authors.split(",").map((i) => +i))) && // Проверка поля offset
|
||||||
|
(req.query.offset === undefined
|
||||||
|
? true
|
||||||
|
: Number.isInteger(+req.query.offset)) && // Проверка поля count
|
||||||
|
(req.query.count === undefined
|
||||||
|
? true
|
||||||
|
: Number.isInteger(+req.query.count)) && // Проверка поля min_date
|
||||||
|
(req.query.min_date === undefined
|
||||||
|
? true
|
||||||
|
: Number.isInteger(+req.query.min_date)) && // Проверка поля max_date
|
||||||
|
(req.query.max_date === undefined
|
||||||
|
? true
|
||||||
|
: Number.isInteger(+req.query.max_date)) && // Проверка поля q. (Ключевые слова для поиска)
|
||||||
|
true && // (Проверки нет, query всегда строка, необязательный параметр) // Проверка поля searchByAuthor (Флаг для 'q'. 0 - отключить)
|
||||||
|
true && // (Проверки нет, query всегда строка, необязательный параметр) // Проверка поля searchByName (Флаг для 'q'. 0 - отключить)
|
||||||
|
true // (Проверки нет, query всегда строка, необязательный параметр)
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = async (req, res) => {
|
||||||
|
if (req.method !== "GET") {
|
||||||
|
throw new ApiError("METHOD_MUST_BE_GET", {
|
||||||
|
request_method: req.method,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (!(await checkSyntaxArgs(req, res))) {
|
||||||
|
throw new ApiError("INVALID_OR_UNSYNTAX_PARAMS", {
|
||||||
|
request_method: req.method,
|
||||||
|
params: {
|
||||||
|
author: req.query?.author === undefined ? null : req.query.author,
|
||||||
|
authors: req.query?.authors === undefined ? null : req.query.authors,
|
||||||
|
q: req.query?.q === undefined ? null : req.query.q,
|
||||||
|
offset: req.query?.offset === undefined ? null : req.query.offset,
|
||||||
|
count: req.query?.count === undefined ? null : req.query.count,
|
||||||
|
searchByAuthor:
|
||||||
|
req.query?.searchByAuthor === undefined
|
||||||
|
? null
|
||||||
|
: req.query.searchByAuthor,
|
||||||
|
searchByName:
|
||||||
|
req.query?.searchByName === undefined ? null : req.query.searchByName,
|
||||||
|
min_date: req.query?.min_date === undefined ? null : req.query.min_date,
|
||||||
|
max_date: req.query?.max_date === undefined ? null : req.query.max_date,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
// Оптимизация: флаг searchByAuthor выставится на 0, если была запрошена выборка по музыке определённого автора
|
||||||
|
// Тем самым, мы ускоряем время ответа, поскольку мы не перебираем массив searchedAuthors с целью поиска совпадений
|
||||||
|
let searchByAuthor =
|
||||||
|
req.query.author === undefined ? req.query.searchByAuthor : "0";
|
||||||
|
|
||||||
|
const offset = req.query.offset === undefined ? 0 : +req.query.offset;
|
||||||
|
const countFromNull =
|
||||||
|
req.query.count === undefined ? undefined : offset + +req.query.count;
|
||||||
|
|
||||||
|
let result = (
|
||||||
|
await global.database.muzic.promiseMode().get(
|
||||||
|
req.query?.author === undefined
|
||||||
|
? {}
|
||||||
|
: {
|
||||||
|
where: {
|
||||||
|
author_id: +req.query.author,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
)
|
||||||
|
).map((i) => ({
|
||||||
|
id: i.id,
|
||||||
|
name: i.name,
|
||||||
|
author_id: i.author_id,
|
||||||
|
is_data_exists: i.data !== null && i.data.length > 0,
|
||||||
|
date: i.time,
|
||||||
|
}));
|
||||||
|
// Если просят выборку по authors
|
||||||
|
if (req.query.authors) {
|
||||||
|
let authors = req.query.authors.split(",").map((author) => +author);
|
||||||
|
result = result.filter((res) => authors.includes(res.author_id));
|
||||||
|
}
|
||||||
|
// Если просят выборку по времени
|
||||||
|
if (req.query.min_date || req.query.max_date) {
|
||||||
|
const minDate = req.query.min_date === undefined ? 0 : +req.query.min_date;
|
||||||
|
const maxDate =
|
||||||
|
req.query.max_date === undefined ? 1e32 : +req.query.max_date;
|
||||||
|
|
||||||
|
result = result.filter((res) => minDate <= res.date && res.date <= maxDate);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (req.query?.q !== undefined) {
|
||||||
|
let authors = await global.database.authors.promiseMode().get();
|
||||||
|
let searchedAuthors = result.map((i) => {
|
||||||
|
let author_id = i.author_id;
|
||||||
|
return authors.filter((a) => a.id === author_id)[0];
|
||||||
|
});
|
||||||
|
result = result.filter((i) => {
|
||||||
|
const search = req.query.q.toLowerCase();
|
||||||
|
return (
|
||||||
|
(req.query.searchByName !== "0" &&
|
||||||
|
i.name.toLowerCase().includes(search)) ||
|
||||||
|
!!(
|
||||||
|
searchByAuthor !== "0" &&
|
||||||
|
searchedAuthors
|
||||||
|
.filter((a) => a.id === i.author_id)[0]
|
||||||
|
?.name.toLowerCase()
|
||||||
|
.includes(search)
|
||||||
|
)
|
||||||
|
);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
result = result.slice(offset, countFromNull);
|
||||||
|
return {
|
||||||
|
count: result.length,
|
||||||
|
items: result,
|
||||||
|
};
|
||||||
|
};
|
||||||
@ -1,30 +0,0 @@
|
|||||||
const router = require('express').Router();
|
|
||||||
|
|
||||||
router.use(
|
|
||||||
require('./create-item')
|
|
||||||
);
|
|
||||||
|
|
||||||
router.use(
|
|
||||||
require('./edit-item')
|
|
||||||
);
|
|
||||||
|
|
||||||
router.use(
|
|
||||||
require('./remove-item')
|
|
||||||
);
|
|
||||||
|
|
||||||
router.use(
|
|
||||||
require('./get-authors')
|
|
||||||
);
|
|
||||||
|
|
||||||
router.use(
|
|
||||||
require('./get-music')
|
|
||||||
);
|
|
||||||
|
|
||||||
router.use('*', async (req, res) => {
|
|
||||||
res.result({
|
|
||||||
error : "UNKNOWN_METHOD",
|
|
||||||
details : {}
|
|
||||||
}, true, 400);
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,68 +1,72 @@
|
|||||||
const ApiError = require("../errorClass");
|
const ApiError = require("../errorClass");
|
||||||
const database = require("../../../database");
|
const config = require("../../../config-handler");
|
||||||
const apiTypes = require("../typeChecker");
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
async function isAuthorExists(authorId) {
|
||||||
|
if (!authorId) return false;
|
||||||
async function checkSyntaxArgs(req, res) {
|
return (
|
||||||
if (req.body === undefined || !req.headers['content-type'].includes('json')) {
|
(
|
||||||
throw new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'remove-item', no_post : false });
|
await global.database.authors
|
||||||
}
|
.promiseMode()
|
||||||
const checker = new apiTypes.TypeChecker();
|
.get({ where: { id: authorId } })
|
||||||
|
).length !== 0
|
||||||
await checker.checkRequired(req.body.type, apiTypes.ItemType, 'type');
|
);
|
||||||
|
|
||||||
if (req.body.type === 'music') {
|
|
||||||
await checker.checkRequired(req.body.id, apiTypes.MusicType, 'id');
|
|
||||||
}
|
|
||||||
else if (req.body.type === 'author') {
|
|
||||||
await checker.checkRequired(req.body.id, apiTypes.AuthorType, 'id');
|
|
||||||
}
|
|
||||||
|
|
||||||
const result = await checker.calculate();
|
|
||||||
if (!result.success) {
|
|
||||||
throw new ApiError("UNSYNTAX_PARAMS_OR_MISSED_REQUIRED_PARAMS", result);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
router.post('/remove-item', async (req, res, next) => {
|
async function checkSyntaxArgs(req, res) {
|
||||||
try {
|
return !!(
|
||||||
await checkSyntaxArgs(req, res);
|
// Проверка поля type.
|
||||||
|
["author", "muzic"].indexOf(req.json?.type) !== -1 && // Проверка поля id.
|
||||||
|
(Number.isInteger(req.json.id) && req.json.type === "author"
|
||||||
|
? await isAuthorExists(req.json.id)
|
||||||
|
: true)
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
if (req.body.type === "author") {
|
module.exports = async (req, res) => {
|
||||||
|
if (req.json === undefined) {
|
||||||
|
// console.log(req.headers);
|
||||||
|
throw new ApiError("METHOD_MUST_BE_POST_JSON", {
|
||||||
|
request_method: req.method,
|
||||||
|
"content-type": !req.headers["content-type"]
|
||||||
|
? null
|
||||||
|
: req.headers["content-type"],
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (!(await checkSyntaxArgs(req, res))) {
|
||||||
|
throw new ApiError("INVALID_OR_UNSYNTAX_PARAMS", {
|
||||||
|
request_method: req.method,
|
||||||
|
params: {
|
||||||
|
type: req.json?.type === undefined ? null : req.json.type,
|
||||||
|
name: req.json?.name === undefined ? null : req.json.name,
|
||||||
|
...(req.json?.type === "muzic"
|
||||||
|
? {
|
||||||
|
author_id:
|
||||||
|
req.json?.author_id === undefined ? null : req.json?.author_id,
|
||||||
|
data: req.json?.data === undefined ? null : req.json.data,
|
||||||
|
}
|
||||||
|
: {}),
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (req.json.type === "author") {
|
||||||
// Удаляем всю музыку этого исполнителя
|
// Удаляем всю музыку этого исполнителя
|
||||||
await database.music.destroy({
|
await global.database.muzic.promiseMode().remove({
|
||||||
where: {
|
where: {
|
||||||
author_id: req.body.id,
|
author_id: req.json.id,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
// Удаляем исполнителя
|
// Удаляем исполнителя
|
||||||
await database.authors.destroy({
|
await global.database.authors.promiseMode().remove({
|
||||||
where: {
|
where: {
|
||||||
id: req.body.id,
|
id: req.json.id,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
} else {
|
} else {
|
||||||
await database.music.destroy({
|
await global.database.muzic.promiseMode().remove({
|
||||||
where: {
|
where: {
|
||||||
id: req.body.id,
|
id: req.json.id,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
res.result("ok");
|
return "ok";
|
||||||
}
|
};
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/remove-item', async (req, res, next) => {
|
|
||||||
try {
|
|
||||||
return next(new ApiError("METHOD_MUST_BE_POST_JSON", { method : 'remove-item', no_post : true }));
|
|
||||||
}
|
|
||||||
catch (err) {
|
|
||||||
return next(err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
61
api/v1/response-wrapper.js
Normal file
61
api/v1/response-wrapper.js
Normal file
@ -0,0 +1,61 @@
|
|||||||
|
const fs = require("fs");
|
||||||
|
const config = require("../../config-handler");
|
||||||
|
|
||||||
|
const unknownError = (err) => {
|
||||||
|
const stackId = new Date().getTime();
|
||||||
|
let errorLoggingFolder = config().error_logs_folder;
|
||||||
|
errorLoggingFolder = !["/", "\\"].includes(errorLoggingFolder.at(-1))
|
||||||
|
? errorLoggingFolder + "/"
|
||||||
|
: errorLoggingFolder;
|
||||||
|
fs.writeFileSync(
|
||||||
|
`${errorLoggingFolder}error_${stackId}.log`,
|
||||||
|
`ERROR:
|
||||||
|
Date: ${new Date()}
|
||||||
|
Name: ${err.name}
|
||||||
|
Message: ${err.message}
|
||||||
|
Stack:
|
||||||
|
${err.stack}`,
|
||||||
|
);
|
||||||
|
|
||||||
|
return {
|
||||||
|
error: "UNKNOWN_ERROR",
|
||||||
|
details: {
|
||||||
|
trace_id: stackId,
|
||||||
|
},
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
|
const unknownResponseFormat = "UNKNOWN_RESPONSE_FORMAT";
|
||||||
|
|
||||||
|
async function handlingError(funct, success, error) {
|
||||||
|
try {
|
||||||
|
success(await funct());
|
||||||
|
} catch (e) {
|
||||||
|
// console.log('error', e);
|
||||||
|
error(
|
||||||
|
e.name === "ApiError"
|
||||||
|
? {
|
||||||
|
error: e.message,
|
||||||
|
details: e.details,
|
||||||
|
}
|
||||||
|
: unknownError(e),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = async (method, req, res) => {
|
||||||
|
if (req.query.response_format === "json") {
|
||||||
|
handlingError(
|
||||||
|
async () => ({ response: await method(req, res) }),
|
||||||
|
async (data) => {
|
||||||
|
res.sendModed(data);
|
||||||
|
},
|
||||||
|
async (errBody) => {
|
||||||
|
res.errorModeOn();
|
||||||
|
res.status(400).sendModed(errBody);
|
||||||
|
},
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
res.status(400).sendModed(unknownResponseFormat);
|
||||||
|
}
|
||||||
|
};
|
||||||
@ -1,203 +0,0 @@
|
|||||||
const { Op } = require("sequelize");
|
|
||||||
const database = require("../../database");
|
|
||||||
|
|
||||||
// TypeChecker class
|
|
||||||
class TypeChecker {
|
|
||||||
constructor (strictMode = true) {
|
|
||||||
this.strict = strictMode;
|
|
||||||
|
|
||||||
this.requiredMissed = [];
|
|
||||||
this.additionalMissed = [];
|
|
||||||
|
|
||||||
this.requiredUnsyntax = [];
|
|
||||||
this.additionalUnsyntax = [];
|
|
||||||
|
|
||||||
this.unsyntax = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkRequired (param, Type, paramName) {
|
|
||||||
if (param === undefined) {
|
|
||||||
this.requiredMissed.push(paramName);
|
|
||||||
this.unsyntax = true;
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
const type = new Type(param);
|
|
||||||
if (this.strict && !(await type.checkStrict())) {
|
|
||||||
this.requiredUnsyntax.push(paramName);
|
|
||||||
this.unsyntax = true;
|
|
||||||
}
|
|
||||||
else if (!this.strict && !(await type.checkNoStrict())) {
|
|
||||||
this.requiredUnsyntax.push(paramName);
|
|
||||||
this.unsyntax = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkAdditional (param, Type, paramName) {
|
|
||||||
if (param === undefined) {
|
|
||||||
this.additionalMissed.push(paramName);
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
const type = new Type(param);
|
|
||||||
if (this.strict && !(await type.checkStrict())) {
|
|
||||||
this.additionalUnsyntax.push(paramName);
|
|
||||||
this.unsyntax = true;
|
|
||||||
}
|
|
||||||
else if (!this.strict && !(await type.checkNoStrict())) {
|
|
||||||
this.additionalUnsyntax.push(paramName);
|
|
||||||
this.unsyntax = true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
async calculate () {
|
|
||||||
return {
|
|
||||||
success : !this.unsyntax,
|
|
||||||
missed : {
|
|
||||||
required : this.requiredMissed,
|
|
||||||
additional : this.additionalMissed
|
|
||||||
},
|
|
||||||
unsyntax : {
|
|
||||||
required : this.requiredUnsyntax,
|
|
||||||
additional : this.additionalUnsyntax
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// Types
|
|
||||||
|
|
||||||
class ParamType {
|
|
||||||
constructor (value) {
|
|
||||||
this.value = value;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkStrict () {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
class StrType extends ParamType {
|
|
||||||
async checkStrict () {
|
|
||||||
return typeof this.value === 'string';
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
return typeof this.value === 'string';
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class IntType extends ParamType {
|
|
||||||
async checkNoStrict () {
|
|
||||||
return Number.isInteger(+this.value);
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkStrict () {
|
|
||||||
return Number.isInteger(this.value);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Custom types
|
|
||||||
|
|
||||||
class ItemType extends StrType {
|
|
||||||
async checkStrict () {
|
|
||||||
if (await super.checkStrict()) return ['music', 'author'].includes(this.value);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
if (await super.checkNoStrict()) return ['music', 'author'].includes(this.value);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class NameType extends StrType {
|
|
||||||
async checkStrict () {
|
|
||||||
if (await super.checkStrict()) return this.value.length >= 2;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
if (await super.checkNoStrict()) return this.value.length >= 2;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class AuthorType extends IntType {
|
|
||||||
async checkStrict () {
|
|
||||||
if (await super.checkStrict()) {
|
|
||||||
const authorId = this.value;
|
|
||||||
return (await database.authors.findAll({ where: { id: authorId }, raw : true })).length !== 0;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
if (await super.checkNoStrict()) {
|
|
||||||
const authorId = +this.value;
|
|
||||||
return (await database.authors.findAll({ where: { id: authorId }, raw : true })).length !== 0;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class AuthorsType extends AuthorType {
|
|
||||||
async checkStrict () {
|
|
||||||
if (Array.isArray(this.value) && !this.value.map(i => Number.isInteger(i)).includes(false)) {
|
|
||||||
// return (await database.authors.findAll({ where: [Op.or]: [
|
|
||||||
// { id: 12 },
|
|
||||||
// { id: 13 }
|
|
||||||
// ], raw : true })).length === this.value;
|
|
||||||
return (await database.authors.findAll({ where: { [Op.or]: this.value.map(id => ({ id })) }, raw : true })).length === this.value;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
if (await(new StrType(this.value)).checkStrict()) {
|
|
||||||
const values = this.value.split(',').map(i => +i);
|
|
||||||
if (!values.map(i => Number.isInteger(i)).includes(false)) {
|
|
||||||
return (await database.authors.findAll({ where: { [Op.or]: values.map(id => ({ id })) }, raw : true })).length === this.value.length;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class MusicType extends IntType {
|
|
||||||
async checkStrict () {
|
|
||||||
if (await super.checkStrict()) {
|
|
||||||
const musicId = this.value;
|
|
||||||
return (await database.music.findAll({ where: { id: musicId }, raw : true })).length !== 0;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
async checkNoStrict () {
|
|
||||||
if (await super.checkNoStrict()) {
|
|
||||||
const musicId = +this.value;
|
|
||||||
return (await database.music.findAll({ where: { id: musicId }, raw : true })).length !== 0;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
class Base64FileType extends StrType {
|
|
||||||
async checkStrict () {
|
|
||||||
return this.value === null || (await super.checkStrict());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = {
|
|
||||||
ParamType,
|
|
||||||
StrType, IntType,
|
|
||||||
ItemType, NameType, AuthorType, AuthorsType, MusicType, Base64FileType,
|
|
||||||
TypeChecker
|
|
||||||
};
|
|
||||||
@ -20,7 +20,5 @@
|
|||||||
|
|
||||||
"authors_blacklist" : [
|
"authors_blacklist" : [
|
||||||
"Монеточка", "Monetochka"
|
"Монеточка", "Monetochka"
|
||||||
],
|
]
|
||||||
|
|
||||||
"request_size_limit" : "150mb"
|
|
||||||
}
|
}
|
||||||
50
database.js
50
database.js
@ -1,7 +1,6 @@
|
|||||||
const { Sequelize, DataTypes } = require("sequelize");
|
const { Sequelize, DataTypes } = require("sequelize");
|
||||||
const config = require('./config-handler');
|
|
||||||
|
|
||||||
/*class Table {
|
class Table {
|
||||||
constructor(model) {
|
constructor(model) {
|
||||||
this.model = model;
|
this.model = model;
|
||||||
}
|
}
|
||||||
@ -59,7 +58,7 @@ class TablePromise extends Table {
|
|||||||
async edit(data, condition) {
|
async edit(data, condition) {
|
||||||
return await this.model.update(data, condition);
|
return await this.model.update(data, condition);
|
||||||
}
|
}
|
||||||
}*/
|
}
|
||||||
|
|
||||||
class Database {
|
class Database {
|
||||||
constructor(address, port, username, password, database) {
|
constructor(address, port, username, password, database) {
|
||||||
@ -68,32 +67,8 @@ class Database {
|
|||||||
);
|
);
|
||||||
this.sequelize.authenticate().then(
|
this.sequelize.authenticate().then(
|
||||||
() => {
|
() => {
|
||||||
// this.authors = new Table(
|
this.authors = new Table(
|
||||||
// this.sequelize.define(
|
this.sequelize.define(
|
||||||
// "authors",
|
|
||||||
// {
|
|
||||||
// id: {
|
|
||||||
// type: DataTypes.INTEGER,
|
|
||||||
// primaryKey: true,
|
|
||||||
// autoIncrement: true,
|
|
||||||
// allowNull: false,
|
|
||||||
// },
|
|
||||||
// name: {
|
|
||||||
// type: DataTypes.TEXT,
|
|
||||||
// allowNull: false,
|
|
||||||
// },
|
|
||||||
// time: {
|
|
||||||
// type: DataTypes.INTEGER,
|
|
||||||
// allowNull: false,
|
|
||||||
// },
|
|
||||||
// },
|
|
||||||
// {
|
|
||||||
// freezeTableName: true,
|
|
||||||
// timestamps: false,
|
|
||||||
// },
|
|
||||||
// ),
|
|
||||||
// );
|
|
||||||
this.authors = this.sequelize.define(
|
|
||||||
"authors",
|
"authors",
|
||||||
{
|
{
|
||||||
id: {
|
id: {
|
||||||
@ -115,9 +90,11 @@ class Database {
|
|||||||
freezeTableName: true,
|
freezeTableName: true,
|
||||||
timestamps: false,
|
timestamps: false,
|
||||||
},
|
},
|
||||||
)
|
),
|
||||||
this.music = this.sequelize.define(
|
);
|
||||||
"music",
|
this.muzic = new Table(
|
||||||
|
this.sequelize.define(
|
||||||
|
"muzic",
|
||||||
{
|
{
|
||||||
id: {
|
id: {
|
||||||
type: DataTypes.INTEGER,
|
type: DataTypes.INTEGER,
|
||||||
@ -145,6 +122,7 @@ class Database {
|
|||||||
freezeTableName: true,
|
freezeTableName: true,
|
||||||
timestamps: false,
|
timestamps: false,
|
||||||
},
|
},
|
||||||
|
),
|
||||||
);
|
);
|
||||||
console.log("Database successful connected!");
|
console.log("Database successful connected!");
|
||||||
},
|
},
|
||||||
@ -155,10 +133,4 @@ class Database {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = new Database(
|
module.exports = { Database };
|
||||||
config().database.address,
|
|
||||||
config().database.port,
|
|
||||||
config().database.username,
|
|
||||||
config().database.password,
|
|
||||||
config().database.database
|
|
||||||
);
|
|
||||||
|
|||||||
Binary file not shown.
@ -1,7 +1,7 @@
|
|||||||
<!DOCTYPE html>
|
<!DOCTYPE html>
|
||||||
<html>
|
<html>
|
||||||
<head>
|
<head>
|
||||||
<title>Kodex Music</title>
|
<title>Kodex Muzic</title>
|
||||||
<link href="/bootstrap/css/bootstrap.min.css" rel="stylesheet">
|
<link href="/bootstrap/css/bootstrap.min.css" rel="stylesheet">
|
||||||
<link href="/css/main.css" rel="stylesheet">
|
<link href="/css/main.css" rel="stylesheet">
|
||||||
<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootstrap-icons@1.10.3/font/bootstrap-icons.css">
|
<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootstrap-icons@1.10.3/font/bootstrap-icons.css">
|
||||||
@ -10,7 +10,7 @@
|
|||||||
<!-- <h3><center>Kodex Muzic</center></h3> -->
|
<!-- <h3><center>Kodex Muzic</center></h3> -->
|
||||||
<nav class="navbar navbar-light" style="background-color: #e3f2fd;">
|
<nav class="navbar navbar-light" style="background-color: #e3f2fd;">
|
||||||
<div class="container-fluid">
|
<div class="container-fluid">
|
||||||
<span class="navbar-brand mb-0 h1">Kodex Music</span>
|
<span class="navbar-brand mb-0 h1">Kodex Muzic</span>
|
||||||
</div>
|
</div>
|
||||||
<p style="margin-left: 10px;"><b>Поиск:</b> <input type="text" placeholder="Поиск по ключевым словам" class="form-control" id="search-input" style="width: 250%"></p>
|
<p style="margin-left: 10px;"><b>Поиск:</b> <input type="text" placeholder="Поиск по ключевым словам" class="form-control" id="search-input" style="width: 250%"></p>
|
||||||
</nav>
|
</nav>
|
||||||
|
|||||||
@ -18,13 +18,13 @@ class Api {
|
|||||||
xhr.send();
|
xhr.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
getMusic(params, cb) {
|
getMuzic(params, cb) {
|
||||||
const xhr = new XMLHttpRequest();
|
const xhr = new XMLHttpRequest();
|
||||||
params = Object.entries(params)
|
params = Object.entries(params)
|
||||||
.map(([key, value]) => `${key}=${value}`)
|
.map(([key, value]) => `${key}=${value}`)
|
||||||
.join("&");
|
.join("&");
|
||||||
params = params !== "" ? `&${params}` : "";
|
params = params !== "" ? `&${params}` : "";
|
||||||
xhr.open("GET", `/api/v/1.0/get-music?response_format=json${params}`, true);
|
xhr.open("GET", `/api/v/1.0/get-muzic?response_format=json${params}`, true);
|
||||||
xhr.onreadystatechange = function (event) {
|
xhr.onreadystatechange = function (event) {
|
||||||
//console.log(event);
|
//console.log(event);
|
||||||
if (this.readyState != 4) return;
|
if (this.readyState != 4) return;
|
||||||
@ -33,7 +33,7 @@ class Api {
|
|||||||
xhr.send();
|
xhr.send();
|
||||||
}
|
}
|
||||||
|
|
||||||
deleteMusic(id, cb) {
|
deleteMuzic(id, cb) {
|
||||||
const xhr = new XMLHttpRequest();
|
const xhr = new XMLHttpRequest();
|
||||||
xhr.open("POST", `/api/v/1.0/remove-item?response_format=json`, true);
|
xhr.open("POST", `/api/v/1.0/remove-item?response_format=json`, true);
|
||||||
xhr.setRequestHeader("Content-type", "application/json; charset=utf-8");
|
xhr.setRequestHeader("Content-type", "application/json; charset=utf-8");
|
||||||
@ -47,13 +47,13 @@ class Api {
|
|||||||
};
|
};
|
||||||
xhr.send(
|
xhr.send(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
type: "music",
|
type: "muzic",
|
||||||
id,
|
id,
|
||||||
}),
|
}),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
editMusic(id, name, data, author_id, cb) {
|
editMuzic(id, name, data, author_id, cb) {
|
||||||
const xhr = new XMLHttpRequest();
|
const xhr = new XMLHttpRequest();
|
||||||
xhr.open("POST", `/api/v/1.0/edit-item?response_format=json`, true);
|
xhr.open("POST", `/api/v/1.0/edit-item?response_format=json`, true);
|
||||||
xhr.setRequestHeader("Content-type", "application/json; charset=utf-8");
|
xhr.setRequestHeader("Content-type", "application/json; charset=utf-8");
|
||||||
@ -67,7 +67,7 @@ class Api {
|
|||||||
};
|
};
|
||||||
xhr.send(
|
xhr.send(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
type: "music",
|
type: "muzic",
|
||||||
id,
|
id,
|
||||||
name,
|
name,
|
||||||
author_id,
|
author_id,
|
||||||
@ -76,7 +76,7 @@ class Api {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
createMusic(author_id, name, data = null, cb) {
|
createMuzic(author_id, name, data = null, cb) {
|
||||||
data = data === null ? undefined : data;
|
data = data === null ? undefined : data;
|
||||||
const xhr = new XMLHttpRequest();
|
const xhr = new XMLHttpRequest();
|
||||||
xhr.open("POST", `/api/v/1.0/create-item?response_format=json`, true);
|
xhr.open("POST", `/api/v/1.0/create-item?response_format=json`, true);
|
||||||
@ -84,12 +84,11 @@ class Api {
|
|||||||
xhr.onreadystatechange = function (event) {
|
xhr.onreadystatechange = function (event) {
|
||||||
//console.log(event);
|
//console.log(event);
|
||||||
if (this.readyState != 4) return;
|
if (this.readyState != 4) return;
|
||||||
console.log(this.responseText);
|
|
||||||
cb(JSON.parse(this.responseText).response);
|
cb(JSON.parse(this.responseText).response);
|
||||||
};
|
};
|
||||||
xhr.send(
|
xhr.send(
|
||||||
JSON.stringify({
|
JSON.stringify({
|
||||||
type: "music",
|
type: "muzic",
|
||||||
name,
|
name,
|
||||||
author_id,
|
author_id,
|
||||||
data,
|
data,
|
||||||
|
|||||||
@ -10,10 +10,10 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
showAudio.settingsAuthors = settingsAuthors;
|
showAudio.settingsAuthors = settingsAuthors;
|
||||||
showAudio.settingsAudio = settingsAudio;
|
showAudio.settingsAudio = settingsAudio;
|
||||||
|
|
||||||
const step2 = (music) => {
|
const step2 = (muzic) => {
|
||||||
//console.log(music.items);
|
//console.log(muzic.items);
|
||||||
const showedAuthors = [
|
const showedAuthors = [
|
||||||
...new Set(music.items.map((i) => `author-${i.author_id}`)),
|
...new Set(muzic.items.map((i) => `author-${i.author_id}`)),
|
||||||
];
|
];
|
||||||
[...document.getElementsByClassName("author-element")].forEach((el) => {
|
[...document.getElementsByClassName("author-element")].forEach((el) => {
|
||||||
if (
|
if (
|
||||||
@ -22,7 +22,7 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
) {
|
) {
|
||||||
if (!showedAuthors.includes(el.id)) {
|
if (!showedAuthors.includes(el.id)) {
|
||||||
const id = el.id.slice(7);
|
const id = el.id.slice(7);
|
||||||
document.getElementById(`loader-music-${id}`).innerHTML =
|
document.getElementById(`loader-muzic-${id}`).innerHTML =
|
||||||
"<p><b>Пусто. Добавьте произведения</b></p>";
|
"<p><b>Пусто. Добавьте произведения</b></p>";
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
@ -30,48 +30,48 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
el.hidden = !showedAuthors.includes(el.id);
|
el.hidden = !showedAuthors.includes(el.id);
|
||||||
});
|
});
|
||||||
|
|
||||||
music.items
|
muzic.items
|
||||||
.sort((a, b) => a.date - b.date)
|
.sort((a, b) => a.date - b.date)
|
||||||
.forEach((music) => {
|
.forEach((muzic) => {
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`loader-music-${music.author_id}`,
|
`loader-muzic-${muzic.author_id}`,
|
||||||
).hidden = true;
|
).hidden = true;
|
||||||
if (music.is_data_exists)
|
if (muzic.is_data_exists)
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`playlist-author-${music.author_id}`,
|
`playlist-author-${muzic.author_id}`,
|
||||||
).innerHTML += `<p><div id="music-item-${music.id}">
|
).innerHTML += `<p><div id="muzic-item-${muzic.id}">
|
||||||
<h6><button class="btn btn-secondary" id="edit-music-item-${
|
<h6><button class="btn btn-secondary" id="edit-muzic-item-${
|
||||||
music.id
|
muzic.id
|
||||||
}" onclick='showEditMusic(${music.id}, ${JSON.stringify(
|
}" onclick='showEditMuzic(${muzic.id}, ${JSON.stringify(
|
||||||
music.name,
|
muzic.name,
|
||||||
)}, ${
|
)}, ${
|
||||||
music.is_data_exists
|
muzic.is_data_exists
|
||||||
});'><i class="bi bi-pencil-square"></i></button> ${music.name}</h6>
|
});'><i class="bi bi-pencil-square"></i></button> ${muzic.name}</h6>
|
||||||
<button class="btn btn-primary play-button" onclick="playMusic(${
|
<button class="btn btn-primary play-button" onclick="playMuzic(${
|
||||||
music.id
|
muzic.id
|
||||||
})" id="play-${music.id}">Прослушать</button>
|
})" id="play-${muzic.id}">Прослушать</button>
|
||||||
<button class="btn btn-primary pause-button" onclick="" id="pause-${
|
<button class="btn btn-primary pause-button" onclick="" id="pause-${
|
||||||
music.id
|
muzic.id
|
||||||
}" disabled>Пауза</button>
|
}" disabled>Пауза</button>
|
||||||
<input class="road-music" type="range" id="road-${
|
<input class="road-muzic" type="range" id="road-${
|
||||||
music.id
|
muzic.id
|
||||||
}" name="stop" min="0" max="0" value="0" step="0.01" style="width: 70%;"></label>
|
}" name="stop" min="0" max="0" value="0" step="0.01" style="width: 70%;"></label>
|
||||||
<p style="margin-top: 7px;"><input type="checkbox" class="form-check-input" id="repeat-mode-${
|
<p style="margin-top: 7px;"><input type="checkbox" class="form-check-input" id="repeat-mode-${
|
||||||
music.id
|
muzic.id
|
||||||
}">
|
}">
|
||||||
<label class="form-check-label" for="exampleCheck1">Повторять</label></p>
|
<label class="form-check-label" for="exampleCheck1">Повторять</label></p>
|
||||||
</div></p>`;
|
</div></p>`;
|
||||||
else
|
else
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`playlist-author-${music.author_id}`,
|
`playlist-author-${muzic.author_id}`,
|
||||||
).innerHTML += `<p><div id="music-item-${music.id}">
|
).innerHTML += `<p><div id="muzic-item-${muzic.id}">
|
||||||
<h6>${music.name}</h6>
|
<h6>${muzic.name}</h6>
|
||||||
<button class="btn btn-secondary" onclick='showEditMusic(${
|
<button class="btn btn-secondary" onclick='showEditMuzic(${
|
||||||
music.id
|
muzic.id
|
||||||
}, ${JSON.stringify(music.name)}, ${
|
}, ${JSON.stringify(muzic.name)}, ${
|
||||||
music.is_data_exists
|
muzic.is_data_exists
|
||||||
});' id="add-file-${music.id}" id="edit-music-item-${
|
});' id="add-file-${muzic.id}" id="edit-muzic-item-${
|
||||||
music.id
|
muzic.id
|
||||||
}">Добавить звуковой файл</button>
|
}">Добавить звуковой файл</button>
|
||||||
</div></p>`;
|
</div></p>`;
|
||||||
});
|
});
|
||||||
@ -89,43 +89,43 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
<hr/>
|
<hr/>
|
||||||
<a href='#' onclick="toggleShow(${author.id})">Показать/Скрыть</a>
|
<a href='#' onclick="toggleShow(${author.id})">Показать/Скрыть</a>
|
||||||
<div id="playlist-author-${author.id}">
|
<div id="playlist-author-${author.id}">
|
||||||
<p id="loader-music-${author.id}">Загрузка..</p>
|
<p id="loader-muzic-${author.id}">Загрузка..</p>
|
||||||
</div>
|
</div>
|
||||||
<div id="add-music-${author.id}" style="margin-bottom: 15px;"><center><button class="btn btn-primary" id="add-music-button-${author.id}">Добавить произведение</button></center></div>
|
<div id="add-muzic-${author.id}" style="margin-bottom: 15px;"><center><button class="btn btn-primary" id="add-muzic-button-${author.id}">Добавить произведение</button></center></div>
|
||||||
</div>`;
|
</div>`;
|
||||||
const addMusicButtonFunct = () =>
|
const addMuzicButtonFunct = () =>
|
||||||
setTimeout(
|
setTimeout(
|
||||||
() =>
|
() =>
|
||||||
(document.getElementById(
|
(document.getElementById(
|
||||||
`add-music-button-${author.id}`,
|
`add-muzic-button-${author.id}`,
|
||||||
).onclick = async () => {
|
).onclick = async () => {
|
||||||
// console.log('>>', author.id);
|
// console.log('>>', author.id);
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`add-music-${author.id}`,
|
`add-muzic-${author.id}`,
|
||||||
).innerHTML = `<p><input class="form-control" type="text" placeholder="Введите название произведения" id="music-name-input-${author.id}" style="width: 90%"></p>
|
).innerHTML = `<p><input class="form-control" type="text" placeholder="Введите название произведения" id="muzic-name-input-${author.id}" style="width: 90%"></p>
|
||||||
<p><button class="btn btn-primary" id="attach-file-${author.id}">Добавить файл (.mp3)</button>
|
<p><button class="btn btn-primary" id="attach-file-${author.id}">Добавить файл (.mp3)</button>
|
||||||
<button class="btn btn-primary" id="add-music-act-${author.id}">Добавить произведение</button>
|
<button class="btn btn-primary" id="add-muzic-act-${author.id}">Добавить произведение</button>
|
||||||
<button class="btn btn-danger" id="cancel-add-music-${author.id}">Отменить</button></p>`;
|
<button class="btn btn-danger" id="cancel-add-muzic-${author.id}">Отменить</button></p>`;
|
||||||
setTimeout(() => {
|
setTimeout(() => {
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`cancel-add-music-${author.id}`,
|
`cancel-add-muzic-${author.id}`,
|
||||||
).onclick = function () {
|
).onclick = function () {
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`add-music-${author.id}`,
|
`add-muzic-${author.id}`,
|
||||||
).innerHTML = `<center><button class="btn btn-primary" id="add-music-button-${author.id}">Добавить произведение</button></center>`;
|
).innerHTML = `<center><button class="btn btn-primary" id="add-muzic-button-${author.id}">Добавить произведение</button></center>`;
|
||||||
addMusicButtonFunct();
|
addMuzicButtonFunct();
|
||||||
};
|
};
|
||||||
|
|
||||||
document.getElementById(`add-music-act-${author.id}`).onclick =
|
document.getElementById(`add-muzic-act-${author.id}`).onclick =
|
||||||
function () {
|
function () {
|
||||||
if (
|
if (
|
||||||
document.getElementById(`music-name-input-${author.id}`)
|
document.getElementById(`muzic-name-input-${author.id}`)
|
||||||
.value.length >= 2
|
.value.length >= 2
|
||||||
) {
|
) {
|
||||||
api.createMusic(
|
api.createMuzic(
|
||||||
author.id,
|
author.id,
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`music-name-input-${author.id}`,
|
`muzic-name-input-${author.id}`,
|
||||||
).value,
|
).value,
|
||||||
document.getElementById(`attach-file-${author.id}`)
|
document.getElementById(`attach-file-${author.id}`)
|
||||||
.filedata,
|
.filedata,
|
||||||
@ -134,7 +134,7 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
},
|
},
|
||||||
);
|
);
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`add-music-${author.id}`,
|
`add-muzic-${author.id}`,
|
||||||
).innerHTML = "Добавление файла...";
|
).innerHTML = "Добавление файла...";
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
@ -178,9 +178,9 @@ function showAudio(settingsAuthors, settingsAudio) {
|
|||||||
}),
|
}),
|
||||||
0,
|
0,
|
||||||
);
|
);
|
||||||
addMusicButtonFunct();
|
addMuzicButtonFunct();
|
||||||
});
|
});
|
||||||
api.getMusic(settingsAudio, step2);
|
api.getMuzic(settingsAudio, step2);
|
||||||
document.getElementById("app-window").innerHTML +=
|
document.getElementById("app-window").innerHTML +=
|
||||||
'<div id="add-author" style="margin-bottom: 15px;"><center><button class="btn btn-primary" id="add-author-button" onclick="addAuthorMenu();">Добавить исполнителя</button></center></div>';
|
'<div id="add-author" style="margin-bottom: 15px;"><center><button class="btn btn-primary" id="add-author-button" onclick="addAuthorMenu();">Добавить исполнителя</button></center></div>';
|
||||||
});
|
});
|
||||||
|
|||||||
@ -83,7 +83,7 @@ function addAuthorMenu() {
|
|||||||
setTimeout(authorMenuButtonInit, 5);
|
setTimeout(authorMenuButtonInit, 5);
|
||||||
}
|
}
|
||||||
|
|
||||||
function selectFile(musicId) {
|
function selectFile(muzicId) {
|
||||||
const input = document.createElement("input");
|
const input = document.createElement("input");
|
||||||
input.type = "file";
|
input.type = "file";
|
||||||
input.accept = "audio/mpeg";
|
input.accept = "audio/mpeg";
|
||||||
@ -106,22 +106,22 @@ function selectFile(musicId) {
|
|||||||
reader.onload = function () {
|
reader.onload = function () {
|
||||||
// console.log('reader.result', reader.result);
|
// console.log('reader.result', reader.result);
|
||||||
if (file.type === "audio/mpeg") {
|
if (file.type === "audio/mpeg") {
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).filedata =
|
document.getElementById(`edit-attach-file-${muzicId}`).filedata =
|
||||||
arrayBufferToBase64(reader.result);
|
arrayBufferToBase64(reader.result);
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).innerText =
|
document.getElementById(`edit-attach-file-${muzicId}`).innerText =
|
||||||
"Загружен файл: " + file.name;
|
"Загружен файл: " + file.name;
|
||||||
document.getElementById(`delete-attach-${musicId}`).disabled = false;
|
document.getElementById(`delete-attach-${muzicId}`).disabled = false;
|
||||||
}
|
}
|
||||||
// console.log(arrayBufferToBase64(reader.result));
|
// console.log(arrayBufferToBase64(reader.result));
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
function editMusic(musicId, musicName) {
|
function editMuzic(muzicId, muzicName) {
|
||||||
api.editMusic(
|
api.editMuzic(
|
||||||
musicId,
|
muzicId,
|
||||||
musicName,
|
muzicName,
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).filedata,
|
document.getElementById(`edit-attach-file-${muzicId}`).filedata,
|
||||||
undefined,
|
undefined,
|
||||||
(res) => {
|
(res) => {
|
||||||
showAudio(showAudio.settingsAuthors, showAudio.settingsAudio);
|
showAudio(showAudio.settingsAuthors, showAudio.settingsAudio);
|
||||||
@ -129,57 +129,57 @@ function editMusic(musicId, musicName) {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
function removeMusic(musicId) {
|
function removeMuzic(muzicId) {
|
||||||
api.deleteMusic(musicId, (res) => {
|
api.deleteMuzic(muzicId, (res) => {
|
||||||
showAudio(showAudio.settingsAuthors, showAudio.settingsAudio);
|
showAudio(showAudio.settingsAuthors, showAudio.settingsAudio);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
function bindShowEditMusicButtons(musicId, musicName, dataExists) {
|
function bindShowEditMuzicButtons(muzicId, muzicName, dataExists) {
|
||||||
document.getElementById(`cancel-edit-music-${musicId}`).onclick = () => {
|
document.getElementById(`cancel-edit-muzic-${muzicId}`).onclick = () => {
|
||||||
document.getElementById(`music-item-${musicId}`).innerHTML = dataExists
|
document.getElementById(`muzic-item-${muzicId}`).innerHTML = dataExists
|
||||||
? `<h6><button class="btn btn-secondary" id="edit-music-item-${musicId}" onclick='showEditMusic(${musicId}, ${JSON.stringify(
|
? `<h6><button class="btn btn-secondary" id="edit-muzic-item-${muzicId}" onclick='showEditMuzic(${muzicId}, ${JSON.stringify(
|
||||||
musicName,
|
muzicName,
|
||||||
)}, ${dataExists});'><i class="bi bi-pencil-square"></i></button> ${musicName}</h6>
|
)}, ${dataExists});'><i class="bi bi-pencil-square"></i></button> ${muzicName}</h6>
|
||||||
<button class="btn btn-primary play-button" onclick="playMusic(${musicId})" id="play-${musicId}">Прослушать</button>
|
<button class="btn btn-primary play-button" onclick="playMuzic(${muzicId})" id="play-${muzicId}">Прослушать</button>
|
||||||
<button class="btn btn-primary pause-button" onclick="" id="pause-${musicId}" disabled>Пауза</button>
|
<button class="btn btn-primary pause-button" onclick="" id="pause-${muzicId}" disabled>Пауза</button>
|
||||||
<input class="road-music" type="range" id="road-${musicId}" name="stop" min="0" max="0" value="0" step="0.01" style="width: 70%;"/>`
|
<input class="road-muzic" type="range" id="road-${muzicId}" name="stop" min="0" max="0" value="0" step="0.01" style="width: 70%;"/>`
|
||||||
: `<p><div id="music-item-${musicId}">
|
: `<p><div id="muzic-item-${muzicId}">
|
||||||
<h6>${musicName}</h6>
|
<h6>${muzicName}</h6>
|
||||||
<button class="btn btn-secondary" onclick='showEditMusic(${musicId}, ${JSON.stringify(
|
<button class="btn btn-secondary" onclick='showEditMuzic(${muzicId}, ${JSON.stringify(
|
||||||
musicName,
|
muzicName,
|
||||||
)}, ${dataExists});' id="add-file-${musicId}" id="edit-music-item-${musicId}">Добавить звуковой файл</button>
|
)}, ${dataExists});' id="add-file-${muzicId}" id="edit-muzic-item-${muzicId}">Добавить звуковой файл</button>
|
||||||
</div></p>`;
|
</div></p>`;
|
||||||
};
|
};
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).onclick = () =>
|
document.getElementById(`edit-attach-file-${muzicId}`).onclick = () =>
|
||||||
selectFile(musicId);
|
selectFile(muzicId);
|
||||||
document.getElementById(`delete-attach-${musicId}`).onclick = () => {
|
document.getElementById(`delete-attach-${muzicId}`).onclick = () => {
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).innerText =
|
document.getElementById(`edit-attach-file-${muzicId}`).innerText =
|
||||||
"Добавить файл (.mp3)";
|
"Добавить файл (.mp3)";
|
||||||
document.getElementById(`edit-attach-file-${musicId}`).filedata = null;
|
document.getElementById(`edit-attach-file-${muzicId}`).filedata = null;
|
||||||
document.getElementById(`delete-attach-${musicId}`).disabled = true;
|
document.getElementById(`delete-attach-${muzicId}`).disabled = true;
|
||||||
};
|
};
|
||||||
document.getElementById(`edit-music-${musicId}`).onclick = () =>
|
document.getElementById(`edit-muzic-${muzicId}`).onclick = () =>
|
||||||
editMusic(musicId, document.getElementById(`music-edit-name-input-${musicId}`).value);
|
editMuzic(muzicId, document.getElementById(`muzic-edit-name-input-${muzicId}`).value);
|
||||||
document.getElementById(`delete-music-${musicId}`).onclick = () =>
|
document.getElementById(`delete-muzic-${muzicId}`).onclick = () =>
|
||||||
removeMusic(musicId);
|
removeMuzic(muzicId);
|
||||||
}
|
}
|
||||||
|
|
||||||
function showEditMusic(musicId, musicName, dataExists) {
|
function showEditMuzic(muzicId, muzicName, dataExists) {
|
||||||
document.getElementById(
|
document.getElementById(
|
||||||
`music-item-${musicId}`,
|
`muzic-item-${muzicId}`,
|
||||||
).innerHTML = `<p><input class="form-control" type="text" placeholder="Введите название произведения" value=${JSON.stringify(
|
).innerHTML = `<p><input class="form-control" type="text" placeholder="Введите название произведения" value=${JSON.stringify(
|
||||||
musicName,
|
muzicName,
|
||||||
)} id="music-edit-name-input-${musicId}" style="width: 90%"></p>
|
)} id="muzic-edit-name-input-${muzicId}" style="width: 90%"></p>
|
||||||
<p><button class="btn btn-primary" id="edit-attach-file-${musicId}">${
|
<p><button class="btn btn-primary" id="edit-attach-file-${muzicId}">${
|
||||||
dataExists ? "Сменить файл (.mp3)" : "Добавить файл (.mp3)"
|
dataExists ? "Сменить файл (.mp3)" : "Добавить файл (.mp3)"
|
||||||
}</button>
|
}</button>
|
||||||
<button class="btn btn-danger" id="delete-attach-${musicId}"${
|
<button class="btn btn-danger" id="delete-attach-${muzicId}"${
|
||||||
dataExists ? "" : " disabled"
|
dataExists ? "" : " disabled"
|
||||||
}>Удалить файл</button>
|
}>Удалить файл</button>
|
||||||
<button class="btn btn-primary" id="edit-music-${musicId}">Редактировать произведение</button>
|
<button class="btn btn-primary" id="edit-muzic-${muzicId}">Редактировать произведение</button>
|
||||||
<button class="btn btn-secondary" id="cancel-edit-music-${musicId}">Отменить</button>
|
<button class="btn btn-secondary" id="cancel-edit-muzic-${muzicId}">Отменить</button>
|
||||||
<button class="btn btn-danger" id="delete-music-${musicId}">Удалить произведение</button></p>`;
|
<button class="btn btn-danger" id="delete-muzic-${muzicId}">Удалить произведение</button></p>`;
|
||||||
|
|
||||||
setTimeout(() => bindShowEditMusicButtons(musicId, musicName, dataExists), 5);
|
setTimeout(() => bindShowEditMuzicButtons(muzicId, muzicName, dataExists), 5);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -1,31 +1,28 @@
|
|||||||
let audio = new Audio("/api/v/1.0/music");
|
let audio = new Audio("/api/v/1.0/muzic");
|
||||||
|
|
||||||
function stopMusic(id, interval) {
|
function stopMuzic(id, interval) {
|
||||||
audio.pause();
|
audio.pause();
|
||||||
// pauseMusic(id);
|
|
||||||
audio.currentTime = 0;
|
audio.currentTime = 0;
|
||||||
document.getElementById(`play-${id}`).innerText = "Прослушать";
|
document.getElementById(`play-${id}`).innerText = "Прослушать";
|
||||||
document.getElementById(`play-${id}`).disabled = false;
|
|
||||||
document.getElementById(`pause-${id}`).innerText = "Пауза";
|
|
||||||
document.getElementById(`pause-${id}`).disabled = true;
|
document.getElementById(`pause-${id}`).disabled = true;
|
||||||
document.getElementById(`play-${id}`).onclick = () => playMusic(id);
|
document.getElementById(`play-${id}`).onclick = () => playMuzic(id);
|
||||||
|
|
||||||
clearInterval(interval);
|
clearInterval(interval);
|
||||||
document.getElementById(`road-${id}`).value = 0;
|
document.getElementById(`road-${id}`).value = 0;
|
||||||
document.getElementById(`road-${id}`).max = 0;
|
document.getElementById(`road-${id}`).max = 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
function pauseMusic(id) {
|
function pauseMuzic(id) {
|
||||||
document.getElementById(`play-${id}`).disabled = true;
|
document.getElementById(`play-${id}`).disabled = true;
|
||||||
document.getElementById(`pause-${id}`).innerText = "Продолжить";
|
document.getElementById(`pause-${id}`).innerText = "Продолжить";
|
||||||
document.getElementById(`pause-${id}`).onclick = () => resumeMusic(id);
|
document.getElementById(`pause-${id}`).onclick = () => resumeMuzic(id);
|
||||||
audio.pause();
|
audio.pause();
|
||||||
}
|
}
|
||||||
|
|
||||||
function resumeMusic(id) {
|
function resumeMuzic(id) {
|
||||||
document.getElementById(`play-${id}`).disabled = false;
|
document.getElementById(`play-${id}`).disabled = false;
|
||||||
document.getElementById(`pause-${id}`).innerText = "Пауза";
|
document.getElementById(`pause-${id}`).innerText = "Пауза";
|
||||||
document.getElementById(`pause-${id}`).onclick = () => pauseMusic(id);
|
document.getElementById(`pause-${id}`).onclick = () => pauseMuzic(id);
|
||||||
audio.play();
|
audio.play();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -33,12 +30,12 @@ function changeTime(value, id) {
|
|||||||
audio.currentTime = value;
|
audio.currentTime = value;
|
||||||
}
|
}
|
||||||
|
|
||||||
function playMusic(id) {
|
function playMuzic(id) {
|
||||||
audio.pause();
|
audio.pause();
|
||||||
audio.currentTime = 0;
|
audio.currentTime = 0;
|
||||||
if (audio.muzId !== undefined) stopMusic(audio.muzId, audio.muzTimer);
|
if (audio.muzId !== undefined) stopMuzic(audio.muzId, audio.muzTimer);
|
||||||
|
|
||||||
audio = new Audio(`/api/v/1.0/music?id=${id}`);
|
audio = new Audio(`/api/v/1.0/muzic?id=${id}`);
|
||||||
audio.onloadedmetadata = function () {
|
audio.onloadedmetadata = function () {
|
||||||
audio.muzId = id;
|
audio.muzId = id;
|
||||||
document.getElementById(`play-${id}`).innerText = "Остановить";
|
document.getElementById(`play-${id}`).innerText = "Остановить";
|
||||||
@ -55,8 +52,8 @@ function playMusic(id) {
|
|||||||
}, 750);
|
}, 750);
|
||||||
audio.muzTimer = interval;
|
audio.muzTimer = interval;
|
||||||
document.getElementById(`play-${id}`).onclick = () =>
|
document.getElementById(`play-${id}`).onclick = () =>
|
||||||
stopMusic(id, interval);
|
stopMuzic(id, interval);
|
||||||
document.getElementById(`pause-${id}`).onclick = () => pauseMusic(id);
|
document.getElementById(`pause-${id}`).onclick = () => pauseMuzic(id);
|
||||||
|
|
||||||
document.getElementById(`road-${id}`).onchange = function () {
|
document.getElementById(`road-${id}`).onchange = function () {
|
||||||
// console.log('value', this.value);
|
// console.log('value', this.value);
|
||||||
|
|||||||
65
logger.js
65
logger.js
@ -1,39 +1,40 @@
|
|||||||
const config = require("./config-handler");
|
const config = require("./config-handler");
|
||||||
const fs = require("fs");
|
const fs = require("fs");
|
||||||
|
|
||||||
class Logger {
|
function log(date, req, ip, res) {
|
||||||
constructor () {
|
const requestBody = !req.byteBody.toString("utf-8")
|
||||||
this.isLoggerModeOn = config().logger_mode;
|
? ""
|
||||||
if (this.isLoggerModeOn) {
|
: `
|
||||||
this.logId = `${(new Date()).getTime()}`;
|
~~~~~~~~~~~~~~
|
||||||
this.loggerFolder = config().logger_folder;
|
[REQUEST BODY]
|
||||||
this.loggerFolder = !["/", "\\"].includes(this.loggerFolder.at(-1))
|
~~~~~~~~~~~~~~
|
||||||
? this.loggerFolder + "/"
|
${req.byteBody.toString("utf-8")}`;
|
||||||
: this.loggerFolder;
|
let action = `HTTP ${req.httpVersion} ${req.method} ${req.originalUrl}
|
||||||
fs.writeFile(
|
~~~~~~~~~
|
||||||
`${this.loggerFolder}${this.logId}.log`, '',
|
[HEADERS]
|
||||||
{
|
~~~~~~~~~
|
||||||
encoding: "utf8"
|
${Object.entries(req.headers)
|
||||||
},
|
.map(([header, value]) => header + ": " + value)
|
||||||
(err) => {
|
.join("\n")}${requestBody}`;
|
||||||
if (err) throw err;
|
let response = !res.isError
|
||||||
}
|
? ""
|
||||||
);
|
: `\n----------------\nError raised:\n----------------\n${JSON.stringify(
|
||||||
}
|
res.responseData,
|
||||||
}
|
)}`;
|
||||||
|
//console.log(`================================\nREPORT\n================================\n\nIP: ${ip}\n----------------\nACTION:\n----------------\n${action}${response}`);
|
||||||
|
let loggerFolder = config().logger_folder;
|
||||||
|
loggerFolder = !["/", "\\"].includes(loggerFolder.at(-1))
|
||||||
|
? loggerFolder + "/"
|
||||||
|
: loggerFolder;
|
||||||
|
|
||||||
log (date, ip, action, isError = false) {
|
fs.writeFileSync(
|
||||||
if (this.isLoggerModeOn) fs.writeFile(
|
`${loggerFolder}${date.getTime()}.log`,
|
||||||
`${this.loggerFolder}${this.logId}.log`, !isError ? `IP: ${ip}\nДата запроса: ${date}\nАктивное действие: ${action}` : `\nПроизошла ошибка: ${action}`,
|
`================================\nREPORT\n================================\n\nIP: ${ip}\n----------------\nACTION:\n----------------\n${action}${response}`,
|
||||||
{
|
|
||||||
encoding : "utf8",
|
|
||||||
flag : "a"
|
|
||||||
},
|
|
||||||
(err) => {
|
|
||||||
if (err) throw err;
|
|
||||||
}
|
|
||||||
);
|
);
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = { Logger };
|
module.exports = async (req, res, next) => {
|
||||||
|
// console.log('ip', req.ip);
|
||||||
|
log(new Date(), req, req.ip, res);
|
||||||
|
next();
|
||||||
|
};
|
||||||
112
package-lock.json
generated
112
package-lock.json
generated
@ -5,6 +5,7 @@
|
|||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"body": "^5.1.0",
|
||||||
"body-parser": "^1.20.2",
|
"body-parser": "^1.20.2",
|
||||||
"cookie-parser": "^1.4.6",
|
"cookie-parser": "^1.4.6",
|
||||||
"express": "^4.18.2",
|
"express": "^4.18.2",
|
||||||
@ -52,6 +53,17 @@
|
|||||||
"resolved": "https://registry.npmjs.org/array-flatten/-/array-flatten-1.1.1.tgz",
|
"resolved": "https://registry.npmjs.org/array-flatten/-/array-flatten-1.1.1.tgz",
|
||||||
"integrity": "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg=="
|
"integrity": "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg=="
|
||||||
},
|
},
|
||||||
|
"node_modules/body": {
|
||||||
|
"version": "5.1.0",
|
||||||
|
"resolved": "https://registry.npmjs.org/body/-/body-5.1.0.tgz",
|
||||||
|
"integrity": "sha512-chUsBxGRtuElD6fmw1gHLpvnKdVLK302peeFa9ZqAEk8TyzZ3fygLyUEDDPTJvL9+Bor0dIwn6ePOsRM2y0zQQ==",
|
||||||
|
"dependencies": {
|
||||||
|
"continuable-cache": "^0.3.1",
|
||||||
|
"error": "^7.0.0",
|
||||||
|
"raw-body": "~1.1.0",
|
||||||
|
"safe-json-parse": "~1.0.1"
|
||||||
|
}
|
||||||
|
},
|
||||||
"node_modules/body-parser": {
|
"node_modules/body-parser": {
|
||||||
"version": "1.20.2",
|
"version": "1.20.2",
|
||||||
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.2.tgz",
|
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.2.tgz",
|
||||||
@ -75,6 +87,23 @@
|
|||||||
"npm": "1.2.8000 || >= 1.4.16"
|
"npm": "1.2.8000 || >= 1.4.16"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"node_modules/body/node_modules/bytes": {
|
||||||
|
"version": "1.0.0",
|
||||||
|
"resolved": "https://registry.npmjs.org/bytes/-/bytes-1.0.0.tgz",
|
||||||
|
"integrity": "sha512-/x68VkHLeTl3/Ll8IvxdwzhrT+IyKc52e/oyHhA2RwqPqswSnjVbSddfPRwAsJtbilMAPSRWwAlpxdYsSWOTKQ=="
|
||||||
|
},
|
||||||
|
"node_modules/body/node_modules/raw-body": {
|
||||||
|
"version": "1.1.7",
|
||||||
|
"resolved": "https://registry.npmjs.org/raw-body/-/raw-body-1.1.7.tgz",
|
||||||
|
"integrity": "sha512-WmJJU2e9Y6M5UzTOkHaM7xJGAPQD8PNzx3bAd2+uhZAim6wDk6dAZxPVYLF67XhbR4hmKGh33Lpmh4XWrCH5Mg==",
|
||||||
|
"dependencies": {
|
||||||
|
"bytes": "1",
|
||||||
|
"string_decoder": "0.10"
|
||||||
|
},
|
||||||
|
"engines": {
|
||||||
|
"node": ">= 0.8.0"
|
||||||
|
}
|
||||||
|
},
|
||||||
"node_modules/buffer-writer": {
|
"node_modules/buffer-writer": {
|
||||||
"version": "2.0.0",
|
"version": "2.0.0",
|
||||||
"resolved": "https://registry.npmjs.org/buffer-writer/-/buffer-writer-2.0.0.tgz",
|
"resolved": "https://registry.npmjs.org/buffer-writer/-/buffer-writer-2.0.0.tgz",
|
||||||
@ -122,6 +151,11 @@
|
|||||||
"node": ">= 0.6"
|
"node": ">= 0.6"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"node_modules/continuable-cache": {
|
||||||
|
"version": "0.3.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/continuable-cache/-/continuable-cache-0.3.1.tgz",
|
||||||
|
"integrity": "sha512-TF30kpKhTH8AGCG3dut0rdd/19B7Z+qCnrMoBLpyQu/2drZdNrrpcjPEoJeSVsQM+8KmWG5O56oPDjSSUsuTyA=="
|
||||||
|
},
|
||||||
"node_modules/cookie": {
|
"node_modules/cookie": {
|
||||||
"version": "0.5.0",
|
"version": "0.5.0",
|
||||||
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.5.0.tgz",
|
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.5.0.tgz",
|
||||||
@ -198,6 +232,14 @@
|
|||||||
"node": ">= 0.8"
|
"node": ">= 0.8"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"node_modules/error": {
|
||||||
|
"version": "7.2.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/error/-/error-7.2.1.tgz",
|
||||||
|
"integrity": "sha512-fo9HBvWnx3NGUKMvMwB/CBCMMrfEJgbDTVDEkPygA3Bdd3lM1OyCd+rbQ8BwnpF6GdVeOLDNmyL4N5Bg80ZvdA==",
|
||||||
|
"dependencies": {
|
||||||
|
"string-template": "~0.2.1"
|
||||||
|
}
|
||||||
|
},
|
||||||
"node_modules/escape-html": {
|
"node_modules/escape-html": {
|
||||||
"version": "1.0.3",
|
"version": "1.0.3",
|
||||||
"resolved": "https://registry.npmjs.org/escape-html/-/escape-html-1.0.3.tgz",
|
"resolved": "https://registry.npmjs.org/escape-html/-/escape-html-1.0.3.tgz",
|
||||||
@ -747,6 +789,11 @@
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
"node_modules/safe-json-parse": {
|
||||||
|
"version": "1.0.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/safe-json-parse/-/safe-json-parse-1.0.1.tgz",
|
||||||
|
"integrity": "sha512-o0JmTu17WGUaUOHa1l0FPGXKBfijbxK6qoHzlkihsDXxzBHvJcA7zgviKR92Xs841rX9pK16unfphLq0/KqX7A=="
|
||||||
|
},
|
||||||
"node_modules/safer-buffer": {
|
"node_modules/safer-buffer": {
|
||||||
"version": "2.1.2",
|
"version": "2.1.2",
|
||||||
"resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
|
"resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
|
||||||
@ -932,6 +979,16 @@
|
|||||||
"node": ">= 0.8"
|
"node": ">= 0.8"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
"node_modules/string_decoder": {
|
||||||
|
"version": "0.10.31",
|
||||||
|
"resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-0.10.31.tgz",
|
||||||
|
"integrity": "sha512-ev2QzSzWPYmy9GuqfIVildA4OdcGLeFZQrq5ys6RtiuF+RQQiZWr8TZNyAcuVXyQRYfEO+MsoB/1BuQVhOJuoQ=="
|
||||||
|
},
|
||||||
|
"node_modules/string-template": {
|
||||||
|
"version": "0.2.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/string-template/-/string-template-0.2.1.tgz",
|
||||||
|
"integrity": "sha512-Yptehjogou2xm4UJbxJ4CxgZx12HBfeystp0y3x7s4Dj32ltVVG1Gg8YhKjHZkHicuKpZX/ffilA8505VbUbpw=="
|
||||||
|
},
|
||||||
"node_modules/toidentifier": {
|
"node_modules/toidentifier": {
|
||||||
"version": "1.0.1",
|
"version": "1.0.1",
|
||||||
"resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz",
|
"resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz",
|
||||||
@ -1057,6 +1114,33 @@
|
|||||||
"resolved": "https://registry.npmjs.org/array-flatten/-/array-flatten-1.1.1.tgz",
|
"resolved": "https://registry.npmjs.org/array-flatten/-/array-flatten-1.1.1.tgz",
|
||||||
"integrity": "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg=="
|
"integrity": "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg=="
|
||||||
},
|
},
|
||||||
|
"body": {
|
||||||
|
"version": "5.1.0",
|
||||||
|
"resolved": "https://registry.npmjs.org/body/-/body-5.1.0.tgz",
|
||||||
|
"integrity": "sha512-chUsBxGRtuElD6fmw1gHLpvnKdVLK302peeFa9ZqAEk8TyzZ3fygLyUEDDPTJvL9+Bor0dIwn6ePOsRM2y0zQQ==",
|
||||||
|
"requires": {
|
||||||
|
"continuable-cache": "^0.3.1",
|
||||||
|
"error": "^7.0.0",
|
||||||
|
"raw-body": "~1.1.0",
|
||||||
|
"safe-json-parse": "~1.0.1"
|
||||||
|
},
|
||||||
|
"dependencies": {
|
||||||
|
"bytes": {
|
||||||
|
"version": "1.0.0",
|
||||||
|
"resolved": "https://registry.npmjs.org/bytes/-/bytes-1.0.0.tgz",
|
||||||
|
"integrity": "sha512-/x68VkHLeTl3/Ll8IvxdwzhrT+IyKc52e/oyHhA2RwqPqswSnjVbSddfPRwAsJtbilMAPSRWwAlpxdYsSWOTKQ=="
|
||||||
|
},
|
||||||
|
"raw-body": {
|
||||||
|
"version": "1.1.7",
|
||||||
|
"resolved": "https://registry.npmjs.org/raw-body/-/raw-body-1.1.7.tgz",
|
||||||
|
"integrity": "sha512-WmJJU2e9Y6M5UzTOkHaM7xJGAPQD8PNzx3bAd2+uhZAim6wDk6dAZxPVYLF67XhbR4hmKGh33Lpmh4XWrCH5Mg==",
|
||||||
|
"requires": {
|
||||||
|
"bytes": "1",
|
||||||
|
"string_decoder": "0.10"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
"body-parser": {
|
"body-parser": {
|
||||||
"version": "1.20.2",
|
"version": "1.20.2",
|
||||||
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.2.tgz",
|
"resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.2.tgz",
|
||||||
@ -1108,6 +1192,11 @@
|
|||||||
"resolved": "https://registry.npmjs.org/content-type/-/content-type-1.0.5.tgz",
|
"resolved": "https://registry.npmjs.org/content-type/-/content-type-1.0.5.tgz",
|
||||||
"integrity": "sha512-nTjqfcBFEipKdXCv4YDQWCfmcLZKm81ldF0pAopTvyrFGVbcR6P/VAAd5G7N+0tTr8QqiU0tFadD6FK4NtJwOA=="
|
"integrity": "sha512-nTjqfcBFEipKdXCv4YDQWCfmcLZKm81ldF0pAopTvyrFGVbcR6P/VAAd5G7N+0tTr8QqiU0tFadD6FK4NtJwOA=="
|
||||||
},
|
},
|
||||||
|
"continuable-cache": {
|
||||||
|
"version": "0.3.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/continuable-cache/-/continuable-cache-0.3.1.tgz",
|
||||||
|
"integrity": "sha512-TF30kpKhTH8AGCG3dut0rdd/19B7Z+qCnrMoBLpyQu/2drZdNrrpcjPEoJeSVsQM+8KmWG5O56oPDjSSUsuTyA=="
|
||||||
|
},
|
||||||
"cookie": {
|
"cookie": {
|
||||||
"version": "0.5.0",
|
"version": "0.5.0",
|
||||||
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.5.0.tgz",
|
"resolved": "https://registry.npmjs.org/cookie/-/cookie-0.5.0.tgz",
|
||||||
@ -1167,6 +1256,14 @@
|
|||||||
"resolved": "https://registry.npmjs.org/encodeurl/-/encodeurl-1.0.2.tgz",
|
"resolved": "https://registry.npmjs.org/encodeurl/-/encodeurl-1.0.2.tgz",
|
||||||
"integrity": "sha512-TPJXq8JqFaVYm2CWmPvnP2Iyo4ZSM7/QKcSmuMLDObfpH5fi7RUGmd/rTDf+rut/saiDiQEeVTNgAmJEdAOx0w=="
|
"integrity": "sha512-TPJXq8JqFaVYm2CWmPvnP2Iyo4ZSM7/QKcSmuMLDObfpH5fi7RUGmd/rTDf+rut/saiDiQEeVTNgAmJEdAOx0w=="
|
||||||
},
|
},
|
||||||
|
"error": {
|
||||||
|
"version": "7.2.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/error/-/error-7.2.1.tgz",
|
||||||
|
"integrity": "sha512-fo9HBvWnx3NGUKMvMwB/CBCMMrfEJgbDTVDEkPygA3Bdd3lM1OyCd+rbQ8BwnpF6GdVeOLDNmyL4N5Bg80ZvdA==",
|
||||||
|
"requires": {
|
||||||
|
"string-template": "~0.2.1"
|
||||||
|
}
|
||||||
|
},
|
||||||
"escape-html": {
|
"escape-html": {
|
||||||
"version": "1.0.3",
|
"version": "1.0.3",
|
||||||
"resolved": "https://registry.npmjs.org/escape-html/-/escape-html-1.0.3.tgz",
|
"resolved": "https://registry.npmjs.org/escape-html/-/escape-html-1.0.3.tgz",
|
||||||
@ -1565,6 +1662,11 @@
|
|||||||
"resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
|
"resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
|
||||||
"integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ=="
|
"integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ=="
|
||||||
},
|
},
|
||||||
|
"safe-json-parse": {
|
||||||
|
"version": "1.0.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/safe-json-parse/-/safe-json-parse-1.0.1.tgz",
|
||||||
|
"integrity": "sha512-o0JmTu17WGUaUOHa1l0FPGXKBfijbxK6qoHzlkihsDXxzBHvJcA7zgviKR92Xs841rX9pK16unfphLq0/KqX7A=="
|
||||||
|
},
|
||||||
"safer-buffer": {
|
"safer-buffer": {
|
||||||
"version": "2.1.2",
|
"version": "2.1.2",
|
||||||
"resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
|
"resolved": "https://registry.npmjs.org/safer-buffer/-/safer-buffer-2.1.2.tgz",
|
||||||
@ -1684,6 +1786,16 @@
|
|||||||
"resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz",
|
"resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz",
|
||||||
"integrity": "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ=="
|
"integrity": "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ=="
|
||||||
},
|
},
|
||||||
|
"string_decoder": {
|
||||||
|
"version": "0.10.31",
|
||||||
|
"resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-0.10.31.tgz",
|
||||||
|
"integrity": "sha512-ev2QzSzWPYmy9GuqfIVildA4OdcGLeFZQrq5ys6RtiuF+RQQiZWr8TZNyAcuVXyQRYfEO+MsoB/1BuQVhOJuoQ=="
|
||||||
|
},
|
||||||
|
"string-template": {
|
||||||
|
"version": "0.2.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/string-template/-/string-template-0.2.1.tgz",
|
||||||
|
"integrity": "sha512-Yptehjogou2xm4UJbxJ4CxgZx12HBfeystp0y3x7s4Dj32ltVVG1Gg8YhKjHZkHicuKpZX/ffilA8505VbUbpw=="
|
||||||
|
},
|
||||||
"toidentifier": {
|
"toidentifier": {
|
||||||
"version": "1.0.1",
|
"version": "1.0.1",
|
||||||
"resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz",
|
"resolved": "https://registry.npmjs.org/toidentifier/-/toidentifier-1.0.1.tgz",
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
{
|
{
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
"body": "^5.1.0",
|
||||||
"body-parser": "^1.20.2",
|
"body-parser": "^1.20.2",
|
||||||
"cookie-parser": "^1.4.6",
|
"cookie-parser": "^1.4.6",
|
||||||
"express": "^4.18.2",
|
"express": "^4.18.2",
|
||||||
|
|||||||
@ -1,64 +0,0 @@
|
|||||||
-----BEGIN PGP PUBLIC KEY BLOCK-----
|
|
||||||
|
|
||||||
mQINBFtyz58BEACgKbtY59R0mxs8rWJNAn1BWNXwhuTvELNCV6gZkMRGFP14tMop
|
|
||||||
d9VcUx5UWiulT5wysji63xhkNljmE90jJdlxZwZ+XtnmLzIqp6i29EkAIUt1AoxM
|
|
||||||
w2ipMhfuwE6WA6VYxQihu5z2IDOR1PdDUHF5cX/GZgBon/2A33rG5IKTcaNZzL0O
|
|
||||||
c3rS5VzOzwnp1FHPlR7PY7BRDNe8q1MrQq14tlgMTaYziNg2t2YwjuhNV6G33qGE
|
|
||||||
h390aUnO/eMWIPJzKoi4mE5mhEbh4L/7sFlcRUC6Vs1xa5Ab+L5y2xoDe2grraKD
|
|
||||||
u+XpGJaDPLunlhDSTUsp0HsoLVU4ne/HNbCAm2b25tKFcFTUwDH4Ekge1/bQLCvx
|
|
||||||
kB63MMLa/FgsJ0XAr8zKEQFrc89qJU4JuvadL4hAIqZ1ywFlwTOBaNfZHbW2Pt5f
|
|
||||||
prktIL5d5jIHAdQrFPvLqhhjhM03de6O6dS5lDeP8dTdqzMcqBkwFMmjZMeRAcoJ
|
|
||||||
vs0jJNc0fYwL3h2JSWQnIhsvcSe6gk8GFVRbCCy9UplK1K/5TWw+y3mtfWwUCUSW
|
|
||||||
nBIuUTV+5iG21o3rdZgfEjXJtBAWW/hKoVwBTe5Ir9yIqaomG5ul0Sn2EgOravns
|
|
||||||
AWe2nk4l9cno5CPhGunEtiOD8YQJHskk7/NMtnPegB5j4tprXGS/cK/5hQARAQAB
|
|
||||||
tDxQYWNrYWdlIE1hbmFnZXIgKFBhY2thZ2UgU2lnbmluZyBLZXkpIDxwYWNrYWdl
|
|
||||||
c0BwZ2FkbWluLm9yZz6JAk4EEwEKADgWIQToaX4u73bALTpjMneIgbKoIQl28gUC
|
|
||||||
W3LPnwIbAwULCQgHAgYVCgkICwIEFgIDAQIeAQIXgAAKCRCIgbKoIQl28ukfD/4y
|
|
||||||
3gGysVSJU1964mpi/4NtSTruQ+fx8rN1vY/cctdQVr1ltuJsDRyPgGpXIh9zeK0/
|
|
||||||
bkCreCcuGezm2WOUFR6Kf54zMWWbIrAPpbib7rYi8n50jz7SkCfSyJZgqO2bAPBU
|
|
||||||
MP6Y09mdLaB4jib9Y6nDhFgm2V0rO64yX/bznVjBzNXFjCTgbPoABU0Guy4yHGUF
|
|
||||||
HkQ7Hdg1QLhupMWlphlMJbeSxZJx0T6ApNvr2Qg+uFykSXbXjP2e/tXGb9NeHveT
|
|
||||||
tw/hD2yMPzXJZ4uQbk8mJWDfD87fHY4ZUVqLJtKiS3omePJ5FWMPnLl0PLICkvmh
|
|
||||||
mhoxyKFGjB+62/PpYwclZLR8iB7wn9tIA/q6BqP/BBhgmzpuh7ZOAU/zUZ5D+tHu
|
|
||||||
Q9X0e29iFs4nxewmSM1uCq++l+gGMFRMn0FPH8nyQS/EcB/qXXRc0J3Ja7VVfH5B
|
|
||||||
djmVvqTeJmwY+xGdLZAh/WZ9raWd/qbRGNIcYOyhHnvp719EQxYSiiJbIQcRLDbc
|
|
||||||
IBiUG322ubSiR4+saYfx4ixrHvx8QYbtagien0kkXtoouhhIuLxq/EADRb979ZvQ
|
|
||||||
1hnlUkSGHRN6mDNyLztRqy/iibZrSgX+iKR9lQYI5MnhchihgoN7jyFUiGTV/VSG
|
|
||||||
6oH2KHiTgUQawli9OirnBB1oekf2+QZfZUvnM+b+SokCMwQQAQoAHRYhBODEzuuC
|
|
||||||
ax/aT7Ro4CSt+q9pjxUZBQJbcs/+AAoJECSt+q9pjxUZ4fAP/iQpwcrUZrPp3WI3
|
|
||||||
hi3wHAe+L6E6LiWlhMEMlqfy/2/xOpDEniwy6IEbMV7+H8WSbFYnTBM6EJAWPCMK
|
|
||||||
ZAfkduuB6xqHllEuPuFY9O13+fV5bJMrW/ej3MbX2yz+wfa6LLORRBB/e4R34suz
|
|
||||||
mlSzQzRttPHejmpNicn0S2kA07kqdl/2I3KcsWM1a5GeRZAukDSMLI6orZAGR+r4
|
|
||||||
xKpdEiEMHfoxYYxujmQR9+jqYYPsuViHc3LtIwaKMjTiWBx7wUDF+qIl7bNkT7P9
|
|
||||||
4VudNU9hhzCcYSAt4qiDykTojbSlXSx/ltqoTRhVQlk1kFk2g1O1zHyVpuAkolje
|
|
||||||
5ZmRGa/ZFQWuSOd01n1QqiRLrQDXHKDBh+sUOqaF4Hby/pwZwcsXGLEzSI9uC5He
|
|
||||||
WAn/yomDJInpyYwGmT9FyD9YSd9QjpM1y2/w2+KMj1KRq7GvmZUONYaWp1+A0eCL
|
|
||||||
yhdsZ+bqdS6DVnh0qKT/8ulWUKe+sxiRyAaKBF0QacuuRiRFAfgWbQbsrEQGcDqL
|
|
||||||
q7lmtmOKa0GrBQJAvTMUkxrpMG6SIe+HsJJ3/u+pmTWg77oiQqTByQPPJF0/EgMV
|
|
||||||
g/JzstHdI+FA7Q/4DKJZ5NrPBpUUQC0h+Iex426C7gBtnGXQHYB2Nx6xCtwmpPZv
|
|
||||||
w5THrRb07Y59nZEZLEdcL8bbH/CZuQINBFtyz58BEACt0Hcb8t24ZXsGcOlVnElo
|
|
||||||
cMMo17IdyDvs1j2jJxrNTT6jkxlgwG+ojStsRvllRrG85Wq/FNI6LuBY3Ux+Ymda
|
|
||||||
Nm+p8CJiEDE/Gql4GPSNZ7fCiiopRyyFXg61VM72lWokAT9o9GaSU0/sM5WDeXvM
|
|
||||||
A5QIlAg6+jQ7+R0MMLHeH0GTMnF58KAFmE7T72+H1zPtvH3qeQlOt+PBMJVNhjiO
|
|
||||||
2MwU7NlUIKVz4Vn1JmxA1kCWEIxZyFS82XXKc9BXgPqwnk27lqBxdZzDWFki8SBn
|
|
||||||
DdvwTT/s0chtwekWN4t2RofK0w33TF7+MSQLxpWLr8igrQQvBq6LBfMqm8tQWHL2
|
|
||||||
VDORDg5kKIpZv4pNxxIFmu1VX+W01Oj2GV6AOJgX6jadMiRlHptkz7D/dmnqsCyf
|
|
||||||
DRCmLcwB3y2/behbV1+iW2bViUaFoQIt/XXm2Jo1YtskxZ7LDngDin88pU6jId1N
|
|
||||||
dxjP2rKUjm/dyH5jMn1engv71w16TH+GVr42ho+yOwOTYo8qKDAvQgI8I8e+MlkM
|
|
||||||
LRLpgmFiECmWCovJOQ2JHizqFOmr+eSbeg7o5VpWA+cb0sCdbGUX8Kv6i8zP/ayh
|
|
||||||
VnWg1oU5Q0HTgH9gQ0rzkR+Re2O5xSKuNYnqVOJv4eRzt1NPFgZZOw+PFMJlvEz4
|
|
||||||
ujGwA/OsdJNLQK/HEK75GwARAQABiQI2BBgBCgAgFiEE6Gl+Lu92wC06YzJ3iIGy
|
|
||||||
qCEJdvIFAltyz58CGwwACgkQiIGyqCEJdvKPUg//f2YJGHX9FaNkCpoEk51QW5sv
|
|
||||||
pqITO24Ig65mEVVyx1GPOR9BQnCJoXZrnhEv2d/BpijFE/cR/fHv9bmqc434waeZ
|
|
||||||
PyDyflWTn6+MQYMJJfszKdJFaaY4qPeaCcoh7GC2qw4I5MINfNVTcinOU52XZzt6
|
|
||||||
F+ENm4h8u6vbS+55sKXjRRxNMHbBlNMr0yylukdGrs3PTGEYtXEPBhms4Plz5uHj
|
|
||||||
wkvf+rti84z2qqdX6y0YWxtRBy0cGeo15NYA8kHJLIQeUYbkV20PC7Uooj29DpIs
|
|
||||||
RxDv7F2qZ3KIse8oiJTIubdM+O7zNhzMo+XSUY2HM6aWDLCjV5SuJVJUsPxA3aEK
|
|
||||||
ijn/PjmGkr4DKhiant0nIB/pzyKelNQJHO5fgCFuV72R9GIR7yBRG2AU5OwgHQdy
|
|
||||||
5F0/4/6LtNVWZMKy2lEYuyW8fm0rbC7G5Qbz0KhYZWxp3F20rO6679ViMuNQTwQf
|
|
||||||
HI9akdtFqFEFPuoHyT3VAMxzeUAcMXwBaPcHw1EOlX1kibaM5dbDVOfKEr6JNj4V
|
|
||||||
N00CeuM++rHJSTeM/gcxO+BWpzaNFF9MMrCBL74wiY+WJ7rogRf5Du7H2e0+w/XO
|
|
||||||
puIx3rGSO9VhVrVcoTHimJPuWH7j56wybLS/TCh6HI8soMjYLzxWbqvSyV0b4xfb
|
|
||||||
czb/7fY4Fah80eE59/M=
|
|
||||||
=E6/L
|
|
||||||
-----END PGP PUBLIC KEY BLOCK-----
|
|
||||||
79
server.js
79
server.js
@ -1,42 +1,69 @@
|
|||||||
"use strict";
|
"use strict";
|
||||||
|
|
||||||
const express = require("express");
|
const express = require("express");
|
||||||
//const bodyHand = require("body");
|
const bodyHand = require("body");
|
||||||
const config = require("./config-handler");
|
const config = require("./config-handler");
|
||||||
// const http = require("http");
|
const http = require("http");
|
||||||
const { Database } = require("./database");
|
const { Database } = require("./database");
|
||||||
const { Logger } = require('./logger');
|
|
||||||
const bodyParser = require('body-parser');
|
|
||||||
|
|
||||||
const app = express();
|
const app = express();
|
||||||
// Выставляем адекватное ограничение на тело запроса
|
|
||||||
app.use(bodyParser.json({limit: config().request_size_limit}));
|
|
||||||
|
|
||||||
app.use(
|
global.database = new Database(
|
||||||
(req, res, next) => {
|
config().database.address,
|
||||||
if (req.query.response_format === 'json') {
|
config().database.port,
|
||||||
res.result = function (data, isErr = false, code = 200) {
|
config().database.username,
|
||||||
this.status(code).json(!isErr ? {
|
config().database.password,
|
||||||
response : data
|
config().database.database,
|
||||||
} : {
|
|
||||||
error : data
|
|
||||||
});
|
|
||||||
};
|
|
||||||
}
|
|
||||||
next();
|
|
||||||
}
|
|
||||||
);
|
);
|
||||||
|
|
||||||
app.use(async (req, res, next) => {
|
http.ServerResponse.prototype.errorModeOn = function () {
|
||||||
req.logger = new Logger();
|
this.isError = true;
|
||||||
req.logger.log(
|
};
|
||||||
new Date(),
|
|
||||||
req.ip,
|
http.ServerResponse.prototype.bindNext = function (next) {
|
||||||
`Пользователь обратился по пути: ${req.originalUrl} (HTTP ${req.httpVersion}; ${req.method})`
|
this.next = next;
|
||||||
);
|
};
|
||||||
|
|
||||||
|
http.ServerResponse.prototype.sendModed = function (sendData) {
|
||||||
|
// Модифицируем res.send
|
||||||
|
if (sendData !== undefined && config().logger_mode) {
|
||||||
|
this.responseData = sendData;
|
||||||
|
require("./logger")(this.req, this, this.next);
|
||||||
|
}
|
||||||
|
this.send(sendData);
|
||||||
|
};
|
||||||
|
|
||||||
|
app.use((req, res, next) => {
|
||||||
|
res.bindNext(next);
|
||||||
next();
|
next();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
app.use((req, res, next) => {
|
||||||
|
// Для добавления оригинального тела запроса
|
||||||
|
const body = bodyHand(
|
||||||
|
req,
|
||||||
|
res,
|
||||||
|
{
|
||||||
|
limit: 9999999999,
|
||||||
|
cache: false,
|
||||||
|
encoding: "base64",
|
||||||
|
},
|
||||||
|
(err, body) => {
|
||||||
|
if (!err) {
|
||||||
|
req.byteBody = Buffer.from(body, "base64");
|
||||||
|
|
||||||
|
// Запись в req.json при json
|
||||||
|
if (!!req.headers && req.headers["content-type"]?.includes("json")) {
|
||||||
|
try {
|
||||||
|
req.json = JSON.parse(req.byteBody.toString("utf8"));
|
||||||
|
} catch (_e) {}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
next();
|
||||||
|
},
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
app.use("/", require("./page-view"));
|
app.use("/", require("./page-view"));
|
||||||
app.use("/api", require("./api"));
|
app.use("/api", require("./api"));
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user