robogo
v0.6.11
Published
a backend multitool for projects using MongoDB, Mongoose and Express
Downloads
8
Maintainers
Readme
robogo
Robogo is a backend multitool for projects using MongoDB, Mongoose and Express. Its aim is to reduce the amount of time needed to start, extend and maintain a project. Robogo started out as a CRUD operation helper, but soon evolved into a much more complex system with a lots of features on top of being a CRUD engine.
It is recommended to use this package's frontend helper robolt to make things simpler on the frontend.
Table of contents
Disclaimer
We take no responsibility for any demage done by this package.
If you find anything that isn't working or not up to the documentation, please open issue or a pull request over on github.
Thank You in advance!
Getting started
The documentation will refer back to this section, so don't worry if you don't understand something now.
A very simple example:
const Robogo = require('robogo') // import the package
const robogo = new Robogo({
SchemaDir: path.resolve(__dirname, './schemas')
}) // create the instance
// here should be your auth middleware
// something like: Router.use(someGenericAuthMiddlware)
Router.use('/api', robogo.GenerateRoutes()) // register as a route
The constructor uses the following parameters: | Parameter | Type | Description | Default | |:-|:-:|:-:|:-:| | SchemaDir | String | Absolute path to a folder containing files that are exporting the models that should be handled by robogo. | | | ServiceDir | String | Absolute path to the folder that is containing the service files. | null | | FileDir | String | Absolute path to the folder in which uploaded files should be stored. | null | | ServeStaticPath | String | Relative path through which files in the FileDir will be accessible. | '/static' | | MaxFileCacheAge | Number | The time in milliseconds until if the same file is requested another time, it can be served from the cache memory. | 5000 | | MaxImageSize | Number | Uploaded images higher or wider than this number will be resized to this size.* | 800 | | CreateThumbnail | Boolean | Indicates whether robogo should create a small sized version of the images that are uploaded or not. | false | | MaxThumbnailSize | Number | If CreateThumbnail is true, it behaves the same way as MaxImageSize but for thumbnail images. | 200 | | MongooseConnection | Object | Only needed if the mongoose connection was created using mongoose.connect(). | require('mongoose') | | CheckAccess | Boolean | Indicates whether robogo should use its access features. Disabling it will speed operations up when handling huge documents. | true | | ShowLogs | Boolean | Indicates whether robogo should log basic information to the console. | true | | ShowWarnings | Boolean | Indicates whether robogo should log warning messages to the console. | true | | ShowErrors | Boolean | Indicates whether robogo should log error messages to the console. | true |
* Note: Even if an image is already smaller then the size specified it will be compressed to take up less space. If null is given as value no resizing or compressing will be done.
Schemas
Robogo is a solid base for you to build upon automated processes. For this you can provide some additional information in your schemas, that you can use later.
The documentation will refer back to this section, so don't worry if you don't understand something now.
| Field | Description | Default | |:-|:-:|:-:| | name | Can be used to display as an input label or table column name. e.g.: {type String, name: “Username”} | | | description | Can be used to display as a hover tooltip text. e.g.: {type String, description: “Unique identifier of the user”} | | | minWriteAccess | A positive number. If given, one needs an accesslevel higher or equal to create, update or delete this field | 0 | | minReadAccess | A positive number. If given, one needs an accesslevel higher or equal to read this field | 0 | | hidden | Fields marked as hidden will not be included in the result of the '/fields/:model' route | false | | marked | Simply marks this field, that you can interpret later like however you want it | false | | props | Can be anything json serializable that you later want to use for this field | {} |
You can add some properties to the model/schema itself:
| Field | Description | Default | |:-|:-:|:-:| | name | The user readable name of the model, e.g.: if you intend to list out the available models | | | description | A description of what the purpose of the model is | | | accesslevel | A positive number. If given, one needs an accesslevel higher or equal to see the model, when queried using this route. | 0 | | props | Can be anything json serializable that you later want to use for this model | {} |
An example schema can look like this:
// This is the schemas/user.js file
const mongoose = require("mongoose")
const autopopulate = require("mongoose-autopopulate") // Not required, but suggested to be used with file handling (https://www.npmjs.com/package/mongoose-autopopulate)
const UserSchema = new mongoose.Schema({
username: {
type: String,
required: true,
name: 'Username',
description: "Unique identifier of the user",
minWriteAccess: 100, // One has to have an accesslevel of 100 or higher to create this field
minReadAccess: 0, // But don't need it to read it
marked: true
},
avatar: {
type: ObjectId,
ref: "RoboFile", // File refrences will be stored in this special schema
autopopulate: true, // Not required, but suggested to be used for file fields
name: "Avatar"
},
friends: {
type: [new mongoose.Schema({
name: {type: String, name: "A friends name"}
})],
name: "List of the users friends",
hidden: true
}
}, {
selectPopulatedPaths: false, // We usually need this if using mongoose-autopopulate otherwise fields will always be present when queried regardless of the projection
name: 'User',
description: 'Holds the registered users',
accesslevel: 100,
})
UserSchema.plugin(autopopulate) // Not required, but suggested to be used with file handling
module.exports = mongoose.model('User', UserSchema) // Export the model so that Robogo can import it later
Field access
Most of the time we want to make differences between users in the sense of who can see or modify the data in the database. Robogo provides an easy to use system that makes it possible for us to manage accesses on every field of every document.
For this to work an express.js or robogo middleware has to add an access level number to the req object (as req.accesslevel) of every request. If this is not present the accesslevel of the request will be set to 0 by default. We must also include some special attributes for the fields of our schemas, as described in the Schemas chapter.
Read routes will scan trough the results of the database query and remove every field that has a higher minReadAccess than the provided accesslevel in the req object. So if a field requires a minReadAccess of 100 then a user with an accesslevel of 50 will get the field removed from the results.
In the case of Create and Update routes the minWriteAccess will matter mostly. Fields that have a higher minWriteAccess than the provided accesslevel will be removed before trying to save them in the database. This will cause a mongoose error, when a required field is removed, so only those will be able to create documents who have a high enough accesslevel to modify every required field of a model. Create routes also use minReadAcces as they send back the result of the operation to the client as response.
If someone is trying to delete a document with a field with a greater minWriteAccess than the user's accesslevel using the Delete routes, the request will fail and the 'EPERM' message will be sent back.
Field accesses will also be taken in count, when the '/schema/:model' or the '/fields/:model' Special routes are used. If a field has a greater minReadAccess than the the provided accesslevel, then it will be removed from the response.
Requirements and disabling
Disabling access checking can make requests a bit faster (~150ms when reading 14.000 bigger documents). This can be done globaly in the constructor, but you can also disable (or enable) access checking on a per request basis, by appending a 'checkAccess' property in an express.js or robogo middleware to the req object (like req.checkAccess) and setting it to false (or true).
Robogo tries to optimize its requests, so access checking will only take place when at least one of the following requirements is true for a model:
- has at least one field with a minReadAccess (in case of reading) or minWriteAccess (in case of writing) attribute higher than the accesslevel of the request (req.accesslevel)
- has at least one field that uses the mongoose-autopopulate package and has a reference to a model that fulfills the first point.
Working with files
Robogo can help greatly with file handling. Files sent to its '/fileupload' path will be saved automatically into the folder given to the constructor as the 'FileDir' parameter. Images can be compressed and resized with no hassle, it can even create thumbnail images if needed. These functionalities can be configured in the constructor of robogo. You can get more information on them in the Getting started chapter. The Routes - File section describes the routes that can be used to create new or delete and access the uploaded files.
Robogo creates a special RoboFile model to store information about the files it handles. This special model can not be handled by robogos default routes. Every time a file is uploaded an instance of this model is saved into the database containing the properties of the file. You can reference this document in your documents like in the example of the Schemas chapter.
The RoboFile model has the following schema:
{
name: { type: String, name: "File name", description: "Name of the saved file", required: true, marked: true },
path: { type: String, name: "File path", description: "Path of the saved file", required: true },
size: { type: Number, name: "File size", description: "Sized of the saved file", required: true },
extension: { type: String, name: "File extension", description: "Extension of the saved file", required: true },
isImage: { type: Boolean, name: "Is image?", description: "Indicates whether the saved file is an image or not", default: false },
thumbnailPath: { type: String, name: "Thumbnail path", description: "Path of the saved thumbnail", default: null },
uploadDate: { type: Date, name: "Upload date", description: "The date when the file was uploaded", default: () => new Date() }
}
Services
Services are just like normal express.js routes that are registered automatically by and can be reached through robogo. Every service's functions can be reached with both GET and POST methods, depending on which robogo route was used when calling it.
Services are created by creating separate .js files that are containing one or more service functions. These files should export an object containing the service functions of the service. Service files should then be put in a single folder and this folder should be registered in robogo by giving the path of it to the constructor as the 'ServiceDir' parameter.
Service functions are identified and called by providing their service name (name of the .js file they are in) and their function name. All service functions must return a Promise whose resolved value will be sent back as a response to the client. Rejecting the Promise will send the rejected error back to the client, with a status code of 500. Every service's 'this' context is the robogo instance it was registered in. Service functions can use three parameters, that are in order:
- req: Request object (from Express.js)
- res: Response object (from Express.js)
- data: req.body or req.query depending on the HTTP method used - for easy access.
Here is an example service file:
// services/user.js file
const Services = {
// service function created using async/await
clearFriends: async (req, res, data) => {
let userId = data.id
try {
deleteFriendsOfUser(userId)
return 'Success'
} catch(err) {
throw 'Failed'
}
},
// service function created using Promise
removeAvatar: (req, res, data) => {
return new Promise((resolve, reject) => {
let userId = data.id
deleteAvatarOfUser(userId)
.then( () => resolve('Success') )
.catch( () => reject('Failed')
})
},
}
module.exports = Services
Routes
In this section you can find the description of the endpoints that are created by robogo. All of the routes are prefixed with the path that was used, when the routes were registered in Express using the GenerateRoutes method. So in this example '/api'.
It is recommended to use this package's frontend helper robolt, that will hide the complexity of the routes.
Create routes
/create/:model
Creates a new document.
- Method: POST
- Returns: Object (MongoDB document)
// an example using the axios library
axios.post('/api/create/User', UserData)
Params:
An object that matches the given model's schema. The whole req.body should be the object.
Read routes
/read/:model
Returns documents for the given model.
- Method: GET
- Returns: Array<Object>
// an example using the axios library
axios.get('/api/read/User', {
params: {
filter: {friends: 'Chandler'},
projection: ['username', 'friends'],
sort: {username: 1},
skip: 10,
limit: 5
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | filter | Object | Mongodb query | {friends: 'Chandler'} | | projection | Array<String> | Fields to include in results. Uses MongoDB projection. | ['username', 'friends'] | | sort | Object | Mongodb sort | {age : 1} | | skip | Number | The number of documents to skip in the results set. | 10 | | limit | Number | The number of documents to include in the results set. | 5 |
/get/:model/:id
Returns one document for the given model that matches the given id.
- Method: GET
- Returns: Object
// an example using the axios library
axios.get('/api/get/User/507f191e810c19729de860ea', {
params: {
projection: ['username', 'friends']
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | projection | Array<String> | Fields to include in projection. | ['username', 'friends'] |
/search/:model
Returns documents for the given model that are matching the given search term. This route uses the Fuse.js library in the background. Searching in huge amount of keys and data can be slow and searching in date fields is not supported.
- Method: GET
- Returns: Array<Object>
// an example using the axios library
axios.get('/api/search/User', {
params: {
filter: {friends: 'Chandler'},
projection: ['username', 'friends'],
threshold: 0.4,
keys: ['username'],
// depth: 2,
term: 'search term',
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | filter | Object | Mongodb query | {friends: 'Chandler'} | | projection | Array<String> | Fields to include in results. Uses MongoDB projection. | ['username', 'friends'] | | threshold | Number | Fuse.js threshold, defaults to 0.4 | 0.6 | | keys | Array<String> | Keys of the document that are searched in. If no keys are provided keys will be automatically picked from the schema | ['username'] | | depth | Number | If no keys are provided, we can limit the depth of the keys to be picked from the schema, defaults to Infinity | 2 | | term | String | Search term that is searched for | 'search term' |
Update routes
/update/:model
Updates a document matched by its _id field.
- Method: PATCH
- Returns: WriteResults
// an example using the axios library
axios.patch('/api/update/User', UpdatedUser)
Params:
The whole body should be an object with an _id field containing the ObjectId of the document we want to update and the fields we want to change with their new values.
Delete routes
/delete/:model/:id
Deletes the document of the given model matched by the given id.
- Method: DELETE
- Returns: WriteResults
// an example using the axios library
axios.delete('/api/delete/User/507f191e810c19729de860ea')
Service routes
There are two types of services: getters and runners. The difference between the two is just the HTTP-method they are using. Runners use POST so you can send data more easily and not get the results cached. Getters use GET so you can get the results cached if needed.
/runner/:service/:function
Runs a function in services.
- Method: POST
- Returns: Any
// an example using the axios library
axios.post('/api/runner/user/clearFriends')
/getter/:service/:function
Runs a function in services.
- Method: GET
- Returns: Any
// an example using the axios library
axios.get('/api/getter/user/clearFriends')
File routes
The following routes are only available, if the 'FileDir' parameter was provided in the constructor.
/fileupload
Uploads a given file, and generates a unique name for it. We must send the file as multipart/form-data. If the file is an image and the 'CreateThumbnail' option was set to true in the constructor it will generate a thumbnail for it. Thumbnail images will have names like 'fileUniqueName_thumbnail.jpg'.
- Method: POST
- Returns: Object (RoboFile document)
// an example using the axios library
let formData = new FormData()
formData.append('file', UserAvatar) // the field name must be 'file'
axios.post(`/api/fileupload`, formData, {
headers: {'Content-Type': 'multipart/form-data'}
})
/filedelete/:id
Deletes the RoboFile document with the given id and the corresponding file from the FileDir.
- Method: DELETE
- Returns: empty response
axios.delete(`/api/filedelete/:id`)
Special routes
/model
Returns the registered models and their properties from the schemas section.
- Method: GET
- Returns: Array<Object>
// an example using the axios library
axios.get('/api/model')
/model/:model
Returns the properties for the given model registered in the schemas section.
- Method: GET
- Returns: Object
// an example using the axios library
axios.get('/api/model/User')
/schema/:model
Returns a tree-like structure of the fields and their properties for the given model. This is great for creating automated interfaces.
- Method: GET
- Returns: Object
// an example using the axios library
axios.get('/api/schema/User')
/fields/:model
Returns a tree-like structure of the fields and their properties for the given model. Similar to the '/schema/:model' route, but only returns a reduced set of properties and leaves out fields that were marked as "hidden" in the schema. The returned properties are: name, key, description, type, isArray, marked.
- Methods: GET
- Returns: Array<Object>
// an example using the axios library
axios.get('/api/fields/User', {
params: {
depth: 0
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | depth | Number | Limits the depth of the fields returned. Starts from 0. | 0 |
/count/:model
Returns the count of documents for the given model that are matched by the given filter.
- Method: GET
- Returns: Number
// an example using the axios library
axios.get('/api/count/User', {
params: {
filter: {friends: 'Chandler'},
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | filter | Object | Mongodb query | {friends: 'Chandler'} |
/searchkeys/:model
Returns the keys of a model's schema that are compatible with Fuse.js and as such can be passed to the '/:model/search' route as keys.
- Method: GET
- Returns: Array<String>
// an example using the axios library
axios.get('/api/searchkeys/User', {
params: {
depth: 2,
}
})
Params:
| key | type | description | example | |:-|:-:|:-:|:-:| | depth | Number | Limits the depth of the keys to be picked from the schema, defaults to Infinity | 2 |
Adding custom middlewares
If needed, we can extend the functionalities of the default routes of robogo with middlewares. Middleware functions have to return a Promise. This Promise should be resolved when the middleware is done with its work and the route should continue running. Rejecting the Promise will stop the route from continuing and (if the 'ShowLogs' parameter of the constructor was set to true) the value given to the reject function will be written to the console. In this case do not forget to send a response from inside the middleware. Every middleware's 'this' context is the robogo instance it was registered in.
There are four categories of routes that can have middlewares:
- C(reat)
- R(ead)
- U(pdate)
- D(elete)
- S(pecial)
Each route-category can have a single 'before' and an 'after' middleware.
'before' middlewares
'before' middlewares will run before the database operation, so they can be used for example to deny permission to a route based on some logic using the Request object, or they can modify the payload of the request, before it reaches the database part of the route.
Parameters: 'before' middlewares receive two parameters. These are in order:
- req: Request object (from Express.js)
- res: Response object (from Express.js)
'after' middlewares
'after' middlewares will run after the database operation, so they can be used for example to modify the result of the database operation before sending back a response.
Parameters: 'after' middlewares receive three parameters. These are in order:
- req: Request object (from Express.js)
- res: Response object (from Express.js)
- result: Any (the result of the database operation)
Registering middlewares
Middlewares can be registered by calling the 'addMiddleware' method of the robogo instance. The method has four parameters, these are in order:
- modelname: String, the name of the model that the middleware should be bound to.
- operation: String, the initial of one of the four route-categories ('C', 'R', 'U', 'D').
- timing: String, one of the timing options ('before', 'after').
- function: Function, the middleware function returning a Promise.
The 'addMiddleware' method can throw the following exceptions:
- 'Middleware: No model found with name: ${modelname}'
- 'Middleware: Operation should be one of: [ 'C', 'R', 'U', 'D' ]'
- 'Middleware: Timing should be one of: [ 'after', 'before' ]'
Here are some example middlewares:
const robogo = new Robogo({
SchemaDir: path.resolve(__dirname, './schemas')
}) // create the robogo instance
try {
// middleware created using async/await
robogo.addMiddleware('User', 'C', 'before', async (req, res) => {
if(await isNotAdmin(req.query.uId)) {
res.status(401).send('YOU SHALL NOT PASS!') // we have to send a response
throw `${req.query.uId} tried to access restricted information!` // this message will be logged to the console
}
})
// middleware created using Promise
robogo.addMiddleware('User', 'C', 'before', (req, res) => {
return new Promise((resolve, reject) => {
isNotAdmin(req.query.uId).then(isNotAdmin => {
if(!isNotAdmin) resolve()
else {
res.status(401).send('YOU SHALL NOT PASS!') // we have to send a response
reject(`${req.query.uId} tried to access restricted information!`) // this message will be logged to
}
})
})
})
} catch(e) {
console.warn("Setting up middlewares not succeeded. Error was: ", e);
}
Contributing
Every contribution is more then welcomed. If you have an idea or made some changes to the code, please open an issue or pull request at the package's github page.
Authors
- Horváth Bálint
- Zákány Balázs