Resume
/
sub-manager-backend
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

protect endpoint

This commit is contained in:
andrzej 2024-05-27 15:20:24 +02:00
parent 68f77317a3
commit c749adff34
2 changed files with 35 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
logger.mjs
View File

@ -1,6 +1,6 @@
import pino from 'pino'
import path from 'path'
import { fileURLToPath } from 'url';
import pino from "pino";
import path from "path";
import { fileURLToPath } from "url";
const __filename = fileURLToPath(import.meta.url);
const __dirname = path.dirname(__filename);
@ -15,14 +15,15 @@ const __dirname = path.dirname(__filename);
// }]
// })
export default pino(
{
level: 'fatal',
formatters: {
level: (label) => {
return { level: label.toUpperCase() };
},
{
level: "info",
formatters: {
level: (label) => {
return { level: label.toUpperCase() };
},
timestamp: pino.stdTimeFunctions.isoTime,
},
//pino.destination(`${__dirname}/app.log`)
);
timestamp: pino.stdTimeFunctions.isoTime,
},
//pino.destination(`${__dirname}/app.log`)
);

51
objects/Endpoints.mjs
View File

@ -54,35 +54,28 @@ export const postEndpoints = (db, data) => {
};
const protectedEndpoint = (router, Entity, path, method, db, data) => {
router.post(`/${Entity.name.toLowerCase()}/${path}`, async (req, res) => {
passport.authenticate(
"jwt",
{ session: false },
async (err, user, info) => {
if (err) {
logger.error(err);
}
if (info !== undefined) {
logger.info(info.message);
res.status(401).send(info.message);
}
try {
logger.trace({ data: req.body }, "POST request received");
const entity = new Entity(req.body);
await entity[method](db, data);
res.sendStatus(200);
data.init();
return;
} catch (error) {
logger.error(error);
if (error instanceof TypeError) {
res.sendStatus(400);
return;
}
res.sendStatus(500);
router.post(
`/${Entity.name.toLowerCase()}/${path}`,
passport.authenticate("jwt", { session: false }, (_, res) => {
res.json({ message: "protected endpoint" });
}),
async (req, res) => {
try {
logger.trace({ data: req.body }, "POST request received");
const entity = new Entity(req.body);
await entity[method](db, data);
res.sendStatus(200);
data.init();
return;
} catch (error) {
logger.error(error);
if (error instanceof TypeError) {
res.sendStatus(400);
return;
}
},
);
});
res.sendStatus(500);
return;
}
},
);
};