RageStudio/linebridge
1
0
Fork 0
mirror of https://github.com/ragestudio/linebridge.git synced 2025-06-09 10:34:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

added utils

Browse Source
This commit is contained in:
srgooglo 2022-06-22 17:36:19 +02:00
parent 3aa45b3338
commit 4d7fbfbaee
2 changed files with 61 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/utils/index.js Normal file
View File

@ -0,0 +1,3 @@
module.exports = {
schematized: require("./schematized"),
}

58
src/utils/schematized/index.js Normal file
View File

@ -0,0 +1,58 @@
module.exports = (schema = {}, fn) => {
return async (req, res, next) => {
if (typeof req.body === "undefined") {
req.body = {}
}
if (typeof req.query === "undefined") {
req.query = {}
}
if (schema.required) {
if (Array.isArray(schema.required)) {
const missingKeys = []
const requiredKeys = Array.isArray(schema.required) ? schema.required : []
for await (let key of requiredKeys) {
if (typeof req.body[key] === "undefined" && typeof req.query[key] === "undefined") {
req.selection[key] = req.body[key]
continue
}
}
if (missingKeys.length > 0) {
return res.status(400).json({ error: `Missing ${missingKeys}` })
}
} else {
console.warn("[INVALID SCHEMA] schema.required is defined but is not an array")
}
}
if (schema.select) {
if (Array.isArray(schema.select)) {
if (typeof req.selection !== "object") {
req.selection = {}
}
// assign objects along request body and query.
for await (let key of schema.select) {
if (req.body && typeof req.body[key] !== "undefined") {
req.selection[key] = req.body[key]
continue
}
if (req.query && typeof req.query[key] !== "undefined") {
req.selection[key] = req.query[key]
continue
}
}
} else {
console.warn("[INVALID SCHEMA] schema.select is defined but is not an array")
}
}
if (typeof fn === "function") {
return await fn(req, res, next)
}
}
}