slate/node_common/middleware.js

61 lines
1.7 KiB
JavaScript
Raw Normal View History

import * as Environment from "~/node_common/environment";
import * as Credentials from "~/common/credentials";
import * as Strings from "~/common/strings";
import * as Data from "~/node_common/data";
import * as Powergate from "~/node_common/powergate";
import * as Logging from "~/common/logging";
import JWT from "jsonwebtoken";
export const init = (middleware) => {
return (req, res) =>
new Promise((resolve, reject) => {
middleware(req, res, (result) => {
if (result instanceof Error) {
return reject(result);
}
return resolve(result);
});
});
};
2020-02-19 09:30:47 +03:00
export const CORS = async (req, res, next) => {
2020-06-19 06:57:57 +03:00
res.header("Access-Control-Allow-Origin", "*");
res.header("Access-Control-Allow-Methods", "GET, POST, PATCH, PUT, DELETE, OPTIONS");
res.header("Access-Control-Allow-Headers", "Origin, Accept, Content-Type, Authorization");
2020-02-19 09:30:47 +03:00
2020-06-19 06:57:57 +03:00
if (req.method === "OPTIONS") {
2020-02-19 09:30:47 +03:00
return res.status(200).end();
}
next();
};
export const RequireCookieAuthentication = async (req, res, next) => {
if (Strings.isEmpty(req.headers.cookie)) {
return res.status(403).json({ decorator: "SERVER_AUTH_USER_NO_TOKEN", error: true });
}
const token = req.headers.cookie.replace(
/(?:(?:^|.*;\s*)WEB_SERVICE_SESSION_KEY\s*\=\s*([^;]*).*$)|^.*$/,
"$1"
);
let user;
try {
const decoded = JWT.verify(token, Environment.JWT_SECRET);
user = await Data.getUserById({
id: decoded.id,
});
if (!user || user.error) {
return res.status(403).json({ decorator: "SERVER_AUTH_USER_NOT_FOUND", error: true });
}
} catch (err) {
Logging.error(err);
return res.status(403).json({ decorator: "SERVER_AUTH_USER_ERROR", error: true });
}
next();
};